Merge branch 'master' into fxamacker/reduce-checkpoint-serialization-…

…memory

.github/workflows/flaky-test-debug.yml

@@ -8,13 +8,26 @@ env:
   GO_VERSION: 1.18
 
 jobs:
+  unit-test:
+    name: Unit Tests
+    runs-on: ubuntu-latest
+    steps:
+      - name: Setup Go
+        uses: actions/setup-go@v2
+        with:
+          go-version: ${{ env.GO_VERSION }}
+      - name: Checkout repo
+        uses: actions/checkout@v2
+      - name: Run tests
+        if: github.actor != 'bors[bot]'
+        run: make ci
   integration-test:
     name: Integration Tests
     strategy:
       fail-fast: false
       matrix:
         test-category:
-          - integration-epochs
+          - integration-bft
     env:
       TEST_CATEGORY: ${{ matrix.test-category }}
     runs-on: ubuntu-latest

insecure/attack_orchestrator.go

@@ -0,0 +1,18 @@
+package insecure
+
+// AttackOrchestrator represents the stateful interface that implements a certain type of attack, e.g., wintermute attack.
+type AttackOrchestrator interface {
+	// HandleEgressEvent implements logic of processing the outgoing events received from a corrupted node.
+	// Corrupted nodes relay all their outgoing events to the orchestrator instead of dispatching them to the network.
+	//
+	// Note: as a design assumption, this method is invoked sequentially by the OrchestratorNetwork to pass the
+	// events of corrupted nodes. Hence, no extra concurrency-safe consideration is needed.
+	HandleEgressEvent(*EgressEvent) error
+
+	Register(OrchestratorNetwork)
+
+	// HandleIngressEvent implements the logic of processing an incoming event to a corrupted node.
+	// Note: as a design assumption, this method is invoked sequentially by the OrchestratorNetwork to pass the
+	// events of corrupted nodes. Hence, no extra concurrency-safe consideration is needed.
+	HandleIngressEvent(*IngressEvent) error
+}

insecure/attacker.proto

@@ -22,21 +22,26 @@ message Message {
   IngressMessage Ingress = 2;
 }
 
-// EgressMessage represents the message exchanged between the CorruptibleConduitFactory and Attacker services.
+// EgressMessage represents an outgoing message from a corrupt node to another (honest or corrupt) node.
+// The exchanged message is between the CorruptibleConduitFactory and Attacker services.
 message EgressMessage {
   string ChannelID = 1;
-  bytes OriginID = 2;
+
+  // CorruptOriginID represents the corrupt node id where the outgoing message is coming from.
+  bytes CorruptOriginID = 2;
   uint32 TargetNum = 3;
   repeated bytes TargetIDs = 4;
   bytes Payload = 5;
   Protocol protocol = 6;
 }
 
-// OriginID for IngressMessage represents the node id where the message is coming from - that node could be corrupted or honest.
+// IngressMessage represents an incoming message from another node (honest or corrupt) to a corrupt node.
 message IngressMessage {
   string ChannelID = 1;
+
+  // OriginID represents the node id where the incoming message is coming from - that node could be corrupt or honest.
   bytes OriginID = 2;
-  bytes TargetID = 3;
+  bytes CorruptTargetID = 3;
   bytes Payload = 4;
 }