102 lines
3.6 KiB
TypeScript
102 lines
3.6 KiB
TypeScript
import { remove } from 'fs-extra'
|
|
import { join } from 'path'
|
|
import { Transaction } from 'sequelize/types'
|
|
import { ActorModel } from '@server/models/actor/actor'
|
|
import { getLowercaseExtension } from '@shared/core-utils'
|
|
import { buildUUID } from '@shared/extra-utils'
|
|
import { ActivityPubActorType, ActorImageType } from '@shared/models'
|
|
import { retryTransactionWrapper } from '../helpers/database-utils'
|
|
import { CONFIG } from '../initializers/config'
|
|
import { ACTOR_IMAGES_SIZE, WEBSERVER } from '../initializers/constants'
|
|
import { sequelizeTypescript } from '../initializers/database'
|
|
import { MAccountDefault, MActor, MChannelDefault } from '../types/models'
|
|
import { deleteActorImages, updateActorImages } from './activitypub/actors'
|
|
import { sendUpdateActor } from './activitypub/send'
|
|
import { processImageFromWorker } from './worker/parent-process'
|
|
|
|
export function buildActorInstance (type: ActivityPubActorType, url: string, preferredUsername: string) {
|
|
return new ActorModel({
|
|
type,
|
|
url,
|
|
preferredUsername,
|
|
publicKey: null,
|
|
privateKey: null,
|
|
followersCount: 0,
|
|
followingCount: 0,
|
|
inboxUrl: url + '/inbox',
|
|
outboxUrl: url + '/outbox',
|
|
sharedInboxUrl: WEBSERVER.URL + '/inbox',
|
|
followersUrl: url + '/followers',
|
|
followingUrl: url + '/following'
|
|
}) as MActor
|
|
}
|
|
|
|
export async function updateLocalActorImageFiles (
|
|
accountOrChannel: MAccountDefault | MChannelDefault,
|
|
imagePhysicalFile: Express.Multer.File,
|
|
type: ActorImageType
|
|
) {
|
|
const processImageSize = async (imageSize: { width: number, height: number }) => {
|
|
const extension = getLowercaseExtension(imagePhysicalFile.filename)
|
|
|
|
const imageName = buildUUID() + extension
|
|
const destination = join(CONFIG.STORAGE.ACTOR_IMAGES, imageName)
|
|
await processImageFromWorker({ path: imagePhysicalFile.path, destination, newSize: imageSize, keepOriginal: true })
|
|
|
|
return {
|
|
imageName,
|
|
imageSize
|
|
}
|
|
}
|
|
|
|
const processedImages = await Promise.all(ACTOR_IMAGES_SIZE[type].map(processImageSize))
|
|
await remove(imagePhysicalFile.path)
|
|
|
|
return retryTransactionWrapper(() => sequelizeTypescript.transaction(async t => {
|
|
const actorImagesInfo = processedImages.map(({ imageName, imageSize }) => ({
|
|
name: imageName,
|
|
fileUrl: null,
|
|
height: imageSize.height,
|
|
width: imageSize.width,
|
|
onDisk: true
|
|
}))
|
|
|
|
const updatedActor = await updateActorImages(accountOrChannel.Actor, type, actorImagesInfo, t)
|
|
await updatedActor.save({ transaction: t })
|
|
|
|
await sendUpdateActor(accountOrChannel, t)
|
|
|
|
return type === ActorImageType.AVATAR
|
|
? updatedActor.Avatars
|
|
: updatedActor.Banners
|
|
}))
|
|
}
|
|
|
|
export async function deleteLocalActorImageFile (accountOrChannel: MAccountDefault | MChannelDefault, type: ActorImageType) {
|
|
return retryTransactionWrapper(() => {
|
|
return sequelizeTypescript.transaction(async t => {
|
|
const updatedActor = await deleteActorImages(accountOrChannel.Actor, type, t)
|
|
await updatedActor.save({ transaction: t })
|
|
|
|
await sendUpdateActor(accountOrChannel, t)
|
|
|
|
return updatedActor.Avatars
|
|
})
|
|
})
|
|
}
|
|
|
|
// ---------------------------------------------------------------------------
|
|
|
|
export async function findAvailableLocalActorName (baseActorName: string, transaction?: Transaction) {
|
|
let actor = await ActorModel.loadLocalByName(baseActorName, transaction)
|
|
if (!actor) return baseActorName
|
|
|
|
for (let i = 1; i < 30; i++) {
|
|
const name = `${baseActorName}-${i}`
|
|
|
|
actor = await ActorModel.loadLocalByName(name, transaction)
|
|
if (!actor) return name
|
|
}
|
|
|
|
throw new Error('Cannot find available actor local name (too much iterations).')
|
|
}
|