import { uploadFromUrl } from "../../../services/drive/upload-from-url.js"; import Resolver from "../resolver.js"; import { fetchMeta } from "../../../misc/fetch-meta.js"; import { apLogger } from "../logger.js"; import { DriveFiles } from "../../../models/index.js"; import { truncate } from "../../../misc/truncate.js"; import { DB_MAX_IMAGE_COMMENT_LENGTH } from "../../../misc/hard-limits.js"; const logger = apLogger; /** * create an Image. */ export async function createImage(actor, value) { // Skip if author is frozen. if (actor.isSuspended) { throw new Error("actor has been suspended"); } const image = await new Resolver().resolve(value); if (image.url == null) { throw new Error("Invalid image, URL not provided"); } if (!image.url.startsWith("https://") && !image.url.startsWith("http://")) { throw new Error(`Invalid image, unexpected schema: ${image.url}`); } logger.info(`Creating the Image: ${image.url}`); const instance = await fetchMeta(); let file = await uploadFromUrl({ url: image.url, user: actor, uri: image.url, sensitive: image.sensitive, isLink: !instance.cacheRemoteFiles, comment: truncate(image.name, DB_MAX_IMAGE_COMMENT_LENGTH) }); if (file.isLink) { // If the URL is different, it means that the same image was previously // registered with a different URL, so update the URL if (file.url !== image.url) { await DriveFiles.update({ id: file.id }, { url: image.url, uri: image.url }); file = await DriveFiles.findOneByOrFail({ id: file.id }); } } return file; } /** * Resolve Image. * * If the target Image is registered in Iceshrimp, return it, otherwise * Fetch from remote server, register with Iceshrimp and return it. */ export async function resolveImage(actor, value) { // TODO // Fetch from remote server and register return await createImage(actor, value); }