init

Author: chescos

.editorconfig

@@ -0,0 +1,15 @@
+# http://editorconfig.org
+root = true
+
+[*]
+charset = utf-8
+end_of_line = lf
+indent_size = 2
+indent_style = space
+insert_final_newline = true
+trim_trailing_whitespace = true
+# editorconfig-tools is unable to ignore longs strings or urls
+max_line_length = off
+
+[*.md]
+trim_trailing_whitespace = false

.env.example

@@ -0,0 +1,2 @@
+NODE_ENV=development
+PORT=3000

.eslintrc.json

@@ -0,0 +1,18 @@
+{
+  "extends": [
+    "airbnb-base"
+  ],
+  "env": {
+    "browser": true,
+    "commonjs": true,
+    "es6": true,
+    "node": true
+  },
+  "parserOptions": {
+    "ecmaVersion": 9,
+    "sourceType": "module"
+  },
+  "globals": {
+    "process": false
+  }
+}

.gitignore

@@ -0,0 +1,54 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+
+# 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
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+
+# Dependency directories
+.idea/
+.env
+.env.production
+.env.local
+.env.development
+.env.docker
+node_modules
+jspm_packages
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity

app.js

@@ -0,0 +1,36 @@
+const path = require('path');
+require('dotenv').config({ path: path.join(__dirname, './.env') });
+const config = require('config');
+const express = require('express');
+const http = require('http');
+const logger = require('./modules/Logger');
+
+const app = express();
+const port = config.get('port');
+
+// Parse the HTTP message body for input parameters.
+// Any parameters that are found will be added to `req.body`.
+app.use(require('./middlewares/bodyParserJson'));
+app.use(require('./middlewares/bodyParserUrlencoded'));
+
+// Load all API routes.
+const inspectLinkRoute = require('./routes/inspectLinkRoute');
+
+// Register the API routes.
+app.use('/inspect-links', inspectLinkRoute);
+
+// Use a 404 handler for all requests where no Express route was found.
+app.use('*', require('./middlewares/notFoundHandler'));
+
+// The global error handler.
+app.use(require('./middlewares/errorHandler'));
+
+// Create a new HTTP server instance and attach our Express app as the request listener.
+const server = http.createServer(app);
+
+// Start the HTTP server and listen for connections.
+server.listen(port, '0.0.0.0', () => {
+  logger.info(`Listening on port ${port}`);
+});
+
+module.exports = { app, server };

config/default.js

@@ -0,0 +1,9 @@
+const path = require('path');
+require('dotenv').config({ path: path.join(__dirname, '../.env') });
+
+const { env } = process;
+
+module.exports = {
+  env: env.NODE_ENV || 'development',
+  port: env.PORT || 3000,
+};

controllers/inspectLinkController.js

@@ -0,0 +1,27 @@
+const Inspector = require('../modules/Inspector');
+const ErrorResponse = require('../modules/ErrorResponse');
+const logger = require('../modules/Logger');
+
+exports.store = async (req, res) => {
+  const {
+    body: { link },
+  } = req;
+
+  let inspection;
+
+  try {
+    inspection = await Inspector.inspect(link, 10000);
+
+    logger.info('Inspected link', inspection);
+  } catch (error) {
+    logger.warn('Inspection failed', { link });
+    logger.error(error);
+
+    return res.status(500).json(ErrorResponse.inspectionFailed());
+  }
+
+  return res.status(201).json({
+    success: true,
+    inspection,
+  });
+};

middlewares/bodyParserJson.js

@@ -0,0 +1,5 @@
+const parser = require('body-parser');
+
+module.exports = parser.json({
+  limit: '1mb',
+});

middlewares/bodyParserUrlencoded.js

@@ -0,0 +1,7 @@
+const parser = require('body-parser');
+
+module.exports = parser.urlencoded({
+  extended: true,
+  parameterLimit: 500,
+  limit: '1mb',
+});

middlewares/errorHandler.js

@@ -0,0 +1,25 @@
+const ErrorResponse = require('../modules/ErrorResponse');
+const logger = require('../modules/Logger');
+
+// `next` must be defined in the function arguments,
+// otherwise, this middleware will not work!
+// eslint-disable-next-line no-unused-vars
+module.exports = (err, req, res, next) => {
+  logger.warn('Request error', {
+    url: req.originalUrl,
+    method: req.method,
+    parameters: {
+      body: req.body,
+      query: req.query,
+      params: req.params,
+    },
+    client: {
+      ip: req.ip,
+      userAgent: req.headers['user-agent'],
+    },
+  });
+
+  logger.error(err);
+
+  return res.status(500).json(ErrorResponse.serverError());
+};

