package resultset import ( "context" "fmt" "queryorchestration/internal/database" "queryorchestration/internal/database/repository" "queryorchestration/internal/query" "queryorchestration/internal/query/result" resultprocessor "queryorchestration/internal/query/result/processor" resultsync "queryorchestration/internal/query/result/sync" "queryorchestration/internal/serviceconfig" queryc "queryorchestration/internal/serviceconfig/queue/query" 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" ) type ResultSetConfig struct { serviceconfig.BaseConfig queryc.QueryConfig } func TestSet(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &ResultSetConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) mockSQS := queuemock.NewMockSQSClient(t) cfg.QueueClient = mockSQS cfg.QueryURL = "/i/am/here" que := query.New(cfg) svc := Service{ cfg: cfg, svc: &Services{ Query: que, Result: result.New(cfg, &result.Services{ Query: que, }), Sync: resultsync.New(cfg), }, } qcfg := "{\"path\":\"examplekey\"}" query := &resultprocessor.Query{ ID: uuid.New(), Version: 2, RequiredQueryIDs: &[]uuid.UUID{uuid.New()}, Config: &qcfg, } params := Set{ DocumentID: uuid.New(), QueryID: query.ID, } textEntryId := uuid.New() pool.ExpectQuery("name: GetDocumentTextEntry :one").WithArgs(database.MustToDBUUID(params.DocumentID)). WillReturnRows( pgxmock.NewRows([]string{"id", "documentId", "bucket", "key", "version", "cleanEntryId"}). AddRow(database.MustToDBUUID(textEntryId), database.MustToDBUUID(params.DocumentID), "buket", "/i/am/here", int32(1), database.MustToDBUUID(uuid.New())), ) pool.ExpectQuery("name: GetQuery :one").WithArgs(database.MustToDBUUID(query.ID)).WillReturnRows( pgxmock.NewRows([]string{"id", "type", "activeVersion", "latestVersion", "config", "requiredIds"}). AddRow(database.MustToDBUUID(query.ID), repository.QuerytypeJsonExtractor, query.Version, query.Version, []byte(*query.Config), database.MustToDBUUIDArray(*query.RequiredQueryIDs)), ) pool.ExpectQuery("name: GetQueryWithVersion :one").WithArgs(database.MustToDBUUID(query.ID), &query.Version).WillReturnRows( pgxmock.NewRows([]string{"id", "type", "activeVersion", "latestVersion", "config", "requiredIds"}). AddRow(database.MustToDBUUID(query.ID), repository.QuerytypeJsonExtractor, query.Version, query.Version, []byte(*query.Config), database.MustToDBUUIDArray(*query.RequiredQueryIDs)), ) requiredResultId := uuid.New() strVal := "{\"examplekey\":\"example_value\"}" pool.ExpectQuery("name: ListQueryRequirementValues :many").WithArgs(database.MustToDBUUID(query.ID), &query.Version, database.MustToDBUUID(params.DocumentID)). WillReturnRows( pgxmock.NewRows([]string{"id", "queryId", "type", "value"}). AddRow(database.MustToDBUUID(requiredResultId), database.MustToDBUUID((*query.RequiredQueryIDs)[0]), repository.QuerytypeContextFull, &strVal), ) pool.ExpectQuery("name: GetActiveQueryConfig :one").WithArgs(database.MustToDBUUID(query.ID)).WillReturnRows( pgxmock.NewRows([]string{"config"}). AddRow([]byte(qcfg)), ) pool.ExpectBegin() resultId := uuid.New() pool.ExpectQuery("name: AddResult :one").WithArgs(database.MustToDBUUID(query.ID), pgxmock.AnyArg(), database.MustToDBUUID(textEntryId), query.Version). WillReturnRows( pgxmock.NewRows([]string{"id"}). AddRow(database.MustToDBUUID(resultId)), ) pool.ExpectQuery("name: ListQueryRequirementValues :many").WithArgs(database.MustToDBUUID(query.ID), &query.Version, database.MustToDBUUID(params.DocumentID)). WillReturnRows( pgxmock.NewRows([]string{"id", "queryId", "type", "value"}). AddRow(database.MustToDBUUID(requiredResultId), database.MustToDBUUID((*query.RequiredQueryIDs)[0]), repository.QuerytypeContextFull, &strVal), ) pool.ExpectExec("name: AddResultDependency :exec").WithArgs(database.MustToDBUUID(resultId), database.MustToDBUUID(requiredResultId)). WillReturnResult(pgxmock.NewResult("", 1)) pool.ExpectCommit() pool.ExpectQuery("name: ListQueryDirectDependentsByDocumentID :many").WithArgs(database.MustToDBUUID(params.QueryID), database.MustToDBUUID(params.DocumentID)). WillReturnRows( pgxmock.NewRows([]string{"queryId"}). AddRow(database.MustToDBUUID((*query.RequiredQueryIDs)[0])), ) mockSQS.EXPECT(). SendMessage( mock.Anything, mock.MatchedBy(func(in *sqs.SendMessageInput) bool { return *in.QueueUrl == cfg.QueryURL && *in.MessageBody == fmt.Sprintf("{\"document_id\":\"%s\",\"query_id\":\"%s\"}", params.DocumentID.String(), (*query.RequiredQueryIDs)[0].String()) }), mock.Anything, ). Return(&sqs.SendMessageOutput{}, nil) err = svc.Set(ctx, ¶ms) assert.NoError(t, err) } func TestInformQueryDependents(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &ResultSetConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) mockSQS := queuemock.NewMockSQSClient(t) cfg.QueueClient = mockSQS cfg.QueryURL = "/i/am/here" que := query.New(cfg) svc := Service{ cfg: cfg, svc: &Services{ Query: que, Result: result.New(cfg, &result.Services{ Query: que, }), Sync: resultsync.New(cfg), }, } qIds := []uuid.UUID{ uuid.New(), uuid.New(), } params := &Set{ DocumentID: uuid.New(), QueryID: uuid.New(), } pool.ExpectQuery("name: ListQueryDirectDependentsByDocumentID :many").WithArgs(database.MustToDBUUID(params.QueryID), database.MustToDBUUID(params.DocumentID)). WillReturnRows( pgxmock.NewRows([]string{"queryId"}). AddRow(database.MustToDBUUID(qIds[0])). AddRow(database.MustToDBUUID(qIds[1])), ) mockSQS.EXPECT(). SendMessage( mock.Anything, mock.MatchedBy(func(in *sqs.SendMessageInput) bool { return *in.QueueUrl == cfg.QueryURL && *in.MessageBody == fmt.Sprintf("{\"document_id\":\"%s\",\"query_id\":\"%s\"}", params.DocumentID.String(), qIds[0].String()) }), mock.Anything, ). Return(&sqs.SendMessageOutput{}, nil) mockSQS.EXPECT(). SendMessage( mock.Anything, mock.MatchedBy(func(in *sqs.SendMessageInput) bool { return *in.QueueUrl == cfg.QueryURL && *in.MessageBody == fmt.Sprintf("{\"document_id\":\"%s\",\"query_id\":\"%s\"}", params.DocumentID.String(), qIds[1].String()) }), mock.Anything, ). Return(&sqs.SendMessageOutput{}, nil) err = svc.informQueryDependents(ctx, params) assert.NoError(t, err) }