tx

#!/usr/bin/env node

(function (crypto, rest, Q) {
  'use strict';

  var action = process.argv[2];
  var txProject = process.argv[3];
  var txResource = process.argv[4];
  // skip (node + tx.js + action + project + resource)
  var args = process.argv.splice(5);

  txResource = txResource.replace(/\./g, '');

  var baseUrl = 'https://www.transifex.com/api/2';
  var transifexResourceUrl = baseUrl + '/project/' + txProject + '/resource/' + txResource + '/content';

  switch (action) {
    case 'rm':
      getResource()
        .then(removeKeysFromResource, throwError)
        .then(updateTransifexResource, throwError)
        .done();
      break;
    case 'add':
      getResource()
        .then(addKeysToResource, throwError)
        .then(updateTransifexResource, throwError)
        .done();
      break;
    case 'comment':
      getStringFromTx(args[0])
        .then(function () {
          return setCommentForString(args[0], args[1]);
        }, throwError)
        .done();
      break;
    default:
      console.log('The action "' + action + '" is not supported');
  }

  /**
   * Get resource content from Transifex
   * @return {Q.Promise} 
   */
  function getResource() {
    var deferred = Q.defer();

    rest
      .get(transifexResourceUrl, {
        username: process.env.TX_USER,
        password: process.env.TX_PASS
      })
      .on('success', function (data, response) {
        deferred.resolve(JSON.parse(data.content));
      })
      .on('fail', function (err, response) {
        deferred.reject(err);
      })
      .on('error', function (err, response) {
        deferred.reject(err);
      });

    return deferred.promise;
  }

  /**
   * Update resource on Transifex with the new content
   * @param  {Object} resourceContent 
   * @return {Q.Promise} 
   */
  function updateTransifexResource(resourceContent) {
    var deferred = Q.defer();

    console.log('Uploading updated resource to Transifex...');

    rest.put(transifexResourceUrl, {
        headers: {
          "Content-Type": "application/json"
        },
        data: JSON.stringify({ "content": JSON.stringify(resourceContent)}),
        username: process.env.TX_USER,
        password: process.env.TX_PASS
      })
      .on('success', function (data, response) {
        console.log('Transifex resource updated');
        deferred.resolve(data);
      })
      .on('fail', function (err, response) {
        deferred.reject(err);
      });

    return deferred.promise;
  }

  /**
   * Remove keys (args) from resource content
   * @param  {Object} resourceContent 
   * @return {Q.Promise} 
   */
  function removeKeysFromResource(resourceContent) {
    console.log('Removing keys from resource "' + txResource + '" of project "' + txProject + '"');
    var resourceKeysBefore = Object.keys(resourceContent);
    args.forEach(function (key) {
      delete resourceContent[key];
    });
    var resourceKeysAfter = Object.keys(resourceContent);
    console.log('Number of keys that will be deleted: ' + (resourceKeysBefore.length - resourceKeysAfter.length));
    return Q.when(resourceContent);
  }

  /**
   * Add keys (args) to resource content
   * @param  {Object} resourceContent 
   * @return {Q.Promise} 
   */
  function addKeysToResource(resourceContent) {
    console.log('Adding keys to resource "' + txResource + '" of project "' + txProject + '"');
    var resourceKeysBefore = Object.keys(resourceContent);
    args.forEach(function (key) {
      if (!resourceContent[key]) {
        resourceContent[key] = key;
      }
    });
    var resourceKeysAfter = Object.keys(resourceContent);
    console.log('Number of keys that will be added: ' + (resourceKeysAfter.length - resourceKeysBefore.length));
    return Q.when(resourceContent);
  }

  /**
   * Get the string from Transifex to check if it exists
   * @param  {String} word 
   * @return {Q.Promise} 
   */
  function getStringFromTx(word) {
    var deferred = Q.defer();
    var url = baseUrl + '/project/' + txProject + '/resource/' + txResource + '/source/' + getHashString(word);

    console.log('Fetching string "' + word + '" on Transifex...');

    rest
      .get(url, {
        username: process.env.TX_USER,
        password: process.env.TX_PASS
      })
      .on('success', function (data, response) {
        console.log('String "' + word + '" found!');
        deferred.resolve(data);
      })
      .on('fail', function (err, response) {
        console.log('String "' + word + '" not found!');
        deferred.reject(err);
      })
      .on('error', function (err, response) {
        deferred.reject(err);
      });

    return deferred.promise;
  }

  /**
   * Update word on the Transifex resource to display the users's comment
   * @param {String} word 
   * @param {String} comment 
   * @return {Q.Promise} 
   */
  function setCommentForString(word, comment) {
    var deferred = Q.defer();
    var url = baseUrl + '/project/' + txProject + '/resource/' + txResource + '/source/' + getHashString(word);

    console.log('Adding comment "' + comment + '" on string "' + word + '" on Transifex...');

    rest.put(url, {
        headers: {
          "Content-Type": "application/json"
        },
        data: JSON.stringify({ "comment": comment }),
        username: process.env.TX_USER,
        password: process.env.TX_PASS
      })
      .on('success', function (data, response) {
        console.log('Transifex string "' + word + '" successfully updated!');
        deferred.resolve(data);
      })
      .on('fail', function (err, response) {
        console.log('Transifex string "' + word + '" could not be updated.');
        deferred.reject(err);
      });

    return deferred.promise;
  }

  /**
   * Compute the hash string for the given word+context
   * @param  {String} word 
   * @param  {String} context 
   * @return {String} 
   */
  function getHashString(word, context) {
    word = word.replace(/\./g, '\\.');
    context = context || '';
    var md5sum = crypto.createHash('md5');
    md5sum.update([word, context].join(':'), 'utf-8');
    return md5sum.digest('hex');
  }

  function throwError(err) {
    throw new Error(err);
  }

})(require('crypto'), require('restler'), require('q'));