Initial

1 files changed, 104 insertions, 0 deletions

diff --git a/backend/src/manager.py b/backend/src/manager.py
new file mode 100644
index 0000000..03df5d8
--- /dev/null
+++ b/backend/src/manager.py
@@ -0,0 +1,104 @@
+import threading
+
+from graph import Graph
+from esi.api import get_location, set_waypoints, open_market_window
+from market import Market
+from arbitrage import arbitrage, snipe
+from pathfinder import pathfinder
+import route
+
+
+
+class Manager:
+    
+    def __init__(self):
+        self.ship = {
+            "location": get_location(),
+            "cargo": 600,
+            "max_warp_speed": 8.22, # AU/s
+            "max_subwarp_speed": 216.5, # m/s
+            "gankers_areas": {"Ahbazon": 0.5}, #["Miroitem", "Rancer", "Huola", "Ahbazon", "Uedama", "Sivala", "Tama", "Onatoh"],
+            "player_cost": 15_000_000 / 3600,  # isk/second
+            "risk_cost": 60_000_000, # isk
+            "ship_cost": 50_000_000 # isk
+        }
+        self.graph = Graph(self.ship)
+        self.route = []
+        self.route_info = {}
+        self.market = Market()
+        self.updating_orders = False
+        self.log = ["Test Log"]
+
+    def route(self):
+        return self.route
+    
+    def route_info(self):
+        return self.route_info
+    
+    def get_log(self):
+        result = self.log
+        self.log = []
+        return result
+
+    def snipe_callback(self, updated_regions):
+
+        if self.ship["location"] in self.graph.solar_systems:
+            current_region = self.graph.solar_systems[self.ship["location"]]["region_id"]
+        else:
+            current_region = self.graph.stations[self.ship["location"]]["region_id"]
+
+        if current_region in updated_regions:
+            potential_snipe = snipe(self.market.orders, self.ship["cargo"], current_region)
+            if potential_snipe:
+                self.log.append("----------------")
+                self.log.append("Snipe: " + str(potential_snipe[1]) + " orders for " + str(potential_snipe[0]) + " ISK")
+                self.log.append("----------------")
+
+                print("snipe possible", potential_snipe[0], "ISK", potential_snipe[1])
+
+                open_market_window(potential_snipe[1]["type_id"])
+                
+
+    def update(self):
+        self.log = self.log[-100:]
+
+        location = get_location()
+        self.ship["location"] = location
+
+        if len(self.route) == 1:
+            # Only the last step is left, so we are at the destination
+            self.log.append("Arrived at Destination")
+            self.route = []
+            return
+
+        for i, step in enumerate(self.route[:2]):
+            if i != 0 and step["location_id"] == location:
+                self.log.append("Arrived at " + step["location"])
+                self.route = self.route[i:]
+                break
+
+        if not self.updating_orders:
+            self.updating_orders = True
+
+            def target_function(log):
+                try:
+                    updated_regions = self.market.update_orders(log)
+                    if updated_regions:
+                        self.snipe_callback(updated_regions)
+                finally:
+                    self.updating_orders = False
+
+            update_thread = threading.Thread(target=target_function, args=(self.log,))
+            update_thread.start()
+
+
+    def create_route(self):
+        order_matches = arbitrage(self.market.orders, self.ship["cargo"])
+        order_matches = pathfinder(order_matches, self.graph, self.ship)
+        self.route, self.route_info = route.route(order_matches, self.graph, self.ship)
+
+        set_waypoints([r["location_id"] for r in self.route[1:]])
+
+        print(self.route)
+         
+    
\ No newline at end of file