From 43d37d0a5f46211f610c57359a6cf25957ce482b Mon Sep 17 00:00:00 2001 From: ginuerzh Date: Sat, 27 Jan 2024 21:28:25 +0800 Subject: [PATCH] fix hop http plugin --- hop/plugin/http.go | 16 +--------------- listener/udp/metadata.go | 4 ++-- 2 files changed, 3 insertions(+), 17 deletions(-) diff --git a/hop/plugin/http.go b/hop/plugin/http.go index 0025e01..9e77da8 100644 --- a/hop/plugin/http.go +++ b/hop/plugin/http.go @@ -24,10 +24,6 @@ type httpPluginRequest struct { Src string `json:"src"` } -type httpPluginResponse struct { - Node string `json:"node"` -} - type httpPlugin struct { name string url string @@ -101,18 +97,8 @@ func (p *httpPlugin) Select(ctx context.Context, opts ...hop.SelectOption) *chai return nil } - res := httpPluginResponse{} - if err := json.NewDecoder(resp.Body).Decode(&res); err != nil { - p.log.Error(resp.Status) - return nil - } - - if res.Node == "" { - return nil - } - var cfg config.NodeConfig - if err := json.NewDecoder(bytes.NewReader([]byte(res.Node))).Decode(&cfg); err != nil { + if err := json.NewDecoder(resp.Body).Decode(&cfg); err != nil { p.log.Error(err) return nil } diff --git a/listener/udp/metadata.go b/listener/udp/metadata.go index 2c7eeec..6cb7b30 100644 --- a/listener/udp/metadata.go +++ b/listener/udp/metadata.go @@ -27,7 +27,7 @@ func (l *udpListener) parseMetadata(md mdata.Metadata) (err error) { readBufferSize = "readBufferSize" readQueueSize = "readQueueSize" backlog = "backlog" - keepAlive = "keepAlive" + keepalive = "keepalive" ttl = "ttl" ) @@ -49,7 +49,7 @@ func (l *udpListener) parseMetadata(md mdata.Metadata) (err error) { if l.md.backlog <= 0 { l.md.backlog = defaultBacklog } - l.md.keepalive = mdutil.GetBool(md, keepAlive) + l.md.keepalive = mdutil.GetBool(md, keepalive) return }