Merge branch 'master' into cody/add_raw_tx_forwarder

Author: cody-wang-cb

.env.example

@@ -32,6 +32,8 @@ TIPS_AUDIT_S3_ACCESS_KEY_ID=minioadmin
 TIPS_AUDIT_S3_SECRET_ACCESS_KEY=minioadmin
 
 # TIPS UI
+NEXT_PUBLIC_BLOCK_EXPLORER_URL=https://base.blockscout.com
+TIPS_UI_RPC_URL=http://localhost:8549
 TIPS_UI_AWS_REGION=us-east-1
 TIPS_UI_S3_BUCKET_NAME=tips
 TIPS_UI_S3_CONFIG_TYPE=manual

.github/workflows/stale.yml

@@ -0,0 +1,32 @@
+name: Mark stale issues and PRs
+
+on:
+  schedule:
+    - cron: '30 0 * * *'
+  workflow_dispatch:
+permissions:
+  contents: read
+
+jobs:
+  stale:
+    runs-on: ubuntu-latest
+    permissions:
+      actions: write
+      issues: write
+      pull-requests: write
+    steps:
+      - name: Harden the runner (Audit all outbound calls)
+        uses: step-security/harden-runner@95d9a5deda9de15063e7595e9719c11c38c90ae2 # v2.13.2
+        with:
+          egress-policy: audit
+
+      - uses: actions/stale@5f858e3efba33a5ca4407a664cc011ad407f2008 # v10.1.0
+        with:
+          days-before-stale: 14
+          days-before-close: 5
+          stale-issue-message: 'This issue has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. Thank you for your contributions.'
+          stale-pr-message: 'This pull request has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. Thank you for your contributions.'
+          close-issue-message: 'This issue was closed because it has been inactive for 5 days since being marked as stale.'
+          close-pr-message: 'This pull request was closed because it has been inactive for 5 days since being marked as stale.'
+          exempt-issue-labels: keep-open
+          exempt-pr-labels: keep-open

Cargo.lock

@@ -55,12 +55,11 @@ wiremock = "0.6.2"
 axum = "0.8.3"
 
 # Kafka and S3 dependencies
-rdkafka = { version = "0.37.0", features = ["libz-static", "ssl-vendored"] }
+rdkafka = { version = "0.37.0", features = ["zstd", "ssl-vendored"] }
 aws-config = "1.1.7"
 aws-sdk-s3 = "1.106.0"
 aws-credential-types = "1.1.7"
 bytes = { version = "1.8.0", features = ["serde"] }
-lz4_flex = "0.12"
 
 # tips-ingress
 backon = "1.5.2"

Cargo.toml

@@ -32,7 +32,6 @@ aws-config = { workspace = true }
 aws-sdk-s3 = { workspace = true }
 aws-credential-types = { workspace = true }
 bytes = { workspace = true }
-lz4_flex = { workspace = true }
 
 [dev-dependencies]
 testcontainers = { workspace = true }

crates/audit/Cargo.toml

@@ -26,8 +26,7 @@ impl KafkaBundleEventPublisher {
     async fn send_event(&self, event: &BundleEvent) -> Result<()> {
         let bundle_id = event.bundle_id();
         let key = event.generate_event_key();
-        let json_bytes = serde_json::to_vec(event)?;
-        let payload = lz4_flex::compress_prepend_size(&json_bytes);
+        let payload = serde_json::to_vec(event)?;
 
         let record = FutureRecord::to(&self.topic).key(&key).payload(&payload);
 

crates/audit/src/publisher.rs

@@ -77,9 +77,7 @@ impl EventReader for KafkaAuditLogReader {
                         .as_millis() as i64,
                 };
 
-                let json_bytes = lz4_flex::decompress_size_prepended(payload)
-                    .map_err(|e| anyhow::anyhow!("Failed to decompress LZ4: {e}"))?;
-                let event: BundleEvent = serde_json::from_slice(&json_bytes)?;
+                let event: BundleEvent = serde_json::from_slice(payload)?;
 
                 debug!(
                     bundle_id = %event.bundle_id(),

crates/audit/src/reader.rs

@@ -278,7 +278,7 @@ pub struct TransactionResult {
     pub execution_time_us: u128,
 }
 
-#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
+#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq, Default)]
 #[serde(rename_all = "camelCase")]
 pub struct MeterBundleResponse {
     pub bundle_gas_price: U256,

crates/core/src/types.rs

@@ -81,7 +81,7 @@ mod tests {
                 assert_eq!(user_operation.signature, Bytes::from_str("0x01").unwrap());
             }
             _ => {
-                panic!("Expected EntryPointV06, got {user_operation:?}");
+                panic!("Expected EntryPointV06, got {:?}", user_operation);
             }
         }
     }
@@ -132,7 +132,7 @@ mod tests {
                 assert_eq!(user_operation.pre_verification_gas, Uint::from(0x186a0));
             }
             _ => {
-                panic!("Expected EntryPointV07, got {user_operation:?}");
+                panic!("Expected EntryPointV07, got {:?}", user_operation);
             }
         }
     }

crates/core/src/user_ops_types.rs

@@ -40,3 +40,7 @@ metrics.workspace = true
 metrics-derive.workspace = true
 metrics-exporter-prometheus.workspace = true
 axum.workspace = true
+
+[dev-dependencies]
+wiremock.workspace = true
+serde_json.workspace = true