Printer.js

const _ = require('lodash')
const fs = require('fs')
const {promisify} = require('util');

const fsReadFile = promisify(fs.readFile)
const Bot = require('./Bot')
const MarlinServer = require('./MarlinServer')

const sleep = ms => new Promise(res => setTimeout(res, ms))


module.exports = class Printer {
  constructor (options) {
    this.options = options
    this.channel = new MarlinServer(options)
    this.channel.on('data', this.parse.bind(this))
    this.switch = {
      x: false,
      y: false,
      z: false,
      b: false,
    }
  }

  parse(data) {
    if (data.startsWith('x_min:')) {
      this.switch.x = data.includes('TRIGGERED')
    } else if (data.startsWith('y_min:')) {
      this.switch.y = data.includes('TRIGGERED')
    } else if (data.startsWith('z_min:')) {
      this.switch.z = data.includes('TRIGGERED')
    } else if (data.startsWith('x_max:')){
      this.switch.b = data.includes('TRIGGERED')
    }
  }

  get name () {
    return this.options.name || this.channel.name
  }

  // Resolves promise once connected
  ready() {
    return this.channel.ready()
  }

  connect() {
    return this.channel.connect()
  }

  async command(gcode) {
    let original = gcode
    gcode = gcode.replace(/\s*;.*/g, '').trim()

    if (gcode.length <= 1) {
      if (this.options.debug)
        console.log('!', 'skip command:', original)
      return
    }

    this.gcode = gcode

    // Special Soft cases
    if (gcode.startsWith('SOFT:')){
      let cmd = gcode.replace('SOFT:', '')
      if (this.options.debug) {
        console.log('> SOFT', cmd)
      }
      await this[cmd]()
      return
    } 

    await this.channel.execute(gcode)
  }

  async commands(gcodes) {
    for (let gcode of gcodes) {
      await this.command(gcode)
    }
  }

  async executeFile(path) {
    let file = await fsReadFile(path)
    let commands = file.toString().split('\n')
    await this.commands(commands)
  }

  async display(string) {
    await this.command(`M117 ${string}`)
  }

  async homeAll() { 
    await this.homeW()
    await this.meshBedLevel()
  }
  async home(axes){
    axes = _.intersection(axes, ['X', 'Y', 'Z', 'W'])
    let cmd = 'G28 ' + axes.join(' ')
    await this.channel.execute(cmd)
  }

  async homeX(){ await this.home(['X']) }
  async homeY(){ await this.home(['Y']) }
  async homeZ(){ await this.home(['Z']) }
  async homeW(){ await this.home(['W']) }
  
  async waitForButtonPress(){
    this.display("Press Extrud Button")
    
    do {
      await this.readSwitches()
      await sleep(50)
    } while(!this.switch.b)

    this.display("Ok! Beginning")
  }
  
  async softwareHome(axis) {
    let homed = false
    let limit = 2000
    
    let AXIS = axis.toUpperCase()
    axis = axis.toLowerCase()

    if (AXIS != 'X' && AXIS != 'Y' && AXIS != 'Z') {
      throw new Error('Invalid softwareHome axis: ' + AXIS)
    }
    
    await this.command(`G4 P40`)
    await this.readSwitches()
    if (this.switch[axis]) {
      await this.command(`G1 ${AXIS}5`)
      await this.command(`G4 P40`)
      await this.readSwitches()
    }

    while(limit--) {
      await this.readSwitches()
      if (this.switch[axis]) {
        homed = true
        break
      }
      this.command(`G92 ${AXIS}0.5 F3000`)
      this.command(`G1 ${AXIS}0`)
    }


    let offset = {X: -0.1, Y: -3, Z: 0}
    this.command(`G92 ${AXIS}${offset[AXIS]}`)
    this.command(`G1 ${AXIS}0`)
    this.command(`M300 S2000 P200`)
    if (homed) {
      console.log("Home Ok")
    } else {
      throw new Error("Homing failed on:", AXIS)
    }

  }

  async checkPrint() {
    await this.readSwitches()
    if (this.switch.b){
      await this.display("Part Found 200 OK")
    }else {
      await this.shutdown()
      await this.command('M300 S2000 P500')
      await this.command('M300 S0 P20')
      await this.command('M300 S2000 P500')
      await this.command('M300 S0 P20')
      await this.command('M300 S2000 P500')
      await this.command('M300 S0 P20')
      throw new Error("Part Not Found 404")
    }
  }

  async shutdown(){
    await this.command('G1 Z30 F3000.0')
    await this.command('M84')
    await this.command('M104 S0')
    await this.command('M140 S0')
  }

  async softwareHomeY() {
    await this.softwareHome('Y')
  }

  async softwareHomeX() {
    await this.softwareHome('X')
  }

  async softwareHomeZ() {
    await this.softwareHome('Z')
  }

  async readSwitches() {
    await this.command('M119')
  }

  async meshBedLevel(){ 
    await this.command('G80')
  }


}