xchg

Sep 25, 2023

Changes in this version

+ type DefaultLogger struct

+ func NewDefaultLogger() *DefaultLogger

+ func (c *DefaultLogger) Println(args ...interface{})

+ type Logger interface

+ Println func(v ...interface{})

Sep 18, 2023

Changes in this version

type Network

+ Source string

type RemotePeer

+ func (c *RemotePeer) Check(peerContext PeerContext, frame20 *Transaction, network *Network, ...) error

+ func (c *RemotePeer) Post(url, contentType string, body io.Reader, host string) (resp *http.Response, err error)

+ func (c *RemotePeer) Send(peerContext PeerContext, network *Network, tr *Transaction) (err error)

May 9, 2023

Changes in this version

type Network

+ func (c *Network) GetLocalNodes() []string

+ func (c *Network) IsLocalNode(nodeAddress string) bool

type Transaction

+ FromLocalNode bool

Jan 11, 2023

Changes in this version

type Peer

+ func (c *Peer) UDPConn() net.PacketConn

+ type PeerContext struct

+ type PeerTransport interface

+ Start func(peerProcessor PeerProcessor, localAddressBS []byte) error

+ Stop func() error

type RemotePeerHttp

+ func (c *RemotePeerHttp) DeclareError(peerContext PeerContext, sentViaTransportMap map[string]struct{})

+ func (c *RemotePeerHttp) Id() string

+ func (c *RemotePeerHttp) SetRemoteUDPAddress(udpAddress *net.UDPAddr)

+ type RemotePeerTcp struct

+ func NewRemotePeerTcp() *RemotePeerTcp

+ func (c *RemotePeerTcp) Check(peerContext PeerContext, frame20 *Transaction, network *Network, ...) error

+ func (c *RemotePeerTcp) DeclareError(peerContext PeerContext, sentViaTransportMap map[string]struct{})

+ func (c *RemotePeerTcp) Id() string

+ func (c *RemotePeerTcp) Send(peerContext PeerContext, network *Network, tr *Transaction) error

+ func (c *RemotePeerTcp) SetRemoteUDPAddress(udpAddress *net.UDPAddr)

+ type RemotePeerTransport interface

+ Check func(peerContext PeerContext, frame20 *Transaction, network *Network, ...) error

+ DeclareError func(peerContext PeerContext, sentViaTransportMap map[string]struct{})

+ Id func() string

+ Send func(peerContext PeerContext, network *Network, tr *Transaction) error

+ SetRemoteUDPAddress func(udpAddress *net.UDPAddr)

type RemotePeerUdp

+ func (c *RemotePeerUdp) DeclareError(peerContext PeerContext, sentViaTransportMap map[string]struct{})

+ func (c *RemotePeerUdp) Id() string

+ func (c *RemotePeerUdp) SetRemoteUDPAddress(udpAddress *net.UDPAddr)

type Transaction

+ func (c *Transaction) DestAddressString() string

+ func (c *Transaction) SrcAddressString() string

Jan 9, 2023

Changes in this version

+ const INTERNAL_ERROR

type Peer

+ func (c *Peer) StartHttpOnlyLocalRouter() error

Nov 20, 2022

Changes in this version

+ const NetworkContainerDefault

type Network

+ func NetworkContainerLoadFromInternet() (network *Network, err error)

+ func NetworkContainerLoadStaticDefault() (network *Network, err error)

Nov 20, 2022

Changes in this version

type Network

+ InitialPoints []string

+ Timestamp int64

Nov 18, 2022

Changes in this version

+ const NetworkContainerEncryptedPrivateKey

+ const NetworkContainerFileNetwork

+ const NetworkContainerFileSignature

+ const NetworkContainerPublicKey

+ func NetworkContainerCreateKey(privateKeyPassword string) (encryptedPrivateKeyBase64 string, publicKeyBase64 string, err error)

+ func NetworkContainerMake(network *Network, encryptedPrivateKeyBase64 string, privateKeyPassword string) (resultZipFile []byte, err error)

type Network

+ func NetworkContainerLoad(zipFileBS []byte, publicKeyBase64 string) (network *Network, err error)

