package queryversionsyncrunner_test import ( "context" "encoding/json" "fmt" "testing" queryversionsyncrunner "queryorchestration/api/queryVersionSyncRunner" "queryorchestration/internal/database/repository" queryversionsync "queryorchestration/internal/query/versionsync" "queryorchestration/internal/server/runner" "queryorchestration/internal/serviceconfig/queue/clientsync" queuemock "queryorchestration/mocks/queue" "github.com/aws/aws-sdk-go-v2/service/sqs" "github.com/aws/aws-sdk-go-v2/service/sqs/types" "github.com/go-playground/validator/v10" "github.com/google/uuid" "github.com/pashagolub/pgxmock/v3" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" "github.com/stretchr/testify/require" ) type QuerySyncConfig struct { runner.BaseConfig clientsync.ClientSyncConfig } func TestQueryRunner(t *testing.T) { ctx := context.Background() pool, err := pgxmock.NewPool() require.NoError(t, err) cfg := &QuerySyncConfig{} cfg.DBPool = pool cfg.DBQueries = repository.New(pool) mockSQS := queuemock.NewMockSQSClient(t) cfg.QueueClient = mockSQS cfg.ClientSyncURL = "/i/am/here" svc := queryversionsync.New(cfg) runner := queryversionsyncrunner.New(validator.New(), &queryversionsyncrunner.Services{ Sync: svc, }) assert.NotNil(t, runner) t.Run("valid", func(t *testing.T) { doc := queryversionsyncrunner.Body{ ID: uuid.New(), } bodyBytes, err := json.Marshal(doc) require.NoError(t, err) body := string(bodyBytes) msg := &types.Message{ Body: &body, } clientOne := uuid.New() clientTwo := uuid.New() clientIds := []uuid.UUID{ clientOne, clientTwo, } pool.ExpectQuery("name: ListQueryClientIDs :many").WithArgs(&doc.ID). WillReturnRows( pgxmock.NewRows([]string{"clientId"}). AddRow(clientOne). AddRow(clientTwo), ) mockSQS.EXPECT(). SendMessage( mock.Anything, mock.MatchedBy(func(in *sqs.SendMessageInput) bool { return *in.QueueUrl == cfg.ClientSyncURL && *in.MessageBody == fmt.Sprintf("{\"id\":\"%s\"}", clientIds[0].String()) }), mock.Anything, ). Return(&sqs.SendMessageOutput{}, nil) mockSQS.EXPECT(). SendMessage( mock.Anything, mock.MatchedBy(func(in *sqs.SendMessageInput) bool { return *in.QueueUrl == cfg.ClientSyncURL && *in.MessageBody == fmt.Sprintf("{\"id\":\"%s\"}", clientIds[1].String()) }), mock.Anything, ). Return(&sqs.SendMessageOutput{}, nil) assert.True(t, runner.Process(ctx, msg)) }) t.Run("invalid body", func(t *testing.T) { body := "definitely invalid" msgId := "id" msg := &types.Message{ Body: &body, MessageId: &msgId, } assert.True(t, runner.Process(ctx, msg)) }) }