Method handleNetworkPeers

internal/extension/host_api_network.go:72–96

(ctx context.Context, raw json.RawMessage)

}

func (h *HostAPIHandler) handleNetworkPeers(ctx context.Context, raw json.RawMessage) (any, error) {
	var params extensioncontract.NetworkPeersParams
	if err := decodeHostAPIParams(raw, &params); err != nil {
		return nil, err
	}
	service, err := h.requireHostAPINetworkService()
	if err != nil {
		return nil, err
	}
	channel := strings.TrimSpace(params.Channel)
	if channel != "" {
		if err := network.ValidateChannel(channel); err != nil {
			return nil, invalidParamsRPCError(err)
		}
	}
	workspaceID, err := h.hostAPINetworkWorkspaceID(ctx, params.WorkspaceID)
	if err != nil {
		return nil, err
	}
	peers, err := service.ListPeers(ctx, workspaceID, channel)
	if err != nil {
		return nil, mapHostAPINetworkRPCError(err)
	}
	return hostAPINetworkPeerPayloads(peers), nil
}

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