java.rs/src/vm.rs

use std::collections::HashMap;
use std::rc::Rc;
use anyhow::Error;

use crate::opcodes;
use crate::class::{AttributeType, Class, Method, Value};
use crate::classloader::{CpEntry, load_class};
use crate::heap::{Heap, Object};
use crate::io::*;

struct StackFrame {
    data: Vec<Value>,
}

impl StackFrame {
    fn new() -> Self {
        Self {
            data: vec![]
        }
    }

    fn push(&mut self, val: Value) {
        self.data.push(val);
    }

    fn pop(&mut self) -> Option<Value> {
        self.data.pop()
    }
}

pub struct Vm {
    classpath: Vec<String>,
    classes: HashMap<String, Class>,
    //TODO implement classloader
    heap: Heap,
}

impl Vm {
    pub fn new(classpath: &'static str) -> Self {
        Self {
            classpath: classpath.split(":").into_iter().map(|s| s.to_owned()).collect(),
            classes: HashMap::new(),
            heap: Heap::new(),
        }
    }

    pub fn get_class(&mut self, class_name: &str) -> Result<&Class, Error> {
        if !self.classes.contains_key(class_name) {
            self.load_class(class_name)?;
        }
        let class = self.classes.get(class_name);
        Ok(class.expect("ClassNotFoundException"))
    }

    pub fn load_class(&mut self, name: &str) -> Result<(), Error> {
        let resolved_path = find_class(&self.classpath, name)?;
        let bytecode = read_class_file(resolved_path)?;
        self.classes.insert(name.to_owned(), load_class(bytecode)?);
        Ok(())
    }

    pub fn new_instance(&self, class: Rc<Class>) {
        let mut data = HashMap::new();
        for f in &class.fields {
            let value = match f.type_of().as_str() {
                "Z" => Value::BOOL(false),
                "B" => Value::I32(0),
                "S" => Value::I32(0),
                "I" => Value::I32(0),
                "J" => Value::I64(0),
                "F" => Value::F32(0.0),
                "D" => Value::F64(0.0),
                "L" => Value::Null,
                _ => Value::Void
            };
            data.insert(f.name_index, value);
        }
        Object::new(class.clone(), data);
    }

    pub fn execute(&mut self, class_name: &str, method_name: &str) -> Option<Value> {
        let class = self.classes.get(class_name);
        if let Some(c) = class {
            let method = c.get_method(method_name);
            if let AttributeType::Code(code) = method.attributes.get("Code").unwrap() {
                let mut stack = StackFrame::new();
                let mut pc: usize = 0;
                while pc < code.opcodes.len() {
                    let opcode = &code.opcodes[pc];
                    pc += 1;
                    println!("{}", opcode);
                    match opcode {
                        &opcodes::BIPUSH => {
                            let c = code.opcodes[pc] as i32;
                            stack.push(Value::I32(c));
                            pc += 1;
                        }
                        &opcodes::LDC => {
                            let cp_index = read_u8(&code.opcodes, pc) as u16;
                            match method.constant_pool.get(&cp_index).unwrap() {
                                CpEntry::Integer(i) => {
                                    stack.push(Value::I32(*i));
                                }
                                CpEntry::Float(f) => {
                                    stack.push(Value::F32(*f));
                                }
                                _ => {}
                            }
                            pc += 1;
                        }
                        &opcodes::LDC_W => {
                            let cp_index = read_u16(&code.opcodes, pc);
                            match method.constant_pool.get(&cp_index).unwrap() {
                                CpEntry::Integer(i) => {
                                    stack.push(Value::I32(*i));
                                }
                                CpEntry::Float(f) => {
                                    stack.push(Value::F32(*f));
                                }
                                _ => { panic!("unexpected") }
                            }
                            pc += 2;
                        }
                        &opcodes::LDC2_W => {
                            let cp_index = read_u16(&code.opcodes, pc);
                            match method.constant_pool.get(&cp_index).unwrap() {
                                CpEntry::Double(d) => {
                                    stack.push(Value::F64(*d));
                                }
                                CpEntry::Long(l) => {
                                    stack.push(Value::I64(*l));
                                }
                                _ => { panic!("unexpected") }
                            }

                            pc += 2;
                        }
                        &opcodes::ALOAD_0 => {}
                        &opcodes::IRETURN => {
                            return stack.pop();
                        }
                        &opcodes::DRETURN => {
                            return stack.pop();
                        }
                        &opcodes::FRETURN => {
                            return stack.pop();
                        }
                        &opcodes::NEW => {
                            let cp_index = read_u16(&code.opcodes, pc);
                            if let CpEntry::ClassRef(class_name_index) = method.constant_pool.get(&cp_index).unwrap() {
                                if let CpEntry::Utf8(class) = method.constant_pool.get(class_name_index).unwrap() {}
                            }
                        }
                        //TODO implement all opcodes
                        _ => { panic!("opcode not implemented") }
                    }
                }
            }
            None // TODO error situation
        } else {
            panic!("class not found");
        }
    }
}