awa 0.0.1 · OCaml Package

type event =

| Channel_exec of int32 * string
| Channel_data of int32 * Cstruct.t
| Channel_eof of int32
| Disconnected of string

type t = {

client_version : string option;
server_version : string;
client_kexinit : Ssh.kexinit option;
server_kexinit : Ssh.kexinit;
neg_kex : Kex.negotiation option;
host_key : Hostkey.priv;
session_id : Cstruct.t option;
keys_ctos : Kex.keys;
keys_stoc : Kex.keys;
new_keys_ctos : Kex.keys option;
new_keys_stoc : Kex.keys option;
keying : bool;
key_eol : Mtime.t option;
expect : Ssh.message_id option;
auth_state : Auth.state;
user_db : Auth.db;
channels : Channel.db;
ignore_next_packet : bool;

}

val guard_msg : t -> Ssh.message -> (unit, string) Rresult.result

val make : Hostkey.priv -> Auth.db -> t * Ssh.message list

val of_new_keys_ctos : t -> (t, string) Rresult.result

val of_new_keys_stoc : t -> (t, string) Rresult.result

val rekey : t -> (t * Ssh.message) option

val should_rekey : t -> Mtime.t -> bool

val maybe_rekey : t -> Mtime.t -> (t * Ssh.message) option

val pop_msg2 : 
  t ->
  Cstruct.t ->
  (t * Ssh.message option * Cstruct.t, string) Rresult.result

val make_noreply : 'a -> ('a * 'b list * 'c option, 'd) Rresult.result

val make_reply : 'a -> 'b -> ('a * 'b list * 'c option, 'd) Rresult.result

val make_replies : 'a -> 'b -> ('a * 'b * 'c option, 'd) Rresult.result

val make_event : 'a -> 'b -> ('a * 'c list * 'b option, 'd) Rresult.result

val make_reply_with_event : 
  'a ->
  'b ->
  'c ->
  ('a * 'b list * 'c option, 'd) Rresult.result

val make_disconnect : 
  'a ->
  Ssh.disconnect_code ->
  string ->
  ('a * Ssh.message list * event option, 'b) Rresult.result

val input_userauth_request : 
  t ->
  string ->
  string ->
  Ssh.auth_method ->
  (t * Ssh.message list * event option, string) Rresult.result

val input_channel_open : 
  t ->
  int32 ->
  int32 ->
  int32 ->
  Ssh.channel_open ->
  (t * Ssh.message list * 'a option, 'b) Rresult.result

val input_channel_request : 
  t ->
  Channel.Channel_map.key ->
  bool ->
  Ssh.channel_request ->
  (t * Ssh.message list * event option, 'a) Rresult.result

val input_msg : 
  t ->
  Ssh.message ->
  Mtime.t ->
  (t * Ssh.message list * event option, string) Rresult.result

val output_msg : t -> Ssh.message -> (t * Cstruct.t, string) Rresult.result

val output_channel_data : 
  t ->
  Channel.Channel_map.key ->
  Cstruct_sexp.t ->
  (t * Ssh.message list, string) Rresult.result

package awa