|
| 1 | +package mg7 |
| 2 | + |
| 3 | +import ( |
| 4 | + "encoding/json" |
| 5 | + "fmt" |
| 6 | + "io" |
| 7 | + "io/ioutil" |
| 8 | + "os" |
| 9 | + "strings" |
| 10 | + |
| 11 | + "github.com/ipfs/go-cid" |
| 12 | +) |
| 13 | + |
| 14 | +var ( |
| 15 | + dnsAddr = "bootstrap.libp2p.io" |
| 16 | + dnsBootstrapPeers = []string{ |
| 17 | + "QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN", |
| 18 | + "QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa", |
| 19 | + "QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb", |
| 20 | + "QmcZf59bWwK5XFi76CZX8cbJ4BhTzzA3gU1ZjYZcYW3dwt", |
| 21 | + } |
| 22 | + smallKeyBootstrapPeers = []string{ |
| 23 | + "QmSoLnSGccFuZQJzRadHn95W2CrSFmZuTdDWP8HXaHca9z", |
| 24 | + "QmSoLueR4xBeUbY9WZ9xGUUxunbKWcrNFTDAadQJmocnWm", |
| 25 | + "QmSoLMeWqB7YGVLJN3pNLQpmmEk35v6wYtsMGLzSr5QBU3", |
| 26 | + "QmSoLju6m7xTh3DuokvT3886QRYqxAzb1kShaanJgW36yx", |
| 27 | + "QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM", |
| 28 | + "QmSoLSafTMBsPKadTEgaXctDQVcqN88CNLHXMkTNwMKPnu", |
| 29 | + "QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64", |
| 30 | + "QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd", |
| 31 | + } |
| 32 | + oldBootstrapAddrs = []string{ |
| 33 | + "/ip4/104.131.131.82/tcp/4001/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ", |
| 34 | + "/ip4/104.236.179.241/tcp/4001/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM", |
| 35 | + "/ip4/128.199.219.111/tcp/4001/p2p/QmSoLSafTMBsPKadTEgaXctDQVcqN88CNLHXMkTNwMKPnu", |
| 36 | + "/ip4/104.236.76.40/tcp/4001/p2p/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64", |
| 37 | + "/ip4/178.62.158.247/tcp/4001/p2p/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd", |
| 38 | + "/ip6/2604:a880:1:20::203:d001/tcp/4001/p2p/QmSoLPppuBtQSGwKDZT2M73ULpjvfd3aZ6ha4oFGL1KrGM", |
| 39 | + "/ip6/2400:6180:0:d0::151:6001/tcp/4001/p2p/QmSoLSafTMBsPKadTEgaXctDQVcqN88CNLHXMkTNwMKPnu", |
| 40 | + "/ip6/2604:a880:800:10::4a:5001/tcp/4001/p2p/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64", |
| 41 | + "/ip6/2a03:b0c0:0:1010::23:1001/tcp/4001/p2p/QmSoLer265NRgSp2LA3dPaeykiS1J6DifTC88f5uVQKNAd", |
| 42 | + } |
| 43 | +) |
| 44 | + |
| 45 | +// convFunc does an inplace conversion of the "Bootstrap" |
| 46 | +// configuration from one version to another |
| 47 | +type convFunc func([]string) []string |
| 48 | + |
| 49 | +// convertFile converts a config file from one version to another, the |
| 50 | +// converted config is stored in |
| 51 | +func convertFile(orig string, new string, convFunc convFunc) error { |
| 52 | + in, err := os.Open(orig) |
| 53 | + if err != nil { |
| 54 | + return err |
| 55 | + } |
| 56 | + out, err := os.Create(new) |
| 57 | + if err != nil { |
| 58 | + return err |
| 59 | + } |
| 60 | + return convert(in, out, convFunc) |
| 61 | +} |
| 62 | + |
| 63 | +// convert converts the config from one version to another, returns |
| 64 | +// the converted config as a map[string]interface{} |
| 65 | +func convert(in io.Reader, out io.Writer, convFunc convFunc) error { |
| 66 | + data, err := ioutil.ReadAll(in) |
| 67 | + if err != nil { |
| 68 | + return err |
| 69 | + } |
| 70 | + confMap := make(map[string]interface{}) |
| 71 | + if err = json.Unmarshal(data, &confMap); err != nil { |
| 72 | + return err |
| 73 | + } |
| 74 | + bootstrapi, _ := confMap["Bootstrap"].([]interface{}) |
| 75 | + if bootstrapi == nil { |
| 76 | + bootstrapi, _ := confMap["bootstrap"].([]interface{}) |
| 77 | + if bootstrapi == nil { |
| 78 | + return fmt.Errorf("Bootstrap field missing or of the wrong type") |
| 79 | + } |
| 80 | + } |
| 81 | + bootstrap := make([]string, len(bootstrapi)) |
| 82 | + for i := range bootstrapi { |
| 83 | + bootstrap[i] = bootstrapi[i].(string) |
| 84 | + } |
| 85 | + res := convFunc(bootstrap) |
| 86 | + confMap["Bootstrap"] = res |
| 87 | + fixed, err := json.MarshalIndent(confMap, "", " ") |
| 88 | + if err != nil { |
| 89 | + return err |
| 90 | + } |
| 91 | + out.Write(fixed) |
| 92 | + out.Write([]byte("\n")) |
| 93 | + return nil |
| 94 | +} |
| 95 | + |
| 96 | +func ver7to8(bootstrap []string) []string { |
| 97 | + // Make sure the dnsaddrs bootstrap peers are included |
| 98 | + var res []string |
| 99 | + for _, p := range dnsBootstrapPeers { |
| 100 | + res = append(res, fmt.Sprintf("/dnsaddr/%s/p2p/%s", dnsAddr, p)) |
| 101 | + } |
| 102 | + |
| 103 | + // Filter out peers that we added above, or that have an ID known to belong |
| 104 | + // to a peer with a small key |
| 105 | + for _, addr := range bootstrap { |
| 106 | + if ok, err := isDNSBootstrapPeer(addr); !ok && err == nil { |
| 107 | + if ok, err = isSmallKeyPeer(addr); !ok && err == nil { |
| 108 | + // Replace /ipfs with /p2p |
| 109 | + addr = strings.Replace(addr, "/ipfs", "/p2p", -1) |
| 110 | + res = append(res, addr) |
| 111 | + } |
| 112 | + } |
| 113 | + } |
| 114 | + |
| 115 | + return res |
| 116 | +} |
| 117 | + |
| 118 | +func ver8to7(bootstrap []string) []string { |
| 119 | + // Make sure the old addresses are included |
| 120 | + res := append([]string{}, oldBootstrapAddrs...) |
| 121 | + |
| 122 | + oldPeerIDs := make(map[string]struct{}) |
| 123 | + for _, addr := range oldBootstrapAddrs { |
| 124 | + pid, err := getAddrPeerID(addr) |
| 125 | + if err != nil { |
| 126 | + panic(err) |
| 127 | + } |
| 128 | + oldPeerIDs[pid] = struct{}{} |
| 129 | + } |
| 130 | + |
| 131 | + // Filter out old addresses added above, and addresses with the new DNS |
| 132 | + // addresses |
| 133 | + for _, btAddr := range bootstrap { |
| 134 | + pid, err := getAddrPeerID(btAddr) |
| 135 | + if err == nil { |
| 136 | + if _, ok := oldPeerIDs[pid]; !ok && !strings.Contains(btAddr, dnsAddr) { |
| 137 | + res = append(res, btAddr) |
| 138 | + } |
| 139 | + } |
| 140 | + } |
| 141 | + |
| 142 | + return res |
| 143 | +} |
| 144 | + |
| 145 | +func getAddrPeerID(addr string) (string, error) { |
| 146 | + // eg /ip4/104.131.131.82/tcp/4001/ipfs/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ |
| 147 | + parts := strings.Split(addr, "/") |
| 148 | + if len(parts) == 0 { |
| 149 | + return "", fmt.Errorf("Could not parse peer ID from addr '%s'", addr) |
| 150 | + } |
| 151 | + last := parts[len(parts)-1] |
| 152 | + if _, err := cid.Decode(last); err != nil { |
| 153 | + return "", fmt.Errorf("Could not parse peer ID from addr '%s'", addr) |
| 154 | + } |
| 155 | + return last, nil |
| 156 | +} |
| 157 | + |
| 158 | +func addrPeerIDInList(peers []string, addr string) (bool, error) { |
| 159 | + addrID, err := getAddrPeerID(addr) |
| 160 | + if err != nil { |
| 161 | + return false, err |
| 162 | + } |
| 163 | + for _, p := range peers { |
| 164 | + if p == addrID { |
| 165 | + return true, nil |
| 166 | + } |
| 167 | + } |
| 168 | + return false, nil |
| 169 | +} |
| 170 | + |
| 171 | +func isDNSBootstrapPeer(addr string) (bool, error) { |
| 172 | + return addrPeerIDInList(dnsBootstrapPeers, addr) |
| 173 | +} |
| 174 | + |
| 175 | +func isSmallKeyPeer(addr string) (bool, error) { |
| 176 | + return addrPeerIDInList(smallKeyBootstrapPeers, addr) |
| 177 | +} |
0 commit comments