import { subscribeToActivity } from '@mosaia/mosaia-node-sdk';
const lastSeenId = localStorage.getItem('activity:lastId') ?? undefined;
const sub = subscribeToActivity({
onStart: (info) => console.log('connected', info.collections),
onUpdate: (activity) => {
localStorage.setItem('activity:lastId', activity.id);
reduceActivity(activity);
},
onError: (err) => console.error(err),
}, { since: lastSeenId });
// Later
sub.close();
Subscribe to the unified activity feed for the authenticated requester.
Opens a single SSE connection to the relay's
/v1/activityendpoint. The relay scopes events torequestOrgif present, otherwiserequestUser.