about summary refs log tree commit diff stats
path: root/apworld
diff options
context:
space:
mode:
Diffstat (limited to 'apworld')
-rw-r--r--apworld/__init__.py2
-rw-r--r--apworld/client/client.gd77
-rw-r--r--apworld/client/gamedata.gd132
-rw-r--r--apworld/client/keyboard.gd36
-rw-r--r--apworld/client/main.gd1
-rw-r--r--apworld/client/manager.gd33
-rw-r--r--apworld/client/pauseMenu.gd40
-rw-r--r--apworld/client/player.gd1
-rw-r--r--apworld/client/textclient.gd128
-rw-r--r--apworld/client/worldport.gd10
-rw-r--r--apworld/context.py469
-rw-r--r--apworld/locations.py2
-rw-r--r--apworld/player_logic.py13
-rw-r--r--apworld/regions.py29
-rw-r--r--apworld/static_logic.py1
-rw-r--r--apworld/tracker.py106
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 = ""
18var _team = 0 18var _team = 0
19var _slot = 0 19var _slot = 0
20var _checked_locations = [] 20var _checked_locations = []
21var _checked_worldports = []
21var _received_indexes = [] 22var _received_indexes = []
22var _received_items = {} 23var _received_items = {}
23var _slot_data = {} 24var _slot_data = {}
25var _accessible_locations = []
26var _accessible_worldports = []
24 27
25signal could_not_connect 28signal could_not_connect
26signal connect_status 29signal connect_status
@@ -30,6 +33,10 @@ signal location_scout_received(location_id, item_name, player_name, flags, for_s
30signal text_message_received(message) 33signal text_message_received(message)
31signal item_sent_notification(message) 34signal item_sent_notification(message)
32signal hint_received(message) 35signal hint_received(message)
36signal accessible_locations_updated
37signal checked_locations_updated
38signal checked_worldports_updated
39signal keyboard_update_received
33 40
34 41
35func _init(): 42func _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
56func disconnect_from_ap(): 66func 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
138func connectToServer(server, un, pw): 187func 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
182func 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
195func say(textdata): 231func 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
243func updateKeyboard(updates):
244 sendMessage([{"cmd": "UpdateKeyboard", "keyboard": updates}])
245
246
247func checkWorldport(port_id):
248 if not _checked_worldports.has(port_id):
249 sendMessage([{"cmd": "CheckWorldport", "port_id": port_id}])
250
251
252func sendQuit():
253 sendMessage([{"cmd": "Quit"}])
254
255
207func hasItem(item_id): 256func 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 = {}
13var letter_id_by_ap_id = {} 13var letter_id_by_ap_id = {}
14var symbol_item_ids = [] 14var symbol_item_ids = []
15var anti_trap_ids = {} 15var anti_trap_ids = {}
16var location_name_by_id = {}
16 17
17var kSYMBOL_ITEMS 18var 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
164func 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
151func get_door_receivers(door_id): 171func 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
156func get_door_map_name(door_id): 176func 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
181func _get_map_object_map_name(obj):
182 return objects.get_maps()[obj.get_map_id()].get_display_name()
183
184
185func _get_room_object_map_name(obj):
186 return _get_map_object_map_name(objects.get_rooms()[obj.get_room_id()])
187
188
189func _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
199func _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
212func _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
263func _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
269func _get_mastery_location_name(mastery):
270 return "%s - Mastery" % _get_room_object_map_name(mastery)
271
272
273func _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
279func _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
107func collect_local_letter(key, level): 110func 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
215func 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():
137func _back_pressed(): 137func _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 = ""
14var ap_pass = "" 14var ap_pass = ""
15var connection_history = [] 15var connection_history = []
16var show_compass = false 16var show_compass = false
17var show_locations = false
18var show_minimap = false
17 19
18var client 20var client
19var keyboard 21var 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
93func _ready(): 101func _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
113func saveSettings(): 125func 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
320func _on_accessible_locations_updated():
321 var textclient_node = global.get_node("Textclient")
322 if textclient_node != null:
323 textclient_node.update_locations()
324
325
326func _on_checked_locations_updated():
327 var textclient_node = global.get_node("Textclient")
328 if textclient_node != null:
329 textclient_node.update_locations()
330
331
332func _on_checked_worldports_updated():
333 var textclient_node = global.get_node("Textclient")
334 if textclient_node != null:
335 textclient_node.update_locations()
336
337
305func _client_could_not_connect(message): 338func _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 @@
1extends "res://scripts/ui/pauseMenu.gd" 1extends "res://scripts/ui/pauseMenu.gd"
2 2
3var compass_button 3var compass_button
4var locations_button
5var minimap_button
4 6
5 7
6func _ready(): 8func _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
75func _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
84func _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 @@
1extends CanvasLayer 1extends CanvasLayer
2 2
3var tabs
3var panel 4var panel
4var label 5var label
5var entry 6var entry
7var tracker_label
6var is_open = false 8var is_open = false
7 9
10var locations_overlay
11
8 12
9func _ready(): 13func _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
53func _input(event): 87func _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
132func 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
171func update_locations_visibility():
172 var ap = global.get_node("Archipelago")
173 locations_overlay.visible = ap.show_locations
174
175
176func 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"
3var absolute_rotation = false 3var absolute_rotation = false
4var target_rotation = 0 4var target_rotation = 0
5 5
6var port_id = null
7
6 8
7func _ready(): 9func _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
40func bodyEntered(body): 44func 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
9import Utils 9import Utils
10import settings 10import settings
11from BaseClasses import ItemClassification
11from CommonClient import CommonContext, server_loop, gui_enabled, logger, get_base_parser, handle_url_arg 12from CommonClient import CommonContext, server_loop, gui_enabled, logger, get_base_parser, handle_url_arg
12from NetUtils import Endpoint, decode, encode 13from NetUtils import Endpoint, decode, encode
13from Utils import async_start 14from Utils import async_start
15from . import Lingo2World
16from .tracker import Tracker
14 17
15PORT = 43182 18ALL_LETTERS = "abcdefghijklmnopqrstuvwxyz"
16MESSAGE_MAX_SIZE = 16*1024*1024 19MESSAGE_MAX_SIZE = 16*1024*1024
20PORT = 43182
21
22KEY_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
29REVERSE_KEY_STORAGE_MAPPING = {t: k for k, t in KEY_STORAGE_MAPPING.items()}
30
31
32class 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
19class Lingo2GameContext: 82class 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
94class Lingo2ClientContext(CommonContext): 222class 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
199async 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
448async 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
217async def process_game_cmd(ctx: Lingo2GameContext, args: dict): 467async 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
237async def run_game(): 502async 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
4class Lingo2Location(Location): 4class 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
35def create_regions(world: "Lingo2World"): 51def 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
2from .items import SYMBOL_ITEMS, ANTI_COLLECTABLE_TRAPS 2from .items import SYMBOL_ITEMS, ANTI_COLLECTABLE_TRAPS
3import pkgutil 3import pkgutil
4 4
5
5class Lingo2StaticLogic: 6class 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 @@
1from typing import TYPE_CHECKING
2
3from BaseClasses import MultiWorld, CollectionState, ItemClassification
4from NetUtils import NetworkItem
5from . import Lingo2World, Lingo2Item
6from .regions import connect_ports_from_ut
7from .options import Lingo2Options, ShuffleLetters
8
9if TYPE_CHECKING:
10 from .context import Lingo2Manager
11
12PLAYER_NUM = 1
13
14
15class 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)