net.vpn

import net.tunnel
import net.vpn

func main:
    vpn.RegisterWith(vpn.Options { fragment = true, fragment_min = 2, fragment_max = 8 })
    each proto in ["vless", "vmess", "trojan", "socks", "http", "mixed"]:
        ib := tunnel.CreateInbound(tunnel.InboundConfig { protocol = proto, settings = `{"clients":[{"id":"0b3a8c6e-1f3d-4d7e-9a50-3f8e6a1c2b44","password":"secret"}],"method":"aes-128-gcm","password":"secret"}` })
        println "inbound", proto, ib.Name()
    end
    each proto in ["vless", "vmess", "trojan", "shadowsocks", "ss", "socks", "http", "freedom"]:
        ob := tunnel.CreateOutbound(tunnel.OutboundConfig { protocol = proto, settings = `{"address":"vpn.example.com","port":443}` })
        println "outbound", proto, ob.Name()
    end

    cfg := tunnel.ParseConfig(`{"inbounds":[{"tag":"in","port":0,"protocol":"mixed"}],"outbounds":[{"tag":"direct","protocol":"freedom"},{"tag":"out","protocol":"socks","settings":{"address":"127.0.0.1","port":1080}}]}`)
    dialer := vpn.BuildDialer(cfg)
    println dialer.Name()

    vpn.Register()
    println tunnel.CreateInbound(tunnel.InboundConfig { protocol = "vless" }).Name()
end

import net.transport
import net.tunnel
import net.vpn

func main:
    raw := `{"network":"ws","security":"tls","tlsSettings":{"serverName":"cdn.example.com"},"wsSettings":{"path":"/chat","headers":{"Host":"front.example.com"}}}`
    s := vpn.StreamSettings(raw)
    println s.network, s.tls, s.sni, s.path, s.host

    node := tunnel.Node { protocol = "vless", host = "vpn.example.com", port = 443, network = "ws", tls = true, sni = "vpn.example.com", path = "/ws" }
    n := vpn.NodeSettings(node)
    println n.network, n.tls, n.sni, n.path

    each proto in ["vless", "vmess", "shadowsocks", "trojan", "socks", "http", "wireguard"]:
        println proto, vpn.DialerFromNode(tunnel.Node { protocol = proto, host = "vpn.example.com", port = 443 }).Name()
    end

    t := vpn.ToTunnelAddr(transport.NewAddr("example.com", 443))
    println t.host, t.port
    back := vpn.ToTransportAddr(tunnel.NewAddr("example.org", 80))
    println back.host, back.port
end

import net.socks
import net.tcp
import net.tunnel
import net.vpn

mut echo_srv := tcp.Server {}

func echo_once():
    c := tcp.Accept(echo_srv)
    s := tunnel.WrapTcp(c)
    data := s.Read(100)
    s.Write("echo:" + data)
    s.Close()
end

func main:
    echo_srv = tcp.Bind(0)
    _t := spawn(echo_once)
    vpn.Register()
    cfg := tunnel.ParseConfig(`{"inbounds":[{"tag":"in","port":0,"protocol":"mixed"}],"outbounds":[{"tag":"direct","protocol":"freedom"}]}`)
    stats := tunnel.NewStats()
    listeners := vpn.StartAll(cfg, stats)
    println "listening:", vpn.Ok(listeners[0])
    s := tunnel.DialTcp("127.0.0.1", listeners[0].port, 3000)
    r := socks.ClientHandshake(s, socks.Client { version = 5 }, socks.CmdConnect, "127.0.0.1", tcp.Port(echo_srv))
    println "socks handshake:", r.ok
    s.Write("hello")
    println s.Read(100)
    s.Close()
    vpn.Stop(listeners[0])
    tcp.CloseServer(echo_srv)
end