liquid-funding/app/actions/lpEvents.js

import { Q } from '@nozbe/watermelondb'
import database from '../db'

const lpCollection = database.collections.get('lp_events')
export const addEvent = async data => {
  await database.action(async () => {
    const res = await lpCollection.create(lpEvent => {
      const { event, address, id, blockNumber } = data
      lpEvent.eventId = id
      lpEvent.address = address
      lpEvent.event = event
      lpEvent.blockNumber = blockNumber
    })
    return res
  })
}

export const batchAddEvents = async events => {
  const batch = events.map(e => {
    return lpCollection.prepareCreate(lpEvent => {
      const { event, address, id, blockNumber } = e
      lpEvent.eventId = id
      lpEvent.address = address
      lpEvent.event = event
      lpEvent.blockNumber = blockNumber
    })
  })
  console.log({batch})
  return await database.action(async () => await database.batch(...batch))
}


export const getLpEventById = async id => {
  const event = await lpCollection.query(
    Q.where('event_id', id)
  ).fetch()
  return event
}

export const getLastBlockStored = async () => {
  const col = await lpCollection.query().fetch()
  const sorted = col.sort(
    (a,b) => b.blockNumber - a.blockNumber
  )
  return sorted[0].blockNumber
}