zgo/backend/app.js

540 lines
14 KiB
JavaScript

const express = require('express');
const app = express();
const bodyparser = require('body-parser');
const cors = require('cors');
const crypto = require('crypto');
const postmodel = require('./models/post');
const usermodel = require('./models/user');
const ownermodel = require('./models/owner');
const itemmodel = require('./models/item');
const ordermodel = require('./models/order');
const pricemodel = require('./models/price');
const txmodel = require('./models/tx');
const mongoose = require('mongoose');
const stdrpc = require('stdrpc');
const CoinGecko = require('coingecko-api');
var URLSafeBase64 = require('urlsafe-base64');
var Buffer = require('buffer/').Buffer;
var db = require('./config/db');
mongoose.connect('mongodb://'+db.user+':'+db.password+'@'+db.server+'/'+db.database).then(() => {
console.log("connecting-- ", db.database);
}).catch(() => {
console.log("connection failed!");
});
var fullnode = require('./config/fullnode');
const rpc = stdrpc({
url: fullnode.url,
username: fullnode.username,
password: fullnode.password
});
var async = require('async');
const CoinGeckoClient = new CoinGecko();
var intervalObject = setInterval( function() {
CoinGeckoClient.simple.price({
ids: ['zcash'],
vs_currencies: ['usd', 'gbp', 'eur', 'cad', 'aud']
}).then((data) => {
pricemodel.findOneAndUpdate({currency: 'usd'}, { price: data.data.zcash.usd, timestamp: Date.now()}, {new:true, upsert:true}, function(err,docs) {
if(err) {
console.log(err);
}
});
pricemodel.findOneAndUpdate({currency: 'gbp'}, { price: data.data.zcash.gbp, timestamp: Date.now()}, {new:true, upsert:true}, function(err,docs) {
if(err) {
console.log(err);
}
});
pricemodel.findOneAndUpdate({currency: 'eur'}, { price: data.data.zcash.eur, timestamp: Date.now()}, {new:true, upsert:true}, function(err,docs) {
if(err) {
console.log(err);
}
});
pricemodel.findOneAndUpdate({currency: 'cad'}, { price: data.data.zcash.cad, timestamp: Date.now()}, {new:true, upsert:true}, function(err,docs) {
if(err) {
console.log(err);
}
});
pricemodel.findOneAndUpdate({currency: 'aud'}, { price: data.data.zcash.aud, timestamp: Date.now()}, {new:true, upsert:true}, function(err,docs) {
if(err) {
console.log(err);
}
});
}).catch((err) => {
console.log(err);
});
}, 90000);
function hexToString(hexString) {
var str = '';
for (var n=0; n < hexString.length; n +=2) {
str += String.fromCharCode(parseInt(hexString.substr(n, 2), 16));
}
return str;
}
function sendPin(pin, address) {
//var memo = URLSafeBase64.encode(Buffer.from('ZGO pin: '.concat(pin)));
var memo = Buffer.from('ZGO pin: '.concat(pin)).toString('hex');
//console.log(typeof(memo));
var amounts = [
{
address: address,
amount: 0.00000001,
memo: memo
}
];
rpc.z_sendmany(fullnode.addr, amounts).catch((err) => {
console.log('Sendmany', err);
});
}
var blockInterval = setInterval( function() {
console.log('Node periodic Zcash scan');
rpc.z_listreceivedbyaddress(fullnode.addr, 1).then(txs => {
var re = /.*ZGO::(.*)\sReply-To:\s(z\w+)/;
async.each (txs, function(txData, callback) {
var memo = hexToString(txData.memo);
if (re.test(memo)) {
//console.log('Processing tx:', memo);
var match = re.exec(memo);
if (match != null) {
var address = match[2];
var session = match[1];
var blocktime = txData.blocktime;
var amount = txData.amount;
var expiration = blocktime;
//console.log(' ', session, blocktime);
if (txData.confirmations >= 10 ) {
usermodel.findOne({address: address, session: session, blocktime: blocktime}).then(function(doc){
if (doc != null) {
console.log('Found user');
} else {
console.log('User not found', session, blocktime, amount);
if (amount >= 0.001 && amount < 0.005){
expiration = blocktime + 3600;
} else if (amount >= 0.005){
expiration = blocktime + 24*3600;
}
console.log('exp', expiration);
const n = crypto.randomInt(0, 10000000);
const pin = n.toString().padStart(6, '0');
sendPin(pin, address);
var user = new usermodel({
address: address,
session: session,
blocktime: blocktime,
expiration: expiration,
pin: pin,
validated: false
});
user.save(function(error) {
if (error) {
console.log(error);
}
console.log('User saved');
});
}
});
ownermodel.findOne({address: address}).then(function (oDoc) {
if (oDoc != null) {
console.log('Found owner');
} else {
console.log('Owner not found', session);
var owner = new ownermodel({
address: address,
name: 'Z-Go-'.concat(address.substring(0,5))
});
owner.save().then(function(err) {
if (err) {
console.log(err);
}
console.log('Owner saved!');
}).catch(() => {
console.log('Owner exists');
});
}
}).catch((err) => {
console.log(err);
});
txmodel.deleteMany({session: session}, function(err) {
if (err) console.log(err);
console.log('Deleted confirmed login');
});
} else {
txmodel.updateOne({address: address, session: session}, { confirmations: txData.confirmations, amount:txData.amount}, {new:true, upsert:true}, function(err,docs) {
if (err) {
console.log(err);
}
});
}
}
}
}, function (err) {
if (err) {
console.log(err);
}
console.log('Txs synced');
});
});
}, 90000);
app.use(cors());
app.options('*', cors());
app.use(bodyparser.json());
app.use((req, res, next) => {
res.setHeader("Access-Control-Allow-Origin", "*");
res.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept");
res.setHeader("Access-Control-Allow-Methods", "GET, POST, PATCH, DELETE, OPTIONS");
next();
});
app.use((req, res, next) => {
if (req.headers.authorization !== 'Le2adeic8Thah4Aeng4daem6i' ) {
return res.status(401).send('Authorization required.');
} else {
next();
}
});
app.get('/api/test', (req, res, next) => {
sendPin('12345678', 'zs1w6nkameazc5gujm69350syl5w8tgvyaphums3pw8eytzy5ym08x7dvskmykkatmwrucmgv3er8e');
res.status(200).send('Endpoint triggered');
});
app.get('/api/users', (req, res, next) => {
console.log('Get: /api/users');
usermodel.find({'address': req.query.address, 'session': req.query.session}).
then((documents) => {
if (documents != null) {
res.status(200).json({
message: 'Users found successfully',
users: documents
});
} else {
res.status(204).json({
message: 'User not found',
users: null
});
}
});
});
app.get('/api/pending', (req, res, next) => {
console.log('Get: /api/pending');
txmodel.find({'session': req.query.session}).
then((documents) => {
if (documents.length > 0) {
//console.log('pending', documents);
res.status(200).json({
message: 'Found pending txs',
txs: documents
});
} else {
//console.log('pending not found', documents);
res.status(204).json({
message: 'No txs found',
txs: null
});
}
});
});
app.get('/api/getuser', (req, res, next) => {
console.log('Get: /api/getuser/', req.query.session);
var today = new Date().getTime() / 1000;
usermodel.find({'session': req.query.session, 'expiration': { $gt: today }}).
then((documents) => {
if(documents.length > 0){
//console.log(documents);
console.log(' found user');
res.status(200).json({
message: 'User found!',
user: documents
});
} else {
console.log(' did not find user');
res.status(204).json({
message: 'User not found!',
user: null
});
}
});
});
app.get('/api/blockheight', (req, res, next) => {
console.log('Get: /api/blockheight');
rpc.getblock("-1", 1).then(block => {
res.status(200).json({
message: 'Found block',
height: block.height
});
});
});
app.get('/api/txs', (req, res, next) => {
console.log('Get: /api/txs');
rpc.z_listreceivedbyaddress(fullnode.addr, 10).then(txs => {
res.status(200).json({
message: 'Transactions found',
txs: txs
});
});
});
app.get('/api/getaddr', (req, res, next) => {
console.log('Get: /api/getaddr');
res.status(200).json({
message: 'Sending address',
addr: fullnode.addr
});
});
app.get('/api/getowner', (req, res, next) => {
console.log('Get: /api/getowner');
ownermodel.find({'address': req.query.address}).then((documents) => {
if(documents.length > 0){
//console.log(documents);
res.status(200).json({
message: 'Owner found!',
owner: documents
});
} else {
res.status(204).json({
message: 'Owner not found!',
owner: null
});
}
});
});
app.post('/api/addowner', (req, res, next) => {
console.log('Post: /api/addowner');
const owner = new ownermodel(req.body);
owner.save();
res.status(201).json({
message: 'Owner added successfully'
});
});
app.post('/api/validateuser', (req, res, next) => {
console.log('Post: /api/validateuser');
usermodel.findByIdAndUpdate(req.body.user._id, req.body.user,
function(err, docs) {
if (err) {
console.log(err);
} else {
res.status(201).json({
message: 'User Validated',
user: docs
});
}
});
});
app.post('/api/updateowner', (req, res, next) => {
console.log('Post: /api/updateowner');
ownermodel.findByIdAndUpdate(req.body.owner._id, req.body.owner,
function(err, docs) {
if (err) {
console.log(err);
} else {
res.status(201).json({
message: 'Owner updated',
owner: docs
});
}
});
});
app.get('/api/getitems', (req, res, next) => {
console.log('Get: /api/getitems');
//console.log('getitems', req.query.address);
if (req.query.address.length > 0 ) {
const items = itemmodel.find({user: req.query.address}).then((documents) => {
if(documents.length > 0){
//console.log(documents);
res.status(200).json({
message: 'items found!',
items: documents
});
} else {
res.status(204).json({
message: 'items not found!',
items: []
});
}
});
} else {
res.status(204).json({
message: 'no address',
items: []
});
}
});
app.post('/api/item', (req, res, next) => {
console.log('Post: /api/item', req.body.item);
if ( req.body.item._id == null ) {
const item = new itemmodel(req.body.item);
item.save();
res.status(201).json({
message: 'Item added'
});
} else {
console.log('Editing', req.body.item._id);
itemmodel.findByIdAndUpdate(req.body.item._id, {'name': req.body.item.name, 'description': req.body.item.description, 'cost': req.body.item.cost},
function(err, docs) {
if (err) {
console.log(err);
} else {
res.status(201).json({
message: 'Item updated'
});
}
});
}
});
app.delete('/api/item/:id', (req, res, next) => {
console.log('delete endpoint', req.params.id);
itemmodel.findByIdAndDelete(req.params.id, function (err, docs) {
if (err) {
console.log(err);
} else {
res.status(200).json({
message: 'Item deleted'
});
}
});
});
app.get('/api/price', (req, res, next) => {
console.log('Get /api/price');
const price = pricemodel.findOne({currency: 'usd'}).then((document) => {
if (document != null) {
res.status(200).json({
message: 'price found!',
price: document
});
} else {
res.status(204).json({
message: 'no price found!',
order: null
});
}
});
});
app.get('/api/allorders', (req, res, next) => {
console.log('Get /api/allorders');
if (req.query.address.length > 0) {
const orders = ordermodel.find({address: req.query.address, closed: true}).then((documents) => {
if (documents != null) {
res.status(200).json({
message: 'orders found!',
orders: documents
});
} else {
res.status(204).json({
message: 'no orders found',
orders: null
});
}
});
}
});
app.get('/api/order', (req, res, next) => {
console.log('Get /api/order');
if (req.query.session.length > 0) {
const order = ordermodel.findOne({session: req.query.session, closed: false}).then((documents) => {
if (documents != null) {
console.log(documents);
res.status(200).json({
message: 'order found!',
order: documents
});
} else {
res.status(204).json({
message: 'no order found!',
order: null
});
}
});
} else {
res.status(204).json({
message: 'no session received',
order: null
});
}
});
app.post('/api/order', (req, res, next) => {
console.log('Post /api/order', req.body);
if(req.body.order._id == null) {
const order = new ordermodel(req.body.order);
order.save();
res.status(200).json({
message: 'Order added',
order: order
});
} else {
ordermodel.findByIdAndUpdate(req.body.order._id, {
address: req.body.order.address,
session: req.body.order.session,
price: req.body.order.price,
total: req.body.order.total,
totalZec: req.body.order.totalZec,
closed: req.body.order.closed
}, function(err, docs) {
if(err) {
console.log(err);
} else {
res.status(200).json({
message: 'Order updated'
});
}
});
}
});
app.post('/api/lineitem', (req, res, next) => {
console.log('Post /api/lineitem');
ordermodel.findByIdAndUpdate(req.body.order_id, { $push: {lines: req.body.line}}, function(err,docs) {
if (err) {
console.log(err);
} else {
res.status(200).json({
message: 'Item added to order'
});
}
});
});
app.delete('/api/order/:id', (req, res, next) => {
console.log('delete order endpoint', req.params.id);
ordermodel.findByIdAndDelete(req.params.id, function (err, docs) {
if (err) {
console.log(err);
} else {
console.log(docs);
res.status(200).json({
message: 'Order deleted'
});
}
});
});
module.exports = app;