Twitter account monitor API & real-time webhooks

curl --fail-with-body -X POST https://xquik.com/api/v1/monitors \
  -H "x-api-key: xq_YOUR_KEY_HERE" \
  -H "Content-Type: application/json" \
  -d '{
    "username": "elonmusk",
    "eventTypes": ["tweet.new", "tweet.reply"]
  }' |
  jq -c '{
    monitor_id: .id,
    username: .username,
    x_user_id: .xUserId,
    event_types: .eventTypes,
    is_active: .isActive,
    created_at: .createdAt,
    next_billing_at: .nextBillingAt,
    verify_endpoint: "/api/v1/monitors/\(.id)",
    update_endpoint: "/api/v1/monitors/\(.id)",
    delete_endpoint: "/api/v1/monitors/\(.id)",
    events_endpoint: "/api/v1/events?monitorId=\(.id)",
    event_detail_endpoint_pattern: "/api/v1/events/{event_id}",
    webhooks_endpoint: "/api/v1/webhooks",
    deliveries_endpoint_pattern: "/api/v1/webhooks/{webhook_id}/deliveries"
  }'

const response = await fetch("https://xquik.com/api/v1/monitors", {
  method: "POST",
  headers: {
    "x-api-key": "xq_YOUR_KEY_HERE",
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    username: "elonmusk",
    eventTypes: ["tweet.new", "tweet.reply"],
  }),
});
const monitor = await response.json();
if (!response.ok) {
  throw new Error(monitor.message || "Twitter monitor creation failed.");
}
const monitorState = {
  monitor_id: monitor.id,
  username: monitor.username,
  x_user_id: monitor.xUserId,
  event_types: monitor.eventTypes,
  is_active: monitor.isActive,
  created_at: monitor.createdAt,
  next_billing_at: monitor.nextBillingAt,
  verify_endpoint: `/api/v1/monitors/${monitor.id}`,
  update_endpoint: `/api/v1/monitors/${monitor.id}`,
  delete_endpoint: `/api/v1/monitors/${monitor.id}`,
  events_endpoint: `/api/v1/events?monitorId=${monitor.id}`,
  event_detail_endpoint_pattern: "/api/v1/events/{event_id}",
  webhooks_endpoint: "/api/v1/webhooks",
  deliveries_endpoint_pattern: "/api/v1/webhooks/{webhook_id}/deliveries",
};
process.stdout.write(`${JSON.stringify(monitorState)}\n`);

import json
import requests

response = requests.post(
    "https://xquik.com/api/v1/monitors",
    headers={"x-api-key": "xq_YOUR_KEY_HERE"},
    json={
        "username": "elonmusk",
        "eventTypes": ["tweet.new", "tweet.reply"],
    },
)
monitor = response.json()
if not response.ok:
    raise RuntimeError(monitor.get("message", "Twitter monitor creation failed."))
monitor_state = {
    "monitor_id": monitor["id"],
    "username": monitor["username"],
    "x_user_id": monitor["xUserId"],
    "event_types": monitor["eventTypes"],
    "is_active": monitor["isActive"],
    "created_at": monitor["createdAt"],
    "next_billing_at": monitor["nextBillingAt"],
    "verify_endpoint": f"/api/v1/monitors/{monitor['id']}",
    "update_endpoint": f"/api/v1/monitors/{monitor['id']}",
    "delete_endpoint": f"/api/v1/monitors/{monitor['id']}",
    "events_endpoint": f"/api/v1/events?monitorId={monitor['id']}",
    "event_detail_endpoint_pattern": "/api/v1/events/{event_id}",
    "webhooks_endpoint": "/api/v1/webhooks",
    "deliveries_endpoint_pattern": "/api/v1/webhooks/{webhook_id}/deliveries",
}
print(json.dumps(monitor_state))

package main

import (
    "bytes"
    "encoding/json"
    "io"
    "log"
    "net/http"
    "os"
)

type Monitor struct {
    ID            string   `json:"id"`
    Username      string   `json:"username"`
    XUserID       string   `json:"xUserId"`
    EventTypes    []string `json:"eventTypes"`
    IsActive      bool     `json:"isActive"`
    CreatedAt     string   `json:"createdAt"`
    NextBillingAt string   `json:"nextBillingAt"`
}

type MonitorState struct {
    CreatedAt                  string   `json:"created_at"`
    DeleteEndpoint             string   `json:"delete_endpoint"`
    DeliveriesEndpointPattern  string   `json:"deliveries_endpoint_pattern"`
    EventDetailEndpointPattern string   `json:"event_detail_endpoint_pattern"`
    EventsEndpoint             string   `json:"events_endpoint"`
    EventTypes                 []string `json:"event_types"`
    IsActive                   bool     `json:"is_active"`
    MonitorID                  string   `json:"monitor_id"`
    NextBillingAt              string   `json:"next_billing_at"`
    UpdateEndpoint             string   `json:"update_endpoint"`
    Username                   string   `json:"username"`
    VerifyEndpoint             string   `json:"verify_endpoint"`
    WebhooksEndpoint           string   `json:"webhooks_endpoint"`
    XUserID                    string   `json:"x_user_id"`
}

func main() {
    body, _ := json.Marshal(map[string]interface{}{
        "username":   "elonmusk",
        "eventTypes": []string{"tweet.new", "tweet.reply"},
    })

    req, err := http.NewRequest("POST", "https://xquik.com/api/v1/monitors", bytes.NewReader(body))
    if err != nil {
        log.Fatal(err)
    }
    req.Header.Set("x-api-key", "xq_YOUR_KEY_HERE")
    req.Header.Set("Content-Type", "application/json")

    resp, err := http.DefaultClient.Do(req)
    if err != nil {
        log.Fatal(err)
    }
    defer resp.Body.Close()

    if resp.StatusCode < 200 || resp.StatusCode >= 300 {
        problem, readErr := io.ReadAll(resp.Body)
        if readErr != nil {
            log.Fatal(readErr)
        }
        log.Fatalf("Twitter monitor creation failed with %d: %s", resp.StatusCode, string(problem))
    }

    var monitor Monitor
    if err := json.NewDecoder(resp.Body).Decode(&monitor); err != nil {
        log.Fatal(err)
    }
    state := MonitorState{
        CreatedAt:                  monitor.CreatedAt,
        DeleteEndpoint:             "/api/v1/monitors/" + monitor.ID,
        DeliveriesEndpointPattern:  "/api/v1/webhooks/{webhook_id}/deliveries",
        EventDetailEndpointPattern: "/api/v1/events/{event_id}",
        EventsEndpoint:             "/api/v1/events?monitorId=" + monitor.ID,
        EventTypes:                 monitor.EventTypes,
        IsActive:                   monitor.IsActive,
        MonitorID:                  monitor.ID,
        NextBillingAt:              monitor.NextBillingAt,
        UpdateEndpoint:             "/api/v1/monitors/" + monitor.ID,
        Username:                   monitor.Username,
        VerifyEndpoint:             "/api/v1/monitors/" + monitor.ID,
        WebhooksEndpoint:           "/api/v1/webhooks",
        XUserID:                    monitor.XUserID,
    }
    if err := json.NewEncoder(os.Stdout).Encode(state); err != nil {
        log.Fatal(err)
    }
}