@ -3,8 +3,8 @@ const escape = require('escape-html');
const fetch = require ( 'node-fetch' ) ; const fetch = require ( 'node-fetch' ) ;
const { deleteS3 } = require ( '../storage' ) ; const { deleteS3 } = require ( '../storage' ) ;
const { diskFilePath , s3enabled } = require ( '../config.json' ) ; const { diskFilePath , s3enabled } = require ( '../config.json' ) ;
const { path , saveData, log, getTrueHttp , getTrueDomain , formatBytes , formatTimestamp , getS3url , getDirectUrl , getSafeExt , getResourceColor , replaceholder } = require ( '../utils' ) ; const { path , , getTrueHttp , getTrueDomain , formatBytes , formatTimestamp , getS3url , getDirectUrl , getSafeExt , getResourceColor , replaceholder } = require ( '../utils' ) ;
const { CODE _ BAD_REQUEST , CODE _ UNAUTHORIZED, CODE _NOT _FOUND , } = require ( '../MagicNumbers.json' ) ; const { CODE _ UNAUTHORIZED, CODE _NOT _FOUND , } = require ( '../MagicNumbers.json' ) ;
const data = require ( '../data' ) ; const data = require ( '../data' ) ;
const users = require ( '../auth' ) ; const users = require ( '../auth' ) ;
@ -14,16 +14,17 @@ const router = express.Router();
// Middleware for parsing the resource ID and handling 404
// Middleware for parsing the resource ID and handling 404
router . use ( ( req , res , next ) => { router . use ( ( req , res , next ) => {
// Parse the resource ID
// Parse the resource ID
req . ass = { resourceId : escape ( req . resourceId ) . split ( '.' ) [ 0 ] } ;
req . ass = { resourceId : escape ( req . resourceId || '' ) . split ( '.' ) [ 0 ] } ;
// If the ID is invalid, return 404. Otherwise, continue normally // skipcq: JS-0093
// If the ID is invalid, return 404. Otherwise, continue normally
( ! req . ass . resourceId || ! data [ req . ass . resourceId ] ) ? res . sendStatus ( CODE _NOT _FOUND ) : next ( ) ;
data . has ( req . ass . resourceId )
. then ( ( has ) => has ? next ( ) : res . sendStatus ( CODE _NOT _FOUND ) )
. catch ( next ) ;
} ) ; } ) ;
// View file
// View file
router . get ( '/' , ( req , res => { router . get ( '/' , ( req , res , next ) => data . get ( req . ass . resourceId ) . then ( ( fileData ) => {
const { resourceId } = req . ass ;
const { resourceId } = req . ass ;
const fileData = data [ resourceId ] ;
const isVideo = fileData . mimetype . includes ( 'video' ) ;
const isVideo = fileData . mimetype . includes ( 'video' ) ;
// Build OpenGraph meta tags
// Build OpenGraph meta tags
@ -47,15 +48,12 @@ router.get('/', (req, res) => {
oembedUrl : ` ${ getTrueHttp ( ) } ${ getTrueDomain ( ) } / ${ resourceId } /oembed ` ,
oembedUrl : ` ${ getTrueHttp ( ) } ${ getTrueDomain ( ) } / ${ resourceId } /oembed ` ,
ogtype : isVideo ? 'video.other' : 'image' ,
ogtype : isVideo ? 'video.other' : 'image' ,
urlType : ` og: ${ isVideo ? 'video' : 'image' } ` ,
urlType : ` og: ${ isVideo ? 'video' : 'image' } ` ,
opengraph : replaceholder ( ogs . join ( '\n' ) , fileData
opengraph : replaceholder ( ogs . join ( '\n' ) , fileData .size , fileData . timestamp , fileData . originalname )
} ) ;
} ) ;
} ) } ) .catch ( next ) ) ;
// Direct resource
// Direct resource
router . get ( '/direct*' , ( req , res ) => { router . get ( '/direct*' , ( req , res , next ) => data . get ( req . ass . resourceId ) . then ( ( fileData ) => {
const { resourceId } = req . ass ;
const fileData = data [ resourceId ] ;
// Send file as an attachement for downloads
// Send file as an attachement for downloads
if ( req . query . download )
if ( req . query . download )
res . header ( 'Content-Disposition' , ` attachment; filename=" ${ fileData . originalname } " ` ) ;
res . header ( 'Content-Disposition' , ` attachment; filename=" ${ fileData . originalname } " ` ) ;
@ -73,58 +71,52 @@ router.get('/direct*', (req, res) => {
} ;
} ;
uploaders [ s3enabled ? 's3' : 'local' ] ( ) ;
uploaders [ s3enabled ? 's3' : 'local' ] ( ) ;
} ) } ) .catch ( next ) ) ;
// Thumbnail response
// Thumbnail response
router . get ( '/thumbnail' , ( req , res ) => { router . get ( '/thumbnail' , ( req , res , next ) =>
const { resourceId } = req . ass ;
data . get ( req . ass . resourceId )
. then ( ( { thumbnail } ) => fs . readFile ( path ( diskFilePath , 'thumbnails/' , thumbnail ) ) )
// Read the file and send it to the client
fs . readFile ( path ( diskFilePath , 'thumbnails/' , data [ resourceId ] . thumbnail ) )
. then ( ( fileData ) => res . type ( 'jpg' ) . send ( fileData ) )
. then ( ( fileData ) => res . type ( 'jpg' ) . send ( fileData ) )
. catch ( console . error ) ;
. catch ( next ) ) ;
} ) ;
// oEmbed response for clickable authors/providers
// oEmbed response for clickable authors/providers
// https://oembed.com/
// https://oembed.com/
// https://old.reddit.com/r/discordapp/comments/82p8i6/a_basic_tutorial_on_how_to_get_the_most_out_of/
// https://old.reddit.com/r/discordapp/comments/82p8i6/a_basic_tutorial_on_how_to_get_the_most_out_of/
router . get ( '/oembed' , ( req , res ) => { router . get ( '/oembed' , ( req , res , next ) =>
const { resourceId } = req . ass ;
data . get ( req . ass . resourceId )
. then ( ( { opengraph , mimetype , size , timestamp , originalname } ) =>
// Build the oEmbed object & send the response
res . type ( 'json' ) . send ( {
const { opengraph , mimetype } = data [ resourceId ] ;
version : '1.0' ,
res . type ( 'json' ) . send ( {
type : mimetype . includes ( 'video' ) ? 'video' : 'photo' ,
version : '1.0' ,
author _url : opengraph . authorUrl ,
type : mimetype . includes ( 'video' ) ? 'video' : 'photo' ,
provider _url : opengraph . providerUrl ,
author _url : opengraph . authorUrl ,
author _name : replaceholder ( opengraph . author || '' , size , timestamp , originalname ) ,
provider _url : opengraph . providerUrl ,
provider _name : replaceholder ( opengraph . provider || '' , size , timestamp , originalname )
author _name : replaceholder ( opengraph . author || '' , data [ resourceId ] ) ,
} ) )
provider _name : replaceholder ( opengraph . provider || '' , data [ resourceId ] )
. catch ( next ) ) ;
} ) ;
} ) ;
// Delete file
// Delete file
router . get ( '/delete/:deleteId' , ( req , res ) => { router . get ( '/delete/:deleteId' , ( req , res , next ) => {
const { resourceId } = req . ass ;
let oldName , oldType ;
const deleteId = escape ( req . params . deleteId ) ;
data . get ( req . ass . resourceId )
const fileData = data [ resourceId ] ;
. then ( ( fileData ) => {
// Extract info for logs
// If the delete ID doesn't match, don't delete the file
oldName = fileData . originalname ;
if ( deleteId !== fileData . deleteId ) return res . sendStatus ( CODE _UNAUTHORIZED ) ;
oldType = fileData . mimetype ;
// If the ID is invalid, return 400 because we are unable to process the resource
// Clean deleteId
if ( ! resourceId || ! fileData ) return res . sendStatus ( CODE _BAD _REQUEST ) ;
const deleteId = escape ( req . params . deleteId ) ;
log ( ` Deleted: ${ fileData . originalname } ( ${ fileData . mimetype } ) ` ) ;
// If the delete ID doesn't match, don't delete the file
if ( deleteId !== fileData . deleteId ) return res . sendStatus ( CODE _UNAUTHORIZED ) ;
// Save the file information
Promise . all ( [ s3enabled ? deleteS3 ( fileData ) : fs . rmSync ( path ( fileData . path ) ) , fs . rmSync ( path ( diskFilePath , 'thumbnails/' , fileData . thumbnail ) ) ] )
// Save the file information
. then ( ( ) => {
return Promise . all ( [ s3enabled ? deleteS3 ( fileData ) : fs . rmSync ( path ( fileData . path ) ) , fs . rmSync ( path ( diskFilePath , 'thumbnails/' , fileData . thumbnail ) ) ] ) ;
delete data [ resourceId ] ;
saveData ( data ) ;
res . type ( 'text' ) . send ( 'File has been deleted!' ) ;
} )
} )
. catch ( console . error ) ;
. then ( ( ) => data . del ( req . ass . resourceId ) )
. then ( ( ) => ( log ( ` Deleted: ${ oldName } ( ${ oldType } ) ` ) , res . type ( 'text' ) . send ( 'File has been deleted!' ) ) )
. catch ( next ) ;
} ) ; } ) ;
module . exports = router ; module . exports = router ;
tycrek
3 years ago