forked from Silverfish/proton-bridge
fix(GODT-2802): Fix missing key pass input for keyring unlock
This commit is contained in:
@ -117,6 +117,7 @@ func (s *syncHandler) launch(service *Service) {
|
|||||||
panicHandler: service.panicHandler,
|
panicHandler: service.panicHandler,
|
||||||
reporter: service.reporter,
|
reporter: service.reporter,
|
||||||
maxSyncMemory: service.maxSyncMemory,
|
maxSyncMemory: service.maxSyncMemory,
|
||||||
|
keyProvider: service.identityState.keyPassProvider,
|
||||||
}
|
}
|
||||||
|
|
||||||
s.group.Once(func(ctx context.Context) {
|
s.group.Once(func(ctx context.Context) {
|
||||||
|
|||||||
@ -50,6 +50,7 @@ type syncJob struct {
|
|||||||
identityState *useridentity.State
|
identityState *useridentity.State
|
||||||
panicHandler async.PanicHandler
|
panicHandler async.PanicHandler
|
||||||
reporter reporter.Reporter
|
reporter reporter.Reporter
|
||||||
|
keyProvider useridentity.KeyPassProvider
|
||||||
maxSyncMemory uint64
|
maxSyncMemory uint64
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -381,7 +381,7 @@ func startMessageBuilder(ctx context.Context, s *syncJob, buildCh <-chan downloa
|
|||||||
logrus.Debugf("sync builder exit")
|
logrus.Debugf("sync builder exit")
|
||||||
}()
|
}()
|
||||||
|
|
||||||
if err := s.identityState.WithAddrKRs(nil, func(_ *crypto.KeyRing, addrKRs map[string]*crypto.KeyRing) error {
|
if err := s.identityState.WithAddrKRs(s.keyProvider.KeyPass(), func(_ *crypto.KeyRing, addrKRs map[string]*crypto.KeyRing) error {
|
||||||
maxMessagesInParallel := runtime.NumCPU()
|
maxMessagesInParallel := runtime.NumCPU()
|
||||||
|
|
||||||
for buildBatch := range buildCh {
|
for buildBatch := range buildCh {
|
||||||
|
|||||||
Reference in New Issue
Block a user