/
litepeer.go
61 lines (49 loc) · 1.12 KB
/
litepeer.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
package main
// This example launches an IPFS-Lite peer and fetches a hello-world
// hash from the IPFS network.
import (
"context"
"fmt"
"io"
ipfslite "github.com/hsanjuan/ipfs-lite"
"github.com/ipfs/go-cid"
"github.com/libp2p/go-libp2p/core/crypto"
"github.com/multiformats/go-multiaddr"
)
func main() {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
ds := ipfslite.NewInMemoryDatastore()
priv, _, err := crypto.GenerateKeyPair(crypto.RSA, 2048)
if err != nil {
panic(err)
}
listen, _ := multiaddr.NewMultiaddr("/ip4/0.0.0.0/tcp/4005")
h, dht, err := ipfslite.SetupLibp2p(
ctx,
priv,
nil,
[]multiaddr.Multiaddr{listen},
ds,
ipfslite.Libp2pOptionsExtra...,
)
if err != nil {
panic(err)
}
lite, err := ipfslite.New(ctx, ds, nil, h, dht, nil)
if err != nil {
panic(err)
}
lite.Bootstrap(ipfslite.DefaultBootstrapPeers())
c, _ := cid.Decode("QmWATWQ7fVPP2EFGu71UkfnqhYXDYH566qy47CnJDgvs8u")
rsc, err := lite.GetFile(ctx, c)
if err != nil {
panic(err)
}
defer rsc.Close()
content, err := io.ReadAll(rsc)
if err != nil {
panic(err)
}
fmt.Println(string(content))
}