Sub informs the manager to subscribe to the given rendezvous point and to call handler once a message is received in the given point. Note that handl

appendPacketHeader appends this packet's header into a byte slice.

ComposeCompressedRM creates a blobified message that has a header and a payload that can then be encrypted and transmitted to the other side. The cont

FetchResource requests the specified resource from the client. Once the resource is returned the ResourceFetched handler will be called with the respo

Level returns the current logging level.

MetadataHash calculates the hash of the metadata info. Note that the specific information that is hashed depends on the version of the metadata.

SendRM sends the given routed message to the server whenever possible. It returns when the RM has been successfully written and acknowledged as receiv

SendRandomData sends data in the random stream. This is only used during tests.

True asserts the given bool is true.

ack clears the replay log up to the specified id.

assertClientsCanPM asserts that the clients can PM each other.

assertNextRandomData asserts that the next message from server is data sent on the random stream by some other test client and it equals the given exp

changeActiveWindow changes the state to the specified window.

newClient creates a new test client for this server.

newServerStreams creates a new set of server streams for a given message type.

newTestServer creates a new test server.

runStream runs the stream, sending unacked messages from the replayLog starting at unackedFrom.

send the notification on all running streams.

AcceptGroupChatInvite accepts the given invitation, previously received from some user.

AcceptInvite accepts an invite to kx with the user-provided invite.

Error formats message using the default formats for its operands and writes to log with LevelError.

Info formats message using the default formats for its operands and writes to log with LevelInfo.

UpdateRTDTSession updates the data for the given RTDT session.

assertPostSubscriber asserts whether client c contains the target user in its list of subscribers (target is/isn't subscribed to c's posts).

assertPostSubscription asserts whether client c is/isn't subscribed to the target user's posts. This is the reverse of assertContainsPostSubscriber.

isEnterMsg returns true if the message is a key down message of the enter key.

logGCEvent logs the given GC event. Must not be called from inside a DB transaction.

logger creates a logger for the given subsystem in the configured backend.

newHandshakedSession creates a new session and completes the handshake with the scaffold server.

partitionTableName returns the name of the data table to use for a partition based on the provided date.

pushReadMsg pushes a message that will be read by the next call to Read(). This blocks until the message is read.

recreateStoppedClient recreates a client that was previously stopped. If the client was not stopped, results are undefined.

removeIfExists removes the filename if it exists. If it does not exist, this doesn't return an error.

serverWrite sends a message from the server encoded with the key for this session.

write sends the given data to the server (either encrypted or not depending on how the connection was setup).

Bind the service server to the specified name.

CreatePost creates the given post in the local DB. Note that the optional file specified in fname is **copied** to the post.

FromBytes decodes the byte slice into this framed packet.

GetAddressBookEntry loads the address book information of an user.

IsOwnerOrAdmin returns true if the given ID is the owner or an admin of the session.

LogGCMsg logs a GC message sent in the given GC. Returns the message, with any filters and modifications applied.

New returns a new INIDB context. Depth contains the maximum number of files that are retained. Create indicates if the database should be created if

Public returns the full public identity data for the local client.

RMReceived should be called whenever an RM for a user is received.

RVPoint calculates the RV point that corresponds to this key.

Run runs all client goroutines until the given context is canceled. Must only be called once.

Run runs the rendezvous manager services. A given RVManager instance should not be reused once its run method returns.

UnsubscribeToPosts makes the local client unsubscribe from a remote user's posts.

UserLogNick returns the nick to use when logging a remote user. If the user does not exist, returns the UID itself as string. If this uid is for the c

activeChatWindow returns the currently active chat window or nil if the active window is _not_ a chat window.

assertClientJoinsGC asserts that the admin of the GC can invite and the invitee joins the GC.

assertNextMembersList asserts the next command received by the client is a members list bitmap and returns the decoded bitmap.

listenerWrite writes the given raw message bytes to the remote conn. temp is used to encrypt the message if necessary.

nextServerBytesAddr reads the next message received by the server and returns it and the address that sent it.

popNArgs returns the N first arguments in s and the rest of the s string after those first n args. Returns nil if there aren't enough args.

readNext reads the next message sent by the server.

sleep for d duration or m*d if running in race mode.

writeWrappedWithStyle writes s to b using the style with wrapping at winW. Returns the new offset.

CreateRTDTSession creates a new RTDT session. This involves fetching a creation token from brserver. The local client does NOT automatically join the

EncryptedSize returns the estimated size for an encrypted ratched message, given the specified payload msg size.

GCKick kicks the given user from the GC. This only works if we're the gc admin.

JoinLiveRTDTSession joins the live RTDT session.

Last returns the number and filename of the file with highest number in the dir. If no file is found, the returned filename is empty.

Listen to any Write() events by calling the specificed callback function. Note the callbacks are called synchronously with the Write() call, so care m

LocalIsAdmin returns true if the local client is an admin of this session.

MaxMsgSizeForVersion returns the max message size according to the given max message size version. It returns 0 for unknown versions.

RandomShortID returns a random short id, generated from the cryptographically secure random generator.

Run the server.

Save flushes current in memory database back to disk. The process is as follows: 1. Check if the database is dirty and abort process if it isn't 2. C

ServerCmd decodes the packet as a server command and payload.

SplitPath splits the path into path elements according to the separator.

Write data to a temp file, then renames the temp file to the passed filename in json format. log is used to log warnings that are not fatal to the Wr