const std = @import("std"); const jv = @import("../jv.zig"); const tokenize = @import("./tokenize.zig").tokenize; const parse = @import("./parse.zig").parse; const Instr = @import("./compile.zig").Instr; const compile = @import("./compile.zig").compile; pub const ExecuteError = error{ Unimplemented, InvalidType, InternalError, } || jv.ops.OpsError; const SaveableStack = @import("./saveable_stack.zig").SaveableStack; const ValueStack = struct { const Self = @This(); const Stack = SaveableStack(jv.Value); stack: Stack, pub fn init(allocator: std.mem.Allocator) !Self { return .{ .stack = try Stack.init(allocator), }; } pub fn deinit(self: *Self) void { self.stack.deinit(); } pub fn push(self: *Self, value: jv.Value) !void { try self.stack.push(value); } pub fn pop(self: *Self) jv.Value { return self.stack.pop(); } pub fn popInteger(self: *Self) ExecuteError!i64 { const value = self.pop(); return switch (value) { .integer => |i| i, else => error.InvalidType, }; } pub fn popNumber(self: *Self) ExecuteError!f64 { const value = self.pop(); return switch (value) { .integer => |i| @floatFromInt(i), .float => |f| f, else => error.InvalidType, }; } pub fn popString(self: *Self) ExecuteError![]const u8 { const value = self.pop(); return switch (value) { .string => |s| s, else => error.InvalidType, }; } pub fn popArray(self: *Self) ExecuteError!jv.Array { const value = self.pop(); return switch (value) { .array => |a| a, else => error.InvalidType, }; } pub fn popObject(self: *Self) ExecuteError!jv.Object { const value = self.pop(); return switch (value) { .object => |o| o, else => error.InvalidType, }; } pub fn dup(self: *Self) !void { const top = self.stack.top().*; try self.push(top); } pub fn swap(self: *Self) !void { std.debug.assert(self.ensureSize(2)); const a = self.pop(); const b = self.pop(); try self.push(a); try self.push(b); } pub fn save(self: *Self) !void { try self.stack.save(); } pub fn restore(self: *Self) void { self.stack.restore(); } pub fn ensureSize(self: *Self, n: usize) bool { return self.stack.ensureSize(n); } }; pub const Runtime = struct { const Self = @This(); allocator: std.mem.Allocator, values: ValueStack, forks: std.ArrayList(usize), instrs: []const Instr, pc: usize, constants: std.ArrayList(jv.Value), pub fn init(allocator: std.mem.Allocator) !Self { return .{ .allocator = allocator, .values = try ValueStack.init(allocator), .forks = .{}, .instrs = &[_]Instr{}, .pc = 0, .constants = .{}, }; } pub fn deinit(self: *Self) void { for (self.constants.items) |*value| { switch (value.*) { .string => |s| self.allocator.free(s), .array => |*a| a.deinit(), .object => |*o| o.deinit(), else => {}, } } self.constants.deinit(self.allocator); self.allocator.free(self.instrs); self.values.deinit(); self.forks.deinit(self.allocator); } pub fn compileFromReader(self: *Self, reader: *std.Io.Reader) !void { std.debug.assert(self.instrs.len == 0); var compile_allocator = std.heap.ArenaAllocator.init(self.allocator); defer compile_allocator.deinit(); const tokens = try tokenize(compile_allocator.allocator(), reader); const ast = try parse(self.allocator, compile_allocator.allocator(), tokens, &self.constants); const instrs = try compile(self.allocator, compile_allocator.allocator(), ast); self.instrs = instrs; // std.debug.print("BEGIN\n", .{}); // for (self.instrs) |instr| { // std.debug.print("{}\n", .{instr}); // } // std.debug.print("END\n", .{}); } pub fn compileFromSlice(self: *Self, query: []const u8) !void { var reader = std.Io.Reader.fixed(query); return self.compileFromReader(&reader); } pub fn start(self: *Self, input: jv.Value) !void { try self.values.push(input); } pub fn next(self: *Self) !?jv.Value { std.debug.assert(self.instrs.len > 0); self.restore_stack(); while (self.pc < self.instrs.len) : (self.pc += 1) { const cur = self.instrs[self.pc]; // std.debug.print("{}\n", .{cur}); switch (cur) { .nop => {}, .ret => { self.pc += 1; return self.values.pop(); }, .jump => |offset| { self.pc += offset - 1; }, .fork => |offset| { try self.save_stack(self.pc + offset); }, .subexp_begin => try self.values.dup(), .subexp_end => try self.values.swap(), .index => { std.debug.assert(self.values.ensureSize(2)); const base = self.values.pop(); const key = self.values.pop(); const result = try jv.ops.index(base, key); try self.values.push(result); }, .index_opt => { std.debug.assert(self.values.ensureSize(2)); const base = self.values.pop(); const key = self.values.pop(); const result = jv.ops.index(base, key) catch .null; try self.values.push(result); }, .add => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = try self.values.popInteger(); const rhs = try self.values.popInteger(); const result = lhs + rhs; try self.values.push(.{ .integer = result }); }, .sub => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = try self.values.popInteger(); const rhs = try self.values.popInteger(); const result = lhs - rhs; try self.values.push(.{ .integer = result }); }, .mul => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = try self.values.popInteger(); const rhs = try self.values.popInteger(); const result = lhs * rhs; try self.values.push(.{ .integer = result }); }, .div => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = try self.values.popInteger(); const rhs = try self.values.popInteger(); const result = @divTrunc(lhs, rhs); try self.values.push(.{ .integer = result }); }, .mod => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = try self.values.popInteger(); const rhs = try self.values.popInteger(); const result = @mod(lhs, rhs); try self.values.push(.{ .integer = result }); }, .eq => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = self.values.pop(); const rhs = self.values.pop(); const result = try jv.ops.compare(lhs, rhs, .eq); try self.values.push(.{ .bool = result }); }, .ne => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = self.values.pop(); const rhs = self.values.pop(); const result = try jv.ops.compare(lhs, rhs, .ne); try self.values.push(.{ .bool = result }); }, .lt => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = self.values.pop(); const rhs = self.values.pop(); const result = try jv.ops.compare(lhs, rhs, .lt); try self.values.push(.{ .bool = result }); }, .gt => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = self.values.pop(); const rhs = self.values.pop(); const result = try jv.ops.compare(lhs, rhs, .gt); try self.values.push(.{ .bool = result }); }, .le => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = self.values.pop(); const rhs = self.values.pop(); const result = try jv.ops.compare(lhs, rhs, .le); try self.values.push(.{ .bool = result }); }, .ge => { std.debug.assert(self.values.ensureSize(3)); _ = self.values.pop(); const lhs = self.values.pop(); const rhs = self.values.pop(); const result = try jv.ops.compare(lhs, rhs, .ge); try self.values.push(.{ .bool = result }); }, .@"const" => |idx| { std.debug.assert(self.values.ensureSize(1)); _ = self.values.pop(); try self.values.push(self.constants.items[@intFromEnum(idx)]); }, } } return null; } fn save_stack(self: *Self, target_pc: usize) !void { try self.forks.append(self.allocator, target_pc); try self.values.save(); } fn restore_stack(self: *Self) void { if (self.forks.pop()) |target_pc| { self.pc = target_pc; self.values.restore(); } } };