feat: Report discarded transactions to external service

CHANGELOG.md

@@ -1,5 +1,8 @@
 # Changelog
 
+## Next release
+* feat: Report rejected transactions to an external service [#69](https://github.com/Consensys/linea-sequencer/pull/69)
+
 ## 0.6.0-rc1.1
 * bump linea-arithmetization version to 0.6.0-rc1 [#71](https://github.com/Consensys/linea-sequencer/pull/71)
 * bump Linea-Besu version to 24.9-delivery32 [#71](https://github.com/Consensys/linea-sequencer/pull/71)

gradle/common-dependencies.gradle

@@ -34,4 +34,6 @@ dependencies {
 
   testImplementation 'org.mockito:mockito-core'
   testImplementation 'org.mockito:mockito-junit-jupiter'
+
+  testImplementation "org.wiremock:wiremock"
 }

gradle/dependency-management.gradle

@@ -104,6 +104,8 @@ dependencyManagement {
       entry 'picocli-codegen'
     }
 
+    dependency 'com.squareup.okhttp3:okhttp:4.12.0'
+
     dependencySet(group: 'io.tmio', version: '2.4.2') {
       entry 'tuweni-bytes'
       entry 'tuweni-net'
@@ -157,5 +159,7 @@ dependencyManagement {
       entry 'core'
       entry 'crypto'
     }
+
+    dependency "org.wiremock:wiremock:3.9.1"
   }
 }

sequencer/build.gradle

@@ -47,6 +47,8 @@ dependencies {
 
   compileOnly 'io.vertx:vertx-core'
 
+  compileOnly 'com.squareup.okhttp3:okhttp'
+
   implementation project(":native:compress")
 
   implementation 'com.fasterxml.jackson.core:jackson-databind'
@@ -68,6 +70,8 @@ dependencies {
   testImplementation "${besuArtifactGroup}.internal:core"
   testImplementation "${besuArtifactGroup}.internal:rlp"
   testImplementation "${besuArtifactGroup}.internal:core"
+  testImplementation "${besuArtifactGroup}:plugin-api"
+  testImplementation "org.awaitility:awaitility"
 
   // workaround for bug https://github.com/dnsjava/dnsjava/issues/329, remove when upgraded upstream
   testImplementation 'dnsjava:dnsjava:3.6.1'

sequencer/src/main/java/net/consensys/linea/config/LineaTransactionSelectorCliOptions.java

@@ -15,6 +15,8 @@
 
 package net.consensys.linea.config;
 
+import java.net.URI;
+
 import com.google.common.base.MoreObjects;
 import jakarta.validation.constraints.Positive;
 import net.consensys.linea.plugins.LineaCliOptions;
@@ -39,6 +41,8 @@ public class LineaTransactionSelectorCliOptions implements LineaCliOptions {
   public static final String UNPROFITABLE_RETRY_LIMIT = "--plugin-linea-unprofitable-retry-limit";
   public static final int DEFAULT_UNPROFITABLE_RETRY_LIMIT = 10;
 
+  public static final String REJECTED_TX_ENDPOINT = "--plugin-linea-rejected-tx-endpoint";
+
   @Positive
   @CommandLine.Option(
       names = {MAX_BLOCK_CALLDATA_SIZE},
@@ -82,6 +86,13 @@ public class LineaTransactionSelectorCliOptions implements LineaCliOptions {
           "Max number of unprofitable transactions we retry on each block creation (default: ${DEFAULT-VALUE})")
   private int unprofitableRetryLimit = DEFAULT_UNPROFITABLE_RETRY_LIMIT;
 
+  @CommandLine.Option(
+      names = {REJECTED_TX_ENDPOINT},
+      hidden = true,
+      paramLabel = "<URI>",
+      description = "Endpoint URI for reporting rejected transactions  (default: ${DEFAULT-VALUE})")
+  private URI rejectedTxEndpoint = null;
+
   private LineaTransactionSelectorCliOptions() {}
 
   /**
@@ -107,6 +118,7 @@ public static LineaTransactionSelectorCliOptions fromConfig(
     options.maxGasPerBlock = config.maxGasPerBlock();
     options.unprofitableCacheSize = config.unprofitableCacheSize();
     options.unprofitableRetryLimit = config.unprofitableRetryLimit();
+    options.rejectedTxEndpoint = config.rejectedTxEndpoint();
     return options;
   }
 
@@ -123,6 +135,7 @@ public LineaTransactionSelectorConfiguration toDomainObject() {
         .maxGasPerBlock(maxGasPerBlock)
         .unprofitableCacheSize(unprofitableCacheSize)
         .unprofitableRetryLimit(unprofitableRetryLimit)
+        .rejectedTxEndpoint(rejectedTxEndpoint)
         .build();
   }
 
@@ -134,6 +147,7 @@ public String toString() {
         .add(MAX_GAS_PER_BLOCK, maxGasPerBlock)
         .add(UNPROFITABLE_CACHE_SIZE, unprofitableCacheSize)
         .add(UNPROFITABLE_RETRY_LIMIT, unprofitableRetryLimit)
+        .add(REJECTED_TX_ENDPOINT, rejectedTxEndpoint)
         .toString();
   }
 }

sequencer/src/main/java/net/consensys/linea/config/LineaTransactionSelectorConfiguration.java

@@ -15,6 +15,8 @@
 
 package net.consensys.linea.config;
 
+import java.net.URI;
+
 import lombok.Builder;
 import net.consensys.linea.plugins.LineaOptionsConfiguration;
 
@@ -25,5 +27,6 @@ public record LineaTransactionSelectorConfiguration(
     int overLinesLimitCacheSize,
     long maxGasPerBlock,
     int unprofitableCacheSize,
-    int unprofitableRetryLimit)
+    int unprofitableRetryLimit,
+    URI rejectedTxEndpoint)
     implements LineaOptionsConfiguration {}