cropuploader-server.js

var Future = Npm.require("fibers/future");

Meteor.methods({
	cropUploaderS3urlBase: function() {
		//
		return CropUploader.knox.urlBase;
	},
	cropUploaderS3contents: function(prefix) {
		var future = new Future();

		CropUploader.knox.list({prefix: prefix}, function(error, response) {
		  if(error)
		  {
			console.log(error);
			throw new Meteor.Error(500, "An error occured getting your files");
		  }
		  else 
		  {
			response.Contents.forEach(function(image){
			  image.urlBase = CropUploader.knox.urlBase;
			});
			future.return(response.Contents);
		  }
		});
		return future.wait();
	},
	cropUploaderS3Delete: function(url) {
	  	// console.log(this.userId);
	  	var future = new Future();
	  	var uparts = url.split('//');
	  	var purl = uparts.length > 2 ? uparts[2] : uparts[1]; 
		var relativeUrl = '/'+purl.split('/').slice(1).join('/');
		console.log('cropUploaderS3Delete', url, relativeUrl);
		CropUploader.knox.deleteFile( relativeUrl, function(error, res) {
			if(error) {
				console.log('cropUploaderS3Delete', error);
				future.return(true);
			}
			else future.return(true);
		});
		return future.wait()
	},
	cropUploaderConsolidate: function() {
		//
		// get all images from this directory
		//
		var res = Meteor.call('cropUploaderS3contents',CropUploader.directory);
		console.log('cropUploaderConsolidate', CropUploader.directory, res);
		var ret = [];
		if(res)
		{
			res.forEach(function(image){
				//
				// skip directories (/ at the end)
				//
				if( !image.Key.match(/\/$/) )
				{
					ret.push(image.Key);
					// slingshot/derivative/thumbnail/cb276bcc-3ee3-4cd8-a03b-d4965adfca71.1429836526914.png
					var url = 'https://'+image.urlBase+'/'+image.Key;
					var pp = image.Key.split('/');
					// get the uuid of the image
					var uuid = pp.pop().split('.')[0];
					//
					// check if this is the original
					//
					if( !image.Key.match('derivative/') )
					{
						var img = CropUploader.images.findOne({url: url});
						if(!img)
						{
							console.log(url+' does not exist');
							CropUploader.images.insert({
								url: url,
								uuid: uuid,
								relativeUrl: image.Key,
								urlBase: image.urlBase,
							});
						}
						else
						{
							if(img.relativeUrl == undefined)
							{
								CropUploader.images.update(img._id,{$set:{
									relativeUrl: image.Key,
									urlBase: image.urlBase,
								}});
							}
						}
					}
					else
					{
						//
						// find the image record for this uuid
						//
						var img = CropUploader.images.findOne({uuid: uuid});
						if(img)
						{
							var type = pp.pop();
							// console.log(type, img.derivatives);
							var set = {};set['derivatives.'+type] = url;
							CropUploader.images.update(img._id,{$set: set});
						}
						else
						{
							//
							// we have a derivative without image, delete
							//
							console.log(uuid+' not adding '+image.Key);
							Meteor.call('cropUploaderS3Delete', url);
						}
					}
				}
			});
		}
		return ret;
	},
	cropUploaderUrl: function(url) {
		// http://www.gettyimages.ca/gi-resources/images/Homepage/Hero/UK/CMS_Creative_164657191_Kingfisher.jpg
		// http://stackoverflow.com/questions/17124053/node-js-get-image-from-web-and-encode-with-base64
		// request.get('http://tinypng.org/images/example-shrunk-8cadd4c7.png', function (error, response, body) {
		//     if (!error && response.statusCode == 200) {
		//         data = "data:" + response.headers["content-type"] + ";base64," + new Buffer(body).toString('base64');
		//         console.log(data);
		//     }
		// });
		try {
			var response = HTTP.call('GET', url,{npmRequestOptions: { encoding: null }});
			var content_type = response.headers['content-type'];
			var content_length = response.headers['content-length'];
			if(content_type.match(/^image/)) {
				console.log(`cropUploaderUrl ${content_type} of ${content_length} bytes`);
				return "data:" + content_type + ";base64," + new Buffer(response.content).toString('base64');
			} else {
				throw new Meteor.Error(500,'wrong content type', 'the url '+url+' returned '+content_type);
			}
		} catch (e) {
		    throw new Meteor.Error(e.statusCode, 'url wrong', 'the '+url+' is wrong');
		}
	}
});

