1.2.21

Author: acharneski

gradle.properties

@@ -1,5 +1,5 @@
 # Gradle Releases -> https://github.com/gradle/gradle/releases
 libraryGroup=com.simiacryptus.skyenet
-libraryVersion=1.2.20
+libraryVersion=1.2.21
 gradleVersion=7.6.1
 kotlin.daemon.jvmargs=-Xmx4g

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/general/AutoPlanChatApp.kt

@@ -4,7 +4,6 @@ package com.simiacryptus.skyenet.apps.general
 import com.simiacryptus.diff.FileValidationUtils
 import com.simiacryptus.jopenai.ChatClient
 import com.simiacryptus.jopenai.models.ChatModel
-import com.simiacryptus.jopenai.models.TextModel
 import com.simiacryptus.skyenet.core.platform.Session
 import com.simiacryptus.skyenet.set
 import com.simiacryptus.skyenet.webui.session.SessionTask
@@ -98,8 +97,7 @@ class CmdPatchApp(
   }
 
   override fun output(task: SessionTask): OutputResult = run {
-    val command =
-      listOf(settings.executable.absolutePath) + settings.arguments.split(" ").filter(String::isNotBlank)
+    val command = listOf(settings.executable.absolutePath) + settings.arguments.split(" ").filter(String::isNotBlank)
     val processBuilder = ProcessBuilder(command).directory(settings.workingDirectory)
     // Pass the current environment to the subprocess
     processBuilder.environment().putAll(System.getenv())

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/general/CmdPatchApp.kt

@@ -57,14 +57,19 @@ abstract class PatchApp(
     val socketManager = super.newSession(user, session)
     val ui = (socketManager as ApplicationSocketManager).applicationInterface
     val task = ui.newTask()
-    Retryable(
+    lateinit var retry : Retryable
+    var retries = 3
+    retry = Retryable(
       ui = ui,
       task = task,
       process = { content ->
         val newTask = ui.newTask(false)
         newTask.add("Running Command")
         Thread {
-          run(ui, newTask)
+          val result = run(ui, newTask)
+          if (result.exitCode != 0 && retries-- > 0) {
+            retry.retry()
+          }
         }.start()
         newTask.placeholder
       }

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/general/PatchApp.kt

@@ -4,9 +4,8 @@ import com.simiacryptus.jopenai.API
 import com.simiacryptus.jopenai.ChatClient
 import com.simiacryptus.jopenai.OpenAIClient
 import com.simiacryptus.jopenai.models.ChatModel
-import com.simiacryptus.jopenai.models.TextModel
 import com.simiacryptus.skyenet.apps.plan.*
-import com.simiacryptus.skyenet.apps.plan.file.InquiryTask.InquiryTaskData
+import com.simiacryptus.skyenet.apps.plan.file.InquiryTask.InquiryTaskConfigData
 import com.simiacryptus.skyenet.core.platform.Session
 import com.simiacryptus.skyenet.core.platform.model.User
 import com.simiacryptus.skyenet.util.MarkdownUtil
@@ -143,11 +142,11 @@ open class PlanChatApp(
 
   }
 
-  protected open fun addRespondToChatTask(plan: Map<String, PlanTaskBase>): Map<String, PlanTaskBase> {
+  protected open fun addRespondToChatTask(plan: Map<String, TaskConfigBase>): Map<String, TaskConfigBase> {
     val tasksByID = plan?.toMutableMap() ?: mutableMapOf()
     val respondTaskId = "respond_to_chat"
 
-    tasksByID[respondTaskId] = InquiryTaskData(
+    tasksByID[respondTaskId] = InquiryTaskConfigData(
       task_description = "Respond to the user's chat message based on the executed plan",
       task_dependencies = tasksByID.keys.toList()
     )

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/general/PlanChatApp.kt

@@ -9,7 +9,7 @@ import java.io.File
 import java.nio.file.Path
 
 
-abstract class AbstractTask<T : PlanTaskBase>(
+abstract class AbstractTask<T : TaskConfigBase>(
   val planSettings: PlanSettings,
   val planTask: T?
 ) {

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/plan/AbstractTask.kt

@@ -6,7 +6,7 @@ import com.simiacryptus.jopenai.describe.Description
 import com.simiacryptus.skyenet.Retryable
 import com.simiacryptus.skyenet.apps.general.CmdPatchApp
 import com.simiacryptus.skyenet.apps.general.PatchApp
-import com.simiacryptus.skyenet.apps.plan.CommandAutoFixTask.CommandAutoFixTaskData
+import com.simiacryptus.skyenet.apps.plan.CommandAutoFixTask.CommandAutoFixTaskConfigData
 import com.simiacryptus.skyenet.util.MarkdownUtil
 import com.simiacryptus.skyenet.webui.session.SessionTask
 import org.slf4j.LoggerFactory
@@ -16,16 +16,16 @@ import java.util.concurrent.atomic.AtomicBoolean
 
 class CommandAutoFixTask(
   planSettings: PlanSettings,
-  planTask: CommandAutoFixTaskData?
-) : AbstractTask<CommandAutoFixTaskData>(planSettings, planTask) {
+  planTask: CommandAutoFixTaskConfigData?
+) : AbstractTask<CommandAutoFixTaskConfigData>(planSettings, planTask) {
 
-  class CommandAutoFixTaskData(
+  class CommandAutoFixTaskConfigData(
     @Description("The commands to be executed with their respective working directories")
     val commands: List<CommandWithWorkingDir>? = null,
     task_description: String? = null,
     task_dependencies: List<String>? = null,
     state: TaskState? = null
-  ) : PlanTaskBase(
+  ) : TaskConfigBase(
     task_type = TaskType.CommandAutoFix.name,
     task_description = task_description,
     task_dependencies = task_dependencies,
@@ -64,7 +64,7 @@ ${planSettings.commandAutoFixCommands?.joinToString("\n") { "    * ${File(it).na
     val semaphore = Semaphore(0)
     val hasError = AtomicBoolean(false)
     val onComplete = { semaphore.release() }
-    lateinit var retryable: Retryable
+    var retryable: Retryable? = null
     retryable = Retryable(agent.ui, task = task) {
       val task = agent.ui.newTask(false).apply { it.append(placeholder) }
       this.planTask?.commands?.forEachIndexed { index, commandWithDir ->
@@ -137,7 +137,7 @@ ${planSettings.commandAutoFixCommands?.joinToString("\n") { "    * ${File(it).na
           ) {
             onComplete()
           }
-          if(autoRetries-- > 0) retryable.retry()
+          if(autoRetries-- > 0) retryable?.retry()
           s
         })
       task.placeholder

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/plan/CommandAutoFixTask.kt

@@ -3,7 +3,6 @@ package com.simiacryptus.skyenet.apps.plan
 import com.simiacryptus.jopenai.ChatClient
 import com.simiacryptus.jopenai.OpenAIClient
 import com.simiacryptus.jopenai.describe.Description
-import com.simiacryptus.skyenet.core.platform.ApplicationServices
 import com.simiacryptus.skyenet.webui.session.SessionTask
 import org.slf4j.LoggerFactory
 import java.io.BufferedReader
@@ -14,8 +13,8 @@ import java.util.concurrent.TimeUnit
 
 class CommandSessionTask(
     planSettings: PlanSettings,
-    planTask: CommandSessionTaskData?
-) : AbstractTask<CommandSessionTask.CommandSessionTaskData>(planSettings, planTask) {
+    planTask: CommandSessionTaskConfigData?
+) : AbstractTask<CommandSessionTask.CommandSessionTaskConfigData>(planSettings, planTask) {
     companion object {
         private val log = LoggerFactory.getLogger(CommandSessionTask::class.java)
         private val activeSessions = ConcurrentHashMap<String, Process>()
@@ -68,7 +67,7 @@ class CommandSessionTask(
         fun getActiveSessionCount(): Int = activeSessions.size
     }
 
-    class CommandSessionTaskData(
+    class CommandSessionTaskConfigData(
         @Description("The command to start the interactive session")
         val command: List<String>,
         @Description("Commands to send to the interactive session")
@@ -82,7 +81,7 @@ class CommandSessionTask(
         task_description: String? = null,
         task_dependencies: List<String>? = null,
         state: TaskState? = null,
-    ) : PlanTaskBase(
+    ) : TaskConfigBase(
         task_type = TaskType.CommandSession.name,
         task_description = task_description,
         task_dependencies = task_dependencies,
@@ -175,7 +174,7 @@ class CommandSessionTask(
     }
 
     private fun formatResults(
-        planTask: CommandSessionTaskData,
+        planTask: CommandSessionTaskConfigData,
         results: List<String>
     ): String = buildString {
         appendLine("## Command Session Results")

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/plan/CommandSessionTask.kt

@@ -3,26 +3,26 @@ package com.simiacryptus.skyenet.apps.plan
 import com.simiacryptus.jopenai.ChatClient
 import com.simiacryptus.jopenai.OpenAIClient
 import com.simiacryptus.jopenai.describe.Description
-import com.simiacryptus.skyenet.apps.plan.ForeachTask.ForeachTaskData
+import com.simiacryptus.skyenet.apps.plan.ForeachTask.ForeachTaskConfigData
 import com.simiacryptus.skyenet.apps.plan.PlanUtil.diagram
 import com.simiacryptus.skyenet.apps.plan.PlanUtil.executionOrder
 import com.simiacryptus.skyenet.webui.session.SessionTask
 import org.slf4j.LoggerFactory
 
 class ForeachTask(
   planSettings: PlanSettings,
-  planTask: ForeachTaskData?
-) : AbstractTask<ForeachTaskData>(planSettings, planTask) {
+  planTask: ForeachTaskConfigData?
+) : AbstractTask<ForeachTaskConfigData>(planSettings, planTask) {
 
-  class ForeachTaskData(
-    @Description("A list of items over which the ForEach task will iterate. (Only applicable for ForeachTask tasks) Can be used to process outputs from previous tasks.")
+  class ForeachTaskConfigData(
+      @Description("A list of items over which the ForEach task will iterate. (Only applicable for ForeachTask tasks) Can be used to process outputs from previous tasks.")
     val foreach_items: List<String>? = null,
-    @Description("A map of sub-task IDs to PlanTask objects to be executed for each item. (Only applicable for ForeachTask tasks) Allows for complex task dependencies and information flow within iterations.")
-    val foreach_subplan: Map<String, PlanTaskBase>? = null,
-    task_description: String? = null,
-    task_dependencies: List<String>? = null,
-    state: TaskState? = null,
-  ) : PlanTaskBase(
+      @Description("A map of sub-task IDs to PlanTask objects to be executed for each item. (Only applicable for ForeachTask tasks) Allows for complex task dependencies and information flow within iterations.")
+    val foreach_subplan: Map<String, TaskConfigBase>? = null,
+      task_description: String? = null,
+      task_dependencies: List<String>? = null,
+      state: TaskState? = null,
+  ) : TaskConfigBase(
     task_type = TaskType.ForeachTask.name,
     task_description = task_description,
     task_dependencies = task_dependencies,

webui/src/main/kotlin/com/simiacryptus/skyenet/apps/plan/ForeachTask.kt

@@ -15,9 +15,9 @@ import java.net.http.HttpResponse
 
 class GitHubSearchTask(
   planSettings: PlanSettings,
-  planTask: GitHubSearchTaskData?
-) : AbstractTask<GitHubSearchTask.GitHubSearchTaskData>(planSettings, planTask) {
-  class GitHubSearchTaskData(
+  planTask: GitHubSearchTaskConfigData?
+) : AbstractTask<GitHubSearchTask.GitHubSearchTaskConfigData>(planSettings, planTask) {
+  class GitHubSearchTaskConfigData(
     @Description("The search query to use for GitHub search")
     val search_query: String,
     @Description("The type of GitHub search to perform (code, commits, issues, repositories, topics, users)")
@@ -31,7 +31,7 @@ class GitHubSearchTask(
     task_description: String? = null,
     task_dependencies: List<String>? = null,
     state: TaskState? = null,
-  ) : PlanTaskBase(
+  ) : TaskConfigBase(
     task_type = TaskType.GitHubSearch.name,
     task_description = task_description,
     task_dependencies = task_dependencies,