#3013

Committed 17 Aug 2022 11:01PM UTC coverage: 49.061% (-36.1%) from 85.141%

Build # #3013

Build Type

push

Committed by

Commit Message

setup coveralls (#81)

Run Details

575 of 1172 relevant lines covered (49.06%)

0.49 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

54.17

/lib/dispatch-rider/queue_services/file_system.rb

# This is a rudementary queue service that uses file system instead of
# Aws::SQS or SimpleQueue. It addresses SimpleQueue's inability to be used
# by only one application instance while avoiding the cost of setting up Aws::SQS.
# This is ideal to be used in development mode between multiple applications.
module DispatchRider
  module QueueServices
    require "dispatch-rider/queue_services/file_system/queue"
    require "dispatch-rider/queue_services/file_system/fs_received_message"
    class FileSystem < Base
      def assign_storage(attrs)
        begin
          path = attrs.fetch(:path)
          Queue.new(path)
        rescue IndexError
          raise RecordInvalid.new(self, ["Path can not be blank"])
        end
      end

      def insert(item)
        queue.add item
      end

      def raw_head
        queue.pop
      end
      
      def received_message_for(raw_item)
         FsReceivedMessage.new(construct_message_from(raw_item), raw_item, queue)
      end

      def construct_message_from(item)
        deserialize(item.read)
      end
      
      def put_back(item)
        queue.put_back(item)
      end

      def delete(item)
        queue.remove item
      end

      def size
        queue.size
      end
    end
  end
end

1	# This is a rudementary queue service that uses file system instead of
2	# Aws::SQS or SimpleQueue. It addresses SimpleQueue's inability to be used
3	# by only one application instance while avoiding the cost of setting up Aws::SQS.
4	# This is ideal to be used in development mode between multiple applications.
5	module DispatchRider	1✔
6	module QueueServices	1✔
7	require "dispatch-rider/queue_services/file_system/queue"	1✔
8	require "dispatch-rider/queue_services/file_system/fs_received_message"	1✔
9	class FileSystem < Base	1✔
10	def assign_storage(attrs)	1✔
11	begin
12	path = attrs.fetch(:path)	×
13	Queue.new(path)	×
14	rescue IndexError	×
15	raise RecordInvalid.new(self, ["Path can not be blank"])	×
16	end
17	end
18
19	def insert(item)	1✔
20	queue.add item	×
21	end
22
23	def raw_head	1✔
24	queue.pop	×
25	end
26
27	def received_message_for(raw_item)	1✔
28	FsReceivedMessage.new(construct_message_from(raw_item), raw_item, queue)	×
29	end
30
31	def construct_message_from(item)	1✔
32	deserialize(item.read)	×
33	end
34
35	def put_back(item)	1✔
36	queue.put_back(item)	×
37	end
38
39	def delete(item)	1✔
40	queue.remove item	×
41	end
42
43	def size	1✔
44	queue.size	×
45	end
46	end
47	end
48	end

payrollhero / dispatch-rider / #3013

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous