-
Notifications
You must be signed in to change notification settings - Fork 37
/
Copy pathindex.js
107 lines (107 loc) · 6.6 KB
/
index.js
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
/*!
* top-github-users-monitor 2.0.0
* https://github.com/gayanvoice/top-github-users-monitor
* (c) 2021 gayanvoice
* Released under the MIT License
*/
const pullGit = require('./helper/git/pull-git');
const commitGit = require('./helper/git/commit-git');
const pushGit = require('./helper/git/push-git');
const configFile = require('./helper/file/config_file');
const outputCheckpoint = require('./helper/checkpoint/output_checkpoint');
const outputCache = require('./helper/cache/output_cache');
const outputMarkdown = require('./helper/markdown/output_markdown');
const outputHtml = require('./helper/html/output_html');
const createHtmlFile = require('./helper/html/file/create_html_file');
const createRankingJsonFile = require('./helper/html/file/create_ranking_json_file');
const createIndexPage = require('./helper/markdown/page/create_index_page');
const createPublicContributionsPage = require('./helper/markdown/page/create_public_contributions_page');
const createTotalContributionsPage = require('./helper/markdown/page/create_total_contributions_page');
const createFollowersPage = require('./helper/markdown/page/create_followers_page');
const requestOctokit = require('./helper/octokit/request_octokit');
const formatMarkdown = require('./helper/markdown/format_markdown');
const OutputMarkdownModel = require('./model/markdown/OutputMarkdownModel');
let Index = function () {
// const AUTH_KEY = "";
// const GITHUB_USERNAME_AND_REPOSITORY = 'gayanvoice/top-github-users';
const AUTH_KEY = process.env.CUSTOM_TOKEN;
const GITHUB_USERNAME_AND_REPOSITORY = process.env.GITHUB_REPOSITORY;
const MAXIMUM_ERROR_ITERATIONS = 4;
let getCheckpoint = async function (locationsArray, country, checkpoint) {
let indexOfTheCountry = locationsArray.findIndex(location => location.country === country);
if(indexOfTheCountry === checkpoint){
console.log("checkpoint set", country)
return true;
} else {
console.log("checkpoint not set", country)
return false;
}
}
let saveCache = async function (readConfigResponseModel, readCheckpointResponseModel) {
console.log(`########## SaveCache ##########`)
for await(const locationDataModel of readConfigResponseModel.locations){
let isCheckpoint = await getCheckpoint(readConfigResponseModel.locations, locationDataModel.country, readCheckpointResponseModel.checkpoint);
if(isCheckpoint){
let json = await requestOctokit.request(AUTH_KEY, MAXIMUM_ERROR_ITERATIONS, locationDataModel.locations);
let readCacheResponseModel = await outputCache.readCacheFile(locationDataModel.country);
if(readCacheResponseModel.status){
if(readCacheResponseModel.users.length > json.length){
if(json.length > 750) {
console.log(`request success minimum:750 cache:${readCacheResponseModel.users.length} octokit:${json.length}`);
await outputCache.saveCacheFile(locationDataModel.country, json);
}
else
{
console.log(`octokit error minimum:750 cache:${readCacheResponseModel.users.length} octokit:${json.length}`);
}
} else {
console.log(`request success cache:${readCacheResponseModel.users.length} octokit:${json.length}`);
await outputCache.saveCacheFile(locationDataModel.country, json);
}
} else {
console.log(`request success octokit:${json.length}`);
await outputCache.saveCacheFile(locationDataModel.country, json);
}
}
}
}
let saveMarkdown = async function (readConfigResponseModel, readCheckpointResponseModel) {
console.log(`########## SaveMarkDown ##########`)
for await(const locationDataModel of readConfigResponseModel.locations){
let isCheckpoint = await getCheckpoint(readConfigResponseModel.locations, locationDataModel.country, readCheckpointResponseModel.checkpoint)
if(isCheckpoint){
let readCacheResponseModel = await outputCache.readCacheFile(locationDataModel.country);
if(readCacheResponseModel.status) {
let outputMarkdownModel = new OutputMarkdownModel(GITHUB_USERNAME_AND_REPOSITORY, locationDataModel, readCacheResponseModel, readConfigResponseModel);
await outputMarkdown.savePublicContributionsMarkdownFile(locationDataModel.country, createPublicContributionsPage.create(outputMarkdownModel));
await outputMarkdown.saveTotalContributionsMarkdownFile(locationDataModel.country, createTotalContributionsPage.create(outputMarkdownModel));
await outputMarkdown.saveFollowersMarkdownFile(locationDataModel.country, createFollowersPage.create(outputMarkdownModel));
}
}
await outputCheckpoint.saveCheckpointFile(readConfigResponseModel.locations, locationDataModel.country, readCheckpointResponseModel.checkpoint)
}
if(!readConfigResponseModel.devMode) await outputMarkdown.saveIndexMarkdownFile(createIndexPage.create(GITHUB_USERNAME_AND_REPOSITORY, readConfigResponseModel));
}
let saveHtml = async function (readConfigResponseModel) {
console.log(`########## SaveHtml ##########`);
await outputHtml.saveRankingJsonFile(await createRankingJsonFile.create(readConfigResponseModel));
await outputHtml.saveHtmlFile(createHtmlFile.create());
}
let main = async function () {
let readConfigResponseModel = await configFile.readConfigFile();
let readCheckpointResponseModel = await outputCheckpoint.readCheckpointFile();
if(readConfigResponseModel.status && readCheckpointResponseModel.status){
if(!readConfigResponseModel.devMode) await pullGit.pull();
let checkpointCountry = readConfigResponseModel.locations[readCheckpointResponseModel.checkpoint].country
await saveCache(readConfigResponseModel, readCheckpointResponseModel);
await saveMarkdown(readConfigResponseModel, readCheckpointResponseModel)
await saveHtml(readConfigResponseModel)
if(!readConfigResponseModel.devMode) await commitGit.commit(`Update ${formatMarkdown.capitalizeTheFirstLetterOfEachWord(checkpointCountry)}`);
if(!readConfigResponseModel.devMode) await pushGit.push();
}
}
return {
main: main,
};
}();
Index.main().then(() => { });