#!/usr/bin/python3 import sys import time import enum import threading import argparse import subprocess import socket import struct import blup.frame import blup.output class Game(object): def __init__(self): self.balance = None self.pygame = False self.output = None pass @property def logo(self): return self._logo @property def args(self): args = [] args += ['--players', str(self.players)] if self.balance is not None: args += ['--balance', self.balance] if self.pygame: args += ['--pygame'] if self.output is not None: args += ['--out', self.output] return args class PongGame(Game): def __init__(self): self.name = 'Pong' self.executable = 'balancep0ng.py' self.players = 0 self._logo = [ [1,1,0,0,0,1,1,0,0,1,0,0,1,0,0,1,1,0], [1,0,1,0,1,0,0,1,0,1,1,0,1,0,1,0,0,0], [1,1,0,0,1,0,0,1,0,1,0,1,1,0,1,0,1,1], [1,0,0,0,1,0,0,1,0,1,0,0,1,0,1,0,0,1], [1,0,0,0,0,1,1,0,0,1,0,0,1,0,0,1,1,0], ] class TetrisGame(Game): def __init__(self): self.name = 'Tetris' self.executable = 'ttrs.py' self.players = 0 self._logo = [ [1,1,1,0,1,1,0,1,1,1,0,1,1,0,0,1,0,0,1,1], [0,1,0,0,1,0,0,0,1,0,0,1,0,1,0,1,0,1,0,0], [0,1,0,0,1,1,0,0,1,0,0,1,1,0,0,1,0,0,1,0], [0,1,0,0,1,0,0,0,1,0,0,1,0,1,0,1,0,0,0,1], [0,1,0,0,1,1,0,0,1,0,0,1,0,1,0,1,0,1,1,0], ] arrow_up = [ [0,0,1,0,0], [0,1,1,1,0], [1,1,1,1,1], ] arrow_down = list(reversed(arrow_up)) arrow_left = [ [0,0,1], [0,1,1], [1,1,1], [0,1,1], [0,0,1], ] arrow_right = [list(reversed(x)) for x in arrow_left] go = [ [0,1,0,0,0,1,0], [1,0,0,0,1,0,1], [1,0,1,0,1,0,1], [0,1,0,0,0,1,0], ] select_game = [ [0,1,1,0,1,1,0,1,0,0,1,1,0,1,1,0,1,1,1], [1,0,0,0,1,0,0,1,0,0,1,0,0,1,0,0,0,1,0], [0,1,0,0,1,1,0,1,0,0,1,1,0,1,0,0,0,1,0], [0,0,1,0,1,0,0,1,0,0,1,0,0,1,0,0,0,1,0], [1,1,0,0,1,1,0,1,1,0,1,1,0,1,1,0,0,1,0], [0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0], [0,0,1,1,0,0,0,1,0,0,1,0,0,0,1,0,1,1,0], [0,1,0,0,0,0,1,0,1,0,1,1,0,1,1,0,1,0,0], [0,1,0,1,1,0,1,1,1,0,1,0,1,0,1,0,1,1,0], [0,1,0,0,1,0,1,0,1,0,1,0,0,0,1,0,1,0,0], [0,0,1,1,0,0,1,0,1,0,1,0,0,0,1,0,1,1,0], ] player = [ [1,1,0,0,1,0,0,0,1,0,0,1,0,1,0,1,1,0,1,1,0], [1,0,1,0,1,0,0,1,0,1,0,1,0,1,0,1,0,0,1,0,1], [1,1,0,0,1,0,0,1,1,1,0,0,1,0,0,1,1,0,1,1,0], [1,0,0,0,1,0,0,1,0,1,0,0,1,0,0,1,0,0,1,0,1], [1,0,0,0,1,1,0,1,0,1,0,0,1,0,0,1,1,0,1,0,1], ] two = [ [0,1,1,1,0,0,0,1,1,0], [1,0,0,0,1,0,1,0,0,1], [0,0,0,1,0,0,0,0,1,0], [0,0,1,0,0,0,0,1,0,0], [0,1,0,0,0,0,0,0,0,0], [1,1,1,1,1,0,0,1,0,0], ] def copy_bitmap(bitmap, frame, color, xoffs=0, yoffs=0): for x in range(len(bitmap[0])): for y in range(len(bitmap)): if bitmap[y][x] == 1: frame.setPixel(xoffs + x, yoffs + y, color) def create_init_screen(dimension): frame = blup.frame.Frame(dimension) xoffs = (dimension.size()[0]-len(select_game[0]))//2 yoffs = (dimension.size()[1]-len(select_game))//2 color = (0, 255, 0) copy_bitmap(select_game, frame, color, xoffs, yoffs) return frame def create_2player_screen(dimension): frame = blup.frame.Frame(dimension) xoffs = (dimension.size()[0]-len(player[0]))//2 yoffs = 1 color = (0, 255, 0) copy_bitmap(player, frame, color, xoffs, yoffs) xoffs = (dimension.size()[0]-len(two[0]))//2 yoffs += 1+len(two) color = (0, 255, 0) copy_bitmap(two, frame, color, xoffs, yoffs) return frame def create_menu_frame(dimension, game): frame = blup.frame.Frame(dimension) xoffs = (dimension.size()[0]-len(arrow_up[0]))//2 yoffs = 0 color = (255, 0, 0) copy_bitmap(arrow_up, frame, color, xoffs, yoffs) xoffs = xoffs+len(arrow_up[0])+1 color = (255, 0, 0) copy_bitmap(go, frame, color, xoffs, yoffs) xoffs = 0 yoffs = dimension.size()[1]-len(arrow_right) color = (0, 0, 255) copy_bitmap(arrow_left, frame, color, xoffs, yoffs) xoffs = dimension.size()[0]-len(arrow_right[0]) color = (255, 255, 0) copy_bitmap(arrow_right, frame, color, xoffs, yoffs) xoffs = (dimension.size()[0]-len(game.logo[0]))//2 yoffs = (dimension.size()[1]-len(game.logo))//2 color = (0, 255, 255) copy_bitmap(game.logo, frame, color, xoffs, yoffs) return frame InputEvent = enum.Enum('InputEvent', ['UP', 'DOWN', 'LEFT', 'RIGHT', 'QUIT', 'STEP_ON']) class AbstractInput(): def __init__(self): self.player_present = False pass def get_event(self): return None class TestInput(AbstractInput): def __init__(self): self.__evt = None import pygame self.__pygame = pygame self.screen = pygame.display.set_mode((100, 100)) pygame.display.update() self.controls = { pygame.K_a: InputEvent.LEFT, pygame.K_d: InputEvent.RIGHT, pygame.K_w: InputEvent.UP, pygame.K_s: InputEvent.STEP_ON, pygame.K_ESCAPE: InputEvent.QUIT, } def get_event(self): pygame = self.__pygame for event in pygame.event.get(): if event.type == pygame.KEYDOWN: if self.control.get(event.key, None) == InputEvent.STEP_ON: self.player_present = True return self.controls.get(event.key, None) return None class BalanceInput(AbstractInput, threading.Thread): def __init__(self, addr, player_id): self.addr = addr self.player_id = player_id self.evt = None self.lastevt = None self.player_present = False self.running = False threading.Thread.__init__(self, daemon=True) self.start() def run(self): sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) try: sock.connect(self.addr) except ConnectionRefusedError: print('could not connect to balance server', file=sys.stderr) self.evt = InputEvent.QUIT return self.running = True evt = None oldevt = None lastchange = 0 while self.running: sock.send(b'a') data = sock.recv(4) p0x, p0y, p1x, p1y = struct.unpack('bbbb', data) if self.player_id == 0: xbal, ybal = p0x, p0y elif self.player_id == 1: xbal, ybal = p1x, p1y print('player_id=%d xbal=%d ybal=%d' % (self.player_id, xbal, ybal)) THRESHOLD = 40 MIN_TIMES = { InputEvent.LEFT: 0.05, InputEvent.RIGHT: 0.05, InputEvent.UP: 0.05, InputEvent.DOWN: 0.05, } if self.player_present: if xbal == -128 or ybal == -128: self.evt = InputEvent.QUIT self.player_present = False continue if abs(xbal) < THRESHOLD and abs(ybal) < THRESHOLD: evt = None else: if abs(xbal) < abs(ybal): if ybal > 0: evt = InputEvent.UP else: evt = InputEvent.DOWN else: if xbal > 0: evt = InputEvent.RIGHT else: evt = InputEvent.LEFT if evt != oldevt: lastchange = time.time() oldevt = evt if time.time() - lastchange < MIN_TIMES.get(evt, 0): print('player_id=%d debounce %s' % (self.player_id, evt)) continue if self.lastevt != evt: self.evt = evt self.lastevt = evt print('player_id=%d event=%s' % (self.player_id, self.evt)) else: if xbal != -128 and ybal != -128: self.evt = InputEvent.STEP_ON self.player_present = True continue def get_event(self): evt = self.evt if self.running: self.evt = None return evt def start_game(game, players): print('Starting', game.name, 'for', players, 'player(s)') game.players = players arg = ['./'+game.executable] + game.args subprocess.call(arg) sys.exit() if __name__ == '__main__': parser = argparse.ArgumentParser(description='Blinkenbunt Game Selection Menu') parser.add_argument('--pygame', dest='pygame', action='store_true', help='use pygame as input') parser.add_argument('--balance', dest='balance', type=str, metavar='HOST:PORT', help='use balance input') parser.add_argument('--out', dest='out', type=str, metavar='OUTPUT', default='e3blp', help='blup output specification') args = parser.parse_args() if args.balance is None and not args.pygame: print('please specify an input method', file=sys.stderr) sys.exit(1) w = 22 h = 16 out = blup.output.getOutput(args.out) dim = blup.frame.FrameDimension(w, h, 256, 3) if args.pygame: inp1 = TestInput() inp2 = TestInput() elif args.balance is not None: host, port = args.balance.split(':') inp1 = BalanceInput((host, int(port)), 0) inp2 = BalanceInput((host, int(port)), 1) while True: evt = inp1.get_event() if evt == InputEvent.STEP_ON: break elif evt == InputEvent.QUIT: sys.exit() time.sleep(0.05) init_frame = create_init_screen(dim) out.sendFrame(init_frame) time.sleep(1) games = Game.__subclasses__() game_idx = 0 old_idx = -1 while True: if old_idx != game_idx: gamecls = games[game_idx] game = gamecls() out.sendFrame(create_menu_frame(dim, game)) old_idx = game_idx evt = inp1.get_event() if evt == InputEvent.LEFT: game_idx -= 1 if game_idx < 0: game_idx = len(games)-1 if evt == InputEvent.RIGHT: game_idx += 1 if game_idx >= len(games): game_idx = 0 if evt == InputEvent.UP: game.output = args.out game.balance = args.balance game.pygame = args.pygame break if evt == InputEvent.QUIT: sys.exit() p2_frame = create_2player_screen(dim) out.sendFrame(p2_frame) wait_time = 3 start = time.time() while time.time() < start+wait_time: while True: evt = inp2.get_event() if inp2.player_present: inp1.running = False inp2.running = False start_game(game, 2) elif evt == InputEvent.QUIT: sys.exit() time.sleep(0.1) inp1.running = False inp2.running = False start_game(game, 1)