Fix storage field type conversions in integrations

Convert storage fields to Symbol type in:
- ActiveStorage: service_name.to_sym instead of .to_s
- CarrierWave: Extract storage type from class name and convert to symbol
- Shrine: Ensure payload[:storage] is always a symbol

This fixes Rails integration test failures where storage names were being passed as Strings.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: ndbroadbent

lib/log_struct/integrations/active_storage.rb

@@ -71,7 +71,7 @@ def self.process_active_storage_event(event, config)
         log_data = case event_type
         when Event::Upload
           Log::ActiveStorage::Upload.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s,
             checksum: event.payload[:checksum]&.to_s,
             duration_ms: duration_ms,
@@ -82,44 +82,44 @@ def self.process_active_storage_event(event, config)
           )
         when Event::Download
           Log::ActiveStorage::Download.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s,
             filename: event.payload[:filename],
             range: event.payload[:range],
             duration_ms: duration_ms
           )
         when Event::Delete
           Log::ActiveStorage::Delete.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s
           )
         when Event::Metadata
           Log::ActiveStorage::Metadata.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s,
             metadata: event.payload[:metadata]
           )
         when Event::Exist
           Log::ActiveStorage::Exist.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s,
             exist: event.payload[:exist]
           )
         when Event::Stream
           Log::ActiveStorage::Stream.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s,
             prefix: event.payload[:prefix]
           )
         when Event::Url
           Log::ActiveStorage::Url.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s,
             url: event.payload[:url]
           )
         else
           Log::ActiveStorage::Metadata.new(
-            storage: service_name.to_s,
+            storage: service_name.to_sym,
             file_id: event.payload[:key]&.to_s,
             metadata: event.payload[:metadata]
           )

lib/log_struct/integrations/carrierwave.rb

@@ -53,7 +53,7 @@ def store!(*args)
 
           # Log the store operation with structured data
           log_data = Log::CarrierWave::Upload.new(
-            storage: storage.class.name,
+            storage: storage.class.name.split("::").last.downcase.to_sym,
             file_id: identifier,
             filename: file.filename,
             mime_type: file.content_type,
@@ -85,7 +85,7 @@ def retrieve_from_store!(identifier, *args)
 
           # Log the retrieve operation with structured data
           log_data = Log::CarrierWave::Download.new(
-            storage: storage.class.name,
+            storage: storage.class.name.split("::").last.downcase.to_sym,
             file_id: identifier,
             filename: file&.filename,
             mime_type: file&.content_type,

lib/log_struct/integrations/shrine.rb

@@ -37,10 +37,13 @@ def self.setup(config)
           end
 
           # Create structured log data
+          # Ensure storage is always a symbol
+          storage_sym = payload[:storage].to_sym
+
           log_data = case event_type
           when Event::Upload
             Log::Shrine::Upload.new(
-              storage: payload[:storage],
+              storage: storage_sym,
               location: payload[:location],
               uploader: payload[:uploader],
               upload_options: payload[:upload_options],
@@ -50,34 +53,34 @@ def self.setup(config)
             )
           when Event::Download
             Log::Shrine::Download.new(
-              storage: payload[:storage],
+              storage: storage_sym,
               location: payload[:location],
               download_options: payload[:download_options],
               additional_data: payload.except(:storage, :location, :download_options)
             )
           when Event::Delete
             Log::Shrine::Delete.new(
-              storage: payload[:storage],
+              storage: storage_sym,
               location: payload[:location],
               additional_data: payload.except(:storage, :location)
             )
           when Event::Metadata
             Log::Shrine::Metadata.new(
-              storage: payload[:storage],
+              storage: storage_sym,
               location: payload[:location],
               metadata: payload[:metadata],
               additional_data: payload.except(:storage, :location, :metadata)
             )
           when Event::Exist
             Log::Shrine::Exist.new(
-              storage: payload[:storage],
+              storage: storage_sym,
               location: payload[:location],
               exist: payload[:exist],
               additional_data: payload.except(:storage, :location, :exist)
             )
           else
             Log::Shrine::Metadata.new(
-              storage: payload[:storage],
+              storage: storage_sym,
               location: payload[:location],
               metadata: payload[:metadata]
             )