Compare commits
29 Commits
bf7159ec33
...
v1.3.0
| Author | SHA1 | Date | |
|---|---|---|---|
| 24849b6c92 | |||
| a8800d1593 | |||
| e8e252f73c | |||
| 41d79051f8 | |||
| 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
|
||||
coverage.lcov
|
||||
/lib
|
||||
/data
|
||||
3
AUTHORS.md
Normal file
3
AUTHORS.md
Normal file
@@ -0,0 +1,3 @@
|
||||
### Authors
|
||||
|
||||
- joe fleming ([w33ble](https://github.com/w33ble))
|
||||
35
CHANGELOG.md
Normal file
35
CHANGELOG.md
Normal file
@@ -0,0 +1,35 @@
|
||||
### Changelog
|
||||
|
||||
#### [v1.3.0](https://git.w33ble.com/w33ble/gh-action-bot/compare/v1.2.1...v1.3.0) (23 October 2018)
|
||||
- feat: add a clean command [`e8e252f`](https://git.w33ble.com/w33ble/gh-action-bot/commit/e8e252f73c315663a6cc79336c914615bdfe1ad5)
|
||||
- chroe: user logger on force errors [`41d7905`](https://git.w33ble.com/w33ble/gh-action-bot/commit/41d79051f8550f428ea41505ab4740caa0509e93)
|
||||
- docs: add clean script to readme [`a8800d1`](https://git.w33ble.com/w33ble/gh-action-bot/commit/a8800d1593f5cbd4fb5a90a895bcc88aa004e892)
|
||||
|
||||
#### [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)
|
||||
23
README.md
23
README.md
@@ -1,10 +1,27 @@
|
||||
# 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://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
|
||||
|
||||
`yanr run clean owner/repo pr_number`: removed any comments that match the owner and body requirements
|
||||
|
||||
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
|
||||
|
||||
|
||||
0
data/.empty
Normal file
0
data/.empty
Normal file
2
index.js
2
index.js
@@ -2,4 +2,4 @@
|
||||
require = require('esm')(module);
|
||||
const mod = require('./src/index.mjs').default;
|
||||
|
||||
module.exports = mod;
|
||||
mod();
|
||||
|
||||
11
package.json
11
package.json
@@ -1,6 +1,7 @@
|
||||
{
|
||||
"name": "gh-action-bot",
|
||||
"version": "0.0.0",
|
||||
"version": "1.3.0",
|
||||
"private": true,
|
||||
"description": "Action bot for Github",
|
||||
"main": "index",
|
||||
"module": "index.mjs",
|
||||
@@ -8,7 +9,9 @@
|
||||
"lint": "eslint \"*.{js,mjs}\" \"src/**/*.{js,mjs}\"",
|
||||
"precommit": "lint-staged",
|
||||
"version": "auto-changelog -p && auto-authors && git add CHANGELOG.md AUTHORS.md",
|
||||
"start": "node ."
|
||||
"start": "node .",
|
||||
"force": "node -r esm src/force.mjs",
|
||||
"clean": "node -r esm src/clean.mjs"
|
||||
},
|
||||
"repository": {
|
||||
"type": "git",
|
||||
@@ -52,7 +55,9 @@
|
||||
"cjs": true
|
||||
},
|
||||
"dependencies": {
|
||||
"esm": "^3.0.17"
|
||||
"dotenv": "^6.1.0",
|
||||
"esm": "^3.0.17",
|
||||
"octokat": "^0.10.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"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
|
||||
30
src/clean.mjs
Normal file
30
src/clean.mjs
Normal file
@@ -0,0 +1,30 @@
|
||||
import dotenv from 'dotenv';
|
||||
import logger from './lib/logger.mjs';
|
||||
import createRepo from './lib/create_repo.mjs';
|
||||
import getPullComments from './lib/get_pull_comments.mjs';
|
||||
import { deleteComment } from './lib/comments.mjs';
|
||||
|
||||
dotenv.config();
|
||||
|
||||
async function forceRetest() {
|
||||
const [ownerRepo, prNumber] = process.argv.splice(2);
|
||||
const { COMMENT_BODY_REGEXP, COMMENT_BODY_REGEXP_FLAGS, COMMENT_ACTOR } = 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 comments = await getPullComments(repo, prNumber);
|
||||
const bodyRegexp = new RegExp(COMMENT_BODY_REGEXP, COMMENT_BODY_REGEXP_FLAGS);
|
||||
comments
|
||||
.filter(comment => bodyRegexp.test(comment.body) && comment.owner === COMMENT_ACTOR)
|
||||
.forEach(async comment => {
|
||||
const res = await deleteComment(repo, comment.id);
|
||||
if (res) logger.debug(`Comment ${comment.id} deleted`);
|
||||
else logger.error(new Error(`Failed to remove comment ${comment.id}`));
|
||||
});
|
||||
}
|
||||
|
||||
forceRetest().catch(err => logger.error(err));
|
||||
23
src/force.mjs
Normal file
23
src/force.mjs
Normal file
@@ -0,0 +1,23 @@
|
||||
import dotenv from 'dotenv';
|
||||
import logger from './lib/logger.mjs';
|
||||
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);
|
||||
const res = await deleteComment(repo, comment.id);
|
||||
if (res) logger.debug(`Comment ${comment.id} deleted`);
|
||||
else logger.error(new Error(`Failed to remove comment ${comment.id}`));
|
||||
}
|
||||
|
||||
forceRetest().catch(err => logger.error(err));
|
||||
@@ -1,3 +1,92 @@
|
||||
export default function() {
|
||||
// es6 module code goes here
|
||||
import dotenv from 'dotenv';
|
||||
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),
|
||||
};
|
||||
}
|
||||
9
src/lib/get_pull_comments.mjs
Normal file
9
src/lib/get_pull_comments.mjs
Normal file
@@ -0,0 +1,9 @@
|
||||
export default async function getPull(repo, id) {
|
||||
const { items } = await repo.issues(id).comments.fetch();
|
||||
|
||||
return items.map(item => ({
|
||||
id: item.id,
|
||||
owner: item.user.login,
|
||||
body: item.body,
|
||||
}));
|
||||
}
|
||||
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:
|
||||
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:
|
||||
version "1.0.1"
|
||||
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"
|
||||
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:
|
||||
version "1.3.2"
|
||||
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"
|
||||
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:
|
||||
version "1.7.0"
|
||||
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"
|
||||
strip-indent "^2.0.0"
|
||||
|
||||
iconv-lite@^0.4.17:
|
||||
iconv-lite@^0.4.17, iconv-lite@~0.4.13:
|
||||
version "0.4.24"
|
||||
resolved "https://registry.yarnpkg.com/iconv-lite/-/iconv-lite-0.4.24.tgz#2022b4b25fbddc21d2f524974a474aafe733908b"
|
||||
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"
|
||||
integrity sha512-qgDYXFSR5WvEfuS5dMj6oTMEbrrSaM0CrFk2Yiq/gXnBvD9pMa2jGXxyhGLfvhZpuMZe18CJpFxAt3CRs42NMg==
|
||||
|
||||
is-stream@^1.1.0:
|
||||
is-stream@^1.0.1, is-stream@^1.1.0:
|
||||
version "1.1.0"
|
||||
resolved "https://registry.yarnpkg.com/is-stream/-/is-stream-1.1.0.tgz#12d4a3dd4e68e0b79ceb8dbc84173ae80d91ca44"
|
||||
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"
|
||||
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"
|
||||
resolved "https://registry.yarnpkg.com/lodash/-/lodash-4.17.11.tgz#b39ea6229ef607ecd89e2c8df12536891cac9b8d"
|
||||
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"
|
||||
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"
|
||||
resolved "https://registry.yarnpkg.com/node-fetch/-/node-fetch-2.2.0.tgz#4ee79bde909262f9775f731e3656d0db55ced5b5"
|
||||
integrity sha512-OayFWziIxiHY8bCUyLX6sTpDH8Jsbp4FfYd1j1f7vZyfgkcOnAyM4oQR16f8a0s7Gl/viMGRey8eScYk4V4EZA==
|
||||
@@ -1818,6 +1846,15 @@ object.pick@^1.3.0:
|
||||
dependencies:
|
||||
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:
|
||||
version "1.4.0"
|
||||
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-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:
|
||||
version "1.3.1"
|
||||
resolved "https://registry.yarnpkg.com/which/-/which-1.3.1.tgz#a45043d54f5805316da8d62f9f50918d3da70b0a"
|
||||
|
||||
Reference in New Issue
Block a user