summary refs log tree commit diff
path: root/cdn/src/util/FileStorage.ts
diff options
context:
space:
mode:
Diffstat (limited to 'cdn/src/util/FileStorage.ts')
-rw-r--r--cdn/src/util/FileStorage.ts51
1 files changed, 0 insertions, 51 deletions
diff --git a/cdn/src/util/FileStorage.ts b/cdn/src/util/FileStorage.ts
deleted file mode 100644

index aee9d345..00000000 --- a/cdn/src/util/FileStorage.ts +++ /dev/null
@@ -1,51 +0,0 @@ -import { Storage } from "./Storage"; -import fs from "fs"; -import { join, relative, dirname } from "path"; -import { Readable } from "stream"; -//import ExifTransformer = require("exif-be-gone"); -import ExifTransformer from "exif-be-gone"; - -// TODO: split stored files into separate folders named after cloned route - -function getPath(path: string) { - // STORAGE_LOCATION has a default value in start.ts - const root = process.env.STORAGE_LOCATION || "../"; - let filename = join(root, path); - - if (path.indexOf("\0") !== -1 || !filename.startsWith(root)) - throw new Error("invalid path"); - return filename; -} - -export class FileStorage implements Storage { - async get(path: string): Promise<Buffer | null> { - path = getPath(path); - try { - return fs.readFileSync(path); - } catch (error) { - try { - const files = fs.readdirSync(path); - if (!files.length) return null; - return fs.readFileSync(join(path, files[0])); - } catch (error) { - return null; - } - } - } - - async set(path: string, value: any) { - path = getPath(path); - //fse.ensureDirSync(dirname(path)); - fs.mkdirSync(dirname(path), {recursive: true}); - - value = Readable.from(value); - const cleaned_file = fs.createWriteStream(path); - - return value.pipe(new ExifTransformer()).pipe(cleaned_file); - } - - async delete(path: string) { - //TODO we should delete the parent directory if empty - fs.unlinkSync(getPath(path)); - } -}