| #!/usr/bin/env node |
| |
| // Copyright (c) 2012-2017, Matt Godbolt |
| // All rights reserved. |
| // |
| // Redistribution and use in source and binary forms, with or without |
| // modification, are permitted provided that the following conditions are met: |
| // |
| // * Redistributions of source code must retain the above copyright notice, |
| // this list of conditions and the following disclaimer. |
| // * Redistributions in binary form must reproduce the above copyright |
| // notice, this list of conditions and the following disclaimer in the |
| // documentation and/or other materials provided with the distribution. |
| // |
| // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" |
| // AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE |
| // IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE |
| // ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE |
| // LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR |
| // CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF |
| // SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS |
| // INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN |
| // CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) |
| // ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE |
| // POSSIBILITY OF SUCH DAMAGE. |
| |
| // load external and internal libraries (will load more internal binaries later) |
| var nopt = require('nopt'), |
| os = require('os'), |
| props = require('./lib/properties'), |
| CompileHandler = require('./lib/compile-handler').CompileHandler, |
| buildDiffHandler = require('./lib/diff').buildDiffHandler, |
| express = require('express'), |
| child_process = require('child_process'), |
| path = require('path'), |
| fs = require('fs-extra'), |
| http = require('http'), |
| https = require('https'), |
| url = require('url'), |
| utils = require('./lib/utils'), |
| Promise = require('promise'), |
| aws = require('./lib/aws'), |
| _ = require('underscore-node'), |
| logger = require('./lib/logger').logger; |
| |
| // Parse arguments from command line 'node ./app.js args...' |
| var opts = nopt({ |
| 'env': [String, Array], |
| 'rootDir': [String], |
| 'language': [String], |
| 'host': [String], |
| 'port': [Number], |
| 'propDebug': [Boolean], |
| 'debug': [Boolean], |
| 'static': [String], |
| 'archivedVersions': [String] |
| }); |
| |
| if (opts.debug) logger.level = 'debug'; |
| |
| // Set default values for omitted arguments |
| var rootDir = opts.rootDir || './etc'; |
| var language = opts.language || "C++"; |
| var env = opts.env || ['dev']; |
| var hostname = opts.host; |
| var port = opts.port || 10240; |
| var staticDir = opts.static || 'static'; |
| var archivedVersions = opts.archivedVersions; |
| var gitReleaseName = child_process.execSync('git rev-parse HEAD').toString().trim(); |
| |
| var propHierarchy = _.flatten([ |
| 'defaults', |
| env, |
| language, |
| _.map(env, function (e) { |
| return e + '.' + process.platform; |
| }), |
| process.platform, |
| os.hostname(), |
| 'local']); |
| logger.info("properties hierarchy: " + propHierarchy.join(', ')); |
| |
| // Propagate debug mode if need be |
| if (opts.propDebug) props.setDebug(true); |
| |
| // *All* files in config dir are parsed |
| props.initialize(rootDir + '/config', propHierarchy); |
| |
| // Instantiate a function to access records concerning "compiler-explorer" |
| // in hidden object props.properties |
| var gccProps = props.propsFor("compiler-explorer"); |
| |
| // Read from gccexplorer's config the wdiff configuration |
| // that will be used to configure lib/diff.js |
| var wdiffConfig = { |
| wdiffExe: gccProps('wdiff', "wdiff"), |
| maxOutput: gccProps("max-diff-output", 100000) |
| }; |
| |
| // Instantiate a function to access records concerning the chosen language |
| // in hidden object props.properties |
| var compilerPropsFunc = props.propsFor(language.toLowerCase()); |
| |
| // If no option for the compiler ... use gcc's options (??) |
| function compilerProps(property, defaultValue) { |
| // My kingdom for ccs... [see Matt's github page] |
| var forCompiler = compilerPropsFunc(property, undefined); |
| if (forCompiler !== undefined) return forCompiler; |
| return gccProps(property, defaultValue); // gccProps comes from lib/compile-handler.js |
| } |
| var staticMaxAgeSecs = gccProps('staticMaxAgeSecs', 0); |
| |
| var awsProps = props.propsFor("aws"); |
| var awsPoller = null; |
| function awsInstances() { |
| if (!awsPoller) awsPoller = new aws.InstanceFetcher(awsProps); |
| return awsPoller.getInstances(); |
| } |
| |
| // function to load internal binaries (i.e. lib/source/*.js) |
| function loadSources() { |
| var sourcesDir = "lib/sources"; |
| var sources = fs.readdirSync(sourcesDir) |
| .filter(function (file) { |
| return file.match(/.*\.js$/); |
| }) |
| .map(function (file) { |
| return require("./" + path.join(sourcesDir, file)); |
| }); |
| return sources; |
| } |
| |
| // load effectively |
| var fileSources = loadSources(); |
| var sourceToHandler = {}; |
| fileSources.forEach(function (source) { |
| sourceToHandler[source.urlpart] = source; |
| }); |
| |
| var clientOptionsHandler = new ClientOptionsHandler(fileSources); |
| var apiHandler = new ApiHandler(); |
| var compileHandler = new CompileHandler(gccProps, compilerProps); |
| |
| // auxiliary function used in clientOptionsHandler |
| function compareOn(key) { |
| return function (xObj, yObj) { |
| var x = xObj[key]; |
| var y = yObj[key]; |
| if (x < y) return -1; |
| if (x > y) return 1; |
| return 0; |
| }; |
| } |
| |
| // instantiate a function that generate javascript code, |
| function ClientOptionsHandler(fileSources) { |
| var sources = fileSources.map(function (source) { |
| return {name: source.name, urlpart: source.urlpart}; |
| }); |
| // sort source file alphabetically |
| sources = sources.sort(compareOn("name")); |
| var text = ""; |
| this.setCompilers = function (compilers) { |
| var options = { |
| googleAnalyticsAccount: gccProps('clientGoogleAnalyticsAccount', 'UA-55180-6'), |
| googleAnalyticsEnabled: gccProps('clientGoogleAnalyticsEnabled', false), |
| sharingEnabled: gccProps('clientSharingEnabled', true), |
| githubEnabled: gccProps('clientGitHubRibbonEnabled', true), |
| gapiKey: gccProps('googleApiKey', ''), |
| googleShortLinkRewrite: gccProps('googleShortLinkRewrite', '').split('|'), |
| defaultSource: gccProps('defaultSource', ''), |
| language: language, |
| compilers: compilers, |
| sourceExtension: compilerProps('compileFilename').split('.', 2)[1], |
| defaultCompiler: compilerProps('defaultCompiler', ''), |
| compileOptions: compilerProps("options"), |
| supportsBinary: !!compilerProps("supportsBinary"), |
| sources: sources, |
| raven: gccProps('ravenUrl', ''), |
| release: gitReleaseName, |
| environment: env |
| }; |
| text = JSON.stringify(options); |
| }; |
| this.setCompilers([]); |
| this.handler = function getClientOptions(req, res) { |
| res.set('Content-Type', 'application/json'); |
| res.set('Cache-Control', 'public, max-age=' + staticMaxAgeSecs); |
| res.end(text); |
| }; |
| } |
| |
| // function used to enable loading and saving source code from web interface |
| function getSource(req, res, next) { |
| var bits = req.url.split("/"); |
| var handler = sourceToHandler[bits[1]]; |
| if (!handler) { |
| next(); |
| return; |
| } |
| var action = bits[2]; |
| if (action == "list") action = handler.list; |
| else if (action == "load") action = handler.load; |
| else if (action == "save") action = handler.save; |
| else action = null; |
| if (action === null) { |
| next(); |
| return; |
| } |
| action.apply(handler, bits.slice(3).concat(function (err, response) { |
| res.set('Cache-Control', 'public, max-age=' + staticMaxAgeSecs); |
| if (err) { |
| res.end(JSON.stringify({err: err})); |
| } else { |
| res.end(JSON.stringify(response)); |
| } |
| })); |
| } |
| |
| function retryPromise(promiseFunc, name, maxFails, retryMs) { |
| return new Promise(function (resolve, reject) { |
| var fails = 0; |
| |
| function doit() { |
| var promise = promiseFunc(); |
| promise.then(function (arg) { |
| resolve(arg); |
| }, function (e) { |
| fails++; |
| if (fails < maxFails) { |
| logger.warn("Failed " + name + " : " + e + ", retrying"); |
| setTimeout(doit, retryMs); |
| } else { |
| logger.error("Too many retries for " + name + " : " + e); |
| reject(e); |
| } |
| }); |
| } |
| |
| doit(); |
| }); |
| } |
| |
| |
| function findCompilers() { |
| var exes = compilerProps("compilers", "/usr/bin/g++").split(":"); |
| var ndk = compilerProps('androidNdk'); |
| if (ndk) { |
| var toolchains = fs.readdirSync(ndk + "/toolchains"); |
| toolchains.forEach(function (v, i, a) { |
| var path = ndk + "/toolchains/" + v + "/prebuilt/linux-x86_64/bin/"; |
| if (fs.existsSync(path)) { |
| var cc = fs.readdirSync(path).filter(function (filename) { |
| return filename.indexOf("g++") != -1; |
| }); |
| a[i] = path + cc[0]; |
| } else { |
| a[i] = null; |
| } |
| }); |
| toolchains = toolchains.filter(function (x) { |
| return x !== null; |
| }); |
| exes.push.apply(exes, toolchains); |
| } |
| |
| function fetchRemote(host, port, props) { |
| logger.info("Fetching compilers from remote source " + host + ":" + port); |
| return retryPromise(function () { |
| return new Promise(function (resolve, reject) { |
| var request = http.get({ |
| hostname: host, |
| port: port, |
| path: "/api/compilers" |
| }, function (res) { |
| var str = ''; |
| res.on('data', function (chunk) { |
| str += chunk; |
| }); |
| res.on('end', function () { |
| var compilers = JSON.parse(str).map(function (compiler) { |
| compiler.exe = null; |
| compiler.remote = "http://" + host + ":" + port; |
| return compiler; |
| }); |
| resolve(compilers); |
| }); |
| }).on('error', function (e) { |
| reject(e); |
| }).on('timeout', function () { |
| reject("timeout"); |
| }); |
| request.setTimeout(awsProps('proxyTimeout', 1000)); |
| }); |
| }, |
| host + ":" + port, |
| props('proxyRetries', 5), |
| props('proxyRetryMs', 500)) |
| .catch(function () { |
| logger.warn("Unable to contact " + host + ":" + port + "; skipping"); |
| return []; |
| }); |
| } |
| |
| function fetchAws() { |
| logger.info("Fetching instances from AWS"); |
| return awsInstances().then(function (instances) { |
| return Promise.all(instances.map(function (instance) { |
| logger.info("Checking instance " + instance.InstanceId); |
| var address = instance.PrivateDnsName; |
| if (awsProps("externalTestMode", false)) { |
| address = instance.PublicDnsName; |
| } |
| return fetchRemote(address, port, awsProps); |
| })); |
| }); |
| } |
| |
| function compilerConfigFor(name, parentProps) { |
| var base = "compiler." + name; |
| |
| function props(name, def) { |
| return parentProps(base + "." + name, parentProps(name, def)); |
| } |
| |
| var compilerInfo = { |
| id: name, |
| exe: compilerProps(base + ".exe", name), |
| name: props("name", name), |
| alias: props("alias"), |
| options: props("options"), |
| versionFlag: props("versionFlag"), |
| versionRe: props("versionRe"), |
| compilerType: props("compilerType", ""), |
| demangler: props("demangler", ""), |
| intelAsm: props("intelAsm", ""), |
| needsMulti: !!props("needsMulti", true), |
| supportsBinary: !!props("supportsBinary", true), |
| postProcess: props("postProcess", "").split("|") |
| }; |
| logger.info("Found compiler", compilerInfo); |
| return Promise.resolve(compilerInfo); |
| } |
| |
| function recurseGetCompilers(name, parentProps) { |
| if (name.indexOf("@") !== -1) { |
| var bits = name.split("@"); |
| var host = bits[0]; |
| var port = parseInt(bits[1]); |
| return fetchRemote(host, port, gccProps); |
| } |
| if (name.indexOf("&") === 0) { |
| var groupName = name.substr(1); |
| |
| var props = function (name, def) { |
| return compilerProps("group." + groupName + "." + name, parentProps(name, def)); |
| }; |
| |
| var exes = props('compilers', '').split(":"); |
| logger.info("Processing compilers from group " + groupName); |
| return Promise.all(exes.map(function (compiler) { |
| return recurseGetCompilers(compiler, props); |
| })); |
| } |
| if (name == "AWS") return fetchAws(); |
| return Promise.resolve(compilerConfigFor(name, parentProps)); |
| } |
| |
| return Promise.all( |
| exes.map(function (compiler) { |
| return recurseGetCompilers(compiler, compilerProps); |
| }) |
| ) |
| .then(_.flatten) |
| .then(function (compilers) { |
| return compileHandler.setCompilers(compilers); |
| }) |
| .then(function (compilers) { |
| return _.filter(compilers, function (x) { |
| return x; |
| }); |
| }) |
| .then(function (compilers) { |
| compilers = compilers.sort(compareOn("name")); |
| return compilers; |
| }); |
| } |
| |
| // Instantiate a function that writes information on the compiler, |
| // in JSON format, for ease of external listing. |
| function ApiHandler() { |
| var reply = ""; |
| this.setCompilers = function (compilers) { |
| reply = JSON.stringify(compilers); |
| }; |
| this.handler = function apiHandler(req, res, next) { |
| var bits = req.url.split("/"); |
| if (bits.length !== 2 || req.method !== "GET") return next(); |
| switch (bits[1]) { |
| default: |
| next(); |
| break; |
| |
| case "compilers": |
| res.set('Content-Type', 'application/json'); |
| res.end(reply); |
| break; |
| } |
| }; |
| } |
| |
| function shortUrlHandler(req, res, next) { |
| var bits = req.url.split("/"); |
| if (bits.length !== 2 || req.method !== "GET") return next(); |
| var key = process.env.GOOGLE_API_KEY; |
| var googleApiUrl = 'https://www.googleapis.com/urlshortener/v1/url?shortUrl=http://goo.gl/' + |
| encodeURIComponent(bits[1]) + '&key=' + key; |
| https.get(googleApiUrl, function (response) { |
| var responseText = ''; |
| response.on('data', function (d) { |
| responseText += d; |
| }); |
| response.on('end', function () { |
| if (response.statusCode != 200) { |
| logger.error("Failed to resolve short URL " + bits[1] + " - got response " + |
| response.statusCode + " : " + responseText); |
| return next(); |
| } |
| |
| var resultObj = JSON.parse(responseText); |
| var parsed = url.parse(resultObj.longUrl); |
| var allowedRe = new RegExp(gccProps('allowedShortUrlHostRe')); |
| if (parsed.host.match(allowedRe) === null) { |
| logger.warn("Denied access to short URL " + bits[1] + " - linked to " + resultObj.longUrl); |
| return next(); |
| } |
| res.writeHead(301, { |
| Location: resultObj.id, |
| 'Cache-Control': 'public' |
| }); |
| res.end(); |
| }); |
| }).on('error', function (e) { |
| logger.error("Error handling google URL shortener request", e); |
| res.end("Error " + e.message); |
| }); |
| } |
| |
| // TODO: write the info here directly instead of redirecting... |
| function embeddedHandler(req, res, next) { |
| res.writeHead(301, { |
| Location: 'embed.html', |
| 'Cache-Control': 'public' |
| }); |
| res.end(); |
| } |
| |
| |
| findCompilers() |
| .then(function (compilers) { |
| var prevCompilers; |
| |
| function onCompilerChange(compilers) { |
| if (JSON.stringify(prevCompilers) == JSON.stringify(compilers)) { |
| return; |
| } |
| logger.info("Compilers:", compilers); |
| if (compilers.length === 0) { |
| logger.error("#### No compilers found: no compilation will be done!"); |
| } |
| prevCompilers = compilers; |
| clientOptionsHandler.setCompilers(compilers); |
| apiHandler.setCompilers(compilers); |
| } |
| |
| onCompilerChange(compilers); |
| |
| var rescanCompilerSecs = gccProps('rescanCompilerSecs', 0); |
| if (rescanCompilerSecs) { |
| logger.info("Rescanning compilers every " + rescanCompilerSecs + "secs"); |
| setInterval(function () { |
| findCompilers().then(onCompilerChange); |
| }, rescanCompilerSecs * 1000); |
| } |
| |
| var webServer = express(), |
| sFavicon = require('serve-favicon'), |
| sStatic = require('serve-static'), |
| bodyParser = require('body-parser'), |
| morgan = require('morgan'), |
| compression = require('compression'), |
| restreamer = require('./lib/restreamer'), |
| diffHandler = buildDiffHandler(wdiffConfig); |
| |
| logger.info("======================================="); |
| logger.info("Listening on http://" + (hostname || 'localhost') + ":" + port + "/"); |
| logger.info(" serving static files from '" + staticDir + "'"); |
| logger.info(" git release " + gitReleaseName); |
| |
| webServer |
| .set('trust proxy', true) |
| .use(morgan('combined', {stream: logger.stream})) |
| .use(compression()) |
| .use(sFavicon(staticDir + '/favicon.ico')) |
| .use('/v', sStatic(staticDir + '/v', {maxAge: Infinity})) |
| .use(sStatic(staticDir, {maxAge: staticMaxAgeSecs * 1000})); |
| if (archivedVersions) { |
| // The archived versions directory is used to serve "old" versioned data during updates. It's expected |
| // to contain all the SHA-hashed directories from previous versions of Compiler Explorer. |
| logger.info(" serving archived versions from", archivedVersions); |
| webServer.use('/v', sStatic(archivedVersions, {maxAge: Infinity})); |
| } |
| webServer |
| .use(bodyParser.json({limit: gccProps('bodyParserLimit', '1mb')})) |
| .use(restreamer()) |
| .get('/client-options.json', clientOptionsHandler.handler) |
| .use('/source', getSource) |
| .use('/api', apiHandler.handler) |
| .use('/g', shortUrlHandler) |
| .use('/e', embeddedHandler) |
| .post('/compile', compileHandler.handler) // used inside static/compiler.js |
| .post('/diff', diffHandler); // used inside static/compiler.js |
| logger.info("======================================="); |
| |
| webServer.on('error', function (err) { |
| logger.error('Caught error:', err, "(in web error handler; continuing)"); |
| }); |
| |
| webServer.listen(port, hostname); |
| }) |
| .catch(function (err) { |
| logger.error("Promise error:", err, "(shutting down)"); |
| process.exit(1); |
| }); |