Method GetMatchingRule

database/reconciliation.go:568–600

GetMatchingRule retrieves a specific matching rule from the database by its rule ID. Parameters: - ctx: Context for managing the request and tracing. - id: The ID of the matching rule to be retrieved. Returns: - A pointer to the MatchingRule object if found, or an APIError if the operation fails.

(ctx context.Context, id string)

// Returns:
// - A pointer to the MatchingRule object if found, or an APIError if the operation fails.
func (d Datasource) GetMatchingRule(ctx context.Context, id string) (*model.MatchingRule, error) {
	ctx, span := otel.Tracer("reconciliation.database").Start(ctx, "Fetching matching rule")
	defer span.End()

	var rule model.MatchingRule
	var criteriaJSON []byte

	// Execute SQL query to retrieve the matching rule by rule_id
	err := d.Conn.QueryRowContext(ctx, `
		SELECT id, rule_id, created_at, updated_at, name, description, criteria
		FROM ledgerforge.matching_rules
		WHERE rule_id = $1
	`, id).Scan(
		&rule.ID, &rule.RuleID, &rule.CreatedAt, &rule.UpdatedAt,
		&rule.Name, &rule.Description, &criteriaJSON,
	)
	if err != nil {
		// Return NotFound error if no rows are returned
		if err == sql.ErrNoRows {
			return nil, apierror.NewAPIError(apierror.ErrNotFound, fmt.Sprintf("Matching rule with ID '%s' not found", id), err)
		}
		// Return InternalServer error for any other failure
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to retrieve matching rule", err)
	}

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

	return &rule, nil
}

// GetExternalTransactionsPaginated retrieves external transactions based on the provided upload ID
// with pagination. It first checks the cache, and if the data is not available, it fetches from the