#[macro_use]
extern crate gluon_codegen;
extern crate gluon;
#[macro_use]
extern crate gluon_vm;
extern crate env_logger;
#[macro_use]
extern crate serde_derive;
use std::collections::HashMap;
use std::sync::Arc;
use gluon::base::types::ArcType;
use gluon::base::types::{AppVec, Type};
use gluon::vm::api::generic::{A, L, R};
use gluon::vm::api::{
self, ActiveThread, FunctionRef, Getable, Hole, OpaqueRef, OpaqueValue, Pushable,
UserdataValue, ValueRef, VmType, IO,
};
use gluon::vm::{self, ExternModule, Variants};
use gluon::{import, new_vm, Compiler, Result, RootedThread, Thread};
#[derive(Debug, Deserialize, Serialize)]
enum Enum {
A,
B(i32),
C(String, String),
}
impl api::VmType for Enum {
type Type = Self;
fn make_type(thread: &Thread) -> ArcType {
thread
.find_type_info("examples.enum.Enum")
.unwrap()
.clone()
.into_type()
}
}
impl<'vm, 'value> api::Pushable<'vm> for Enum {
fn push(self, context: &mut ActiveThread<'vm>) -> vm::Result<()> {
api::ser::Ser(self).push(context)
}
}
impl<'vm, 'value> api::Getable<'vm, 'value> for Enum {
fn from_value(thread: &'vm Thread, value: vm::Variants<'value>) -> Self {
api::de::De::from_value(thread, value).0
}
}
field_decl! { unwrap_b, value, key }
#[derive(Getable, Pushable, VmType)]
#[gluon(vm_type = "examples.either.Either")]
enum Either<L, R> {
Left(L),
Right(R),
}
fn marshal_enum() -> Result<()> {
let thread = new_vm();
let enum_source = api::typ::make_source::<Enum>(&thread)?;
Compiler::new().load_script(&thread, "examples.enum", &enum_source)?;
let source = r#"
let { Enum } = import! "examples/enum.glu"
let unwrap_b x =
match x with
| B y -> y
| _ -> error "Expected B"
{
unwrap_b,
value = C "hello" "world"
}
"#;
type SourceType<'thread> = record_type! {
unwrap_b => api::FunctionRef<'thread, fn (Enum) -> i32>,
value => Enum
};
let (record_p! { mut unwrap_b, value }, _) =
Compiler::new().run_expr::<SourceType>(&thread, "example", source)?;
match value {
Enum::C(ref a, ref b) => {
assert_eq!(a, "hello");
assert_eq!(b, "world");
println!("`value` evaluated to: {:?}", value)
}
_ => panic!("Unexpected result returned"),
}
let x = unwrap_b.call(Enum::B(123))?;
assert_eq!(x, 123);
println!("`unwrap_b` returned: {}", x);
Ok(())
}
fn marshal_map<I>(iterable: I) -> Result<()>
where
I: IntoIterator<Item = (String, String)>,
{
let thread = new_vm();
Compiler::new().run_expr::<()>(&thread, "example", "let _ = import! std.map in ()")?;
let config_example = r#"
let array = import! std.array
let map @ { Map } = import! std.map
let run config_array =
let f m entry : Map String String -> (String, String) -> _ =
map.insert entry._0 entry._1 m
array.foldable.foldl f map.empty config_array
run
"#;
let mut make_map: FunctionRef<
fn(Vec<(String, String)>) -> OpaqueValue<RootedThread, api::Map<String, String>>,
> = Compiler::new()
.run_expr(&thread, "example", config_example)?
.0;
let entries: Vec<_> = iterable.into_iter().collect();
let map = make_map.call(entries)?;
let config_query_example = r#"
let map = import! std.map
let run config_map =
(map.find "key" config_map, map.find "undefined" config_map)
run
"#;
let mut query_map: FunctionRef<
fn(OpaqueValue<RootedThread, api::Map<String, String>>) -> (Option<String>, Option<String>),
> = Compiler::new()
.run_expr(&thread, "example", config_query_example)?
.0;
let tuple = query_map.call(map)?;
assert_eq!(tuple, (Some("value".to_string()), None));
println!("Querying the map returned: {:?}", tuple);
Ok(())
}
fn flip<'a>(
either: Either<OpaqueRef<'a, L>, OpaqueRef<'a, R>>,
) -> Either<OpaqueRef<'a, R>, OpaqueRef<'a, L>> {
match either {
Either::Left(val) => Either::Right(val),
Either::Right(val) => Either::Left(val),
}
}
fn marshal_generic() -> Result<()> {
let vm = new_vm();
let mut compiler = Compiler::new();
let src = r#"
type Either l r = | Left l | Right r
{ Either }
"#;
fn load_mod(vm: &Thread) -> vm::Result<ExternModule> {
let module = record! {
flip => primitive!(1, flip),
};
ExternModule::new(vm, module)
}
compiler.load_script(&vm, "examples.either", src).unwrap();
import::add_extern_module(&vm, "examples.prim", load_mod);
let script = r#"
let { Either } = import! examples.either
let { flip } = import! examples.prim
let { (<>) } = import! std.semigroup
let io @ { flat_map } = import! std.io
// Either is defined as:
// type Either l r = | Left l | Right r
let either: forall r . Either String r = Left "hello rust!"
// we can pass the generic Either to the Rust function without an issue
seq
match flip either with
| Left _ -> error "unreachable!"
| Right val -> io.println ("Right is: " <> val)
// using an Int instead also works
let either: forall r . Either Int r = Left 42
match flip either with
| Left _ -> error "also unreachable!"
| Right 42 -> io.println "this is the right answer"
| Right _ -> error "wrong answer!"
"#;
compiler
.run_io(true)
.run_expr::<IO<()>>(&vm, "example", script)?;
Ok(())
}
#[derive(Debug)]
struct User<T> {
name: String,
age: u32,
data: T,
}
struct GluonUser<T> {
inner: User<T>,
}
impl<T> VmType for GluonUser<T>
where
T: 'static + VmType,
{
type Type = Self;
fn make_type(vm: &Thread) -> ArcType {
let ty = vm
.find_type_info("examples.wrapper.User")
.expect("Could not find type")
.into_type();
let mut vec = AppVec::new();
vec.push(T::make_type(vm));
Type::app(ty, vec)
}
}
impl<'vm, T> Pushable<'vm> for GluonUser<T>
where
T: Pushable<'vm>,
{
fn push(self, ctx: &mut ActiveThread<'vm>) -> vm::Result<()> {
(record! {
name => self.inner.name,
age => self.inner.age,
data => self.inner.data,
})
.push(ctx)
}
}
impl<'vm, 'value, T> Getable<'vm, 'value> for GluonUser<T>
where
T: Getable<'vm, 'value>,
{
fn from_value(vm: &'vm Thread, data: Variants<'value>) -> GluonUser<T> {
let data = match data.as_ref() {
ValueRef::Data(data) => data,
_ => panic!("Value is not a complex type"),
};
GluonUser {
inner: User {
name: String::from_value(vm, data.lookup_field(vm, "name").unwrap()),
age: u32::from_value(vm, data.lookup_field(vm, "age").unwrap()),
data: T::from_value(vm, data.lookup_field(vm, "data").unwrap()),
},
}
}
}
fn marshal_wrapper() -> Result<()> {
let vm = new_vm();
let mut compiler = Compiler::new();
let src = r#"
type User a = { name: String, age: Int, data: a }
{ User }
"#;
fn load_mod(vm: &Thread) -> vm::Result<ExternModule> {
let module = record! {
roundtrip => primitive!(1, |user: GluonUser<OpaqueValue<RootedThread, A>>| {
println!("name: {}, age: {}", user.inner.name, user.inner.age);
user
}),
};
ExternModule::new(vm, module)
}
compiler.load_script(&vm, "examples.wrapper", src).unwrap();
import::add_extern_module(&vm, "examples.prim", load_mod);
let script = r#"
let { User } = import! examples.wrapper
let { roundtrip } = import! examples.prim
let { assert } = import! std.test
let actual = { name = "Bob", age = 11, data = True }
let expected = roundtrip actual
assert (actual.name == expected.name)
assert (actual.age == expected.age)
assert (actual.data == expected.data)
"#;
compiler.run_expr::<()>(&vm, "example", script)?;
Ok(())
}
#[derive(Userdata, Debug, Clone)]
struct WindowHandle {
id: Arc<u64>,
metadata: Arc<str>,
}
fn load_mod(vm: &gluon::Thread) -> vm::Result<ExternModule> {
vm.register_type::<WindowHandle>("WindowHandle", &[])?;
let module = record! {
create_hwnd => primitive!(2, create_hwnd),
id => primitive!(1, id),
metadata => primitive!(1, metadata),
};
ExternModule::new(vm, module)
}
fn create_hwnd(id: u64, metadata: String) -> WindowHandle {
WindowHandle {
id: Arc::new(id),
metadata: Arc::from(metadata),
}
}
fn id(hwnd: &WindowHandle) -> u64 {
*hwnd.id
}
fn metadata(hwnd: &WindowHandle) -> String {
String::from(&*hwnd.metadata)
}
fn marshal_userdata() -> Result<()> {
let vm = new_vm();
let mut compiler = gluon::Compiler::new();
gluon::import::add_extern_module(&vm, "hwnd", load_mod);
compiler.run_expr::<OpaqueValue<&Thread, Hole>>(&vm, "", "import! hwnd")?;
let script = r#"
let { assert } = import! std.test
let { create_hwnd, id, metadata } = import! hwnd
let hwnd = create_hwnd 0 "Window1"
assert (id hwnd == 0)
assert (metadata hwnd == "Window1")
hwnd
"#;
let (UserdataValue(handle), _) =
compiler.run_expr::<UserdataValue<WindowHandle>>(&vm, "test", script)?;
assert_eq!(*handle.id, 0);
assert_eq!(&*handle.metadata, "Window1");
let (handle, _) =
compiler.run_expr::<OpaqueValue<&Thread, WindowHandle>>(&vm, "test", script)?;
assert_eq!(*handle.id, 0);
assert_eq!(&*handle.metadata, "Window1");
Ok(())
}
fn main() {
env_logger::init();
if let Err(err) = marshal_enum() {
eprintln!("{}", err)
}
let mut map = HashMap::new();
map.insert("key".to_string(), "value".to_string());
map.insert("key2".to_string(), "value2".to_string());
if let Err(err) = marshal_map(map) {
eprintln!("{}", err);
::std::process::exit(1);
}
if let Err(err) = marshal_generic() {
eprintln!("{}", err);
::std::process::exit(1);
}
if let Err(err) = marshal_wrapper() {
eprintln!("{}", err);
::std::process::exit(1);
}
if let Err(err) = marshal_userdata() {
eprintln!("{}", err);
::std::process::exit(1);
}
}