File "turbo-echo-stream-tag.js"

Full Path: /home/fundopuh/trader.fxex.org/resources/js/elements/turbo-echo-stream-tag.js
File size: 1.13 KB
MIME-type: text/plain
Charset: utf-8

import { connectStreamSource, disconnectStreamSource } from "@hotwired/turbo"

const subscribeTo = (type, channel) => {
    if (type === "presence") {
        return window.Echo.join(channel)
    }

    return window.Echo[type](channel)
}

class TurboEchoStreamSourceElement extends HTMLElement {
    async connectedCallback() {
        connectStreamSource(this)
        this.subscription = subscribeTo(this.type, this.channel)
            .listen('.Tonysm\\TurboLaravel\\Events\\TurboStreamBroadcast', (e) => {
                this.dispatchMessageEvent(e.message)
            })
    }

    disconnectedCallback() {
        disconnectStreamSource(this)
        if (this.subscription) {
            window.Echo.leave(this.channel)
            this.subscription = null
        }
    }

    dispatchMessageEvent(data) {
        const event = new MessageEvent("message", { data })
        return this.dispatchEvent(event)
    }

    get channel() {
        return this.getAttribute("channel")
    }

    get type() {
        return this.getAttribute("type") || "private"
    }
}

customElements.define("turbo-echo-stream-source", TurboEchoStreamSourceElement)