Skip to content

Commit

Permalink
skeleton of IPC mechanism to allow playback control with cmdline flags
Browse files Browse the repository at this point in the history
  • Loading branch information
dweymouth committed Jun 9, 2024
1 parent e3dc2e3 commit a851e0f
Show file tree
Hide file tree
Showing 6 changed files with 128 additions and 0 deletions.
19 changes: 19 additions & 0 deletions backend/ipc/api.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
package ipc

const (
PlayPath = "/transport/play"
PlayPausePath = "/transport/playpause"
PausePath = "/transport/pause"
StopPath = "/transport/stop"
PreviousPath = "/transport/previous"
NextPath = "/transport/next"
TimePosPath = "/transport/timepos"

PlayTrackPath = "/queue/playtrack"

VolumePath = "/volume"
)

type Response struct {
Error string `json:"error"`
}
14 changes: 14 additions & 0 deletions backend/ipc/conn_other.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
//go:build !windows

package ipc

import "net"

func Dial() (net.Conn, error) {
// TODO - use XDG runtime dir, also handle portable mode
return net.Dial("unix", "/tmp/supersonic.sock")
}

func Listen() (net.Listener, error) {
return net.Listen("unix", "/tmp/supersonic.sock")
}
19 changes: 19 additions & 0 deletions backend/ipc/conn_windows.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
//go:build windows

package ipc

import (
"net"
"time"

"github.com/Microsoft/go-winio"
)

func Dial() (net.Conn, error) {
timeout := 300 * time.Millisecond
return winio.DialPipe("supersonic", &timeout)
}

func Listen() (net.Listener, error) {
return winio.ListenPipe("supersonic", nil)
}
73 changes: 73 additions & 0 deletions backend/ipc/server.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
package ipc

import (
"encoding/json"
"net/http"
)

type Handler interface {
PlayPause() error
Stop() error
Pause() error
Continue() error
SeekBackOrPrevious() error
SeekNext() error
SeekSeconds(float64) error
Volume() int
SetVolume(int) error
}

type serverImpl struct {
handler Handler
}

func NewServer(handler Handler) *http.Server {
s := serverImpl{handler: handler}
return &http.Server{
Handler: s.createHandler(),
}
}

func (s *serverImpl) createHandler() http.Handler {
m := http.NewServeMux()
m.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusNotFound)
w.Write([]byte("The given path is not valid"))
})
m.HandleFunc(PlayPath, s.makeSimpleEndpointHandler(s.handler.Continue))
m.HandleFunc(PausePath, s.makeSimpleEndpointHandler(s.handler.Pause))
m.HandleFunc(PlayPausePath, s.makeSimpleEndpointHandler(s.handler.PlayPause))
m.HandleFunc(StopPath, s.makeSimpleEndpointHandler(s.handler.Stop))
m.HandleFunc(PreviousPath, s.makeSimpleEndpointHandler(s.handler.SeekBackOrPrevious))
m.HandleFunc(NextPath, s.makeSimpleEndpointHandler(s.handler.SeekNext))
return m
}

func (s *serverImpl) makeSimpleEndpointHandler(f func() error) func(http.ResponseWriter, *http.Request) {
return func(w http.ResponseWriter, r *http.Request) {
if err := f(); err == nil {
s.writeOK(w)
} else {
s.writeErr(w, err)
}
}
}

func (s *serverImpl) writeOK(w http.ResponseWriter) (int, error) {
var r Response
b, err := json.Marshal(&r)
if err != nil {
return 0, err
}
return w.Write(b)
}

func (s *serverImpl) writeErr(w http.ResponseWriter, err error) (int, error) {
r := Response{Error: err.Error()}
b, err := json.Marshal(&r)
if err != nil {
return 0, err
}
w.WriteHeader(http.StatusInternalServerError)
return w.Write(b)
}
1 change: 1 addition & 0 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ go 1.21
require (
fyne.io/fyne/v2 v2.5.0
github.com/20after4/configdir v0.1.1
github.com/Microsoft/go-winio v0.6.2
github.com/cenkalti/dominantcolor v1.0.2
github.com/deluan/sanitize v0.0.0-20230310221930-6e18967d9fc1
github.com/dweymouth/fyne-lyrics v0.0.0-20240528234907-15eee7ce5e64
Expand Down
2 changes: 2 additions & 0 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,8 @@ github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03
github.com/BurntSushi/toml v1.3.2 h1:o7IhLm0Msx3BaB+n3Ag7L8EVlByGnpq14C4YWiu/gL8=
github.com/BurntSushi/toml v1.3.2/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
github.com/Microsoft/go-winio v0.6.2 h1:F2VQgta7ecxGYO8k3ZZz3RS8fVIXVxONVUPlNERoyfY=
github.com/Microsoft/go-winio v0.6.2/go.mod h1:yd8OoFMLzJbo9gZq8j5qaps8bJ9aShtEA8Ipt1oGCvU=
github.com/akavel/rsrc v0.10.2/go.mod h1:uLoCtb9J+EyAqh+26kdrTgmzRBFPGOolLWKpdxkKq+c=
github.com/alessio/shellescape v1.4.1 h1:V7yhSDDn8LP4lc4jS8pFkt0zCnzVJlG5JXy9BVKJUX0=
github.com/alessio/shellescape v1.4.1/go.mod h1:PZAiSCk0LJaZkiCSkPv8qIobYglO3FPpyFjDCtHLS30=
Expand Down

0 comments on commit a851e0f

Please sign in to comment.