import multiprocessing
import threading
import logging

import PIL

import config as cfg
from util import MsgQueue
from gui import gui
from analyzer import ImageAnalyzer
from analyzer.framecache import FrameCache
from go.core import Go, isLegalPosition
from statebag import StateBag
from video import capVideo

log=logging.getLogger(__name__)


class Core:
	def __init__(self):
		self.grid=None
		self.go=Go()
		self.detector=ImageAnalyzer()
		self._cache=FrameCache()
		self.states=StateBag()

		self._ownMessages=MsgQueue("Core",self._handleEvent)
		self._guiMessages=MsgQueue("GUI")
		self._vidMessages=MsgQueue("Video")
		self._listenerThread=None

		self._frame=None

		self._guiProc=multiprocessing.Process(name="gui", target=gui, args=(self._guiMessages,self._ownMessages))
		self._guiProc.start()
		self._vidProc=multiprocessing.Process(
			name="video",
			target=capVideo,
			args=(cfg.misc.video, self._vidMessages,self._ownMessages)
		)
		self._vidProc.start()

	def fetchFrame(self,key):
		frame=self._cache.get(key)
		if frame is None:
			(key,frame)=self._cache.getRelative(10)
		self._guiMessages.send("setFrame", (frame.copy(), gui.PREVIEW, key))

	def putFrame(self,frame):
		self._frame=PIL.Image.fromarray(frame)
		k=self._cache.put(self._frame)
		self._guiMessages.send("setFrame", (self._frame, gui.RECORDING, k))
		self.analyze()

	def sendParams(self):
		self._guiMessages.send("setParams",(self.detector.params.copy(),))

	def setParams(self,params):
		self.detector.setParams(params)

	def analyze(self):
		if self.detector.analyze(self._frame):
			if isLegalPosition(self.detector.board):
				state=self.states.pushState(self.detector.board)
				rec=[]
				if state:
					rec=state.exportRecord()
					log.debug("progressive game record: %s",rec)
				self._guiMessages.send("setGameState", (self.detector.board,rec))

				self.go.transitionMove(self.detector.board)
				log.debug("conservative game record: %s",self.go._record)
			else:
				log.info("illegal position detected")

	def listen(self):
		self._listenerThread=threading.Thread(target=lambda: self._ownMessages.listen())
		self._listenerThread.start()

	def joinChildren(self):
		self._guiProc.join()
		self._vidMessages.send("shutDown")
		self._vidProc.join()
		self._ownMessages.send("!kill",("core",))
		self._listenerThread.join()
		log.info("Core exiting.")

	def _handleEvent(self,e):
		actions={
			"fetchFrame": self.fetchFrame,
			"putFrame": self.putFrame,
			"fetchParams": self.sendParams,
			"setParams": self.setParams
		}
		(actionName,args,kwargs)=e

		return actions[actionName](*args,**kwargs)

if __name__=="__main__":
	core=Core()
	core.listen()
	log.info("OneEye started.")
	core.joinChildren()
	log.info("OneEye done.")