From 157e7874c4e3f3f20cfe5c090dde1015dcede9d3 Mon Sep 17 00:00:00 2001
From: Andrey Platov <andrey@hardcoreeng.com>
Date: Fri, 8 Oct 2021 11:18:06 +0200
Subject: [PATCH] bulk everything

Signed-off-by: Andrey Platov <andrey@hardcoreeng.com>
---
 .../src/components/KanbanView.svelte          | 26 ++++++++++---------
 server/core/src/storage.ts                    | 15 ++++++++---
 2 files changed, 25 insertions(+), 16 deletions(-)

diff --git a/plugins/view-resources/src/components/KanbanView.svelte b/plugins/view-resources/src/components/KanbanView.svelte
index 6b6a93319a..787e3d591d 100644
--- a/plugins/view-resources/src/components/KanbanView.svelte
+++ b/plugins/view-resources/src/components/KanbanView.svelte
@@ -16,7 +16,7 @@
 
 <script lang="ts">
   import { createEventDispatcher } from 'svelte'
-  import type { Ref, Class, Doc, Space, SpaceWithStates, FindOptions, State, TxBulkWrite } from '@anticrm/core'
+  import type { Ref, Class, Doc, Space, SpaceWithStates, FindOptions, State, TxBulkWrite, TxCUD } from '@anticrm/core'
   import { getResource } from '@anticrm/platform'
   import { buildModel } from '../utils'
   import { getClient } from '@anticrm/presentation'
@@ -78,30 +78,24 @@
   async function move(to: number, state: Ref<State>) {
     console.log('move version 12')
     const id = dragCard._id
-
-    if (dragCardInitialState !== state)
-      client.updateDoc(_class, space, id, { state })
+    const txes: TxCUD<Doc>[] = []
 
     if (dragCardInitialPosition !== to) {
 
-      const remove = client.txFactory.createTxUpdateDoc(core.class.SpaceWithStates, core.space.Model, space, {
+      txes.push(client.txFactory.createTxUpdateDoc(core.class.SpaceWithStates, core.space.Model, space, {
         $pull: {
           order: id
         }
-      })
+      }))
 
-      const add = client.txFactory.createTxUpdateDoc(core.class.SpaceWithStates, core.space.Model, space, {
+      txes.push(client.txFactory.createTxUpdateDoc(core.class.SpaceWithStates, core.space.Model, space, {
         $push: {
           order: {
             $each: [id],
             $position: to
           }
         }
-      })
-
-      const updateTx = client.txFactory.createTxBulkWrite(core.space.Model, [remove, add])
-
-      await client.tx(updateTx)
+      }))
       
       // await client.updateDoc(core.class.SpaceWithStates, core.space.Model, space, {
       //   $pull: {
@@ -118,6 +112,14 @@
       //   }
       // })
     }
+
+    if (dragCardInitialState !== state)
+      txes.push(client.txFactory.createTxUpdateDoc(_class, space, id, { state }))
+
+    if (txes.length > 0) {
+      const updateTx = client.txFactory.createTxBulkWrite(space, txes)
+      await client.tx(updateTx)
+    }
   }
 
   function getValue(doc: Doc, key: string): any {
diff --git a/server/core/src/storage.ts b/server/core/src/storage.ts
index fb04dec52f..fb16c3e63b 100644
--- a/server/core/src/storage.ts
+++ b/server/core/src/storage.ts
@@ -14,7 +14,7 @@
 // limitations under the License.
 //
 
-import type { ServerStorage, Domain, Tx, TxCUD, Doc, Ref, Class, DocumentQuery, FindResult, FindOptions, Storage } from '@anticrm/core'
+import type { ServerStorage, Domain, Tx, TxCUD, Doc, Ref, Class, DocumentQuery, FindResult, FindOptions, Storage, TxBulkWrite } from '@anticrm/core'
 import core, { Hierarchy, DOMAIN_TX } from '@anticrm/core'
 import type { FullTextAdapterFactory, FullTextAdapter } from './types'
 import { FullTextIndex } from './fulltext'
@@ -87,13 +87,20 @@ class TServerStorage implements ServerStorage {
     return adapter
   }
 
-  private routeTx (tx: Tx): Promise<void> {
+  private async routeTx (tx: Tx): Promise<void> {
     if (this.hierarchy.isDerived(tx._class, core.class.TxCUD)) {
       const txCUD = tx as TxCUD<Doc>
       const domain = this.hierarchy.getDomain(txCUD.objectClass)
-      return this.getAdapter(domain).tx(txCUD)
+      return await this.getAdapter(domain).tx(txCUD)
     } else {
-      throw new Error('not implemented (not derived from TxCUD)')
+      if (this.hierarchy.isDerived(tx._class, core.class.TxBulkWrite)) {
+        const bulkWrite = tx as TxBulkWrite
+        for (const tx of bulkWrite.txes) {
+          await this.tx(tx)
+        }
+      } else {
+        throw new Error('not implemented (routeTx)')
+      }
     }
   }