Use ES6 directly; closes #16

Author: Evan Prodromou

.gitignore

@@ -26,6 +26,4 @@ build/Release
 # https://www.npmjs.org/doc/misc/npm-faq.html#should-i-check-my-node_modules-folder-into-git-
 node_modules
 
-*.js
-
 *~

Cakefile

@@ -0,0 +1,194 @@
+#!/usr/bin/env node
+/*
+ * decaffeinate suggestions:
+ * DS101: Remove unnecessary use of Array.from
+ * DS102: Remove unnecessary code created because of implicit returns
+ * DS207: Consider shorter variations of null checks
+ * Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
+ */
+// github-todotxt.coffee
+// Get data from Github issues and format it for todo.txt
+//
+// Copyright 2016 Evan Prodromou <[email protected]>
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+const fs = require('fs');
+const path = require('path');
+
+const _ = require('lodash');
+const yargs = require('yargs');
+const GitHubApi = require('github');
+const async = require('async');
+const split = require('split');
+
+const { argv } = yargs
+  .usage('Usage: $0 -t [token]')
+  .demand('t')
+  .alias('t', 'token')
+  .describe('t', 'OAuth token')
+  .alias('f', 'file')
+  .describe('f', 'todo.txt file')
+  .default('f', path.join(process.env.HOME, "Dropbox", "todo", "todo.txt"))
+  .alias('q', 'quiet')
+  .describe('q', 'Minimize console output')
+  .env('GITHUB_TODOTXT')
+  .alias('c', 'config')
+  .describe('c', 'Config file')
+  .default('c', path.join(process.env.HOME, ".github-todotxt.json"))
+  .config('config')
+  .help('h')
+  .alias('h', 'help')
+  ;
+
+const projectCase = str => _.upperFirst(_.camelCase(str));
+
+const token = argv.t;
+const filename = argv.f;
+const quiet = (argv.q != null);
+
+const note = function(str) {
+  if (!quiet) {
+    return process.stdout.write(str);
+  }
+};
+
+const github = new GitHubApi({
+  debug: false});
+
+github.authenticate({
+  type: "oauth",
+  token
+});
+
+async.parallel([
+  function(callback) {
+    const todos = [];
+    return fs.createReadStream(filename)
+      .pipe(split())
+      .on('data', function(line) {
+        if (line.match(/\S/)) {
+          const m = line.match(/issue:(\S+)/);
+          const todo =
+            {text: line};
+          if (m) {
+            todo.issue = m[1];
+          }
+          return todos.push(todo);
+        }
+    }).on('error', err => callback(err, null)).on('end', () => callback(null, todos));
+  },
+  function(callback) {
+    var getIssues = function(page, acc, callback) {
+      note(".");
+      const props = {
+        state: "all",
+        filter: "assigned",
+        per_page: 100,
+        page
+      };
+      return github.issues.getAll(props, function(err, issues) {
+        if (err) {
+          return callback(err);
+        } else {
+          acc = _.concat(acc, issues);
+          if (issues.length >= 100) {
+            return getIssues(page + 1, acc, callback);
+          } else {
+            note("\n");
+            return callback(null, acc);
+          }
+        }
+      });
+    };
+    if (!quiet) {
+      note("Getting issues...");
+    }
+    return getIssues(1, [], callback);
+  }
+], function(err, results) {
+  if (err) {
+    return console.error(err);
+  } else {
+    let id, number, repo, todo;
+    const [todos, issues] = Array.from(results);
+    if (!quiet) {
+      note(`${todos.length} lines in ${filename}\n`);
+      note(`${issues.length} issues on Github\n`);
+    }
+    for (var issue of Array.from(issues)) {
+      repo = issue.repository.full_name;
+      ({ number } = issue);
+      id = `${repo}#${number}`;
+      todo = _.find(todos, {issue: id});
+      if (todo != null) {
+        if (todo.text.match(/^x/)) {
+          if (issue.state === "open") {
+            "not closing issue";
+          }
+            // XXX: close the github issue
+        } else {
+          if (issue.state === "closed") {
+            note(`Marking line for issue ${id} complete.\n`);
+            todo.text = `x ${todo.text}`;
+          }
+        }
+      } else if (issue.state === "open") {
+        note(`Adding line for issue ${id}.\n`);
+        const ts = issue.created_at.substr(0, 10);
+        const project = projectCase(repo.split("/")[1]);
+        const { title } = issue;
+        let line = `${ts} ${title} issue:${repo}#${number} +${project}`;
+        if (issue.milestone != null) {
+          line += ` +${projectCase(issue.milestone.title)}`;
+        }
+        todos.push({text: line});
+      }
+    }
+
+    // Todos with issues that aren't in the list should be marked as done.
+
+    for (todo of Array.from(todos)) {
+      if ((todo.issue == null)) {
+        continue;
+      }
+      if (todo.text.match(/^x/)) {
+        continue;
+      }
+      issue = _.find(issues, function(issue) {
+        repo = issue.repository.full_name;
+        ({ number } = issue);
+        id = `${repo}#${number}`;
+        return id === todo.issue;
+      });
+      if ((issue == null)) {
+        note(`Issue ${todo.issue} not assigned to you; marking it done.\n`);
+        todo.text = `x ${todo.text}`;
+      }
+    }
+
+    const backup = `${filename}.bak`;
+    return async.waterfall([
+      callback => fs.rename(filename, backup, callback),
+      function(callback) {
+        const texts = _.map(todos, "text");
+        const data = texts.join("\n") + "\n";
+        return fs.writeFile(filename, data, callback);
+      }
+    ], function(err) {
+      if (err) {
+        return console.error(err);
+      }
+    });
+  }
+});