middlewares/notFoundHandler.js

@@ -0,0 +1,3 @@
+const ErrorResponse = require('../modules/ErrorResponse');
+
+module.exports = (req, res) => res.status(404).json(ErrorResponse.notFound());

middlewares/validateInput.js

@@ -0,0 +1,30 @@
+const { validationResult } = require('express-validator');
+const ErrorResponse = require('../modules/ErrorResponse');
+const logger = require('../modules/Logger');
+
+module.exports = (validations) => async (req, res, next) => {
+  await Promise.all(validations.map((validation) => validation.run(req)));
+
+  const errors = validationResult(req);
+
+  if (errors.isEmpty()) {
+    return next();
+  }
+
+  logger.warn('Input validation failed', {
+    url: req.originalUrl,
+    method: req.method,
+    parameters: {
+      body: req.body,
+      query: req.query,
+      params: req.params,
+    },
+    client: {
+      ip: req.ip,
+      userAgent: req.headers['user-agent'],
+    },
+    errors: errors.array(),
+  });
+
+  return res.status(400).json(ErrorResponse.validationError(errors));
+};

modules/ErrorResponse.js

@@ -0,0 +1,35 @@
+const _ = require('lodash');
+
+class ErrorResponse {
+  static inspectionFailed() {
+    return {
+      id: 'INSPECTION_FAILED',
+      message: 'Failed to inspect the given CS:GO inspect link, please try again.',
+    };
+  }
+
+  static notFound() {
+    return {
+      id: 'NOT_FOUND',
+      message: 'Whoops, this endpoint does not exist.',
+    };
+  }
+
+  static serverError() {
+    return {
+      id: 'SERVER_ERROR',
+      message: 'An unexpected server error occurred.',
+    };
+  }
+
+  static validationError(error) {
+    const firstError = _.first(error.array());
+
+    return {
+      id: 'VALIDATION_ERROR',
+      message: `Parameter "${firstError.param}" failed validation: "${firstError.msg}"`,
+    };
+  }
+}
+
+module.exports = ErrorResponse;

modules/Inspector.js

@@ -0,0 +1,79 @@
+const SteamUser = require('steam-user');
+const GlobalOffensive = require('globaloffensive');
+const SteamTotp = require('steam-totp');
+const _ = require('lodash');
+const logger = require('./Logger');
+
+// TODO: Add this to a config or to a database and encrypt it.
+const accounts = [];
+
+const clients = [];
+
+accounts.forEach((account) => {
+  const client = new SteamUser();
+  const csgo = new GlobalOffensive(client);
+
+  client.logOn({
+    accountName: account.username,
+    password: account.password,
+    twoFactorCode: SteamTotp.getAuthCode(account.sharedSecret),
+  });
+
+  client.on('loggedOn', () => {
+    logger.info(`Logged into Steam as ${client.steamID.getSteam3RenderedID()}`);
+    client.setPersona(SteamUser.EPersonaState.Online);
+    client.gamesPlayed(730, true);
+  });
+
+  client.on('error', (e) => {
+    // Some error occurred during logon
+    logger.error('Client error');
+    logger.error(e);
+  });
+
+  client.on('webSession', () => {
+    logger.info('Got web session');
+    // Do something with these cookies if you wish
+  });
+
+  csgo.on('connectedToGC', () => {
+    logger.info('Connected to CS:GO game coordinator');
+  });
+
+  csgo.on('inspectItemTimedOut', (assetid) => {
+    logger.warn(`Inspect timed out for assetid ${assetid}`);
+  });
+
+  clients.push({
+    client,
+    csgo,
+  });
+});
+
+class Inspector {
+  static getClients() {
+    return clients;
+  }
+
+  static inspect(url, timeoutMs = 5000) {
+    return new Promise((resolve, reject) => {
+      const client = _.sample(_.filter(clients, ((x) => x.csgo.haveGCSession)));
+
+      if (_.isUndefined(client)) {
+        reject(
+          new Error('There is currently no client available with an active game coordinator connection'),
+        );
+      }
+
+      client.csgo.inspectItem(url, (item) => {
+        resolve(item);
+      });
+
+      setTimeout(() => {
+        reject(new Error(`Inspection timed out after ${timeoutMs} ms`));
+      }, timeoutMs);
+    });
+  }
+}
+
+module.exports = Inspector;