import.js

var fs = require('fs');
var gulp = require('gulp');
var env = process.env.NODE_ENV || 'development';
var child_process = require('child_process');
var config = require('../../config/config.json')[env];
var path = require('path');

var minimist = require('minimist');
var knownOptions = {
  string: ['from'],
  default: {
    from: 'pg_dump.sql'
  }
};

var options = minimist(process.argv.slice(2), knownOptions);


gulp.task('metastock:import', function (cb) {

  var importFile = fs.createReadStream(path.resolve(options.from));

  var psql = child_process.spawn('/usr/local/bin/psql', ['-h', config.host, '-U', config.username, config.database], {
    env: {
      PGPASSWORD: config.password
    }
  });

  importFile.pipe(psql.stdin);

  psql.stdout.on('close', function (code) {
    cb(null, code);
  });

});