From f54437b0a800697574050a43f310c2e346cd326f Mon Sep 17 00:00:00 2001 From: lbwexler Date: Thu, 15 Jan 2026 17:08:07 -0500 Subject: [PATCH 1/2] Adapt to new websocket APIS --- grails-app/services/io/xh/toolbox/MockUpdatesService.groovy | 2 +- grails-app/services/io/xh/toolbox/app/GitHubService.groovy | 5 +---- .../services/io/xh/toolbox/portfolio/PositionService.groovy | 2 +- 3 files changed, 3 insertions(+), 6 deletions(-) diff --git a/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy b/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy index 8ccae5fe4..dabe1dd16 100644 --- a/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy +++ b/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy @@ -52,7 +52,7 @@ class MockUpdatesService extends BaseService { } private void cullInactiveSubs() { - subs.removeAll{!webSocketService.hasChannel(it)} + subs.removeAll{!webSocketService.hasLocalChannel(it)} } } diff --git a/grails-app/services/io/xh/toolbox/app/GitHubService.groovy b/grails-app/services/io/xh/toolbox/app/GitHubService.groovy index df553f98b..718d02d8d 100644 --- a/grails-app/services/io/xh/toolbox/app/GitHubService.groovy +++ b/grails-app/services/io/xh/toolbox/app/GitHubService.groovy @@ -231,10 +231,7 @@ query XHRepoCommits { } private void pushUpdate() { - webSocketService.pushToChannels( - webSocketService.allChannels*.key, 'gitHubUpdate', - [timestamp: Instant.now()] - ) + webSocketService.pushToAllChannels('gitHubUpdate', [timestamp: Instant.now()]) } void clearCaches() { diff --git a/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy b/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy index 0f945c0dd..d1eb7e909 100644 --- a/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy +++ b/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy @@ -259,7 +259,7 @@ class PositionService extends BaseService { void cullSessions() { def obsoleteSessions = sessions.values().findAll { - !webSocketService.hasChannel(it.channelKey) + !webSocketService.hasLocalChannel(it.channelKey) } obsoleteSessions.each { it.destroy() From ad1ffae8d93729d452410e99304e68319e210247 Mon Sep 17 00:00:00 2001 From: lbwexler Date: Thu, 15 Jan 2026 20:05:25 -0500 Subject: [PATCH 2/2] Make Hoist WebSocketService cluster aware. --- grails-app/services/io/xh/toolbox/MockUpdatesService.groovy | 2 +- .../services/io/xh/toolbox/portfolio/PositionService.groovy | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy b/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy index dabe1dd16..8ccae5fe4 100644 --- a/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy +++ b/grails-app/services/io/xh/toolbox/MockUpdatesService.groovy @@ -52,7 +52,7 @@ class MockUpdatesService extends BaseService { } private void cullInactiveSubs() { - subs.removeAll{!webSocketService.hasLocalChannel(it)} + subs.removeAll{!webSocketService.hasChannel(it)} } } diff --git a/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy b/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy index d1eb7e909..0f945c0dd 100644 --- a/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy +++ b/grails-app/services/io/xh/toolbox/portfolio/PositionService.groovy @@ -259,7 +259,7 @@ class PositionService extends BaseService { void cullSessions() { def obsoleteSessions = sessions.values().findAll { - !webSocketService.hasLocalChannel(it.channelKey) + !webSocketService.hasChannel(it.channelKey) } obsoleteSessions.each { it.destroy()