pleroma-fe/src/modules/users.js

213 lines
6.8 KiB
JavaScript
Raw Normal View History

import backendInteractorService from '../services/backend_interactor_service/backend_interactor_service.js'
2017-03-08 17:04:21 +00:00
import { compact, map, each, merge } from 'lodash'
2017-02-13 22:22:32 +00:00
import { set } from 'vue'
2018-12-10 15:36:25 +00:00
import registerPushNotifications from '../services/push/push.js'
import oauthApi from '../services/new_api/oauth'
import { humanizeErrors } from './errors'
2016-10-27 16:03:14 +00:00
2016-11-30 17:29:44 +00:00
// TODO: Unify with mergeOrAdd in statuses.js
2017-03-08 16:59:12 +00:00
export const mergeOrAdd = (arr, obj, item) => {
2016-11-30 22:32:22 +00:00
if (!item) { return false }
2017-03-08 16:59:12 +00:00
const oldItem = obj[item.id]
2016-11-30 17:29:44 +00:00
if (oldItem) {
// We already have this, so only merge the new info.
merge(oldItem, item)
return { item: oldItem, new: false }
2016-11-30 17:29:44 +00:00
} else {
// This is a new item, prepare it
arr.push(item)
2017-03-08 16:59:12 +00:00
obj[item.id] = item
if (item.screen_name && !item.screen_name.includes('@')) {
obj[item.screen_name] = item
}
return { item, new: true }
2016-11-30 17:29:44 +00:00
}
}
2018-12-13 11:04:09 +00:00
const getNotificationPermission = () => {
const Notification = window.Notification
if (!Notification) return Promise.resolve(null)
if (Notification.permission === 'default') return Notification.requestPermission()
return Promise.resolve(Notification.permission)
}
2016-11-30 17:29:44 +00:00
export const mutations = {
setMuted (state, { user: { id }, muted }) {
2017-03-08 17:04:21 +00:00
const user = state.usersObject[id]
2017-02-13 22:22:32 +00:00
set(user, 'muted', muted)
},
2016-11-30 17:29:44 +00:00
setCurrentUser (state, user) {
state.lastLoginName = user.screen_name
state.currentUser = merge(state.currentUser || {}, user)
2016-10-27 16:03:14 +00:00
},
2017-07-02 10:25:34 +00:00
clearCurrentUser (state) {
state.currentUser = false
state.lastLoginName = false
2017-07-02 10:25:34 +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) {
2017-03-08 16:59:12 +00:00
each(users, (user) => mergeOrAdd(state.users, state.usersObject, user))
},
setUserForStatus (state, status) {
2017-03-08 17:04:21 +00:00
status.user = state.usersObject[status.user.id]
2018-06-18 08:36:58 +00:00
},
setColor (state, { user: { id }, highlighted }) {
2018-06-18 08:36:58 +00:00
const user = state.usersObject[id]
set(user, 'highlight', highlighted)
},
signUpPending (state) {
state.signUpPending = true
state.signUpErrors = []
},
signUpSuccess (state) {
state.signUpPending = false
},
signUpFailure (state, errors) {
state.signUpPending = false
state.signUpErrors = errors
2016-11-30 17:29:44 +00:00
}
}
export const defaultState = {
loggingIn: false,
lastLoginName: false,
2016-11-30 17:29:44 +00:00
currentUser: false,
2017-03-08 16:59:12 +00:00
users: [],
usersObject: {},
signUpPending: false,
signUpErrors: []
2016-11-30 17:29:44 +00:00
}
const users = {
state: defaultState,
mutations,
2016-10-27 16:03:14 +00:00
actions: {
fetchUser (store, id) {
store.rootState.api.backendInteractor.fetchUser({ id })
.then((user) => store.commit('addNewUsers', [user]))
},
2018-12-10 15:36:25 +00:00
registerPushNotifications (store) {
const token = store.state.currentUser.credentials
const vapidPublicKey = store.rootState.instance.vapidPublicKey
const isEnabled = store.rootState.config.webPushNotifications
registerPushNotifications(isEnabled, vapidPublicKey, token)
},
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
},
async signUp (store, userInfo) {
store.commit('signUpPending')
let rootState = store.rootState
let response = await rootState.api.backendInteractor.register(userInfo)
if (response.ok) {
const data = {
oauth: rootState.oauth,
instance: rootState.instance.server
}
let app = await oauthApi.getOrCreateApp(data)
let result = await oauthApi.getTokenWithCredentials({
app,
instance: data.instance,
username: userInfo.username,
password: userInfo.password
})
store.commit('signUpSuccess')
store.commit('setToken', result.access_token)
store.dispatch('loginUser', result.access_token)
} else {
let data = await response.json()
let errors = humanizeErrors(JSON.parse(data.error))
store.commit('signUpFailure', errors)
throw Error(errors)
}
},
2017-07-02 10:25:34 +00:00
logout (store) {
store.commit('clearCurrentUser')
2018-10-26 13:16:23 +00:00
store.commit('setToken', false)
2017-07-02 10:25:34 +00:00
store.dispatch('stopFetching', 'friends')
store.commit('setBackendInteractor', backendInteractorService())
},
2018-10-26 13:16:23 +00:00
loginUser (store, accessToken) {
return new Promise((resolve, reject) => {
const commit = store.commit
commit('beginLogin')
2018-10-26 13:16:23 +00:00
store.rootState.api.backendInteractor.verifyCredentials(accessToken)
.then((response) => {
if (response.ok) {
response.json()
.then((user) => {
2018-10-26 13:16:23 +00:00
// user.credentials = userCredentials
user.credentials = accessToken
commit('setCurrentUser', user)
commit('addNewUsers', [user])
2016-11-30 20:27:25 +00:00
2018-12-13 11:04:09 +00:00
getNotificationPermission()
.then(permission => commit('setNotificationPermission', permission))
// Set our new backend interactor
2018-10-26 13:16:23 +00:00
commit('setBackendInteractor', backendInteractorService(accessToken))
2016-11-30 20:27:25 +00:00
2017-12-04 18:08:33 +00:00
if (user.token) {
2017-12-05 10:47:10 +00:00
store.dispatch('initializeSocket', user.token)
2017-12-04 18:08:33 +00:00
}
// Start getting fresh tweets.
store.dispatch('startFetching', 'friends')
// Start getting our own posts, only really needed for mitigating broken favorites
store.dispatch('startFetching', ['own', user.id])
// 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({ id: user.id })
.then((friends) => commit('addNewUsers', friends))
})
} else {
// Authentication failed
commit('endLogin')
if (response.status === 401) {
reject('Wrong username or password')
} else {
2017-03-08 18:31:39 +00:00
reject('An error occurred, 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