···

       
12
       
 
       
const server = new LabelerServer({ did: DID, signingKey: SIGNING_KEY });

     

       
13
       
 
       


     

       
14
       
 
       
server.start(PORT, (error, address) => {

     

       
15
       
-
       
  if (error) {

     

       
16
       
-
       
    console.error(error);

     

       
17
       
-
       
  } else {

     

       
18
       
-
       
    console.log(`Labeler server listening on ${address}`);

     

       
19
       
-
       
  }

     

       
20
       
 
       
});

     

       
21
       
 
       


     

       
22
       
 
       
export const label = async (did: string, rkey: string) => {

     
···

       
30
       
 
       
    return set;

     

       
31
       
 
       
  }, new Set<string>());

     

       
32
       
 
       


     

       
33
       
-
       
  const timestamp = new Date().toISOString();

     

       
34
       
 
       


     

       
35
       
 
       
  if (rkey.includes(DELETE)) {

     

       
36
       
 
       
    await server

     

       
37
       
 
       
      .createLabels({ uri: did }, { negate: [...labels] })

     

       
38
       
-
       
      .catch((err) => {

     

       
39
       
-
       
        console.log(err);

     

       
40
       
-
       
      })

     

       
41
       
-
       
      .then(() => console.log(`${timestamp}: Deleted labels for ${did}`));

     

       
42
       
 
       
  } else if (labels.size < LABEL_LIMIT && POSTS[rkey]) {

     

       
43
       
 
       
    await server

     

       
44
       
 
       
      .createLabel({ uri: did, val: POSTS[rkey] })

     

       
45
       
-
       
      .catch((err) => {

     

       
46
       
-
       
        console.log(err);

     

       
47
       
-
       
      })

     

       
48
       
-
       
      .then(() =>

     

       
49
       
-
       
        console.log(`${timestamp}: Labeled ${did} with ${POSTS[rkey]}`),

     

       
50
       
-
       
      );

     

       
51
       
 
       
  }

     

       
52
       
 
       
};

     

···

       
12
       
 
       
const server = new LabelerServer({ did: DID, signingKey: SIGNING_KEY });

     

       
13
       
 
       


     

       
14
       
 
       
server.start(PORT, (error, address) => {

     

       
15
       
+
       
  if (error) console.error(error);

     

       
16
       
+
       
  else console.log(`Labeler server listening on ${address}`);

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
17
       
 
       
});

     

       
18
       
 
       


     

       
19
       
 
       
export const label = async (did: string, rkey: string) => {

     
···

       
27
       
 
       
    return set;

     

       
28
       
 
       
  }, new Set<string>());

     

       
29
       
 
       


     

       
30
       
+
       
  const time = new Date().toISOString();

     

       
31
       
 
       


     

       
32
       
 
       
  if (rkey.includes(DELETE)) {

     

       
33
       
 
       
    await server

     

       
34
       
 
       
      .createLabels({ uri: did }, { negate: [...labels] })

     

       
35
       
+
       
      .catch((err) => console.log(err))

     

       
36
       
+
       
      .then(() => console.log(`${time}: Deleted labels for ${did}`));

     

       
0
       
 
       

     

       
0
       
 
       

     

       
37
       
 
       
  } else if (labels.size < LABEL_LIMIT && POSTS[rkey]) {

     

       
38
       
 
       
    await server

     

       
39
       
 
       
      .createLabel({ uri: did, val: POSTS[rkey] })

     

       
40
       
+
       
      .catch((err) => console.log(err))

     

       
41
       
+
       
      .then(() => console.log(`${time}: Labeled ${did} with ${POSTS[rkey]}`));

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
42
       
 
       
  }

     

       
43
       
 
       
};

     

···

       
30
       
 
       
    cursor = event.time_us;

     

       
31
       
 
       
    if (

     

       
32
       
 
       
      event.commit?.record?.subject?.uri?.includes(`${DID}/app.bsky.feed.post`)

     

       
33
       
-
       
    ) {

     

       
34
       
 
       
      label(event.did, event.commit.record.subject.uri.split("/").pop()!);

     

       
35
       
-
       
    }

     

       
36
       
 
       
  });

     

       
37
       
 
       
};

     

       
38
       
 
       


     

···

       
30
       
 
       
    cursor = event.time_us;

     

       
31
       
 
       
    if (

     

       
32
       
 
       
      event.commit?.record?.subject?.uri?.includes(`${DID}/app.bsky.feed.post`)

     

       
33
       
+
       
    )

     

       
34
       
 
       
      label(event.did, event.commit.record.subject.uri.split("/").pop()!);

     

       
0
       
 
       

     

       
35
       
 
       
  });

     

       
36
       
 
       
};

     

       
37