1 files changed, 119 insertions, 0 deletions
diff --git a/src/main/nodejs/misc/ProduceLotsOfQueues.js b/src/main/nodejs/misc/ProduceLotsOfQueues.js
new file mode 100644
index 0000000..810ac63
--- /dev/null
+++ b/src/main/nodejs/misc/ProduceLotsOfQueues.js
@@ -0,0 +1,119 @@
+;(function(){
+
+    const http = require("http");
+    const log = process.stderr;
+    const out = process.stdout;
+    const NOOP = function(){};
+
+    setTimeout(main); return;
+
+
+    function main(){
+        const app = Object.seal({
+            isHelp: false,
+            host: "localhost",
+            port: 7013,
+            uri: "/houston/tmp/gugus/bar",
+            queueName: "my-gaga-queue",
+        });
+        if( parseArgs(app, process.argv) !== 0 ) process.exit(1);
+        if( app.isHelp ){ printHelp(); return; }
+        run(app);
+    }
+
+
+
+    function printHelp(){
+        out.write("\n"
+            +"  Produce a bunch of gateleen queues\n"
+            +"  \n"
+            +"  Options:\n"
+            +"  \n"
+            +"  \n")
+    }
+
+
+    function parseArgs( app, argv ){
+        var isYolo = false;
+        for( var iA = 2 ; iA < argv.length ; ++iA ){
+            var arg = argv[iA];
+            if( arg == "--help" ){
+                app.isHelp = true; return 0;
+            }else if( arg == "--yolo" ){
+                isYolo = true;
+            }else{
+                log.write("EINVAL: "+ arg +"\n");
+                return -1;
+            }
+        }
+        if( !isYolo ){ log.write("EINVAL: wanna yolo?\n"); return; }
+        return 0;
+    }
+
+
+    function run( app ){
+        //placeHook(app);
+        putSomeNonsense(app);
+    }
+
+
+    function placeHook( app ){
+        const req = Object.seal({
+            base: null,
+            app: app,
+        });
+        req.base = http.request({
+            host: app.host, port: app.port,
+            method: "PUT", path: app.uri +"/_hooks/listeners/http",
+            //headers: {
+            //    "X-Expire-After": "42",
+            //},
+        });
+        req.base.on("response", onResponse.bind(0, req));
+        req.base.end(JSON.stringify({
+            destination: "http://127.0.0.1:7099/guguseli",
+            queueExpireAfter/*seconds*/: 42,
+        }));
+        function onResponse( req, rsp ){
+            var app = req.app;
+            log.write("[DEBUG] < HTTP/"+ rsp.httpVersion +" "+ rsp.statusCode +" "+ rsp.statusMessage +"\n");
+            for( var k of Object.keys(rsp.headers) ) log.write("[DEBUG] < "+ k +": "+ rsp.headers[k] +"\n");
+        }
+    }
+
+
+    function putSomeNonsense( app ){
+        const nonsense = Object.seal({
+            app: app,
+            req: null,
+            i: 0,
+            limit: 42,
+        });
+        putNextRequest(nonsense);
+        function putNextRequest( nonsense ){
+            nonsense.req = http.request({
+                host: app.host, port: app.port,
+                method: "PUT", path: app.uri +"/foo/"+ nonsense.i,
+                headers: {
+                    "X-Queue": app.queueName +"-"+ nonsense.i,
+                    "X-Queue-Expire-After": 9999999,
+                },
+            });
+            nonsense.req.on("response", onResponse.bind(0, nonsense));
+            nonsense.req.end("{\"guguseli\":\""+ new Date().toISOString() +"\"}\n");
+        }
+        function onResponse( nonsense, rsp ){
+            var app = nonsense.app;
+            if( rsp.statusCode != 200 ){
+                log.write("[DEBUG] < HTTP/"+ rsp.httpVersion +" "+ rsp.statusCode +" "+ rsp.statusMessage +"\n");
+                for( var k of Object.keys(rsp.headers) ) log.write("[DEBUG] < "+ k +": "+ rsp.headers[k] +"\n");
+            }
+            rsp.on("data", NOOP);
+            if( nonsense.i++ < nonsense.limit ){
+                putNextRequest(nonsense);
+            }
+        }
+    }
+
+
+}());