mirror of
https://github.com/misskey-dev/media-proxy.git
synced 2025-08-08 09:13:51 +09:00
Compare commits
11 Commits
Author | SHA1 | Date | |
---|---|---|---|
d86823e32d | |||
405e6a5adb | |||
78cf2469d4 | |||
969d27e1b3 | |||
d5f5f4023c | |||
30c8088b8e | |||
4d3869020a | |||
4e2230d7cf | |||
cfaf017c15 | |||
808dacda41 | |||
0f65312eef |
@ -1,32 +0,0 @@
|
|||||||
module.exports = {
|
|
||||||
parserOptions: {
|
|
||||||
tsconfigRootDir: __dirname,
|
|
||||||
project: ['./tsconfig.json'],
|
|
||||||
},
|
|
||||||
extends: [
|
|
||||||
'../shared/.eslintrc.js',
|
|
||||||
],
|
|
||||||
rules: {
|
|
||||||
'import/order': ['warn', {
|
|
||||||
'groups': ['builtin', 'external', 'internal', 'parent', 'sibling', 'index', 'object', 'type'],
|
|
||||||
'pathGroups': [
|
|
||||||
{
|
|
||||||
'pattern': '@/**',
|
|
||||||
'group': 'external',
|
|
||||||
'position': 'after'
|
|
||||||
}
|
|
||||||
],
|
|
||||||
}],
|
|
||||||
'no-restricted-globals': [
|
|
||||||
'error',
|
|
||||||
{
|
|
||||||
'name': '__dirname',
|
|
||||||
'message': 'Not in ESModule. Use `import.meta.url` instead.'
|
|
||||||
},
|
|
||||||
{
|
|
||||||
'name': '__filename',
|
|
||||||
'message': 'Not in ESModule. Use `import.meta.url` instead.'
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
};
|
|
12
README.md
12
README.md
@ -1,5 +1,7 @@
|
|||||||
# Media Proxy for Misskey
|
# Media Proxy for Misskey
|
||||||
|
|
||||||
|
[→ メディアプロキシの仕様](./SPECIFICATION.md)
|
||||||
|
|
||||||
Misskeyの/proxyが単体で動作します(Misskeyのコードがほぼそのまま移植されています)。
|
Misskeyの/proxyが単体で動作します(Misskeyのコードがほぼそのまま移植されています)。
|
||||||
|
|
||||||
/proxyは画像ではないと403を返しますが、Media Proxyではそのまま内容を送信します。
|
/proxyは画像ではないと403を返しますが、Media Proxyではそのまま内容を送信します。
|
||||||
@ -61,15 +63,11 @@ export default {
|
|||||||
maxSize: 262144000,
|
maxSize: 262144000,
|
||||||
|
|
||||||
// CORS
|
// CORS
|
||||||
// WARN:
|
'Access-Control-Allow-Origin': '*',
|
||||||
// 'Access-Control-Allow-Origin'を'*'に設定した場合、要求のOriginヘッダーを応答します。
|
'Access-Control-Allow-Headers': '*',
|
||||||
// (Misskeyのアバタークロップに必要なため)
|
|
||||||
// Varyヘッダーが付加されるため、同じURLでもOriginごとに画像が生成されてしまうはずです。
|
|
||||||
['Access-Control-Allow-Origin']: '*',
|
|
||||||
['Access-Control-Allow-Headers']: '*',
|
|
||||||
|
|
||||||
// CSP
|
// CSP
|
||||||
['Content-Security-Policy']: `default-src 'none'; img-src 'self'; media-src 'self'; style-src 'unsafe-inline'`,
|
'Content-Security-Policy': `default-src 'none'; img-src 'self'; media-src 'self'; style-src 'unsafe-inline'`,
|
||||||
|
|
||||||
// フォワードプロキシ
|
// フォワードプロキシ
|
||||||
// proxy: 'http://127.0.0.1:3128'
|
// proxy: 'http://127.0.0.1:3128'
|
||||||
|
85
SPECIFICATION.md
Normal file
85
SPECIFICATION.md
Normal file
@ -0,0 +1,85 @@
|
|||||||
|
# Misskeyメディアプロキシ仕様書
|
||||||
|
|
||||||
|
## メディアプロキシの種類と目的
|
||||||
|
Misskeyメディアプロキシは、リモートのファイルをインスタンス管理者が管理するドメインでプロキシ配信し、また、縮小・加工された画像を提供するためのアプリケーションである。
|
||||||
|
|
||||||
|
Misskeyサーバー本体の/proxy/で提供されている「本体メディアプロキシ (local media proxy)」と、[github.com/misskey-dev/media-proxy](https://github.com/misskey-dev/media-proxy)で配布されている「外部メディアプロキシ (external media proxy)」がある。
|
||||||
|
|
||||||
|
外部メディアプロキシを設定・使用することで、本体のサーバー負荷を軽減できる。また、複数のインスタンスで外部プロキシを共用すると、さらなる負荷軽減が期待できる。
|
||||||
|
|
||||||
|
## 外部メディアプロキシの設定と使用
|
||||||
|
外部メディアプロキシを設定するには、[README.md](./README.md)に記載されている通りインストールする。
|
||||||
|
|
||||||
|
外部メディアプロキシが設定されている場合、本体メディアプロキシは外部メディアプロキシへ301リダイレクトを返答する(originクエリが指定されている場合を除く)。
|
||||||
|
|
||||||
|
Misskeyサーバーのapi/metaの応答に、使用するべきメディアプロキシのURLを示す`mediaProxy`プロパティが存在する。
|
||||||
|
外部メディアプロキシが指定されているならそのURLが、指定されていなければ本体メディアプロキシ(/proxy/)のURLが入っている。
|
||||||
|
本体メディアプロキシはリダイレクトを行うものの、Misskeyクライアントは`mediaProxy`の値に応じて適切なメディアプロキシへ直接要求を行うべきである。
|
||||||
|
|
||||||
|
メディアプロキシへは、クエリ文字列によって命令を行う。
|
||||||
|
|
||||||
|
拡張子によってキャッシュの挙動を変えるCDNがあるため、image.webp、avatar.webp、static.webpなどの適当なファイル名を付加するべきである。
|
||||||
|
例:
|
||||||
|
`https://example.com/proxy/image.webp?url=https%3A%2F%2F......`
|
||||||
|
|
||||||
|
Acceptヘッダーは無視される。
|
||||||
|
Cache-Controlは、正常なレスポンスの場合`max-age=31536000, immutable`、エラーレスポンスの場合`max-age=300`である。
|
||||||
|
Content-Typeは、ファイルの内容について適切なものが挿入される。
|
||||||
|
Content-Security-Policyは、`default-src 'none'; img-src 'self'; media-src 'self'; style-src 'unsafe-inline'`となっている。
|
||||||
|
Content-Dispositionは、filenameは元画像のContent-Disposition.filenameもしくはファイル名に基づいて挿入される。拡張子は適宜変更され、octet-streamの場合は拡張子として.unknownが付加される。inlineが指定される。
|
||||||
|
|
||||||
|
### クエリの一覧
|
||||||
|
#### url (必須)
|
||||||
|
変換ないしはプロキシを行う対象の、元画像のURLを指定する。
|
||||||
|
指定がなかった場合はHTTPコード400が返される。
|
||||||
|
|
||||||
|
https://www.google.com/images/errors/robot.png をプロキシする場合:
|
||||||
|
`https://example.com/proxy/image.webp?url=https%3A%2F%2Fwww.google.com%2Fimages%2Ferrors%2Frobot.png`
|
||||||
|
|
||||||
|
#### origin (本体のみ)
|
||||||
|
存在すると、外部メディアプロキシへのリダイレクトを行わない。
|
||||||
|
|
||||||
|
`https://example.com/proxy/image.webp?url=https%3A%2F%2F...&origin=1`
|
||||||
|
|
||||||
|
「存在すると」というのは、Fastifyで`'origin' in request.query`がtureになる場合という意味である。以下同様。
|
||||||
|
|
||||||
|
#### fallback
|
||||||
|
存在すると、元画像に到達できなかったり画像の変換中にエラーが起きたりした場合、正常なレスポンス(Cache-Controlは`max-age=300`)としてフォールバック画像(カラーバー)が表示される。
|
||||||
|
|
||||||
|
#### 変換クエリが存在しない場合の挙動
|
||||||
|
次の項目からは変換形式を指定するクエリとなっている。
|
||||||
|
|
||||||
|
変換形式が指定されていなかった場合は、画像ファイルもしくは許可されたファイル(FILE_TYPE_BROWSERSAFE)である場合のみプロキシ(ファイルの再配信)が行われる。
|
||||||
|
ただし、svgは、webpに変換される(最大サイズ2048x2048)。
|
||||||
|
|
||||||
|
#### 変換クエリ付加時の挙動
|
||||||
|
一方、以下の変換クエリが指定されているが、元ファイルがsharp.jsで変換できない形式の場合、404が返される。
|
||||||
|
|
||||||
|
#### emoji
|
||||||
|
存在すると、高さ128px以下のwebpが応答される。
|
||||||
|
ただし、sharp.jsの都合により、元画像がapngの場合は無変換で応答される。
|
||||||
|
|
||||||
|
`https://example.com/proxy/emoji.webp?url=https%3A%2F%2F...&emoji=1`
|
||||||
|
|
||||||
|
「以下」というのは、元画像がこれ未満だった場合は拡大を行わないという意味である。以下同様。
|
||||||
|
|
||||||
|
#### avatar
|
||||||
|
存在すると、高さ320px以下のwebpが応答される。
|
||||||
|
ただし、sharp.jsの都合により、元画像がapngの場合は無変換で応答される。
|
||||||
|
|
||||||
|
`https://example.com/proxy/avatar.webp?url=https%3A%2F%2F...&avatar=1`
|
||||||
|
|
||||||
|
#### static
|
||||||
|
存在すると、アニメーション画像では最初のフレームのみの静止画のwebpが応答される。
|
||||||
|
|
||||||
|
emojiまたはavatarとstaticが同時に指定された場合は、それぞれに応じた高さが、指定されていない場合は幅498px・高さ280pxに収まるサイズ以下に縮小される。
|
||||||
|
|
||||||
|
#### preview
|
||||||
|
存在すると、幅200px・高さ200pxに収まるサイズ以下のwebpが応答される。
|
||||||
|
|
||||||
|
#### badge
|
||||||
|
Webプッシュ通知のバッジに適したpngが応答される。
|
||||||
|
|
||||||
|
https://developer.mozilla.org/ja/docs/Web/API/Notification/badge
|
||||||
|
|
||||||
|
サイズは96x96で、元画像がアルファチャンネルのみで表現される。
|
BIN
assets/dummy.png
Normal file
BIN
assets/dummy.png
Normal file
Binary file not shown.
After Width: | Height: | Size: 6.1 KiB |
4
built/download.d.ts
vendored
4
built/download.d.ts
vendored
@ -19,4 +19,6 @@ export declare const defaultDownloadConfig: {
|
|||||||
maxSize: number;
|
maxSize: number;
|
||||||
proxy: boolean;
|
proxy: boolean;
|
||||||
};
|
};
|
||||||
export declare function downloadUrl(url: string, path: string, settings?: DownloadConfig): Promise<void>;
|
export declare function downloadUrl(url: string, path: string, settings?: DownloadConfig): Promise<{
|
||||||
|
filename: string;
|
||||||
|
}>;
|
||||||
|
@ -6,6 +6,7 @@ import IPCIDR from 'ip-cidr';
|
|||||||
import PrivateIp from 'private-ip';
|
import PrivateIp from 'private-ip';
|
||||||
import { StatusError } from './status-error.js';
|
import { StatusError } from './status-error.js';
|
||||||
import { getAgents } from './http.js';
|
import { getAgents } from './http.js';
|
||||||
|
import { parse } from 'content-disposition';
|
||||||
const pipeline = util.promisify(stream.pipeline);
|
const pipeline = util.promisify(stream.pipeline);
|
||||||
export const defaultDownloadConfig = {
|
export const defaultDownloadConfig = {
|
||||||
userAgent: `MisskeyMediaProxy/0.0.0`,
|
userAgent: `MisskeyMediaProxy/0.0.0`,
|
||||||
@ -19,6 +20,8 @@ export async function downloadUrl(url, path, settings = defaultDownloadConfig) {
|
|||||||
console.log(`Downloading ${url} to ${path} ...`);
|
console.log(`Downloading ${url} to ${path} ...`);
|
||||||
const timeout = 30 * 1000;
|
const timeout = 30 * 1000;
|
||||||
const operationTimeout = 60 * 1000;
|
const operationTimeout = 60 * 1000;
|
||||||
|
const urlObj = new URL(url);
|
||||||
|
let filename = urlObj.pathname.split('/').pop() ?? 'unknown';
|
||||||
const req = got.stream(url, {
|
const req = got.stream(url, {
|
||||||
headers: {
|
headers: {
|
||||||
'User-Agent': settings.userAgent,
|
'User-Agent': settings.userAgent,
|
||||||
@ -56,6 +59,13 @@ export async function downloadUrl(url, path, settings = defaultDownloadConfig) {
|
|||||||
req.destroy();
|
req.destroy();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
const contentDisposition = res.headers['content-disposition'];
|
||||||
|
if (contentDisposition != null) {
|
||||||
|
const parsed = parse(contentDisposition);
|
||||||
|
if (parsed.parameters.filename) {
|
||||||
|
filename = parsed.parameters.filename;
|
||||||
|
}
|
||||||
|
}
|
||||||
}).on('downloadProgress', (progress) => {
|
}).on('downloadProgress', (progress) => {
|
||||||
if (progress.transferred > settings.maxSize) {
|
if (progress.transferred > settings.maxSize) {
|
||||||
console.log(`maxSize exceeded (${progress.transferred} > ${settings.maxSize}) on downloadProgress`);
|
console.log(`maxSize exceeded (${progress.transferred} > ${settings.maxSize}) on downloadProgress`);
|
||||||
@ -75,6 +85,9 @@ export async function downloadUrl(url, path, settings = defaultDownloadConfig) {
|
|||||||
}
|
}
|
||||||
if (process.env.NODE_ENV !== 'production')
|
if (process.env.NODE_ENV !== 'production')
|
||||||
console.log(`Download finished: ${url}`);
|
console.log(`Download finished: ${url}`);
|
||||||
|
return {
|
||||||
|
filename,
|
||||||
|
};
|
||||||
}
|
}
|
||||||
function isPrivateIp(ip, allowedPrivateNetworks) {
|
function isPrivateIp(ip, allowedPrivateNetworks) {
|
||||||
for (const net of allowedPrivateNetworks ?? []) {
|
for (const net of allowedPrivateNetworks ?? []) {
|
||||||
|
@ -55,7 +55,7 @@ async function checkSvg(path) {
|
|||||||
import { FILE_TYPE_BROWSERSAFE } from './const.js';
|
import { FILE_TYPE_BROWSERSAFE } from './const.js';
|
||||||
const dictionary = {
|
const dictionary = {
|
||||||
'safe-file': FILE_TYPE_BROWSERSAFE,
|
'safe-file': FILE_TYPE_BROWSERSAFE,
|
||||||
'sharp-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/apng', 'image/vnd.mozilla.apng', 'image/webp', 'image/avif', 'image/svg+xml'],
|
'sharp-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/apng', 'image/vnd.mozilla.apng', 'image/webp', 'image/avif', 'image/svg+xml', 'image/x-icon', 'image/bmp'],
|
||||||
'sharp-animation-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/webp', 'image/avif', 'image/svg+xml'],
|
'sharp-animation-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/webp', 'image/avif', 'image/svg+xml', 'image/x-icon', 'image/bmp'],
|
||||||
};
|
};
|
||||||
export const isMimeImage = (mime, type) => dictionary[type].includes(mime);
|
export const isMimeImage = (mime, type) => dictionary[type].includes(mime);
|
||||||
|
@ -1,11 +1,12 @@
|
|||||||
import sharp from 'sharp';
|
import sharp from 'sharp';
|
||||||
export const webpDefault = {
|
export const webpDefault = {
|
||||||
quality: 85,
|
quality: 77,
|
||||||
alphaQuality: 95,
|
alphaQuality: 95,
|
||||||
lossless: false,
|
lossless: false,
|
||||||
nearLossless: false,
|
nearLossless: false,
|
||||||
smartSubsample: true,
|
smartSubsample: true,
|
||||||
mixed: true,
|
mixed: true,
|
||||||
|
effort: 2,
|
||||||
};
|
};
|
||||||
export function convertToWebpStream(path, width, height, options = webpDefault) {
|
export function convertToWebpStream(path, width, height, options = webpDefault) {
|
||||||
return convertSharpToWebpStream(sharp(path), width, height, options);
|
return convertSharpToWebpStream(sharp(path), width, height, options);
|
||||||
|
@ -3,15 +3,18 @@ import { fileURLToPath } from 'node:url';
|
|||||||
import { dirname } from 'node:path';
|
import { dirname } from 'node:path';
|
||||||
import fastifyStatic from '@fastify/static';
|
import fastifyStatic from '@fastify/static';
|
||||||
import { createTemp } from './create-temp.js';
|
import { createTemp } from './create-temp.js';
|
||||||
import { convertToWebpStream, webpDefault } from './image-processor.js';
|
import { FILE_TYPE_BROWSERSAFE } from './const.js';
|
||||||
|
import { convertToWebpStream, webpDefault, convertSharpToWebpStream } from './image-processor.js';
|
||||||
import { detectType, isMimeImage } from './file-info.js';
|
import { detectType, isMimeImage } from './file-info.js';
|
||||||
import sharp from 'sharp';
|
import sharp from 'sharp';
|
||||||
|
import { sharpBmp } from 'sharp-read-bmp';
|
||||||
import { StatusError } from './status-error.js';
|
import { StatusError } from './status-error.js';
|
||||||
import { defaultDownloadConfig, downloadUrl } from './download.js';
|
import { defaultDownloadConfig, downloadUrl } from './download.js';
|
||||||
import { getAgents } from './http.js';
|
import { getAgents } from './http.js';
|
||||||
|
import _contentDisposition from 'content-disposition';
|
||||||
const _filename = fileURLToPath(import.meta.url);
|
const _filename = fileURLToPath(import.meta.url);
|
||||||
const _dirname = dirname(_filename);
|
const _dirname = dirname(_filename);
|
||||||
const assets = `${_dirname}/../../server/file/assets/`;
|
const assets = `${_dirname}/../assets/`;
|
||||||
let config = defaultDownloadConfig;
|
let config = defaultDownloadConfig;
|
||||||
export function setMediaProxyConfig(setting) {
|
export function setMediaProxyConfig(setting) {
|
||||||
const proxy = process.env.HTTP_PROXY ?? process.env.http_proxy;
|
const proxy = process.env.HTTP_PROXY ?? process.env.http_proxy;
|
||||||
@ -45,13 +48,7 @@ export default function (fastify, options, done) {
|
|||||||
const corsHeader = options['Access-Control-Allow-Headers'] ?? '*';
|
const corsHeader = options['Access-Control-Allow-Headers'] ?? '*';
|
||||||
const csp = options['Content-Security-Policy'] ?? `default-src 'none'; img-src 'self'; media-src 'self'; style-src 'unsafe-inline'`;
|
const csp = options['Content-Security-Policy'] ?? `default-src 'none'; img-src 'self'; media-src 'self'; style-src 'unsafe-inline'`;
|
||||||
fastify.addHook('onRequest', (request, reply, done) => {
|
fastify.addHook('onRequest', (request, reply, done) => {
|
||||||
if (corsOrigin === '*') {
|
|
||||||
reply.header('Access-Control-Allow-Origin', request.headers.origin ?? '*');
|
|
||||||
reply.header('Vary', 'Origin');
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
reply.header('Access-Control-Allow-Origin', corsOrigin);
|
reply.header('Access-Control-Allow-Origin', corsOrigin);
|
||||||
}
|
|
||||||
reply.header('Access-Control-Allow-Headers', corsHeader);
|
reply.header('Access-Control-Allow-Headers', corsHeader);
|
||||||
reply.header('Access-Control-Allow-Methods', 'GET, OPTIONS');
|
reply.header('Access-Control-Allow-Methods', 'GET, OPTIONS');
|
||||||
reply.header('Content-Security-Policy', csp);
|
reply.header('Content-Security-Policy', csp);
|
||||||
@ -111,7 +108,7 @@ async function proxyHandler(request, reply) {
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
const data = sharp(file.path, { animated: !('static' in request.query) })
|
const data = (await sharpBmp(file.path, file.mime, { animated: !('static' in request.query) }))
|
||||||
.resize({
|
.resize({
|
||||||
height: 'emoji' in request.query ? 128 : 320,
|
height: 'emoji' in request.query ? 128 : 320,
|
||||||
withoutEnlargement: true,
|
withoutEnlargement: true,
|
||||||
@ -125,13 +122,13 @@ async function proxyHandler(request, reply) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
else if ('static' in request.query) {
|
else if ('static' in request.query) {
|
||||||
image = convertToWebpStream(file.path, 498, 280);
|
image = convertSharpToWebpStream(await sharpBmp(file.path, file.mime), 498, 280);
|
||||||
}
|
}
|
||||||
else if ('preview' in request.query) {
|
else if ('preview' in request.query) {
|
||||||
image = convertToWebpStream(file.path, 200, 200);
|
image = convertSharpToWebpStream(await sharpBmp(file.path, file.mime), 200, 200);
|
||||||
}
|
}
|
||||||
else if ('badge' in request.query) {
|
else if ('badge' in request.query) {
|
||||||
const mask = sharp(file.path)
|
const mask = (await sharpBmp(file.path, file.mime))
|
||||||
.resize(96, 96, {
|
.resize(96, 96, {
|
||||||
fit: 'inside',
|
fit: 'inside',
|
||||||
withoutEnlargement: false,
|
withoutEnlargement: false,
|
||||||
@ -160,6 +157,9 @@ async function proxyHandler(request, reply) {
|
|||||||
else if (file.mime === 'image/svg+xml') {
|
else if (file.mime === 'image/svg+xml') {
|
||||||
image = convertToWebpStream(file.path, 2048, 2048);
|
image = convertToWebpStream(file.path, 2048, 2048);
|
||||||
}
|
}
|
||||||
|
else if (!file.mime.startsWith('image/') || !FILE_TYPE_BROWSERSAFE.includes(file.mime)) {
|
||||||
|
throw new StatusError('Rejected type', 403, 'Rejected type');
|
||||||
|
}
|
||||||
if (!image) {
|
if (!image) {
|
||||||
image = {
|
image = {
|
||||||
data: fs.createReadStream(file.path),
|
data: fs.createReadStream(file.path),
|
||||||
@ -184,6 +184,7 @@ async function proxyHandler(request, reply) {
|
|||||||
}
|
}
|
||||||
reply.header('Content-Type', image.type);
|
reply.header('Content-Type', image.type);
|
||||||
reply.header('Cache-Control', 'max-age=31536000, immutable');
|
reply.header('Cache-Control', 'max-age=31536000, immutable');
|
||||||
|
reply.header('Content-Disposition', contentDisposition('inline', correctFilename(file.filename, image.ext)));
|
||||||
return reply.send(image.data);
|
return reply.send(image.data);
|
||||||
}
|
}
|
||||||
catch (e) {
|
catch (e) {
|
||||||
@ -195,12 +196,13 @@ async function proxyHandler(request, reply) {
|
|||||||
async function downloadAndDetectTypeFromUrl(url) {
|
async function downloadAndDetectTypeFromUrl(url) {
|
||||||
const [path, cleanup] = await createTemp();
|
const [path, cleanup] = await createTemp();
|
||||||
try {
|
try {
|
||||||
await downloadUrl(url, path, config);
|
const { filename } = await downloadUrl(url, path, config);
|
||||||
const { mime, ext } = await detectType(path);
|
const { mime, ext } = await detectType(path);
|
||||||
return {
|
return {
|
||||||
state: 'remote',
|
state: 'remote',
|
||||||
mime, ext,
|
mime, ext,
|
||||||
path, cleanup,
|
path, cleanup,
|
||||||
|
filename: correctFilename(filename, ext),
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
catch (e) {
|
catch (e) {
|
||||||
@ -208,3 +210,20 @@ async function downloadAndDetectTypeFromUrl(url) {
|
|||||||
throw e;
|
throw e;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
function correctFilename(filename, ext) {
|
||||||
|
const dotExt = ext ? `.${ext}` : '.unknown';
|
||||||
|
if (filename.endsWith(dotExt)) {
|
||||||
|
return filename;
|
||||||
|
}
|
||||||
|
if (ext === 'jpg' && filename.endsWith('.jpeg')) {
|
||||||
|
return filename;
|
||||||
|
}
|
||||||
|
if (ext === 'tif' && filename.endsWith('.tiff')) {
|
||||||
|
return filename;
|
||||||
|
}
|
||||||
|
return `${filename}${dotExt}`;
|
||||||
|
}
|
||||||
|
function contentDisposition(type, filename) {
|
||||||
|
const fallback = filename.replace(/[^\w.-]/g, '_');
|
||||||
|
return _contentDisposition(filename, { type, fallback });
|
||||||
|
}
|
||||||
|
@ -1,9 +1,9 @@
|
|||||||
{
|
{
|
||||||
"name": "misskey-media-proxy",
|
"name": "misskey-media-proxy",
|
||||||
"version": "0.0.12",
|
"version": "0.0.18",
|
||||||
"description": "The Media Proxy for Misskey",
|
"description": "The Media Proxy for Misskey",
|
||||||
"main": "built/index.js",
|
"main": "built/index.js",
|
||||||
"packageManager": "pnpm@7.26.0",
|
"packageManager": "pnpm@7.28.0",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"files": [
|
"files": [
|
||||||
"built",
|
"built",
|
||||||
@ -28,6 +28,7 @@
|
|||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@swc/cli": "^0.1.61",
|
"@swc/cli": "^0.1.61",
|
||||||
"@swc/core": "^1.3.32",
|
"@swc/core": "^1.3.32",
|
||||||
|
"@types/content-disposition": "^0.5.5",
|
||||||
"@types/node": "^18.11.19",
|
"@types/node": "^18.11.19",
|
||||||
"@types/sharp": "^0.31.1",
|
"@types/sharp": "^0.31.1",
|
||||||
"@types/tmp": "^0.2.3",
|
"@types/tmp": "^0.2.3",
|
||||||
@ -36,6 +37,7 @@
|
|||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@fastify/static": "^6.8.0",
|
"@fastify/static": "^6.8.0",
|
||||||
"cacheable-lookup": "^7.0.0",
|
"cacheable-lookup": "^7.0.0",
|
||||||
|
"content-disposition": "^0.5.4",
|
||||||
"fastify": "^4.12.0",
|
"fastify": "^4.12.0",
|
||||||
"fastify-cli": "^5.7.1",
|
"fastify-cli": "^5.7.1",
|
||||||
"file-type": "^18.2.0",
|
"file-type": "^18.2.0",
|
||||||
@ -45,6 +47,7 @@
|
|||||||
"is-svg": "^4.3.2",
|
"is-svg": "^4.3.2",
|
||||||
"private-ip": "^3.0.0",
|
"private-ip": "^3.0.0",
|
||||||
"sharp": "^0.31.3",
|
"sharp": "^0.31.3",
|
||||||
|
"sharp-read-bmp": "github:misskey-dev/sharp-read-bmp",
|
||||||
"tmp": "^0.2.1"
|
"tmp": "^0.2.1"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
45
pnpm-lock.yaml
generated
45
pnpm-lock.yaml
generated
@ -4,10 +4,12 @@ specifiers:
|
|||||||
'@fastify/static': ^6.8.0
|
'@fastify/static': ^6.8.0
|
||||||
'@swc/cli': ^0.1.61
|
'@swc/cli': ^0.1.61
|
||||||
'@swc/core': ^1.3.32
|
'@swc/core': ^1.3.32
|
||||||
|
'@types/content-disposition': ^0.5.5
|
||||||
'@types/node': ^18.11.19
|
'@types/node': ^18.11.19
|
||||||
'@types/sharp': ^0.31.1
|
'@types/sharp': ^0.31.1
|
||||||
'@types/tmp': ^0.2.3
|
'@types/tmp': ^0.2.3
|
||||||
cacheable-lookup: ^7.0.0
|
cacheable-lookup: ^7.0.0
|
||||||
|
content-disposition: ^0.5.4
|
||||||
fastify: ^4.12.0
|
fastify: ^4.12.0
|
||||||
fastify-cli: ^5.7.1
|
fastify-cli: ^5.7.1
|
||||||
file-type: ^18.2.0
|
file-type: ^18.2.0
|
||||||
@ -17,12 +19,14 @@ specifiers:
|
|||||||
is-svg: ^4.3.2
|
is-svg: ^4.3.2
|
||||||
private-ip: ^3.0.0
|
private-ip: ^3.0.0
|
||||||
sharp: ^0.31.3
|
sharp: ^0.31.3
|
||||||
|
sharp-read-bmp: github:misskey-dev/sharp-read-bmp
|
||||||
tmp: ^0.2.1
|
tmp: ^0.2.1
|
||||||
typescript: ^4.9.5
|
typescript: ^4.9.5
|
||||||
|
|
||||||
dependencies:
|
dependencies:
|
||||||
'@fastify/static': 6.8.0
|
'@fastify/static': 6.8.0
|
||||||
cacheable-lookup: 7.0.0
|
cacheable-lookup: 7.0.0
|
||||||
|
content-disposition: 0.5.4
|
||||||
fastify: 4.12.0
|
fastify: 4.12.0
|
||||||
fastify-cli: 5.7.1
|
fastify-cli: 5.7.1
|
||||||
file-type: 18.2.0
|
file-type: 18.2.0
|
||||||
@ -32,11 +36,13 @@ dependencies:
|
|||||||
is-svg: 4.3.2
|
is-svg: 4.3.2
|
||||||
private-ip: 3.0.0
|
private-ip: 3.0.0
|
||||||
sharp: 0.31.3
|
sharp: 0.31.3
|
||||||
|
sharp-read-bmp: github.com/misskey-dev/sharp-read-bmp/c5fb82e26fa50fca8b3b2d7e22467626d7f61baa
|
||||||
tmp: 0.2.1
|
tmp: 0.2.1
|
||||||
|
|
||||||
devDependencies:
|
devDependencies:
|
||||||
'@swc/cli': 0.1.61_@swc+core@1.3.32
|
'@swc/cli': 0.1.61_@swc+core@1.3.32
|
||||||
'@swc/core': 1.3.32
|
'@swc/core': 1.3.32
|
||||||
|
'@types/content-disposition': 0.5.5
|
||||||
'@types/node': 18.11.19
|
'@types/node': 18.11.19
|
||||||
'@types/sharp': 0.31.1
|
'@types/sharp': 0.31.1
|
||||||
'@types/tmp': 0.2.3
|
'@types/tmp': 0.2.3
|
||||||
@ -44,6 +50,10 @@ devDependencies:
|
|||||||
|
|
||||||
packages:
|
packages:
|
||||||
|
|
||||||
|
/@canvas/image-data/1.0.0:
|
||||||
|
resolution: {integrity: sha512-BxOqI5LgsIQP1odU5KMwV9yoijleOPzHL18/YvNqF9KFSGF2K/DLlYAbDQsWqd/1nbaFuSkYD/191dpMtNh4vw==}
|
||||||
|
dev: false
|
||||||
|
|
||||||
/@chainsafe/is-ip/2.0.1:
|
/@chainsafe/is-ip/2.0.1:
|
||||||
resolution: {integrity: sha512-nqSJ8u2a1Rv9FYbyI8qpDhTYujaKEyLknNrTejLYoSWmdeg+2WB7R6BZqPZYfrJzDxVi3rl6ZQuoaEvpKRZWgQ==}
|
resolution: {integrity: sha512-nqSJ8u2a1Rv9FYbyI8qpDhTYujaKEyLknNrTejLYoSWmdeg+2WB7R6BZqPZYfrJzDxVi3rl6ZQuoaEvpKRZWgQ==}
|
||||||
dev: false
|
dev: false
|
||||||
@ -300,6 +310,10 @@ packages:
|
|||||||
'@types/responselike': 1.0.0
|
'@types/responselike': 1.0.0
|
||||||
dev: true
|
dev: true
|
||||||
|
|
||||||
|
/@types/content-disposition/0.5.5:
|
||||||
|
resolution: {integrity: sha512-v6LCdKfK6BwcqMo+wYW05rLS12S0ZO0Fl4w1h4aaZMD7bqT3gVUns6FvLJKGZHQmYn3SX55JWGpziwJRwVgutA==}
|
||||||
|
dev: true
|
||||||
|
|
||||||
/@types/http-cache-semantics/4.0.1:
|
/@types/http-cache-semantics/4.0.1:
|
||||||
resolution: {integrity: sha512-SZs7ekbP8CN0txVG2xVRH6EgKmEm31BOxA07vkFaETzZz1xh+cbt8BcI0slpymvwhx5dlFnQG2rTlPVQn+iRPQ==}
|
resolution: {integrity: sha512-SZs7ekbP8CN0txVG2xVRH6EgKmEm31BOxA07vkFaETzZz1xh+cbt8BcI0slpymvwhx5dlFnQG2rTlPVQn+iRPQ==}
|
||||||
|
|
||||||
@ -635,6 +649,23 @@ packages:
|
|||||||
ms: 2.1.2
|
ms: 2.1.2
|
||||||
dev: false
|
dev: false
|
||||||
|
|
||||||
|
/decode-bmp/0.2.1:
|
||||||
|
resolution: {integrity: sha512-NiOaGe+GN0KJqi2STf24hfMkFitDUaIoUU3eKvP/wAbLe8o6FuW5n/x7MHPR0HKvBokp6MQY/j7w8lewEeVCIA==}
|
||||||
|
engines: {node: '>=8.6.0'}
|
||||||
|
dependencies:
|
||||||
|
'@canvas/image-data': 1.0.0
|
||||||
|
to-data-view: 1.1.0
|
||||||
|
dev: false
|
||||||
|
|
||||||
|
/decode-ico/0.4.1:
|
||||||
|
resolution: {integrity: sha512-69NZfbKIzux1vBOd31al3XnMnH+2mqDhEgLdpygErm4d60N+UwA5Sq5WFjmEDQzumgB9fElojGwWG0vybVfFmA==}
|
||||||
|
engines: {node: '>=8.6'}
|
||||||
|
dependencies:
|
||||||
|
'@canvas/image-data': 1.0.0
|
||||||
|
decode-bmp: 0.2.1
|
||||||
|
to-data-view: 1.1.0
|
||||||
|
dev: false
|
||||||
|
|
||||||
/decompress-response/6.0.0:
|
/decompress-response/6.0.0:
|
||||||
resolution: {integrity: sha512-aW35yZM6Bb/4oJlZncMH2LCoZtJXTRxES17vE3hoRiowU2kWHaJKFkSBDnDR+cm9J+9QhXmREyIfv0pji9ejCQ==}
|
resolution: {integrity: sha512-aW35yZM6Bb/4oJlZncMH2LCoZtJXTRxES17vE3hoRiowU2kWHaJKFkSBDnDR+cm9J+9QhXmREyIfv0pji9ejCQ==}
|
||||||
engines: {node: '>=10'}
|
engines: {node: '>=10'}
|
||||||
@ -1970,6 +2001,10 @@ packages:
|
|||||||
resolution: {integrity: sha512-3f0uOEAQwIqGuWW2MVzYg8fV/QNnc/IpuJNG837rLuczAaLVHslWHZQj4IGiEl5Hs3kkbhwL9Ab7Hrsmuj+Smw==}
|
resolution: {integrity: sha512-3f0uOEAQwIqGuWW2MVzYg8fV/QNnc/IpuJNG837rLuczAaLVHslWHZQj4IGiEl5Hs3kkbhwL9Ab7Hrsmuj+Smw==}
|
||||||
dev: false
|
dev: false
|
||||||
|
|
||||||
|
/to-data-view/1.1.0:
|
||||||
|
resolution: {integrity: sha512-1eAdufMg6mwgmlojAx3QeMnzB/BTVp7Tbndi3U7ftcT2zCZadjxkkmLmd97zmaxWi+sgGcgWrokmpEoy0Dn0vQ==}
|
||||||
|
dev: false
|
||||||
|
|
||||||
/to-regex-range/5.0.1:
|
/to-regex-range/5.0.1:
|
||||||
resolution: {integrity: sha512-65P7iz6X5yEr1cwcgvQxbbIw7Uk3gOy5dIdtZ4rDveLqhrdJP+Li/Hx6tyK0NEb+2GCyneCMJiGqrADCSNk8sQ==}
|
resolution: {integrity: sha512-65P7iz6X5yEr1cwcgvQxbbIw7Uk3gOy5dIdtZ4rDveLqhrdJP+Li/Hx6tyK0NEb+2GCyneCMJiGqrADCSNk8sQ==}
|
||||||
engines: {node: '>=8.0'}
|
engines: {node: '>=8.0'}
|
||||||
@ -2056,3 +2091,13 @@ packages:
|
|||||||
resolution: {integrity: sha512-rVksvsnNCdJ/ohGc6xgPwyN8eheCxsiLM8mxuE/t/mOVqJewPuO1miLpTHQiRgTKCLexL4MeAFVagts7HmNZ2Q==}
|
resolution: {integrity: sha512-rVksvsnNCdJ/ohGc6xgPwyN8eheCxsiLM8mxuE/t/mOVqJewPuO1miLpTHQiRgTKCLexL4MeAFVagts7HmNZ2Q==}
|
||||||
engines: {node: '>=10'}
|
engines: {node: '>=10'}
|
||||||
dev: false
|
dev: false
|
||||||
|
|
||||||
|
github.com/misskey-dev/sharp-read-bmp/c5fb82e26fa50fca8b3b2d7e22467626d7f61baa:
|
||||||
|
resolution: {tarball: https://codeload.github.com/misskey-dev/sharp-read-bmp/tar.gz/c5fb82e26fa50fca8b3b2d7e22467626d7f61baa}
|
||||||
|
name: sharp-read-bmp
|
||||||
|
version: 1.0.0
|
||||||
|
dependencies:
|
||||||
|
decode-bmp: 0.2.1
|
||||||
|
decode-ico: 0.4.1
|
||||||
|
sharp: 0.31.3
|
||||||
|
dev: false
|
||||||
|
@ -8,6 +8,7 @@ import IPCIDR from 'ip-cidr';
|
|||||||
import PrivateIp from 'private-ip';
|
import PrivateIp from 'private-ip';
|
||||||
import { StatusError } from './status-error.js';
|
import { StatusError } from './status-error.js';
|
||||||
import { getAgents } from './http.js';
|
import { getAgents } from './http.js';
|
||||||
|
import { parse } from 'content-disposition';
|
||||||
|
|
||||||
const pipeline = util.promisify(stream.pipeline);
|
const pipeline = util.promisify(stream.pipeline);
|
||||||
|
|
||||||
@ -29,12 +30,17 @@ export const defaultDownloadConfig = {
|
|||||||
...getAgents()
|
...getAgents()
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function downloadUrl(url: string, path: string, settings:DownloadConfig = defaultDownloadConfig): Promise<void> {
|
export async function downloadUrl(url: string, path: string, settings:DownloadConfig = defaultDownloadConfig): Promise<{
|
||||||
|
filename: string;
|
||||||
|
}> {
|
||||||
if (process.env.NODE_ENV !== 'production') console.log(`Downloading ${url} to ${path} ...`);
|
if (process.env.NODE_ENV !== 'production') console.log(`Downloading ${url} to ${path} ...`);
|
||||||
|
|
||||||
const timeout = 30 * 1000;
|
const timeout = 30 * 1000;
|
||||||
const operationTimeout = 60 * 1000;
|
const operationTimeout = 60 * 1000;
|
||||||
|
|
||||||
|
const urlObj = new URL(url);
|
||||||
|
let filename = urlObj.pathname.split('/').pop() ?? 'unknown';
|
||||||
|
|
||||||
const req = got.stream(url, {
|
const req = got.stream(url, {
|
||||||
headers: {
|
headers: {
|
||||||
'User-Agent': settings.userAgent,
|
'User-Agent': settings.userAgent,
|
||||||
@ -73,6 +79,14 @@ export async function downloadUrl(url: string, path: string, settings:DownloadCo
|
|||||||
req.destroy();
|
req.destroy();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const contentDisposition = res.headers['content-disposition'];
|
||||||
|
if (contentDisposition != null) {
|
||||||
|
const parsed = parse(contentDisposition);
|
||||||
|
if (parsed.parameters.filename) {
|
||||||
|
filename = parsed.parameters.filename;
|
||||||
|
}
|
||||||
|
}
|
||||||
}).on('downloadProgress', (progress: Got.Progress) => {
|
}).on('downloadProgress', (progress: Got.Progress) => {
|
||||||
if (progress.transferred > settings.maxSize) {
|
if (progress.transferred > settings.maxSize) {
|
||||||
console.log(`maxSize exceeded (${progress.transferred} > ${settings.maxSize}) on downloadProgress`);
|
console.log(`maxSize exceeded (${progress.transferred} > ${settings.maxSize}) on downloadProgress`);
|
||||||
@ -91,6 +105,10 @@ export async function downloadUrl(url: string, path: string, settings:DownloadCo
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (process.env.NODE_ENV !== 'production') console.log(`Download finished: ${url}`);
|
if (process.env.NODE_ENV !== 'production') console.log(`Download finished: ${url}`);
|
||||||
|
|
||||||
|
return {
|
||||||
|
filename,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function isPrivateIp(ip: string, allowedPrivateNetworks: string[]): boolean {
|
function isPrivateIp(ip: string, allowedPrivateNetworks: string[]): boolean {
|
||||||
|
@ -66,8 +66,8 @@ import { FILE_TYPE_BROWSERSAFE } from './const.js';
|
|||||||
|
|
||||||
const dictionary = {
|
const dictionary = {
|
||||||
'safe-file': FILE_TYPE_BROWSERSAFE,
|
'safe-file': FILE_TYPE_BROWSERSAFE,
|
||||||
'sharp-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/apng', 'image/vnd.mozilla.apng', 'image/webp', 'image/avif', 'image/svg+xml'],
|
'sharp-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/apng', 'image/vnd.mozilla.apng', 'image/webp', 'image/avif', 'image/svg+xml', 'image/x-icon', 'image/bmp'],
|
||||||
'sharp-animation-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/webp', 'image/avif', 'image/svg+xml'],
|
'sharp-animation-convertible-image': ['image/jpeg', 'image/png', 'image/gif', 'image/webp', 'image/avif', 'image/svg+xml', 'image/x-icon', 'image/bmp'],
|
||||||
};
|
};
|
||||||
|
|
||||||
export const isMimeImage = (mime: string, type: keyof typeof dictionary): boolean => dictionary[type].includes(mime);
|
export const isMimeImage = (mime: string, type: keyof typeof dictionary): boolean => dictionary[type].includes(mime);
|
||||||
|
@ -16,12 +16,13 @@ export type IImageStream = {
|
|||||||
export type IImageStreamable = IImage | IImageStream;
|
export type IImageStreamable = IImage | IImageStream;
|
||||||
|
|
||||||
export const webpDefault: sharp.WebpOptions = {
|
export const webpDefault: sharp.WebpOptions = {
|
||||||
quality: 85,
|
quality: 77,
|
||||||
alphaQuality: 95,
|
alphaQuality: 95,
|
||||||
lossless: false,
|
lossless: false,
|
||||||
nearLossless: false,
|
nearLossless: false,
|
||||||
smartSubsample: true,
|
smartSubsample: true,
|
||||||
mixed: true,
|
mixed: true,
|
||||||
|
effort: 2,
|
||||||
};
|
};
|
||||||
|
|
||||||
export function convertToWebpStream(path: string, width: number, height: number, options: sharp.WebpOptions = webpDefault): IImageStream {
|
export function convertToWebpStream(path: string, width: number, height: number, options: sharp.WebpOptions = webpDefault): IImageStream {
|
||||||
|
51
src/index.ts
51
src/index.ts
@ -6,18 +6,20 @@ import { dirname } from 'node:path';
|
|||||||
import fastifyStatic from '@fastify/static';
|
import fastifyStatic from '@fastify/static';
|
||||||
import { createTemp } from './create-temp.js';
|
import { createTemp } from './create-temp.js';
|
||||||
import { FILE_TYPE_BROWSERSAFE } from './const.js';
|
import { FILE_TYPE_BROWSERSAFE } from './const.js';
|
||||||
import { IImageStreamable, convertToWebpStream, webpDefault } from './image-processor.js';
|
import { IImageStreamable, convertToWebpStream, webpDefault, convertSharpToWebpStream } from './image-processor.js';
|
||||||
import type { FastifyInstance, FastifyRequest, FastifyReply, FastifyPluginOptions } from 'fastify';
|
import type { FastifyInstance, FastifyRequest, FastifyReply, FastifyPluginOptions } from 'fastify';
|
||||||
import { detectType, isMimeImage } from './file-info.js';
|
import { detectType, isMimeImage } from './file-info.js';
|
||||||
import sharp from 'sharp';
|
import sharp from 'sharp';
|
||||||
|
import { sharpBmp } from 'sharp-read-bmp';
|
||||||
import { StatusError } from './status-error.js';
|
import { StatusError } from './status-error.js';
|
||||||
import { DownloadConfig, defaultDownloadConfig, downloadUrl } from './download.js';
|
import { DownloadConfig, defaultDownloadConfig, downloadUrl } from './download.js';
|
||||||
import { getAgents } from './http.js';
|
import { getAgents } from './http.js';
|
||||||
|
import _contentDisposition from 'content-disposition';
|
||||||
|
|
||||||
const _filename = fileURLToPath(import.meta.url);
|
const _filename = fileURLToPath(import.meta.url);
|
||||||
const _dirname = dirname(_filename);
|
const _dirname = dirname(_filename);
|
||||||
|
|
||||||
const assets = `${_dirname}/../../server/file/assets/`;
|
const assets = `${_dirname}/../assets/`;
|
||||||
|
|
||||||
export type MediaProxyOptions = {
|
export type MediaProxyOptions = {
|
||||||
['Access-Control-Allow-Origin']?: string;
|
['Access-Control-Allow-Origin']?: string;
|
||||||
@ -73,12 +75,7 @@ export default function (fastify: FastifyInstance, options: MediaProxyOptions |
|
|||||||
const csp = options!['Content-Security-Policy'] ?? `default-src 'none'; img-src 'self'; media-src 'self'; style-src 'unsafe-inline'`;
|
const csp = options!['Content-Security-Policy'] ?? `default-src 'none'; img-src 'self'; media-src 'self'; style-src 'unsafe-inline'`;
|
||||||
|
|
||||||
fastify.addHook('onRequest', (request, reply, done) => {
|
fastify.addHook('onRequest', (request, reply, done) => {
|
||||||
if (corsOrigin === '*') {
|
|
||||||
reply.header('Access-Control-Allow-Origin', request.headers.origin ?? '*');
|
|
||||||
reply.header('Vary', 'Origin');
|
|
||||||
} else {
|
|
||||||
reply.header('Access-Control-Allow-Origin', corsOrigin);
|
reply.header('Access-Control-Allow-Origin', corsOrigin);
|
||||||
}
|
|
||||||
reply.header('Access-Control-Allow-Headers', corsHeader);
|
reply.header('Access-Control-Allow-Headers', corsHeader);
|
||||||
reply.header('Access-Control-Allow-Methods', 'GET, OPTIONS');
|
reply.header('Access-Control-Allow-Methods', 'GET, OPTIONS');
|
||||||
reply.header('Content-Security-Policy', csp);
|
reply.header('Content-Security-Policy', csp);
|
||||||
@ -157,7 +154,7 @@ async function proxyHandler(request: FastifyRequest<{ Params: { url: string; };
|
|||||||
type: file.mime,
|
type: file.mime,
|
||||||
};
|
};
|
||||||
} else {
|
} else {
|
||||||
const data = sharp(file.path, { animated: !('static' in request.query) })
|
const data = (await sharpBmp(file.path, file.mime, { animated: !('static' in request.query) }))
|
||||||
.resize({
|
.resize({
|
||||||
height: 'emoji' in request.query ? 128 : 320,
|
height: 'emoji' in request.query ? 128 : 320,
|
||||||
withoutEnlargement: true,
|
withoutEnlargement: true,
|
||||||
@ -171,11 +168,11 @@ async function proxyHandler(request: FastifyRequest<{ Params: { url: string; };
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
} else if ('static' in request.query) {
|
} else if ('static' in request.query) {
|
||||||
image = convertToWebpStream(file.path, 498, 280);
|
image = convertSharpToWebpStream(await sharpBmp(file.path, file.mime), 498, 280);
|
||||||
} else if ('preview' in request.query) {
|
} else if ('preview' in request.query) {
|
||||||
image = convertToWebpStream(file.path, 200, 200);
|
image = convertSharpToWebpStream(await sharpBmp(file.path, file.mime), 200, 200);
|
||||||
} else if ('badge' in request.query) {
|
} else if ('badge' in request.query) {
|
||||||
const mask = sharp(file.path)
|
const mask = (await sharpBmp(file.path, file.mime))
|
||||||
.resize(96, 96, {
|
.resize(96, 96, {
|
||||||
fit: 'inside',
|
fit: 'inside',
|
||||||
withoutEnlargement: false,
|
withoutEnlargement: false,
|
||||||
@ -206,6 +203,8 @@ async function proxyHandler(request: FastifyRequest<{ Params: { url: string; };
|
|||||||
};
|
};
|
||||||
} else if (file.mime === 'image/svg+xml') {
|
} else if (file.mime === 'image/svg+xml') {
|
||||||
image = convertToWebpStream(file.path, 2048, 2048);
|
image = convertToWebpStream(file.path, 2048, 2048);
|
||||||
|
} else if (!file.mime.startsWith('image/') || !FILE_TYPE_BROWSERSAFE.includes(file.mime)) {
|
||||||
|
throw new StatusError('Rejected type', 403, 'Rejected type');
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!image) {
|
if (!image) {
|
||||||
@ -233,6 +232,12 @@ async function proxyHandler(request: FastifyRequest<{ Params: { url: string; };
|
|||||||
|
|
||||||
reply.header('Content-Type', image.type);
|
reply.header('Content-Type', image.type);
|
||||||
reply.header('Cache-Control', 'max-age=31536000, immutable');
|
reply.header('Cache-Control', 'max-age=31536000, immutable');
|
||||||
|
reply.header('Content-Disposition',
|
||||||
|
contentDisposition(
|
||||||
|
'inline',
|
||||||
|
correctFilename(file.filename, image.ext)
|
||||||
|
)
|
||||||
|
);
|
||||||
return reply.send(image.data);
|
return reply.send(image.data);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
if ('cleanup' in file) file.cleanup();
|
if ('cleanup' in file) file.cleanup();
|
||||||
@ -241,11 +246,11 @@ async function proxyHandler(request: FastifyRequest<{ Params: { url: string; };
|
|||||||
}
|
}
|
||||||
|
|
||||||
async function downloadAndDetectTypeFromUrl(url: string): Promise<
|
async function downloadAndDetectTypeFromUrl(url: string): Promise<
|
||||||
{ state: 'remote'; mime: string; ext: string | null; path: string; cleanup: () => void; }
|
{ state: 'remote'; mime: string; ext: string | null; path: string; cleanup: () => void; filename: string; }
|
||||||
> {
|
> {
|
||||||
const [path, cleanup] = await createTemp();
|
const [path, cleanup] = await createTemp();
|
||||||
try {
|
try {
|
||||||
await downloadUrl(url, path, config);
|
const { filename } = await downloadUrl(url, path, config);
|
||||||
|
|
||||||
const { mime, ext } = await detectType(path);
|
const { mime, ext } = await detectType(path);
|
||||||
|
|
||||||
@ -253,9 +258,29 @@ async function downloadAndDetectTypeFromUrl(url: string): Promise<
|
|||||||
state: 'remote',
|
state: 'remote',
|
||||||
mime, ext,
|
mime, ext,
|
||||||
path, cleanup,
|
path, cleanup,
|
||||||
|
filename: correctFilename(filename, ext),
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
cleanup();
|
cleanup();
|
||||||
throw e;
|
throw e;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function correctFilename(filename: string, ext: string | null) {
|
||||||
|
const dotExt = ext ? `.${ext}` : '.unknown';
|
||||||
|
if (filename.endsWith(dotExt)) {
|
||||||
|
return filename;
|
||||||
|
}
|
||||||
|
if (ext === 'jpg' && filename.endsWith('.jpeg')) {
|
||||||
|
return filename;
|
||||||
|
}
|
||||||
|
if (ext === 'tif' && filename.endsWith('.tiff')) {
|
||||||
|
return filename;
|
||||||
|
}
|
||||||
|
return `${filename}${dotExt}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
function contentDisposition(type: 'inline' | 'attachment', filename: string): string {
|
||||||
|
const fallback = filename.replace(/[^\w.-]/g, '_');
|
||||||
|
return _contentDisposition(filename, { type, fallback });
|
||||||
|
}
|
||||||
|
Reference in New Issue
Block a user