opensource/nocobase
3
0
Fork 0
mirror of https://github.com/nocobase/nocobase.git synced 2026-09-24 16:02:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into next

Browse Source
This commit is contained in:
nocobase[bot]
2025-08-28 03:17:05 +00:00
parent 9e4df68dcb 6cda3daaae
commit dcead006e1
1 changed files with 19 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/plugins/@nocobase/plugin-collection-tree/src/server/plugin.ts
+19 -12
View File
@@ -113,21 +113,28 @@ class PluginCollectionTreeServer extends Plugin {
throw new Error('Cannot set itself as the parent node');
}
});
this.db.on('collections.afterDestroy', async (collection: Model, { transaction }) => {
const name = `main_${collection.get('name')}_path`;
if (!condition(collection.options)) {
return;
}
const collectionTree = this.db.getCollection(name);
if (collectionTree) {
await this.db.getCollection(name).removeFromDb({ transaction });
collectionManager.db.removeAllListeners(`${collection.name}.afterSync`);
this.db.removeAllListeners(`${collection.name}.afterCreate`);
this.db.removeAllListeners(`${collection.name}.afterUpdate`);
this.db.removeAllListeners(`${collection.name}.afterBulkUpdate`);
this.db.removeAllListeners(`${collection.name}.afterDestroy`);
this.db.removeAllListeners(`${collection.name}.beforeSave`);
}
});
});
}
});
this.db.on('collections.afterDestroy', async (collection: Model, { transaction }) => {
const name = `main_${collection.get('name')}_path`;
if (!condition(collection.options)) {
return;
}
const collectionTree = this.db.getCollection(name);
if (collectionTree) {
await this.db.getCollection(name).removeFromDb({ transaction });
}
});
}
private async defineTreePathCollection(name: string, options: { schema?: string }) {