@@ -122,22 +122,18 @@ func (s *AvsSubscriber) SubscribeToNewTasksV2(newTaskCreatedChan chan *servicema
122122 for errMain == nil || errFallback == nil { //while one is active
123123 select {
124124 case err := <- sub .Err ():
125- s .logger .Warn ("Error in new task subscription" , "err" , err )
126- s .logger .Info ("failed states:" , "errMain" , errMain , "errFallback" , errFallback )
125+ s .logger .Warn ("Error in new task subscription of main connection" , "err" , err )
127126
128127 auxSub , errMain = SubscribeToNewTasksV2Retryable (& bind.WatchOpts {}, s .AvsContractBindings .ServiceManager , internalChannel , nil , retry .NetworkRetryParams ())
129128 if errMain == nil {
130- //sub.Unsubscribe()
131129 sub = auxSub // update the subscription only if it was successful
132130 s .logger .Info ("Resubscribed to fallback new task subscription" )
133131 }
134132 case err := <- subFallback .Err ():
135- s .logger .Info ("failed states:" , "errMain" , errMain , "errFallback" , errFallback )
136- s .logger .Warn ("Error in fallback new task subscription" , "err" , err )
133+ s .logger .Warn ("Error in new task subscription of fallback connection" , "err" , err )
137134
138135 auxSubFallback , errFallback = SubscribeToNewTasksV2Retryable (& bind.WatchOpts {}, s .AvsContractBindings .ServiceManagerFallback , internalChannel , nil , retry .NetworkRetryParams ())
139136 if errFallback == nil {
140- //subFallback.Unsubscribe()
141137 subFallback = auxSubFallback // update the subscription only if it was successful
142138 s .logger .Info ("Resubscribed to fallback new task subscription" )
143139 }
@@ -206,22 +202,18 @@ func (s *AvsSubscriber) SubscribeToNewTasksV3(newTaskCreatedChan chan *servicema
206202 for errMain == nil || errFallback == nil { //while one is active
207203 select {
208204 case err := <- sub .Err ():
209- s .logger .Warn ("Error in new task subscription" , "err" , err )
210- s .logger .Info ("failed states:" , "errMain" , errMain , "errFallback" , errFallback )
205+ s .logger .Warn ("Error in new task subscription of main connection" , "err" , err )
211206
212207 auxSub , errMain = SubscribeToNewTasksV3Retryable (& bind.WatchOpts {}, s .AvsContractBindings .ServiceManager , internalChannel , nil , retry .NetworkRetryParams ())
213208 if errMain == nil {
214- //sub.Unsubscribe()
215209 sub = auxSub // update the subscription only if it was successful
216210 s .logger .Info ("Resubscribed to fallback new task subscription" )
217211 }
218212 case err := <- subFallback .Err ():
219- s .logger .Warn ("Error in fallback new task subscription" , "err" , err )
220- s .logger .Info ("failed states:" , "errMain" , errMain , "errFallback" , errFallback )
213+ s .logger .Warn ("Error in new task subscription of fallback connection" , "err" , err )
221214
222215 auxSubFallback , errFallback = SubscribeToNewTasksV3Retryable (& bind.WatchOpts {}, s .AvsContractBindings .ServiceManagerFallback , internalChannel , nil , retry .NetworkRetryParams ())
223216 if errFallback == nil {
224- //subFallback.Unsubscribe()
225217 subFallback = auxSubFallback // update the subscription only if it was successful
226218 s .logger .Info ("Resubscribed to fallback new task subscription" )
227219 }
0 commit comments