| 2066 | } |
| 2067 | |
| 2068 | func (c *unixSocketClient) NetworkDirects( |
| 2069 | ctx context.Context, |
| 2070 | query NetworkDirectsQuery, |
| 2071 | ) ([]NetworkDirectRoomRecord, error) { |
| 2072 | channel, err := requireNetworkPathValue("channel", query.Channel) |
| 2073 | if err != nil { |
| 2074 | return nil, err |
| 2075 | } |
| 2076 | var response struct { |
| 2077 | Directs []NetworkDirectRoomRecord `json:"directs"` |
| 2078 | } |
| 2079 | path, err := networkChannelPath(query.WorkspaceRef, channel) |
| 2080 | if err != nil { |
| 2081 | return nil, err |
| 2082 | } |
| 2083 | path += "/directs" |
| 2084 | if err := c.doJSON(ctx, http.MethodGet, path, networkDirectsValues(query), nil, &response); err != nil { |
| 2085 | return nil, err |
| 2086 | } |
| 2087 | return response.Directs, nil |
| 2088 | } |
| 2089 | |
| 2090 | func (c *unixSocketClient) NetworkDirectResolve( |
| 2091 | ctx context.Context, |