From 06e77b8eba099f1fd23270c49248f7a935d977e9 Mon Sep 17 00:00:00 2001
From: Rob Walsh <brombomb@gmail.com>
Date: Tue, 10 Mar 2026 20:52:45 -0600
Subject: [PATCH] Fix user id routes and job

---
 src/app/api/user/goodreads-shelves/[id]/route.ts | 2 +-
 src/app/api/user/goodreads-shelves/route.ts      | 2 +-
 src/app/api/user/hardcover-shelves/route.ts      | 2 +-
 src/lib/services/job-queue.service.ts            | 1 +
 4 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/app/api/user/goodreads-shelves/[id]/route.ts b/src/app/api/user/goodreads-shelves/[id]/route.ts
index 7f5a226..ce7f54d 100644
--- a/src/app/api/user/goodreads-shelves/[id]/route.ts
+++ b/src/app/api/user/goodreads-shelves/[id]/route.ts
@@ -91,7 +91,7 @@ export async function PATCH(
 
       try {
         const jobQueue = getJobQueueService();
-        await jobQueue.addSyncShelvesJob(undefined, updated.id, 'goodreads', 0);
+        await jobQueue.addSyncShelvesJob(undefined, updated.id, 'goodreads', 0, req.user.id);
       } catch (error) {
         logger.error('Failed to trigger immediate list sync', {
           error: error instanceof Error ? error.message : String(error),
diff --git a/src/app/api/user/goodreads-shelves/route.ts b/src/app/api/user/goodreads-shelves/route.ts
index 8626fc0..2acf3bd 100644
--- a/src/app/api/user/goodreads-shelves/route.ts
+++ b/src/app/api/user/goodreads-shelves/route.ts
@@ -139,7 +139,7 @@ export async function POST(request: NextRequest) {
       // Trigger immediate sync for this shelf (unlimited lookups, process all books)
       try {
         const jobQueue = getJobQueueService();
-        await jobQueue.addSyncShelvesJob(undefined, shelf.id, 'goodreads', 0);
+        await jobQueue.addSyncShelvesJob(undefined, shelf.id, 'goodreads', 0, req.user.id);
         logger.info(`Triggered immediate sync for Goodreads shelf "${shelfName}" (${shelf.id})`);
       } catch (error) {
         logger.error('Failed to trigger immediate shelf sync', { error: error instanceof Error ? error.message : String(error) });
diff --git a/src/app/api/user/hardcover-shelves/route.ts b/src/app/api/user/hardcover-shelves/route.ts
index 56feb35..4289ce7 100644
--- a/src/app/api/user/hardcover-shelves/route.ts
+++ b/src/app/api/user/hardcover-shelves/route.ts
@@ -148,7 +148,7 @@ export async function POST(request: NextRequest) {
       // Trigger immediate sync for this shelf (unlimited lookups, process all books)
       try {
         const jobQueue = getJobQueueService();
-        await jobQueue.addSyncShelvesJob(undefined, shelf.id, 'hardcover', 0);
+        await jobQueue.addSyncShelvesJob(undefined, shelf.id, 'hardcover', 0, req.user.id);
         logger.info(
           `Triggered immediate sync for Hardcover list "${listName}" (${shelf.id})`,
         );
diff --git a/src/lib/services/job-queue.service.ts b/src/lib/services/job-queue.service.ts
index 6a905e6..4e40b57 100644
--- a/src/lib/services/job-queue.service.ts
+++ b/src/lib/services/job-queue.service.ts
@@ -785,6 +785,7 @@ export class JobQueueService {
         shelfId,
         shelfType,
         maxLookupsPerShelf,
+        userId,
       } as SyncShelvesPayload,
       {
         priority: 7,