From 78153de78c9b71bf646deafea7b057e1d90359e7 Mon Sep 17 00:00:00 2001 From: avendauz Date: Thu, 12 Aug 2021 12:10:22 -0400 Subject: [PATCH] move torrent client creation right before broadcast --- x/nft/module.go | 25 ++++++++++++++----------- 1 file changed, 14 insertions(+), 11 deletions(-) diff --git a/x/nft/module.go b/x/nft/module.go index dbda06e4..15c54658 100644 --- a/x/nft/module.go +++ b/x/nft/module.go @@ -145,28 +145,31 @@ func (am AppModule) ExportGenesis(ctx sdk.Context) json.RawMessage { func (am AppModule) BeginBlock(_ sdk.Context, req abci.RequestBeginBlock) { } -var once sync.Once var registerPeerOnce sync.Once // EndBlock returns the end blocker for the nft module. It returns no validator // updates. func (am AppModule) EndBlock(ctx sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate { - once.Do(func () { - btClient, err := torrentClient.NewTorrentClient(am.btDirectory, am.btPort) - - if err != nil { - am.keeper.Logger(ctx).Error("Error creating btClient", "btClient", err) - } - - am.keeper.SetBtClient(btClient) - }) - err := am.keeper.CheckNftUserExists(ctx, am.keeper.KeyringReader, am.accKeeper) fmt.Println("Checking nft user exists", err) if err != nil { am.keeper.Logger(ctx).Error("nft user does not exist in keyring", "nft", err) } else { registerPeerOnce.Do(func () { + + btClient, err := torrentClient.NewTorrentClient(am.btDirectory, am.btPort) + fmt.Println("Torrent client created", *btClient) + if err != nil { + am.keeper.Logger(ctx).Error("Error creating btClient", "btClient", err) + } + + fmt.Println("Bt client before setting", *am.keeper.GetBtClient(), am.keeper.GetBtClient()) + + am.keeper.SetBtClient(btClient) + + fmt.Println("Bt client after setting", *am.keeper.GetBtClient(), am.keeper.GetBtClient()) + + fmt.Println("Doing broadcast register peer") go func() { err := am.keeper.BroadcastRegisterBtPeer(ctx)