Ejemplos de Suscripciones

Usa suscripciones GraphQL para actualizaciones en tiempo real de usuarios y grupos.

Para el modelo de eventos y esquema de carga útil, consulta:

• Conectar a Suscripciones de AppSync
• Formato de Evento de Suscripción
• Esquema de Evento de Suscripción
• Uso de Suscripciones
• Seguimiento del Ciclo de Vida de Documentos y Destinatarios con Suscripciones

Suscripción del Feed de Usuario

subscription SubscribeUserFeed {
  subscribeUserFeed {
    userId
    data
  }
}

Suscripción del Feed de Grupo

subscription SubscribeGroupFeed($groupId: String!) {
  subscribeGroupFeed(groupId: $groupId) {
    groupId
    data
  }
}

Ejemplo en JavaScript

import { createClient } from 'graphql-ws';

import WebSocket from 'ws';

const client = createClient({
  url: 'wss://graphql.uk.legalesign.com/graphql',
  webSocketImpl: WebSocket,
  connectionParams: {
    Authorization: `Bearer ${accessToken}`,
  },
});

const parseEnvelope = (payload) => {
  const raw = payload?.data;
  if (!raw) return null;
  return typeof raw === 'string' ? JSON.parse(raw) : raw;
};

client.subscribe(
  {
    query: `
      subscription SubscribeUserFeed {
        subscribeUserFeed {
          userId
          data
        }
      }
    `,
  },
  {
    next: ({ data }) => {
      const wrapper = data?.subscribeUserFeed;
      const event = parseEnvelope(wrapper);

      console.log('user event', {
        deliveryUserId: wrapper?.userId,
        eventId: event?.eventId,
        category: event?.category,
        event: event?.event,
        payload: event?.data,
      });
    },
    error: console.error,
    complete: () => console.log('user feed closed'),
  }
);

client.subscribe(
  {
    query: `
      subscription SubscribeGroupFeed($groupId: String!) {
        subscribeGroupFeed(groupId: $groupId) {
          groupId
          data
        }
      }
    `,
    variables: { groupId: 'your-group-id' },
  },
  {
    next: ({ data }) => {
      const wrapper = data?.subscribeGroupFeed;
      const event = parseEnvelope(wrapper);

      console.log('group event', {
        deliveryGroupId: wrapper?.groupId,
        eventId: event?.eventId,
        category: event?.category,
        event: event?.event,
        payload: event?.data,
      });
    },
    error: console.error,
    complete: () => console.log('group feed closed'),
  }
);