[READ ONLY MIRROR] Spark Social AppView Server
github.com/sprksocial/server
atproto
deno
hono
lexicon
fix(indexing): deprecated mongoose option
+35
-35
+3
-3
data-plane/indexing/index.ts
+3
-3
data-plane/indexing/index.ts
···
139
139
await this.db.models.Actor.findOneAndUpdate(
140
140
{ did },
141
141
{ did, ...actorInfo },
142
-
{ upsert: true, new: true },
142
+
{ upsert: true, returnDocument: "after" },
143
143
);
144
144
} catch (err) {
145
145
// Log the error but don't throw - this prevents the firehose from crashing
···
154
154
await this.db.models.Actor.findOneAndUpdate(
155
155
{ did },
156
156
{ did, ...actorInfo },
157
-
{ upsert: true, new: true },
157
+
{ upsert: true, returnDocument: "after" },
158
158
);
159
159
} catch (dbErr) {
160
160
console.error(
···
253
253
commitCid: commit.toString(),
254
254
repoRev: rev ?? null,
255
255
},
256
-
{ upsert: true, new: true },
256
+
{ upsert: true, returnDocument: "after" },
257
257
);
258
258
}
259
259
+1
-1
data-plane/indexing/plugins/audio.ts
+1
-1
data-plane/indexing/plugins/audio.ts
···
34
34
const insertedAudio = await db.models.Audio.findOneAndUpdate(
35
35
{ uri: uri.toString() },
36
36
{ $set: audio },
37
-
{ upsert: true, new: true, includeResultMetadata: false },
37
+
{ upsert: true, returnDocument: "after", includeResultMetadata: false },
38
38
);
39
39
return insertedAudio;
40
40
};
+1
-1
data-plane/indexing/plugins/block.ts
+1
-1
data-plane/indexing/plugins/block.ts
+4
-4
data-plane/indexing/plugins/crosspost/reply.ts
+4
-4
data-plane/indexing/plugins/crosspost/reply.ts
···
113
113
const insertedReply = await db.models.CrosspostReply.findOneAndUpdate(
114
114
{ uri: reply.uri },
115
115
{ $set: reply },
116
-
{ upsert: true, new: true },
116
+
{ upsert: true, returnDocument: "after" },
117
117
);
118
118
119
119
const { invalidReplyRoot } = await validateCrosspostReply(db, insertedReply);
···
300
300
await db.models.Post.findOneAndUpdate(
301
301
{ uri: replyIdx.reply.reply?.parent.uri },
302
302
{ $set: { replyCount } },
303
-
{ new: true },
303
+
{ returnDocument: "after" },
304
304
);
305
305
} else if (parentReply) {
306
306
await db.models.Reply.findOneAndUpdate(
307
307
{ uri: replyIdx.reply.reply?.parent.uri },
308
308
{ $set: { replyCount } },
309
-
{ new: true },
309
+
{ returnDocument: "after" },
310
310
);
311
311
} else if (parentCrosspostReply) {
312
312
await db.models.CrosspostReply.findOneAndUpdate(
313
313
{ uri: replyIdx.reply.reply?.parent.uri },
314
314
{ $set: { replyCount } },
315
-
{ new: true },
315
+
{ returnDocument: "after" },
316
316
);
317
317
}
318
318
}
+3
-3
data-plane/indexing/plugins/follow.ts
+3
-3
data-plane/indexing/plugins/follow.ts
···
29
29
const insertedFollow = await db.models.Follow.findOneAndUpdate(
30
30
{ uri: follow.uri },
31
31
{ $set: follow },
32
-
{ upsert: true, new: true },
32
+
{ upsert: true, returnDocument: "after" },
33
33
);
34
34
return insertedFollow;
35
35
};
···
94
94
await db.models.Profile.findOneAndUpdate(
95
95
{ authorDid: follow.subject },
96
96
{ $set: { followersCount } },
97
-
{ new: true },
97
+
{ returnDocument: "after" },
98
98
);
99
99
}
100
100
···
113
113
await db.models.Profile.findOneAndUpdate(
114
114
{ authorDid: follow.authorDid },
115
115
{ $set: { followsCount } },
116
-
{ new: true },
116
+
{ returnDocument: "after" },
117
117
);
118
118
}
119
119
};
+1
-1
data-plane/indexing/plugins/generator.ts
+1
-1
data-plane/indexing/plugins/generator.ts
+1
-1
data-plane/indexing/plugins/labeler.ts
+1
-1
data-plane/indexing/plugins/labeler.ts
+5
-5
data-plane/indexing/plugins/like.ts
+5
-5
data-plane/indexing/plugins/like.ts
···
37
37
const insertedLike = await db.models.Like.findOneAndUpdate(
38
38
{ uri: like.uri },
39
39
{ $set: like },
40
-
{ upsert: true, new: true },
40
+
{ upsert: true, returnDocument: "after" },
41
41
);
42
42
return insertedLike;
43
43
};
···
140
140
await db.models.Generator.findOneAndUpdate(
141
141
{ uri: like.subject },
142
142
{ $set: { likeCount } },
143
-
{ new: true },
143
+
{ returnDocument: "after" },
144
144
);
145
145
}
146
146
} else {
···
152
152
await db.models.Post.findOneAndUpdate(
153
153
{ uri: like.subject },
154
154
{ $set: { likeCount } },
155
-
{ new: true },
155
+
{ returnDocument: "after" },
156
156
);
157
157
}
158
158
···
164
164
await db.models.Reply.findOneAndUpdate(
165
165
{ uri: like.subject },
166
166
{ $set: { likeCount } },
167
-
{ new: true },
167
+
{ returnDocument: "after" },
168
168
);
169
169
}
170
170
···
176
176
await db.models.CrosspostReply.findOneAndUpdate(
177
177
{ uri: like.subject },
178
178
{ $set: { likeCount } },
179
-
{ new: true },
179
+
{ returnDocument: "after" },
180
180
);
181
181
}
182
182
}
+2
-2
data-plane/indexing/plugins/post.ts
+2
-2
data-plane/indexing/plugins/post.ts
···
82
82
const insertedPost = await db.models.Post.findOneAndUpdate(
83
83
{ uri: post.uri },
84
84
{ $set: post },
85
-
{ upsert: true, new: true },
85
+
{ upsert: true, returnDocument: "after" },
86
86
);
87
87
88
88
const facets = (obj.caption?.facets || [])
···
278
278
await db.models.Profile.findOneAndUpdate(
279
279
{ authorDid: postIdx.post.authorDid },
280
280
{ $set: { postsCount } },
281
-
{ new: true },
281
+
{ returnDocument: "after" },
282
282
);
283
283
}
284
284
};
+1
-1
data-plane/indexing/plugins/profile.ts
+1
-1
data-plane/indexing/plugins/profile.ts
+4
-4
data-plane/indexing/plugins/reply.ts
+4
-4
data-plane/indexing/plugins/reply.ts
···
86
86
const insertedReply = await db.models.Reply.findOneAndUpdate(
87
87
{ uri: reply.uri },
88
88
{ $set: reply },
89
-
{ upsert: true, new: true },
89
+
{ upsert: true, returnDocument: "after" },
90
90
);
91
91
92
92
if (obj.reply) {
···
293
293
await db.models.Post.findOneAndUpdate(
294
294
{ uri: replyIdx.reply.reply?.parent.uri },
295
295
{ $set: { replyCount } },
296
-
{ new: true },
296
+
{ returnDocument: "after" },
297
297
);
298
298
} else if (parentReply) {
299
299
await db.models.Reply.findOneAndUpdate(
300
300
{ uri: replyIdx.reply.reply?.parent.uri },
301
301
{ $set: { replyCount } },
302
-
{ new: true },
302
+
{ returnDocument: "after" },
303
303
);
304
304
} else if (parentCrosspostReply) {
305
305
await db.models.CrosspostReply.findOneAndUpdate(
306
306
{ uri: replyIdx.reply.reply?.parent.uri },
307
307
{ $set: { replyCount } },
308
-
{ new: true },
308
+
{ returnDocument: "after" },
309
309
);
310
310
}
311
311
}
+3
-3
data-plane/indexing/plugins/repost.ts
+3
-3
data-plane/indexing/plugins/repost.ts
···
37
37
const insertedRepost = await db.models.Repost.findOneAndUpdate(
38
38
{ uri: repost.uri },
39
39
{ $set: repost },
40
-
{ upsert: true, new: true },
40
+
{ upsert: true, returnDocument: "after" },
41
41
);
42
42
return insertedRepost;
43
43
};
···
137
137
await db.models.Post.findOneAndUpdate(
138
138
{ uri: repost.subject },
139
139
{ $set: { repostCount } },
140
-
{ new: true },
140
+
{ returnDocument: "after" },
141
141
);
142
142
}
143
143
···
153
153
await db.models.Profile.findOneAndUpdate(
154
154
{ authorDid: repost.authorDid },
155
155
{ $set: { repostCount: authorRepostCount } },
156
-
{ new: true },
156
+
{ returnDocument: "after" },
157
157
);
158
158
}
159
159
};
+1
-1
data-plane/indexing/plugins/story.ts
+1
-1
data-plane/indexing/plugins/story.ts
+4
-4
data-plane/indexing/processor.ts
+4
-4
data-plane/indexing/processor.ts
···
128
128
duplicateOf: found.toString(),
129
129
indexedAt: timestamp,
130
130
},
131
-
{ upsert: true, new: true },
131
+
{ upsert: true, returnDocument: "after" },
132
132
);
133
133
return;
134
134
}
···
146
146
createdAt,
147
147
indexedAt: timestamp,
148
148
},
149
-
{ upsert: true, new: true },
149
+
{ upsert: true, returnDocument: "after" },
150
150
);
151
151
152
152
const inserted = await this.params.insertFn(
···
201
201
await this.db.models.Record.findOneAndUpdate(
202
202
{ uri: uri.toString() },
203
203
updateData,
204
-
{ new: true },
204
+
{ returnDocument: "after" },
205
205
);
206
206
207
207
// If the updated record was a dupe, update dupe info for it
···
214
214
duplicateOf: dupe.toString(),
215
215
indexedAt: timestamp,
216
216
},
217
-
{ upsert: true, new: true },
217
+
{ upsert: true, returnDocument: "after" },
218
218
);
219
219
} else {
220
220
await this.db.models.DuplicateRecord.deleteOne({ uri: uri.toString() });