(Client client, Object message)
| 2579 | } |
| 2580 | |
| 2581 | public java.util.concurrent.CompletableFuture<Object> pong(Client client, Object message) |
| 2582 | { |
| 2583 | |
| 2584 | return java.util.concurrent.CompletableFuture.supplyAsync(() -> { |
| 2585 | |
| 2586 | try |
| 2587 | { |
| 2588 | Object ping = this.safeInteger(message, "ping"); |
| 2589 | if (Helpers.isTrue(!Helpers.isEqual(ping, null))) |
| 2590 | { |
| 2591 | (client.send(new java.util.HashMap<String, Object>() {{ |
| 2592 | put( "pong", ping ); |
| 2593 | }})).join(); |
| 2594 | return null; |
| 2595 | } |
| 2596 | Object action = this.safeString(message, "action"); |
| 2597 | if (Helpers.isTrue(Helpers.isEqual(action, "ping"))) |
| 2598 | { |
| 2599 | Object data = this.safeValue(message, "data"); |
| 2600 | Object pingTs = this.safeInteger(data, "ts"); |
| 2601 | (client.send(new java.util.HashMap<String, Object>() {{ |
| 2602 | put( "action", "pong" ); |
| 2603 | put( "data", new java.util.HashMap<String, Object>() {{ |
| 2604 | put( "ts", pingTs ); |
| 2605 | }} ); |
| 2606 | }})).join(); |
| 2607 | return null; |
| 2608 | } |
| 2609 | Object op = this.safeString(message, "op"); |
| 2610 | if (Helpers.isTrue(Helpers.isEqual(op, "ping"))) |
| 2611 | { |
| 2612 | Object pingTs = this.safeInteger(message, "ts"); |
| 2613 | (client.send(new java.util.HashMap<String, Object>() {{ |
| 2614 | put( "op", "pong" ); |
| 2615 | put( "ts", pingTs ); |
| 2616 | }})).join(); |
| 2617 | } |
| 2618 | } catch(Exception e) |
| 2619 | { |
| 2620 | var error = new NetworkError(Helpers.add(Helpers.add(this.id, " pong failed "), this.exceptionMessage(e))); |
| 2621 | client.reset(error); |
| 2622 | } |
| 2623 | return null; |
| 2624 | }); |
| 2625 | |
| 2626 | } |
| 2627 | |
| 2628 | public void handlePing(Client client, Object message) |
| 2629 | { |
no test coverage detected