155 lines
4.2 KiB
GDScript
155 lines
4.2 KiB
GDScript
extends GdUnitTestSuite
|
|
|
|
## NEO-72: `InventoryClient` GET parse + failure signals.
|
|
|
|
const InventoryClient := preload("res://scripts/inventory_client.gd")
|
|
|
|
var _inventory_capture: Dictionary = {}
|
|
|
|
|
|
func _capture_inventory(snapshot: Dictionary) -> void:
|
|
_inventory_capture = snapshot
|
|
|
|
|
|
class MockHttpTransport:
|
|
extends Node
|
|
signal request_completed(
|
|
result: int, response_code: int, headers: PackedStringArray, body: PackedByteArray
|
|
)
|
|
var last_url: String = ""
|
|
var response_code: int = 200
|
|
var body_json: String = ""
|
|
|
|
func request(
|
|
url: String,
|
|
_custom_headers: PackedStringArray = PackedStringArray(),
|
|
_method: HTTPClient.Method = HTTPClient.METHOD_GET,
|
|
_request_data: String = ""
|
|
) -> Error:
|
|
last_url = url
|
|
request_completed.emit(
|
|
HTTPRequest.RESULT_SUCCESS,
|
|
response_code,
|
|
PackedStringArray(),
|
|
body_json.to_utf8_buffer()
|
|
)
|
|
return OK
|
|
|
|
|
|
class PendingSyncHttpTransport:
|
|
extends Node
|
|
signal request_completed(
|
|
result: int, response_code: int, headers: PackedStringArray, body: PackedByteArray
|
|
)
|
|
var request_count: int = 0
|
|
var response_code: int = 200
|
|
var body_json: String = ""
|
|
|
|
func request(
|
|
_url: String,
|
|
_custom_headers: PackedStringArray = PackedStringArray(),
|
|
_method: HTTPClient.Method = HTTPClient.METHOD_GET,
|
|
_request_data: String = ""
|
|
) -> Error:
|
|
request_count += 1
|
|
return OK
|
|
|
|
func complete_pending() -> void:
|
|
request_completed.emit(
|
|
HTTPRequest.RESULT_SUCCESS,
|
|
response_code,
|
|
PackedStringArray(),
|
|
body_json.to_utf8_buffer()
|
|
)
|
|
|
|
|
|
static func _empty_inventory_json() -> String:
|
|
var bag_parts: PackedStringArray = PackedStringArray()
|
|
for i in range(24):
|
|
bag_parts.append('{"slotIndex":%d,"quantity":0}' % i)
|
|
var bag: String = ", ".join(bag_parts)
|
|
return (
|
|
(
|
|
'{"schemaVersion":1,"playerId":"dev-local-1","bagSlots":[%s],'
|
|
+ '"equipmentSlots":[{"slotIndex":0,"quantity":0}]}'
|
|
)
|
|
% bag
|
|
)
|
|
|
|
|
|
func _make_client(transport: Node) -> Node:
|
|
var c: Node = InventoryClient.new()
|
|
c.set("injected_http", transport)
|
|
auto_free(transport)
|
|
auto_free(c)
|
|
add_child(c)
|
|
return c
|
|
|
|
|
|
func test_parse_inventory_json_empty_grid() -> void:
|
|
# Arrange
|
|
var json := _empty_inventory_json()
|
|
# Act
|
|
var snapshot: Variant = InventoryClient.parse_inventory_json(json)
|
|
# Assert
|
|
assert_that(snapshot is Dictionary).is_true()
|
|
var bag: Variant = (snapshot as Dictionary).get("bagSlots", null)
|
|
assert_that(bag is Array).is_true()
|
|
assert_that((bag as Array).size()).is_equal(24)
|
|
|
|
|
|
func test_request_sync_emits_inventory_received() -> void:
|
|
# Arrange
|
|
_inventory_capture = {}
|
|
var transport := MockHttpTransport.new()
|
|
transport.body_json = _empty_inventory_json()
|
|
var c := _make_client(transport)
|
|
c.connect("inventory_received", Callable(self, "_capture_inventory"))
|
|
monitor_signals(c)
|
|
# Act
|
|
c.call("request_sync_from_server")
|
|
# Assert
|
|
await assert_signal(c).is_emitted("inventory_received", any())
|
|
assert_that(_inventory_capture.has("bagSlots")).is_true()
|
|
assert_that((_inventory_capture["bagSlots"] as Array).size()).is_equal(24)
|
|
assert_that((_inventory_capture["equipmentSlots"] as Array).size()).is_equal(1)
|
|
assert_that(transport.last_url).contains("/inventory")
|
|
|
|
|
|
func test_http_404_emits_inventory_sync_failed() -> void:
|
|
# Arrange
|
|
var transport := MockHttpTransport.new()
|
|
transport.response_code = 404
|
|
var c := _make_client(transport)
|
|
monitor_signals(c)
|
|
# Act
|
|
c.call("request_sync_from_server")
|
|
# Assert
|
|
await assert_signal(c).is_emitted("inventory_sync_failed", "HTTP 404 (player unknown)")
|
|
|
|
|
|
func test_malformed_json_emits_inventory_sync_failed() -> void:
|
|
# Arrange
|
|
var transport := MockHttpTransport.new()
|
|
transport.body_json = "[]"
|
|
var c := _make_client(transport)
|
|
monitor_signals(c)
|
|
# Act
|
|
c.call("request_sync_from_server")
|
|
# Assert
|
|
await assert_signal(c).is_emitted("inventory_sync_failed", any())
|
|
|
|
|
|
func test_request_sync_queues_while_busy_and_flushes_after_completion() -> void:
|
|
# Arrange
|
|
var transport := PendingSyncHttpTransport.new()
|
|
transport.body_json = _empty_inventory_json()
|
|
var c := _make_client(transport)
|
|
# Act
|
|
c.call("request_sync_from_server")
|
|
c.call("request_sync_from_server")
|
|
# Assert
|
|
assert_that(transport.request_count).is_equal(1)
|
|
transport.complete_pending()
|
|
assert_that(transport.request_count).is_equal(2)
|