} from '../../typings/models'
import * as Bluebird from 'bluebird'
import { Op, Transaction, literal } from 'sequelize'
+import { ModelCache } from '@server/models/model-cache'
enum ScopeNames {
FULL = 'FULL'
})
VideoChannel: VideoChannelModel
- private static localNameCache: { [ id: string ]: any } = {}
- private static localUrlCache: { [ id: string ]: any } = {}
-
static load (id: number): Bluebird<MActor> {
return ActorModel.unscoped().findByPk(id)
}
}
static loadLocalByName (preferredUsername: string, transaction?: Transaction): Bluebird<MActorFull> {
- // The server actor never change, so we can easily cache it
- if (preferredUsername === SERVER_ACTOR_NAME && ActorModel.localNameCache[preferredUsername]) {
- return Bluebird.resolve(ActorModel.localNameCache[preferredUsername])
- }
+ const fun = () => {
+ const query = {
+ where: {
+ preferredUsername,
+ serverId: null
+ },
+ transaction
+ }
- const query = {
- where: {
- preferredUsername,
- serverId: null
- },
- transaction
+ return ActorModel.scope(ScopeNames.FULL)
+ .findOne(query)
}
- return ActorModel.scope(ScopeNames.FULL)
- .findOne(query)
- .then(actor => {
- if (preferredUsername === SERVER_ACTOR_NAME) {
- ActorModel.localNameCache[preferredUsername] = actor
- }
-
- return actor
- })
+ return ModelCache.Instance.doCache({
+ cacheType: 'local-actor-name',
+ key: preferredUsername,
+ // The server actor never change, so we can easily cache it
+ whitelist: () => preferredUsername === SERVER_ACTOR_NAME,
+ fun
+ })
}
static loadLocalUrlByName (preferredUsername: string, transaction?: Transaction): Bluebird<MActorUrl> {
- // The server actor never change, so we can easily cache it
- if (preferredUsername === SERVER_ACTOR_NAME && ActorModel.localUrlCache[preferredUsername]) {
- return Bluebird.resolve(ActorModel.localUrlCache[preferredUsername])
- }
+ const fun = () => {
+ const query = {
+ attributes: [ 'url' ],
+ where: {
+ preferredUsername,
+ serverId: null
+ },
+ transaction
+ }
- const query = {
- attributes: [ 'url' ],
- where: {
- preferredUsername,
- serverId: null
- },
- transaction
+ return ActorModel.unscoped()
+ .findOne(query)
}
- return ActorModel.unscoped()
- .findOne(query)
- .then(actor => {
- if (preferredUsername === SERVER_ACTOR_NAME) {
- ActorModel.localUrlCache[preferredUsername] = actor
- }
-
- return actor
- })
+ return ModelCache.Instance.doCache({
+ cacheType: 'local-actor-name',
+ key: preferredUsername,
+ // The server actor never change, so we can easily cache it
+ whitelist: () => preferredUsername === SERVER_ACTOR_NAME,
+ fun
+ })
}
static loadByNameAndHost (preferredUsername: string, host: string): Bluebird<MActorFull> {
}, { where, transaction })
}
+ static loadAccountActorByVideoId (videoId: number): Bluebird<MActor> {
+ const query = {
+ include: [
+ {
+ attributes: [ 'id' ],
+ model: AccountModel.unscoped(),
+ required: true,
+ include: [
+ {
+ attributes: [ 'id', 'accountId' ],
+ model: VideoChannelModel.unscoped(),
+ required: true,
+ include: [
+ {
+ attributes: [ 'id', 'channelId' ],
+ model: VideoModel.unscoped(),
+ where: {
+ id: videoId
+ }
+ }
+ ]
+ }
+ ]
+ }
+ ]
+ }
+
+ return ActorModel.unscoped().findOne(query)
+ }
+
getSharedInbox (this: MActorWithInboxes) {
return this.sharedInboxUrl || this.inboxUrl
}