Update KV value type

Author: max-lt

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "openworkers-runner"
-version = "0.7.1"
+version = "0.7.2"
 edition = "2024"
 default-run = "openworkers-runner"
 
@@ -30,11 +30,11 @@ reqwest = { version = "0.12", default-features = false, features = ["rustls-tls"
 
 # Core types
 # openworkers-core = { path = "../openworkers-core" }
-openworkers-core = { git = "https://github.com/openworkers/openworkers-core", tag = "v0.7.0" }
+openworkers-core = { git = "https://github.com/openworkers/openworkers-core", tag = "v0.7.1" }
 
 # Runtime backend (v8 only for now, others require core 0.5)
 # openworkers-runtime-v8 = { path = "../openworkers-runtime-v8", features = ["actix"], optional = true }
-openworkers-runtime-v8 = { git = "https://github.com/openworkers/openworkers-runtime-v8", tag = "v0.7.1", features = ["actix"], optional = true }
+openworkers-runtime-v8 = { git = "https://github.com/openworkers/openworkers-runtime-v8", tag = "v0.7.2", features = ["actix"], optional = true }
 
 # Database bindings (optional)
 # postgate = { path = "../postgate", default-features = false, optional = true }

Cargo.toml

@@ -454,7 +454,7 @@ impl OperationsHandler for RunnerOperations {
         Box::pin(async move {
             match op {
                 KvOp::Get { key } => {
-                    let result = sqlx::query_scalar::<_, String>(
+                    let result = sqlx::query_scalar::<_, serde_json::Value>(
                         r#"
                         SELECT value FROM kv_data
                         WHERE namespace_id = $1::uuid AND key = $2
@@ -480,6 +480,23 @@ impl OperationsHandler for RunnerOperations {
                     value,
                     expires_in,
                 } => {
+                    // Check value size (100KB limit)
+                    const MAX_VALUE_SIZE: usize = 100 * 1024;
+                    let value_str = match serde_json::to_string(&value) {
+                        Ok(s) => s,
+                        Err(e) => {
+                            return KvResult::Error(format!("Invalid JSON value: {}", e));
+                        }
+                    };
+
+                    if value_str.len() > MAX_VALUE_SIZE {
+                        return KvResult::Error(format!(
+                            "Value too large: {} bytes (max {} bytes)",
+                            value_str.len(),
+                            MAX_VALUE_SIZE
+                        ));
+                    }
+
                     // Calculate expires_at from expires_in (seconds from now)
                     let result = if let Some(ttl) = expires_in {
                         sqlx::query(