firemail

标题: pop流程跟踪 [打印本页]

---

作者: hechengjin    时间: 2016-3-27 23:24
标题: pop流程跟踪
-----向导窗口 emailWizard.xul  检测配置--------

接收方式选择pop3 。 重新测试：
onHalfManualTest

涉及到文件
emailWizard.js  
guessConfig成功后设置界面输入输出服务器配置
guessConfig.js  
guessConfig
1.创建AccountConfig对象 accountConfig.js   含有收发服务器参数
resultConfig = new AccountConfig();
2.如果离线，自动配置好resultConfig 的收发信服务器参数返回
if (Services.io.offline)

3.其它情况创建收发服务器探测对象
incomingHostDetector = new IncomingHostDetector(progress, incomingSuccess,
                                                  incomingError);
  outgoingHostDetector = new OutgoingHostDetector(progress, outgoingSuccess,
                                                  outgoingError);

根据设置好的服务器可能域名地址及对应端口号进行测试
"imap." +  domain  "pop3." +  domain等
incomingHostDetector.start
start : function(domain, hostIsPrecise, type, port, socketType)
_tryAll : function()
  thisTry.abortable = SocketUtil(

var transportService = Cc["@mozilla.org/network/socket-transport-service;1"]
                         .getService(Ci.nsISocketTransportService);
var transport = transportService.createTransport
var outstream = transport.openOutputStream(0, 0, 0);  --输出流
  var stream = transport.openInputStream(0, 0, 0);
  var instream = Cc["@mozilla.org/scriptableinputstream;1"]
      .createInstance(Ci.nsIScriptableInputStream);
  instream.init(stream);  ---输入流
var pump = Cc["@mozilla.org/network/input-stream-pump;1"]
        .createInstance(Ci.nsIInputStreamPump);
    pump.init(stream, -1, -1, 0, 0, false);----输入流
    pump.asyncRead(dataListener, null);   --异步读
    return new SocketAbortable(transport);
  } catch (e) { _error(e); }


-----向导窗口 emailWizard.xul  完成操作--------
emailWizard.js  
onCreate
{
  validateAndFinish(configFilledIn) //根据上一步检测出的配置参数进行验证
}
validateAndFinish
{
checkIncomingServerAlreadyExists//检测接收服务器是否已经存在  createInBackend.js 这四个条件相同即存在(username\hostname\type[imap、pop、nntp]\port)
checkOutgoingServerAlreadyExists//检测发送服务器是否已经存在 createInBackend.js 这三个条件相同即存在(username\hostname\port)
verifyConfig //登录验证 verifyConfig.js

}

verifyConfig{
//从账号管理组件入手
var accountManager = Cc["@mozilla.org/messenger/account-manager;1"]
                       .getService(Ci.nsIMsgAccountManager);
1.检测账号中是否有此收信服务器  accountManager.findRealServer
2. 不存在则创建  nsMsgAccountManager.cpp
var inServer =   accountManager.createIncomingServer(config.incoming.username,
                                        config.incoming.hostname,
                                        sanitize.enum(config.incoming.type,
                                                    ["pop3", "imap", "nntp"]));
并初始化负值其它相关参数
inServer.port = config.incoming.port;
  inServer.password = config.incoming.password;
    inServer.socketType = Ci.nsMsgSocketType.plain;
  inServer.authMethod = config.incoming.auth;

3.登录验证
verifyLogon(config, inServer, alter, msgWindow,
                  successCallback, errorCallback);
}

verifyLogon
{
// 设置验证用户登录的回调，verifyLogon 将同步创建 transport并利用通知(notification )回调 此侦听器同时侦听此url和证书错误，故实现 nsIUrlListener和nsIBadCertListener2 这两个接口 另外还实现了nsIInterfaceRequestor和nsISupports接口
  let listener = new urlListener(config, inServer, alter, msgWindow, successCallback, errorCallback);
let uri = inServer.verifyLogon(listener, msgWindow);

验证成功后调用 emailWizard.js 中的 finish : function()
}

urlListener.prototype =
{
//nsIUrlListener
OnStartRunningUrl: function(aUrl)
OnStopRunningUrl: function(aUrl, aExitCode)
//nsIBadCertListener2.idl
  notifyCertProblem: function(socketInfo, status, targetSite)
// nsIInterfaceRequestor
  getInterface: function(iid)
// nsISupports
  QueryInterface: function(iid)
}

inServer.verifyLogon
imap

