WEBDIENSTE/huly-platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2026-08-29 19:29:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove collection tx (#7171)

Browse Source 
Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com>
This commit is contained in:
Denis Bykhov
2024-11-15 11:49:35 +07:00
committed by GitHub
parent 2db44d9495
commit 8bfeba7303
92 changed files with 749 additions and 1262 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/github/pod-github/src/sync/pullrequests.ts
+8 -9
View File
@@ -9,7 +9,6 @@ import core, {
SortingOrder,
Status,
TxCUD,
TxCollectionCUD,
TxMixin,
TxOperations,
TxProcessor,
@@ -652,17 +651,17 @@ export class PullRequestSyncManager extends IssueSyncManagerBase implements DocS
// We also need to track deleted Todos,
const removedTodos: GithubTodo[] = []
const removedTodoOps = await client.findAll<TxCollectionCUD<Doc, ToDo>>(
core.class.TxCollectionCUD,
const removedTodoOps = await client.findAll<TxCUD<ToDo>>(
core.class.TxCUD,
{
objectId: pullRequest._id,
'tx.objectClass': time.class.ProjectToDo,
'tx.objectId': { $nin: allTodos.map((it) => it._id) }
attachedTo: pullRequest._id,
objectClass: time.class.ProjectToDo,
objectId: { $nin: allTodos.map((it) => it._id) }
},
{ sort: { modifiedOn: SortingOrder.Ascending } }
)
const todoIds = removedTodoOps.filter((it) => it.tx._class === core.class.TxCreateDoc).map((it) => it.tx.objectId)
const todoIds = removedTodoOps.filter((it) => it._class === core.class.TxCreateDoc).map((it) => it.objectId)
const mixinOps = await client.findAll<TxMixin<ToDo, GithubTodo>>(
core.class.TxMixin,
@@ -678,8 +677,8 @@ export class PullRequestSyncManager extends IssueSyncManagerBase implements DocS
// We need to rebuild removed todos's if pressent.
for (const tx of removedTodoOps) {
const ops = groupedByTodo.get(tx.tx.objectId)
groupedByTodo.set(tx.tx.objectId, [...(ops ?? []), tx.tx])
const ops = groupedByTodo.get(tx.objectId)
groupedByTodo.set(tx.objectId, [...(ops ?? []), tx])
}
for (const tx of mixinOps) {