From 49703d70a3ede70ce9a0cab824cbcb96dbf824c0 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Mon, 31 May 2021 16:05:00 +0300 Subject: - Rework access_validators - WS plugin uses it's own pool to handle requests on the /ws (or any user-defined) endpoint - Ability to write custom validators Signed-off-by: Valery Piashchynski --- plugins/http/channel.go | 29 ----------------------------- 1 file changed, 29 deletions(-) delete mode 100644 plugins/http/channel.go (limited to 'plugins/http/channel.go') diff --git a/plugins/http/channel.go b/plugins/http/channel.go deleted file mode 100644 index 23b5ff3e..00000000 --- a/plugins/http/channel.go +++ /dev/null @@ -1,29 +0,0 @@ -package http - -import ( - "net/http" -) - -// messages method used to read messages from the ws plugin with the auth requests for the topics and server -func (p *Plugin) messages() { - for msg := range p.hub.ToWorker() { - p.RLock() - // msg here is the structure with http.ResponseWriter and http.Request - rmsg := msg.(struct { - RW http.ResponseWriter - Req *http.Request - }) - - // invoke handler with redirected responsewriter and request - p.handler.ServeHTTP(rmsg.RW, rmsg.Req) - - p.hub.FromWorker() <- struct { - RW http.ResponseWriter - Req *http.Request - }{ - rmsg.RW, - rmsg.Req, - } - p.RUnlock() - } -} -- cgit v1.2.3