Skip to content

Commit 68772a8

Browse files
committed
stop trying to open rmb peer
1 parent 2db6bf4 commit 68772a8

1 file changed

Lines changed: 20 additions & 17 deletions

File tree

cmds/modules/api_gateway/main.go

Lines changed: 20 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package apigateway
33
import (
44
"context"
55
"crypto/ed25519"
6-
"encoding/hex"
6+
// "encoding/hex"
77
"fmt"
88

99
"github.com/cenkalti/backoff/v3"
@@ -49,20 +49,22 @@ func action(cli *cli.Context) error {
4949
if err != nil {
5050
return fmt.Errorf("fail to connect to message broker server: %w", err)
5151
}
52+
5253
redis, err := zbus.NewRedisClient(msgBrokerCon)
5354
if err != nil {
5455
return fmt.Errorf("fail to connect to message broker server: %w", err)
5556
}
57+
5658
idStub := stubs.NewIdentityManagerStub(redis)
5759

5860
sk := ed25519.PrivateKey(idStub.PrivateKey(cli.Context))
5961
pubKey := sk.Public().(ed25519.PublicKey)
6062
log.Info().Str("public key", string(pubKey)).Msg("node public key")
6163

62-
manager, err := environment.GetSubstrate()
63-
if err != nil {
64-
return fmt.Errorf("failed to create substrate manager: %w", err)
65-
}
64+
// manager, err := environment.GetSubstrate()
65+
// if err != nil {
66+
// return fmt.Errorf("failed to create substrate manager: %w", err)
67+
// }
6668

6769
router := peer.NewRouter()
6870
gw, err := registrar.NewRegistrarGateway(cli.Context, redis)
@@ -102,18 +104,19 @@ func action(cli *cli.Context) error {
102104
bo := backoff.NewExponentialBackOff()
103105
bo.MaxElapsedTime = 0
104106
backoff.Retry(func() error {
105-
_, err = peer.NewPeer(
106-
ctx,
107-
hex.EncodeToString(sk.Seed()),
108-
manager,
109-
router.Serve,
110-
peer.WithKeyType(peer.KeyTypeEd25519),
111-
peer.WithRelay(environment.GetRelaysURLs()...),
112-
peer.WithInMemoryExpiration(6*60*60), // 6 hours
113-
)
114-
if err != nil {
115-
return fmt.Errorf("failed to start a new rmb peer: %w", err)
116-
}
107+
// _, err = peer.NewPeer(
108+
// ctx,
109+
// hex.EncodeToString(sk.Seed()),
110+
// manager,
111+
// router.Serve,
112+
// peer.WithKeyType(peer.KeyTypeEd25519),
113+
// peer.WithRelay(environment.GetRelaysURLs()...),
114+
// peer.WithInMemoryExpiration(6*60*60), // 6 hours
115+
// )
116+
// if err != nil {
117+
// log.Error().Err(err).Msg("faling to start api-gateway, trying over and over again")
118+
// return fmt.Errorf("failed to start a new rmb peer: %w", err)
119+
// }
117120

118121
return nil
119122
}, bo)

0 commit comments

Comments
 (0)