From ed9fc00f486222ccf285de517a2a54f0836cbfdb Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Fri, 31 Aug 2018 21:16:34 -0400 Subject: [PATCH] Asking for available relayers functionality --- test-dapp/app/components/callgasrelayed.js | 35 ++---- test-dapp/app/status-gas-relayer.js | 132 +++++++++++++++++++++ 2 files changed, 145 insertions(+), 22 deletions(-) create mode 100644 test-dapp/app/status-gas-relayer.js diff --git a/test-dapp/app/components/callgasrelayed.js b/test-dapp/app/components/callgasrelayed.js index c443cce..ee246b2 100644 --- a/test-dapp/app/components/callgasrelayed.js +++ b/test-dapp/app/components/callgasrelayed.js @@ -15,6 +15,10 @@ import TextField from '@material-ui/core/TextField'; import config from '../config'; import web3 from 'Embark/web3'; import {withStyles} from '@material-ui/core/styles'; + +import StatusGasRelayer, {Contracts} from '../status-gas-relayer'; + + const styles = theme => ({ root: { width: '100%', @@ -98,7 +102,7 @@ class CallGasRelayed extends Component { } } - obtainRelayers = event => { + obtainRelayers = async event => { event.preventDefault(); const {web3, kid, skid} = this.props; @@ -110,28 +114,15 @@ class CallGasRelayed extends Component { this.props.clearMessages(); try { - const sendOptions = { - ttl: 1000, - sig: kid, - powTarget: 1, - powTime: 20, - topic: this.state.topic, - symKeyID: skid, - payload: web3.utils.toHex({ - 'contract': this.props.identityAddress, - 'address': web3.eth.defaultAccount, - 'action': 'availability', - 'gasToken': this.state.gasToken, - 'gasPrice': this.state.gasPrice - }) - }; + const s = new StatusGasRelayer.AvailableRelayers(Contracts.Identity, this.props.identityAddress, web3.eth.defaultAccount) + .setRelayersSymKeyID(skid) + .setAsymmetricKeyID(kid) + .setGas(this.state.gasToken, this.state.gasPrice); + await s.post(web3); + + console.log("Message sent"); + this.setState({submitting: false}); - web3.shh.post(sendOptions) - .then(() => { - this.setState({submitting: false}); - console.log("Message sent"); - return true; - }); } catch(error){ this.setState({messagingError: error.message, submitting: false}); } diff --git a/test-dapp/app/status-gas-relayer.js b/test-dapp/app/status-gas-relayer.js new file mode 100644 index 0000000..1225a2b --- /dev/null +++ b/test-dapp/app/status-gas-relayer.js @@ -0,0 +1,132 @@ +export const Contracts = { + 'Identity': 'IdentityGasRelay', + 'SNT': 'SNTController' +}; + +export const Functions = { + 'Identity': { + 'call': 'callGasRelayed', + 'approveAndCall': 'approveAndCallGasRelayed' + } +} + +export const Actions = { + 'Availability': 'availability', + 'Transaction': 'transaction' +} + +const relayerSymmmetricKeyID = "0xd0d905c1c62b810b787141430417caf2b3f54cffadb395b7bb39fdeb8f17266b"; + +class StatusGasRelayer { + constructor(build, web3) { + this.web3 = web3; + if (arguments.length === 2 && this.validateBuild(build)) { + Object.defineProperties(this, { + message: { + value: build._getMessage(web3), + writable: false + }, + topic: { + value: web3.utils.toHex(build.contractName).slice(0, 10), + writable: false + }, + kid: { + value: build.kid, + writable: false + }, + skid: { + value: build.skid, + writable: false + } + }); + } + } + + post = async (options) => { + options = options || {}; + + let skid = options.skid || this.skid; + if(!skid){ + skid = await this.web3.shh.addSymKey(relayerSymmmetricKeyID); + } + + let kid = options.kid || this.kid; + if(!kid){ + kid = await this.web3.shh.newKeyPair(); + } + + const sendOptions = { + ttl: options.ttl || 1000, + sig: kid, + powTarget: options.powTarget || 1, + powTime: options.powTime || 20, + topic: this.topic, + symKeyID: skid, + payload: this.web3.utils.toHex(this.message) + }; + + return await web3.shh.post(sendOptions); + } + + validateBuild = (build) => { + return (String(build.constructor) === String(StatusGasRelayer.AvailableRelayers)); + } + + static get AvailableRelayers() { + return AvailableRelayersAction; + } +} + +class Action { + setGas(token, price, limit){ + this.gasToken = token; + this.gasPrice = price; + this.gasLimit = limit; + return this; + } + + setOperation(operation){ + this.operation = operation; + return this; + } +} + +class AvailableRelayersAction extends Action { + constructor(contractName, contractAddress, accountAddress) { + super(); + this.contractName = contractName; + this.contractAddress = contractAddress; + this.accountAddress = accountAddress; + + this.operation = Actions.Availability; + + return this; + } + + setRelayersSymKeyID = (skid) => { + this.skid = skid; + return this; + } + + setAsymmetricKeyID = (kid) => { + this.kid = kid; + return this; + } + + _getMessage = (web3) => { + return { + contract: this.contractAddress, + address: this.accountAddress || web3.eth.defaultAccount, + action: Actions.Availability, + gasToken: this.gasToken, + gasPrice: this.gasPrice + }; + } + + post(web3, options) { + const s = new StatusGasRelayer(this, web3); + return s.post(options); + } +} + +export default StatusGasRelayer; \ No newline at end of file