waveringana/embedder
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Move middlewear to seperate file, Files can expire

Browse source
This commit is contained in:
anarch3 2022-11-19 07:53:47 -05:00
parent da127b3118
commit 521390fde7
10 changed files with 2044 additions and 375 deletions
Download patch file Download diff file Expand all files Collapse all files

31
.eslintrc.json Normal file
View file

@ -0,0 +1,31 @@
{
"env": {
"node": true,
"commonjs": true,
"es2021": true
},
"extends": "eslint:recommended",
"overrides": [
],
"parserOptions": {
"ecmaVersion": "latest"
},
"rules": {
"indent": [
"error",
"tab"
],
"linebreak-style": [
"error",
"unix"
],
"quotes": [
"error",
"double"
],
"semi": [
"error",
"always"
]
}
}

82
app.js
View file

@ -1,47 +1,51 @@
require('dotenv').config(); require("dotenv").config();
let createError = require('http-errors');
let express = require('express');
let path = require('path');
let cookieParser = require('cookie-parser');
let passport = require('passport');
let session = require('express-session');
let SQLiteStore = require('connect-sqlite3')(session); let express = require("express");
let passport = require("passport");
let session = require("express-session");
let createError = require("http-errors");
let cookieParser = require("cookie-parser");
let SQLiteStore = require("connect-sqlite3")(session);
let indexRouter = require('./routes/index'); let fs = require("fs");
let authRouter = require('./routes/auth'); let path = require("path");
let authRouter = require("./routes/auth");
let indexRouter = require("./routes/index");
let db = require("./db");
let app = express(); let app = express();
app.enable('trust proxy'); app.enable("trust proxy");
// view engine setup // view engine setup
app.set('views', path.join(__dirname, 'views')); app.set("views", path.join(__dirname, "views"));
app.set('view engine', 'ejs'); app.set("view engine", "ejs");
app.use(express.json()); app.use(express.json());
app.use(express.urlencoded({ app.use(express.urlencoded({
extended: false extended: false
})); }));
app.use(cookieParser()); app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public'))); app.use(express.static(path.join(__dirname, "public")));
app.use(express.static(path.join(__dirname, 'public'))); app.use(express.static(path.join(__dirname, "public")));
app.use(session({ app.use(session({
secret: process.env.EBSECRET || 'pleasechangeme', secret: process.env.EBSECRET || "pleasechangeme",
resave: false, resave: false,
saveUninitialized: false, saveUninitialized: false,
store: new SQLiteStore({ store: new SQLiteStore({
db: 'sessions.db', db: "sessions.db",
dir: './var/db' dir: "./var/db"
}) })
})); }));
app.use(passport.authenticate('session')); app.use(passport.authenticate("session"));
app.use('/', indexRouter); app.use("/", indexRouter);
app.use('/', authRouter); app.use("/", authRouter);
app.use('/uploads', express.static('uploads')) app.use("/uploads", express.static("uploads"));
// catch 404 and forward to error handler // catch 404 and forward to error handler
app.use(function(req, res, next) { app.use(function(req, res, next) {
@ -49,15 +53,41 @@ app.use(function(req, res, next) {
}); });
// error handler // error handler
app.use(function(err, req, res, next) { app.use(function(err, req, res) {
// set locals, only providing error in development // set locals, only providing error in development
console.log(err) console.log(err);
res.locals.message = err.message; res.locals.message = err.message;
res.locals.error = req.app.get('env') === 'development' ? err : {}; res.locals.error = req.app.get("env") === "development" ? err : {};
// render the error page // render the error page
res.status(err.status || 500); res.status(err.status || 500);
res.render('error'); res.render("error");
}); });
function prune () {
console.log("Vacuuming database...");
db.run("VACUUM");
db.all("SELECT * FROM media WHERE expire > ?", [Date.now()], (err, rows) => {
console.log("Expired rows: " + rows);
if (err) return console.error(err);
rows.forEach((row) => {
console.log("Deleting " + row.path);
fs.unlink("uploads/" + row.path, (err) => {
if (err) {
if(err.errno == -4058) return; //file doesn't exist
return console.error(err);
}
console.log("Deleted " + row.path);
});
db.run("DELETE FROM media WHERE expire > ?", [Date.now()], (err) => {
if (err) return console.error(err);
console.log("Deleted " + row.path + " from database");
});
});
});
}
setInterval(prune, 1000 * 60 * 30); //prune every 30 minutes
module.exports = app; module.exports = app;

30
db.js
View file

@ -1,33 +1,33 @@
var sqlite3 = require('sqlite3'); const sqlite3 = require("sqlite3");
var mkdirp = require('mkdirp'); const mkdirp = require("mkdirp");
var crypto = require('crypto'); const crypto = require("crypto");
mkdirp.sync('./var/db'); mkdirp.sync("./var/db");
var db = new sqlite3.Database('./var/db/media.db'); let db = new sqlite3.Database("./var/db/media.db");
db.serialize(function() { db.serialize(function() {
// create the database schema for the todos app // create the database schema for the todos app
db.run("CREATE TABLE IF NOT EXISTS users ( \ db.run("CREATE TABLE IF NOT EXISTS users ( \
id INTEGER PRIMARY KEY, \ id INTEGER PRIMARY KEY, \
username TEXT UNIQUE, \ username TEXT UNIQUE, \
hashed_password BLOB, \ hashed_password BLOB, \
salt BLOB \ salt BLOB \
)"); )");
db.run("CREATE TABLE IF NOT EXISTS media ( \ db.run("CREATE TABLE IF NOT EXISTS media ( \
id INTEGER PRIMARY KEY, \ id INTEGER PRIMARY KEY, \
path TEXT NOT NULL, \ path TEXT NOT NULL, \
expire INTEGER \ expire INTEGER \
)"); )");
// create an initial user (username: alice, password: letmein) // create an initial user (username: alice, password: letmein)
var salt = crypto.randomBytes(16); var salt = crypto.randomBytes(16);
db.run('INSERT OR IGNORE INTO users (username, hashed_password, salt) VALUES (?, ?, ?)', [ db.run("INSERT OR IGNORE INTO users (username, hashed_password, salt) VALUES (?, ?, ?)", [
'admin', "admin",
crypto.pbkdf2Sync(process.env.EBPASS || 'changeme', salt, 310000, 32, 'sha256'), crypto.pbkdf2Sync(process.env.EBPASS || "changeme", salt, 310000, 32, "sha256"),
salt salt
]); ]);
}); });
module.exports = db; module.exports = db;

122
middleware.js Normal file
View file

@ -0,0 +1,122 @@
const ffmpeg = require("fluent-ffmpeg");
const ffmpegpath = require("@ffmpeg-installer/ffmpeg").path;
const ffprobepath = require("@ffprobe-installer/ffprobe").path;
ffmpeg.setFfmpegPath(ffmpegpath);
ffmpeg.setFfprobePath(ffprobepath);
const fs = require("fs");
const process = require("process");
let db = require("./db.js");
function extension(str){
let file = str.split("/").pop();
return [file.substr(0,file.lastIndexOf(".")),file.substr(file.lastIndexOf("."),file.length).toLowerCase()];
}
//Checks ShareX key
function checkAuth(req, res, next) {
let auth = process.env.EBAPI_KEY || process.env.EBPASS || "pleaseSetAPI_KEY";
let key = null;
if (req.headers["key"]) {
key = req.headers["key"];
} else {
return res.status(400).send("{success: false, message: \"No key provided\", fix: \"Provide a key\"}");
}
if (auth != key) {
return res.status(401).send("{success: false, message: '\"'Invalid key\", fix: \"Provide a valid key\"}");
}
let shortKey = key.substr(0, 3) + "...";
console.log("Authenicated user with key: " + shortKey);
next();
}
//Converts mp4 to gif and vice versa with ffmpeg
function convert(req, res, next) {
for (let file in req.files) {
let nameAndExtension = extension(req.files[file].originalname);
let oembed = {
type: "video",
version: "1.0",
provider_name: "embedder",
provider_url: "https://github.com/WaveringAna/embedder",
cache_age: 86400,
html: `<iframe src='${req.protocol}://${req.get("host")}/gifv/${nameAndExtension[0]}${nameAndExtension[1]}'></iframe>`,
width: 640,
height: 360
};
fs.writeFile(`uploads/oembed-${nameAndExtension[0]}.json`, JSON.stringify(oembed), function (err) {
if (err) return next(err);
console.log("oembed file created " + nameAndExtension[0] + ".json");
});
if (nameAndExtension[1] == ".mp4") {
console.log("Converting " + nameAndExtension[0] + nameAndExtension[1] + " to gif");
console.log(nameAndExtension[0] + nameAndExtension[1]);
ffmpeg()
.input("uploads/" + req.files[file].originalname)
.inputFormat("mp4")
.outputFormat("gif")
.output("uploads/" + nameAndExtension[0] + ".gif")
.on("end", function() {
console.log("Conversion complete");
console.log("Uploaded to uploads/" + nameAndExtension[0] + ".gif");
})
.on("error", (e) => console.log(e))
.run();
} else if (nameAndExtension[1] == ".gif") {
console.log(`Converting ${nameAndExtension[0]}${nameAndExtension[1]} to mp4`);
ffmpeg("uploads/" + req.files[file].originalname)
.inputFormat("gif")
.outputFormat("mp4")
.outputOptions([
"-pix_fmt yuv420p",
"-c:v libx264",
"-movflags +faststart"
])
.noAudio()
.output(`uploads/${nameAndExtension[0]}.mp4`)
.on("end", function() {
console.log("Conversion complete");
console.log(`Uploaded to uploads/${nameAndExtension[0]}.mp4`);
})
.run();
}
}
next();
}
function handleUpload(req, res, next) {
if (!req.files || Object.keys(req.files).length === 0) {
console.log("No files were uploaded");
return res.status(400).send("No files were uploaded.");
}
for (let file in req.files) {
let currentdate = Date.now();
let expireDate = new Date(currentdate + (req.body.expire * 24 * 60 * 60 * 1000));
console.log(expireDate);
db.run("INSERT INTO media (path, expire) VALUES (?, ?)", [req.files[file].filename, expireDate], function (err) {
if (err) {
console.log(err);
return next(err);
}
console.log("Uploaded " + req.files[file].filename + " to database");
console.log("It will expire in " + req.body.expire + " days");
});
}
next();
}
module.exports = {
checkAuth: checkAuth,
convert: convert,
handleUpload: handleUpload
};

1574
package-lock.json generated
View file

File diff suppressed because it is too large Load diff

3
package.json
View file

@ -39,5 +39,8 @@
"passport": "^0.6.0", "passport": "^0.6.0",
"passport-local": "^1.0.0", "passport-local": "^1.0.0",
"sqlite3": "^5.0.2" "sqlite3": "^5.0.2"
},
"devDependencies": {
"eslint": "^8.28.0"
} }
} }

