[WIP] ass 0.15.0

.gitignore

@@ -1,107 +1,9 @@
-# Logs
-logs
-*.log
-npm-debug.log*
-yarn-debug.log*
-yarn-error.log*
-lerna-debug.log*
-
-# Diagnostic reports (https://nodejs.org/api/report.html)
-report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
-
-# Runtime data
-pids
-*.pid
-*.seed
-*.pid.lock
-
-# Directory for instrumented libs generated by jscoverage/JSCover
-lib-cov
-
-# Coverage directory used by tools like istanbul
-coverage
-*.lcov
-
-# nyc test coverage
-.nyc_output
-
-# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
-.grunt
-
-# Bower dependency directory (https://bower.io/)
-bower_components
-
-# node-waf configuration
-.lock-wscript
-
-# Compiled binary addons (https://nodejs.org/api/addons.html)
-build/Release
-
 # Dependency directories
 node_modules/
 jspm_packages/
 
-# TypeScript v1 declaration files
-typings/
-
-# TypeScript cache
-*.tsbuildinfo
-
-# Optional npm cache directory
-.npm
-
-# Optional eslint cache
-.eslintcache
-
-# Microbundle cache
-.rpt2_cache/
-.rts2_cache_cjs/
-.rts2_cache_es/
-.rts2_cache_umd/
-
-# Optional REPL history
-.node_repl_history
-
-# Output of 'npm pack'
-*.tgz
-
-# Yarn Integrity file
-.yarn-integrity
-
-# dotenv environment variables file
-.env
-.env.test
-
-# parcel-bundler cache (https://parceljs.org/)
-.cache
-
-# Next.js build output
-.next
-
-# Nuxt.js build / generate output
-.nuxt
-dist
-
-# Gatsby files
-.cache/
-# Comment in the public line in if your project uses Gatsby and *not* Next.js
-# https://nextjs.org/blog/next-9-1#public-directory-support
-# public
-
-# vuepress build output
-.vuepress/dist
-
-# Serverless directories
-.serverless/
-
-# FuseBox cache
-.fusebox/
-
-# DynamoDB Local files
-.dynamodb/
-
-# TernJS port file
-.tern-port
+# build dirs
+dist*/
 
 # tokens
 auth.json*
@@ -115,9 +17,7 @@ uploads/
 
 # config
 config.json
-
-# certificates
-*.crt
+userconfig.json
 
 # share/ directory
 share/

backend/UserConfig.ts

@@ -0,0 +1,104 @@
+import fs from 'fs-extra';
+import { path } from '@tycrek/joint';
+import { UserConfiguration, UserConfigTypeChecker } from 'ass';
+import { log } from './log';
+
+/**
+ * Returns a boolean if the provided value is a number
+ */
+const numChecker = (val: any) => {
+	try { return !isNaN(parseInt(val)) && typeof val !== 'string'; }
+	catch (err) { return false; }
+}
+
+/**
+ * User-config property type checker functions
+ */
+const Checkers: UserConfigTypeChecker = {
+	uploadsDir: (val) => {
+		try { fs.accessSync(val); return true; }
+		catch (err) { return false; }
+	},
+	idType: (val) => {
+		const options = ['random', 'original', 'gfycat', 'timestamp', 'zws'];
+		return options.includes(val);
+	},
+	idSize: numChecker,
+	gfySize: numChecker,
+	maximumFileSize: numChecker,
+}
+
+export class UserConfig {
+	private static _config: UserConfiguration;
+	private static _ready = false;
+
+	public static get config() { return UserConfig._config; }
+	public static get ready() { return UserConfig._ready; }
+
+	constructor(config?: any) {
+		// Typically this would only happen during first-time setup (for now)
+		if (config != null) {
+			UserConfig._config = UserConfig.parseConfig(config);
+			UserConfig._ready = true;
+		}
+	}
+
+	/**
+	 * Ensures that all config options are valid
+	 */
+	private static parseConfig(c: any) {
+		const config = (typeof c === 'string' ? JSON.parse(c) : c) as UserConfiguration;
+
+		if (!Checkers.uploadsDir(config.uploadsDir)) throw new Error(`Unable to access uploads directory: ${config.uploadsDir}`);
+		if (!Checkers.idType(config.idType)) throw new Error(`Invalid ID type: ${config.idType}`);
+		if (!Checkers.idSize(config.idSize)) throw new Error('Invalid ID size');
+		if (!Checkers.gfySize(config.gfySize)) throw new Error('Invalid Gfy size');
+		if (!Checkers.maximumFileSize(config.maximumFileSize)) throw new Error('Invalid maximum file size');
+
+		// All is fine, carry on!
+		return config;
+	}
+
+	/**
+	 * Save the config file to disk
+	 */
+	public static saveConfigFile(): Promise<void> {
+		return new Promise(async (resolve, reject) => {
+			try {
+
+				// Only save is the config has been parsed
+				if (!UserConfig._ready) throw new Error('Config not ready to be saved!');
+
+				// Write to file
+				await fs.writeFile(path.join('userconfig.json'), JSON.stringify(UserConfig._config, null, '\t'));
+
+				resolve(void 0);
+			} catch (err) {
+				log.error('Failed to save config file!');
+				reject(err);
+			}
+		});
+	}
+
+	/**
+	 * Reads the config file from disk
+	 */
+	public static readConfigFile(): Promise<void> {
+		return new Promise(async (resolve, reject) => {
+			try {
+
+				// Read the file data
+				const data = (await fs.readFile(path.join('userconfig.json'))).toString();
+
+				// Ensure the config is valid
+				UserConfig._config = UserConfig.parseConfig(data);
+				UserConfig._ready = true;
+
+				resolve(void 0);
+			} catch (err) {
+				log.error('Failed to read config file!');
+				reject(err);
+			}
+		});
+	}
+}

