[{"_1":2,"_173":-5,"_174":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","ee71156f3611aaa3e5ac1e0e44a96f6a2f8ed490","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_170":171,"_172":-5},"handle","diegoivo","name","sdkAnthropic","path","backend/database/queries.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","465a857e-8dc7-11f0-a84e-0224a6c84d84","createdAt",["D",1757454746679],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","add95710-0ddb-4dc2-90f2-bdcb16df89be","pinnedFileId","pinPreview","screenshotVersion","likeCount","39c8580e-ee92-40a4-b9a2-165f574b6ae2","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycWNtOXpnaDJrU25hbkZMNW15WjN5MlhldEUifQ","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",74,"465aca5c-8dc7-11f0-a84e-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":160,"_161":162,"_163":164,"_165":20,"_166":-5,"_97":167},"1e9a3e0a-8dca-11f0-883b-0224a6c84d84","queries.ts","fileId","1bdbfb24-8dc8-11f0-bdfa-0224a6c84d84","parentId","cf567295-122e-4d2a-9fd0-2a9ab20dfaae","branchId","branchVersion",38,"latest",true,["D",1757455968468],9,"fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type { Agent, Workflow, Execution, AgentExecution } from \"../../shared/types.ts\";\n\n// Agent queries\nexport async function createAgent(agent: Omit): Promise {\n const now = new Date().toISOString();\n await sqlite.execute(\n `INSERT INTO agents (id, name, description, model, max_tokens, context_window, thinking_enabled, budget_tokens, system_prompt, mcps, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n agent.id,\n agent.name,\n agent.description,\n agent.model,\n agent.max_tokens,\n agent.context_window,\n agent.thinking_enabled,\n agent.budget_tokens,\n agent.system_prompt,\n JSON.stringify(agent.mcps),\n now,\n now\n ]\n );\n\n return { ...agent, created_at: now, updated_at: now };\n}\n\nexport async function getAgent(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM agents WHERE id = ?`, [id]);\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n if (rows.length === 0) return null;\n\n const row = rows[0];\n return {\n id: row.id,\n name: row.name,\n description: row.description,\n model: row.model,\n max_tokens: row.max_tokens,\n context_window: row.context_window,\n thinking_enabled: Boolean(row.thinking_enabled),\n budget_tokens: row.budget_tokens,\n system_prompt: row.system_prompt,\n mcps: JSON.parse(row.mcps),\n created_at: row.created_at,\n updated_at: row.updated_at\n };\n}\n\nexport async function listAgents(): Promise {\n const result = await sqlite.execute(`SELECT * FROM agents ORDER BY created_at DESC`);\n \n // Verificar se result é um array ou tem uma propriedade rows\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n return rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n model: row.model,\n max_tokens: row.max_tokens,\n context_window: row.context_window,\n thinking_enabled: Boolean(row.thinking_enabled),\n budget_tokens: row.budget_tokens,\n system_prompt: row.system_prompt,\n mcps: JSON.parse(row.mcps),\n created_at: row.created_at,\n updated_at: row.updated_at\n }));\n}\n\nexport async function updateAgent(id: string, updates: Partial): Promise {\n const agent = await getAgent(id);\n if (!agent) return null;\n\n const now = new Date().toISOString();\n const updatedAgent = { ...agent, ...updates, updated_at: now };\n\n await sqlite.execute(\n `UPDATE agents SET name = ?, description = ?, model = ?, max_tokens = ?, context_window = ?, \n thinking_enabled = ?, budget_tokens = ?, system_prompt = ?, mcps = ?, updated_at = ?\n WHERE id = ?`,\n [\n updatedAgent.name,\n updatedAgent.description,\n updatedAgent.model,\n updatedAgent.max_tokens,\n updatedAgent.context_window,\n updatedAgent.thinking_enabled,\n updatedAgent.budget_tokens,\n updatedAgent.system_prompt,\n JSON.stringify(updatedAgent.mcps),\n now,\n id\n ]\n );\n\n return updatedAgent;\n}\n\nexport async function deleteAgent(id: string): Promise {\n const result = await sqlite.execute(`DELETE FROM agents WHERE id = ?`, [id]);\n return (result.changes || 0) > 0;\n}\n\n// Workflow queries\nexport async function createWorkflow(workflow: Omit): Promise {\n const now = new Date().toISOString();\n await sqlite.execute(\n `INSERT INTO workflows (id, name, description, agents, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?)`,\n [\n workflow.id,\n workflow.name,\n workflow.description,\n JSON.stringify(workflow.agents),\n now,\n now\n ]\n );\n\n return { ...workflow, created_at: now, updated_at: now };\n}\n\nexport async function getWorkflow(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM workflows WHERE id = ?`, [id]);\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n if (rows.length === 0) return null;\n\n const row = rows[0];\n return {\n id: row.id,\n name: row.name,\n description: row.description,\n agents: JSON.parse(row.agents),\n created_at: row.created_at,\n updated_at: row.updated_at\n };\n}\n\nexport async function listWorkflows(): Promise {\n const result = await sqlite.execute(`SELECT * FROM workflows ORDER BY created_at DESC`);\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n return rows.map(row => ({\n id: row.id,\n name: row.name,\n description: row.description,\n agents: JSON.parse(row.agents),\n created_at: row.created_at,\n updated_at: row.updated_at\n }));\n}\n\n// Execution queries\nexport async function createExecution(execution: Omit): Promise {\n const now = new Date().toISOString();\n await sqlite.execute(\n `INSERT INTO executions (id, type, target_id, status, input, output, error, progress, started_at, completed_at, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n execution.id,\n execution.type,\n execution.target_id,\n execution.status,\n JSON.stringify(execution.input),\n execution.output ? JSON.stringify(execution.output) : null,\n execution.error,\n execution.progress || 0,\n execution.started_at,\n execution.completed_at,\n now\n ]\n );\n\n return { ...execution, created_at: now };\n}\n\nexport async function getExecution(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM executions WHERE id = ?`, [id]);\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n if (rows.length === 0) return null;\n\n const row = rows[0];\n return {\n id: row.id,\n type: row.type,\n target_id: row.target_id,\n status: row.status,\n input: JSON.parse(row.input),\n output: row.output ? JSON.parse(row.output) : undefined,\n error: row.error,\n progress: row.progress,\n started_at: row.started_at,\n completed_at: row.completed_at,\n created_at: row.created_at\n };\n}\n\nexport async function updateExecution(id: string, updates: Partial): Promise {\n const execution = await getExecution(id);\n if (!execution) return null;\n\n const updatedExecution = { ...execution, ...updates };\n\n await sqlite.execute(\n `UPDATE executions SET status = ?, output = ?, error = ?, progress = ?, started_at = ?, completed_at = ?\n WHERE id = ?`,\n [\n updatedExecution.status,\n updatedExecution.output ? JSON.stringify(updatedExecution.output) : null,\n updatedExecution.error,\n updatedExecution.progress,\n updatedExecution.started_at,\n updatedExecution.completed_at,\n id\n ]\n );\n\n return updatedExecution;\n}\n\nexport async function listExecutions(type?: string, status?: string): Promise {\n let query = `SELECT * FROM executions`;\n const params: any[] = [];\n\n if (type || status) {\n query += ` WHERE`;\n const conditions = [];\n if (type) {\n conditions.push(` type = ?`);\n params.push(type);\n }\n if (status) {\n conditions.push(` status = ?`);\n params.push(status);\n }\n query += conditions.join(' AND');\n }\n\n query += ` ORDER BY created_at DESC`;\n\n const result = await sqlite.execute(query, params);\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n return rows.map(row => ({\n id: row.id,\n type: row.type,\n target_id: row.target_id,\n status: row.status,\n input: JSON.parse(row.input),\n output: row.output ? JSON.parse(row.output) : undefined,\n error: row.error,\n progress: row.progress,\n started_at: row.started_at,\n completed_at: row.completed_at,\n created_at: row.created_at\n }));\n}\n\n// Agent execution queries\nexport async function createAgentExecution(agentExecution: Omit): Promise {\n const now = new Date().toISOString();\n await sqlite.execute(\n `INSERT INTO agent_executions (id, agent_id, execution_id, status, input, output, error, tokens_used, thinking_content, started_at, completed_at, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n agentExecution.id,\n agentExecution.agent_id,\n agentExecution.execution_id,\n agentExecution.status,\n JSON.stringify(agentExecution.input),\n agentExecution.output ? JSON.stringify(agentExecution.output) : null,\n agentExecution.error,\n agentExecution.tokens_used,\n agentExecution.thinking_content,\n agentExecution.started_at,\n agentExecution.completed_at,\n now\n ]\n );\n\n return { ...agentExecution, created_at: now };\n}\n\nexport async function updateAgentExecution(id: string, updates: Partial): Promise {\n const agentExecution = await getAgentExecution(id);\n if (!agentExecution) return null;\n\n const updatedAgentExecution = { ...agentExecution, ...updates };\n\n await sqlite.execute(\n `UPDATE agent_executions SET status = ?, output = ?, error = ?, tokens_used = ?, thinking_content = ?, started_at = ?, completed_at = ?\n WHERE id = ?`,\n [\n updatedAgentExecution.status,\n updatedAgentExecution.output ? JSON.stringify(updatedAgentExecution.output) : null,\n updatedAgentExecution.error,\n updatedAgentExecution.tokens_used,\n updatedAgentExecution.thinking_content,\n updatedAgentExecution.started_at,\n updatedAgentExecution.completed_at,\n id\n ]\n );\n\n return updatedAgentExecution;\n}\n\nexport async function getAgentExecution(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM agent_executions WHERE id = ?`, [id]);\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n if (rows.length === 0) return null;\n\n const row = rows[0];\n return {\n id: row.id,\n agent_id: row.agent_id,\n execution_id: row.execution_id,\n status: row.status,\n input: JSON.parse(row.input),\n output: row.output ? JSON.parse(row.output) : undefined,\n error: row.error,\n tokens_used: row.tokens_used,\n thinking_content: row.thinking_content,\n started_at: row.started_at,\n completed_at: row.completed_at,\n created_at: row.created_at\n };\n}\n\nexport async function getAgentExecutionsByExecutionId(executionId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM agent_executions WHERE execution_id = ? ORDER BY created_at ASC`,\n [executionId]\n );\n\n const rows = Array.isArray(result) ? result : (result.rows || []);\n \n return rows.map(row => ({\n id: row.id,\n agent_id: row.agent_id,\n execution_id: row.execution_id,\n status: row.status,\n input: JSON.parse(row.input),\n output: row.output ? JSON.parse(row.output) : undefined,\n error: row.error,\n tokens_used: row.tokens_used,\n thinking_content: row.thinking_content,\n started_at: row.started_at,\n completed_at: row.completed_at,\n created_at: row.created_at\n }));\n}","deleted","label",[168,169,149],"backend","database","permalink","https://www.val.town/x/diegoivo/sdkAnthropic/code/backend/database/queries.ts","extension","actionData","errors"]