soundcloud_users.js

#!/usr/bin/env node

var map = require('map-stream');
var csv = require('csv-parse');
var stringify = require('csv-stringify');
var skip = require('skip-stream');
var queue = require('concurrent-map-stream');
var argv = require('minimist')(process.argv.slice(2));
var debug = require('debug')('soundcloudstats');
var through = require('through');

var concurrency = argv.j || 10;
var cid = process.env.SC_CLIENT_ID;
var soundcloud = require('../lib/soundcloud')(cid);

function worker(user, done) {
  user = user.trim();
  soundcloud.user(user, done);
}

process.stdin
.pipe(csv())
.pipe(map(function(row, done){
  done(null, row[0]);
}))
.pipe(queue(worker, concurrency))
.pipe(map(function(user, done){
  var row = Object.keys(user).reduce(function(vals, key){
    vals.push(user[key]);
    return vals;
  }, []);

  done(null, row);
}))
.pipe(stringify())
.pipe(process.stdout);