helpers.js

var redis = require('redis');
var redistogo = require('redis-url');
var settings = require('./settings');
var crypto = require('crypto');

//var redisClient = redis.createClient(settings.REDIS_PORT, settings.REDIS_HOST);

if (process.env.REDISTOGO_URL) {
	//var redisClient2 = require('redis-url').createClient(process.env.REDISTOGO_URL);
	/*function newRedisClient() {
		//var client = redis.createClient(redisConfig.port, redisConfig.host);
		var client = require('redis-url').createClient(process.env.REDISTOGO_URL);
		var clientAuth = function() { client.auth(process.env.REDISTOGO_URL.password); }
		//client.addListener('connected', clientAuth);
		//client.addListener('reconnected', clientAuth);
		//clientAuth();
		return client;
	}*/
	//var redisClient2 = newRedisClient();
	var redisClient2 = redistogo.createClient(process.env.REDISTOGO_URL);
} else {
	var redisClient2 = redis.createClient(settings.REDIS_PORT, settings.REDIS_HOST);
}

function isValidRequest(request) {
    // First, let's verify the payload's integrity by making sure it's
    // coming from a trusted source. We use the client secret as the key
    // to the HMAC.
    var hmac = crypto.createHmac('sha1', settings.CLIENT_SECRET);
    hmac.update(request.rawBody);
    var providedSignature = request.headers['x-hub-signature'];
    var calculatedSignature = hmac.digest(encoding='hex');
    
    // If they don't match up or we don't have any data coming over the
    // wire, then it's not valid.
    return !((providedSignature != calculatedSignature) || !request.body)
}
exports.isValidRequest = isValidRequest;

function debug(msg) {
  if (settings.debug) {
    console.log(msg);
  }
}
exports.debug = debug;

/*

    Each update that comes from Instagram merely tells us that there's new
    data to go fetch. The update does not include the data. So, we take the
    geography ID from the update, and make the call to the API.

*/

function processGeography(geoName, update){
  var path = '/v1/geographies/' + update.object_id + '/media/recent/';
  getMinID(geoName, function(error, minID){
    var queryString = "?client_id="+ settings.CLIENT_ID;
    if(minID){
      queryString += '&min_id=' + minID;
    } else {
        // If this is the first update, just grab the most recent.
      queryString += '&count=1';
    }
    var options = {
      host: settings.apiHost,
      // Note that in all implementations, basePath will be ''. Here at
      // instagram, this aint true ;)
      path: settings.basePath + path + queryString
    };
    if(settings.apiPort){
        options['port'] = settings.apiPort;
    }

        // Asynchronously ask the Instagram API for new media for a given
        // geography.
    debug("processGeography: getting " + path);
    settings.httpClient.get(options, function(response){
      var data = '';
      response.on('data', function(chunk){
        debug("Got data...");
        data += chunk;
      });
      response.on('end', function(){
        debug("Got end.");
          try {
			// trying to remove invalid utf-8 chars... doesn't seem to help
			//var re = /(?![\x00-\x7F]|[\xC0-\xDF][\x80-\xBF]|[\xE0-\xEF][\x80-\xBF]{2}|[\xF0-\xF7][\x80-\xBF]{3})./g;
			//data = data.replace(re, "")
			data = unescape(encodeURIComponent(data));
            var parsedResponse = JSON.parse(data);
          } catch (e) {
              console.log('Couldn\'t parse data. Malformed?');
              return;
          }
        if(!parsedResponse || !parsedResponse['data']){
            console.log('Did not receive data for ' + geoName +':');
            console.log(data);
            return;
        }
        setMinID(geoName, parsedResponse['data']);
        
        // Let all the redis listeners know that we've got new media.
        redisClient2.publish('channel:' + geoName, data);
        debug("Published: " + data);
      });
    });
  });
}
exports.processGeography = processGeography;

/* 
	get the tagged media from Instagram -- tag version of processGeography 
*/

function processTag(tagName, update){
  var path = '/v1/tags/' + update.object_id + '/media/recent/';
  getMinID(tagName, function(error, minID){
    var queryString = "?client_id="+ settings.CLIENT_ID;
    if(minID){
		console.log('minID is present for api call');
      //queryString += '&min_id=' + minID;
		//queryString += '&min_tag_id=' + minID;
    } else {
		console.log('no minID for api call');
        // If this is the first update, just grab the most recent.
      	//queryString += '&count=1';
		//queryString += '&min_tag_id=134086694019836510_16982601';
    }
    var options = {
      host: settings.apiHost,
      // Note that in all implementations, basePath will be ''. Here at
      // instagram, this aint true ;)
      path: settings.basePath + path + queryString
    };
    if(settings.apiPort){
        options['port'] = settings.apiPort;
    }

        // Asynchronously ask the Instagram API for new media for a given
        // geography.
    debug("processTag: getting " + options.path);
    settings.httpClient.get(options, function(response){
      var data = '';
      response.on('data', function(chunk){
        debug("Got data...");
        data += chunk;
      });
      response.on('end', function(){
        debug("Got end.");
          try {
			// trying to remove invalid utf-8 chars... doesn't seem to help
			//var re = /(?![\x00-\x7F]|[\xC0-\xDF][\x80-\xBF]|[\xE0-\xEF][\x80-\xBF]{2}|[\xF0-\xF7][\x80-\xBF]{3})./g;
			//data = data.replace(re, "")
			data = unescape(encodeURIComponent(data));
            var parsedResponse = JSON.parse(data);
          } catch (e) {
              console.log('Couldn\'t parse data. Malformed?');
              return;
          }
        if(!parsedResponse || !parsedResponse['data']){
            console.log('Did not receive data for ' + tagName +':');
            console.log(data);
            return;
        }
        //setMinID(tagName, parsedResponse['data']);
        
        // Let all the redis listeners know that we've got new media.
        redisClient2.publish('channel:' + tagName, data);
        debug("Published: " + data);
      });
    });
  });
}
exports.processTag = processTag;

function getMedia(callback){
    // This function gets the most recent media stored in redis
  redisClient2.lrange('media:objects', 0, 19, function(error, media){
      //debug("getMedia: got " + media.length + " items");
      // Parse each media JSON to send to callback
      media = media.map(function(json){return JSON.parse(json);});
      callback(error, media);
  });
}
exports.getMedia = getMedia;

/*
    In order to only ask for the most recent media, we store the MAXIMUM ID
    of the media for every geography we've fetched. This way, when we get an
    update, we simply provide a min_id parameter to the Instagram API that
    fetches all media that have been posted *since* the min_id.
    
    You might notice there's a fatal flaw in this logic: We create
    media objects once your upload finishes, not when you click 'done' in the
    app. This means that if you take longer to press done than someone else
    who will trigger an update on your same geography, then we will skip
    over your media. Alas, this is a demo app, and I've had far too
    much red bull – so we'll live with it for the time being.
    
*/

function getMinID(geoName, callback){
  redisClient2.get('min-id:channel:' + geoName, callback);
}
exports.getMinID = getMinID;

function setMinID(geoName, data){
    var sorted = data.sort(function(a, b){
        return parseInt(b.id) - parseInt(a.id);
    });
    var nextMinID;
    try {
		console.log('going to set nextMinID');
		console.log('data is:');
		console.log(sorted);
        nextMinID = parseInt(sorted[0].id);
		console.log('set nextMinID');
      	redisClient2.set('min-id:channel:' + geoName, nextMinID);
		console.log('set Redis min-id:channel');
    } catch (e) {
        console.log('Error parsing min ID for: ' + geoName);
        console.log(sorted);
    }
}
exports.setMinID = setMinID;