diff --git a/docker/glutton/Dockerfile b/docker/glutton/Dockerfile index 5d640be7..e686969e 100644 --- a/docker/glutton/Dockerfile +++ b/docker/glutton/Dockerfile @@ -23,7 +23,6 @@ RUN apk -U --no-cache add \ cd go.uuid && \ git checkout v1.2.0 && \ mv /root/dist/system.go /opt/go/src/github.com/mushorg/glutton/ && \ - mv /root/dist/tcp.go /opt/go/src/github.com/mushorg/glutton/ && \ cd /opt/go/src/github.com/mushorg/glutton/ && \ make build && \ cd / && \ diff --git a/docker/glutton/dist/tcp.go b/docker/glutton/dist/tcp.go deleted file mode 100644 index be7999e1..00000000 --- a/docker/glutton/dist/tcp.go +++ /dev/null @@ -1,44 +0,0 @@ -package glutton - -import ( - "context" - "encoding/hex" - "fmt" - "net" - "strconv" - - "github.com/kung-foo/freki" - "go.uber.org/zap" -) - -// HandleTCP takes a net.Conn and peeks at the data send -func (g *Glutton) HandleTCP(ctx context.Context, conn net.Conn) (err error) { - defer func() { - err = conn.Close() - if err != nil { - g.logger.Error(fmt.Sprintf("[log.tcp ] error: %v", err)) - } - }() - host, port, err := net.SplitHostPort(conn.RemoteAddr().String()) - if err != nil { - g.logger.Error(fmt.Sprintf("[log.tcp ] error: %v", err)) - } - ck := freki.NewConnKeyByString(host, port) - md := g.processor.Connections.GetByFlow(ck) - buffer := make([]byte, 1024) - n, err := conn.Read(buffer) - if err != nil { - g.logger.Error(fmt.Sprintf("[log.tcp ] error: %v", err)) - } - if n > 0 && n < 1024 { - g.logger.Info( - fmt.Sprintf("Packet got handled by TCP handler"), - zap.String("dest_port", strconv.Itoa(int(md.TargetPort))), - zap.String("src_ip", host), - zap.String("src_port", port), - zap.String("handler", "tcp"), - zap.String("payload_hex", hex.EncodeToString(buffer[0:n])), - ) - } - return err -}