commit c5f251d7a3db2da254387bbe75942b1355b3b7b0 · gmstn.systems/lattice

+26
src/lib/utils/prism.ts
···

       1
       1
       +
       // Prism is a jetstream/jetstream-compatible fork for receiving filtered events from the firehose

     

       2
       2
       +
       import { PRISM_URL } from "@/lib/env";

     

       3
       3
       +
       import WebSocket from "ws";

     

       4
       4
       +
       

     

       5
       5
       +
       export const connectToPrism = ({

     

       6
       6
       +
           wantedCollections,

     

       7
       7
       +
           wantedDids,

     

       8
       8
       +
           cursor,

     

       9
       9
       +
       }: {

     

       10
       10
       +
           wantedCollections?: Array<string>;

     

       11
       11
       +
           wantedDids?: Array<string>;

     

       12
       12
       +
           cursor: number;

     

       13
       13
       +
       }) => {

     

       14
       14
       +
           const endpoint = PRISM_URL;

     

       15
       15
       +
           if (wantedCollections)

     

       16
       16
       +
               wantedCollections.forEach((collection) => {

     

       17
       17
       +
                   endpoint.searchParams.append("wantedCollections", collection);

     

       18
       18
       +
               });

     

       19
       19
       +
           if (wantedDids)

     

       20
       20
       +
               wantedDids.forEach((did) => {

     

       21
       21
       +
                   endpoint.searchParams.append("wantedDids", did);

     

       22
       22
       +
               });

     

       23
       23
       +
           if (cursor) endpoint.searchParams.append("cursor", cursor.toString());

     

       24
       24
       +
       

     

       25
       25
       +
           return new WebSocket(endpoint);

     

       26
       26
       +
       };