ChatQueuedMessage converts a queued message to its SDK representation.
(message database.ChatQueuedMessage)
| 1614 | |
| 1615 | // ChatQueuedMessage converts a queued message to its SDK representation. |
| 1616 | func ChatQueuedMessage(message database.ChatQueuedMessage) codersdk.ChatQueuedMessage { |
| 1617 | // Queued messages are always written by current code via |
| 1618 | // MarshalParts, so they are always current content version. |
| 1619 | parts, err := chatMessageParts(database.ChatMessage{ |
| 1620 | Role: database.ChatMessageRoleUser, |
| 1621 | Content: pqtype.NullRawMessage{ |
| 1622 | RawMessage: message.Content, |
| 1623 | Valid: len(message.Content) > 0, |
| 1624 | }, |
| 1625 | ContentVersion: chatprompt.CurrentContentVersion, |
| 1626 | }) |
| 1627 | if err != nil { |
| 1628 | parts = nil |
| 1629 | } |
| 1630 | |
| 1631 | return codersdk.ChatQueuedMessage{ |
| 1632 | ID: message.ID, |
| 1633 | ChatID: message.ChatID, |
| 1634 | ModelConfigID: nullUUIDPtr(message.ModelConfigID), |
| 1635 | Content: parts, |
| 1636 | CreatedAt: message.CreatedAt, |
| 1637 | } |
| 1638 | } |
| 1639 | |
| 1640 | // ChatQueuedMessages converts a slice of database queued messages |
| 1641 | // to their SDK representation. |