// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.30.0
// source: AnalyticsCoverage.sql

package store

import (
	"context"
	"time"
)

const deleteAnalyticsCoverageRange = `-- name: DeleteAnalyticsCoverageRange :exec
DELETE FROM analytics_coverage_ranges
WHERE user_id = $1 AND platform = $2 AND covered_start = $3 AND covered_end = $4
`

type DeleteAnalyticsCoverageRangeParams struct {
	UserID       string
	Platform     string
	CoveredStart time.Time
	CoveredEnd   time.Time
}

func (q *Queries) DeleteAnalyticsCoverageRange(ctx context.Context, arg DeleteAnalyticsCoverageRangeParams) error {
	_, err := q.db.ExecContext(ctx, deleteAnalyticsCoverageRange,
		arg.UserID,
		arg.Platform,
		arg.CoveredStart,
		arg.CoveredEnd,
	)
	return err
}

const getAnalyticsCoverageRanges = `-- name: GetAnalyticsCoverageRanges :many
SELECT covered_start, covered_end FROM analytics_coverage_ranges
WHERE user_id = $1 AND platform = $2
ORDER BY covered_start
`

type GetAnalyticsCoverageRangesParams struct {
	UserID   string
	Platform string
}

type GetAnalyticsCoverageRangesRow struct {
	CoveredStart time.Time
	CoveredEnd   time.Time
}

func (q *Queries) GetAnalyticsCoverageRanges(ctx context.Context, arg GetAnalyticsCoverageRangesParams) ([]GetAnalyticsCoverageRangesRow, error) {
	rows, err := q.db.QueryContext(ctx, getAnalyticsCoverageRanges, arg.UserID, arg.Platform)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	var items []GetAnalyticsCoverageRangesRow
	for rows.Next() {
		var i GetAnalyticsCoverageRangesRow
		if err := rows.Scan(&i.CoveredStart, &i.CoveredEnd); 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
}

const insertAnalyticsCoverageRange = `-- name: InsertAnalyticsCoverageRange :exec
INSERT INTO analytics_coverage_ranges (user_id, platform, covered_start, covered_end, updated_at)
VALUES ($1, $2, $3, $4, now())
ON CONFLICT (user_id, platform, covered_start, covered_end)
DO UPDATE SET updated_at = now()
`

type InsertAnalyticsCoverageRangeParams struct {
	UserID       string
	Platform     string
	CoveredStart time.Time
	CoveredEnd   time.Time
}

func (q *Queries) InsertAnalyticsCoverageRange(ctx context.Context, arg InsertAnalyticsCoverageRangeParams) error {
	_, err := q.db.ExecContext(ctx, insertAnalyticsCoverageRange,
		arg.UserID,
		arg.Platform,
		arg.CoveredStart,
		arg.CoveredEnd,
	)
	return err
}