Method SaveReconciliationProgress

database/reconciliation.go:677–694

SaveReconciliationProgress saves the progress of a reconciliation process to the database. If a record with the given reconciliation ID already exists, it updates the progress information. The function ensures that the reconciliation progress is stored and updated properly. Parameters: - ctx: Contex

(ctx context.Context, reconciliationID string, progress model.ReconciliationProgress)

// Returns:
// - An error if the operation fails, wrapped in an APIError if needed.
func (d Datasource) SaveReconciliationProgress(ctx context.Context, reconciliationID string, progress model.ReconciliationProgress) error {
	ctx, span := otel.Tracer("reconciliation.database").Start(ctx, "Saving reconciliation progress to db")
	defer span.End()

	// Execute the query, with conflict handling to update if the record already exists
	_, err := d.Conn.ExecContext(ctx, `
		INSERT INTO ledgerforge.reconciliation_progress (reconciliation_id, processed_count, last_processed_external_txn_id)
		VALUES ($1, $2, $3)
		ON CONFLICT (reconciliation_id) DO UPDATE
		SET processed_count = $2, last_processed_external_txn_id = $3
	`, reconciliationID, progress.ProcessedCount, progress.LastProcessedExternalTxnID)
	// Return an API error if the query fails
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to save reconciliation progress", err)
	}

	return nil
}

// LoadReconciliationProgress retrieves the progress of a reconciliation process from the database. If the reconciliation progress
// is not found, it returns an empty ReconciliationProgress object.