Allow manually providing reporter pid to log funcs

Author: cjfreeze

lib/chore_runner/dsl.ex

@@ -33,9 +33,14 @@ defmodule ChoreRunner.DSL do
       import ChoreRunner.Reporter,
         only: [
           report_failed: 1,
+          report_failed: 2,
           log: 1,
+          log: 2,
           set_counter: 2,
-          inc_counter: 2
+          set_counter: 3,
+          inc_counter: 2,
+          inc_counter: 3,
+          get_reporter: 0
         ]
 
       import ChoreRunner.Input,

lib/chore_runner/reporter.ex

@@ -40,22 +40,28 @@ defmodule ChoreRunner.Reporter do
   defp report_finished(result),
     do: GenServer.cast(get_reporter_pid(), {:chore_finished, DateTime.utc_now(), result})
 
-  def report_failed(reason),
-    do: GenServer.cast(get_reporter_pid(), {:chore_failed, reason, DateTime.utc_now()})
+  def report_failed(reporter \\ nil, reason),
+    do:
+      GenServer.cast(reporter || get_reporter_pid(), {:chore_failed, reason, DateTime.utc_now()})
 
-  def log(message),
-    do: GenServer.cast(get_reporter_pid(), {:log, message, DateTime.utc_now()})
+  def log(reporter \\ nil, message),
+    do: GenServer.cast(reporter || get_reporter_pid(), {:log, message, DateTime.utc_now()})
 
-  def set_counter(name, value), do: do_update_counter(name, value, :set)
-  def inc_counter(name, amount), do: do_update_counter(name, amount, :inc)
+  def set_counter(reporter \\ nil, name, value),
+    do: do_update_counter(reporter, name, value, :set)
 
-  defp do_update_counter(name, value, operation),
-    do: GenServer.cast(get_reporter_pid(), {:update_counter, name, value, operation})
+  def inc_counter(reporter \\ nil, name, amount),
+    do: do_update_counter(reporter, name, amount, :inc)
+
+  defp do_update_counter(reporter, name, value, operation),
+    do: GenServer.cast(reporter || get_reporter_pid(), {:update_counter, name, value, operation})
 
   def get_chore_state(%Chore{} = chore) do
     GenServer.call(name(chore), :chore_state)
   end
 
+  def get_reporter, do: get_reporter_pid()
+
   def handle_call(:chore_state, _from, %{chore: chore} = state), do: {:reply, chore, state}
 
   def handle_call(

mix.exs

@@ -6,7 +6,7 @@ defmodule ChoreRunner.MixProject do
   def project do
     [
       app: :chore_runner,
-      version: "0.2.1",
+      version: "0.2.2",
       elixir: "~> 1.12",
       start_permanent: Mix.env() == :prod,
       deps: deps(),

test/chore_test.exs

@@ -44,7 +44,7 @@ defmodule ChoreTest do
                  sleep?: false,
                  sleep_length: 0
                },
-               logs: [],
+               logs: [_, _],
                mod: ChoreRunner.TestChore,
                result:
                  {:ok,

test/support/test_chore.ex

@@ -21,6 +21,17 @@ defmodule ChoreRunner.TestChore do
         } = attrs
       ) do
     if sleep?, do: Process.sleep(sleep_length)
+    reporter = get_reporter()
+    log("test")
+    set_counter(:test, 5)
+    inc_counter(:test, 1)
+
+    spawn(fn ->
+      log(reporter, "test from process")
+      set_counter(reporter, :process_test, 10)
+      inc_counter(reporter, :process_test, 2)
+    end)
+
     {:ok, Map.put(attrs, :my_file_value, File.read!(my_file))}
   end
 end