Support invoking wasi:http/incoming-handler (#1249)

* Support invoking wasi:http/incoming-handler

* unsafety comment

* Update golem-common/src/virtual_exports/http_incoming_handler.rs

Co-authored-by: Daniel Vigovszky <daniel.vigovszky@gmail.com>

* comments

* test using wasm echo server

* test restore of state when implementing wasi:http/incoming-handler

* remove debug log

---------

Co-authored-by: Daniel Vigovszky <daniel.vigovszky@gmail.com>

Cargo.toml

@@ -64,6 +64,9 @@ exclude = [
     "test-components/update-test-v3-11",
     "test-components/update-test-v4",
     "test-components/variant-service",
+    "test-components/wasi-http-incoming-request-handler",
+    "test-components/wasi-http-incoming-request-handler-echo",
+    "test-components/wasi-http-incoming-request-handler-state",
     "test-components/write-stderr",
     "test-components/write-stdout",
 ]

golem-common/Cargo.toml

@@ -52,6 +52,7 @@ prost-types = { workspace = true, optional = true }
 rand = { workspace = true }
 range-set-blaze = "0.1.16"
 regex = { workspace = true }
+semver = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
 serde_yaml = { workspace = true }

golem-common/src/lib.rs

@@ -56,6 +56,8 @@ pub mod tracing;
 
 pub mod uri;
 
+pub mod virtual_exports;
+
 #[cfg(test)]
 test_r::enable!();
 

golem-common/src/model/component_metadata.rs

@@ -16,7 +16,7 @@ use bincode::{Decode, Encode};
 use std::collections::HashMap;
 use std::fmt::{self, Display, Formatter};
 
-use crate::SafeDisplay;
+use crate::{virtual_exports, SafeDisplay};
 use golem_wasm_ast::analysis::AnalysedFunctionParameter;
 use golem_wasm_ast::core::Mem;
 use golem_wasm_ast::metadata::Producers as WasmAstProducers;
@@ -182,6 +182,7 @@ impl RawComponentMetadata {
             .map_err(ComponentProcessingError::Analysis)?;
 
         add_resource_drops(&mut exports);
+        add_virtual_exports(&mut exports);
 
         let exports = exports.into_iter().collect::<Vec<_>>();
 
@@ -327,6 +328,17 @@ fn drop_from_constructor(constructor: &AnalysedFunction) -> AnalysedFunction {
     }
 }
 
+fn add_virtual_exports(exports: &mut Vec<AnalysedExport>) {
+    // Some interfaces like the golem/http:incoming-handler do not exist on the component,
+    // but are dynamically created by the worker executor based on other existing interfaces.
+
+    if virtual_exports::http_incoming_handler::implements_required_interfaces(exports) {
+        exports.extend(vec![
+            virtual_exports::http_incoming_handler::ANALYZED_EXPORT.clone(),
+        ]);
+    };
+}
+
 #[cfg(feature = "protobuf")]
 mod protobuf {
     use crate::model::component_metadata::{

golem-common/src/model/exports.rs

@@ -16,24 +16,7 @@ use golem_wasm_ast::analysis::{AnalysedExport, AnalysedFunction, AnalysedInstanc
 
 use rib::{ParsedFunctionName, ParsedFunctionReference, ParsedFunctionSite};
 
-pub trait AnalysedExportExtensions {
-    fn function_names(&self) -> Vec<String>;
-}
-
-impl AnalysedExportExtensions for AnalysedExport {
-    fn function_names(&self) -> Vec<String> {
-        match self {
-            AnalysedExport::Instance(instance) => instance
-                .functions
-                .iter()
-                .map(|function| format!("{}.{{{}}}", instance.name, function.name))
-                .collect(),
-            AnalysedExport::Function(function) => vec![function.name.clone()],
-        }
-    }
-}
-
-pub fn instances(exports: &Vec<AnalysedExport>) -> Vec<AnalysedInstance> {
+fn instances(exports: &Vec<AnalysedExport>) -> Vec<AnalysedInstance> {
     let mut instances = vec![];
     for export in exports {
         if let AnalysedExport::Instance(instance) = export {
@@ -43,7 +26,7 @@ pub fn instances(exports: &Vec<AnalysedExport>) -> Vec<AnalysedInstance> {
     instances
 }
 
-pub fn functions(exports: &Vec<AnalysedExport>) -> Vec<AnalysedFunction> {
+fn functions(exports: &Vec<AnalysedExport>) -> Vec<AnalysedFunction> {
     let mut functions = vec![];
     for export in exports {
         if let AnalysedExport::Function(function) = export {