const fetch = (...args) => import('node-fetch').then(({default: fetch}) => fetch(...args));
let controller = new AbortController();
require('dotenv').config()
const RCC_HOST = process.env.RCC_HOST
var convert = require('xml-js');

 let url = 'http://'+RCC_HOST+':8000'; // change this to rcc soap

async function OpenGame(jobid,port,ip,placeid,creatorid){
    return new Promise(async (resolve, reject) => {
  let json  = {"Mode":"GameServer","GameId":"game1","Settings":{"IsRobloxPlace":false,"PlaceId":1,"CreatorId":1,"GameId":"00000000-0000-0000-0000-000000000132","GsmInterval":50,"MaxPlayers":100,"MaxGameInstances":52,"ApiKey":"egg","GameCode":"AAAAAAAAAAAAAA-a","PreferredPlayerCapacity":10,"DatacenterId":1,"PlaceVisitAccessKey":"rbx_evt_ftp","UniverseId":13058,"PlaceFetchUrl":"https://mete0r.xyz/asset?id=11","MatchmakingContextId":1,"CreatorType":"User","PlaceVersion":123,"BaseUrl":"mete0r.xyz","MachineAddress":"localhost","JobId":"game1","PreferredPort":53640}}
        json.GameId = jobid
        json.Settings.PreferredPort = port
      json.Settings.MachineAddress = ip
      json.Settings.JobId = jobid
      json.Settings.PlaceId = parseFloat(placeid)
      json.Settings.UniverseId = json.Settings.PlaceId
      json.Settings.CreatorId = creatorid
      json.Settings.GameId = jobid

      let xml = `<?xml version = "1.0" encoding = "UTF-8"?>
      <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:SOAP-ENC="http://schemas.xmlsoap.org/soap/encoding/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:ns2="http://roblox.com/RCCServiceSoap" xmlns:ns1="http://roblox.com/" xmlns:ns3="http://roblox.com/RCCServiceSoap12">
          <SOAP-ENV:Body>
                 <ns1:OpenJob>
                      <ns1:job>
                      <ns1:id>${jobid}</ns1:id>
                      <ns1:expirationInSeconds>60</ns1:expirationInSeconds>
                      <ns1:category>2</ns1:category>
                      <ns1:cores>1</ns1:cores>
                      </ns1:job>
                      <ns1:script>
                          <ns1:name>game1</ns1:name>
                          <ns1:script>${JSON.stringify(json)}</ns1:script>
                      </ns1:script>
                      </ns1:OpenJob>
              </SOAP-ENV:Body>
      </SOAP-ENV:Envelope>`


//console.log(encodeURIComponent(JSON.stringify(json)))
        try {
          const result = await fetch(url+"/opengame/"+jobid+"/"+encodeURIComponent(JSON.stringify(json)))
          const data = await result.text()
          return resolve(
            data
          )
        } catch (error) {
          return reject(error)
        }
    })
}

