add quorum results

api/docs/disperser_v2.html

@@ -288,7 +288,8 @@ <h3 id="disperser.v2.Attestation">Attestation</h3>
                   <td>quorum_apks</td>
                   <td><a href="#bytes">bytes</a></td>
                   <td>repeated</td>
-                  <td><p>Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum </p></td>
+                  <td><p>Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum
+The order of the quorum_apks should match the order of the quorum_numbers </p></td>
                 </tr>
 
                 <tr>
@@ -305,6 +306,14 @@ <h3 id="disperser.v2.Attestation">Attestation</h3>
                   <td><p>Relevant quorum numbers for the attestation </p></td>
                 </tr>
 
+                <tr>
+                  <td>quorum_signed_percentages</td>
+                  <td><a href="#bytes">bytes</a></td>
+                  <td></td>
+                  <td><p>The attestation rate for each quorum.
+The order of the quorum_signed_percentages should match the order of the quorum_numbers </p></td>
+                </tr>
+
             </tbody>
           </table>
 

api/docs/disperser_v2.md

@@ -44,9 +44,10 @@
 | ----- | ---- | ----- | ----------- |
 | non_signer_pubkeys | [bytes](#bytes) | repeated | Serialized bytes of non signer public keys (G1 points) |
 | apk_g2 | [bytes](#bytes) |  | Serialized bytes of G2 point that represents aggregate public key of all signers |
-| quorum_apks | [bytes](#bytes) | repeated | Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum |
+| quorum_apks | [bytes](#bytes) | repeated | Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum The order of the quorum_apks should match the order of the quorum_numbers |
 | sigma | [bytes](#bytes) |  | Serialized bytes of aggregate signature |
 | quorum_numbers | [uint32](#uint32) | repeated | Relevant quorum numbers for the attestation |
+| quorum_signed_percentages | [bytes](#bytes) |  | The attestation rate for each quorum. The order of the quorum_signed_percentages should match the order of the quorum_numbers |
 
 
 

api/docs/eigenda-protos.html

@@ -1959,7 +1959,8 @@ <h3 id="disperser.v2.Attestation">Attestation</h3>
                   <td>quorum_apks</td>
                   <td><a href="#bytes">bytes</a></td>
                   <td>repeated</td>
-                  <td><p>Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum </p></td>
+                  <td><p>Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum
+The order of the quorum_apks should match the order of the quorum_numbers </p></td>
                 </tr>
 
                 <tr>
@@ -1976,6 +1977,14 @@ <h3 id="disperser.v2.Attestation">Attestation</h3>
                   <td><p>Relevant quorum numbers for the attestation </p></td>
                 </tr>
 
+                <tr>
+                  <td>quorum_signed_percentages</td>
+                  <td><a href="#bytes">bytes</a></td>
+                  <td></td>
+                  <td><p>The attestation rate for each quorum.
+The order of the quorum_signed_percentages should match the order of the quorum_numbers </p></td>
+                </tr>
+
             </tbody>
           </table>
 

api/docs/eigenda-protos.md

@@ -746,9 +746,10 @@ If DisperseBlob returns the following error codes: INVALID_ARGUMENT (400): reque
 | ----- | ---- | ----- | ----------- |
 | non_signer_pubkeys | [bytes](#bytes) | repeated | Serialized bytes of non signer public keys (G1 points) |
 | apk_g2 | [bytes](#bytes) |  | Serialized bytes of G2 point that represents aggregate public key of all signers |
-| quorum_apks | [bytes](#bytes) | repeated | Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum |
+| quorum_apks | [bytes](#bytes) | repeated | Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum The order of the quorum_apks should match the order of the quorum_numbers |
 | sigma | [bytes](#bytes) |  | Serialized bytes of aggregate signature |
 | quorum_numbers | [uint32](#uint32) | repeated | Relevant quorum numbers for the attestation |
+| quorum_signed_percentages | [bytes](#bytes) |  | The attestation rate for each quorum. The order of the quorum_signed_percentages should match the order of the quorum_numbers |
 
 
 

api/proto/disperser/v2/disperser_v2.proto

@@ -138,11 +138,15 @@ message Attestation {
   // Serialized bytes of G2 point that represents aggregate public key of all signers
   bytes apk_g2 = 2;
   // Serialized bytes of aggregate public keys (G1 points) from all nodes for each quorum
+  // The order of the quorum_apks should match the order of the quorum_numbers
   repeated bytes quorum_apks = 3;
   // Serialized bytes of aggregate signature
   bytes sigma = 4;
   // Relevant quorum numbers for the attestation
   repeated uint32 quorum_numbers = 5;
+  // The attestation rate for each quorum.
+  // The order of the quorum_signed_percentages should match the order of the quorum_numbers
+  bytes quorum_signed_percentages = 6;
 }
 
 message PaymentGlobalParams {

core/v2/types.go

@@ -312,6 +312,8 @@ type Attestation struct {
 	Sigma *core.Signature
 	// QuorumNumbers contains the quorums relevant for the attestation
 	QuorumNumbers []core.QuorumID
+	// QuorumResults contains the results of the quorum verification
+	QuorumResults map[core.QuorumID]uint8
 }
 
 func (a *Attestation) ToProtobuf() *disperserpb.Attestation {
@@ -328,19 +330,22 @@ func (a *Attestation) ToProtobuf() *disperserpb.Attestation {
 	}
 
 	quorumNumbers := make([]uint32, len(a.QuorumNumbers))
+	quorumResults := make([]uint8, len(a.QuorumResults))
 	for i, q := range a.QuorumNumbers {
 		quorumNumbers[i] = uint32(q)
+		quorumResults[i] = a.QuorumResults[q]
 	}
 
 	apkG2Bytes := a.APKG2.Bytes()
 	sigmaBytes := a.Sigma.Bytes()
 
 	return &disperserpb.Attestation{
-		NonSignerPubkeys: nonSignerPubKeys,
-		ApkG2:            apkG2Bytes[:],
-		QuorumApks:       quorumAPKs,
-		Sigma:            sigmaBytes[:],
-		QuorumNumbers:    quorumNumbers,
+		NonSignerPubkeys:        nonSignerPubKeys,
+		ApkG2:                   apkG2Bytes[:],
+		QuorumApks:              quorumAPKs,
+		Sigma:                   sigmaBytes[:],
+		QuorumNumbers:           quorumNumbers,
+		QuorumSignedPercentages: quorumResults,
 	}
 }
 

disperser/controller/dispatcher.go

@@ -246,6 +246,10 @@ func (d *Dispatcher) HandleSignatures(ctx context.Context, batchData *batchData,
 		return fmt.Errorf("failed to aggregate signatures: %w", err)
 	}
 
+	quorumResults := make(map[core.QuorumID]uint8)
+	for quorumID, result := range quorumAttestation.QuorumResults {
+		quorumResults[quorumID] = result.PercentSigned
+	}
 	err = d.blobMetadataStore.PutAttestation(ctx, &corev2.Attestation{
 		BatchHeader:      batchData.Batch.BatchHeader,
 		AttestedAt:       uint64(time.Now().UnixNano()),
@@ -254,6 +258,7 @@ func (d *Dispatcher) HandleSignatures(ctx context.Context, batchData *batchData,
 		QuorumAPKs:       aggSig.QuorumAggPubKeys,
 		Sigma:            aggSig.AggSignature,
 		QuorumNumbers:    quorums,
+		QuorumResults:    quorumResults,
 	})
 	putAttestationFinished := time.Now()
 	d.metrics.reportPutAttestationLatency(putAttestationFinished.Sub(aggregateSignaturesFinished))

disperser/controller/dispatcher_test.go

@@ -112,6 +112,7 @@ func TestDispatcherHandleBatch(t *testing.T) {
 	require.Len(t, att.QuorumAPKs, 2)
 	require.NotNil(t, att.Sigma)
 	require.ElementsMatch(t, att.QuorumNumbers, []core.QuorumID{0, 1})
+	require.InDeltaMapValues(t, map[core.QuorumID]uint8{0: 100, 1: 100}, att.QuorumResults, 0)
 
 	deleteBlobs(t, components.BlobMetadataStore, objs.blobKeys, [][32]byte{bhh})
 }

inabox/tests/integration_v2_test.go

@@ -93,6 +93,11 @@ var _ = Describe("Inabox v2 Integration", func() {
 				Expect(batchHeader1.GetReferenceBlockNumber()).To(BeNumerically(">", 0))
 				attestation := reply1.GetSignedBatch().GetAttestation()
 				Expect(attestation).To(Not(BeNil()))
+				Expect(attestation.QuorumNumbers).To(Equal([]uint32{0, 1}))
+				Expect(len(attestation.NonSignerPubkeys)).To(Equal(0))
+				Expect(attestation.ApkG2).To(Not(BeNil()))
+				Expect(len(attestation.QuorumApks)).To(Equal(2))
+				Expect(attestation.QuorumSignedPercentages).To(Equal([]byte{100, 100}))
 				blobVerification := reply1.GetBlobVerificationInfo()
 				Expect(blobVerification).To(Not(BeNil()))
 				Expect(blobVerification.GetBlobCertificate()).To(Not(BeNil()))
@@ -116,6 +121,11 @@ var _ = Describe("Inabox v2 Integration", func() {
 				Expect(batchHeader2.GetReferenceBlockNumber()).To(BeNumerically(">", 0))
 				attestation = reply2.GetSignedBatch().GetAttestation()
 				Expect(attestation).To(Not(BeNil()))
+				Expect(attestation.QuorumNumbers).To(Equal([]uint32{0}))
+				Expect(len(attestation.NonSignerPubkeys)).To(Equal(0))
+				Expect(attestation.ApkG2).To(Not(BeNil()))
+				Expect(len(attestation.QuorumApks)).To(Equal(1))
+				Expect(attestation.QuorumSignedPercentages).To(Equal([]byte{100}))
 				blobVerification = reply2.GetBlobVerificationInfo()
 				Expect(blobVerification).To(Not(BeNil()))
 				Expect(blobVerification.GetBlobCertificate()).To(Not(BeNil()))