0.12

Author: zmh-program

config.js

@@ -3,5 +3,4 @@ module.exports = {
   expiration: 3600,  // expiration second
   requires: ["*"], // CODE STATISTIC can only be parsed for allowed users. ( * indicates that all users are allowed )
   port: 8000, // server port
-  host: "localhost",
 }

index.js

@@ -1,8 +1,6 @@
 const express = require('express');
-const engine = require('ejs-locals');
-const cache = new (require('./cache').ApiCache)();
 const logger = (require("log4js")).getLogger("Backend");
-const utils = require('./utils');
+const stats = require('./stats');
 const conf = require('./config');
 const app = express();
 
@@ -15,54 +13,6 @@ const isAvailableUser = (username) => {
     return ( !! username ) && ( conf.requires.includes("*") || conf.requires.includes(username));
 }
 
-async function getLanguage(user, repo) {
-    return await cache.requestWithCache(`/repos/${user}/${repo}/languages`);
-}
-
-async function langStatistics(queue) {
-    const res = {};
-    for (const idx in queue) {
-        const task = queue[idx];
-        if (task instanceof Promise) {
-            const task_response = await task;
-            for (const lang in task_response) {
-                lang in res ?
-                  res[lang] += task_response[lang] :
-                  res[lang] = task_response[lang];
-            }
-        }
-    }
-    return res;
-}
-
-async function getAccount(username) {
-    const response = await cache.requestWithCache(`/users/${username}`);
-    return {
-        username: username,
-        followers: response['followers'],
-        repos: response['public_repos'],
-        langs: await langStatistics(
-          Object.values(await cache.requestWithCache(`/users/${username}/repos`)
-          ).map(async (resp) => {
-              return await getLanguage(username, resp['name']);
-          })),
-    };
-}
-
-async function getRepository(username, repo) {
-    // get releases (700ms): (await cache.requestWithCache(`/repos/${username}/${repo}/releases`)).length
-    const info = await cache.requestWithCache(`/repos/${username}/${repo}`);
-    return {
-        repo: `${username} / ${repo}`,
-        size: utils.storeConvert(info['size'], 1),
-        forks: info['forks'],
-        stars: info['stargazers_count'],
-        watchers: info['watchers_count'],
-        license: info['license']['spdx_id'],
-        langs: await getLanguage(username, repo),
-    };
-}
-
 app.get('/', function(req, res) {
     res.render('index');
 })
@@ -74,7 +24,7 @@ app.get('/user/:user/', async function (req, res) {
         return;
     }
     res.type('svg');
-    res.render('user', await getAccount(username));
+    res.render('user', await stats.getAccount(username));
 });
 
 app.get('/repo/:user/:repo/', async function (req, res) {
@@ -84,9 +34,9 @@ app.get('/repo/:user/:repo/', async function (req, res) {
         return;
     }
     res.type('svg');
-    res.send(await getRepository(username, repo));
+    res.send(await stats.getRepository(username, repo));
 });
 
 
-app.listen(conf.port, conf.host, () =>
-  logger.info(`Starting deployment server at http://${conf.host}:${conf.port}/.`));
+app.listen(conf.port, () =>
+  logger.info(`Starting deployment server at http://127.0.0.1:${conf.port}/.`));

stats.js

@@ -0,0 +1,69 @@
+const cache = new (require('./cache').ApiCache)();
+
+const units = ["b", "KiB", "MiB", "GiB", "TiB", "PiB"]
+const len_units = units.length - 1;
+
+function storeConvert(size, idx=0) {
+  if (size <= 0) {
+    return "0";
+  }
+
+  while (idx < len_units && size > 1024) {
+    size /= 1024;
+    idx ++;
+  }
+  return `${size.toFixed(1)} ${units[idx]}`;
+}
+
+async function getLanguage(user, repo) {
+  return await cache.requestWithCache(`/repos/${user}/${repo}/languages`);
+}
+
+async function langStatistics(queue) {
+  const res = {};
+  for (const idx in queue) {
+    const task = queue[idx];
+    if (task instanceof Promise) {
+      const task_response = await task;
+      for (const lang in task_response) {
+        lang in res ?
+          res[lang] += task_response[lang] :
+          res[lang] = task_response[lang];
+      }
+    }
+  }
+  return res;
+}
+
+async function getAccount(username) {
+  const response = await cache.requestWithCache(`/users/${username}`);
+  return {
+    username: username,
+    followers: response['followers'],
+    repos: response['public_repos'],
+    langs: await langStatistics(
+      Object.values(await cache.requestWithCache(`/users/${username}/repos`)
+      ).map(async (resp) => {
+        return await getLanguage(username, resp['name']);
+      })),
+  };
+}
+
+async function getRepository(username, repo) {
+  // get releases (700ms): (await cache.requestWithCache(`/repos/${username}/${repo}/releases`)).length
+  const info = await cache.requestWithCache(`/repos/${username}/${repo}`);
+  return {
+    repo: `${username} / ${repo}`,
+    size: storeConvert(info['size'], 1),
+    forks: info['forks'],
+    stars: info['stargazers_count'],
+    watchers: info['watchers_count'],
+    license: info['license']['spdx_id'],
+    langs: await getLanguage(username, repo),
+  };
+}
+
+module.exports = {
+  getAccount: getAccount,
+  getRepository: getRepository,
+}