aaaaaaa

const net = require('net');
const http = require('http');
const express = require('express');
//const ajIp = process.env.AJIP || 'aws-or-prod-iss03-mobile.animaljam.com';
const ajIp = process.env.AJIP || 'aws-or-prod-iss04.animaljam.com';
const ajPort = process.env.AJPORT || 443;
const listenPort = process.env.LISTENPORT || 443;

console.log("AJ IP is " + ajIp);
console.log("AJ port is " + ajPort);

var ajConnection;
var flashConnection;
var server;
var webServer;
var app;
var io;

var String1;
var String2;

var supersocketpower;
var HackyStuff = "";

var nveranderDeze    = [];
var inDeze          = [];
var AANGEPAST       = -1;

var x = 500;
var y = 500;

app = express();

app.use(express.static('public'));


app.set('port', process.env.PORT || 8000);
app.set('host', process.env.HOST || '127.0.0.1');

webServer = http.createServer(app).listen(app.get('port'), app.get('host'), function() {
    console.log(`Web server listening on http://${app.get('host')}:${app.get('port')}`);
});

io = require('socket.io')(webServer);

server = net.createServer(function(c) { //'connection' listener
    flashConnection = c;
    flashConnection.on('data', flashMessageReceived);

    // connect to aj when flash connects to node
    ajConnection = net.connect(ajPort, ajIp, setupAj);
    ajConnection.on('data', ajMessageReceived);
});

io.listen(webServer);

server.listen(listenPort, function () {
    console.log("proxy server on");
});

function setupAj () {
    console.log('aj connected');
}

// console.log(io);
io.on("connection", socketioConnected);

function socketioConnected(socketioConnection) {
    console.log('Socket.io Connection with the client established');

    var message_to_client = {
        data: "Connection with the server established"
    }
    socketioConnection.send(message_to_client);
    socketioConnection.on("message", socketioMessageRecieved);
    supersocketpower = socketioConnection;
}

function socketioMessageRecieved(data) {

    data = JSON.parse(data);

    var test = data.messagee;
    test = test.toString();

    if(HackyStuff==""){
        HackyStuff = test;
    }else{
        if(HackyStuff==test){
            console.log("KILL DATA");
            return;
        }else{
            HackyStuff = test;
        }
    }



    /*Printing the data */
    console.log(data);

    var back_to_client = {
        data: "Server Received the message"
    };

    io.send(back_to_client);


    if(test=="UP"){
        y = y - 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();

        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {y
            ajConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }

    }else if(test=="DOWN"){
        y = y + 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();
        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {
            ajConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }
    }else if(test=="RIGHT"){
        x = x + 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();
        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {
            ajConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }
    }else if(test=="LEFT"){
        x = x - 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();
        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {
            ajConnection.write(transform("%xt%au%8916778%1%1%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }
    }

    //Second NPC

    else if(test=="UP2"){
        y = y - 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();
        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {
            ajConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }

    }else if(test=="DOWN2"){
        y = y + 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();
        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {
            ajConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }
    }else if(test=="RIGHT2"){
        x = x + 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();
        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {
            ajConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }
    }else if(test=="LEFT2"){
        x = x - 30;
        var yy = y;
        var xx = x;
        xx.toString();
        yy.toString();
        //Live Replacements (Client)
        if (flashConnection.writable) {
            flashConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));
        }
        //send message to aj (server)
        if (ajConnection.writable) {
            ajConnection.write(transform("%xt%au%8916778%1%2%1%"+xx+"%"+yy+"%0%" + '\0', false, false, true));

        }

    }else{

        if(test=="NOOOO"){
            //Live Replacements (Client)
            if (flashConnection.writable) {
                flashConnection.write(transform(data.fullstrrr + '\0', data.vervangdit, data.indit, true));
            }
            //send message to aj (server)
            if (ajConnection.writable) {
                ajConnection.write(transform(data.fullstrrr + '\0', data.vervangdit, data.indit, true));

            }
            var fart = data.vervangdit;
            var fart2 = data.indit;
            fart = fart.toString();
            fart2 = fart2.toString();
            var re = new RegExp(fart,"g");
            console.log(output);

            AANGEPAST = AANGEPAST+1;
            veranderDeze.push(re);
            inDeze.push(fart2);

            //veranderDeze[AANGEPAST] = "Opel";
            //inDeze[AANGEPAST]       = "Opel";
        }else{
            var listtt = data.openlist;
            listtt = listtt.toString();
            if(listtt==""){

            }else{

                //////////////////////////////
                // USERNAME:     96gf7t6goy90y
                //////////////////////////////

                //Live Replacements (Client)
                if (flashConnection.writable) {
                    flashConnection.write(transform(data.openlist + '\0', false, false, true));
                }
                //send message to aj (server)
                if (ajConnection.writable) {
                    ajConnection.write(transform(data.openlist + '\0', false, false, true));

                }

            }



            //Live Replacements (Client)
            if (flashConnection.writable) {
                flashConnection.write(transform(data.messagee + '\0', false, false, true));
            }
            //send message to aj (server)
            if (ajConnection.writable) {
                ajConnection.write(transform(data.messagee + '\0', false, false, true));

            }

        }
    }

}
function flashMessageReceived (flashMessage) {

    console.log("Flash message: " + flashMessage);
    flashMessage = transform(flashMessage, false, false, false);
    console.log("Flash message after transform: " + flashMessage);
    var DeString = flashMessage.toString();

    var RegExEQUIP = /\%xt\%o\%iu\%\d\d\d\d\d\d\d\%1\%0\%[1-9]\d{3,}\%/;
    var RegExUNEQUIP = /\%xt\%o\%iu\%\d\d\d\d\d\d\d\%0\%1\%[1-9]\d{3,}\%/;
    // %xt%o%iu%1316821%1%0%1000%
    var EquipSlot = DeString[DeString.search(RegExEQUIP)+21] + DeString[DeString.search(RegExEQUIP)+22] + DeString[DeString.search(RegExEQUIP)+23] + DeString[DeString.search(RegExEQUIP)+24];
    var UnEquipSlot = DeString[DeString.search(RegExUNEQUIP)+21] + DeString[DeString.search(RegExUNEQUIP)+22] + DeString[DeString.search(RegExUNEQUIP)+23] + DeString[DeString.search(RegExUNEQUIP)+24];
    console.log(EquipSlot);

    if(RegExEQUIP.test(DeString)==true){
        console.log("Ik zie dat FAKE item " + EquipSlot + " is equipped");

        EquipSlot = EquipSlot + "HAXX";
        var message_to_jonat = {
            data: EquipSlot
        }
        supersocketpower.send(message_to_jonat);
        supersocketpower.on("message", socketioMessageRecieved);

    }

    if(RegExUNEQUIP.test(DeString)==true){
        console.log("Ik zie dat FAKE item " + UnEquipSlot + " is UNequipped");

        UnEquipSlot = UnEquipSlot + "FAXX";
        var message_to_jonatt = {
            data: UnEquipSlot
        }
        supersocketpower.send(message_to_jonatt);
        supersocketpower.on("message", socketioMessageRecieved);
    }

    io.send({data: "From flash: " + flashMessage});
    ajConnection.write(flashMessage);
}

function ajMessageReceived (ajMessage) {
    console.log("AJ message: " + ajMessage);
    ajMessage = transform(ajMessage, false, false, true);
    console.log("AJ message after transform: " + ajMessage);
    var ECHTeenSTRING = ajMessage.toString();

    var REGGG = /"userId":\d\d\d\d\d\d,"/;
    var DeUserId = "";
    var DeExtraUserId = "";
    DeExtraUserId =  ECHTeenSTRING[ECHTeenSTRING.search(REGGG)] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+1] +  ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+2] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+3] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+4] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+5] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+6] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+7] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+8] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+9] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+10] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+11] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+12] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+13] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+14] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+15] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+16];
    DeUserId = ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+9] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+10] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+11] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+12] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+13] + ECHTeenSTRING[ECHTeenSTRING.search(REGGG)+14];
    if(REGGG.test(DeExtraUserId)==true){
        DeUserId = DeUserId + "LOL";
        var message_to_jona = {
            data: DeUserId
        }

        if(supersocketpower==undefined){

        }else{
            supersocketpower.send(message_to_jona);
            supersocketpower.on("message", socketioMessageRecieved);
        }
    }

    io.send({data: "From AJ: " + ajMessage});
    if (flashConnection.writable) {
        flashConnection.write(transform(ajMessage, false, false, true));
    }
}


