akkoma-fe/src/modules/users.js

119 lines
3.6 KiB
JavaScript
Raw Normal View History

import backendInteractorService from '../services/backend_interactor_service/backend_interactor_service.js'
import { compact, map, each, find, merge } from 'lodash'
2017-02-13 22:22:32 +00:00
import { set } from 'vue'
2016-10-27 16:03:14 +00:00
2016-11-30 17:29:44 +00:00
// TODO: Unify with mergeOrAdd in statuses.js
export const mergeOrAdd = (arr, item) => {
2016-11-30 22:32:22 +00:00
if (!item) { return false }
2016-11-30 17:29:44 +00:00
const oldItem = find(arr, {id: item.id})
if (oldItem) {
// We already have this, so only merge the new info.
merge(oldItem, item)
return {item: oldItem, new: false}
} else {
// This is a new item, prepare it
arr.push(item)
return {item, new: true}
}
}
export const mutations = {
2017-02-13 22:22:32 +00:00
setMuted (state, { user: {id}, muted }) {
const user = find(state.users, {id})
set(user, 'muted', muted)
},
2016-11-30 17:29:44 +00:00
setCurrentUser (state, user) {
state.currentUser = user
2016-10-27 16:03:14 +00:00
},
2016-11-30 17:29:44 +00:00
beginLogin (state) {
state.loggingIn = true
},
endLogin (state) {
state.loggingIn = false
2016-10-27 16:03:14 +00:00
},
2016-11-30 17:29:44 +00:00
addNewUsers (state, users) {
each(users, (user) => mergeOrAdd(state.users, user))
},
setUserForStatus (state, status) {
status.user = find(state.users, status.user)
2016-11-30 17:29:44 +00:00
}
}
export const defaultState = {
currentUser: false,
loggingIn: false,
users: []
}
const users = {
state: defaultState,
mutations,
2016-10-27 16:03:14 +00:00
actions: {
2016-11-30 17:29:44 +00:00
addNewStatuses (store, { statuses }) {
const users = map(statuses, 'user')
const retweetedUsers = compact(map(statuses, 'retweeted_status.user'))
2016-11-30 17:29:44 +00:00
store.commit('addNewUsers', users)
store.commit('addNewUsers', retweetedUsers)
2017-02-13 23:01:50 +00:00
// Reconnect users to statuses
each(statuses, (status) => {
store.commit('setUserForStatus', status)
2017-02-13 23:01:50 +00:00
})
// Reconnect users to retweets
each(compact(map(statuses, 'retweeted_status')), (status) => {
store.commit('setUserForStatus', status)
2017-02-13 23:01:50 +00:00
})
2016-11-30 17:29:44 +00:00
},
2016-10-28 12:26:51 +00:00
loginUser (store, userCredentials) {
return new Promise((resolve, reject) => {
const commit = store.commit
commit('beginLogin')
store.rootState.api.backendInteractor.verifyCredentials(userCredentials)
.then((response) => {
if (response.ok) {
response.json()
.then((user) => {
user.credentials = userCredentials
commit('setCurrentUser', user)
commit('addNewUsers', [user])
2016-11-30 20:27:25 +00:00
// Set our new backend interactor
commit('setBackendInteractor', backendInteractorService(userCredentials))
2016-11-30 20:27:25 +00:00
// Start getting fresh tweets.
store.dispatch('startFetching', 'friends')
// Get user mutes and follower info
store.rootState.api.backendInteractor.fetchMutes().then((mutedUsers) => {
each(mutedUsers, (user) => { user.muted = true })
store.commit('addNewUsers', mutedUsers)
})
// Fetch our friends
store.rootState.api.backendInteractor.fetchFriends()
.then((friends) => commit('addNewUsers', friends))
})
} else {
// Authentication failed
commit('endLogin')
if (response.status === 401) {
reject('Wrong username or password')
} else {
reject('An error occured, please try again')
}
}
commit('endLogin')
resolve()
})
.catch((error) => {
console.log(error)
commit('endLogin')
reject('Failed to connect to server, try again')
})
})
2016-10-27 16:03:14 +00:00
}
}
}
export default users