From f628addd800ffd07cbc6d32c310b684838ddfd2f Mon Sep 17 00:00:00 2001
From: m5r <mokht@rmi.al>
Date: Sat, 14 Aug 2021 01:15:35 +0800
Subject: [PATCH] skip duplicates when inserting calls and messages

---
 app/messages/api/queue/insert-messages.ts | 2 +-
 app/phone-calls/api/queue/fetch-calls.ts  | 1 +
 app/phone-calls/api/queue/insert-calls.ts | 2 +-
 3 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/app/messages/api/queue/insert-messages.ts b/app/messages/api/queue/insert-messages.ts
index 0834fc5..93a0647 100644
--- a/app/messages/api/queue/insert-messages.ts
+++ b/app/messages/api/queue/insert-messages.ts
@@ -35,7 +35,7 @@ const insertMessagesQueue = Queue<Payload>(
 			}))
 			.sort((a, b) => a.sentAt.getTime() - b.sentAt.getTime());
 
-		await db.message.createMany({ data: sms });
+		await db.message.createMany({ data: sms, skipDuplicates: true });
 	},
 );
 
diff --git a/app/phone-calls/api/queue/fetch-calls.ts b/app/phone-calls/api/queue/fetch-calls.ts
index ef0732c..c06a18c 100644
--- a/app/phone-calls/api/queue/fetch-calls.ts
+++ b/app/phone-calls/api/queue/fetch-calls.ts
@@ -15,6 +15,7 @@ const fetchCallsQueue = Queue<Payload>("api/queue/fetch-calls", async ({ organiz
 		include: { organization: true },
 	});
 	if (!phoneNumber) {
+		console.log("no phone number found");
 		return;
 	}
 
diff --git a/app/phone-calls/api/queue/insert-calls.ts b/app/phone-calls/api/queue/insert-calls.ts
index 71044cf..32e4fb7 100644
--- a/app/phone-calls/api/queue/insert-calls.ts
+++ b/app/phone-calls/api/queue/insert-calls.ts
@@ -32,7 +32,7 @@ const insertCallsQueue = Queue<Payload>("api/queue/insert-calls", async ({ calls
 		}))
 		.sort((a, b) => a.createdAt.getTime() - b.createdAt.getTime());
 
-	await db.phoneCall.createMany({ data: phoneCalls });
+	await db.phoneCall.createMany({ data: phoneCalls, skipDuplicates: true });
 });
 
 export default insertCallsQueue;