import vibe.core.core;

import vibe.core.net;

import vibe.core.log;

​

import std.functional;

import std.algorithm : min;

import core.time;

import eventcore.driver;

import std.digest : toHexString;

​

​

void main()

{

    listenTCP_s(1400, &proxyFun, "0.0.0.0");

    runApplication();

}

​

void proxyFun(TCPConnection conn) @safe nothrow

{

    try

    {

        TCPConnection client = connectTCP("www.smart-locator.com", 5050);

        logInfo("Tracker open communication: %s", client.connected);

​

        auto buffer = new ubyte[4096];

​

        while(conn.connected)

        {

            WaitForDataStatus conn_status = conn.waitForDataEx(150.msecs);

            if (conn_status == WaitForDataStatus.dataAvailable)

            {

                size_t chunk = min(conn.leastSize, buffer.length);

                conn.read(buffer, IOMode.once);

                auto readData = buffer[0 .. chunk].dup;

                logInfo("Tracker send data: %s", readData.toHexString);

                client.write(readData);

​

            }

            else if (conn_status == WaitForDataStatus.noMoreData)

            {

                logInfo("Tracker closing connection");

            }

            WaitForDataStatus client_status = client.waitForDataEx(150.msecs);

            if (client_status == WaitForDataStatus.dataAvailable)

            {

                size_t chunk = min(client.leastSize, buffer.length);

                client.read(buffer, IOMode.once);

                auto readData = buffer[0 .. chunk].dup;

                logInfo("Platform send data: %s", readData.toHexString);

                conn.write(readData);

            }

            else if (client_status == WaitForDataStatus.noMoreData)

            {

                logInfo("Platform closing connection");

                conn.close;

            }

​

            if ((conn_status | client_status) & WaitForDataStatus.noMoreData)

            {

                logInfo("Closing connection");

                break;

            }

​

        }

        logInfo("Closed connection");

​

    }

    catch (Exception e)

    {

        logInfo("Exception: %s", e.msg);

    }

}