package documentinit import ( "context" "errors" "fmt" "queryorchestration/internal/database" "queryorchestration/internal/database/repository" "queryorchestration/internal/document" "queryorchestration/internal/job" queuemock "queryorchestration/mocks/queue" "testing" "github.com/stretchr/testify/require" "github.com/aws/aws-sdk-go-v2/service/sqs" "github.com/google/uuid" "github.com/pashagolub/pgxmock/v3" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) func TestCreate(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &DocInitConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) mockSQS := queuemock.NewMockSQSClient(t) cfg.QueueClient = mockSQS cfg.DocumentSyncURL = "/i/am/here" svc := New(cfg) j := job.Job{ ID: uuid.New(), ClientID: uuid.New(), } doc := document.Document{ ID: uuid.New(), JobID: j.ID, Hash: "example_hash", } location := document.Location{ Bucket: "example_bucket", Key: "/i/am/here", } pool.ExpectQuery("name: GetDocumentIDByHash :one").WithArgs(doc.Hash, database.MustToDBUUID(doc.JobID)).WillReturnRows( pgxmock.NewRows([]string{"id"}), ) pool.ExpectBegin() pool.ExpectQuery("name: CreateDocument :one").WithArgs(database.MustToDBUUID(doc.JobID), doc.Hash). WillReturnRows( pgxmock.NewRows([]string{"id"}). AddRow(database.MustToDBUUID(doc.ID)), ) pool.ExpectExec("name: AddDocumentEntry :exec").WithArgs(database.MustToDBUUID(doc.ID), location.Bucket, location.Key). WillReturnResult(pgxmock.NewResult("", 1)) pool.ExpectCommit() pool.ExpectQuery("name: GetDocument :one").WithArgs(database.MustToDBUUID(doc.ID)). WillReturnRows( pgxmock.NewRows([]string{"id", "jobId", "hash"}). AddRow(database.MustToDBUUID(doc.ID), database.MustToDBUUID(doc.JobID), doc.Hash), ) pool.ExpectQuery("name: GetJob :one").WithArgs(database.MustToDBUUID(j.ID)).WillReturnRows( pgxmock.NewRows([]string{"id", "clientId", "canSync"}). AddRow(database.MustToDBUUID(j.ID), database.MustToDBUUID(j.ClientID), j.CanSync), ) pool.ExpectQuery("name: GetClient :one").WithArgs(database.MustToDBUUID(j.ClientID)).WillReturnRows( pgxmock.NewRows([]string{"id", "name", "canSync"}). AddRow(database.MustToDBUUID(j.ClientID), "client_name", true), ) mockSQS.EXPECT(). SendMessage( mock.Anything, mock.MatchedBy(func(in *sqs.SendMessageInput) bool { return *in.QueueUrl == cfg.DocumentSyncURL && *in.MessageBody == fmt.Sprintf("{\"id\":\"%s\"}", doc.ID.String()) }), mock.Anything, ). Return(&sqs.SendMessageOutput{}, nil) id, err := svc.Create(ctx, &Create{ JobID: doc.JobID, Location: location, Hash: doc.Hash, }) assert.NoError(t, err) assert.Equal(t, doc.ID, id) } func TestGetCreateParams(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &DocInitConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) svc := New(cfg) doc := document.Document{ JobID: uuid.New(), Hash: "example_hash", } location := document.Location{ Bucket: "example_bucket", Key: "/i/am/here", } pool.ExpectQuery("name: GetDocumentIDByHash :one").WithArgs(doc.Hash, database.MustToDBUUID(doc.JobID)).WillReturnRows( pgxmock.NewRows([]string{"id"}), ) params, err := svc.getCreateParams(ctx, &Create{ JobID: doc.JobID, Location: location, Hash: doc.Hash, }) assert.NoError(t, err) assert.Equal(t, &createDocumentParams{ JobID: database.MustToDBUUID(doc.JobID), Hash: doc.Hash, Location: location, }, params) } func TestGetCreateParamsExisting(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &DocInitConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) svc := New(cfg) doc := document.Document{ ID: uuid.New(), JobID: uuid.New(), Hash: "example_hash", } location := document.Location{ Bucket: "example_bucket", Key: "/i/am/here", } pool.ExpectQuery("name: GetDocumentIDByHash :one").WithArgs(doc.Hash, database.MustToDBUUID(doc.JobID)).WillReturnRows( pgxmock.NewRows([]string{"id"}). AddRow(database.MustToDBUUID(doc.ID)), ) params, err := svc.getCreateParams(ctx, &Create{ JobID: doc.JobID, Location: location, Hash: doc.Hash, }) assert.NoError(t, err) dbid := database.MustToDBUUID(doc.ID) assert.Equal(t, &createDocumentParams{ ID: &dbid, JobID: database.MustToDBUUID(doc.JobID), Hash: doc.Hash, Location: location, }, params) } func TestGetCreateParamsCurrentDocErr(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &DocInitConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) svc := New(cfg) doc := document.Document{ JobID: uuid.New(), Hash: "example_hash", } location := document.Location{ Bucket: "example_bucket", Key: "/i/am/here", } pool.ExpectQuery("name: GetDocumentIDByHash :one").WithArgs(doc.Hash, database.MustToDBUUID(doc.JobID)). WillReturnError(errors.New("db err")) _, err = svc.getCreateParams(ctx, &Create{ JobID: doc.JobID, Location: location, }) assert.Error(t, err) } func TestSubmitCreate(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &DocInitConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) svc := New(cfg) doc := document.Document{ ID: uuid.New(), JobID: uuid.New(), Hash: "example_hash", } location := document.Location{ Bucket: "example_bucket", Key: "/i/am/here", } pool.ExpectBegin() pool.ExpectQuery("name: CreateDocument :one").WithArgs(database.MustToDBUUID(doc.JobID), doc.Hash). WillReturnRows( pgxmock.NewRows([]string{"id"}). AddRow(database.MustToDBUUID(doc.ID)), ) pool.ExpectExec("name: AddDocumentEntry :exec").WithArgs(database.MustToDBUUID(doc.ID), location.Bucket, location.Key). WillReturnResult(pgxmock.NewResult("", 1)) pool.ExpectCommit() id, err := svc.submitCreate(ctx, &createDocumentParams{ JobID: database.MustToDBUUID(doc.JobID), Location: location, Hash: doc.Hash, }) assert.NoError(t, err) assert.Equal(t, doc.ID, id) } func TestSubmitCreateExists(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &DocInitConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) svc := New(cfg) doc := document.Document{ ID: uuid.New(), JobID: uuid.New(), Hash: "example_hash", } location := document.Location{ Bucket: "example_bucket", Key: "/i/am/here", } pool.ExpectBegin() pool.ExpectExec("name: AddDocumentEntry :exec").WithArgs(database.MustToDBUUID(doc.ID), location.Bucket, location.Key). WillReturnResult(pgxmock.NewResult("", 1)) pool.ExpectCommit() docid := database.MustToDBUUID(doc.ID) id, err := svc.submitCreate(ctx, &createDocumentParams{ ID: &docid, JobID: database.MustToDBUUID(doc.JobID), Location: location, Hash: doc.Hash, }) assert.NoError(t, err) assert.Equal(t, doc.ID, id) } func TestGetJobIDFromKey(t *testing.T) { svc := Service{} _, err := svc.GetJobIDFromKey("") assert.Error(t, err) _, err = svc.GetJobIDFromKey("jkhaskhweuifhwhieh") assert.Error(t, err) _, err = svc.GetJobIDFromKey("aaa/bbb/ccc") assert.Error(t, err) id := uuid.New() _, err = svc.GetJobIDFromKey(fmt.Sprintf("aaa/%s/bbb", id.String())) assert.Error(t, err) aid, err := svc.GetJobIDFromKey(fmt.Sprintf("%s/%s/bbb", uuid.NewString(), id.String())) assert.NoError(t, err) assert.Equal(t, id, aid) }