• line 969, as member of class nsImapIncomingServer -- nsImapIncomingServer::VerifyLogon(nsIUrlListener *aUrlListener,
  

pop

• line 480, as member of class nsPop3IncomingServer -- nsPop3IncomingServer::VerifyLogon(nsIUrlListener *aUrlListener,
  

---

作者: hechengjin    时间: 2016-3-27 23:24

1. --------pop3验证底层实现-------
   
2. nsPop3IncomingServer.cpp
   
3. NS_IMETHODIMP nsPop3IncomingServer::VerifyLogon(nsIUrlListener *aUrlListener,nsIMsgWindow *aMsgWindow, nsIURI **aURL)
   
4. {
   
5.   nsresult rv;
   
6.   nsCOMPtr<nsIPop3Service> pop3Service = do_GetService(kCPop3ServiceCID, &rv);
   
7.   NS_ENSURE_SUCCESS(rv,rv);
   
8.   return pop3Service->VerifyLogon(this, aUrlListener, aMsgWindow, aURL);
   
9. }
   
10. 
    
11. nsPop3Service.cpp
    
12. NS_IMETHODIMP nsPop3Service::VerifyLogon(nsIMsgIncomingServer *aServer,...
    
13. {
    
14. //根据pop3收信服务器的前端设置(用户名[进行编码防止含有 / % @]、主机名、端口)构造url
    
15. char *urlSpec = PR_smprintf("pop3://%s@%s:%d/?verifyLogon", escapedUsername.get(), popHost.get(), popPort);
    
16. ////pop3://13342978053@pop3.139.com:110/?verifyLogon
    
17. //构造url接口智能指针 nsIURI
    
18. nsCOMPtr<nsIURI> url;   //参考下面 url构建做了什么
    
19.   rv = BuildPop3Url(urlSpec, nullptr, popServer, aUrlListener,  getter_AddRefs(url), aMsgWindow);
    
20. //运行url
    
21. rv = RunPopUrl(aServer, url);
    
22. 
    
23. }
    
24. 
    
25. RunPopUrl
    
26. {
    
27. 1.获取pop收信服务器配置的用户名
    
28. nsresult rv = aServer->GetRealUsername(userName);
    
29. 
    
30. 2.判断收信服务是否在忙
    
31. rv = aServer->GetServerBusy(&serverBusy);  //参考下面 服务是否在忙做了什么
    
32. a.忙，弹出提示
    
33. nsCOMPtr<nsIMsgMailNewsUrl> url = do_QueryInterface(aUrlToRun);
    
34.     if (url)
    
35.       AlertServerBusy(url);
    
36. b.不忙进行如下执行
    
37. nsRefPtr<nsPop3Protocol> protocol = new nsPop3Protocol(aUrlToRun); //参看下面的关于nsPop3Protocol类
    
38. //设置用户名
    
39. protocol->SetUsername(userName.get());
    
40. //加载url //参看下面的关于nsPop3Protocol类中加载Url
    
41. rv = protocol->LoadUrl(aUrlToRun);
    
42. //设置收取邮件数
    
43. protocol->SetNumForRETR(aNumForRETR);
    
44. }
    
45. 
    
46. 
    
47. ****url构建做了什么*************
    
48. url中有一个指向pop3sink的指针m_pop3Sink
    
49. nsresult nsPop3Service::BuildPop3Url()
    
50. {
    
51. nsPop3Sink *pop3Sink = new nsPop3Sink(); //nsIPop3Sink
    
52. pop3Sink->SetPopServer(server);
    
53.   pop3Sink->SetFolder(inbox);
    
54. //创建pop3Url
    
55. nsCOMPtr<nsIPop3URL> pop3Url = do_CreateInstance(kPop3UrlCID, &rv);
    
56. pop3Url->SetPop3Sink(pop3Sink);  //m_pop3Sink = aPop3Sink;
    
57. 
    
58. nsCOMPtr<nsIMsgMailNewsUrl> mailnewsurl = do_QueryInterface(pop3Url);
    
59. //前端传入的侦听器在这里注册  
    
60. mailnewsurl->RegisterListener(aUrlListener);
    
61. {
    
62. nsMsgMailNewsUrl::RegisterListener    mUrlListeners.AppendElement(aUrlListener);
    
63. nsMsgMailNewsUrl.cpp文件中使用 NOTIFY_URL_LISTENERS(propertyfunc_, params_) 发出侦听通知
    
64. 
    
65. }
    
66. ****************
    
67. 
    
68. ****服务是否在忙做了什么******
    
69. NS_IMETHODIMP nsMsgIncomingServer::GetServerBusy(bool * aServerBusy)
    
70. {
    
71.   NS_ENSURE_ARG_POINTER(aServerBusy);
    
72.   *aServerBusy = m_serverBusy;
    
73.   return NS_OK;
    
74. ｝
    
75. //主要看什么时候设置了忙状态
    
76. NS_IMETHODIMP nsMsgIncomingServer::SetServerBusy(bool aServerBusy)
    
77. {
    
78.   m_serverBusy = aServerBusy;
    
79.   return NS_OK;
    
80. }
    
81. 
    
82. 
    
83. ***************************
    
84. 
    
85. ************关于nsPop3Protocol类******nsPop3Protocol.cpp
    
86. class nsPop3Protocol : public nsMsgProtocol,
    
87.                        public nsIPop3Protocol,
    
88.                        public nsIMsgAsyncPromptListener
    
89. { ...}
    
90. nsresult nsPop3Protocol:oadUrl(nsIURI* aURL..)
    
91. {
    
92. //1.初始化url  完成功能
    
93. *a.日志初始化  b.创建pop3连接数据结构 m_pop3ConData  c.设置关于下载的其它参数初始值  d.从url中获取状态信息m_statusFeedback
    
94. *e.从url中获取收信服务器，及其相关参数m_socketType  authMethod 用于连接设置 f.记录此url于m_url变量  g.预留接收弹出窗口方法 ir
    
95. *h.初始化代理信息详细参考下面代理信息 usePAC=false    i.过滤器列表应用 可优化点，以提高性能？ j.连接类型设置  connectionType = "ssl";
    
96. *k.打开网络Socket 参考 打开网络Socket  l.创建命令输出流 参考 创建命令输出流  m.初始化后端访问的语言资源方法 mLocalBundle
    
97.   nsresult rv = Initialize(aURL);
    
98. 
    
99. //2.记录url
    
100. m_url = do_QueryInterface(aURL);
     
101. 
     
102. //3.参考 检测端口安全
     
103. rv = NS_CheckPortSafety(port, "pop");
     
104. 
     
105. //4.获取url的Query段mQuery，用来判决进行的查询操作上面url最后传入的字符串参数 参考 获取url的Query段
     
106. nsCAutoString queryPart;
     
107.   rv = url->GetQuery(queryPart);  //如： "verifyLogon"
     
108. 
     
109. //5.根据上面的返回设置连接结构中对应的标志值
     
110. m_pop3ConData->only_check_for_new_mail = (PL_strcasestr(queryPart.get(), "check") != nullptr);
     
111.   m_pop3ConData->verify_logon = (PL_strcasestr(queryPart.get(), "verifyLogon") != nullptr);
     
112.   m_pop3ConData->get_url = (PL_strcasestr(queryPart.get(), "gurl") != nullptr);
     
113. 
     
114. //6.非登录情况下执行
     
115. if (!m_pop3ConData->verify_logon)
     
116. {
     
117. m_pop3Server->GetLeaveMessagesOnServer(&m_pop3ConData->leave_on_server); // 会根据不同的邮件夹的设置获取
     
118. m_pop3Server->GetHeadersOnly(&m_pop3ConData->headers_only);  //根据收信服务器的设置获取
     
119. //关于消息大小的限制,并设置相关变量的值
     
120. server->GetLimitOfflineMessageSize(&limitMessageSize);  ----"limit_offline_message_size"
     
121. m_pop3ConData->size_limit = (max_size) ? max_size * 1024 : 50 * 1024;
     
122. //关于在服务器上留取邮件数量的设置
     
123. m_pop3Server->GetDeleteByAgeFromServer(&deleteByAgeFromServer);  //根据收信服务器的设置获取
     
124. deleteByAgeFromServer
     
125. ;
     
126. 
     
127.       if (deleteByAgeFromServer)
     
128.         m_pop3Server->GetNumDaysToLeaveOnServer(&numDaysToLeaveOnServer);  //根据收信服务器的设置获取
     
129. numDaysToLeaveOnServer
     
130. 
     
131. }
     
132. 
     
133. //7.记录sink  // UIDL stuff  UIDL的东西？？？
     
134. nsCOMPtr<nsIPop3URL> pop3Url = do_QueryInterface(m_url);
     
135.   if (pop3Url)
     
136.     pop3Url->GetPop3Sink(getter_AddRefs(m_nsIPop3Sink));
     
137. 
     
138. //8.关于邮件目录的设置
     
139. nsCOMPtr<nsIFile> mailDirectory;
     
140. //根据收信服务获取邮件目录 详细参考 收信服务获取本地目录
     
141. rv = server->GetLocalPath(getter_AddRefs(mailDirectory));   如创建的子目录名为“pop3.139.com”
     
142. 9.设置服务器为忙
     
143. server->SetServerBusy(true); // the server is now busy
     
144. 
     
145. 10.非登录状态下设置Pop3UidlHost链表结构  维护每个账号的哈希表？
     
146. if (!m_pop3ConData->verify_logon)
     
147.     m_pop3ConData->uidlinfo = net_pop3_load_state(hostName.get(), userName.get(), mailDirectory);
     
148. 
     
149. 11. 设置为无新邮件状态
     
150. m_pop3ConData->biffstate = nsIMsgFolder::nsMsgBiffState_NoMail;
     
151. 
     
152. 12.邮件删除逻辑处理  _____
     
153. if (m_pop3ConData->uidlinfo && numDaysToLeaveOnServer > 0)
     
154. ....
     
155. 13.uidl逻辑处理___
     
156. const char* uidl = PL_strcasestr(queryPart.get(), "uidl=");
     
157. .....
     
158. 14.连接状态设置
     
159. m_pop3ConData->next_state = POP3_START_CONNECT;
     
160.   m_pop3ConData->next_state_after_response = POP3_FINISH_CONNECT;
     
161. 
     
162. 15.运行当前url
     
163. m_pop3Server->SetRunningProtocol(this);
     
164.     return nsMsgProtocol:oadUrl(aURL);
     
165. 
     
166. 
     
167. 
     
168. 
     
169. 
     
170. 
     
171. 
     
172. }
     
173. 
     
174. 
     
175. ******************
     
176. ***** 收信服务获取本地目录*****
     
177. nsMsgIncomingServer.cpp
     
178. nsMsgIncomingServer::GetLocalPath(nsIFile **aLocalPath)
     
179. {
     
180. rv = GetFileValue("directory-rel", "directory", aLocalPath);
     
181. //根据当前收信服务器的相关信息创建对应目录
     
182. nsCOMPtr<nsIMsgProtocolInfo> protocolInfo;
     
183.   rv = getProtocolInfo(getter_AddRefs(protocolInfo));
     
184. nsCOMPtr<nsIFile> localPath;
     
185.   rv = protocolInfo->GetDefaultLocalPath(getter_AddRefs(localPath));
     
186. localPath->Create(nsIFile:IRECTORY_TYPE, 0755);
     
187. 
     
188. }
     
189. 
     
190. *****************************
     
191. 
     
192. 
     
193. ***代理信息********
     
194. PAC可能是代理访问控制的意思
     
195. nsProtocolProxyService.cpp
     
196. nsProtocolProxyService::Resolve(nsIURI *uri, uint32_t flags,
     
197. pop://pop3.139.com:110  ----代理url含有的相关信息
     
198. DIRECT  直接
     
199. class nsProxyInfo MOZ_FINAL : public nsIProxyInfo
     
200. **********************
     
201. 
     
202. *******打开网络Socket *********
     
203. rv = OpenNetworkSocketWithInfo(hostName.get(), port, connectionType, proxyInfo, ir);
     
204. {
     
205. //1. 获取 SocketTransportService
     
206. nsCOMPtr<nsISocketTransportService> socketService (do_GetService(NS_SOCKETTRANSPORTSERVICE_CONTRACTID));
     
207. //2.创建Transport  详细参见创建Transport
     
208. nsCOMPtr<nsISocketTransport> strans;
     
209.   rv = socketService->CreateTransport(&connectionType, connectionType != nullptr,
     
210.                                       nsDependentCString(aHostName),
     
211.                                       aGetPort, aProxyInfo,
     
212.                                       getter_AddRefs(strans));
     
213. //3.设置安全回调，即指向上面的ir用于后端弹出窗口
     
214. strans->SetSecurityCallbacks(callbacks);
     
215. 
     
216. //4.创建循环引用，可能用来防止线程阻塞？？？  是在主线程吗？线程ID是哪个？
     
217. // creates cyclic reference!
     
218.   nsCOMPtr<nsIThread> currentThread(do_GetCurrentThread());
     
219.   strans->SetEventSink(this, currentThread);
     
220. 
     
221. //5.记录当前传输连接
     
222. m_transport = strans;
     
223. 
     
224. //6.获取tcp连接超时设置,并进行相关设置
     
225. prefBranch->GetIntPref("mailnews.tcptimeout", &gSocketTimeout);
     
226. strans->SetTimeout(nsISocketTransport::TIMEOUT_CONNECT, gSocketTimeout + 60);
     
227.   strans->SetTimeout(nsISocketTransport::TIMEOUT_READ_WRITE, gSocketTimeout);
     
228. 
     
229. //7.设置QoS
     
230. (Quality of Service) "服务质量"  详细参看下面 关于Qos的获取
     
231. 
     
232. uint8_t qos;
     
233.   rv = GetQoSBits(&qos);
     
234.   if (NS_SUCCEEDED(rv))
     
235.     strans->SetQoSBits(qos);
     
236. 
     
237. 
     
238. //8.设置传输状态  详见下面  设置传输状态
     
239. return SetupTransportState();
     
240. 
     
241. }
     
242. ****************************
     
243. 
     
244. ***创建Transport*************
     
245. .\mozilla\netwerk\base\src\nsSocketTransportService2.cpp
     
246. nsSocketTransportService::CreateTransport(const char **types,
     
247. {
     
248. nsSocketTransport *trans = new nsSocketTransport();
     
249. nsresult rv = trans->Init(types, typeCount, host, port, proxyInfo);
     
250. }
     
251. ***************************
     
252. 
     
253. 
     
254. *******关于Qos的获取*************
     
255. nsCAutoString prefName("mail.");
     
256.   prefName.Append(protocol);
     
257.   prefName.Append(".qos");
     
258.   nsresult rv;
     
259.   nsCOMPtr<nsIPrefBranch> prefBranch = do_GetService(NS_PREFSERVICE_CONTRACTID, &rv);
     
260.   NS_ENSURE_SUCCESS(rv,rv);
     
261.   int32_t val;
     
262.   rv = prefBranch->GetIntPref(prefName.get(), &val);
     
263.   NS_ENSURE_SUCCESS(rv, rv);
     
264. *****************************************
     
265. 
     
266. ************设置传输状态*************
     
267. if (!m_socketIsOpen && m_transport)
     
268.   // open buffered, blocking output stream  输出流m_outputStream 用于发送数据 nsMsgProtocol::SendData  m_outputStream->Write(dataBuffer, PL_strlen(dataBuffer), &writeCount);
     
269.     rv = m_transport->OpenOutputStream(nsITransport::OPEN_BLOCKING, 0, 0, getter_AddRefs(m_outputStream));
     
270. ****************************
     
271. 
     
272. *********创建命令输出流***************
     
273. m_lineStreamBuffer = new nsMsgLineStreamBuffer(OUTPUT_BUFFER_SIZE, true);
     
274. 
     
275. ************************************
     
276. 
     
277. ***********检测端口安全*********************
     
278. NS_CheckPortSafety(int32_t       port,
     
279.                    const char   *scheme,
     
280.                    nsIIOService *ioService = nullptr)
     
281. {
     
282.     nsresult rv;
     
283.     nsCOMPtr<nsIIOService> grip;
     
284.     rv = net_EnsureIOService(&ioService, grip);
     
285.     if (ioService) {
     
286.         bool allow;
     
287.         rv = ioService->AllowPort(port, scheme, &allow);
     
288.         if (NS_SUCCEEDED(rv) && !allow) {
     
289.             NS_WARNING("port blocked");
     
290.             rv = NS_ERROR_PORT_ACCESS_NOT_ALLOWED;
     
291.         }
     
292.     }
     
293.     return rv;
     
294. }
     
295. *******************************************
     
296. 
     
297. 
     
298. *****获取url的Query段*************
     
299.   const nsDependentCSubstring Query()     { return Segment(mQuery); }
     
300. // url parts (relative to mSpec)
     
301.     URLSegment mScheme;
     
302.     URLSegment mAuthority;
     
303.     URLSegment mUsername;
     
304.     URLSegment mPassword;
     
305.     URLSegment mHost;
     
306.     URLSegment mPath;
     
307.     URLSegment mFilepath;
     
308.     URLSegment mDirectory;
     
309.     URLSegment mBasename;
     
310.     URLSegment mExtension;
     
311.     URLSegment mQuery;
     
312.     URLSegment mRef;
     
313. ********************************
     

复制代码

---

作者: hechengjin    时间: 2016-3-27 23:24
15.运行当前协议
m_pop3Server->SetRunningProtocol(this);
{
m_runningProtocol = aProtocol;
}

16.调用父类执行

return nsMsgProtocol:: LoadUrl(aURL);

// Ouput stream for writing commands to the socket  
  nsCOMPtr<nsIOutputStream>   m_outputStream;   // this will be obtained from the transport interface
  nsCOMPtr<nsIInputStream>    m_inputStream;
  // Ouput stream for writing commands to the socket
  nsCOMPtr<nsITransport>  m_transport;
  nsCOMPtr<nsIRequest>    m_request;

nsresult nsMsgProtocol:: LoadUrl(nsIURI * aURL, nsISupports * aConsumer)
｛
//从transport获取输入流 nsCOMPtr<nsIInputStream>    m_inputStream;
rv = m_transport->OpenInputStream(0, 0, 0, getter_AddRefs(m_inputStream));
///inputStream关联 pump 提供异步方法
nsCOMPtr<nsIInputStreamPump> pump;
        rv = NS_NewInputStreamPump(getter_AddRefs(pump),
          m_inputStream, -1, m_readCount);
m_request = pump; // keep a reference to the pump so we can cancel it
//注册有数据的通知 // put us in a state where we are always notified of incoming data
        rv = pump->AsyncRead(this, urlSupports);

｝

---

作者: hechengjin    时间: 2016-3-27 23:27
触发的状态机的跟踪  nsPop3Protocol:: ProcessProtocolState(nsIURI * url, nsIInputStream * aInputStream, uint32_t sourceOffset, uint32_t aLength)

1. xul.dll!nsPop3Protocol::ProcessProtocolState(nsIURI * url, nsIInputStream * aInputStream, unsigned int sourceOffset, unsigned int aLength) 行 3868 C++
   
2. > xul.dll!nsMsgProtocol::OnDataAvailable(nsIRequest * request, nsISupports * ctxt, nsIInputStream * inStr, unsigned int sourceOffset, unsigned int count) 行 357 + 0x14 字节 C++
   
3. xul.dll!nsInputStreamPump::OnStateTransfer() 行 490 + 0x16 字节 C++
   
4. xul.dll!nsInputStreamPump::OnInputStreamReady(nsIAsyncInputStream * stream) 行 372 C++
   
5. xul.dll!nsOutputStreamReadyEvent::Run() 行 83 C++
   
6. xul.dll!nsThread::ProcessNextEvent(bool mayWait, bool * result) 行 624 + 0x6 字节 C++
   
7. xul.dll!NS_ProcessNextEvent_P(nsIThread * thread, bool mayWait) 行 220 + 0xd 字节 C++
   
8. xul.dll!nsThread::Shutdown() 行 466 + 0xa 字节 C++
   
9. xul.dll!nsRunnableMethodImpl<unsigned int (__stdcall nsIThread::*)(void),1>::Run() 行 350 C++
   
10. xul.dll!nsThread::ProcessNextEvent(bool mayWait, bool * result) 行 624 + 0x6 字节 C++
    
11. xul.dll!NS_ProcessNextEvent_P(nsIThread * thread, bool mayWait) 行 220 + 0xd 字节 C++
    
12. xul.dll!mozilla::ipc::MessagePump::Run(base::MessagePump::Delegate * aDelegate) 行 82 + 0xa 字节 C++
    
13. xul.dll!MessageLoop::RunHandler() 行 202 C++
    
14. xul.dll!MessageLoop::Run() 行 176 C++
    
15. xul.dll!nsBaseAppShell::Run() 行 165 C++
    
16. xul.dll!nsAppShell::Run() 行 232 + 0x6 字节 C++
    
17. xul.dll!nsAppStartup::Run() 行 274 C++
    
18. xul.dll!XREMain::XRE_mainRun() 行 3856 + 0x9 字节 C++
    
19. xul.dll!XREMain::XRE_main(int argc, char * * argv, const nsXREAppData * aAppData) 行 3933 + 0x7 字节 C++
    
20. xul.dll!XRE_main(int argc, char * * argv, const nsXREAppData * aAppData, unsigned int aFlags) 行 4009 + 0x12 字节 C++
    
21. 139Mail.exe!do_main(const char * exePath, int argc, char * * argv) 行 112 C++
    
22. 139Mail.exe!NS_internal_main(int argc, char * * argv) 行 200 + 0x12 字节 C++
    
23. 139Mail.exe!wmain(int argc, wchar_t * * argv) 行 102 C++
    
24. 139Mail.exe!__tmainCRTStartup() 行 552 + 0x17 字节 C
    

复制代码

即连接的缓存中有可用数据时，会触发OnDataAvailable调用，抓包如下：

创建url后的状态更新过程：
1.POP3_START_CONNECT
2.POP3_FINISH_CONNECT
3.POP3_WAIT_FOR_START_OF_CONNECTION_RESPONSE
根据服务端的返回设置服务器相关信息
然后再根据连接类型发送用户名密码登录。
如：
int32_t nsPop3Protocol::SendAuth()
{
  if(!m_pop3ConData->command_succeeded)
    return(Error(POP3_SERVER_ERROR));

  nsCAutoString command("AUTH" CRLF);

  m_pop3ConData->next_state_after_response = POP3_AUTH_RESPONSE;
  return SendData(command.get());
}

---

作者: hechengjin    时间: 2016-3-27 23:27
+OK richmail system v10(32d255323e8d829-c3ed4)
AUTH
-ERR Bad sequence of commands
CAPA
-ERR Bad sequence of commands
USER 13342978053@139.com
+OK
PASS cccccpassword
+OK login success
STAT
+OK 3 140231
QUIT
+OK dewey POP3 server signing off

前端createAccountInBackend
进行上面几个命令后，
前端js文件 createInBackend.js
function createAccountInBackend(config, isPublicEmailAddr, curEmailAddr)
  account.incomingServer = inServer; // will create folder  调用下面c++代码
会进入邮件夹创建
nsMsgAccount::SetIncomingServer(nsIMsgIncomingServer *aIncomingServer)

---

作者: hechengjin    时间: 2016-3-27 23:27
第一阶段总结：

验证接收成功失败的回调函数
function verifyLogon(config, inServer, alter, msgWindow, successCallback, errorCallback)
回调函数在verifyConfig.js验证函数内部转换成js对象 listener
let listener = new urlListener(config, inServer, alter, msgWindow,
                                  successCallback, errorCallback);
listener对象实现 nsIUrlListener 接口
//nsIUrlListener
OnStartRunningUrl: function(aUrl)
OnStopRunningUrl: function(aUrl, aExitCode)
{
  this._log.info("Finished verifyConfig resulted in " + aExitCode);
    if (Components.isSuccessCode(aExitCode))//判断返回的退出码
     {
       this._cleanup();
       this.mSuccessCallback(this.mConfig);  //登录成功，完成成功函数的回调
     }
}
--------C++后端关于listener对象的传递与处理机制-------------
js:
let listener = new urlListener(config, inServer, alter, msgWindow,
                                  successCallback, errorCallback);
msgWindow.notificationCallbacks = listener;//注意这里有一个回调通知的保存和恢复
let uri = inServer.verifyLogon(listener, msgWindow);
c++:    //aUrlListener对应js中的listener
nsPop3IncomingServer::VerifyLogon(nsIUrlListener *aUrlListener,nsIMsgWindow *aMsgWindow, nsIURI **aURL)
{
nsCOMPtr<nsIPop3Service> pop3Service = do_GetService(kCPop3ServiceCID, &rv);
return pop3Service->VerifyLogon(this, aUrlListener, aMsgWindow, aURL);
}
nsPop3Service::VerifyLogon(nsIMsgIncomingServer *aServer,nsIUrlListener *aUrlListener,nsIMsgWindow *aMsgWindow,
nsIURI **aURL)
{
//组建url并把listener对象封装进去
char *urlSpec = PR_smprintf("pop3://%s@%s:%d/?verifyLogon",escapedUsername.get(), popHost.get(), popPort);
//构造结果示例：pop3://13342978053@pop3.139.com:110/?verifyLogon
  nsCOMPtr<nsIURI> url;
  
  rv = BuildPop3Url(urlSpec, nullptr, popServer, aUrlListener,
getter_AddRefs(url), aMsgWindow);
}
nsPop3Service::BuildPop3Url(const char *urlSpec,
nsIMsgFolder *inbox,
nsIPop3IncomingServer *server,
nsIUrlListener *aUrlListener,nsIURI **aUrl,nsIMsgWindow *aMsgWindow)
{
nsCOMPtr<nsIPop3URL> pop3Url = do_CreateInstance(kPop3UrlCID, &rv);
rv = CallQueryInterface(pop3Url, aUrl);
nsCOMPtr<nsIMsgMailNewsUrl> mailnewsurl = do_QueryInterface(pop3Url);
//上面接口的获取参看nsIPop3URL的继承关系 class nsPop3URL : public nsIPop3URL, public nsMsgMailNewsUrl
mailnewsurl->RegisterListener(aUrlListener);  
}
//注册后查看后面是处理的
\mailnews\base\util\nsMsgMailNewsUrl.cpp
nsMsgMailNewsUrl::RegisterListener(nsIUrlListener *aUrlListener)
{
mUrlListeners.AppendElement(aUrlListener);
}
//发送通知的宏
#define NOTIFY_URL_LISTENERS(propertyfunc_, params_)                   \
  PR_BEGIN_MACRO                                                       \
  nsTObserverArray<nsCOMPtr<nsIUrlListener> >::ForwardIterator iter(mUrlListeners); \
  while (iter.HasMore()) {                                             \
    nsCOMPtr<nsIUrlListener> listener = iter.GetNext();                \
    listener->propertyfunc_ params_;                                   \
  }                                                                    \
  PR_END_MACRO
//跟踪何时调用这个宏
nsresult nsMsgMailNewsUrl::SetUrlState(bool aRunningUrl, nsresult aExitCode)
{
{
if (m_runningUrl)
  {
    NOTIFY_URL_LISTENERS(OnStartRunningUrl, (this));
  }
  else
  {
    NOTIFY_URL_LISTENERS(OnStopRunningUrl, (this, aExitCode));
    mUrlListeners.Clear();
  }
}
//协议中何时调用
nsPop3Protocol.cpp#4119
case POP3_FREE:
mailnewsurl->SetUrlState(false, m_pop3ConData->urlStatus);

---

作者: hechengjin    时间: 2016-3-27 23:28
emailWizard.js
validateAndFinish
self.finish();
finish : function()
{
curAccount =createAccountInBackend(this.getConcreteConfig(), true, this._email);
let folder = curAccount.incomingServer.rootMsgFolder;
    let server = curAccount.incomingServer;
if ("imap" == server.type) {
else if ("pop3" == server.type) {
this.startPop3FetchMsg(server, folder);{ server.getNewMessages(folder, null, null);}
}
createInBackend.js
createAccountInBackend
{
//创建收信服务
var accountManager = Cc["@mozilla.org/messenger/account-manager;1"]
                       .getService(Ci.nsIMsgAccountManager);
var inServer = accountManager.createIncomingServer
//创建发信服务
outServer = smtpManager.createSmtpServer();
//创建identity
var identity = accountManager.createIdentity();
//创建账号并记录收信服务器不同于验证过程，验证过程没有这步
var account = accountManager.createAccount();
account.incomingServer = inServer; // will create folder
//设置账号的identity
account.addIdentity(identity);

setFolders(identity, inServer);
//保存账号信息
accountManager.saveAccountInfo();

return account;

}

---

作者: hechengjin    时间: 2016-3-27 23:28

1. var inServer = accountManager.createIncomingServer
   
2. nsMsgAccountManager.cpp  //创建后台C++中的内存对象与js对应
   
3. nsMsgAccountManager::CreateIncomingServer(const nsACString&  username,
   
4.                                           const nsACString& hostname,
   
5.                                           const nsACString& type,
   
6.                                           nsIMsgIncomingServer **_retval)
   
7. {
   
8. nsresult rv = LoadAccounts();
   
9. }
   
10. 
    
11. nsMsgAccountManager:oadAccounts()
    
12. {
    
13. //1.mailSession的作用
    
14. nsCOMPtr<nsIMsgMailSession> mailSession = do_GetService(NS_MSGMAILSESSION_CONTRACTID, &rv);
    
15.     mailSession->AddFolderListener(this, nsIFolderListener::added |
    
16.                                          nsIFolderListener::removed |
    
17.                                          nsIFolderListener::intPropertyChanged);
    
18. //2.biff service 的作用
    
19. nsCOMPtr<nsIMsgBiffManager> biffService =
    
20.            do_GetService(NS_MSGBIFFMANAGER_CONTRACTID, &rv);
    
21. biffService->Init();
    
22. 
    
23. //3.purge service的作用
    
24. nsCOMPtr<nsIMsgPurgeService> purgeService =
    
25.            do_GetService(NS_MSGPURGESERVICE_CONTRACTID, &rv);
    
26. purgeService->Init();
    
27. 
    
28. //4.integration service 的作用
    
29. nsCOMPtr<nsIMessengerOSIntegration> integrationService =
    
30.            do_GetService(NS_MESSENGEROSINTEGRATION_CONTRACTID, &rv);
    
31. //5.通过mail.accountmanager.accounts配置中存储的所有账号信息获取账号进入点
    
32. nsCString accountList;
    
33. rv = m_prefs->GetCharPref(PREF_MAIL_ACCOUNTMANAGER_ACCOUNTS, getter_Copies(accountList));
    
34. //6.关于预加载账号
    
35. mailnews.js
    
36. pref("mailnews.append_preconfig_accounts.version", 1); //预加载账号的版本号配置
    
37. mail.accountmanager.appendaccounts  //预加载账号 逗号分隔的帐户列表  参考mail.accountmanager.accounts里的配置
    
38. 判断默认配置mailnews.js和当前配置prefs.js的不同，以确认预加载账号的更新
    
39. //7.解析账号列表(字符串转为数组)，加载每个账号
    
40. nsTArray<nsCString> accountsArray;
    
41.   ParseString(accountList, ACCOUNT_DELIMITER, accountsArray);
    
42. 去重复及判断是否存在m_accounts中
    
43. nsCOMPtr<nsISupportsArray> m_accounts;
    
44. 
    
45. //8.创建账号
    
46. createKeyedAccount(accountsArray, getter_AddRefs(account))) || !account)    // nsCOMPtr<nsIMsgAccount> account = do_CreateInstance(kMsgAccountCID, &rv);
    
47. 
    
48. //9. secondsToLeaveUnavailable 和 timeFoundUnavailable 配置
    
49. 
    
50. //10.identities加载
    
51. nsCOMPtr<nsISupportsArray> identities;
    
52.     account->GetIdentities(getter_AddRefs(identities));
    
53. 
    
54. //创建账号服务
    
55. rv = account->CreateServer();
    
56. ｛
    
57. //即通过AccountManager服务获取到之前创建的服务，然后与账号的m_incomingServer变量关联,并通知NotifyServerLoaded
    
58. nsCOMPtr<nsIMsgAccountManager> accountManager =
    
59.            do_GetService(NS_MSGACCOUNTMANAGER_CONTRACTID, &rv);
    
60.   NS_ENSURE_SUCCESS(rv, rv);
    
61.   nsCOMPtr<nsIMsgIncomingServer> server;
    
62.   rv = accountManager->GetIncomingServer(serverKey, getter_AddRefs(server));
    
63.   NS_ENSURE_SUCCESS(rv, rv);
    
64.   // store the server in this structure
    
65.   m_incomingServer = server;
    
66.   accountManager->NotifyServerLoaded(server);
    
67. ｝
    
68. 
    
69. }

复制代码

---

欢迎光临 firemail (http://firemail.wang:8088/)

Powered by Discuz! X3