Initial Commit.

Author: Z-a-r-a-k-i

.gitignore

@@ -0,0 +1,75 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# TypeScript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+# parcel-bundler cache (https://parceljs.org/)
+.cache
+
+# next.js build output
+.next
+
+# nuxt.js build output
+.nuxt
+
+# vuepress build output
+.vuepress/dist
+
+# Serverless directories
+.serverless
+
+.vscode

README.md

@@ -0,0 +1,12 @@
+# A faucet for osmose devnet
+
+## Installation
+Be sure that NodeJs is installed (version > 8.x.x).
+Clone the repository
+`npm install`
+
+## Start the faucet
+`node main.js`
+
+## Access the faucet
+Open a browser and enter http://localhost:8080 in url navbar

config.json

@@ -0,0 +1,3 @@
+{
+  "faucetWallet" : ""
+}

lib/dbclient.js

@@ -0,0 +1,69 @@
+var MongoClient = require('mongodb').MongoClient;
+var url = "mongodb://localhost:27017/osmose_faucet";
+
+module.exports = {
+  CheckAddressInDatabase: async function (address) {
+    let addressFound = await new Promise(function(resolve, reject) {
+      MongoClient.connect(url, {}, function(err, db) {
+        if (err)
+          throw err;
+        
+        db.collection("addresses").find({address: address}, {sort: {time: -1}, limit: 1}, function (error, results) {
+          if (error) {
+            db.close();
+            reject(error);
+          }
+
+          results.toArray().then(function (value) {
+            db.close();
+            resolve(value[0]);
+          });
+        });
+      });
+    });
+
+    if(!addressFound || addressFound.time.getTime() + 24 * 60 * 60000 < new Date().getTime())
+      return true;
+    else
+      return false;
+  },
+  AddAddressToDatabase: function (address) {
+    MongoClient.connect(url, {}, function(err, db) {
+      if (err)
+        throw err;
+    
+      let addressItem = { address: address, time: new Date() };
+      db.collection("addresses").insert(addressItem, null, function (error, results) {
+        if (error)
+          throw error; 
+      });
+    
+      db.close();
+    });
+  },
+  CanSend: async function() {
+    let addressFound = await new Promise(function(resolve, reject) {
+      MongoClient.connect(url, {}, function(err, db) {
+        if (err)
+          throw err;
+        
+        db.collection("addresses").find({}, {sort: {time: -1}, limit: 1}, function (error, results) {
+          if (error) {
+            db.close();
+            reject(error);
+          }
+
+          results.toArray().then(function (value) {
+            db.close();
+            resolve(value[0]);
+          });
+        });
+      });
+    });
+
+    if(!addressFound || addressFound.time.getTime() + 30000 < new Date().getTime())
+      return true;
+    else
+      return false;
+  }
+};

lib/osmose.js

@@ -0,0 +1,39 @@
+var arkjs = require("arkjs");
+var fs = require('fs');
+var XMLHttpRequest = require("xmlhttprequest").XMLHttpRequest;
+
+module.exports = {
+  CheckAddress: function (address) {
+    return arkjs.crypto.validateAddress(address, 115);
+  },
+  SendOSM: function (address) {
+    let wallet = JSON.parse(fs.readFileSync('config.json', 'utf8')).faucetWallet;
+    let nethash = "fa976091894eee4cad258bdae4e3323d0768c4f8610e471237408ac4aa0a92d0";
+    let sender = arkjs.crypto.getKeys(wallet);
+    let amountSatoshi = 1000 * Math.pow(10, 8);
+
+    let transaction = arkjs.transaction.createTransaction(address, amountSatoshi, "Courtesy of our faucet", sender, undefined, 115);
+
+    let transactions = {
+      transactions: [transaction]
+    }
+
+    let http = new XMLHttpRequest();
+    let url = 'http://blockchain.osmose.world:4100/peer/transactions';
+    http.open('POST', url, true);
+    http.setRequestHeader("nethash", nethash);
+    http.setRequestHeader("version", "1.6.0");
+    http.setRequestHeader("port", "1");
+    
+    //Send the proper header information along with the request
+    http.setRequestHeader("Content-Type", "application/json");
+    
+    http.onreadystatechange = function () {
+      if (http.readyState === 4 && http.status === 200) {
+          console.log(new Date() + " | 1000 OSM sent from : " + arkjs.crypto.getAddress(sender.publicKey, 115) + " --> " + address);
+      }
+    };
+
+    http.send(JSON.stringify(transactions));
+  }
+};

main.js

@@ -0,0 +1,55 @@
+var express = require('express');
+var bodyParser = require('body-parser');
+var osmose = require('./lib/osmose');
+var dbclient = require('./lib/dbclient');
+
+var app = express();
+app.use(express.static('public'));
+app.use( bodyParser.json() );
+app.use(bodyParser.urlencoded({
+  extended: true
+})); 
+
+app.get('/', function(req, res) {
+  let param = {
+    formData: {
+      addressError: false,
+      delayError: false,
+      delayAddressError: false,
+      success: false
+    }
+  };
+
+  res.render('index.ejs', param);
+});
+
+app.post('/', async function(req, res) {
+  let address = req.body.address;
+  let param = {
+    formData: {
+      addressError: !osmose.CheckAddress(address),
+      delayError: false,
+      delayAddressError: false,
+      success: false
+    }
+  };
+
+  if(!param.formData.addressError) {
+    if(await dbclient.CheckAddressInDatabase(address)) {
+      if(await dbclient.CanSend()) {
+        osmose.SendOSM(address);
+        dbclient.AddAddressToDatabase(address);
+        param.formData.success = true;
+      }
+      else {
+        param.formData.delayError = true;
+      }
+    }
+    else
+      param.formData.delayAddressError = true;
+  }
+
+  res.render('index.ejs', param);
+});
+
+app.listen(8080);