1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
const { spawn } = require("child_process");
const { differenceInMilliseconds } = require('date-fns');
const fs = require('fs');
function execGit(path, action, args = [""], error)
{
const git = spawn("git", ["-C", path, action, args].concat(args));
git.on("error", (err) =>
{
const no_such_file_or_dir = new RegExp(`cannot change to '${path.replace('/', "\/")}': No such file or directory\\n$`);
if(no_such_file_or_dir.test(err.toString())) {
error({ "error": 404 })
return;
}
error({ "error": err });
});
git.stderr.on("data", () => error({ "error": "Failed to communicate with git!" }));
return git;
}
function getLog(base_dir, path)
{
return new Promise((resolve) =>
{
let log = [];
const log_format='{"hash":"%H","author":"%an","author_email":"%ae","date":"%at","subject":"%s"}';
const git = execGit(`${base_dir}/${path}`, "log", [`--format=format:${log_format}`, "--shortstat"], (err) => resolve(err));
git.stdout.on("data", (data) =>
{
data = data.toString().split('\n').filter((item) => item != "");
data[0] = JSON.parse(data[0]);
["files changed", "insertions", "deletions"].forEach((stat) =>
{
const stat_nr = new RegExp(`(\\d+)\\ ${stat.replaceAll(/s(?=(\ |$))/g, "s?")}`).exec(data[1]);
data[0][stat.replaceAll(" ", "_")] = stat_nr ? stat_nr[1] : 0;
});
log.push(data[0]);
});
git.on("close", (code) =>
{
if(code === 0) {
resolve({ "data": log });
return;
}
resolve({ "error": "Failed to communicate with git!" });
});
})
}
function getOptimalDateDifference(difference)
{
const time_values = { "second": 1000, "minute": 60000, "hour": 3600000, "day": 86400000, "week": 604800000, "month": 2629800000, "year": 31557600000 };
let last;
for(const [key, value] of Object.entries(time_values)) {
if(difference > value) {
last = key;
continue;
}
break;
}
return `${Math.round(difference / time_values[last])} ${last}s`;
}
function getTimeSinceLatestCommit(path)
{
return new Promise((resolve) =>
{
const git = execGit(path, "log", [`--format=format:%at`, "-n 1"], (err) => resolve(err));
const commit = [];
git.stdout.on("data", (data) => commit.push(data));
git.on("close", (code) =>
{
const commit_timestamp = new Date(Number(Buffer.concat(commit).toString()) * 1000);
const now_date = new Date();
resolve(getOptimalDateDifference(differenceInMilliseconds(now_date, commit_timestamp)));
});
});
}
function getRepoFile(base_dir, repo, file)
{
return new Promise(resolve =>
{
fs.readFile(`${base_dir}/${repo}/${file}`, async (err, content) =>
{
if(!err) {
resolve(content.toString().replaceAll('\n', ''));
return;
}
resolve("");
});
});
}
function getBasicRepoInfo(base_dir, repo_dirs)
{
return new Promise((resolve) =>
{
let repos = {};
repo_dirs.forEach(async (repo, index, arr) =>
{
const desc = await getRepoFile(base_dir, repo, "description");
const owner = await getRepoFile(base_dir, repo, "owner");
const last_commit_date = await getTimeSinceLatestCommit(`${base_dir}/${repo}`);
let repo_name = "";
repo_name = repo.slice(0, -4);
repos[repo_name] = { "description": desc, "owner": owner, "last_updated": last_commit_date };
if(index === 0) resolve(repos);
});
});
}
function getRepos(base_dir)
{
return new Promise((resolve) =>
{
fs.readdir(base_dir, async (err, content) =>
{
if(err) {
resolve({ "error": err });
return;
}
resolve({ "data": content });
});
});
}
module.exports.getLog = getLog;
module.exports.getBasicRepoInfo = getBasicRepoInfo;
module.exports.getRepos = getRepos;
module.exports.getRepoFile = getRepoFile;
|
