Bookhoard/bookhoard
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 12 Wiki Activity

fix(tests): update worker tests for API changes and error handling

Browse Source 
- Update ListMediaItems calls to include required Limit and Offset parameters
- Change Enqueue() to EnqueueJob() to match updated worker API
- Add error assertions for job enqueue operations with descriptive messages
- Ensure all database queries use proper pagination parameters

This ensures tests properly validate error conditions and use the latest worker service API.
This commit is contained in:
john-okeefe
2026-03-06 10:48:33 -05:00
parent bb0158e8fb
commit c5c7f50aac
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/server/tests/worker_test.go
+14 -5
View File
@@ -107,7 +107,10 @@ func TestWorker_DirectoryScanJob(t *testing.T) {
// Check that items were created in database // Check that items were created in database
ctx := context.Background() ctx := context.Background()
items, err := setup.DB.ListMediaItems(ctx, database.ListMediaItemsParams{}) items, err := setup.DB.ListMediaItems(ctx, database.ListMediaItemsParams{
Limit: 1000,
Offset: 0,
})
require.NoError(t, err) require.NoError(t, err)
// Should have at least 3 items (our test files) // Should have at least 3 items (our test files)
@@ -161,7 +164,8 @@ func TestWorker_SetFoldersJob(t *testing.T) {
Status: services.JobStatusPending, Status: services.JobStatusPending,
} }
services.WorkerInstance.Enqueue(job) err = services.WorkerInstance.EnqueueJob(job)
require.NoError(t, err, "Failed to enqueue set folders job")
// Wait for job to process // Wait for job to process
time.Sleep(1 * time.Second) time.Sleep(1 * time.Second)
@@ -228,14 +232,18 @@ func TestWorker_ConcurrentJobs(t *testing.T) {
}, },
Status: services.JobStatusPending, Status: services.JobStatusPending,
} }
services.WorkerInstance.Enqueue(job) err = services.WorkerInstance.EnqueueJob(job)
require.NoError(t, err, "Failed to enqueue set folders job")
} }
// Wait for all jobs to process // Wait for all jobs to process
time.Sleep(3 * time.Second) time.Sleep(3 * time.Second)
// Verify all directories were processed // Verify all directories were processed
allItems, err := setup.DB.ListMediaItems(ctx, database.ListMediaItemsParams{}) allItems, err := setup.DB.ListMediaItems(ctx, database.ListMediaItemsParams{
Limit: 1000,
Offset: 0,
})
require.NoError(t, err) require.NoError(t, err)
assert.NotEmpty(t, allItems, "Should have media items from concurrent jobs") assert.NotEmpty(t, allItems, "Should have media items from concurrent jobs")
} }
@@ -278,7 +286,8 @@ func TestWorker_JobStatusTracking(t *testing.T) {
Status: services.JobStatusPending, Status: services.JobStatusPending,
} }
services.WorkerInstance.Enqueue(job) err = services.WorkerInstance.EnqueueJob(job)
require.NoError(t, err, "Failed to enqueue set folders job")
// Poll job status // Poll job status
var finalStatus string var finalStatus string