mproxy-forward 0.1.8

MPROXY: Forwarding Proxy. Forward TLS/TCP, UDP, or Multicast to a downstream UDP socket address.
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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

use std::path::PathBuf;
use std::thread::sleep;
use std::time::Duration;

use mproxy_client::client_socket_stream;
use mproxy_forward::forward_udp;
use mproxy_server::listener;

use testconfig::{truncate, TESTDATA, TESTINGDIR};

#[test]
fn test_forward_udp_ipv4_unicast() {
    let client_target = "127.0.0.1:8890".to_string();
    let proxy_listen = "0.0.0.0:8890".to_string();
    let proxy_target = "127.0.0.1:8891".to_string();
    //let proxy_target = "0.0.0.0:8891".to_string();
    let server_listen = "0.0.0.0:8891".to_string();

    let data = PathBuf::from(TESTDATA);
    let pathstr = &[TESTINGDIR, "streamoutput_forward_udp_ipv4_output.log"].join(&"");
    let output = PathBuf::from(pathstr);
    assert!(data.is_file());

    let _l = listener(server_listen, output, true);
    sleep(Duration::from_millis(15));

    let targets = vec![proxy_target];
    let _p = forward_udp(proxy_listen, &targets, false);
    sleep(Duration::from_millis(15));

    let _c = client_socket_stream(&data, vec![client_target], false);

    let output = PathBuf::from(pathstr);
    let bytesize = truncate(output);
    assert!(bytesize > 0);
}

#[test]
fn test_forward_udp_ipv6_unicast() {
    let client_target = "[::1]:8892".to_string();
    let proxy_listen = "[::]:8892".to_string();
    let proxy_target = "[::1]:8893".to_string();
    let server_listen = "[::]:8893".to_string();

    let data = PathBuf::from(TESTDATA);
    let pathstr = &[TESTINGDIR, "streamoutput_forward_udp_ipv6_output.log"].join(&"");
    let output = PathBuf::from(pathstr);
    assert!(data.is_file());

    let _l = listener(server_listen, output, false);
    sleep(Duration::from_millis(15));

    let targets = vec![proxy_target];
    let _p = forward_udp(proxy_listen, &targets, false);
    sleep(Duration::from_millis(15));

    let _c = client_socket_stream(&data, vec![client_target], false);

    let output = PathBuf::from(pathstr);
    let bytesize = truncate(output);
    assert!(bytesize > 0);
}

#[test]
fn test_forward_udp_ipv4_multicast() {
    let client_target = "127.0.0.1:8894".to_string();
    let proxy_listen = "0.0.0.0:8894".to_string();
    let proxy_target = "127.0.0.1:8895".to_string();
    let server_listen = "0.0.0.0:8895".to_string();

    let data = PathBuf::from(TESTDATA);
    let pathstr = &[
        TESTINGDIR,
        "streamoutput_forward_udp_ipv4_multicast_output.log",
    ]
    .join(&"");
    let output = PathBuf::from(pathstr);
    assert!(data.is_file());

    let _l = listener(server_listen, output, false);
    sleep(Duration::from_millis(15));

    let targets = vec![proxy_target];
    let _p = forward_udp(proxy_listen, &targets, false);
    sleep(Duration::from_millis(15));

    let _c = client_socket_stream(&data, vec![client_target], false);

    let output = PathBuf::from(pathstr);
    let bytesize = truncate(output);
    assert!(bytesize > 0);
}

#[test]
fn test_forward_udp_ipv6_multicast() {
    let client_target = "[ff02::1]:8896".to_string();
    let proxy_listen = "[ff02::]:8896".to_string();
    let proxy_target = "[ff02::1]:8897".to_string();
    let server_listen = "[ff02::]:8897".to_string();

    let data = PathBuf::from(TESTDATA);
    let pathstr = &[
        TESTINGDIR,
        "streamoutput_forward_udp_ipv6_multicast_output.log",
    ]
    .join(&"");
    let output = PathBuf::from(pathstr);
    assert!(data.is_file());

    let _l = listener(server_listen, output, false);
    sleep(Duration::from_millis(15));

    let targets = vec![proxy_target];
    let _p = forward_udp(proxy_listen, &targets, false);
    sleep(Duration::from_millis(15));

    let _c = client_socket_stream(&data, vec![client_target], false);
    sleep(Duration::from_millis(15));

    let output = PathBuf::from(pathstr);
    let bytesize = truncate(output);
    assert!(bytesize > 0);
}