Gerçek zamanlı Twitter (X) API
Kendi scraper'ın olmadan, trading botları, terminaller ve Agent'lar için

import asyncio, json
import websockets

URL = "wss://api.xanguard.tech/v1/dt/realtime/ws"
API_KEY = "dt_anahtarin"

async def main():
    async with websockets.connect(URL) as ws:
        # op 10 HELLO: heartbeat aralığını taşır (milisaniye)
        hello = json.loads(await ws.recv())
        interval = hello["d"]["heartbeat_interval"] / 1000

        # op 2 LOGIN: anahtarı 15 saniye içinde gönder
        await ws.send(json.dumps({"op": 2, "d": API_KEY}))
        ready = json.loads(await ws.recv())
        if ready["op"] != 4:  # başarısızsa yanıt op 3 DISCONNECT olur
            raise SystemExit(ready["d"].get("reason"))
        print("Bağlandı:", ready["d"]["modules"])

        # aralığa göre heartbeat gönder; 90 saniye heartbeat yoksa bağlantı kesilir
        async def heartbeat():
            while True:
                await asyncio.sleep(interval)
                await ws.send(json.dumps({"op": 1}))
        hb = asyncio.create_task(heartbeat())

        async for raw in ws:
            msg = json.loads(raw)
            if msg["op"] != 0:  # yalnızca op 0 EVENT işlenir
                continue
            ev, d = msg["d"]["event"], msg["d"]["data"]
            if ev == "twitter.post.new":
                print(d["author"]["handle"], d["text"])
            elif ev == "twitter.tweet.deleted":
                print("Tweet silindi:", d["tweet_id"])
            elif ev == "twitter.profile.update":
                print("Profil değişti:", d["field"], d["updated"])

asyncio.run(main())

const WebSocket = require('ws');
const URL = 'wss://api.xanguard.tech/v1/dt/realtime/ws';
const ws = new WebSocket(URL);
let hb;

ws.on('message', (raw) => {
  const msg = JSON.parse(raw.toString());
  switch (msg.op) {
    case 10: // HELLO: LOGIN gönder, sonra aralığa göre heartbeat
      ws.send(JSON.stringify({ op: 2, d: 'dt_anahtarin' }));
      hb = setInterval(
        () => ws.send(JSON.stringify({ op: 1 })),
        msg.d.heartbeat_interval
      );
      break;
    case 4: // READY: kimlik doğrulama başarılı
      console.log('Bağlandı', msg.d.modules);
      break;
    case 3: // DISCONNECT: anahtar geçersiz veya süresi dolmuş, vb.
      console.error('Bağlantı kesildi:', msg.d.reason);
      break;
    case 0: { // EVENT: gerçek zamanlı olay
      const { event, data } = msg.d;
      if (event === 'twitter.post.new') {
        console.log(data.author.handle, data.text);
      } else if (event === 'twitter.following.new') {
        console.log('Yeni follow:', data.handle);
      }
      break;
    }
  }
});

ws.on('close', () => clearInterval(hb));