104 lines
3.0 KiB
JavaScript
104 lines
3.0 KiB
JavaScript
import LiquidPledging from 'Embark/contracts/LiquidPledging'
|
|
import LPVault from 'Embark/contracts/LPVault'
|
|
import web3 from 'Embark/web3'
|
|
import { getLastBlockStored } from '../actions/lpEvents'
|
|
|
|
|
|
const AUTHORIZE_PAYMENT = 'AuthorizePayment'
|
|
export const GIVER_ADDED = 'GiverAdded'
|
|
export const DELEGATE_ADDED = 'DelegateAdded'
|
|
export const PROJECT_ADDED = 'ProjectAdded'
|
|
const ALL_EVENTS = 'allEvents'
|
|
const lookups = {
|
|
[GIVER_ADDED]: {
|
|
id: 'idGiver',
|
|
type: 'Funder'
|
|
},
|
|
[DELEGATE_ADDED]: {
|
|
id: 'idDelegate',
|
|
type: 'Delegate'
|
|
},
|
|
[PROJECT_ADDED]: {
|
|
id: 'idProject',
|
|
type: 'Project'
|
|
}
|
|
}
|
|
|
|
const hexToDecimal = hex => Number(parseInt(hex, 16))
|
|
const formatVaultEvent = async event => {
|
|
const { returnValues } = event
|
|
return {
|
|
...returnValues,
|
|
ref: hexToDecimal(returnValues.ref)
|
|
}
|
|
}
|
|
|
|
const getPastVaultEvents = async (event, raw = false, fromBlock = 0) => {
|
|
const events = await LPVault.getPastEvents(event, {
|
|
addr: await web3.eth.getCoinbase(),
|
|
fromBlock,
|
|
toBlock: 'latest'
|
|
})
|
|
if (raw) return events
|
|
const formattedEvents = await Promise.all(
|
|
events.map(formatVaultEvent)
|
|
)
|
|
return formattedEvents
|
|
}
|
|
|
|
const { getPledgeAdmin } = LiquidPledging.methods
|
|
export const formatFundProfileEvent = async event => {
|
|
const lookup = lookups[event.event]
|
|
const { id, returnValues: { url } } = event
|
|
const idProfile = event.returnValues[lookup.id]
|
|
const { addr, commitTime, name, canceled } = await getPledgeAdmin(idProfile).call()
|
|
return {
|
|
id,
|
|
idProfile,
|
|
url,
|
|
commitTime,
|
|
name,
|
|
addr,
|
|
canceled,
|
|
type: lookups[event.event].type
|
|
}
|
|
}
|
|
|
|
const getPastEvents = async (event, raw = false, fromBlock = 0) => {
|
|
const events = await LiquidPledging.getPastEvents(event, {
|
|
addr: await web3.eth.getCoinbase(),
|
|
fromBlock,
|
|
toBlock: 'latest'
|
|
})
|
|
if (raw) console.log({events, fromBlock})
|
|
if (raw) return events
|
|
const formattedEvents = await Promise.all(
|
|
events.map(formatFundProfileEvent)
|
|
)
|
|
return formattedEvents
|
|
}
|
|
|
|
export const lpEventsSubscription = async () => {
|
|
//todo add on event handlers
|
|
const events = await LiquidPledging.events.allEvents({
|
|
fromBlock: 0,
|
|
toBlock: 'latest'
|
|
})
|
|
return events
|
|
}
|
|
export const getFunderProfiles = async () => await getPastEvents(GIVER_ADDED)
|
|
export const getDelegateProfiles = async () => await getPastEvents(DELEGATE_ADDED)
|
|
export const getProjectProfiles = async () => await getPastEvents(PROJECT_ADDED)
|
|
export const getAllLPEvents = async fromBlock => await getPastEvents(
|
|
ALL_EVENTS,
|
|
true,
|
|
fromBlock
|
|
)
|
|
export const getAuthorizedPayments = async () => getPastVaultEvents(AUTHORIZE_PAYMENT)
|
|
export const getAllVaultEvents = async (fromBlock = 0) => getPastVaultEvents(ALL_EVENTS,true, fromBlock)
|
|
export const getProfileEvents = async () => {
|
|
const [ funderProfiles, delegateProfiles, projectProfiles]
|
|
= await Promise.all([getFunderProfiles(), getDelegateProfiles(), getProjectProfiles()])
|
|
return [ ...funderProfiles, ...delegateProfiles, ...projectProfiles]
|
|
}
|