const cluster = require 'cluster'
import np from 'path'
import cp from 'child_process'
import Component from './component'
import {Logger} from '../utils/logger'

const FLAGS = {

	REPLACED: 1
	EXITED: 2
	PAUSED: 4
	ERRORED: 8
}

class Instance
	runner = null
	args = {}
	mode = 'cluster'
	name = 'worker'
	restarts = 0

	get manifest
		runner.manifest

	def constructor runner, options
		super(options)
		options = options
		runner = runner
		atime = Date.now!
		state = 'closed'
		log = new Logger(prefix: ["%bold%dim",name,": "])
		current = null
		restarts = 0

		# setInterval(&,2000) do reload!

	def start
		return if current and current.#next
		# let exec = args.exec = manifest.main.source.path # path and loader
		let o = runner.o
		let regpath = np.resolve(o.imbaPath,"loader.imba.js")
		let loader = o.imbaPath ? regpath : "imba/loader"
		let path = manifest.main.absPath

		let args = {
			windowsHide: yes
			args: o.extras
			exec: path
			execArgv: [
				o.inspect and '--inspect',
				o.sourcemap and '--enable-source-maps'
				'-r',loader
			].filter do $1
		}
		let env = {
			IMBA_RESTARTS: restarts
			IMBA_SERVE: true
			IMBA_PATH: o.imbaPath
			IMBA_MANIFEST_PATH: manifest.path
			IMBA_HMR: o.hmr ? true : undefined
			IMBA_WORKER_NR: options.number
			IMBA_LOGLEVEL: process.env.IMBA_LOGLEVEL or 'info'
			PORT: process.env.PORT or o.port
		}

		if o.execMode == 'fork'
			args.env = Object.assign({},process.env,env)
			return cp.fork(np.resolve(path),args.args,args)

		log.info "starting"

		cluster.setupMaster(args)

		let worker = cluster.fork(env)

		worker.nr = restarts++
		let prev = worker.#prev = current

		if prev
			log.info "reloading"
			prev.#next = worker
			prev..send(['emit','reloading'])

		worker.on 'exit' do(code, signal)
			if signal
				log.info "killed by signal: %d",signal
			elif code != 0
				log.error "exited with error code: %red",code
			elif !worker.#next
				log.info "exited"
		
		worker.on 'listening' do(address)
			o.#listening = address
			log.success "listening on %address",address
			prev..send(['emit','reloaded'])
			# now we can kill the reloaded process?

		worker.on 'error' do
			log.info "%red","errorerd"

		# worker.on 'online' do log.info "%green","online"

		worker.on 'message' do(message, handle)
			if message == 'reload'
				console.log "RELOAD MESSAGE"
				reload!

		current = worker
	
	def broadcast event
		current..send(event)

	def reload
		start!
		self


export default class Runner < Component
	def constructor manifest, options
		super()
		o = options
		manifest = manifest
		workers = new Set

	def start
		let max = o.instances or 1
		let nr = 1
		let args = {
			windowsHide: yes
			args: o.extras
			execArgv: [
				o.inspect and '--inspect',
				o.sourcemap and '--enable-source-maps'
			].filter do $1
		}

		let name = o.name or np.basename(manifest.main.source.path)

		while nr <= max
			let opts = {
				number: nr,
				name: max > 1 ? "{name} {nr}/{max}" : name
			}
			workers.add new Instance(self,opts)
			nr++

		for worker of workers
			worker.start!

		return self

	def reload
		for worker of workers
			worker.reload!
		self

	def broadcast ...params
		for worker of workers
			worker.broadcast(...params)
		self