dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-17 22:36:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor DbKeyDetailTab to streamline insert handling for Redis data types

Browse Source
This commit is contained in:
Stela Augustinova
2025-12-23 19:32:50 +01:00
parent 6689849f97
commit 3078e3584c
1 changed files with 23 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
packages/web/src/tabs/DbKeyDetailTab.svelte
View File

@@ -182,8 +182,6 @@
changes: [...changeSetRedis.changes, change]
};
}
console.log('ChangeSetRedis updated:', JSON.stringify(changeSetRedis, null, 2));
}
function getDisplayRow(row, keyInfo) {
@@ -236,23 +234,36 @@
c => c.key === keyInfo.key && c.type === keyInfo.type
);
if (!existingChange || !existingChange.inserts) {
return null;
let records = [];
// Add existing inserts if any
if (existingChange && existingChange.inserts) {
// @ts-ignore
records = existingChange.inserts.map(insert => {
if (keyInfo.type === 'hash') {
return { key: insert.key || '', value: insert.value || '', ttl: insert.ttl ? String(insert.ttl) : '' };
} else if (keyInfo.type === 'list' || keyInfo.type === 'set') {
return { value: insert.value || '' };
} else if (keyInfo.type === 'zset') {
return { member: insert.member || '', score: insert.score ? String(insert.score) : '' };
} else if (keyInfo.type === 'stream') {
return { id: insert.id || '', value: insert.value || '' };
}
return insert;
});
}
// @ts-ignore
const records = existingChange.inserts.map(insert => {
if (records.length === 0) {
if (keyInfo.type === 'hash') {
return { key: insert.key || '', value: insert.value || '', ttl: insert.ttl ? String(insert.ttl) : '' };
records.push({ key: '', value: '', ttl: '' });
} else if (keyInfo.type === 'list' || keyInfo.type === 'set') {
return { value: insert.value || '' };
records.push({ value: '' });
} else if (keyInfo.type === 'zset') {
return { member: insert.member || '', score: insert.score ? String(insert.score) : '' };
records.push({ member: '', score: '' });
} else if (keyInfo.type === 'stream') {
return { id: insert.id || '', value: insert.value || '' };
records.push({ id: '', value: '' });
}
return insert;
});
}
return { records };
}
@@ -264,7 +275,6 @@
}
async function saveAll() {
console.log('Saving all changes:', changeSetRedis);
await apiCall('database-connections/save-redis-data', {
conid,
database,