#!/usr/bin/env node

var hlsdump = require('commander');
hlsdump.version('0.0.0')
   .usage('[options] <url>')
   .option('-o, --output <path>', 'target file')
   .option('-u, --udp [host:port]', 'relay TS over UDP', function(val) {
     var r = { host:'localhost', port:1234 };
     if (val) {
       var s = val.split(':');
       if (s.length === 1) {
         r.port = parseInt(s[0], 10);
       } else {
         r.host = s[0];
         r.port = parseInt(s[1], 10);
       }
     }
     return r;
   })
   .option('-b, --buffer-size <bytes>', 'try to buffer <bytes> of input data (implies -s)')
   .option('-s, --sync', 'clock sync using stream PCR')
   .option('-k, --keep-connection', 'don\'t give up once connected')
   .option('-f, --full-stream', 'fetch all stream data')
   .option('-a, --user-agent <string>', 'HTTP User-Agent')
   .parse(process.argv);

var util = require('util'),
    url = require('url'),
    fs = require('fs');

var reader = require('../lib/reader'),
    tssmooth = require('../lib/tssmooth'),
    tsblast = require('../lib/tsblast');

var src = process.argv[2];
if (!src) return hlsdump.help();

if (hlsdump.bufferSize) hlsdump.sync = true;

var r = reader(src, {highWaterMark:hlsdump.bufferSize, keepConnection:hlsdump.keepConnection, fullStream:hlsdump.fullStream});

var time = 0;
r.on('segment', function(seqNo, duration, meta) {
//  console.error(new Date().toJSON() + sep + meta.size + sep + duration.toFixed(3) + sep + (meta.size / (duration * 1024/8)).toFixed(3));
  console.error('new segment at '+time.toFixed(0)+' seconds, avg bitrate (kbps):', (meta.size / (duration * 1024/8)).toFixed(1));
  time += duration;
});

r.on('error', function(err) {
  console.error('error', err.stack || err);
});

r.on('end', function() {
  console.error('done');
});

var stream = r;
if (hlsdump.sync)
  stream = stream.pipe(tssmooth(), {chunkSize:16*1024});

if (hlsdump.udp)
  stream.pipe(tsblast(hlsdump.udp));

if (hlsdump.output) {
  var dst;
  if (hlsdump.output === '-')
    dst = process.stdout;
  else
    dst = fs.createWriteStream(hlsdump.output);

  if (dst)
    stream.pipe(dst);
}