diff --git a/src/backend/core/commands/user-notification.js b/src/backend/core/commands/user-notification.js
new file mode 100644
index 0000000..da9a0d3
--- /dev/null
+++ b/src/backend/core/commands/user-notification.js
@@ -0,0 +1,38 @@
+import { ObjectId } from 'bson';
+import UserNotification from '../../../shared/user-notification';
+import sendEvent from '../../kafka/events/producer';
+import KafkaMessage from '../../kafka/kafka-message';
+import logger from '../logger';
+/**
+ * A user notification is associated with an activity
+ *
+ *
+ * Should have:
+ * - activity: Object notification activity
+ * - user: Actor notification user target
+ *
+ * may have:
+ * - emailId(String) and email(EmailHead)
+ *
+ */
+
+const debug = logger.extend('commands:user-notification');
+
+export async function createUserNotification(notification, sender) {
+  let userNotification;
+  const _id = new ObjectId();
+  try {
+    userNotification = UserNotification.fromObject({ ...notification, _id });
+  } catch (e) {
+    debug('Bad parameter: %O', e.message);
+    throw e;
+  }
+
+  const kafkaMessage = KafkaMessage.fromObject(userNotification.user._id, {
+    event: 'user:notification:create',
+    sender,
+    payload: userNotification,
+  });
+
+  await sendEvent(kafkaMessage);
+}
diff --git a/src/backend/core/events/email/share.js b/src/backend/core/events/email/share.js
index 8e5458c..ec8f8d2 100644
--- a/src/backend/core/events/email/share.js
+++ b/src/backend/core/events/email/share.js
@@ -2,8 +2,12 @@ import sendNotification from '../../../kafka/notifications/producer';
 import { dbCol } from '../../../mongodb';
 import logger from '../../logger';
 import EmailShareActivity from '../../../../shared/email-share-activity';
+import EmailHead from '../../../../shared/email-head';
 import Actor from '../../../../shared/actor';
 import { getEmailIfAllowed } from '../../../api-middleware/email-permission';
+import KafkaMessage from '../../../kafka/kafka-message';
+import UserNotification from '../../../../shared/user-notification';
+import { createUserNotification } from '../../commands/user-notification';
 
 const debug = logger.extend('events:email:share');
 
@@ -32,6 +36,25 @@ export async function emailShareReceiver(kafkaMessage) {
     return false;
   }
 
