forked from cybrespace/pinafore
79 lines
2.3 KiB
JavaScript
79 lines
2.3 KiB
JavaScript
import { getAccount } from '../_api/user'
|
|
import { getRelationship } from '../_api/relationships'
|
|
import {
|
|
getAccount as getAccountFromDatabase,
|
|
setAccount as setAccountInDatabase} from '../_database/accounts'
|
|
import {
|
|
getRelationship as getRelationshipFromDatabase,
|
|
setRelationship as setRelationshipInDatabase
|
|
} from '../_database/relationships'
|
|
import { store } from '../_store/store'
|
|
|
|
async function _updateAccount (accountId, instanceName, accessToken) {
|
|
let localPromise = getAccountFromDatabase(instanceName, accountId)
|
|
let remotePromise = getAccount(instanceName, accessToken, accountId).then(account => {
|
|
/* no await */ setAccountInDatabase(instanceName, account)
|
|
return account
|
|
})
|
|
|
|
try {
|
|
store.set({currentAccountProfile: (await localPromise)})
|
|
} catch (e) {
|
|
console.error(e)
|
|
}
|
|
try {
|
|
store.set({currentAccountProfile: (await remotePromise)})
|
|
} catch (e) {
|
|
console.error(e)
|
|
}
|
|
}
|
|
|
|
async function _updateRelationship (accountId, instanceName, accessToken) {
|
|
let localPromise = getRelationshipFromDatabase(instanceName, accountId)
|
|
let remotePromise = getRelationship(instanceName, accessToken, accountId).then(relationship => {
|
|
/* no await */ setRelationshipInDatabase(instanceName, relationship)
|
|
return relationship
|
|
})
|
|
try {
|
|
store.set({currentAccountRelationship: (await localPromise)})
|
|
} catch (e) {
|
|
console.error(e)
|
|
}
|
|
try {
|
|
store.set({currentAccountRelationship: (await remotePromise)})
|
|
} catch (e) {
|
|
console.error(e)
|
|
}
|
|
}
|
|
|
|
export async function updateLocalRelationship (instanceName, accountId, relationship) {
|
|
await setRelationshipInDatabase(instanceName, relationship)
|
|
try {
|
|
store.set({currentAccountRelationship: relationship})
|
|
} catch (e) {
|
|
console.error(e)
|
|
}
|
|
}
|
|
|
|
export async function clearProfileAndRelationship () {
|
|
store.set({
|
|
currentAccountProfile: null,
|
|
currentAccountRelationship: null
|
|
})
|
|
}
|
|
|
|
export async function updateProfileAndRelationship (accountId) {
|
|
let { currentInstance, accessToken } = store.get()
|
|
|
|
await Promise.all([
|
|
_updateAccount(accountId, currentInstance, accessToken),
|
|
_updateRelationship(accountId, currentInstance, accessToken)
|
|
])
|
|
}
|
|
|
|
export async function updateRelationship (accountId) {
|
|
let { currentInstance, accessToken } = store.get()
|
|
|
|
await _updateRelationship(accountId, currentInstance, accessToken)
|
|
}
|