Enhances logging with structured data

Updates log statements to include structured emission of
job-related information such as ID, status, and expiry.
Improves log consistency across dead letter, retry, and timeout
handlers, aiding in monitoring and debugging efforts.

Refines job handling within worker by converting job instances
to strings.

src/joobq/dead_letter_manager.cr

@@ -14,7 +14,8 @@ module JoobQ
 
     def self.add(job)
       store.mark_as_dead(job, expires)
-      Log.info { "Job #{job.id} has been added to the dead letter queue" }
+      Log.info &.emit("Job added to dead letter queue",
+        job_id: job.jid, status: job.status, expires: job.expires, retries: job.retries, queue: job.queue)
     end
   end
 end

src/joobq/middlewares/retry.cr

@@ -39,7 +39,8 @@ module JoobQ
       delay = (2 ** (job.retries)) * 1000 # Delay in ms
       # Logic to add the job back to the queue after a delay
       queue.store.schedule(job, delay, delay_set: RedisStore::FAILED_SET)
-      Log.info { "Job #{job.id} has been scheduled for retry in #{delay}ms" }
+      Log.info &.emit("Job has been scheduled for retry", retry_in: delay,
+        job_id: job.jid, status: job.status, expires: job.expires, retries: job.retries, queue: job.queue)
     end
   end
 end

src/joobq/middlewares/throttle.cr

@@ -28,7 +28,7 @@ module JoobQ
             elapsed = now - last_job_time
             sleep_time = min_interval - elapsed
 
-            Log.debug { "Throttling #{queue.name} queue. Last job was #{elapsed}ms ago. Sleeping for #{sleep_time}ms" }
+            Log.debug &.emit("Throttling #{queue.name} queue. Last job was #{elapsed}ms ago. Sleeping for #{sleep_time}ms")
 
             if sleep_time > 0
               sleep (sleep_time / 1000.0).seconds

src/joobq/middlewares/timeout.cr

@@ -10,8 +10,10 @@ module JoobQ
       def call(job : Job, queue : BaseQueue, next_middleware : ->) : Nil
         if job.expired?
           job.expired!
-          Log.info { "Job #{job.id} has expired" }
+
           DeadLetterManager.add(job)
+          Log.info &.emit("Job has expired, added to dead letter queue",
+            job_id: job.jid, status: job.status, expires: job.expires, retries: job.retries, queue: job.queue)
         else
           next_middleware.call
         end

src/joobq/worker.cr

@@ -40,7 +40,7 @@ module JoobQ
               break
             else
               if job = @queue.next_job
-                handle_job job
+                handle_job job.to_s
               end
             end
           end