Method RecordMatchingRule

database/reconciliation.go:414–436

RecordMatchingRule saves a new matching rule to the database. Parameters: - ctx: Context for managing the request and tracing. - rule: A pointer to the MatchingRule object containing rule details. Returns: - An error wrapped in an APIError if the operation fails.

(ctx context.Context, rule *model.MatchingRule)

// Returns:
// - An error wrapped in an APIError if the operation fails.
func (d Datasource) RecordMatchingRule(ctx context.Context, rule *model.MatchingRule) error {
	ctx, span := otel.Tracer("reconciliation.database").Start(ctx, "Saving matching rule to db")
	defer span.End()

	// Marshal the matching rule criteria into JSON format
	criteriaJSON, err := json.Marshal(rule.Criteria)
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to marshal matching rule criteria", err)
	}

	// Execute the SQL insert query to record the rule in the database
	_, err = d.Conn.ExecContext(ctx,
		`INSERT INTO ledgerforge.matching_rules(
			rule_id, created_at, updated_at, name, description, criteria
		) VALUES ($1, $2, $3, $4, $5, $6)`,
		rule.RuleID, rule.CreatedAt, rule.UpdatedAt, rule.Name, rule.Description, criteriaJSON,
	)
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to record matching rule", err)
	}

	return nil
}

// GetMatchingRules retrieves all matching rules from the database.
// Parameters: