fetch a bunch of ads with bacon

var fs = require("fs");

var Bacon = require("baconjs");
var lifestyle = require("lifestyle");

var root = "https://api.finn.no/iad/"
var adListPath = "adids.txt";
var client = new lifestyle.FinnClient(root);

function fetchAd(id) {
    return Bacon.fromPromise(client.getAd(id));
}

function handleError(err) {
    process.stderr.write(err.message + "\n");
}

function handleSuccess(ad) {
    process.stdout.write(JSON.stringify(ad) + "\n");
}

function getAdIds(path) {
    return fs.readFileSync(path, 'utf8').trim().split('\n');    
}

var responses = Bacon
    .fromArray(getAdIds(adListPath))
    .flatMapWithConcurrencyLimit(6, fetchAd);

responses.onValue(handleSuccess);
responses.onError(handleError);