Remove ActiveSupport

.rubocop.yml

@@ -44,7 +44,7 @@ Style/GuardClause:
   MinBodyLength: 4
 
 Style/HashSyntax:
-  EnforcedStyle: hash_rockets
+  Enabled: False
 
 Style/IndentHash:
   EnforcedStyle: consistent

lib/protobuf.rb

@@ -1,14 +1,27 @@
 require 'base64'
+require 'json'
 require 'logger'
 require 'pp'
 require 'socket'
 require 'stringio'
 
-require 'active_support/core_ext/object/blank'
-require 'active_support/core_ext/object/try'
-require 'active_support/inflector'
-require 'active_support/json'
-require 'active_support/notifications'
+# rubocop:disable Lint/HandleExceptions
+begin
+  require 'active_support/lazy_load_hooks'
+rescue LoadError
+end
+begin
+  require 'active_support/notifications'
+rescue LoadError
+end
+# rubocop:enable Lint/HandleExceptions
+
+require 'protobuf/refinements/string/classify'
+require 'protobuf/refinements/string/constantize'
+
+using Protobuf::Refinements::String::Classify
+using Protobuf::Refinements::String::Constantize
+
 # Under MRI, this optimizes proto decoding by around 15% in tests.
 # When unavailable, we fall to pure Ruby.
 # rubocop:disable Lint/HandleExceptions
@@ -55,17 +68,33 @@ class << self
   end
 
   def self.after_server_bind(&block)
+    unless Object.const_defined?('::ActiveSupport::Notifications')
+      warn_no_active_support_notifications('after_server_bind')
+      return
+    end
+
     ::ActiveSupport::Notifications.subscribe('after_server_bind') do |*args|
       block.call(*args)
     end
   end
 
   def self.before_server_bind(&block)
+    unless Object.const_defined?('::ActiveSupport::Notifications')
+      warn_no_active_support_notifications('before_server_bind')
+      return
+    end
+
     ::ActiveSupport::Notifications.subscribe('before_server_bind') do |*args|
       block.call(*args)
     end
   end
 
+  def self.warn_no_active_support_notifications(method)
+    return if ENV['PROTOBUF_SUPPRESS_NO_ACTIVE_SUPPORT_NOTIFICATIONS_WARNING'] == '1'
+
+    STDERR.puts("[WARN] ActiveSupport::Notifications is not loaded. To use `Protobuf.#{method}`, you need to require 'active_support/notifications'")
+  end
+
   def self.client_host
     @client_host ||= Socket.gethostname
   end

lib/protobuf/cli.rb

@@ -1,11 +1,15 @@
-require 'active_support/core_ext/hash/keys'
-require 'active_support/inflector'
-
 require 'thor'
 require 'protobuf/version'
 require 'protobuf/logging'
 require 'protobuf/rpc/servers/socket_runner'
 require 'protobuf/rpc/servers/zmq_runner'
+require 'protobuf/refinements/hash/symbolize_keys'
+require 'protobuf/refinements/string/classify'
+require 'protobuf/refinements/string/constantize'
+
+using Protobuf::Refinements::Hash::SymbolizeKeys
+using Protobuf::Refinements::String::Classify
+using Protobuf::Refinements::String::Constantize
 
 module Protobuf
   class CLI < ::Thor
@@ -240,14 +244,14 @@ def shutdown_server
       def start_server
         debug_say('Running server')
 
-        ::ActiveSupport::Notifications.instrument("before_server_bind")
+        ::ActiveSupport::Notifications.instrument("before_server_bind") if Object.const_defined?('::ActiveSupport::Notifications')
 
         runner.run do
           logger.info do
             "pid #{::Process.pid} -- #{mode} RPC Server listening at #{options.host}:#{options.port}"
           end
 
-          ::ActiveSupport::Notifications.instrument("after_server_bind")
+          ::ActiveSupport::Notifications.instrument("after_server_bind") if Object.const_defined?('::ActiveSupport::Notifications')
         end
 
         logger.info { 'Shutdown complete' }

lib/protobuf/code_generator.rb

@@ -1,4 +1,3 @@
-require 'active_support/core_ext/module/aliasing'
 require 'protobuf/generators/file_generator'
 
 module Protobuf

lib/protobuf/deprecation.rb

@@ -1,7 +1,20 @@
-require 'active_support/deprecation'
+begin
+  require 'active_support/deprecation'
+rescue LoadError # rubocop:disable Lint/HandleExceptions
+end
 
 module Protobuf
