From 09115443b72ff881f226adda615b1966121f44c1 Mon Sep 17 00:00:00 2001
From: Luca Frosini <luca.frosini@isti.cnr.it>
Date: Wed, 25 Oct 2017 14:44:05 +0000
Subject: [PATCH] Added missing map-reduce

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/private/luca.frosini/GenerateMapReduceCouchbase@157575 82a268e6-3cf1-43bd-a215-b396298e98cf
---
 .../noContext/operationType/map.js            | 23 +++++++++++++++++++
 .../noContext/operationType/reduce.js         | 14 +++++++++++
 2 files changed, 37 insertions(+)
 create mode 100644 src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/map.js
 create mode 100644 src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/reduce.js

diff --git a/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/map.js b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/map.js
new file mode 100644
index 0000000..808c5b5
--- /dev/null
+++ b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/map.js
@@ -0,0 +1,23 @@
+function(doc,meta) {
+	if(doc.usageRecordType == "StorageUsageRecord" || doc.recordType == "StorageUsageRecord"){
+		if((doc.dataVolume && isNaN(Number(doc.dataVolume))) || (doc.operationCount && isNaN(Number(doc.operationCount)))){
+			emit([0, "Invalid Value", doc.id], doc);
+			return;
+		}
+		var data = {};
+		data.dataVolume = doc.dataVolume ? Number(doc.dataVolume) : 0;
+		data.operationCount = doc.operationCount ? Number(doc.operationCount) : 1;
+		var timestamp = Number(doc.creationTime);
+                var date = new Date(timestamp);
+		var dataKey = [];
+		dataKey.push(date.getUTCFullYear());
+		dataKey.push(date.getUTCMonth()+1);
+		dataKey.push(date.getUTCDate());
+		dataKey.push(date.getUTCHours());
+		dataKey.push(date.getUTCMinutes());
+		dataKey.push(doc.operationType);
+		
+		emit(dataKey, data);
+	}
+}	
+ 
diff --git a/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/reduce.js b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/reduce.js
new file mode 100644
index 0000000..29d805d
--- /dev/null
+++ b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/reduce.js
@@ -0,0 +1,14 @@
+function(keys, values, rereduce){
+	var total = 0;
+	var dataVolume = 0;
+	for(i=0; i<values.length; i++){
+		total = Number(total) + Number(values[i].operationCount);
+		dataVolume = Number(dataVolume) + Number(values[i].dataVolume);
+	}
+	
+	ret = {};
+	ret.operationCount = Number(total);
+	ret.dataVolume = Number(dataVolume);
+ 
+	return ret;
+}