Mercurial > pidgin
view libpurple/protocols/msn/oim.c @ 21030:3cc856ca2338
Add a --with-extraversion option to ./configure so packagers can fine tune
the version displayed to the end user to assist in support and things.
Fixes #3681
author | Stu Tomlinson <stu@nosnilmot.com> |
---|---|
date | Sat, 27 Oct 2007 13:56:54 +0000 |
parents | 2097b1664fa3 |
children | f387e8c671a4 |
line wrap: on
line source
/** * @file oim.c * get and send MSN offline Instant Message via SOAP request * Author * MaYuan<mayuan2006@gmail.com> * purple * * Purple is the legal property of its developers, whose names are too numerous * to list here. Please refer to the COPYRIGHT file distributed with this * source distribution. * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ #include "msn.h" #include "soap.h" #include "oim.h" #include "msnutils.h" /*Local Function Prototype*/ static void msn_oim_post_single_get_msg(MsnOim *oim,const char *msgid); static MsnOimSendReq *msn_oim_new_send_req(const char *from_member, const char *friendname, const char* to_member, gint send_seq, const char *msg); static void msn_oim_retrieve_connect_init(MsnSoapConn *soapconn); static void msn_oim_send_connect_init(MsnSoapConn *soapconn); static void msn_oim_free_send_req(MsnOimSendReq *req); static void msn_oim_report_to_user(MsnOim *oim, const char *msg_str); static void msn_oim_get_process(MsnOim *oim, const char *oim_msg); static gchar *msn_oim_msg_to_str(MsnOim *oim, const char *body); static void msn_oim_send_process(MsnOim *oim, const char *body, int len); /*new a OIM object*/ MsnOim * msn_oim_new(MsnSession *session) { MsnOim *oim; oim = g_new0(MsnOim, 1); oim->session = session; oim->retrieveconn = msn_soap_new(session, oim, TRUE); oim->oim_list = NULL; oim->sendconn = msn_soap_new(session, oim, TRUE); oim->run_id = rand_guid(); oim->challenge = NULL; oim->send_queue = g_queue_new(); oim->send_seq = 1; return oim; } /*destroy the oim object*/ void msn_oim_destroy(MsnOim *oim) { MsnOimSendReq *request; purple_debug_info("OIM","destroy the OIM \n"); msn_soap_destroy(oim->retrieveconn); msn_soap_destroy(oim->sendconn); g_free(oim->run_id); g_free(oim->challenge); while((request = g_queue_pop_head(oim->send_queue)) != NULL){ msn_oim_free_send_req(request); } g_queue_free(oim->send_queue); g_free(oim); } static MsnOimSendReq * msn_oim_new_send_req(const char *from_member, const char*friendname, const char* to_member, gint send_seq, const char *msg) { MsnOimSendReq *request; request = g_new0(MsnOimSendReq, 1); request->from_member =g_strdup(from_member); request->friendname = g_strdup(friendname); request->to_member = g_strdup(to_member); request->send_seq = send_seq; request->oim_msg = g_strdup(msg); return request; } static void msn_oim_free_send_req(MsnOimSendReq *req) { g_return_if_fail(req != NULL); g_free(req->from_member); g_free(req->friendname); g_free(req->to_member); g_free(req->oim_msg); g_free(req); } /**************************************** * OIM send SOAP request * **************************************/ /*encode the message to OIM Message Format*/ static gchar * msn_oim_msg_to_str(MsnOim *oim, const char *body) { char *oim_body,*oim_base64; purple_debug_info("MSN OIM","encode OIM Message...\n"); oim_base64 = purple_base64_encode((const guchar *)body, strlen(body)); purple_debug_info("MSN OIM","encoded base64 body:{%s}\n",oim_base64); oim_body = g_strdup_printf(MSN_OIM_MSG_TEMPLATE, oim->run_id,oim->send_seq,oim_base64); g_free(oim_base64); return oim_body; } /*oim SOAP server login error*/ static void msn_oim_send_error_cb(MsnSoapConn *soapconn, PurpleSslConnection *gsc, PurpleSslErrorType error) { MsnSession *session; session = soapconn->session; g_return_if_fail(session != NULL); msn_session_set_error(session, MSN_ERROR_SERV_DOWN, _("Unable to connect to OIM server")); } /*msn oim SOAP server connect process*/ static gboolean msn_oim_send_connect_cb(MsnSoapConn *soapconn, PurpleSslConnection *gsc) { MsnSession * session; MsnOim *oim; oim = soapconn->parent; g_return_val_if_fail(oim != NULL, TRUE); session = oim->session; g_return_val_if_fail(session != NULL, FALSE); return TRUE; } /* * Process the send return SOAP string * If got SOAP Fault,get the lock key,and resend it. */ static void msn_oim_send_process(MsnOim *oim, const char *body, int len) { xmlnode *responseNode, *bodyNode; xmlnode *faultNode = NULL, *faultCodeNode, *faultstringNode; xmlnode *detailNode, *challengeNode; char *fault_code, *fault_text; responseNode = xmlnode_from_str(body,len); g_return_if_fail(responseNode != NULL); if ((bodyNode = xmlnode_get_child(responseNode, "Body"))) faultNode = xmlnode_get_child(bodyNode, "Fault"); if (faultNode == NULL) { /*Send OK! return*/ MsnOimSendReq *request; xmlnode_free(responseNode); request = g_queue_pop_head(oim->send_queue); msn_oim_free_send_req(request); /*send next buffered Offline Message*/ msn_soap_post(oim->sendconn, NULL); return; } /*get the challenge,and repost it*/ if (faultNode) faultCodeNode = xmlnode_get_child(faultNode, "faultcode"); if(faultCodeNode == NULL){ purple_debug_info("MSN OIM", "No faultcode for failed Offline Message.\n"); xmlnode_free(responseNode); return; } fault_code = xmlnode_get_data(faultCodeNode); #if 0 if(!strcmp(fault_code,"q0:AuthenticationFailed")){ /*other Fault Reason?*/ goto oim_send_process_fail; } #endif faultstringNode = xmlnode_get_child(faultNode, "faultstring"); fault_text = xmlnode_get_data(faultstringNode); purple_debug_info("MSN OIM", "Error sending Offline Message: %s (%s)\n", fault_text ? fault_text : "(null)", fault_code ? fault_code : "(null)"); /* lock key fault reason, * compute the challenge and resend it */ if ((detailNode = xmlnode_get_child(faultNode, "detail")) && (challengeNode = xmlnode_get_child(detailNode, "LockKeyChallenge"))) { g_free(oim->challenge); oim->challenge = xmlnode_get_data(challengeNode); purple_debug_info("MSN OIM", "Retrying Offline IM with lockkey:{%s}\n", oim->challenge ? oim->challenge : "(null)"); /*repost the send*/ msn_oim_send_msg(oim); /* XXX: This needs to give up eventually (1 retry, maybe?) */ } g_free(fault_text); g_free(fault_code); xmlnode_free(responseNode); } static gboolean msn_oim_send_read_cb(MsnSoapConn *soapconn) { MsnSession *session = soapconn->session; MsnOim * oim; if (soapconn->body == NULL) return TRUE; g_return_val_if_fail(session != NULL, FALSE); oim = soapconn->session->oim; g_return_val_if_fail(oim != NULL, TRUE); purple_debug_info("MSN OIM","read buffer:{%s}\n", soapconn->body); msn_oim_send_process(oim,soapconn->body,soapconn->body_len); return TRUE; } static void msn_oim_send_written_cb(MsnSoapConn *soapconn) { soapconn->read_cb = msn_oim_send_read_cb; // msn_soap_read_cb(data,source,cond); } void msn_oim_prep_send_msg_info(MsnOim *oim, const char *membername, const char* friendname, const char *tomember, const char * msg) { MsnOimSendReq *request; g_return_if_fail(oim != NULL); request = msn_oim_new_send_req(membername,friendname,tomember,oim->send_seq,msg); g_queue_push_tail(oim->send_queue,request); } /*post send single message request to oim server*/ void msn_oim_send_msg(MsnOim *oim) { MsnSoapReq *soap_request; MsnOimSendReq *oim_request; char *soap_body,*mspauth; gchar *msg_body; char buf[33]; g_return_if_fail(oim != NULL); oim_request = g_queue_pop_head(oim->send_queue); g_return_if_fail(oim_request != NULL); purple_debug_info("MSN OIM","send single OIM Message\n"); mspauth = g_strdup_printf("t=%s&p=%s", oim->session->passport_info.t, oim->session->passport_info.p ); g_queue_push_head(oim->send_queue,oim_request); /* if we got the challenge lock key, we compute it * else we go for the SOAP fault and resend it. */ if(oim->challenge != NULL){ msn_handle_chl(oim->challenge, buf); }else{ purple_debug_info("MSN OIM","no lock key challenge,wait for SOAP Fault and Resend\n"); buf[0]='\0'; } purple_debug_info("MSN OIM","get the lock key challenge {%s}\n",buf); msg_body = msn_oim_msg_to_str(oim, oim_request->oim_msg); soap_body = g_strdup_printf(MSN_OIM_SEND_TEMPLATE, oim_request->from_member, oim_request->friendname, oim_request->to_member, mspauth, MSNP13_WLM_PRODUCT_ID, buf, oim_request->send_seq, msg_body); soap_request = msn_soap_request_new(MSN_OIM_SEND_HOST, MSN_OIM_SEND_URL, MSN_OIM_SEND_SOAP_ACTION, soap_body, NULL, msn_oim_send_read_cb, msn_oim_send_written_cb, msn_oim_send_connect_init); g_free(mspauth); g_free(msg_body); g_free(soap_body); /*increase the offline Sequence control*/ if(oim->challenge != NULL){ oim->send_seq++; } msn_soap_post(oim->sendconn,soap_request); } /**************************************** * OIM delete SOAP request * **************************************/ static gboolean msn_oim_delete_read_cb(MsnSoapConn *soapconn) { if (soapconn->body == NULL) return TRUE; purple_debug_info("MSN OIM","OIM delete read buffer:{%s}\n",soapconn->body); msn_soap_free_read_buf(soapconn); /*get next single Offline Message*/ // msn_soap_post(soapconn,NULL); /* we already do this in soap.c */ return TRUE; } static void msn_oim_delete_written_cb(MsnSoapConn *soapconn) { soapconn->read_cb = msn_oim_delete_read_cb; } /*Post to get the Offline Instant Message*/ static void msn_oim_post_delete_msg(MsnOim *oim,const char *msgid) { MsnSoapReq *soap_request; gchar *soap_body; const char *t,*p; g_return_if_fail(oim != NULL); g_return_if_fail(msgid != NULL); purple_debug_info("MSN OIM","Delete single OIM Message {%s}\n",msgid); t = oim->session->passport_info.t; p = oim->session->passport_info.p; soap_body = g_strdup_printf(MSN_OIM_DEL_TEMPLATE, t, p, msgid ); soap_request = msn_soap_request_new(MSN_OIM_RETRIEVE_HOST, MSN_OIM_RETRIEVE_URL, MSN_OIM_DEL_SOAP_ACTION, soap_body, NULL, msn_oim_delete_read_cb, msn_oim_delete_written_cb, msn_oim_retrieve_connect_init); g_free(soap_body); msn_soap_post(oim->retrieveconn,soap_request); } /**************************************** * OIM get SOAP request * **************************************/ /*oim SOAP server login error*/ static void msn_oim_get_error_cb(MsnSoapConn *soapconn, PurpleSslConnection *gsc, PurpleSslErrorType error) { MsnSession *session; session = soapconn->session; g_return_if_fail(session != NULL); msn_soap_clean_unhandled_requests(soapconn); // msn_session_set_error(session, MSN_ERROR_SERV_DOWN, _("Unable to connect to OIM server")); } /*msn oim SOAP server connect process*/ static gboolean msn_oim_get_connect_cb(MsnSoapConn *soapconn, PurpleSslConnection *gsc) { MsnSession * session; MsnOim *oim; oim = soapconn->parent; g_return_val_if_fail(oim != NULL, TRUE); session = oim->session; g_return_val_if_fail(session != NULL, FALSE); purple_debug_info("MSN OIM","Connected and ready to get OIM!\n"); return TRUE; } /* like purple_str_to_time, but different. The format of the timestamp * is like this: 5 Sep 2007 21:42:12 -0700 */ static time_t msn_oim_parse_timestamp(const char *timestamp) { char month_str[4], tz_str[6]; char *tz_ptr = tz_str; static const char *months[] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec", NULL }; struct tm t; memset(&t, 0, sizeof(t)); if (sscanf(timestamp, "%02d %03s %04d %02d:%02d:%02d %05s", &t.tm_mday, month_str, &t.tm_year, &t.tm_hour, &t.tm_min, &t.tm_sec, tz_str) == 7) { gboolean offset_positive = TRUE; int tzhrs; int tzmins; for (t.tm_mon = 0; months[t.tm_mon] != NULL && strcmp(months[t.tm_mon], month_str) != 0; t.tm_mon++); if (months[t.tm_mon] != NULL) { if (*tz_str == '-') { offset_positive = FALSE; tz_ptr++; } else if (*tz_str == '+') { tz_ptr++; } if (sscanf(tz_ptr, "%02d%02d", &tzhrs, &tzmins) == 2) { time_t tzoff = tzhrs * 60 * 60 + tzmins * 60; #ifdef _WIN32 long sys_tzoff; #endif if (!offset_positive) tzoff *= -1; t.tm_year -= 1900; t.tm_isdst = 0; #ifdef _WIN32 if ((sys_tzoff = wpurple_get_tz_offset()) != -1) tzoff += sys_tzoff; #else #ifdef HAVE_TM_GMTOFF tzoff += t.tm_gmtoff; #else # ifdef HAVE_TIMEZONE tzset(); /* making sure */ tzoff -= timezone; # endif #endif #endif /* _WIN32 */ return mktime(&t) + tzoff; } } } purple_debug_info("MSN OIM:OIM", "Can't parse timestamp %s\n", timestamp); return time(NULL); } /*Post the Offline Instant Message to User Conversation*/ static void msn_oim_report_to_user(MsnOim *oim, const char *msg_str) { MsnMessage *message; char *date,*from,*decode_msg; gsize body_len; char **tokens; char *start,*end; int has_nick = 0; char *passport_str, *passport; char *msg_id; time_t stamp; message = msn_message_new(MSN_MSG_UNKNOWN); msn_message_parse_payload(message, msg_str, strlen(msg_str), MSG_OIM_LINE_DEM, MSG_OIM_BODY_DEM); purple_debug_info("MSN OIM","oim body:{%s}\n",message->body); decode_msg = (char *)purple_base64_decode(message->body,&body_len); date = (char *)g_hash_table_lookup(message->attr_table, "Date"); from = (char *)g_hash_table_lookup(message->attr_table, "From"); if(strstr(from," ")){ has_nick = 1; } if(has_nick){ tokens = g_strsplit(from , " " , 2); passport_str = g_strdup(tokens[1]); purple_debug_info("MSN OIM","oim Date:{%s},nickname:{%s},tokens[1]:{%s} passport{%s}\n", date,tokens[0],tokens[1],passport_str); g_strfreev(tokens); }else{ passport_str = g_strdup(from); purple_debug_info("MSN OIM","oim Date:{%s},passport{%s}\n", date,passport_str); } start = strstr(passport_str,"<"); start += 1; end = strstr(passport_str,">"); passport = g_strndup(start,end - start); g_free(passport_str); purple_debug_info("MSN OIM","oim Date:{%s},passport{%s}\n",date,passport); stamp = msn_oim_parse_timestamp(date); serv_got_im(oim->session->account->gc, passport, decode_msg, 0, stamp); /*Now get the oim message ID from the oim_list. * and append to read list to prepare for deleting the Offline Message when sign out */ if(oim->oim_list != NULL){ msg_id = oim->oim_list->data; msn_oim_post_delete_msg(oim,msg_id); oim->oim_list = g_list_remove(oim->oim_list, oim->oim_list->data); g_free(msg_id); } g_free(passport); } /* Parse the XML data, * prepare to report the OIM to user */ static void msn_oim_get_process(MsnOim *oim, const char *oim_msg) { xmlnode *oim_node,*bodyNode,*responseNode,*msgNode; char *msg_str; oim_node = xmlnode_from_str(oim_msg, strlen(oim_msg)); bodyNode = xmlnode_get_child(oim_node,"Body"); responseNode = xmlnode_get_child(bodyNode,"GetMessageResponse"); msgNode = xmlnode_get_child(responseNode,"GetMessageResult"); msg_str = xmlnode_get_data(msgNode); purple_debug_info("OIM","msg:{%s}\n",msg_str); msn_oim_report_to_user(oim,msg_str); g_free(msg_str); xmlnode_free(oim_node); } static gboolean msn_oim_get_read_cb(MsnSoapConn *soapconn) { MsnOim * oim = soapconn->session->oim; if (soapconn->body == NULL) return TRUE; purple_debug_info("MSN OIM","OIM get read buffer:{%s}\n",soapconn->body); /*we need to process the read message!*/ msn_oim_get_process(oim,soapconn->body); msn_soap_free_read_buf(soapconn); /*get next single Offline Message*/ // msn_soap_post(soapconn,NULL); /* we already do this in soap.c */ return TRUE; } static void msn_oim_get_written_cb(MsnSoapConn *soapconn) { soapconn->read_cb = msn_oim_get_read_cb; // msn_soap_read_cb(data,source,cond); } /* parse the oim XML data * and post it to the soap server to get the Offline Message * */ void msn_parse_oim_msg(MsnOim *oim,const char *xmlmsg) { xmlnode *node, *mNode,*ENode,*INode,*rtNode,*nNode; char *passport,*msgid,*nickname, *unread, *rTime = NULL; MsnSession *session = oim->session; purple_debug_info("MSN OIM:OIM", "%s", xmlmsg); node = xmlnode_from_str(xmlmsg, strlen(xmlmsg)); if (!node || !node->name || strcmp(node->name, "MD") != 0) { if (node) xmlnode_free(node); return; } ENode = xmlnode_get_child(node, "E"); INode = xmlnode_get_child(ENode, "IU"); unread = xmlnode_get_data(INode); if (unread != NULL && purple_account_get_check_mail(session->account)) { int count = atoi(unread); if (count > 0) { const char *passport; const char *url; passport = msn_user_get_passport(session->user); url = session->passport_info.file; purple_notify_emails(session->account->gc, atoi(unread), FALSE, NULL, NULL, &passport, &url, NULL, NULL); } } for(mNode = xmlnode_get_child(node, "M"); mNode; mNode = xmlnode_get_next_twin(mNode)){ /*email Node*/ ENode = xmlnode_get_child(mNode,"E"); passport = xmlnode_get_data(ENode); /*Index */ INode = xmlnode_get_child(mNode,"I"); msgid = xmlnode_get_data(INode); /*Nickname*/ nNode = xmlnode_get_child(mNode,"N"); nickname = xmlnode_get_data(nNode); /*receive time*/ rtNode = xmlnode_get_child(mNode,"RT"); if(rtNode != NULL) rTime = xmlnode_get_data(rtNode); /* purple_debug_info("MSN OIM","E:{%s},I:{%s},rTime:{%s}\n",passport,msgid,rTime); */ oim->oim_list = g_list_append(oim->oim_list,strdup(msgid)); msn_oim_post_single_get_msg(oim,msgid); g_free(passport); g_free(msgid); g_free(rTime); rTime = NULL; g_free(nickname); } g_free(unread); xmlnode_free(node); } /*Post to get the Offline Instant Message*/ static void msn_oim_post_single_get_msg(MsnOim *oim,const char *msgid) { MsnSoapReq *soap_request; gchar *soap_body; const char *t,*p; purple_debug_info("MSN OIM","Get single OIM Message\n"); t = oim->session->passport_info.t; p = oim->session->passport_info.p; soap_body = g_strdup_printf(MSN_OIM_GET_TEMPLATE, t, p, msgid ); soap_request = msn_soap_request_new(MSN_OIM_RETRIEVE_HOST, MSN_OIM_RETRIEVE_URL, MSN_OIM_GET_SOAP_ACTION, soap_body, NULL, msn_oim_get_read_cb, msn_oim_get_written_cb, msn_oim_retrieve_connect_init); g_free(soap_body); msn_soap_post(oim->retrieveconn,soap_request); } /*msn oim retrieve server connect init */ static void msn_oim_retrieve_connect_init(MsnSoapConn *soapconn) { purple_debug_info("MSN OIM","Initializing OIM retrieve connection\n"); msn_soap_init(soapconn, MSN_OIM_RETRIEVE_HOST, TRUE, msn_oim_get_connect_cb, msn_oim_get_error_cb); } /*Msn OIM Send Server Connect Init Function*/ static void msn_oim_send_connect_init(MsnSoapConn *sendconn) { purple_debug_info("MSN OIM","Initializing OIM send connection\n"); msn_soap_init(sendconn, MSN_OIM_SEND_HOST, TRUE, msn_oim_send_connect_cb, msn_oim_send_error_cb); } /* EOF oim.c*/