async function OpenGame2020(jobid,port,ip,placeid,creatorid){
  return new Promise(async (resolve, reject) => {
let json  = {"Mode":"GameServer","GameId":"game1","Settings":{"IsRobloxPlace":false,"PlaceId":1,"CreatorId":1,"GameId":"00000000-0000-0000-0000-000000000132","GsmInterval":50,"MaxPlayers":100,"MaxGameInstances":52,"ApiKey":"egg","GameCode":"AAAAAAAAAAAAAA-a","PreferredPlayerCapacity":10,"DatacenterId":1,"PlaceVisitAccessKey":"rbx_evt_ftp","UniverseId":13058,"PlaceFetchUrl":"https://mete0r.xyz/asset?id=11","MatchmakingContextId":1,"CreatorType":"User","PlaceVersion":123,"BaseUrl":"mete0r.xyz","MachineAddress":"localhost","JobId":"game1","PreferredPort":53640}}
      json.GameId = jobid
      json.Settings.PreferredPort = port
    json.Settings.MachineAddress = ip
    json.Settings.JobId = jobid
    json.Settings.PlaceId = parseFloat(placeid)
    json.Settings.UniverseId = json.Settings.PlaceId
    json.Settings.CreatorId = creatorid
    json.Settings.GameId = jobid
    json.Settings.PlaceFetchUrl = "https://mete0r.xyz/asset?id="+parseFloat(placeid)

    let xml = `<?xml version = "1.0" encoding = "UTF-8"?>
    <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:SOAP-ENC="http://schemas.xmlsoap.org/soap/encoding/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:ns2="http://roblox.com/RCCServiceSoap" xmlns:ns1="http://roblox.com/" xmlns:ns3="http://roblox.com/RCCServiceSoap12">
        <SOAP-ENV:Body>
               <ns1:OpenJob>
                    <ns1:job>
                    <ns1:id>${jobid}</ns1:id>
                    <ns1:expirationInSeconds>60</ns1:expirationInSeconds>
                    <ns1:category>2</ns1:category>
                    <ns1:cores>1</ns1:cores>
                    </ns1:job>
                    <ns1:script>
                        <ns1:name>game1</ns1:name>
                        <ns1:script>${JSON.stringify(json)}</ns1:script>
                    </ns1:script>
                    </ns1:OpenJob>
            </SOAP-ENV:Body>
    </SOAP-ENV:Envelope>`


//console.log(encodeURIComponent(JSON.stringify(json)))
      try {
        const result = await fetch(url+"/opengame2020/"+jobid+"/"+encodeURIComponent(JSON.stringify(json)))
        const data = await result.text()
        return resolve(
          data
        )
      } catch (error) {
        return reject(error)
      }
  })
}

async function CloseJob(jobid) {
    return new Promise(async (resolve, reject) => {
        var xml = {
            _declaration: { _attributes: { version: '1.0', encoding: 'UTF - 8' } },
            'SOAP-ENV:Envelope': {
              _attributes: {
                'xmlns:SOAP-ENV': 'http://schemas.xmlsoap.org/soap/envelope/',
                'xmlns:SOAP-ENC': 'http://schemas.xmlsoap.org/soap/encoding/',
                'xmlns:xsi': 'http://www.w3.org/2001/XMLSchema-instance',
                'xmlns:xsd': 'http://www.w3.org/2001/XMLSchema',
                'xmlns:ns2': 'http://roblox.com/RCCServiceSoap',
                'xmlns:ns1': 'http://roblox.com/',
                'xmlns:ns3': 'http://roblox.com/RCCServiceSoap12'
              },
              'SOAP-ENV:Body': {
                'ns1:CloseJob': {
                  'ns1:jobID': { _text: 'Test' }
                }
              }
            }
          }
    xml['SOAP-ENV:Envelope']['SOAP-ENV:Body']['ns1:CloseJob']['ns1:jobID']._text = jobid
          const body = convert.js2xml(xml, { compact: true, spaces: 4 })
        
            try {
              const result = await fetch(url+"/closejob/"+jobid)
              const data = await result.text()
              return resolve(
                data
              )
            } catch (error) {
              return reject(error)
            }
          })
}

async function OpenRender(userid,closeup) {
  return new Promise(async (resolve, reject) => {
          try {
            const result = await fetch(url+"/openrender/"+userid+"/"+closeup)
            const data = await result.text()
            //console.log(data)
            if (data === '{"status": "error","error":"Already started"}'){
              return resolve(
                JSON.parse(data)
              )
            }
            const convertedData = convert.xml2js(data, { compact: true, spaces: 4 })
            return resolve(
              convertedData
            )
          } catch (error) {
            return reject(error)
          }
        })
}

async function OpenRenderAsset(assetid,type) {
  return new Promise(async (resolve, reject) => {
          try {
            const result = await fetch(url+"/openrenderasset/"+assetid+"/"+type)
            const data = await result.text()
            //console.log(data)
            if (data === '{"status": "error","error":"Already started"}'){
              return resolve(
                JSON.parse(data)
              )
            }
            const convertedData = convert.xml2js(data, { compact: true, spaces: 4 })
            return resolve(
              convertedData
            )
          } catch (error) {
            return reject(error)
          }
        })
}

async function lol2(){
  const lol = await OpenRender(0)
  console.log(lol['SOAP-ENV:Envelope']['SOAP-ENV:Body']['ns1:OpenJobResponse']['ns1:OpenJobResult'][0]['ns1:value']._text)
}

