refactor: tidy

packages/s13n/src/serializer.js

@@ -37,11 +37,7 @@ export default class Serializer {
     if (!promise) {
       return Promise.resolve();
     }
-    return promise.then((resource) => {
+    return promise.then((resource) => (resource ? fn(resource) : undefined));
-      if (resource) {
-        fn(resource);
-      }
-    });
   }
 
 }

packages/s13n/src/synchronized/client.js

@@ -11,7 +11,6 @@ export default (flecks) => (Resource) => (
 
     async acceptPacket(packet) {
       const {s13nType} = packet;
-      // eslint-disable-next-line max-len
       if (!s13nType) {
         return;
       }
@@ -24,30 +23,7 @@ export default (flecks) => (Resource) => (
           await this.destroySynchronized(type, id);
           break;
         case 'update':
-          if (this.$$synchronized[type]?.[id]) {
+          await this.updateSynchronized(type, id, packet.data.packets);
-            const promises = [];
-            for (let i = 0; i < packet.data.packets.length; i++) {
-              const update = packet.data.packets[i];
-              promises.push(
-                Promise
-                  .resolve(this.$$synchronized[type][id])
-                  .then((resource) => {
-                    resource.acceptPacket(update);
-                  }),
-              );
-            }
-            await Promise.all(promises);
-          }
-          else {
-            await this.$$serializer.later(
-              `${type}:${id}`,
-              (resource) => {
-                for (let i = 0; i < packet.data.packets.length; i++) {
-                  resource.acceptPacket(packet.data.packets[i]);
-                }
-              },
-            );
-          }
           break;
         default:
       }
@@ -116,5 +92,26 @@ export default (flecks) => (Resource) => (
       return this.$$synchronized[type]?.[id];
     }
 
+    async updateSynchronized(type, id, packets) {
+      if (this.$$synchronized[type]?.[id]) {
+        await Promise.all(
+          packets.map((update) => (
+            Promise
+              .resolve(this.$$synchronized[type][id])
+              .then((resource) => resource.acceptPacket(update))
+          )),
+        );
+      }
+      else {
+        await this.$$serializer.later(
+          `${type}:${id}`,
+          (resource) => Promise.all(
+            packets
+              .map((packet) => resource.acceptPacket(packet)),
+          ),
+        );
+      }
+    }
+
   }
 );