Fix user id routes and job

This commit is contained in:
Rob Walsh
2026-03-10 20:52:45 -06:00
parent 5d2e33e369
commit 06e77b8eba
4 changed files with 4 additions and 3 deletions
@@ -91,7 +91,7 @@ export async function PATCH(
try { try {
const jobQueue = getJobQueueService(); const jobQueue = getJobQueueService();
await jobQueue.addSyncShelvesJob(undefined, updated.id, 'goodreads', 0); await jobQueue.addSyncShelvesJob(undefined, updated.id, 'goodreads', 0, req.user.id);
} catch (error) { } catch (error) {
logger.error('Failed to trigger immediate list sync', { logger.error('Failed to trigger immediate list sync', {
error: error instanceof Error ? error.message : String(error), error: error instanceof Error ? error.message : String(error),
+1 -1
View File
@@ -139,7 +139,7 @@ export async function POST(request: NextRequest) {
// Trigger immediate sync for this shelf (unlimited lookups, process all books) // Trigger immediate sync for this shelf (unlimited lookups, process all books)
try { try {
const jobQueue = getJobQueueService(); 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})`); logger.info(`Triggered immediate sync for Goodreads shelf "${shelfName}" (${shelf.id})`);
} catch (error) { } catch (error) {
logger.error('Failed to trigger immediate shelf sync', { error: error instanceof Error ? error.message : String(error) }); logger.error('Failed to trigger immediate shelf sync', { error: error instanceof Error ? error.message : String(error) });
+1 -1
View File
@@ -148,7 +148,7 @@ export async function POST(request: NextRequest) {
// Trigger immediate sync for this shelf (unlimited lookups, process all books) // Trigger immediate sync for this shelf (unlimited lookups, process all books)
try { try {
const jobQueue = getJobQueueService(); const jobQueue = getJobQueueService();
await jobQueue.addSyncShelvesJob(undefined, shelf.id, 'hardcover', 0); await jobQueue.addSyncShelvesJob(undefined, shelf.id, 'hardcover', 0, req.user.id);
logger.info( logger.info(
`Triggered immediate sync for Hardcover list "${listName}" (${shelf.id})`, `Triggered immediate sync for Hardcover list "${listName}" (${shelf.id})`,
); );
+1
View File
@@ -785,6 +785,7 @@ export class JobQueueService {
shelfId, shelfId,
shelfType, shelfType,
maxLookupsPerShelf, maxLookupsPerShelf,
userId,
} as SyncShelvesPayload, } as SyncShelvesPayload,
{ {
priority: 7, priority: 7,