+  const updated = await updateEmailDocument(collection, email, activity, target);
+  if (!updated) {
+    return;
+  }
+  const notificationMessage = kafkaMessage.setEvent(NOTIFICATION_NAME);
+  await sendNotification(notificationMessage);
+
+  const userNotification = UserNotification.fromObject({
+    activity,
+    user: target,
+    seen: false,
+    email: EmailHead.fromEmail(email.email),
+    emailId: email._id,
+  });
+
+  await createUserNotification(userNotification, kafkaMessage.sender());
+}
+
+const updateEmailDocument = async (collection, email, activity, target) => {
   try {
     const { modifiedCount } = await collection.updateOne(
       { _id: email._id },
@@ -51,10 +74,8 @@ export async function emailShareReceiver(kafkaMessage) {
     debug('MongoDB document update failed: %s %s', e.message, e.stack);
     return false;
   }
-
-  const notificationMessage = kafkaMessage.setEvent(NOTIFICATION_NAME);
-  sendNotification(notificationMessage);
-}
+  return true;
+};
 
 export const EVENTS = {
   'email:share': emailShareReceiver,
diff --git a/src/backend/core/events/index.js b/src/backend/core/events/index.js
index e6ca046..e13d8da 100644
--- a/src/backend/core/events/index.js
+++ b/src/backend/core/events/index.js
@@ -10,6 +10,7 @@ import { EVENTS as EVENTS9 } from './email/label-add';
 import { EVENTS as EVENTS10 } from './chat-message/last-seen-pointer-update';
 import { EVENTS as EVENTS11 } from './task';
 import { EVENTS as EVENTS12 } from './email/user-state';
+import { EVENTS as EVENTS13 } from './user-notification';
 
 export const eventsListeners = {};
 
@@ -25,3 +26,4 @@ Object.keys(EVENTS9).forEach((k) => (eventsListeners[k] = EVENTS9[k]));
 Object.keys(EVENTS10).forEach((k) => (eventsListeners[k] = EVENTS10[k]));
 Object.keys(EVENTS11).forEach((k) => (eventsListeners[k] = EVENTS11[k]));
 Object.keys(EVENTS12).forEach((k) => (eventsListeners[k] = EVENTS12[k]));
+Object.keys(EVENTS13).forEach((k) => (eventsListeners[k] = EVENTS13[k]));
diff --git a/src/backend/core/events/task.js b/src/backend/core/events/task.js
index 6c0b3cf..e9651ca 100644
--- a/src/backend/core/events/task.js
+++ b/src/backend/core/events/task.js
@@ -2,8 +2,10 @@ import { ObjectId } from 'bson';
 import Task from '../../../shared/task';
 import TaskCreatedActivity from '../../../shared/task-created-activity';
 import TaskDoneStatusUpdatedActivity from '../../../shared/task-done-status-updated-activity';
+import UserNotification from '../../../shared/user-notification';
 import { dbCol } from '../../mongodb';
 import { recordActivity } from '../activity';
+import { createUserNotification } from '../commands/user-notification';
 import logger from '../logger';
 
 const debugF = logger.extend('events:task');
@@ -35,6 +37,17 @@ export async function taskCreateReceiver(kafkaMessage) {
   const activity = TaskCreatedActivity.fromKafkaMessage(kafkaMessage);
 
   await recordActivity(activity, task.emailId, true);
+
+  if (activity.actor._id !== activity.target._id) {
+    debug('creating user notification for user %s, task %s', activity.target.email, task.description);
+    const userNotification = UserNotification.fromObject({
+      activity,
+      user: activity.target,
+      seen: false,
+      emailId: task.emailId,
+    });
+    await createUserNotification(userNotification, kafkaMessage.sender());
+  }
 }
 
 export async function taskDoneStatusUpdateReceiver(kafkaMessage) {
diff --git a/src/backend/core/events/user-notification.js b/src/backend/core/events/user-notification.js
new file mode 100644
index 0000000..6acdd37
--- /dev/null
+++ b/src/backend/core/events/user-notification.js
@@ -0,0 +1,35 @@
+import logger from '../logger';
+import UserNotification from '../../../shared/user-notification';
+import { dbCol } from '../../mongodb';
+import { ObjectId } from 'bson';
+import sendNotification from '../../kafka/notifications/producer';
+
+const debug = logger.extend('events:user-notifications');
+
+export async function userNotificationCreateReceiver(kafkaMessage) {
+  let userNotification;
+  try {
+    userNotification = UserNotification.fromObject(kafkaMessage.payload());
+  } catch (e) {
+    debug('Invalid payload %s: %O', e.message, kafkaMessage.payload());
+  }
+
+  try {
+    const collection = await dbCol('userNotifications');
+    const { insertedCount } = await collection.insertOne({ ...userNotification, _id: new ObjectId(userNotification._id) });
+    if (insertedCount !== 1) {
+      throw new Error('No document have been inserted in the datastore.');
+    }
+  } catch (e) {
+    debug('Can not insert new user notification: %s', e.message);
+    return;
+  }
+
+  const notification = kafkaMessage.setEvent('user:notification:created');
+
+  await sendNotification(notification);
+}
+
+export const EVENTS = {
+  'user:notification:create': userNotificationCreateReceiver,
+};
diff --git a/src/components/Modal.svelte b/src/components/Modal.svelte
index f2ec715..757b008 100644
--- a/src/components/Modal.svelte
+++ b/src/components/Modal.svelte
@@ -120,8 +120,12 @@
     }
   };
 
+  const isOpened = () => {
+    return !!Component;
+  }
+
   setContext(key, { open, close });
-  registerModal(open, close);
+  registerModal(open, close, isOpened);
 </script>
 
 <style>
diff --git a/src/components/Nav.svelte b/src/components/Nav.svelte
index 2ccc4d8..70fee7f 100644
--- a/src/components/Nav.svelte
+++ b/src/components/Nav.svelte
@@ -1,6 +1,7 @@
 <script>
 import { user } from '../libs/users';
 import UserInline from '../routes/_components/User/Inline.svelte';
+import NotificationNavButton from '../routes/_components/Notification/NavButton.svelte';
 </script>
 
 <style>
@@ -36,6 +37,7 @@ nav {
             <i class="fas fa-cog fa-lg"></i>
           </span>
         </a>
+        <NotificationNavButton />
         <UserInline user={$user} bgclass="has-background-white-bis is-large" />
       </div>
     </div>
diff --git a/src/libs/modal/modalService.js b/src/libs/modal/modalService.js
index 66ffe0d..982ca76 100644
--- a/src/libs/modal/modalService.js
+++ b/src/libs/modal/modalService.js
@@ -1,9 +1,11 @@
 let openModalFn;
 let closeModalFn;
+let isOpenedFn = () => {};
 
-export function registerModal(open, close) {
+export function registerModal(open, close, isOpened) {
   openModalFn = open;
   closeModalFn = close;
+  isOpenedFn = isOpened;
 }
 
 export function openModal() {
@@ -13,3 +15,7 @@ export function openModal() {
 export function closeModal() {
   return closeModalFn;
 }
+
+export function isOpened() {
+  return isOpenedFn();
+}
diff --git a/src/libs/notificationProvider.js b/src/libs/notificationProvider.js
new file mode 100644
index 0000000..bf20d36
--- /dev/null
+++ b/src/libs/notificationProvider.js
@@ -0,0 +1,62 @@
+import { writable } from 'svelte/store';
+import { get } from 'api';
+import { registerEvent } from './sse';
+import { isAfter, isBefore } from 'date-fns';
+import EmailHead from '../shared/email-head';
+
+export const unreadNotifications = writable([]);
+
+export const start = () => {
+  const unregister = registerEvent('user:notification:created', (payload) => {
+    updateStore([payload]);
+  });
+  loadFromServer();
+};
+
+const loadFromServer = async () => {
+  try {
+    const unreads = await get('/api/notifications');
+    updateStore(unreads);
+  } catch (e) {
+    console.log('Error loading notifications from store:', e.message, e);
+    throw e;
+  }
+};
+
+const updateStore = (notifications) => {
+  const toUpdate = notifications.filter(n => !n.seen);
+  if (!toUpdate.length) {
+    return;
+  }
+  unreadNotifications.update((notifs) => {
+    const newStoreContents = [...notifs];
+
+    toUpdate.forEach(n => {
+      const hydratedNotif = hydrateNotification(n);
+      const index = newStoreContents.findIndex(notification => hydratedNotif._id === notification._id);
+      if (index >= 0) {
+        newStoreContents.splice(index, 1, hydratedNotif);
+      } else {
+        const previousNotifIndex = newStoreContents.findIndex(notification => {
+          console.log(new Date(hydratedNotif.activity.date), new Date(notification.activity.date), isAfter(new Date(hydratedNotif.activity.date), new Date(notification.activity.date)));
+          return isAfter(new Date(hydratedNotif.activity.date), new Date(notification.activity.date));
+        });
+        if (previousNotifIndex < 0) {
+          newStoreContents.push(hydratedNotif);
+        } else {
+          newStoreContents.splice(previousNotifIndex, 0, hydratedNotif);
+        }
+      }
+    });
+
+    return newStoreContents;
+  });
+};
+
+const hydrateNotification = (n) => {
+  const hydratedNotification = { ...n };
+  if (hydratedNotification.email) {
+    hydratedNotification.email = EmailHead.fromObject(n.email);
+  }
+  return hydratedNotification;
+};
diff --git a/src/libs/tasks/tasksProvider.js b/src/libs/tasks/tasksProvider.js
new file mode 100644
index 0000000..2894ac1
--- /dev/null
+++ b/src/libs/tasks/tasksProvider.js
@@ -0,0 +1,136 @@
+import { get } from 'api';
+import { isAfter, isBefore, sub } from 'date-fns';
+import { writable } from 'svelte/store';
+import Task from '../../shared/task';
+import { registerEvent } from '../sse';
+import { user } from '../users';
+
+const LATE_TASKS_INTERVAL = 10 * 60 * 1000;
+
+export const lateTasks = writable([]);
+
+let tasksUpdateInterval;
+let currentUser = null;
+let started = false;
+const registeredEvents = [];
+
+export const start = async () => {
+  if (!started) {
+    const unsubscribe = user.subscribe((userObject) => {
+      currentUser = userObject;
+    });
+    registeredEvents.push(unsubscribe);
+    tasksUpdateInterval = setInterval(refreshLateTasks, LATE_TASKS_INTERVAL);
+    refreshLateTasks();
+    registerAllEvents();
+    started = true;
+  }
+};
+export const stop = async () => {
+  if (started) {
+    clearInterval(tasksUpdateInterval);
+    tasksUpdateInterval = null;
+    started = false;
+  }
+};
+
+const refreshLateTasks = async () => {
+  const today = new Date();
+  const before = sub(today, { months: 3 });
+
+  const lateTasksResponse = await get('/api/tasks', null, {
+    qs: {
+      to: today,
+      from: before,
+      done: false,
+    },
+  });
+  lateTasks.set(lateTasksResponse.tasks.map(t => ({ ...Task.fromObject(t), emailSubject: t.emailSubject })));
+};
+
+export const registerAllEvents = () => {
+  registeredEvents.push(
+    registerEvent('email:shared', async (payload) => {
+      let email;
+      try {
+        const data = await get(`/api/emails/${payload.emailId}`);
+        email = data.email;
+      } catch (e) {
+        console.log('Error: unable to fetch email', payload.emailId, payload);
+        return;
+      }
+      insertEmailTasks(email);
+    })
+  );
+
+  registeredEvents.push(
+    registerEvent('email:task:done-status:updated', async (payload) => {
+      const task = Task.fromObject(payload.task);
+      if (task.done) {
+        removeLateTask(task);
+      } else {
+        maybeAddLateTask(task, payload.emailId);
+      }
+    })
+  );
+};
+
+const maybeAddLateTask = async (task, emailId) => {
+  const now = new Date();
+  let email;
+  if (isBefore(now, task.deadline.date)) {
+    try {
+      const data = await get(`/api/emails/${emailId}`);
+      email = data.email;
+    } catch (e) {
+      console.log('Error: unable to fetch email', emailId);
+      return;
+    }
+    lateTasks.update((existingTasks) => {
+      const newLateTasks = [...existingTasks];
+      insertOneTask(newLateTasks, { ...task, emailSubject: email.email.subject });
+      return newLateTasks;
+    });
+  }
+};
+
+const removeLateTask = (task) => {
+  lateTasks.update((existingTasks) => {
+    return existingTasks.filter(t => !t._id.equals(task._id));
+  });
+};
+
+const insertEmailTasks = (email) => {
+  const tasks = email.tasks
+    .map(t => ({ ...Task.fromObject(t), emailSubject: email.email.subject }))
+    .filter(t => {
+      return t.assignee._id === currentUser._id && isAfter(new Date(), new Date(t.deadline.date));
+    });
+  if (!tasks.length) {
+    return;
+  }
+  lateTasks.update((existingTasks) => {
+    const newTasks = [];
+    tasks.forEach((t) => {
+      const found = existingTasks.some(et => et._id.equals(t._id));
+      if (!found) {
+        newTasks.push(t);
+      }
+    });
+    if (!newTasks.length) {
+      return existingTasks;
+    }
+    const updatedTasks = [...existingTasks];
+    newTasks.forEach(t => insertOneTask(updatedTasks, t));
+    return updatedTasks;
+  });
+};
+
+const insertOneTask = (existing, task) => {
+  const index = existing.findIndex((t) => isBefore(new Date(task.deadline.date), new Date(t.deadline.date)));
+  if (index < 0) {
+    existing.push(task);
+  } else {
+    existing.splice(index, 0, task);
+  }
+};
diff --git a/src/libs/users.js b/src/libs/users.js
index 7e6c2e9..8f70e71 100644
--- a/src/libs/users.js
+++ b/src/libs/users.js
@@ -1,12 +1,12 @@
 import { writable } from 'svelte/store';
+
+import { getDisplayName } from './users-cache';
 export {
   cacheStore as userCache,
   updateCache,
   getDisplayName,
 } from './users-cache';
 
-import { getDisplayName } from './users-cache';
-
 const user = writable({});
 
 export { user };
@@ -21,7 +21,7 @@ export function getUserAvatar(user, size) {
     const url = new URL('/api/avatar', host);
     url.searchParams.append('email', user.email);
     url.searchParams.append('name', getDisplayName(user));
-    url.searchParams.append('size', size);
+    url.searchParams.append('size', avatarSize);
     avatarUrl = url.toString();
   } else {
     avatarUrl = '/foo';
diff --git a/src/routes/_components/ClickOutside.svelte b/src/routes/_components/ClickOutside.svelte
new file mode 100644
index 0000000..f8b299e
--- /dev/null
+++ b/src/routes/_components/ClickOutside.svelte
@@ -0,0 +1,36 @@
+<script>
+  import { createEventDispatcher } from 'svelte';
+import { isOpened } from '../../libs/modal/modalService';
+
+  export let exclude = [];
+
+  let child;
+
+  const dispatch = createEventDispatcher();
+
+  function isExcludedFromBlackList(node) {
+    return isOpened() || exclude.indexOf(node) >= 0;
+  }
+
+  function isExcluded(target) {
+    var parent = target;
+    while (parent) {
+      if (isExcludedFromBlackList(parent) || parent === child) {
+        return true;
+      }
+      parent = parent.parentNode;
+    }
+    return false;
+  }
+
+  function onClickOutside(event) {
+    if (!isExcluded(event.target)) {
+      dispatch('clickoutside');
+    }
+  }
+</script>
+
+<svelte:body on:click={onClickOutside} />
+<div bind:this={child}>
+  <slot></slot>
+</div>
diff --git a/src/routes/_components/EmailView/EmailViewActionButton.svelte b/src/routes/_components/EmailView/EmailViewActionButton.svelte
index 7e70653..f29e011 100644
--- a/src/routes/_components/EmailView/EmailViewActionButton.svelte
+++ b/src/routes/_components/EmailView/EmailViewActionButton.svelte
@@ -4,6 +4,7 @@ export let email;
 import { openModal, closeModal } from '../../../libs/modal/modalService';
 import LabelSelect from '../../_components/Labels/LabelSelect.svelte';
 import TaskCreateForm  from '../Task/CreateForm.svelte';
+import ClickOutside from '../ClickOutside.svelte';
 import { put } from 'api';
 
 let menuOpened = false;
@@ -38,22 +39,27 @@ const openTaskDialog = () => {
   });
 }
 
+const closeMenu = () => {
+  menuOpened = false;
+}
 </script>
 
-<div class="dropdown is-right" class:is-active={menuOpened}>
-  <div class="dropdown-trigger">
-    <button class="button is-small" aria-haspopup="true" aria-controls="dropdown-menu" on:click='{() => menuOpened = !menuOpened}'>
-      <span class="icon is-small">
-        <i class="fas fa-ellipsis-v" aria-hidden="true"></i>
-      </span>
-    </button>
-  </div>
-  <div class="dropdown-menu" id="dropdown-menu" role="menu">
-    <div class="dropdown-content">
-      <!-- svelte-ignore a11y-missing-attribute -->
-      <a class="dropdown-item" on:click="{openLabelDialog}">Set/unset labels</a>
-      <!-- svelte-ignore a11y-missing-attribute -->
-      <a class="dropdown-item" on:click="{openTaskDialog}">Add task</a>
+<ClickOutside on:clickoutside={closeMenu}>
+  <div class="dropdown is-right" class:is-active={menuOpened}>
+    <div class="dropdown-trigger">
+      <button class="button is-small" aria-haspopup="true" aria-controls="dropdown-menu" on:click='{() => menuOpened = !menuOpened}'>
+        <span class="icon is-small">
+          <i class="fas fa-ellipsis-v" aria-hidden="true"></i>
+        </span>
+      </button>
+    </div>
+    <div class="dropdown-menu" id="dropdown-menu" role="menu">
+      <div class="dropdown-content">
+        <!-- svelte-ignore a11y-missing-attribute -->
+        <a class="dropdown-item" on:click="{openLabelDialog}">Set/unset labels</a>
+        <!-- svelte-ignore a11y-missing-attribute -->
+        <a class="dropdown-item" on:click="{openTaskDialog}">Add task</a>
+      </div>
     </div>
   </div>
-</div>
+</ClickOutside>
diff --git a/src/routes/_components/EmailView/EmailViewShare.svelte b/src/routes/_components/EmailView/EmailViewShare.svelte
index 1920a53..48ccedf 100644
--- a/src/routes/_components/EmailView/EmailViewShare.svelte
+++ b/src/routes/_components/EmailView/EmailViewShare.svelte
@@ -1,5 +1,4 @@
 <script>
-
 import EmailViewShareForm from "./EmailViewShareForm.svelte";
 
 export let email;
@@ -25,7 +24,7 @@ const toggleVisible = () => isVisible = !isVisible;
   </div>
   <div class="dropdown-menu" role="menu">
     {#if isVisible}
-      <EmailViewShareForm email="{email}" />
+    <EmailViewShareForm email="{email}" />
     {/if}
   </div>
 </div>
diff --git a/src/routes/_components/LeftMenu.svelte b/src/routes/_components/LeftMenu.svelte
index a7246b2..769b6e7 100644
--- a/src/routes/_components/LeftMenu.svelte
+++ b/src/routes/_components/LeftMenu.svelte
@@ -12,12 +12,15 @@ const { page } = stores();
 let selected = {};
 
 $: {
+  console.log($page);
 	selected = {};
 	if ($page.params.folder) {
 		selected.folder = $page.params.folder;
 	} else if ($page.params.labelName) {
 		selected.labelName = $page.params.labelName;
-	}
+	} else if ($page.path === '/tasks') {
+    selected.tasks = true;
+  }
 };
 $: unreadAll = $emails.filter(e => !e.userState[$user._id] || !e.userState[$user._id].seen).length;
 $: unreadShared = $sharedEmails.filter(e => !e.userState[$user._id] || !e.userState[$user._id].seen).length;
@@ -74,7 +77,7 @@ onMount(() => {
       Tasks
     </p>
     <ul class="menu-list">
-      <li><a href="/inbox/tasks">My tasks</a></li>
+      <li><a href="/tasks" class:is-active={selected.tasks}>My tasks</a></li>
     </ul>
   </aside>
 </div>
diff --git a/src/routes/_components/Notification/Activity/Activity.svelte b/src/routes/_components/Notification/Activity/Activity.svelte
new file mode 100644
index 0000000..1cd3901
--- /dev/null
+++ b/src/routes/_components/Notification/Activity/Activity.svelte
@@ -0,0 +1,14 @@
+<script>
+export let userNotification;
+
+import EmailTaskCreated from './EmailTaskCreated.svelte';
+import EmailShared from './EmailShared.svelte';
+
+const compMap = {
+  'email:task:created': EmailTaskCreated,
+  'email:share': EmailShared,
+};
+
+</script>
+
+<svelte:component this="{compMap[userNotification.activity.name]}" {userNotification} />
diff --git a/src/routes/_components/Notification/Activity/ActivityTemplate.svelte b/src/routes/_components/Notification/Activity/ActivityTemplate.svelte
new file mode 100644
index 0000000..fe1ce87
--- /dev/null
+++ b/src/routes/_components/Notification/Activity/ActivityTemplate.svelte
@@ -0,0 +1,40 @@
+<script>
+export let userNotification;
+
+import { parseISO, isToday, format } from "date-fns";
+
+$: dateObj = parseISO(userNotification.activity.date);
+$: hoursOnly = isToday(dateObj);
+$: displayAlt = format(dateObj, 'eee MMM d, Y HH:mm');
+$: displayDate = hoursOnly ? format(dateObj, 'HH:mm') : displayAlt;
+</script>
+
+<div class="block">
+  <div class="image">
+    <slot name="icon">
+      <span class="icon is-medium has-text-info">
+        <i class="fas fa-lg fa-info-circle"></i>
+      </span>
+    </slot>
+    <span class="notificationTitle">
+      <slot name="title"></slot>
+    </span>
+  </div>
+  <div class="content">
+    <div>
+      <slot />
+    </div>
+    <div>
+      <small>{displayDate}</small>
+    </div>
+  </div>
+</div>
+
+<style>
+.block {
+  display: flex;
+  flex-direction: column;
+}
+
+
+</style>
diff --git a/src/routes/_components/Notification/Activity/EmailShared.svelte b/src/routes/_components/Notification/Activity/EmailShared.svelte
new file mode 100644
index 0000000..eef01aa
--- /dev/null
+++ b/src/routes/_components/Notification/Activity/EmailShared.svelte
@@ -0,0 +1,18 @@
+<script>
+  export let userNotification;
+
+  import ActivityTemplate from './ActivityTemplate.svelte';
+  import UserInline from '../../User/Inline.svelte';
+  </script>
+
+  <ActivityTemplate {userNotification}>
+    <span>
+      <UserInline user={userNotification.activity.actor} /> shared the email <strong>{userNotification.email.subject}</strong> with you.
+
+    </span>
+    <span slot="icon" class="icon is-medium has-text-link">
+      <i class="fas fa-lg fa-lock"></i>
+    </span>
+    <span slot="title">New shared email <strong>{userNotification.email.subject}</strong></span>
+  </ActivityTemplate>
+
diff --git a/src/routes/_components/Notification/Activity/EmailTaskCreated.svelte b/src/routes/_components/Notification/Activity/EmailTaskCreated.svelte
new file mode 100644
index 0000000..3f47791
--- /dev/null
+++ b/src/routes/_components/Notification/Activity/EmailTaskCreated.svelte
@@ -0,0 +1,18 @@
+<script>
+export let userNotification;
+
+import ActivityTemplate from './ActivityTemplate.svelte';
+import UserInline from '../../User/Inline.svelte';
+</script>
+
+<ActivityTemplate {userNotification}>
+  <span>
+    <UserInline user={userNotification.activity.task.creator} /> created a task on email <em>{userNotification.activity.task.email.subject}</em> and assigned it to you.
+
+  </span>
+  <span slot="icon" class="icon is-medium has-text-warning">
+    <i class="fas fa-lg fa-tasks"></i>
+  </span>
+  <span slot="title">New task <strong>{userNotification.activity.task.description}</strong></span>
+</ActivityTemplate>
+
diff --git a/src/routes/_components/Notification/NavButton.svelte b/src/routes/_components/Notification/NavButton.svelte
new file mode 100644
index 0000000..99ad66e
--- /dev/null
+++ b/src/routes/_components/Notification/NavButton.svelte
@@ -0,0 +1,60 @@
+<script>
+import { onMount } from 'svelte';
+
+import { start, unreadNotifications } from '../../../libs/notificationProvider';
+import Badge from '../Badge.svelte';
+import Activity from './Activity/Activity.svelte';
+import ClickOutside from '../ClickOutside.svelte';
+
+let isMenuOpened = false;
+const closeMenu = () => isMenuOpened = false;
+onMount(() => {
+  start();
+});
+</script>
+<ClickOutside on:clickoutside={closeMenu}>
+
+  <div class="dropdown is-right" class:is-active={isMenuOpened}>
+    <div class="dropdown-trigger">
+      <button class="button" title="Notifications" on:click={() => isMenuOpened = !isMenuOpened}>
+        <span class="icon">
+          <i class="far fa-flag fa-lg"></i>
+          <span class="badge">
+            <Badge count={$unreadNotifications.length} classname="has-background-success" />
+          </span>
+        </span>
+      </button>
+    </div>
+    <div class="dropdown-menu" role="menu">
+      <div class="dropdown-content p-3">
+        {#each $unreadNotifications as userNotification}
+        <Activity {userNotification} />
+        {:else}
+        <div>
+          No unread notification
+        </div>
+        {/each}
+
+      </div>
+    </div>
+  </div>
+</ClickOutside>
+
+  <style>
+.icon {
+  position: relative;
+}
+
+.badge {
+  position: absolute;
+  bottom: -14px;
+  right: -14px;
+}
+
+/* contents */
+
+.dropdown-menu {
+  min-width: 40rem;
+}
+
+</style>
diff --git a/src/routes/_components/Task/CreateForm.svelte b/src/routes/_components/Task/CreateForm.svelte
index 050c10e..1885816 100644
--- a/src/routes/_components/Task/CreateForm.svelte
+++ b/src/routes/_components/Task/CreateForm.svelte
@@ -16,6 +16,7 @@ export let description = '';
 
 let selectedValue = { ...selectedUser, dn: getDisplayName(selectedUser) } ;
 
+
 // ------------------ SELECT SPECIFIC VARIABLES
 const optionIdentifier = '_id';
 
@@ -37,7 +38,9 @@ const loadOptions = async (q) => {
 // ---------------------------------------------
 
 let deadlineDateString;
+let isRecording = false;
 
+$: assigneeIsInMail = email.users.concat(email.usersShared).some((id) => id === selectedValue._id);
 $: deadlineDate = add(new Date(), {
     weeks: deadlineScale === 'week' && deadlineCount || 0,
     days: deadlineScale === 'day' && deadlineCount || 0,
@@ -48,10 +51,29 @@ $: deadlineDateString = format(deadlineDate, 'PPPP \'at\' HH\'h\'');
 $: canBeRecorded = selectedValue && selectedValue._id && description && description.length;
 
 const create = async () => {
-  if (!canBeRecorded) {
+  if (!canBeRecorded || isRecording) {
     return;
   }
 
+  isRecording = true;
+
+  if (!assigneeIsInMail) {
+    try {
+      const response = await post(`/api/emails/${email._id}/share`, {
+        userIds: [selectedValue._id],
+      });
+      if (!response || response.error) {
+        throw new Error(`Bad server response: ${JSON.stringify(response)}`);
+      }
+    } catch(e) {
+      console.log('Unable to share email: ', e);
+      isRecording = false;
+      return;
+    }
+
+    await new Promise(resolve => setTimeout(resolve, 2000));
+  }
+
   await createTask({
     assignee: selectedValue,
     deadline: {
@@ -61,13 +83,14 @@ const create = async () => {
     },
     description,
   });
-
+  isRecording = false;
   return onCreate();
 }
 
 const createTask = async (task) => {
   let id;
   try {
+
     const response = await post(`/api/tasks/${email._id}`, task);
     id = response._id;
   } catch(e) {
@@ -83,19 +106,6 @@ const createTask = async (task) => {
     <button class="delete" aria-label="delete" on:click={onCancel}></button>
   </div>
   <div class="message-body">
-    <div class="field is-horizontal">
-      <div class="field-label is-normal">
-        <!-- svelte-ignore a11y-label-has-associated-control -->
-        <label class="label">
-          Assignee
-        </label>
-      </div>
-      <div class="field-body">
-        <div class="control is-expanded">
-          <Select {loadOptions} {optionIdentifier} {getOptionLabel} {getSelectionLabel} {noOptionsMessage} bind:selectedValue placeholder="Choose user..." />
-        </div>
-      </div>
-    </div>
     <div class="field is-horizontal has-addons is-narrow">
       <div class="field-label is-normal">
         <!-- svelte-ignore a11y-label-has-associated-control -->
@@ -127,6 +137,24 @@ const createTask = async (task) => {
       </div>
     </div>
     <p class="help pb-2">Deadline set to {deadlineDateString}</p>
+
+    <div class="field is-horizontal">
+      <div class="field-label is-normal">
+        <!-- svelte-ignore a11y-label-has-associated-control -->
+        <label class="label">
+          Assignee
+        </label>
+      </div>
+      <div class="field-body">
+        <div class="control is-expanded">
+          <Select {loadOptions} {optionIdentifier} {getOptionLabel} {getSelectionLabel} {noOptionsMessage} bind:selectedValue placeholder="Choose user..." />
+        </div>
+      </div>
+    </div>
+    {#if !assigneeIsInMail}
+      <p class="help">Email <em>{email.email.subject}</em> will be shared with {selectedValue.dn} first.</p>
+    {/if}
+
     <div class="field">
       <!-- svelte-ignore a11y-label-has-associated-control -->
       <label class="label">Task</label>
@@ -136,10 +164,10 @@ const createTask = async (task) => {
     </div>
     <div class="field is-grouped">
       <div class="control">
-        <button class="button is-link" disabled={!canBeRecorded} on:click={create}>Save</button>
+        <button class="button is-link" disabled={!canBeRecorded || isRecording} on:click={create}>Save</button>
       </div>
       <div class="control">
-        <button class="button is-link is-light" on:click={onCancel}>Cancel</button>
+        <button class="button is-link is-light" on:click={onCancel} disabled={isRecording}>Cancel</button>
       </div>
     </div>
   </div>
diff --git a/src/routes/_components/Task/HumanDeadline.svelte b/src/routes/_components/Task/HumanDeadline.svelte
new file mode 100644
index 0000000..f7de5d3
--- /dev/null
+++ b/src/routes/_components/Task/HumanDeadline.svelte
@@ -0,0 +1,10 @@
+<script>
+import { formatDistanceToNow } from "date-fns";
+
+
+export let date = new Date();
+
+$: human = formatDistanceToNow(date);
+</script>
+
+{human}
diff --git a/src/routes/api/notifications.js b/src/routes/api/notifications.js
new file mode 100644
index 0000000..c7fde66
--- /dev/null
+++ b/src/routes/api/notifications.js
@@ -0,0 +1,67 @@
+import { requireUser } from '../../backend/api-middleware/user';
+import { dbCol } from '../../backend/mongodb';
+
+/**
+ * Get notifications for the current user
+ *
+ * @param {express.Request} req express.js request
+ * @param {express.Response} res express.js response
+ */
+export async function get(req, res) {
+  const currentUser = await requireUser(req, res);
+  if (!currentUser) {
+    return;
+  }
+
+  try {
+    const collection = await dbCol('userNotifications');
+    const notifications = await collection
+      .find({ 'user._id': currentUser._id, seen: false })
+      .sort({ 'activity.date': -1 })
+      .toArray();
+
+    return res.status(200).json(notifications);
+  } catch (e) {
+    return res.status(500).json({ error: e.message, stack: e.stack });
+  }
+}
+
+/**
+ * Update notification read status for the current user
+ *
+ * body JSON param:
+ *
+ * ```javascript
+ *   { markReadUntil: String (Date.toIsoString) }
+ * ```
+ *
+ * @param {express.Request} req express.js request
+ * @param {express.Response} res express.js response
+ */
+export async function post(req, res) {
+  const currentUser = await requireUser(req, res);
+  if (!currentUser) {
+    return;
+  }
+
+  if (!req.body || !req.body.markReadUntil) {
+    return res.status(400).json({ error: 'Body should contain a markReadUntil property' });
+  }
+
+  const date = new Date(req.body.markReadUntil);
+
+  if (isNaN(date.getTime())) {
+    return res.status(400).json({ error: 'Body markReadUntil property should be a valid date' });
+  }
+
+  try {
+    const collection = await dbCol('userNotifications');
+    const { updatedCount } = collection.updateMany({ 'activity.date': { $lte: date } }, {
+      $set: { seen: true },
+    });
+
+    return res.status(200).json({ updated: updatedCount });
+  } catch (e) {
+    return res.status(500).json({ error: e.message, stack: e.stack });
+  }
+}
diff --git a/src/routes/api/sse/[clientId].js b/src/routes/api/sse/[clientId].js
index 8879f54..65d73d2 100644
--- a/src/routes/api/sse/[clientId].js
+++ b/src/routes/api/sse/[clientId].js
@@ -78,6 +78,8 @@ export async function get(req, res) {
       emailUserStateSeenUpdatedEvent(kafkaMessage, eventCallbackArgs);
     } else if (kafkaMessage.event() === 'email:task:done-status:updated') {
       emailTaskDoneStatusUpdatedEvent(kafkaMessage, eventCallbackArgs);
+    } else if (kafkaMessage.event() === 'user:notification:created') {
+      userNotificationCreatedEvent(kafkaMessage, eventCallbackArgs);
     }
   });
 
@@ -133,6 +135,13 @@ const emailDeliveredEvent = async (kafkaMessage, { user, send, debug }) => {
   send(kafkaMessage.event(), payload);
 };
 
+const sendToUser = async (kafkaMessage, { userId, send }) => {
+  const notification = kafkaMessage.payload();
+  if (userId === notification.user._id) {
+    send(kafkaMessage.event(), notification);
+  }
+};
+
 const emailSharedEvent = sendIfUserIsInEmail;
 const chatMessagePostedEvent = sendIfUserIsInEmail;
 const chatStartedEvent = sendIfUserIsInEmail;
@@ -145,3 +154,4 @@ const taskCreatedEvent = sendIfUserIsInEmail;
 const emailUserAddedEvent = sendIfUserIsInEmail;
 const emailUserStateSeenUpdatedEvent = sendOnlyToSender;
 const emailTaskDoneStatusUpdatedEvent = sendIfUserIsInEmail;
+const userNotificationCreatedEvent = sendToUser;
diff --git a/src/routes/api/tasks/[emailId]/index.js b/src/routes/api/tasks/[emailId]/index.js
index e1ec190..d53d65a 100644
--- a/src/routes/api/tasks/[emailId]/index.js
+++ b/src/routes/api/tasks/[emailId]/index.js
@@ -2,6 +2,7 @@ import { ObjectId } from 'mongodb';
 import { getEmailIfAllowed } from '../../../../backend/api-middleware/email-permission';
 import { createTask } from '../../../../backend/core/commands/task';
 import Actor from '../../../../shared/actor';
+import EmailHead from '../../../../shared/email-head';
 
 export async function post(req, res) {
   if (!req.session.user) {
@@ -10,7 +11,7 @@ export async function post(req, res) {
   const currentUser = req.session.user;
   const emailId = req.params.emailId;
 
-  const email = getEmailIfAllowed(currentUser, emailId, res);
+  const email = await getEmailIfAllowed(currentUser, emailId, res);
   if (!email) {
     return;
   }
@@ -30,6 +31,7 @@ export async function post(req, res) {
     deadline: req.body.deadline,
     description: req.body.description,
     emailId,
+    email: EmailHead.fromEmail(email.email),
     done: false,
     date: new Date(),
   };
diff --git a/src/routes/api/tasks/index.js b/src/routes/api/tasks/index.js
index d46e327..0231105 100644
--- a/src/routes/api/tasks/index.js
+++ b/src/routes/api/tasks/index.js
@@ -63,7 +63,7 @@ export async function get(req, res) {
   }
 
   let done = TASK_DONE.both;
-  if (req.query.done) {
+  if ('done' in req.query) {
     if (!(req.query.done in TASK_DONE)) {
       return res.status(400).json({ error: `done query string parameter should be in [${Object.keys(TASK_DONE).join(', ')}]` });
     }
diff --git a/src/routes/inbox/[folder]/index.svelte b/src/routes/inbox/[folder]/index.svelte
index 76827c6..5017280 100644
--- a/src/routes/inbox/[folder]/index.svelte
+++ b/src/routes/inbox/[folder]/index.svelte
@@ -67,8 +67,4 @@ $: {
   align-items: center;
   width: 100%;
 }
-
-activity-container {
-
-}
 </style>
diff --git a/src/routes/inbox/labels/[labelName]/index.svelte b/src/routes/inbox/labels/[labelName]/index.svelte
index 49d83ca..2d5b71d 100644
--- a/src/routes/inbox/labels/[labelName]/index.svelte
+++ b/src/routes/inbox/labels/[labelName]/index.svelte
@@ -65,8 +65,4 @@ $: {
   align-items: center;
   width: 100%;
 }
-
-activity-container {
-
-}
 </style>
diff --git a/src/routes/inbox/tasks/_components/TaskBox.svelte b/src/routes/tasks/_components/TaskBox.svelte
similarity index 86%
rename from src/routes/inbox/tasks/_components/TaskBox.svelte
rename to src/routes/tasks/_components/TaskBox.svelte
index a4ef243..453b1ca 100644
--- a/src/routes/inbox/tasks/_components/TaskBox.svelte
+++ b/src/routes/tasks/_components/TaskBox.svelte
@@ -1,6 +1,7 @@
 <script>
-import { formatDistanceToNow, formatRFC7231 } from "date-fns";
-import UserInline from '../../../_components/User/Inline.svelte';
+import { formatRFC7231 } from "date-fns";
+import UserInline from '../../_components/User/Inline.svelte';
+import TaskHumanDeadline from '../../_components/Task/HumanDeadline.svelte';
 import { put } from 'api';
 
 export let task;
@@ -24,7 +25,7 @@ const toggleDoneStatus = async () => {
     <div class="task-info pr-4">
       <div class="info">
         <span class="deadline" title="Deadline: {formatRFC7231(task.deadline.date)}">
-          <i class="fas fa-stopwatch" />  {formatDistanceToNow(task.deadline.date)}
+          <i class="fas fa-stopwatch" />  <TaskHumanDeadline date={task.deadline.date} />
         </span>
         {#if task.creator._id !== task.assignee._id}
         <span class="creator" title="Assigned by">
diff --git a/src/routes/tasks/_layout.svelte b/src/routes/tasks/_layout.svelte
new file mode 100644
index 0000000..5592e7e
--- /dev/null
+++ b/src/routes/tasks/_layout.svelte
@@ -0,0 +1,46 @@
+<script context="module">
+	export function preload({ params }, { user }) {
+		if (!user) {
+			this.redirect(302, `/login`);
+		}
+	}
+</script>
+
+<script>
+import { onMount } from 'svelte';
+import Modal from '../../components/Modal.svelte';
+import { loadLabels } from '../../libs/labels/labelProvider';
+import { connect } from '../../libs/sse';
+import { fetchEmails } from '../../libs/emails/emailProvider';
+import LeftMenu from '../_components/LeftMenu.svelte';
+import { start as startTaskBGSync } from '../../libs/tasks/tasksProvider';
+
+onMount(() => {
+	console.log('/inbox: connecting to SSE');
+  connect();
+  console.log('tasks: launching start()');
+  startTaskBGSync();
+});
+</script>
+
+<svelte:head>
+	<title>Your tasks - SoBox</title>
+</svelte:head>
+
+{#await Promise.all([loadLabels(), fetchEmails()])}
+Loading your inbox...
+{:then foo}
+<div class="columns p-0 m-0">
+	<LeftMenu />
+  <slot>In layout</slot>
+</div>
+{/await}
+<Modal />
+
+<style lang='less'>
+.columns {
+	overflow-y: hidden;
+	height: calc(100%);
+}
+
+</style>
diff --git a/src/routes/inbox/tasks/index.svelte b/src/routes/tasks/index.svelte
similarity index 84%
rename from src/routes/inbox/tasks/index.svelte
rename to src/routes/tasks/index.svelte
index 29d0f26..f73de7e 100644
--- a/src/routes/inbox/tasks/index.svelte
+++ b/src/routes/tasks/index.svelte
@@ -1,10 +1,10 @@
 <script>
 import { get } from 'api';
-import { add, endOfMonth, endOfWeek, formatDistanceToNow, formatRFC7231, isSameMonth, isSameWeek } from 'date-fns';
+import { add, endOfMonth, endOfWeek, formatDistanceToNow, isSameMonth, isSameWeek, sub } from 'date-fns';
 import { onMount } from 'svelte';
 import { writable } from 'svelte/store';
-import Task from '../../../shared/task';
-import UserInline from '../../_components/User/Inline.svelte';
+import { lateTasks } from '../../libs/tasks/tasksProvider';
+import Task from '../../shared/task';
 import TaskBox from './_components/TaskBox.svelte';
 
 const taskList = writable([]);
@@ -21,7 +21,6 @@ let nextMonth = [];
 onMount(async () => {
   const today = new Date();
   const lastSecondOfWeek = endOfWeek(today, sameWeekOpts);
-
   const sameMonth = isSameMonth(today, lastSecondOfWeek);
   let lastOfMonth;
   if (sameMonth) {
@@ -47,6 +46,17 @@ const formatDate = (date) => {
 </script>
 
 <article>
+  {#if $lateTasks.length}
+  <section class="section">
+    <div class="subtitle is-4">Late tasks</div>
+    <div class="tasks">
+      {#each $lateTasks as task}
+        <TaskBox {task} />
+      {/each}
+    </div>
+  </section>
+  {/if}
+
   <section class="section">
     <div class="subtitle is-4">This week</div>
     {#if thisWeek.length}
@@ -95,6 +105,7 @@ const formatDate = (date) => {
 
 <style lang="less">
 article {
+  flex: 1 1 auto;
   overflow-y: auto;
 }
 .tasks {
diff --git a/src/shared/activity.js b/src/shared/activity.js
new file mode 100644
index 0000000..2a7abc0
--- /dev/null
+++ b/src/shared/activity.js
@@ -0,0 +1,15 @@
+export const isActivity = (object) => {
+  if (!object) {
+    return false;
+  }
+  if (!object.name || typeof object.name !== 'string') {
+    return false;
+  }
+  if (!object.actor || !object.actor.origin || !object.actor._id) {
+    return false;
+  }
+  if (!object.date) {
+    return false;
+  }
+  return true;
+};
diff --git a/src/shared/email-head.js b/src/shared/email-head.js
new file mode 100644
index 0000000..2f1a6a7
--- /dev/null
+++ b/src/shared/email-head.js
@@ -0,0 +1,89 @@
+export default class EmailHead {
+  constructor({ _id, subject, from, to = null, cc = null, bcc = null, sentAt, receivedAt }) {
+    this._id = _id;
+    this.id = _id;
+    this.subject = subject;
+    this.from = from;
+    this.to = to;
+    this.cc = cc;
+    this.bcc = bcc;
+    this.sentAt = sentAt;
+    this.sentAtTs = sentAt.getTime();
+    this.receivedAt = receivedAt;
+    this.receivedAtTs = receivedAt.getTime();
+  }
+
+  static fromEmail(email) {
+    const emailHead = {
+      subject: email.subject,
+      from: email.from,
+      to: email.to,
+      cc: email.cc,
+      bcc: email.bcc,
+      sentAt: new Date(email.sentAt),
+      receivedAt: new Date(email.receivedAt),
+      _id: email.id,
+    };
+
+    return EmailHead.fromObject(emailHead);
+  }
+
+  static fromObject(object) {
+    if (!object._id) {
+      throw new Error('_id property is mandatory');
+    }
+    ensureRecipients(object.from, 'from');
+    const to = object.to || [];
+    ensureRecipients(to, 'to');
+    const cc = object.cc || [];
+    ensureRecipients(cc, 'cc');
+    const bcc = object.bcc || [];
+    ensureRecipients(bcc, 'bcc');
+    const sentAt = new Date(object.sentAt);
+    ensureDate(sentAt, 'sentAt');
+    const receivedAt = new Date(object.receivedAt);
+    ensureDate(receivedAt, 'receivedAt');
+    const emailHeadData = {
+      _id: object._id,
+      subject: object.subject,
+      sentAt,
+      receivedAt,
+      from: object.from,
+    };
+    if (object.to) {
+      emailHeadData.to = to;
+    }
+    if (object.cc) {
+      emailHeadData.cc = cc;
+    }
+    if (object.bcc) {
+      emailHeadData.bcc = bcc;
+    }
+
+    return new EmailHead(emailHeadData);
+  };
+}
+
+const ensureDate = (date, label) => {
+  if (!date || !('getTime' in date)) {
+    throw new Error(`${label} should be a valid date.`);
+  }
+};
+
+const ensureRecipients = (recipients, label) => {
+  if (!Array.isArray(recipients)) {
+    throw new Error(`recipient ${label} should be an array.`);
+  }
+  const badRecipients = recipients.filter(r => {
+    if (!r) {
+      return true;
+    }
+    if (!r.email) {
+      return true;
+    }
+    return false;
+  });
+  if (badRecipients.length) {
+    throw new Error(`recipients should be object with an email property: ${JSON.stringify(badRecipients)}`);
+  }
+};
diff --git a/src/shared/task.js b/src/shared/task.js
index 651a181..67c903b 100644
--- a/src/shared/task.js
+++ b/src/shared/task.js
@@ -7,6 +7,7 @@ export default class Task {
   constructor({
     _id,
     emailId,
+    email,
     creator,
     assignee,
     deadline,
@@ -16,6 +17,7 @@ export default class Task {
   }) {
     this._id = _id;
     this.emailId = emailId;
+    this.email = email;
     this.creator = creator;
     this.assignee = assignee;
     this.deadline = { ...deadline };
@@ -27,6 +29,7 @@ export default class Task {
   static fromObject({
     _id,
     emailId,
+    email = {},
     creator,
     assignee,
     deadline,
@@ -53,6 +56,10 @@ export default class Task {
       throw new Error('Task should have an emailId');
     }
 
+    if (!email) {
+      throw new Error('email should exist');
+    }
+
     if (!deadline || !deadline.date) {
       throw new Error('deadline should have a date property');
     }
@@ -83,6 +90,7 @@ export default class Task {
     return new Task({
       _id: taskId,
       emailId,
+      email,
       creator: taskCreator,
       assignee: taskAssignee,
       deadline: taskDeadline,
diff --git a/src/shared/user-notification.js b/src/shared/user-notification.js
new file mode 100644
index 0000000..95c5ed7
--- /dev/null
+++ b/src/shared/user-notification.js
@@ -0,0 +1,43 @@
+import { isActivity } from './activity';
+
+export default class UserNotification {
+  constructor({ activity, user, _id, seen, email, emailId }) {
+    this.activity = activity;
+    this.user = user;
+    if (_id) {
+      this._id = _id;
+    }
+    if (seen === true || seen === false) {
+      this.seen = seen;
+    } else {
+      this.seen = false;
+    }
+    if (email) {
+      this.email = email;
+    }
+    if (emailId) {
+      this.emailId = emailId;
+    }
+  }
+
+  static fromObject({ activity, user, _id = null, seen = false, email = null, emailId = null }) {
+    if (!activity) {
+      throw new Error('activity property is required');
+    }
+    if (!isActivity(activity)) {
+      throw new Error('activity propert should be an valid activity object');
+    }
+    if (!user || !user.origin || !user._id) {
+      throw new Error('user property should be a valid Actor');
+    }
+
+    return new UserNotification({
+      activity,
+      user,
+      _id,
+      seen,
+      email,
+      emailId,
+    });
+  }
+}