Merge pull request #10 from Lay3rLabs/deployment

Full service flow

Author: dakom

Cargo.lock

@@ -1,7 +1,7 @@
 # This is mostly just a convenience to start common tasks from the root directory
 version: "3"
 
-# silent: true
+silent: true
 
 dotenv: [".env"]
 

Taskfile.yml

@@ -10,26 +10,62 @@
 8. Download the latest WIT definitions: `task components:fetch-wit`
 9. Copy `.example.env` to `.env` and replace the values
 
-## Summary
+## TL;DR
+
+1. Build all contracts, components, and schema
 
-Start all backend services
 ```bash
+task build-all
+```
+
+2. Start all backend services
+
+```bash
+task backend:start-all
+
 # Alternatively, if you need more than one operator
+# 
 # task backend:start-all OPERATORS=3
-task backend:start-all
 ```
 
-_... do stuff ..._
+3. Tap the faucet for all the mnemonics
+
+```bash
+task deploy:tap-faucet-all
+```
+
+4. Deploy everything
+
+```bash
+task deploy:all
+
+# Alternatively, skip uploading contracts, middleware, and/or components
+# this assumes they were already uploaded before and the output files exist
+# 
+# task deploy:all SKIP_UPLOAD_CONTRACTS=true SKIP_UPLOAD_COMPONENTS=true SKIP_UPLOAD_MIDDLEWARE=true
+```
+
+5. Send an email to the operator email address
+
+See [LocalEmail](./LocalEmail.md) for using the local email server for testing, otherwise, use a real email server
+
+6. Check the on-chain results
+
+```bash
+task contracts:query-service-handler-emails
+```
+
+7. When done, stop all backend services
 
-Stop all backend services
 ```bash
 task backend:stop-all
 ```
 
-But "do stuff" assumes you've build and tested all the contracts and components
-and sometimes you only want to start/stop parts of the backend
+Each of these steps can be done individually and with more granularity as needed.
+
+Let's step through each of these:
+
 
-So, with that in mind...
 
 ## Building
 

builds/deployments/aggregator-submitter-cid.json

@@ -17,20 +17,21 @@ struct Component;
 impl Guest for Component {
     fn process_packet(_packet: Packet) -> Result<Vec<AggregatorAction>, String> {
         let chain = host::config_var("CHAIN").ok_or("CHAIN config var is required")?;
-        let payments_addr = host::config_var("PAYMENTS_CONTRACT_ADDRESS")
-            .ok_or("PAYMENTS_CONTRACT_ADDRESS config var is required")?;
+        let service_handler_addr = host::config_var("SERVICE_HANDLER_CONTRACT_ADDRESS")
+            .ok_or("SERVICE_HANDLER_CONTRACT_ADDRESS config var is required")?;
 
         host::get_cosmos_chain_config(&chain)
             .ok_or(format!("failed to get chain config for {}", chain))?;
 
-        let payments_addr = CosmosAddr::new_str(&payments_addr, None).map_err(|e| e.to_string())?;
+        let service_handler_addr =
+            CosmosAddr::new_str(&service_handler_addr, None).map_err(|e| e.to_string())?;
 
         Ok(vec![AggregatorAction::Submit(SubmitAction::Cosmos(
             CosmosSubmitAction {
                 chain: chain.to_string(),
                 address: CosmosAddress {
-                    bech32_addr: payments_addr.to_string(),
-                    prefix_len: payments_addr.prefix().len() as u32,
+                    bech32_addr: service_handler_addr.to_string(),
+                    prefix_len: service_handler_addr.prefix().len() as u32,
                 },
                 gas_price: None,
             },

builds/deployments/operator-email-reader-cid.json

@@ -11,6 +11,8 @@ rust-version = "1.90.0"
 crate-type = ["cdylib"]
 
 [dependencies]
+# Local
+app-contract-api = { workspace = true }
 
 # Error handling
 anyhow = { workspace = true }
@@ -41,6 +43,9 @@ imap = { workspace = true, default-features = false }
 mailparse = { workspace = true }
 cfdkim = { workspace = true}
 
+# Hashing
+sha2 = { workspace = true }
+
 # Security
 zeroize = { workspace = true }
 

builds/deployments/service-handler-code-id.json

@@ -10,9 +10,9 @@ pub struct EmailMessage {
     // 1) "Original sender" best-effort (From / Resent-From / Sender / envelope)
     pub original_sender: String,
     // 2) All DKIM-Signature header values (there can be multiple)
-    dkim_signatures: Vec<String>,
+    pub dkim_signatures: Vec<String>,
     // 3) Subject (decoded)
-    subject: Option<String>,
+    pub subject: Option<String>,
     // 4) Body (best-effort: prefer text/plain part; fall back to full text)
     pub body_text: Option<String>,
     // 5) Raw email bytes (can be parsed on demand)

docs/GettingStarted.md

@@ -5,6 +5,7 @@ mod email;
 mod error;
 
 use anyhow::bail;
+use app_contract_api::service_handler::msg::{CustomExecuteMsg, Email};
 use cfdkim::verify_email_with_resolver;
 
 use crate::{email::verify::verify_email, wavs::operator::input::TriggerData};
@@ -38,6 +39,37 @@ impl Guest for Component {
 
 async fn inner(trigger_action: TriggerAction) -> anyhow::Result<Vec<WasmResponse>> {
     match trigger_action.data {
+        TriggerData::Cron(_) => {
+            // TODO - read a batch instead of just one email
+            let email = match email::read_next_email().await? {
+                Some(email) => email,
+                None => {
+                    return Ok(Vec::new());
+                }
+            };
+
+            verify_email(&email).await?;
+
+            // For right now, treat each email as its own event
+            let event_id_salt = {
+                use sha2::{Digest, Sha256};
+
+                let mut hasher = Sha256::new();
+                hasher.update(&email.raw_bytes);
+                hasher.finalize().to_vec()
+            };
+
+            return Ok(vec![WasmResponse {
+                payload: CustomExecuteMsg::Email(Email {
+                    from: email.original_sender,
+                    subject: email.subject.unwrap_or_default(),
+                })
+                .encode()
+                .map_err(|e| anyhow::anyhow!("{e:?}"))?,
+                ordering: None,
+                event_id_salt: Some(event_id_salt),
+            }]);
+        }
         TriggerData::Raw(data) => {
             let data = std::str::from_utf8(&data)?;
             match data {