liquid-funding/app/actions/pledges.js

import web3 from 'Embark/web3'
import { Q } from '@nozbe/watermelondb'
import database from '../db'
import { getPledges, getAllPledges } from '../utils/pledges'
import { getProfilesById } from './profiles'

const createPledge = (pledge, data, profiles) => {
  const { id, owner, amount, blockNumber, token, commitTime, nDelegates, pledgeState, intendedProject } = data
  const profile = profiles.find(p => p.idProfile == owner)
  pledge.pledgeId = Number(id)
  pledge.owner = Number(owner)
  pledge.amount = amount
  pledge.token = token
  pledge.commitTime = Number(commitTime)
  pledge.nDelegates = Number(nDelegates)
  pledge.pledgeState = pledgeState
  pledge.intendedProject = Number(intendedProject)
  pledge.blockNumber = Number(blockNumber)
  pledge.profile.set(profile)
}

const pledgesCollection = database.collections.get('pledges')
export const addPledge = async data => {
  return await database.action(async () => {
    const res = await pledgesCollection.create(pledge => createPledge(pledge, data))
    return res
  })
}

export const batchAddPledges = async (pledges, profiles = []) => {
  const batch = pledges.map(data => {
    return pledgesCollection.prepareCreate(pledge => createPledge(pledge, data, profiles))
  })
  console.log({batch})
  return await database.action(async () => await database.batch(...batch))
}

const getLastPledge = pledges => {
  const pledgeId = pledges.length
        ? pledges.sort((a,b) => b.pledgeId - a.pledgeId)[0].pledgeId
        : 0
  return pledgeId
}
export const getAndAddPledges = async () => {
  const pledges = await getLocalPledges()
  const pledgeId = getLastPledge(pledges)
  const newPledges = await getAllPledges(pledgeId + 1)
  const pledgeIds = newPledges.map(p => p.owner)
  const profiles = await getProfilesById(pledgeIds)
  batchAddPledges(newPledges, profiles)
}

export const updateStalePledges = async () => {
  //TODO optimize fetch based only on events
  const stalePledges = await getStalePledges()
  const updatedPledges = await getPledges(stalePledges)
  const batch = stalePledges.map(p => {
    const updated = updatedPledges[p.pledgeId]
    return p.prepareUpdate(p => {
      const { amount, nDelegates, pledgeState, blockNumber } = updated
      p.amount = amount
      p.nDelegates = Number(nDelegates)
      p.pledgeState = pledgeState
      p.blockNumber = blockNumber
    })
  })
  database.action(() => database.batch(...batch))
  console.log('updated batch completed')
}

export const getLocalPledges = async () => {
  const events = await pledgesCollection.query().fetch()
  return events
}

export const getStalePledges = async () => {
  const blockNumber = await web3.eth.getBlockNumber()
  const pledges = await pledgesCollection.query(
    Q.where('block_number', Q.lt(blockNumber))
  ).fetch()
  return pledges
}

export const getPledgeById = async id => {
  const event = await pledgesCollection.query(
    Q.where('id_profile', id)
  ).fetch()
  return event
}