From 01bcbd01ab1bc461bd8d54035dacf89ba01ec15c Mon Sep 17 00:00:00 2001
From: Tyagiquamar <tyagiquamar@users.noreply.github.com>
Date: Mon, 21 Sep 2026 19:47:05 +0530
Subject: [PATCH 1/2] fix: map Mongo duplicate key error to DuplicatedJobError

---
 .../backends/backend-test/src/createNewJob.ts   |  3 ++-
 packages/backends/mongo/src/mongo-backend.ts    | 17 +++++++++++++++--
 2 files changed, 17 insertions(+), 3 deletions(-)

diff --git a/packages/backends/backend-test/src/createNewJob.ts b/packages/backends/backend-test/src/createNewJob.ts
index 2885bc1d..73ba7f3c 100644
--- a/packages/backends/backend-test/src/createNewJob.ts
+++ b/packages/backends/backend-test/src/createNewJob.ts
@@ -1,4 +1,5 @@
 import { NewJobData } from "@sidequest/backend";
+import { DuplicatedJobError } from "@sidequest/core";
 import { describe, it } from "vitest";
 import { backend } from "./backend";
 
@@ -124,7 +125,7 @@ export default function defineCreateNewJobTestSuite() {
       };
 
       await backend.createNewJob(job);
-      await expect(backend.createNewJob(job2)).rejects.toThrow();
+      await expect(backend.createNewJob(job2)).rejects.toThrow(DuplicatedJobError);
     });
   });
 }
diff --git a/packages/backends/mongo/src/mongo-backend.ts b/packages/backends/mongo/src/mongo-backend.ts
index c69552d1..57316dae 100644
--- a/packages/backends/mongo/src/mongo-backend.ts
+++ b/packages/backends/mongo/src/mongo-backend.ts
@@ -10,7 +10,7 @@ import {
   UpdateJobData,
   UpdateQueueData,
 } from "@sidequest/backend";
-import { JobData, JobState, QueueConfig } from "@sidequest/core";
+import { DuplicatedJobError, JobData, JobState, QueueConfig } from "@sidequest/core";
 import { Collection, Db, Filter, MongoClient } from "mongodb";
 import { addCoalescedField, generateTimeBuckets, getTimeRangeConfig, matchDateRange, parseTimeRange } from "./utils";
 
@@ -156,7 +156,20 @@ export default class MongoBackend implements Backend {
       inserted_at: now,
       available_at: job.available_at ?? now,
     };
-    await this.jobs.insertOne(doc);
+    try {
+      await this.jobs.insertOne(doc);
+    } catch (error) {
+      if (
+        error instanceof Error &&
+        (("code" in error && error.code === 11000) ||
+          error.message?.includes("E11000") ||
+          error.message?.includes("unique_digest"))
+      ) {
+        throw new DuplicatedJobError(doc);
+      }
+
+      throw error;
+    }
     return doc;
   }
 

From c71b38d21fed1fb360a7e959e22dbee524b66054 Mon Sep 17 00:00:00 2001
From: Tyagiquamar <mohdquamartyagi@gmail.com>
Date: Tue, 22 Sep 2026 12:48:48 +0530
Subject: [PATCH 2/2] fix: map MySQL duplicate key error to DuplicatedJobError

MySQL reports unique_digest collisions as ER_DUP_ENTRY (errno 1062)
with key sidequest_jobs.sidequest_jobs_unique_digest_unique, which
did not match the previous sidequest_jobs.unique_digest check.

createNewJob now maps those failures to DuplicatedJobError, matching
the Mongo backend contract.

Co-authored-by: Cursor <cursoragent@cursor.com>
---
 packages/backends/mysql/src/mysql-backend.ts | 31 ++++++++++++++++----
 1 file changed, 26 insertions(+), 5 deletions(-)

diff --git a/packages/backends/mysql/src/mysql-backend.ts b/packages/backends/mysql/src/mysql-backend.ts
index e6e7dc5b..f26242e3 100644
--- a/packages/backends/mysql/src/mysql-backend.ts
+++ b/packages/backends/mysql/src/mysql-backend.ts
@@ -25,6 +25,31 @@ const defaultKnexConfig = {
   },
 };
 
+const MYSQL_ER_DUP_ENTRY = 1062;
+
+function isUniqueDigestDuplicateError(error: unknown): boolean {
+  if (!(error instanceof Error)) {
+    return false;
+  }
+
+  const code = "code" in error ? error.code : undefined;
+  const errno = "errno" in error ? error.errno : undefined;
+  const sqlMessage = "sqlMessage" in error && typeof error.sqlMessage === "string" ? error.sqlMessage : "";
+  const constraint = "constraint" in error && typeof error.constraint === "string" ? error.constraint : "";
+  const details = `${error.message}\n${sqlMessage}\n${constraint}`;
+
+  if (!details.includes("unique_digest")) {
+    return false;
+  }
+
+  return (
+    code === "ER_DUP_ENTRY" ||
+    errno === MYSQL_ER_DUP_ENTRY ||
+    constraint === "sidequest_jobs_unique_digest_active_idx" ||
+    /duplicate entry/i.test(details)
+  );
+}
+
 export default class MysqlBackend extends SQLBackend {
   constructor(dbConfig: string | SQLDriverConfig) {
     const knexConfig: Knex.Config = {
@@ -119,11 +144,7 @@ export default class MysqlBackend extends SQLBackend {
 
       return insertedJob;
     } catch (error) {
-      if (
-        error instanceof Error &&
-        (error.message?.includes("sidequest_jobs.unique_digest") ||
-          ("constraint" in error && error.constraint === "sidequest_jobs_unique_digest_active_idx"))
-      ) {
+      if (isUniqueDigestDuplicateError(error)) {
         throw new DuplicatedJobError(job as JobData);
       }