go htmx and sse example-Golang-php.cn

Home

Backend Development

Golang

go htmx and sse example

Aug 28, 2024 am 06:34 AM

go htmx and sse example

This example demonstrates how to replace few blocks on event for example "post with id 1 changed" ( post-1-changed ) and trigger to load content via ajax request on "chatter" event.

package main

import (
    "fmt"
    "net/http"
    "time"

    "github.com/r3labs/sse/v2"
)

func main() {
    server := sse.New()
    _ = server.CreateStream("messages")

    mux := http.NewServeMux()
    mux.HandleFunc("/events", func(w http.ResponseWriter, r *http.Request) {

        // la security
        token := r.URL.Query().Get("token")
        if token != "secret" {
            http.Error(w, "invalid token", http.StatusUnauthorized)
            return
        }
        go func() {
            &lt;-r.Context().Done()
            println("The client is disconnected here")
            return
        }()

        server.ServeHTTP(w, r)
    })

    mux.HandleFunc("/chatroom", func(w http.ResponseWriter, r *http.Request) {
        w.Write([]byte(`&lt;div&gt;Hello from chat room&lt;/div&gt;`))
    })

    mux.HandleFunc("/index", func(w http.ResponseWriter, r *http.Request) {
        w.Write([]byte(`
        &lt;html&gt;
        &lt;head&gt;
        &lt;script src="https://unpkg.com/htmx.org@2.0.2/dist/htmx.js"&gt;&lt;/script&gt;
        &lt;script src="https://unpkg.com/htmx-ext-sse@2.2.2/sse.js"&gt;&lt;/script&gt;
        &lt;/head&gt;
        &lt;body hx-ext="sse" sse-connect="/events?stream=messages&amp;token=secret"&gt;
        &lt;div &gt;
            &lt;div sse-swap="post-1-changed"&gt;one&lt;/div&gt;
        &lt;/div&gt;
        &lt;div&gt;
            &lt;div sse-swap="post-1-changed"&gt;one&lt;/div&gt;
        &lt;/div&gt;
        &lt;div&gt;
            &lt;div sse-swap="post-1-changed"&gt;one&lt;/div&gt;
        &lt;/div&gt;
        &lt;div&gt;
            &lt;div sse-swap="notifications"&gt;one&lt;/div&gt;
        &lt;/div&gt;
        &lt;div&gt;
            &lt;div hx-get="/chatroom" hx-trigger="sse:chatter"&gt;
                chat body reloaded
            &lt;/div&gt;
        &lt;/div&gt;
        &lt;/body&gt;&lt;/html&gt;
        `))
    })

    go func() {
        i := 0
        for {
            i++
            time.Sleep(1 * time.Second)

            server.TryPublish("messages", &amp;sse.Event{
                ID:    []byte(fmt.Sprintf("%d", i)),
                Event: []byte("post-1-changed"),
                Data:  []byte(`&lt;div&gt;Hello from sse ` + fmt.Sprintf("%d", i) + `&lt;/div&gt;`),
            })

            server.TryPublish("messages", &amp;sse.Event{
                ID:    []byte(fmt.Sprintf("%d", i)),
                Event: []byte("notifications"),
                Data:  []byte(`&lt;div&gt;Hello from post 2 sse ` + fmt.Sprintf("%d", i) + `&lt;/div&gt;`),
            })

            server.TryPublish("messages", &amp;sse.Event{
                ID:    []byte(fmt.Sprintf("%d", i)),
                Event: []byte("chatter"),
                Data:  []byte(`&lt;div&gt;&lt;/div&gt;`),
            })
            server.EventTTL = 5 * time.Second
        }
    }()

    http.ListenAndServe(":9999", mux)
}

Copy after login

The above is the detailed content of go htmx and sse example. For more information, please follow other related articles on the PHP Chinese website!

Statement of this Website

The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn