address imports in specs

Author: jsonbailey

lib/ldclient-rb/impl/data_system/fdv1.rb

@@ -2,6 +2,9 @@
 require 'ldclient-rb/impl/broadcaster'
 require 'ldclient-rb/impl/data_source'
 require 'ldclient-rb/impl/data_source/null_processor'
+require 'ldclient-rb/impl/data_source/polling'
+require 'ldclient-rb/impl/data_source/requestor'
+require 'ldclient-rb/impl/data_source/stream'
 require 'ldclient-rb/impl/data_store'
 require 'ldclient-rb/impl/data_system'
 require 'ldclient-rb/impl/store_client_wrapper'
@@ -149,14 +152,12 @@ def target_availability
           return LaunchDarkly::Impl::DataSource::NullUpdateProcessor.new if @config.offline? || @config.use_ldd?
 
           if @config.stream?
-            require 'ldclient-rb/stream'
-            return LaunchDarkly::StreamProcessor.new(@sdk_key, @config, @diagnostic_accumulator)
+            return LaunchDarkly::Impl::DataSource::StreamProcessor.new(@sdk_key, @config, @diagnostic_accumulator)
           end
 
           # Polling processor
-          require 'ldclient-rb/polling'
-          requestor = LaunchDarkly::Requestor.new(@sdk_key, @config)
-          LaunchDarkly::PollingProcessor.new(@config, requestor)
+          requestor = LaunchDarkly::Impl::DataSource::Requestor.new(@sdk_key, @config)
+          LaunchDarkly::Impl::DataSource::PollingProcessor.new(@config, requestor)
         end
       end
     end

lib/ldclient-rb/ldclient.rb

@@ -1,16 +1,20 @@
 require "ldclient-rb/impl/big_segments"
 require "ldclient-rb/impl/broadcaster"
+require "ldclient-rb/impl/context"
 require "ldclient-rb/impl/data_source"
-require "ldclient-rb/impl/data_store"
 require "ldclient-rb/impl/data_source/null_processor"
+require "ldclient-rb/impl/data_source/polling"
+require "ldclient-rb/impl/data_source/requestor"
+require "ldclient-rb/impl/data_source/stream"
+require "ldclient-rb/impl/data_store"
 require "ldclient-rb/impl/diagnostic_events"
-require "ldclient-rb/impl/evaluator"
-require "ldclient-rb/events"
-require "ldclient-rb/in_memory_store"
 require "ldclient-rb/impl/evaluation_with_hook_result"
+require "ldclient-rb/impl/evaluator"
 require "ldclient-rb/impl/flag_tracker"
-require "ldclient-rb/impl/store_client_wrapper"
 require "ldclient-rb/impl/migrations/tracker"
+require "ldclient-rb/impl/store_client_wrapper"
+require "ldclient-rb/events"
+require "ldclient-rb/in_memory_store"
 require "concurrent"
 require "concurrent/atomics"
 require "digest/sha1"

spec/expiring_cache_spec.rb

@@ -1,9 +1,10 @@
+require 'spec_helper'
 require 'timecop'
-require "ldclient-rb/expiring_cache"
+require "ldclient-rb/impl/expiring_cache"
 
 module LaunchDarkly
-  describe ExpiringCache do
-    subject { ExpiringCache }
+  describe Impl::ExpiringCache do
+    subject { Impl::ExpiringCache }
 
     before(:each) do
       Timecop.freeze(Time.now)

spec/impl/data_system/fdv1_spec.rb

@@ -24,18 +24,18 @@ module DataSystem
           end
 
           it "creates streaming processor by default" do
-            allow(LaunchDarkly::StreamProcessor).to receive(:new).and_call_original
+            allow(LaunchDarkly::Impl::DataSource::StreamProcessor).to receive(:new).and_call_original
             subject.start
-            expect(LaunchDarkly::StreamProcessor).to have_received(:new).with(sdk_key, config, nil)
+            expect(LaunchDarkly::Impl::DataSource::StreamProcessor).to have_received(:new).with(sdk_key, config, nil)
           end
 
           context "with polling mode" do
             let(:config) { LaunchDarkly::Config.new(stream: false) }
 
             it "creates polling processor" do
-              allow(LaunchDarkly::PollingProcessor).to receive(:new).and_call_original
+              allow(LaunchDarkly::Impl::DataSource::PollingProcessor).to receive(:new).and_call_original
               subject.start
-              expect(LaunchDarkly::PollingProcessor).to have_received(:new)
+              expect(LaunchDarkly::Impl::DataSource::PollingProcessor).to have_received(:new)
             end
           end
 
@@ -249,7 +249,7 @@ module DataSystem
             diagnostic_accumulator = double("DiagnosticAccumulator")
             subject.set_diagnostic_accumulator(diagnostic_accumulator)
 
-            expect(LaunchDarkly::StreamProcessor).to receive(:new).with(sdk_key, config, diagnostic_accumulator).and_call_original
+            expect(LaunchDarkly::Impl::DataSource::StreamProcessor).to receive(:new).with(sdk_key, config, diagnostic_accumulator).and_call_original
             subject.start
           end
 
@@ -261,7 +261,7 @@ module DataSystem
               subject.set_diagnostic_accumulator(diagnostic_accumulator)
 
               # PollingProcessor doesn't accept diagnostic_accumulator
-              expect(LaunchDarkly::PollingProcessor).to receive(:new).with(config, anything).and_call_original
+              expect(LaunchDarkly::Impl::DataSource::PollingProcessor).to receive(:new).with(config, anything).and_call_original
               subject.start
             end
           end

spec/polling_spec.rb

@@ -1,3 +1,4 @@
+require "ldclient-rb/impl/data_source/polling"
 require "ldclient-rb/impl/model/feature_flag"
 require "ldclient-rb/impl/model/segment"
 require 'ostruct'

spec/requestor_spec.rb

@@ -1,4 +1,5 @@
 require "http_util"
+require "ldclient-rb/impl/data_source/requestor"
 require "model_builders"
 require "spec_helper"
 

spec/simple_lru_cache_spec.rb

@@ -1,3 +1,4 @@
+require "ldclient-rb/impl/simple_lru_cache"
 require "spec_helper"
 
 module LaunchDarkly

spec/store_spec.rb

@@ -1,3 +1,4 @@
+require "ldclient-rb/impl/cache_store"
 require "spec_helper"
 
 module LaunchDarkly

spec/stream_spec.rb

@@ -1,3 +1,4 @@
+require "ldclient-rb/impl/data_source/stream"
 require "ld-eventsource"
 require "model_builders"
 require "spec_helper"