Nostale NodeJS cryptography

'use strict'

const { pipeline } = require('stream');
const iconv = require('iconv-lite');
const net = require('net');
const nosCrypto = require('nostale-cryptography/client')

const host = 'xx.xx.xx.xx' //login server's ip
const port = 'xxxx' //Port

const socket = net.connect(port, host, () => {
  const encryptStream = nosCrypto.createCipher()
  const decryptStream = nosCrypto.createDecipher()

  const encodingStream = iconv.encodeStream('win1252'); 
  const decodingStream = iconv.decodeStream('win1252'); 

  pipeline(
    encodingStream,
    encryptStream,
    socket,
    decryptStream,
    decodingStream,
    err => {
      if (err) {
        console.error('Pipeline failed.', err);
      } else {
        console.log('Pipeline succeeded.');
      }

      console.log('Game closed because stream pipeline closed.')
    }
  )

  buildLoginPacket().then((loginPacket) => {
    console.log(loginPacket)

    encodingStream.write(loginPacket)

    decodingStream.on('data', (packet) => {
      console.log(packet)

      if (packet.startsWith('NsTeST')) {
        console.log('Login packet received')

        //send packet to channel/server ip and port, according to server response ?
        
      }else{
        console.log("This account is already connected")
      }
    })
  })
})

async function buildLoginPacket() {
  const nostalePath = './client' //Put NostaleClient.exe and NostaleClientX.exe in this folder
  const username = 'myLogin' //my login
  const password = 'myPassword' //my password
  const versionJeu = '0.9.3.3104'   //current version of nostaleClientX.exe

  const encodedUsername = iconv.encode(username, 'win1252') 
  const encodedPassword = iconv.encode(password, 'win1252') 

  const random = Math.floor(Math.random() * 9999999)
  const encryptedPassword = nosCrypto.encryptPassword(encodedPassword)
  const guid = 'xxxxxxxx-xxxx-4xxx-xxxx-xxxxxxxxxxxx' // Used only by the Gameforge Client
  const version = await nosCrypto.createVersion(versionJeu)
  const checksumHash = await nosCrypto.createChecksumHash(encodedUsername, nostalePath) 

  return `NoS0575 ${random} ${username} ${encryptedPassword} ${guid} ${version} 0 ${checksumHash}`
}

NsTeST username sessionId 79.110.84.37:4015:0:2.6.Galaxie 79.110.84.37:4016:0:2.7.Galaxie 79.110.84.37:4013:0:2.4.Galaxie 79.110.84.37:4011:4:2.2.Galaxie 79.110.84.37:4012:0:2.3.Galaxie 79.110.84.37:4014:0:2.5.Galaxie 79.110.84.37:4010:0:2.1.Galaxie 79.110.84.250:4016:0:1.7.Cosmos 79.110.84.250:4015:0:1.6.Cosmos 79.110.84.250:4014:0:1.5.Cosmos 79.110.84.250:4011:6:1.2.Cosmos 79.110.84.250:4012:0:1.3.Cosmos 79.110.84.250:4013:0:1.4.Cosmos 79.110.84.250:4010:0:1.1.Cosmos -1:-1:-1:10000.10000.4

79.110.84.37:4015:0:2.6.Galaxie

       
        var host = '79.110.84.xx' //Ip
        var port = 40xx //Port
        var worldSocket = new net.Socket();
        worldSocket.connect(port, host, () => {
          console.log(session)
          const encryptWorldStream = nosCrypto.createCipher(session)
          console.log("encrypt world stream " + encryptWorldStream)
          const decryptWorldStream = nosCrypto.createDecipher(session)

          const encodingStream = iconv.encodeStream('win1252'); 
          const decodingStream = iconv.decodeStream('win1252'); 

          pipeline(
            encodingStream,
            encryptWorldStream,
            worldSocket,
            decryptWorldStream,
            decodingStream,
            err => {
              if (err) {
                console.error('Pipeline failed.', err);
              } else {
                console.log('Pipeline succeeded.');
              }

              console.log('Game closed because stream pipeline closed.')
            }
          )

          buildWorldPacket(1, encryptWorldStream).then((loginPacket) => {
            console.log(loginPacket)

            encodingStream.write(loginPacket)

            decodingStream.on('data', (packet) => {
              console.log(packet)
            })
          })
          //wait1 sec
          setTimeout(() => {
            buildWorldPacket(2, session).then((loginPacket) => {
              console.log(loginPacket)


              encodingStream.write(loginPacket)

              decodingStream.on('data', (packet) => {
                console.log(packet)
              })
            })

            buildWorldPacket(3, session).then((loginPacket) => {
              console.log(loginPacket)

              encodingStream.write(loginPacket)

              decodingStream.on('data', (packet) => {
                console.log(packet)
              })
            })
          }, 1000);
        })

        

async function buildWorldPacket(packetNumber, session) {


  if (packetNumber == 1) {
    console.log("return encrypted session")
    return session
  }
  if (packetNumber == 2) {
    console.log("return username")
    return username
  }
  if (packetNumber == 3) {
    console.log("return pwd")
    return password
  }

}

async function worldConnect() {
  var host = '79.110.84.xx' // IP
  var port = 40xx //port

  var worldSocket = new net.Socket();
  worldSocket.connect(port, host, () => {
    const encryptWorldStream = nosCrypto.createCipher(session)
    const decryptWorldStream = nosCrypto.createDecipher(session)

    const encodingStream = iconv.encodeStream('win1252'); //encode to Win1252
    const decodingStream = iconv.decodeStream('win1252'); //encode to Win1252

    pipeline(
      encodingStream,
      encryptWorldStream,
      worldSocket,
      decryptWorldStream,
      decodingStream,
      err => {
        if (err) {
          console.error('Pipeline failed.', err);
        } else {
          console.log('Pipeline succeeded.');
        }

        console.log('Game closed because stream pipeline closed.')
      }
    )
    console.log(sessionStr)

    encodingStream.write(sessionStr)

    setTimeout(() => {
      encodingStream.write(username)
      encodingStream.write(password)
    }, 1000);

    decodingStream.on('data', (packet) => {
      console.log(packet)
    })
  })
}

this.socket = net.connect(this.serverPort, this.serverAdress, () => {
      const encryptStream = nosCrypto.createCipher(+this.sessionId);
      const decryptStream = nosCrypto.createDecipher(+this.sessionId);

      this.encodingStream = iconv.encodeStream("win1252");
      const decodingStream = iconv.decodeStream("win1252");

      pipeline(
        this.encodingStream,
        encryptStream,
        this.socket,
        decryptStream,
        decodingStream,
        (err) => {
          console.log(err);
        }
      );

      decodingStream.on("data", (packet) => {
        console.log(packet);
        this.handlePacket(packet);
      });

      const encryptedSession = nosCrypto.encryptSession(+this.sessionId);

      this.socket.write(encryptedSession);
      setTimeout(() => {
        this.encodingStream.write(this.sessionName + " GF 0");
        this.encodingStream.write("thisisgfmode");
      }, 1289);
    });