summaryrefslogtreecommitdiffhomepage
path: root/internal/db/messages.sql.go
diff options
context:
space:
mode:
authoradamdottv <[email protected]>2025-05-29 15:41:13 -0500
committeradamdottv <[email protected]>2025-05-29 15:41:13 -0500
commit4818bc542611b3ab554824fece8a071b0ac6307b (patch)
treecddbdf77119ba15a86368a4027130baeb9ae333c /internal/db/messages.sql.go
parent8a8c6b14afe8edd71f19d1d6054e0eac51d4a3ae (diff)
downloadopencode-4818bc542611b3ab554824fece8a071b0ac6307b.tar.gz
opencode-4818bc542611b3ab554824fece8a071b0ac6307b.zip
wip: refactoring tui
Diffstat (limited to 'internal/db/messages.sql.go')
-rw-r--r--internal/db/messages.sql.go199
1 files changed, 0 insertions, 199 deletions
diff --git a/internal/db/messages.sql.go b/internal/db/messages.sql.go
deleted file mode 100644
index 57d940872..000000000
--- a/internal/db/messages.sql.go
+++ /dev/null
@@ -1,199 +0,0 @@
-// Code generated by sqlc. DO NOT EDIT.
-// versions:
-// sqlc v1.29.0
-// source: messages.sql
-
-package db
-
-import (
- "context"
- "database/sql"
-)
-
-const createMessage = `-- name: CreateMessage :one
-INSERT INTO messages (
- id,
- session_id,
- role,
- parts,
- model
-) VALUES (
- ?, ?, ?, ?, ?
-)
-RETURNING id, session_id, role, parts, model, created_at, updated_at, finished_at
-`
-
-type CreateMessageParams struct {
- ID string `json:"id"`
- SessionID string `json:"session_id"`
- Role string `json:"role"`
- Parts string `json:"parts"`
- Model sql.NullString `json:"model"`
-}
-
-func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (Message, error) {
- row := q.queryRow(ctx, q.createMessageStmt, createMessage,
- arg.ID,
- arg.SessionID,
- arg.Role,
- arg.Parts,
- arg.Model,
- )
- var i Message
- err := row.Scan(
- &i.ID,
- &i.SessionID,
- &i.Role,
- &i.Parts,
- &i.Model,
- &i.CreatedAt,
- &i.UpdatedAt,
- &i.FinishedAt,
- )
- return i, err
-}
-
-const deleteMessage = `-- name: DeleteMessage :exec
-DELETE FROM messages
-WHERE id = ?
-`
-
-func (q *Queries) DeleteMessage(ctx context.Context, id string) error {
- _, err := q.exec(ctx, q.deleteMessageStmt, deleteMessage, id)
- return err
-}
-
-const deleteSessionMessages = `-- name: DeleteSessionMessages :exec
-DELETE FROM messages
-WHERE session_id = ?
-`
-
-func (q *Queries) DeleteSessionMessages(ctx context.Context, sessionID string) error {
- _, err := q.exec(ctx, q.deleteSessionMessagesStmt, deleteSessionMessages, sessionID)
- return err
-}
-
-const getMessage = `-- name: GetMessage :one
-SELECT id, session_id, role, parts, model, created_at, updated_at, finished_at
-FROM messages
-WHERE id = ? LIMIT 1
-`
-
-func (q *Queries) GetMessage(ctx context.Context, id string) (Message, error) {
- row := q.queryRow(ctx, q.getMessageStmt, getMessage, id)
- var i Message
- err := row.Scan(
- &i.ID,
- &i.SessionID,
- &i.Role,
- &i.Parts,
- &i.Model,
- &i.CreatedAt,
- &i.UpdatedAt,
- &i.FinishedAt,
- )
- return i, err
-}
-
-const listMessagesBySession = `-- name: ListMessagesBySession :many
-SELECT id, session_id, role, parts, model, created_at, updated_at, finished_at
-FROM messages
-WHERE session_id = ?
-ORDER BY created_at ASC
-`
-
-func (q *Queries) ListMessagesBySession(ctx context.Context, sessionID string) ([]Message, error) {
- rows, err := q.query(ctx, q.listMessagesBySessionStmt, listMessagesBySession, sessionID)
- if err != nil {
- return nil, err
- }
- defer rows.Close()
- items := []Message{}
- for rows.Next() {
- var i Message
- if err := rows.Scan(
- &i.ID,
- &i.SessionID,
- &i.Role,
- &i.Parts,
- &i.Model,
- &i.CreatedAt,
- &i.UpdatedAt,
- &i.FinishedAt,
- ); 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 listMessagesBySessionAfter = `-- name: ListMessagesBySessionAfter :many
-SELECT id, session_id, role, parts, model, created_at, updated_at, finished_at
-FROM messages
-WHERE session_id = ? AND created_at > ?
-ORDER BY created_at ASC
-`
-
-type ListMessagesBySessionAfterParams struct {
- SessionID string `json:"session_id"`
- CreatedAt string `json:"created_at"`
-}
-
-func (q *Queries) ListMessagesBySessionAfter(ctx context.Context, arg ListMessagesBySessionAfterParams) ([]Message, error) {
- rows, err := q.query(ctx, q.listMessagesBySessionAfterStmt, listMessagesBySessionAfter, arg.SessionID, arg.CreatedAt)
- if err != nil {
- return nil, err
- }
- defer rows.Close()
- items := []Message{}
- for rows.Next() {
- var i Message
- if err := rows.Scan(
- &i.ID,
- &i.SessionID,
- &i.Role,
- &i.Parts,
- &i.Model,
- &i.CreatedAt,
- &i.UpdatedAt,
- &i.FinishedAt,
- ); 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 updateMessage = `-- name: UpdateMessage :exec
-UPDATE messages
-SET
- parts = ?,
- finished_at = ?,
- updated_at = strftime('%Y-%m-%dT%H:%M:%f000Z', 'now')
-WHERE id = ?
-`
-
-type UpdateMessageParams struct {
- Parts string `json:"parts"`
- FinishedAt sql.NullString `json:"finished_at"`
- ID string `json:"id"`
-}
-
-func (q *Queries) UpdateMessage(ctx context.Context, arg UpdateMessageParams) error {
- _, err := q.exec(ctx, q.updateMessageStmt, updateMessage, arg.Parts, arg.FinishedAt, arg.ID)
- return err
-}