Skip to content

Commit

Permalink
added all changes
Browse files Browse the repository at this point in the history
  • Loading branch information
afkbyte committed Jun 9, 2024
1 parent 0b37bb8 commit 48faf73
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 5 deletions.
2 changes: 1 addition & 1 deletion .gitmodules
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[submodule "go-ethereum"]
path = go-ethereum
url = https://github.com/OffchainLabs/go-ethereum.git
url = git@github.com:Layr-Labs/nitro-go-ethereum-private.git
[submodule "fastcache"]
path = fastcache
url = https://github.com/OffchainLabs/fastcache.git
Expand Down
4 changes: 2 additions & 2 deletions cmd/replay/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -152,7 +152,7 @@ func (r *BlobPreimageReader) Initialize(ctx context.Context) error {

// struct for recovering data from preimage, impl interface EigenDAReader

func (dasReader *PreimageEigenDAReader) QueryBlob(ctx context.Context, cert *eigenda.EigenDABlobInfo) ([]byte, error) {
func (dasReader *PreimageEigenDAReader) QueryBlob(ctx context.Context, cert *eigenda.EigenDABlobInfo, domain string) ([]byte, error) {
dataPointer, err := cert.SerializeCommitment()
if err != nil {
return nil, err
Expand Down Expand Up @@ -241,7 +241,7 @@ func main() {
daProviders = append(daProviders, arbstate.NewDAProviderEigenDA(eigenDAReader))
}
daProviders = append(daProviders, arbstate.NewDAProviderBlobReader(&BlobPreimageReader{}))
inboxMultiplexer := arbstate.NewInboxMultiplexer(backend, delayedMessagesRead, daProviders, nil, keysetValidationMode)
inboxMultiplexer := arbstate.NewInboxMultiplexer(backend, delayedMessagesRead, daProviders, keysetValidationMode)
ctx := context.Background()
message, err := inboxMultiplexer.Pop(ctx)
if err != nil {
Expand Down
11 changes: 9 additions & 2 deletions eigenda/eigenda.go
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 +147,10 @@ func (e *EigenDA) Serialize(blobInfo *EigenDABlobInfo) ([]byte, error) {
return rlp.EncodeToBytes(blobInfo)
}

func (e *EigenDABlobInfo) SerializeCommitment() ([]byte, error) {
return append(e.BlobHeader.Commitment.X.Bytes(), e.BlobHeader.Commitment.Y.Bytes()...), nil
}

func (b *EigenDABlobInfo) loadBlobInfo(disperserBlobInfo *disperser.BlobInfo) {
b.BlobHeader.Commitment = &G1Point{
X: new(big.Int).SetBytes(disperserBlobInfo.GetBlobHeader().GetCommitment().GetX()),
Expand Down Expand Up @@ -219,9 +223,12 @@ func RecoverPayloadFromEigenDABatch(ctx context.Context,

// record preimage data,
log.Info("Recording preimage data for EigenDA")
pointer, err := blobInfo.SerializeCommitment()
if err != nil {
return nil, err
}
shaDataHash := sha256.New()
shaDataHash.Write(blobInfo.BlobHeader.Commitment.X.Bytes())
shaDataHash.Write(blobInfo.BlobHeader.Commitment.Y.Bytes())
shaDataHash.Write(pointer)
dataHash := shaDataHash.Sum([]byte{})
dataHash[0] = 1
if eigenDAPreimages != nil {
Expand Down

0 comments on commit 48faf73

Please sign in to comment.