Feat/continue command

packages/opencode/src/cli/cmd/tui/component/prompt/autocomplete.tsx

@@ -271,6 +271,11 @@ export function Autocomplete(props: {
           description: "toggle thinking visibility",
           onSelect: () => command.trigger("session.toggle.thinking"),
         },
+        {
+          display: "/continue",
+          description: "continue interrupted conversation",
+          onSelect: () => command.trigger("session.continue"),
+        },
       )
       if (sync.data.config.share !== "disabled") {
         results.push({
@@ -301,7 +306,7 @@ export function Autocomplete(props: {
       },
       {
         display: "/session",
-        aliases: ["/resume", "/continue"],
+        aliases: ["/resume"],
         description: "list sessions",
         onSelect: () => command.trigger("session.list"),
       },

packages/opencode/src/cli/cmd/tui/routes/session/index.tsx

@@ -388,6 +388,23 @@ export function Session() {
         })
       },
     },
+    {
+      title: "Continue interrupted conversation",
+      value: "session.continue",
+      keybind: "session_continue",
+      category: "Session",
+      onSelect: async (dialog) => {
+        const result = await sdk.client.session.continue({
+          sessionID: route.sessionID,
+        })
+
+        if (result.data) {
+          toBottom()
+        } else {
+          dialog.clear()
+        }
+      },
+    },
     {
       title: sidebarVisible() ? "Hide sidebar" : "Show sidebar",
       value: "session.sidebar.toggle",

packages/opencode/src/server/server.ts

@@ -1373,6 +1373,49 @@ export namespace Server {
           return c.json(session)
         },
       )
+      .post(
+        "/session/:sessionID/continue",
+        describeRoute({
+          description: "Continue interrupted conversation",
+          operationId: "session.continue",
+          responses: {
+            200: {
+              description: "Conversation continued",
+              content: {
+                "application/json": {
+                  schema: resolver(z.boolean()),
+                },
+              },
+            },
+            ...errors(400, 404),
+          },
+        }),
+        validator(
+          "param",
+          z.object({
+            sessionID: z.string(),
+          }),
+        ),
+        async (c) => {
+          const sessionID = c.req.valid("param").sessionID
+
+          // Check if there's a user message to continue from
+          const msgs = await Session.messages({ sessionID })
+          const hasUserMessage = msgs.some((m) => m.info.role === "user")
+          if (!hasUserMessage) {
+            return c.json(false)
+          }
+
+          // Cancel any existing session state to ensure clean start
+          SessionPrompt.cancel(sessionID)
+
+          // Start conversation loop - it will continue from where it left off
+          // The loop handles incomplete assistant messages automatically
+          SessionPrompt.loop(sessionID)
+
+          return c.json(true)
+        },
+      )
       .post(
         "/session/:sessionID/permissions/:permissionID",
         describeRoute({

packages/opencode/test/session/session.test.ts

@@ -68,4 +68,22 @@ describe("session.started event", () => {
       },
     })
   })
+
+  describe("session continue functionality", () => {
+    test("should identify unfinished assistant messages correctly", async () => {
+      await Instance.provide({
+        directory: projectRoot,
+        fn: async () => {
+          // Create a session
+          const session = await Session.create({})
+
+          // Test that empty session has no messages
+          const emptyMsgs = await Session.messages({ sessionID: session.id })
+          expect(emptyMsgs).toEqual([])
+
+          await Session.remove(session.id)
+        },
+      })
+    })
+  })
 })

packages/sdk/js/src/gen/sdk.gen.ts

@@ -109,6 +109,9 @@ import type {
   SessionUnrevertData,
   SessionUnrevertResponses,
   SessionUnrevertErrors,
+  SessionContinueData,
+  SessionContinueResponses,
+  SessionContinueErrors,
   PostSessionIdPermissionsPermissionIdData,
   PostSessionIdPermissionsPermissionIdResponses,
   PostSessionIdPermissionsPermissionIdErrors,
@@ -698,6 +701,16 @@ class Session extends _HeyApiClient {
       ...options,
     })
   }
