rsscript: expose http response bytes

Author: Haofei

crates/rsscript/src/reg_vm/mod.rs

@@ -2146,6 +2146,7 @@ enum RegIntrinsic {
     HttpRequestWithHeader,
     HttpRequestWithRetry,
     HttpRequestWithTimeout,
+    HttpResponseBytes,
     HttpResponseIsSuccess,
     HttpResponseLines,
     HttpResponseStatus,
@@ -4248,6 +4249,7 @@ impl RegLowerer<'_> {
                     ("HttpRequest", "with_header") => RegIntrinsic::HttpRequestWithHeader,
                     ("HttpRequest", "with_retry") => RegIntrinsic::HttpRequestWithRetry,
                     ("HttpRequest", "with_timeout") => RegIntrinsic::HttpRequestWithTimeout,
+                    ("HttpResponse", "bytes") => RegIntrinsic::HttpResponseBytes,
                     ("HttpResponse", "is_success") => RegIntrinsic::HttpResponseIsSuccess,
                     ("HttpResponse", "lines") => RegIntrinsic::HttpResponseLines,
                     ("HttpResponse", "status") => RegIntrinsic::HttpResponseStatus,
@@ -9882,6 +9884,12 @@ impl RegVm {
                 request.timeout_ms = timeout_ms;
                 Ok(request.to_value())
             }
+            RegIntrinsic::HttpResponseBytes => {
+                let response = intrinsic_arg(&self.stack, base, args, 0)?;
+                let text = read_field_ref(response, "body")?;
+                let text = expect_string_ref(&text)?;
+                Ok(VmValue::Bytes(Rc::new(text.as_bytes().to_vec())))
+            }
             RegIntrinsic::HttpResponseIsSuccess => {
                 let response = intrinsic_arg(&self.stack, base, args, 0)?;
                 let status = expect_int_ref(&read_field_ref(response, "status")?)?;

crates/rsscript/src/runtime_abi.rs

@@ -734,6 +734,11 @@ const RUNTIME_INTRINSICS: &[RuntimeIntrinsic] = &[
         "is_success",
         "rsscript_runtime::http_response_is_success",
     ),
+    runtime_intrinsic(
+        "HttpResponse",
+        "bytes",
+        "rsscript_runtime::http_response_bytes",
+    ),
     runtime_intrinsic(
         "HttpResponse",
         "lines",

crates/rsscript/tests/vm.rs

@@ -4232,6 +4232,7 @@ async fn main() -> Result<Unit, String> {
     match Http.get(url: read url) {
         Ok(response) => {
             Log.write(message: read HttpResponse.text(response: read response))
+            Log.write(message: read String.from_int(value: Bytes.len(value: read HttpResponse.bytes(response: read response))))
         }
         Err(error) => {
             Log.write(message: read HttpError.message(error: read error))

crates/runtime/src/domain.rs

@@ -745,6 +745,10 @@ pub fn http_response_text(response: &Response) -> String {
     response.body.clone()
 }
 
+pub fn http_response_bytes(response: &Response) -> Vec<u8> {
+    response.body.as_bytes().to_vec()
+}
+
 pub fn http_response_lines(response: &Response) -> Vec<String> {
     response.body.lines().map(str::to_string).collect()
 }

stdlib/http/client.rssi

@@ -42,6 +42,9 @@ pub native fn HttpResponse.status(response: read HttpResponse) -> Int
 pub native fn HttpResponse.text(response: read HttpResponse) -> fresh String
     effects(native)
 
+pub native fn HttpResponse.bytes(response: read HttpResponse) -> fresh Bytes
+    effects(native)
+
 pub native fn HttpResponse.lines(response: read HttpResponse) -> fresh List<String>
     effects(native)