Improve volunteering for a task

Author: rowanwork

.vscode/launch.json

@@ -4,6 +4,12 @@
   // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
   "version": "0.2.0",
   "configurations": [
+    {
+      "type": "node",
+      "request": "attach",
+      "name": "Attach by Process ID",
+      "processId": "${command:PickProcess}"
+    },
     {
       "type": "node",
       "request": "launch",

client/src/components/Gigs/API/RocketChat/RocketChat.jsx

@@ -21,6 +21,24 @@ export const publishMessage = function(payload) {
   });
 };
 
+export const publishMessageWithReplyOptions = async function(payload) {
+  const authSet = UserProfile.getAuthSet();
+  const response = await fetch(`/admin-ui/api/rc/publish-replyable-message`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      "x-auth-token": authSet.token,
+      "x-user-id": authSet.userId
+    },
+    body: JSON.stringify(payload)
+  });
+
+  if (response.status !== 200) {
+    const json = await response.json();
+    NotificationManager.error(json.error.errmsg);
+  }
+};
+
 export const setRoomToReadOnly = function(gigRoomId) {
   const authSet = UserProfile.getAuthSet();
   const setReadOnlyPayload = {

client/src/components/Gigs/API/Tasks/index.js

@@ -1,5 +1,5 @@
 import { NotificationManager } from "react-notifications";
-import { publishMessage } from "components/Gigs/API/RocketChat/RocketChat";
+import { publishMessageWithReplyOptions } from "components/Gigs/API/RocketChat/RocketChat";
 
 const fetchOptions = method => {
   return {
@@ -50,26 +50,27 @@ export const update = function(taskId, payload, statusCallback) {
   });
 };
 
-export const add = function(gigRoomId, gigId, state, statusCallback) {
+export const add = async function(gigRoomId, gigId, state, statusCallback) {
   if (statusCallback) statusCallback("loading");
-  fetch("/admin-ui/api/tasks/addTask", {
+  const data = await fetch("/admin-ui/api/tasks/addTask", {
     method: "POST",
     headers: { "Content-Type": "application/json" },
     body: JSON.stringify(buildTaskPayload(gigId, state))
-  }).then(data => {
-    if (data.status !== 200) {
-      data.json().then(json => {
-        NotificationManager.error(json.error.errmsg);
-      });
-      if (statusCallback) statusCallback("working");
-    } else {
-      data.json().then(json => {
-        const task = json.task;
-        publishMessage(buildTaskPublishMessage(gigRoomId, task));
-      });
-      if (statusCallback) statusCallback("success");
-    }
   });
+
+  const json = await data.json();
+  if (data.status !== 200) {
+    NotificationManager.error(json.error.errmsg);
+    //TODO: should this be error?
+    if (statusCallback) statusCallback("working");
+    return;
+  }
+
+  const task = json.task;
+  publishMessageWithReplyOptions(
+    buildTaskPublishMessageWithReply(gigRoomId, task)
+  );
+  if (statusCallback) statusCallback("success");
 };
 
 export const remove = function(gigRoomId, taskId, taskName, statusCallback) {
@@ -91,13 +92,21 @@ export const remove = function(gigRoomId, taskId, taskName, statusCallback) {
   });
 };
 
-function buildTaskPublishMessage(roomId, task) {
-  const message = `New Task!
-**${task.task_name}** (${task._id})
-Description: ${task.task_description}
-Reply "volunteer" to volunteer for this task.`;
+function buildTaskPublishMessageWithReply(roomId, task) {
+  const message = `A new task **${task.task_name}** in category *${
+    task.task_category
+  }* has been created.
+  _${task.task_description}_`;
+
+  const optionsTitle = "Please click volunteer if you can help";
+  const replyOptions = [
+    {
+      label: "Volunteer",
+      reply: `I would like to volunteer for **${task.task_name}** (${task._id})`
+    }
+  ];
 
-  return { message, roomId };
+  return { message, roomId, optionsTitle, replyOptions };
 }
 
 function buildTaskPayload(gigId, state) {

server/controllers/rc.controller.js

@@ -115,6 +115,43 @@ exports.publish_message = async function(req, res) {
   });
 };
 
+exports.publishMessageWithReplyOptions = asyncMiddleware(async function(
+  req,
+  res
+) {
+  const authSetBot = getCachedApiAuth(req);
+  const data = await api.post(
+    "chat.postMessage",
+    authSetBot.authToken,
+    authSetBot.userId,
+    {
+      roomId: req.body.roomId,
+      text: req.body.message,
+      attachments: [
+        {
+          title: req.body.optionsTitle,
+          collapsed: false,
+          actions: req.body.replyOptions.map(x => ({
+            type: "button",
+            text: x.label,
+            msg: x.reply,
+            msg_in_chat_window: true
+          }))
+        }
+      ]
+    }
+  );
+
+  if (!data.success) {
+    return res.status(500).send({
+      error: "Unable to publish message to " + req.body.roomId
+    });
+  }
+  res.status(200).send({
+    message: data.message
+  });
+});
+
 exports.publishBroadcastMessage = async function(authSetBot, roomId, text) {
   const result = await api.post(
     "chat.postMessage",

server/routes/rc.route.js

@@ -6,6 +6,10 @@ const rc_controller = require("../controllers/rc.controller");
 router.post("/set_read_only_channel", rc_controller.set_read_only_channel);
 router.post("/set_group_type", rc_controller.set_group_type);
 router.post("/publish_message", rc_controller.publish_message);
+router.post(
+  "/publish-replyable-message",
+  rc_controller.publishMessageWithReplyOptions
+);
 router.post("/kick_user", rc_controller.kick_user);
 router.post("/remove_owner_from_group", rc_controller.remove_owner_from_group);