@@ -59,15 +59,18 @@ module Mel
5959 ) : Array (String )?
6060 return if count.zero?
6161
62- return find_due_update(time, count) if delete.nil?
63- delete ? find_due_delete(time, count) : find_due_no_delete(time, count)
62+ return find_due_delete_nil(time, count) if delete.nil?
63+
64+ delete ?
65+ find_due_delete_true(time, count) :
66+ find_due_delete_false(time, count)
6467 end
6568
6669 def find (count : Int , * , delete : Bool ? = false ) : Array (String )?
6770 return if count.zero?
6871
69- return find_update (count) if delete.nil?
70- delete ? find_delete (count) : find_no_delete (count)
72+ return find_delete_nil (count) if delete.nil?
73+ delete ? find_delete_true (count) : find_delete_false (count)
7174 end
7275
7376 def find (ids : Indexable , * , delete : Bool = false ) : Array (String )?
@@ -145,7 +148,7 @@ module Mel
145148 end
146149 end
147150
148- private def find_due_delete (time , count )
151+ private def find_due_delete_true (time , count )
149152 sql = <<-SQL
150153 SELECT id, data FROM #{ tasks_table }
151154 WHERE schedule >= $1 AND schedule <= $2
@@ -166,7 +169,7 @@ module Mel
166169 end
167170 end
168171
169- private def find_due_no_delete (time , count )
172+ private def find_due_delete_false (time , count )
170173 sql = <<-SQL
171174 SELECT data FROM #{ tasks_table }
172175 WHERE schedule >= $1 AND schedule <= $2
@@ -186,7 +189,7 @@ module Mel
186189 end
187190 end
188191
189- private def find_due_update (time , count )
192+ private def find_due_delete_nil (time , count )
190193 sql = <<-SQL
191194 SELECT id, data FROM #{ tasks_table }
192195 WHERE schedule >= $1 AND schedule <= $2
@@ -211,7 +214,7 @@ module Mel
211214 end
212215 end
213216
214- private def find_delete (count )
217+ private def find_delete_true (count )
215218 sql = <<-SQL
216219 SELECT id, data FROM #{ tasks_table } WHERE schedule >= $1
217220 ORDER BY schedule LIMIT $2 FOR UPDATE SKIP LOCKED;
@@ -230,7 +233,7 @@ module Mel
230233 end
231234 end
232235
233- private def find_no_delete (count )
236+ private def find_delete_false (count )
234237 sql = <<-SQL
235238 SELECT data FROM #{ tasks_table } WHERE schedule >= $1
236239 ORDER BY schedule LIMIT $2 ;
@@ -248,7 +251,7 @@ module Mel
248251 end
249252 end
250253
251- private def find_update (count )
254+ private def find_delete_nil (count )
252255 sql = <<-SQL
253256 SELECT id, data FROM #{ tasks_table } WHERE schedule >= $1
254257 ORDER BY schedule LIMIT $2 FOR UPDATE SKIP LOCKED;
0 commit comments