| 1213 | } |
| 1214 | |
| 1215 | func createAndStartPrivValidatorGRPCClient( |
| 1216 | cfg *config.Config, |
| 1217 | chainID string, |
| 1218 | logger log.Logger, |
| 1219 | ) (types.PrivValidator, error) { |
| 1220 | pvsc, err := tmgrpc.DialRemoteSigner( |
| 1221 | cfg.PrivValidator, |
| 1222 | chainID, |
| 1223 | logger, |
| 1224 | cfg.Instrumentation.Prometheus, |
| 1225 | ) |
| 1226 | if err != nil { |
| 1227 | return nil, fmt.Errorf("failed to start private validator: %w", err) |
| 1228 | } |
| 1229 | |
| 1230 | // try to get a pubkey from private validate first time |
| 1231 | _, err = pvsc.GetPubKey(context.TODO()) |
| 1232 | if err != nil { |
| 1233 | return nil, fmt.Errorf("can't get pubkey: %w", err) |
| 1234 | } |
| 1235 | |
| 1236 | return pvsc, nil |
| 1237 | } |
| 1238 | |
| 1239 | func getRouterConfig(conf *config.Config, proxyApp proxy.AppConns) p2p.RouterOptions { |
| 1240 | opts := p2p.RouterOptions{ |