-  if ::ActiveSupport::Deprecation.is_a?(Class)
+  if !Object.const_defined?('::ActiveSupport::Deprecation')
+    class NullDeprecator
+      def initialize(*); end
+      def define_deprecated_methods(*); end
+      def deprecate_methods(*); end
+      attr_accessor :silenced, :behavior
+    end
+
+    Deprecation = NullDeprecator.clone
+    FieldDeprecation = NullDeprecator.clone
+  elsif ::ActiveSupport::Deprecation.is_a?(Class)
     class DeprecationBase < ::ActiveSupport::Deprecation
       def deprecate_methods(*args)
         deprecation_options = { :deprecator => self }

lib/protobuf/enum.rb

@@ -1,5 +1,9 @@
 require 'delegate'
 
+require 'protobuf/refinements/object/try'
+
+using Protobuf::Refinements::Object::Try
+
 ##
 # Adding extension to Numeric until
 # we can get people to stop calling #value

lib/protobuf/field/base_field.rb

@@ -1,7 +1,9 @@
-require 'active_support/core_ext/hash/slice'
 require 'protobuf/field/field_array'
 require 'protobuf/field/field_hash'
 require 'protobuf/field/base_field_object_definitions'
+require 'protobuf/refinements/hash/slice'
+
+using Protobuf::Refinements::Hash::Slice
 
 module Protobuf
   module Field

lib/protobuf/field/base_field_object_definitions.rb

@@ -1,3 +1,7 @@
+require 'protobuf/refinements/kernel/blank'
+
+using Protobuf::Refinements::Kernel::Blank
+
 module Protobuf
   module Field
     module BaseFieldObjectDefinitions

lib/protobuf/field/bytes_field.rb

@@ -70,7 +70,7 @@ def coerce!(value)
         end
       end
 
-      def json_encode(value, options={})
+      def json_encode(value, _options = {})
         Base64.strict_encode64(value)
       end
     end

lib/protobuf/field/enum_field.rb

@@ -37,7 +37,7 @@ def coerce!(value)
         type_class.fetch(value) || fail(TypeError, "Invalid Enum value: #{value.inspect} for #{name}")
       end
 
-      def json_encode(value, options={})
+      def json_encode(value, _options = {})
         enum = type_class.enums.find { |e| e.to_i == value }
         enum.to_s(:name)
       end

lib/protobuf/field/string_field.rb

@@ -43,7 +43,7 @@ def encode(value)
         "#{::Protobuf::Field::VarintField.encode(value_to_encode.bytesize)}#{value_to_encode}"
       end
 
-      def json_encode(value, options={})
+      def json_encode(value, _options = {})
         value
       end
     end

lib/protobuf/generators/enum_generator.rb

@@ -1,5 +1,8 @@
 require 'protobuf/generators/base'
 require 'protobuf/generators/option_generator'
+require 'protobuf/refinements/object/try'
+
+using Protobuf::Refinements::Object::Try
 
 module Protobuf
   module Generators

lib/protobuf/generators/field_generator.rb

@@ -1,4 +1,7 @@
 require 'protobuf/generators/base'
+require 'protobuf/refinements/object/try'
+
+using Protobuf::Refinements::Object::Try
 
 module Protobuf
   module Generators

lib/protobuf/generators/file_generator.rb

@@ -1,6 +1,9 @@
 require 'set'
 require 'protobuf/generators/base'
 require 'protobuf/generators/group_generator'
+require 'protobuf/refinements/string/constantize'
+
+using Protobuf::Refinements::String::Constantize
 
 module Protobuf
   module Generators

lib/protobuf/generators/group_generator.rb

@@ -4,6 +4,9 @@
 require 'protobuf/generators/message_generator'
 require 'protobuf/generators/option_generator'
 require 'protobuf/generators/service_generator'
+require 'protobuf/refinements/object/try'
+
+using Protobuf::Refinements::Object::Try
 
 module Protobuf
   module Generators

lib/protobuf/generators/service_generator.rb

@@ -1,5 +1,8 @@
 require 'protobuf/generators/base'
 require 'protobuf/generators/option_generator'
+require 'protobuf/refinements/string/underscore'
+
+using Protobuf::Refinements::String::Underscore
 
 module Protobuf
   module Generators

lib/protobuf/lifecycle.rb

@@ -5,25 +5,29 @@ def register(event_name)
         fail "Lifecycle register must have a block" unless block_given?
         event_name = normalized_event_name(event_name)
 
