Get webhook event & monitor payload details

curl https://xquik.com/api/v1/events/9001 \
  -H "x-api-key: xq_YOUR_KEY_HERE" \
  | jq '{
    event_id: .id,
    event_type: .type,
    monitor_type: .monitorType,
    monitor_id: .monitorId,
    keyword_monitor_id: (.keywordMonitorId // null),
    username: (.username // null),
    query: (.query // null),
    occurred_at: .occurredAt,
    x_event_id: (.xEventId // null),
    tweet_id: (.xEventId // .data.id // null),
    tweet_text: (.data.text // null),
    author_username: (.data.author.userName // null),
    event_detail_endpoint: ("/api/v1/events/" + .id),
    delivery_join_key: .id
  }'

const response = await fetch("https://xquik.com/api/v1/events/9001", {
  headers: { "x-api-key": "xq_YOUR_KEY_HERE" },
});
const event = await response.json();
const eventRow = {
  event_id: event.id,
  event_type: event.type,
  monitor_type: event.monitorType,
  monitor_id: event.monitorId,
  keyword_monitor_id: event.keywordMonitorId ?? null,
  username: event.username ?? null,
  query: event.query ?? null,
  occurred_at: event.occurredAt,
  x_event_id: event.xEventId ?? null,
  tweet_id: event.xEventId ?? event.data?.id ?? null,
  tweet_text: event.data?.text ?? null,
  author_username: event.data?.author?.userName ?? null,
  event_detail_endpoint: `/api/v1/events/${event.id}`,
  delivery_join_key: event.id,
};

process.stdout.write(`${JSON.stringify(eventRow)}\n`);

import json
import requests

response = requests.get(
    "https://xquik.com/api/v1/events/9001",
    headers={"x-api-key": "xq_YOUR_KEY_HERE"},
)
event = response.json()
tweet = event.get("data") if isinstance(event.get("data"), dict) else {}
author = tweet.get("author") if isinstance(tweet.get("author"), dict) else {}
event_row = {
    "event_id": event["id"],
    "event_type": event["type"],
    "monitor_type": event["monitorType"],
    "monitor_id": event["monitorId"],
    "keyword_monitor_id": event.get("keywordMonitorId"),
    "username": event.get("username"),
    "query": event.get("query"),
    "occurred_at": event["occurredAt"],
    "x_event_id": event.get("xEventId"),
    "tweet_id": event.get("xEventId") or tweet.get("id"),
    "tweet_text": tweet.get("text"),
    "author_username": author.get("userName"),
    "event_detail_endpoint": f"/api/v1/events/{event['id']}",
    "delivery_join_key": event["id"],
}
print(json.dumps(event_row))

package main

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

type EventAuthor struct {
  UserName *string `json:"userName"`
}

type EventPayload struct {
  ID     *string      `json:"id"`
  Text   *string      `json:"text"`
  Author *EventAuthor `json:"author"`
}

type Event struct {
  ID               string       `json:"id"`
  Type             string       `json:"type"`
  MonitorType      string       `json:"monitorType"`
  MonitorID        string       `json:"monitorId"`
  KeywordMonitorID *string      `json:"keywordMonitorId"`
  Username         *string      `json:"username"`
  Query            *string      `json:"query"`
  OccurredAt       string       `json:"occurredAt"`
  Data             EventPayload `json:"data"`
  XEventID         *string      `json:"xEventId"`
}

type EventRow struct {
  DeliveryJoinKey      string  `json:"delivery_join_key"`
  EventDetailEndpoint  string  `json:"event_detail_endpoint"`
  EventID              string  `json:"event_id"`
  EventType            string  `json:"event_type"`
  MonitorType          string  `json:"monitor_type"`
  MonitorID            string  `json:"monitor_id"`
  KeywordMonitorID     *string `json:"keyword_monitor_id"`
  Username             *string `json:"username"`
  Query                *string `json:"query"`
  OccurredAt           string  `json:"occurred_at"`
  XEventID             *string `json:"x_event_id"`
  TweetID              *string `json:"tweet_id"`
  TweetText            *string `json:"tweet_text"`
  AuthorUsername       *string `json:"author_username"`
}

func main() {
  req, err := http.NewRequest("GET", "https://xquik.com/api/v1/events/9001", nil)
  if err != nil {
    log.Fatal(err)
  }
  req.Header.Set("x-api-key", "xq_YOUR_KEY_HERE")

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

  var event Event
  if err := json.NewDecoder(resp.Body).Decode(&event); err != nil {
    log.Fatal(err)
  }

  tweetID := event.XEventID
  if tweetID == nil {
    tweetID = event.Data.ID
  }

  var authorUsername *string
  if event.Data.Author != nil {
    authorUsername = event.Data.Author.UserName
  }

  row := EventRow{
    DeliveryJoinKey:     event.ID,
    EventDetailEndpoint: "/api/v1/events/" + event.ID,
    EventID:             event.ID,
    EventType:           event.Type,
    MonitorType:         event.MonitorType,
    MonitorID:           event.MonitorID,
    KeywordMonitorID:    event.KeywordMonitorID,
    Username:            event.Username,
    Query:               event.Query,
    OccurredAt:          event.OccurredAt,
    XEventID:            event.XEventID,
    TweetID:             tweetID,
    TweetText:           event.Data.Text,
    AuthorUsername:      authorUsername,
  }
  if err := json.NewEncoder(os.Stdout).Encode(row); err != nil {
    log.Fatal(err)
  }
}