firebase-tools/commands/data-push.js

'use strict';

var Command = require('../lib/command');
var requireDataAccess = require('../lib/requireDataAccess');
var request = require('request');
var api = require('../lib/api');
var responseToError = require('../lib/responseToError');
var FirebaseError = require('../lib/error');
var RSVP = require('rsvp');
var utils = require('../lib/utils');
var querystring = require('querystring');
var chalk = require('chalk');
var logger = require('../lib/logger');
var fs = require('fs');
var Firebase = require('firebase');
var _ = require('lodash');

module.exports = new Command('data:push <path> [infile]')
  .description('add a new JSON object to a list of data in your Firebase')
  .option('-f, --firebase <app>', 'override the app specified in firebase.json')
  .option('-d, --data <data>', 'specify escaped JSON directly')
  .before(requireDataAccess)
  .action(function(path, infile, options) {
    if (!_.startsWith(path, '/')) {
      return utils.reject('Path must begin with /', {exit: 1});
    }

    return new RSVP.Promise(function(resolve, reject) {
      var inStream = utils.stringToStream(options.data) || (infile ? fs.createReadStream(infile) : process.stdin);

      var url = utils.addSubdomain(api.realtimeOrigin, options.firebase) + path + '.json?';
      var query = {auth: options.dataToken};

      url += querystring.stringify(query);

      if (!infile && !options.data) {
        utils.explainStdin();
      }

      inStream.pipe(request.post(url, {json: true}, function(err, res, body) {
        logger.info();
        if (err) {
          return reject(new FirebaseError('Unexpected error while pushing data', {exit: 2}));
        } else if (res.statusCode >= 400) {
          return reject(responseToError(res, body));
        }

        var refurl = utils.addSubdomain(api.realtimeOrigin, options.firebase) + path + '/' + body.name;

        utils.logSuccess('Data pushed successfully');
        logger.info();
        logger.info(chalk.bold('View data at:'), refurl);
        return resolve(new Firebase(refurl));
      }));
    });
  });