@@ -93,12 +93,19 @@ func (node *localNode) AttachPeer(ctx context.Context, router router.InboundHand
93
93
return nil , err
94
94
}
95
95
tlsConfg := peer .TLSConfig (* tlsCert , nil )
96
- counter := prometheus .NewCounter (prometheus.CounterOpts {})
97
- clientUpgrader := peer .NewTLSClientUpgrader (tlsConfg , counter , time.Time {})
96
+ clientUpgrader := peer .NewTLSClientUpgrader (
97
+ tlsConfg ,
98
+ prometheus .NewCounter (prometheus.CounterOpts {}),
99
+ version .GetDurangoTime (node .networkID ),
100
+ )
98
101
conn , err := node .getConnFunc (ctx , node )
99
102
if err != nil {
100
103
return nil , err
101
104
}
105
+ peerID , conn , cert , err := clientUpgrader .Upgrade (conn )
106
+ if err != nil {
107
+ return nil , err
108
+ }
102
109
mc , err := message .NewCreator (
103
110
logging.NoLog {},
104
111
prometheus .NewRegistry (),
@@ -127,7 +134,7 @@ func (node *localNode) AttachPeer(ctx context.Context, router router.InboundHand
127
134
if err != nil {
128
135
return nil , err
129
136
}
130
- signerIP := ips .NewDynamicIPPort (net .IPv6zero , 0 )
137
+ signerIP := ips .NewDynamicIPPort (net .IPv6zero , 1 )
131
138
tls := tlsCert .PrivateKey .(crypto.Signer )
132
139
config := & peer.Config {
133
140
Metrics : metrics ,
@@ -149,16 +156,12 @@ func (node *localNode) AttachPeer(ctx context.Context, router router.InboundHand
149
156
SupportedACPs : []uint32 {},
150
157
ObjectedACPs : []uint32 {},
151
158
}
152
- _ , conn , cert , err := clientUpgrader .Upgrade (conn )
153
- if err != nil {
154
- return nil , err
155
- }
156
159
157
160
p := peer .Start (
158
161
config ,
159
162
conn ,
160
163
cert ,
161
- ids . NodeIDFromCert ( staking . CertificateFromX509 ( tlsCert . Leaf )) ,
164
+ peerID ,
162
165
peer .NewBlockingMessageQueue (
163
166
config .Metrics ,
164
167
logging.NoLog {},
0 commit comments