113 lines
3.9 KiB
JavaScript
113 lines
3.9 KiB
JavaScript
const { map, scan, last, distinctUntilChanged } = require('rxjs/operators');
|
|
const Web3 = require('web3');
|
|
|
|
let web3 = new Web3("ws://localhost:8545");
|
|
|
|
let myscan = scan((acc, curr) => {
|
|
acc.push(curr);
|
|
return acc;
|
|
}, [])
|
|
|
|
let mymap = map(arr => arr.reduce((acc, current) => acc + current, 0) / arr.length)
|
|
|
|
async function deployContract() {
|
|
let accounts = await web3.eth.getAccounts();
|
|
|
|
// pragma solidity >=0.4.22 <0.6.0;
|
|
// contract Escrow {
|
|
// event Created(uint indexed escrowId, address buyer, address seller);
|
|
// function createEscrow(uint escrowId, address buyer, address seller) external {
|
|
// emit Created(escrowId, buyer, seller);
|
|
// }
|
|
// }
|
|
|
|
let abi = [
|
|
{
|
|
"constant": false,
|
|
"inputs": [
|
|
{
|
|
"name": "escrowId",
|
|
"type": "uint256"
|
|
},
|
|
{
|
|
"name": "buyer",
|
|
"type": "address"
|
|
},
|
|
{
|
|
"name": "seller",
|
|
"type": "address"
|
|
}
|
|
],
|
|
"name": "createEscrow",
|
|
"outputs": [],
|
|
"payable": false,
|
|
"stateMutability": "nonpayable",
|
|
"type": "function"
|
|
},
|
|
{
|
|
"anonymous": false,
|
|
"inputs": [
|
|
{
|
|
"indexed": true,
|
|
"name": "escrowId",
|
|
"type": "uint256"
|
|
},
|
|
{
|
|
"indexed": false,
|
|
"name": "buyer",
|
|
"type": "address"
|
|
},
|
|
{
|
|
"indexed": false,
|
|
"name": "seller",
|
|
"type": "address"
|
|
}
|
|
],
|
|
"name": "Created",
|
|
"type": "event"
|
|
}
|
|
]
|
|
|
|
var contract = new web3.eth.Contract(abi)
|
|
let instance = await contract.deploy({
|
|
data: '0x608060405234801561001057600080fd5b50610184806100206000396000f3fe60806040526004361061003b576000357c01000000000000000000000000000000000000000000000000000000009004806378015cf414610040575b600080fd5b34801561004c57600080fd5b506100b96004803603606081101561006357600080fd5b8101908080359060200190929190803573ffffffffffffffffffffffffffffffffffffffff169060200190929190803573ffffffffffffffffffffffffffffffffffffffff1690602001909291905050506100bb565b005b827fcbd6f84bfed2ee8cc01ea152b5d9f7126a72c410dbc5ab04c486a5800627b1908383604051808373ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff1681526020018273ffffffffffffffffffffffffffffffffffffffff1673ffffffffffffffffffffffffffffffffffffffff1681526020019250505060405180910390a250505056fea165627a7a72305820cc868ec126578f5508ee248fb823cd9f1ac6deb0562091cdf31843840b2a56410029',
|
|
arguments: []
|
|
}).send({
|
|
from: accounts[0],
|
|
gas: '4700000'
|
|
})
|
|
return instance
|
|
}
|
|
|
|
async function run() {
|
|
let accounts = await web3.eth.getAccounts();
|
|
var EscrowContract = await deployContract()
|
|
console.dir(EscrowContract)
|
|
|
|
await EscrowContract.methods.createEscrow(1, accounts[0], accounts[1]).send({from: accounts[0]})
|
|
await EscrowContract.methods.createEscrow(1, accounts[1], accounts[2]).send({from: accounts[0]})
|
|
await EscrowContract.methods.createEscrow(1, accounts[1], accounts[0]).send({from: accounts[0]})
|
|
await EscrowContract.methods.createEscrow(1, accounts[0], accounts[2]).send({from: accounts[0]})
|
|
|
|
// EscrowContract.events.getPastEvents('Rating', {fromBlock: 1})
|
|
EscrowContract.events.Created({fromBlock: 1}, (err, event) => {
|
|
// console.dir("new event")
|
|
// console.dir(event)
|
|
})
|
|
|
|
const EventSyncer = require('../src/eventSyncer.js')
|
|
const eventSyncer = new EventSyncer(web3.currentProvider);
|
|
|
|
await eventSyncer.init()
|
|
console.dir("getting escrows created by " + accounts[0])
|
|
|
|
// eventSyncer.trackEvent(EscrowContract, 'Created', ((x) => true)).pipe().subscribe((v) => {
|
|
eventSyncer.trackEvent(EscrowContract, 'Created', { filter: { buyer: accounts[0] }, fromBlock: 1 }).pipe().subscribe((v) => {
|
|
// eventSyncer.trackEvent(EscrowContract, 'Rating', ((x) => true)).pipe(map(x => x.rating)).subscribe((v) => {
|
|
console.dir("value is ")
|
|
console.dir(v)
|
|
});
|
|
|
|
}
|
|
|
|
run() |