Initial commit

Author: nimatt

.gitignore

@@ -0,0 +1,3 @@
+__pycache__
+.vscode
+/player.1.py

game.py

@@ -0,0 +1,58 @@
+from typing import List
+
+def build_distance_map(zero_x: int, zero_y: int, floor_map: list):
+  dist_map = [[None for y in range(len(floor_map[0]))] for x in range(len(floor_map))]
+  def set_distance(x: int, y: int, floor_map: list, distance: int):
+    if not floor_map[x][y] or (dist_map[x][y] != None and dist_map[x][y] <= distance):
+      return
+
+    dist_map[x][y] = distance
+    if x > 0:
+      set_distance(x - 1, y, floor_map, distance + 1)
+    if x < len(floor_map) - 1:
+      set_distance(x + 1, y, floor_map, distance + 1)
+    if y > 0:
+      set_distance(x, y - 1, floor_map, distance + 1)
+    if y < len(floor_map[0]) - 1:
+      set_distance(x, y + 1, floor_map, distance + 1)
+  
+  set_distance(zero_x, zero_y, floor_map, 0)
+  return dist_map
+
+class Unit:
+  def __init__(self, input_unit):
+    self.id: str = input_unit['id']
+    self.power: int = input_unit['power']
+    self.health: int = input_unit['health']
+    self.x: int = input_unit['x']
+    self.y: int = input_unit['y']
+    self.dist_map: List[List[int]] = None
+
+  def get_distance(self, x: int, y: int, state):
+    if self.dist_map == None:
+      self.dist_map = build_distance_map(self.x, self.y, state.empty_map)
+
+    return self.dist_map[x][y]
+
+class GameState:
+  def __init__(self, input_state):
+    self.unit = Unit(input_state['unit'])
+    self.units: List[Unit] = [Unit(u) for u in input_state['units']]
+    self.foes: List[Unit] = [Unit(u) for u in input_state['foes']]
+    self.floor_map: List[List[bool]] = input_state['floorMap']
+    self.empty_map: List[List[bool]] = [[square for square in col] for col in self.floor_map]
+
+    for unit in self.units:
+      if unit.health > 0 and unit.id != self.unit.id:
+        self.empty_map[unit.x][unit.y] = False
+    for foe in self.foes:
+      if foe.health > 0:
+        self.empty_map[foe.x][foe.y] = False
+
+class Action:
+  def __init__(self, action_type: str, direction: str):
+    self.type = action_type
+    self.direction = direction
+
+def is_empty(x: int, y: int, state: GameState):
+  return state.empty_map[x][y]

main.py

@@ -0,0 +1,111 @@
+import tornado.ioloop
+import tornado.web
+from tornado.httpclient import HTTPClient, HTTPRequest
+import sys
+import json
+import importlib
+import os
+import threading
+import traceback
+from time import sleep
+
+import player
+from game import GameState
+
+running = True
+
+def monitor_changes(port):
+    last_write_time = os.path.getmtime('player.py')
+
+    while running:
+        current_write_time = os.path.getmtime('player.py')
+        if last_write_time != current_write_time:
+            last_write_time = current_write_time
+            print ('Change detected')
+            importlib.reload(player)
+            register_player(port)
+
+        sleep(1)
+
+    print('Stopping')
+
+class MainHandler(tornado.web.RequestHandler):
+
+    def get(self):
+        self.handle_method('GET')
+
+    def post(self):
+        self.handle_method('POST')
+
+    def get_payload(self):
+        
+        payload_len = int(self.request.headers.get('content-length', 0))
+        if payload_len == 0:
+            return None
+        return tornado.escape.json_decode(self.request.body)
+
+    def handle_method(self, method):
+        try:
+            if method == 'GET':
+                self.set_status(200)
+                self.write('Please send POST with game data\n'.encode())
+            else:
+                payload = self.get_payload()
+                response = ''
+                if self.request.path == '/end':
+                    player.game_end()
+                else:    
+                    actions = player.get_actions(GameState(payload))
+                    response = json.dumps(list(map(lambda a : a.__dict__, actions)), sort_keys=True, indent=2).encode()
+                self.set_status(200)
+                self.set_header('Content-Type', 'application/json')
+                self.write(response)
+
+        except Exception as e:
+            print(e)
+            print(traceback.format_exc())
+            self.set_status(500)
+            self.write('An error occured')
+
+
+poll_interval = 0.1
+
+def make_app():
+    return tornado.web.Application([
+        (r"/.*", MainHandler),
+    ])
+
+def start_server(port):
+    'Starts the server on specified port'
+    print('Starting HTTP server at port %d' % port)
+    app = make_app()
+    app.listen(port)
+    try:
+        tornado.ioloop.IOLoop.current().start()
+    except KeyboardInterrupt:
+        pass
+
+def register_player(port):
+    'Register the player with the game server'
+    info = player.get_player_info()
+    info["address"] = "http://10.0.75.1:" + str(port)
+    http_client = HTTPClient()
+    http_client.fetch(
+        HTTPRequest(
+            'http://localhost:8080/api/players',
+            method="POST",
+            headers={
+                'Content-Type': 'application/json'
+            },
+            body=json.dumps(info, sort_keys=True, indent=2).encode()
+        )
+    )
+
+if __name__ == '__main__':
+    port = 9080
+    register_player(port)
+    monitor = threading.Thread(target=monitor_changes, args=(port,))
+    monitor.start()
+    start_server(port)
+    running = False
+    monitor.join()

player.py

@@ -0,0 +1,17 @@
+# Logic for controlling units
+
+from game import Action, is_empty, Unit, GameState, build_distance_map
+
+def get_actions(state):
+  return [
+    Action('move', 'left')
+  ]
+
+def get_player_info():
+  return {
+    "id": "cc9ddc91-2e0d-4565-af30-a39748f2344b",
+    "name": "Swamp prawns"
+  }
+
+def game_end():
+  pass

registerPlayers.ps1

@@ -0,0 +1,36 @@
+Invoke-WebRequest -Headers @{'Content-Type' = 'application/json'} `
+  -Method Post `
+  -Uri 'http://localhost:8080/api/players' `
+  -Body '{
+	"id": "a9cd1ada-c81a-463a-b997-b6ef8ee57da9",
+	"name": "Giant Wipeout",
+	"address": "http://10.0.75.1:9080"
+}'
+
+
+Invoke-WebRequest -Headers @{'Content-Type' = 'application/json'} `
+  -Method Post `
+  -Uri 'http://localhost:8080/api/players' `
+  -Body '{
+	"id": "7c3c1128-792c-46b2-afa1-1de3e55974e2",
+	"name": "Purple spawn",
+	"address": "http://10.0.75.1:9080"
+}'
+
+Invoke-WebRequest -Headers @{'Content-Type' = 'application/json'} `
+  -Method Post `
+  -Uri 'http://localhost:8080/api/players' `
+  -Body '{
+	"id": "cc9ddc91-2e0d-4565-af30-a39748f2344b",
+	"name": "Swamp prawns",
+	"address": "http://10.0.75.1:9080"
+}'
+
+Invoke-WebRequest -Headers @{'Content-Type' = 'application/json'} `
+  -Method Post `
+  -Uri 'http://localhost:8080/api/players' `
+  -Body '{
+	"id": "414d3aef-a0a4-4f1b-b2d7-b77d52df9c40",
+	"name": "Blank pixies",
+	"address": "http://10.0.75.1:9080"
+}'