idk what I was doing before

events/db.go

@@ -0,0 +1,31 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.26.0
+
+package events
+
+import (
+	"context"
+	"database/sql"
+)
+
+type DBTX interface {
+	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
+	PrepareContext(context.Context, string) (*sql.Stmt, error)
+	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
+	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
+}
+
+func New(db DBTX) *Queries {
+	return &Queries{db: db}
+}
+
+type Queries struct {
+	db DBTX
+}
+
+func (q *Queries) WithTx(tx *sql.Tx) *Queries {
+	return &Queries{
+		db: tx,
+	}
+}

events/events.go

@@ -0,0 +1,43 @@
+package events
+
+import (
+	"bytes"
+	"encoding/gob"
+)
+
+func decode(data []byte, value any) error {
+	buf := bytes.NewBuffer(data)
+	dec := gob.NewDecoder(buf)
+	return dec.Decode(value)
+}
+
+func encode(value any) ([]byte, error) {
+	var buf bytes.Buffer
+	enc := gob.NewEncoder(&buf)
+	err := enc.Encode(value)
+	return buf.Bytes(), err
+}
+
+func (e *DbEvent) ReadData(value any) error {
+	return decode(e.Data, value)
+}
+
+func (e *DbEvent) WriteData(value any) error {
+	b, err := encode(value)
+	if err == nil {
+		e.Data = b
+	}
+	return err
+}
+
+func (e *DbEvent) ReadHistory(value any) error {
+	return decode(e.History, value)
+}
+
+func (e *DbEvent) WriteHistory(value any) error {
+	b, err := encode(value)
+	if err == nil {
+		e.History = b
+	}
+	return err
+}

events/models.go

@@ -0,0 +1,11 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.26.0
+
+package events
+
+type DbEvent struct {
+	Url     string `json:"url"`
+	Data    []byte `json:"data"`
+	History []byte `json:"history"`
+}

events/query.sql.go

@@ -0,0 +1,60 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+//   sqlc v1.26.0
+// source: query.sql
+
+package events
+
+import (
+	"context"
+)
+
+const createEvent = `-- name: CreateEvent :exec
+INSERT INTO
+  db_events (url)
+VALUES
+  (?) ON CONFLICT (url) DO NOTHING
+`
+
+func (q *Queries) CreateEvent(ctx context.Context, url string) error {
+	_, err := q.db.ExecContext(ctx, createEvent, url)
+	return err
+}
+
+const getEvent = `-- name: GetEvent :one
+SELECT
+  url, data, history
+FROM
+  db_events
+WHERE
+  url = ?
+LIMIT
+  1
+`
+
+func (q *Queries) GetEvent(ctx context.Context, url string) (DbEvent, error) {
+	row := q.db.QueryRowContext(ctx, getEvent, url)
+	var i DbEvent
+	err := row.Scan(&i.Url, &i.Data, &i.History)
+	return i, err
+}
+
+const updateEvent = `-- name: UpdateEvent :exec
+UPDATE db_events
+set
+  data = ?,
+  history = ?
+WHERE
+  url = ?
+`
+
+type UpdateEventParams struct {
+	Data    []byte `json:"data"`
+	History []byte `json:"history"`
+	Url     string `json:"url"`
+}
+
+func (q *Queries) UpdateEvent(ctx context.Context, arg UpdateEventParams) error {
+	_, err := q.db.ExecContext(ctx, updateEvent, arg.Data, arg.History, arg.Url)
+	return err
+}