Support pause and continue requests

Author: ddoktorski

src/debugger.rs

@@ -1,4 +1,4 @@
-use anyhow::Result;
+use anyhow::{Result, bail};
 use cairo_vm::vm::vm_core::VirtualMachine;
 
 use crate::connection::Connection;
@@ -33,8 +33,25 @@ impl CairoDebugger {
     }
 
     fn sync(&self, _vm: &VirtualMachine) -> Result<()> {
-        if let Some(request) = self.connection.try_next_request()? {
-            self.handle_request(request)?;
+        if let Some(request) = self.connection.try_next_request()?
+            && let HandleResult::Trigger(NextAction::Stop) = self.handle_request(request)?
+        {
+            self.process_until_resume()?;
+        }
+
+        Ok(())
+    }
+
+    fn process_until_resume(&self) -> Result<()> {
+        loop {
+            let request = self.connection.next_request()?;
+            match self.handle_request(request)? {
+                HandleResult::Trigger(NextAction::Resume) => break,
+                HandleResult::Trigger(NextAction::FinishInit) => {
+                    bail!("Unexpected request received during execution");
+                }
+                HandleResult::Handled | HandleResult::Trigger(NextAction::Stop) => {}
+            }
         }
 
         Ok(())

src/debugger/handler.rs

@@ -2,8 +2,8 @@ use anyhow::{Result, bail};
 use dap::events::{Event, StoppedEventBody};
 use dap::prelude::{Command, Request, ResponseBody};
 use dap::responses::{
-    EvaluateResponse, ScopesResponse, SetBreakpointsResponse, StackTraceResponse, ThreadsResponse,
-    VariablesResponse,
+    ContinueResponse, EvaluateResponse, ScopesResponse, SetBreakpointsResponse, StackTraceResponse,
+    ThreadsResponse, VariablesResponse,
 };
 use dap::types::{Breakpoint, Capabilities, Source, StackFrame, StoppedEventReason, Thread};
 use tracing::trace;
@@ -16,6 +16,8 @@ pub enum HandleResult {
 }
 
 pub enum NextAction {
+    Resume,
+    Stop,
     FinishInit,
 }
 
@@ -94,7 +96,11 @@ impl CairoDebugger {
                 Ok(HandleResult::Trigger(NextAction::FinishInit))
             }
             Command::Continue(_) => {
-                todo!()
+                self.connection.send_success(
+                    request,
+                    ResponseBody::Continue(ContinueResponse { all_threads_continued: Some(true) }),
+                )?;
+                Ok(HandleResult::Trigger(NextAction::Resume))
             }
             Command::Launch(_) => {
                 // Start running the Cairo program here.
@@ -115,7 +121,7 @@ impl CairoDebugger {
                     hit_breakpoint_ids: None,
                 }))?;
                 self.connection.send_success(request, ResponseBody::Pause)?;
-                Ok(HandleResult::Handled)
+                Ok(HandleResult::Trigger(NextAction::Stop))
             }
             Command::SetBreakpoints(args) => {
                 let mut response_bps = Vec::new();