pleroma-fe/src/modules/statuses.js

import { reduce, map, slice, last, intersectionBy, sortBy, unionBy, toInteger, groupBy, differenceBy, each, find, flatten, maxBy, merge } from 'lodash'
import moment from 'moment'
import apiService from '../services/api/api.service.js'
// import parse from '../services/status_parser/status_parser.js'

export const defaultState = {
  allStatuses: [],
  maxId: 0,
  timelines: {
    public: {
      statuses: [],
      faves: [],
      visibleStatuses: [],
      newStatusCount: 0,
      maxId: 0,
      minVisibleId: 0,
      loading: false
    },
    publicAndExternal: {
      statuses: [],
      faves: [],
      visibleStatuses: [],
      newStatusCount: 0,
      maxId: 0,
      minVisibleId: 0,
      loading: false
    },
    friends: {
      statuses: [],
      faves: [],
      visibleStatuses: [],
      newStatusCount: 0,
      maxId: 0,
      minVisibleId: 0,
      loading: false
    }
  }
}

const statusType = (status) => {
  return !status.is_post_verb && status.uri.match(/fave/) ? 'fave' : 'status'
}

export const prepareStatus = (status) => {
  // Parse nsfw tags
  if (status.nsfw === undefined) {
    const nsfwRegex = /#nsfw/i
    status.nsfw = !!status.text.match(nsfwRegex)
  }

  // Set created_at_parsed to initial value
  status.created_at_parsed = status.created_at

  return status
}

// Merges old and new status collections.
const mergeStatuses = (oldStatuses, newStatuses) => {
  each(newStatuses, (status) => {
    let oldStatus = find(oldStatuses, { id: status.id })
    if (oldStatus) {
      merge(oldStatus, status)
    } else {
      oldStatuses.push(status)
    }
  })
  return oldStatuses
}

const addStatusesToTimeline = (addedStatuses, showImmediately, { statuses, visibleStatuses, newStatusCount, faves, loading, maxId }) => {
  const statusesAndFaves = groupBy(addedStatuses, statusType)
  const addedFaves = statusesAndFaves['fave'] || []
  const unseenFaves = differenceBy(addedFaves, faves, 'id')

  // Update fave count
  each(unseenFaves, ({in_reply_to_status_id}) => {
    const status = find(statuses, { id: toInteger(in_reply_to_status_id) })
    if (status) {
      status.fave_num += 1
    }
  })

  addedStatuses = statusesAndFaves['status'] || []

  // Add some html and nsfw to the statuses.
  addedStatuses = map(addedStatuses, (status) => {
    const statusoid = status.retweeted_status || status

    prepareStatus(statusoid)

    return status
  })

  const newStatuses = sortBy(
    unionBy(addedStatuses, statuses, 'id'),
    ({id}) => -id
  )

  let newNewStatusCount = newStatusCount + (newStatuses.length - statuses.length)

  let newVisibleStatuses = visibleStatuses

  if (showImmediately) {
    newVisibleStatuses = unionBy(addedStatuses, newVisibleStatuses, 'id')
    newVisibleStatuses = sortBy(newVisibleStatuses, ({id}) => -id)
    newNewStatusCount = newStatusCount
  };

  newVisibleStatuses = intersectionBy(newStatuses, newVisibleStatuses, 'id')

  return {
    statuses: newStatuses,
    visibleStatuses: newVisibleStatuses,
    newStatusCount: newNewStatusCount,
    minVisibleId: (last(newVisibleStatuses) || { id: undefined }).id,
    faves: unionBy(faves, addedFaves, 'id'),
    maxId,
    loading
  }
}

const updateTimestampsInStatuses = (statuses) => {
  return map(statuses, (statusoid) => {
    const status = statusoid.retweeted_status || statusoid

    // Parse date
    status.created_at_parsed = moment(status.created_at).fromNow()
    return status
  })
}

// const groupStatusesByType = (statuses) => {
//   return groupBy(statuses, (status) => {
//     if (status.is_post_verb) {
//       return 'status'
//     }

//     if (status.retweeted_status) {
//       return 'retweet'
//     }

//     if (typeof status.uri === 'string' && status.uri.match(/fave/)) {
//       return 'favorite'
//     }

//     return 'unknown'
//   })
// }

export const findMaxId = (...args) => {
  return (maxBy(flatten(args), 'id') || {}).id
}

export const mutations = {
  addNewStatuses (state, { statuses, showImmediately = false, timeline }) {

    // Merge in the new status into the old ones.
    mergeStatuses(state.allStatuses, statuses)

    // Get relevant timeline
    const timelineObject = state.timelines[timeline]

    // Set new maxId
    const maxId = findMaxId(statuses, timelineObject.statuses)
    timelineObject.maxId = maxId

    // Split statuses by type
    // const statusesByType = groupStatusesByType(statuses)

    state.timelines[timeline] = addStatusesToTimeline(statuses, showImmediately, state.timelines[timeline])

    // Set up retweets with most current status
    const getRetweets = (result, status) => {
      if (status.retweeted_status) {
        result.push(status.retweeted_status)
      }
      return result
    }

    const retweets = reduce(statuses, getRetweets, [])

    // state.allStatuses = unionBy(retweets, state.allStatuses, 'id')

    mergeStatuses(state.allStatuses, retweets)

    each(state.allStatuses, (status) => {
      if (status.retweeted_status) {
        const retweetedStatus = find(state.allStatuses, { id: status.retweeted_status.id })
        status.retweeted_status = retweetedStatus
      }
    })
  },
  showNewStatuses (state, { timeline }) {
    const oldTimeline = (state.timelines[timeline])

    oldTimeline.newStatusCount = 0
    oldTimeline.visibleStatuses = slice(oldTimeline.statuses, 0, 50)
  },
  updateTimestamps (state) {
    updateTimestampsInStatuses(state.allStatuses)
  },
  setFavorited (state, { status, value }) {
    const newStatus = find(state.allStatuses, status)
    newStatus.favorited = value
  },
  setRetweeted (state, { status, value }) {
    const newStatus = find(state.allStatuses, status)
    newStatus.repeated = value
  },
  setLoading (state, { timeline, value }) {
    state.timelines[timeline].loading = value
  },
  setNsfw (state, { id, nsfw }) {
    const newStatus = find(state.allStatuses, { id })
    newStatus.nsfw = nsfw
  }
}

const statuses = {
  state: defaultState,
  actions: {
    favorite ({ rootState, commit }, status) {
      // Optimistic favoriting...
      commit('setFavorited', { status, value: true })
      apiService.favorite({ id: status.id, credentials: rootState.users.currentUser.credentials })
    },
    unfavorite ({ rootState, commit }, status) {
      // Optimistic favoriting...
      commit('setFavorited', { status, value: false })
      apiService.unfavorite({ id: status.id, credentials: rootState.users.currentUser.credentials })
    },
    retweet ({ rootState, commit }, status) {
      // Optimistic retweeting...
      commit('setRetweeted', { status, value: true })
      apiService.retweet({ id: status.id, credentials: rootState.users.currentUser.credentials })
    }
  },
  mutations
}

export default statuses