+ func NetworkContainerLoadDefault(zipFileBS []byte) (network *Network, err error)

type Transaction

+ ReceivedFrames []*Transaction

+ func (c *Transaction) AppendReceivedData(transaction *Transaction)

Nov 6, 2022

Changes in this version

type Peer

+ func (c *Peer) IsHttpEnabled() bool

+ func (c *Peer) IsUdpEnabled() bool

+ func (c *Peer) StartHttpOnly() error

+ func (c *Peer) StartUDPOnly() error

+ type PeerHttp struct

+ func NewPeerHttp() *PeerHttp

+ func (c *PeerHttp) Post(httpClient *http.Client, url, contentType string, body io.Reader, host string) (resp *http.Response, err error)

+ func (c *PeerHttp) Start(peerProcessor PeerProcessor, localAddressBS []byte) (err error)

+ func (c *PeerHttp) Stop() (err error)

+ type PeerProcessor interface

+ type PeerUdp struct

+ func NewPeerUdp() *PeerUdp

+ func (c *PeerUdp) Conn() (conn net.PacketConn)

+ func (c *PeerUdp) Start(peerProcessor PeerProcessor) (err error)

+ func (c *PeerUdp) Stop() (err error)

Nov 5, 2022

Changes in this version

+ func AddressBSForPublicKey(publicKey *rsa.PublicKey) []byte

+ func AddressBSForPublicKeyBS(publicKeyBS []byte) []byte

type Peer

+ func (c *Peer) Post(httpClient *http.Client, url, contentType string, body io.Reader, host string) (resp *http.Response, err error)

type RemotePeer

+ func (c *RemotePeer) RemoteAddress() string

+ type RemotePeerHttp struct

+ func NewRemotePeerHttp(nonces *Nonces, remoteAddress string, privateKey *rsa.PrivateKey) *RemotePeerHttp

+ func (c *RemotePeerHttp) Check()

+ func (c *RemotePeerHttp) Post(url, contentType string, body io.Reader, host string) (resp *http.Response, err error)

+ func (c *RemotePeerHttp) Send(frame []byte) error

+ func (c *RemotePeerHttp) SetConnectionPoint(routerHost string)

+ type RemotePeerUdp struct

+ func NewRemotePeerUdp(nonces *Nonces, remoteAddress string, privateKey *rsa.PrivateKey) *RemotePeerUdp

+ func (c *RemotePeerUdp) Check(conn net.PacketConn)

+ func (c *RemotePeerUdp) IsValid() (result bool)

+ func (c *RemotePeerUdp) ResetConnectionPoint()

+ func (c *RemotePeerUdp) Send(conn net.PacketConn, frame []byte) error

+ func (c *RemotePeerUdp) SetConnectionPoint(udpAddress *net.UDPAddr)

type Transaction

+ Appendix [28]byte

+ CRC uint32

+ DestAddress [AddressBytesSize]byte

+ Length uint32

+ Reserved10 byte

+ Reserved11 byte

+ Reserved12 byte

+ Reserved13 byte

+ Reserved14 byte

+ Reserved15 byte

+ Reserved9 byte

+ SrcAddress [AddressBytesSize]byte

Oct 9, 2022

Changes in this version

+ const ERR_XCHG_CL_CONN_AUTH_NO_REMOTE_PUBLIC_KEY

type Network

+ func NewNetworkLocalhost() *Network

+ func (c *Network) FlatListRandom() []string

+ type Nonces struct

+ func NewNonces(size int) *Nonces

+ func (c *Nonces) Check(nonce []byte) bool

+ func (c *Nonces) Next() [16]byte

type Peer

+ func (c *Peer) Network() *Network

Sep 17, 2022

Changes in this version

+ const ERR_XCHG_NOT_IMPLEMENTED

+ const FrameTypeCall

+ const FrameTypeResponse

+ const INPUT_BUFFER_SIZE

+ const PEER_UDP_END_PORT

+ const PEER_UDP_START_PORT

+ const UDP_PORT

+ func ConnectionPointString(remoteConnectionPoint *net.UDPAddr) string

+ func DecryptAESGCM(encryptedMessage []byte, key []byte) (decryptedMessage []byte, err error)

+ func EncryptAESGCM(decryptedMessage []byte, key []byte) (encryptedMessage []byte, err error)

+ func GenerateRSAKey() (privateKey *rsa.PrivateKey, err error)

+ func NewHost(address string) *host

+ func NewRange(prefix string) *rng

+ func PackBytes(data []byte) []byte

+ func RSAPublicKeyFromDer(publicKeyDer []byte) (publicKey *rsa.PublicKey, err error)

+ func RSAPublicKeyToDer(publicKey *rsa.PublicKey) (publicKeyDer []byte)

+ func UnpackBytes(zippedData []byte) (result []byte, err error)

+ type Network struct

+ EthAddress string

+ Gateways []*host

+ Name string

+ Ranges []*rng

+ SolAddress string

+ func NewNetwork() *Network

+ func NewNetworkDefault() *Network

+ func NewNetworkFromBytes(rawContent []byte) (*Network, error)

+ func NewNetworkFromFile(fileName string) (*Network, error)

+ func NewNetworkFromFileOrCreate(fileName string) (network *Network)

+ func NewNetworkFromInternet() *Network

+ func (c *Network) AddHostToRange(prefix string, address string)

+ func (c *Network) GetLocalIPs() (result []string)

+ func (c *Network) GetLocalPrefixes() []string

+ func (c *Network) GetNodesAddressesByAddress(address string) []string

+ func (c *Network) ReloadFromInternet()

+ func (c *Network) SaveToFile(fileName string) error

+ func (c *Network) String() string

+ type NonceGenerator struct

+ func NewNonceGenerator(size int) *NonceGenerator

+ func (c *NonceGenerator) Check(nonceBytes []byte) bool

+ func (c *NonceGenerator) Get() []byte

+ func (c *NonceGenerator) Init(size int)

+ type Peer struct

+ func NewPeer(privateKey *rsa.PrivateKey) *Peer

+ func (c *Peer) Call(remoteAddress string, authData string, function string, data []byte, ...) (result []byte, err error)

+ func (c *Peer) SetProcessor(processor ServerProcessor)

+ func (c *Peer) Start() (err error)

+ func (c *Peer) Stop() (err error)

+ type RemotePeer struct

+ func NewRemotePeer(remoteAddress string, authData string, privateKey *rsa.PrivateKey) *RemotePeer

+ func (c *RemotePeer) Call(conn net.PacketConn, function string, data []byte, timeout time.Duration) (result []byte, err error)

+ func (c *RemotePeer) InternetConnectionPoint() string

+ func (c *RemotePeer) LANConnectionPoint() string

+ func (c *RemotePeer) Reset()

+ type ServerProcessor interface

+ ServerProcessorAuth func(authData []byte) (err error)

+ ServerProcessorCall func(function string, parameter []byte) (response []byte, err error)

+ type Session struct

+ type SnakeCounter struct

+ func NewSnakeCounter(size int, initValue int) *SnakeCounter

+ func (c *SnakeCounter) LastProcessed() int

+ func (c *SnakeCounter) Print()

+ func (c *SnakeCounter) TestAndDeclare(counter int) error

type Transaction

+ Reserved2 byte

+ Reserved3 byte

+ Reserved4 uint32

+ Reserved5 uint64

+ Status byte

+ func (c *Transaction) Marshal() (result []byte)

Sep 4, 2022

Changes in this version

+ const FrameSetOTP

type Connection

+ func (c *Connection) MakeUDPHole(address string, otp []byte)

Aug 26, 2022

Changes in this version

+ type ConnectionsPerformanceCounters struct

+ InTrafficCounter uint64

+ Init1Counter uint64

+ Init4Counter uint64

+ Init5Counter uint64

+ OutTrafficCounter uint64

Aug 24, 2022

Changes in this version

type Transaction

+ Offset uint32

+ ReceivedDataLen int

+ TotalSize uint32

Aug 24, 2022

Changes in this version

type Transaction

+ WaitingResponseFromSID uint64

Aug 23, 2022

Changes in this version

+ const ERR_XCHG_CL_CONN_CALL_UNPACK

+ const ERR_XCHG_SRV_CONN_UNPACK

Aug 23, 2022

Changes in this version

+ const ERR_XCHG_CL_CONN_CALL_DECRYPT

Aug 18, 2022

Changes in this version

+ const AddressBytesSize

+ const AddressSize

+ const ERR_XCHG_CL_CONN_AUTH_AUTH

+ const ERR_XCHG_CL_CONN_AUTH_DECR

+ const ERR_XCHG_CL_CONN_AUTH_ENC

+ const ERR_XCHG_CL_CONN_AUTH_GET_NONCE

+ const ERR_XCHG_CL_CONN_AUTH_NO_LOCAL_PRIVATE_KEY

+ const ERR_XCHG_CL_CONN_AUTH_WRONG_AUTH_RESP_LEN

+ const ERR_XCHG_CL_CONN_AUTH_WRONG_NONCE_LEN

+ const ERR_XCHG_CL_CONN_CALL_FROM_PEER

+ const ERR_XCHG_CL_CONN_CALL_NO_LOCAL_PRIVATE_KEY

+ const ERR_XCHG_CL_CONN_CALL_NO_ROUTE_TO_PEER

+ const ERR_XCHG_CL_CONN_CALL_RESP_LEN

+ const ERR_XCHG_CL_CONN_CALL_RESP_STATUS_BYTE

+ const ERR_XCHG_CL_CONN_CALL_SEARCHING_NODE

+ const ERR_XCHG_CL_CONN_CALL_WRONG_FUNCTION_LEN

+ func NeedToChangeNode(err error) bool

+ func NeedToMakeSession(err error) bool

Aug 16, 2022

Changes in this version

+ const ERR_SIMPLE_SERVER_FUNC_IS_NOT_IMPL

+ const ERR_XCHG_CL_CONN_CALL_ENC

+ const ERR_XCHG_CL_CONN_CALL_ERR

+ const ERR_XCHG_CL_CONN_FROM_PEER

+ const ERR_XCHG_CL_CONN_NO_ROUTE_TO_PEER

+ const ERR_XCHG_CL_CONN_SEARCHING_NODE

+ const ERR_XCHG_CL_CONN_WRONG_AUTH_RESPONSE_LEN

+ const ERR_XCHG_CL_CONN_WRONG_CALL_RESPONSE

+ const ERR_XCHG_CL_CONN_WRONG_CALL_RESPONSE_BYTE

+ const ERR_XCHG_CL_CONN_WRONG_FUNCTION_LEN

+ const ERR_XCHG_CL_CONN_WRONG_NONCE_LEN

+ const ERR_XCHG_PEER_CONN_LOSS

+ const ERR_XCHG_PEER_CONN_RCVD_ERR

+ const ERR_XCHG_PEER_CONN_REQ_SID_SIZE

+ const ERR_XCHG_PEER_CONN_TR_TIMEOUT

+ const ERR_XCHG_PEER_CONN_WRONG_PROT_VERSION

+ const ERR_XCHG_ROUTER_ALREADY_STARTED

+ const ERR_XCHG_ROUTER_CONFIG_IS_DIRECTORY

+ const ERR_XCHG_ROUTER_CONN_DECR4

+ const ERR_XCHG_ROUTER_CONN_DECR5

+ const ERR_XCHG_ROUTER_CONN_ENC

+ const ERR_XCHG_ROUTER_CONN_NO_ROUTE_TO_PEER

+ const ERR_XCHG_ROUTER_CONN_WRONG_FRAME_TYPE

+ const ERR_XCHG_ROUTER_CONN_WRONG_PROTOCOL_VERSION

+ const ERR_XCHG_ROUTER_CONN_WRONG_PUBLIC_KEY_SIZE

+ const ERR_XCHG_ROUTER_IS_NOT_STARTED

+ const ERR_XCHG_ROUTER_SERVER_ALREADY_STARTED

+ const ERR_XCHG_ROUTER_SERVER_IS_NOT_STARTED

+ const ERR_XCHG_SRV_CONN_AUTH_DATA_LEN4

+ const ERR_XCHG_SRV_CONN_AUTH_DATA_LEN_NONCE

+ const ERR_XCHG_SRV_CONN_AUTH_DATA_LEN_PK

+ const ERR_XCHG_SRV_CONN_AUTH_WRONG_NONCE

+ const ERR_XCHG_SRV_CONN_DECR

+ const ERR_XCHG_SRV_CONN_NOT_IMPL

+ const ERR_XCHG_SRV_CONN_WRONG_LEN1

+ const ERR_XCHG_SRV_CONN_WRONG_LEN9

+ const ERR_XCHG_SRV_CONN_WRONG_LEN_FN

+ const ERR_XCHG_SRV_CONN_WRONG_NONCE

+ const ERR_XCHG_SRV_CONN_WRONG_SESSION

Aug 15, 2022

Changes in this version

type Transaction

+ AddressDest string

+ AddressSrc string

+ BeginDT time.Time

+ func (c *Transaction) String() string

Aug 13, 2022

Changes in this version

type Connection

+ func (c *Connection) State() (state ConnectionState)

type ConnectionState

+ Connected bool

+ Started bool

+ Stopping bool

Aug 13, 2022

Changes in this version

type Connection

+ func (c *Connection) Dispose()

Aug 13, 2022

Changes in this version

+ const Base32Alphabet

+ func AddressForPublicKey(publicKey *rsa.PublicKey) string

+ func AddressForPublicKeyBS(publicKeyBS []byte) string

+ func NormalizeAddress(address string) string

Aug 12, 2022

Changes in this version

type Connection

+ func (c *Connection) GetState() ConnectionState

+ type ConnectionState struct

+ Host string

+ ReceivedBytes uint64

+ ReceivedFrames uint64

+ SentBytes uint64

+ SentFrames uint64

Aug 12, 2022

Changes in this version

+ const ERR_XCHG_ACCESS_DENIED

+ const ERR_XCHG_CONN_NO_CONNECTION

+ const ERR_XCHG_CONN_SENDING_ERROR

+ const ERR_XCHG_CONN_WRONG_FRAME_SIZE

+ const ERR_XCHG_TR_WRONG_FRAME

+ const FrameCall

+ const FrameError

+ const FrameInit1

+ const FrameInit2

+ const FrameInit3

+ const FrameInit4

+ const FrameInit5

+ const FrameInit6

+ const FrameResolveAddress

+ const FrameResolvedAddress

+ const FrameResponse

+ const TransactionHeaderSize

+ type Connection struct

+ func NewConnection() *Connection

+ func (c *Connection) InitIncomingConnection(conn net.Conn, processor ITransactionProcessor)

+ func (c *Connection) InitOutgoingConnection(host string, processor ITransactionProcessor)

+ func (c *Connection) IsClosed() bool

+ func (c *Connection) IsIncoming() bool

+ func (c *Connection) IsOutgoing() bool

+ func (c *Connection) ReceivedBytes() uint64

+ func (c *Connection) ReceivedFrames() uint64

+ func (c *Connection) Send(transaction *Transaction) (err error)

+ func (c *Connection) SendError(transaction *Transaction, err error)

+ func (c *Connection) SentBytes() uint64

+ func (c *Connection) SentFrames() uint64

+ func (c *Connection) Start()

+ func (c *Connection) Stop()

+ type ITransactionProcessor interface

+ Connected func()

+ Disconnected func()

+ ProcessTransaction func(transaction *Transaction)

+ type Transaction struct

+ Complete bool

+ Data []byte

+ Err error

+ FrameLen uint32

+ FrameType byte

+ OriginalTransactionId uint64

+ ProtocolVersion byte

+ Reserved byte

+ ResponseSender TransactionSender

+ Result []byte

+ SID uint64

+ SessionId uint64

+ Signature byte

+ TransactionId uint64

+ func NewTransaction(frameType byte, targetSID uint64, transactionId uint64, sessionId uint64, ...) *Transaction

+ func Parse(frame []byte) (tr *Transaction, err error)

+ type TransactionSender interface

+ Send func(transaction *Transaction) (err error)