inn-network 0.1.1

A network library for Inn
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

//-------------------------------------------------------------------
// MIT License
// Copyright (c) 2022 black-mongo
// @author CameronYang
// @doc
//
// @end
// Created : 2022-04-15T11:16:30+08:00
//-------------------------------------------------------------------

use std::collections::HashMap;

use actix::Message;
use actix::Recipient;
use serde::Deserialize;
use serde::Serialize;

use crate::codec::DstAddress;
// Command Message to session actor
#[derive(Debug, Clone)]
pub enum ToSession {
    Ping,
    Stop,
    Meta,
    RemoteConnected(Recipient<ToFoward>, DstAddress),
    RemoteConnectionRefuse,
    Forward(Vec<u8>),
    ProxyServerReply(ProxyServerReply),
}
// Message reply from session actor
#[derive(Debug, PartialEq)]
pub enum SessionReply {
    Pong,
    Meta(SessionMeta),
    Ok,
}
impl Message for ToSession {
    type Result = SessionReply;
}

#[derive(Default, Debug, PartialEq)]
pub struct SessionMeta(pub usize);

#[derive(Debug)]
pub enum ToProxyServer {
    Connect(Recipient<ToSession>),
    DisConnect(usize),
    OnlineCounter(usize),
    Cli(usize, inn_common::cli::Cli),
    HttpReq(Box<WsHttpReq>),
}
#[derive(Debug, PartialEq, Clone)]
pub enum ProxyServerReply {
    Id(usize),
    OnlineCounter(usize),
    Ok,
    Cli(inn_common::cli::Cli),
    HttpReq(Box<WsHttpReq>),
}
impl Message for ToProxyServer {
    type Result = ProxyServerReply;
}
#[derive(Debug, PartialEq)]
pub enum ToFoward {
    Stop,
    Forward(Vec<u8>),
}
pub enum ForwardReply {
    Ok,
}
impl Message for ToFoward {
    type Result = ForwardReply;
}
#[derive(Serialize, Deserialize)]
#[serde(rename_all = "lowercase")]
pub enum MsgName {
    HttpReq,
}
#[derive(Serialize, Deserialize, Clone, Default, Debug, PartialEq)]
#[serde(rename_all = "lowercase")]
pub struct WsHttpReq {
    pub id: String,
    pub uri: String,
    pub headers: HashMap<String, String>,
    pub status: u16,
    pub error: String,
    pub method: String,
    pub req_body: String,
    pub time: String,
    pub host: String,
    pub server_ip: String,
    pub protocol: String,
    pub resp_headers: HashMap<String, String>,
    pub resp_body: String,
}
#[derive(Serialize, Deserialize)]
#[serde(rename_all = "lowercase")]
pub struct WsMsg<T> {
    pub msg_name: MsgName,
    pub msg: T,
}