UniqAI/hexabot
1
0
Fork 0
mirror of https://github.com/hexastack/hexabot synced 2025-06-26 18:27:28 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: consolidate block updates operations

Browse Source
This commit is contained in:
medchedli 2025-06-12 12:20:25 +01:00
parent 6a128541df
commit e211aa36ba
1 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
api/src/chat/repositories/block.repository.ts
View File

@ -187,10 +187,12 @@ export class BlockRepository extends BaseRepository<
? attachedBlock
: null;
await this.updateOne(id, {
const updates: Partial<Block> = {
nextBlocks: updatedNextBlocks,
attachedBlock: updatedAttachedBlock,
});
};
await this.updateOne(id, updates);
} catch (error) {
this.logger?.error(
`Failed to update block ${id} during in-category scope update.`,
@ -214,23 +216,26 @@ export class BlockRepository extends BaseRepository<
): Promise<void> {
for (const block of otherBlocks) {
try {
// If block has an attachedBlock, we only need to check that
const updates: Partial<Block> = {};
// Check if the block has an attachedBlock
if (block.attachedBlock) {
if (ids.includes(block.attachedBlock)) {
await this.updateOne(block.id, { attachedBlock: null });
updates.attachedBlock = null;
}
} else {
// Only check nextBlocks if there is no attachedBlock
const filteredNextBlocks = block.nextBlocks?.filter(
(nextBlock) => !ids.includes(nextBlock),
);
if (filteredNextBlocks?.length !== block.nextBlocks?.length) {
updates.nextBlocks = filteredNextBlocks || [];
}
continue; // Skip nextBlocks check since it can't have both
}
// Only check nextBlocks if there is no attachedBlock
const filteredNextBlocks = block.nextBlocks?.filter(
(nextBlock) => !ids.includes(nextBlock),
);
if (filteredNextBlocks?.length !== block.nextBlocks?.length) {
await this.updateOne(block.id, {
nextBlocks: filteredNextBlocks || [],
});
if (Object.keys(updates).length > 0) {
await this.updateOne(block.id, updates);
}
} catch (error) {
this.logger?.error(