Method GetMatchingRules

database/reconciliation.go:443–487

GetMatchingRules retrieves all matching rules from the database. Parameters: - ctx: Context for managing the request and tracing. Returns: - A slice of MatchingRule pointers or an error wrapped in an APIError if the operation fails.

(ctx context.Context)

// Returns:
// - A slice of MatchingRule pointers or an error wrapped in an APIError if the operation fails.
func (d Datasource) GetMatchingRules(ctx context.Context) ([]*model.MatchingRule, error) {
	ctx, span := otel.Tracer("reconciliation.database").Start(ctx, "Fetching matching rules")
	defer span.End()

	// Execute the query to fetch all matching rules
	rows, err := d.Conn.QueryContext(ctx, `
		SELECT id, rule_id, created_at, updated_at, name, description, criteria
		FROM ledgerforge.matching_rules
	`)
	if err != nil {
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to retrieve matching rules", err)
	}
	defer func() { _ = rows.Close() }()

	var rules []*model.MatchingRule

	// Iterate over the rows to scan each rule into a MatchingRule object
	for rows.Next() {
		rule := &model.MatchingRule{}
		var criteriaJSON []byte
		err = rows.Scan(
			&rule.ID, &rule.RuleID, &rule.CreatedAt, &rule.UpdatedAt,
			&rule.Name, &rule.Description, &criteriaJSON,
		)
		if err != nil {
			return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to scan matching rule data", err)
		}

		// Unmarshal the criteria JSON into the MatchingRule's Criteria field
		err = json.Unmarshal(criteriaJSON, &rule.Criteria)
		if err != nil {
			return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to unmarshal matching rule criteria", err)
		}

		// Append the rule to the rules slice
		rules = append(rules, rule)
	}

	// Check for any errors that occurred during the iteration
	if err = rows.Err(); err != nil {
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Error occurred while iterating over matching rules", err)
	}

	return rules, nil
}

// UpdateMatchingRule updates a specific matching rule in the database.
// Parameters: