use sized queue

lib/graphql-hive/usage_reporter.rb

@@ -3,7 +3,6 @@
 require "digest"
 require "graphql-hive/analyzer"
 require "graphql-hive/printer"
-require "graphql-hive/bounded_queue"
 
 module GraphQL
   class Hive < GraphQL::Tracing::PlatformTracing
@@ -21,16 +20,15 @@ def initialize(options, client)
         @client = client
         @options_mutex = Mutex.new
         @sampler = Sampler.new(options[:collect_usage_sampling], options[:logger]) # NOTE: logs for deprecated field
-        @queue = BoundedQueue.new(
-          bound: options[:queue_size],
-          logger: options[:logger]
-        )
+        @queue = Thread::SizedQueue.new(options[:queue_size])
 
         start_thread
       end
 
       def add_operation(operation)
-        @queue.push(operation)
+        @queue.push(operation, true)
+      rescue ThreadError
+        @options[:logger].error("SizedQueue is full, discarding operation. Size: #{@queue.size}, Max: #{@queue.max}")
       end
 
       def on_exit

spec/graphql/graphql-hive/usage_reporter_spec.rb

@@ -33,7 +33,7 @@
       expect(usage_reporter_instance.instance_variable_get(:@client)).to eq(client)
 
       expect(usage_reporter_instance.instance_variable_get(:@options_mutex)).to be_an_instance_of(Mutex)
-      expect(usage_reporter_instance.instance_variable_get(:@queue)).to be_an_instance_of(GraphQL::Hive::BoundedQueue)
+      expect(usage_reporter_instance.instance_variable_get(:@queue)).to be_an_instance_of(Thread::SizedQueue)
       expect(usage_reporter_instance.instance_variable_get(:@sampler)).to be_an_instance_of(GraphQL::Hive::Sampler)
     end
   end
@@ -44,6 +44,17 @@
       usage_reporter_instance.add_operation(operation)
       expect(usage_reporter_instance.instance_variable_get(:@queue).pop).to eq(operation)
     end
+
+    describe "when the queue is full" do
+      let(:options) { {logger: logger, buffer_size: 1, queue_size: 1} }
+
+      it "logs an error" do
+        allow(logger).to receive(:error)
+        usage_reporter_instance.add_operation("operation 1")
+        usage_reporter_instance.add_operation("operation 2")
+        expect(logger).to have_received(:error)
+      end
+    end
   end
 
   describe "#on_exit" do