mirror of
https://github.com/luxfi/node.git
synced 2026-10-30 15:24:05 +00:00
zeekay
7cf87b230b
The module already called itself github.com/luxfi/node while containing no node in Go: cmd/luxd was twenty-one lines that printed the size of a few types, and the Go column of the matrix measured a VM plugin. A repo that fetches the thing it claims to be has not replaced it, so the Go sources move in — 1515 files, the daemon and everything under it — and the build reaches outside this module for nothing. Rust and C++ sit beside it unchanged and are still measured against it by the differential. That is the point of one repo: the reference implementation and the two ports are the same checkout, so parity is a thing you can run rather than a thing you assert. Verified: builds, and the closure carries no lux-private — checked at build time rather than believed. The daemon starts twelve chains on a local network (P X C Q Z A B G K M F, plus D through its plugin) and reports healthy.
93 lines
2.6 KiB
Go
93 lines
2.6 KiB
Go
// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package blockdb
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/luxfi/compress"
|
|
)
|
|
|
|
func TestDataSplitting(t *testing.T) {
|
|
// Each data file should have enough space for 2 blocks
|
|
config := DefaultConfig().WithMaxDataFileSize(1024 * 2.5)
|
|
store, cleanup := newTestDatabase(t, config)
|
|
defer cleanup()
|
|
|
|
// Override the compressor so we can have fixed size blocks
|
|
store.compressor = compress.NewNoCompressor()
|
|
|
|
// create 11 blocks, 1kb each
|
|
numBlocks := 11
|
|
blocks := make([][]byte, numBlocks)
|
|
for i := range numBlocks {
|
|
blocks[i] = fixedSizeBlock(t, 1024, uint64(i))
|
|
require.NoError(t, store.WriteBlock(uint64(i), blocks[i]))
|
|
}
|
|
|
|
// Verify that multiple data files were created.
|
|
files, err := os.ReadDir(store.config.DataDir)
|
|
require.NoError(t, err)
|
|
var dataFileCount int
|
|
for _, file := range files {
|
|
var index int
|
|
if n, err := fmt.Sscanf(file.Name(), dataFileNameFormat, &index); n == 1 && err == nil {
|
|
dataFileCount++
|
|
}
|
|
}
|
|
|
|
// 6 data files should be created
|
|
require.Equal(t, 6, dataFileCount)
|
|
|
|
// Verify all blocks are readable
|
|
for i := range numBlocks {
|
|
readBlock, err := store.ReadBlock(uint64(i))
|
|
require.NoError(t, err)
|
|
require.Equal(t, blocks[i], readBlock)
|
|
}
|
|
|
|
// reopen and verify all blocks are readable
|
|
require.NoError(t, store.Close())
|
|
config = config.WithDataDir(store.config.DataDir).WithIndexDir(store.config.IndexDir)
|
|
store, err = New(config, store.log)
|
|
require.NoError(t, err)
|
|
store.compressor = compress.NewNoCompressor()
|
|
defer store.Close()
|
|
for i := range numBlocks {
|
|
readBlock, err := store.ReadBlock(uint64(i))
|
|
require.NoError(t, err)
|
|
require.Equal(t, blocks[i], readBlock)
|
|
}
|
|
}
|
|
|
|
func TestDataSplitting_DeletedFile(t *testing.T) {
|
|
config := DefaultConfig().WithMaxDataFileSize(1024 * 2.5)
|
|
store, cleanup := newTestDatabase(t, config)
|
|
defer cleanup()
|
|
|
|
// create 5 blocks, 1kb each
|
|
numBlocks := 5
|
|
blocks := make([][]byte, numBlocks)
|
|
for i := range numBlocks {
|
|
blocks[i] = fixedSizeBlock(t, 1024, uint64(i))
|
|
require.NoError(t, store.WriteBlock(uint64(i), blocks[i]))
|
|
}
|
|
store.Close()
|
|
|
|
// Delete the first data file (blockdb_0.dat)
|
|
firstDataFilePath := filepath.Join(store.config.DataDir, fmt.Sprintf(dataFileNameFormat, 0))
|
|
require.NoError(t, os.Remove(firstDataFilePath))
|
|
|
|
// reopen and verify the blocks
|
|
require.NoError(t, store.Close())
|
|
config = config.WithIndexDir(store.config.IndexDir).WithDataDir(store.config.DataDir)
|
|
_, err := New(config, store.log)
|
|
require.ErrorIs(t, err, ErrCorrupted)
|
|
}
|