From e9bf22ae73b50bf7e72664bd7e71daedacbac9b6 Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Thu, 27 Feb 2020 19:38:31 +0300 Subject: add zip module --- pkg/server/module/hex.go | 15 +++++++------ pkg/server/module/zip.go | 55 ++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 63 insertions(+), 7 deletions(-) create mode 100644 pkg/server/module/zip.go (limited to 'pkg/server/module') diff --git a/pkg/server/module/hex.go b/pkg/server/module/hex.go index c3ad0db..e71688c 100644 --- a/pkg/server/module/hex.go +++ b/pkg/server/module/hex.go @@ -9,7 +9,7 @@ import ( type hexModule struct{} -func (h hexModule) Send(rq, wq queue.Q) error { +func (m hexModule) Send(rq, wq queue.Q) error { enc := hex.NewEncoder(wq.Writer()) for b := range rq { @@ -19,18 +19,19 @@ func (h hexModule) Send(rq, wq queue.Q) error { return nil } -func (h hexModule) Recv(rq, wq queue.Q) error { +func (m hexModule) Recv(rq, wq queue.Q) error { r := hex.NewDecoder(rq.Reader()) - w := wq.Writer() - return queue.IoCopy(r, w) + return queue.IoCopy(r, wq.Writer()) } func (m hexModule) Open(env env.Env) (interface{}, error) { return m, nil } +func newHexModule(opts.Opts, env.Env) (module, error) { + return hexModule{}, nil +} + func init() { - register("hex", func(opts.Opts, env.Env) (module, error) { - return hexModule{}, nil - }) + register("hex", newHexModule) } diff --git a/pkg/server/module/zip.go b/pkg/server/module/zip.go new file mode 100644 index 0000000..b0abb38 --- /dev/null +++ b/pkg/server/module/zip.go @@ -0,0 +1,55 @@ +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) +} -- cgit v1.2.3-70-g09d2