remove unprocessed from store. Nothing was stored in the store

it was simply as passthrough to the Data file.
No we directly call the data file instead

Gruntfile.js

@@ -76,12 +76,10 @@ module.exports = grunt => {
           'libtextsecure/errors.js',
           'libtextsecure/libsignal-protocol.js',
           'libtextsecure/protocol_wrapper.js',
-
           'libtextsecure/crypto.js',
           'libtextsecure/storage.js',
           'libtextsecure/storage/user.js',
           'libtextsecure/storage/groups.js',
-          'libtextsecure/storage/unprocessed.js',
           'libtextsecure/protobufs.js',
           'libtextsecure/helpers.js',
           'libtextsecure/stringview.js',

libtextsecure/storage/unprocessed.js

@@ -1,39 +0,0 @@
-/* global window */
-
-// eslint-disable-next-line func-names
-(function() {
-  /** ***************************************
-   *** Not-yet-processed message storage ***
-   **************************************** */
-  window.textsecure = window.textsecure || {};
-  window.textsecure.storage = window.textsecure.storage || {};
-
-  window.textsecure.storage.unprocessed = {
-    getCount() {
-      return window.Signal.Data.getUnprocessedCount();
-    },
-    getAll() {
-      return window.Signal.Data.getAllUnprocessed();
-    },
-    get(id) {
-      return window.Signal.Data.getUnprocessedById(id);
-    },
-    add(data) {
-      return window.Signal.Data.saveUnprocessed(data, {
-        forceSave: true,
-      });
-    },
-    updateAttempts(id, attempts) {
-      return window.Signal.Data.updateUnprocessedAttempts(id, attempts);
-    },
-    addDecryptedData(id, data) {
-      return window.Signal.Data.updateUnprocessedWithData(id, data);
-    },
-    remove(id) {
-      return window.Signal.Data.removeUnprocessed(id);
-    },
-    removeAll() {
-      return window.Signal.Data.removeAllUnprocessed();
-    },
-  };
-})();

ts/receiver/cache.ts

@@ -1,12 +1,22 @@
 import { EnvelopePlus } from './types';
 import { StringUtils } from '../session/utils';
 import _ from 'lodash';
+import {
+  getAllUnprocessed,
+  getUnprocessedById,
+  getUnprocessedCount,
+  removeAllUnprocessed,
+  removeUnprocessed,
+  saveUnprocessed,
+  updateUnprocessedAttempts,
+  updateUnprocessedWithData,
+} from '../data/data';
 
 export async function removeFromCache(envelope: EnvelopePlus) {
   const { id } = envelope;
   window.log.info(`removing from cache envelope: ${id}`);
 
-  return window.textsecure.storage.unprocessed.remove(id);
+  return removeUnprocessed(id);
 }
 
 export async function addToCache(
@@ -28,23 +38,23 @@ export async function addToCache(
     data.senderIdentity = envelope.senderIdentity;
   }
 
-  return window.textsecure.storage.unprocessed.add(data);
+  return saveUnprocessed(data, { forceSave: true });
 }
 
 async function fetchAllFromCache(): Promise<Array<any>> {
   const { textsecure } = window;
 
-  const count = await textsecure.storage.unprocessed.getCount();
+  const count = await getUnprocessedCount();
 
   if (count > 1500) {
-    await textsecure.storage.unprocessed.removeAll();
+    await removeAllUnprocessed();
     window.log.warn(
       `There were ${count} messages in cache. Deleted all instead of reprocessing`
     );
     return [];
   }
 
-  const items = await textsecure.storage.unprocessed.getAll();
+  const items = await getAllUnprocessed();
   return items;
 }
 
@@ -65,12 +75,9 @@ export async function getAllFromCache() {
             'getAllFromCache final attempt for envelope',
             item.id
           );
-          await textsecure.storage.unprocessed.remove(item.id);
+          await removeUnprocessed(item.id);
         } else {
-          await textsecure.storage.unprocessed.updateAttempts(
+          await updateUnprocessedAttempts(item.id, attempts);
-            item.id,
-            attempts
-          );
         }
       } catch (error) {
         window.log.error(
@@ -109,12 +116,9 @@ export async function getAllFromCacheForSource(source: string) {
             'getAllFromCache final attempt for envelope',
             item.id
           );
-          await textsecure.storage.unprocessed.remove(item.id);
+          await removeUnprocessed(item.id);
         } else {
-          await textsecure.storage.unprocessed.updateAttempts(
+          await updateUnprocessedAttempts(item.id, attempts);
-            item.id,
-            attempts
-          );
         }
       } catch (error) {
         window.log.error(
@@ -133,7 +137,7 @@ export async function updateCache(
   plaintext: ArrayBuffer
 ): Promise<void> {
   const { id } = envelope;
-  const item = await window.textsecure.storage.unprocessed.get(id);
+  const item = await getUnprocessedById(id);
   if (!item) {
     window.log.error(`updateCache: Didn't find item ${id} in cache to update`);
     return;
@@ -148,5 +152,5 @@ export async function updateCache(
 
   item.decrypted = StringUtils.decode(plaintext, 'base64');
 
-  return window.textsecure.storage.unprocessed.addDecryptedData(item.id, item);
+  return updateUnprocessedWithData(item.id, item);
 }

ts/receiver/receiver.ts

@@ -233,7 +233,7 @@ async function queueCached(item: any) {
 
     try {
       const { id } = item;
-      await textsecure.storage.unprocessed.remove(id);
+      await removeUnprocessed(id);
     } catch (deleteError) {
       window.log.error(
         'queueCached error deleting item',

ts/session/utils/syncUtils.ts

@@ -25,7 +25,7 @@ export const syncConfigurationIfNeeded = async () => {
   const allConvos = ConversationController.getInstance().getConversations();
   const configMessage = await getCurrentConfigurationMessage(allConvos);
   try {
-    window.log.info('syncConfigurationIfNeeded with', configMessage);
+    // window.log.info('syncConfigurationIfNeeded with', configMessage);
 
     await getMessageQueue().sendSyncMessage(configMessage);
   } catch (e) {