Function TestPsyNetRPC_SendRequestSync

psynetrpc_test.go:108–146

(t *testing.T)

}

func TestPsyNetRPC_SendRequestSync(t *testing.T) {
	// Setup mock server
	mockServer := NewMockWSServer()
	defer mockServer.Close()

	// Create PsyNet instance and establish connection
	psyNet := NewPsyNet()
	rpc, err := psyNet.establishSocket(mockServer.URL(), "test-token", "test-session", "test-player")
	if err != nil {
		t.Fatalf("Failed to establish socket: %v", err)
	}

	go rpc.readMessages()
	rpc.schedulePing()
	defer rpc.Close()

	// Setup expected response
	expectedResponse := &PsyResponse{
		Result: json.RawMessage(`{"Result":{"shops": [{"id": 1, "name": "test shop"}]}}`),
	}
	mockServer.SetResponse("PsyNetMessage_X_0", expectedResponse)

	// Test sync request
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	var result map[string]interface{}
	err = rpc.sendRequestSync(ctx, "Shops/GetStandardShops", map[string]interface{}{}, &result)
	if err != nil {
		t.Fatalf("sendRequestSync failed: %v", err)
	}

	// Verify result
	if shops, ok := result["shops"]; !ok {
		t.Error("Expected 'shops' in response")
	} else if shopsArray, ok := shops.([]interface{}); !ok || len(shopsArray) != 1 {
		t.Error("Expected shops array with one item")
	}
}

func TestPsyNetRPC_SendRequestAsync(t *testing.T) {
	// Setup mock server