feat(persisted-metrics): Add new type of aggregation

app/models/billable_metric.rb

@@ -16,6 +16,7 @@ class BillableMetric < ApplicationRecord
     sum_agg
     max_agg
     unique_count_agg
+    recurring_count_agg
   ].freeze
 
   enum billable_period: BILLABLE_PERIODS

app/services/billable_metrics/aggregations/recurring_count_service.rb

@@ -0,0 +1,14 @@
+# frozen_string_literal: true
+
+module BillableMetrics
+  module Aggregations
+    class RecurringCountService < BillableMetrics::Aggregations::BaseService
+      def aggregate(from_date:, to_date:, options: {})
+        # TODO: implement aggregation logic
+        result.aggregation = 0
+        result.count = 0
+        result
+      end
+    end
+  end
+end

app/services/fees/charge_service.rb

@@ -101,6 +101,8 @@ def aggregator
                              BillableMetrics::Aggregations::SumService
                            when :unique_count_agg
                              BillableMetrics::Aggregations::UniqueCountService
+                           when :recurring_count_agg
+                             BillableMetrics::Aggregations::RecurringCountService
                            else
                              raise NotImplementedError
       end

schema.graphql

@@ -62,6 +62,7 @@ input AddStripePaymentProviderInput {
 enum AggregationTypeEnum {
   count_agg
   max_agg
+  recurring_count_agg
   sum_agg
   unique_count_agg
 }

schema.json

@@ -551,6 +551,12 @@
               "description": null,
               "isDeprecated": false,
               "deprecationReason": null
+            },
+            {
+              "name": "recurring_count_agg",
+              "description": null,
+              "isDeprecated": false,
+              "deprecationReason": null
             }
           ]
         },