adds #default_logger to RedisStream (#4)

* adds #default_logger to RedisStream

* allows setting the loggin_stream_key

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    redis_stream (0.1.2)
+    redis_stream (0.1.3)
 
 GEM
   remote: https://rubygems.org/

lib/redis_stream.rb

@@ -27,4 +27,8 @@ def self.client
   def self.default_publisher
     @default_publisher ||= Publisher.new(config.stream_key)
   end
+
+  def self.default_logger
+    @default_logger ||= Publisher.new(config.logging_stream_key)
+  end
 end

lib/redis_stream/configuration.rb

@@ -1,11 +1,12 @@
 module RedisStream
   class Configuration
-    attr_accessor :client, :group_id, :consumer_id, :stream_key
+    attr_accessor :client, :group_id, :consumer_id, :stream_key, :logging_stream_key
 
     def initialize
       @group = "group"
       @consumer = "consumer"
       @stream_key = "stream"
+      @logging_stream_key = "logging_stream"
     end
 
     def redis(client)
@@ -27,5 +28,9 @@ def consumer(consumer_id)
     def stream(stream)
       @stream_key = stream
     end
+
+    def logging_stream(logging_stream)
+      @logging_stream_key = logging_stream
+    end
   end
 end

lib/redis_stream/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module RedisStream
-  VERSION = "0.1.2"
+  VERSION = "0.1.3"
 end

spec/redis_stream_spec.rb

@@ -20,4 +20,14 @@
       expect(RedisStream.client).to be_instance_of(DummyRedisClient)
     end
   end
+
+  describe ".default_logger" do
+    it "returns a Publisher instance" do
+      expect(RedisStream.default_logger).to be_instance_of(RedisStream::Publisher)
+    end
+
+    it "uses the logging stream key" do
+      expect(RedisStream.default_logger.instance_variable_get(:@stream_key)).to eq("logging_stream")
+    end
+  end
 end