use crate::encoding::{Instance, Item, LibraryInfo, MainOrAdapter};
use crate::ComponentEncoder;
use anyhow::{bail, Context, Result};
use indexmap::{map::Entry, IndexMap, IndexSet};
use std::mem;
use wasm_encoder::ExportKind;
use wasmparser::names::{ComponentName, ComponentNameKind};
use wasmparser::{
types::TypesRef, Encoding, ExternalKind, FuncType, Parser, Payload, TypeRef, ValType,
ValidPayload, Validator,
};
use wit_parser::{
abi::{AbiVariant, WasmSignature, WasmType},
Function, InterfaceId, PackageName, Resolve, TypeDefKind, TypeId, WorldId, WorldItem, WorldKey,
};
fn wasm_sig_to_func_type(signature: WasmSignature) -> FuncType {
fn from_wasm_type(ty: &WasmType) -> ValType {
match ty {
WasmType::I32 => ValType::I32,
WasmType::I64 => ValType::I64,
WasmType::F32 => ValType::F32,
WasmType::F64 => ValType::F64,
WasmType::Pointer => ValType::I32,
WasmType::PointerOrI64 => ValType::I64,
WasmType::Length => ValType::I32,
}
}
FuncType::new(
signature.params.iter().map(from_wasm_type),
signature.results.iter().map(from_wasm_type),
)
}
#[derive(Default)]
pub struct ValidatedModule {
pub imports: ImportMap,
pub exports: ExportMap,
}
impl ValidatedModule {
fn new(
encoder: &ComponentEncoder,
bytes: &[u8],
exports: &IndexSet<WorldKey>,
info: Option<&LibraryInfo>,
) -> Result<ValidatedModule> {
let mut validator = Validator::new();
let mut ret = ValidatedModule::default();
for payload in Parser::new(0).parse_all(bytes) {
let payload = payload?;
if let ValidPayload::End(_) = validator.payload(&payload)? {
break;
}
let types = validator.types(0).unwrap();
match payload {
Payload::Version { encoding, .. } if encoding != Encoding::Module => {
bail!("data is not a WebAssembly module");
}
Payload::ImportSection(s) => {
for import in s {
let import = import?;
ret.imports.add(import, encoder, info, types)?;
}
}
Payload::ExportSection(s) => {
for export in s {
let export = export?;
ret.exports.add(export, encoder, &exports, types)?;
}
}
_ => continue,
}
}
ret.exports.validate(encoder, exports)?;
Ok(ret)
}
}
#[derive(Default)]
pub struct ImportMap {
names: IndexMap<String, ImportInstance>,
}
pub enum ImportInstance {
Whole(MainOrAdapter),
Names(IndexMap<String, Import>),
}
#[derive(Debug, Clone)]
pub enum Import {
WorldFunc(WorldKey, String),
InterfaceFunc(WorldKey, InterfaceId, String),
ImportedResourceDrop(WorldKey, Option<InterfaceId>, TypeId),
ExportedResourceDrop(WorldKey, TypeId),
ExportedResourceNew(WorldKey, TypeId),
ExportedResourceRep(WorldKey, TypeId),
AdapterExport(FuncType),
MainModuleMemory,
MainModuleExport { name: String, kind: ExportKind },
Item(Item),
}
impl ImportMap {
pub fn uses_toplevel_func(&self, func: &str) -> bool {
self.imports().any(|(_, _, item)| match item {
Import::WorldFunc(_, name) => func == name,
_ => false,
})
}
pub fn uses_interface_func(&self, interface: InterfaceId, func: &str) -> bool {
self.imports().any(|(_, _, import)| match import {
Import::InterfaceFunc(_, id, name) => *id == interface && name == func,
_ => false,
})
}
pub fn uses_imported_resource_drop(&self, resource: TypeId) -> bool {
self.imports().any(|(_, _, import)| match import {
Import::ImportedResourceDrop(_, _, id) => resource == *id,
_ => false,
})
}
pub fn required_from_adapter(&self, name: &str) -> IndexMap<String, FuncType> {
let names = match self.names.get(name) {
Some(ImportInstance::Names(names)) => names,
_ => return IndexMap::new(),
};
names
.iter()
.map(|(name, import)| {
(
name.clone(),
match import {
Import::AdapterExport(ty) => ty.clone(),
_ => unreachable!(),
},
)
})
.collect()
}
pub fn imports(&self) -> impl Iterator<Item = (&str, &str, &Import)> + '_ {
self.names
.iter()
.filter_map(|(module, m)| match m {
ImportInstance::Names(names) => Some((module, names)),
ImportInstance::Whole(_) => None,
})
.flat_map(|(module, m)| {
m.iter()
.map(move |(field, import)| (module.as_str(), field.as_str(), import))
})
}
pub fn modules(&self) -> &IndexMap<String, ImportInstance> {
&self.names
}
fn add(
&mut self,
import: wasmparser::Import<'_>,
encoder: &ComponentEncoder,
library_info: Option<&LibraryInfo>,
types: TypesRef<'_>,
) -> Result<()> {
if self.classify_import_with_library(import, library_info)? {
return Ok(());
}
let item = self.classify(import, encoder, types).with_context(|| {
format!(
"failed to resolve import `{}::{}`",
import.module, import.name,
)
})?;
self.insert_import(import, item)
}
fn classify(
&self,
import: wasmparser::Import<'_>,
encoder: &ComponentEncoder,
types: TypesRef<'_>,
) -> Result<Import> {
if import.module == "env" && import.name == "memory" {
return Ok(Import::MainModuleMemory);
}
if import.module == "__main_module__" {
return Ok(Import::MainModuleExport {
name: import.name.to_string(),
kind: match import.ty {
TypeRef::Func(_) => ExportKind::Func,
TypeRef::Table(_) => ExportKind::Table,
TypeRef::Memory(_) => ExportKind::Memory,
TypeRef::Global(_) => ExportKind::Global,
TypeRef::Tag(_) => ExportKind::Tag,
},
});
}
let ty_index = match import.ty {
TypeRef::Func(ty) => ty,
_ => bail!("module is only allowed to import functions"),
};
let ty = types[types.core_type_at_in_module(ty_index)].unwrap_func();
if encoder.adapters.contains_key(import.module) {
return Ok(Import::AdapterExport(ty.clone()));
}
let (module, names) = match import.module.strip_prefix("cm32p2") {
Some(suffix) => (suffix, STANDARD),
None if encoder.reject_legacy_names => (import.module, STANDARD),
None => (import.module, LEGACY),
};
self.classify_component_model_import(module, import.name, encoder, ty, names)
}
fn classify_component_model_import(
&self,
module: &str,
name: &str,
encoder: &ComponentEncoder,
ty: &FuncType,
names: &dyn NameMangling,
) -> Result<Import> {
let resolve = &encoder.metadata.resolve;
let world_id = encoder.metadata.world;
let world = &resolve.worlds[world_id];
if module == names.import_root() {
let key = WorldKey::Name(name.to_string());
if let Some(WorldItem::Function(func)) = world.imports.get(&key) {
validate_func(resolve, ty, func, AbiVariant::GuestImport)?;
return Ok(Import::WorldFunc(key, func.name.clone()));
}
let get_resource = resource_test_for_world(resolve, world_id);
if let Some(resource) = names.resource_drop_name(name) {
if let Some(id) = get_resource(resource) {
let expected = FuncType::new([ValType::I32], []);
validate_func_sig(name, &expected, ty)?;
return Ok(Import::ImportedResourceDrop(key, None, id));
}
}
match world.imports.get(&key) {
Some(_) => bail!("expected world top-level import `{name}` to be a function"),
None => bail!("no top-level imported function `{name}` specified"),
}
}
let interface = match module.strip_prefix(names.import_non_root_prefix()) {
Some(name) => name,
None => bail!("unknown or invalid component model import syntax"),
};
if let Some(interface) = interface.strip_prefix(names.import_exported_intrinsic_prefix()) {
let (key, id) = names.module_to_interface(interface, resolve, &world.exports)?;
let get_resource = resource_test_for_interface(resolve, id);
if let Some(name) = names.resource_drop_name(name) {
if let Some(id) = get_resource(name) {
let expected = FuncType::new([ValType::I32], []);
validate_func_sig(name, &expected, ty)?;
return Ok(Import::ExportedResourceDrop(key, id));
}
}
if let Some(name) = names.resource_new_name(name) {
if let Some(id) = get_resource(name) {
let expected = FuncType::new([ValType::I32], [ValType::I32]);
validate_func_sig(name, &expected, ty)?;
return Ok(Import::ExportedResourceNew(key, id));
}
}
if let Some(name) = names.resource_rep_name(name) {
if let Some(id) = get_resource(name) {
let expected = FuncType::new([ValType::I32], [ValType::I32]);
validate_func_sig(name, &expected, ty)?;
return Ok(Import::ExportedResourceRep(key, id));
}
}
bail!("unknown function `{name}`")
}
let (key, id) = names.module_to_interface(interface, resolve, &world.imports)?;
let interface = &resolve.interfaces[id];
let get_resource = resource_test_for_interface(resolve, id);
if let Some(f) = interface.functions.get(name) {
validate_func(resolve, ty, f, AbiVariant::GuestImport).with_context(|| {
let name = resolve.name_world_key(&key);
format!("failed to validate import interface `{name}`")
})?;
return Ok(Import::InterfaceFunc(key, id, f.name.clone()));
} else if let Some(resource) = names.resource_drop_name(name) {
if let Some(resource) = get_resource(resource) {
let expected = FuncType::new([ValType::I32], []);
validate_func_sig(name, &expected, ty)?;
return Ok(Import::ImportedResourceDrop(key, Some(id), resource));
}
}
bail!(
"import interface `{module}` is missing function \
`{name}` that is required by the module",
)
}
fn classify_import_with_library(
&mut self,
import: wasmparser::Import<'_>,
library_info: Option<&LibraryInfo>,
) -> Result<bool> {
let info = match library_info {
Some(info) => info,
None => return Ok(false),
};
let Some((_, instance)) = info
.arguments
.iter()
.find(|(name, _items)| *name == import.module)
else {
return Ok(false);
};
match instance {
Instance::MainOrAdapter(module) => match self.names.get(import.module) {
Some(ImportInstance::Whole(which)) => {
if which != module {
bail!("different whole modules imported under the same name");
}
}
Some(ImportInstance::Names(_)) => {
bail!("cannot mix individual imports and whole module imports")
}
None => {
let instance = ImportInstance::Whole(module.clone());
self.names.insert(import.module.to_string(), instance);
}
},
Instance::Items(items) => {
let Some(item) = items.iter().find(|i| i.alias == import.name) else {
return Ok(false);
};
self.insert_import(import, Import::Item(item.clone()))?;
}
}
Ok(true)
}
fn insert_import(&mut self, import: wasmparser::Import<'_>, item: Import) -> Result<()> {
let entry = self
.names
.entry(import.module.to_string())
.or_insert(ImportInstance::Names(IndexMap::default()));
let names = match entry {
ImportInstance::Names(names) => names,
_ => bail!("cannot mix individual imports with module imports"),
};
let entry = match names.entry(import.name.to_string()) {
Entry::Occupied(_) => {
bail!(
"module has duplicate import for `{}::{}`",
import.module,
import.name
);
}
Entry::Vacant(v) => v,
};
log::trace!(
"classifying import `{}::{} as {item:?}",
import.module,
import.name
);
entry.insert(item);
Ok(())
}
}
#[derive(Default)]
pub struct ExportMap {
names: IndexMap<String, Export>,
raw_exports: IndexMap<String, FuncType>,
}
#[derive(Debug)]
pub enum Export {
WorldFunc(String),
WorldFuncPostReturn(WorldKey),
InterfaceFunc(InterfaceId, String),
InterfaceFuncPostReturn(WorldKey, String),
ResourceDtor(TypeId),
Memory,
GeneralPurposeRealloc,
GeneralPurposeExportRealloc,
GeneralPurposeImportRealloc,
Initialize,
ReallocForAdapter,
}
impl ExportMap {
fn add(
&mut self,
export: wasmparser::Export<'_>,
encoder: &ComponentEncoder,
exports: &IndexSet<WorldKey>,
types: TypesRef<'_>,
) -> Result<()> {
if let Some(item) = self.classify(export, encoder, exports, types)? {
log::debug!("classifying export `{}` as {item:?}", export.name);
let prev = self.names.insert(export.name.to_string(), item);
assert!(prev.is_none());
}
Ok(())
}
fn classify(
&mut self,
export: wasmparser::Export<'_>,
encoder: &ComponentEncoder,
exports: &IndexSet<WorldKey>,
types: TypesRef<'_>,
) -> Result<Option<Export>> {
match export.kind {
ExternalKind::Func => {
let ty = types[types.core_function_at(export.index)].unwrap_func();
self.raw_exports.insert(export.name.to_string(), ty.clone());
}
_ => {}
}
if export.name == "canonical_abi_realloc" {
return Ok(Some(Export::GeneralPurposeRealloc));
} else if export.name == "cabi_import_realloc" {
return Ok(Some(Export::GeneralPurposeImportRealloc));
} else if export.name == "cabi_export_realloc" {
return Ok(Some(Export::GeneralPurposeExportRealloc));
} else if export.name == "cabi_realloc_adapter" {
return Ok(Some(Export::ReallocForAdapter));
}
let (name, names) = match export.name.strip_prefix("cm32p2") {
Some(name) => (name, STANDARD),
None if encoder.reject_legacy_names => return Ok(None),
None => (export.name, LEGACY),
};
if let Some(export) = self
.classify_component_export(names, name, &export, encoder, exports, types)
.with_context(|| format!("failed to classify export `{}`", export.name))?
{
return Ok(Some(export));
}
log::debug!("unknown export `{}`", export.name);
Ok(None)
}
fn classify_component_export(
&mut self,
names: &dyn NameMangling,
name: &str,
export: &wasmparser::Export<'_>,
encoder: &ComponentEncoder,
exports: &IndexSet<WorldKey>,
types: TypesRef<'_>,
) -> Result<Option<Export>> {
let resolve = &encoder.metadata.resolve;
let world = encoder.metadata.world;
match export.kind {
ExternalKind::Func => {}
ExternalKind::Memory => {
if name == names.export_memory() {
return Ok(Some(Export::Memory));
}
return Ok(None);
}
_ => return Ok(None),
}
let ty = types[types.core_function_at(export.index)].unwrap_func();
if name == names.export_realloc() {
let expected = FuncType::new([ValType::I32; 4], [ValType::I32]);
validate_func_sig(name, &expected, ty)?;
return Ok(Some(Export::GeneralPurposeRealloc));
} else if name == names.export_initialize() {
let expected = FuncType::new([], []);
validate_func_sig(name, &expected, ty)?;
return Ok(Some(Export::Initialize));
}
if let Some((key, id, f)) = names.match_wit_export(name, resolve, world, exports) {
validate_func(resolve, ty, f, AbiVariant::GuestExport).with_context(|| {
let key = resolve.name_world_key(key);
format!("failed to validate export for `{key}`")
})?;
match id {
Some(id) => {
return Ok(Some(Export::InterfaceFunc(id, f.name.clone())));
}
None => {
return Ok(Some(Export::WorldFunc(f.name.clone())));
}
}
}
if let Some(remaining) = names.strip_post_return(name) {
if let Some((key, id, f)) = names.match_wit_export(remaining, resolve, world, exports) {
validate_post_return(resolve, ty, f).with_context(|| {
let key = resolve.name_world_key(key);
format!("failed to validate export for `{key}`")
})?;
match id {
Some(_id) => {
return Ok(Some(Export::InterfaceFuncPostReturn(
key.clone(),
f.name.clone(),
)));
}
None => {
return Ok(Some(Export::WorldFuncPostReturn(key.clone())));
}
}
}
}
if let Some(dtor) = names.match_wit_resource_dtor(name, resolve, world, exports) {
let expected = FuncType::new([ValType::I32], []);
validate_func_sig(export.name, &expected, ty)?;
return Ok(Some(Export::ResourceDtor(dtor)));
}
Ok(None)
}
pub fn post_return(&self, key: &WorldKey, func: &Function) -> Option<&str> {
self.find(|m| match m {
Export::WorldFuncPostReturn(k) => k == key,
Export::InterfaceFuncPostReturn(k, f) => k == key && func.name == *f,
_ => false,
})
}
pub fn export_realloc_for(&self, key: &WorldKey, func: &Function) -> Option<&str> {
let _ = (key, func);
if let Some(name) = self.find(|m| matches!(m, Export::GeneralPurposeExportRealloc)) {
return Some(name);
}
self.general_purpose_realloc()
}
pub fn import_realloc_for(&self, interface: Option<InterfaceId>, func: &str) -> Option<&str> {
let _ = (interface, func);
if let Some(name) = self.find(|m| matches!(m, Export::GeneralPurposeImportRealloc)) {
return Some(name);
}
self.general_purpose_realloc()
}
pub fn realloc_to_import_into_adapter(&self) -> Option<&str> {
if let Some(name) = self.find(|m| matches!(m, Export::ReallocForAdapter)) {
return Some(name);
}
self.general_purpose_realloc()
}
fn general_purpose_realloc(&self) -> Option<&str> {
self.find(|m| matches!(m, Export::GeneralPurposeRealloc))
}
pub fn memory(&self) -> Option<&str> {
self.find(|m| matches!(m, Export::Memory))
}
pub fn initialize(&self) -> Option<&str> {
self.find(|m| matches!(m, Export::Initialize))
}
pub fn resource_dtor(&self, ty: TypeId) -> Option<&str> {
self.find(|m| match m {
Export::ResourceDtor(t) => *t == ty,
_ => false,
})
}
fn find(&self, f: impl Fn(&Export) -> bool) -> Option<&str> {
let (name, _) = self.names.iter().filter(|(_, m)| f(m)).next()?;
Some(name)
}
pub fn iter(&self) -> impl Iterator<Item = (&str, &Export)> + '_ {
self.names.iter().map(|(n, e)| (n.as_str(), e))
}
fn validate(&self, encoder: &ComponentEncoder, exports: &IndexSet<WorldKey>) -> Result<()> {
let resolve = &encoder.metadata.resolve;
let world = encoder.metadata.world;
if self
.names
.values()
.filter(|m| matches!(m, Export::Memory))
.count()
> 1
{
bail!("cannot componentize module that exports multiple memories")
}
for export in exports {
let require_interface_func = |interface: InterfaceId, name: &str| -> Result<()> {
let result = self.find(|e| match e {
Export::InterfaceFunc(id, s) => interface == *id && name == s,
_ => false,
});
if result.is_some() {
Ok(())
} else {
let export = resolve.name_world_key(export);
bail!("failed to find export of interface `{export}` function `{name}`")
}
};
let require_world_func = |name: &str| -> Result<()> {
let result = self.find(|e| match e {
Export::WorldFunc(s) => name == s,
_ => false,
});
if result.is_some() {
Ok(())
} else {
bail!("failed to find export of function `{name}`")
}
};
match &resolve.worlds[world].exports[export] {
WorldItem::Interface { id, .. } => {
for (name, _) in resolve.interfaces[*id].functions.iter() {
require_interface_func(*id, name)?;
}
}
WorldItem::Function(f) => {
require_world_func(&f.name)?;
}
WorldItem::Type(_) => unreachable!(),
}
}
Ok(())
}
}
trait NameMangling {
fn import_root(&self) -> &str;
fn import_non_root_prefix(&self) -> &str;
fn import_exported_intrinsic_prefix(&self) -> &str;
fn export_memory(&self) -> &str;
fn export_initialize(&self) -> &str;
fn export_realloc(&self) -> &str;
fn resource_drop_name<'a>(&self, s: &'a str) -> Option<&'a str>;
fn resource_new_name<'a>(&self, s: &'a str) -> Option<&'a str>;
fn resource_rep_name<'a>(&self, s: &'a str) -> Option<&'a str>;
fn module_to_interface(
&self,
module: &str,
resolve: &Resolve,
items: &IndexMap<WorldKey, WorldItem>,
) -> Result<(WorldKey, InterfaceId)>;
fn strip_post_return<'a>(&self, s: &'a str) -> Option<&'a str>;
fn match_wit_export<'a>(
&self,
export_name: &str,
resolve: &'a Resolve,
world: WorldId,
exports: &'a IndexSet<WorldKey>,
) -> Option<(&'a WorldKey, Option<InterfaceId>, &'a Function)>;
fn match_wit_resource_dtor<'a>(
&self,
export_name: &str,
resolve: &'a Resolve,
world: WorldId,
exports: &'a IndexSet<WorldKey>,
) -> Option<TypeId>;
}
struct Standard;
const STANDARD: &'static dyn NameMangling = &Standard;
impl NameMangling for Standard {
fn import_root(&self) -> &str {
""
}
fn import_non_root_prefix(&self) -> &str {
"|"
}
fn import_exported_intrinsic_prefix(&self) -> &str {
"_ex_"
}
fn export_memory(&self) -> &str {
"_memory"
}
fn export_initialize(&self) -> &str {
"_initialize"
}
fn export_realloc(&self) -> &str {
"_realloc"
}
fn resource_drop_name<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_suffix("_drop")
}
fn resource_new_name<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_suffix("_new")
}
fn resource_rep_name<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_suffix("_rep")
}
fn module_to_interface(
&self,
interface: &str,
resolve: &Resolve,
items: &IndexMap<WorldKey, WorldItem>,
) -> Result<(WorldKey, InterfaceId)> {
for (key, item) in items.iter() {
let id = match key {
WorldKey::Name(name) => match item {
WorldItem::Interface { id, .. } if name == interface => *id,
_ => continue,
},
WorldKey::Interface(id) => {
if resolve.canonicalized_id_of(*id).as_deref() != Some(interface) {
continue;
}
*id
}
};
return Ok((key.clone(), id));
}
bail!("failed to find world item corresponding to interface `{interface}`")
}
fn strip_post_return<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_suffix("_post")
}
fn match_wit_export<'a>(
&self,
export_name: &str,
resolve: &'a Resolve,
world: WorldId,
exports: &'a IndexSet<WorldKey>,
) -> Option<(&'a WorldKey, Option<InterfaceId>, &'a Function)> {
if let Some(world_export_name) = export_name.strip_prefix("||") {
let key = exports.get(&WorldKey::Name(world_export_name.to_string()))?;
match &resolve.worlds[world].exports[key] {
WorldItem::Function(f) => return Some((key, None, f)),
_ => return None,
}
}
let (key, id, func_name) =
self.match_wit_interface(export_name, resolve, world, exports)?;
let func = resolve.interfaces[id].functions.get(func_name)?;
Some((key, Some(id), func))
}
fn match_wit_resource_dtor<'a>(
&self,
export_name: &str,
resolve: &'a Resolve,
world: WorldId,
exports: &'a IndexSet<WorldKey>,
) -> Option<TypeId> {
let (_key, id, name) =
self.match_wit_interface(export_name.strip_suffix("_dtor")?, resolve, world, exports)?;
let ty = *resolve.interfaces[id].types.get(name)?;
match resolve.types[ty].kind {
TypeDefKind::Resource => Some(ty),
_ => None,
}
}
}
impl Standard {
fn match_wit_interface<'a, 'b>(
&self,
export_name: &'b str,
resolve: &'a Resolve,
world: WorldId,
exports: &'a IndexSet<WorldKey>,
) -> Option<(&'a WorldKey, InterfaceId, &'b str)> {
let world = &resolve.worlds[world];
let export_name = export_name.strip_prefix("|")?;
for export in exports {
let id = match &world.exports[export] {
WorldItem::Interface { id, .. } => *id,
WorldItem::Function(_) => continue,
WorldItem::Type(_) => unreachable!(),
};
let remaining = match export {
WorldKey::Name(name) => export_name.strip_prefix(name),
WorldKey::Interface(_) => {
let prefix = resolve.canonicalized_id_of(id).unwrap();
export_name.strip_prefix(&prefix)
}
};
let item_name = match remaining.and_then(|s| s.strip_prefix("|")) {
Some(name) => name,
None => continue,
};
return Some((export, id, item_name));
}
None
}
}
struct Legacy;
const LEGACY: &'static dyn NameMangling = &Legacy;
impl NameMangling for Legacy {
fn import_root(&self) -> &str {
"$root"
}
fn import_non_root_prefix(&self) -> &str {
""
}
fn import_exported_intrinsic_prefix(&self) -> &str {
"[export]"
}
fn export_memory(&self) -> &str {
"memory"
}
fn export_initialize(&self) -> &str {
"_initialize"
}
fn export_realloc(&self) -> &str {
"cabi_realloc"
}
fn resource_drop_name<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_prefix("[resource-drop]")
}
fn resource_new_name<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_prefix("[resource-new]")
}
fn resource_rep_name<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_prefix("[resource-rep]")
}
fn module_to_interface(
&self,
module: &str,
resolve: &Resolve,
items: &IndexMap<WorldKey, WorldItem>,
) -> Result<(WorldKey, InterfaceId)> {
let bare_name = WorldKey::Name(module.to_string());
if let Some(WorldItem::Interface { id, .. }) = items.get(&bare_name) {
return Ok((bare_name, *id));
}
let kebab_name = ComponentName::new(module, 0);
let name = match kebab_name.as_ref().map(|k| k.kind()) {
Ok(ComponentNameKind::Interface(name)) => name,
_ => bail!("module requires an import interface named `{module}`"),
};
let pkgname = PackageName {
namespace: name.namespace().to_string(),
name: name.package().to_string(),
version: name.version(),
};
if let Some(pkg) = resolve.package_names.get(&pkgname) {
if let Some(id) = resolve.packages[*pkg]
.interfaces
.get(name.interface().as_str())
{
let key = WorldKey::Interface(*id);
if items.contains_key(&key) {
return Ok((key, *id));
}
}
}
for (key, _) in items {
let id = match key {
WorldKey::Interface(id) => *id,
WorldKey::Name(_) => continue,
};
let interface = &resolve.interfaces[id];
if interface.name.as_ref().unwrap() != name.interface().as_str() {
continue;
}
let pkg = &resolve.packages[interface.package.unwrap()];
if pkg.name.namespace != pkgname.namespace || pkg.name.name != pkgname.name {
continue;
}
let module_version = match name.version() {
Some(version) => version,
None => continue,
};
let pkg_version = match &pkg.name.version {
Some(version) => version,
None => continue,
};
let module_compat = PackageName::version_compat_track(&module_version);
let pkg_compat = PackageName::version_compat_track(pkg_version);
if module_compat == pkg_compat {
return Ok((key.clone(), id));
}
}
bail!("module requires an import interface named `{module}`")
}
fn strip_post_return<'a>(&self, s: &'a str) -> Option<&'a str> {
s.strip_prefix("cabi_post_")
}
fn match_wit_export<'a>(
&self,
export_name: &str,
resolve: &'a Resolve,
world: WorldId,
exports: &'a IndexSet<WorldKey>,
) -> Option<(&'a WorldKey, Option<InterfaceId>, &'a Function)> {
let world = &resolve.worlds[world];
for name in exports {
match &world.exports[name] {
WorldItem::Function(f) => {
if f.legacy_core_export_name(None) == export_name {
return Some((name, None, f));
}
}
WorldItem::Interface { id, .. } => {
let string = resolve.name_world_key(name);
for (_, func) in resolve.interfaces[*id].functions.iter() {
if func.legacy_core_export_name(Some(&string)) == export_name {
return Some((name, Some(*id), func));
}
}
}
WorldItem::Type(_) => unreachable!(),
}
}
None
}
fn match_wit_resource_dtor<'a>(
&self,
export_name: &str,
resolve: &'a Resolve,
world: WorldId,
exports: &'a IndexSet<WorldKey>,
) -> Option<TypeId> {
let world = &resolve.worlds[world];
for name in exports {
let id = match &world.exports[name] {
WorldItem::Interface { id, .. } => *id,
WorldItem::Function(_) => continue,
WorldItem::Type(_) => unreachable!(),
};
let name = resolve.name_world_key(name);
let resource = match export_name
.strip_prefix(&name)
.and_then(|s| s.strip_prefix("#[dtor]"))
.and_then(|r| resolve.interfaces[id].types.get(r))
{
Some(id) => *id,
None => continue,
};
match resolve.types[resource].kind {
TypeDefKind::Resource => {}
_ => continue,
}
return Some(resource);
}
None
}
}
pub fn validate_module(encoder: &ComponentEncoder, bytes: &[u8]) -> Result<ValidatedModule> {
ValidatedModule::new(encoder, bytes, &encoder.main_module_exports, None)
}
pub fn validate_adapter_module(
encoder: &ComponentEncoder,
bytes: &[u8],
required_by_import: &IndexMap<String, FuncType>,
exports: &IndexSet<WorldKey>,
library_info: Option<&LibraryInfo>,
) -> Result<ValidatedModule> {
let ret = ValidatedModule::new(encoder, bytes, exports, library_info)?;
for (name, required_ty) in required_by_import {
let actual = match ret.exports.raw_exports.get(name) {
Some(ty) => ty,
None => bail!("adapter module did not export `{name}`"),
};
validate_func_sig(name, required_ty, &actual)?;
}
Ok(ret)
}
fn resource_test_for_interface<'a>(
resolve: &'a Resolve,
id: InterfaceId,
) -> impl Fn(&str) -> Option<TypeId> + 'a {
let interface = &resolve.interfaces[id];
move |name: &str| {
let ty = match interface.types.get(name) {
Some(ty) => *ty,
None => return None,
};
if matches!(resolve.types[ty].kind, TypeDefKind::Resource) {
Some(ty)
} else {
None
}
}
}
fn resource_test_for_world<'a>(
resolve: &'a Resolve,
id: WorldId,
) -> impl Fn(&str) -> Option<TypeId> + 'a {
let world = &resolve.worlds[id];
move |name: &str| match world.imports.get(&WorldKey::Name(name.to_string()))? {
WorldItem::Type(r) => {
if matches!(resolve.types[*r].kind, TypeDefKind::Resource) {
Some(*r)
} else {
None
}
}
_ => None,
}
}
fn validate_func(
resolve: &Resolve,
ty: &wasmparser::FuncType,
func: &Function,
abi: AbiVariant,
) -> Result<()> {
validate_func_sig(
&func.name,
&wasm_sig_to_func_type(resolve.wasm_signature(abi, func)),
ty,
)
}
fn validate_post_return(
resolve: &Resolve,
ty: &wasmparser::FuncType,
func: &Function,
) -> Result<()> {
let mut sig = resolve.wasm_signature(AbiVariant::GuestExport, func);
sig.params = mem::take(&mut sig.results);
validate_func_sig(
&format!("{} post-return", func.name),
&wasm_sig_to_func_type(sig),
ty,
)
}
fn validate_func_sig(name: &str, expected: &FuncType, ty: &wasmparser::FuncType) -> Result<()> {
if ty != expected {
bail!(
"type mismatch for function `{}`: expected `{:?} -> {:?}` but found `{:?} -> {:?}`",
name,
expected.params(),
expected.results(),
ty.params(),
ty.results()
);
}
Ok(())
}