Include next_run_args for background worker.

config/mapping.rb

@@ -91,13 +91,14 @@
   entity     BackgroundWorker
   repository BackgroundWorkerRepository
 
-  attribute :id,          Integer
-  attribute :host_id,     Integer
-  attribute :supplier_id, Integer
-  attribute :next_run_at, Time
-  attribute :interval,    Integer
-  attribute :type,        String
-  attribute :status,      String
-  attribute :created_at,  Time
-  attribute :updated_at,  Time
+  attribute :id,            Integer
+  attribute :host_id,       Integer
+  attribute :supplier_id,   Integer
+  attribute :next_run_at,   Time
+  attribute :next_run_args, Concierge::PGJSON
+  attribute :interval,      Integer
+  attribute :type,          String
+  attribute :status,        String
+  attribute :created_at,    Time
+  attribute :updated_at,    Time
 end

db/migrations/20160829034305_add_next_run_args_to_background_worker.rb

@@ -0,0 +1,7 @@
+Hanami::Model.migration do
+  change do
+    alter_table :background_workers do
+      add_column :next_run_args, JSON, null: false, default: Sequel.pg_json({})
+    end
+  end
+end

lib/concierge/entities/background_worker.rb

@@ -9,17 +9,19 @@
 #
 # Attributes
 #
-# +id+          - the ID of the the record on the database, automatically generated.
-# +host_id+     - a foreign key to the +hosts+ table, indicating which host
-#                 the background worker is associated with.
-# +supplier_id+ - a foreign key to the +suppliers+ table, indicating which supplier
-#                 the background worker is associated with. Either this column or
-#                 +host_id+ must be set.
-# +next_run_at+ - a timestamp that indicates when the background worker should be
-#                 invoked next.
-# +interval+    - how often (in seconds), the background worker should be invoked.
-# +type+        - the type of synchronisation performed by the background worker.
-# +status+      - the status of the worker, which indicate its activity at a given moment.
+# +id+            - the ID of the the record on the database, automatically generated.
+# +host_id+       - a foreign key to the +hosts+ table, indicating which host
+#                   the background worker is associated with.
+# +supplier_id+   - a foreign key to the +suppliers+ table, indicating which supplier
+#                   the background worker is associated with. Either this column or
+#                   +host_id+ must be set.
+# +next_run_at+   - a timestamp that indicates when the background worker should be
+#                   invoked next.
+# +next_run_args+ - arguments to be passed to the worker implementation (listening on the
+#                   proper event) on the next run.
+# +interval+      - how often (in seconds), the background worker should be invoked.
+# +type+          - the type of synchronisation performed by the background worker.
+# +status+        - the status of the worker, which indicate its activity at a given moment.
 class BackgroundWorker
   include Hanami::Entity
 
@@ -39,8 +41,8 @@ class BackgroundWorker
   #             be rescheduled.
   STATUSES = %w(idle running)
 
-  attributes :id, :host_id, :supplier_id, :next_run_at, :interval, :type, :status,
-    :created_at, :updated_at
+  attributes :id, :host_id, :supplier_id, :next_run_at, :next_run_args, :interval,
+    :type, :status, :created_at, :updated_at
 
   def running?
     status == "running"