app.js

var PocketClient = require('./lib/pocket_client').PocketClient;
var koa = require('koa');
var router = require('koa-router');
var app = koa();
var koaBody = require('koa-body')();
var crypto = require('crypto');
var _ = require('lodash');
var thunkify = require('thunkify-wrap');

app.use(router(app));
app.use(koaBody);

var pocketConsumerKey = process.env.POCKET_CONSUMER_KEY;
var pocketClient = new PocketClient(pocketConsumerKey);

app.get('/', function *(next) {
  this.body = '<form method=POST action="/auth/pocket"><button>Archive all</button></form>';
});

app.post('/auth/pocket', function *(next) {
  var buf = yield thunkify(crypto.randomBytes)(32);
  var state = buf.toString('hex');
  var code = yield pocketClient.authRequest({state: state});
  this.redirect('https://getpocket.com/auth/authorize?request_token='+ code +'&redirect_uri=http://localhost:3000/auth/pocket/callback?state=' + state);
});

app.get('/auth/pocket/callback', function *(next) {
  var state = this.query.state;
  var accessToken = yield pocketClient.authorize({state: state});
  console.log(accessToken);
  var items = yield pocketClient.get({accessToken: accessToken});
  var itemIds = Object.keys(items);
  var results = yield pocketClient.archiveAll({accessToken: accessToken, itemIds: itemIds});
  var numberOfArchivedItems = _.compact(results).length;
  var message = numberOfArchivedItems + ' item' + (numberOfArchivedItems.length > 1 ? 's' : '') + ' have been archived. You\'ll be redirected to pocket in a few seconds...';
  this.body = '<pre>' + message + '</pre><script type="text/javascript">setTimeout(function() { window.location = "https://getpocket.com/"; }, 5000);</script>'
});

app.listen(3000);
console.log('listening on port %d', 3000);