feature works.

packages/frontend/src/data/models/message/model.ts

@@ -116,6 +116,13 @@ export default class Message extends Model {
 
   @attr() sendError?: string;
 
+  /**
+   * When a user comes online, they dispatch a bunch of pings to their contacts.
+   * If any of those contacts have queue messages (designated by this boolean)
+   * the messages will automatically be sent to the user who jest came online
+   * */
+  @attr() queueForResend?: boolean;
+
   @belongsTo('identity', { async: false }) sender?: Identity;
 
   // @belongsTo('message', { async: false, inverse: 'deliveryConfirmations' }) confirmationFor?: Message;

packages/frontend/src/services/messages/auto-responder.ts

@@ -1,9 +1,11 @@
 import Service from '@ember/service';
 import { service } from '@ember-decorators/service';
+import StoreService from 'ember-data/store';
 
 import MessageDispatcher from 'emberclear/src/services/messages/dispatcher';
 import MessageFactory from 'emberclear/src/services/messages/factory';
 import Message from 'emberclear/src/data/models/message/model';
+import Identity from 'emberclear/src/data/models/identity/model';
 
 /**
  * Nothing here should be blocking, as these responses should not matter
@@ -14,13 +16,25 @@ import Message from 'emberclear/src/data/models/message/model';
 export default class MessageAutoResponder extends Service {
   @service('messages/dispatcher') dispatcher!: MessageDispatcher;
   @service('messages/factory') factory!: MessageFactory;
+  @service store!: StoreService;
 
   async messageReceived(respondToMessage: Message) {
     const sender = await respondToMessage.sender;
     const response = this.factory.buildDeliveryConfirmation(respondToMessage);
 
     this.dispatcher.sendToUser.perform(response, sender);
   }
+
+  async cameOnline(identity: Identity) {
+    const pendingMessages = await this.store.query('message', {
+      queueForResend: true,
+      to: identity.uid,
+    });
+
+    pendingMessages.forEach((message: Message) => {
+      this.dispatcher.sendToUser.perform(message, identity);
+    });
+  }
 }
 
 // DO NOT DELETE: this is how TypeScript knows how to look up your services.

packages/frontend/src/services/messages/dispatcher.ts

@@ -33,7 +33,14 @@ export default class MessageDispatcher extends Service {
     this.sendTo(message, to);
   }
 
+  // there needs to be a polymorphic relationship in order for this to work
+  // sendMessage(message: Message) {
+  //   return sendTo(message, message.to);
+  // }
+
   async sendTo(message: Message, to: Identity | Channel) {
+    message.set('queueForResend', false);
+
     if (to instanceof Identity) {
       if (to.id === 'me') return;
 

packages/frontend/src/services/messages/handler/service.ts

@@ -110,6 +110,7 @@ export default class ReceivedMessageHandler extends Service {
     const sender = await this.findOrCreateSender(senderInfo);
 
     this.statusManager.markOnline(sender);
+    this.autoResponder.cameOnline(sender);
 
     const message = this.store.createRecord('message', {
       id,

packages/frontend/src/services/toast.ts

@@ -32,7 +32,7 @@ export default class Toast extends Service {
       ...options,
       message: message || 'status',
       type: status,
-      cssClasses: `notification ${status} p-xs has-shadow height-tall`,
+      cssClasses: `notification ${status} is-${status} p-xs has-shadow height-tall`,
     });
   }
 }

packages/frontend/src/ui/components/chat-history/message/delivery-confirmations/component.ts

@@ -77,4 +77,13 @@ export default class DeliveryConfirmation extends Component<IArgs> {
 
     yield message.destroyRecord();
   }
+
+  @dropTask
+  *resendAutomatically(this: DeliveryConfirmation) {
+    const { message } = this.args;
+
+    message.set('queueForResend', true);
+
+    yield message.save();
+  }
 }

packages/frontend/src/ui/components/chat-history/message/delivery-confirmations/template.hbs

@@ -15,6 +15,14 @@
         {{#if this.resend.isIdle}}
           <a {{action (perform this.resend)}}>{{t 'buttons.resend'}}</a>
         {{/if}}
+        |
+        {{#if this.resendAutomatically.isIdle}}
+          {{#if @message.queueForResend}}
+            {{t 'models.message.autosendPending'}}
+          {{else}}
+            <a {{action (perform this.resendAutomatically)}}>{{t 'buttons.resendAutomatically'}}</a>
+          {{/if}}
+        {{/if}}
 
         {{fa-icon 'exclamation-circle'}}
 

packages/frontend/translations/en-us.yaml

@@ -27,6 +27,7 @@ connection:
 buttons:
   delete: delete
   resend: resend
+  resendAutomatically: resend automatically
   save: Save
   next: Next
   back: Back
@@ -89,6 +90,7 @@ models:
     publicKey: Public Key
 
   message:
+    autosendPending: autosend pending
     errors:
       timeout: 'Sending timed out.'