From 82742846526dd8c4af3105f2f9a4bf674c043b05 Mon Sep 17 00:00:00 2001
From: Evgeny Mazovetskiy <otzy@users.noreply.github.com>
Date: Mon, 3 Aug 2015 17:01:24 +0200
Subject: [PATCH] count aggregate function

feeds_into_counts
---
 app/helpers/feed_helper.rb | 67 ++++++++++++++++++++++++++++++++++++++
 1 file changed, 67 insertions(+)

diff --git a/app/helpers/feed_helper.rb b/app/helpers/feed_helper.rb
index 073d55e..34734de 100644
--- a/app/helpers/feed_helper.rb
+++ b/app/helpers/feed_helper.rb
@@ -356,6 +356,73 @@ def feeds_into_medians(feeds, params)
 
     return timeslices
   end
+  
+    # slice feed into sums
+  def feeds_into_counts(feeds, params)
+    # convert timescale (minutes) into seconds
+    seconds = params[:count].to_i * 60
+    # get floored time ranges
+    start_time = get_floored_time(feeds.first.created_at, seconds)
+    end_time = get_floored_time(feeds.last.created_at, seconds)
+
+    # create empty array with appropriate size
+    timeslices = Array.new((((end_time - start_time) / seconds).abs).floor)
+
+    # create a blank clone of the first feed so that we only get the necessary attributes
+    empty_feed = create_empty_clone(feeds.first)
+
+    # add feeds to array
+    feeds.each do |f|
+      i = ((f.created_at - start_time) / seconds).floor
+      f.created_at = start_time + i * seconds
+      # create multidimensional array
+      timeslices[i] = [] if timeslices[i].nil?
+      timeslices[i].push(f)
+    end
+
+    # keep track of whether numbers use commas as decimals
+    comma_flag = false
+
+    # fill in array
+    timeslices.each_index do |i|
+      # insert empty values
+      if timeslices[i].nil?
+        current_feed = empty_feed.dup
+        current_feed.created_at = (start_time + (i * seconds))
+        timeslices[i] = current_feed
+        # else sum the inner array
+      else
+        sum_feed = empty_feed.dup
+        sum_feed.created_at = timeslices[i].first.created_at
+        # for each feed
+        timeslices[i].each do |f|
+          # for each attribute, add to sum_feed so that we have the total
+          sum_feed.attribute_names.each do |attr|
+            # only add non-null integer fields
+            if attr.index('field') and !f[attr].nil? and is_a_number?(f[attr])
+
+              # set comma_flag once if we find a number with a comma
+              comma_flag = true if !comma_flag and f[attr].to_s.index(',')
+
+              # set initial data
+              if sum_feed[attr].nil?
+                sum_feed[attr] = 0
+                # add data
+              elsif f[attr]
+                sum_feed[attr] = sum_feed[attr] + 1
+              end
+
+            end
+          end
+        end
+
+        # set to the summed feed
+        timeslices[i] = object_sum(sum_feed, comma_flag, params[:round])
+      end
+    end
+
+    return timeslices
+  end
 
   # checks for valid timescale
   def timeparam_valid?(timeparam)