feat: agg-sender (#22)

Co-authored-by: Goran Rojovic <[email protected]> Co-authored-by: Victor Castell <[email protected]> Co-authored-by: joanestebanr <[email protected]> Co-authored-by: Arnau Bennassar <[email protected]>
0xPolygon · Oct 31, 2024 · 2a76deb · 2a76deb
1 parent b43c062
commit 2a76deb
Show file tree

Hide file tree

Showing 51 changed files with 6,741 additions and 183 deletions.
diff --git a/aggregator/agglayer/agglayer_client.go → agglayer/client.go b/aggregator/agglayer/agglayer_client.go → agglayer/client.go
@@ -21,6 +21,8 @@ var ErrAgglayerRateLimitExceeded = fmt.Errorf("agglayer rate limit exceeded")
 type AgglayerClientInterface interface {
 	SendTx(signedTx SignedTx) (common.Hash, error)
 	WaitTxToBeMined(hash common.Hash, ctx context.Context) error
+	SendCertificate(certificate *SignedCertificate) (common.Hash, error)
+	GetCertificateHeader(certificateHash common.Hash) (*CertificateHeader, error)
 }
 
 // AggLayerClient is the client that will be used to interact with the AggLayer
@@ -86,3 +88,43 @@ func (c *AggLayerClient) WaitTxToBeMined(hash common.Hash, ctx context.Context)
 		}
 	}
 }
+
+// SendCertificate sends a certificate to the AggLayer
+func (c *AggLayerClient) SendCertificate(certificate *SignedCertificate) (common.Hash, error) {
+	response, err := rpc.JSONRPCCall(c.url, "interop_sendCertificate", certificate)
+	if err != nil {
+		return common.Hash{}, err
+	}
+
+	if response.Error != nil {
+		return common.Hash{}, fmt.Errorf("%d %s", response.Error.Code, response.Error.Message)
+	}
+
+	var result types.ArgHash
+	err = json.Unmarshal(response.Result, &result)
+	if err != nil {
+		return common.Hash{}, err
+	}
+
+	return result.Hash(), nil
+}
+
+// GetCertificateHeader returns the certificate header associated to the hash
+func (c *AggLayerClient) GetCertificateHeader(certificateHash common.Hash) (*CertificateHeader, error) {
+	response, err := rpc.JSONRPCCall(c.url, "interop_getCertificateHeader", certificateHash)
+	if err != nil {
+		return nil, err
+	}
+
+	if response.Error != nil {
+		return nil, fmt.Errorf("%d %s", response.Error.Code, response.Error.Message)
+	}
+
+	var result *CertificateHeader
+	err = json.Unmarshal(response.Result, &result)
+	if err != nil {
+		return nil, err
+	}
+
+	return result, nil
+}
diff --git a/agglayer/mock_agglayer_client.go b/agglayer/mock_agglayer_client.go
diff --git a/aggregator/agglayer/agglayer_tx.go → agglayer/tx.go b/aggregator/agglayer/agglayer_tx.go → agglayer/tx.go