summaryrefslogtreecommitdiff
path: root/pkg/server/hook/alpha.go
diff options
context:
space:
mode:
authorMikhail Osipov <mike.osipov@gmail.com>2020-02-29 00:58:01 +0300
committerMikhail Osipov <mike.osipov@gmail.com>2020-02-29 00:58:01 +0300
commitc55afd2de177f128fae6e1c52d0c56af17096258 (patch)
tree2b06eeabf4db3a6c7ef357fb1569c4e8f72aab68 /pkg/server/hook/alpha.go
parent11501b56a751d2959480aaeaf2036eff586e5629 (diff)
rename module to hook
Diffstat (limited to 'pkg/server/hook/alpha.go')
-rw-r--r--pkg/server/hook/alpha.go32
1 files changed, 32 insertions, 0 deletions
diff --git a/pkg/server/hook/alpha.go b/pkg/server/hook/alpha.go
new file mode 100644
index 0000000..d1fefcc
--- /dev/null
+++ b/pkg/server/hook/alpha.go
@@ -0,0 +1,32 @@
+package hook
+
+import (
+ "bufio"
+ "io"
+ "tunnel/pkg/server/queue"
+ "unicode"
+)
+
+func alpha(cb func(rune) rune) Func {
+ return func(rq, wq queue.Q) error {
+ r := bufio.NewReader(rq.Reader())
+
+ for {
+ c, _, err := r.ReadRune()
+ if err != nil {
+ if err == io.EOF {
+ break
+ }
+ return err
+ }
+ wq <- []byte(string(cb(c)))
+ }
+
+ return nil
+ }
+}
+
+func init() {
+ registerFunc("lower", alpha(unicode.ToLower))
+ registerFunc("upper", alpha(unicode.ToUpper))
+}