]> code.octet-stream.net Git - broadcaster/blobdiff - server/web_sync.go
Make headings consistent in UI
[broadcaster] / server / web_sync.go
index e59403d984cf2d78d37824821646133b4d2ea7a3..a6b1a6e50313e85beb9b1237125370efbcbe1a5f 100644 (file)
@@ -8,7 +8,7 @@ import (
        "strconv"
        "strings"
 
        "strconv"
        "strings"
 
-       "code.octet-stream.net/broadcaster/protocol"
+       "code.octet-stream.net/broadcaster/internal/protocol"
        "golang.org/x/net/websocket"
 )
 
        "golang.org/x/net/websocket"
 )
 
@@ -18,12 +18,12 @@ func WebSync(ws *websocket.Conn) {
 
        badRead := false
        isAuthenticated := false
 
        badRead := false
        isAuthenticated := false
-       var user string
+       var user User
        for {
                // Ignore any massively oversize messages
                n, err := ws.Read(buf)
                if err != nil {
        for {
                // Ignore any massively oversize messages
                n, err := ws.Read(buf)
                if err != nil {
-                       if user != "" {
+                       if user.Username != "" {
                                log.Println("Lost websocket to user:", user)
                        } else {
                                log.Println("Lost unauthenticated website websocket")
                                log.Println("Lost websocket to user:", user)
                        } else {
                                log.Println("Lost unauthenticated website websocket")
@@ -40,9 +40,9 @@ func WebSync(ws *websocket.Conn) {
 
                if !isAuthenticated {
                        token := string(buf[:n])
 
                if !isAuthenticated {
                        token := string(buf[:n])
-                       u, err := db.GetUserForSession(token)
+                       u, err := users.GetUserForSession(token)
                        if err != nil {
                        if err != nil {
-                               log.Println("Could not find user for offered token", token)
+                               log.Println("Could not find user for offered token", token, err)
                                ws.Close()
                                return
                        }
                                ws.Close()
                                return
                        }
@@ -145,7 +145,7 @@ func sendRadioStatusToWeb(ws *websocket.Conn) error {
                Radios: webStatuses,
        }
        buf := new(strings.Builder)
                Radios: webStatuses,
        }
        buf := new(strings.Builder)
-       tmpl := template.Must(template.ParseFiles("templates/radios.partial.html"))
+       tmpl := template.Must(template.ParseFS(content, "templates/radios.partial.html"))
        tmpl.Execute(buf, data)
        _, err := ws.Write([]byte(buf.String()))
        return err
        tmpl.Execute(buf, data)
        _, err := ws.Write([]byte(buf.String()))
        return err