fix(agent): pin host-scope resource runtime

Author: fffonion

Cargo.lock

@@ -25,7 +25,7 @@ hyper = { version = "1", features = ["client", "http1"] }
 hyper-util = { version = "0.1", features = ["client-legacy", "http1", "tokio"] }
 parking_lot = "0.12"
 rustls = { version = "0.23", default-features = false, features = ["ring", "std", "tls12"] }
-rustscript-vm = { package = "pd-vm", git = "https://github.com/rustscript-lang/rustscript.git", rev = "fd4b570d08d7cc90cc29e3b05df59c9e9bf3b88e", default-features = false, features = ["runtime", "http-client", "sqlite"] }
+rustscript-vm = { package = "pd-vm", git = "https://github.com/rustscript-lang/rustscript.git", rev = "8763366c4a0d9d43ea9efabf7e8ed08df6ce6d92", default-features = false, features = ["runtime", "http-client", "sqlite"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 tokio = { version = "1", features = ["full"] }

Cargo.toml

@@ -30,7 +30,7 @@ struct AdmissionCreateInput {
     expires_at_ms: int
 }
 
-pub fn storage_admission_create(db_id: int, payload_json: string) -> map {
+pub fn storage_admission_create(db_id: resource<sqlite.connection>, payload_json: string) -> map {
     let input: AdmissionCreateInput = json::decode::<AdmissionCreateInput>(payload_json);
     let mut failed: bool = false;
     let mut failure_code: string = "";
@@ -55,7 +55,7 @@ pub fn storage_admission_create(db_id: int, payload_json: string) -> map {
     if failed == false {
         if input.idempotency_key.copy() != "" {
             let existing: map = sqlite::query(
-                db_id,
+                &db_id,
                 "SELECT scope, key, request_hash, resource_type, resource_id, state, response_json FROM idempotency_records WHERE scope = ? AND key = ? LIMIT 1",
                 [&input.idempotency_scope, &input.idempotency_key],
                 { max_rows: 1, max_result_bytes: 8192 }
@@ -116,12 +116,12 @@ pub fn storage_admission_create(db_id: int, payload_json: string) -> map {
                 sql: "INSERT INTO run_retention (run_id, first_seq, high_water_seq, updated_at_ms) SELECT ?, COALESCE((SELECT MIN(seq) FROM run_events WHERE run_id = ?), 0), COALESCE((SELECT MAX(seq) FROM run_events WHERE run_id = ?), 0), ? WHERE EXISTS (SELECT 1 FROM runs WHERE id = ?) ON CONFLICT (run_id) DO UPDATE SET first_seq = excluded.first_seq, high_water_seq = MAX(run_retention.high_water_seq, excluded.high_water_seq), updated_at_ms = excluded.updated_at_ms",
                 params: [&input.run_id, &input.run_id, &input.run_id, input.now_ms.copy(), &input.run_id]
             };
-            sqlite::transaction(db_id, statements);
+            sqlite::transaction(&db_id, statements);
         }
     }
     let query_run_id: string = if replay => { existing_run_id } else => { input.run_id.copy() };
     let run_result: map = sqlite::query(
-        db_id,
+        &db_id,
         "SELECT id, session_id, parent_run_id, status, input_json, provider, model, script_hash, idempotency_scope, idempotency_key, turn_count, input_tokens, output_tokens, error_code, error_message, recovery_reason, created_at_ms, started_at_ms, finished_at_ms, updated_at_ms FROM runs WHERE id = ? LIMIT 1",
         [&query_run_id],
         { max_rows: 1, max_result_bytes: 65536 }
@@ -141,13 +141,13 @@ pub fn storage_admission_create(db_id: int, payload_json: string) -> map {
         }
     }
     let session_result: map = sqlite::query(
-        db_id,
+        &db_id,
         "SELECT id, profile, platform, account_id, chat_id, thread_id, user_id, generation, status, system_prompt, model, provider, toolset_hash, metadata_json, last_message_seq, created_at_ms, updated_at_ms FROM sessions WHERE id = ? LIMIT 1",
         [&input.session_id],
         { max_rows: 1, max_result_bytes: 65536 }
     );
     let message_result: map = sqlite::query(
-        db_id,
+        &db_id,
         "SELECT id, session_id, ordinal, role, content_json, name, tool_call_id, parent_message_id, token_estimate, compacted, metadata_json, run_id, finish_reason, created_at_ms FROM messages WHERE id = ? AND session_id = ? LIMIT 1",
         [&input.message_id, &input.session_id],
         { max_rows: 1, max_result_bytes: 65536 }
@@ -156,7 +156,7 @@ pub fn storage_admission_create(db_id: int, payload_json: string) -> map {
         { columns: [], rows: [] }
     } else => {
         sqlite::query(
-            db_id,
+            &db_id,
             "SELECT scope, key, request_hash, resource_type, resource_id, state, response_json, created_at_ms, expires_at_ms, completed_at_ms FROM idempotency_records WHERE scope = ? AND key = ? LIMIT 1",
             [&input.idempotency_scope, &input.idempotency_key],
             { max_rows: 1, max_result_bytes: 8192 }