(
message: AckUpdatesClientSocketMessage,
)
| 557 | } |
| 558 | |
| 559 | async handleAckUpdatesClientSocketMessage( |
| 560 | message: AckUpdatesClientSocketMessage, |
| 561 | ): Promise<ServerServerSocketMessage[]> { |
| 562 | const { viewer } = this; |
| 563 | invariant(viewer, 'should be set'); |
| 564 | const { currentAsOf } = message.payload; |
| 565 | await Promise.all([ |
| 566 | deleteUpdatesBeforeTimeTargetingSession(viewer, currentAsOf), |
| 567 | commitSessionUpdate(viewer, { lastUpdate: currentAsOf }), |
| 568 | ]); |
| 569 | return []; |
| 570 | } |
| 571 | |
| 572 | async handleAPIRequestClientSocketMessage( |
| 573 | message: APIRequestClientSocketMessage, |
no test coverage detected