async function RenewLease(jobid,expiration) {
  return new Promise(async (resolve, reject) => {
      var xml = {
          _declaration: { _attributes: { version: '1.0', encoding: 'UTF-8' } },
          'SOAP-ENV:Envelope': {
            _attributes: {
              'xmlns:SOAP-ENV': 'http://schemas.xmlsoap.org/soap/envelope/',
              'xmlns:ns1': 'http://roblox.com/',
              'xmlns:xsi': 'http://www.w3.org/2001/XMLSchema-instance'
            },
            'SOAP-ENV:Body': {
              'ns1:RenewLease': {
                'ns1:jobID': { _text: 'Test' },
                'ns1:expirationInSeconds': { _text: '100' }
              }
            }
          }
        }
  xml['SOAP-ENV:Envelope']['SOAP-ENV:Body']['ns1:RenewLease']['ns1:jobID']._text = jobid
  xml['SOAP-ENV:Envelope']['SOAP-ENV:Body']['ns1:RenewLease']['ns1:expirationInSeconds']._text = expiration
        const body = convert.js2xml(xml, { compact: true, spaces: 4 })
      
          try {
            const result = await fetch(url+"/renewlease/"+jobid+"/"+expiration)
            const data = await result.text()
            return resolve(
              data
            )
          } catch (error) {
            return reject(error)
          }
        })
}

async function Execute(jobid,json) {
  return new Promise(async (resolve, reject) => {
          try {
            const result = await fetch(url+"/executejson/"+jobid+"/"+encodeURIComponent(JSON.stringify(json)))
            const data = await result.text()
            return resolve(
              data
            )
          } catch (error) {
            return reject(error)
          }
        })
}

async function GetAllJobs() {
  return new Promise(async (resolve, reject) => {
      const xmlData = (xml = {
        _declaration: {
          _attributes: { version: '1.0', encoding: 'UTF - 8' },
        },
        'SOAP-ENV:Envelope': {
          _attributes: {
            'xmlns:SOAP-ENV': 'http://schemas.xmlsoap.org/soap/envelope/',
            'xmlns:SOAP-ENC': 'http://schemas.xmlsoap.org/soap/encoding/',
            'xmlns:xsi': 'http://www.w3.org/2001/XMLSchema-instance',
            'xmlns:xsd': 'http://www.w3.org/2001/XMLSchema',
            'xmlns:ns2': 'http://roblox.com/RCCServiceSoap',
            'xmlns:ns1': 'http://roblox.com/',
            'xmlns:ns3': 'http://roblox.com/RCCServiceSoap12',
          },
          'SOAP-ENV:Body': { 'ns1:GetAllJobsEx': {} },
        },
      })
  
      const body = convert.js2xml(xmlData, { compact: true, spaces: 4 })
  
      try {
        const result = await fetch(url, { method: 'POST', body })
        const data = await result.text()
        const convertedData = convert.xml2js(data, { compact: true, spaces: 4 })
        return resolve(
          convertedData['SOAP-ENV:Envelope']['SOAP-ENV:Body']['ns1:GetAllJobsExResponse']['ns1:GetAllJobsExResult']
        )
      } catch (error) {
        return reject(error)
      }
    })
}

//RenewLease('game2',"69530318916789546987353800")
async function lol(){
let res = await GetAllJobs()
//console.dir(res,{ depth: null })
let exists = false
if (res != "{}"){
  if (Array.isArray(res['ns1:Job']) === false){
    console.log('asd')
    //console.log(res['ns1:Job']['ns1:id']._text)
    if (res['ns1:Job']['ns1:id']._text === 'game2'){
      exists = true
    }
  }else{
    res['ns1:Job'].forEach(element => {
      if (element['ns1:id']?._text === 'game2'){
        exists = true
      }
    })
  }


}
console.log(exists)
}
//lol()
//GetAllJobs()
//OpenGame('game2','3333','127.0.0.1','2')
module.exports = {OpenGame,CloseJob,RenewLease,GetAllJobs,OpenRender,OpenRenderAsset,OpenGame2020,Execute}