messages

Documentation

Overview

import "github.com/justhx0r/snowflake/common/messages"

import "github.com/justhx0r/snowflake/common/messages"

Index

• Constants
• Variables
• func DecodeAnswerRequest(data []byte) (string, string, error)
• func DecodeAnswerResponse(data []byte) (bool, error)
• func DecodePollResponse(data []byte) (string, string, error)
• func DecodePollResponseWithRelayURL(data []byte) (string, string, string, error)
• func DecodeProxyPollRequest(data []byte) (sid string, proxyType string, natType string, clients int, err error)
• func DecodeProxyPollRequestWithRelayPrefix(data []byte) (sid string, proxyType string, natType string, clients int, relayPrefix string, ...)
• func EncodeAnswerRequest(answer string, sid string) ([]byte, error)
• func EncodeAnswerResponse(success bool) ([]byte, error)
• func EncodePollResponse(offer string, success bool, natType string) ([]byte, error)
• func EncodePollResponseWithRelayURL(offer string, success bool, natType, relayURL, failReason string) ([]byte, error)
• func EncodeProxyPollRequest(sid string, proxyType string, natType string, clients int) ([]byte, error)
• func EncodeProxyPollRequestWithRelayPrefix(sid string, proxyType string, natType string, clients int, relayPattern string) ([]byte, error)
• type Arg
• type ClientPollRequest
  • func DecodeClientPollRequest(data []byte) (*ClientPollRequest, error)
  • func (req *ClientPollRequest) EncodeClientPollRequest() ([]byte, error)
• type ClientPollResponse
  • func DecodeClientPollResponse(data []byte) (*ClientPollResponse, error)
  • func (resp *ClientPollResponse) EncodePollResponse() ([]byte, error)
• type ProxyAnswerRequest
• type ProxyAnswerResponse
• type ProxyPollRequest
• type ProxyPollResponse

Constants

const ClientVersion = "1.0"

const (
	ProxyUnknown = "unknown"
)

Variables

var (
	ErrBadRequest = errors.New("bad request")
	ErrInternal   = errors.New("internal error")
	ErrExtraInfo  = errors.New("client sent extra info")

	StrTimedOut  = "timed out waiting for answer!"
	StrNoProxies = "no snowflake proxies currently available"
)

var KnownProxyTypes = map[string]bool{
	"standalone": true,
	"webext":     true,
	"badge":      true,
	"iptproxy":   true,
}

Functions

func DecodeAnswerRequest

func DecodeAnswerRequest(data []byte) (string, string, error)

Returns the sdp answer and proxy sid

func DecodeAnswerResponse

func DecodeAnswerResponse(data []byte) (bool, error)

func DecodePollResponse

func DecodePollResponse(data []byte) (string, string, error)

func DecodePollResponseWithRelayURL

func DecodePollResponseWithRelayURL(data []byte) (string, string, string, error)

Decodes a poll response from the broker and returns an offer and the client's NAT type If there is a client match, the returned offer string will be non-empty

func DecodeProxyPollRequest

func DecodeProxyPollRequest(data []byte) (sid string, proxyType string, natType string, clients int, err error)

func DecodeProxyPollRequestWithRelayPrefix

func DecodeProxyPollRequestWithRelayPrefix(data []byte) (
	sid string, proxyType string, natType string, clients int, relayPrefix string, relayPrefixAware bool, err error)

Decodes a poll message from a snowflake proxy and returns the sid, proxy type, nat type and clients of the proxy on success and an error if it failed

func EncodeAnswerRequest

func EncodeAnswerRequest(answer string, sid string) ([]byte, error)

func EncodeAnswerResponse

func EncodeAnswerResponse(success bool) ([]byte, error)

func EncodePollResponse

func EncodePollResponse(offer string, success bool, natType string) ([]byte, error)

func EncodePollResponseWithRelayURL

func EncodePollResponseWithRelayURL(offer string, success bool, natType, relayURL, failReason string) ([]byte, error)

func EncodeProxyPollRequest

func EncodeProxyPollRequest(sid string, proxyType string, natType string, clients int) ([]byte, error)

func EncodeProxyPollRequestWithRelayPrefix

func EncodeProxyPollRequestWithRelayPrefix(sid string, proxyType string, natType string, clients int, relayPattern string) ([]byte, error)

Types

type Arg

type Arg struct {
	Body       []byte
	RemoteAddr string
}

type ClientPollRequest

type ClientPollRequest struct {
	Offer       string `json:"offer"`
	NAT         string `json:"nat"`
	Fingerprint string `json:"fingerprint"`
}

func DecodeClientPollRequest

func DecodeClientPollRequest(data []byte) (*ClientPollRequest, error)

Decodes a poll message from a snowflake client

func (*ClientPollRequest) EncodeClientPollRequest

func (req *ClientPollRequest) EncodeClientPollRequest() ([]byte, error)

Encodes a poll message from a snowflake client

type ClientPollResponse

type ClientPollResponse struct {
	Answer string `json:"answer,omitempty"`
	Error  string `json:"error,omitempty"`
}

func DecodeClientPollResponse

func DecodeClientPollResponse(data []byte) (*ClientPollResponse, error)

Decodes a poll response for a snowflake client If the Error field is empty, the Answer should be non-empty

func (*ClientPollResponse) EncodePollResponse

func (resp *ClientPollResponse) EncodePollResponse() ([]byte, error)

Encodes a poll response for a snowflake client

type ProxyAnswerRequest

type ProxyAnswerRequest struct {
	Version string
	Sid     string
	Answer  string
}

type ProxyAnswerResponse

type ProxyAnswerResponse struct {
	Status string
}

type ProxyPollRequest

type ProxyPollRequest struct {
	Sid     string
	Version string
	Type    string
	NAT     string
	Clients int

	AcceptedRelayPattern *string
}

type ProxyPollResponse

type ProxyPollResponse struct {
	Status string
	Offer  string
	NAT    string

	RelayURL string
}