98 lines
2.8 KiB
JavaScript
98 lines
2.8 KiB
JavaScript
const express = require('express');
|
|
const Web3 = require('web3');
|
|
const parseArgs = require('minimist');
|
|
const Account = require('./account.js');
|
|
const utils = require('./utils.js');
|
|
const fs = require('fs');
|
|
const morgan = require("morgan");
|
|
|
|
const argv = parseArgs(process.argv.slice(2), {string: ["sender", "bucket"], default: {"endpoint": "ws://127.0.0.1:8546"}});
|
|
const web3 = new Web3(argv["endpoint"]);
|
|
const account = new Account(web3);
|
|
|
|
const Bucket = utils.loadContract(web3, "Bucket");
|
|
|
|
const port = process.env.PORT || 3000;
|
|
const app = express();
|
|
app.use(morgan('combined'))
|
|
|
|
async function redeem(bucket, message, sig) {
|
|
Bucket.transactionConfirmationBlocks = 1;
|
|
Bucket.options.address = bucket;
|
|
let methodCall = Bucket.methods.redeem(message, sig);
|
|
return account.sendMethod(methodCall, Bucket.options.address);
|
|
}
|
|
|
|
function validateAddress(addr) {
|
|
return addr != null && addr.startsWith("0x") && addr.length == 42;
|
|
}
|
|
|
|
function validate32Bytes(data) {
|
|
return data != null && data.startsWith("0x") && data.length == 66;
|
|
}
|
|
|
|
function validateNumber(num) {
|
|
return !isNaN(parseInt(num));
|
|
}
|
|
|
|
async function validateBucket(bucket) {
|
|
Bucket.options.address = bucket;
|
|
const owner = await Bucket.methods.owner().call();
|
|
return account.address() === owner;
|
|
}
|
|
|
|
async function validateRequest(body) {
|
|
if (!validateAddress(body.bucket)) {
|
|
return "invalid bucket address";
|
|
} else if (!await validateBucket(body.bucket)) {
|
|
return "invalid bucket owner";
|
|
} else if (body.message === undefined) {
|
|
return "message must be specified";
|
|
} else if (!validateNumber(body.message.blockNumber)) {
|
|
return "invalid block number";
|
|
} else if (!validate32Bytes(body.message.blockHash)) {
|
|
return "invalid block hash";
|
|
} else if (!validateAddress(body.message.receiver)) {
|
|
return "invalid receiver address";
|
|
} else if (!validate32Bytes(body.message.code)) {
|
|
return "invalid code";
|
|
} else {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
async function redeemOptions(req, res) {
|
|
res.append("Access-Control-Allow-Origin", ["*"]);
|
|
res.append("Access-Control-Allow-Headers", ["*"]);
|
|
res.json({message: "ok"})
|
|
}
|
|
|
|
async function redeemRequest(req, res) {
|
|
res.append("Access-Control-Allow-Origin", ["*"]);
|
|
res.append("Access-Control-Allow-Headers", ["*"]);
|
|
|
|
let err = await validateRequest(req.body);
|
|
if (err) {
|
|
res.status(400).json({error: err});
|
|
}
|
|
|
|
try {
|
|
let receipt = await redeem(req.body.bucket, req.body.message, req.body.sig);
|
|
res.json({tx: receipt.transactionHash});
|
|
} catch(e) {
|
|
console.error(e)
|
|
res.status(500).json({error: "Couldn't send tx"});
|
|
}
|
|
}
|
|
|
|
async function run() {
|
|
await account.init(argv);
|
|
|
|
app.use(express.json());
|
|
app.post('/redeem', redeemRequest);
|
|
app.options('/redeem', redeemOptions);
|
|
app.listen(port, () => console.log(`Relayer listening at http://localhost:${port}`));
|
|
}
|
|
|
|
run();
|