Eventos de X Chat en tiempo real

import { Client } from '@xdevplatform/xdk';

// Creating a subscription requires user-context auth for the monitored user
const client = new Client({ accessToken: 'YOUR_OAUTH2_USER_TOKEN' });
await client.activity.createSubscription({
  event_type: 'chat.received',
  filter: { user_id: 'USER_ID_TO_MONITOR' },
});
// Stream: client.activity.stream() when available in your SDK version

// chat has keys loaded and setIdentity called (see Getting Started)
chat.setCacheKeys(true);
chat.setSigningKeys(participantSigningKeys); // all participants, from the public-key routes

const data = body?.data ?? {};
if (data.event_type === 'chat.received' || data.event_type === 'chat.sent') {
  const p = data.payload ?? {};
  if (p.conversation_key_change_event) {
    // Verify the key change and retain its key in the cache
    chat.decryptEvents([p.conversation_key_change_event]);
  }
  const ev = chat.decryptEvent(p.encoded_event);
  if (ev.type === 'message') {
    console.log(ev.senderId, ev.content.text);
  }
}

// chat has keys loaded and set_identity called (see Getting Started)
chat.set_cache_keys(true);
chat.set_signing_keys(participant_signing_keys); // all participants

if let Some(kc) = key_change.as_deref() {
    // Verify the key change and retain its key in the cache
    let _ = chat.decrypt_events(&[kc], &[]);
}
// Decrypt with the cached conversation key; verify against the stored signing keys
let event = chat.decrypt_event(&encoded_event, &Default::default(), &[])?;

// chat has keys loaded and SetIdentity called (see Getting Started)
chat.SetCacheKeys(true)
_ = chat.SetSigningKeys(participantSigningKeys) // all participants

if keyChange != "" {
    // Verify the key change and retain its key in the cache
    _, _ = chat.DecryptEvents([]string{keyChange}, nil)
}
// Decrypt with the cached conversation key; verify against the stored signing keys
event, err := chat.DecryptEvent(encodedEvent, nil, nil)
if err == nil && event.Type == "Message" {
    fmt.Println(event.AsMessage().Text())
}

// chat has keys loaded and SetIdentity called (see Getting Started)
chat.SetCacheKeys(true);
chat.SetSigningKeys(participantSigningKeys); // all participants

if (!string.IsNullOrEmpty(keyChangeB64))
{
    // Verify the key change and retain its key in the cache
    chat.DecryptEvents(new[] { keyChangeB64 });
}
// Decrypt with the cached conversation key; verify against the stored signing keys
var evt = chat.DecryptEvent(encodedEvent);
if (evt.GetProperty("type").GetString() == "Message")
    Console.WriteLine(evt.GetProperty("content").GetProperty("text").GetString());

// chat has keys loaded and setIdentity called (see Getting Started)
chat.setCacheKeys(true);
chat.setSigningKeys(participantSigningKeys); // all participants

if (keyChangeB64 != null && !keyChangeB64.isEmpty()) {
    // Verify the key change and retain its key in the cache
    chat.decryptEvents(List.of(keyChangeB64), null);
}
// Decrypt with the cached conversation key; verify against the stored signing keys
JsonNode evt = chat.decryptEvent(encodedEvent, (Map<String, byte[]>) null, null);
if ("Message".equals(evt.path("type").asText())) {
    System.out.println(evt.path("content").path("text").asText());
}