semaphore/routes/_actions/timeline.js

import { store } from '../_store/store'
import { database } from '../_utils/database/database'
import { getTimeline } from '../_utils/mastodon/timelines'
import { toast } from '../_utils/toast'
import { mark, stop } from '../_utils/marks'
import { mergeArrays } from '../_utils/arrays'

const FETCH_LIMIT = 20

async function fetchTimelineItems(instanceName, accessToken, timelineName, lastTimelineItemId, online) {
  mark('fetchTimelineItems')
  let items
  if (!online) {
    items = await database.getTimeline(instanceName, timelineName, lastTimelineItemId, FETCH_LIMIT)
  } else {
    try {
      items = await getTimeline(instanceName, accessToken, timelineName, lastTimelineItemId, FETCH_LIMIT)
      /* no await */ database.insertTimelineItems(instanceName, timelineName, items)
    } catch (e) {
      console.error(e)
      toast.say('Internet request failed. Showing offline content.')
      items = await database.getTimeline(instanceName, timelineName, lastTimelineItemId, FETCH_LIMIT)
    }
  }
  stop('fetchTimelineItems')
  return items
}

async function addTimelineItems(instanceName, timelineName, newItems) {
  console.log('addTimelineItems, length:', newItems.length)
  mark('addTimelineItems')
  let newIds = newItems.map(item => item.id)
  let oldIds = store.getForTimeline(instanceName, timelineName, 'timelineItemIds') || []
  let merged = mergeArrays(oldIds, newIds)
  store.setForTimeline(instanceName, timelineName, { timelineItemIds: merged })
  stop('addTimelineItems')
}

async function fetchTimelineItemsAndPossiblyFallBack() {
  mark('fetchTimelineItemsAndPossiblyFallBack')
  let timelineName = store.get('currentTimeline')
  let instanceName = store.get('currentInstance')
  let accessToken = store.get('accessToken')
  let lastTimelineItemId = store.get('lastTimelineItemId')
  let online = store.get('online')

  let newItems = await fetchTimelineItems(instanceName, accessToken, timelineName, lastTimelineItemId, online)
  addTimelineItems(instanceName, timelineName, newItems)
  stop('fetchTimelineItemsAndPossiblyFallBack')
}

export function initializeTimeline() {
  mark('initializeTimeline')
  let instanceName = store.get('currentInstance')
  let timeline = store.get('currentTimeline')
  requestAnimationFrame(() => {
    requestAnimationFrame(() => {
      store.setForTimeline(instanceName, timeline, {initialized: true})
    })
  })
  stop('initializeTimeline')
}

export async function setupTimeline() {
  mark('setupTimeline')
  let timelineName = store.get('currentTimeline')
  let instanceName = store.get('currentInstance')
  let accessToken = store.get('accessToken')
  if (!store.get('timelineItemIds').length) {
    await fetchTimelineItemsAndPossiblyFallBack()
  }
  stop('setupTimeline')
}

export async function fetchTimelineItemsOnScrollToBottom() {
  let timelineName = store.get('currentTimeline')
  let instanceName = store.get('currentInstance')
  store.setForTimeline(instanceName, timelineName, { runningUpdate: true })
  await fetchTimelineItemsAndPossiblyFallBack()
  store.setForTimeline(instanceName, timelineName, { runningUpdate: false })
}