backend/app.ts

@@ -0,0 +1,111 @@
+import express, { Request, Response, NextFunction, RequestHandler, json as BodyParserJson } from 'express';
+import fs from 'fs-extra';
+import { path, isProd } from '@tycrek/joint';
+import { epcss } from '@tycrek/express-postcss';
+import tailwindcss from 'tailwindcss';
+import { log } from './log';
+import { UserConfig } from './UserConfig';
+import { ServerConfiguration } from 'ass';
+
+/**
+ * Custom middleware to attach the ass object (and construct the `host` property)
+ */
+function assMetaMiddleware(port: number, proxied: boolean): RequestHandler {
+	return (req: Request, _res: Response, next: NextFunction) => {
+		req.ass = { host: `${req.protocol}://${req.hostname}${proxied ? '' : `:${port}`}` };
+		next();
+	}
+}
+
+/**
+ * Main function.
+ * Yes I'm using main() in TS, cry about it
+ */
+async function main() {
+
+	// Launch log
+	const pkg = await fs.readJson(path.join('package.json')) as { name: string, version: string };
+	log.blank().info(pkg.name, pkg.version).blank();
+
+	// Set default server configuration
+	const serverConfig: ServerConfiguration = {
+		host: '0.0.0.0',
+		port: 40115,
+		proxied: isProd()
+	};
+
+	// Replace with user details, if necessary
+	try {
+		const exists = await fs.pathExists(path.join('server.json'));
+		if (exists) {
+
+			// Read file
+			const { host, port, proxied } = await fs.readJson(path.join('server.json')) as { host?: string, port?: number, proxied?: boolean };
+
+			// Set details, if available
+			if (host) serverConfig.host = host;
+			if (port) serverConfig.port = port;
+			if (proxied != undefined) serverConfig.proxied = proxied;
+
+			log.debug('server.json', `${host ? `host=${host},` : ''}${port ? `port=${port},` : ''}${proxied != undefined ? `proxied=${proxied},` : ''}`);
+		}
+	} catch (err) {
+		log.error('Failed to read server.json');
+		console.error(err);
+		throw err;
+	}
+
+	// Attempt to load user configuration
+	await new Promise((resolve) => UserConfig.readConfigFile().then(() => resolve(void 0))
+		.catch((err) => (err.code && err.code === 'ENOENT' ? {} : console.error(err), resolve(void 0))));
+
+	// Set up Express
+	const app = express();
+
+	app.enable('case sensitive routing');
+	app.disable('x-powered-by');
+
+	app.set('trust proxy', serverConfig.proxied);
+	app.set('view engine', 'pug');
+	app.set('views', 'views2/');
+
+	// Middleware
+	app.use(log.express());
+	app.use(BodyParserJson());
+	app.use(assMetaMiddleware(serverConfig.port, serverConfig.proxied));
+
+	// CSS
+	app.use('/.css', epcss({
+		cssPath: path.join('tailwind2.css'),
+		plugins: [
+			tailwindcss,
+			(await import('autoprefixer')).default(),
+			(await import('cssnano')).default(),
+			(await import('@tinycreek/postcss-font-magician')).default(),
+		],
+		warn: (warning: Error) => log.warn('PostCSS', warning.toString())
+	}));
+
+	app.get('/.ass.host', (req, res) => res.send(req.ass.host));
+
+	// Routing
+	app.use('/setup', (await import('./routers/setup')).router);
+	app.use('/', (await import('./routers/index')).router);
+
+	// Host app
+	app.listen(serverConfig.port, serverConfig.host, () => log[UserConfig.ready ? 'success' : 'warn']('Server listening', UserConfig.ready ? 'Ready for uploads' : 'Setup required', `click http://127.0.0.1:${serverConfig.port}`));
+}
+
+// Start program
+main().catch((err) => (console.error(err), process.exit(1)));
+
+// Exit tasks
+['SIGINT', 'SIGTERM'].forEach((signal) => process.addListener(signal as any, () => {
+
+	// Hide ^C in console output
+	process.stdout.write('\r');
+
+	// Log then exit
+	log.info('Exiting', `received ${signal}`);
+	process.exit();
+}));

backend/generators.ts

@@ -0,0 +1,2 @@
+import cryptoRandomString from 'crypto-random-string';
+export const random = ({ length }: { length: number }) => cryptoRandomString({ length, type: 'alphanumeric' });

backend/log.ts

@@ -0,0 +1,2 @@
+import { TLog } from '@tycrek/log';
+export const log = new TLog('debug');