Skip to content

Commit fad7859

Browse files
committed
feat: Proxy client - alias blob info to certificate
1 parent f4c466e commit fad7859

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

store/eigenda.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@ import (
77
"github.com/Layr-Labs/eigenda-proxy/common"
88
"github.com/Layr-Labs/eigenda-proxy/verify"
99
"github.com/Layr-Labs/eigenda/api/clients"
10-
"github.com/Layr-Labs/eigenda/api/grpc/disperser"
1110
"github.com/ethereum/go-ethereum/rlp"
1211
)
1312

@@ -31,7 +30,7 @@ func NewEigenDAStore(ctx context.Context, client *clients.EigenDAClient, v *veri
3130
// Get fetches a blob from DA using certificate fields and verifies blob
3231
// against commitment to ensure data is valid and non-tampered.
3332
func (e EigenDAStore) Get(ctx context.Context, key []byte, domain common.DomainType) ([]byte, error) {
34-
var cert disperser.BlobInfo
33+
var cert common.Certificate
3534
err := rlp.DecodeBytes(key, &cert)
3635
if err != nil {
3736
return nil, fmt.Errorf("failed to decode DA cert to RLP format: %w", err)

store/memory.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import (
1010
"github.com/ethereum/go-ethereum/log"
1111
"github.com/ethereum/go-ethereum/rlp"
1212

13+
"github.com/Layr-Labs/eigenda-proxy/common"
1314
eigendacommon "github.com/Layr-Labs/eigenda-proxy/common"
1415
"github.com/Layr-Labs/eigenda-proxy/verify"
1516
"github.com/Layr-Labs/eigenda/api/clients/codecs"
@@ -104,7 +105,7 @@ func (e *MemStore) Get(ctx context.Context, commit []byte, domain eigendacommon.
104105
e.RLock()
105106
defer e.RUnlock()
106107

107-
var cert disperser.BlobInfo
108+
var cert common.Certificate
108109
err := rlp.DecodeBytes(commit, &cert)
109110
if err != nil {
110111
return nil, fmt.Errorf("failed to decode DA cert to RLP format: %w", err)
@@ -160,7 +161,7 @@ func (e *MemStore) Put(ctx context.Context, value []byte) ([]byte, error) {
160161
mockBatchHeaderHash := crypto.Keccak256Hash(entropy)
161162

162163
// only filling out commitment fields for now
163-
cert := &disperser.BlobInfo{
164+
cert := &common.Certificate{
164165
BlobHeader: &disperser.BlobHeader{
165166
Commitment: &grpccommon.G1Commitment{
166167
X: commitment.X.Marshal(),

0 commit comments

Comments
 (0)