frereth.cp.client — com.frereth/cp 0.0.3-g3b13aae

Implement the client half of the CurveCP protocol.

It seems like it would be nice if I could just declare the message exchange, but that approach gets complicated on the server side. At least half the point there is reducing DoS.

chan->server-closed clj

(chan->server-closed
  {:keys [:frereth.weald.specs/logger :frereth.weald.specs/state] :as this})

child->server clj

(child->server this msg)

Child sent us a signal to add bytes to the stream to the server

child-exited! clj

(child-exited! this)

ctor clj

(ctor opts logger-initializer)

heartbeat-interval clj

hide-long-arrays clj

(hide-long-arrays this)

Make pretty printing a little less verbose

server->child clj

(server->child this msg)

Received bytes from the server that need to be streamed back to child

start! clj

(start! {:keys [:frereth.weald.specs/logger
                :frereth.cp.client.state/chan->server]
         log-state :frereth.weald.specs/state
         :as this})

Perform the side-effects to establish a connection with a server

stop! clj

(stop! {log-state :frereth.weald.specs/state
        :keys [:frereth.weald.specs/logger
               :frereth.cp.client.state/chan->server]
        :or {log-state (log/init :frereth.cp.client/stop!-missing-logs)
             logger (log/std-out-log-factory)}
        :as this})

unexpectedly-terminated-successfully clj

(unexpectedly-terminated-successfully result unexpected)

unexpectedly-terminated-unsuccessfully clj

(unexpectedly-terminated-unsuccessfully result outcome)