Prep for pull

ts/session/sending/MessageQueue.ts

@@ -12,32 +12,9 @@ import {
 import { PendingMessageCache } from './PendingMessageCache';
 import { JobQueue, TypedEventEmitter } from '../utils';
 
-// Used for ExampleMessage
-import { v4 as uuid } from 'uuid';
-import { SignalService } from '../../protobuf';
 
-export class ExampleMessage extends ContentMessage {
-  constructor() {
-    super({
-      timestamp: Math.floor(Math.random() * 10000000000000),
-      identifier: uuid(),
-    });
-  }
 
-  public ttl(): number {
-    // throw new Error("Method not implemented.");
-    return 5;
-  }
-
-  protected contentProto(): SignalService.Content {
-    // throw new Error("Method not implemented.");
 
-    // TODO - get actual content
-    const content = SignalService.Content.create();
-
-    return content;
-  }
-}
 
 export class MessageQueue implements MessageQueueInterface {
   public readonly events: TypedEventEmitter<MessageQueueInterfaceEvents>;
@@ -59,6 +36,7 @@ export class MessageQueue implements MessageQueueInterface {
 
     console.log('[vince] userDevices:', userDevices);
   }
+
   public send(device: string, message: ContentMessage) {
     // throw new Error('Method not implemented.');
 
@@ -68,12 +46,14 @@ export class MessageQueue implements MessageQueueInterface {
     console.log(`[vince] send: Queueing message`, message);
     this.queue(device, message);
   }
+
   public sendToGroup(message: ContentMessage | OpenGroupMessage) {
     throw new Error('Method not implemented.');
 
     // If you see an open group message just call
     // MessageSender.sendToOpenGroup directly.
   }
+  
   public sendSyncMessage(message: ContentMessage) {
     // PSEDUOCODE
     // if message is undefined

ts/test/session/sending/MessageQueue_test.ts

@@ -1,31 +1,60 @@
-// import { expect } from 'chai';
+import { expect } from 'chai';
-
+
-// import { ChatMessage, SessionResetMessage,  } from '../../../session/messages/outgoing';
+import { ChatMessage, SessionResetMessage } from '../../../session/messages/outgoing';
-// import { TextEncoder } from 'util';
+import { TextEncoder } from 'util';
-// import { MessageUtils } from '../../../session/utils';
+import { MessageUtils } from '../../../session/utils';
-// import { PendingMessageCache } from '../../../session/sending/PendingMessageCache';
+import { PendingMessageCache } from '../../../session/sending/PendingMessageCache';
-
+
-// describe('PendingMessageCache', () => {
+
-//     const pendingMessageCache = new PendingMessageCache();
+// Used for ExampleMessage
-
+import { v4 as uuid } from 'uuid';
-//     let sessionResetMessage: SessionResetMessage;
+import { SignalService } from '../../../protobuf';
-//     const preKeyBundle = {
+
-//         deviceId: 123456,
+export class ExampleMessage extends ContentMessage {
-//         preKeyId: 654321,
+  constructor() {
-//         signedKeyId: 111111,
+    super({
-//         preKey: new TextEncoder().encode('preKey'),
+      timestamp: Math.floor(Math.random() * 10000000000000),
-//         signature: new TextEncoder().encode('signature'),
+      identifier: uuid(),
-//         signedKey: new TextEncoder().encode('signedKey'),
+    });
-//         identityKey: new TextEncoder().encode('identityKey'),
+  }
-//     };
+
-
+  public ttl(): number {
-//     // queue with session reset message.
+    // throw new Error("Method not implemented.");
-//     // should return undefined
+    return 5;
-//     // TOOD: Send me to MESSAGE QUEUE TEST
+  }
-//     it('queue session reset message', () => {
+
-//       const timestamp = Date.now();
+  protected contentProto(): SignalService.Content {
-//       sessionResetMessage = new SessionResetMessage({timestamp, preKeyBundle});
+    // throw new Error("Method not implemented.");
-
+
-//     });
+    // TODO - get actual content
-
+    const content = SignalService.Content.create();
-// });
+
+    return content;
+  }
+}
+
+
+describe('PendingMessageCache', () => {
+    const pendingMessageCache = new PendingMessageCache();
+
+    let sessionResetMessage: SessionResetMessage;
+    const preKeyBundle = {
+        deviceId: 123456,
+        preKeyId: 654321,
+        signedKeyId: 111111,
+        preKey: new TextEncoder().encode('preKey'),
+        signature: new TextEncoder().encode('signature'),
+        signedKey: new TextEncoder().encode('signedKey'),
+        identityKey: new TextEncoder().encode('identityKey'),
+    };
+
+    // queue with session reset message.
+    // should return undefined
+    // TOOD: Send me to MESSAGE QUEUE TEST
+    it('queue session reset message', () => {
+      const timestamp = Date.now();
+      sessionResetMessage = new SessionResetMessage({timestamp, preKeyBundle});
+
+    });
+
+});

ts/test/session/sending/PendingMessageCache_test.ts

@@ -1,15 +1,11 @@
-// tslint:disable-next-line: no-require-imports no-var-requires
+import { expect } from 'chai';
-const Data = require('../../../../js/modules/data');
+import * as sinon from 'sinon';
-
-import { expect, assert } from 'chai';
-import sinon from 'sinon';
 import uuid from 'uuid';
 
 import { ChatMessage } from '../../../session/messages/outgoing';
 import { MessageUtils, PubKey } from '../../../session/utils';
 import { PendingMessageCache } from '../../../session/sending/PendingMessageCache';
 import { RawMessage } from '../../../session/types/RawMessage';
-import { SignalService } from '../../../protobuf';
 
 describe('PendingMessageCache', () => {
   const sandbox = sinon.createSandbox();