From 2f0bcf4ae06b75ca52e9bb07d3f521a47f95e041 Mon Sep 17 00:00:00 2001 From: Nicolas Mowen Date: Thu, 13 Oct 2022 14:58:26 -0600 Subject: [PATCH] Add ability for API to set name of stream --- cmd/api/api.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/cmd/api/api.go b/cmd/api/api.go index e67ec7b3..e73353f5 100644 --- a/cmd/api/api.go +++ b/cmd/api/api.go @@ -85,10 +85,15 @@ var wsHandlers = make(map[string]WSHandler) func streamsHandler(w http.ResponseWriter, r *http.Request) { src := r.URL.Query().Get("src") + name := r.URL.Query().Get("name") + + if name == "" { + name = src + } switch r.Method { case "PUT": - streams.New(src, src) + streams.New(name, src) return case "DELETE": streams.Delete(src)