mirror of
https://github.com/denoland/deno.git
synced 2024-12-29 10:39:10 -05:00
67 lines
1.6 KiB
Rust
67 lines
1.6 KiB
Rust
// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.
|
|
use super::dispatch_json::{JsonOp, Value};
|
|
use crate::ops::json_op;
|
|
use crate::state::State;
|
|
use deno_core::CoreIsolate;
|
|
use deno_core::CoreIsolateState;
|
|
use deno_core::ErrBox;
|
|
use deno_core::ZeroCopyBuf;
|
|
use std::rc::Rc;
|
|
use std::sync::Arc;
|
|
use std::sync::Mutex;
|
|
|
|
pub fn init(
|
|
i: &mut CoreIsolate,
|
|
_s: &Rc<State>,
|
|
response: Arc<Mutex<Option<String>>>,
|
|
) {
|
|
let custom_assets = std::collections::HashMap::new();
|
|
// TODO(ry) use None.
|
|
// TODO(bartlomieju): is this op even required?
|
|
i.register_op(
|
|
"op_fetch_asset",
|
|
crate::op_fetch_asset::op_fetch_asset(custom_assets),
|
|
);
|
|
|
|
i.register_op(
|
|
"op_compiler_respond",
|
|
json_op(compiler_op(response, op_compiler_respond)),
|
|
);
|
|
}
|
|
|
|
pub fn compiler_op<D>(
|
|
response: Arc<Mutex<Option<String>>>,
|
|
dispatcher: D,
|
|
) -> impl Fn(
|
|
&mut deno_core::CoreIsolateState,
|
|
Value,
|
|
&mut [ZeroCopyBuf],
|
|
) -> Result<JsonOp, ErrBox>
|
|
where
|
|
D: Fn(
|
|
Arc<Mutex<Option<String>>>,
|
|
Value,
|
|
&mut [ZeroCopyBuf],
|
|
) -> Result<JsonOp, ErrBox>,
|
|
{
|
|
move |_isolate_state: &mut CoreIsolateState,
|
|
args: Value,
|
|
zero_copy: &mut [ZeroCopyBuf]|
|
|
-> Result<JsonOp, ErrBox> {
|
|
dispatcher(response.clone(), args, zero_copy)
|
|
}
|
|
}
|
|
|
|
fn op_compiler_respond(
|
|
response: Arc<Mutex<Option<String>>>,
|
|
args: Value,
|
|
_zero_copy: &mut [ZeroCopyBuf],
|
|
) -> Result<JsonOp, ErrBox> {
|
|
let mut r = response.lock().unwrap();
|
|
assert!(
|
|
r.is_none(),
|
|
"op_compiler_respond found unexpected existing compiler output"
|
|
);
|
|
*r = Some(args.to_string());
|
|
Ok(JsonOp::Sync(json!({})))
|
|
}
|