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
109
|
import threading
from graph import NavigationGraph
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": 4000,
"max_warp_speed": 4.55, # AU/s
"max_subwarp_speed": 166.9, # 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": 5_500_000 # isk
}
self.graph = NavigationGraph(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(f"Snipe: {potential_snipe.item_name} orders for {potential_snipe.gross_profit} ISK")
self.log.append("----------------")
print("snipe possible", potential_snipe.gross_profit, "ISK", potential_snipe.item_name)
open_market_window(potential_snipe.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()
if updated_regions:
log.append(f"Updated {len(updated_regions)} market 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)
if self.route:
set_waypoints([r["location_id"] for r in self.route[1:]])
print(self.route)
else:
self.route = []
self.route_info = {}
print("No profitable route found yet.")
|
