makemehapi streams is bad example...

cristinecula · Jul 4, 2014 · c156bc8 · c156bc8
1 parent 9de0c42
commit c156bc8
Show file tree

Hide file tree

Showing 4 changed files with 195 additions and 0 deletions.
diff --git a/makemehapi/08-STREAMS.js b/makemehapi/08-STREAMS.js
@@ -0,0 +1,101 @@
+var Fs = require('fs');
+var Hapi = require('hapi');
+var Stream = require('stream');
+var Util = require('util');
+var server = Hapi.createServer('localhost', Number(process.argv[2] || 8081));
+
+function ROT13Stream () {
+
+    Stream.Transform.call(this);
+}
+Util.inherits(ROT13Stream, Stream.Transform);
+
+ROT13Stream.table = {
+    A: 'N',
+    B: 'O',
+    C: 'P',
+    D: 'Q',
+    E: 'R',
+    F: 'S',
+    G: 'T',
+    H: 'U',
+    I: 'V',
+    J: 'W',
+    K: 'X',
+    L: 'Y',
+    M: 'Z',
+    N: 'A',
+    O: 'B',
+    P: 'C',
+    Q: 'D',
+    R: 'E',
+    S: 'F',
+    T: 'G',
+    U: 'H',
+    V: 'I',
+    W: 'J',
+    X: 'K',
+    Y: 'L',
+    Z: 'M',
+    a: 'n',
+    b: 'o',
+    c: 'p',
+    d: 'q',
+    e: 'r',
+    f: 's',
+    g: 't',
+    h: 'u',
+    i: 'v',
+    j: 'w',
+    k: 'x',
+    l: 'y',
+    m: 'z',
+    n: 'a',
+    o: 'b',
+    p: 'c',
+    q: 'd',
+    r: 'e',
+    s: 'f',
+    t: 'g',
+    u: 'h',
+    v: 'i',
+    w: 'j',
+    x: 'k',
+    y: 'l',
+    z: 'm'
+};
+
+ROT13Stream.prototype._transform = function (data, encoding, callback) {
+
+    encoding = (encoding == 'buffer' ? 'utf8' : encoding);
+    data = data.toString(encoding);
+
+    var modified = "";
+    var l = data.length;
+    for(var i = 0;i<l;i++) {
+        if (ROT13Stream.table.hasOwnProperty(data[i])) {
+            modified += ROT13Stream.table[data[i]];
+        } else {
+            modified += data[i];
+        }
+    }
+    this.push(modified, encoding);
+
+    callback();
+};
+
+
+server.route({
+    method: "GET",
+    path: "/",
+    config: {
+        handler: function (request, reply) {
+            var thisfile = Fs.createReadStream(__dirname + '/input.txt');
+            var rot13 = new ROT13Stream();
+
+            reply(thisfile.pipe(rot13));
+        }
+    }
+});
+
+server.start();
diff --git a/makemehapi/README.md b/makemehapi/README.md
@@ -12,3 +12,5 @@ but you actually need
 {{query.name}}
 ```
 *but* most intelligent people can figure it out.
+
+> http://en.wikipedia.org/wiki/ROT13
diff --git a/makemehapi/input.txt b/makemehapi/input.txt
@@ -0,0 +1 @@
+The Pursuit of Hapi-ness
diff --git a/makemehapi/simple-rot13-stream.js b/makemehapi/simple-rot13-stream.js
@@ -0,0 +1,91 @@
+var Stream = require('stream');
+var Util = require('util');
+
+/*
+  To Use:
+
+  var rot13 = new ROT13Stream();
+  streamOne.pipe(rot13).pipe(process.stdout); // takes readstream streamOne, modifies with rot13, pipes into stdout
+*/
+
+
+function ROT13Stream() {
+    Stream.Transform.call(this);
+}
+Util.inherits(ROT13Stream, Stream.Transform);
+
+ROT13Stream.table = {
+    A: 'N',
+    B: 'O',
+    C: 'P',
+    D: 'Q',
+    E: 'R',
+    F: 'S',
+    G: 'T',
+    H: 'U',
+    I: 'V',
+    J: 'W',
+    K: 'X',
+    L: 'Y',
+    M: 'Z',
+    N: 'A',
+    O: 'B',
+    P: 'C',
+    Q: 'D',
+    R: 'E',
+    S: 'F',
+    T: 'G',
+    U: 'H',
+    V: 'I',
+    W: 'J',
+    X: 'K',
+    Y: 'L',
+    Z: 'M',
+    a: 'n',
+    b: 'o',
+    c: 'p',
+    d: 'q',
+    e: 'r',
+    f: 's',
+    g: 't',
+    h: 'u',
+    i: 'v',
+    j: 'w',
+    k: 'x',
+    l: 'y',
+    m: 'z',
+    n: 'a',
+    o: 'b',
+    p: 'c',
+    q: 'd',
+    r: 'e',
+    s: 'f',
+    t: 'g',
+    u: 'h',
+    v: 'i',
+    w: 'j',
+    x: 'k',
+    y: 'l',
+    z: 'm'
+};
+
+ROT13Stream.prototype._transform = function (data, encoding, callback) {
+
+    encoding = (encoding == 'buffer' ? 'utf8' : encoding);
+    data = data.toString(encoding);
+
+    var modified = "";
+    var l = data.length;
+    for(var i = 0;i<l;i++) {
+        if (ROT13Stream.table.hasOwnProperty(data[i])) {
+            modified += ROT13Stream.table[data[i]];
+        } else {
+            modified += data[i];
+        }
+    }
+    this.push(modified, encoding);
+
+    callback();
+};
+
+module.exports = ROT13Stream;