Method handleNetworkDirects

internal/extension/host_api_network.go:191–221

(ctx context.Context, raw json.RawMessage)

}

func (h *HostAPIHandler) handleNetworkDirects(ctx context.Context, raw json.RawMessage) (any, error) {
	var params extensioncontract.NetworkDirectsParams
	if err := decodeHostAPIParams(raw, &params); err != nil {
		return nil, err
	}
	networkStore, err := h.requireHostAPINetworkStore()
	if err != nil {
		return nil, err
	}
	channel, err := hostAPINetworkChannel(params.Channel)
	if err != nil {
		return nil, err
	}
	query, err := hostAPINetworkDirectRoomQuery(params.Limit, params.After, params.PeerID)
	if err != nil {
		return nil, err
	}
	workspaceID, err := h.hostAPINetworkWorkspaceID(ctx, params.WorkspaceID)
	if err != nil {
		return nil, err
	}
	directs, err := networkStore.ListDirectRooms(
		ctx,
		store.NetworkChannelRef{WorkspaceID: workspaceID, Channel: channel},
		query,
	)
	if err != nil {
		return nil, mapHostAPINetworkRPCError(err)
	}
	return hostAPINetworkDirectRoomPayloads(directs), nil
}

func (h *HostAPIHandler) handleNetworkDirectResolve(ctx context.Context, raw json.RawMessage) (any, error) {
	var params extensioncontract.NetworkDirectResolveParams