Files
@ 0cb3fbe06b5d
Branch filter:
Location: OneEye/src/core.py
0cb3fbe06b5d
2.6 KiB
text/x-python
Go, Engine: some tests and numerous bugfixes
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 | import os
import multiprocessing
import threading
import logging as log
import PIL
from util import MsgQueue
from gui import gui
from analyzer import ImageAnalyzer
from go.core import Go, isLegalPosition
from statebag import StateBag
import config as cfg
class Core:
def __init__(self):
self.grid=None
self.go=Go()
self.detector=ImageAnalyzer()
self.states=StateBag()
self._ownMessages=MsgQueue(self._handleEvent)
self._guiMessages=MsgQueue()
self._imgs=sorted(os.listdir(cfg.misc.imgDir))
self._imgIndex=cfg.misc.defaultImage
imgPath=os.path.join(cfg.misc.imgDir,self._imgs[self._imgIndex])
self._frame=PIL.Image.open(imgPath)
self._guiProc=multiprocessing.Process(name="gui", target=gui, args=(self._guiMessages,self._ownMessages))
self._guiProc.start()
self.relativeFrame(0)
def setCorners(self,corners):
self.detector.setGridCorners(corners)
self.analyze()
def setTresholds(self,tresB=None,tresW=None):
if tresB is not None: self.detector.tresB=tresB
if tresW is not None: self.detector.tresW=tresW
self.analyze()
def relativeFrame(self,step):
self._imgIndex=(self._imgIndex+step)%len(self._imgs)
imgPath=os.path.join(cfg.misc.imgDir,self._imgs[self._imgIndex])
self._frame=PIL.Image.open(imgPath)
self._guiMessages.send("setCurrentFrame",(self._frame.copy(),))
self.analyze()
def analyze(self):
if self.detector.analyze(self._frame):
if isLegalPosition(self.detector.board):
self.states.pushState(self.detector.board)
self._guiMessages.send("setGameState",(self.detector.board,))
self.go.transitionMove(self.detector.board)
log.debug("game record: %s",self.go._record)
else:
log.info("illegal position detected")
def listen(self):
listenerThread=threading.Thread(target=lambda: self._ownMessages.listen())
listenerThread.start()
def joinGui(self):
self._guiProc.join()
self._ownMessages.send("!kill")
def _handleEvent(self,e):
actions={
"setCorners": self.setCorners,
"setTresholds": self.setTresholds,
"prevFrame": lambda: self.relativeFrame(-1),
"nextFrame": lambda: self.relativeFrame(1)
}
(actionName,args,kwargs)=e
return actions[actionName](*args,**kwargs)
core=Core()
core.listen()
core.joinGui()
"""
core
====
grid
go
imageAnalyzer
gui
===
corners
a) keeps references to important objects and uses them
b) gets and sets all relevant data through method calls with core
GUI
<- addCorner(corner)
-> redrawImgView(img,grid)
<- refreshTresholds(tresB,tresW)
BoardView
-> redrawState(go)
core-gui: just pass messages with relevant data (!! always pass object copies, don't share instances)
"""
|