diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-05-07 01:06:07 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-05-07 01:06:07 +0300 |
| commit | 2c5259a594f5d8ddf12691deb6a79a0b566f024e (patch) | |
| tree | 7dabb3c34f1c9b3821766132f842a19617d08235 /pkg/server/hook/look-http.go | |
| parent | b089b35f35a14e85d89df69254cc61495d59d3dd (diff) | |
rename look to info
Diffstat (limited to 'pkg/server/hook/look-http.go')
| -rw-r--r-- | pkg/server/hook/look-http.go | 55 |
1 files changed, 0 insertions, 55 deletions
diff --git a/pkg/server/hook/look-http.go b/pkg/server/hook/look-http.go deleted file mode 100644 index 50ec663..0000000 --- a/pkg/server/hook/look-http.go +++ /dev/null @@ -1,55 +0,0 @@ -package hook - -import ( - "bufio" - "tunnel/pkg/http" - "tunnel/pkg/server/env" - "tunnel/pkg/server/opts" - "tunnel/pkg/server/queue" -) - -type lookHttpHook struct{} - -type lookHttp struct { - env env.Env -} - -func (look *lookHttp) Send(rq, wq queue.Q) error { - q := queue.New() - s := bufio.NewScanner(q.Reader()) - - go func() { - for b := range rq { - q <- b - wq <- b - } - - close(q) - }() - - if s.Scan() { - if method, uri, _, ok := http.ParseRequestLine(s.Text()); ok { - look.env.Set("look.info", method+" "+uri) - } - } - - q.Dry() - - return nil -} - -func (look *lookHttp) Recv(rq, wq queue.Q) error { - return queue.Copy(rq, wq) -} - -func (lookHttpHook) Open(env env.Env) (interface{}, error) { - return &lookHttp{env: env}, nil -} - -func newLookHttpHook(opts opts.Opts, env env.Env) (hook, error) { - return lookHttpHook{}, nil -} - -func init() { - register("look-http", newLookHttpHook) -} |
