diff options
Diffstat (limited to 'apworld')
-rw-r--r-- | apworld/__init__.py | 2 | ||||
-rw-r--r-- | apworld/client/client.gd | 77 | ||||
-rw-r--r-- | apworld/client/gamedata.gd | 132 | ||||
-rw-r--r-- | apworld/client/keyboard.gd | 36 | ||||
-rw-r--r-- | apworld/client/main.gd | 1 | ||||
-rw-r--r-- | apworld/client/manager.gd | 33 | ||||
-rw-r--r-- | apworld/client/pauseMenu.gd | 40 | ||||
-rw-r--r-- | apworld/client/player.gd | 1 | ||||
-rw-r--r-- | apworld/client/textclient.gd | 128 | ||||
-rw-r--r-- | apworld/client/worldport.gd | 10 | ||||
-rw-r--r-- | apworld/context.py | 469 | ||||
-rw-r--r-- | apworld/locations.py | 2 | ||||
-rw-r--r-- | apworld/player_logic.py | 13 | ||||
-rw-r--r-- | apworld/regions.py | 29 | ||||
-rw-r--r-- | apworld/static_logic.py | 1 | ||||
-rw-r--r-- | apworld/tracker.py | 106 |
16 files changed, 925 insertions, 155 deletions
diff --git a/apworld/__init__.py b/apworld/__init__.py index f99f5f5..8da6d1f 100644 --- a/apworld/__init__.py +++ b/apworld/__init__.py | |||
@@ -59,6 +59,8 @@ class Lingo2World(World): | |||
59 | item_name_groups = static_logic.item_name_groups | 59 | item_name_groups = static_logic.item_name_groups |
60 | location_name_groups = static_logic.location_name_groups | 60 | location_name_groups = static_logic.location_name_groups |
61 | 61 | ||
62 | for_tracker: ClassVar[bool] = False | ||
63 | |||
62 | player_logic: Lingo2PlayerLogic | 64 | player_logic: Lingo2PlayerLogic |
63 | 65 | ||
64 | port_pairings: dict[int, int] | 66 | port_pairings: dict[int, int] |
diff --git a/apworld/client/client.gd b/apworld/client/client.gd index 67edf29..a23e85a 100644 --- a/apworld/client/client.gd +++ b/apworld/client/client.gd | |||
@@ -18,9 +18,12 @@ var _seed = "" | |||
18 | var _team = 0 | 18 | var _team = 0 |
19 | var _slot = 0 | 19 | var _slot = 0 |
20 | var _checked_locations = [] | 20 | var _checked_locations = [] |
21 | var _checked_worldports = [] | ||
21 | var _received_indexes = [] | 22 | var _received_indexes = [] |
22 | var _received_items = {} | 23 | var _received_items = {} |
23 | var _slot_data = {} | 24 | var _slot_data = {} |
25 | var _accessible_locations = [] | ||
26 | var _accessible_worldports = [] | ||
24 | 27 | ||
25 | signal could_not_connect | 28 | signal could_not_connect |
26 | signal connect_status | 29 | signal connect_status |
@@ -30,6 +33,10 @@ signal location_scout_received(location_id, item_name, player_name, flags, for_s | |||
30 | signal text_message_received(message) | 33 | signal text_message_received(message) |
31 | signal item_sent_notification(message) | 34 | signal item_sent_notification(message) |
32 | signal hint_received(message) | 35 | signal hint_received(message) |
36 | signal accessible_locations_updated | ||
37 | signal checked_locations_updated | ||
38 | signal checked_worldports_updated | ||
39 | signal keyboard_update_received | ||
33 | 40 | ||
34 | 41 | ||
35 | func _init(): | 42 | func _init(): |
@@ -51,6 +58,9 @@ func _reset_state(): | |||
51 | _should_process = false | 58 | _should_process = false |
52 | _received_items = {} | 59 | _received_items = {} |
53 | _received_indexes = [] | 60 | _received_indexes = [] |
61 | _checked_worldports = [] | ||
62 | _accessible_locations = [] | ||
63 | _accessible_worldports = [] | ||
54 | 64 | ||
55 | 65 | ||
56 | func disconnect_from_ap(): | 66 | func disconnect_from_ap(): |
@@ -92,15 +102,34 @@ func _on_web_socket_server_message_received(_peer_id: int, packet: String) -> vo | |||
92 | _gen_version = message["generator_version"] | 102 | _gen_version = message["generator_version"] |
93 | _team = message["team"] | 103 | _team = message["team"] |
94 | _slot = message["slot"] | 104 | _slot = message["slot"] |
95 | _checked_locations = message["checked_locations"] | ||
96 | _slot_data = message["slot_data"] | 105 | _slot_data = message["slot_data"] |
97 | 106 | ||
107 | _checked_locations = [] | ||
108 | for location in message["checked_locations"]: | ||
109 | _checked_locations.append(int(message["checked_locations"])) | ||
110 | |||
98 | client_connected.emit(_slot_data) | 111 | client_connected.emit(_slot_data) |
99 | 112 | ||
100 | elif cmd == "ConnectionRefused": | 113 | elif cmd == "ConnectionRefused": |
101 | could_not_connect.emit(message["text"]) | 114 | could_not_connect.emit(message["text"]) |
102 | global._print("Connection to AP refused") | 115 | global._print("Connection to AP refused") |
103 | 116 | ||
117 | elif cmd == "UpdateLocations": | ||
118 | for location in message["locations"]: | ||
119 | var lint = int(location) | ||
120 | if not _checked_locations.has(lint): | ||
121 | _checked_locations.append(lint) | ||
122 | |||
123 | checked_locations_updated.emit() | ||
124 | |||
125 | elif cmd == "UpdateWorldports": | ||
126 | for port_id in message["worldports"]: | ||
127 | var lint = int(port_id) | ||
128 | if not _checked_worldports.has(lint): | ||
129 | _checked_worldports.append(lint) | ||
130 | |||
131 | checked_worldports_updated.emit() | ||
132 | |||
104 | elif cmd == "ItemReceived": | 133 | elif cmd == "ItemReceived": |
105 | for item in message["items"]: | 134 | for item in message["items"]: |
106 | var index = int(item["index"]) | 135 | var index = int(item["index"]) |
@@ -134,6 +163,26 @@ func _on_web_socket_server_message_received(_peer_id: int, packet: String) -> vo | |||
134 | int(loc["for_self"]) | 163 | int(loc["for_self"]) |
135 | ) | 164 | ) |
136 | 165 | ||
166 | elif cmd == "AccessibleLocations": | ||
167 | _accessible_locations.clear() | ||
168 | _accessible_worldports.clear() | ||
169 | |||
170 | for loc in message["locations"]: | ||
171 | _accessible_locations.append(int(loc)) | ||
172 | |||
173 | if "worldports" in message: | ||
174 | for port_id in message["worldports"]: | ||
175 | _accessible_worldports.append(int(port_id)) | ||
176 | |||
177 | accessible_locations_updated.emit() | ||
178 | |||
179 | elif cmd == "UpdateKeyboard": | ||
180 | var updates = {} | ||
181 | for k in message["updates"]: | ||
182 | updates[k] = int(message["updates"][k]) | ||
183 | |||
184 | keyboard_update_received.emit(updates) | ||
185 | |||
137 | 186 | ||
138 | func connectToServer(server, un, pw): | 187 | func connectToServer(server, un, pw): |
139 | sendMessage([{"cmd": "Connect", "server": server, "player": un, "password": pw}]) | 188 | sendMessage([{"cmd": "Connect", "server": server, "player": un, "password": pw}]) |
@@ -179,19 +228,6 @@ func sendLocations(loc_ids): | |||
179 | sendMessage([{"cmd": "LocationChecks", "locations": loc_ids}]) | 228 | sendMessage([{"cmd": "LocationChecks", "locations": loc_ids}]) |
180 | 229 | ||
181 | 230 | ||
182 | func setValue(key, value, operation = "replace"): | ||
183 | sendMessage( | ||
184 | [ | ||
185 | { | ||
186 | "cmd": "Set", | ||
187 | "key": "Lingo2_%d_%s" % [_slot, key], | ||
188 | "want_reply": false, | ||
189 | "operations": [{"operation": operation, "value": value}] | ||
190 | } | ||
191 | ] | ||
192 | ) | ||
193 | |||
194 | |||
195 | func say(textdata): | 231 | func say(textdata): |
196 | sendMessage([{"cmd": "Say", "text": textdata}]) | 232 | sendMessage([{"cmd": "Say", "text": textdata}]) |
197 | 233 | ||
@@ -204,6 +240,19 @@ func scoutLocations(loc_ids): | |||
204 | sendMessage([{"cmd": "LocationScouts", "locations": loc_ids}]) | 240 | sendMessage([{"cmd": "LocationScouts", "locations": loc_ids}]) |
205 | 241 | ||
206 | 242 | ||
243 | func updateKeyboard(updates): | ||
244 | sendMessage([{"cmd": "UpdateKeyboard", "keyboard": updates}]) | ||
245 | |||
246 | |||
247 | func checkWorldport(port_id): | ||
248 | if not _checked_worldports.has(port_id): | ||
249 | sendMessage([{"cmd": "CheckWorldport", "port_id": port_id}]) | ||
250 | |||
251 | |||
252 | func sendQuit(): | ||
253 | sendMessage([{"cmd": "Quit"}]) | ||
254 | |||
255 | |||
207 | func hasItem(item_id): | 256 | func hasItem(item_id): |
208 | return _received_items.has(item_id) | 257 | return _received_items.has(item_id) |
209 | 258 | ||
diff --git a/apworld/client/gamedata.gd b/apworld/client/gamedata.gd index 9eeec3b..e44fa17 100644 --- a/apworld/client/gamedata.gd +++ b/apworld/client/gamedata.gd | |||
@@ -13,6 +13,7 @@ var progressive_id_by_ap_id = {} | |||
13 | var letter_id_by_ap_id = {} | 13 | var letter_id_by_ap_id = {} |
14 | var symbol_item_ids = [] | 14 | var symbol_item_ids = [] |
15 | var anti_trap_ids = {} | 15 | var anti_trap_ids = {} |
16 | var location_name_by_id = {} | ||
16 | 17 | ||
17 | var kSYMBOL_ITEMS | 18 | var kSYMBOL_ITEMS |
18 | 19 | ||
@@ -70,6 +71,7 @@ func load(data_bytes): | |||
70 | 71 | ||
71 | if door.has_ap_id(): | 72 | if door.has_ap_id(): |
72 | door_id_by_ap_id[door.get_ap_id()] = door.get_id() | 73 | door_id_by_ap_id[door.get_ap_id()] = door.get_id() |
74 | location_name_by_id[door.get_ap_id()] = _get_door_location_name(door) | ||
73 | 75 | ||
74 | for painting in objects.get_paintings(): | 76 | for painting in objects.get_paintings(): |
75 | var room = objects.get_rooms()[painting.get_room_id()] | 77 | var room = objects.get_rooms()[painting.get_room_id()] |
@@ -95,6 +97,17 @@ func load(data_bytes): | |||
95 | 97 | ||
96 | for letter in objects.get_letters(): | 98 | for letter in objects.get_letters(): |
97 | letter_id_by_ap_id[letter.get_ap_id()] = letter.get_id() | 99 | letter_id_by_ap_id[letter.get_ap_id()] = letter.get_id() |
100 | location_name_by_id[letter.get_ap_id()] = _get_letter_location_name(letter) | ||
101 | |||
102 | for mastery in objects.get_masteries(): | ||
103 | location_name_by_id[mastery.get_ap_id()] = _get_mastery_location_name(mastery) | ||
104 | |||
105 | for ending in objects.get_endings(): | ||
106 | location_name_by_id[ending.get_ap_id()] = _get_ending_location_name(ending) | ||
107 | |||
108 | for keyholder in objects.get_keyholders(): | ||
109 | if keyholder.has_key(): | ||
110 | location_name_by_id[keyholder.get_ap_id()] = _get_keyholder_location_name(keyholder) | ||
98 | 111 | ||
99 | for panel in objects.get_panels(): | 112 | for panel in objects.get_panels(): |
100 | var room = objects.get_rooms()[panel.get_room_id()] | 113 | var room = objects.get_rooms()[panel.get_room_id()] |
@@ -148,12 +161,123 @@ func get_door_ap_id(door_id): | |||
148 | return null | 161 | return null |
149 | 162 | ||
150 | 163 | ||
164 | func get_door_map_name(door_id): | ||
165 | var door = objects.get_doors()[door_id] | ||
166 | var room = objects.get_rooms()[door.get_room_id()] | ||
167 | var map = objects.get_maps()[room.get_map_id()] | ||
168 | return map.get_name() | ||
169 | |||
170 | |||
151 | func get_door_receivers(door_id): | 171 | func get_door_receivers(door_id): |
152 | var door = objects.get_doors()[door_id] | 172 | var door = objects.get_doors()[door_id] |
153 | return door.get_receivers() | 173 | return door.get_receivers() |
154 | 174 | ||
155 | 175 | ||
156 | func get_door_map_name(door_id): | 176 | func get_worldport_display_name(port_id): |
157 | var door = objects.get_doors()[door_id] | 177 | var port = objects.get_ports()[port_id] |
158 | var map = objects.get_maps()[door.get_map_id()] | 178 | return "%s - %s (Worldport)" % [_get_room_object_map_name(port), port.get_name()] |
159 | return map.get_name() | 179 | |
180 | |||
181 | func _get_map_object_map_name(obj): | ||
182 | return objects.get_maps()[obj.get_map_id()].get_display_name() | ||
183 | |||
184 | |||
185 | func _get_room_object_map_name(obj): | ||
186 | return _get_map_object_map_name(objects.get_rooms()[obj.get_room_id()]) | ||
187 | |||
188 | |||
189 | func _get_room_object_location_prefix(obj): | ||
190 | var room = objects.get_rooms()[obj.get_room_id()] | ||
191 | var game_map = objects.get_maps()[room.get_map_id()] | ||
192 | |||
193 | if room.has_panel_display_name(): | ||
194 | return "%s (%s)" % [game_map.get_display_name(), room.get_panel_display_name()] | ||
195 | else: | ||
196 | return game_map.get_display_name() | ||
197 | |||
198 | |||
199 | func _get_door_location_name(door): | ||
200 | var map_part = _get_room_object_location_prefix(door) | ||
201 | |||
202 | if door.has_location_name(): | ||
203 | return "%s - %s" % [map_part, door.get_location_name()] | ||
204 | |||
205 | var generated_location_name = _get_generated_door_location_name(door) | ||
206 | if generated_location_name != null: | ||
207 | return generated_location_name | ||
208 | |||
209 | return "%s - %s" % [map_part, door.get_name()] | ||
210 | |||
211 | |||
212 | func _get_generated_door_location_name(door): | ||
213 | if door.get_type() != SCRIPT_proto.DoorType.STANDARD: | ||
214 | return null | ||
215 | |||
216 | if door.get_keyholders().size() > 0 or door.get_endings().size() > 0 or door.has_complete_at(): | ||
217 | return null | ||
218 | |||
219 | if door.get_panels().size() > 4: | ||
220 | return null | ||
221 | |||
222 | var map_areas = [] | ||
223 | for panel_id in door.get_panels(): | ||
224 | var panel = objects.get_panels()[panel_id.get_panel()] | ||
225 | var panel_room = objects.get_rooms()[panel.get_room_id()] | ||
226 | # It's okay if panel_display_name is not present because then it's coalesced with other unnamed areas. | ||
227 | if not map_areas.has(panel_room.get_panel_display_name()): | ||
228 | map_areas.append(panel_room.get_panel_display_name()) | ||
229 | |||
230 | if map_areas.size() > 1: | ||
231 | return null | ||
232 | |||
233 | var game_map = objects.get_maps()[door.get_map_id()] | ||
234 | var map_area = map_areas[0] | ||
235 | var map_part | ||
236 | if map_area == "": | ||
237 | map_part = game_map.get_display_name() | ||
238 | else: | ||
239 | map_part = "%s (%s)" % [game_map.get_display_name(), map_area] | ||
240 | |||
241 | var panel_names = [] | ||
242 | for panel_id in door.get_panels(): | ||
243 | var panel_data = objects.get_panels()[panel_id.get_panel()] | ||
244 | var panel_name | ||
245 | if panel_data.has_display_name(): | ||
246 | panel_name = panel_data.get_display_name() | ||
247 | else: | ||
248 | panel_name = panel_data.get_name() | ||
249 | |||
250 | var location_part | ||
251 | if panel_id.has_answer(): | ||
252 | location_part = "%s/%s" % [panel_name, panel_id.get_answer().to_upper()] | ||
253 | else: | ||
254 | location_part = panel_name | ||
255 | |||
256 | panel_names.append(location_part) | ||
257 | |||
258 | panel_names.sort() | ||
259 | |||
260 | return map_part + " - " + ", ".join(panel_names) | ||
261 | |||
262 | |||
263 | func _get_letter_location_name(letter): | ||
264 | var letter_level = 2 if letter.get_level2() else 1 | ||
265 | var letter_name = "%s%d" % [letter.get_key().to_upper(), letter_level] | ||
266 | return "%s - %s" % [_get_room_object_map_name(letter), letter_name] | ||
267 | |||
268 | |||
269 | func _get_mastery_location_name(mastery): | ||
270 | return "%s - Mastery" % _get_room_object_map_name(mastery) | ||
271 | |||
272 | |||
273 | func _get_ending_location_name(ending): | ||
274 | return ( | ||
275 | "%s - %s Ending" % [_get_room_object_map_name(ending), ending.get_name().to_pascal_case()] | ||
276 | ) | ||
277 | |||
278 | |||
279 | func _get_keyholder_location_name(keyholder): | ||
280 | return ( | ||
281 | "%s - %s Keyholder" | ||
282 | % [_get_room_object_location_prefix(keyholder), keyholder.get_key().to_upper()] | ||
283 | ) | ||
diff --git a/apworld/client/keyboard.gd b/apworld/client/keyboard.gd index 450566d..a59c4d0 100644 --- a/apworld/client/keyboard.gd +++ b/apworld/client/keyboard.gd | |||
@@ -48,6 +48,9 @@ func load_seed(): | |||
48 | if localdata.size() > 2: | 48 | if localdata.size() > 2: |
49 | keyholder_state = localdata[2] | 49 | keyholder_state = localdata[2] |
50 | 50 | ||
51 | if not letters_saved.is_empty(): | ||
52 | ap.client.updateKeyboard(letters_saved) | ||
53 | |||
51 | for k in kALL_LETTERS: | 54 | for k in kALL_LETTERS: |
52 | var level = 0 | 55 | var level = 0 |
53 | 56 | ||
@@ -105,10 +108,20 @@ func update_unlocks(): | |||
105 | 108 | ||
106 | 109 | ||
107 | func collect_local_letter(key, level): | 110 | func collect_local_letter(key, level): |
108 | if level < 0 or level > 2 or level < letters_saved.get(key, 0): | 111 | var ap = global.get_node("Archipelago") |
112 | var true_level = 0 | ||
113 | |||
114 | if ap.get_letter_behavior(key, false) == ap.kLETTER_BEHAVIOR_VANILLA: | ||
115 | true_level += 1 | ||
116 | if level == 2 and ap.get_letter_behavior(key, true) == ap.kLETTER_BEHAVIOR_VANILLA: | ||
117 | true_level += 1 | ||
118 | |||
119 | if true_level < letters_saved.get(key, 0): | ||
109 | return | 120 | return |
110 | 121 | ||
111 | letters_saved[key] = level | 122 | letters_saved[key] = true_level |
123 | |||
124 | ap.client.updateKeyboard({key: true_level}) | ||
112 | 125 | ||
113 | if letters_blocked.has(key): | 126 | if letters_blocked.has(key): |
114 | letters_blocked.erase(key) | 127 | letters_blocked.erase(key) |
@@ -197,3 +210,22 @@ func reset_keyholders(): | |||
197 | save() | 210 | save() |
198 | 211 | ||
199 | return cleared_anything | 212 | return cleared_anything |
213 | |||
214 | |||
215 | func remote_keyboard_updated(updates): | ||
216 | var reverse = {} | ||
217 | var should_update = false | ||
218 | |||
219 | for k in updates: | ||
220 | if not letters_saved.has(k) or updates[k] > letters_saved[k]: | ||
221 | letters_saved[k] = updates[k] | ||
222 | should_update = true | ||
223 | elif updates[k] < letters_saved[k]: | ||
224 | reverse[k] = letters_saved[k] | ||
225 | |||
226 | if should_update: | ||
227 | update_unlocks() | ||
228 | |||
229 | if not reverse.is_empty(): | ||
230 | var ap = global.get_node("Archipelago") | ||
231 | ap.client.updateKeyboard(reverse) | ||
diff --git a/apworld/client/main.gd b/apworld/client/main.gd index 9d66358..8425d8c 100644 --- a/apworld/client/main.gd +++ b/apworld/client/main.gd | |||
@@ -137,6 +137,7 @@ func _connect_pressed(): | |||
137 | func _back_pressed(): | 137 | func _back_pressed(): |
138 | var ap = global.get_node("Archipelago") | 138 | var ap = global.get_node("Archipelago") |
139 | ap.disconnect_from_ap() | 139 | ap.disconnect_from_ap() |
140 | ap.client.sendQuit() | ||
140 | 141 | ||
141 | get_tree().quit() | 142 | get_tree().quit() |
142 | 143 | ||
diff --git a/apworld/client/manager.gd b/apworld/client/manager.gd index 955d470..3facfba 100644 --- a/apworld/client/manager.gd +++ b/apworld/client/manager.gd | |||
@@ -14,6 +14,8 @@ var ap_user = "" | |||
14 | var ap_pass = "" | 14 | var ap_pass = "" |
15 | var connection_history = [] | 15 | var connection_history = [] |
16 | var show_compass = false | 16 | var show_compass = false |
17 | var show_locations = false | ||
18 | var show_minimap = false | ||
17 | 19 | ||
18 | var client | 20 | var client |
19 | var keyboard | 21 | var keyboard |
@@ -89,6 +91,12 @@ func _init(): | |||
89 | if data.size() > 4: | 91 | if data.size() > 4: |
90 | show_compass = data[4] | 92 | show_compass = data[4] |
91 | 93 | ||
94 | if data.size() > 5: | ||
95 | show_locations = data[5] | ||
96 | |||
97 | if data.size() > 6: | ||
98 | show_minimap = data[6] | ||
99 | |||
92 | 100 | ||
93 | func _ready(): | 101 | func _ready(): |
94 | client = SCRIPT_client.new() | 102 | client = SCRIPT_client.new() |
@@ -99,6 +107,9 @@ func _ready(): | |||
99 | client.text_message_received.connect(_process_text_message) | 107 | client.text_message_received.connect(_process_text_message) |
100 | client.item_sent_notification.connect(_process_item_sent_notification) | 108 | client.item_sent_notification.connect(_process_item_sent_notification) |
101 | client.hint_received.connect(_process_hint_received) | 109 | client.hint_received.connect(_process_hint_received) |
110 | client.accessible_locations_updated.connect(_on_accessible_locations_updated) | ||
111 | client.checked_locations_updated.connect(_on_checked_locations_updated) | ||
112 | client.checked_worldports_updated.connect(_on_checked_worldports_updated) | ||
102 | 113 | ||
103 | client.could_not_connect.connect(_client_could_not_connect) | 114 | client.could_not_connect.connect(_client_could_not_connect) |
104 | client.connect_status.connect(_client_connect_status) | 115 | client.connect_status.connect(_client_connect_status) |
@@ -108,6 +119,7 @@ func _ready(): | |||
108 | 119 | ||
109 | keyboard = SCRIPT_keyboard.new() | 120 | keyboard = SCRIPT_keyboard.new() |
110 | add_child(keyboard) | 121 | add_child(keyboard) |
122 | client.keyboard_update_received.connect(keyboard.remote_keyboard_updated) | ||
111 | 123 | ||
112 | 124 | ||
113 | func saveSettings(): | 125 | func saveSettings(): |
@@ -121,6 +133,8 @@ func saveSettings(): | |||
121 | ap_pass, | 133 | ap_pass, |
122 | connection_history, | 134 | connection_history, |
123 | show_compass, | 135 | show_compass, |
136 | show_locations, | ||
137 | show_minimap, | ||
124 | ] | 138 | ] |
125 | file.store_var(data, true) | 139 | file.store_var(data, true) |
126 | file.close() | 140 | file.close() |
@@ -182,6 +196,7 @@ func _process_item(item, amount): | |||
182 | if gamedata.get_door_map_name(lock[0]) != global.map: | 196 | if gamedata.get_door_map_name(lock[0]) != global.map: |
183 | continue | 197 | continue |
184 | 198 | ||
199 | # TODO: fix doors opening from door groups | ||
185 | var receivers = gamedata.get_door_receivers(lock[0]) | 200 | var receivers = gamedata.get_door_receivers(lock[0]) |
186 | var scene = get_tree().get_root().get_node_or_null("scene") | 201 | var scene = get_tree().get_root().get_node_or_null("scene") |
187 | if scene != null: | 202 | if scene != null: |
@@ -302,6 +317,24 @@ func _process_location_scout(location_id, item_name, player_name, flags, for_sel | |||
302 | collectable.setScoutedText(item_name) | 317 | collectable.setScoutedText(item_name) |
303 | 318 | ||
304 | 319 | ||
320 | func _on_accessible_locations_updated(): | ||
321 | var textclient_node = global.get_node("Textclient") | ||
322 | if textclient_node != null: | ||
323 | textclient_node.update_locations() | ||
324 | |||
325 | |||
326 | func _on_checked_locations_updated(): | ||
327 | var textclient_node = global.get_node("Textclient") | ||
328 | if textclient_node != null: | ||
329 | textclient_node.update_locations() | ||
330 | |||
331 | |||
332 | func _on_checked_worldports_updated(): | ||
333 | var textclient_node = global.get_node("Textclient") | ||
334 | if textclient_node != null: | ||
335 | textclient_node.update_locations() | ||
336 | |||
337 | |||
305 | func _client_could_not_connect(message): | 338 | func _client_could_not_connect(message): |
306 | could_not_connect.emit(message) | 339 | could_not_connect.emit(message) |
307 | 340 | ||
diff --git a/apworld/client/pauseMenu.gd b/apworld/client/pauseMenu.gd index 8bc12c6..72b45e8 100644 --- a/apworld/client/pauseMenu.gd +++ b/apworld/client/pauseMenu.gd | |||
@@ -1,6 +1,8 @@ | |||
1 | extends "res://scripts/ui/pauseMenu.gd" | 1 | extends "res://scripts/ui/pauseMenu.gd" |
2 | 2 | ||
3 | var compass_button | 3 | var compass_button |
4 | var locations_button | ||
5 | var minimap_button | ||
4 | 6 | ||
5 | 7 | ||
6 | func _ready(): | 8 | func _ready(): |
@@ -19,6 +21,24 @@ func _ready(): | |||
19 | compass_button.pressed.connect(_toggle_compass) | 21 | compass_button.pressed.connect(_toggle_compass) |
20 | ap_panel.add_child(compass_button) | 22 | ap_panel.add_child(compass_button) |
21 | 23 | ||
24 | locations_button = CheckBox.new() | ||
25 | locations_button.text = "show locations overlay" | ||
26 | locations_button.button_pressed = ap.show_locations | ||
27 | locations_button.position = Vector2(65, 200) | ||
28 | locations_button.theme = preload("res://assets/themes/baseUI.tres") | ||
29 | locations_button.add_theme_font_size_override("font_size", 60) | ||
30 | locations_button.pressed.connect(_toggle_locations) | ||
31 | ap_panel.add_child(locations_button) | ||
32 | |||
33 | minimap_button = CheckBox.new() | ||
34 | minimap_button.text = "show minimap" | ||
35 | minimap_button.button_pressed = ap.show_minimap | ||
36 | minimap_button.position = Vector2(65, 300) | ||
37 | minimap_button.theme = preload("res://assets/themes/baseUI.tres") | ||
38 | minimap_button.add_theme_font_size_override("font_size", 60) | ||
39 | minimap_button.pressed.connect(_toggle_minimap) | ||
40 | ap_panel.add_child(minimap_button) | ||
41 | |||
22 | super._ready() | 42 | super._ready() |
23 | 43 | ||
24 | 44 | ||
@@ -32,6 +52,7 @@ func _main_menu(): | |||
32 | global.get_node("Archipelago").disconnect_from_ap() | 52 | global.get_node("Archipelago").disconnect_from_ap() |
33 | global.get_node("Messages").clear() | 53 | global.get_node("Messages").clear() |
34 | global.get_node("Compass").visible = false | 54 | global.get_node("Compass").visible = false |
55 | global.get_node("Textclient").reset() | ||
35 | 56 | ||
36 | autosplitter.reset() | 57 | autosplitter.reset() |
37 | _unpause_game() | 58 | _unpause_game() |
@@ -49,3 +70,22 @@ func _toggle_compass(): | |||
49 | 70 | ||
50 | var compass = global.get_node("Compass") | 71 | var compass = global.get_node("Compass") |
51 | compass.visible = compass_button.button_pressed | 72 | compass.visible = compass_button.button_pressed |
73 | |||
74 | |||
75 | func _toggle_locations(): | ||
76 | var ap = global.get_node("Archipelago") | ||
77 | ap.show_locations = locations_button.button_pressed | ||
78 | ap.saveSettings() | ||
79 | |||
80 | var textclient = global.get_node("Textclient") | ||
81 | textclient.update_locations_visibility() | ||
82 | |||
83 | |||
84 | func _toggle_minimap(): | ||
85 | var ap = global.get_node("Archipelago") | ||
86 | ap.show_minimap = minimap_button.button_pressed | ||
87 | ap.saveSettings() | ||
88 | |||
89 | var minimap = get_tree().get_root().get_node("scene/Minimap") | ||
90 | if minimap != null: | ||
91 | minimap.visible = ap.show_minimap | ||
diff --git a/apworld/client/player.gd b/apworld/client/player.gd index fb88880..366c3b0 100644 --- a/apworld/client/player.gd +++ b/apworld/client/player.gd | |||
@@ -330,6 +330,7 @@ func _ready(): | |||
330 | 330 | ||
331 | var minimap = ap.SCRIPT_minimap.new() | 331 | var minimap = ap.SCRIPT_minimap.new() |
332 | minimap.name = "Minimap" | 332 | minimap.name = "Minimap" |
333 | minimap.visible = ap.show_minimap | ||
333 | get_parent().add_child.call_deferred(minimap) | 334 | get_parent().add_child.call_deferred(minimap) |
334 | 335 | ||
335 | super._ready() | 336 | super._ready() |
diff --git a/apworld/client/textclient.gd b/apworld/client/textclient.gd index 9841063..af155fb 100644 --- a/apworld/client/textclient.gd +++ b/apworld/client/textclient.gd | |||
@@ -1,35 +1,57 @@ | |||
1 | extends CanvasLayer | 1 | extends CanvasLayer |
2 | 2 | ||
3 | var tabs | ||
3 | var panel | 4 | var panel |
4 | var label | 5 | var label |
5 | var entry | 6 | var entry |
7 | var tracker_label | ||
6 | var is_open = false | 8 | var is_open = false |
7 | 9 | ||
10 | var locations_overlay | ||
11 | |||
8 | 12 | ||
9 | func _ready(): | 13 | func _ready(): |
10 | process_mode = ProcessMode.PROCESS_MODE_ALWAYS | 14 | process_mode = ProcessMode.PROCESS_MODE_ALWAYS |
11 | layer = 2 | 15 | layer = 2 |
12 | 16 | ||
13 | panel = Panel.new() | 17 | locations_overlay = RichTextLabel.new() |
14 | panel.set_name("Panel") | 18 | locations_overlay.name = "LocationsOverlay" |
15 | panel.offset_left = 100 | 19 | locations_overlay.offset_top = 220 |
16 | panel.offset_right = 1820 | 20 | locations_overlay.offset_bottom = 720 |
17 | panel.offset_top = 100 | 21 | locations_overlay.offset_left = 20 |
18 | panel.offset_bottom = 980 | 22 | locations_overlay.anchor_right = 1.0 |
19 | panel.visible = false | 23 | locations_overlay.offset_right = -20 |
20 | add_child(panel) | 24 | locations_overlay.scroll_active = false |
25 | locations_overlay.mouse_filter = Control.MOUSE_FILTER_IGNORE | ||
26 | add_child(locations_overlay) | ||
27 | update_locations_visibility() | ||
28 | |||
29 | tabs = TabContainer.new() | ||
30 | tabs.name = "Tabs" | ||
31 | tabs.offset_left = 100 | ||
32 | tabs.offset_right = 1820 | ||
33 | tabs.offset_top = 100 | ||
34 | tabs.offset_bottom = 980 | ||
35 | tabs.visible = false | ||
36 | tabs.theme = preload("res://assets/themes/baseUI.tres") | ||
37 | tabs.add_theme_font_size_override("font_size", 36) | ||
38 | add_child(tabs) | ||
39 | |||
40 | panel = MarginContainer.new() | ||
41 | panel.name = "Text Client" | ||
42 | panel.add_theme_constant_override("margin_top", 60) | ||
43 | panel.add_theme_constant_override("margin_left", 60) | ||
44 | panel.add_theme_constant_override("margin_right", 60) | ||
45 | panel.add_theme_constant_override("margin_bottom", 60) | ||
46 | tabs.add_child(panel) | ||
21 | 47 | ||
22 | label = RichTextLabel.new() | 48 | label = RichTextLabel.new() |
23 | label.set_name("Label") | 49 | label.set_name("Label") |
24 | label.offset_left = 80 | ||
25 | label.offset_right = 1640 | ||
26 | label.offset_top = 80 | ||
27 | label.offset_bottom = 720 | ||
28 | label.scroll_following = true | 50 | label.scroll_following = true |
29 | label.selection_enabled = true | 51 | label.selection_enabled = true |
30 | panel.add_child(label) | 52 | label.size_flags_horizontal = Control.SIZE_EXPAND_FILL |
31 | 53 | label.size_flags_vertical = Control.SIZE_EXPAND_FILL | |
32 | label.push_font(load("res://assets/fonts/Lingo2.ttf")) | 54 | label.push_font(preload("res://assets/fonts/Lingo2.ttf")) |
33 | label.push_font_size(36) | 55 | label.push_font_size(36) |
34 | 56 | ||
35 | var entry_style = StyleBoxFlat.new() | 57 | var entry_style = StyleBoxFlat.new() |
@@ -37,18 +59,30 @@ func _ready(): | |||
37 | 59 | ||
38 | entry = LineEdit.new() | 60 | entry = LineEdit.new() |
39 | entry.set_name("Entry") | 61 | entry.set_name("Entry") |
40 | entry.offset_left = 80 | 62 | entry.add_theme_font_override("font", preload("res://assets/fonts/Lingo2.ttf")) |
41 | entry.offset_right = 1640 | ||
42 | entry.offset_top = 760 | ||
43 | entry.offset_bottom = 840 | ||
44 | entry.add_theme_font_override("font", load("res://assets/fonts/Lingo2.ttf")) | ||
45 | entry.add_theme_font_size_override("font_size", 36) | 63 | entry.add_theme_font_size_override("font_size", 36) |
46 | entry.add_theme_color_override("font_color", Color(0, 0, 0, 1)) | 64 | entry.add_theme_color_override("font_color", Color(0, 0, 0, 1)) |
47 | entry.add_theme_color_override("cursor_color", Color(0, 0, 0, 1)) | 65 | entry.add_theme_color_override("cursor_color", Color(0, 0, 0, 1)) |
48 | entry.add_theme_stylebox_override("focus", entry_style) | 66 | entry.add_theme_stylebox_override("focus", entry_style) |
49 | panel.add_child(entry) | ||
50 | entry.text_submitted.connect(text_entered) | 67 | entry.text_submitted.connect(text_entered) |
51 | 68 | ||
69 | var tc_arranger = VBoxContainer.new() | ||
70 | tc_arranger.add_child(label) | ||
71 | tc_arranger.add_child(entry) | ||
72 | tc_arranger.add_theme_constant_override("separation", 40) | ||
73 | panel.add_child(tc_arranger) | ||
74 | |||
75 | var tracker_margins = MarginContainer.new() | ||
76 | tracker_margins.name = "Locations" | ||
77 | tracker_margins.add_theme_constant_override("margin_top", 60) | ||
78 | tracker_margins.add_theme_constant_override("margin_left", 60) | ||
79 | tracker_margins.add_theme_constant_override("margin_right", 60) | ||
80 | tracker_margins.add_theme_constant_override("margin_bottom", 60) | ||
81 | tabs.add_child(tracker_margins) | ||
82 | |||
83 | tracker_label = RichTextLabel.new() | ||
84 | tracker_margins.add_child(tracker_label) | ||
85 | |||
52 | 86 | ||
53 | func _input(event): | 87 | func _input(event): |
54 | if global.loaded and event is InputEventKey and event.pressed: | 88 | if global.loaded and event is InputEventKey and event.pressed: |
@@ -57,7 +91,7 @@ func _input(event): | |||
57 | is_open = true | 91 | is_open = true |
58 | get_tree().paused = true | 92 | get_tree().paused = true |
59 | Input.set_mouse_mode(Input.MOUSE_MODE_VISIBLE) | 93 | Input.set_mouse_mode(Input.MOUSE_MODE_VISIBLE) |
60 | panel.visible = true | 94 | tabs.visible = true |
61 | entry.grab_focus() | 95 | entry.grab_focus() |
62 | get_viewport().set_input_as_handled() | 96 | get_viewport().set_input_as_handled() |
63 | else: | 97 | else: |
@@ -72,7 +106,7 @@ func dismiss(): | |||
72 | if is_open: | 106 | if is_open: |
73 | get_tree().paused = false | 107 | get_tree().paused = false |
74 | Input.set_mouse_mode(Input.MOUSE_MODE_CAPTURED) | 108 | Input.set_mouse_mode(Input.MOUSE_MODE_CAPTURED) |
75 | panel.visible = false | 109 | tabs.visible = false |
76 | is_open = false | 110 | is_open = false |
77 | 111 | ||
78 | 112 | ||
@@ -93,3 +127,51 @@ func text_entered(text): | |||
93 | return | 127 | return |
94 | 128 | ||
95 | ap.client.say(cmd) | 129 | ap.client.say(cmd) |
130 | |||
131 | |||
132 | func update_locations(): | ||
133 | var ap = global.get_node("Archipelago") | ||
134 | var gamedata = global.get_node("Gamedata") | ||
135 | |||
136 | tracker_label.clear() | ||
137 | tracker_label.push_font(preload("res://assets/fonts/Lingo2.ttf")) | ||
138 | tracker_label.push_font_size(24) | ||
139 | |||
140 | locations_overlay.clear() | ||
141 | locations_overlay.push_font(preload("res://assets/fonts/Lingo2.ttf")) | ||
142 | locations_overlay.push_font_size(24) | ||
143 | locations_overlay.push_color(Color(0.9, 0.9, 0.9, 1)) | ||
144 | locations_overlay.push_outline_color(Color(0, 0, 0, 1)) | ||
145 | locations_overlay.push_outline_size(2) | ||
146 | |||
147 | var location_names = [] | ||
148 | for location_id in ap.client._accessible_locations: | ||
149 | if not ap.client._checked_locations.has(location_id): | ||
150 | var location_name = gamedata.location_name_by_id.get(location_id, "(Unknown)") | ||
151 | location_names.append(location_name) | ||
152 | |||
153 | for port_id in ap.client._accessible_worldports: | ||
154 | if not ap.client._checked_worldports.has(port_id): | ||
155 | var port_name = gamedata.get_worldport_display_name(port_id) | ||
156 | location_names.append(port_name) | ||
157 | |||
158 | location_names.sort() | ||
159 | |||
160 | var count = 0 | ||
161 | for location_name in location_names: | ||
162 | tracker_label.append_text("[p]%s[/p]" % location_name) | ||
163 | if count < 18: | ||
164 | locations_overlay.append_text("[p align=right]%s[/p]" % location_name) | ||
165 | count += 1 | ||
166 | |||
167 | if count > 18: | ||
168 | locations_overlay.append_text("[p align=right][lb]...[rb][/p]") | ||
169 | |||
170 | |||
171 | func update_locations_visibility(): | ||
172 | var ap = global.get_node("Archipelago") | ||
173 | locations_overlay.visible = ap.show_locations | ||
174 | |||
175 | |||
176 | func reset(): | ||
177 | locations_overlay.clear() | ||
diff --git a/apworld/client/worldport.gd b/apworld/client/worldport.gd index cdca248..ed9891e 100644 --- a/apworld/client/worldport.gd +++ b/apworld/client/worldport.gd | |||
@@ -3,6 +3,8 @@ extends "res://scripts/nodes/worldport.gd" | |||
3 | var absolute_rotation = false | 3 | var absolute_rotation = false |
4 | var target_rotation = 0 | 4 | var target_rotation = 0 |
5 | 5 | ||
6 | var port_id = null | ||
7 | |||
6 | 8 | ||
7 | func _ready(): | 9 | func _ready(): |
8 | var node_path = String( | 10 | var node_path = String( |
@@ -13,7 +15,7 @@ func _ready(): | |||
13 | 15 | ||
14 | if ap.shuffle_worldports: | 16 | if ap.shuffle_worldports: |
15 | var gamedata = global.get_node("Gamedata") | 17 | var gamedata = global.get_node("Gamedata") |
16 | var port_id = gamedata.get_port_for_map_node_path(global.map, node_path) | 18 | port_id = gamedata.get_port_for_map_node_path(global.map, node_path) |
17 | if port_id != null: | 19 | if port_id != null: |
18 | if port_id in ap.port_pairings: | 20 | if port_id in ap.port_pairings: |
19 | var target_port = gamedata.objects.get_ports()[ap.port_pairings[port_id]] | 21 | var target_port = gamedata.objects.get_ports()[ap.port_pairings[port_id]] |
@@ -29,6 +31,8 @@ func _ready(): | |||
29 | sets_entry_point = true | 31 | sets_entry_point = true |
30 | invisible = false | 32 | invisible = false |
31 | fades = true | 33 | fades = true |
34 | else: | ||
35 | port_id = null | ||
32 | 36 | ||
33 | if global.map == "icarus" and exit == "daedalus": | 37 | if global.map == "icarus" and exit == "daedalus": |
34 | if not ap.daedalus_roof_access: | 38 | if not ap.daedalus_roof_access: |
@@ -39,6 +43,10 @@ func _ready(): | |||
39 | 43 | ||
40 | func bodyEntered(body): | 44 | func bodyEntered(body): |
41 | if body.is_in_group("player"): | 45 | if body.is_in_group("player"): |
46 | if port_id != null: | ||
47 | var ap = global.get_node("Archipelago") | ||
48 | ap.client.checkWorldport(port_id) | ||
49 | |||
42 | if absolute_rotation: | 50 | if absolute_rotation: |
43 | entry_rotate.y = target_rotation - body.rotation_degrees.y | 51 | entry_rotate.y = target_rotation - body.rotation_degrees.y |
44 | 52 | ||
diff --git a/apworld/context.py b/apworld/context.py index 05f75a3..4a85868 100644 --- a/apworld/context.py +++ b/apworld/context.py | |||
@@ -8,37 +8,106 @@ import websockets | |||
8 | 8 | ||
9 | import Utils | 9 | import Utils |
10 | import settings | 10 | import settings |
11 | from BaseClasses import ItemClassification | ||
11 | from CommonClient import CommonContext, server_loop, gui_enabled, logger, get_base_parser, handle_url_arg | 12 | from CommonClient import CommonContext, server_loop, gui_enabled, logger, get_base_parser, handle_url_arg |
12 | from NetUtils import Endpoint, decode, encode | 13 | from NetUtils import Endpoint, decode, encode |
13 | from Utils import async_start | 14 | from Utils import async_start |
15 | from . import Lingo2World | ||
16 | from .tracker import Tracker | ||
14 | 17 | ||
15 | PORT = 43182 | 18 | ALL_LETTERS = "abcdefghijklmnopqrstuvwxyz" |
16 | MESSAGE_MAX_SIZE = 16*1024*1024 | 19 | MESSAGE_MAX_SIZE = 16*1024*1024 |
20 | PORT = 43182 | ||
21 | |||
22 | KEY_STORAGE_MAPPING = { | ||
23 | "a": (1, 0), "b": (1, 1), "c": (1, 2), "d": (1, 3), "e": (1, 4), "f": (1, 5), "g": (1, 6), "h": (1, 7), "i": (1, 8), | ||
24 | "j": (1, 9), "k": (1, 10), "l": (1, 11), "m": (1, 12), "n": (2, 0), "o": (2, 1), "p": (2, 2), "q": (2, 3), | ||
25 | "r": (2, 4), "s": (2, 5), "t": (2, 6), "u": (2, 7), "v": (2, 8), "w": (2, 9), "x": (2, 10), "y": (2, 11), | ||
26 | "z": (2, 12), | ||
27 | } | ||
28 | |||
29 | REVERSE_KEY_STORAGE_MAPPING = {t: k for k, t in KEY_STORAGE_MAPPING.items()} | ||
30 | |||
31 | |||
32 | class Lingo2Manager: | ||
33 | game_ctx: "Lingo2GameContext" | ||
34 | client_ctx: "Lingo2ClientContext" | ||
35 | tracker: Tracker | ||
36 | |||
37 | keyboard: dict[str, int] | ||
38 | worldports: set[int] | ||
39 | |||
40 | def __init__(self, game_ctx: "Lingo2GameContext", client_ctx: "Lingo2ClientContext"): | ||
41 | self.game_ctx = game_ctx | ||
42 | self.game_ctx.manager = self | ||
43 | self.client_ctx = client_ctx | ||
44 | self.client_ctx.manager = self | ||
45 | self.tracker = Tracker(self) | ||
46 | self.keyboard = {} | ||
47 | self.worldports = set() | ||
48 | |||
49 | self.reset() | ||
50 | |||
51 | def reset(self): | ||
52 | for k in ALL_LETTERS: | ||
53 | self.keyboard[k] = 0 | ||
54 | |||
55 | self.worldports = set() | ||
56 | |||
57 | def update_keyboard(self, new_keyboard: dict[str, int]) -> dict[str, int]: | ||
58 | ret: dict[str, int] = {} | ||
59 | |||
60 | for k, v in new_keyboard.items(): | ||
61 | if v > self.keyboard.get(k, 0): | ||
62 | self.keyboard[k] = v | ||
63 | ret[k] = v | ||
64 | |||
65 | if len(ret) > 0: | ||
66 | self.tracker.refresh_state() | ||
67 | self.game_ctx.send_accessible_locations() | ||
68 | |||
69 | return ret | ||
70 | |||
71 | def update_worldports(self, new_worldports: set[int]) -> set[int]: | ||
72 | ret = new_worldports.difference(self.worldports) | ||
73 | self.worldports.update(new_worldports) | ||
74 | |||
75 | if len(ret) > 0: | ||
76 | self.tracker.refresh_state() | ||
77 | self.game_ctx.send_accessible_locations() | ||
78 | |||
79 | return ret | ||
17 | 80 | ||
18 | 81 | ||
19 | class Lingo2GameContext: | 82 | class Lingo2GameContext: |
20 | server: Endpoint | None | 83 | server: Endpoint | None |
21 | client: "Lingo2ClientContext" | 84 | manager: Lingo2Manager |
22 | 85 | ||
23 | def __init__(self): | 86 | def __init__(self): |
24 | self.server = None | 87 | self.server = None |
25 | 88 | ||
26 | def send_connected(self): | 89 | def send_connected(self): |
90 | if self.server is None: | ||
91 | return | ||
92 | |||
27 | msg = { | 93 | msg = { |
28 | "cmd": "Connected", | 94 | "cmd": "Connected", |
29 | "user": self.client.username, | 95 | "user": self.manager.client_ctx.username, |
30 | "seed_name": self.client.seed_name, | 96 | "seed_name": self.manager.client_ctx.seed_name, |
31 | "version": self.client.server_version, | 97 | "version": self.manager.client_ctx.server_version, |
32 | "generator_version": self.client.generator_version, | 98 | "generator_version": self.manager.client_ctx.generator_version, |
33 | "team": self.client.team, | 99 | "team": self.manager.client_ctx.team, |
34 | "slot": self.client.slot, | 100 | "slot": self.manager.client_ctx.slot, |
35 | "checked_locations": self.client.checked_locations, | 101 | "checked_locations": self.manager.client_ctx.checked_locations, |
36 | "slot_data": self.client.slot_data, | 102 | "slot_data": self.manager.client_ctx.slot_data, |
37 | } | 103 | } |
38 | 104 | ||
39 | async_start(self.send_msgs([msg]), name="game Connected") | 105 | async_start(self.send_msgs([msg]), name="game Connected") |
40 | 106 | ||
41 | def send_item_sent_notification(self, item_name, receiver_name, item_flags): | 107 | def send_item_sent_notification(self, item_name, receiver_name, item_flags): |
108 | if self.server is None: | ||
109 | return | ||
110 | |||
42 | msg = { | 111 | msg = { |
43 | "cmd": "ItemSentNotif", | 112 | "cmd": "ItemSentNotif", |
44 | "item_name": item_name, | 113 | "item_name": item_name, |
@@ -49,6 +118,9 @@ class Lingo2GameContext: | |||
49 | async_start(self.send_msgs([msg]), name="item sent notif") | 118 | async_start(self.send_msgs([msg]), name="item sent notif") |
50 | 119 | ||
51 | def send_hint_received(self, item_name, location_name, receiver_name, item_flags, for_self): | 120 | def send_hint_received(self, item_name, location_name, receiver_name, item_flags, for_self): |
121 | if self.server is None: | ||
122 | return | ||
123 | |||
52 | msg = { | 124 | msg = { |
53 | "cmd": "HintReceived", | 125 | "cmd": "HintReceived", |
54 | "item_name": item_name, | 126 | "item_name": item_name, |
@@ -61,6 +133,9 @@ class Lingo2GameContext: | |||
61 | async_start(self.send_msgs([msg]), name="hint received notif") | 133 | async_start(self.send_msgs([msg]), name="hint received notif") |
62 | 134 | ||
63 | def send_item_received(self, items): | 135 | def send_item_received(self, items): |
136 | if self.server is None: | ||
137 | return | ||
138 | |||
64 | msg = { | 139 | msg = { |
65 | "cmd": "ItemReceived", | 140 | "cmd": "ItemReceived", |
66 | "items": items, | 141 | "items": items, |
@@ -69,6 +144,9 @@ class Lingo2GameContext: | |||
69 | async_start(self.send_msgs([msg]), name="item received") | 144 | async_start(self.send_msgs([msg]), name="item received") |
70 | 145 | ||
71 | def send_location_info(self, locations): | 146 | def send_location_info(self, locations): |
147 | if self.server is None: | ||
148 | return | ||
149 | |||
72 | msg = { | 150 | msg = { |
73 | "cmd": "LocationInfo", | 151 | "cmd": "LocationInfo", |
74 | "locations": locations, | 152 | "locations": locations, |
@@ -77,6 +155,9 @@ class Lingo2GameContext: | |||
77 | async_start(self.send_msgs([msg]), name="location info") | 155 | async_start(self.send_msgs([msg]), name="location info") |
78 | 156 | ||
79 | def send_text_message(self, parts): | 157 | def send_text_message(self, parts): |
158 | if self.server is None: | ||
159 | return | ||
160 | |||
80 | msg = { | 161 | msg = { |
81 | "cmd": "TextMessage", | 162 | "cmd": "TextMessage", |
82 | "data": parts, | 163 | "data": parts, |
@@ -84,6 +165,53 @@ class Lingo2GameContext: | |||
84 | 165 | ||
85 | async_start(self.send_msgs([msg]), name="notif") | 166 | async_start(self.send_msgs([msg]), name="notif") |
86 | 167 | ||
168 | def send_accessible_locations(self): | ||
169 | if self.server is None: | ||
170 | return | ||
171 | |||
172 | msg = { | ||
173 | "cmd": "AccessibleLocations", | ||
174 | "locations": list(self.manager.tracker.accessible_locations), | ||
175 | } | ||
176 | |||
177 | if len(self.manager.tracker.accessible_worldports) > 0: | ||
178 | msg["worldports"] = list(self.manager.tracker.accessible_worldports) | ||
179 | |||
180 | async_start(self.send_msgs([msg]), name="accessible locations") | ||
181 | |||
182 | def send_update_locations(self, locations): | ||
183 | if self.server is None: | ||
184 | return | ||
185 | |||
186 | msg = { | ||
187 | "cmd": "UpdateLocations", | ||
188 | "locations": locations, | ||
189 | } | ||
190 | |||
191 | async_start(self.send_msgs([msg]), name="update locations") | ||
192 | |||
193 | def send_update_keyboard(self, updates): | ||
194 | if self.server is None: | ||
195 | return | ||
196 | |||
197 | msg = { | ||
198 | "cmd": "UpdateKeyboard", | ||
199 | "updates": updates, | ||
200 | } | ||
201 | |||
202 | async_start(self.send_msgs([msg]), name="update keyboard") | ||
203 | |||
204 | def send_update_worldports(self, worldports): | ||
205 | if self.server is None: | ||
206 | return | ||
207 | |||
208 | msg = { | ||
209 | "cmd": "UpdateWorldports", | ||
210 | "worldports": worldports, | ||
211 | } | ||
212 | |||
213 | async_start(self.send_msgs([msg]), name="update worldports") | ||
214 | |||
87 | async def send_msgs(self, msgs: list[Any]) -> None: | 215 | async def send_msgs(self, msgs: list[Any]) -> None: |
88 | """ `msgs` JSON serializable """ | 216 | """ `msgs` JSON serializable """ |
89 | if not self.server or not self.server.socket.open or self.server.socket.closed: | 217 | if not self.server or not self.server.socket.open or self.server.socket.closed: |
@@ -92,7 +220,7 @@ class Lingo2GameContext: | |||
92 | 220 | ||
93 | 221 | ||
94 | class Lingo2ClientContext(CommonContext): | 222 | class Lingo2ClientContext(CommonContext): |
95 | game_ctx: Lingo2GameContext | 223 | manager: Lingo2Manager |
96 | 224 | ||
97 | game = "Lingo 2" | 225 | game = "Lingo 2" |
98 | items_handling = 0b111 | 226 | items_handling = 0b111 |
@@ -117,104 +245,226 @@ class Lingo2ClientContext(CommonContext): | |||
117 | elif cmd == "Connected": | 245 | elif cmd == "Connected": |
118 | self.slot_data = args.get("slot_data", None) | 246 | self.slot_data = args.get("slot_data", None) |
119 | 247 | ||
120 | if self.game_ctx.server is not None: | 248 | self.manager.reset() |
121 | self.game_ctx.send_connected() | 249 | |
250 | self.manager.game_ctx.send_connected() | ||
251 | |||
252 | self.manager.tracker.setup_slot(self.slot_data) | ||
253 | self.manager.tracker.set_checked_locations(self.checked_locations) | ||
254 | self.manager.game_ctx.send_accessible_locations() | ||
255 | |||
256 | self.set_notify(self.get_datastorage_key("keyboard1"), self.get_datastorage_key("keyboard2")) | ||
257 | msg_batch = [{ | ||
258 | "cmd": "Set", | ||
259 | "key": self.get_datastorage_key("keyboard1"), | ||
260 | "default": 0, | ||
261 | "want_reply": True, | ||
262 | "operations": [{"operation": "default", "value": 0}] | ||
263 | }, { | ||
264 | "cmd": "Set", | ||
265 | "key": self.get_datastorage_key("keyboard2"), | ||
266 | "default": 0, | ||
267 | "want_reply": True, | ||
268 | "operations": [{"operation": "default", "value": 0}] | ||
269 | }] | ||
270 | |||
271 | if self.slot_data["shuffle_worldports"]: | ||
272 | self.set_notify(self.get_datastorage_key("worldports")) | ||
273 | msg_batch.append({ | ||
274 | "cmd": "Set", | ||
275 | "key": self.get_datastorage_key("worldports"), | ||
276 | "default": [], | ||
277 | "want_reply": True, | ||
278 | "operations": [{"operation": "default", "value": []}] | ||
279 | }) | ||
280 | |||
281 | async_start(self.send_msgs(msg_batch), name="default keys") | ||
282 | elif cmd == "RoomUpdate": | ||
283 | self.manager.tracker.set_checked_locations(self.checked_locations) | ||
284 | self.manager.game_ctx.send_update_locations(args["checked_locations"]) | ||
122 | elif cmd == "ReceivedItems": | 285 | elif cmd == "ReceivedItems": |
123 | if self.game_ctx.server is not None: | 286 | self.manager.tracker.set_collected_items(self.items_received) |
124 | cur_index = 0 | ||
125 | items = [] | ||
126 | 287 | ||
127 | for item in args["items"]: | 288 | cur_index = 0 |
128 | index = cur_index + args["index"] | 289 | items = [] |
129 | cur_index += 1 | ||
130 | 290 | ||
131 | item_msg = { | 291 | for item in args["items"]: |
132 | "id": item.item, | 292 | index = cur_index + args["index"] |
133 | "index": index, | 293 | cur_index += 1 |
134 | "flags": item.flags, | ||
135 | "text": self.item_names.lookup_in_slot(item.item, self.slot), | ||
136 | } | ||
137 | 294 | ||
138 | if item.player != self.slot: | 295 | item_msg = { |
139 | item_msg["sender"] = self.player_names.get(item.player) | 296 | "id": item.item, |
297 | "index": index, | ||
298 | "flags": item.flags, | ||
299 | "text": self.item_names.lookup_in_slot(item.item, self.slot), | ||
300 | } | ||
140 | 301 | ||
141 | items.append(item_msg) | 302 | if item.player != self.slot: |
303 | item_msg["sender"] = self.player_names.get(item.player) | ||
142 | 304 | ||
143 | self.game_ctx.send_item_received(items) | 305 | items.append(item_msg) |
144 | elif cmd == "PrintJSON": | ||
145 | if self.game_ctx.server is not None: | ||
146 | if "receiving" in args and "item" in args and args["item"].player == self.slot: | ||
147 | item_name = self.item_names.lookup_in_slot(args["item"].item, args["receiving"]) | ||
148 | location_name = self.location_names.lookup_in_slot(args["item"].location, args["item"].player) | ||
149 | receiver_name = self.player_names.get(args["receiving"]) | ||
150 | |||
151 | if args["type"] == "Hint" and not args.get("found", False): | ||
152 | self.game_ctx.send_hint_received(item_name, location_name, receiver_name, args["item"].flags, | ||
153 | int(args["receiving"]) == self.slot) | ||
154 | elif args["receiving"] != self.slot: | ||
155 | self.game_ctx.send_item_sent_notification(item_name, receiver_name, args["item"].flags) | ||
156 | |||
157 | parts = [] | ||
158 | for message_part in args["data"]: | ||
159 | if "type" not in message_part and "text" in message_part: | ||
160 | parts.append({"type": "text", "text": message_part["text"]}) | ||
161 | elif message_part["type"] == "player_id": | ||
162 | parts.append({ | ||
163 | "type": "player", | ||
164 | "text": self.player_names.get(int(message_part["text"])), | ||
165 | "self": int(int(message_part["text"]) == self.slot), | ||
166 | }) | ||
167 | elif message_part["type"] == "item_id": | ||
168 | parts.append({ | ||
169 | "type": "item", | ||
170 | "text": self.item_names.lookup_in_slot(int(message_part["text"]), message_part["player"]), | ||
171 | "flags": message_part["flags"], | ||
172 | }) | ||
173 | elif message_part["type"] == "location_id": | ||
174 | parts.append({ | ||
175 | "type": "location", | ||
176 | "text": self.location_names.lookup_in_slot(int(message_part["text"]), | ||
177 | message_part["player"]) | ||
178 | }) | ||
179 | elif "text" in message_part: | ||
180 | parts.append({"type": "text", "text": message_part["text"]}) | ||
181 | |||
182 | self.game_ctx.send_text_message(parts) | ||
183 | elif cmd == "LocationInfo": | ||
184 | if self.game_ctx.server is not None: | ||
185 | locations = [] | ||
186 | |||
187 | for location in args["locations"]: | ||
188 | locations.append({ | ||
189 | "id": location.location, | ||
190 | "item": self.item_names.lookup_in_slot(location.item, location.player), | ||
191 | "player": self.player_names.get(location.player), | ||
192 | "flags": location.flags, | ||
193 | "self": int(location.player) == self.slot, | ||
194 | }) | ||
195 | 306 | ||
196 | self.game_ctx.send_location_info(locations) | 307 | self.manager.game_ctx.send_item_received(items) |
197 | 308 | ||
309 | if any(ItemClassification.progression in ItemClassification(item.flags) for item in args["items"]): | ||
310 | self.manager.game_ctx.send_accessible_locations() | ||
311 | elif cmd == "PrintJSON": | ||
312 | if "receiving" in args and "item" in args and args["item"].player == self.slot: | ||
313 | item_name = self.item_names.lookup_in_slot(args["item"].item, args["receiving"]) | ||
314 | location_name = self.location_names.lookup_in_slot(args["item"].location, args["item"].player) | ||
315 | receiver_name = self.player_names.get(args["receiving"]) | ||
316 | |||
317 | if args["type"] == "Hint" and not args.get("found", False): | ||
318 | self.manager.game_ctx.send_hint_received(item_name, location_name, receiver_name, args["item"].flags, | ||
319 | int(args["receiving"]) == self.slot) | ||
320 | elif args["receiving"] != self.slot: | ||
321 | self.manager.game_ctx.send_item_sent_notification(item_name, receiver_name, args["item"].flags) | ||
322 | |||
323 | parts = [] | ||
324 | for message_part in args["data"]: | ||
325 | if "type" not in message_part and "text" in message_part: | ||
326 | parts.append({"type": "text", "text": message_part["text"]}) | ||
327 | elif message_part["type"] == "player_id": | ||
328 | parts.append({ | ||
329 | "type": "player", | ||
330 | "text": self.player_names.get(int(message_part["text"])), | ||
331 | "self": int(int(message_part["text"]) == self.slot), | ||
332 | }) | ||
333 | elif message_part["type"] == "item_id": | ||
334 | parts.append({ | ||
335 | "type": "item", | ||
336 | "text": self.item_names.lookup_in_slot(int(message_part["text"]), message_part["player"]), | ||
337 | "flags": message_part["flags"], | ||
338 | }) | ||
339 | elif message_part["type"] == "location_id": | ||
340 | parts.append({ | ||
341 | "type": "location", | ||
342 | "text": self.location_names.lookup_in_slot(int(message_part["text"]), | ||
343 | message_part["player"]) | ||
344 | }) | ||
345 | elif "text" in message_part: | ||
346 | parts.append({"type": "text", "text": message_part["text"]}) | ||
198 | 347 | ||
199 | async def pipe_loop(ctx: Lingo2GameContext): | 348 | self.manager.game_ctx.send_text_message(parts) |
200 | while not ctx.client.exit_event.is_set(): | 349 | elif cmd == "LocationInfo": |
350 | locations = [] | ||
351 | |||
352 | for location in args["locations"]: | ||
353 | locations.append({ | ||
354 | "id": location.location, | ||
355 | "item": self.item_names.lookup_in_slot(location.item, location.player), | ||
356 | "player": self.player_names.get(location.player), | ||
357 | "flags": location.flags, | ||
358 | "self": int(location.player) == self.slot, | ||
359 | }) | ||
360 | |||
361 | self.manager.game_ctx.send_location_info(locations) | ||
362 | elif cmd == "SetReply": | ||
363 | if args["key"] == self.get_datastorage_key("keyboard1"): | ||
364 | self.handle_keyboard_update(1, args) | ||
365 | elif args["key"] == self.get_datastorage_key("keyboard2"): | ||
366 | self.handle_keyboard_update(2, args) | ||
367 | elif args["key"] == self.get_datastorage_key("worldports"): | ||
368 | updates = self.manager.update_worldports(set(args["value"])) | ||
369 | if len(updates) > 0: | ||
370 | self.manager.game_ctx.send_update_worldports(updates) | ||
371 | |||
372 | def get_datastorage_key(self, name: str): | ||
373 | return f"Lingo2_{self.slot}_{name}" | ||
374 | |||
375 | async def update_keyboard(self, updates: dict[str, int]): | ||
376 | kb1 = 0 | ||
377 | kb2 = 0 | ||
378 | |||
379 | for k, v in updates.items(): | ||
380 | if v == 0: | ||
381 | continue | ||
382 | |||
383 | effect = 0 | ||
384 | if v >= 1: | ||
385 | effect |= 1 | ||
386 | if v == 2: | ||
387 | effect |= 2 | ||
388 | |||
389 | pos = KEY_STORAGE_MAPPING[k] | ||
390 | if pos[0] == 1: | ||
391 | kb1 |= (effect << pos[1] * 2) | ||
392 | else: | ||
393 | kb2 |= (effect << pos[1] * 2) | ||
394 | |||
395 | msgs = [] | ||
396 | |||
397 | if kb1 != 0: | ||
398 | msgs.append({ | ||
399 | "cmd": "Set", | ||
400 | "key": self.get_datastorage_key("keyboard1"), | ||
401 | "want_reply": True, | ||
402 | "operations": [{ | ||
403 | "operation": "or", | ||
404 | "value": kb1 | ||
405 | }] | ||
406 | }) | ||
407 | |||
408 | if kb2 != 0: | ||
409 | msgs.append({ | ||
410 | "cmd": "Set", | ||
411 | "key": self.get_datastorage_key("keyboard2"), | ||
412 | "want_reply": True, | ||
413 | "operations": [{ | ||
414 | "operation": "or", | ||
415 | "value": kb2 | ||
416 | }] | ||
417 | }) | ||
418 | |||
419 | if len(msgs) > 0: | ||
420 | await self.send_msgs(msgs) | ||
421 | |||
422 | def handle_keyboard_update(self, field: int, args: dict[str, Any]): | ||
423 | keys = {} | ||
424 | value = args["value"] | ||
425 | |||
426 | for i in range(0, 13): | ||
427 | if (value & (1 << (i * 2))) != 0: | ||
428 | keys[REVERSE_KEY_STORAGE_MAPPING[(field, i)]] = 1 | ||
429 | if (value & (1 << (i * 2 + 1))) != 0: | ||
430 | keys[REVERSE_KEY_STORAGE_MAPPING[(field, i)]] = 2 | ||
431 | |||
432 | updates = self.manager.update_keyboard(keys) | ||
433 | if len(updates) > 0: | ||
434 | self.manager.game_ctx.send_update_keyboard(updates) | ||
435 | |||
436 | async def update_worldports(self, updates: set[int]): | ||
437 | await self.send_msgs([{ | ||
438 | "cmd": "Set", | ||
439 | "key": self.get_datastorage_key("worldports"), | ||
440 | "want_reply": True, | ||
441 | "operations": [{ | ||
442 | "operation": "update", | ||
443 | "value": updates | ||
444 | }] | ||
445 | }]) | ||
446 | |||
447 | |||
448 | async def pipe_loop(manager: Lingo2Manager): | ||
449 | while not manager.client_ctx.exit_event.is_set(): | ||
201 | try: | 450 | try: |
202 | socket = await websockets.connect("ws://localhost", port=PORT, ping_timeout=None, ping_interval=None, | 451 | socket = await websockets.connect("ws://localhost", port=PORT, ping_timeout=None, ping_interval=None, |
203 | max_size=MESSAGE_MAX_SIZE) | 452 | max_size=MESSAGE_MAX_SIZE) |
204 | ctx.server = Endpoint(socket) | 453 | manager.game_ctx.server = Endpoint(socket) |
205 | logger.info("Connected to Lingo 2!") | 454 | logger.info("Connected to Lingo 2!") |
206 | if ctx.client.auth is not None: | 455 | if manager.client_ctx.auth is not None: |
207 | ctx.send_connected() | 456 | manager.game_ctx.send_connected() |
208 | async for data in ctx.server.socket: | 457 | manager.game_ctx.send_accessible_locations() |
458 | async for data in manager.game_ctx.server.socket: | ||
209 | for msg in decode(data): | 459 | for msg in decode(data): |
210 | await process_game_cmd(ctx, msg) | 460 | await process_game_cmd(manager, msg) |
211 | except ConnectionRefusedError: | 461 | except ConnectionRefusedError: |
212 | logger.info("Could not connect to Lingo 2.") | 462 | logger.info("Could not connect to Lingo 2.") |
213 | finally: | 463 | finally: |
214 | ctx.server = None | 464 | manager.game_ctx.server = None |
215 | 465 | ||
216 | 466 | ||
217 | async def process_game_cmd(ctx: Lingo2GameContext, args: dict): | 467 | async def process_game_cmd(manager: Lingo2Manager, args: dict): |
218 | cmd = args["cmd"] | 468 | cmd = args["cmd"] |
219 | 469 | ||
220 | if cmd == "Connect": | 470 | if cmd == "Connect": |
@@ -227,20 +477,38 @@ async def process_game_cmd(ctx: Lingo2GameContext, args: dict): | |||
227 | else: | 477 | else: |
228 | server_address = f"{player}:None@{server}" | 478 | server_address = f"{player}:None@{server}" |
229 | 479 | ||
230 | async_start(ctx.client.connect(server_address), name="client connect") | 480 | async_start(manager.client_ctx.connect(server_address), name="client connect") |
231 | elif cmd == "Disconnect": | 481 | elif cmd == "Disconnect": |
232 | async_start(ctx.client.disconnect(), name="client disconnect") | 482 | async_start(manager.client_ctx.disconnect(), name="client disconnect") |
233 | elif cmd in ["Sync", "LocationChecks", "Say", "StatusUpdate", "LocationScouts"]: | 483 | elif cmd in ["Sync", "LocationChecks", "Say", "StatusUpdate", "LocationScouts"]: |
234 | async_start(ctx.client.send_msgs([args]), name="client forward") | 484 | async_start(manager.client_ctx.send_msgs([args]), name="client forward") |
485 | elif cmd == "UpdateKeyboard": | ||
486 | updates = manager.update_keyboard(args["keyboard"]) | ||
487 | if len(updates) > 0: | ||
488 | async_start(manager.client_ctx.update_keyboard(updates), name="client update keyboard") | ||
489 | elif cmd == "CheckWorldport": | ||
490 | port_id = args["port_id"] | ||
491 | worldports = {port_id} | ||
492 | if str(port_id) in manager.client_ctx.slot_data["port_pairings"]: | ||
493 | worldports.add(manager.client_ctx.slot_data["port_pairings"][str(port_id)]) | ||
494 | |||
495 | updates = manager.update_worldports(worldports) | ||
496 | if len(updates) > 0: | ||
497 | async_start(manager.client_ctx.update_worldports(updates), name="client update worldports") | ||
498 | elif cmd == "Quit": | ||
499 | manager.client_ctx.exit_event.set() | ||
235 | 500 | ||
236 | 501 | ||
237 | async def run_game(): | 502 | async def run_game(): |
238 | exe_file = settings.get_settings().lingo2_options.exe_file | 503 | exe_file = settings.get_settings().lingo2_options.exe_file |
239 | 504 | ||
240 | from worlds import AutoWorldRegister | 505 | # This ensures we can use Steam features without having to open the game |
241 | world = AutoWorldRegister.world_types["Lingo 2"] | 506 | # through steam. |
507 | steam_appid_path = os.path.join(os.path.dirname(exe_file), "steam_appid.txt") | ||
508 | with open(steam_appid_path, "w") as said_handle: | ||
509 | said_handle.write("2523310") | ||
242 | 510 | ||
243 | if world.zip_path is not None: | 511 | if Lingo2World.zip_path is not None: |
244 | # This is a packaged apworld. | 512 | # This is a packaged apworld. |
245 | init_scene = pkgutil.get_data(__name__, "client/run_from_apworld.tscn") | 513 | init_scene = pkgutil.get_data(__name__, "client/run_from_apworld.tscn") |
246 | init_path = Utils.local_path("data", "lingo2_init.tscn") | 514 | init_path = Utils.local_path("data", "lingo2_init.tscn") |
@@ -254,7 +522,7 @@ async def run_game(): | |||
254 | "--scene", | 522 | "--scene", |
255 | init_path, | 523 | init_path, |
256 | "--", | 524 | "--", |
257 | str(world.zip_path.absolute()), | 525 | str(Lingo2World.zip_path.absolute()), |
258 | ], | 526 | ], |
259 | cwd=os.path.dirname(exe_file), | 527 | cwd=os.path.dirname(exe_file), |
260 | ) | 528 | ) |
@@ -278,9 +546,7 @@ def client_main(*launch_args: str) -> None: | |||
278 | 546 | ||
279 | client_ctx = Lingo2ClientContext(args.connect, args.password) | 547 | client_ctx = Lingo2ClientContext(args.connect, args.password) |
280 | game_ctx = Lingo2GameContext() | 548 | game_ctx = Lingo2GameContext() |
281 | 549 | manager = Lingo2Manager(game_ctx, client_ctx) | |
282 | client_ctx.game_ctx = game_ctx | ||
283 | game_ctx.client = client_ctx | ||
284 | 550 | ||
285 | client_ctx.server_task = asyncio.create_task(server_loop(client_ctx), name="ServerLoop") | 551 | client_ctx.server_task = asyncio.create_task(server_loop(client_ctx), name="ServerLoop") |
286 | 552 | ||
@@ -288,7 +554,7 @@ def client_main(*launch_args: str) -> None: | |||
288 | client_ctx.run_gui() | 554 | client_ctx.run_gui() |
289 | client_ctx.run_cli() | 555 | client_ctx.run_cli() |
290 | 556 | ||
291 | pipe_task = asyncio.create_task(pipe_loop(game_ctx), name="GameWatcher") | 557 | pipe_task = asyncio.create_task(pipe_loop(manager), name="GameWatcher") |
292 | 558 | ||
293 | try: | 559 | try: |
294 | await pipe_task | 560 | await pipe_task |
@@ -296,6 +562,7 @@ def client_main(*launch_args: str) -> None: | |||
296 | logger.exception(e) | 562 | logger.exception(e) |
297 | 563 | ||
298 | await client_ctx.exit_event.wait() | 564 | await client_ctx.exit_event.wait() |
565 | client_ctx.ui.stop() | ||
299 | await client_ctx.shutdown() | 566 | await client_ctx.shutdown() |
300 | 567 | ||
301 | Utils.init_logging("Lingo2Client", exception_logger="Client") | 568 | Utils.init_logging("Lingo2Client", exception_logger="Client") |
diff --git a/apworld/locations.py b/apworld/locations.py index 108decb..a502931 100644 --- a/apworld/locations.py +++ b/apworld/locations.py | |||
@@ -3,3 +3,5 @@ from BaseClasses import Location | |||
3 | 3 | ||
4 | class Lingo2Location(Location): | 4 | class Lingo2Location(Location): |
5 | game: str = "Lingo 2" | 5 | game: str = "Lingo 2" |
6 | |||
7 | port_id: int | ||
diff --git a/apworld/player_logic.py b/apworld/player_logic.py index 966f712..8f2bd59 100644 --- a/apworld/player_logic.py +++ b/apworld/player_logic.py | |||
@@ -297,13 +297,14 @@ class Lingo2PlayerLogic: | |||
297 | AccessRequirements())) | 297 | AccessRequirements())) |
298 | behavior = self.get_letter_behavior(letter.key, letter.level2) | 298 | behavior = self.get_letter_behavior(letter.key, letter.level2) |
299 | if behavior == LetterBehavior.VANILLA: | 299 | if behavior == LetterBehavior.VANILLA: |
300 | letter_name = f"{letter.key.upper()}{'2' if letter.level2 else '1'}" | 300 | if not world.for_tracker: |
301 | event_name = f"{letter_name} (Collected)" | 301 | letter_name = f"{letter.key.upper()}{'2' if letter.level2 else '1'}" |
302 | self.event_loc_item_by_room.setdefault(letter.room_id, {})[event_name] = letter.key.upper() | 302 | event_name = f"{letter_name} (Collected)" |
303 | |||
304 | if letter.level2: | ||
305 | event_name = f"{letter_name} (Double Collected)" | ||
306 | self.event_loc_item_by_room.setdefault(letter.room_id, {})[event_name] = letter.key.upper() | 303 | self.event_loc_item_by_room.setdefault(letter.room_id, {})[event_name] = letter.key.upper() |
304 | |||
305 | if letter.level2: | ||
306 | event_name = f"{letter_name} (Double Collected)" | ||
307 | self.event_loc_item_by_room.setdefault(letter.room_id, {})[event_name] = letter.key.upper() | ||
307 | elif behavior == LetterBehavior.ITEM: | 308 | elif behavior == LetterBehavior.ITEM: |
308 | self.real_items.append(letter.key.upper()) | 309 | self.real_items.append(letter.key.upper()) |
309 | 310 | ||
diff --git a/apworld/regions.py b/apworld/regions.py index a7d9a1c..9f44682 100644 --- a/apworld/regions.py +++ b/apworld/regions.py | |||
@@ -32,6 +32,22 @@ def create_locations(room, new_region: Region, world: "Lingo2World", regions: di | |||
32 | new_location.place_locked_item(event_item) | 32 | new_location.place_locked_item(event_item) |
33 | new_region.locations.append(new_location) | 33 | new_region.locations.append(new_location) |
34 | 34 | ||
35 | if world.for_tracker and world.options.shuffle_worldports: | ||
36 | for port_id in room.ports: | ||
37 | port = world.static_logic.objects.ports[port_id] | ||
38 | if port.no_shuffle: | ||
39 | continue | ||
40 | |||
41 | new_location = Lingo2Location(world.player, f"Worldport {port.id} Entered", None, new_region) | ||
42 | new_location.port_id = port.id | ||
43 | |||
44 | if port.HasField("required_door"): | ||
45 | new_location.access_rule = \ | ||
46 | make_location_lambda(world.player_logic.get_door_open_reqs(port.required_door), world, regions) | ||
47 | |||
48 | new_region.locations.append(new_location) | ||
49 | |||
50 | |||
35 | def create_regions(world: "Lingo2World"): | 51 | def create_regions(world: "Lingo2World"): |
36 | regions = { | 52 | regions = { |
37 | "Menu": Region("Menu", world.player, world.multiworld) | 53 | "Menu": Region("Menu", world.player, world.multiworld) |
@@ -52,7 +68,6 @@ def create_regions(world: "Lingo2World"): | |||
52 | 68 | ||
53 | regions["Menu"].connect(regions["The Entry - Starting Room"], "Start Game") | 69 | regions["Menu"].connect(regions["The Entry - Starting Room"], "Start Game") |
54 | 70 | ||
55 | # TODO: The requirements of the opposite trigger also matter. | ||
56 | for connection in world.static_logic.objects.connections: | 71 | for connection in world.static_logic.objects.connections: |
57 | if connection.roof_access and not world.options.daedalus_roof_access: | 72 | if connection.roof_access and not world.options.daedalus_roof_access: |
58 | continue | 73 | continue |
@@ -176,11 +191,17 @@ def connect_ports_from_ut(port_pairings: dict[int, int], world: "Lingo2World"): | |||
176 | 191 | ||
177 | connection = Entrance(world.player, f"{from_region_name} - {from_port.name}", from_region) | 192 | connection = Entrance(world.player, f"{from_region_name} - {from_port.name}", from_region) |
178 | 193 | ||
194 | reqs = AccessRequirements() | ||
179 | if from_port.HasField("required_door"): | 195 | if from_port.HasField("required_door"): |
180 | door_reqs = world.player_logic.get_door_open_reqs(from_port.required_door) | 196 | reqs = world.player_logic.get_door_open_reqs(from_port.required_door).copy() |
181 | connection.access_rule = make_location_lambda(door_reqs, world, None) | ||
182 | 197 | ||
183 | for region in door_reqs.get_referenced_rooms(): | 198 | if world.for_tracker: |
199 | reqs.items.add(f"Worldport {fpid} Entered") | ||
200 | |||
201 | if not reqs.is_empty(): | ||
202 | connection.access_rule = make_location_lambda(reqs, world, None) | ||
203 | |||
204 | for region in reqs.get_referenced_rooms(): | ||
184 | world.multiworld.register_indirect_condition(world.multiworld.get_region(region, world.player), | 205 | world.multiworld.register_indirect_condition(world.multiworld.get_region(region, world.player), |
185 | connection) | 206 | connection) |
186 | 207 | ||
diff --git a/apworld/static_logic.py b/apworld/static_logic.py index e4d7d49..ef70b58 100644 --- a/apworld/static_logic.py +++ b/apworld/static_logic.py | |||
@@ -2,6 +2,7 @@ from .generated import data_pb2 as data_pb2 | |||
2 | from .items import SYMBOL_ITEMS, ANTI_COLLECTABLE_TRAPS | 2 | from .items import SYMBOL_ITEMS, ANTI_COLLECTABLE_TRAPS |
3 | import pkgutil | 3 | import pkgutil |
4 | 4 | ||
5 | |||
5 | class Lingo2StaticLogic: | 6 | class Lingo2StaticLogic: |
6 | item_id_to_name: dict[int, str] | 7 | item_id_to_name: dict[int, str] |
7 | location_id_to_name: dict[int, str] | 8 | location_id_to_name: dict[int, str] |
diff --git a/apworld/tracker.py b/apworld/tracker.py new file mode 100644 index 0000000..cf2dbe1 --- /dev/null +++ b/apworld/tracker.py | |||
@@ -0,0 +1,106 @@ | |||
1 | from typing import TYPE_CHECKING | ||
2 | |||
3 | from BaseClasses import MultiWorld, CollectionState, ItemClassification | ||
4 | from NetUtils import NetworkItem | ||
5 | from . import Lingo2World, Lingo2Item | ||
6 | from .regions import connect_ports_from_ut | ||
7 | from .options import Lingo2Options, ShuffleLetters | ||
8 | |||
9 | if TYPE_CHECKING: | ||
10 | from .context import Lingo2Manager | ||
11 | |||
12 | PLAYER_NUM = 1 | ||
13 | |||
14 | |||
15 | class Tracker: | ||
16 | manager: "Lingo2Manager" | ||
17 | |||
18 | multiworld: MultiWorld | ||
19 | world: Lingo2World | ||
20 | |||
21 | collected_items: dict[int, int] | ||
22 | checked_locations: set[int] | ||
23 | accessible_locations: set[int] | ||
24 | accessible_worldports: set[int] | ||
25 | |||
26 | state: CollectionState | ||
27 | |||
28 | def __init__(self, manager: "Lingo2Manager"): | ||
29 | self.manager = manager | ||
30 | self.collected_items = {} | ||
31 | self.checked_locations = set() | ||
32 | self.accessible_locations = set() | ||
33 | self.accessible_worldports = set() | ||
34 | |||
35 | def setup_slot(self, slot_data): | ||
36 | Lingo2World.for_tracker = True | ||
37 | |||
38 | self.multiworld = MultiWorld(players=PLAYER_NUM) | ||
39 | self.world = Lingo2World(self.multiworld, PLAYER_NUM) | ||
40 | self.multiworld.worlds[1] = self.world | ||
41 | self.world.options = Lingo2Options(**{k: t(slot_data.get(k, t.default)) | ||
42 | for k, t in Lingo2Options.type_hints.items()}) | ||
43 | |||
44 | self.world.generate_early() | ||
45 | self.world.create_regions() | ||
46 | |||
47 | if self.world.options.shuffle_worldports: | ||
48 | port_pairings = {int(fp): int(tp) for fp, tp in slot_data["port_pairings"].items()} | ||
49 | connect_ports_from_ut(port_pairings, self.world) | ||
50 | |||
51 | self.refresh_state() | ||
52 | |||
53 | def set_checked_locations(self, checked_locations: set[int]): | ||
54 | self.checked_locations = checked_locations.copy() | ||
55 | |||
56 | def set_collected_items(self, network_items: list[NetworkItem]): | ||
57 | self.collected_items = {} | ||
58 | |||
59 | for item in network_items: | ||
60 | self.collected_items[item.item] = self.collected_items.get(item.item, 0) + 1 | ||
61 | |||
62 | self.refresh_state() | ||
63 | |||
64 | def refresh_state(self): | ||
65 | self.state = CollectionState(self.multiworld) | ||
66 | |||
67 | for item_id, item_amount in self.collected_items.items(): | ||
68 | for i in range(item_amount): | ||
69 | self.state.collect(Lingo2Item(Lingo2World.static_logic.item_id_to_name.get(item_id), | ||
70 | ItemClassification.progression, item_id, PLAYER_NUM), prevent_sweep=True) | ||
71 | |||
72 | for k, v in self.manager.keyboard.items(): | ||
73 | # Unless all level 1 letters are pre-unlocked, H1 I1 N1 and T1 act differently between the generator and | ||
74 | # game. The generator considers them to be unlocked, which means they are not included in logic | ||
75 | # requirements, and only one item/event is needed to unlock their level 2 forms. The game considers them to | ||
76 | # be vanilla, which means you still have to pick them up in the Starting Room in order for them to appear on | ||
77 | # your keyboard. This also means that whether or not you have the level 1 forms should be synced to the | ||
78 | # multiworld. The tracker specifically should collect one fewer item for these letters in this scenario. | ||
79 | tv = v | ||
80 | if k in "hint" and self.world.options.shuffle_letters in [ShuffleLetters.option_vanilla, | ||
81 | ShuffleLetters.option_progressive]: | ||
82 | tv = max(0, v - 1) | ||
83 | |||
84 | if tv > 0: | ||
85 | for i in range(tv): | ||
86 | self.state.collect(Lingo2Item(k.upper(), ItemClassification.progression, None, PLAYER_NUM), | ||
87 | prevent_sweep=True) | ||
88 | |||
89 | for port_id in self.manager.worldports: | ||
90 | self.state.collect(Lingo2Item(f"Worldport {port_id} Entered", ItemClassification.progression, None, | ||
91 | PLAYER_NUM), prevent_sweep=True) | ||
92 | |||
93 | self.state.sweep_for_advancements() | ||
94 | |||
95 | self.accessible_locations = set() | ||
96 | self.accessible_worldports = set() | ||
97 | |||
98 | for region in self.state.reachable_regions[PLAYER_NUM]: | ||
99 | for location in region.locations: | ||
100 | if location.access_rule(self.state): | ||
101 | if location.address is not None: | ||
102 | if location.address not in self.checked_locations: | ||
103 | self.accessible_locations.add(location.address) | ||
104 | elif hasattr(location, "port_id"): | ||
105 | if location.port_id not in self.manager.worldports: | ||
106 | self.accessible_worldports.add(location.port_id) | ||