diff options
| author | Kyren223 <Kyren223@proton.me> | 2024-11-02 13:13:11 +0200 |
|---|---|---|
| committer | Kyren223 <Kyren223@proton.me> | 2024-11-02 13:18:21 +0200 |
| commit | 7ad5f5aa60cc940dbd4c6ec6cb091e7214a3fdb4 (patch) | |
| tree | 4a24d486c9257bae5dc11623832e158fe3591625 /internal/data/messages.sql.go | |
| parent | 8e3d1c5beebac25c15b348b073b253ec30c1b3f4 (diff) | |
feat(data): update message queries
Diffstat (limited to 'internal/data/messages.sql.go')
| -rw-r--r-- | internal/data/messages.sql.go | 42 |
1 files changed, 5 insertions, 37 deletions
diff --git a/internal/data/messages.sql.go b/internal/data/messages.sql.go index 38d2b24..e84b306 100644 --- a/internal/data/messages.sql.go +++ b/internal/data/messages.sql.go @@ -11,45 +11,11 @@ import ( "github.com/kyren223/eko/pkg/snowflake" ) -const createDirectMessage = `-- name: CreateDirectMessage :one -INSERT INTO messages ( - id, content, sender_id, receiver_id -) VALUES ( - ?, ?, ?, ? -) -RETURNING id, sender_id, content, frequency_id, receiver_id -` - -type CreateDirectMessageParams struct { - ID snowflake.ID - Content string - SenderID snowflake.ID - ReceiverID snowflake.ID -} - -func (q *Queries) CreateDirectMessage(ctx context.Context, arg CreateDirectMessageParams) (Message, error) { - row := q.db.QueryRowContext(ctx, createDirectMessage, - arg.ID, - arg.Content, - arg.SenderID, - arg.ReceiverID, - ) - var i Message - err := row.Scan( - &i.ID, - &i.SenderID, - &i.Content, - &i.FrequencyID, - &i.ReceiverID, - ) - return i, err -} - const createMessage = `-- name: CreateMessage :one INSERT INTO messages ( - id, content, sender_id, frequency_id + id, content, sender_id, frequency_id, receiver_id ) VALUES ( - ?, ?, ?, ? + ?, ?, ?, ?, ? ) RETURNING id, sender_id, content, frequency_id, receiver_id ` @@ -58,7 +24,8 @@ type CreateMessageParams struct { ID snowflake.ID Content string SenderID snowflake.ID - FrequencyID snowflake.ID + FrequencyID *snowflake.ID + ReceiverID *snowflake.ID } func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (Message, error) { @@ -67,6 +34,7 @@ func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (M arg.Content, arg.SenderID, arg.FrequencyID, + arg.ReceiverID, ) var i Message err := row.Scan( |