diff options
| author | adamdottv <[email protected]> | 2025-05-29 15:41:13 -0500 |
|---|---|---|
| committer | adamdottv <[email protected]> | 2025-05-29 15:41:13 -0500 |
| commit | 4818bc542611b3ab554824fece8a071b0ac6307b (patch) | |
| tree | cddbdf77119ba15a86368a4027130baeb9ae333c /internal/db/messages.sql.go | |
| parent | 8a8c6b14afe8edd71f19d1d6054e0eac51d4a3ae (diff) | |
| download | opencode-4818bc542611b3ab554824fece8a071b0ac6307b.tar.gz opencode-4818bc542611b3ab554824fece8a071b0ac6307b.zip | |
wip: refactoring tui
Diffstat (limited to 'internal/db/messages.sql.go')
| -rw-r--r-- | internal/db/messages.sql.go | 199 |
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 -} |
