2.0-alpha

Author: zmh-program

.replit

@@ -1,6 +1,6 @@
 
 hidden = [".config", "package-lock.json"]
-run = "node index"
+run = "ts-node index"
 
 [[hints]]
 regex = "Error \\[ERR_REQUIRE_ESM\\]"
@@ -62,7 +62,7 @@ support = true
       cwd = "."
       environment = []
       pauseForSourceMap = false
-      program = "./index.js"
+      program = "./index.ts"
       request = "launch"
       sourceMaps = true
       stopOnEntry = false

cache.js

@@ -0,0 +1,73 @@
+const conf = require("./config");
+const logger = (require("log4js")).getLogger("Cache");
+
+logger.level = "debug";
+
+
+class Cache {
+  protected caches: object;
+  public expiration: number;
+  constructor(expiration: number) {
+    this.caches = {};
+    this.expiration = expiration;
+    this.uptime();
+  }
+
+  get(key: string): undefined | any {
+    const value = this.caches[key];
+    if (this.exist(key)) {
+      return JSON.parse(value.value);
+    }
+  }
+
+  set(key: string, value: any): void {
+    this.caches[key] = {
+      value: JSON.stringify(value),
+      expiration: (new Date().getTime() / 1000) + this.expiration,
+    }
+  }
+
+  exist(key: string): boolean {
+    const value = this.caches[key];
+    return (!!value) && (value.expiration > (new Date().getTime() / 1000));
+  }
+
+  remove(key: string): boolean {
+    return delete this.caches[key];
+  }
+
+  uptime(): void {
+    const _this = this;
+    setInterval(function (){
+      let n: number = 0;
+      for (const key in _this.caches) {
+        if (_this.caches[key].expiration < (new Date().getTime() / 1000)) {
+          _this.remove(key); n++;
+        }
+        if (n > 0) logger.debug(`Clean ${n} Caches`);
+      }
+    }, 1800);
+  }
+
+  wrap(func: (params: any[]) => Promise<any>): (...params: any[]) => Promise<any> {
+    /**
+     * Async Function Cache.
+     */
+
+    const _this = this;
+    return async function (...params : any[]) {
+      const key: string = func.name + JSON.stringify(params);
+      if (_this.exist(key)) {
+        logger.debug(`Hit Cache <${func.name}>`)
+        return _this.get(key);
+      } else {
+        logger.info(`Cache Response ${func.name}`); // @ts-ignore
+        const response: any = await func(...params);
+        _this.set(key, response);
+        return response;
+      }
+    }
+  }
+}
+
+export const cache = new Cache(conf.expiration);

cache.ts

@@ -1,4 +1,4 @@
-module.exports = {
+export default {
   token: process.env.CODE_STATISTIC, // GitHub Access Token (Minimum permissions). Increase QPS of GitHub APIs.
   expiration: 3600,  // expiration second
   requires: ["*"], // CODE STATISTIC can only be parsed for allowed users. ( * indicates that all users are allowed )

config.js config.tsconfig.js renamed to config.ts

@@ -25,5 +25,8 @@
     "ejs-locals": "^1.0.2",
     "express": "^4.18.2",
     "log4js": "^6.7.1"
+  },
+  "devDependencies": {
+    "@types/node": "^18.14.6"
   }
 }

index.js index.tsindex.js renamed to index.ts

@@ -1,9 +1,6 @@
-const cache = new (require('./cache').ApiCache)();
+const cache = require('./cache').cache;
 
