rename module to hook

1 files changed, 0 insertions, 55 deletions

diff --git a/pkg/server/module/zip.go b/pkg/server/module/zip.go
deleted file mode 100644
index b0abb38..0000000
--- a/pkg/server/module/zip.go
+++ /dev/null
@@ -1,55 +0,0 @@
-package module
-
-import (
-	"compress/flate"
-	"io"
-	"tunnel/pkg/server/env"
-	"tunnel/pkg/server/opts"
-	"tunnel/pkg/server/queue"
-)
-
-type zipModule struct{}
-
-func (m zipModule) Send(rq, wq queue.Q) error {
-	w, err := flate.NewWriter(wq.Writer(), flate.BestCompression)
-	if err != nil {
-		return err
-	}
-
-	for b := range rq {
-		if _, err := w.Write(b); err != nil {
-			return err
-		}
-		if err := w.Flush(); err != nil {
-			return err
-		}
-	}
-
-	return w.Close()
-}
-
-func (m zipModule) Recv(rq, wq queue.Q) error {
-	r := flate.NewReader(rq.Reader())
-
-	// FIXME: not received ending due to ultimate conn.Close
-	if err := queue.IoCopy(r, wq.Writer()); err != nil {
-		if err == io.ErrUnexpectedEOF {
-			return nil
-		}
-		return err
-	}
-
-	return r.Close()
-}
-
-func (m zipModule) Open(env.Env) (interface{}, error) {
-	return m, nil
-}
-
-func newZipModule(opts.Opts, env.Env) (module, error) {
-	return zipModule{}, nil
-}
-
-func init() {
-	register("zip", newZipModule)
-}