refactor: simplify package structure by eliminating templates directory

templates/dev.js

@@ -172,7 +172,7 @@ async function callClaude(prdContent, prdPath, numTasks, retryCount = 0) {
     ]
   }`
 
-  let systemPrompt = "You are a helpful assistant that generates tasks from a PRD using the following template: " + TASKS_JSON_TEMPLATE + "ONLY RETURN THE JSON, NOTHING ELSE.";
+  let systemPrompt = "You are a helpful assistant that generates tasks from a PRD using the below json template. You don't worry much about non-task related content, nor do you worry about tasks that don't particularly add value to an mvp. Things like implementing security enhancements, documentation, expansive testing etc are nice to have. The most important is to turn the PRD into a task list that fully materializes the product enough so it can go to market. The JSON template goes as follows -- make sure to only return the json, nothing else: " + TASKS_JSON_TEMPLATE + "ONLY RETURN THE JSON, NOTHING ELSE.";
   
   // Add instruction about the number of tasks if specified
   if (numTasks) {
@@ -275,25 +275,21 @@ async function handleStreamingRequest(prdContent, prdPath, numTasks, maxTokens,
   let fullResponse = '';
   let streamComplete = false;
   let streamError = null;
-  
+  let streamingInterval = null; // Initialize streamingInterval here
+
   try {
     const stream = await anthropic.messages.create({
       max_tokens: maxTokens,
       model: CONFIG.model,
       temperature: CONFIG.temperature,
-      messages: [
-        { 
-          role: "user", 
-          content: prdContent 
-        }
-      ],
+      messages: [{ role: "user", content: prdContent }],
       system: systemPrompt,
       stream: true
     });
     
     // Update loading indicator to show streaming progress
     let dotCount = 0;
-    const streamingInterval = setInterval(() => {
+    streamingInterval = setInterval(() => {
       readline.cursorTo(process.stdout, 0);
       process.stdout.write(`Receiving streaming response from Claude${'.'.repeat(dotCount)}`);
       dotCount = (dotCount + 1) % 4;
@@ -316,7 +312,7 @@ async function handleStreamingRequest(prdContent, prdPath, numTasks, maxTokens,
     
     return processClaudeResponse(fullResponse, numTasks, 0, prdContent, prdPath);
   } catch (error) {
-    clearInterval(streamingInterval);
+    if (streamingInterval) clearInterval(streamingInterval); // Safely clear interval
     stopLoadingIndicator(loadingIndicator);
     log('error', "Error during streaming response:", error);
     throw error;
@@ -432,17 +428,72 @@ async function updateTasks(tasksPath, fromId, prompt) {
     log('error', "Invalid or missing tasks.json.");
     process.exit(1);
   }
+
   log('info', `Updating tasks from ID >= ${fromId} with prompt: ${prompt}`);
 
-  // In real usage, you'd feed data.tasks + prompt to an LLM. We'll just do a naive approach:
-  data.tasks.forEach(task => {
-    if (task.id >= fromId && task.status !== "done") {
-      task.description += ` [UPDATED: ${prompt}]`;
-    }
-  });
+  const tasksToUpdate = data.tasks.filter(task => task.id >= fromId && task.status !== "done");
+  
+  const systemPrompt = "You are a helpful assistant that updates tasks based on provided insights. Return only the updated tasks as a JSON array.";
+  const userPrompt = `Update these tasks based on the following insight: ${prompt}\nTasks: ${JSON.stringify(tasksToUpdate, null, 2)}`;
+  
+  // Start loading indicator
+  const loadingIndicator = startLoadingIndicator("Waiting for Claude to update tasks...");
+  
+  let fullResponse = '';
+  let streamingInterval = null;
 
-  writeJSON(tasksPath, data);
-  log('info', "Tasks updated successfully.");
+  try {
+    const stream = await anthropic.messages.create({
+      max_tokens: CONFIG.maxTokens,
+      model: CONFIG.model,
+      temperature: CONFIG.temperature,
+      messages: [{ role: "user", content: userPrompt }],
+      system: systemPrompt,
+      stream: true
+    });
+    
+    // Update loading indicator to show streaming progress
+    let dotCount = 0;
+    streamingInterval = setInterval(() => {
+      readline.cursorTo(process.stdout, 0);
+      process.stdout.write(`Receiving streaming response from Claude${'.'.repeat(dotCount)}`);
+      dotCount = (dotCount + 1) % 4;
+    }, 500);
+    
+    // Process the stream
+    for await (const chunk of stream) {
+      if (chunk.type === 'content_block_delta' && chunk.delta.text) {
+        fullResponse += chunk.delta.text;
+      }
+    }
+    
+    clearInterval(streamingInterval);
+    stopLoadingIndicator(loadingIndicator);
+    
+    log('info', "Completed streaming response from Claude API!");
+    log('debug', `Streaming response length: ${fullResponse.length} characters`);
+
+    try {
+      const updatedTasks = JSON.parse(fullResponse);
+      
+      data.tasks = data.tasks.map(task => {
+        const updatedTask = updatedTasks.find(t => t.id === task.id);
+        return updatedTask || task;
+      });
+
+      writeJSON(tasksPath, data);
+      log('info', "Tasks updated successfully.");
+    } catch (parseError) {
+      log('error', "Failed to parse Claude's response as JSON:", parseError);
+      log('debug', "Response content:", fullResponse);
+      process.exit(1);
+    }
+  } catch (error) {
+    if (streamingInterval) clearInterval(streamingInterval);
+    stopLoadingIndicator(loadingIndicator);
+    log('error', "Error during streaming response:", error);
+    process.exit(1);
+  }
 }
 
 //