Meteor.publish('cropUploaderImages', function(query) {
	query = query || {};
	return CropUploader.images.find(query);
});

CropUploader.images.allow({
	insert: function(userId, image) {
		// https://buzzledom-slingshot.s3-us-west-1.amazonaws.com/slingshot/2014-09-26.jpg
		image.userId = userId;
		image.created = new Date();
		image.urlBase = CropUploader.knox.urlBase;
		image.relativeUrl = image.url.split('//')[1].split('/').slice(1).join('/');
		if(image.dropboxImage) delete image.dropboxImage;
		if(image.template) delete image.template;
		// if('insert' in CropUploader._hooks && typeof CropUploader._hooks.insert == 'function')
		// 	image = CropUploader._hooks.insert(image);
		return userId && image;
	},
	update: function(userId, doc, fieldNames, modifier) {
		//
		// check if we are updating a derivative and delete the old one first
		//
		// { '$set': { 'derivatives.thumbnail': 'https://buzzledom-slingshot.s3-us-west-1.amazonaws.com/slingshot/derivative/thumbnail3f2aae7d-711f-48d1-87fe-b58611014de0.1429835432477.png' } }
		//
		var allowed = (doc.userId == userId || Roles.userIsInRole(userId, 'admin'));
		var deleteUrl = null;
		if( allowed && '$set' in modifier )
		{
			for(var m in modifier['$set'])
			{
				if(m.match('derivatives.'))
				{
					var t = m.split('.')[1];
					var url = modifier['$set'][m];
					if(url != doc.derivatives[t])
					{
						deleteUrl = url;
					}
				}
			}
		}
		if(deleteUrl) {
			console.log('images.update we should be deleting', deleteUrl);
		}
		return allowed;
	},
	remove: function(userId, doc) {
		if(doc.userId != userId && !Roles.userIsInRole(userId, 'admin')) return false;
		else return true;
		// var future = new Future();
		// var files = [ doc.relativeUrl ];
		// //
		// // build array of derivative relativeUrl
		// //
		// if(doc.derivatives)
		// {
		// 	for(var d in doc.derivatives) {
		// 		// add short relativeUrl
		// 		var uparts = doc.derivatives[d].split('//');
		// 		var purl = uparts.length > 2 ? uparts[2] : uparts[1]; 
		// 		// var relativeUrl = '/'+purl.split('/').slice(1).join('/');
		// 		// https://github.com/Automattic/knox/issues/121
		// 		var relativeUrl = purl.split('/').slice(1).join('/');
		// 		files.push( relativeUrl );
		// 	}
		// }
		// var deleteMultiple = CropUploader.knox.deleteMultiple( files , function(error, result){
		// 	// console.log('CropUploader.images.remove result', result);
		// 	if(error)
		// 	{
		// 		console.log('CropUploader.images.remove', error);
		// 		// throw new Meteor.Error(500, "An error occured deleting your file");
		// 		future.return(false);
		// 	}
		// 	else 
		// 	{
		// 		console.log('CropUploader.images.remove', files);
		// 		future.return(true);
		// 	}
		// });
		// // console.log('deleteMultiple', deleteMultiple);
		// return future.wait();
	}
});

CropUploader.images.after.remove(function(userId, image) {
	if(!image) return true;
	console.log('CropUploader.images.after.remove '+ image._id);
	var future = new Future();
	var files = [];
	if(image.relativeUrl) files.push( image.relativeUrl)
	//
	// build array of derivative relativeUrl
	//
	if(image.derivatives)
	{
		for(var d in image.derivatives) {
			// add short relativeUrl
			var uparts = image.derivatives[d].split('//');
			var purl = uparts.length > 2 ? uparts[2] : uparts[1]; 
			// var relativeUrl = '/'+purl.split('/').slice(1).join('/');
			// https://github.com/Automattic/knox/issues/121
			var relativeUrl = purl.split('/').slice(1).join('/');
			files.push( relativeUrl );
		}
	}
	// if(files.length>0) {
		var deleteMultiple = CropUploader.knox.deleteMultiple( files , function(error, result){
			// console.log('CropUploader.images.remove result', result);
			if(error)
			{
				console.log(' - error ', error);
				// throw new Meteor.Error(500, "An error occured deleting your file");
				future.return(false);
			}
			else 
			{
				console.log(' - files', files);
				future.return(true);
			}
		});
		// console.log(' - deleteMultiple', files);
		return future.wait();
	// }
});

Meteor.startup(function () {
	//
	// code to run on server at startup
	//
	// Meteor.call('cropUploaderConsolidate');
});