zgo/backend/app.js

const express = require('express');
const bodyparser = require('body-parser');
const app = express();
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 mongoose = require('mongoose');
const stdrpc = require('stdrpc');
const CoinGecko = require('coingecko-api');
//const RequestIP = require('@supercharge/request-ip');

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;
}

var blockInterval = setInterval( function() {
	console.log('Node periodic Zcash scan');
	//usermodel.find({}, function (err, docs) {
		//if (err) {
			//console.log(err);
		//} else {
			//console.log(session, blocktime);
			//console.log(docs);
		//}
	//});
	rpc.z_listreceivedbyaddress(fullnode.addr, 10).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;
					//console.log('  ', session, blocktime);
					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);
							var user = new usermodel({
								address: address,
								session: session,
								blocktime: blocktime
							});
							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);
					});
				}
			}
		}, function (err) {
			if (err) {
				console.log(err);
			}
			console.log('Txs synced');
		});

	});
}, 90000);

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");
	//req.ip = RequestIP.getClientIp(req);
	next();
});



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/getuser', (req, res, next) => {
	console.log('Get: /api/getuser/', req.query.session);
	var today = new Date().getTime() / 1000;
	var expiration = today - (7*24*3600);
	usermodel.find({'session': req.query.session, 'blocktime': { $gt: expiration }}).
		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/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/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;