Georg/teddit
1
0
Fork 0
mirror of https://codeberg.org/tacerus/teddit.git synced 2024-11-28 18:49:23 +01:00
Code Issues Projects Releases Wiki Activity

export helper functions from app.js

Browse Source
This commit is contained in:
json 2021-09-02 21:25:03 +01:00
parent 53e4d66f07
commit 69725d54c7
1 changed files with 112 additions and 93 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

205
app.js
View File

@ -1,16 +1,18 @@
const config = require('./config') const config = require('./config');
global.client_id_b64 = Buffer.from(`${config.reddit_app_id}:`).toString('base64') global.client_id_b64 = Buffer.from(`${config.reddit_app_id}:`).toString(
global.reddit_access_token = null 'base64'
global.reddit_refresh_token = null );
global.ratelimit_counts = {} global.reddit_access_token = null;
global.ratelimit_timestamps = {} global.reddit_refresh_token = null;
global.ratelimit_counts = {};
global.ratelimit_timestamps = {};
const pug = require('pug') const pug = require('pug');
const compression = require('compression') const compression = require('compression');
const express = require('express') const express = require('express');
const cookieParser = require('cookie-parser') const cookieParser = require('cookie-parser');
const r = require('redis') const r = require('redis');
const redis = (() => { const redis = (() => {
if (!config.redis_enabled) { if (!config.redis_enabled) {
@ -18,145 +20,162 @@ const redis = (() => {
return { return {
get: (_, callback) => callback(null, null), get: (_, callback) => callback(null, null),
setex: (_, _1, _2, callback) => callback(null), setex: (_, _1, _2, callback) => callback(null),
on: () => {} on: () => {},
} };
} }
const redisOptions = { const redisOptions = {
host: '127.0.0.1', host: '127.0.0.1',
port: 6379 port: 6379,
} };
if (config.redis_db) { if (config.redis_db) {
redisOptions.db = config.redis_db redisOptions.db = config.redis_db;
} }
if (config.redis_host) { if (config.redis_host) {
redisOptions.host = config.redis_host redisOptions.host = config.redis_host;
} }
if (config.redis_port && config.redis_port > 0) { if (config.redis_port && config.redis_port > 0) {
redisOptions.port = config.redis_port redisOptions.port = config.redis_port;
} }
if (config.redis_password) { if (config.redis_password) {
redisOptions.password = config.redis_password redisOptions.password = config.redis_password;
} }
return r.createClient(redisOptions) return r.createClient(redisOptions);
})() })();
const nodeFetch = require('node-fetch') const nodeFetch = require('node-fetch');
const fetch = config.http_proxy const fetch = config.http_proxy
? (() => { ? (() => {
const agent = require('https-proxy-agent')(config.http_proxy) const agent = require('https-proxy-agent')(config.http_proxy);
return (url, options) => { return (url, options) => {
const instanceOptions = { const instanceOptions = {
agent, agent,
...options ...options,
}; };
return nodeFetch(url, instanceOptions); return nodeFetch(url, instanceOptions);
} };
})() })()
: nodeFetch : nodeFetch;
const helmet = require('helmet') const helmet = require('helmet');
const bodyParser = require('body-parser') const bodyParser = require('body-parser');
const fs = require('fs') const fs = require('fs');
const app = express() const app = express();
const request = require('postman-request') const request = require('postman-request');
const commons = require('./inc/commons.js')(request, fs) const commons = require('./inc/commons.js')(request, fs);
const dlAndSave = require('./inc/downloadAndSave.js')(commons); const dlAndSave = require('./inc/downloadAndSave.js')(commons);
['pics/thumbs', 'pics/flairs', 'pics/icons', 'vids'] ['pics/thumbs', 'pics/flairs', 'pics/icons', 'vids']
.map(d => `./static/${d}`) .map((d) => `./static/${d}`)
.filter(d => !fs.existsSync(d)) .filter((d) => !fs.existsSync(d))
.forEach(d => fs.mkdirSync(d, { recursive: true })) .forEach((d) => fs.mkdirSync(d, { recursive: true }));
if(!config.https_enabled && config.redirect_http_to_https) { if (!config.https_enabled && config.redirect_http_to_https) {
console.error(`Cannot redirect HTTP=>HTTPS while "https_enabled" is false.`) console.error(`Cannot redirect HTTP=>HTTPS while "https_enabled" is false.`);
} }
let https = null let https = null;
if(config.https_enabled) { if (config.https_enabled) {
const privateKey = fs.readFileSync(`${config.cert_dir}/privkey.pem`, 'utf8') const privateKey = fs.readFileSync(`${config.cert_dir}/privkey.pem`, 'utf8');
const certificate = fs.readFileSync(`${config.cert_dir}/cert.pem`, 'utf8') const certificate = fs.readFileSync(`${config.cert_dir}/cert.pem`, 'utf8');
const ca = fs.readFileSync(`${config.cert_dir}/chain.pem`, 'utf8') const ca = fs.readFileSync(`${config.cert_dir}/chain.pem`, 'utf8');
const credentials = { const credentials = {
key: privateKey, key: privateKey,
cert: certificate, cert: certificate,
ca: ca ca: ca,
} };
https = require('https').Server(credentials, app) https = require('https').Server(credentials, app);
global.protocol = 'https://' global.protocol = 'https://';
} else { } else {
global.protocol = 'http://' global.protocol = 'http://';
} }
const http = require('http').Server(app) const http = require('http').Server(app);
if(config.redirect_www) { if (config.redirect_www) {
app.use((req, res, next) => { app.use((req, res, next) => {
if(req.headers.host) { if (req.headers.host) {
if(req.headers.host.slice(0, 4) === 'www.') { if (req.headers.host.slice(0, 4) === 'www.') {
let newhost = req.headers.host.slice(4) let newhost = req.headers.host.slice(4);
return res.redirect(301, `${req.protocol}://${newhost}${req.originalUrl}`) return res.redirect(
301,
`${req.protocol}://${newhost}${req.originalUrl}`
);
} }
} }
next() next();
}) });
} }
if(config.use_helmet && config.https_enabled) { if (config.use_helmet && config.https_enabled) {
app.use(helmet()) app.use(helmet());
if(config.use_helmet_hsts) { if (config.use_helmet_hsts) {
app.use(helmet.hsts({ maxAge: 31536000, preload: true })) app.use(helmet.hsts({ maxAge: 31536000, preload: true }));
} }
} }
if(config.use_compression) { if (config.use_compression) {
app.use(compression()) app.use(compression());
} }
app.use(cookieParser()) app.use(cookieParser());
if(config.use_view_cache) { if (config.use_view_cache) {
app.set('view cache', true) app.set('view cache', true);
} }
if(config.trust_proxy) { if (config.trust_proxy) {
app.set('trust proxy', config.trust_proxy_address) app.set('trust proxy', config.trust_proxy_address);
} }
app.use(bodyParser.urlencoded({ extended: true, limit: '10mb' })) app.use(bodyParser.urlencoded({ extended: true, limit: '10mb' }));
app.use(bodyParser.json({ limit: '10mb' })) app.use(bodyParser.json({ limit: '10mb' }));
app.use(express.static(`${__dirname}/static`)) app.use(express.static(`${__dirname}/static`));
app.set('views', './views') app.set('views', './views');
app.set('view engine', 'pug') app.set('view engine', 'pug');
if(config.redirect_http_to_https) { const redditAPI = require('./inc/initRedditApi.js')(fetch);
/*
This is temporary. It's needed for the routes to work.
It can be removed once these functions are made more modular.
*/
module.exports = { redis, fetch, RedditAPI: redditAPI };
const allRoutes = require('./routes/index');
app.use('/', allRoutes);
// The old routes
//require('./routes')(app, redis, fetch, redditAPI);
if (config.redirect_http_to_https) {
app.use((req, res, next) => { app.use((req, res, next) => {
if(req.secure) if (req.secure) next();
next() else res.redirect(`https://${req.headers.host}${req.url}`);
else });
res.redirect(`https://${req.headers.host}${req.url}`)
})
} }
const redditAPI = require('./inc/initRedditApi.js')(fetch)
require('./routes')(app, redis, fetch, redditAPI)
redis.on('error', (error) => { redis.on('error', (error) => {
if(error) { if (error) {
console.error(`Redis error: ${error}`) console.error(`Redis error: ${error}`);
} }
}) });
const cacheControl = require('./cacheControl.js') const cacheControl = require('./cacheControl.js');
cacheControl.removeCacheFiles() cacheControl.removeCacheFiles();
if(config.https_enabled) { if (config.https_enabled) {
https.listen(config.ssl_port, config.listen_address, () => console.log(`Teddit running on https://${config.domain}:${config.ssl_port}`)) https.listen(config.ssl_port, config.listen_address, () =>
console.log(`Teddit running on https://${config.domain}:${config.ssl_port}`)
);
} }
http.listen(config.nonssl_port, config.listen_address, () => console.log(`Teddit running on http://${config.domain}:${config.nonssl_port}`)) http.listen(config.nonssl_port, config.listen_address, () =>
console.log(`Teddit running on http://${config.domain}:${config.nonssl_port}`)
);