X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fhelpers%2Futils.ts;h=5a4fe4fdd5b27f13228b13539ab6e4d0e9bd96d6;hb=c56dd2807fe5d129907b9bf8c42656a8314d754b;hp=0ebbf48a866eaafe33c89b0fbe3c05edfee7ccc8;hpb=404b54e14f6623c1644a8c87ca22f4bab98d5484;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/helpers/utils.ts b/server/helpers/utils.ts index 0ebbf48a8..5a4fe4fdd 100644 --- a/server/helpers/utils.ts +++ b/server/helpers/utils.ts @@ -1,93 +1,70 @@ -import * as express from 'express' -import * as Sequelize from 'sequelize' - -import { pseudoRandomBytesPromise } from './core-utils' -import { CONFIG, database as db } from '../initializers' -import { ResultList } from '../../shared' -import { VideoResolution } from '../../shared/models/videos/video-resolution.enum' - -function badRequest (req: express.Request, res: express.Response, next: express.NextFunction) { - return res.type('json').status(400).end() +import { remove } from 'fs-extra' +import { Instance as ParseTorrent } from 'parse-torrent' +import { join } from 'path' +import { sha256 } from '@shared/extra-utils' +import { ResultList } from '@shared/models' +import { CONFIG } from '../initializers/config' +import { randomBytesPromise } from './core-utils' +import { logger } from './logger' + +function deleteFileAndCatch (path: string) { + remove(path) + .catch(err => logger.error('Cannot delete the file %s asynchronously.', path, { err })) } async function generateRandomString (size: number) { - const raw = await pseudoRandomBytesPromise(size) + const raw = await randomBytesPromise(size) return raw.toString('hex') } -interface FormattableToJSON { - toFormattedJSON () +interface FormattableToJSON { + toFormattedJSON (args?: U): V } -function getFormattedObjects (objects: T[], objectsTotal: number) { - const formattedObjects: U[] = [] - - objects.forEach(object => { - formattedObjects.push(object.toFormattedJSON()) - }) +function getFormattedObjects> (objects: T[], objectsTotal: number, formattedArg?: U) { + const formattedObjects = objects.map(o => o.toFormattedJSON(formattedArg)) - const res: ResultList = { + return { total: objectsTotal, data: formattedObjects - } - - return res + } as ResultList } -async function isSignupAllowed () { - if (CONFIG.SIGNUP.ENABLED === false) { - return false - } - - // No limit and signup is enabled - if (CONFIG.SIGNUP.LIMIT === -1) { - return true - } +function generateVideoImportTmpPath (target: string | ParseTorrent, extension = '.mp4') { + const id = typeof target === 'string' + ? target + : target.infoHash - const totalUsers = await db.User.countTotal() - - return totalUsers < CONFIG.SIGNUP.LIMIT + const hash = sha256(id) + return join(CONFIG.STORAGE.TMP_DIR, `${hash}-import${extension}`) } -function computeResolutionsToTranscode (videoFileHeight: number) { - const resolutionsEnabled: number[] = [] - const configResolutions = CONFIG.TRANSCODING.RESOLUTIONS +function getSecureTorrentName (originalName: string) { + return sha256(originalName) + '.torrent' +} - const resolutions = [ - VideoResolution.H_240P, - VideoResolution.H_360P, - VideoResolution.H_480P, - VideoResolution.H_720P, - VideoResolution.H_1080P - ] +/** + * From a filename like "ede4cba5-742b-46fa-a388-9a6eb3a3aeb3.mp4", returns + * only the "ede4cba5-742b-46fa-a388-9a6eb3a3aeb3" part. If the filename does + * not contain a UUID, returns null. + */ +function getUUIDFromFilename (filename: string) { + const regex = /[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}/ + const result = filename.match(regex) - for (const resolution of resolutions) { - if (configResolutions[resolution.toString()] === true && videoFileHeight > resolution) { - resolutionsEnabled.push(resolution) - } - } + if (!result || Array.isArray(result) === false) return null - return resolutionsEnabled + return result[0] } -function resetSequelizeInstance (instance: Sequelize.Instance, savedFields: object) { - Object.keys(savedFields).forEach(key => { - const value = savedFields[key] - instance.set(key, value) - }) -} - -type SortType = { sortModel: any, sortValue: string } - // --------------------------------------------------------------------------- export { - badRequest, + deleteFileAndCatch, generateRandomString, getFormattedObjects, - isSignupAllowed, - computeResolutionsToTranscode, - resetSequelizeInstance, - SortType + getSecureTorrentName, + generateVideoImportTmpPath, + getUUIDFromFilename }