+
+  /**
+   * Continue interrupted conversation
+   */
+  public continue<ThrowOnError extends boolean = false>(options: Options<SessionContinueData, ThrowOnError>) {
+    return (options.client ?? this._client).post<SessionContinueResponses, SessionContinueErrors, ThrowOnError>({
+      url: "/session/{id}/continue",
+      ...options,
+    })
+  }
 }
 
 class Command extends _HeyApiClient {

packages/sdk/js/src/gen/types.gen.ts

@@ -2859,6 +2859,39 @@ export type SessionUnrevertResponses = {
 
 export type SessionUnrevertResponse = SessionUnrevertResponses[keyof SessionUnrevertResponses]
 
+export type SessionContinueData = {
+  body?: never
+  path: {
+    id: string
+  }
+  query?: {
+    directory?: string
+  }
+  url: "/session/{id}/continue"
+}
+
+export type SessionContinueErrors = {
+  /**
+   * Bad request
+   */
+  400: BadRequestError
+  /**
+   * Not found
+   */
+  404: NotFoundError
+}
+
+export type SessionContinueError = SessionContinueErrors[keyof SessionContinueErrors]
+
+export type SessionContinueResponses = {
+  /**
+   * Conversation continued
+   */
+  200: boolean
+}
+
+export type SessionContinueResponse = SessionContinueResponses[keyof SessionContinueResponses]
+
 export type PostSessionIdPermissionsPermissionIdData = {
   body?: {
     response: "once" | "always" | "reject"

packages/sdk/js/src/v2/gen/sdk.gen.ts

@@ -77,6 +77,8 @@ import type {
   SessionChildrenResponses,
   SessionCommandErrors,
   SessionCommandResponses,
+  SessionContinueErrors,
+  SessionContinueResponses,
   SessionCreateErrors,
   SessionCreateResponses,
   SessionDeleteErrors,
@@ -1484,6 +1486,34 @@ export class Session extends HeyApiClient {
       ...params,
     })
   }
+
+  /**
+   * Continue interrupted conversation
+   */
+  public continue<ThrowOnError extends boolean = false>(
+    parameters: {
+      sessionID: string
+      directory?: string
+    },
+    options?: Options<never, ThrowOnError>,
+  ) {
+    const params = buildClientParams(
+      [parameters],
+      [
+        {
+          args: [
+            { in: "path", key: "sessionID" },
+            { in: "query", key: "directory" },
+          ],
+        },
+      ],
+    )
+    return (options?.client ?? this.client).post<SessionContinueResponses, SessionContinueErrors, ThrowOnError>({
+      url: "/session/{sessionID}/continue",
+      ...options,
+      ...params,
+    })
+  }
 }
 
 export class Permission extends HeyApiClient {

packages/sdk/js/src/v2/gen/types.gen.ts

@@ -3089,6 +3089,39 @@ export type SessionUnrevertResponses = {
 
 export type SessionUnrevertResponse = SessionUnrevertResponses[keyof SessionUnrevertResponses]
 
+export type SessionContinueData = {
+  body?: never
+  path: {
+    sessionID: string
+  }
+  query?: {
+    directory?: string
+  }
+  url: "/session/{sessionID}/continue"
+}
+
+export type SessionContinueErrors = {
+  /**
+   * Bad request
+   */
+  400: BadRequestError
+  /**
+   * Not found
+   */
+  404: NotFoundError
+}
+
+export type SessionContinueError = SessionContinueErrors[keyof SessionContinueErrors]
+
+export type SessionContinueResponses = {
+  /**
+   * Conversation continued
+   */
+  200: boolean
+}
+
+export type SessionContinueResponse = SessionContinueResponses[keyof SessionContinueResponses]
+
 export type PermissionRespondData = {
   body?: {
     response: "once" | "always" | "reject"