FIX: correct next configuration on flow jobs

Re: OpenFn/microservice#35

Author: stuartc

lib/engine/run_broadcaster.ex

@@ -131,7 +131,7 @@ defmodule Engine.RunBroadcaster do
               %{}
           end
 
-        next_state = %{"configuration" => Config.credential_body_for(config, job)}
+        next_state = %{"configuration" => Config.credential_body_for(config, triggered_job)}
 
         initial_state = merge_states([source_state, next_state])
 

mix.exs

@@ -1,7 +1,7 @@
 defmodule Engine.MixProject do
   use Mix.Project
 
-  @version "0.7.2"
+  @version "0.7.3"
   @source_url "https://github.com/OpenFn/engine"
 
   def project do

test/engine/run_broadcaster_test.exs

@@ -33,7 +33,12 @@ defmodule Engine.RunBroadcaster.UnitTest do
           cron_job =
             Job.new(name: "cron-job", trigger: "cron-trigger", adaptor: "@openfn/language-http"),
           success_flow_job =
-            Job.new(name: "flow-job", trigger: "after-test-job", adaptor: "@openfn/language-http"),
+            Job.new(
+              name: "flow-job",
+              trigger: "after-test-job",
+              adaptor: "@openfn/language-http",
+              credential: "test-credential"
+            ),
           failure_flow_job =
             Job.new(
               name: "flow-job-failure",
@@ -61,7 +66,7 @@ defmodule Engine.RunBroadcaster.UnitTest do
     start_supervised!(
       {Engine.Adaptor.Service,
        [
-         adaptors_path: adaptors_path = "./priv/openfn/lib",
+         adaptors_path: "./priv/openfn/lib",
          repo: TestRepo,
          name: :test_adaptor_service
        ]}
@@ -190,7 +195,7 @@ defmodule Engine.RunBroadcaster.UnitTest do
       %Run{
         trigger: ^failure_flow_trigger,
         job: ^failure_flow_job,
-        initial_state: %{"foo" => "bar"}
+        initial_state: %{"foo" => "bar", "configuration" => nil}
       }
     }
 

test/fixtures/project_config.yaml

@@ -11,6 +11,7 @@ jobs:
     expression: none
     adaptor: "@openfn/language-common"
     trigger: trigger-3
+    credential: credential-1
   job-3:
     expression: >
       alterState((state) => {
@@ -19,6 +20,7 @@ jobs:
       })
     adaptor: "@openfn/language-common"
     trigger: trigger-4
+    credential: credential-1
 
 triggers:
   trigger-2:
@@ -34,3 +36,6 @@ credentials:
   credential-1:
     username: "[email protected]"
     password: "shhh"
+  credential-2:
+    username: "[email protected]"
+    password: "password"