first working version

1 files changed, 32 insertions, 0 deletions

diff --git a/pkg/server/module/alpha.go b/pkg/server/module/alpha.go
new file mode 100644
index 0000000..be9032c
--- /dev/null
+++ b/pkg/server/module/alpha.go
@@ -0,0 +1,32 @@
+package module
+
+import (
+	"tunnel/pkg/server/queue"
+	"unicode"
+	"bufio"
+	"io"
+)
+
+func alpha(cb func (rune) rune) pipe {
+	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() {
+	register("lower", alpha(unicode.ToLower))
+	register("upper", alpha(unicode.ToUpper))
+}