|
|
@@ -976,6 +976,265 @@ class ScriptPort(object):
|
|
|
# self.deactivate()
|
|
|
# return
|
|
|
|
|
|
+class ScriptSpace(object):
|
|
|
+ """ Space Exploration script.
|
|
|
+
|
|
|
+ Send "SD", verify paths are clear.
|
|
|
+ Find nearest unknown. Sector + CR.
|
|
|
+ Save "shortest path from to" information.
|
|
|
+ At 'Engage the Autopilot', Send "S" (Single Step)
|
|
|
+ At '[Stop in this sector', Send "SD", verify path is clear.
|
|
|
+ Send "SH" (glean sector/port information along the way.)
|
|
|
+ Send "N" (Next)!
|
|
|
+
|
|
|
+ Send "SD" / Verify clear.
|
|
|
+ Send "SH"
|
|
|
+
|
|
|
+ Repeat for Next closest.
|
|
|
+
|
|
|
+ """
|
|
|
+ def __init__(self, game):
|
|
|
+ self.game = game
|
|
|
+ self.queue_game = game.queue_game
|
|
|
+ self.queue_player = game.queue_player
|
|
|
+ self.observer = game.observer
|
|
|
+ self.r = Style.RESET_ALL
|
|
|
+ self.nl = "\n\r"
|
|
|
+
|
|
|
+ self.this_sector = None # Starting sector
|
|
|
+ self.target_sector = None # Sector going to
|
|
|
+ self.path = []
|
|
|
+
|
|
|
+ self.times_left = 0 # How many times to look for target
|
|
|
+ self.density = dict() # Results of density scan. (Just the numbers)
|
|
|
+
|
|
|
+ # Activate
|
|
|
+ self.prompt = game.buffer
|
|
|
+ self.save = self.observer.save()
|
|
|
+ self.observer.connect('player', self.player)
|
|
|
+ self.observer.connect("prompt", self.game_prompt)
|
|
|
+ self.observer.connect("game-line", self.game_line)
|
|
|
+
|
|
|
+ self.defer = None
|
|
|
+ self.queue_game.put(
|
|
|
+ self.nl + "Bugz (like space), is big." + self.r + self.nl
|
|
|
+ )
|
|
|
+
|
|
|
+ self.state = 1
|
|
|
+ self.queue_player.put("SD")
|
|
|
+
|
|
|
+ # Get current density scan + also get the current sector.
|
|
|
+ # [Command [TL=00:00:00]:[XXXX] (?=Help)? : D]
|
|
|
+
|
|
|
+ def whenDone(self):
|
|
|
+ self.defer = defer.Deferred()
|
|
|
+ # Call this to chain something after we exit.
|
|
|
+ return self.defer
|
|
|
+
|
|
|
+ def deactivate(self):
|
|
|
+ self.state = 0
|
|
|
+ log.msg("ScriptPort.deactivate ({0})".format(self.times_left))
|
|
|
+ assert(not self.save is None)
|
|
|
+ self.observer.load(self.save)
|
|
|
+ self.save = None
|
|
|
+ if self.defer:
|
|
|
+ self.defer.callback('done')
|
|
|
+ self.defer = None
|
|
|
+
|
|
|
+ def player(self, chunk: bytes):
|
|
|
+ # If we receive anything -- ABORT!
|
|
|
+ self.deactivate()
|
|
|
+
|
|
|
+ def unknown_search(self, starting_sector):
|
|
|
+ seen = set()
|
|
|
+ possible = set()
|
|
|
+ possible.add(int(starting_sector))
|
|
|
+ done = False
|
|
|
+
|
|
|
+ while not done:
|
|
|
+ next_possible = set()
|
|
|
+
|
|
|
+ for s in possible:
|
|
|
+ p = self.game.gamedata.get_warps(s)
|
|
|
+ if p is not None:
|
|
|
+ for pos in p:
|
|
|
+ if pos not in seen:
|
|
|
+ next_possible.add(pos)
|
|
|
+ else:
|
|
|
+ log.msg("unknown found:", s)
|
|
|
+ self.unknown = s
|
|
|
+ done = True
|
|
|
+ break
|
|
|
+
|
|
|
+ seen.add(s)
|
|
|
+
|
|
|
+ if self.unknown is None:
|
|
|
+ log.msg("possible:", next_possible)
|
|
|
+ possible = next_possible
|
|
|
+ yield
|
|
|
+
|
|
|
+ def find_unknown(self, starting_sector):
|
|
|
+ log.msg("find_unknown( {0})".format(starting_sector))
|
|
|
+ d = defer.Deferred()
|
|
|
+ # Process things
|
|
|
+
|
|
|
+ self.unknown = None
|
|
|
+
|
|
|
+ c = coiterate(self.unknown_search(starting_sector))
|
|
|
+ c.addCallback(lambda unknown: d.callback(self.unknown))
|
|
|
+ return d
|
|
|
+
|
|
|
+ def show_unknown(self, sector):
|
|
|
+ if sector is None:
|
|
|
+ self.deactivate()
|
|
|
+ return
|
|
|
+ log.msg("Travel to {0}...".format(sector))
|
|
|
+ self.queue_player.put("{0}\r".format(sector))
|
|
|
+
|
|
|
+ def game_prompt(self, prompt: str):
|
|
|
+ log.msg("{0} : {1}".format(self.state, prompt))
|
|
|
+ if self.state == 3:
|
|
|
+ if re.match(r"Command \[TL=.* \(\?=Help\)\? :", prompt):
|
|
|
+ # this_sector code isn't working -- so! Get sector from prompt
|
|
|
+ self.state = 4
|
|
|
+ _, _, sector = prompt.partition(']:[')
|
|
|
+ sector, _, _ = sector.partition(']')
|
|
|
+ self.this_sector = int(sector)
|
|
|
+ # Ok, we're done with Density Scan, and we're back at the command prompt
|
|
|
+ log.msg("Go find the nearest unknown...")
|
|
|
+ d = self.find_unknown(sector)
|
|
|
+ d.addCallback(self.show_unknown)
|
|
|
+ elif self.state == 6:
|
|
|
+ # Engage the autopilot?
|
|
|
+ if prompt.startswith('Engage the Autopilot? (Y/N/Single step/Express) [Y]'):
|
|
|
+ self.state = 7
|
|
|
+ sector = self.path.pop(0)
|
|
|
+ if sector in self.density:
|
|
|
+ if self.density[sector] in (0, 100):
|
|
|
+ # Ok, looks safe!
|
|
|
+ self.queue_player.put("S")
|
|
|
+ self.this_sector = sector
|
|
|
+ else:
|
|
|
+ log.msg("FATAL: Density for {0} is {1}".format(sector, self.density[sector]))
|
|
|
+ self.deactivate()
|
|
|
+ return
|
|
|
+ else:
|
|
|
+ log.msg("{0} not in density scan? (how's that possible?)".format(sector))
|
|
|
+ self.deactivate()
|
|
|
+ return
|
|
|
+ elif self.state == 7:
|
|
|
+ # Ok, we're in a new sector (single stepping through space)
|
|
|
+ # update density scan
|
|
|
+ if prompt.startswith('Stop in this sector (Y,N,E,I,R,S,D,P,?) (?=Help) [N] ?'):
|
|
|
+ self.queue_player.put("SD")
|
|
|
+ self.state = 8
|
|
|
+ elif self.state == 10:
|
|
|
+ # Because we're here
|
|
|
+ if prompt.startswith('Stop in this sector (Y,N,E,I,R,S,D,P,?) (?=Help) [N] ?'):
|
|
|
+ self.queue_player.put("SH")
|
|
|
+ self.state = 11
|
|
|
+ elif self.state == 11:
|
|
|
+ if prompt.startswith('Stop in this sector (Y,N,E,I,R,S,D,P,?) (?=Help) [N] ?'):
|
|
|
+ # Ok, is the density scan clear?
|
|
|
+ sector = self.path.pop(0)
|
|
|
+ if sector in self.density:
|
|
|
+ if self.density[sector] in (0, 100):
|
|
|
+ # Ok, looks safe
|
|
|
+ self.queue_player.put("N")
|
|
|
+ self.state = 7
|
|
|
+ self.this_sector = sector
|
|
|
+ else:
|
|
|
+ log.msg("FATAL: Density for {0} is {1}".format(sector, self.density[sector]))
|
|
|
+ self.deactivate()
|
|
|
+ return
|
|
|
+ else:
|
|
|
+ log.msg("{0} not in density scane? (how's that possible...)".format(sector))
|
|
|
+ self.deactivate()
|
|
|
+ return
|
|
|
+
|
|
|
+ def next_unknown(self, sector):
|
|
|
+ log.msg("Unknown is :", sector)
|
|
|
+ self.deactivate()
|
|
|
+
|
|
|
+ def game_line(self, line: str):
|
|
|
+ log.msg("line {0} : {1}".format(self.state, line))
|
|
|
+
|
|
|
+ if line.startswith('Sector : '):
|
|
|
+ work = line.strip()
|
|
|
+ parts = re.split(r"\s+", work)
|
|
|
+ self.this_sector = int(parts[2])
|
|
|
+ log.msg("game_line sector", self.this_sector)
|
|
|
+ elif line.startswith("Command [TL=]"):
|
|
|
+ # Ok, get the current sector from this
|
|
|
+ _, _, sector = line.partition("]:[")
|
|
|
+ sector, _, _ = sector.partition("]")
|
|
|
+ self.this_sector = int(sector)
|
|
|
+ log.msg("current sector: {0}".format(self.this_sector))
|
|
|
+ elif line.startswith('Warps to Sector(s) :'):
|
|
|
+ # Warps to Sector(s) : 5468
|
|
|
+ _, _, work = line.partition(':')
|
|
|
+ work = work.strip().replace('(', '').replace(')', '').replace(' - ', ' ')
|
|
|
+ parts = [ int(x) for x in work.split(' ')]
|
|
|
+ self.path = list(parts)
|
|
|
+
|
|
|
+ if self.state in (1, 8):
|
|
|
+ if 'Relative Density Scan' in line:
|
|
|
+ # Start Density Scan
|
|
|
+ self.state += 1
|
|
|
+ self.density = {}
|
|
|
+
|
|
|
+ elif self.state in (2, 9):
|
|
|
+ if line == '':
|
|
|
+ # End of Density Scan
|
|
|
+ self.state += 1
|
|
|
+ log.msg("Density: {0}".format(self.density))
|
|
|
+ # self.deactivate()
|
|
|
+ elif line.startswith('Sector'):
|
|
|
+ # Parse Density Scan values
|
|
|
+ work = line.replace('(', '').replace(')', '').replace(':', '').replace('%', '').replace(',', '')
|
|
|
+ parts = re.split(r'\s+', work)
|
|
|
+ log.msg("Sector", parts)
|
|
|
+ sector = int(parts[1])
|
|
|
+ self.density[sector] = int(parts[3])
|
|
|
+ if parts[7] != '0':
|
|
|
+ log.msg("NavHaz {0} : {1}".format(parts[7], work))
|
|
|
+ self.density[sector] += 99
|
|
|
+ if parts[9] != 'No':
|
|
|
+ log.msg("Anom {0} : {1}".format(parts[9], work))
|
|
|
+ self.density[sector] += 990
|
|
|
+ elif self.state == 4:
|
|
|
+ # Looking for shortest path message / warp info
|
|
|
+ # Or possibly, "We're here!"
|
|
|
+ if line.startswith('Sector :') and str(self.unknown) in line:
|
|
|
+ # Ok, I'd guess that we're already there!
|
|
|
+ # Try it again!
|
|
|
+ self.queue_player.put("SD")
|
|
|
+ self.state = 1
|
|
|
+ if line.startswith('The shortest path'):
|
|
|
+ self.state = 5
|
|
|
+ elif self.state == 5:
|
|
|
+ # This is the warps line
|
|
|
+ # Can this be multiple lines?
|
|
|
+ if line == "":
|
|
|
+ self.state = 6
|
|
|
+ else:
|
|
|
+ work = line.replace("(", "").replace(")", "").replace(">", "").strip()
|
|
|
+ self.path = [int(x) for x in work.split()]
|
|
|
+ log.msg("Path:", self.path)
|
|
|
+
|
|
|
+ # Verify
|
|
|
+ current = self.path.pop(0)
|
|
|
+ if current != self.this_sector:
|
|
|
+ log.msg("Failed: {0} != {1}".format(current, self.this_sector))
|
|
|
+ self.deactivate()
|
|
|
+ return
|
|
|
+ elif self.state == 7:
|
|
|
+ if self.unknown == self.this_sector:
|
|
|
+ # We have arrived!
|
|
|
+ log.msg("We're here!")
|
|
|
+ self.deactivate()
|
|
|
+
|
|
|
+
|
|
|
|
|
|
class ProxyMenu(object):
|
|
|
""" Display ProxyMenu
|
|
|
@@ -1120,7 +1379,7 @@ class ProxyMenu(object):
|
|
|
# best_trades.append( "{0:5} -=- {1:5}".format(sector, w))
|
|
|
elif GameData.port_trading(pd['port'], self.game.gamedata.ports[w]['port']):
|
|
|
# ok_trades.append( "{0:5} -=- {1:5}".format(sector,w))
|
|
|
- ok_trades.append(GameData.port_show(sector, pd, w, wd))
|
|
|
+ ok_trades.append(self.game.gamedata.port_trade_show(sector, w))
|
|
|
yield
|
|
|
|
|
|
self.trade_report.append("Best Trades: (org/equ)")
|
|
|
@@ -1284,7 +1543,7 @@ class ProxyMenu(object):
|
|
|
|
|
|
menu_item("1", "Ports (Trades between two sectors)")
|
|
|
menu_item("2", "TODO")
|
|
|
- menu_item("3", "TODO")
|
|
|
+ menu_item("3", "Space... the final frontier...")
|
|
|
menu_item("X", "eXit")
|
|
|
self.queue_game.put(" " + c1 + "-=>" + self.r + " ")
|
|
|
|
|
|
@@ -1300,6 +1559,14 @@ class ProxyMenu(object):
|
|
|
d = ports.whenDone()
|
|
|
# d.addCallback(self.scripts_menu)
|
|
|
# d.addErrback(self.scripts_menu)
|
|
|
+ d.addCallback(self.deactivate_scripts_menu)
|
|
|
+ d.addErrback(self.deactivate_scripts_menu)
|
|
|
+ return
|
|
|
+ elif key == '3':
|
|
|
+ self.queue_game.put(self.c + key + self.r + self.nl)
|
|
|
+ space = ScriptSpace(self.game)
|
|
|
+ d = space.whenDone()
|
|
|
+
|
|
|
d.addCallback(self.deactivate_scripts_menu)
|
|
|
d.addErrback(self.deactivate_scripts_menu)
|
|
|
return
|
Steve Thielemann