Method GetBlob

ethstorage/node/es_api.go:42–86

(kvIndex uint64, blobHash common.Hash, decodeType DecodeType, off, size uint64)

}

func (api *esAPI) GetBlob(kvIndex uint64, blobHash common.Hash, decodeType DecodeType, off, size uint64) (hexutil.Bytes, error) {
	blob := api.dl.Cache.GetKeyValueByIndex(kvIndex, blobHash)

	if blob == nil {
		commit, _, err := api.sm.TryReadMeta(kvIndex)
		if err != nil {
			return nil, err
		}

		if err := ethstorage.CompareCommits(blobHash.Bytes(), commit); err != nil {
			return nil, err
		}

		readCommit := common.Hash{}
		copy(readCommit[0:ethstorage.HashSizeInContract], blobHash[0:ethstorage.HashSizeInContract])

		var found bool
		blob, found, err = api.sm.TryRead(kvIndex, int(api.sm.MaxKvSize()), readCommit)
		if err != nil {
			return nil, err
		}
		if !found {
			return nil, ethereum.NotFound
		}
	} else {
		blob = api.sm.DecodeBlob(blob, blobHash, kvIndex, api.sm.MaxKvSize())
	}

	ret := blob

	if decodeType == PaddingPer31Bytes {
		ret = utils.DecodeBlob(blob)
	} else if decodeType == OptimismCompact {
		var err error
		if ret, err = utils.ToData(blob); err != nil {
			return nil, err
		}
	}

	if len(ret) < int(off+size) {
		return nil, errors.New("beyond the range of blob size")
	}

	return ret[off : off+size], nil
}