feat: beacon-storage-part2

impl get and put for LightClientFinalityUpdate and LightClientOptimisticUpdate

portalnetwork/beacon/storage.go

@@ -19,6 +19,12 @@ type BeaconStorage struct {
 	db                     *sql.DB
 	log                    log.Logger
 	spec                   *common.Spec
+	cache                  *beaconStorageCache
+}
+
+type beaconStorageCache struct {
+	OptimisticUpdate []byte
+	FinalityUpdate   []byte
 }
 
 var _ storage.ContentStorage = &BeaconStorage{}
@@ -29,6 +35,7 @@ func NewBeaconStorage(config storage.PortalStorageConfig) (storage.ContentStorag
 		db:                     config.DB,
 		log:                    log.New("beacon_storage"),
 		spec:                   config.Spec,
+		cache:                  &beaconStorageCache{},
 	}
 	if err := bs.setup(); err != nil {
 		return nil, err
@@ -58,7 +65,15 @@ func (bs *BeaconStorage) Get(contentKey []byte, contentId []byte) ([]byte, error
 		}
 		return bs.getLcUpdateValueByRange(lightClientUpdateKey.StartPeriod, lightClientUpdateKey.StartPeriod+lightClientUpdateKey.Count)
 	case LightClientFinalityUpdate:
+		if bs.cache.FinalityUpdate == nil {
+			return nil, storage.ErrContentNotFound
+		}
+		return bs.cache.FinalityUpdate, nil
 	case LightClientOptimisticUpdate:
+		if bs.cache.OptimisticUpdate == nil {
+			return nil, storage.ErrContentNotFound
+		}
+		return bs.cache.OptimisticUpdate, nil
 	}
 	return nil, nil
 }
@@ -94,7 +109,11 @@ func (bs *BeaconStorage) Put(contentKey []byte, contentId []byte, content []byte
 		}
 		return nil
 	case LightClientFinalityUpdate:
+		bs.cache.FinalityUpdate = content
+		return nil
 	case LightClientOptimisticUpdate:
+		bs.cache.OptimisticUpdate = content
+		return nil
 	}
 	return nil
 }

portalnetwork/beacon/storage_test.go

@@ -33,33 +33,25 @@ func TestGetAndPut(t *testing.T) {
 	beaconStorage, err := genStorage(testDir)
 	require.NoError(t, err)
 	defer clearNodeData(testDir)
-	key, value, err := getClientBootstrap()
+
+	testData, err := getTestData()
 	require.NoError(t, err)
 
-	contentId := defaultContentIdFunc(key)
+	for _, entry := range testData {
-	_, err = beaconStorage.Get(key, contentId)
+		key := entry.key
-	require.Equal(t, storage.ErrContentNotFound, err)
+		value := entry.value
 
-	err = beaconStorage.Put(key, contentId, value)
+		contentId := defaultContentIdFunc(key)
-	require.NoError(t, err)
+		_, err = beaconStorage.Get(key, contentId)
+		require.Equal(t, storage.ErrContentNotFound, err)
 
-	res, err := beaconStorage.Get(key, contentId)
+		err = beaconStorage.Put(key, contentId, value)
-	require.NoError(t, err)
+		require.NoError(t, err)
-	require.Equal(t, value, res)
 
-	key, value, err = getClientUpdatesByRange()
+		res, err := beaconStorage.Get(key, contentId)
-	require.NoError(t, err)
+		require.NoError(t, err)
-
+		require.Equal(t, value, res)
-	contentId = defaultContentIdFunc(key)
+	}
-	_, err = beaconStorage.Get(key, contentId)
-	require.Equal(t, storage.ErrContentNotFound, err)
-
-	err = beaconStorage.Put(key, contentId, value)
-	require.NoError(t, err)
-
-	res, err = beaconStorage.Get(key, contentId)
-	require.NoError(t, err)
-	require.Equal(t, value, res)
 }
 
 func genStorage(testDir string) (storage.ContentStorage, error) {
@@ -77,38 +69,40 @@ func genStorage(testDir string) (storage.ContentStorage, error) {
 	return NewBeaconStorage(*config)
 }
 
-func getClientBootstrap() ([]byte, []byte, error) {
+type entry struct {
-	filePath := "testdata/light_client_bootstrap.json"
+	key   []byte
-
+	value []byte
-	f, err := os.ReadFile(filePath)
-	if err != nil {
-		return nil, nil, err
-	}
-	var result map[string]map[string]string
-	err = json.Unmarshal(f, &result)
-	if err != nil {
-		return nil, nil, err
-	}
-	contentKey := hexutil.MustDecode(result["6718368"]["content_key"])
-	contentValue := hexutil.MustDecode(result["6718368"]["content_value"])
-	return contentKey, contentValue, nil
 }
 
-func getClientUpdatesByRange() ([]byte, []byte, error) {
+func getTestData() ([]entry, error) {
-	filePath := "testdata/light_client_updates_by_range.json"
+	baseDir := "./testdata"
+	items, err := os.ReadDir(baseDir)
+	if err != nil {
+		return nil, err
+	}
 
-	f, err := os.ReadFile(filePath)
+	entries := make([]entry, 0)
-	if err != nil {
+
-		return nil, nil, err
+	for _, item := range items {
+		if !item.IsDir() {
+			f, err := os.ReadFile(fmt.Sprintf("%s/%s", baseDir, item.Name()))
+			if err != nil {
+				return nil, err
+			}
+			var result map[string]map[string]string
+			err = json.Unmarshal(f, &result)
+			if err != nil {
+				return nil, err
+			}
+			for _, v := range result {
+				entries = append(entries, entry{
+					key:   hexutil.MustDecode(v["content_key"]),
+					value: hexutil.MustDecode(v["content_value"]),
+				})
+			}
+		}
 	}
-	var result map[string]map[string]string
+	return entries, nil
-	err = json.Unmarshal(f, &result)
-	if err != nil {
-		return nil, nil, err
-	}
-	contentKey := hexutil.MustDecode(result["6684738"]["content_key"])
-	contentValue := hexutil.MustDecode(result["6684738"]["content_value"])
-	return contentKey, contentValue, nil
 }
 
 func clearNodeData(nodeDataDir string) {