diff --git a/events.go b/events.go deleted file mode 100644 index 7043979..0000000 --- a/events.go +++ /dev/null @@ -1,11 +0,0 @@ -package main - -import ( - "mmaschedule-go/events" - "mmaschedule-go/scraper" -) - -func stuff(db events.DbEvent) { - e := scraper.Event{} - db.ReadData(&e) -} diff --git a/events/db.go b/events/db.go deleted file mode 100644 index ad532cb..0000000 --- a/events/db.go +++ /dev/null @@ -1,31 +0,0 @@ -// 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, - } -} diff --git a/events/events.go b/events/events.go deleted file mode 100644 index df2b301..0000000 --- a/events/events.go +++ /dev/null @@ -1,43 +0,0 @@ -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 -} diff --git a/events/models.go b/events/models.go deleted file mode 100644 index 2507e4a..0000000 --- a/events/models.go +++ /dev/null @@ -1,11 +0,0 @@ -// 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"` -} diff --git a/events/query.sql.go b/events/query.sql.go deleted file mode 100644 index 812dae9..0000000 --- a/events/query.sql.go +++ /dev/null @@ -1,60 +0,0 @@ -// 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 -} diff --git a/sqlite/query.sql b/sql/query.sql similarity index 100% rename from sqlite/query.sql rename to sql/query.sql diff --git a/sqlite/schema.sql b/sql/schema.sql similarity index 100% rename from sqlite/schema.sql rename to sql/schema.sql