Add chunk_type to info struct

CHANGELOG.md

@@ -1,6 +1,7 @@
 # Changelog
 
 ## Unreleased
+* Add chunk_type to info struct (#47)
 
 ## 0.5.1
 * Update Info struct for RTS 1.4 compatibility (#45)

lib/redis/time_series/info.rb

@@ -38,6 +38,7 @@ class TimeSeries
     Info = Struct.new(
       :chunk_count,
       :chunk_size,
+      :chunk_type,
       :duplicate_policy,
       :first_timestamp,
       :labels,
@@ -56,12 +57,14 @@ class TimeSeries
       def self.parse(series:, data:)
         data.each_slice(2).reduce({}) do |h, (key, value)|
           # Convert camelCase info keys to snake_case
-          h[key.gsub(/(.)([A-Z])/,'\1_\2').downcase] = value
+          key = key.gsub(/(.)([A-Z])/,'\1_\2').downcase.to_sym
+          next h unless members.include?(key)
+          h[key] = value
           h
         end.then do |parsed_hash|
-          parsed_hash['series'] = series
-          parsed_hash['labels'] = parsed_hash['labels'].to_h
-          parsed_hash['rules'] = parsed_hash['rules'].map { |d| Rule.new(source: series, data: d) }
+          parsed_hash[:series] = series
+          parsed_hash[:labels] = parsed_hash[:labels].to_h
+          parsed_hash[:rules] = parsed_hash[:rules].map { |d| Rule.new(source: series, data: d) }
           new(parsed_hash)
         end
       end

spec/redis/time_series_spec.rb

@@ -314,6 +314,7 @@ def msec(ts)
         {
           chunk_count: 1,
           chunk_size: 4096,
+          chunk_type: 'compressed',
           duplicate_policy: nil,
           first_timestamp: 0,
           labels: {},