androiddrew
/
learning_sse
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

merge into: androiddrew:main
Branches Tags
androiddrew:drew/ui
androiddrew:main
...
pull from: androiddrew:drew/ui
Branches Tags
androiddrew:drew/ui
androiddrew:main

2 Commits
main ... drew/ui

Author SHA1 Message Date
Drew Bednar fcceaa9b81 Working example 5 days ago
Drew Bednar 6393ef71f6 Saving work 5 days ago
8 changed files with 129 additions and 8 deletions
Show Stats

52
.air.toml
Unescape Escape View File

@ -0,0 +1,52 @@
root = "."
testdata_dir = "testdata"
tmp_dir = "tmp"
[build]
args_bin = []
bin = "./tmp/main"
cmd = "go build -o ./tmp/main ."
delay = 1000
exclude_dir = ["assets", "tmp", "vendor", "testdata"]
exclude_file = []
exclude_regex = ["_test.go"]
exclude_unchanged = false
follow_symlink = false
full_bin = ""
include_dir = []
include_ext = ["go", "tpl", "tmpl", "html"]
include_file = []
kill_delay = "0s"
log = "build-errors.log"
poll = false
poll_interval = 0
post_cmd = []
pre_cmd = []
rerun = false
rerun_delay = 500
send_interrupt = false
stop_on_error = false
[color]
app = ""
build = "yellow"
main = "magenta"
runner = "green"
watcher = "cyan"
[log]
main_only = false
silent = false
time = false
[misc]
clean_on_exit = false
[proxy]
app_port = 0
enabled = false
proxy_port = 0
[screen]
clear_on_rebuild = false
keep_scroll = true

1
.gitignore vendored
Unescape Escape View File

@ -21,3 +21,4 @@
# Go workspace file # Go workspace file
go.work go.work
tmp/

2
go.mod
Unescape Escape View File

@ -1,3 +1,3 @@
module git.runcible.io/androiddrew/learning_sse module git.runcible.io/androiddrew/learning_sse
go 1.21.0 go 1.24.1

44
main.go
Unescape Escape View File

@ -3,14 +3,39 @@ package main
import ( import (
"context" "context"
"fmt" "fmt"
"io" "html/template"
//"io"
"log/slog" "log/slog"
"net/http" "net/http"
"os"
//"os"
"strings" "strings"
"time" "time"
) )
func IndexHandler(w http.ResponseWriter, r *http.Request) {
files := []string{
"./ui/html/base.go.tmpl",
"./ui/html/index.go.tmpl",
}
ts, err := template.ParseFiles(files...)
if err != nil {
slog.Error("error parsing files", "error", err)
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
return
}
err = ts.ExecuteTemplate(w, "base", nil)
if err != nil {
slog.Error("error executing template", "error", err)
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
return
}
}
func SSEHandler(w http.ResponseWriter, r *http.Request) { func SSEHandler(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "text/event-stream") w.Header().Set("Content-Type", "text/event-stream")
@ -23,26 +48,31 @@ func SSEHandler(w http.ResponseWriter, r *http.Request) {
} }
func routes() http.Handler { func routes() http.Handler {
// TODO add static server and an HTML index with `new EventSource` JS that writes the data message contents into an element on the page fileServer := http.FileServer(http.Dir("./ui/static/"))
mux := http.NewServeMux() mux := http.NewServeMux()
mux.HandleFunc("/sse", SSEHandler) mux.Handle("GET /static/", http.StripPrefix("/static", fileServer))
mux.HandleFunc("GET /sse", SSEHandler)
mux.HandleFunc("GET /{$}", IndexHandler)
return mux return mux
} }
func run(ctx context.Context, w io.Writer, args []string) error { // TODO add args slice and process flags
// TODO add io.Writer and pass that to the logger
func run(ctx context.Context) error {
addr := fmt.Sprintf("%s:%d", "0.0.0.0", 8888) addr := fmt.Sprintf("%s:%d", "0.0.0.0", 8888)
srv := &http.Server{ srv := &http.Server{
Addr: addr, Addr: addr,
Handler: routes(), Handler: routes(),
} }
slog.Info("Listing on: http://0.0.0.0:8888") slog.Info("Listing on: http://0.0.0.0:8888/")
return srv.ListenAndServe() return srv.ListenAndServe()
} }
func main() { func main() {
ctx := context.Background() ctx := context.Background()
if err := run(ctx, os.Stdout, os.Args); err != nil { // TODO add os.Args
if err := run(ctx); err != nil {
slog.Error("an error occurred", "error", err) slog.Error("an error occurred", "error", err)
} }
} }

21
ui/html/base.go.tmpl
Unescape Escape View File

@ -0,0 +1,21 @@
{{ define "base" -}}
<!doctype html>
<html lang="en">
<head>
<meta charset="utf-8">
<title>{{template "title" .}}</title>
<link rel="stylesheet" href="/static/css/main.css"/>
<link rel="short icon" href="/static/img/favicon.ico" type="image/x-icon"/>
</head>
<body>
<header>
<h1>Server Sent Events Example</h1>
</header>
<main>
{{template "main" .}}
</main>
</body>
<footer>Powered By <a href='https://golang.org/'>Go</a> in {{ .CurrentYear }}</footer>
<script src="/static/js/main.js" type="text/javascript"></script>
</html>
{{ end }}

5
ui/html/index.go.tmpl
Unescape Escape View File

@ -0,0 +1,5 @@
{{define "title"}}SSE Example{{end}}
{{define "main"}}
<p id="stuff"></p>
{{end}}

4
ui/static/css/main.css
Unescape Escape View File

@ -0,0 +1,4 @@
body {
background-color: slategrey;
text-align: center;
}

8
ui/static/js/main.js
Unescape Escape View File

@ -0,0 +1,8 @@
const evtSource = new EventSource("/sse");
let content = document.getElementById("stuff")
evtSource.onmessage = (event) => {
content.innerHTML += event.data + ' ';
};
Write Preview
Loading…
Cancel
Save