Merge pull request #4 from vandie/fix---stop-duplication

fix(storeMentionForPage): #3 - use update with upsert for new mentions

.github/FUNDING.yml

@@ -0,0 +1 @@
+github: [vandie]

package.json

@@ -1,6 +1,6 @@
 {
   "name": "webmention-handler-mongodb",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "description": "A Mongo DB Storage Handler for the Webmention Handler Project",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/mongo-webmention-storage.class.ts

@@ -50,14 +50,16 @@ export class MongoWebMentionStorage implements IWebMentionStorage {
 
   async deleteMention(mention: SimpleMention): Promise<null> {
     const collection = this.fetchCollection<Mention>(this.mentionCollection);
-    await collection.deleteMany({ source: mention.source, target: mention.target });
+    await collection.deleteOne({ source: mention.source, target: mention.target });
     return null;
   }
 
   async storeMentionForPage(page: string, mention: Mention): Promise<WithId<Mention>> {
     const collection = this.fetchCollection<Mention>(this.mentionCollection);
-    const storedMention = await collection.insertOne(mention);
-    return {...mention, _id: storedMention.insertedId};
+    await collection.updateOne({target: mention.target, source: mention.source}, {$set: mention }, { upsert: true });
+    const storedMention = await collection.findOne<WithId<Mention>>({target: mention.target, source: mention.source});
+    if(!storedMention) throw new Error(`Could not find Mention after insertion, source ${mention.source} & target ${mention.target}`);
+    return storedMention;
   }
 
   async getMentionsForPage(page: string, type?: string): Promise<WithId<Mention>[]> {