mirror of
https://github.com/denoland/deno.git
synced 2024-10-30 09:08:00 -04:00
87 lines
2.3 KiB
Rust
87 lines
2.3 KiB
Rust
// Copyright 2018-2019 the Deno authors. All rights reserved. MIT license.
|
|
use super::dispatch_json::{Deserialize, JsonOp, Value};
|
|
use crate::assets;
|
|
use crate::state::ThreadSafeState;
|
|
use crate::tokio_util;
|
|
use deno::*;
|
|
|
|
#[derive(Deserialize)]
|
|
#[serde(rename_all = "camelCase")]
|
|
struct CacheArgs {
|
|
module_id: String,
|
|
contents: String,
|
|
extension: String,
|
|
}
|
|
|
|
pub fn op_cache(
|
|
state: &ThreadSafeState,
|
|
args: Value,
|
|
_zero_copy: Option<PinnedBuf>,
|
|
) -> Result<JsonOp, ErrBox> {
|
|
let args: CacheArgs = serde_json::from_value(args)?;
|
|
|
|
let module_specifier = ModuleSpecifier::resolve_url(&args.module_id)
|
|
.expect("Should be valid module specifier");
|
|
|
|
state.ts_compiler.cache_compiler_output(
|
|
&module_specifier,
|
|
&args.extension,
|
|
&args.contents,
|
|
)?;
|
|
|
|
Ok(JsonOp::Sync(json!({})))
|
|
}
|
|
|
|
#[derive(Deserialize)]
|
|
struct FetchSourceFileArgs {
|
|
specifier: String,
|
|
referrer: String,
|
|
}
|
|
|
|
pub fn op_fetch_source_file(
|
|
state: &ThreadSafeState,
|
|
args: Value,
|
|
_zero_copy: Option<PinnedBuf>,
|
|
) -> Result<JsonOp, ErrBox> {
|
|
let args: FetchSourceFileArgs = serde_json::from_value(args)?;
|
|
|
|
// TODO(ry) Maybe a security hole. Only the compiler worker should have access
|
|
// to this. Need a test to demonstrate the hole.
|
|
let is_dyn_import = false;
|
|
|
|
let resolved_specifier =
|
|
state.resolve(&args.specifier, &args.referrer, false, is_dyn_import)?;
|
|
|
|
let fut = state
|
|
.file_fetcher
|
|
.fetch_source_file_async(&resolved_specifier);
|
|
|
|
// WARNING: Here we use tokio_util::block_on() which starts a new Tokio
|
|
// runtime for executing the future. This is so we don't inadvernently run
|
|
// out of threads in the main runtime.
|
|
let out = tokio_util::block_on(fut)?;
|
|
Ok(JsonOp::Sync(json!({
|
|
"moduleName": out.url.to_string(),
|
|
"filename": out.filename.to_str().unwrap(),
|
|
"mediaType": out.media_type as i32,
|
|
"sourceCode": String::from_utf8(out.source_code).unwrap(),
|
|
})))
|
|
}
|
|
|
|
#[derive(Deserialize)]
|
|
struct FetchAssetArgs {
|
|
name: String,
|
|
}
|
|
|
|
pub fn op_fetch_asset(
|
|
_state: &ThreadSafeState,
|
|
args: Value,
|
|
_zero_copy: Option<PinnedBuf>,
|
|
) -> Result<JsonOp, ErrBox> {
|
|
let args: FetchAssetArgs = serde_json::from_value(args)?;
|
|
if let Some(source_code) = assets::get_source_code(&args.name) {
|
|
Ok(JsonOp::Sync(json!(source_code)))
|
|
} else {
|
|
panic!("op_fetch_asset bad asset {}", args.name)
|
|
}
|
|
}
|