Compare commits
25 Commits
ec6edf598c
...
v1.2.1
| Author | SHA1 | Date | |
|---|---|---|---|
| 2e816c2bf9 | |||
| f4c3e02c1a | |||
| 3db973febc | |||
| c70e8e49ec | |||
| 24ed23098d | |||
| 872d9c790f | |||
| 0dce32781b | |||
| 08799b48d7 | |||
| 62c6216878 | |||
| 725638ee6b | |||
| f907a64f08 | |||
| 3b4496864b | |||
| eb4666c3df | |||
| def91e35d3 | |||
| 4794c6be26 | |||
| b68c3dab33 | |||
| 68cccb72a9 | |||
| 87f4a94734 | |||
| a28d6a2509 | |||
| ced41f4a49 | |||
| c117cb847d | |||
| d1cfd7c20b | |||
| b6b5c27ffc | |||
| def95cd838 | |||
| 79f21f8a54 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -9,3 +9,4 @@ coverage
|
|||||||
.nyc_output
|
.nyc_output
|
||||||
coverage.lcov
|
coverage.lcov
|
||||||
/lib
|
/lib
|
||||||
|
/data
|
||||||
3
AUTHORS.md
Normal file
3
AUTHORS.md
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
### Authors
|
||||||
|
|
||||||
|
- joe fleming ([w33ble](https://github.com/w33ble))
|
||||||
30
CHANGELOG.md
Normal file
30
CHANGELOG.md
Normal file
@@ -0,0 +1,30 @@
|
|||||||
|
### Changelog
|
||||||
|
|
||||||
|
#### [v1.2.1](https://git.w33ble.com/w33ble/gh-action-bot/compare/v1.2.0...v1.2.1) (23 October 2018)
|
||||||
|
- feat: add more debugging output [`3db973f`](https://git.w33ble.com/w33ble/gh-action-bot/commit/3db973febc5387605279f7855976a4ec431f0362)
|
||||||
|
- fix: correctly handle errors in logger.error [`c70e8e4`](https://git.w33ble.com/w33ble/gh-action-bot/commit/c70e8e49ecb9041b22a8f4b92398339d45871ca1)
|
||||||
|
- fix: correctly check for pr author [`f4c3e02`](https://git.w33ble.com/w33ble/gh-action-bot/commit/f4c3e02c1a31aea89a565f5685dd3b879bd38b14)
|
||||||
|
|
||||||
|
#### [v1.2.0](https://git.w33ble.com/w33ble/gh-action-bot/compare/v1.1.0...v1.2.0) (23 October 2018)
|
||||||
|
- feat: add debugging output to script [`0dce327`](https://git.w33ble.com/w33ble/gh-action-bot/commit/0dce32781b0f8c138d7f8b28382289d67be730dd)
|
||||||
|
- feat: debug logging and better timestamps [`08799b4`](https://git.w33ble.com/w33ble/gh-action-bot/commit/08799b48d74d12266d5ebb85811f5d3fa046b086)
|
||||||
|
- docs: add note about using DEBUG=1 output [`872d9c7`](https://git.w33ble.com/w33ble/gh-action-bot/commit/872d9c790fc723f1b255536225be60f547cf5196)
|
||||||
|
|
||||||
|
#### [v1.1.0](https://git.w33ble.com/w33ble/gh-action-bot/compare/v1.0.1...v1.1.0) (22 October 2018)
|
||||||
|
- feat: add timestamp to log output [`725638e`](https://git.w33ble.com/w33ble/gh-action-bot/commit/725638ee6b7fbb816518239f5524f6c37056da2e)
|
||||||
|
|
||||||
|
#### [v1.0.1](https://git.w33ble.com/w33ble/gh-action-bot/compare/v1.0.0...v1.0.1) (22 October 2018)
|
||||||
|
- feat: add a force retest script [`def91e3`](https://git.w33ble.com/w33ble/gh-action-bot/commit/def91e35d3c8028b7f78772049b0e93c3c8d677e)
|
||||||
|
- fix: add error handling code [`3b44968`](https://git.w33ble.com/w33ble/gh-action-bot/commit/3b4496864b0e9bd248e6d4ea12f2608dd41c0374)
|
||||||
|
- docs: add info about force script [`eb4666c`](https://git.w33ble.com/w33ble/gh-action-bot/commit/eb4666c3df312a9b5d8eb8ff5cf58027d794b417)
|
||||||
|
- docs: add token info to readme [`4794c6b`](https://git.w33ble.com/w33ble/gh-action-bot/commit/4794c6be2673402d5a76d8c61974ba3f9c936977)
|
||||||
|
|
||||||
|
### [v1.0.0](https://git.w33ble.com/w33ble/gh-action-bot/compare/v0.1.0...v1.0.0) (18 October 2018)
|
||||||
|
- feat: allow filtering by pr author [`68cccb7`](https://git.w33ble.com/w33ble/gh-action-bot/commit/68cccb72a9801c502003c7b913844fc01721a6e3)
|
||||||
|
|
||||||
|
#### v0.1.0 (18 October 2018)
|
||||||
|
- docs: update readme, add sample env [`a28d6a2`](https://git.w33ble.com/w33ble/gh-action-bot/commit/a28d6a25096efb9c8acea3e8d26e7f7f50dfd6b5)
|
||||||
|
- feat: add retest comment, delete it [`ced41f4`](https://git.w33ble.com/w33ble/gh-action-bot/commit/ced41f4a495823205e5769e4531f923a982d29b4)
|
||||||
|
- feat: process 2 pages of events [`c117cb8`](https://git.w33ble.com/w33ble/gh-action-bot/commit/c117cb847d5cb7a6b57b705e0c192cc725c0d646)
|
||||||
|
- feat: fetch data for prs that need retest [`d1cfd7c`](https://git.w33ble.com/w33ble/gh-action-bot/commit/d1cfd7c20b17802f2de1b9153ae9a8392ed1bc44)
|
||||||
|
- feat: add history tracking [`b6b5c27`](https://git.w33ble.com/w33ble/gh-action-bot/commit/b6b5c27ffc43ff2e1c1ccf041958021cf7c8c4d4)
|
||||||
21
README.md
21
README.md
@@ -1,10 +1,25 @@
|
|||||||
# gh-action-bot
|
# gh-action-bot
|
||||||
|
|
||||||
Action bot for Github.
|
Action bot for Github. Checks a repo's event stream and leaves a ghost comment when your criteria is met.
|
||||||
|
|
||||||
[](https://raw.githubusercontent.com/w33ble/gh-action-bot/master/LICENSE)
|
[](https://raw.githubusercontent.com/w33ble/gh-action-bot/master/LICENSE)
|
||||||
[](https://www.npmjs.com/package/gh-action-bot)
|
[](https://nodejs.org/api/documentation.html#documentation_stability_index)
|
||||||
[](https://nodejs.org/api/documentation.html#documentation_stability_index)
|
|
||||||
|
## Usage
|
||||||
|
|
||||||
|
`yarn start owner/repo`: watch the event stream and handle matches
|
||||||
|
|
||||||
|
`yarn run force owner/repo pr_number`: force a comment on a specific pr, by number
|
||||||
|
|
||||||
|
You'll need to set some environment flags. Check `sample-env` for what is available, and you can copy the file to `.env` in the root and add your settings there as well.
|
||||||
|
|
||||||
|
### Personal Access Token
|
||||||
|
|
||||||
|
You will need to provide a Github [Personal Access Token](https://github.com/settings/tokens/new). It will need `write:org` access in order to create comments.
|
||||||
|
|
||||||
|
### Debugging
|
||||||
|
|
||||||
|
If the script isn't doing what you expect, you can get more output from it by prepending the script with `DEBUG=1`.
|
||||||
|
|
||||||
#### License
|
#### License
|
||||||
|
|
||||||
|
|||||||
0
data/.empty
Normal file
0
data/.empty
Normal file
2
index.js
2
index.js
@@ -2,4 +2,4 @@
|
|||||||
require = require('esm')(module);
|
require = require('esm')(module);
|
||||||
const mod = require('./src/index.mjs').default;
|
const mod = require('./src/index.mjs').default;
|
||||||
|
|
||||||
module.exports = mod;
|
mod();
|
||||||
|
|||||||
@@ -1,3 +1,3 @@
|
|||||||
import mod from './src/index.mjs';
|
import mod from './src/index.mjs';
|
||||||
|
|
||||||
export default mod;
|
mod();
|
||||||
|
|||||||
10
package.json
10
package.json
@@ -1,6 +1,7 @@
|
|||||||
{
|
{
|
||||||
"name": "gh-action-bot",
|
"name": "gh-action-bot",
|
||||||
"version": "0.0.0",
|
"version": "1.2.1",
|
||||||
|
"private": true,
|
||||||
"description": "Action bot for Github",
|
"description": "Action bot for Github",
|
||||||
"main": "index",
|
"main": "index",
|
||||||
"module": "index.mjs",
|
"module": "index.mjs",
|
||||||
@@ -8,7 +9,8 @@
|
|||||||
"lint": "eslint \"*.{js,mjs}\" \"src/**/*.{js,mjs}\"",
|
"lint": "eslint \"*.{js,mjs}\" \"src/**/*.{js,mjs}\"",
|
||||||
"precommit": "lint-staged",
|
"precommit": "lint-staged",
|
||||||
"version": "auto-changelog -p && auto-authors && git add CHANGELOG.md AUTHORS.md",
|
"version": "auto-changelog -p && auto-authors && git add CHANGELOG.md AUTHORS.md",
|
||||||
"start": "node ."
|
"start": "node .",
|
||||||
|
"force": "node -r esm src/force.mjs"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@@ -52,7 +54,9 @@
|
|||||||
"cjs": true
|
"cjs": true
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"esm": "^3.0.17"
|
"dotenv": "^6.1.0",
|
||||||
|
"esm": "^3.0.17",
|
||||||
|
"octokat": "^0.10.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"auto-authors": "^0.1.1",
|
"auto-authors": "^0.1.1",
|
||||||
|
|||||||
7
sample-env
Normal file
7
sample-env
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
GITHUB_ACCESS_TOKEN=xxx
|
||||||
|
COMMENT_ACTOR=username
|
||||||
|
COMMENT_BODY_REGEXP=build failed
|
||||||
|
COMMENT_BODY_REGEXP_FLAGS=i
|
||||||
|
PULL_LABEL_FILTER=
|
||||||
|
PULL_AUTHOR_FILTER=
|
||||||
|
PULL_RETEST_BODY=retest
|
||||||
20
src/force.mjs
Normal file
20
src/force.mjs
Normal file
@@ -0,0 +1,20 @@
|
|||||||
|
import dotenv from 'dotenv';
|
||||||
|
import createRepo from './lib/create_repo.mjs';
|
||||||
|
import { createComment, deleteComment } from './lib/comments.mjs';
|
||||||
|
|
||||||
|
dotenv.config();
|
||||||
|
|
||||||
|
async function forceRetest() {
|
||||||
|
const [ownerRepo, prNumber] = process.argv.splice(2);
|
||||||
|
const { PULL_RETEST_BODY } = process.env;
|
||||||
|
|
||||||
|
if (!ownerRepo || !prNumber) {
|
||||||
|
throw new Error('You must specify an owner/repo combo and a pull request number');
|
||||||
|
}
|
||||||
|
|
||||||
|
const repo = createRepo(ownerRepo);
|
||||||
|
const comment = await createComment(repo, prNumber, PULL_RETEST_BODY);
|
||||||
|
await deleteComment(repo, comment.id);
|
||||||
|
}
|
||||||
|
|
||||||
|
forceRetest().catch(err => console.error(err));
|
||||||
@@ -1,3 +1,92 @@
|
|||||||
export default function() {
|
import dotenv from 'dotenv';
|
||||||
// es6 module code goes here
|
import logger from './lib/logger.mjs';
|
||||||
|
import createRepo from './lib/create_repo.mjs';
|
||||||
|
import getComments from './lib/get_comments.mjs';
|
||||||
|
import getPull from './lib/get_pull.mjs';
|
||||||
|
import getCommits from './lib/get_commits.mjs';
|
||||||
|
import getCommitStatus from './lib/get_commit_status.mjs';
|
||||||
|
import { createComment, deleteComment } from './lib/comments.mjs';
|
||||||
|
import History from './lib/history.mjs';
|
||||||
|
|
||||||
|
// load env vars from .env file
|
||||||
|
dotenv.config();
|
||||||
|
|
||||||
|
async function ghActionBot() {
|
||||||
|
// parse repo name from cli and create repo instance
|
||||||
|
const repo = createRepo(process.argv.splice(2)[0]);
|
||||||
|
|
||||||
|
const {
|
||||||
|
COMMENT_BODY_REGEXP,
|
||||||
|
COMMENT_BODY_REGEXP_FLAGS,
|
||||||
|
COMMENT_ACTOR,
|
||||||
|
PULL_LABEL_FILTER,
|
||||||
|
PULL_AUTHOR_FILTER,
|
||||||
|
PULL_RETEST_BODY,
|
||||||
|
} = process.env;
|
||||||
|
|
||||||
|
// load the history module
|
||||||
|
const history = new History();
|
||||||
|
|
||||||
|
// fetch comment info from event stream, filter for only new comments
|
||||||
|
const comments = (await getComments(repo, {
|
||||||
|
body: new RegExp(COMMENT_BODY_REGEXP, COMMENT_BODY_REGEXP_FLAGS),
|
||||||
|
actor: COMMENT_ACTOR,
|
||||||
|
})).filter(comment => !history.get(comment.id));
|
||||||
|
|
||||||
|
// read pull data
|
||||||
|
const pulls = (await Promise.all(
|
||||||
|
comments.map(async comment => {
|
||||||
|
const pull = await getPull(repo, comment.number);
|
||||||
|
|
||||||
|
if (pull.state !== 'open') {
|
||||||
|
logger.debug(`SKIP #${pull.number}: state is ${pull.state}`);
|
||||||
|
return false; // filter out any closed pulls
|
||||||
|
}
|
||||||
|
if (PULL_AUTHOR_FILTER && pull.owner !== PULL_AUTHOR_FILTER) {
|
||||||
|
logger.debug(`SKIP #${pull.number}: author is ${pull.owner}`);
|
||||||
|
return false; // filter on owner
|
||||||
|
}
|
||||||
|
if (PULL_LABEL_FILTER && !pull.labels.includes(PULL_LABEL_FILTER)) {
|
||||||
|
logger.debug(`SKIP #${pull.number}: labels are ${pull.labels.join(',')}`);
|
||||||
|
return false; // filter on label
|
||||||
|
}
|
||||||
|
|
||||||
|
return { comment, pull };
|
||||||
|
})
|
||||||
|
)).filter(Boolean);
|
||||||
|
|
||||||
|
const records = (await Promise.all(
|
||||||
|
pulls.map(async ({ pull, comment }) => {
|
||||||
|
const commit = await getCommits(repo, pull.number, true);
|
||||||
|
const buildStatus = await getCommitStatus(repo, commit.sha);
|
||||||
|
// do nothing if the build has not started, or is pending or successful
|
||||||
|
if (!buildStatus || buildStatus.state === 'pending' || buildStatus.state === 'success') {
|
||||||
|
logger.debug(`SKIP #${pull.number}: build status is ${buildStatus.state}`);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return { comment, pull, commit, buildStatus };
|
||||||
|
})
|
||||||
|
)).filter(Boolean);
|
||||||
|
|
||||||
|
if (records.length) {
|
||||||
|
logger.log(`Found ${records.length} outstanding failures`);
|
||||||
|
} else {
|
||||||
|
logger.debug(`Found ${records.length} outstanding failures`);
|
||||||
|
}
|
||||||
|
|
||||||
|
await Promise.all(
|
||||||
|
records.map(async record => {
|
||||||
|
logger.log(`Re-testing PR #${record.pull.number}`);
|
||||||
|
const comment = await createComment(repo, records[0].pull.number, PULL_RETEST_BODY);
|
||||||
|
logger.debug(`Created comment id ${comment.id}`);
|
||||||
|
await deleteComment(repo, comment.id);
|
||||||
|
})
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
export default function() {
|
||||||
|
return ghActionBot().catch(err => {
|
||||||
|
logger.error(err);
|
||||||
|
return process.exit(1);
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|||||||
7
src/lib/comments.mjs
Normal file
7
src/lib/comments.mjs
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
export async function createComment(repo, issueId, body) {
|
||||||
|
return repo.issues(issueId).comments.create({ body });
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function deleteComment(repo, commentId) {
|
||||||
|
return repo.issues.comments(commentId).remove();
|
||||||
|
}
|
||||||
21
src/lib/create_repo.mjs
Normal file
21
src/lib/create_repo.mjs
Normal file
@@ -0,0 +1,21 @@
|
|||||||
|
/* eslint no-console: 0 */
|
||||||
|
import Octokat from 'octokat';
|
||||||
|
|
||||||
|
function usageError() {
|
||||||
|
console.error('You must provide a github repo in the form of "owner/repo"');
|
||||||
|
process.exit(1);
|
||||||
|
}
|
||||||
|
|
||||||
|
export default function(repo) {
|
||||||
|
if (typeof repo !== 'string' || repo.length === 0) usageError();
|
||||||
|
const settings = {
|
||||||
|
token: process.env.GITHUB_ACCESS_TOKEN,
|
||||||
|
};
|
||||||
|
|
||||||
|
const octo = new Octokat(settings);
|
||||||
|
const [owner, name] = repo.split('/');
|
||||||
|
|
||||||
|
if (!owner || !name) usageError();
|
||||||
|
|
||||||
|
return octo.repos(owner, name);
|
||||||
|
}
|
||||||
54
src/lib/get_comments.mjs
Normal file
54
src/lib/get_comments.mjs
Normal file
@@ -0,0 +1,54 @@
|
|||||||
|
import logger from './logger.mjs';
|
||||||
|
|
||||||
|
export default async function getEvents(repo, { body, actor } = {}) {
|
||||||
|
const events = await repo.events.fetch();
|
||||||
|
|
||||||
|
const items = await (async () => {
|
||||||
|
// process 2 pages of events
|
||||||
|
if (events.nextPage) {
|
||||||
|
const moreEvents = await events.nextPage.fetch();
|
||||||
|
return [...events.items, ...moreEvents.items];
|
||||||
|
}
|
||||||
|
|
||||||
|
return events.items;
|
||||||
|
})();
|
||||||
|
|
||||||
|
return items
|
||||||
|
.map(comment => {
|
||||||
|
let skip = false;
|
||||||
|
const isComment = comment.type === 'IssueCommentEvent';
|
||||||
|
const bodyMatch = isComment && (!body || body.test(comment.payload.comment.body));
|
||||||
|
const isActor = comment.actor.login === actor;
|
||||||
|
|
||||||
|
// skip events that don't match the criteria
|
||||||
|
if (!isComment) skip = true;
|
||||||
|
if (comment.payload.action !== 'created') skip = true;
|
||||||
|
if (!isActor) skip = true;
|
||||||
|
if (isComment && !bodyMatch) skip = true;
|
||||||
|
|
||||||
|
if (skip) {
|
||||||
|
if (isActor) {
|
||||||
|
logger.debug(
|
||||||
|
`SKIP EVENT ${isComment ? `#${comment.payload.issue.number}` : comment.id}: ${
|
||||||
|
comment.type
|
||||||
|
} ${comment.payload.action} by ${comment.actor.login}`,
|
||||||
|
isComment && !bodyMatch && `(${comment.payload.comment.body.slice(0, 30)})`
|
||||||
|
);
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.debug(`PROCESS #${comment.payload.issue.number}`);
|
||||||
|
|
||||||
|
return {
|
||||||
|
id: comment.id,
|
||||||
|
number: comment.payload.issue.number,
|
||||||
|
owner: comment.payload.issue.user.login,
|
||||||
|
labels: comment.payload.issue.labels.map(label => label.name),
|
||||||
|
comment_id: comment.payload.comment.id,
|
||||||
|
comment_author: comment.payload.comment.user.login,
|
||||||
|
comment_body: comment.payload.comment.body,
|
||||||
|
};
|
||||||
|
})
|
||||||
|
.filter(Boolean);
|
||||||
|
}
|
||||||
22
src/lib/get_commit_status.mjs
Normal file
22
src/lib/get_commit_status.mjs
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
function getBuildStatus({ items: statuses }) {
|
||||||
|
const buildStatus = statuses.find(status => status.context === 'kibana-ci');
|
||||||
|
if (!buildStatus) return buildStatus;
|
||||||
|
return {
|
||||||
|
id: buildStatus.id,
|
||||||
|
url: buildStatus.url,
|
||||||
|
state: buildStatus.state,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
export default async function getCommitStatus(repo, sha) {
|
||||||
|
const statuses = await repo.commits(sha).statuses.fetch();
|
||||||
|
|
||||||
|
const buildStatus = await (async stats => {
|
||||||
|
if (stats.lastPage) {
|
||||||
|
return getBuildStatus(await stats.lastPage.fetch());
|
||||||
|
}
|
||||||
|
return getBuildStatus(stats);
|
||||||
|
})(statuses);
|
||||||
|
|
||||||
|
return buildStatus;
|
||||||
|
}
|
||||||
23
src/lib/get_commits.mjs
Normal file
23
src/lib/get_commits.mjs
Normal file
@@ -0,0 +1,23 @@
|
|||||||
|
function formatCommit(commit) {
|
||||||
|
return {
|
||||||
|
sha: commit.sha,
|
||||||
|
owner: commit.committer.login,
|
||||||
|
message: commit.commit.message,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
function formatCommits(commits, lastOnly) {
|
||||||
|
if (lastOnly) return formatCommit(commits.pop());
|
||||||
|
return commits.map(c => formatCommit(c));
|
||||||
|
}
|
||||||
|
|
||||||
|
export default async function getCommits(repo, id, lastOnly = true) {
|
||||||
|
const commits = await repo.pulls(id).commits.fetch();
|
||||||
|
|
||||||
|
if (commits.lastPage) {
|
||||||
|
const { items } = await commits.lastPage.fetch();
|
||||||
|
return formatCommits(items, lastOnly);
|
||||||
|
}
|
||||||
|
|
||||||
|
return formatCommits(commits.items, lastOnly);
|
||||||
|
}
|
||||||
12
src/lib/get_pull.mjs
Normal file
12
src/lib/get_pull.mjs
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
export default async function getPull(repo, id) {
|
||||||
|
const pull = await repo.pulls(id).fetch();
|
||||||
|
return {
|
||||||
|
id: pull.id,
|
||||||
|
url: pull.url,
|
||||||
|
number: pull.number,
|
||||||
|
owner: pull.user.login,
|
||||||
|
state: pull.state,
|
||||||
|
title: pull.title,
|
||||||
|
labels: pull.labels.map(label => label.name),
|
||||||
|
};
|
||||||
|
}
|
||||||
30
src/lib/history.mjs
Normal file
30
src/lib/history.mjs
Normal file
@@ -0,0 +1,30 @@
|
|||||||
|
import fs from 'fs';
|
||||||
|
import path from 'path';
|
||||||
|
|
||||||
|
export default class History {
|
||||||
|
constructor() {
|
||||||
|
this.filePath = path.resolve('data', 'history.json');
|
||||||
|
try {
|
||||||
|
const data = fs.readFileSync(this.filePath);
|
||||||
|
this.db = data.length === 0 ? [] : JSON.parse(data);
|
||||||
|
} catch (e) {
|
||||||
|
this.db = [];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
get(id) {
|
||||||
|
return this.db.find(doc => parseInt(doc.id, 10) === parseInt(id, 10));
|
||||||
|
}
|
||||||
|
|
||||||
|
add(doc) {
|
||||||
|
// prevent duplicate entries
|
||||||
|
if (this.get(doc.id)) return;
|
||||||
|
|
||||||
|
// add doc to history, truncate as needed
|
||||||
|
this.db.push(doc);
|
||||||
|
if (this.db.length > 1000) this.db.splice(0, 1000);
|
||||||
|
|
||||||
|
// write the updated content to the file
|
||||||
|
fs.writeFileSync(this.filePath, JSON.stringify(this.db), { encoding: 'utf8' });
|
||||||
|
}
|
||||||
|
}
|
||||||
43
src/lib/logger.mjs
Normal file
43
src/lib/logger.mjs
Normal file
@@ -0,0 +1,43 @@
|
|||||||
|
/* eslint no-console: 0 */
|
||||||
|
const zeroPad = (str, len) => {
|
||||||
|
let output = `${str}`;
|
||||||
|
if (!len || len <= output.length) return str;
|
||||||
|
|
||||||
|
while (output.length < len) {
|
||||||
|
output = `0${output}`;
|
||||||
|
}
|
||||||
|
return output;
|
||||||
|
};
|
||||||
|
|
||||||
|
const getTimestamp = () => {
|
||||||
|
const d = new Date();
|
||||||
|
return `${[d.getFullYear(), zeroPad(d.getMonth(), 2), zeroPad(d.getDate(), 2)].join('/')} ${[
|
||||||
|
zeroPad(d.getHours(), 2),
|
||||||
|
zeroPad(d.getMinutes(), 2),
|
||||||
|
zeroPad(d.getSeconds(), 2),
|
||||||
|
].join(':')}`;
|
||||||
|
};
|
||||||
|
|
||||||
|
const wrapMessage = msg => `[${getTimestamp()}]: ${msg.join(' ')}`;
|
||||||
|
|
||||||
|
const logger = {
|
||||||
|
log(...args) {
|
||||||
|
console.log(wrapMessage(args));
|
||||||
|
},
|
||||||
|
warn(...args) {
|
||||||
|
console.warn(wrapMessage(args));
|
||||||
|
},
|
||||||
|
error(...args) {
|
||||||
|
if (args[0] instanceof Error) {
|
||||||
|
console.error(getTimestamp(), args[0].stack);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
console.error(wrapMessage(args));
|
||||||
|
},
|
||||||
|
debug(...args) {
|
||||||
|
if (!process.env.DEBUG) return;
|
||||||
|
console.log(wrapMessage(args));
|
||||||
|
},
|
||||||
|
};
|
||||||
|
|
||||||
|
export default logger;
|
||||||
50
yarn.lock
50
yarn.lock
@@ -561,6 +561,11 @@ doctrine@^2.1.0:
|
|||||||
dependencies:
|
dependencies:
|
||||||
esutils "^2.0.2"
|
esutils "^2.0.2"
|
||||||
|
|
||||||
|
dotenv@^6.1.0:
|
||||||
|
version "6.1.0"
|
||||||
|
resolved "https://registry.yarnpkg.com/dotenv/-/dotenv-6.1.0.tgz#9853b6ca98292acb7dec67a95018fa40bccff42c"
|
||||||
|
integrity sha512-/veDn2ztgRlB7gKmE3i9f6CmDIyXAy6d5nBq+whO9SLX+Zs1sXEgFLPi+aSuWqUuusMfbi84fT8j34fs1HaYUw==
|
||||||
|
|
||||||
elegant-spinner@^1.0.1:
|
elegant-spinner@^1.0.1:
|
||||||
version "1.0.1"
|
version "1.0.1"
|
||||||
resolved "https://registry.yarnpkg.com/elegant-spinner/-/elegant-spinner-1.0.1.tgz#db043521c95d7e303fd8f345bedc3349cfb0729e"
|
resolved "https://registry.yarnpkg.com/elegant-spinner/-/elegant-spinner-1.0.1.tgz#db043521c95d7e303fd8f345bedc3349cfb0729e"
|
||||||
@@ -571,6 +576,13 @@ emoji-regex@^6.5.1:
|
|||||||
resolved "https://registry.yarnpkg.com/emoji-regex/-/emoji-regex-6.5.1.tgz#9baea929b155565c11ea41c6626eaa65cef992c2"
|
resolved "https://registry.yarnpkg.com/emoji-regex/-/emoji-regex-6.5.1.tgz#9baea929b155565c11ea41c6626eaa65cef992c2"
|
||||||
integrity sha512-PAHp6TxrCy7MGMFidro8uikr+zlJJKJ/Q6mm2ExZ7HwkyR9lSVFfE3kt36qcwa24BQL7y0G9axycGjK1A/0uNQ==
|
integrity sha512-PAHp6TxrCy7MGMFidro8uikr+zlJJKJ/Q6mm2ExZ7HwkyR9lSVFfE3kt36qcwa24BQL7y0G9axycGjK1A/0uNQ==
|
||||||
|
|
||||||
|
encoding@^0.1.11:
|
||||||
|
version "0.1.12"
|
||||||
|
resolved "https://registry.yarnpkg.com/encoding/-/encoding-0.1.12.tgz#538b66f3ee62cd1ab51ec323829d1f9480c74beb"
|
||||||
|
integrity sha1-U4tm8+5izRq1HsMjgp0flIDHS+s=
|
||||||
|
dependencies:
|
||||||
|
iconv-lite "~0.4.13"
|
||||||
|
|
||||||
error-ex@^1.2.0, error-ex@^1.3.1:
|
error-ex@^1.2.0, error-ex@^1.3.1:
|
||||||
version "1.3.2"
|
version "1.3.2"
|
||||||
resolved "https://registry.yarnpkg.com/error-ex/-/error-ex-1.3.2.tgz#b4ac40648107fdcdcfae242f428bea8a14d4f1bf"
|
resolved "https://registry.yarnpkg.com/error-ex/-/error-ex-1.3.2.tgz#b4ac40648107fdcdcfae242f428bea8a14d4f1bf"
|
||||||
@@ -882,6 +894,14 @@ fast-levenshtein@~2.0.4:
|
|||||||
resolved "https://registry.yarnpkg.com/fast-levenshtein/-/fast-levenshtein-2.0.6.tgz#3d8a5c66883a16a30ca8643e851f19baa7797917"
|
resolved "https://registry.yarnpkg.com/fast-levenshtein/-/fast-levenshtein-2.0.6.tgz#3d8a5c66883a16a30ca8643e851f19baa7797917"
|
||||||
integrity sha1-PYpcZog6FqMMqGQ+hR8Zuqd5eRc=
|
integrity sha1-PYpcZog6FqMMqGQ+hR8Zuqd5eRc=
|
||||||
|
|
||||||
|
fetch-vcr@^1.1.0:
|
||||||
|
version "1.1.2"
|
||||||
|
resolved "https://registry.yarnpkg.com/fetch-vcr/-/fetch-vcr-1.1.2.tgz#8cfee49c45b464366b97fe550487dde15b948d21"
|
||||||
|
integrity sha512-bFOx3+5YtViximcqhG05tqMlsyPRXNOmiToDCf6TyVUCKHYP/vGPmn0HUhGVNd1jI0KpElwz+RH3X/ZQo0Asfg==
|
||||||
|
dependencies:
|
||||||
|
node-fetch "^1.6.3"
|
||||||
|
whatwg-fetch "^2.0.3"
|
||||||
|
|
||||||
figures@^1.7.0:
|
figures@^1.7.0:
|
||||||
version "1.7.0"
|
version "1.7.0"
|
||||||
resolved "https://registry.yarnpkg.com/figures/-/figures-1.7.0.tgz#cbe1e3affcf1cd44b80cadfed28dc793a9701d2e"
|
resolved "https://registry.yarnpkg.com/figures/-/figures-1.7.0.tgz#cbe1e3affcf1cd44b80cadfed28dc793a9701d2e"
|
||||||
@@ -1106,7 +1126,7 @@ husky@^0.14.3:
|
|||||||
normalize-path "^1.0.0"
|
normalize-path "^1.0.0"
|
||||||
strip-indent "^2.0.0"
|
strip-indent "^2.0.0"
|
||||||
|
|
||||||
iconv-lite@^0.4.17:
|
iconv-lite@^0.4.17, iconv-lite@~0.4.13:
|
||||||
version "0.4.24"
|
version "0.4.24"
|
||||||
resolved "https://registry.yarnpkg.com/iconv-lite/-/iconv-lite-0.4.24.tgz#2022b4b25fbddc21d2f524974a474aafe733908b"
|
resolved "https://registry.yarnpkg.com/iconv-lite/-/iconv-lite-0.4.24.tgz#2022b4b25fbddc21d2f524974a474aafe733908b"
|
||||||
integrity sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA==
|
integrity sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA==
|
||||||
@@ -1349,7 +1369,7 @@ is-resolvable@^1.0.0:
|
|||||||
resolved "https://registry.yarnpkg.com/is-resolvable/-/is-resolvable-1.1.0.tgz#fb18f87ce1feb925169c9a407c19318a3206ed88"
|
resolved "https://registry.yarnpkg.com/is-resolvable/-/is-resolvable-1.1.0.tgz#fb18f87ce1feb925169c9a407c19318a3206ed88"
|
||||||
integrity sha512-qgDYXFSR5WvEfuS5dMj6oTMEbrrSaM0CrFk2Yiq/gXnBvD9pMa2jGXxyhGLfvhZpuMZe18CJpFxAt3CRs42NMg==
|
integrity sha512-qgDYXFSR5WvEfuS5dMj6oTMEbrrSaM0CrFk2Yiq/gXnBvD9pMa2jGXxyhGLfvhZpuMZe18CJpFxAt3CRs42NMg==
|
||||||
|
|
||||||
is-stream@^1.1.0:
|
is-stream@^1.0.1, is-stream@^1.1.0:
|
||||||
version "1.1.0"
|
version "1.1.0"
|
||||||
resolved "https://registry.yarnpkg.com/is-stream/-/is-stream-1.1.0.tgz#12d4a3dd4e68e0b79ceb8dbc84173ae80d91ca44"
|
resolved "https://registry.yarnpkg.com/is-stream/-/is-stream-1.1.0.tgz#12d4a3dd4e68e0b79ceb8dbc84173ae80d91ca44"
|
||||||
integrity sha1-EtSj3U5o4Lec6428hBc66A2RykQ=
|
integrity sha1-EtSj3U5o4Lec6428hBc66A2RykQ=
|
||||||
@@ -1580,7 +1600,7 @@ lodash.uniqby@^4.7.0:
|
|||||||
resolved "https://registry.yarnpkg.com/lodash.uniqby/-/lodash.uniqby-4.7.0.tgz#d99c07a669e9e6d24e1362dfe266c67616af1302"
|
resolved "https://registry.yarnpkg.com/lodash.uniqby/-/lodash.uniqby-4.7.0.tgz#d99c07a669e9e6d24e1362dfe266c67616af1302"
|
||||||
integrity sha1-2ZwHpmnp5tJOE2Lf4mbGdhavEwI=
|
integrity sha1-2ZwHpmnp5tJOE2Lf4mbGdhavEwI=
|
||||||
|
|
||||||
lodash@^4.17.10, lodash@^4.17.4, lodash@^4.17.5, lodash@^4.3.0:
|
lodash@^4.16.4, lodash@^4.17.10, lodash@^4.17.4, lodash@^4.17.5, lodash@^4.3.0:
|
||||||
version "4.17.11"
|
version "4.17.11"
|
||||||
resolved "https://registry.yarnpkg.com/lodash/-/lodash-4.17.11.tgz#b39ea6229ef607ecd89e2c8df12536891cac9b8d"
|
resolved "https://registry.yarnpkg.com/lodash/-/lodash-4.17.11.tgz#b39ea6229ef607ecd89e2c8df12536891cac9b8d"
|
||||||
integrity sha512-cQKh8igo5QUhZ7lg38DYWAxMvjSAKG0A8wGSVimP07SIUEK2UO+arSRKbRZWtelMtN5V0Hkwh5ryOto/SshYIg==
|
integrity sha512-cQKh8igo5QUhZ7lg38DYWAxMvjSAKG0A8wGSVimP07SIUEK2UO+arSRKbRZWtelMtN5V0Hkwh5ryOto/SshYIg==
|
||||||
@@ -1737,7 +1757,15 @@ natural-compare@^1.4.0:
|
|||||||
resolved "https://registry.yarnpkg.com/natural-compare/-/natural-compare-1.4.0.tgz#4abebfeed7541f2c27acfb29bdbbd15c8d5ba4f7"
|
resolved "https://registry.yarnpkg.com/natural-compare/-/natural-compare-1.4.0.tgz#4abebfeed7541f2c27acfb29bdbbd15c8d5ba4f7"
|
||||||
integrity sha1-Sr6/7tdUHywnrPspvbvRXI1bpPc=
|
integrity sha1-Sr6/7tdUHywnrPspvbvRXI1bpPc=
|
||||||
|
|
||||||
node-fetch@^2.1.2, node-fetch@^2.2.0:
|
node-fetch@^1.6.3:
|
||||||
|
version "1.7.3"
|
||||||
|
resolved "https://registry.yarnpkg.com/node-fetch/-/node-fetch-1.7.3.tgz#980f6f72d85211a5347c6b2bc18c5b84c3eb47ef"
|
||||||
|
integrity sha512-NhZ4CsKx7cYm2vSrBAr2PvFOe6sWDf0UYLRqA6svUYg7+/TSfVAu49jYC4BvQ4Sms9SZgdqGBgroqfDhJdTyKQ==
|
||||||
|
dependencies:
|
||||||
|
encoding "^0.1.11"
|
||||||
|
is-stream "^1.0.1"
|
||||||
|
|
||||||
|
node-fetch@^2.0.0, node-fetch@^2.1.2, node-fetch@^2.2.0:
|
||||||
version "2.2.0"
|
version "2.2.0"
|
||||||
resolved "https://registry.yarnpkg.com/node-fetch/-/node-fetch-2.2.0.tgz#4ee79bde909262f9775f731e3656d0db55ced5b5"
|
resolved "https://registry.yarnpkg.com/node-fetch/-/node-fetch-2.2.0.tgz#4ee79bde909262f9775f731e3656d0db55ced5b5"
|
||||||
integrity sha512-OayFWziIxiHY8bCUyLX6sTpDH8Jsbp4FfYd1j1f7vZyfgkcOnAyM4oQR16f8a0s7Gl/viMGRey8eScYk4V4EZA==
|
integrity sha512-OayFWziIxiHY8bCUyLX6sTpDH8Jsbp4FfYd1j1f7vZyfgkcOnAyM4oQR16f8a0s7Gl/viMGRey8eScYk4V4EZA==
|
||||||
@@ -1818,6 +1846,15 @@ object.pick@^1.3.0:
|
|||||||
dependencies:
|
dependencies:
|
||||||
isobject "^3.0.1"
|
isobject "^3.0.1"
|
||||||
|
|
||||||
|
octokat@^0.10.0:
|
||||||
|
version "0.10.0"
|
||||||
|
resolved "https://registry.yarnpkg.com/octokat/-/octokat-0.10.0.tgz#a56846178199f36ddfc8979c9749ffea65736508"
|
||||||
|
integrity sha512-VJ21L1gMlByYMurduLYiOcI8AwlZkUV8OXRN8pMXsbkIqIVqn0tgdTfxzWM9spX4VJTTG02OgqwDTqQsOmDing==
|
||||||
|
dependencies:
|
||||||
|
fetch-vcr "^1.1.0"
|
||||||
|
lodash "^4.16.4"
|
||||||
|
node-fetch "^2.0.0"
|
||||||
|
|
||||||
once@^1.3.0:
|
once@^1.3.0:
|
||||||
version "1.4.0"
|
version "1.4.0"
|
||||||
resolved "https://registry.yarnpkg.com/once/-/once-1.4.0.tgz#583b1aa775961d4b113ac17d9c50baef9dd76bd1"
|
resolved "https://registry.yarnpkg.com/once/-/once-1.4.0.tgz#583b1aa775961d4b113ac17d9c50baef9dd76bd1"
|
||||||
@@ -2576,6 +2613,11 @@ validate-npm-package-license@^3.0.1:
|
|||||||
spdx-correct "^3.0.0"
|
spdx-correct "^3.0.0"
|
||||||
spdx-expression-parse "^3.0.0"
|
spdx-expression-parse "^3.0.0"
|
||||||
|
|
||||||
|
whatwg-fetch@^2.0.3:
|
||||||
|
version "2.0.4"
|
||||||
|
resolved "https://registry.yarnpkg.com/whatwg-fetch/-/whatwg-fetch-2.0.4.tgz#dde6a5df315f9d39991aa17621853d720b85566f"
|
||||||
|
integrity sha512-dcQ1GWpOD/eEQ97k66aiEVpNnapVj90/+R+SXTPYGHpYBBypfKJEQjLrvMZ7YXbKm21gXd4NcuxUTjiv1YtLng==
|
||||||
|
|
||||||
which@^1.2.10, which@^1.2.9:
|
which@^1.2.10, which@^1.2.9:
|
||||||
version "1.3.1"
|
version "1.3.1"
|
||||||
resolved "https://registry.yarnpkg.com/which/-/which-1.3.1.tgz#a45043d54f5805316da8d62f9f50918d3da70b0a"
|
resolved "https://registry.yarnpkg.com/which/-/which-1.3.1.tgz#a45043d54f5805316da8d62f9f50918d3da70b0a"
|
||||||
|
|||||||
Reference in New Issue
Block a user