From 5b08301d9b91d77d22e91cf1007b68a9279a6c02 Mon Sep 17 00:00:00 2001 From: Charles Iliya Krempeaux Date: Wed, 7 Aug 2024 10:47:47 -0700 Subject: [PATCH] /api/v1/streaming/public/local --- api/v1/streaming/public/local/dial.go | 10 ++++++++++ api/v1/streaming/public/local/errors.go | 1 + 2 files changed, 11 insertions(+) diff --git a/api/v1/streaming/public/local/dial.go b/api/v1/streaming/public/local/dial.go index effbbfe..40e815f 100644 --- a/api/v1/streaming/public/local/dial.go +++ b/api/v1/streaming/public/local/dial.go @@ -25,6 +25,16 @@ func DialHost(host string) (Client, error) { } func Dial(req *http.Request) (Client, error) { + if nil == req { + return nil, errNilHTTPRequest + } + + if nil == req.URL { + req.URL = new(url.URL) + } + + req.URL.Path = Path + sseclient, err :=httpsse.Dial(req) if nil != err { return nil, err diff --git a/api/v1/streaming/public/local/errors.go b/api/v1/streaming/public/local/errors.go index 0590ee4..fc13d1c 100644 --- a/api/v1/streaming/public/local/errors.go +++ b/api/v1/streaming/public/local/errors.go @@ -6,6 +6,7 @@ import ( const ( errNilDestination = erorr.Error("mstdn: nil destination") + errNilHTTPRequest = erorr.Error("mstdn: nil http-request") errNilHTTPSSEClient = erorr.Error("mstdn: nil http-sse-client") errNilReceiver = erorr.Error("mstdn: nil receiver") )