166
public/js/index.js
View file

@ -1,29 +1,31 @@
/* eslint-env browser: true */
function copyURI(evt) { function copyURI(evt) {
evt.preventDefault(); evt.preventDefault();
navigator.clipboard.writeText(absolutePath(evt.target.getAttribute('src'))).then(() => { navigator.clipboard.writeText(absolutePath(evt.target.getAttribute("src"))).then(() => {
/* clipboard successfully set */ /* clipboard successfully set */
console.log("copied") console.log("copied");
}, () => { }, () => {
/* clipboard write failed */ /* clipboard write failed */
console.log("failed") console.log("failed");
}); });
} }
function copyA(evt) { function copyA(evt) {
evt.preventDefault(); evt.preventDefault();
navigator.clipboard.writeText(absolutePath(evt.target.getAttribute('href'))).then(() => { navigator.clipboard.writeText(absolutePath(evt.target.getAttribute("href"))).then(() => {
console.log("copied"); console.log("copied");
}, () => { }, () => {
console.log("failed"); console.log("failed");
}); });
} }
function copyPath(evt) { function copyPath(evt) {
navigator.clipboard.writeText(absolutePath(evt)).then(() => { navigator.clipboard.writeText(absolutePath(evt)).then(() => {
console.log("copied"); console.log("copied");
}, () => { }, () => {
console.log("failed"); console.log("failed");
}); });
} }
function absolutePath (href) { function absolutePath (href) {
@ -33,99 +35,109 @@ function absolutePath (href) {
} }
function extension(string) { function extension(string) {
return string.slice((string.lastIndexOf(".") - 2 >>> 0) + 2); return string.slice((string.lastIndexOf(".") - 2 >>> 0) + 2);
} }
let dropArea = document.getElementById("dropArea"); let dropArea = document.getElementById("dropArea");
;['dragenter', 'dragover', 'dragleave', 'drop'].forEach(eventName => { ["dragenter", "dragover", "dragleave", "drop"].forEach(eventName => {
dropArea.addEventListener(eventName, preventDefaults, false) dropArea.addEventListener(eventName, preventDefaults, false);
}) });
function preventDefaults (e) { function preventDefaults (e) {
e.preventDefault() e.preventDefault();
e.stopPropagation() e.stopPropagation();
} }
;['dragenter', 'dragover'].forEach(eventName => { ["dragenter", "dragover"].forEach(eventName => {
dropArea.addEventListener(eventName, highlight, false) dropArea.addEventListener(eventName, highlight, false);
}) })
;['dragleave', 'drop'].forEach(eventName => { ;["dragleave", "drop"].forEach(eventName => {
dropArea.addEventListener(eventName, unhighlight, false) dropArea.addEventListener(eventName, unhighlight, false);
}) });
function highlight(e) { function highlight(e) {
dropArea.classList.add('highlight') dropArea.classList.add("highlight");
} }
function unhighlight(e) { function unhighlight(e) {
dropArea.classList.remove('highlight') dropArea.classList.remove("highlight");
} }
dropArea.addEventListener('drop', handleDrop, false) dropArea.addEventListener("drop", handleDrop, false);
window.addEventListener('paste', handlePaste); window.addEventListener("paste", handlePaste);
function handleDrop(e) { function handleDrop(e) {
let dt = e.dataTransfer let dt = e.dataTransfer;
let files = dt.files let files = dt.files;
handleFiles(files) handleFiles(files);
} }
function handlePaste(e) { function handlePaste(e) {
// Get the data of clipboard // Get the data of clipboard
const clipboardItems = e.clipboardData.items; const clipboardItems = e.clipboardData.items;
const items = [].slice.call(clipboardItems).filter(function (item) { const items = [].slice.call(clipboardItems).filter(function (item) {
// Filter the image items only // Filter the image items only
return item.type.indexOf('image') !== -1; return item.type.indexOf("image") !== -1;
}); });
if (items.length === 0) { if (items.length === 0) {
return; return;
} }
const item = items[0]; const item = items[0];
// Get the blob of image // Get the blob of image
const blob = item.getAsFile(); const blob = item.getAsFile();
console.log(blob) console.log(blob);
uploadFile(blob) uploadFile(blob);
previewFile(blob); previewFile(blob);
} }
function handleFiles(files) { function handleFiles(files) {
files = [...files] files = [...files];
files.forEach(uploadFile) files.forEach(uploadFile);
files.forEach(previewFile) files.forEach(previewFile);
} }
function previewFile(file) { function previewFile(file) {
let reader = new FileReader() let reader = new FileReader();
reader.readAsDataURL(file) reader.readAsDataURL(file);
reader.onloadend = function() { reader.onloadend = function() {
let img = document.createElement('img'); let img = document.createElement("img");
img.src = reader.result img.src = reader.result;
img.className = "image"; img.className = "image";
document.getElementById('gallery').appendChild(img) document.getElementById("gallery").appendChild(img);
console.log(document.getElementById('fileupload')) console.log(document.getElementById("fileupload"));
document.getElementById('fileupload').src = img.src; document.getElementById("fileupload").src = img.src;
} };
} }
function uploadFile(file) { function uploadFile(file) {
let xhr = new XMLHttpRequest(); let xhr = new XMLHttpRequest();
let formData = new FormData(); let formData = new FormData();
xhr.open('POST', '/', true); let reader = new FileReader();
xhr.open("POST", "/", true);
xhr.addEventListener('readystatechange', function(e) { xhr.addEventListener("readystatechange", function(e) {
if (xhr.readyState == 4 && xhr.status == 200) { if (xhr.readyState == 4 && xhr.status == 200) {
location.reload(); location.reload();
} }
else if (xhr.readyState == 4 && xhr.status != 200) { else if (xhr.readyState == 4 && xhr.status != 200) {
// Error. Inform the user // Error. Inform the user
} }
}) });
formData.append('fileupload', file); if (file == null || file == undefined) {
xhr.send(formData) //file = reader.readAsDataURL(document.getElementById("fileupload").files[0]);
//file = reader.readAsDataURL(document.querySelector("#fileupload").files[0]);
file = document.querySelector("#fileupload").files[0];
}
formData.append("fileupload", file);
formData.append("expire", document.getElementById("expire").value);
console.log(formData);
xhr.send(formData);
} }

33
routes/auth.js
View file

@ -1,29 +1,30 @@
let express = require('express'); let crypto = require("crypto");
let passport = require('passport'); let express = require("express");
let LocalStrategy = require('passport-local'); let passport = require("passport");
let crypto = require('crypto'); let LocalStrategy = require("passport-local");
let db = require('../db');
let db = require("../db");
let router = express.Router(); let router = express.Router();
passport.use(new LocalStrategy(function verify(username, password, cb) { passport.use(new LocalStrategy(function verify(username, password, cb) {
db.get('SELECT * FROM users WHERE username = ?', [username], function(err, row) { db.get("SELECT * FROM users WHERE username = ?", [username], function(err, row) {
if (err) { if (err) {
return cb(err); return cb(err);
} }
if (!row) { if (!row) {
return cb(null, false, { return cb(null, false, {
message: 'Incorrect username or password.' message: "Incorrect username or password."
}); });
} }
crypto.pbkdf2(password, row.salt, 310000, 32, 'sha256', function(err, hashedPassword) { crypto.pbkdf2(password, row.salt, 310000, 32, "sha256", function(err, hashedPassword) {
if (err) { if (err) {
return cb(err); return cb(err);
} }
if (!crypto.timingSafeEqual(row.hashed_password, hashedPassword)) { if (!crypto.timingSafeEqual(row.hashed_password, hashedPassword)) {
return cb(null, false, { return cb(null, false, {
message: 'Incorrect username or password.' message: "Incorrect username or password."
}); });
} }
return cb(null, row); return cb(null, row);
@ -46,21 +47,21 @@ passport.deserializeUser(function(user, cb) {
}); });
}); });
router.get('/login', function(req, res, next) { router.get("/login", function(req, res) {
res.render('login'); res.render("login");
}); });
router.post('/login/password', passport.authenticate('local', { router.post("/login/password", passport.authenticate("local", {
successRedirect: '/', successRedirect: "/",
failureRedirect: '/login' failureRedirect: "/login"
})); }));
router.post('/logout', function(req, res, next) { router.post("/logout", function(req, res, next) {
req.logout(function(err) { req.logout(function(err) {
if (err) { if (err) {
return next(err); return next(err);
} }
res.redirect('/'); res.redirect("/");
}); });
}); });

366
routes/index.js
View file

@ -1,268 +1,164 @@
let express = require('express'); let multer = require("multer");
let multer = require('multer'); let express = require("express");
let ffmpegpath = require('@ffmpeg-installer/ffmpeg').path; let ffmpeg = require("fluent-ffmpeg");
let ffprobepath = require('@ffprobe-installer/ffprobe').path; let ffmpegpath = require("@ffmpeg-installer/ffmpeg").path;
let ffmpeg = require('fluent-ffmpeg'); let ffprobepath = require("@ffprobe-installer/ffprobe").path;
ffmpeg.setFfmpegPath(ffmpegpath); ffmpeg.setFfmpegPath(ffmpegpath);
ffmpeg.setFfprobePath(ffprobepath); ffmpeg.setFfprobePath(ffprobepath);
let db = require('../db'); let fs = require("fs");
let fs = require('fs');
let db = require("../db");
let {checkAuth, convert, handleUpload} = require("../middleware");
function extension(str){ function extension(str){
let file = str.split('/').pop(); let file = str.split("/").pop();
return [file.substr(0,file.lastIndexOf('.')),file.substr(file.lastIndexOf('.'),file.length).toLowerCase()] return [file.substr(0,file.lastIndexOf(".")),file.substr(file.lastIndexOf("."),file.length).toLowerCase()];
} }
const storage = multer.diskStorage({ const storage = multer.diskStorage({
destination: function (req, file, cb) { destination: function (req, file, cb) {
cb(null, 'uploads/') cb(null, "uploads/");
}, },
filename : function(req, file, cb) { filename : function(req, file, cb) {
let nameAndExtension = extension(file.originalname); let nameAndExtension = extension(file.originalname);
db.all('SELECT * FROM media WHERE path = ?', [nameAndExtension[0] + nameAndExtension[1]], function (err, exists) { db.all("SELECT * FROM media WHERE path = ?", [nameAndExtension[0] + nameAndExtension[1]], function (err, exists) {
if (exists.length != 0) { if (exists.length != 0) {
let suffix = new Date().getTime() / 1000; let suffix = new Date().getTime() / 1000;
if (req.body.title == '' || req.body.title == null || req.body.title == undefined) if (req.body.title == "" || req.body.title == null || req.body.title == undefined)
cb(null, nameAndExtension[0] + '-' + suffix + nameAndExtension[1]) cb(null, nameAndExtension[0] + "-" + suffix + nameAndExtension[1]);
else else
cb(null, req.body.title + '-' + suffix + nameAndExtension[1]) cb(null, req.body.title + "-" + suffix + nameAndExtension[1]);
} else { } else {
if (req.body.title == '' || req.body.title == null || req.body.title == undefined) if (req.body.title == "" || req.body.title == null || req.body.title == undefined)
cb(null, nameAndExtension[0] + nameAndExtension[1]) cb(null, nameAndExtension[0] + nameAndExtension[1]);
else else
cb(null, req.body.title + nameAndExtension[1]) cb(null, req.body.title + nameAndExtension[1]);
} }
}) });
} }
}); });
let allowedMimeTypes = [ /**let allowedMimeTypes = [
'image/png', "image/png",
'image/jpg', "image/jpg",
'image/jpeg', "image/jpeg",
'image/gif', "image/gif",
'image/webp', "image/webp",
'video/mp4', "video/mp4",
'video/mov', "video/mov",
'video/webm', "video/webm",
'audio/mpeg', "audio/mpeg",
'audio/ogg' "audio/ogg"
] ];
const fileFilter = function(req, file, cb) { const fileFilter = function(req, file, cb) {
if (allowedMimeTypes.includes(file.mimetype)) { if (allowedMimeTypes.includes(file.mimetype)) {
cb(null, true); cb(null, true);
} else { } else {
cb(null, false); cb(null, false);
} }
} };**/
let upload = multer({ storage: storage /**, fileFilter: fileFilter**/ }); //maybe make this a env variable? let upload = multer({ storage: storage /**, fileFilter: fileFilter**/ }); //maybe make this a env variable?
function fetchMedia(req, res, next) { function fetchMedia(req, res, next) {
db.all('SELECT * FROM media', (err, rows) => { db.all("SELECT * FROM media", (err, rows) => {
if (err) return next(err); if (err) return next(err);
let files = rows.map((row)=> { let files = rows.map((row)=> {
return { return {
id: row.id, id: row.id,
path: row.path, path: row.path,
expire: row.expire, expire: row.expire,
url: '/' + row.id url: "/" + row.id
} };
}); });
res.locals.files = files.reverse(); //reverse so newest files appear first res.locals.files = files.reverse(); //reverse so newest files appear first
res.locals.Count = files.length; res.locals.Count = files.length;
next(); next();
}); });
} }
//middleware
//Checks ShareX key
function checkAuth(req, res, next) {
let auth = process.env.EBAPI_KEY || process.env.EBPASS || 'pleaseSetAPI_KEY';
let key = null;
if (req.headers['key']) {
key = req.headers['key'];
} else {
return res.status(400).send('{success: false, message: "No key provided", fix: "Provide a key"}');
}
if (auth != key) {
return res.status(401).send('{success: false, message: "Invalid key", fix: "Provide a valid key"}');
}
shortKey = key.substr(0, 3) + '...';
console.log('Authenicated user with key: ' + shortKey);
next();
}
//Converts mp4 to gif and vice versa with ffmpeg
function convert(req, res, next) {
for (file in req.files) {
let nameAndExtension = extension(req.files[file].originalname);
let oembed = {
type: "video",
version: "1.0",
provider_name: "embedder",
provider_url: "https://github.com/WaveringAna/embedder",
cache_age: 86400,
html: "<iframe src='" + req.protocol + "://" + req.get('host') + "/gifv/" + nameAndExtension[0] + "'></iframe>",
width: 640,
height: 360
};
fs.writeFile('uploads/oembed-' + nameAndExtension[0] + '.json', JSON.stringify(oembed), function (err) {
if (err) return next(err);
console.log('oembed file created ' + nameAndExtension[0] + '.json');
});
if (nameAndExtension[1] == '.mp4') {
console.log('Converting ' + nameAndExtension[0] + nameAndExtension[1] + ' to gif');
console.log(nameAndExtension[0] + nameAndExtension[1]);
ffmpeg()
.input('uploads/' + req.files[file].originalname)
.inputFormat('mp4')
.outputFormat('gif')
.output('uploads/' + nameAndExtension[0] + '.gif')
.on('end', function() {
console.log('Conversion complete');
console.log('Uploaded to uploads/' + nameAndExtension[0] + '.gif');
})
.on('error', (e) => console.log(e))
.run();
} else if (nameAndExtension[1] == '.gif') {
console.log('Converting ' + nameAndExtension[0] + nameAndExtension[1] + ' to mp4');
ffmpeg('uploads/' + req.files[file].originalname)
.inputFormat('gif')
.outputFormat('mp4')
.outputOptions([
'-pix_fmt yuv420p',
'-c:v libx264',
'-movflags +faststart'
])
.noAudio()
.output('uploads/' + nameAndExtension[0] + '.mp4')
.on('end', function() {
console.log('Conversion complete');
console.log('Uploaded to uploads/' + nameAndExtension[0] + '.mp4');
})
.run();
}
}
next();
};
let router = express.Router(); let router = express.Router();
router.get('/', function (req, res, next) { router.get("/", function (req, res, next) {
if (!req.user) { return res.render('home'); } if (!req.user) { return res.render("home"); }
next(); next();
}, fetchMedia, function(req, res, next) { }, fetchMedia, function(req, res) {
res.locals.filter = null; res.locals.filter = null;
res.render('index', { user: req.user }); res.render("index", { user: req.user });
}); });
router.get('/gifv/:file', function (req, res, next) { router.get("/gifv/:file", function (req, res, next) {
let url = req.protocol + '://' + req.get('host') + '/uploads/' + req.params.file; let url = req.protocol + "://" + req.get("host") + "/uploads/" + req.params.file;
let width; let height; let width; let height;
nameAndExtension = extension('uploads/' + req.params.file); let nameAndExtension = extension("uploads/" + req.params.file);
if (nameAndExtension[1] == '.mp4') { if (nameAndExtension[1] == ".mp4") {
ffmpeg() ffmpeg()
.input('uploads/' + req.params.file) .input("uploads/" + req.params.file)
.inputFormat('mp4') .inputFormat("mp4")
.ffprobe(function(err, data) { .ffprobe(function(err, data) {
if (err) return next(err); if (err) return next(err);
width = data.streams[0].width; width = data.streams[0].width;
height = data.streams[0].height; height = data.streams[0].height;
console.log(width + 'x' + height); console.log(width + "x" + height);
return res.render('gifv', { url: url, host: req.protocol + '://' + req.get('host'), width: width, height: height }); return res.render("gifv", { url: url, host: req.protocol + "://" + req.get("host"), width: width, height: height });
}); });
} else if (nameAndExtension[1] == '.gif') { } else if (nameAndExtension[1] == ".gif") {
ffmpeg() ffmpeg()
.input('uploads/' + req.params.file) .input("uploads/" + req.params.file)
.inputFormat('gif') .inputFormat("gif")
.ffprobe(function(err, data) { .ffprobe(function(err, data) {
if (err) return next(err); if (err) return next(err);
width = data.streams[0].width; width = data.streams[0].width;
height = data.streams[0].height; height = data.streams[0].height;
console.log(width + 'x' + height); console.log(width + "x" + height);
return res.render('gifv', { url: url, host: req.protocol + '://' + req.get('host'), width: width, height: height }); return res.render("gifv", { url: url, host: req.protocol + "://" + req.get("host"), width: width, height: height });
}); });
} }
}); });
router.post('/', [upload.array('fileupload'), convert], function(req, res, next) { router.post("/", [upload.array("fileupload"), convert, handleUpload], function(req, res) {
if (!req.files || Object.keys(req.files).length === 0) { return res.redirect("/");
console.log(req)
return res.status(400).send('No files were uploaded.');
}
for (file in req.files) {
db.run('INSERT INTO media (path) VALUES (?)', [req.files[file].filename], function (err) {
if (err) {
console.log(err);
return next(err);
}
return res.redirect('/');
})
}
}); });
router.post('/sharex', [checkAuth, upload.array('fileupload')], function(req, res, next) { router.post("/sharex", [checkAuth, upload.array("fileupload"), convert, handleUpload], function(req, res) {
if (!req.files || Object.keys(req.files).length === 0) { return res.send(`${req.protocol}://${req.get("host")}/uploads/${req.files[0].filename}`);
console.log(req);
return res.status(400).send('No files were uploaded.');
}
for (file in req.files) {
db.run('INSERT INTO media (path) VALUES (?)', [req.files[file].filename], function (err) {
if (err) {
console.log(err);
return next(err);
}
console.log(req.protocol + '://' + req.get('host') + '/uploads/' + req.files[file].filename);
return res.send(req.protocol + '://' + req.get('host') + '/uploads/' + req.files[file].filename);
});
}
}); });
router.post('/:id(\\d+)/delete', function(req, res, next) { router.post("/:id(\\d+)/delete", function(req, res, next) {
db.all('SELECT path FROM media WHERE id = ?', [ req.params.id ], function(err, path) { db.all("SELECT path FROM media WHERE id = ?", [ req.params.id ], function(err, path) {
if (err) { return next(err); } if (err) { return next(err); }
fs.unlink('uploads/' + path[0].path, (err => { fs.unlink("uploads/" + path[0].path, (err => {
if (err) { if (err) {
console.log(err) console.log(err);
if (err.errno = -4058) { //File just doesnt exist anymore if (err.errno == -4058) { //File just doesnt exist anymore
db.run('DELETE FROM media WHERE id = ?', [ db.run("DELETE FROM media WHERE id = ?", [
req.params.id req.params.id
], function(err) { ], function(err) {
if (err) { return next(err); } if (err) { return next(err); }
return res.redirect('/'); return res.redirect("/");
}); });
} else { } else {
console.log(err) console.log(err);
return res.redirect('/'); return res.redirect("/");
} }
} }
else { else {
console.log(`Deleted ${path}`); console.log(`Deleted ${path}`);
//Callback Hell :D //Callback Hell :D
db.run('DELETE FROM media WHERE id = ?', [ db.run("DELETE FROM media WHERE id = ?", [
req.params.id req.params.id
], function(err) { ], function(err) {
if (err) { return next(err); } if (err) { return next(err); }
return res.redirect('/'); return res.redirect("/");
}); });
} }
})); }));
}); });
}); });
module.exports = router; module.exports = router;

12
views/index.ejs
View file

@ -32,11 +32,19 @@ return string.slice((string.lastIndexOf(".") - 2 >>> 0) + 2);
<header class="header"> <header class="header">
<h1>Embedder</h1> <h1>Embedder</h1>
<form action="/" method="post" encType="multipart/form-data"> <form action="/" method="post" encType="multipart/form-data">
<!---->
<div id="dropArea"> <div id="dropArea">
<p class="dragregion">Upload a file, copy paste, or drag n' drop into the dashed region</p> <p class="dragregion">Upload a file, copy paste, or drag n' drop into the dashed region</p>
<div id="gallery"></div> <div id="gallery"></div>
<p class="dragregion"><input class="" type="file" id="fileupload" name="fileupload"><input type="submit" value="Upload"></p> <p class="dragregion"><input class="" type="file" id="fileupload" name="fileupload"><input type="button" value="Upload" id="submit" onclick="uploadFile()"></p>
<br>
<br>
<p class="dragregion">Select file expiration date: <select name="expire" id="expire">
<option value="1">1 day</option>
<option value="7">7 days</option>
<option value="14">14 days</option>
<option value="30">30 days</option>
<option value="">never</option>
</select></p>
<p class="dragregion">Click the file to copy the url</p> <p class="dragregion">Click the file to copy the url</p>
</div> </div>
</form> </form>