vrr/eigent
2
0
Fork 0
mirror of https://github.com/eigent-ai/eigent.git synced 2026-05-19 07:59:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

enhance and bug fix

Browse source
This commit is contained in:
Wendong-Fan 2025-11-12 01:34:53 +08:00
parent 8386cea1fa
commit 69e02194db
2 changed files with 29 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/lib/replay.ts
View file

@ -59,10 +59,10 @@ export const replayActiveTask = async (
if (project && project.chatStores) {
Object.entries(project.chatStores).forEach(([chatStoreId, chatStoreData]: [string, any]) => {
const timestamp = project.chatStoreTimestamps[chatStoreId] || 0;
chatStoreData = chatStoreData.getState();
const chatState = chatStoreData.getState();
if (chatStoreData.tasks) {
Object.values(chatStoreData.tasks).forEach((task: any) => {
if (chatState.tasks) {
Object.values(chatState.tasks).forEach((task: any) => {
// Check messages for user content
if (task.messages && task.messages.length > 0) {
const userMessage = task.messages.find((msg: any) => msg.role === 'user');

44
src/store/projectStore.ts
View file

@ -473,27 +473,35 @@ const projectStore = create<ProjectStore>()((set, get) => ({
}
console.log(`[ProjectStore] Created replay project ${replayProjectId} for ${taskIds.length} tasks`);
// For each taskId, create a chat store within the project and call replay
taskIds.forEach(async (taskId, index) => {
console.log(`[ProjectStore] Creating replay for task ${index + 1}/${taskIds.length}: ${taskId}`);
// Create a new chat store for this task
const chatId = createChatStore(replayProjectId, `Task ${taskId}`);
if (chatId) {
const project = get().projects[replayProjectId];
const chatStore = project.chatStores[chatId];
if (chatStore) {
// Call replay on the chat store with the taskId, question, and 0 delay
await chatStore.getState().replay(taskId, question, 0.2);
console.log(`[ProjectStore] Started replay for task ${taskId}`);
// Use for...of loop instead of forEach to properly handle async operations
(async () => {
for (let index = 0; index < taskIds.length; index++) {
const taskId = taskIds[index];
console.log(`[ProjectStore] Creating replay for task ${index + 1}/${taskIds.length}: ${taskId}`);
// Create a new chat store for this task
const chatId = createChatStore(replayProjectId, `Task ${taskId}`);
if (chatId) {
const project = get().projects[replayProjectId];
const chatStore = project.chatStores[chatId];
if (chatStore) {
// Call replay on the chat store with the taskId, question, and 0 delay
try {
await chatStore.getState().replay(taskId, question, 0.2);
console.log(`[ProjectStore] Started replay for task ${taskId}`);
} catch (error) {
console.error(`[ProjectStore] Failed to replay task ${taskId}:`, error);
}
}
}
}
});
console.log(`[ProjectStore] Completed replay setup for ${taskIds.length} tasks`);
console.log(`[ProjectStore] Completed replay setup for ${taskIds.length} tasks`);
})();
return replayProjectId;
},