-        ::ActiveSupport::Notifications.subscribe(event_name) do |_name, _start, _finish, _id, args|
-          yield(*args)
+        if Object.const_defined?('::ActiveSupport::Notifications')
+          ::ActiveSupport::Notifications.subscribe(event_name) do |_name, _start, _finish, _id, args|
+            yield(*args)
+          end
         end
       end
       alias :on register
 
       def trigger(event_name, *args)
         event_name = normalized_event_name(event_name)
 
-        ::ActiveSupport::Notifications.instrument(event_name, args)
+        ::ActiveSupport::Notifications.instrument(event_name, args) if Object.const_defined?('::ActiveSupport::Notifications')
       end
 
-      replacement = ::ActiveSupport::Notifications
+      if Object.const_defined?('::ActiveSupport::Notifications')
+        replacement = ::ActiveSupport::Notifications
 
-      ::Protobuf.deprecator.deprecate_methods(
-        self,
-        :register => "#{replacement}.#{replacement.method(:subscribe).name}".to_sym,
-        :trigger => "#{replacement}.#{replacement.method(:instrument).name}".to_sym,
-      )
+        ::Protobuf.deprecator.deprecate_methods(
+          self,
+          :register => "#{replacement}.#{replacement.method(:subscribe).name}".to_sym,
+          :trigger => "#{replacement}.#{replacement.method(:instrument).name}".to_sym,
+        )
+      end
 
       def normalized_event_name(event_name)
         event_name.to_s.downcase

lib/protobuf/message.rb

@@ -1,6 +1,11 @@
 require 'protobuf/message/fields'
 require 'protobuf/message/serialization'
 require 'protobuf/varint'
+require 'protobuf/refinements/string/camelize'
+require 'protobuf/refinements/string/underscore'
+
+using Protobuf::Refinements::String::Camelize
+using Protobuf::Refinements::String::Underscore
 
 module Protobuf
   class Message
@@ -174,7 +179,17 @@ def to_json_hash(options = {})
                          value
                        end
 
-        if proto3 && (hashed_value.nil? || value == field.class.default rescue field.default rescue nil)
+        if proto3 && (
+            begin
+              begin
+                hashed_value.nil? || value == field.class.default
+              rescue
+                field.default
+              end
+            rescue
+              nil
+            end
+        )
           result.delete(field.name)
         else
           key = proto3 ? field.name.to_s.camelize(:lower).to_sym : field.name

lib/protobuf/message/fields.rb

@@ -1,4 +1,9 @@
 require "set"
+require 'protobuf/refinements/kernel/blank'
+require 'protobuf/refinements/object/try'
+
+using Protobuf::Refinements::Kernel::Blank
+using Protobuf::Refinements::Object::Try
 
 module Protobuf
   class Message

lib/protobuf/optionable.rb

@@ -1,3 +1,7 @@
+require 'protobuf/refinements/object/try'
+
+using Protobuf::Refinements::Object::Try
+
 module Protobuf
   module Optionable
     module ClassMethods

lib/protobuf/refinements/hash/slice.rb

@@ -0,0 +1,36 @@
+# Adapted from: https://github.com/rubyworks/facets/blob/master/lib/core/facets/hash/slice.rb
+
+module Protobuf
+  module Refinements
+    module Hash
+      module Slice
+        refine ::Hash do
+          def slice(*keep_keys)
+            if block_given?
+              each do |k, v|
+                keep_keys << k if yield(k, v)
+              end
+            end
+
+            keep_keys.each_with_object({}) do |key, hash|
+              hash[key] = fetch(key) if key?(key)
+            end
+          end
+
+          def slice!(*keep_keys)
+            if block_given?
+              each do |k, v|
+                keep_keys << k if yield(k, v)
+              end
+            end
+
+            rejected = keys - keep_keys
+            removed = {}
+            rejected.each { |k| removed[k] = delete(k) }
+            removed
+          end
+        end
+      end
+    end
+  end
+end

lib/protobuf/refinements/hash/symbolize_keys.rb

@@ -0,0 +1,21 @@
+# Adapted from: https://github.com/rails/rails/blob/v6.0.3.2/activesupport/lib/active_support/core_ext/hash/keys.rb
+
+module Protobuf
+  module Refinements
+    module Hash
+      module SymbolizeKeys
+        refine ::Hash do
+          def symbolize_keys
+            transform_keys do |key|
+              begin
+                key.to_sym
+              rescue
+                key
+              end
+            end
+          end
+        end
+      end
+    end
+  end
+end