diff --git a/dms/internal/workerruntime/workerruntime_test.go b/dms/internal/workerruntime/workerruntime_test.go index aa7b50dd..869bf104 100644 --- a/dms/internal/workerruntime/workerruntime_test.go +++ b/dms/internal/workerruntime/workerruntime_test.go @@ -33,7 +33,7 @@ func requireTools(t *testing.T) { } } -func upload(t *testing.T, e *testenv.Env, rt *Runtime, queue *jobqueue.Queue, name string, data []byte) (docID, revID string) { +func uploadPDF(t *testing.T, e *testenv.Env, rt *Runtime, queue *jobqueue.Queue, name string, data []byte) (docID, revID string) { t.Helper() svc := e.UploadService(t) AttachEnqueuers(svc, e.Pool, queue, rt.JobTypes()) @@ -90,7 +90,7 @@ func TestEndToEnd_AllJobTypesReachTheirFinalState(t *testing.T) { go func() { rt.Run(ctx, 3, "e2e", 20*time.Millisecond); close(done) }() defer func() { cancel(); <-done }() - docID, revID := upload(t, e, rt, queue, "durchsuchbar.pdf", testcorpus.GeneratePDF("Rechnung", []string{"Rechnung Nr. 2026-0001", "Musterhandel Nordlicht GmbH", "Gesamtbetrag 77,50 EUR"})) + docID, revID := uploadPDF(t, e, rt, queue, "durchsuchbar.pdf", testcorpus.GeneratePDF("Rechnung", []string{"Rechnung Nr. 2026-0001", "Musterhandel Nordlicht GmbH", "Gesamtbetrag 77,50 EUR"})) waitFor(t, "vorschau", 60*time.Second, func() bool { th, err := thumbnail.GetForRevision(ctx, e.Pool, revID) @@ -136,7 +136,7 @@ func TestMissingToolsAndConfigurationAreReportedAndNotEnqueued(t *testing.T) { t.Errorf("registrierte jobtypen: %v, erwartet nur %s", types, export.JobType) } - upload(t, e, rt, queue, "x.pdf", testcorpus.GeneratePDF("x", []string{"Testinhalt Zeile eins", "Zeile zwei"})) + uploadPDF(t, e, rt, queue, "x.pdf", testcorpus.GeneratePDF("x", []string{"Testinhalt Zeile eins", "Zeile zwei"})) if n := count(t, e, `SELECT count(*) FROM processing_jobs WHERE job_type IN ($1, $2, $3)`, thumbnail.JobType, malwarescan.JobType, ocr.JobPlan); n != 0 { t.Errorf("%d jobs fuer nicht abgeholte typen eingereiht (sie blieben ewig pending)", n) } @@ -175,7 +175,7 @@ func TestMultipleWorkersProcessEachJobExactlyOnce(t *testing.T) { const docs = 15 revs := make([]string, docs) for i := range revs { - _, revs[i] = upload(t, e, rt, queue, fmt.Sprintf("d%02d.pdf", i), testcorpus.GeneratePDF("t", []string{fmt.Sprintf("Dokument Nummer %d", i), "Musterhandel Nordlicht GmbH Zeile"})) + _, revs[i] = uploadPDF(t, e, rt, queue, fmt.Sprintf("d%02d.pdf", i), testcorpus.GeneratePDF("t", []string{fmt.Sprintf("Dokument Nummer %d", i), "Musterhandel Nordlicht GmbH Zeile"})) } ctx, cancel := context.WithCancel(context.Background()) done := make(chan struct{})