| 2042 | } |
| 2043 | |
| 2044 | func (c *unixSocketClient) NetworkThreadMessages( |
| 2045 | ctx context.Context, |
| 2046 | query NetworkConversationMessagesQuery, |
| 2047 | ) ([]NetworkConversationMessageRecord, error) { |
| 2048 | path, err := networkThreadMessagesPath(query.WorkspaceRef, query.Channel, query.ThreadID) |
| 2049 | if err != nil { |
| 2050 | return nil, err |
| 2051 | } |
| 2052 | var response struct { |
| 2053 | Messages []NetworkConversationMessageRecord `json:"messages"` |
| 2054 | } |
| 2055 | if err := c.doJSON( |
| 2056 | ctx, |
| 2057 | http.MethodGet, |
| 2058 | path, |
| 2059 | networkConversationMessagesValues(query), |
| 2060 | nil, |
| 2061 | &response, |
| 2062 | ); err != nil { |
| 2063 | return nil, err |
| 2064 | } |
| 2065 | return response.Messages, nil |
| 2066 | } |
| 2067 | |
| 2068 | func (c *unixSocketClient) NetworkDirects( |
| 2069 | ctx context.Context, |