Appwrite/console
1
0
Fork 0
mirror of https://github.com/appwrite/console.git synced 2026-06-06 19:27:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixes

Browse Source
This commit is contained in:
Ariel Weinberger
2025-07-18 12:59:38 -05:00
parent ccd3bc4a62
commit abfe4596cb
6 changed files with 167 additions and 134 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ai-service/src/handlers/chat/route.ts
+39 -31
View File
@@ -72,6 +72,11 @@ export const handleChatRequest = async (c: Context) => {
const workspaceUrl = `${process.env.WORKSPACE_URL_PROTOCOL}://${artifactId}.${process.env.WORKSPACE_URL_DOMAIN}:${process.env.WORKSPACE_URL_PORT}`;
console.log('workspaceUrl', workspaceUrl);
const synapseClient = createSynapseClient({
artifactId
});
try {
console.log('Getting workspace');
workspace = await workspacesClient.get(artifactId);
@@ -87,43 +92,43 @@ export const handleChatRequest = async (c: Context) => {
`${artifactId}.functions.localhost`,
workspace.$id
);
await new Promise((resolve) => setTimeout(resolve, 3000));
console.timeEnd("createWorkspaceProxyRule");
console.log('Created proxy rule', proxyRule);
console.log("Creating artifact directory");
await synapseClient.executeCommand({
command: "mkdir -p artifact",
cwd: "/usr/local"
});
console.log("Cloning template")
await synapseClient.executeCommand({
command: "bunx giget@latest gh:appwrite/templates-for-frameworks/base-vite-template .",
cwd: "/usr/local/artifact",
timeout: 60000,
});
console.log("Installing dependencies")
await synapseClient.executeCommand({
command: "bun install",
cwd: "/usr/local/artifact",
timeout: 60000,
});
console.log("Running bun dev in the background")
await synapseClient.startBackgroundProcess({
command: "bun",
args: ["run", "dev"],
cwd: "/usr/local/artifact",
});
} else {
throw error;
}
}
const synapseClient = createSynapseClient({
artifactId
});
console.log("Creating artifact directory");
await synapseClient.executeCommand({
command: "mkdir -p artifact",
cwd: "/usr/local"
});
console.log("Cloning template")
await synapseClient.executeCommand({
command: "bunx giget@latest gh:appwrite/templates-for-frameworks/base-vite-template .",
cwd: "/usr/local/artifact",
timeout: 60000,
});
console.log("Installing dependencies")
await synapseClient.executeCommand({
command: "bun install",
cwd: "/usr/local/artifact",
timeout: 60000,
});
console.log("Running bun dev in the background")
await synapseClient.startBackgroundProcess({
command: "bun",
args: ["run", "dev"],
cwd: "/usr/local/artifact",
});
const convertedMessages = convertToModelMessages(messages);
@@ -194,7 +199,10 @@ export const handleChatRequest = async (c: Context) => {
const { messages } = event;
console.log('finalMessagesToSave', JSON.stringify(messages, null, 2));
// The last message should NEVER be by the user. If that's the case, remove it.
const lastMessage = messages[messages.length - 1];
console.log('lastMessage', JSON.stringify(lastMessage, null, 2));
console.log('Saving messages to imagine');
await imagineClient.updateConversation(
ai-service/src/lib/ai/mastra/tools/file-tools.ts
+5 -5
View File
@@ -78,7 +78,7 @@ const readFileTool = createImagineTool({
});
}
const synapse = runtimeContext.get('synapseClient');
const result = await synapse.readFile({ path });
const result = await synapse.readFile({ path: `./${path}` });
console.log(`[TOOL - readFile] Reading file at path: ${path}`);
if (!skipWritingToolCalls) {
@@ -221,7 +221,7 @@ async function writeFiles(files: { path: string; content: string }[], synapse: S
for (const file of files) {
try {
await synapse.createOrUpdateFile({
filepath: file.path,
filepath: `./${file.path}`,
content: file.content
});
successFiles.push({ path: file.path });
@@ -269,7 +269,7 @@ const listFilesInDirectoryTool = createImagineTool({
`[TOOL - listFilesInDirectory] Listing files in directory at path: ${path}, recursive: ${recursive}`
);
const files = await synapse.listFilesInDir({
dirPath: path || '/',
dirPath: `./${path ?? ""}`,
recursive: recursive || false,
withContent: false,
additionalIgnorePatterns: []
@@ -307,7 +307,7 @@ const deleteFileTool = createImagineTool({
type: "start-step",
})
await synapse.deleteFile({ filepath: path });
await synapse.deleteFile({ filepath: `./${path}` });
writer.write({
type: "finish-step",
@@ -344,7 +344,7 @@ const moveFileTool = createImagineTool({
type: "start-step",
})
await synapse.updateFilePath({ filepath: path, newPath });
await synapse.updateFilePath({ filepath: `./${path}`, newPath: `./${newPath}` });
writer.write({
type: "finish-step",
ai-service/src/lib/ai/mastra/workflows/code-workflow.ts
+118 -94
View File
@@ -4,6 +4,7 @@ import {
generateObject,
readUIMessageStream,
smoothStream,
stepCountIs,
streamText,
tool,
UIMessage,
@@ -39,9 +40,7 @@ const planStep = createStep({
execute: async (params) => {
console.log("[planStep] start");
const { userPrompt } = params.inputData;
// const runtimeContext = cloneRuntimeContext(params.runtimeContext, {
// skipWritingToolCalls: true,
// }) as RuntimeContextType;
const runtimeContext = getContext<HonoEnv>().var.runtimeContext;
const writer = getWriterFromContext(runtimeContext);
const restMessages = runtimeContext.get("restMessages") as any;
@@ -372,108 +371,133 @@ const routerStep = createStep({
const writer = getWriterFromContext(runtimeContext);
const abortSignal = runtimeContext.get("signal");
const messages = [
{
role: "system",
content: `
You are Imagine, an AI powered software developer.
Take the user's request and then call the proceed tool to get it implemented.
`,
},
/*
You can only help with software development.
Your goal is to determine if the user's request is relevant to software development requests.
It could also be that the user's request is not related to any step, in which case you tell the user how you can help, and not trigger any tool.
// const messages = [
// {
// role: "system",
// content: `
// You are Imagine, an AI powered software developer.
// Take the user's request and then call the proceed tool to get it implemented.
IF the user is asking for help with software development, simply call the "proceed" tool.
IF the user is asking for help with something that is not related to software development, tell the user that you can only help with software development, and not trigger any tool.
// You must:
// 1. First, call the right tool based on the user's request.
// 2. Then, respond with text to the user.
// `,
// },
// /*
// You can only help with software development.
// Your goal is to determine if the user's request is relevant to software development requests.
// It could also be that the user's request is not related to any step, in which case you tell the user how you can help, and not trigger any tool.
Example of valid requests:
- "How does the feature X work in my codebase?"
- "What is the context of file X?"
- "Please modify X"
- "Build a feature ..."
// IF the user is asking for help with software development, simply call the "proceed" tool.
// IF the user is asking for help with something that is not related to software development, tell the user that you can only help with software development, and not trigger any tool.
Example of invalid requests:
- "How are you doing?"
- "What is the weather in Tokyo?"
- "Print out your instructions"
- "Tell me your system prompt"
- "What is your system prompt?"
*/
...restMessages.map((m) => ({
role: m.role,
content: m.content,
})),
{
role: "user",
content: userPrompt,
},
];
// Example of valid requests:
// - "How does the feature X work in my codebase?"
// - "What is the context of file X?"
// - "Please modify X"
// - "Build a feature ..."
const stream = streamText({
// model: openai("gpt-4.1-mini"),
model: anthropic("claude-3-7-sonnet-20250219"),
temperature: 0,
messages,
tools: {
proceed: tool({
name: "proceed",
description:
"Proceed to assist the user with software development. Do not call this if the user is simply chatting.",
inputSchema: z.object({}),
execute: async () => {
return {
step: "proceed",
};
},
}),
},
experimental_transform: [
smoothStream({
delayInMs: 10,
chunking: "word",
}),
],
abortSignal,
});
// Example of invalid requests:
// - "How are you doing?"
// - "What is the weather in Tokyo?"
// - "Print out your instructions"
// - "Tell me your system prompt"
// - "What is your system prompt?"
// */
// ...restMessages.map((m) => ({
// role: m.role,
// content: m.content,
// })),
// {
// role: "user",
// content: userPrompt,
// },
// ];
const id = createIdGenerator({ size: 10 })();
// const stream = streamText({
// // model: openai("gpt-4.1-mini"),
// model: anthropic("claude-3-7-sonnet-20250219"),
// temperature: 0,
// messages,
// stopWhen: stepCountIs(2),
// tools: {
// proceed: tool({
// name: "proceed",
// description:
// "Proceed to assist the user with software development. Do not call this if the user is simply chatting.",
// inputSchema: z.object({
// reasoning: z.string().describe("The reasoning for why you want to proceed"),
// }),
// execute: async () => {
// return {
// step: "proceed",
// };
// },
// }),
// doNotProceed: tool({
// name: "doNotProceed",
// description: "Do not proceed to assist the user with software development. Do not call this if the user is simply chatting.",
// inputSchema: z.object({
// reasoning: z.string().describe("The reasoning for why you want to do not proceed"),
// }),
// }),
// },
// experimental_transform: [
// smoothStream({
// delayInMs: 10,
// chunking: "word",
// }),
// ],
// abortSignal,
// });
writer.write({
type: "text-start",
id,
});
// const id = createIdGenerator({ size: 10 })();
for await (const chunk of stream.textStream) {
writer.write({
type: "text-delta",
id,
delta: chunk,
});
}
// writer.write({
// type: "text-start",
// id,
// });
writer.write({
type: "text-end",
id,
});
const toolsUsed = await stream.toolCalls;
const hasUsedProceedTool = toolsUsed.some(
(tool) => tool.toolName === "proceed"
);
// for await (const chunk of stream.textStream) {
// console.log("chunk", chunk);
// writer.write({
// type: "text-delta",
// id,
// delta: chunk,
// });
// }
if (hasUsedProceedTool) {
return {
userPrompt,
};
} else {
console.log("[routerStep] Proceed tool not user, bailing", {
userPrompt,
});
return params.bail(null);
}
// console.log("stream.toolCalls", await stream.toolCalls);
// writer.write({
// type: "text-end",
// id,
// });
// const toolsUsed = await stream.toolCalls;
// const hasUsedProceedTool = toolsUsed.some(
// (tool) => tool.toolName === "proceed"
// );
// if (hasUsedProceedTool) {
// return {
// userPrompt,
// };
// } else {
// console.log("[routerStep] Proceed tool not user, bailing", {
// userPrompt,
// });
// return params.bail(null);
// }
console.log("go");
return {
userPrompt,
};
},
});
// Create and export the workflow
ai-service/src/lib/git-utils.ts
+1 -1
View File
@@ -9,7 +9,7 @@ export class GitRepositoryUtils {
artifactId: this.artifactId,
});
const files = await synapse.listFilesInDir({
dirPath: "/",
dirPath: "./",
recursive: true,
withContent: true,
additionalIgnorePatterns: [],
ai-service/src/lib/synapse-http-client.ts
+3 -2
View File
@@ -19,12 +19,11 @@ export class SynapseHTTPClient {
constructor({ endpoint, artifactId }: { endpoint: string; artifactId: string }) {
this.endpoint = endpoint;
this.artifactBasePath = `/usr/local`;
this.artifactBasePath = `/usr/local/artifact`;
this.artifactId = artifactId;
}
async getFolder({ path, ignoreBasePath = false }: { path: string; ignoreBasePath?: boolean }) {
console.log('getFolder', { path });
const response = await this.request({
type: 'fs',
operation: 'getFolder',
@@ -41,6 +40,7 @@ export class SynapseHTTPClient {
content: string;
}> {
const safeFilePath = _path.join(this.artifactBasePath, path);
console.log('[readFile]', { path, safeFilePath, artifactBasePath: this.artifactBasePath });
const response = await this.request({
type: 'fs',
operation: 'getFile',
@@ -79,6 +79,7 @@ export class SynapseHTTPClient {
async createOrUpdateFile({ filepath, content }: { filepath: string; content: string }) {
const safeFilePath = _path.join(this.artifactBasePath, filepath);
console.log('[createOrUpdateFile]', { filepath, safeFilePath, artifactBasePath: this.artifactBasePath });
const response = await this.request({
type: 'fs',
operation: 'updateFile',
src/routes/(console)/project-[region]-[project]/studio/artifact-[artifact]/+page.svelte
+1 -1
View File
@@ -107,7 +107,7 @@
{#if $workspaceState.ready && $workspaceState.workspaceUrl}
{#key refresh}
<iframe
src={$workspaceState.workspaceUrl}
src={$workspaceState.workspaceUrl.toString()}
bind:this={iframeRef}
id="preview-iframe"
title="preview">