···109 data: record.value as Json,
110 });
111 if (docResult.error) console.log(docResult.error);
000000000112 if (record.value.publication) {
113 let publicationURI = new AtUri(record.value.publication);
114···269 data: record.value as Json,
270 });
271 if (docResult.error) console.log(docResult.error);
000000000272273 // site.standard.document uses "site" field to reference the publication
274 // For documents in publications, site is an AT-URI (at://did:plc:xxx/site.standard.publication/rkey)
···109 data: record.value as Json,
110 });
111 if (docResult.error) console.log(docResult.error);
112+ if (record.value.postRef?.uri) {
113+ await inngest.send({
114+ name: "appview/sync-bsky-likes",
115+ data: {
116+ document_uri: evt.uri.toString(),
117+ bsky_post_uri: record.value.postRef.uri,
118+ },
119+ });
120+ }
121 if (record.value.publication) {
122 let publicationURI = new AtUri(record.value.publication);
123···278 data: record.value as Json,
279 });
280 if (docResult.error) console.log(docResult.error);
281+ if (record.value.bskyPostRef?.uri) {
282+ await inngest.send({
283+ name: "appview/sync-bsky-likes",
284+ data: {
285+ document_uri: evt.uri.toString(),
286+ bsky_post_uri: record.value.bskyPostRef.uri,
287+ },
288+ });
289+ }
290291 // site.standard.document uses "site" field to reference the publication
292 // For documents in publications, site is an AT-URI (at://did:plc:xxx/site.standard.publication/rkey)