ws

package

v0.0.0-...-b8ee67f Latest Latest Go to latest Published: Sep 12, 2024 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

View Source

const HmacQuery = "hmac"

View Source

const PAIR_CODE_LEN = 4

View Source

const PaircodeQuery = "paircode"

View Source

const PubkeyQuery = "pubkey"

View Source

const SaltQuery = "salt"

View Source

const StatusTimeoutError = websocket.StatusCode(3000)

This section is empty.

func GetJsonMessageBytes(messageRoute string, data interface{}) ([]byte, error)

func ParseTextMessage(message []byte) (string, []byte, error)

func ReadAndParseTextMessage(conn *websocket.Conn, route string, v interface{}) error

func Receive(sharePairCode string, url string, w io.Writer) error

func Send(shareCode string, url string, r io.Reader, size int64) error

type ClientInfo struct {
	PubKey []byte
	Salt   []byte
	Hmac   []byte
}

func NewClientInfoFromQueryString(query url.Values) (*ClientInfo, error)

func (info *ClientInfo) AddToQuery(query url.Values)

type ErrorMessage struct {
	Error string
}

type WsReceiveHandler struct {
	// contains filtered or unexported fields
}

func NewWsReceiveHandler(sharePairCode string, addr string) (*WsReceiveHandler, error)

func (h *WsReceiveHandler) Read(p []byte) (int, error)

type WsSenderHandler struct {
	// contains filtered or unexported fields
}

func NewWsSendHandler(shareCode string, addr string) (*WsSenderHandler, error)

func (s *WsSenderHandler) Write(p []byte) (int, error)