| 2131 | } |
| 2132 | |
| 2133 | func (c *unixSocketClient) NetworkDirectMessages( |
| 2134 | ctx context.Context, |
| 2135 | query NetworkConversationMessagesQuery, |
| 2136 | ) ([]NetworkConversationMessageRecord, error) { |
| 2137 | path, err := networkDirectMessagesPath(query.WorkspaceRef, query.Channel, query.DirectID) |
| 2138 | if err != nil { |
| 2139 | return nil, err |
| 2140 | } |
| 2141 | var response struct { |
| 2142 | Messages []NetworkConversationMessageRecord `json:"messages"` |
| 2143 | } |
| 2144 | if err := c.doJSON( |
| 2145 | ctx, |
| 2146 | http.MethodGet, |
| 2147 | path, |
| 2148 | networkConversationMessagesValues(query), |
| 2149 | nil, |
| 2150 | &response, |
| 2151 | ); err != nil { |
| 2152 | return nil, err |
| 2153 | } |
| 2154 | return response.Messages, nil |
| 2155 | } |
| 2156 | |
| 2157 | func (c *unixSocketClient) NetworkWork( |
| 2158 | ctx context.Context, |