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") )