misskey-dev/media-proxy
1
0
Fork 0
mirror of https://github.com/misskey-dev/media-proxy.git synced 2025-04-29 02:47:26 +09:00
Code Issues Packages Projects Releases Wiki Activity

Better garbage collection?

Browse Source
This commit is contained in:
tamaina 2023-02-07 14:58:25 +00:00
parent 9b1da926e1
commit 0e741f928c
3 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
built/index.js
View File

@ -158,8 +158,12 @@ async function proxyHandler(request, reply) {
if ('cleanup' in file) { if ('cleanup' in file) {
if ('pipe' in image.data && typeof image.data.pipe === 'function') { if ('pipe' in image.data && typeof image.data.pipe === 'function') {
// image.dataがstreamなら、stream終了後にcleanup // image.dataがstreamなら、stream終了後にcleanup
image.data.on('end', file.cleanup); const cleanup = () => {
image.data.on('close', file.cleanup); file.cleanup();
image = null;
};
image.data.on('end', cleanup);
image.data.on('close', cleanup);
} }
else { else {
// image.dataがstreamでないなら直ちにcleanup // image.dataがstreamでないなら直ちにcleanup

2
package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "misskey-media-proxy", "name": "misskey-media-proxy",
"version": "0.0.5", "version": "0.0.6",
"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.26.0",

8
src/index.ts
View File

@ -204,8 +204,12 @@ async function proxyHandler(request: FastifyRequest<{ Params: { url: string; };
if ('cleanup' in file) { if ('cleanup' in file) {
if ('pipe' in image.data && typeof image.data.pipe === 'function') { if ('pipe' in image.data && typeof image.data.pipe === 'function') {
// image.dataがstreamなら、stream終了後にcleanup // image.dataがstreamなら、stream終了後にcleanup
image.data.on('end', file.cleanup); const cleanup = () => {
image.data.on('close', file.cleanup); file.cleanup();
image = null;
}
image.data.on('end', cleanup);
image.data.on('close', cleanup);
} else { } else {
// image.dataがstreamでないなら直ちにcleanup // image.dataがstreamでないなら直ちにcleanup
file.cleanup(); file.cleanup();