aboutsummaryrefslogtreecommitdiff
path: root/src/services/backend_interactor_service
diff options
context:
space:
mode:
Diffstat (limited to 'src/services/backend_interactor_service')
-rw-r--r--src/services/backend_interactor_service/backend_interactor_service.js9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/services/backend_interactor_service/backend_interactor_service.js b/src/services/backend_interactor_service/backend_interactor_service.js
index 0cef4640..850b7867 100644
--- a/src/services/backend_interactor_service/backend_interactor_service.js
+++ b/src/services/backend_interactor_service/backend_interactor_service.js
@@ -12,18 +12,23 @@ const backendInteractorService = credentials => ({
return notificationsFetcher.startFetching({ store, credentials })
},
+ fetchAndUpdateNotifications ({ store }) {
+ return notificationsFetcher.fetchAndUpdate({ store, credentials })
+ },
+
startFetchingFollowRequest ({ store }) {
return followRequestFetcher.startFetching({ store, credentials })
},
startUserSocket ({ store, onMessage }) {
- const serv = store.rootState.instance.server.replace('https', 'wss')
- // const serb = 'ws://localhost:8080/'
+ const serv = store.rootState.instance.server.replace('http', 'ws')
const url = serv + getMastodonSocketURI({ credentials, stream: 'user' })
const socket = new WebSocket(url)
console.log(socket)
if (socket) {
socket.addEventListener('message', (wsEvent) => onMessage(handleMastoWS(wsEvent)))
+ socket.addEventListener('error', (error) => console.error('WebSocket Error:', error))
+ return socket
} else {
throw new Error('failed to connect to socket')
}