Method CreateLedger

database/ledger.go:41–72

CreateLedger inserts a new ledger record into the database, ensuring metadata is properly marshaled into JSON format. It assigns a unique ledger ID with a suffix and captures the current timestamp as the creation time. Parameters: - ledger: The ledger data to be inserted into the database. Returns

(ledger model.Ledger)

// - model.Ledger: The created ledger object including the generated LedgerID and creation timestamp.
// - error: An error if the ledger creation fails, including specific database error handling for conflicts.
func (d Datasource) CreateLedger(ledger model.Ledger) (model.Ledger, error) {
	// Marshal the metadata into JSON format
	metaDataJSON, err := json.Marshal(ledger.MetaData)
	if err != nil {
		return model.Ledger{}, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to marshal metadata", err)
	}

	// Assign a unique ledger ID and record the creation time
	ledger.LedgerID = model.GenerateUUIDWithSuffix("ldg")
	ledger.CreatedAt = time.Now()

	// Insert the ledger into the database
	_, err = d.Conn.ExecContext(context.Background(), `
		INSERT INTO ledgerforge.ledgers (meta_data, name, ledger_id)
		VALUES ($1, $2, $3)
	`, metaDataJSON, ledger.Name, ledger.LedgerID)
	// Handle database errors, specifically unique constraint violations
	if err != nil {
		pqErr, ok := err.(*pq.Error)
		if ok {
			switch pqErr.Code.Name() {
			case "unique_violation":
				return model.Ledger{}, apierror.NewAPIError(apierror.ErrConflict, "Ledger with this name or ID already exists", err)
			default:
				return model.Ledger{}, apierror.NewAPIError(apierror.ErrInternalServer, "Database error occurred", err)
			}
		}
		return model.Ledger{}, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to create ledger", err)
	}

	return ledger, nil
}

// GetAllLedgers retrieves a paginated list of ledger records from the database, unmarshaling their metadata from JSON format.
// This method supports pagination and can be used to efficiently retrieve all ledgers over multiple requests.