Add dishwasher manager bot

config/config.exs

@@ -6,4 +6,7 @@ config :logger,
   handle_otp_reports: true,
   handle_sasl_reports: true
 
+config :cronex,
+       timezone: "Europe/Copenhagen"
+
 import_config "#{Mix.env}.secret.exs"

config/prod.secret.exs.example

@@ -6,7 +6,10 @@ use Mix.Config
 config :slack,
   token: "xoxb",
   owner: "cdetroye",
+  github: "https://github.com/m1dnight/slackbot",
   benvolios_owner: "cdetroye",
   benvolios_channel: "benvolios",
+  diswasher_duties_owner: "humberto",
+  diswasher_duties_channel: "dishwasher_duties",
   rss_channel: "bots"
 

data/dishwasher_manager/schedule.dat

@@ -0,0 +1,85 @@
+[{cderoove,{<<"Coen De Roover">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 11,month => 9,year => 2017}}},
+ {mathsaey,{<<"Mathijs Saey">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 18,month => 9,year => 2017}}},
+ {thierry,{<<"Thierry Renaux">>,
+           #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+             day => 25,month => 9,year => 2017}}},
+ {kevin,{<<"Kevin Pinte">>,
+         #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+           day => 2,month => 10,year => 2017}}},
+ {fmyter,{<<"Florian Myter">>,
+          #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+            day => 9,month => 10,year => 2017}}},
+ {tmoldere,{<<"Tim Molderez">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 16,month => 10,year => 2017}}},
+ {joeri,{<<"Joeri De Koster">>,
+         #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+           day => 23,month => 10,year => 2017}}},
+ {simon,{<<"Simon Van de Water">>,
+         #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+           day => 30,month => 10,year => 2017}}},
+ {nathalie,{<<"Nathalie Oostvogels">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 6,month => 11,year => 2017}}},
+ {jswalens,{<<"Janwillem Swalens">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 13,month => 11,year => 2017}}},
+ {eljenso,{<<"Jens Nicolay">>,
+           #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+             day => 20,month => 11,year => 2017}}},
+ {kennedy,{<<"Kennedy Kambona">>,
+           #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+             day => 27,month => 11,year => 2017}}},
+ {qstieven,{<<"Quentin Stievenart">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 4,month => 12,year => 2017}}},
+ {dirk,{<<"Dirk van Deun">>,
+        #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+          day => 11,month => 12,year => 2017}}},
+ {jbsartor,{<<"Jennifer Sartor">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 18,month => 12,year => 2017}}},
+ {jdeblese,{<<"Jonas De Bleser">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 8,month => 1,year => 2018}}},
+ {nvgeele,{<<"Nils Van Geele">>,
+           #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+             day => 15,month => 1,year => 2018}}},
+ {ascullpu,{<<"Angel Luis Scull Pupo">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 22,month => 1,year => 2018}}},
+ {carmen,{<<"Carmen Torres Lopez">>,
+          #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+            day => 29,month => 1,year => 2018}}},
+ {jezaman,{<<"Jesse Zaman">>,
+           #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+             day => 5,month => 2,year => 2018}}},
+ {mvdcamme,{<<"Maarten Vandercammen">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 12,month => 2,year => 2018}}},
+ {lachrist,{<<"Laurent Christophe">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 19,month => 2,year => 2018}}},
+ {marmat,{<<"Matteo Marra">>,
+          #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+            day => 26,month => 2,year => 2018}}},
+ {noah,{<<"Noah Van Es">>,
+        #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+          day => 5,month => 3,year => 2018}}},
+ {svdvonde,{<<"Sam Van den Vonder">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 12,month => 3,year => 2018}}},
+ {humberto,{<<"Humberto Rodriguez">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 19,month => 3,year => 2018}}},
+ {cdetroye,{<<"Christophe De Troyer">>,
+            #{'__struct__' => 'Elixir.Date',calendar => 'Elixir.Calendar.ISO',
+              day => 26,month => 3,year => 2018}}},
+ {elisagboix,{<<"Elisa Gonzalez">>,
+              #{'__struct__' => 'Elixir.Date',
+                calendar => 'Elixir.Calendar.ISO',day => 2,month => 4,
+                year => 2018}}}].

data/dishwasher_manager/users.dat

@@ -0,0 +1,33 @@
+[{'U03K40ETE',<<"Humberto Rodriguez">>},
+ {'U08DX089E',<<"Christophe De Troyer">>},
+ {'U02D6HWS1',<<"Elisa Gonzalez Boix">>},
+ {'U0LV04PPT',<<"Ward Muylaert">>},
+ {'U02C3FMQ2',<<"Wolfgang De Meuter">>},
+ {'U94HUEHLJ',<<"Thomas Dupriez">>},
+ {'U8PGUSQ3F',<<"Dario Di Nucci">>},
+ {'U02QPK57T',<<"Coen De Roover">>},
+ {'U02J6647B',<<"Mathijs Saey">>},
+ {'U02J62LRF',<<"Thierry Renaux">>},
+ {'U02BYG1E9',<<"Kevin Pinte">>},
+ {'U02MXLBFX',<<"Florian Myter">>},
+ {'U03QXV0QJ',<<"Tim Molderez">>},
+ {'U03SKNNFB',<<"Joeri De Koster">>},
+ {'U21S584KW',<<"Sam Van den Vonder">>},
+ {'U02C2C9BD',<<"Nathalie Oostvogels">>},
+ {'U02C3M0CL',<<"Janwillem Swalens">>},
+ {'U02C36Q3E',<<"Jens Nicolay">>},
+ {'U02J62SFM',<<"Kennedy Kambona">>},
+ {'U02J7ERTW',<<"Quentin Stievenart">>},
+ {'U02C53L03',<<"Dirk van Deun">>},
+ {'U21RHEHR7',<<"Jonas De Bleser">>},
+ {'U21SQKEFL',<<"Nils Van Geele">>},
+ {'U0QSNFR96',<<"Angel Luis Scull Pupo">>},
+ {'U15B9LJHL',<<"Carmen Torres">>},
+ {'U02C36WBA',<<"Jesse Zaman">>},
+ {'U088RMBMY',<<"Maarten Vandercammen">>},
+ {'U03U17WCQ',<<"Laurent Christophe">>},
+ {'U4U6994KG',<<"Matteo Marra">>},
+ {'U6X6VGMF1',<<"Noah Van Es">>},
+ {'U21S584KW',<<"Sam Van den Vonder">>},
+ {'U6SH5G347',<<"Isaac Oteyo">>},
+ {'U758VEE2E',<<"Yunior Pacheco Correa">>}].

lib/behaviours/plugin.ex

@@ -24,18 +24,29 @@ defmodule Plugin do
         GenServer.start_link(__MODULE__, [args], [{:name, __MODULE__}])
       end
 
+      # "Handling indidual messages"
+      def handle_info(message = %{channel: nil, type: "message", text: text, user: from}, state) do
+        reply = on_message(text, :dishwasher_app, from)
+
+        case reply do
+          {:ok, reply}     -> SlackManager.send_private_message("#{reply}", from)
+          {:error, reason} -> IO.puts "Error in plugin #{reason}"
+          {:noreply}       -> :noop
+        end
+
+        {:noreply, state}
+      end
+
       def handle_info(message = %{type: "message", text: text, user: from}, state) do
         reply = on_message(text, message.channel, from)
 
         case reply do
           {:ok, reply}     ->
             SlackManager.send_message("#{reply}", message.channel)
-          {:error, reason} ->
-            IO.puts "Error in plugin #{reason}"
-          {:noreply}       ->
-            :noop
+          {:error, reason} -> IO.puts "Error in plugin #{reason}"
+          {:noreply}       -> :noop
         end
-        
+
         {:noreply, state}
       end
 

lib/bot/benvolios.ex

@@ -56,7 +56,7 @@ defmodule Bot.Benvolios do
   end
 
   # Prints out help message.
-  def on_message(<<"help"::utf8>>, _channel, _sender) do
+  def on_message(<<"help"::utf8>>, @channel, _sender) do
     res = """
     ```
     order        : Order something.

lib/bot/diswasher_manager.ex

@@ -0,0 +1,194 @@
+defmodule Bot.DiswasherManager do
+  require Logger
+  use Plugin
+
+  @boss    Application.fetch_env!(:slack, :diswasher_duties_owner)
+  @channel Application.fetch_env!(:slack, :diswasher_duties_channel)
+  @private_channel  :dishwasher_app
+  @channels [@channel, @private_channel ]
+
+  # The message "swap_with @x" is used to swap weekly duties with the user  `x`.
+  def on_message(<<"swap_with"::utf8, user::bitstring>>, _channel, sender)  do
+    user = String.trim(user)
+    case Brain.DishwasherManager.swap_duties(sender, user) do
+       :ok -> SlackManager.send_private_message("You swapped your dishwasher duties with @#{sender}.", user)
+              {:ok, "Duties swapped!"}
+       {:error, msg} -> {:ok, msg}
+    end
+  end
+
+  # The message "manager?" return the name uf the current dishwasher manager
+  def on_message(<<"manager?"::utf8>>, _channel, _sender) do
+    {:ok, manager, fullname} = Brain.DishwasherManager.manager?()
+
+    case manager do
+       :no_specified -> {:ok, "The schedule has not been created. Use the command 'help' for more information."}
+       _name          -> {:ok, "The current dishwasher manager is `#{fullname}`"}
+    end
+  end
+
+  def on_message(<<"when?"::utf8>>, _channel, sender) do
+    {:ok, fullname, startDate} = Brain.DishwasherManager.when?(sender)
+
+    case fullname do
+      :invalid_user -> {:ok, "The schedule has not been created. Use the command 'help' for more information."}
+
+                  _ -> from = Date.to_string(startDate)
+                       to = startDate |> Date.add(4) |> Date.to_string()
+                       {:ok, "Your next dishwasher duties will be from `#{from}` to `#{to}`"}
+    end
+  end
+
+  # Prints out all the outstanding orders.
+  # Restricted to admins only.
+  def on_message(<<"schedule"::utf8, _::bitstring>>, channel, _sender) when channel in @channels do
+    {:ok, schedule} = Brain.DishwasherManager.schedule()
+    build_schedule_list(schedule)
+  end
+
+  # Prints out all the outstanding orders.
+  # Restricted to admins only.
+  def on_message(<<"create_schedule"::utf8, startDate::bitstring>>, channel, @boss) when channel in @channels  do
+    {:ok, schedule} = Brain.DishwasherManager.create_schedule(startDate)
+    build_schedule_list(schedule)
+  end
+
+  def on_message(<<"users"::utf8, _::bitstring>>, channel, @boss) when channel in @channels  do
+    {:ok, users} = Brain.DishwasherManager.users()
+    build_user_list(users)
+  end
+
+  def on_message(<<"add_user"::utf8, userDetails::bitstring>>, channel, @boss) when channel in @channels do
+     case String.split(userDetails) do
+      []          -> {:noreply}
+      [user| fullname] -> :ok  = Brain.DishwasherManager.add_user(user, fullname)
+                          {:ok, "The user {#{user}, #{fullname}} has been saved."}
+    end
+  end
+
+  def on_message(<<"remove_user"::utf8, user::bitstring>>, channel, @boss) when channel in @channels do
+    :ok  = Brain.DishwasherManager.remove_user(user)
+    {:ok, "The user #{user} has been removed."}
+  end
+
+  def on_message(<<"remove_users"::utf8>>, channel, @boss) when channel in @channels do
+    :ok  = Brain.DishwasherManager.remove_users()
+    {:ok, "The user list was removed."}
+  end
+
+  def on_message(<<"remove_schedule"::utf8>>, channel, @boss) when channel in @channels do
+    :ok  = Brain.DishwasherManager.remove_schedule()
+    {:ok, "The schedule was removed."}
+  end
+
+  def on_message(<<"set_manager"::utf8>>, channel, @boss) when channel in @channels do
+    {:ok, manager}  = Brain.DishwasherManager.set_manager_of_the_week()
+    case manager do
+      :no_specified -> {:ok, "The schedule has not been created. Use the command 'help' for more information."}
+      name          -> {:ok, "The current dishwasher manager is `#{name}`"}
+    end
+  end
+
+  def on_message(<<"wave"::utf8>>, channel, _sender) when channel in @channels do
+    wave_dishwasher_manager()
+  end
+
+  def on_message(<<":wave:"::utf8>>, channel, _sender) when channel in @channels do
+    wave_dishwasher_manager()
+  end
+
+  # Prints out help message.
+  def on_message(<<"help"::utf8>>, channel, @boss) when channel in @channels do
+    res = boss_help_menu()
+    {:ok, res}
+  end
+
+  # Prints out help message.
+  def on_message(<<"help"::utf8>>, channel, _sender)  when channel in @channels do
+    res = user_help_menu()
+    {:ok, res}
+  end
+
+  def on_message(_text, _channel, _sender) do
+    {:noreply}
+  end
+
+
+  defp build_schedule_list(schedule) when schedule == %{}  , do: {:ok, "There is no schedule ready. Use the command 'help' for more information."}
+
+  defp build_schedule_list(schedule) do
+    resp = schedule
+           |> Enum.map(fn {_k,{fullname, from}} ->
+                "- #{fullname} -> from: #{from} to: #{Date.add(from, 4)}" end)
+           |> Enum.join("\n")
+
+    {:ok, "```#{resp}```"}
+  end
+
+  defp build_user_list(users)  when users == %{} , do: {:ok, "The list of user is empty. Use the command 'help' for more information."}
+
+  defp build_user_list(users) do
+    resp = users
+           |> Enum.map(fn {_, fullname} -> "- #{fullname}" end)
+           |> Enum.join("\n")
+
+    {:ok, "```#{resp}```"}
+  end
+
+  defp user_help_menu do
+    """
+    ```
+    swap_with           : Swaps weekly duties with another person.
+                          Example: "swap_with @cdtroye".
+    manager?            : Shows the current dishwasher manager.
+                          Example: "manager?"
+    schedule            : Shows the current dishwasher schedule.
+                          Example: "schedule"
+    wave                : Sends a notification to the current dishwasher manager in case he has to do his duties.
+                          Example: "wave"  or  ":wave:"
+    when?               : Shows the dates of your the next dishwasher duties.
+                          Example: "when? "
+    ```
+
+    """
+  end
+
+  defp boss_help_menu do
+    """
+    ```
+    swap_with           : Swaps weekly duties with another person.
+                          Example: "swap_with @cdtroye".
+    manager?            : Shows the current dishwasher manager.
+                          Example: "manager?"
+    schedule            : Shows the current dishwasher schedule.
+                          Example: "schedule"
+    create_schedule     : Creates a dishwasher schedule starting from the date specified.
+                          Example: "create_schedule 2017-09-07"
+    users               : Shows the current list of users.
+                          Example: "users"
+    add_user            : Add a new user. The first argument is the "slack user name",
+                          followed by its fullname.
+                          Example: "add_user @humberto Humberto Rodriguez Avila"
+    remove_user         : Remove an user.
+                          Example: "remove_user @humberto"
+    set_manager         : Set the manager for the current week.
+                          Example: "set_manager"
+    ```
+
+    """
+  end
+
+
+  defp wave_dishwasher_manager do
+    {:ok, manager, fullname} = Brain.DishwasherManager.manager?()
+
+    case manager do
+      :no_specified -> {:ok, "As the schedule has not been created, there is not Dishwasher Manager."}
+      _name          -> SlackManager.send_private_message(":wave: Hey Dishwasher Manager! Please do your dishwasher duties as soon as you can.", manager)
+                       {:ok, "The current dishwasher manager `#{fullname}` was :wave:"}
+    end
+  end
+
+
+
+end

lib/bot/misc.ex

@@ -7,7 +7,7 @@ defmodule Bot.Misc do
     {:ok,"My owner is #{@owner}"}
   end
 
-  def on_message(<<"!bug "::utf8, target::bitstring>>, channel, from) do
+  def on_message(<<"!bug "::utf8, target::bitstring>>, _channel, _from) do
     {:ok, "#{target}, seems like are not happy with the current operations of the bot. If you feel like this hinders you in any way, feel free to write a patch and submit it on GitHub. You can find the repository at #{@github}"}
   end