Release_2025-07-01

Release 2025 07 01

Author: DominikAlberski

lib/travis/api/v3/renderer/csv_exports.rb

@@ -0,0 +1,6 @@
+module Travis::API::V3
+  class Renderer::CsvExports < ModelRenderer
+    representation(:minimal, :status, :message, :owner_id, :owner_type)
+    representation(:standard, :status, :message, :owner_id, :owner_type)
+  end
+end

lib/travis/api/v3/routes.rb

@@ -169,6 +169,11 @@ module Routes
         route '/executions_per_sender'
         get :for_owner_per_sender
       end
+
+      resource :csv_exports do
+        route '/csv_exports'
+        post :create
+      end
     end
 
     resource :credits_calculator do

lib/travis/api/v3/services.rb

@@ -24,6 +24,7 @@ module Services
     CreditsCalculator     = Module.new { extend Services }
     Cron                  = Module.new { extend Services }
     Crons                 = Module.new { extend Services }
+    CsvExports            = Module.new { extend Services }
     CustomKey             = Module.new { extend Services }
     CustomKeys            = Module.new { extend Services }
     EmailSubscription     = Module.new { extend Services }

lib/travis/api/v3/services/csv_exports/create.rb

@@ -0,0 +1,58 @@
+module Travis::API::V3
+  module Services::CsvExports
+    class Create < Service
+      params :report_type, :recipient_email, :expires_in, :start_date, :end_date, prefix: :csv_export
+
+      def run!
+        owner = query(:owner).find
+        raise NotFound, 'Owner not found' unless owner
+
+        csv_export_data = get_csv_export_data
+        enqueue_csv_export(owner, csv_export_data)
+
+        recipient_email = csv_export_data['recipient_email']
+
+        response = OpenStruct.new(
+          status: 202,
+          message: "CSV export job enqueued. You will receive an email at #{recipient_email} when it's ready.",
+          owner_id: owner.id,
+          owner_type: owner.class.name
+        )
+
+        result(response)
+      end
+
+      private
+
+      def get_csv_export_data
+        input_json = @env['travis.input.json'] if @env
+        input_json&.dig('csv_export') || {}
+      end
+
+      def enqueue_csv_export(owner, csv_export_data)
+        payload = {
+          'owner_id' => owner.id,
+          'owner_type' => owner.class.name,
+          'report_type' => csv_export_data['report_type'],
+          'recipient_email' => csv_export_data['recipient_email'],
+          'expires_in' => csv_export_data['expires_in'],
+          'start_date' => csv_export_data['start_date'],
+          'end_date' => csv_export_data['end_date']
+        }
+
+        Sidekiq::Client.push(
+          'queue' => 'billing',
+          'class' => 'Travis::Billing::Worker',
+          'args' => [
+            nil,
+            'Travis::Billing::Services::Executions::CsvExport',
+            'perform',
+            payload
+          ].map(&:to_json)
+        )
+
+        Travis.logger.info "CSV export job enqueued with payload: #{payload}"
+      end
+    end
+  end
+end