Skip to content

Commit

Permalink
Extend streams API to allow multiple sources
Browse files Browse the repository at this point in the history
  • Loading branch information
edenhaus committed Oct 22, 2024
1 parent ef7d898 commit 95a5283
Show file tree
Hide file tree
Showing 4 changed files with 42 additions and 10 deletions.
2 changes: 1 addition & 1 deletion internal/homekit/api.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ func apiPair(id, url string) error {
return err
}

streams.New(id, conn.URL())
streams.New(id, []string{conn.URL()})

return app.PatchConfig(id, conn.URL(), "streams")
}
Expand Down
32 changes: 28 additions & 4 deletions internal/streams/api.go
Original file line number Diff line number Diff line change
@@ -1,20 +1,26 @@
package streams

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

"github.com/AlexxIT/go2rtc/internal/api"
"github.com/AlexxIT/go2rtc/internal/app"
"github.com/AlexxIT/go2rtc/pkg/probe"
)

func returnAllStreams(w http.ResponseWriter) {
api.ResponseJSON(w, streams)
}

func apiStreams(w http.ResponseWriter, r *http.Request) {
query := r.URL.Query()
src := query.Get("src")

// without source - return all streams list
if src == "" && r.Method != "POST" {
api.ResponseJSON(w, streams)
// PUT checks first body for sources
if src == "" && r.Method != "POST" && r.Method != "PUT" {
returnAllStreams(w)
return
}

Expand Down Expand Up @@ -47,13 +53,31 @@ func apiStreams(w http.ResponseWriter, r *http.Request) {
if name == "" {
name = src
}
var sources []string
if src != "" {
sources = []string{src}
} else if r.Header.Get("Content-Type") == "application/json" {
var data struct {
Sources []string `json:"sources"`
}
if err := json.NewDecoder(r.Body).Decode(&data); err != nil {
log.Error().Err(err).Caller().Send()
http.Error(w, err.Error(), http.StatusBadRequest)
return
}
sources = data.Sources
} else {
// without source(s) - return all streams list
returnAllStreams(w)
return
}

if New(name, src) == nil {
if New(name, sources) == nil {
http.Error(w, "", http.StatusBadRequest)
return
}

if err := app.PatchConfig(name, src, "streams"); err != nil {
if err := app.PatchConfig(name, sources, "streams"); err != nil {
http.Error(w, err.Error(), http.StatusBadRequest)
}

Expand Down
6 changes: 6 additions & 0 deletions internal/streams/stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,12 @@ func NewStream(source any) *Stream {
return &Stream{
producers: []*Producer{NewProducer(source)},
}
case []string:
s := new(Stream)
for _, str := range source {
s.producers = append(s.producers, NewProducer(str))
}
return s
case []any:
s := new(Stream)
for _, src := range source {
Expand Down
12 changes: 7 additions & 5 deletions internal/streams/streams.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,12 +56,14 @@ func Validate(source string) error {
return nil
}

func New(name string, source string) *Stream {
if Validate(source) != nil {
return nil
func New(name string, sources []string) *Stream {
for _, source := range sources {
if Validate(source) != nil {
return nil
}
}

stream := NewStream(source)
stream := NewStream(sources)

streamsMu.Lock()
streams[name] = stream
Expand Down Expand Up @@ -105,7 +107,7 @@ func Patch(name string, source string) *Stream {
}

// create new stream with this name
return New(name, source)
return New(name, []string{source})
}

func GetOrPatch(query url.Values) *Stream {
Expand Down

0 comments on commit 95a5283

Please sign in to comment.