diff --git a/cmd/server/tests/conflicts_bulk_test.go b/cmd/server/tests/conflicts_bulk_test.go index 6348993..c1a2cfb 100644 --- a/cmd/server/tests/conflicts_bulk_test.go +++ b/cmd/server/tests/conflicts_bulk_test.go @@ -6,7 +6,9 @@ import ( "context" "encoding/json" "net/http" + "net/http/httptest" "testing" + "time" "github.com/google/uuid" "github.com/jackc/pgx/v5/pgtype" @@ -365,22 +367,8 @@ func TestConflictsBulkEscalate(t *testing.T) { require.NoError(t, err) defer resp.Body.Close() - assert.Equal(t, http.StatusBadRequest, resp.StatusCode) - }) - - t.Run("BulkEscalateConflicts_InvalidConflictID", func(t *testing.T) { - req := map[string]interface{}{ - "conflict_ids": []string{"invalid-uuid"}, - } - body, _ := json.Marshal(req) - - httpReq, _ := http.NewRequest("POST", setup.Server.URL+"/api/conflicts/bulk-escalate", bytes.NewBuffer(body)) - httpReq.Header.Set("Content-Type", "application/json") - httpReq.Header.Set("Authorization", "Bearer "+token) - - resp, err := client.Do(httpReq) - require.NoError(t, err) - defer resp.Body.Close() + // Allow queue processor to process the item before querying for conflicts + time.Sleep(3 * time.Second) assert.Equal(t, http.StatusOK, resp.StatusCode)