Method HandleNotification

internal/search/search.go:231–247

HandleNotification processes incoming notifications and updates Typesense collections based on the table and data. It ensures the required fields exist and upserts the data into Typesense.

(ctx context.Context, table string, data map[string]interface{})

// HandleNotification processes incoming notifications and updates Typesense collections based on the table and data.
// It ensures the required fields exist and upserts the data into Typesense.
func (t *TypesenseClient) HandleNotification(ctx context.Context, table string, data map[string]interface{}) error {
	config, ok := collectionConfigs[table]
	if !ok {
		return fmt.Errorf("unknown collection: %s", table)
	}

	// Process and normalize the data
	if err := t.processMetadata(data); err != nil {
		return err
	}
	t.convertLargeNumbers(config, data)
	t.ensureSchemaFields(config, data)
	t.normalizeTimeFields(config, data)

	// Upsert the document
	return t.upsertDocument(ctx, table, data)
}

// 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).