mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-21 10:27:46 +08:00
6a008fc74c
* chore: apply go fix modernizers from Go 1.26
automated refactoring: interface{} to any, slices.Contains,
and other idiomatic updates.
* feat(ci): add `go fix` check to Go analysis workflow
ensures Go 1.26 modernizers are applied, fails CI if `go fix ./...`
produces any changes (similar to existing `go fmt` enforcement)
42 lines
1.1 KiB
Go
42 lines
1.1 KiB
Go
package cli
|
|
|
|
import (
|
|
"bytes"
|
|
"testing"
|
|
|
|
"github.com/ipfs/go-test/random"
|
|
"github.com/ipfs/kubo/test/cli/harness"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestDHTAutoclient(t *testing.T) {
|
|
t.Parallel()
|
|
nodes := harness.NewT(t).NewNodes(10).Init()
|
|
harness.Nodes(nodes[8:]).ForEachPar(func(node *harness.Node) {
|
|
node.IPFS("config", "Routing.Type", "autoclient")
|
|
})
|
|
nodes.StartDaemons().Connect()
|
|
t.Cleanup(func() { nodes.StopDaemons() })
|
|
|
|
t.Run("file added on node in client mode is retrievable from node in client mode", func(t *testing.T) {
|
|
t.Parallel()
|
|
randomBytes := random.Bytes(1000)
|
|
randomBytes = append(randomBytes, '\r')
|
|
hash := nodes[8].IPFSAdd(bytes.NewReader(randomBytes))
|
|
|
|
res := nodes[9].IPFS("cat", hash)
|
|
assert.Equal(t, randomBytes, []byte(res.Stdout.Trimmed()))
|
|
})
|
|
|
|
t.Run("file added on node in server mode is retrievable from all nodes", func(t *testing.T) {
|
|
t.Parallel()
|
|
randomBytes := random.Bytes(1000)
|
|
hash := nodes[0].IPFSAdd(bytes.NewReader(randomBytes))
|
|
|
|
for i := range 10 {
|
|
res := nodes[i].IPFS("cat", hash)
|
|
assert.Equal(t, randomBytes, []byte(res.Stdout.Trimmed()))
|
|
}
|
|
})
|
|
}
|