zoom_repo.go RawHistoryFolder

1package sqlite
2
3import (
4	"context"
5	"database/sql"
6	"errors"
7
8	"github.com/bnema/dumber/internal/domain/entity"
9	"github.com/bnema/dumber/internal/domain/repository"
10	"github.com/bnema/dumber/internal/infrastructure/persistence/sqlite/sqlc"
11	"github.com/bnema/dumber/internal/logging"
12)
13
14type zoomRepo struct {
15	queries *sqlc.Queries
16}
17
18// NewZoomRepository creates a new SQLite-backed zoom repository.
19func NewZoomRepository(db *sql.DB) repository.ZoomRepository {
20	return &zoomRepo{queries: sqlc.New(db)}
21}
22
23func (r *zoomRepo) Get(ctx context.Context, domain string) (*entity.ZoomLevel, error) {
24	log := logging.FromContext(ctx)
25	log.Debug().Str("domain", domain).Msg("getting zoom level")
26
27	row, err := r.queries.GetZoomLevel(ctx, domain)
28	if err != nil {
29		if errors.Is(err, sql.ErrNoRows) {
30			return nil, nil
31		}
32		return nil, err
33	}
34	return zoomFromRow(row), nil
35}
36
37func (r *zoomRepo) Set(ctx context.Context, level *entity.ZoomLevel) error {
38	log := logging.FromContext(ctx)
39	log.Debug().Str("domain", level.Domain).Float64("factor", level.ZoomFactor).Msg("setting zoom level")
40
41	return r.queries.SetZoomLevel(ctx, sqlc.SetZoomLevelParams{
42		Domain:     level.Domain,
43		ZoomFactor: level.ZoomFactor,
44	})
45}
46
47func (r *zoomRepo) Delete(ctx context.Context, domain string) error {
48	return r.queries.DeleteZoomLevel(ctx, domain)
49}
50
51func (r *zoomRepo) GetAll(ctx context.Context) ([]*entity.ZoomLevel, error) {
52	rows, err := r.queries.ListZoomLevels(ctx)
53	if err != nil {
54		return nil, err
55	}
56
57	levels := make([]*entity.ZoomLevel, len(rows))
58	for i, row := range rows {
59		levels[i] = zoomFromRow(row)
60	}
61	return levels, nil
62}
63
64func zoomFromRow(row sqlc.ZoomLevel) *entity.ZoomLevel {
65	return &entity.ZoomLevel{
66		Domain:     row.Domain,
67		ZoomFactor: row.ZoomFactor,
68		UpdatedAt:  row.UpdatedAt.Time,
69	}
70}