MailSpring源码分析--同步邮件 重试 邮件数据的处理

Qter

1. app\internal_packages\notifications\lib\items\account-error-notif.tsx
   
2. this._onCheckAgain([erroredAccount]),
   
3.   _onCheckAgain(accounts) {
   
4.   accounts.forEach(acct => AppEnv.mailsyncBridge.forceRelaunchClient(acct));
   
5.   }
   
6.   
   
7. 
   
8. app\src\flux\mailsync-bridge.ts
   
9. async forceRelaunchClient(account: Account) {
   
10.   const keys = await KeyManager._getKeyHash();
    
11.   this._launchClient(account, keys, { force: true });
    
12. }
    
13. 
    
14. async _launchClient(account: Account, keys, { force }: { force?: boolean } = {}) {
    
15.   const client = new MailsyncProcess(this._getClientConfiguration());
    
16.     const fullAccountJSON = (await KeyManager.insertAccountSecrets(account, keys)).toJSON();
    
17.    client.account = fullAccountJSON;
    
18.     client.identity = IdentityStore.identity();
    
19.     client.sync();
    
20.     client.on('deltas', this._onIncomingMessages);
    
21. }
    
22. 
    
23. _onIncomingMessages = msgs => {
    
24. for (const msg of msgs) {
    
25.       const models = modelJSONs.map(Utils.convertToModel);
    
26.       this._onIncomingChangeRecord(
    
27.         new DatabaseChangeRecord({
    
28.           type, // TODO BG move to "model" naming style, finding all uses might be tricky
    
29.           objectClass: modelClass,
    
30.           objects: models,
    
31.           objectsRawJSON: modelJSONs,
    
32.         })
    
33.       );
    
34. }
    
35. }
    
36. 
    
37. app\src\mailsync-process.ts
    
38. sync() {
    
39. this._spawnProcess('sync');
    
40.   const msgs = outBuffer.split('\n');
    
41.           outBuffer = msgs.pop();
    
42.           this.emit('deltas', msgs);
    
43. }

复制代码