Fix follows

gabboman · Jan 21, 2025 · 44d1bc2 · 44d1bc2
1 parent d2aafca
commit 44d1bc2
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/packages/backend/atproto/workers/processFirehoseWorker.ts b/packages/backend/atproto/workers/processFirehoseWorker.ts
@@ -80,12 +80,16 @@ async function processFirehose(job: Job) {
           case 'app.bsky.graph.follow': {
             const userFollowed = await getAtprotoUser(record.subject, (await adminUser) as Model<any, any>)
             if (userFollowed) {
-              let tmp = await Follows.create({
-                followedId: userFollowed.id,
-                followerId: remoteUser.id,
-                bskyPath: operation.path,
-                accepted: true
+              let tmp = await Follows.findOrCreate({
+                where: {
+                  followedId: userFollowed.id,
+                  followerId: remoteUser.id
+                }
               })
+              const follow = tmp[0]
+              follow.bskyPath = operation.path
+              follow.accepted = true
+              await follow.save()
             }
             break
           }