inventory-plus-plus/domains/reports/events_test.go

package reports_test

import (
	"context"
	"encoding/json"
	"testing"
	"time"

	"github.com/google/uuid"
	"github.com/jackc/pgx/v5/pgxpool"
	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"

	"ruben/inventory2/consts"
	"ruben/inventory2/domains/accounts"
	"ruben/inventory2/domains/reports"
	"ruben/inventory2/internal/testdb"
)

// setupEtsyMockShop creates a fresh account and an Etsy mock shop for it,
// and registers cleanup for every row it creates, in FK-safe order
// (shop_etsy[_events] -> mock.accounts -> accounts; oauth_users cleanup is
// handled by testdb.SeedOAuthUser itself).
//
// Etsy (not Amazon) is deliberately used here: domains/amazon's tests
// process every unprocessed row in mock.shop_amazon_events system-wide
// (that's correct production behavior for a background worker, not a
// bug), so any test that writes Amazon-platform mock events risks being
// picked up by domains/amazon's tests when the two packages' test
// binaries run concurrently (go test ./... does this by default). Using
// a different platform here keeps this package's fixtures completely off
// domains/amazon's tables and NOTIFY channel.
func setupEtsyMockShop(t *testing.T, pool *pgxpool.Pool, acctStore *accounts.Store) (acctID int64, shopID string) {
	t.Helper()
	ctx := context.Background()

	userID := testdb.NewUserID(t)
	testdb.SeedOAuthUser(t, pool, userID)

	acct, err := acctStore.CreateAccount(ctx, userID, userID+"@example.com")
	require.NoError(t, err, "CreateAccount()")
	t.Cleanup(func() {
		pool.Exec(context.Background(), "DELETE FROM accounts WHERE account_id = $1", acct.AccountID)
	})

	id, err := acctStore.CreateMockShop(ctx, acct.AccountID, accounts.Etsy, "Test Shop")
	require.NoError(t, err, "CreateMockShop()")
	shopID = id.String()

	t.Cleanup(func() {
		ctx := context.Background()
		pool.Exec(ctx, "DELETE FROM mock.shop_etsy_events WHERE shop_id = $1", shopID)
		pool.Exec(ctx, "DELETE FROM mock.raw_shop_events WHERE shop_id = $1", shopID)
		pool.Exec(ctx, "DELETE FROM mock.shop_etsy WHERE account_id = $1", acct.AccountID)
		pool.Exec(ctx, "DELETE FROM mock.accounts WHERE account_id = $1", acct.AccountID)
	})

	return acct.AccountID, shopID
}

func insertRawShopEvent(t *testing.T, pool *pgxpool.Pool, shopID, eventID string, ts time.Time, payload string) {
	t.Helper()
	_, err := pool.Exec(context.Background(), `
		INSERT INTO mock.raw_shop_events (platform, shop_id, event_timestamp, event_id, raw_payload)
		VALUES ($1, $2, $3, $4, $5::jsonb)
	`, string(accounts.Etsy), shopID, ts, eventID, payload)
	require.NoError(t, err, "insert raw shop event")
}

func TestGetRawShopEvents(t *testing.T) {
	pool := testdb.Pool(t)
	acctStore := accounts.NewStore(testdb.Logger(), pool)
	reportsStore := reports.NewStore(testdb.Logger(), pool, acctStore)
	ctx := context.Background()

	acctID, shopID := setupEtsyMockShop(t, pool, acctStore)

	older := time.Now().Add(-time.Hour).UTC()
	newer := time.Now().UTC()
	insertRawShopEvent(t, pool, shopID, "evt-1", older, `{"n":1}`)
	insertRawShopEvent(t, pool, shopID, "evt-2", newer, `{"n":2}`)

	got, err := reportsStore.GetRawShopEvents(ctx, acctID, accounts.Etsy, shopID)
	require.NoError(t, err, "GetRawShopEvents()")
	require.Len(t, got, 2, "GetRawShopEvents()")

	// ordered event_timestamp DESC, event_id ASC - newest first.
	assert.Equal(t, "evt-2", got[0].EventID, "GetRawShopEvents()[0]")
	assert.Equal(t, "evt-1", got[1].EventID, "GetRawShopEvents()[1]")

	assert.Equal(t, accounts.Etsy, got[0].Platform, "got[0].Platform")
	assert.Equal(t, shopID, got[0].ShopID, "got[0].ShopID")

	var payload struct{ N int }
	require.NoError(t, json.Unmarshal(got[0].RawPayload, &payload), "unmarshal got[0].RawPayload")
	assert.Equal(t, 2, payload.N, "got[0].RawPayload n")
}

func TestGetRawShopEvents_NoEvents(t *testing.T) {
	pool := testdb.Pool(t)
	acctStore := accounts.NewStore(testdb.Logger(), pool)
	reportsStore := reports.NewStore(testdb.Logger(), pool, acctStore)
	ctx := context.Background()

	acctID, shopID := setupEtsyMockShop(t, pool, acctStore)

	got, err := reportsStore.GetRawShopEvents(ctx, acctID, accounts.Etsy, shopID)
	require.NoError(t, err, "GetRawShopEvents()")
	assert.Empty(t, got, "GetRawShopEvents()")
}

func TestGetRawShopEvents_UnknownShop(t *testing.T) {
	pool := testdb.Pool(t)
	acctStore := accounts.NewStore(testdb.Logger(), pool)
	reportsStore := reports.NewStore(testdb.Logger(), pool, acctStore)
	ctx := context.Background()

	userID := testdb.NewUserID(t)
	testdb.SeedOAuthUser(t, pool, userID)

	acct, err := acctStore.CreateAccount(ctx, userID, userID+"@example.com")
	require.NoError(t, err, "CreateAccount()")
	t.Cleanup(func() {
		pool.Exec(context.Background(), "DELETE FROM accounts WHERE account_id = $1", acct.AccountID)
	})

	_, err = reportsStore.GetRawShopEvents(ctx, acct.AccountID, accounts.Etsy, "no-such-shop-"+uuid.NewString())
	require.ErrorIs(t, err, consts.ErrNotFound, "GetRawShopEvents()")
}