|
| 1 | +use std::collections::HashMap; |
| 2 | +use wasmer::{ |
| 3 | + Function, FunctionEnv, FunctionEnvMut, Instance, Memory, Module, Store, Value, imports, |
| 4 | +}; |
| 5 | + |
| 6 | +struct Ctx { |
| 7 | + kv: HashMap<Vec<u8>, Vec<u8>>, |
| 8 | + mem: Option<Memory>, |
| 9 | +} |
| 10 | + |
| 11 | +/// kp and kl are the key pointer and length in wasm memory, vp and vl are for the return value |
| 12 | +/// if read value is bigger than vl then it will be truncated to vl, returns read bytes |
| 13 | +fn kv_get(mut ctx: FunctionEnvMut<Ctx>, kp: i32, kl: i32, vp: i32, vl: i32) -> i32 { |
| 14 | + let (c, s) = ctx.data_and_store_mut(); |
| 15 | + let mut key = vec![0u8; kl as usize]; |
| 16 | + if c.mem |
| 17 | + .as_ref() |
| 18 | + .unwrap() |
| 19 | + .view(&s) |
| 20 | + .read(kp as u64, &mut key) |
| 21 | + .is_err() |
| 22 | + { |
| 23 | + return -1; |
| 24 | + } |
| 25 | + match c.kv.get(&key) { |
| 26 | + Some(val) => { |
| 27 | + let len = val.len().min(vl as usize); |
| 28 | + if c.mem |
| 29 | + .as_ref() |
| 30 | + .unwrap() |
| 31 | + .view(&s) |
| 32 | + .write(vp as u64, &val[..len]) |
| 33 | + .is_err() |
| 34 | + { |
| 35 | + return -1; |
| 36 | + } |
| 37 | + len as i32 |
| 38 | + } |
| 39 | + None => 0, |
| 40 | + } |
| 41 | +} |
| 42 | + |
| 43 | +/// kp and kl are the key pointer and length in wasm memory, vp and vl are for the value |
| 44 | +fn kv_put(mut ctx: FunctionEnvMut<Ctx>, kp: i32, kl: i32, vp: i32, vl: i32) -> i32 { |
| 45 | + let (c, s) = ctx.data_and_store_mut(); |
| 46 | + let mut key = vec![0u8; kl as usize]; |
| 47 | + let mut val = vec![0u8; vl as usize]; |
| 48 | + let m = c.mem.as_ref().unwrap().view(&s); |
| 49 | + if m.read(kp as u64, &mut key).is_err() || m.read(vp as u64, &mut val).is_err() { |
| 50 | + return -1; |
| 51 | + } |
| 52 | + c.kv.insert(key, val); |
| 53 | + 0 |
| 54 | +} |
| 55 | + |
| 56 | +// // p and l are the buffer pointer and length in wasm memory. |
| 57 | +// fn get_code(mut ctx:FunctionEnvMut<Ctx>, p: i32, l: i32) -> i32 { |
| 58 | +// let file_name = std::env::args().nth(2).expect("file_name is not given"); |
| 59 | +// let code : String = std::fs::read_to_string(file_name).expect("file read failed"); |
| 60 | +// if code.len() > l as usize { |
| 61 | +// eprintln!("code is too long"); |
| 62 | +// return -1; |
| 63 | +// } |
| 64 | + |
| 65 | +// let (c, s) = ctx.data_and_store_mut(); |
| 66 | +// let m = c.mem.as_ref().unwrap().view(&s); |
| 67 | +// if m.write(p as u64, code.as_bytes()).is_err() { |
| 68 | +// return -2; |
| 69 | +// } |
| 70 | + |
| 71 | +// 0 |
| 72 | +// } |
| 73 | + |
| 74 | +// p and l are the message pointer and length in wasm memory. |
| 75 | +fn print(mut ctx: FunctionEnvMut<Ctx>, p: i32, l: i32) -> i32 { |
| 76 | + let (c, s) = ctx.data_and_store_mut(); |
| 77 | + let mut msg = vec![0u8; l as usize]; |
| 78 | + let m = c.mem.as_ref().unwrap().view(&s); |
| 79 | + if m.read(p as u64, &mut msg).is_err() { |
| 80 | + return -1; |
| 81 | + } |
| 82 | + let s = std::str::from_utf8(&msg).expect("print got non-utf8 str"); |
| 83 | + println!("{s}"); |
| 84 | + 0 |
| 85 | +} |
| 86 | + |
| 87 | +fn main() { |
| 88 | + let mut store = Store::default(); |
| 89 | + let module = Module::new( |
| 90 | + &store, |
| 91 | + &std::fs::read(&std::env::args().nth(1).unwrap()).unwrap(), |
| 92 | + ) |
| 93 | + .unwrap(); |
| 94 | + |
| 95 | + // Prepare initial KV store with Python code |
| 96 | + let mut initial_kv = HashMap::new(); |
| 97 | + initial_kv.insert( |
| 98 | + b"code".to_vec(), |
| 99 | + b"a=10;b='str';f'{a}{b}'".to_vec(), // Python code to execute |
| 100 | + ); |
| 101 | + |
| 102 | + let env = FunctionEnv::new( |
| 103 | + &mut store, |
| 104 | + Ctx { |
| 105 | + kv: initial_kv, |
| 106 | + mem: None, |
| 107 | + }, |
| 108 | + ); |
| 109 | + let imports = imports! { |
| 110 | + "env" => { |
| 111 | + "kv_get" => Function::new_typed_with_env(&mut store, &env, kv_get), |
| 112 | + "kv_put" => Function::new_typed_with_env(&mut store, &env, kv_put), |
| 113 | + // "get_code" => Function::new_typed_with_env(&mut store, &env, get_code), |
| 114 | + "print" => Function::new_typed_with_env(&mut store, &env, print), |
| 115 | + } |
| 116 | + }; |
| 117 | + let inst = Instance::new(&mut store, &module, &imports).unwrap(); |
| 118 | + env.as_mut(&mut store).mem = inst.exports.get_memory("memory").ok().cloned(); |
| 119 | + let res = inst |
| 120 | + .exports |
| 121 | + .get_function("eval") |
| 122 | + .unwrap() |
| 123 | + // TODO: actually pass source code |
| 124 | + .call(&mut store, &[wasmer::Value::I32(0), wasmer::Value::I32(0)]) |
| 125 | + .unwrap(); |
| 126 | + println!( |
| 127 | + "Result: {}", |
| 128 | + match res[0] { |
| 129 | + Value::I32(v) => v, |
| 130 | + _ => -1, |
| 131 | + } |
| 132 | + ); |
| 133 | +} |
0 commit comments