Method HandleBatchNotification

internal/search/search.go:252–279

HandleBatchNotification processes a batch of items and indexes them in dependency order. It first indexes all dependencies (e.g., balances), then indexes the primary item (e.g., transaction). This ensures referential integrity in the search index.

(ctx context.Context, batch *IndexBatch)

// It first indexes all dependencies (e.g., balances), then indexes the primary item (e.g., transaction).
// This ensures referential integrity in the search index.
func (t *TypesenseClient) HandleBatchNotification(ctx context.Context, batch *IndexBatch) error {
	// Deduplicate dependencies to avoid redundant indexing
	batch.Deduplicate()

	// Step 1: Index all dependencies first (in order)
	for _, dep := range batch.Dependencies {
		data, err := toMap(dep.Data)
		if err != nil {
			return fmt.Errorf("failed to convert dependency %s/%s to map: %w", dep.Collection, dep.DocumentID, err)
		}
		if err := t.HandleNotification(ctx, dep.Collection, data); err != nil {
			return fmt.Errorf("failed to index dependency %s/%s: %w", dep.Collection, dep.DocumentID, err)
		}
	}

	// Step 2: Index primary entity after dependencies exist
	if batch.Primary != nil {
		data, err := toMap(batch.Primary.Data)
		if err != nil {
			return fmt.Errorf("failed to convert primary %s/%s to map: %w", batch.Primary.Collection, batch.Primary.DocumentID, err)
		}
		if err := t.HandleNotification(ctx, batch.Primary.Collection, data); err != nil {
			return fmt.Errorf("failed to index primary %s/%s: %w", batch.Primary.Collection, batch.Primary.DocumentID, err)
		}
	}

	return nil
}

// toMap converts an interface{} to map[string]interface{} via JSON marshaling.
func toMap(data interface{}) (map[string]interface{}, error) {