Added MarkThreadAsUnread task

packages/nylas-api/routes/threads.js

@@ -184,6 +184,13 @@ module.exports = (server) => {
             threadId: request.params.id,
           },
         })
+      } else if (payload.unread === true) {
+        createSyncbackRequest(request, reply, {
+          type: "MarkThreadAsUnread",
+          props: {
+            threadId: request.params.id,
+          },
+        })
       }
     },
   });

packages/nylas-sync/syncback-task-factory.js

@@ -10,6 +10,8 @@ class SyncbackTaskFactory {
         Task = require('./syncback_tasks/move-to-folder.imap'); break;
       case "MarkThreadAsRead":
         Task = require('./syncback_tasks/mark-thread-as-read.imap'); break;
+      case "MarkThreadAsUnread":
+        Task = require('./syncback_tasks/mark-thread-as-unread.imap'); break;
       default:
         throw new Error(`Invalid Task Type: ${syncbackRequest.type}`)
     }

packages/nylas-sync/syncback_tasks/mark-thread-as-unread.imap.js

@@ -0,0 +1,19 @@
+const SyncbackTask = require('./syncback-task')
+const TaskHelpers = require('./task-helpers')
+
+class MarkThreadAsUnread extends SyncbackTask {
+  description() {
+    return `MarkThreadAsUnread`;
+  }
+
+  run(db, imap) {
+    const threadId = this.syncbackRequestObject().props.threadId
+
+    const eachMsg = ({message, box}) => {
+      return box.delFlags(message.categoryUID, 'SEEN')
+    }
+
+    return TaskHelpers.forEachMessageInThread({threadId, db, imap, callback: eachMsg})
+  }
+}
+module.exports = MarkThreadAsUnread;