forked from rollkit/rollkit
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge remote-tracking branch 'origin/main' into assert
- Loading branch information
Showing
19 changed files
with
230 additions
and
97 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,125 @@ | ||
| package newda | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/binary" | ||
| "fmt" | ||
|
|
||
| pb "github.com/rollkit/rollkit/types/pb/rollkit" | ||
|
|
||
| "github.com/gogo/protobuf/proto" | ||
| ds "github.com/ipfs/go-datastore" | ||
|
|
||
| newda "github.com/rollkit/go-da" | ||
| "github.com/rollkit/rollkit/da" | ||
| "github.com/rollkit/rollkit/third_party/log" | ||
| "github.com/rollkit/rollkit/types" | ||
| ) | ||
|
|
||
| // NewDA is a new DA implementation. | ||
| type NewDA struct { | ||
| DA newda.DA | ||
| logger log.Logger | ||
| } | ||
|
|
||
| // Init is called once to allow DA client to read configuration and initialize resources. | ||
| func (n *NewDA) Init(namespaceID types.NamespaceID, config []byte, kvStore ds.Datastore, logger log.Logger) error { | ||
| n.logger = logger | ||
| return nil | ||
| } | ||
|
|
||
| // Start creates connection to gRPC server and instantiates gRPC client. | ||
| func (n *NewDA) Start() error { | ||
| return nil | ||
| } | ||
|
|
||
| // Stop closes connection to gRPC server. | ||
| func (n *NewDA) Stop() error { | ||
| return nil | ||
| } | ||
|
|
||
| // SubmitBlocks submits blocks to DA. | ||
| func (n *NewDA) SubmitBlocks(ctx context.Context, blocks []*types.Block) da.ResultSubmitBlocks { | ||
| blobs := make([][]byte, len(blocks)) | ||
| for i := range blocks { | ||
| blob, err := blocks[i].MarshalBinary() | ||
| if err != nil { | ||
| return da.ResultSubmitBlocks{ | ||
| BaseResult: da.BaseResult{ | ||
| Code: da.StatusError, | ||
| Message: "failed to serialize block", | ||
| }, | ||
| } | ||
| } | ||
| blobs[i] = blob | ||
| } | ||
| ids, _, err := n.DA.Submit(blobs) | ||
| if err != nil { | ||
| return da.ResultSubmitBlocks{ | ||
| BaseResult: da.BaseResult{ | ||
| Code: da.StatusError, | ||
| Message: "failed to submit blocks: " + err.Error(), | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| return da.ResultSubmitBlocks{ | ||
| BaseResult: da.BaseResult{ | ||
| Code: da.StatusSuccess, | ||
| DAHeight: binary.LittleEndian.Uint64(ids[0]), | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| // RetrieveBlocks retrieves blocks from DA. | ||
| func (n *NewDA) RetrieveBlocks(ctx context.Context, dataLayerHeight uint64) da.ResultRetrieveBlocks { | ||
| ids, err := n.DA.GetIDs(dataLayerHeight) | ||
| if err != nil { | ||
| return da.ResultRetrieveBlocks{ | ||
| BaseResult: da.BaseResult{ | ||
| Code: da.StatusError, | ||
| Message: fmt.Sprintf("failed to get IDs: %s", err.Error()), | ||
| DAHeight: dataLayerHeight, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| blobs, err := n.DA.Get(ids) | ||
| if err != nil { | ||
| return da.ResultRetrieveBlocks{ | ||
| BaseResult: da.BaseResult{ | ||
| Code: da.StatusError, | ||
| Message: fmt.Sprintf("failed to get blobs: %s", err.Error()), | ||
| DAHeight: dataLayerHeight, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| blocks := make([]*types.Block, len(blobs)) | ||
| for i, blob := range blobs { | ||
| var block pb.Block | ||
| err = proto.Unmarshal(blob, &block) | ||
| if err != nil { | ||
| n.logger.Error("failed to unmarshal block", "daHeight", dataLayerHeight, "position", i, "error", err) | ||
| continue | ||
| } | ||
| blocks[i] = new(types.Block) | ||
| err := blocks[i].FromProto(&block) | ||
| if err != nil { | ||
| return da.ResultRetrieveBlocks{ | ||
| BaseResult: da.BaseResult{ | ||
| Code: da.StatusError, | ||
| Message: err.Error(), | ||
| }, | ||
| } | ||
| } | ||
| } | ||
|
|
||
| return da.ResultRetrieveBlocks{ | ||
| BaseResult: da.BaseResult{ | ||
| Code: da.StatusSuccess, | ||
| DAHeight: dataLayerHeight, | ||
| }, | ||
| Blocks: blocks, | ||
| } | ||
| } |
Oops, something went wrong.