-const store_units = ["b", "KiB", "MiB", "GiB", "TiB", "PiB"];
-const dec_units = ["", "k", "m"];
-
-const lang_colors = {  /** thanks, @anuraghazra's github-readme-stats **/
+const colors = {  /** thanks, @anuraghazra's github-readme-stats **/
   "1C Enterprise": "#814CCC",
   "2-Dimensional Array": "#38761D",
   "4D": "#004289",
@@ -552,45 +549,6 @@ const lang_colors = {  /** thanks, @anuraghazra's github-readme-stats **/
   "xBase": "#403a40"
 }
 
-function sort(arr) {
-  const len = arr.length - 1;
-  for (let i = 0; i <= len; i++) {for (let j = 0; j < len - i; j++) {if (arr[j] > arr[j + 1]) {[arr[j], arr[j + 1]] = [arr[j + 1], arr[j]]}}}
-  return arr
-}
-
-function storeConvert(size, idx=0) {
-  if (size <= 0) {
-    return "0";
-  }
-  while (idx < (store_units.length - 1) && size > 1024) {
-    size /= 1024;
-    idx ++;
-  }
-  return `${size.toFixed(1)} ${store_units[idx]}`;
-}
-
-function decConvert(n, allowed_pre=true) {
-  let idx = 0;
-  let condition = allowed_pre ? 100 : 1000;
-  while (idx < (dec_units.length - 1) && n > condition) { n /= 1000 ; idx ++ }
-  return idx === 0 ? n : n.toFixed(1) + dec_units[idx];
-}
-
-function sum(arr) {
-  switch (arr.length) {
-    case 0 :
-      return 0;
-    case 1:
-      return arr[0];
-    default:
-      return arr.reduce((a, b) => a + b);
-  }
-}
-
-async function getLanguage(user, repo) {
-  return await cache.requestWithCache(`/repos/${user}/${repo}/languages`);
-}
-
 async function langStatistics(queue) {
   const res = {};
   for (const idx in queue) {
@@ -622,7 +580,7 @@ function langHandler(langs) {
     cursor += ratio;
     return {
       name: lang,
-      color: lang_colors[lang],
+      color: colors[lang],
       cursor: cursor - ratio,
       ratio: ratio,
       text: `${lang} ${(ratio * 100).toFixed(0)}% (${decConvert(key, false)})`,
@@ -662,7 +620,7 @@ async function getRepository(username, repo, dark=false) {
     stars: decConvert(res['stargazers_count']),
     watchers: decConvert(res['watchers_count']),
     license: license ? license['spdx_id'] : "Empty",
-    color: lang_colors[res['language']],
+    color: colors[res['language']],
     langs: langHandler(await getLanguage(username, repo)),
   };
 }

package.json

@@ -0,0 +1,70 @@
+const axios = require("axios");
+const conf = require("./config");
+axios.defaults.baseURL = "https://api.github.com";
+
+export function sort(arr: number[]): number[] {
+    const len = arr.length - 1;
+    for (let i = 0; i <= len; i++) {for (let j = 0; j < len - i; j++) {if (arr[j] > arr[j + 1]) {[arr[j], arr[j + 1]] = [arr[j + 1], arr[j]]}}}
+    return arr
+}
+
+const store_units = ["b", "KiB", "MiB", "GiB", "TiB", "PiB"];
+export function storeConvert(size: number, idx: number = 0): string {
+    if (size <= 0) {
+        return "0";
+    }
+    while (idx < (store_units.length - 1) && size > 1024) {
+        size /= 1024;
+        idx ++;
+    }
+    return `${size.toFixed(1)} ${store_units[idx]}`;
+}
+
+const dec_units = ["", "k", "m"];
+export function decConvert(n: number, allowed_pre: boolean = true): string {
+    let idx = 0;
+    let condition = allowed_pre ? 100 : 1000;
+    while (idx < (dec_units.length - 1) && n > condition) { n /= 1000 ; idx ++ }
+    return idx === 0 ? n.toString() : n.toFixed(1) + dec_units[idx];
+}
+
+export function sum(arr: number[]): number {
+    switch (arr.length) {
+        case 0 : return 0;
+        case 1: return arr[0];
+        default: return arr.reduce((a, b) => a + b);
+    }
+}
+
+export async function request(url: string): Promise<any> {
+    const response = await axios.get(url, {
+        headers: {
+            Accept: "application/json",
+            Authorization: `Bearer ${this.token}`,
+        },
+    });
+    return response.data;
+}
+
+export async function requestUser(user): Promise<any> {
+    return await request(`/users/${user}`);
+}
+
+export async function listRepos(user): Promise<object> {
+    return Object.values(await request(`/users/${user}/repos`)).filter(repo => !repo['fork']);
+}
+
+export async function requestRepo(user, repo): Promise<any> {
+    return await request(`/repos/${user}/${repo}`);
+}
+
+export async function requestLanguage(user, repo): Promise<any> {
+    return await request(`/repos/${user}/${repo}/languages`);
+}
+
+export async function isAuthenticated(user): Promise<boolean> {
+    user = user.trim();
+    return (!! user.length) &&
+        (conf.requires.includes("*") || conf.requires.includes(user)) &&
+        ((await requestUser(user))['message'] !== "Not Found");
+}