factors: Port redis trigger

Signed-off-by: Lann Martin <[email protected]>

crates/expressions/src/lib.rs

@@ -267,7 +267,7 @@ impl<'a> AsRef<str> for Key<'a> {
     }
 }
 
-type Result<T> = std::result::Result<T, Error>;
+pub type Result<T> = std::result::Result<T, Error>;
 
 /// A variable resolution error.
 #[derive(Debug, thiserror::Error)]

crates/factor-variables/src/lib.rs

@@ -5,7 +5,7 @@ pub mod spin_cli;
 use std::sync::Arc;
 
 use runtime_config::RuntimeConfig;
-use spin_expressions::ProviderResolver as ExpressionResolver;
+use spin_expressions::{ProviderResolver as ExpressionResolver, Template};
 use spin_factors::{
     anyhow, ConfigureAppContext, Factor, InitContext, InstanceBuilders, PrepareContext,
     RuntimeFactors, SelfInstanceBuilder,
@@ -70,6 +70,16 @@ pub struct AppState {
     expression_resolver: Arc<ExpressionResolver>,
 }
 
+impl AppState {
+    pub async fn resolve_expression(
+        &self,
+        expr: impl Into<Box<str>>,
+    ) -> spin_expressions::Result<String> {
+        let template = Template::new(expr)?;
+        self.expression_resolver.resolve_template(&template).await
+    }
+}
+
 pub struct InstanceState {
     component_id: String,
     expression_resolver: Arc<ExpressionResolver>,

crates/factors-executor/src/lib.rs

@@ -115,6 +115,10 @@ impl<T: RuntimeFactors, U: Send + 'static> FactorsExecutorApp<T, U> {
         &self.executor.core_engine
     }
 
+    pub fn configured_app(&self) -> &ConfiguredApp<T> {
+        &self.configured_app
+    }
+
     pub fn app(&self) -> &App {
         self.configured_app.app()
     }

crates/trigger-http2/src/lib.rs

@@ -60,8 +60,6 @@ impl CliArgs {
     }
 }
 
-pub(crate) type InstanceState = ();
-
 /// The Spin HTTP trigger.
 pub struct HttpTrigger {
     /// The address the server should listen on.
@@ -76,7 +74,7 @@ impl Trigger for HttpTrigger {
     const TYPE: &'static str = "http";
 
     type CliArgs = CliArgs;
-    type InstanceState = InstanceState;
+    type InstanceState = ();
 
     fn new(cli_args: Self::CliArgs, app: &spin_app::App) -> anyhow::Result<Self> {
         Self::new(app, cli_args.address, cli_args.into_tls_config())

crates/trigger-redis/Cargo.toml

@@ -12,19 +12,13 @@ anyhow = "1.0"
 async-trait = "0.1"
 futures = "0.3"
 serde = "1.0.188"
-spin-app = { path = "../app" }
-spin-common = { path = "../common" }
-spin-core = { path = "../core" }
-spin-expressions = { path = "../expressions" }
-spin-trigger = { path = "../trigger" }
+spin-factor-variables = { path = "../factor-variables" }
+spin-telemetry = { path = "../telemetry" }
+spin-trigger2 = { path = "../trigger2" }
 spin-world = { path = "../world" }
-redis = { version = "0.21", features = ["tokio-comp"] }
+redis = { version = "0.26.1", features = ["tokio-comp"] }
 tracing = { workspace = true }
-tokio = { version = "1.23", features = ["full"] }
-spin-telemetry = { path = "../telemetry" }
-
-[dev-dependencies]
-spin-testing = { path = "../testing" }
+tokio = { version = "1.39.3", features = ["macros", "rt"] }
 
 [lints]
 workspace = true