diff options
Diffstat (limited to 'apworld/client/manager.gd')
-rw-r--r-- | apworld/client/manager.gd | 201 |
1 files changed, 77 insertions, 124 deletions
diff --git a/apworld/client/manager.gd b/apworld/client/manager.gd index b170c77..46c5456 100644 --- a/apworld/client/manager.gd +++ b/apworld/client/manager.gd | |||
@@ -6,8 +6,8 @@ var SCRIPT_client | |||
6 | var SCRIPT_keyboard | 6 | var SCRIPT_keyboard |
7 | var SCRIPT_locationListener | 7 | var SCRIPT_locationListener |
8 | var SCRIPT_minimap | 8 | var SCRIPT_minimap |
9 | var SCRIPT_uuid | ||
10 | var SCRIPT_victoryListener | 9 | var SCRIPT_victoryListener |
10 | var SCRIPT_websocketserver | ||
11 | 11 | ||
12 | var ap_server = "" | 12 | var ap_server = "" |
13 | var ap_user = "" | 13 | var ap_user = "" |
@@ -92,14 +92,17 @@ func _init(): | |||
92 | 92 | ||
93 | func _ready(): | 93 | func _ready(): |
94 | client = SCRIPT_client.new() | 94 | client = SCRIPT_client.new() |
95 | client.SCRIPT_uuid = SCRIPT_uuid | 95 | client.SCRIPT_websocketserver = SCRIPT_websocketserver |
96 | 96 | ||
97 | client.connect("item_received", _process_item) | 97 | client.item_received.connect(_process_item) |
98 | client.connect("message_received", _process_message) | 98 | client.location_scout_received.connect(_process_location_scout) |
99 | client.connect("location_scout_received", _process_location_scout) | 99 | client.text_message_received.connect(_process_text_message) |
100 | client.connect("could_not_connect", _client_could_not_connect) | 100 | client.item_sent_notification.connect(_process_item_sent_notification) |
101 | client.connect("connect_status", _client_connect_status) | 101 | client.hint_received.connect(_process_hint_received) |
102 | client.connect("client_connected", _client_connected) | 102 | |
103 | client.could_not_connect.connect(_client_could_not_connect) | ||
104 | client.connect_status.connect(_client_connect_status) | ||
105 | client.client_connected.connect(_client_connected) | ||
103 | 106 | ||
104 | add_child(client) | 107 | add_child(client) |
105 | 108 | ||
@@ -163,20 +166,17 @@ func get_item_id_for_door(door_id): | |||
163 | return _item_locks.get(door_id, null) | 166 | return _item_locks.get(door_id, null) |
164 | 167 | ||
165 | 168 | ||
166 | func _process_item(item, index, from, flags, amount): | 169 | func _process_item(item, amount): |
167 | var item_name = "Unknown" | ||
168 | if client._item_id_to_name["Lingo 2"].has(item): | ||
169 | item_name = client._item_id_to_name["Lingo 2"][item] | ||
170 | |||
171 | var gamedata = global.get_node("Gamedata") | 170 | var gamedata = global.get_node("Gamedata") |
172 | 171 | ||
172 | var item_id = int(item["id"]) | ||
173 | var prog_id = null | 173 | var prog_id = null |
174 | if _inverse_item_locks.has(item): | 174 | if _inverse_item_locks.has(item_id): |
175 | for lock in _inverse_item_locks.get(item): | 175 | for lock in _inverse_item_locks.get(item_id): |
176 | if lock[1] != amount: | 176 | if lock[1] != amount: |
177 | continue | 177 | continue |
178 | 178 | ||
179 | if gamedata.progressive_id_by_ap_id.has(item): | 179 | if gamedata.progressive_id_by_ap_id.has(item_id): |
180 | prog_id = lock[0] | 180 | prog_id = lock[0] |
181 | 181 | ||
182 | if gamedata.get_door_map_name(lock[0]) != global.map: | 182 | if gamedata.get_door_map_name(lock[0]) != global.map: |
@@ -190,38 +190,35 @@ func _process_item(item, index, from, flags, amount): | |||
190 | if rnode != null: | 190 | if rnode != null: |
191 | rnode.handleTriggered() | 191 | rnode.handleTriggered() |
192 | 192 | ||
193 | var letter_id = gamedata.letter_id_by_ap_id.get(item, null) | 193 | var letter_id = gamedata.letter_id_by_ap_id.get(item_id, null) |
194 | if letter_id != null: | 194 | if letter_id != null: |
195 | var letter = gamedata.objects.get_letters()[letter_id] | 195 | var letter = gamedata.objects.get_letters()[letter_id] |
196 | if not letter.has_level2() or not letter.get_level2(): | 196 | if not letter.has_level2() or not letter.get_level2(): |
197 | _process_key_item(letter.get_key(), amount) | 197 | _process_key_item(letter.get_key(), amount) |
198 | 198 | ||
199 | if gamedata.symbol_item_ids.has(item): | 199 | if gamedata.symbol_item_ids.has(item_id): |
200 | var player = get_tree().get_root().get_node_or_null("scene/player") | 200 | var player = get_tree().get_root().get_node_or_null("scene/player") |
201 | if player != null: | 201 | if player != null: |
202 | player.emit_signal("evaluate_solvability") | 202 | player.evaluate_solvability.emit() |
203 | 203 | ||
204 | # Show a message about the item if it's new. | 204 | # Show a message about the item if it's new. |
205 | if index != null and index > _last_new_item: | 205 | if int(item["index"]) > _last_new_item: |
206 | _last_new_item = index | 206 | _last_new_item = int(item["index"]) |
207 | saveLocaldata() | 207 | saveLocaldata() |
208 | 208 | ||
209 | var player_name = "Unknown" | 209 | var full_item_name = item["text"] |
210 | if client._player_name_by_slot.has(float(from)): | ||
211 | player_name = client._player_name_by_slot[float(from)] | ||
212 | |||
213 | var full_item_name = item_name | ||
214 | if prog_id != null: | 210 | if prog_id != null: |
215 | var door = gamedata.objects.get_doors()[prog_id] | 211 | var door = gamedata.objects.get_doors()[prog_id] |
216 | full_item_name = "%s (%s)" % [item_name, door.get_name()] | 212 | full_item_name = "%s (%s)" % [full_item_name, door.get_name()] |
217 | 213 | ||
218 | var message | 214 | var message |
219 | if from == client._slot: | 215 | if "sender" in item: |
220 | message = "Found %s" % wrapInItemColorTags(full_item_name, flags) | ||
221 | else: | ||
222 | message = ( | 216 | message = ( |
223 | "Received %s from %s" % [wrapInItemColorTags(full_item_name, flags), player_name] | 217 | "Received %s from %s" |
218 | % [wrapInItemColorTags(full_item_name, item["flags"]), item["sender"]] | ||
224 | ) | 219 | ) |
220 | else: | ||
221 | message = "Found %s" % wrapInItemColorTags(full_item_name, item["flags"]) | ||
225 | 222 | ||
226 | if gamedata.anti_trap_ids.has(item): | 223 | if gamedata.anti_trap_ids.has(item): |
227 | keyboard.block_letter(gamedata.anti_trap_ids[item]) | 224 | keyboard.block_letter(gamedata.anti_trap_ids[item]) |
@@ -231,112 +228,68 @@ func _process_item(item, index, from, flags, amount): | |||
231 | global.get_node("Messages").showMessage(message) | 228 | global.get_node("Messages").showMessage(message) |
232 | 229 | ||
233 | 230 | ||
234 | func _process_message(message): | 231 | func _process_item_sent_notification(message): |
235 | parse_printjson_for_textclient(message) | 232 | var sentMsg = ( |
236 | 233 | "Sent %s to %s" | |
237 | if ( | 234 | % [ |
238 | !message.has("receiving") | 235 | wrapInItemColorTags(message["item_name"], message["item_flags"]), |
239 | or !message.has("item") | 236 | message["receiver_name"] |
240 | or message["item"]["player"] != client._slot | 237 | ] |
241 | ): | 238 | ) |
242 | return | 239 | #if _hinted_locations.has(message["item"]["location"]): |
243 | 240 | # sentMsg += " ([color=#fafad2]Hinted![/color])" | |
244 | var item_name = "Unknown" | 241 | global.get_node("Messages").showMessage(sentMsg) |
245 | var item_player_game = client._game_by_player[message["receiving"]] | 242 | |
246 | if client._item_id_to_name[item_player_game].has(int(message["item"]["item"])): | 243 | |
247 | item_name = client._item_id_to_name[item_player_game][int(message["item"]["item"])] | 244 | func _process_hint_received(message): |
248 | 245 | var is_for = "" | |
249 | var location_name = "Unknown" | 246 | if message["self"] == 0: |
250 | var location_player_game = client._game_by_player[message["item"]["player"]] | 247 | is_for = " for %s" % message["receiver_name"] |
251 | if client._location_id_to_name[location_player_game].has(int(message["item"]["location"])): | 248 | |
252 | location_name = (client._location_id_to_name[location_player_game][int( | 249 | global.get_node("Messages").showMessage( |
253 | message["item"]["location"] | 250 | ( |
254 | )]) | 251 | "Hint: %s%s is on %s" |
255 | 252 | % [ | |
256 | var player_name = "Unknown" | 253 | wrapInItemColorTags(message["item_name"], message["item_flags"]), |
257 | if client._player_name_by_slot.has(message["receiving"]): | 254 | is_for, |
258 | player_name = client._player_name_by_slot[message["receiving"]] | 255 | message["location_name"] |
259 | 256 | ] | |
260 | var item_color = colorForItemType(message["item"]["flags"]) | 257 | ) |
261 | 258 | ) | |
262 | if message["type"] == "Hint": | 259 | |
263 | var is_for = "" | 260 | |
264 | if message["receiving"] != client._slot: | 261 | func _process_text_message(message): |
265 | is_for = " for %s" % player_name | ||
266 | if !message.has("found") || !message["found"]: | ||
267 | global.get_node("Messages").showMessage( | ||
268 | ( | ||
269 | "Hint: %s%s is on %s" | ||
270 | % [ | ||
271 | wrapInItemColorTags(item_name, message["item"]["flags"]), | ||
272 | is_for, | ||
273 | location_name | ||
274 | ] | ||
275 | ) | ||
276 | ) | ||
277 | else: | ||
278 | if message["receiving"] != client._slot: | ||
279 | var sentMsg = ( | ||
280 | "Sent %s to %s" | ||
281 | % [wrapInItemColorTags(item_name, message["item"]["flags"]), player_name] | ||
282 | ) | ||
283 | #if _hinted_locations.has(message["item"]["location"]): | ||
284 | # sentMsg += " ([color=#fafad2]Hinted![/color])" | ||
285 | global.get_node("Messages").showMessage(sentMsg) | ||
286 | |||
287 | |||
288 | func parse_printjson_for_textclient(message): | ||
289 | var parts = [] | 262 | var parts = [] |
290 | for message_part in message["data"]: | 263 | for message_part in message: |
291 | if !message_part.has("type") and message_part.has("text"): | 264 | if message_part["type"] == "text": |
292 | parts.append(message_part["text"]) | 265 | parts.append(message_part["text"]) |
293 | elif message_part["type"] == "player_id": | 266 | elif message_part["type"] == "player": |
294 | if int(message_part["text"]) == client._slot: | 267 | if message_part["self"] == 1: |
295 | parts.append( | 268 | parts.append("[color=#ee00ee]%s[/color]" % message_part["text"]) |
296 | "[color=#ee00ee]%s[/color]" % client._player_name_by_slot[client._slot] | ||
297 | ) | ||
298 | else: | 269 | else: |
299 | var from = float(message_part["text"]) | 270 | parts.append("[color=#fafad2]%s[/color]" % message_part["text"]) |
300 | parts.append("[color=#fafad2]%s[/color]" % client._player_name_by_slot[from]) | 271 | elif message_part["type"] == "item": |
301 | elif message_part["type"] == "item_id": | 272 | parts.append(wrapInItemColorTags(message_part["text"], message_part["flags"])) |
302 | var item_name = "Unknown" | 273 | elif message_part["type"] == "location": |
303 | var item_player_game = client._game_by_player[message_part["player"]] | 274 | parts.append("[color=#00ff7f]%s[/color]" % message_part["text"]) |
304 | if client._item_id_to_name[item_player_game].has(int(message_part["text"])): | ||
305 | item_name = client._item_id_to_name[item_player_game][int(message_part["text"])] | ||
306 | |||
307 | parts.append(wrapInItemColorTags(item_name, message_part["flags"])) | ||
308 | elif message_part["type"] == "location_id": | ||
309 | var location_name = "Unknown" | ||
310 | var location_player_game = client._game_by_player[message_part["player"]] | ||
311 | if client._location_id_to_name[location_player_game].has(int(message_part["text"])): | ||
312 | location_name = client._location_id_to_name[location_player_game][int( | ||
313 | message_part["text"] | ||
314 | )] | ||
315 | |||
316 | parts.append("[color=#00ff7f]%s[/color]" % location_name) | ||
317 | elif message_part.has("text"): | ||
318 | parts.append(message_part["text"]) | ||
319 | 275 | ||
320 | var textclient_node = global.get_node("Textclient") | 276 | var textclient_node = global.get_node("Textclient") |
321 | if textclient_node != null: | 277 | if textclient_node != null: |
322 | textclient_node.parse_printjson("".join(parts)) | 278 | textclient_node.parse_printjson("".join(parts)) |
323 | 279 | ||
324 | 280 | ||
325 | func _process_location_scout(item_id, location_id, player, flags): | 281 | func _process_location_scout(location_id, item_name, player_name, flags, for_self): |
326 | _location_scouts[location_id] = {"item": item_id, "player": player, "flags": flags} | 282 | _location_scouts[location_id] = { |
283 | "item": item_name, "player": player_name, "flags": flags, "for_self": for_self | ||
284 | } | ||
327 | 285 | ||
328 | if player == client._slot and flags & 4 != 0: | 286 | if for_self and flags & 4 != 0: |
329 | # This is a trap for us, so let's not display it. | 287 | # This is a trap for us, so let's not display it. |
330 | return | 288 | return |
331 | 289 | ||
332 | var gamedata = global.get_node("Gamedata") | 290 | var gamedata = global.get_node("Gamedata") |
333 | var map_id = gamedata.map_id_by_name.get(global.map) | 291 | var map_id = gamedata.map_id_by_name.get(global.map) |
334 | 292 | ||
335 | var item_name = "Unknown" | ||
336 | var item_player_game = client._game_by_player[float(player)] | ||
337 | if client._item_id_to_name[item_player_game].has(item_id): | ||
338 | item_name = client._item_id_to_name[item_player_game][item_id] | ||
339 | |||
340 | var letter_id = gamedata.letter_id_by_ap_id.get(location_id, null) | 293 | var letter_id = gamedata.letter_id_by_ap_id.get(location_id, null) |
341 | if letter_id != null: | 294 | if letter_id != null: |
342 | var letter = gamedata.objects.get_letters()[letter_id] | 295 | var letter = gamedata.objects.get_letters()[letter_id] |
@@ -350,11 +303,11 @@ func _process_location_scout(item_id, location_id, player, flags): | |||
350 | 303 | ||
351 | 304 | ||
352 | func _client_could_not_connect(message): | 305 | func _client_could_not_connect(message): |
353 | emit_signal("could_not_connect", message) | 306 | could_not_connect.emit(message) |
354 | 307 | ||
355 | 308 | ||
356 | func _client_connect_status(message): | 309 | func _client_connect_status(message): |
357 | emit_signal("connect_status", message) | 310 | connect_status.emit(message) |
358 | 311 | ||
359 | 312 | ||
360 | func _client_connected(slot_data): | 313 | func _client_connected(slot_data): |
@@ -463,7 +416,7 @@ func _client_connected(slot_data): | |||
463 | 416 | ||
464 | _inverse_item_locks[lock[0]].append([door_id, lock[1]]) | 417 | _inverse_item_locks[lock[0]].append([door_id, lock[1]]) |
465 | 418 | ||
466 | emit_signal("ap_connected") | 419 | ap_connected.emit() |
467 | 420 | ||
468 | 421 | ||
469 | func start_batching_locations(): | 422 | func start_batching_locations(): |