// Replacements
function transform(input, vv, ind, fromAj) {
    output = input.toString();
    var VERVANG = "F";
    var INDITTE = "F";
    if(vv!=false){
        VERVANG = vv.toString();
        //VERVANG = VERVANG - '\0';
    }
    if(ind!=false){
        INDITTE = ind.toString();
        //INDITTE = INDITTE - '\0';
    }

    if(AANGEPAST!=-1){
        var i;
        for (i = 0; i < AANGEPAST+1; i++){
            output = output.replace(veranderDeze[i], inDeze[i]);
        }
    }

    if(VERVANG=="F"&&INDITTE=="F"){
        //output = output.replace(/"accountType":1/, '"accountType":2'); // Make yourself a member.
        //output = output.replace(/"woodCount":0/, '"woodCount":999999');
        //output = output.replace(/"isGuide":false/, '"isGuide":true'); // Make yourself a member.
        //output = output.replace(/"isModerator":false/, '"isModerator":true'); // Make yourself a member.
        //output = output.replace(/%58%/, '%1995%').replace(/5580347/, '678068991'); // Replaces 2ND variant baseball cap with a gray/teal aviator hat.
        //output = output.replace(/%58%/, '%1994%').replace(/5580347/, '678068991');
        //output = output.replace(/%58%/, '%1993%').replace(/5580347/, '678068991');
        // output = output.replace(/%131%/, '%3409%')
        // output = output.replace(/%58%/, '%2000%').replace(/5580347/, '678068991');
        // output = output.replace(/%468%/, '%1998%').replace(/124207360/, '521702955');
        //output = output.replace(/("jamaaTime":.+?,)/, '"jamaaTime":0,');
    }else{
        // var re = new RegExp(VERVANG,"g");
        // output = output.replace(re, INDITTE);
        // console.log(output);
        // AANGEPAST = true;
        // DDDDDDDDD = re;
        // NNNNNNNNN = INDITTE;
    }

//****************************************************** THE END **********************************************************//
    if (fromAj) {
        output = output.replace(/%only do this FROM aj%/, '%blah%');
    } else {
        output = output.replace(/%only do this from flash%/, '%blah%');
    }

    return output;
}