SILVER
/
NODEDC_PLATFORM
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: align assistant executor payload with engine

This commit is contained in:
Codex 2026-06-09 11:48:57 +03:00
parent 65da785a9d
commit e208b9f659
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
services/ai-workspace-assistant/src/server.mjs
View File

@ -200,7 +200,7 @@ async function createExecutor(owner, command) {
) )
returning *`, returning *`,
[ [
randomUUID(), command.id || randomUUID(),
owner.key, owner.key,
owner.userId, owner.userId,
owner.email, owner.email,
@ -580,6 +580,9 @@ function sanitizeExecutorCommand(payload, { partial }) {
const source = isPlainObject(payload) ? payload : {}; const source = isPlainObject(payload) ? payload : {};
const command = {}; const command = {};
if (Object.hasOwn(source, "id")) {
command.id = sanitizeUuid(source.id, "id");
}
if (!partial || Object.hasOwn(source, "name")) { if (!partial || Object.hasOwn(source, "name")) {
command.name = requireNonEmptyString(source.name, "name"); command.name = requireNonEmptyString(source.name, "name");
} }
@ -596,7 +599,7 @@ function sanitizeExecutorCommand(payload, { partial }) {
copyOptionalString(command, "model", source.model); copyOptionalString(command, "model", source.model);
copyOptionalString(command, "accountLabel", source.accountLabel || source.account_label); copyOptionalString(command, "accountLabel", source.accountLabel || source.account_label);
if (!partial || Object.hasOwn(source, "capabilities")) { if (!partial || Object.hasOwn(source, "capabilities")) {
command.capabilities = isPlainObject(source.capabilities) ? source.capabilities : {}; command.capabilities = isJsonContainer(source.capabilities) ? source.capabilities : {};
} }
if (!partial || Object.hasOwn(source, "status")) { if (!partial || Object.hasOwn(source, "status")) {
command.status = sanitizeEnum(source.status || "unknown", SUPPORTED_EXECUTOR_STATUSES, "unsupported_executor_status"); command.status = sanitizeEnum(source.status || "unknown", SUPPORTED_EXECUTOR_STATUSES, "unsupported_executor_status");
@ -859,6 +862,10 @@ function isPlainObject(value) {
return Boolean(value && typeof value === "object" && !Array.isArray(value)); return Boolean(value && typeof value === "object" && !Array.isArray(value));
} }
function isJsonContainer(value) {
return Boolean(value && typeof value === "object");
}
function toIso(value) { function toIso(value) {
if (!value) return null; if (!value) return null;
return value instanceof Date ? value.toISOString() : new Date(value).toISOString(); return value instanceof Date ? value.toISOString() : new Date(value).toISOString();