merge upstream/main

Signed-off-by: William Hankins <william@sundae.fi>

Author: whankinsiv

.github/workflows/run-tests-on-push-to-main.yml

@@ -40,8 +40,10 @@ jobs:
             --package acropolis_module_snapshot_bootstrapper \
             --package acropolis_module_spdd_state \
             --package acropolis_module_stake_delta_filter \
+            --package acropolis_module_tx_submitter \
             --package acropolis_module_upstream_chain_fetcher \
-            --package acropolis_module_utxo_state
+            --package acropolis_module_utxo_state \
+            --package acropolis_process_tx_submitter_cli
 
       - name: Run Build
         run: cargo build --verbose

.github/workflows/weekly-update.yml

@@ -0,0 +1,88 @@
+name: Weekly Status Markdown
+
+on:
+  schedule:
+    - cron: "0 14 * * MON"   # Mondays 07:00 PT (14:00 UTC)
+  workflow_dispatch:
+
+jobs:
+  build-status:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      issues: write # needed to create/update issues
+      pull-requests: write # needed to post/update a PR comment
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: "3.11"
+
+      - name: Install deps
+        run: pip install requests
+
+      - name: Get current date
+        id: date
+        run: echo "date=$(date +'%Y-%m-%d')" >> $GITHUB_OUTPUT
+
+      - name: Generate weekly status markdown
+        id: gen
+        env:
+          GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+          REPO: input-output-hk/acropolis
+          # --- Use ONE of the two approaches below ---
+
+          # A) Projects v2 (recommended):
+          PROJECT_OWNER: input-output-hk
+          PROJECT_NUMBER: 7
+          STATUS_DONE_VALUE: Done
+          STATUS_INPROGRESS_VALUE: In Progress
+
+          # B) Fallback via labels:
+          # DONE_LABELS: "status: done,done"
+          # INPROGRESS_LABELS: "status: in progress,in progress"
+
+          OUTPUT_PATH: artifacts/weekly_status.md
+        run: |
+          mkdir -p artifacts
+          python scripts/weekly_status_markdown.py | tee /tmp/out.md
+          echo "md<<EOF" >> $GITHUB_OUTPUT
+          cat /tmp/out.md >> $GITHUB_OUTPUT
+          echo "EOF" >> $GITHUB_OUTPUT
+
+      - name: Upload markdown artifact
+        uses: actions/upload-artifact@v4
+        with:
+          name: weekly-status
+          path: artifacts/weekly_status.md
+          if-no-files-found: warn
+
+      # Create GitHub Issue with weekly status
+      - name: Create Weekly Status Issue
+        if: ${{ github.event_name != 'pull_request' }}
+        uses: actions/github-script@v7
+        with:
+          script: |
+            console.log('Event name:', context.eventName);
+            console.log('Checking if artifacts/weekly_status.md exists...');
+
+            const fs = require('fs');
+            if (!fs.existsSync('artifacts/weekly_status.md')) {
+              console.log('❌ artifacts/weekly_status.md not found!');
+              throw new Error('Weekly status file not found');
+            }
+
+            const content = fs.readFileSync('artifacts/weekly_status.md', 'utf8');
+            console.log('✅ File read successfully, length:', content.length);
+
+            const issue = await github.rest.issues.create({
+              owner: context.repo.owner,
+              repo: context.repo.repo,
+              title: `📊 Weekly Status - Week of ${{ steps.date.outputs.date }}`,
+              body: content,
+              labels: ['weekly-status', 'automated']
+            });
+
+            console.log('✅ Issue created successfully:', issue.data.html_url);

Cargo.lock

@@ -25,11 +25,13 @@ members = [
     "modules/historical_accounts_state",    # Tracks historical account information
     "modules/consensus",                    # Chooses favoured chain across multiple options
     "modules/chain_store",                  # Tracks historical information about blocks and TXs
+    "modules/tx_submitter",                 # Submits TXs to peers
 
     # Process builds
-    "processes/omnibus",      # All-inclusive omnibus process
-    "processes/replayer",     # All-inclusive process to replay messages
-    "processes/golden_tests", # All-inclusive golden tests process
+    "processes/omnibus",            # All-inclusive omnibus process
+    "processes/replayer",           # All-inclusive process to replay messages
+    "processes/golden_tests",       # All-inclusive golden tests process
+    "processes/tx_submitter_cli",   # CLI wrapper for TX submitter
 ]
 resolver = "2"
 
@@ -41,7 +43,7 @@ caryatid_module_clock = "0.12"
 caryatid_module_spy = "0.12"
 anyhow = "1.0"
 chrono = "0.4"
-clap = { version = "4.5", features = ["derive"] }
+clap = { version = "4.5", features = ["derive", "string"] }
 config = "0.15.11"
 dashmap = "6.1.0"
 hex = "0.4"

Cargo.toml

@@ -69,13 +69,9 @@ pub fn map_address(address: &addresses::Address) -> Result<Address> {
 
         addresses::Address::Stake(stake_address) => Ok(Address::Stake(StakeAddress {
             network: map_network(stake_address.network())?,
-            payload: match stake_address.payload() {
-                addresses::StakePayload::Stake(hash) => {
-                    StakeAddressPayload::StakeKeyHash(hash.to_vec())
-                }
-                addresses::StakePayload::Script(hash) => {
-                    StakeAddressPayload::ScriptHash(hash.to_vec())
-                }
+            credential: match stake_address.payload() {
+                addresses::StakePayload::Stake(hash) => StakeCredential::AddrKeyHash(hash.to_vec()),
+                addresses::StakePayload::Script(hash) => StakeCredential::ScriptHash(hash.to_vec()),
             },
         })),
     }
@@ -97,10 +93,10 @@ pub fn map_stake_credential(cred: &PallasStakeCredential) -> StakeCredential {
 pub fn map_stake_address(cred: &PallasStakeCredential, network_id: NetworkId) -> StakeAddress {
     let payload = match cred {
         PallasStakeCredential::AddrKeyhash(key_hash) => {
-            StakeAddressPayload::StakeKeyHash(key_hash.to_vec())
+            StakeCredential::AddrKeyHash(key_hash.to_vec())
         }
         PallasStakeCredential::ScriptHash(script_hash) => {
-            StakeAddressPayload::ScriptHash(script_hash.to_vec())
+            StakeCredential::ScriptHash(script_hash.to_vec())
         }
     };
 
@@ -274,7 +270,7 @@ pub fn map_certificate(
                             .iter()
                             .map(|v| {
                                 StakeAddress::new(
-                                    StakeAddressPayload::StakeKeyHash(v.to_vec()),
+                                    StakeCredential::AddrKeyHash(v.to_vec()),
                                     network_id.clone().into(),
                                 )
                             })
@@ -398,7 +394,7 @@ pub fn map_certificate(
                                 .into_iter()
                                 .map(|v| {
                                     StakeAddress::new(
-                                        StakeAddressPayload::StakeKeyHash(v.to_vec()),
+                                        StakeCredential::AddrKeyHash(v.to_vec()),
                                         network_id.clone().into(),
                                     )
                                 })