540 lines
14 KiB
JavaScript
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;
|