nodekey.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. package common
  2. import (
  3. "fmt"
  4. "github.com/libp2p/go-libp2p-core/crypto"
  5. "github.com/libp2p/go-libp2p-core/peer"
  6. "go.uber.org/zap"
  7. "io/ioutil"
  8. "os"
  9. )
  10. func GetOrCreateNodeKey(logger *zap.Logger, path string) (crypto.PrivKey, error) {
  11. b, err := ioutil.ReadFile(path)
  12. if err != nil {
  13. if os.IsNotExist(err) {
  14. logger.Info("No node key found, generating a new one...", zap.String("path", path))
  15. priv, _, err := crypto.GenerateKeyPair(crypto.Ed25519, -1)
  16. if err != nil {
  17. panic(err)
  18. }
  19. s, err := crypto.MarshalPrivateKey(priv)
  20. if err != nil {
  21. panic(err)
  22. }
  23. err = ioutil.WriteFile(path, s, 0600)
  24. if err != nil {
  25. return nil, fmt.Errorf("failed to write node key: %w", err)
  26. }
  27. return priv, nil
  28. } else {
  29. return nil, fmt.Errorf("failed to read node key: %w", err)
  30. }
  31. }
  32. priv, err := crypto.UnmarshalPrivateKey(b)
  33. if err != nil {
  34. return nil, fmt.Errorf("failed to unmarshal node key: %w", err)
  35. }
  36. peerID, err := peer.IDFromPrivateKey(priv)
  37. if err != nil {
  38. panic(err)
  39. }
  40. logger.Info("Found existing node key",
  41. zap.String("path", path),
  42. zap.Stringer("peerID", peerID))
  43. return priv, nil
  44. }