init

joyeecheung · joyeecheung · commit 2f3843c05b09 · 2017-10-23T14:05:00.000+08:00
diff --git a/.eslintrc b/.eslintrc
@@ -0,0 +1,9 @@
+{
+  "extends": "standard",
+  "rules": {
+    "semi": ["error", "always"],
+    "space-before-function-paren": ["error", "never"],
+    "no-multi-spaces": ["error", { "ignoreEOLComments": true }],
+    "camelcase": "off"
+  }
+}
diff --git a/index.js b/index.js
@@ -0,0 +1,62 @@
+'use strict';
+
+const fs = require('fs');
+
+const PR_QUERY = fs.readFileSync('./queries/PR.gql', 'utf8');
+const request = require('./lib/request');
+const logger = require('./lib/logger');
+const PR_ID = parseInt(process.argv[2]) || 12756;
+const OWNER = 'nodejs';
+const REPO = 'node';
+
+function getReviewers(pr) {
+  return []; // TODO
+}
+
+function getFixes(pr) {
+  return []; // TODO
+}
+
+function getRefs(pr) {
+  return []; // TODO
+}
+
+async function main() {
+  logger.info(`Requesting ${OWNER}/${REPO}/pull/${PR_ID}`);
+  const data = await request(PR_QUERY, {
+    prid: PR_ID,
+    owner: OWNER,
+    repo: REPO
+  });
+
+  const pr = data.repository.pullRequest;
+  const output = {
+    prUrl: pr.url,
+    reviewedBy: getReviewers(pr),
+    fixes: getFixes(pr),
+    refs: getRefs(pr)
+  };
+
+  let meta = [
+    '-------------------------------- >8 --------------------------------',
+    `PR-URL: ${output.prUrl}`];
+  meta = meta.concat(output.reviewedBy.map((reviewer) => {
+    return `Reviewed-By: ${reviewer.name} <${reviewer.email}>`;
+  }));
+  meta = meta.concat(output.fixes.map((fix) => {
+    return `Fixes: ${fix}`;
+  }));
+  meta = meta.concat(output.refs.map((ref) => {
+    return `Refs: ${ref}`;
+  }));
+  meta.push(
+    '-------------------------------- 8< --------------------------------'
+  );
+
+  logger.info({ raw: meta.join('\n') }, `Generated metadta:`);
+}
+
+main().catch((err) => {
+  logger.error(err);
+  process.exit(-1);
+});
diff --git a/lib/auth.js b/lib/auth.js
@@ -0,0 +1,10 @@
+'use strict';
+
+const fs = require('fs');
+const os = require('os');
+const path = require('path');
+const authFile = path.join(os.homedir(), '.ncurc');
+// TODO: try-catch, validate properties
+const { username, token } = JSON.parse(fs.readFileSync(authFile, 'utf8'));
+const auth = Buffer.from(`${username}:${token}`).toString('base64');
+module.exports = auth;
diff --git a/lib/collaborators.js b/lib/collaborators.js
@@ -0,0 +1,35 @@
+'use strict';
+
+const rp = require('request-promise-native');
+
+async function getCollaborators(owner, repo) {
+  // This is more or less taken from
+  // https://github.com/rvagg/iojs-tools/blob/master/pr-metadata/pr-metadata.js
+  const RE = /\* \[(.+?)\]\(.+?\) -\s\*\*(.+?)\*\* &lt;(.+?)&gt;/mg;
+  const url = `https://raw.githubusercontent.com/${owner}/${repo}/master/README.md`;
+
+  const response = await rp({
+    url: url
+  });
+
+  const members = new Map();
+  let m;
+
+  while (m = RE.exec(response)) { // eslint-disable-line no-cond-assign
+    members.set(m[1].toLowerCase(), {
+      login: m[1],
+      name: m[2],
+      email: m[3]
+    });
+  }
+
+  if (!members.size) {
+    throw new Error('Could not find any collaborators');
+  }
+
+  return members;
+}
+
+module.exports = {
+  getCollaborators
+};
diff --git a/lib/logger.js b/lib/logger.js
@@ -0,0 +1,30 @@
+'use strict';
+
+const pino = require('pino');
+const LEVELS = new Map(Object.keys(pino.levels.values)
+  .map((key) => [pino.levels.values[key], key.toUpperCase()]));
+const pretty = pino.pretty({
+  forceColor: true,
+  formatter(obj) {
+    const level = LEVELS.get(obj.level);
+    let timestamp = '';
+    if (obj.showTime) {
+      timestamp = `[${new Date(obj.time).toISOString()}] `;
+    }
+    if (level === 'ERROR') {
+      return `[${level}] ${timestamp}${obj.type} ${obj.msg}\n` +
+             `[STACK] ${obj.stack}\n` +
+             `[DATA] ${JSON.stringify(obj.data, null, 2)}\n`;
+    } else if (level === 'INFO' && obj.raw) {
+      return `[${level}] ${timestamp}${obj.msg || ''}\n ${obj.raw}`;
+    } else {
+      return `[${level}] ${timestamp}${obj.msg}`;
+    }
+  }
+});
+pretty.pipe(process.stdout);
+const logger = pino({
+  name: 'node-core-utils',
+  safe: true
+}, pretty);
+module.exports = logger;
diff --git a/lib/request.js b/lib/request.js
@@ -0,0 +1,35 @@
+'use strict';
+
+const rp = require('request-promise-native');
+const auth = require('./auth');
+
+async function request(query, variables) {
+  const options = {
+    uri: 'https://api.github.com/graphql',
+    method: 'POST',
+    headers: {
+      'Authorization': `Basic ${auth}`,
+      'User-Agent': 'node-check-pr'
+    },
+    json: true,
+    gzip: true,
+    body: {
+      query: query,
+      variables: variables
+    }
+  };
+  // console.log(options);
+  const result = await rp(options);
+  if (result.errors) {
+    const err = new Error('GraphQL request Error');
+    err.data = {
+      // query: query,
+      variables: variables,
+      errors: result.errors
+    };
+    throw err;
+  }
+  return result.data;
+}
+
+module.exports = request;
diff --git a/lib/user.js b/lib/user.js
@@ -0,0 +1,10 @@
+'use strict';
+
+function isTheSamePerson(actor, b) {
+  if (!actor || !actor.login) return false; // ghost
+  return actor.login.toLowerCase() === b.toLowerCase();
+}
+
+module.exports = {
+  isTheSamePerson
+};
diff --git a/package.json b/package.json
@@ -0,0 +1,16 @@
+{
+  "name": "node-core-utils",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "Joyee Cheung <joyeec9h3@gmail.com>",
+  "license": "MIT",
+  "dependencies": {
+    "pino": "^4.8.0",
+    "request": "^2.83.0",
+    "request-promise-native": "^1.0.5"
+  }
+}
diff --git a/queries/PR.gql b/queries/PR.gql
@@ -0,0 +1,48 @@
+query PR($prid: Int!, $owner: String!, $repo: String!) {
+  repository(owner: $owner, name: $repo) {
+    pullRequest(number: $prid) {
+      url,
+      bodyText,
+      commits(first: 100) {
+        totalCount
+        nodes {
+          commit {
+            committedDate
+            author {
+              email
+              name
+            }
+            committer {
+              email
+              name
+            }
+            oid
+            message
+            authoredByCommitter
+          }
+        }
+      }
+      comments(first: 100) {
+        totalCount
+        nodes {
+          bodyText
+          author {
+            login
+          }
+        }
+      }
+      reviews(first: 100) {
+        totalCount
+        nodes {
+          state
+          author {
+            login
+            resourcePath
+          }
+          authorAssociation
+          publishedAt
+        }
+      }
+    }
+  }
+}
