Method UpdateMatchingRule

database/reconciliation.go:495–527

UpdateMatchingRule updates a specific matching rule in the database. Parameters: - ctx: Context for managing the request and tracing. - rule: The matching rule to be updated, including the RuleID, name, description, and criteria. Returns: - An error wrapped in an APIError if the operation fails, or

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

// Returns:
// - An error wrapped in an APIError if the operation fails, or nil if the update is successful.
func (d Datasource) UpdateMatchingRule(ctx context.Context, rule *model.MatchingRule) error {
	ctx, span := otel.Tracer("reconciliation.database").Start(ctx, "Updating matching rule")
	defer span.End()

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

	// Execute the SQL update statement
	result, err := d.Conn.ExecContext(ctx, `
		UPDATE ledgerforge.matching_rules
		SET name = $2, description = $3, criteria = $4
		WHERE rule_id = $1
	`, rule.RuleID, rule.Name, rule.Description, criteriaJSON)
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to update matching rule", err)
	}

	// Check how many rows were affected
	rowsAffected, err := result.RowsAffected()
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to get rows affected", err)
	}

	// If no rows were affected, return a NotFound error
	if rowsAffected == 0 {
		return apierror.NewAPIError(apierror.ErrNotFound, fmt.Sprintf("Matching rule with ID '%s' not found", rule.RuleID), nil)
	}

	return nil
}

// DeleteMatchingRule deletes a specific matching rule from the database.
// Parameters: