connections

Documentation

Index

• Constants
• Variables
• func ConnectionStateToType() map[string]ConnectionState
• func MakePayment(tokenServiceOnion string, tokenService *privacypass.TokenServer, ...) error
• func NewTokenBoardClient(acn connectivity.ACN, Y *ristretto255.Element, tokenServiceOnion string, ...) tapir.Application
• type ConnectionState
• type Engine
  • func NewProtocolEngine(identity primitives.Identity, privateKey ed25519.PrivateKey, ...) Engine
• type PeerApp
  • func (pa *PeerApp) Init(connection tapir.Connection)
  • func (pa *PeerApp) NewInstance() tapir.Application
  • func (pa *PeerApp) SendMessage(message model2.PeerMessage) error
• type TokenBoardClient
  • func (ta *TokenBoardClient) Init(connection tapir.Connection)
  • func (ta *TokenBoardClient) Listen()
  • func (ta *TokenBoardClient) NewInstance() tapir.Application
  • func (ta *TokenBoardClient) NextToken(data []byte, hostname string) (privacypass.SpentToken, int, error)
  • func (ta *TokenBoardClient) Post(group string, ct []byte, sig []byte) (bool, int)
  • func (ta *TokenBoardClient) PurchaseTokens()
  • func (ta *TokenBoardClient) Replay()
• type TokenBoardHandler
• type TokenManager
  • func NewTokenManager() *TokenManager
  • func (tm *TokenManager) FetchToken() (*privacypass.Token, int, error)
  • func (tm *TokenManager) NumTokens() int
  • func (tm *TokenManager) StoreNewTokens(tokens []*privacypass.Token)

Constants

const TorMaxPendingConns = 28

32 from tor/src/app/config/config.c MaxClientCircuitsPending we lower a bit because there's a lot of spillage - just cus we get a SOCKS timeout doesn't mean tor has stopped trying as a huge sorce - potential multiple profiles as a huge source - second order connections like token service's second servers aren't tracked in our system adding a few extra periodically

const Version1 = 0x01

const Version2 = 0x02

Variables

var (
	// ConnectionStateName allows conversion of states to their string representations
	ConnectionStateName = []string{"Disconnected", "Connecting", "Connected", "Authenticated", "Synced", "Failed", "Killed"}
)

Functions

func ConnectionStateToType

func ConnectionStateToType() map[string]ConnectionState

ConnectionStateToType allows conversion of strings to their state type

func MakePayment

func MakePayment(tokenServiceOnion string, tokenService *privacypass.TokenServer, acn connectivity.ACN, handler TokenBoardHandler) error

MakePayment uses the PoW based token protocol to obtain more tokens

func NewTokenBoardClient

func NewTokenBoardClient(acn connectivity.ACN, Y *ristretto255.Element, tokenServiceOnion string, lastKnownSignature []byte, tokenBoardHandler TokenBoardHandler) tapir.Application

NewTokenBoardClient generates a new Client for Token Board

Types

type ConnectionState

type ConnectionState int

ConnectionState defines the various states a connection can be in from disconnected to authenticated

const (
	DISCONNECTED ConnectionState = iota
	CONNECTING
	CONNECTED
	AUTHENTICATED
	SYNCED
	FAILED
	KILLED
)

Connection States DISCONNECTED - No existing connection has been made, or all attempts have failed CONNECTING - We are in the process of attempting to connect to a given endpoint CONNECTED - We have connected but not yet authenticated AUTHENTICATED - im.ricochet.auth-hidden-server has succeeded on the connection. SYNCED - we have pulled all the messages for groups from the server and are ready to send

type Engine

type Engine interface {
	ACN() connectivity.ACN
	EventManager() event.Manager
	Shutdown()
}

Engine (ProtocolEngine) encapsulates the logic necessary to make and receive Cwtch connections. Note: ProtocolEngine doesn't have access to any information necessary to encrypt or decrypt GroupMessages Protocol Engine *can* associate Group Identifiers with Group Servers, although we don't currently make use of this fact other than to route errors back to the UI.

func NewProtocolEngine

func NewProtocolEngine(identity primitives.Identity, privateKey ed25519.PrivateKey, acn connectivity.ACN, eventManager event.Manager, peerAuthorizations map[string]model.Authorization) Engine

NewProtocolEngine initializes a new engine that runs Cwtch using the given parameters

type PeerApp

type PeerApp struct {
	applications.AuthApp

	MessageHandler    func(string, string, string, []byte)
	IsBlocked         func(string) bool
	IsAllowed         func(string) bool
	OnAcknowledgement func(string, string)
	OnAuth            func(string)
	OnClose           func(string)
	OnConnecting      func(string)
	// contains filtered or unexported fields
}

PeerApp encapsulates the behaviour of a Cwtch Peer

func (*PeerApp) Init

func (pa *PeerApp) Init(connection tapir.Connection)

Init is run when the connection is first started.

func (*PeerApp) NewInstance

func (pa *PeerApp) NewInstance() tapir.Application

NewInstance should always return a new instantiation of the application.

func (*PeerApp) SendMessage

func (pa *PeerApp) SendMessage(message model2.PeerMessage) error

SendMessage sends the peer a preformatted message NOTE: This is a stub, we will likely want to extend this to better reflect the desired protocol

type TokenBoardClient

type TokenBoardClient struct {
	applications.AuthApp
	// contains filtered or unexported fields
}

TokenBoardClient defines a client for the TokenBoard server

func (*TokenBoardClient) Init

func (ta *TokenBoardClient) Init(connection tapir.Connection)

Init initializes the cryptographic TokenBoardApp

func (*TokenBoardClient) Listen

func (ta *TokenBoardClient) Listen()

Listen processes the messages for this application

func (*TokenBoardClient) NewInstance

func (ta *TokenBoardClient) NewInstance() tapir.Application

NewInstance Client a new TokenBoardApp

func (*TokenBoardClient) NextToken

func (ta *TokenBoardClient) NextToken(data []byte, hostname string) (privacypass.SpentToken, int, error)

NextToken retrieves the next token

func (*TokenBoardClient) Post

func (ta *TokenBoardClient) Post(group string, ct []byte, sig []byte) (bool, int)

Post sends a Post Request to the server

func (*TokenBoardClient) PurchaseTokens

func (ta *TokenBoardClient) PurchaseTokens()

PurchaseTokens purchases the given number of tokens from the server (using the provided payment handler)

func (*TokenBoardClient) Replay

func (ta *TokenBoardClient) Replay()

Replay posts a Replay Message to the server.

type TokenBoardHandler

type TokenBoardHandler interface {
	GroupMessageHandler(server string, gm *groups.EncryptedGroupMessage)
	ServerAuthedHandler(server string)
	ServerSyncedHandler(server string)
	ServerClosedHandler(server string)
	NewTokenHandler(tokenService string, tokens []*privacypass.Token)
	PostingFailed(server string, sig []byte)
	FetchToken(tokenService string) (*privacypass.Token, int, error)
}

TokenBoardHandler encapsulates all the various handlers a client needs to interact with a token board this includes handlers to receive new messages, as well as handlers to manage tokens.

type TokenManager

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

TokenManager maintains a list of tokens associated with a single TokenServer

func NewTokenManager

func NewTokenManager() *TokenManager

func (*TokenManager) FetchToken

func (tm *TokenManager) FetchToken() (*privacypass.Token, int, error)

FetchToken removes a token from the internal list and returns it, along with a count of the remaining tokens. Errors if no tokens available.

func (*TokenManager) NumTokens

func (tm *TokenManager) NumTokens() int

NumTokens returns the current number of tokens

func (*TokenManager) StoreNewTokens

func (tm *TokenManager) StoreNewTokens(tokens []*privacypass.Token)

StoreNewTokens adds tokens to the internal list managed by this TokenManager