// All rights reserved by Cekvenich|INTUITION.DEV) |  Cekvenich, licensed under LGPL 3.0

import { SysAgent } from "./SysAgent"

import { HttpRPC } from "http-rpc/lib/SrvRPC"
import { YamlConfig } from "./FileOpsExtra"

import { TerseB } from "terse-b/terse-b"

export class Agent {

    _log:any = new TerseB(this.constructor.name) 
    
    config
    constructor() {
      this.config =new YamlConfig(process.cwd()+'/agentg.yaml')
      
      Agent.rpc = new HttpRPC(this.config['proto'], this.config['host'], this.config['port'])
    }
    static rpc 

    async runSmall() {
      let params = await SysAgent.statsSmall()

      try {
        await Agent.rpc.invoke('agent', 'agentSmall', params  )
      } catch(err) {this._log.warn(err)}

      await  SysAgent.wait(1400)
      this.runSmall()
    }

    async runBig() {
      let params = {}
      params = await SysAgent.statsBig()
      let ports = await new SysAgent().ports()
      params['ports'] = ports
      let ps = await SysAgent.ps()
      params['ps']= ps

      try {
        await Agent.rpc.invoke('agent', 'agentBig', params  )
      } catch(err) {this._log.warn(err)}

      await  SysAgent.wait(20*1000)
      this.runBig()
    }


}