// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.29.0
// source: subscription_items.sql

package billing

import (
	"context"
)

const createSubscriptionItem = `-- name: CreateSubscriptionItem :one
INSERT INTO billing.subscription_items (subscription_id, product_id, price_id, quantity)
VALUES ($1, $2, $3, $4)
RETURNING subscription_item_id, subscription_id, product_id, price_id, quantity, created_at, updated_at
`

type CreateSubscriptionItemParams struct {
	SubscriptionID string `json:"subscription_id"`
	ProductID      string `json:"product_id"`
	PriceID        string `json:"price_id"`
	Quantity       int32  `json:"quantity"`
}

func (q *Queries) CreateSubscriptionItem(ctx context.Context, arg CreateSubscriptionItemParams) (SubscriptionItem, error) {
	row := q.db.QueryRowContext(ctx, createSubscriptionItem,
		arg.SubscriptionID,
		arg.ProductID,
		arg.PriceID,
		arg.Quantity,
	)
	var i SubscriptionItem
	err := row.Scan(
		&i.SubscriptionItemID,
		&i.SubscriptionID,
		&i.ProductID,
		&i.PriceID,
		&i.Quantity,
		&i.CreatedAt,
		&i.UpdatedAt,
	)
	return i, err
}

const getSubscriptionItemsBySubscriptionID = `-- name: GetSubscriptionItemsBySubscriptionID :many
SELECT subscription_item_id, subscription_id, product_id, price_id, quantity, created_at, updated_at FROM billing.subscription_items
WHERE subscription_id = $1
ORDER BY created_at ASC
`

func (q *Queries) GetSubscriptionItemsBySubscriptionID(ctx context.Context, subscriptionID string) ([]SubscriptionItem, error) {
	rows, err := q.db.QueryContext(ctx, getSubscriptionItemsBySubscriptionID, subscriptionID)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	items := []SubscriptionItem{}
	for rows.Next() {
		var i SubscriptionItem
		if err := rows.Scan(
			&i.SubscriptionItemID,
			&i.SubscriptionID,
			&i.ProductID,
			&i.PriceID,
			&i.Quantity,
			&i.CreatedAt,
			&i.UpdatedAt,
		); err != nil {
			return nil, err
		}
		items = append(items, i)
	}
	if err := rows.Close(); err != nil {
		return nil, err
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return items, nil
}