pleroma-fe/src/modules/statuses.js

208 lines
5.9 KiB
JavaScript
Raw Normal View History

2016-11-13 21:09:27 +00:00
import { reduce, map, slice, last, intersectionBy, sortBy, unionBy, toInteger, groupBy, differenceBy, each, find, flatten, maxBy } from 'lodash'
2016-10-28 13:59:49 +00:00
import moment from 'moment'
2016-10-30 15:12:35 +00:00
import apiService from '../services/api/api.service.js'
import parse from '../services/status_parser/status_parser.js'
2016-10-26 17:03:55 +00:00
export const defaultState = {
2016-10-26 17:03:55 +00:00
allStatuses: [],
maxId: 0,
timelines: {
public: {
statuses: [],
faves: [],
visibleStatuses: [],
newStatusCount: 0,
maxId: 0,
2016-11-06 16:44:05 +00:00
minVisibleId: 0,
loading: false
2016-10-26 17:03:55 +00:00
},
publicAndExternal: {
statuses: [],
faves: [],
visibleStatuses: [],
newStatusCount: 0,
maxId: 0,
2016-11-06 16:44:05 +00:00
minVisibleId: 0,
loading: false
2016-10-26 17:03:55 +00:00
},
friends: {
statuses: [],
faves: [],
visibleStatuses: [],
newStatusCount: 0,
maxId: 0,
2016-11-06 16:44:05 +00:00
minVisibleId: 0,
loading: false
2016-10-26 17:03:55 +00:00
}
}
}
const statusType = (status) => {
return !status.is_post_verb && status.uri.match(/fave/) ? 'fave' : 'status'
}
2016-11-13 21:09:27 +00:00
const addStatusesToTimeline = (addedStatuses, showImmediately, { statuses, visibleStatuses, newStatusCount, faves, loading, maxId }) => {
2016-10-26 17:03:55 +00:00
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'] || []
2016-10-28 23:38:41 +00:00
// Add some html and nsfw to the statuses.
addedStatuses = map(addedStatuses, (status) => {
2016-10-26 17:03:55 +00:00
const statusoid = status.retweeted_status || status
2016-10-31 09:20:02 +00:00
statusoid.created_at_parsed = statusoid.created_at
statusoid.statusnet_html = parse(statusoid.statusnet_html)
2016-10-28 23:38:41 +00:00
if (statusoid.nsfw === undefined) {
const nsfwRegex = /#nsfw/i
statusoid.nsfw = statusoid.text.match(nsfwRegex)
}
return status
2016-10-26 17:03:55 +00:00
})
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,
2016-10-27 16:03:14 +00:00
minVisibleId: (last(newVisibleStatuses) || { id: undefined }).id,
2016-11-06 16:44:05 +00:00
faves: unionBy(faves, addedFaves, 'id'),
2016-11-13 21:09:27 +00:00
maxId,
2016-11-06 16:44:05 +00:00
loading
2016-10-26 17:03:55 +00:00
}
}
2016-10-28 13:59:49 +00:00
const updateTimestampsInStatuses = (statuses) => {
2016-10-28 23:38:41 +00:00
return map(statuses, (statusoid) => {
const status = statusoid.retweeted_status || statusoid
2016-10-28 13:59:49 +00:00
// Parse date
status.created_at_parsed = moment(status.created_at).fromNow()
return status
})
}
2016-11-13 21:09:27 +00:00
export const findMaxId = (...args) => {
return (maxBy(flatten(args), 'id') || {}).id
}
2016-11-13 21:40:33 +00:00
export const prepareStatus = (status) => {
2016-11-13 21:54:49 +00:00
// Parse nsfw tags
2016-11-13 21:40:33 +00:00
if (status.nsfw === undefined) {
const nsfwRegex = /#nsfw/i
status.nsfw = !!status.text.match(nsfwRegex)
}
2016-11-13 21:54:49 +00:00
// Set created_at_parsed to initial value
status.created_at_parsed = status.created_at
2016-11-13 21:40:33 +00:00
return status
}
export const mutations = {
addNewStatuses (state, { statuses, showImmediately = false, timeline }) {
2016-11-13 21:09:27 +00:00
const timelineObject = state.timelines[timeline]
// Set new maxId
const maxId = findMaxId(statuses, timelineObject.statuses)
timelineObject.maxId = maxId
state.timelines[timeline] = addStatusesToTimeline(statuses, showImmediately, state.timelines[timeline])
state.allStatuses = unionBy(state.timelines[timeline].statuses, state.allStatuses, 'id')
// 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')
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
},
2016-11-13 16:09:16 +00:00
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 }) {
2016-11-07 17:47:38 +00:00
const newStatus = find(state.allStatuses, { id })
newStatus.nsfw = nsfw
}
}
2016-10-26 17:03:55 +00:00
const statuses = {
state: defaultState,
2016-10-30 15:12:35 +00:00
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 })
2016-11-13 16:09:16 +00:00
},
retweet ({ rootState, commit }, status) {
// Optimistic retweeting...
commit('setRetweeted', { status, value: true })
apiService.retweet({ id: status.id, credentials: rootState.users.currentUser.credentials })
2016-10-30 15:12:35 +00:00
}
},
mutations
2016-10-26 17:03:55 +00:00
}
export default statuses