Mercurial > pidgin
changeset 2991:9d11dbb33b6f
[gaim-migrate @ 3004]
KingAnt says: SSI SSI SSI
I say! HI HI HI!
committer: Tailor Script <tailor@pidgin.im>
| author | Rob Flynn <gaim@robflynn.com> |
|---|---|
| date | Sat, 02 Mar 2002 01:36:01 +0000 |
| parents | 06f2bae259a0 |
| children | d16a0504f1c8 |
| files | src/protocols/oscar/aim.h src/protocols/oscar/aim_cbtypes.h src/protocols/oscar/conn.c src/protocols/oscar/oscar.c src/protocols/oscar/ssi.c |
| diffstat | 5 files changed, 1438 insertions(+), 53 deletions(-) [+] |
line wrap: on
line diff
--- a/src/protocols/oscar/aim.h Tue Feb 26 23:06:53 2002 +0000 +++ b/src/protocols/oscar/aim.h Sat Mar 02 01:36:01 2002 +0000 @@ -305,6 +305,16 @@ /* ---- Internal Use Only ------------------------ */ + /* Server-stored information (ssi) */ + struct { + int received_data; + fu16_t revision; + struct aim_ssi_item *items; + time_t timestamp; + int waiting_for_ack; + aim_frame_t *holding_queue; + } ssi; + /* Connection information */ aim_conn_t *connlist; @@ -998,9 +1008,26 @@ faim_export int aim_ssi_reqrights(aim_session_t *sess, aim_conn_t *conn); faim_export int aim_ssi_reqdata(aim_session_t *sess, aim_conn_t *conn, time_t localstamp, fu16_t localrev); faim_export int aim_ssi_enable(aim_session_t *sess, aim_conn_t *conn); +faim_export int aim_ssi_additems(aim_session_t *sess, aim_conn_t *conn, struct aim_ssi_item **items, unsigned int num); +faim_export int aim_ssi_moditems(aim_session_t *sess, aim_conn_t *conn, struct aim_ssi_item **items, unsigned int num); +faim_export int aim_ssi_delitems(aim_session_t *sess, aim_conn_t *conn, struct aim_ssi_item **items, unsigned int num); faim_export int aim_ssi_modbegin(aim_session_t *sess, aim_conn_t *conn); faim_export int aim_ssi_modend(aim_session_t *sess, aim_conn_t *conn); +faim_export int aim_ssi_inlist(aim_session_t *sess, aim_conn_t *conn, char *name, fu16_t type); +/* faim_export int aim_ssi_getpermdeny(aim_tlvlist_t *tlvlist); */ +faim_export int aim_ssi_cleanlist(aim_session_t *sess, aim_conn_t *conn); +faim_export int aim_ssi_addmastergroup(aim_session_t *sess, aim_conn_t *conn); +faim_export int aim_ssi_addbuddies(aim_session_t *sess, aim_conn_t *conn, char *gn, char **sn, unsigned int num); +faim_export int aim_ssi_addgroups(aim_session_t *sess, aim_conn_t *conn, char **gn, unsigned int num); +faim_export int aim_ssi_addpermits(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num); +faim_export int aim_ssi_adddenies(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num); +faim_export int aim_ssi_delbuddies(aim_session_t *sess, aim_conn_t *conn, char *gn, char **sn, unsigned int num); +faim_export int aim_ssi_delgroups(aim_session_t *sess, aim_conn_t *conn, char **gn, unsigned int num); +faim_export int aim_ssi_delpermits(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num); +faim_export int aim_ssi_deldenies(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num); +faim_export int aim_ssi_setpermdeny(aim_session_t *sess, aim_conn_t *conn, int permdeny); + struct aim_icq_offlinemsg { fu32_t sender; fu16_t year;
--- a/src/protocols/oscar/aim_cbtypes.h Tue Feb 26 23:06:53 2002 +0000 +++ b/src/protocols/oscar/aim_cbtypes.h Sat Mar 02 01:36:01 2002 +0000 @@ -23,6 +23,7 @@ #define AIM_CB_FAM_TRN 0x000c #define AIM_CB_FAM_CTN 0x000d /* ChatNav */ #define AIM_CB_FAM_CHT 0x000e /* Chat */ +#define AIM_CB_FAM_SSI 0x0013 /* Server stored information */ #define AIM_CB_FAM_ICQ 0x0015 #define AIM_CB_FAM_ATH 0x0017 #define AIM_CB_FAM_OFT 0xfffe /* OFT/Rvous */ @@ -184,6 +185,23 @@ #define AIM_CB_ICQ_DEFAULT 0xffff /* + * SNAC Family: Server-Stored Buddy Lists + */ +#define AIM_CB_SSI_ERROR 0x0001 +#define AIM_CB_SSI_REQRIGHTS 0x0002 +#define AIM_CB_SSI_RIGHTSINFO 0x0003 +#define AIM_CB_SSI_REQLIST 0x0005 +#define AIM_CB_SSI_LIST 0x0006 +#define AIM_CB_SSI_ACTIVATE 0x0007 +#define AIM_CB_SSI_ADD 0x0008 +#define AIM_CB_SSI_MOD 0x0009 +#define AIM_CB_SSI_DEL 0x000A +#define AIM_CB_SSI_SRVACK 0x000E +#define AIM_CB_SSI_NOLIST 0x000F +#define AIM_CB_SSI_EDITSTART 0x0011 +#define AIM_CB_SSI_EDITSTOP 0x0012 + +/* * SNAC Family: Authorizer * * Used only in protocol versions three and above.
--- a/src/protocols/oscar/conn.c Tue Feb 26 23:06:53 2002 +0000 +++ b/src/protocols/oscar/conn.c Sat Mar 02 01:36:01 2002 +0000 @@ -876,6 +876,13 @@ sess->modlistv = NULL; + sess->ssi.received_data = 0; + sess->ssi.waiting_for_ack = 0; + sess->ssi.holding_queue = NULL; + sess->ssi.revision = 0; + sess->ssi.items = NULL; + sess->ssi.timestamp = (time_t)0; + /* * Default to SNAC login unless XORLOGIN is explicitly set. */
--- a/src/protocols/oscar/oscar.c Tue Feb 26 23:06:53 2002 +0000 +++ b/src/protocols/oscar/oscar.c Sat Mar 02 01:36:01 2002 +0000 @@ -254,6 +254,8 @@ static int gaim_offlinemsgdone (aim_session_t *, aim_frame_t *, ...); static int gaim_simpleinfo (aim_session_t *, aim_frame_t *, ...); static int gaim_popup (aim_session_t *, aim_frame_t *, ...); +static int gaim_ssi_parserights (aim_session_t *, aim_frame_t *, ...); +static int gaim_ssi_parselist (aim_session_t *, aim_frame_t *, ...); static int gaim_directim_initiate(aim_session_t *, aim_frame_t *, ...); static int gaim_directim_incoming(aim_session_t *, aim_frame_t *, ...); @@ -682,6 +684,9 @@ aim_conn_addhandler(sess, bosconn, AIM_CB_FAM_ICQ, AIM_CB_ICQ_OFFLINEMSGCOMPLETE, gaim_offlinemsgdone, 0); aim_conn_addhandler(sess, bosconn, AIM_CB_FAM_POP, 0x0002, gaim_popup, 0); aim_conn_addhandler(sess, bosconn, AIM_CB_FAM_ICQ, AIM_CB_ICQ_SIMPLEINFO, gaim_simpleinfo, 0); + aim_conn_addhandler(sess, bosconn, AIM_CB_FAM_SSI, AIM_CB_SSI_RIGHTSINFO, gaim_ssi_parserights, 0); + aim_conn_addhandler(sess, bosconn, AIM_CB_FAM_SSI, AIM_CB_SSI_LIST, gaim_ssi_parselist, 0); + aim_conn_addhandler(sess, bosconn, AIM_CB_FAM_SSI, AIM_CB_SSI_NOLIST, gaim_ssi_parselist, 0); ((struct oscar_data *)gc->proto_data)->conn = bosconn; for (i = 0; i < (int)strlen(info->bosip); i++) { @@ -2160,6 +2165,8 @@ aim_reqservice(sess, fr->conn, AIM_CONN_TYPE_CHATNAV); + aim_ssi_reqrights(sess, fr->conn); + return 1; } @@ -2515,14 +2522,44 @@ static void oscar_add_buddy(struct gaim_connection *g, char *name) { struct oscar_data *odata = (struct oscar_data *)g->proto_data; - aim_add_buddy(odata->sess, odata->conn, name); + if (odata->sess->ssi.received_data) { + debug_printf("ssi: adding %s to group %s\n", name, find_group_by_buddy(g, name)->name); + aim_ssi_addbuddies(odata->sess, odata->conn, find_group_by_buddy(g, name)->name, &name, 1); + } +/* aim_add_buddy(odata->sess, odata->conn, name); */ } static void oscar_add_buddies(struct gaim_connection *g, GList *buddies) { + char **sns; + GSList *grp, *mem; + struct group *group; struct oscar_data *odata = (struct oscar_data *)g->proto_data; - char buf[MSG_LEN]; - int n = 0; - while (buddies) { +/* char buf[MSG_LEN]; */ + int tmp=0, n=0; + + if (odata->sess->ssi.received_data) { + for (grp=g->groups; grp; grp=g_slist_next(grp)) { + group = (struct group*)grp->data; + tmp = 0; + for (mem=group->members; mem; mem=mem->next) + if (!aim_ssi_inlist(odata->sess, odata->conn, ((struct buddy*)mem->data)->name, 0x0000)) + tmp++; + sns = (char **)malloc(tmp*sizeof(char*)); + tmp = 0; + for (mem=group->members; mem; mem=mem->next) + if (!aim_ssi_inlist(odata->sess, odata->conn, ((struct buddy*)mem->data)->name, 0x0000)) { + debug_printf("ssi: adding %s from local list to server list\n", ((struct buddy*)mem->data)->name); + sns[tmp] = ((char *)((struct buddy*)mem->data)->name); + tmp++; + } + if (tmp) { + aim_ssi_addbuddies(odata->sess, odata->conn, group->name, sns, tmp); + free(sns); + } + } + } + +/* while (buddies) { if (n > MSG_LEN - 18) { aim_bos_setbuddylist(odata->sess, odata->conn, buf); n = 0; @@ -2530,12 +2567,218 @@ n += g_snprintf(buf + n, sizeof(buf) - n, "%s&", (char *)buddies->data); buddies = buddies->next; } - aim_bos_setbuddylist(odata->sess, odata->conn, buf); + aim_bos_setbuddylist(odata->sess, odata->conn, buf); */ } static void oscar_remove_buddy(struct gaim_connection *g, char *name, char *group) { struct oscar_data *odata = (struct oscar_data *)g->proto_data; - aim_remove_buddy(odata->sess, odata->conn, name); + if (odata->sess->ssi.received_data) + while (aim_ssi_inlist(odata->sess, odata->conn, name, 0x0000) && !aim_ssi_delbuddies(odata->sess, odata->conn, group, &name, 1)) + debug_printf("ssi: deleted %s from the server list\n", name); +/* aim_remove_buddy(odata->sess, odata->conn, name); */ +} + +static void oscar_remove_buddies(struct gaim_connection *g, GList *buddies, char *group) { + GList *cur; + struct oscar_data *odata = (struct oscar_data *)g->proto_data; + if (odata->sess->ssi.received_data) { + int tmp = 0; + for (cur=buddies; cur; cur=cur->next) + if (aim_ssi_inlist(odata->sess, odata->conn, cur->data, 0x0000)) + tmp++; + if (tmp) { + char **sns; + sns = (char **)malloc(tmp*sizeof(char*)); + tmp = 0; + for (cur=buddies; cur; cur=cur->next) + if (aim_ssi_inlist(odata->sess, odata->conn, cur->data, 0x0000)) { + sns[tmp] = cur->data; + tmp++; + } + aim_ssi_delbuddies(odata->sess, odata->conn, group, sns, tmp); + debug_printf("ssi: deleted some buddies from the server list\n"); + free(sns); + } + } +/* for (cur=buddies; cur; cur=cur->next) + aim_remove_buddy(odata->sess, odata->conn, cur->data); */ +} + +static int gaim_ssi_parserights(aim_session_t *sess, aim_frame_t *fr, ...) { +/* XXX - Fix parsing of the ssi rights packet and pass us the data + fu16_t maxbuddies, maxgroups, maxpermits, maxdenies; + va_list ap; + + va_start(ap, fr); + maxbuddies = (fu16_t)va_arg(ap, unsigned int); + maxgroupss = (fu16_t)va_arg(ap, unsigned int); + maxpermits = (fu16_t)va_arg(ap, unsigned int); + maxdenies = (fu16_t)va_arg(ap, unsigned int); + va_end(ap); + + debug_printf("ssi rights: Max buddies = %d / Max groups = %d / Max permits = %d / Max denies = %d\n", maxbuddies, maxgroups, maxpermits, maxdenies); +*/ + debug_printf("ssi: requesting ssi list\n"); + + aim_ssi_reqdata(sess, fr->conn, sess->ssi.timestamp, sess->ssi.revision); + + return 1; +} + +static int gaim_ssi_parselist(aim_session_t *sess, aim_frame_t *fr, ...) { + struct gaim_connection *gc = sess->aux_data; + struct aim_ssi_item *curitem, *curgroup; + struct group *g; + GSList *grp; + GSList *mem; + int tmp; + char **sns; + + debug_printf("ssi: syncing local list and server list\n"); + + /* Activate SSI */ + debug_printf("ssi: activating server-stored buddy list\n"); + aim_ssi_enable(sess, fr->conn); + + /* Clean the buddy list */ +/* aim_ssi_cleanlist(sess, fr->conn); */ + + /* Delete the buddy list */ +/* aim_ssi_deletelist(sess, fr->conn); */ + + /* Add from server list to local list */ + tmp = 0; + for (curitem=sess->ssi.items; curitem; curitem=curitem->next) { + switch (curitem->type) { + case 0x0000: /* Buddy */ + if ((curitem->name) && (!find_buddy(gc, curitem->name))) { + curgroup = sess->ssi.items; + while (curgroup) { + if ((curgroup->type == 0x0001) && (curgroup->gid == curitem->gid) && (curgroup->name)) { + debug_printf("ssi: adding buddy %s from server list to local list\n", curitem->name); + add_buddy(gc, curgroup->name, curitem->name, 0); + tmp++; + } + curgroup = curgroup->next; + } + } + break; + + case 0x0002: /* Permit item */ + if (curitem->name) { + GSList *list; + for (list=gc->permit; (list && aim_sncmp(curitem->name, list->data)); list=list->next); + if (!list) { + char *name; + debug_printf("ssi: adding permit %s from server list to local list\n", curitem->name); + name = g_strdup(normalize(curitem->name)); + gc->permit = g_slist_append(gc->permit, name); + build_allow_list(); + tmp++; + } + } + break; + + case 0x0003: /* Deny item */ + if (curitem->name) { + GSList *list; + for (list=gc->deny; (list && aim_sncmp(curitem->name, list->data)); list=list->next); + if (!list) { + char *name; + debug_printf("ssi: adding deny %s from server list to local list\n", curitem->name); + name = g_strdup(normalize(curitem->name)); + gc->deny = g_slist_append(gc->deny, name); + build_block_list(); + tmp++; + } + } + break; + + case 0x0004: /* Permit/deny item */ + if (curitem->data) { + fu8_t permdeny; + if (permdeny = aim_ssi_getpermdeny(curitem->data)) { + debug_printf("ssi: changing permdeny from %d to %d\n", gc->permdeny, permdeny); + gc->permdeny = permdeny; + } + } + break; + } /* End of switch on curitem->type */ + } /* End of for loop */ + if (tmp) + do_export(gc); + + /* Add from local list to server list */ + if (gc) { + /* Buddies */ + grp = gc->groups; + while (grp) { + g = (struct group*)grp->data; + tmp = 0; + for (mem=g->members; mem; mem=mem->next) + if (!aim_ssi_inlist(sess, fr->conn, ((struct buddy*)mem->data)->name, 0x0000)) + tmp++; + sns = (char **)malloc(tmp*sizeof(char*)); + tmp = 0; + for (mem=g->members; mem; mem=mem->next) + if (!aim_ssi_inlist(sess, fr->conn, ((struct buddy*)mem->data)->name, 0x0000)) { + debug_printf("ssi: adding buddy %s from local list to server list\n", ((struct buddy*)mem->data)->name); + sns[tmp] = ((char *)((struct buddy*)mem->data)->name); + tmp++; + } + if (tmp) { + aim_ssi_addbuddies(sess, fr->conn, g->name, sns, tmp); + free(sns); + } + grp = g_slist_next(grp); + } + + /* Permit list */ + if (gc->permit) { + GSList *list; + tmp = 0; + for (list=gc->permit; list; list=list->next) + if (!aim_ssi_inlist(sess, fr->conn, list->data, 0x0002)) { + tmp++; + } + sns = (char **)malloc(tmp*sizeof(char*)); + tmp = 0; + for (list=gc->permit; list; list=list->next) + if (!aim_ssi_inlist(sess, fr->conn, list->data, 0x0002)) { + debug_printf("ssi: adding permit %s from local list to server list\n", list->data); + sns[tmp] = list->data; + tmp++; + } + if (tmp) { + aim_ssi_addpermits(sess, fr->conn, sns, tmp); + free(sns); + } + } + + /* Deny list */ + if (gc->deny) { + GSList *list; + tmp = 0; + for (list=gc->deny; list; list=list->next) + if (!aim_ssi_inlist(sess, fr->conn, list->data, 0x0003)) { + tmp++; + } + sns = (char **)malloc(tmp*sizeof(char*)); + tmp = 0; + for (list=gc->deny; list; list=list->next) + if (!aim_ssi_inlist(sess, fr->conn, list->data, 0x0003)) { + debug_printf("ssi: adding deny %s from local list to server list\n", list->data); + sns[tmp] = list->data; + tmp++; + } + if (tmp) { + aim_ssi_adddenies(sess, fr->conn, sns, tmp); + free(sns); + } + } + } + + return 1; } static GList *oscar_chat_info(struct gaim_connection *gc) { @@ -2908,11 +3151,14 @@ static void oscar_set_permit_deny(struct gaim_connection *gc) { struct oscar_data *od = (struct oscar_data *)gc->proto_data; - GSList *list; +/* GSList *list; char buf[MAXMSGLEN]; - int at; - - switch(gc->permdeny) { + int at; */ + + if (od->sess->ssi.received_data) + aim_ssi_setpermdeny(od->sess, od->conn, gc->permdeny); + +/* switch(gc->permdeny) { case 1: aim_bos_changevisibility(od->sess, od->conn, AIM_VISIBILITYCHANGE_DENYADD, gc->username); break; @@ -2940,27 +3186,43 @@ default: break; } - signoff_blocked(gc); + signoff_blocked(gc); */ } static void oscar_add_permit(struct gaim_connection *gc, char *who) { - if (gc->permdeny != 3) return; - oscar_set_permit_deny(gc); + struct oscar_data *od = (struct oscar_data *)gc->proto_data; + debug_printf("ssi: About to add a permit\n"); + if (od->sess->ssi.received_data) + aim_ssi_addpermits(od->sess, od->conn, &who, 1); +/* if (gc->permdeny != 3) return; + oscar_set_permit_deny(gc); */ } static void oscar_add_deny(struct gaim_connection *gc, char *who) { - if (gc->permdeny != 4) return; - oscar_set_permit_deny(gc); + struct oscar_data *od = (struct oscar_data *)gc->proto_data; + debug_printf("ssi: About to add a deny\n"); + if (od->sess->ssi.received_data) + aim_ssi_adddenies(od->sess, od->conn, &who, 1); +/* if (gc->permdeny != 4) return; + oscar_set_permit_deny(gc); */ } static void oscar_rem_permit(struct gaim_connection *gc, char *who) { - if (gc->permdeny != 3) return; - oscar_set_permit_deny(gc); + struct oscar_data *od = (struct oscar_data *)gc->proto_data; + debug_printf("ssi: About to delete a permit\n"); + if (od->sess->ssi.received_data) + aim_ssi_delpermits(od->sess, od->conn, &who, 1); +/* if (gc->permdeny != 3) return; + oscar_set_permit_deny(gc); */ } static void oscar_rem_deny(struct gaim_connection *gc, char *who) { - if (gc->permdeny != 4) return; - oscar_set_permit_deny(gc); + struct oscar_data *od = (struct oscar_data *)gc->proto_data; + debug_printf("ssi: About to delete a deny\n"); + if (od->sess->ssi.received_data) + aim_ssi_deldenies(od->sess, od->conn, &who, 1); +/* if (gc->permdeny != 4) return; + oscar_set_permit_deny(gc); */ } static GList *oscar_away_states(struct gaim_connection *gc) @@ -3114,6 +3376,7 @@ ret->add_buddy = oscar_add_buddy; ret->add_buddies = oscar_add_buddies; ret->remove_buddy = oscar_remove_buddy; + ret->remove_buddies = oscar_remove_buddies; ret->add_permit = oscar_add_permit; ret->add_deny = oscar_add_deny; ret->rem_permit = oscar_rem_permit;
--- a/src/protocols/oscar/ssi.c Tue Feb 26 23:06:53 2002 +0000 +++ b/src/protocols/oscar/ssi.c Sat Mar 02 01:36:01 2002 +0000 @@ -6,6 +6,12 @@ * to be stored on the server, so that they can be accessed from any client. * * This is entirely too complicated. + * You don't know the half of it. + * + * XXX - Make sure moving buddies from group to group moves the buddy in the server list also + * XXX - Test for memory leaks + * XXX - Write a c plugin to manage ssi data + * XXX - Better parsing of rights, and use the rights info to limit adds * */ @@ -13,6 +19,899 @@ #include <aim.h> /* + * Checks if the given screen name is anywhere in our buddy list. + */ +faim_export int aim_ssi_inlist(aim_session_t *sess, aim_conn_t *conn, char *name, fu16_t type) +{ + struct aim_ssi_item *cur; + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->type==type) && (cur->name) && (!aim_sncmp(cur->name, name))) + return 1; + return 0; +} + +/* + * Returns the permit/deny byte + * Should should be removed and the byte should be passed directly to + * the handler + */ +faim_export int aim_ssi_getpermdeny(aim_tlvlist_t *tlvlist) +{ + aim_tlv_t *tlv; + if ((tlv = aim_gettlv(tlvlist, 0x00ca, 1)) && tlv->value) + return tlv->value[0]; + return 0; +} + +/* + * Returns a pointer to an item with the given name and type, or NULL if one does not exist. + */ +static struct aim_ssi_item *get_ssi_item(struct aim_ssi_item *items, char *name, fu16_t type) +{ + struct aim_ssi_item *cur; + if (name) { + for (cur=items; cur; cur=cur->next) + if ((cur->type == type) && (cur->name) && !(aim_sncmp(cur->name, name))) + return cur; + } else { /* they probably want the master group */ + for (cur=items; cur; cur=cur->next) + if ((cur->type == type) && (cur->gid == 0x0000)) + return cur; + } + return NULL; +} + +/* + * Add the given packet to the holding queue. + */ +static int aim_ssi_enqueue(aim_session_t *sess, aim_conn_t *conn, aim_frame_t *fr) +{ + aim_frame_t *cur; + + if (!sess || !conn || !fr) + return -EINVAL; + + fr->next = NULL; + if (sess->ssi.holding_queue == NULL) { + sess->ssi.holding_queue = fr; + if (!sess->ssi.waiting_for_ack) + aim_ssi_modbegin(sess, conn); + } else { + for (cur = sess->ssi.holding_queue; cur->next; cur = cur->next) ; + cur->next = fr; + } + + return 0; +} + +/* + * Send the next SNAC from the holding queue. + */ +static int aim_ssi_dispatch(aim_session_t *sess, aim_conn_t *conn) +{ + aim_frame_t *cur; + + if (!sess || !conn) + return -EINVAL; + + if (!sess->ssi.waiting_for_ack) { + if (sess->ssi.holding_queue) { + sess->ssi.waiting_for_ack = 1; + cur = sess->ssi.holding_queue->next; + sess->ssi.holding_queue->next = NULL; + aim_tx_enqueue(sess, sess->ssi.holding_queue); + sess->ssi.holding_queue = cur; + } else + aim_ssi_modend(sess, conn); + } + + return 0; +} + +/* + * Rebuild the additional data for the given group(s). + */ +static int aim_ssi_rebuildgroup(aim_session_t *sess, aim_conn_t *conn, struct aim_ssi_item *parentgroup) +{ + int newlen; + struct aim_ssi_item *cur; + + if (!sess || !conn || !parentgroup) + return -EINVAL; + + /* Free the old additional data */ + if (parentgroup->data) { + aim_freetlvchain((aim_tlvlist_t **)&parentgroup->data); + parentgroup->data = NULL; + } + + /* Find the length for the new additional data */ + newlen = 0; + if (parentgroup->gid == 0x0000) { + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->gid != 0x0000) && (cur->type == 0x0001)) + newlen += 2; + } else { + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->gid == parentgroup->gid) && (cur->type == 0x0000)) + newlen += 2; + } + + /* Rebuild the additional data */ + if (newlen>0) { + aim_bstream_t tbs; + tbs.len = newlen+4; + tbs.offset = 0; + if (!(tbs.data = (fu8_t *)malloc((tbs.len)*sizeof(fu8_t)))) + return -ENOMEM; + aimbs_put16(&tbs, 0x00c8); + aimbs_put16(&tbs, tbs.len-4); + if (parentgroup->gid == 0x0000) { + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->gid != 0x0000) && (cur->type == 0x0001)) + aimbs_put16(&tbs, cur->gid); + } else { + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->gid == parentgroup->gid) && (cur->type == 0x0000)) + aimbs_put16(&tbs, cur->bid); + } + tbs.offset = 0; + parentgroup->data = (void *)aim_readtlvchain(&tbs); + free(tbs.data); + +/* XXX - WHYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYY does this crash? + fu8_t *newdata; + if (!(newdata = (fu8_t *)malloc((newlen)*sizeof(fu8_t)))) + return -ENOMEM; + newlen = 0; + if (parentgroup->gid == 0x0000) { + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->gid != 0x0000) && (cur->type == 0x0001)) { + memcpy(&newdata[newlen*2], &cur->gid, 2); + newlen += 2; + } + } else { + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->gid == parentgroup->gid) && (cur->type == 0x0000)) { + memcpy(newdata+newlen*2, &cur->bid, 2); + newlen += 2; + } + } + aim_addtlvtochain_raw((aim_tlvlist_t **)&parentgroup->data, 0x00c8, newlen, newdata); + free(newdata); */ + } + + return 0; +} + +/* + * Clears all of our locally stored buddy list information. + */ +static int aim_ssi_freelist(aim_session_t *sess) +{ + struct aim_ssi_item *cur, *delitem; + + cur = sess->ssi.items; + while (cur) { + if (cur->name) free(cur->name); + if (cur->data) aim_freetlvchain((aim_tlvlist_t **)&cur->data); + delitem = cur; + cur = cur->next; + free(delitem); + } + + sess->ssi.revision = 0; + sess->ssi.items = NULL; + sess->ssi.timestamp = (time_t)0; + + return 0; +} + +/* + * This removes all ssi data from server and local copy. + */ +faim_export int aim_ssi_deletelist(aim_session_t *sess, aim_conn_t *conn) +{ + int i, num; + struct aim_ssi_item *cur, **items; + + for (cur=sess->ssi.items, num=0; cur; cur=cur->next) + num++; + + if (!(items = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)))) + return -ENOMEM; + bzero(items, num*sizeof(struct aim_ssi_item *)); + for (cur=sess->ssi.items, num=0; cur; cur=cur->next) { + items[num] = cur; + num++; + } + + aim_ssi_delitems(sess, conn, items, num); + free(items[num]); + aim_ssi_dispatch(sess, conn); + aim_ssi_freelist(sess); + + return 0; +} + +/* + * This "cleans" the ssi list. It makes sure all buddies are in a group, and + * all groups have additional data for the buddies that are in them. It does + * this by rebuilding the additional data for every group, sending mod SNACs + * as necessary. + */ +faim_export int aim_ssi_cleanlist(aim_session_t *sess, aim_conn_t *conn) +{ + unsigned int num_to_be_fixed; + struct aim_ssi_item *cur, *parentgroup; + + /* Make sure we actually need to clean out the list */ + for (cur=sess->ssi.items, num_to_be_fixed=0; cur; cur=cur->next) { + /* Any buddies directly in the master group */ + if ((cur->type == 0x0000) && (cur->gid == 0x0000)) + num_to_be_fixed++; + } + if (!num_to_be_fixed) + return 0; + + /* Remove all the additional data from all groups and buddies */ + for (cur=sess->ssi.items; cur; cur=cur->next) + if (cur->data && ((cur->type == 0x0000) || (cur->type == 0x0001))) { + aim_freetlvchain((aim_tlvlist_t **)&cur->data); + cur->data = NULL; + } + + /* If there are buddies directly in the master group, make sure */ + /* there is a group to put them in. Any group, any group at all. */ + for (cur=sess->ssi.items; ((cur) && ((cur->type != 0x0000) || (cur->gid != 0x0000))); cur=cur->next); + if (!cur) { + for (parentgroup=sess->ssi.items; ((parentgroup) && ((parentgroup->type!=0x0001) || (parentgroup->gid!=0x0000))); parentgroup=parentgroup->next); + if (!parentgroup) { + char *newgroup; + newgroup = (char*)malloc(strlen("Unknown")*sizeof(char)); + strcpy(newgroup, "Unknown"); + aim_ssi_addgroups(sess, conn, &newgroup, 1); + } + } + + /* Set parentgroup equal to any arbitray group */ + for (parentgroup=sess->ssi.items; parentgroup->gid==0x0000 || parentgroup->type!=0x0001; parentgroup=parentgroup->next); + + /* If there are any buddies directly in the master group, put them in a real group */ + for (cur=sess->ssi.items; cur; cur=cur->next) + if ((cur->type == 0x0000) && (cur->gid == 0x0000)) { + aim_ssi_delitems(sess, conn, &cur, 1); + cur->gid = parentgroup->gid; + aim_ssi_additems(sess, conn, &cur, 1); + } + + /* Rebuild additional data for all groups */ + for (parentgroup=sess->ssi.items; parentgroup; parentgroup=parentgroup->next) + if (parentgroup->type == 0x0001) + aim_ssi_rebuildgroup(sess, conn, parentgroup); + + /* Send a mod snac for all groups */ + for (cur=sess->ssi.items; cur; cur=cur->next) + if (cur->type == 0x0001) + aim_ssi_moditems(sess, conn, &cur, 1); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +/* + * This adds the master group (the group containing all groups) if it doesn't exist. + * It's called by aim_ssi_addgroups, if your list is empty. + */ +faim_export int aim_ssi_addmastergroup(aim_session_t *sess, aim_conn_t *conn) { + struct aim_ssi_item *newitem; + + if (!sess || !conn) + return -EINVAL; + + /* Allocate an array of pointers to each of the new items */ + if (!(newitem = (struct aim_ssi_item *)malloc(sizeof(struct aim_ssi_item)))) + return -ENOMEM; + bzero(newitem, sizeof(struct aim_ssi_item)); + + /* bzero sets most of the vars to what they should be */ + newitem->type = 0x0001; + + /* Add the item to our list */ + newitem->next = sess->ssi.items; + sess->ssi.items = newitem; + + /* If there are any existing groups (technically there shouldn't be, but */ + /* just in case) then add their group ID#'s to the additional data */ + if (sess->ssi.items) + aim_ssi_rebuildgroup(sess, conn, newitem); + + /* Send the add item SNAC */ + aim_ssi_additems(sess, conn, &newitem, 1); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +/* + * The next few functions take data as screen names and groups, + * modifies the ssi item list, and calls the functions to + * add, mod, or del an item or items. + * + * These are what the client should call. The client should + * also make sure it's not adding a buddy that's already in + * the list (using aim_ssi_inlist). + */ +faim_export int aim_ssi_addbuddies(aim_session_t *sess, aim_conn_t *conn, char *gn, char **sn, unsigned int num) +{ + struct aim_ssi_item *cur, *parentgroup, **newitems; + fu16_t i, j; + + if (!sess || !conn || !gn || !sn || !num) + return -EINVAL; + + /* Look up the parent group */ + if (!(parentgroup = get_ssi_item(sess->ssi.items, gn, 0x0001))) { + aim_ssi_addgroups(sess, conn, &gn, 1); + if (!(parentgroup = get_ssi_item(sess->ssi.items, gn, 0x0001))) + return -ENOMEM; + } + + /* Allocate an array of pointers to each of the new items */ + if (!(newitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)))) + return -ENOMEM; + bzero(newitems, num*sizeof(struct aim_ssi_item *)); + + /* The following for loop iterates once per item that needs to be added. */ + /* For each i, create an item and tack it onto the newitems array */ + for (i=0; i<num; i++) { + if (!(newitems[i] = (struct aim_ssi_item *)malloc(sizeof(struct aim_ssi_item)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems); + return -ENOMEM; + } + if (!(newitems[i]->name = (char *)malloc((strlen(sn[i])+1)*sizeof(char)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems[i]); + free(newitems); + return -ENOMEM; + } + strcpy(newitems[i]->name, sn[i]); + newitems[i]->gid = parentgroup->gid; + newitems[i]->bid = i ? newitems[i-1]->bid : 0; + do { + newitems[i]->bid += 0x0001; + for (cur=sess->ssi.items, j=0; ((cur) && (!j)); cur=cur->next) + if ((cur->bid == newitems[i]->bid) && (cur->gid == newitems[i]->gid) && (cur->type == 0x0000)) + j=1; + } while (j); + newitems[i]->type = 0x0000; + newitems[i]->data = NULL; + newitems[i]->next = i ? newitems[i-1] : NULL; + } + + /* Add the items to our list */ + newitems[0]->next = sess->ssi.items; + sess->ssi.items = newitems[num-1]; + + /* Send the add item SNAC */ + aim_ssi_additems(sess, conn, newitems, num); + + /* Free the array of pointers to each of the new items */ + free(newitems); + + /* Rebuild the additional data in the parent group */ + aim_ssi_rebuildgroup(sess, conn, parentgroup); + + /* Send the mod item SNAC */ + aim_ssi_moditems(sess, conn, &parentgroup, 1); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +faim_export int aim_ssi_addgroups(aim_session_t *sess, aim_conn_t *conn, char **gn, unsigned int num) +{ + struct aim_ssi_item *cur, *parentgroup, **newitems; + fu16_t i, j; + + if (!sess || !conn || !gn || !num) + return -EINVAL; + + /* Look up the parent group */ + if (!(parentgroup = get_ssi_item(sess->ssi.items, NULL, 0x0001))) { + aim_ssi_addmastergroup(sess, conn); + if (!(parentgroup = get_ssi_item(sess->ssi.items, NULL, 0x0001))) + return -ENOMEM; + } + + /* Allocate an array of pointers to each of the new items */ + if (!(newitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)))) + return -ENOMEM; + bzero(newitems, num*sizeof(struct aim_ssi_item *)); + + /* The following for loop iterates once per item that needs to be added. */ + /* For each i, create an item and tack it onto the newitems array */ + for (i=0; i<num; i++) { + if (!(newitems[i] = (struct aim_ssi_item *)malloc(sizeof(struct aim_ssi_item)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems); + return -ENOMEM; + } + if (!(newitems[i]->name = (char *)malloc((strlen(gn[i])+1)*sizeof(char)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems[i]); + free(newitems); + return -ENOMEM; + } + strcpy(newitems[i]->name, gn[i]); + newitems[i]->gid = i ? newitems[i-1]->gid : 0; + do { + newitems[i]->gid += 0x0001; + for (cur=sess->ssi.items, j=0; ((cur) && (!j)); cur=cur->next) + if ((cur->gid == newitems[i]->gid) && (cur->type == 0x0001)) + j=1; + } while (j); + newitems[i]->bid = 0x0000; + newitems[i]->type = 0x0001; + newitems[i]->data = NULL; + newitems[i]->next = i ? newitems[i-1] : NULL; + } + + /* Add the items to our list */ + newitems[0]->next = sess->ssi.items; + sess->ssi.items = newitems[num-1]; + + /* Send the add item SNAC */ + aim_ssi_additems(sess, conn, newitems, num); + + /* Free the array of pointers to each of the new items */ + free(newitems); + + /* Rebuild the additional data in the parent group */ + aim_ssi_rebuildgroup(sess, conn, parentgroup); + + /* Send the mod item SNAC */ + aim_ssi_moditems(sess, conn, &parentgroup, 1); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +faim_export int aim_ssi_addpermits(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num) +{ + struct aim_ssi_item *cur, **newitems; + fu16_t i, j; + + if (!sess || !conn || !sn || !num) + return -EINVAL; + + /* Allocate an array of pointers to each of the new items */ + if (!(newitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)))) + return -ENOMEM; + bzero(newitems, num*sizeof(struct aim_ssi_item *)); + + /* The following for loop iterates once per item that needs to be added. */ + /* For each i, create an item and tack it onto the newitems array */ + for (i=0; i<num; i++) { + if (!(newitems[i] = (struct aim_ssi_item *)malloc(sizeof(struct aim_ssi_item)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems); + return -ENOMEM; + } + if (!(newitems[i]->name = (char *)malloc((strlen(sn[i])+1)*sizeof(char)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems[i]); + free(newitems); + return -ENOMEM; + } + strcpy(newitems[i]->name, sn[i]); + newitems[i]->gid = 0x0000; + newitems[i]->bid = i ? newitems[i-1]->bid : 0x0000; + do { + newitems[i]->bid += 0x0001; + for (cur=sess->ssi.items, j=0; ((cur) && (!j)); cur=cur->next) + if ((cur->bid == newitems[i]->bid) && ((cur->type == 0x0002) || (cur->type == 0x0003))) + j=1; + } while (j); + newitems[i]->type = 0x0002; + newitems[i]->data = NULL; + newitems[i]->next = i ? newitems[i-1] : NULL; + } + + /* Add the items to our list */ + newitems[0]->next = sess->ssi.items; + sess->ssi.items = newitems[num-1]; + + /* Send the add item SNAC */ + aim_ssi_additems(sess, conn, newitems, num); + + /* Free the array of pointers to each of the new items */ + free(newitems); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +faim_export int aim_ssi_adddenies(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num) +{ + struct aim_ssi_item *cur, **newitems; + fu16_t i, j; + + if (!sess || !conn || !sn || !num) + return -EINVAL; + + /* Allocate an array of pointers to each of the new items */ + if (!(newitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)))) + return -ENOMEM; + bzero(newitems, num*sizeof(struct aim_ssi_item *)); + + /* The following for loop iterates once per item that needs to be added. */ + /* For each i, create an item and tack it onto the newitems array */ + for (i=0; i<num; i++) { + if (!(newitems[i] = (struct aim_ssi_item *)malloc(sizeof(struct aim_ssi_item)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems); + return -ENOMEM; + } + if (!(newitems[i]->name = (char *)malloc((strlen(sn[i])+1)*sizeof(char)))) { + for (j=0; j<(i-1); j++) { + free(newitems[j]->name); + free(newitems[j]); + } + free(newitems[i]); + free(newitems); + return -ENOMEM; + } + strcpy(newitems[i]->name, sn[i]); + newitems[i]->gid = 0x0000; + newitems[i]->bid = i ? newitems[i-1]->bid : 0x0000; + do { + newitems[i]->bid += 0x0001; + for (cur=sess->ssi.items, j=0; ((cur) && (!j)); cur=cur->next) + if ((cur->bid == newitems[i]->bid) && ((cur->type == 0x0002) || (cur->type == 0x0003))) + j=1; + } while (j); + newitems[i]->type = 0x0003; + newitems[i]->data = NULL; + newitems[i]->next = i ? newitems[i-1] : NULL; + } + + /* Add the items to our list */ + newitems[0]->next = sess->ssi.items; + sess->ssi.items = newitems[num-1]; + + /* Send the add item SNAC */ + aim_ssi_additems(sess, conn, newitems, num); + + /* Free the array of pointers to each of the new items */ + free(newitems); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +faim_export int aim_ssi_delbuddies(aim_session_t *sess, aim_conn_t *conn, char *gn, char **sn, unsigned int num) +{ + struct aim_ssi_item *cur, *parentgroup, **delitems; + int i; + + if (!sess || !conn || !gn || !sn || !num) + return -EINVAL; + + /* Look up the parent group */ + if (!(parentgroup = get_ssi_item(sess->ssi.items, gn, 0x0001))) + return -EINVAL; + + /* Allocate an array of pointers to each of the items to be deleted */ + delitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)); + bzero(delitems, num*sizeof(struct aim_ssi_item *)); + + /* Make the delitems array a pointer to the aim_ssi_item structs to be deleted */ + for (i=0; i<num; i++) { + if (!(delitems[i] = get_ssi_item(sess->ssi.items, sn[i], 0x0000))) { + free(delitems); + return -EINVAL; + } + + /* Remove the delitems from the item list */ + if (sess->ssi.items == delitems[i]) { + sess->ssi.items = sess->ssi.items->next; + } else { + for (cur=sess->ssi.items; (cur->next && (cur->next!=delitems[i])); cur=cur->next); + if (cur->next) + cur->next = cur->next->next; + } + } + + /* Send the del item SNAC */ + aim_ssi_delitems(sess, conn, delitems, num); + + /* Free the items */ + for (i=0; i<num; i++) { + if (delitems[i]->name) + free(delitems[i]->name); + if (delitems[i]->data) + aim_freetlvchain((aim_tlvlist_t **)&delitems[i]->data); + free(delitems[i]); + } + free(delitems); + + /* Rebuild the additional data in the parent group */ + aim_ssi_rebuildgroup(sess, conn, parentgroup); + + /* Send the mod item SNAC */ + aim_ssi_moditems(sess, conn, &parentgroup, 1); + + /* Delete the group, but only if it's empty */ + if (!parentgroup->data) + aim_ssi_delgroups(sess, conn, &parentgroup->name, 1); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +faim_export int aim_ssi_delgroups(aim_session_t *sess, aim_conn_t *conn, char **gn, unsigned int num) { + struct aim_ssi_item *cur, *parentgroup, **delitems; + int i; + + if (!sess || !conn || !gn || !num) + return -EINVAL; + + /* Look up the parent group */ + if (!(parentgroup = get_ssi_item(sess->ssi.items, NULL, 0x0001))) + return -EINVAL; + + /* Allocate an array of pointers to each of the items to be deleted */ + delitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)); + bzero(delitems, num*sizeof(struct aim_ssi_item *)); + + /* Make the delitems array a pointer to the aim_ssi_item structs to be deleted */ + for (i=0; i<num; i++) { + if (!(delitems[i] = get_ssi_item(sess->ssi.items, gn[i], 0x0001))) { + free(delitems); + return -EINVAL; + } + + /* Remove the delitems from the item list */ + if (sess->ssi.items == delitems[i]) { + sess->ssi.items = sess->ssi.items->next; + } else { + for (cur=sess->ssi.items; (cur->next && (cur->next!=delitems[i])); cur=cur->next); + if (cur->next) + cur->next = cur->next->next; + } + } + + /* Send the del item SNAC */ + aim_ssi_delitems(sess, conn, delitems, num); + + /* Free the items */ + for (i=0; i<num; i++) { + if (delitems[i]->name) + free(delitems[i]->name); + if (delitems[i]->data) + aim_freetlvchain((aim_tlvlist_t **)&delitems[i]->data); + free(delitems[i]); + } + free(delitems); + + /* Rebuild the additional data in the parent group */ + aim_ssi_rebuildgroup(sess, conn, parentgroup); + + /* Send the mod item SNAC */ + aim_ssi_moditems(sess, conn, &parentgroup, 1); + + /* Delete the group, but only if it's empty */ + if (!parentgroup->data) + aim_ssi_delgroups(sess, conn, &parentgroup->name, 1); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +faim_export int aim_ssi_delpermits(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num) { + struct aim_ssi_item *cur, **delitems; + int i; + + if (!sess || !conn || !sn || !num) + return -EINVAL; + + /* Allocate an array of pointers to each of the items to be deleted */ + delitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)); + bzero(delitems, num*sizeof(struct aim_ssi_item *)); + + /* Make the delitems array a pointer to the aim_ssi_item structs to be deleted */ + for (i=0; i<num; i++) { + if (!(delitems[i] = get_ssi_item(sess->ssi.items, sn[i], 0x0002))) { + free(delitems); + return -EINVAL; + } + + /* Remove the delitems from the item list */ + if (sess->ssi.items == delitems[i]) { + sess->ssi.items = sess->ssi.items->next; + } else { + for (cur=sess->ssi.items; (cur->next && (cur->next!=delitems[i])); cur=cur->next); + if (cur->next) + cur->next = cur->next->next; + } + } + + /* Send the del item SNAC */ + aim_ssi_delitems(sess, conn, delitems, num); + + /* Free the items */ + for (i=0; i<num; i++) { + if (delitems[i]->name) + free(delitems[i]->name); + if (delitems[i]->data) + aim_freetlvchain((aim_tlvlist_t **)&delitems[i]->data); + free(delitems[i]); + } + free(delitems); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +faim_export int aim_ssi_deldenies(aim_session_t *sess, aim_conn_t *conn, char **sn, unsigned int num) { + struct aim_ssi_item *cur, **delitems; + int i; + + if (!sess || !conn || !sn || !num) + return -EINVAL; + + /* Allocate an array of pointers to each of the items to be deleted */ + delitems = (struct aim_ssi_item **)malloc(num*sizeof(struct aim_ssi_item *)); + bzero(delitems, num*sizeof(struct aim_ssi_item *)); + + /* Make the delitems array a pointer to the aim_ssi_item structs to be deleted */ + for (i=0; i<num; i++) { + if (!(delitems[i] = get_ssi_item(sess->ssi.items, sn[i], 0x0003))) { + free(delitems); + return -EINVAL; + } + + /* Remove the delitems from the item list */ + if (sess->ssi.items == delitems[i]) { + sess->ssi.items = sess->ssi.items->next; + } else { + for (cur=sess->ssi.items; (cur->next && (cur->next!=delitems[i])); cur=cur->next); + if (cur->next) + cur->next = cur->next->next; + } + } + + /* Send the del item SNAC */ + aim_ssi_delitems(sess, conn, delitems, num); + + /* Free the items */ + for (i=0; i<num; i++) { + if (delitems[i]->name) + free(delitems[i]->name); + if (delitems[i]->data) + aim_freetlvchain((aim_tlvlist_t **)&delitems[i]->data); + free(delitems[i]); + } + free(delitems); + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +/* + * Stores your permit/deny setting on the server, and starts using it. + * The permit/deny byte should be: + * 1 - Allow all users + * 2 - Block all users + * 3 - Allow only the users below + * 4 - Block the users below + * 5 - Allow only users on my buddy list + * To block AIM users, change the x00cb tlv from xffff to x0004 + */ +faim_export int aim_ssi_setpermdeny(aim_session_t *sess, aim_conn_t *conn, int permdeny) { + struct aim_ssi_item *cur, *tmp; + fu16_t i, j; + aim_tlv_t *tlv; + + if (!sess || !conn) + return -EINVAL; + + /* Look up the permit/deny settings item */ + for (cur=sess->ssi.items; (cur && (cur->type!=0x0004)); cur=cur->next); + + if (cur) { + /* The permit/deny item exists */ + if (cur->data && (tlv = aim_gettlv(cur->data, 0x00ca, 1))) { + /* Just change the value of the x00ca TLV */ + if (tlv->length != 1) { + tlv->length = 1; + free(tlv->value); + tlv->value = (fu8_t *)malloc(sizeof(fu8_t)); + } + memcpy(tlv->value, &permdeny, 1); + } else { + /* Need to add the x00ca TLV to the TLV chain */ + aim_addtlvtochain8((aim_tlvlist_t**)&cur->data, 0x00ca, permdeny); + } + + /* Send the mod item SNAC */ + aim_ssi_moditems(sess, conn, &cur, 1); + } else { + /* Need to add the permit/deny item */ + if (!(cur = (struct aim_ssi_item *)malloc(sizeof(struct aim_ssi_item)))) + return -ENOMEM; + cur->name = NULL; + cur->gid = 0x0000; + cur->bid = 0x007a; /* XXX - Is this number significant? */ + do { + cur->bid += 0x0001; + for (tmp=sess->ssi.items, j=0; ((tmp) && (!j)); tmp=tmp->next) + if (tmp->bid == cur->bid) + j=1; + } while (j); + cur->type = 0x0004; + cur->data = NULL; + aim_addtlvtochain8((aim_tlvlist_t**)&cur->data, 0x00ca, permdeny); + aim_addtlvtochain32((aim_tlvlist_t**)&cur->data, 0x00cb, 0xffffffff); + + /* Add the item to our list */ + cur->next = sess->ssi.items; + sess->ssi.items = cur; + + /* Send the add item SNAC */ + aim_ssi_additems(sess, conn, &cur, 1); + } + + /* Begin sending SSI SNACs */ + aim_ssi_dispatch(sess, conn); + + return 0; +} + +/* * Request SSI Rights. */ faim_export int aim_ssi_reqrights(aim_session_t *sess, aim_conn_t *conn) @@ -72,57 +971,54 @@ { int ret = 0; aim_rxcallback_t userfunc; - struct aim_ssi_item *list = NULL; + struct aim_ssi_item *cur = NULL; fu8_t fmtver; /* guess */ - fu16_t itemcount; - fu32_t stamp; + fu16_t revision; + fu32_t timestamp; - fmtver = aimbs_get8(bs); - itemcount = aimbs_get16(bs); + fmtver = aimbs_get8(bs); /* Version of ssi data. Should be 0x00 */ + revision = aimbs_get16(bs); /* # of times ssi data has been modified */ + if (revision != 0) + sess->ssi.revision = revision; + + for (cur = sess->ssi.items; cur && cur->next; cur=cur->next) ; while (aim_bstream_empty(bs) > 4) { /* last four bytes are stamp */ fu16_t namelen, tbslen; - struct aim_ssi_item *nl, *el; - if (!(nl = malloc(sizeof(struct aim_ssi_item)))) - break; - memset(nl, 0, sizeof(struct aim_ssi_item)); + if (!sess->ssi.items) { + if (!(sess->ssi.items = malloc(sizeof(struct aim_ssi_item)))) + return -ENOMEM; + cur = sess->ssi.items; + } else { + if (!(cur->next = malloc(sizeof(struct aim_ssi_item)))) + return -ENOMEM; + cur = cur->next; + } + memset(cur, 0, sizeof(struct aim_ssi_item)); if ((namelen = aimbs_get16(bs))) - nl->name = aimbs_getstr(bs, namelen); - nl->gid = aimbs_get16(bs); - nl->bid = aimbs_get16(bs); - nl->type = aimbs_get16(bs); + cur->name = aimbs_getstr(bs, namelen); + cur->gid = aimbs_get16(bs); + cur->bid = aimbs_get16(bs); + cur->type = aimbs_get16(bs); if ((tbslen = aimbs_get16(bs))) { aim_bstream_t tbs; aim_bstream_init(&tbs, bs->data + bs->offset /* XXX */, tbslen); - nl->data = (void *)aim_readtlvchain(&tbs); + cur->data = (void *)aim_readtlvchain(&tbs); aim_bstream_advance(bs, tbslen); } - - for (el = list; el && el->next; el = el->next) - ; - if (el) - el->next = nl; - else - list = nl; } - stamp = aimbs_get32(bs); + timestamp = aimbs_get32(bs); + if (timestamp != 0) + sess->ssi.timestamp = timestamp; + sess->ssi.received_data = 1; if ((userfunc = aim_callhandler(sess, rx->conn, snac->family, snac->subtype))) - ret = userfunc(sess, rx, fmtver, itemcount, stamp, list); - - while (list) { - struct aim_ssi_item *tmp; - - tmp = list->next; - aim_freetlvchain((aim_tlvlist_t **)&list->data); - free(list); - list = tmp; - } + ret = userfunc(sess, rx, fmtver, sess->ssi.revision, sess->ssi.timestamp, sess->ssi.items); return ret; } @@ -142,6 +1038,170 @@ } /* + * SSI Add Item. + * + * Adds an item to the data stored on the AIM server. An item could + * be a group, buddy, or permit or deny buddy. + * + */ +faim_export int aim_ssi_additems(aim_session_t *sess, aim_conn_t *conn, struct aim_ssi_item **items, unsigned int num) +{ + aim_frame_t *fr; + aim_snacid_t snacid; + int i, snaclen; + + if (!sess || !conn || !items || !num) + return -EINVAL; + + snaclen = 10; /* For family, subtype, flags, and SNAC ID */ + for (i=0; i<num; i++) { + snaclen += 10; /* For length, GID, BID, type, and length */ + if (items[i]->name) + snaclen += strlen(items[i]->name); + if (items[i]->data) + snaclen += aim_sizetlvchain((aim_tlvlist_t **)&items[i]->data); + } + + if (!(fr = aim_tx_new(sess, conn, AIM_FRAMETYPE_FLAP, 0x02, snaclen))) + return -ENOMEM; + + snacid = aim_cachesnac(sess, AIM_CB_FAM_SSI, AIM_CB_SSI_ADD, 0x0000, NULL, 0); + aim_putsnac(&fr->data, AIM_CB_FAM_SSI, AIM_CB_SSI_ADD, 0x0000, snacid); + + for (i=0; i<num; i++) { + aimbs_put16(&fr->data, items[i]->name ? strlen(items[i]->name) : 0); + if (items[i]->name) + aimbs_putraw(&fr->data, items[i]->name, strlen(items[i]->name)); + aimbs_put16(&fr->data, items[i]->gid); + aimbs_put16(&fr->data, items[i]->bid); + aimbs_put16(&fr->data, items[i]->type); + aimbs_put16(&fr->data, items[i]->data ? aim_sizetlvchain((aim_tlvlist_t **)&items[i]->data) : 0); + if (items[i]->data) + aim_writetlvchain(&fr->data, (aim_tlvlist_t **)&items[i]->data); + } + + aim_ssi_enqueue(sess, conn, fr); + + return 0; +} + +/* + * SSI Mod Item. + * + * Modifies an item in the data stored on the AIM server. An item could + * be a group, buddy, or permit or deny buddy. + * + */ +faim_export int aim_ssi_moditems(aim_session_t *sess, aim_conn_t *conn, struct aim_ssi_item **items, unsigned int num) +{ + aim_frame_t *fr; + aim_snacid_t snacid; + int i, snaclen; + + if (!sess || !conn || !items || !num) + return -EINVAL; + + snaclen = 10; /* For family, subtype, flags, and SNAC ID */ + for (i=0; i<num; i++) { + snaclen += 10; /* For length, GID, BID, type, and length */ + if (items[i]->name) + snaclen += strlen(items[i]->name); + if (items[i]->data) + snaclen += aim_sizetlvchain((aim_tlvlist_t **)&items[i]->data); + } + + if (!(fr = aim_tx_new(sess, conn, AIM_FRAMETYPE_FLAP, 0x02, snaclen))) + return -ENOMEM; + + snacid = aim_cachesnac(sess, AIM_CB_FAM_SSI, AIM_CB_SSI_MOD, 0x0000, NULL, 0); + aim_putsnac(&fr->data, AIM_CB_FAM_SSI, AIM_CB_SSI_MOD, 0x0000, snacid); + + for (i=0; i<num; i++) { + aimbs_put16(&fr->data, items[i]->name ? strlen(items[i]->name) : 0); + if (items[i]->name) + aimbs_putraw(&fr->data, items[i]->name, strlen(items[i]->name)); + aimbs_put16(&fr->data, items[i]->gid); + aimbs_put16(&fr->data, items[i]->bid); + aimbs_put16(&fr->data, items[i]->type); + aimbs_put16(&fr->data, items[i]->data ? aim_sizetlvchain((aim_tlvlist_t **)&items[i]->data) : 0); + if (items[i]->data) + aim_writetlvchain(&fr->data, (aim_tlvlist_t **)&items[i]->data); + } + + aim_ssi_enqueue(sess, conn, fr); + + return 0; +} + +/* + * SSI Del Item. + * + * Deletes an item from the data stored on the AIM server. An item + * could be a group, buddy, or permit or deny buddy. + * + */ +faim_export int aim_ssi_delitems(aim_session_t *sess, aim_conn_t *conn, struct aim_ssi_item **items, unsigned int num) +{ + aim_frame_t *fr; + aim_snacid_t snacid; + int i, snaclen; + + if (!sess || !conn || !items || !num) + return -EINVAL; + + snaclen = 10; /* For family, subtype, flags, and SNAC ID */ + for (i=0; i<num; i++) { + snaclen += 10; /* For length, GID, BID, type, and length */ + if (items[i]->name) + snaclen += strlen(items[i]->name); + if (items[i]->data) + snaclen += aim_sizetlvchain((aim_tlvlist_t **)&items[i]->data); + } + + if (!(fr = aim_tx_new(sess, conn, AIM_FRAMETYPE_FLAP, 0x02, snaclen))) + return -ENOMEM; + + snacid = aim_cachesnac(sess, AIM_CB_FAM_SSI, AIM_CB_SSI_DEL, 0x0000, NULL, 0); + aim_putsnac(&fr->data, AIM_CB_FAM_SSI, AIM_CB_SSI_DEL, 0x0000, snacid); + + for (i=0; i<num; i++) { + aimbs_put16(&fr->data, items[i]->name ? strlen(items[i]->name) : 0); + if (items[i]->name) + aimbs_putraw(&fr->data, items[i]->name, strlen(items[i]->name)); + aimbs_put16(&fr->data, items[i]->gid); + aimbs_put16(&fr->data, items[i]->bid); + aimbs_put16(&fr->data, items[i]->type); + aimbs_put16(&fr->data, items[i]->data ? aim_sizetlvchain((aim_tlvlist_t **)&items[i]->data) : 0); + if (items[i]->data) + aim_writetlvchain(&fr->data, (aim_tlvlist_t **)&items[i]->data); + } + + aim_ssi_enqueue(sess, conn, fr); + + return 0; +} + +/* + * SSI Add/Mod/Del Ack. + * + * Response to aim_ssi_additem(), aim_ssi_moditem(), or aim_ssi_delitem(). + * + */ +static int parseack(aim_session_t *sess, aim_module_t *mod, aim_frame_t *rx, aim_modsnac_t *snac, aim_bstream_t *bs) +{ + int ret = 0; + aim_rxcallback_t userfunc; + + sess->ssi.waiting_for_ack = 0; + aim_ssi_dispatch(sess, rx->conn); + + if ((userfunc = aim_callhandler(sess, rx->conn, snac->family, snac->subtype))) + ret = userfunc(sess, rx); + + return ret; +} + +/* * SSI Begin Data Modification. * * Tells the server you're going to start modifying data. @@ -175,6 +1235,8 @@ int ret = 0; aim_rxcallback_t userfunc; + sess->ssi.received_data = 1; + if ((userfunc = aim_callhandler(sess, rx->conn, snac->family, snac->subtype))) ret = userfunc(sess, rx); @@ -188,12 +1250,21 @@ return parserights(sess, mod, rx, snac, bs); else if (snac->subtype == 0x006) return parsedata(sess, mod, rx, snac, bs); + else if (snac->subtype == AIM_CB_SSI_SRVACK) + return parseack(sess, mod, rx, snac, bs); else if (snac->subtype == 0x00f) return parsedataunchanged(sess, mod, rx, snac, bs); return 0; } +static void ssi_shutdown(aim_session_t *sess, aim_module_t *mod) +{ + aim_ssi_freelist(sess); + + return; +} + faim_internal int ssi_modfirst(aim_session_t *sess, aim_module_t *mod) { @@ -204,8 +1275,7 @@ mod->flags = 0; strncpy(mod->name, "ssi", sizeof(mod->name)); mod->snachandler = snachandler; + mod->shutdown = ssi_shutdown; return 0; } - -