Realtime fails to connect/reconnect

actions: {
    async startWatch() {
        if (this.started) return

        const { realTime, Query } = useAppwrite()
        const forNotifications = useNotifications()
        // more stores here...

        const forUserCreds = useUserCreds()
        const forUserCredsId = computed(() => forUserCreds.mdV4UserId)
        const config = useRuntimeConfig().public

        const channels = [
            `databases.${config.APPWRITE_DB_ID}.tables.${config.APPWRITE_USERNOTIFICATIONS_COLL}.rows`,
            // more channels here...
        ]

        this.subscription = await realTime.subscribe(channels, (res) => {
            const row = res.payload
            if (!row) return

            const id = row.$id
            const eventsVals = Object.values(res.events)

            // NOTIFICATIONS
            if (forNotifications.handles(row)) {
                forNotifications.applyRealtime(id, row, eventsVals)
            }

            // more handlers here...

        }, [
            Query.or([
                Query.equal('userId', forUserCredsId.value),
                Query.equal('$id', forUserCredsId.value)
            ])
        ])

        this.started = true
    },

    endWatch() {
        if (this.subscription) this.subscription.close()
        this.subscription = null
        this.started = false
    }
}