1
0
mirror of https://github.com/profanity-im/profanity.git synced 2024-12-04 14:46:46 -05:00

Merge pull request #1513 from profanity-im/fix-possible-segfault1

Fix potential problems caused by unexpected stanzas
This commit is contained in:
Michael Vetter 2021-03-25 17:04:22 +01:00 committed by GitHub
commit c72351375d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
7 changed files with 298 additions and 204 deletions

View File

@ -161,8 +161,7 @@ log_database_add_incoming(ProfMessage* message)
if (message->to_jid) { if (message->to_jid) {
_add_to_db(message, NULL, message->from_jid, message->to_jid); _add_to_db(message, NULL, message->from_jid, message->to_jid);
} else { } else {
const char* jid = connection_get_fulljid(); Jid* myjid = jid_create(connection_get_fulljid());
Jid* myjid = jid_create(jid);
_add_to_db(message, NULL, message->from_jid, myjid); _add_to_db(message, NULL, message->from_jid, myjid);
@ -182,8 +181,7 @@ _log_database_add_outgoing(char* type, const char* const id, const char* const b
msg->timestamp = g_date_time_new_now_local(); //TODO: get from outside. best to have whole ProfMessage from outside msg->timestamp = g_date_time_new_now_local(); //TODO: get from outside. best to have whole ProfMessage from outside
msg->enc = enc; msg->enc = enc;
const char* jid = connection_get_fulljid(); Jid* myjid = jid_create(connection_get_fulljid());
Jid* myjid = jid_create(jid);
_add_to_db(msg, type, myjid, msg->from_jid); // TODO: myjid now in profmessage _add_to_db(msg, type, myjid, msg->from_jid); // TODO: myjid now in profmessage
@ -216,6 +214,8 @@ log_database_get_previous_chat(const gchar* const contact_barejid)
char* query; char* query;
const char* jid = connection_get_fulljid(); const char* jid = connection_get_fulljid();
Jid* myjid = jid_create(jid); Jid* myjid = jid_create(jid);
if (!myjid)
return NULL;
if (asprintf(&query, "SELECT * FROM (SELECT `message`, `timestamp`, `from_jid`, `type` from `ChatLogs` WHERE (`from_jid` = '%s' AND `to_jid` = '%s') OR (`from_jid` = '%s' AND `to_jid` = '%s') ORDER BY `timestamp` DESC LIMIT 10) ORDER BY `timestamp` ASC;", contact_barejid, myjid->barejid, myjid->barejid, contact_barejid) == -1) { if (asprintf(&query, "SELECT * FROM (SELECT `message`, `timestamp`, `from_jid`, `type` from `ChatLogs` WHERE (`from_jid` = '%s' AND `to_jid` = '%s') OR (`from_jid` = '%s' AND `to_jid` = '%s') ORDER BY `timestamp` DESC LIMIT 10) ORDER BY `timestamp` ASC;", contact_barejid, myjid->barejid, myjid->barejid, contact_barejid) == -1) {
log_error("log_database_get_previous_chat(): SQL query. could not allocate memory"); log_error("log_database_get_previous_chat(): SQL query. could not allocate memory");

View File

@ -373,9 +373,11 @@ sv_ev_room_message(ProfMessage* message)
if (prefs_do_room_notify(is_current, mucwin->roomjid, mynick, message->from_jid->resourcepart, message->plain, mention, triggers != NULL)) { if (prefs_do_room_notify(is_current, mucwin->roomjid, mynick, message->from_jid->resourcepart, message->plain, mention, triggers != NULL)) {
Jid* jidp = jid_create(mucwin->roomjid); Jid* jidp = jid_create(mucwin->roomjid);
if (jidp) {
notify_room_message(message->from_jid->resourcepart, jidp->localpart, num, message->plain); notify_room_message(message->from_jid->resourcepart, jidp->localpart, num, message->plain);
jid_destroy(jidp); jid_destroy(jidp);
} }
}
if (triggers) { if (triggers) {
g_list_free_full(triggers, free); g_list_free_full(triggers, free);

View File

@ -113,6 +113,9 @@ static int
_avatar_metadata_handler(xmpp_stanza_t* const stanza, void* const userdata) _avatar_metadata_handler(xmpp_stanza_t* const stanza, void* const userdata)
{ {
const char* from = xmpp_stanza_get_attribute(stanza, STANZA_ATTR_FROM); const char* from = xmpp_stanza_get_attribute(stanza, STANZA_ATTR_FROM);
if (!from) {
return 1;
}
if (!g_hash_table_contains(looking_for, from)) { if (!g_hash_table_contains(looking_for, from)) {
return 1; return 1;
@ -141,23 +144,29 @@ _avatar_metadata_handler(xmpp_stanza_t* const stanza, void* const userdata)
xmpp_stanza_t* item = xmpp_stanza_get_child_by_name(items, "item"); xmpp_stanza_t* item = xmpp_stanza_get_child_by_name(items, "item");
if (item) { if (item) {
xmpp_stanza_t* metadata = xmpp_stanza_get_child_by_name(item, "metadata"); xmpp_stanza_t* metadata = xmpp_stanza_get_child_by_name(item, "metadata");
if (!metadata) if (metadata) {
return 1;
xmpp_stanza_t* info = xmpp_stanza_get_child_by_name(metadata, "info"); xmpp_stanza_t* info = xmpp_stanza_get_child_by_name(metadata, "info");
if (info) {
const char* id = xmpp_stanza_get_id(info); const char* id = xmpp_stanza_get_id(info);
const char* type = xmpp_stanza_get_attribute(info, "type"); const char* type = xmpp_stanza_get_attribute(info, "type");
if(id && type) {
log_debug("Avatar ID for %s is: %s", from, id); log_debug("Avatar ID for %s is: %s", from, id);
avatar_metadata* data = malloc(sizeof(avatar_metadata)); avatar_metadata* data = malloc(sizeof(avatar_metadata));
if(data) {
data->type = strdup(type); data->type = strdup(type);
data->id = strdup(id); data->id = strdup(id);
// request the actual (image) data // request the actual (image) data
_avatar_request_item_by_id(from, data); _avatar_request_item_by_id(from, data);
} }
}
}
}
}
return 1; return 1;
} }
@ -215,6 +224,10 @@ _avatar_request_item_result_handler(xmpp_stanza_t* const stanza, void* const use
} }
char* buf = xmpp_stanza_get_text(st_data); char* buf = xmpp_stanza_get_text(st_data);
if (!buf) {
return 1;
}
gsize size; gsize size;
gchar* de = (gchar*)g_base64_decode(buf, &size); gchar* de = (gchar*)g_base64_decode(buf, &size);
free(buf); free(buf);

View File

@ -288,11 +288,13 @@ void
iq_id_handler_add(const char* const id, ProfIqCallback func, ProfIqFreeCallback free_func, void* userdata) iq_id_handler_add(const char* const id, ProfIqCallback func, ProfIqFreeCallback free_func, void* userdata)
{ {
ProfIqHandler* handler = malloc(sizeof(ProfIqHandler)); ProfIqHandler* handler = malloc(sizeof(ProfIqHandler));
if (handler) {
handler->func = func; handler->func = func;
handler->free_func = free_func; handler->free_func = free_func;
handler->userdata = userdata; handler->userdata = userdata;
g_hash_table_insert(id_handlers, strdup(id), handler); g_hash_table_insert(id_handlers, strdup(id), handler);
}
} }
void void
@ -481,15 +483,17 @@ iq_room_info_request(const char* const room, gboolean display_result)
xmpp_stanza_t* iq = stanza_create_disco_info_iq(ctx, id, room, NULL); xmpp_stanza_t* iq = stanza_create_disco_info_iq(ctx, id, room, NULL);
ProfRoomInfoData* cb_data = malloc(sizeof(ProfRoomInfoData)); ProfRoomInfoData* cb_data = malloc(sizeof(ProfRoomInfoData));
if (cb_data) {
cb_data->room = strdup(room); cb_data->room = strdup(room);
cb_data->display = display_result; cb_data->display = display_result;
iq_id_handler_add(id, _room_info_response_id_handler, (ProfIqFreeCallback)_iq_free_room_data, cb_data); iq_id_handler_add(id, _room_info_response_id_handler, (ProfIqFreeCallback)_iq_free_room_data, cb_data);
free(id);
iq_send_stanza(iq); iq_send_stanza(iq);
xmpp_stanza_release(iq); xmpp_stanza_release(iq);
}
free(id);
} }
void void
@ -667,6 +671,7 @@ iq_room_affiliation_list(const char* const room, char* affiliation, bool show_ui
const char* id = xmpp_stanza_get_id(iq); const char* id = xmpp_stanza_get_id(iq);
ProfAffiliationList* affiliation_list = malloc(sizeof(ProfAffiliationList)); ProfAffiliationList* affiliation_list = malloc(sizeof(ProfAffiliationList));
if (affiliation_list) {
affiliation_list->affiliation = strdup(affiliation); affiliation_list->affiliation = strdup(affiliation);
affiliation_list->show_ui_message = show_ui_message; affiliation_list->show_ui_message = show_ui_message;
@ -674,6 +679,7 @@ iq_room_affiliation_list(const char* const room, char* affiliation, bool show_ui
iq_send_stanza(iq); iq_send_stanza(iq);
xmpp_stanza_release(iq); xmpp_stanza_release(iq);
}
} }
void void
@ -699,6 +705,7 @@ iq_room_affiliation_set(const char* const room, const char* const jid, char* aff
const char* id = xmpp_stanza_get_id(iq); const char* id = xmpp_stanza_get_id(iq);
ProfPrivilegeSet* affiliation_set = malloc(sizeof(struct privilege_set_t)); ProfPrivilegeSet* affiliation_set = malloc(sizeof(struct privilege_set_t));
if (affiliation_set) {
affiliation_set->item = strdup(jid); affiliation_set->item = strdup(jid);
affiliation_set->privilege = strdup(affiliation); affiliation_set->privilege = strdup(affiliation);
@ -706,6 +713,7 @@ iq_room_affiliation_set(const char* const room, const char* const jid, char* aff
iq_send_stanza(iq); iq_send_stanza(iq);
xmpp_stanza_release(iq); xmpp_stanza_release(iq);
}
} }
void void
@ -718,6 +726,7 @@ iq_room_role_set(const char* const room, const char* const nick, char* role,
const char* id = xmpp_stanza_get_id(iq); const char* id = xmpp_stanza_get_id(iq);
struct privilege_set_t* role_set = malloc(sizeof(ProfPrivilegeSet)); struct privilege_set_t* role_set = malloc(sizeof(ProfPrivilegeSet));
if (role_set) {
role_set->item = strdup(nick); role_set->item = strdup(nick);
role_set->privilege = strdup(role); role_set->privilege = strdup(role);
@ -725,6 +734,7 @@ iq_room_role_set(const char* const room, const char* const nick, char* role,
iq_send_stanza(iq); iq_send_stanza(iq);
xmpp_stanza_release(iq); xmpp_stanza_release(iq);
}
} }
void void
@ -2162,6 +2172,7 @@ _room_info_response_id_handler(xmpp_stanza_t* const stanza, void* const userdata
if (name || category || type) { if (name || category || type) {
DiscoIdentity* identity = malloc(sizeof(struct disco_identity_t)); DiscoIdentity* identity = malloc(sizeof(struct disco_identity_t));
if (identity) {
if (name) { if (name) {
identity->name = strdup(name); identity->name = strdup(name);
ProfMucWin* mucwin = wins_get_muc(cb_data->room); ProfMucWin* mucwin = wins_get_muc(cb_data->room);
@ -2185,6 +2196,7 @@ _room_info_response_id_handler(xmpp_stanza_t* const stanza, void* const userdata
identities = g_slist_append(identities, identity); identities = g_slist_append(identities, identity);
} }
} }
}
child = xmpp_stanza_get_next(child); child = xmpp_stanza_get_next(child);
} }
@ -2309,6 +2321,7 @@ _disco_info_response_id_handler(xmpp_stanza_t* const stanza, void* const userdat
if (name || category || type) { if (name || category || type) {
DiscoIdentity* identity = malloc(sizeof(struct disco_identity_t)); DiscoIdentity* identity = malloc(sizeof(struct disco_identity_t));
if (identity) {
if (name) { if (name) {
identity->name = strdup(name); identity->name = strdup(name);
} else { } else {
@ -2328,6 +2341,7 @@ _disco_info_response_id_handler(xmpp_stanza_t* const stanza, void* const userdat
identities = g_slist_append(identities, identity); identities = g_slist_append(identities, identity);
} }
} }
}
child = xmpp_stanza_get_next(child); child = xmpp_stanza_get_next(child);
} }
@ -2491,6 +2505,7 @@ _disco_items_result_handler(xmpp_stanza_t* const stanza)
const char* item_jid = xmpp_stanza_get_attribute(child, STANZA_ATTR_JID); const char* item_jid = xmpp_stanza_get_attribute(child, STANZA_ATTR_JID);
if (item_jid) { if (item_jid) {
DiscoItem* item = malloc(sizeof(struct disco_item_t)); DiscoItem* item = malloc(sizeof(struct disco_item_t));
if (item) {
item->jid = strdup(item_jid); item->jid = strdup(item_jid);
const char* item_name = xmpp_stanza_get_attribute(child, STANZA_ATTR_NAME); const char* item_name = xmpp_stanza_get_attribute(child, STANZA_ATTR_NAME);
if (item_name) { if (item_name) {
@ -2501,6 +2516,7 @@ _disco_items_result_handler(xmpp_stanza_t* const stanza)
items = g_slist_append(items, item); items = g_slist_append(items, item);
} }
} }
}
child = xmpp_stanza_get_next(child); child = xmpp_stanza_get_next(child);
} }
@ -2578,10 +2594,12 @@ iq_mam_request(ProfChatWin* win)
xmpp_stanza_t* iq = stanza_create_mam_iq(ctx, win->barejid, datestr, NULL); xmpp_stanza_t* iq = stanza_create_mam_iq(ctx, win->barejid, datestr, NULL);
MamRsmUserdata* data = malloc(sizeof(MamRsmUserdata)); MamRsmUserdata* data = malloc(sizeof(MamRsmUserdata));
if (data) {
data->datestr = strdup(datestr); data->datestr = strdup(datestr);
data->barejid = strdup(win->barejid); data->barejid = strdup(win->barejid);
iq_id_handler_add(xmpp_stanza_get_id(iq), _mam_rsm_id_handler, NULL, data); iq_id_handler_add(xmpp_stanza_get_id(iq), _mam_rsm_id_handler, NULL, data);
}
g_free(datestr); g_free(datestr);
g_date_time_unref(timestamp); g_date_time_unref(timestamp);

View File

@ -116,14 +116,12 @@ _handled_by_plugin(xmpp_stanza_t* const stanza)
static void static void
_handle_headline(xmpp_stanza_t* const stanza) _handle_headline(xmpp_stanza_t* const stanza)
{ {
xmpp_ctx_t* ctx = connection_get_ctx();
char* text = NULL;
xmpp_stanza_t* body = xmpp_stanza_get_child_by_name(stanza, STANZA_NAME_BODY); xmpp_stanza_t* body = xmpp_stanza_get_child_by_name(stanza, STANZA_NAME_BODY);
if (body) { if (body) {
text = xmpp_stanza_get_text(body); char *text = xmpp_stanza_get_text(body);
if (text) { if (text) {
cons_show("Headline: %s", text); cons_show("Headline: %s", text);
xmpp_free(ctx, text); xmpp_free(connection_get_ctx(), text);
} }
} }
} }
@ -226,6 +224,7 @@ _message_handler(xmpp_conn_t* const conn, xmpp_stanza_t* const stanza, void* con
char* mybarejid = connection_get_barejid(); char* mybarejid = connection_get_barejid();
const char* const stanza_from = xmpp_stanza_get_from(stanza); const char* const stanza_from = xmpp_stanza_get_from(stanza);
if (stanza_from) {
if (g_strcmp0(mybarejid, stanza_from) != 0) { if (g_strcmp0(mybarejid, stanza_from) != 0) {
log_warning("Invalid carbon received, from: %s", stanza_from); log_warning("Invalid carbon received, from: %s", stanza_from);
msg_stanza = NULL; msg_stanza = NULL;
@ -234,6 +233,7 @@ _message_handler(xmpp_conn_t* const conn, xmpp_stanza_t* const stanza, void* con
// returns NULL if it was a carbon that was invalid, so that we dont parse later // returns NULL if it was a carbon that was invalid, so that we dont parse later
msg_stanza = _handle_carbons(carbons); msg_stanza = _handle_carbons(carbons);
} }
}
free(mybarejid); free(mybarejid);
} }
@ -274,6 +274,9 @@ _handle_form(xmpp_stanza_t* const stanza)
} }
const char* const stanza_from = xmpp_stanza_get_from(stanza); const char* const stanza_from = xmpp_stanza_get_from(stanza);
if (!stanza_from) {
return FALSE;
}
DataForm* form = form_create(result); DataForm* form = form_create(result);
ProfConfWin* confwin = (ProfConfWin*)wins_new_config(stanza_from, form, message_muc_submit_voice_approve, NULL, NULL); ProfConfWin* confwin = (ProfConfWin*)wins_new_config(stanza_from, form, message_muc_submit_voice_approve, NULL, NULL);
@ -861,9 +864,11 @@ _handle_error(xmpp_stanza_t* const stanza)
} else { } else {
if (type && (strcmp(type, "cancel") == 0)) { if (type && (strcmp(type, "cancel") == 0)) {
Jid* jidp = jid_create(jid); Jid* jidp = jid_create(jid);
if (jidp) {
chat_session_remove(jidp->barejid); chat_session_remove(jidp->barejid);
jid_destroy(jidp); jid_destroy(jidp);
} }
}
ui_handle_recipient_error(jid, err_msg); ui_handle_recipient_error(jid, err_msg);
} }
@ -877,6 +882,10 @@ _handle_muc_user(xmpp_stanza_t* const stanza)
xmpp_stanza_t* xns_muc_user = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_MUC_USER); xmpp_stanza_t* xns_muc_user = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_MUC_USER);
const char* room = xmpp_stanza_get_from(stanza); const char* room = xmpp_stanza_get_from(stanza);
if (!xns_muc_user) {
return;
}
if (!room) { if (!room) {
log_warning("Message received with no from attribute, ignoring"); log_warning("Message received with no from attribute, ignoring");
return; return;
@ -927,6 +936,13 @@ _handle_conference(xmpp_stanza_t* const stanza)
{ {
xmpp_stanza_t* xns_conference = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_CONFERENCE); xmpp_stanza_t* xns_conference = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_CONFERENCE);
if (xns_conference) {
// XEP-0249
const char* room = xmpp_stanza_get_attribute(xns_conference, STANZA_ATTR_JID);
if (!room) {
return;
}
const char* from = xmpp_stanza_get_from(stanza); const char* from = xmpp_stanza_get_from(stanza);
if (!from) { if (!from) {
log_warning("Message received with no from attribute, ignoring"); log_warning("Message received with no from attribute, ignoring");
@ -938,18 +954,13 @@ _handle_conference(xmpp_stanza_t* const stanza)
return; return;
} }
// XEP-0249 // reason and password are both optional
const char* room = xmpp_stanza_get_attribute(xns_conference, STANZA_ATTR_JID);
if (!room) {
jid_destroy(jidp);
return;
}
const char* reason = xmpp_stanza_get_attribute(xns_conference, STANZA_ATTR_REASON); const char* reason = xmpp_stanza_get_attribute(xns_conference, STANZA_ATTR_REASON);
const char* password = xmpp_stanza_get_attribute(xns_conference, STANZA_ATTR_PASSWORD); const char* password = xmpp_stanza_get_attribute(xns_conference, STANZA_ATTR_PASSWORD);
sv_ev_room_invite(INVITE_DIRECT, jidp->barejid, room, reason, password); sv_ev_room_invite(INVITE_DIRECT, jidp->barejid, room, reason, password);
jid_destroy(jidp); jid_destroy(jidp);
}
} }
static void static void
@ -978,22 +989,20 @@ _handle_groupchat(xmpp_stanza_t* const stanza)
{ {
xmpp_ctx_t* ctx = connection_get_ctx(); xmpp_ctx_t* ctx = connection_get_ctx();
const char* id = xmpp_stanza_get_id(stanza);
char* originid = NULL;
xmpp_stanza_t* origin = xmpp_stanza_get_child_by_name_and_ns(stanza, STANZA_NAME_ORIGIN_ID, STANZA_NS_STABLE_ID);
if (origin) {
originid = (char*)xmpp_stanza_get_attribute(origin, STANZA_ATTR_ID);
}
const char* room_jid = xmpp_stanza_get_from(stanza); const char* room_jid = xmpp_stanza_get_from(stanza);
if(!room_jid) {
return;
}
Jid* from_jid = jid_create(room_jid); Jid* from_jid = jid_create(room_jid);
if(!from_jid) {
return;
}
// handle room subject // handle room subject
xmpp_stanza_t* subject = xmpp_stanza_get_child_by_name(stanza, STANZA_NAME_SUBJECT); xmpp_stanza_t* subject = xmpp_stanza_get_child_by_name(stanza, STANZA_NAME_SUBJECT);
if (subject) { if (subject) {
char* subject_text; // subject_text is optional, can be NULL
subject_text = xmpp_stanza_get_text(subject); char* subject_text = xmpp_stanza_get_text(subject);
sv_ev_room_subject(from_jid->barejid, from_jid->resourcepart, subject_text); sv_ev_room_subject(from_jid->barejid, from_jid->resourcepart, subject_text);
xmpp_free(ctx, subject_text); xmpp_free(ctx, subject_text);
@ -1034,13 +1043,18 @@ _handle_groupchat(xmpp_stanza_t* const stanza)
message->from_jid = from_jid; message->from_jid = from_jid;
message->type = PROF_MSG_TYPE_MUC; message->type = PROF_MSG_TYPE_MUC;
const char* id = xmpp_stanza_get_id(stanza);
if (id) { if (id) {
message->id = strdup(id); message->id = strdup(id);
} }
xmpp_stanza_t* origin = xmpp_stanza_get_child_by_name_and_ns(stanza, STANZA_NAME_ORIGIN_ID, STANZA_NS_STABLE_ID);
if (origin) {
char* originid = (char*)xmpp_stanza_get_attribute(origin, STANZA_ATTR_ID);
if (originid) { if (originid) {
message->originid = strdup(originid); message->originid = strdup(originid);
} }
}
xmpp_stanza_t* replace_id_stanza = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_LAST_MESSAGE_CORRECTION); xmpp_stanza_t* replace_id_stanza = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_LAST_MESSAGE_CORRECTION);
if (replace_id_stanza) { if (replace_id_stanza) {
@ -1126,8 +1140,9 @@ static void
_handle_receipt_received(xmpp_stanza_t* const stanza) _handle_receipt_received(xmpp_stanza_t* const stanza)
{ {
xmpp_stanza_t* receipt = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_RECEIPTS); xmpp_stanza_t* receipt = xmpp_stanza_get_child_by_ns(stanza, STANZA_NS_RECEIPTS);
if (receipt) {
const char* name = xmpp_stanza_get_name(receipt); const char* name = xmpp_stanza_get_name(receipt);
if (g_strcmp0(name, "received") != 0) { if ((name == NULL) || (g_strcmp0(name, "received") != 0)) {
return; return;
} }
@ -1142,8 +1157,13 @@ _handle_receipt_received(xmpp_stanza_t* const stanza)
} }
Jid* jidp = jid_create(fulljid); Jid* jidp = jid_create(fulljid);
if(!jidp) {
return;
}
sv_ev_message_receipt(jidp->barejid, id); sv_ev_message_receipt(jidp->barejid, id);
jid_destroy(jidp); jid_destroy(jidp);
}
} }
static void static void
@ -1164,14 +1184,18 @@ _receipt_request_handler(xmpp_stanza_t* const stanza)
} }
const char* receipts_name = xmpp_stanza_get_name(receipts); const char* receipts_name = xmpp_stanza_get_name(receipts);
if (g_strcmp0(receipts_name, "request") != 0) { if ((receipts_name == NULL) || (g_strcmp0(receipts_name, "request") != 0)) {
return; return;
} }
const gchar* from = xmpp_stanza_get_from(stanza); const gchar* from = xmpp_stanza_get_from(stanza);
if (from) {
Jid* jid = jid_create(from); Jid* jid = jid_create(from);
if (jid) {
_message_send_receipt(jid->fulljid, id); _message_send_receipt(jid->fulljid, id);
jid_destroy(jid); jid_destroy(jid);
}
}
} }
static void static void
@ -1182,7 +1206,14 @@ _handle_muc_private_message(xmpp_stanza_t* const stanza)
message->type = PROF_MSG_TYPE_MUCPM; message->type = PROF_MSG_TYPE_MUCPM;
const gchar* from = xmpp_stanza_get_from(stanza); const gchar* from = xmpp_stanza_get_from(stanza);
if (!from) {
goto out;
}
message->from_jid = jid_create(from); message->from_jid = jid_create(from);
if (!message->from_jid) {
goto out;
}
// message stanza id // message stanza id
const char* id = xmpp_stanza_get_id(stanza); const char* id = xmpp_stanza_get_id(stanza);
@ -1272,6 +1303,9 @@ _handle_chat(xmpp_stanza_t* const stanza, gboolean is_mam, gboolean is_carbon, c
return; return;
} }
Jid* jid = jid_create(from); Jid* jid = jid_create(from);
if (!jid) {
return;
}
// private message from chat room use full jid (room/nick) // private message from chat room use full jid (room/nick)
if (muc_active(jid->barejid)) { if (muc_active(jid->barejid)) {
@ -1404,12 +1438,26 @@ _handle_ox_chat(xmpp_stanza_t* const stanza, ProfMessage* message, gboolean is_m
message->enc = PROF_MSG_ENC_OX; message->enc = PROF_MSG_ENC_OX;
#ifdef HAVE_LIBGPGME #ifdef HAVE_LIBGPGME
xmpp_stanza_t* ox = xmpp_stanza_get_child_by_name_and_ns(stanza, "openpgp", STANZA_NS_OPENPGP_0); xmpp_ctx_t* const ctx = connection_get_ctx();
message->plain = p_ox_gpg_decrypt(xmpp_stanza_get_text(ox));
xmpp_stanza_t *x = xmpp_stanza_new_from_string(connection_get_ctx(), message->plain); xmpp_stanza_t* ox = xmpp_stanza_get_child_by_name_and_ns(stanza, "openpgp", STANZA_NS_OPENPGP_0);
if (!ox) {
return;
}
char* ox_text = xmpp_stanza_get_text(ox);
if (!ox_text) {
return;
}
message->plain = p_ox_gpg_decrypt(ox_text);
xmpp_free(ctx, ox_text);
xmpp_stanza_t *x = xmpp_stanza_new_from_string(ctx, message->plain);
xmpp_stanza_t *p = xmpp_stanza_get_child_by_name(x, "payload"); xmpp_stanza_t *p = xmpp_stanza_get_child_by_name(x, "payload");
if (p) {
xmpp_stanza_t *b = xmpp_stanza_get_child_by_name(p, "body"); xmpp_stanza_t *b = xmpp_stanza_get_child_by_name(p, "body");
if (b) {
message->plain = xmpp_stanza_get_text(b); message->plain = xmpp_stanza_get_text(b);
if(message->plain == NULL ) { if(message->plain == NULL ) {
message->plain = xmpp_stanza_get_text(stanza); message->plain = xmpp_stanza_get_text(stanza);
@ -1420,6 +1468,8 @@ _handle_ox_chat(xmpp_stanza_t* const stanza, ProfMessage* message, gboolean is_m
message->plain = xmpp_stanza_get_text(stanza); message->plain = xmpp_stanza_get_text(stanza);
} }
message->encrypted = xmpp_stanza_get_text(ox); message->encrypted = xmpp_stanza_get_text(ox);
}
}
#endif // HAVE_LIBGPGME #endif // HAVE_LIBGPGME
} }

View File

@ -87,7 +87,7 @@ ox_announce_public_key(const char* const filename)
assert(filename); assert(filename);
cons_show("Annonuce OpenPGP Key for OX %s ...", filename); cons_show("Annonuce OpenPGP Key for OX %s ...", filename);
log_info("Annonuce OpenPGP Key of OX: %s", filename); log_info("[OX] Annonuce OpenPGP Key of OX: %s", filename);
// key the key and the fingerprint via GnuPG from file // key the key and the fingerprint via GnuPG from file
char* key = NULL; char* key = NULL;
@ -98,7 +98,7 @@ ox_announce_public_key(const char* const filename)
cons_show("Error during OpenPGP OX announce. See log file for more information"); cons_show("Error during OpenPGP OX announce. See log file for more information");
return FALSE; return FALSE;
} else { } else {
log_info("Annonuce OpenPGP Key for Fingerprint: %s", fp); log_info("[OX] Annonuce OpenPGP Key for Fingerprint: %s", fp);
xmpp_ctx_t* const ctx = connection_get_ctx(); xmpp_ctx_t* const ctx = connection_get_ctx();
char* id = xmpp_uuid_gen(ctx); char* id = xmpp_uuid_gen(ctx);
xmpp_stanza_t* iq = xmpp_iq_new(ctx, STANZA_TYPE_SET, id); xmpp_stanza_t* iq = xmpp_iq_new(ctx, STANZA_TYPE_SET, id);
@ -118,7 +118,9 @@ ox_announce_public_key(const char* const filename)
xmpp_stanza_t* item = xmpp_stanza_new(ctx); xmpp_stanza_t* item = xmpp_stanza_new(ctx);
xmpp_stanza_set_name(item, STANZA_NAME_ITEM); xmpp_stanza_set_name(item, STANZA_NAME_ITEM);
xmpp_stanza_set_attribute(item, STANZA_ATTR_ID, _gettimestamp()); char *timestamp = _gettimestamp();
xmpp_stanza_set_attribute(item, STANZA_ATTR_ID, timestamp);
free(timestamp);
xmpp_stanza_t* pubkey = xmpp_stanza_new(ctx); xmpp_stanza_t* pubkey = xmpp_stanza_new(ctx);
xmpp_stanza_set_name(pubkey, STANZA_NAME_PUPKEY); xmpp_stanza_set_name(pubkey, STANZA_NAME_PUPKEY);
@ -262,34 +264,34 @@ _ox_metadata_node__public_key(const char* const fingerprint)
static int static int
_ox_metadata_result(xmpp_conn_t* const conn, xmpp_stanza_t* const stanza, void* const userdata) _ox_metadata_result(xmpp_conn_t* const conn, xmpp_stanza_t* const stanza, void* const userdata)
{ {
log_debug("OX: Processing result %s's metadata.", (char*)userdata); log_debug("[OX] Processing result %s's metadata.", (char*)userdata);
if (g_strcmp0(xmpp_stanza_get_type(stanza), "result") != 0) { if (g_strcmp0(xmpp_stanza_get_type(stanza), "result") != 0) {
cons_show("OX: Error:"); log_debug("[OX] Error: No result");
return FALSE; return FALSE;
} }
// pubsub // pubsub
xmpp_stanza_t* pubsub = xmpp_stanza_get_child_by_name_and_ns(stanza, STANZA_NAME_PUBSUB, XMPP_FEATURE_PUBSUB); xmpp_stanza_t* pubsub = xmpp_stanza_get_child_by_name_and_ns(stanza, STANZA_NAME_PUBSUB, XMPP_FEATURE_PUBSUB);
if (!pubsub) { if (!pubsub) {
cons_show("OX: Error: No pubsub"); cons_show("[OX] Error: No pubsub");
return FALSE; return FALSE;
} }
xmpp_stanza_t* items = xmpp_stanza_get_child_by_name(pubsub, STANZA_NAME_ITEMS); xmpp_stanza_t* items = xmpp_stanza_get_child_by_name(pubsub, STANZA_NAME_ITEMS);
if (!items) { if (!items) {
cons_show("OX: Error: No items"); cons_show("[OX] Error: No items");
return FALSE; return FALSE;
} }
xmpp_stanza_t* item = xmpp_stanza_get_child_by_name(items, STANZA_NAME_ITEM); xmpp_stanza_t* item = xmpp_stanza_get_child_by_name(items, STANZA_NAME_ITEM);
if (!item) { if (!item) {
cons_show("OX: Error: No item"); cons_show("[OX] Error: No item");
return FALSE; return FALSE;
} }
xmpp_stanza_t* publickeyslist = xmpp_stanza_get_child_by_name_and_ns(item, STANZA_NAME_PUBLIC_KEYS_LIST, STANZA_NS_OPENPGP_0); xmpp_stanza_t* publickeyslist = xmpp_stanza_get_child_by_name_and_ns(item, STANZA_NAME_PUBLIC_KEYS_LIST, STANZA_NS_OPENPGP_0);
if (!publickeyslist) { if (!publickeyslist) {
cons_show("OX: Error: No publickeyslist"); cons_show("[OX] Error: No publickeyslist");
return FALSE; return FALSE;
} }
@ -297,7 +299,9 @@ _ox_metadata_result(xmpp_conn_t* const conn, xmpp_stanza_t* const stanza, void*
while (pubkeymetadata) { while (pubkeymetadata) {
const char* fingerprint = xmpp_stanza_get_attribute(pubkeymetadata, STANZA_ATTR_V4_FINGERPRINT); const char* fingerprint = xmpp_stanza_get_attribute(pubkeymetadata, STANZA_ATTR_V4_FINGERPRINT);
if (fingerprint) {
cons_show(fingerprint); cons_show(fingerprint);
}
pubkeymetadata = xmpp_stanza_get_next(pubkeymetadata); pubkeymetadata = xmpp_stanza_get_next(pubkeymetadata);
} }
@ -328,7 +332,7 @@ _ox_request_public_key(const char* const jid, const char* const fingerprint)
assert(fingerprint); assert(fingerprint);
assert(strlen(fingerprint) == 40); assert(strlen(fingerprint) == 40);
cons_show("Requesting Public Key %s for %s", fingerprint, jid); cons_show("Requesting Public Key %s for %s", fingerprint, jid);
log_info("OX: Request %s's public key %s.", jid, fingerprint); log_info("[OX] Request %s's public key %s.", jid, fingerprint);
// iq // iq
xmpp_ctx_t* const ctx = connection_get_ctx(); xmpp_ctx_t* const ctx = connection_get_ctx();
char* id = xmpp_uuid_gen(ctx); char* id = xmpp_uuid_gen(ctx);
@ -384,50 +388,60 @@ _ox_request_public_key(const char* const jid, const char* const fingerprint)
int int
_ox_public_key_result(xmpp_conn_t* const conn, xmpp_stanza_t* const stanza, void* const userdata) _ox_public_key_result(xmpp_conn_t* const conn, xmpp_stanza_t* const stanza, void* const userdata)
{ {
log_debug("OX: Processing result public key"); log_debug("[OX] Processing result public key");
if (g_strcmp0(xmpp_stanza_get_type(stanza), "result") != 0) { if (g_strcmp0(xmpp_stanza_get_type(stanza), "result") != 0) {
cons_show("Public Key import failed. Check log for details."); cons_show("Public Key import failed. Check log for details.");
log_error("OX: Public Key response type is wrong"); log_error("[OX] Public Key response type is wrong");
return FALSE; return FALSE;
} }
// pubsub // pubsub
xmpp_stanza_t* pubsub = xmpp_stanza_get_child_by_name_and_ns(stanza, STANZA_NAME_PUBSUB, XMPP_FEATURE_PUBSUB); xmpp_stanza_t* pubsub = xmpp_stanza_get_child_by_name_and_ns(stanza, STANZA_NAME_PUBSUB, XMPP_FEATURE_PUBSUB);
if (!pubsub) { if (!pubsub) {
cons_show("Public Key import failed. Check log for details."); cons_show("Public Key import failed. Check log for details.");
log_error("OX: Public key request response failed: No <pubsub/>"); log_error("[OX] Public key request response failed: No <pubsub/>");
return FALSE; return FALSE;
} }
xmpp_stanza_t* items = xmpp_stanza_get_child_by_name(pubsub, STANZA_NAME_ITEMS); xmpp_stanza_t* items = xmpp_stanza_get_child_by_name(pubsub, STANZA_NAME_ITEMS);
if (!items) { if (!items) {
cons_show("Public Key import failed. Check log for details."); cons_show("Public Key import failed. Check log for details.");
log_error("OX: Public key request response failed: No <items/>"); log_error("[OX] Public key request response failed: No <items/>");
return FALSE; return FALSE;
} }
xmpp_stanza_t* item = xmpp_stanza_get_child_by_name(items, STANZA_NAME_ITEM); xmpp_stanza_t* item = xmpp_stanza_get_child_by_name(items, STANZA_NAME_ITEM);
if (!item) { if (!item) {
cons_show("Public Key import failed. Check log for details."); cons_show("Public Key import failed. Check log for details.");
log_error("OX: Public key request response failed: No <item/>"); log_error("[OX] Public key request response failed: No <item/>");
return FALSE; return FALSE;
} }
xmpp_stanza_t* pubkey = xmpp_stanza_get_child_by_name_and_ns(item, STANZA_NAME_PUPKEY, STANZA_NS_OPENPGP_0); xmpp_stanza_t* pubkey = xmpp_stanza_get_child_by_name_and_ns(item, STANZA_NAME_PUPKEY, STANZA_NS_OPENPGP_0);
if (!pubkey) { if (!pubkey) {
cons_show("Public Key import failed. Check log for details."); cons_show("Public Key import failed. Check log for details.");
log_error("OX: Public key request response failed: No <pubkey/>"); log_error("[OX] Public key request response failed: No <pubkey/>");
return FALSE; return FALSE;
} }
xmpp_stanza_t* data = xmpp_stanza_get_child_by_name(pubkey, STANZA_NAME_DATA); xmpp_stanza_t* data = xmpp_stanza_get_child_by_name(pubkey, STANZA_NAME_DATA);
if (!data) {
log_error("[OX] No data");
}
char* base64_data = xmpp_stanza_get_text(data); char* base64_data = xmpp_stanza_get_text(data);
if (base64_data) {
log_debug("Key data: %s", base64_data); log_debug("Key data: %s", base64_data);
if (p_ox_gpg_import(base64_data)) { if (p_ox_gpg_import(base64_data)) {
cons_show("Public Key imported"); cons_show("Public Key imported");
} else { } else {
cons_show("Public Key import failed. Check log for details."); cons_show("Public Key import failed. Check log for details.");
} }
free(base64_data);
}
return FALSE; return FALSE;
} }

View File

@ -986,7 +986,7 @@ stanza_create_caps_query_element(xmpp_ctx_t* ctx)
GString* name_str = g_string_new("Profanity "); GString* name_str = g_string_new("Profanity ");
g_string_append(name_str, PACKAGE_VERSION); g_string_append(name_str, PACKAGE_VERSION);
if (strcmp(PACKAGE_STATUS, "development") == 0) { if (g_strcmp0(PACKAGE_STATUS, "development") == 0) {
#ifdef HAVE_GIT_VERSION #ifdef HAVE_GIT_VERSION
g_string_append(name_str, "dev."); g_string_append(name_str, "dev.");
g_string_append(name_str, PROF_GIT_BRANCH); g_string_append(name_str, PROF_GIT_BRANCH);
@ -1074,16 +1074,16 @@ stanza_create_caps_sha1_from_query(xmpp_stanza_t* const query)
g_string_append(identity_str, name); g_string_append(identity_str, name);
} }
g_string_append(identity_str, "<"); g_string_append(identity_str, "<");
identities = g_slist_insert_sorted(identities, g_strdup(identity_str->str), (GCompareFunc)strcmp); identities = g_slist_insert_sorted(identities, g_strdup(identity_str->str), (GCompareFunc)g_strcmp0);
g_string_free(identity_str, TRUE); g_string_free(identity_str, TRUE);
} else if (g_strcmp0(xmpp_stanza_get_name(child), STANZA_NAME_FEATURE) == 0) { } else if (g_strcmp0(xmpp_stanza_get_name(child), STANZA_NAME_FEATURE) == 0) {
const char* feature_str = xmpp_stanza_get_attribute(child, "var"); const char* feature_str = xmpp_stanza_get_attribute(child, "var");
features = g_slist_insert_sorted(features, g_strdup(feature_str), (GCompareFunc)strcmp); features = g_slist_insert_sorted(features, g_strdup(feature_str), (GCompareFunc)g_strcmp0);
} else if (g_strcmp0(xmpp_stanza_get_name(child), STANZA_NAME_X) == 0) { } else if (g_strcmp0(xmpp_stanza_get_name(child), STANZA_NAME_X) == 0) {
if (g_strcmp0(xmpp_stanza_get_ns(child), STANZA_NS_DATA) == 0) { if (g_strcmp0(xmpp_stanza_get_ns(child), STANZA_NS_DATA) == 0) {
DataForm* form = form_create(child); DataForm* form = form_create(child);
char* form_type = form_get_form_type_field(form); char* form_type = form_get_form_type_field(form);
form_names = g_slist_insert_sorted(form_names, g_strdup(form_type), (GCompareFunc)strcmp); form_names = g_slist_insert_sorted(form_names, g_strdup(form_type), (GCompareFunc)g_strcmp0);
g_hash_table_insert(forms, g_strdup(form_type), form); g_hash_table_insert(forms, g_strdup(form_type), form);
} }
} }
@ -1154,9 +1154,9 @@ stanza_get_child_by_name_and_from(xmpp_stanza_t* const stanza, const char* const
for (child = xmpp_stanza_get_children(stanza); child; child = xmpp_stanza_get_next(child)) { for (child = xmpp_stanza_get_children(stanza); child; child = xmpp_stanza_get_next(child)) {
child_name = xmpp_stanza_get_name(child); child_name = xmpp_stanza_get_name(child);
if (child_name && strcmp(name, child_name) == 0) { if (child_name && g_strcmp0(name, child_name) == 0) {
child_from = xmpp_stanza_get_attribute(child, STANZA_ATTR_FROM); child_from = xmpp_stanza_get_attribute(child, STANZA_ATTR_FROM);
if (child_from && strcmp(from, child_from) == 0) { if (child_from && g_strcmp0(from, child_from) == 0) {
break; break;
} }
} }
@ -1177,7 +1177,7 @@ _stanza_get_delay_timestamp_xep0203(xmpp_stanza_t* const delay_stanza)
GTimeVal utc_stamp; GTimeVal utc_stamp;
const char* xmlns = xmpp_stanza_get_attribute(delay_stanza, STANZA_ATTR_XMLNS); const char* xmlns = xmpp_stanza_get_attribute(delay_stanza, STANZA_ATTR_XMLNS);
if (xmlns && (strcmp(xmlns, "urn:xmpp:delay") == 0)) { if (xmlns && (g_strcmp0(xmlns, "urn:xmpp:delay") == 0)) {
const char* stamp = xmpp_stanza_get_attribute(delay_stanza, STANZA_ATTR_STAMP); const char* stamp = xmpp_stanza_get_attribute(delay_stanza, STANZA_ATTR_STAMP);
if (stamp && (g_time_val_from_iso8601(stamp, &utc_stamp))) { if (stamp && (g_time_val_from_iso8601(stamp, &utc_stamp))) {
@ -1199,7 +1199,7 @@ _stanza_get_delay_timestamp_xep0091(xmpp_stanza_t* const x_stanza)
GTimeVal utc_stamp; GTimeVal utc_stamp;
const char* xmlns = xmpp_stanza_get_attribute(x_stanza, STANZA_ATTR_XMLNS); const char* xmlns = xmpp_stanza_get_attribute(x_stanza, STANZA_ATTR_XMLNS);
if (xmlns && (strcmp(xmlns, "jabber:x:delay") == 0)) { if (xmlns && (g_strcmp0(xmlns, "jabber:x:delay") == 0)) {
const char* stamp = xmpp_stanza_get_attribute(x_stanza, STANZA_ATTR_STAMP); const char* stamp = xmpp_stanza_get_attribute(x_stanza, STANZA_ATTR_STAMP);
if (stamp && (g_time_val_from_iso8601(stamp, &utc_stamp))) { if (stamp && (g_time_val_from_iso8601(stamp, &utc_stamp))) {
@ -1256,7 +1256,7 @@ stanza_get_oldest_delay(xmpp_stanza_t* const stanza)
child_name = xmpp_stanza_get_name(child); child_name = xmpp_stanza_get_name(child);
if (child_name && strcmp(child_name, STANZA_NAME_DELAY) == 0) { if (child_name && g_strcmp0(child_name, STANZA_NAME_DELAY) == 0) {
GDateTime* tmp = _stanza_get_delay_timestamp_xep0203(child); GDateTime* tmp = _stanza_get_delay_timestamp_xep0203(child);
if (oldest == NULL) { if (oldest == NULL) {
@ -1269,7 +1269,7 @@ stanza_get_oldest_delay(xmpp_stanza_t* const stanza)
} }
} }
if (child_name && strcmp(child_name, STANZA_NAME_X) == 0) { if (child_name && g_strcmp0(child_name, STANZA_NAME_X) == 0) {
GDateTime* tmp = _stanza_get_delay_timestamp_xep0091(child); GDateTime* tmp = _stanza_get_delay_timestamp_xep0091(child);
if (oldest == NULL) { if (oldest == NULL) {
@ -1320,7 +1320,7 @@ stanza_is_muc_presence(xmpp_stanza_t* const stanza)
if (stanza == NULL) { if (stanza == NULL) {
return FALSE; return FALSE;
} }
if (strcmp(xmpp_stanza_get_name(stanza), STANZA_NAME_PRESENCE) != 0) { if (g_strcmp0(xmpp_stanza_get_name(stanza), STANZA_NAME_PRESENCE) != 0) {
return FALSE; return FALSE;
} }
@ -1507,11 +1507,8 @@ stanza_get_muc_destroy_alternative_room(xmpp_stanza_t* stanza)
} }
const char* jid = xmpp_stanza_get_attribute(destroy, STANZA_ATTR_JID); const char* jid = xmpp_stanza_get_attribute(destroy, STANZA_ATTR_JID);
if (jid) {
return jid;
}
return NULL; return jid;
} }
char* char*
@ -1668,7 +1665,7 @@ stanza_get_new_nick(xmpp_stanza_t* const stanza)
xmpp_stanza_t* x_children = xmpp_stanza_get_children(x); xmpp_stanza_t* x_children = xmpp_stanza_get_children(x);
while (x_children) { while (x_children) {
if (strcmp(xmpp_stanza_get_name(x_children), STANZA_NAME_ITEM) == 0) { if (g_strcmp0(xmpp_stanza_get_name(x_children), STANZA_NAME_ITEM) == 0) {
const char* nick = xmpp_stanza_get_attribute(x_children, STANZA_ATTR_NICK); const char* nick = xmpp_stanza_get_attribute(x_children, STANZA_ATTR_NICK);
if (nick) { if (nick) {
return nick; return nick;
@ -1694,7 +1691,7 @@ stanza_get_idle_time(xmpp_stanza_t* const stanza)
return 0; return 0;
} }
if (strcmp(ns, STANZA_NS_LASTACTIVITY) != 0) { if (g_strcmp0(ns, STANZA_NS_LASTACTIVITY) != 0) {
return 0; return 0;
} }
@ -1756,19 +1753,19 @@ stanza_create_caps_from_query_element(xmpp_stanza_t* query)
while (field) { while (field) {
formField = field->data; formField = field->data;
if (formField->values) { if (formField->values) {
if (strcmp(formField->var, "software") == 0) { if (g_strcmp0(formField->var, "software") == 0) {
if (software == NULL) { if (software == NULL) {
software = strdup(formField->values->data); software = strdup(formField->values->data);
} }
} else if (strcmp(formField->var, "software_version") == 0) { } else if (g_strcmp0(formField->var, "software_version") == 0) {
if (software_version == NULL) { if (software_version == NULL) {
software_version = strdup(formField->values->data); software_version = strdup(formField->values->data);
} }
} else if (strcmp(formField->var, "os") == 0) { } else if (g_strcmp0(formField->var, "os") == 0) {
if (os == NULL) { if (os == NULL) {
os = strdup(formField->values->data); os = strdup(formField->values->data);
} }
} else if (strcmp(formField->var, "os_version") == 0) { } else if (g_strcmp0(formField->var, "os_version") == 0) {
if (os_version == NULL) { if (os_version == NULL) {
os_version = strdup(formField->values->data); os_version = strdup(formField->values->data);
} }