[libfaim.git] / aim_chat.c

/*
 * aim_chat.c
 *
 * Routines for the Chat service.
 *
 */

#define FAIM_INTERNAL
#include <faim/aim.h> 

faim_export char *aim_chat_getname(struct aim_conn_t *conn)
{
  if (!conn)
    return NULL;
  if (conn->type != AIM_CONN_TYPE_CHAT)
    return NULL;

  return (char *)conn->priv; /* yuck ! */
}

faim_export struct aim_conn_t *aim_chat_getconn(struct aim_session_t *sess, char *name)
{
  struct aim_conn_t *cur;
  
  faim_mutex_lock(&sess->connlistlock);
  for (cur = sess->connlist; cur; cur = cur->next) {
    if (cur->type != AIM_CONN_TYPE_CHAT)
      continue;
    if (!cur->priv) {
      printf("faim: chat: chat connection with no name! (fd = %d)\n", cur->fd);
      continue;
    }
    if (strcmp((char *)cur->priv, name) == 0)
      break;
  }
  faim_mutex_unlock(&sess->connlistlock);

  return cur;
}

faim_export int aim_chat_attachname(struct aim_conn_t *conn, char *roomname)
{
  if (!conn || !roomname)
    return -1;

  if (conn->priv)
    free(conn->priv);

  conn->priv = strdup(roomname);

  return 0;
}

faim_export unsigned long aim_chat_send_im(struct aim_session_t *sess,
					   struct aim_conn_t *conn, 
					   char *msg)
{   

  int curbyte,i;
  struct command_tx_struct *newpacket;
  struct aim_msgcookie_t *cookie;

  if (!sess || !conn || !msg)
    return 0;
  
  if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 1152)))
    return -1;

  newpacket->lock = 1; /* lock struct */

  curbyte  = 0;
  curbyte += aim_putsnac(newpacket->data+curbyte, 
			 0x000e, 0x0005, 0x0000, sess->snac_nextid);

  /* 
   * Generate a random message cookie 
   */
  for (i=0;i<8;i++)
    curbyte += aimutil_put8(newpacket->data+curbyte, (u_char) rand());

  cookie = aim_mkcookie(newpacket->data+curbyte-8, AIM_COOKIETYPE_CHAT, NULL);
  cookie->data = strdup(conn->priv); /* chat hack dependent */

  aim_cachecookie(sess, cookie);

  /*
   * metaTLV start.  -- i assume this is a metaTLV.  it could be the
   *                    channel ID though.
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0003);

  /*
   * Type 1: Unknown.  Blank.
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0001);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
  
  /*
   * Type 6: Unknown.  Blank.
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0006);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);

  /*
   * Type 5: Message block.  Contains more TLVs.
   *
   * This could include other information... We just
   * put in a message TLV however.  
   * 
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0005);
  curbyte += aimutil_put16(newpacket->data+curbyte, strlen(msg)+4);

  /*
   * SubTLV: Type 1: Message
   */
  curbyte += aim_puttlv_str(newpacket->data+curbyte, 0x0001, strlen(msg), msg);
  
  newpacket->commandlen = curbyte;

  newpacket->lock = 0;
  aim_tx_enqueue(sess, newpacket);

  return (sess->snac_nextid++);
}

/*
 * Join a room of name roomname.  This is the first
 * step to joining an already created room.  It's 
 * basically a Service Request for family 0x000e, 
 * with a little added on to specify the exchange
 * and room name.
 *
 */
faim_export unsigned long aim_chat_join(struct aim_session_t *sess,
					struct aim_conn_t *conn, 
					u_short exchange,
					const char *roomname)
{
  struct command_tx_struct *newpacket;
  int i;

  if (!sess || !conn || !roomname)
    return 0;
  
  if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 10+9+strlen(roomname)+2)))
    return -1;

  newpacket->lock = 1;
  
  i = aim_putsnac(newpacket->data, 0x0001, 0x0004, 0x0000, sess->snac_nextid);

  i+= aimutil_put16(newpacket->data+i, 0x000e);

  /* 
   * this is techinally a TLV, but we can't use normal functions
   * because we need the extraneous nulls and other weird things.
   */
  i+= aimutil_put16(newpacket->data+i, 0x0001);
  i+= aimutil_put16(newpacket->data+i, 2+1+strlen(roomname)+2);
  i+= aimutil_put16(newpacket->data+i, exchange);
  i+= aimutil_put8(newpacket->data+i, strlen(roomname));
  i+= aimutil_putstr(newpacket->data+i, roomname, strlen(roomname));
  i+= aimutil_put16(newpacket->data+i, 0x0000); /* instance? */

  /*
   * Chat hack.
   *
   * XXX: A problem occurs here if we request a channel
   *      join but it fails....pendingjoin will be nonnull
   *      even though the channel is never going to get a
   *      redirect!
   *
   */
  sess->pendingjoin = strdup(roomname);
  sess->pendingjoinexchange = exchange;

  newpacket->lock = 0;
  aim_tx_enqueue(sess, newpacket);

  aim_cachesnac(sess, 0x0001, 0x0004, 0x0000, roomname, strlen(roomname)+1);

  return sess->snac_nextid;
}

faim_internal int aim_chat_readroominfo(u_char *buf, struct aim_chat_roominfo *outinfo)
{
  int namelen = 0;
  int i = 0;

  if (!buf || !outinfo)
    return 0;

  outinfo->exchange = aimutil_get16(buf+i);
  i += 2;

  namelen = aimutil_get8(buf+i);
  i += 1;

  outinfo->name = (char *)malloc(namelen+1);
  memcpy(outinfo->name, buf+i, namelen);
  outinfo->name[namelen] = '\0';
  i += namelen;

  outinfo->instance = aimutil_get16(buf+i);
  i += 2;
  
  return i;
}


/*
 * General room information.  Lots of stuff.
 *
 * Values I know are in here but I havent attached
 * them to any of the 'Unknown's:
 *	- Language (English)
 *
 * SNAC 000e/0002
 */
faim_internal int aim_chat_parse_infoupdate(struct aim_session_t *sess,
					    struct command_rx_struct *command)
{
  struct aim_userinfo_s *userinfo = NULL;
  rxcallback_t userfunc=NULL;	
  int ret = 1, i = 0;
  int usercount = 0;
  u_char detaillevel = 0;
  char *roomname = NULL;
  struct aim_chat_roominfo roominfo;
  u_short tlvcount = 0;
  struct aim_tlvlist_t *tlvlist;
  char *roomdesc = NULL;
  unsigned short unknown_c9 = 0;
  unsigned long creationtime = 0;
  unsigned short maxmsglen = 0;
  unsigned short unknown_d2 = 0, unknown_d5 = 0;

  i = 10;
  i += aim_chat_readroominfo(command->data+i, &roominfo);
  
  detaillevel = aimutil_get8(command->data+i);
  i++;

  if (detaillevel != 0x02) {
    if (detaillevel == 0x01)
      printf("faim: chat_roomupdateinfo: detail level 1 not supported\n");
    else
      printf("faim: chat_roomupdateinfo: unknown detail level %d\n", detaillevel);
    return 1;
  }
  
  tlvcount = aimutil_get16(command->data+i);
  i += 2;

  /*
   * Everything else are TLVs.
   */ 
  tlvlist = aim_readtlvchain(command->data+i, command->commandlen-i);
  
  /*
   * TLV type 0x006a is the room name in Human Readable Form.
   */
  if (aim_gettlv(tlvlist, 0x006a, 1))
      roomname = aim_gettlv_str(tlvlist, 0x006a, 1);

  /*
   * Type 0x006f: Number of occupants.
   */
  if (aim_gettlv(tlvlist, 0x006f, 1))
    usercount = aim_gettlv16(tlvlist, 0x006f, 1);

  /*
   * Type 0x0073:  Occupant list.
   */
  if (aim_gettlv(tlvlist, 0x0073, 1)) {	
    int curoccupant = 0;
    struct aim_tlv_t *tmptlv;
    
    tmptlv = aim_gettlv(tlvlist, 0x0073, 1);

    /* Allocate enough userinfo structs for all occupants */
    userinfo = calloc(usercount, sizeof(struct aim_userinfo_s));
    
    i = 0;
    while (curoccupant < usercount)
      i += aim_extractuserinfo(tmptlv->value+i, &userinfo[curoccupant++]);
  }
  
  /* 
   * Type 0x00c9: Unknown. (2 bytes)
   */
  if (aim_gettlv(tlvlist, 0x00c9, 1))
    unknown_c9 = aim_gettlv16(tlvlist, 0x00c9, 1);
  
  /* 
   * Type 0x00ca: Creation time (4 bytes)
   */
  if (aim_gettlv(tlvlist, 0x00ca, 1))
    creationtime = aim_gettlv32(tlvlist, 0x00ca, 1);

  /* 
   * Type 0x00d1: Maximum Message Length
   */
  if (aim_gettlv(tlvlist, 0x00d1, 1))
    maxmsglen = aim_gettlv16(tlvlist, 0x00d1, 1);

  /* 
   * Type 0x00d2: Unknown. (2 bytes)
   */
  if (aim_gettlv(tlvlist, 0x00d2, 1))
    unknown_d2 = aim_gettlv16(tlvlist, 0x00d2, 1);

  /* 
   * Type 0x00d3: Room Description
   */
  if (aim_gettlv(tlvlist, 0x00d3, 1))
    roomdesc = aim_gettlv_str(tlvlist, 0x00d3, 1);

  /* 
   * Type 0x00d5: Unknown. (1 byte)
   */
  if (aim_gettlv(tlvlist, 0x00d5, 1))
    unknown_d5 = aim_gettlv8(tlvlist, 0x00d5, 1);


  if ((userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_ROOMINFOUPDATE))) {
    ret = userfunc(sess,
		   command, 
		   &roominfo,
		   roomname,
		   usercount,
		   userinfo,	
		   roomdesc,
		   unknown_c9,
		   creationtime,
		   maxmsglen,
		   unknown_d2,
		   unknown_d5);
  }	
  free(roominfo.name);
  free(userinfo);
  free(roomname);
  free(roomdesc);
  aim_freetlvchain(&tlvlist);
 
  return ret;
}

faim_internal int aim_chat_parse_joined(struct aim_session_t *sess,
					struct command_rx_struct *command)
{
  struct aim_userinfo_s *userinfo = NULL;
  rxcallback_t userfunc=NULL;	
  int i = 10, curcount = 0, ret = 1;

  while (i < command->commandlen) {
    curcount++;
    userinfo = realloc(userinfo, curcount * sizeof(struct aim_userinfo_s));
    i += aim_extractuserinfo(command->data+i, &userinfo[curcount-1]);
  }

  if ((userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_USERJOIN))) {
    ret = userfunc(sess,
		   command, 
		   curcount,
		   userinfo);
  }

  free(userinfo);

  return ret;
}	      

faim_internal int aim_chat_parse_leave(struct aim_session_t *sess,
				       struct command_rx_struct *command)
{

  struct aim_userinfo_s *userinfo = NULL;
  rxcallback_t userfunc=NULL;	
  int i = 10, curcount = 0, ret = 1;

  while (i < command->commandlen) {
    curcount++;
    userinfo = realloc(userinfo, curcount * sizeof(struct aim_userinfo_s));
    i += aim_extractuserinfo(command->data+i, &userinfo[curcount-1]);
  }

  if ((userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_USERLEAVE))) {
    ret = userfunc(sess,
		   command, 
		   curcount,
		   userinfo);
  }

  free(userinfo);

  return ret;
}	   

/*
 * We could probably include this in the normal ICBM parsing 
 * code as channel 0x0003, however, since only the start
 * would be the same, we might as well do it here.
 */
faim_internal int aim_chat_parse_incoming(struct aim_session_t *sess,
					  struct command_rx_struct *command)
{
  struct aim_userinfo_s userinfo;
  rxcallback_t userfunc=NULL;	
  int ret = 1, i = 0, z = 0;
  unsigned char cookie[8];
  int channel;
  struct aim_tlvlist_t *outerlist;
  char *msg = NULL;
  struct aim_msgcookie_t *ck;

  memset(&userinfo, 0x00, sizeof(struct aim_userinfo_s));

  i = 10; /* skip snac */

  /*
   * ICBM Cookie.  Cache it.
   */ 
  for (z=0; z<8; z++,i++)
    cookie[z] = command->data[i];

  if ((ck = aim_uncachecookie(sess, cookie, AIM_COOKIETYPE_CHAT))) {
    if (ck->data)
      free(ck->data);
    free(ck);
  }

  /*
   * Channel ID
   *
   * Channels 1 and 2 are implemented in the normal ICBM
   * parser.
   *
   * We only do channel 3 here.
   *
   */
  channel = aimutil_get16(command->data+i);
  i += 2;

  if (channel != 0x0003) {
    printf("faim: chat_incoming: unknown channel! (0x%04x)\n", channel);
    return 1;
  }

  /*
   * Start parsing TLVs right away. 
   */
  outerlist = aim_readtlvchain(command->data+i, command->commandlen-i);
  
  /*
   * Type 0x0003: Source User Information
   */
  if (aim_gettlv(outerlist, 0x0003, 1)) {
    struct aim_tlv_t *userinfotlv;
    
    userinfotlv = aim_gettlv(outerlist, 0x0003, 1);
    aim_extractuserinfo(userinfotlv->value, &userinfo);
  }

  /*
   * Type 0x0001: Unknown.
   */
  if (aim_gettlv(outerlist, 0x0001, 1))
    ;

  /*
   * Type 0x0005: Message Block.  Conains more TLVs.
   */
  if (aim_gettlv(outerlist, 0x0005, 1))
    {
      struct aim_tlvlist_t *innerlist;
      struct aim_tlv_t *msgblock;

      msgblock = aim_gettlv(outerlist, 0x0005, 1);
      innerlist = aim_readtlvchain(msgblock->value, msgblock->length);
      
      /* 
       * Type 0x0001: Message.
       */	
      if (aim_gettlv(innerlist, 0x0001, 1))
	  msg = aim_gettlv_str(innerlist, 0x0001, 1);

      aim_freetlvchain(&innerlist); 
    }

  userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_INCOMINGMSG);
  if (userfunc)
    {
      ret = userfunc(sess,
		     command, 
		     &userinfo,
		     msg);
    }
  free(msg);
  aim_freetlvchain(&outerlist);

  return ret;
}	      

faim_export unsigned long aim_chat_clientready(struct aim_session_t *sess,
					       struct aim_conn_t *conn)
{
  struct command_tx_struct *newpacket;
  int i;

  if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 0x20)))
    return -1;

  newpacket->lock = 1;

  i = aim_putsnac(newpacket->data, 0x0001, 0x0002, 0x0000, sess->snac_nextid);

  i+= aimutil_put16(newpacket->data+i, 0x000e);
  i+= aimutil_put16(newpacket->data+i, 0x0001);

  i+= aimutil_put16(newpacket->data+i, 0x0004);
  i+= aimutil_put16(newpacket->data+i, 0x0001);

  i+= aimutil_put16(newpacket->data+i, 0x0001);
  i+= aimutil_put16(newpacket->data+i, 0x0003);

  i+= aimutil_put16(newpacket->data+i, 0x0004);
  i+= aimutil_put16(newpacket->data+i, 0x0686);

  newpacket->lock = 0;
  aim_tx_enqueue(sess, newpacket);

  return (sess->snac_nextid++);
}

faim_export int aim_chat_leaveroom(struct aim_session_t *sess, char *name)
{
  struct aim_conn_t *conn;

  if ((conn = aim_chat_getconn(sess, name)))
    aim_conn_close(conn);

  if (!conn)
    return -1;
  return 0;
}

/*
 * conn must be a BOS connection!
 */
faim_export unsigned long aim_chat_invite(struct aim_session_t *sess,
					  struct aim_conn_t *conn,
					  char *sn,
					  char *msg,
					  u_short exchange,
					  char *roomname,
					  u_short instance)
{
  struct command_tx_struct *newpacket;
  int i,curbyte=0;
  struct aim_msgcookie_t *cookie;
  struct aim_invite_priv *priv;

  if (!sess || !conn || !sn || !msg || !roomname)
    return -1;

  if (conn->type != AIM_CONN_TYPE_BOS)
    return -1;

  if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 1152+strlen(sn)+strlen(roomname)+strlen(msg))))
    return -1;

  newpacket->lock = 1;

  curbyte = aim_putsnac(newpacket->data, 0x0004, 0x0006, 0x0000, sess->snac_nextid);

  /*
   * Cookie
   */
  for (i=0;i<8;i++)
    curbyte += aimutil_put8(newpacket->data+curbyte, (u_char)rand());

  /* XXX this should get uncached by the unwritten 'invite accept' handler */
  if(!(priv = calloc(sizeof(struct aim_invite_priv), 1)))
    return -1;
  priv->sn = strdup(sn);
  priv->roomname = strdup(roomname);
  priv->exchange = exchange;
  priv->instance = instance;

  if(!(cookie = aim_mkcookie(newpacket->data+curbyte-8, AIM_COOKIETYPE_INVITE, priv)))
    return -1;
  aim_cachecookie(sess, cookie);

  /*
   * Channel (2)
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0002);

  /*
   * Dest sn
   */
  curbyte += aimutil_put8(newpacket->data+curbyte, strlen(sn));
  curbyte += aimutil_putstr(newpacket->data+curbyte, sn, strlen(sn));

  /*
   * TLV t(0005)
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0005);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x28+strlen(msg)+0x04+0x03+strlen(roomname)+0x02);
  
  /* 
   * Unknown info
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x3131);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x3538);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x3446);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x4100);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x748f);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x2420);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x6287);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x11d1);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x8222);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x4445);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x5354);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
  
  /*
   * TLV t(000a) -- Unknown
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x000a);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0002);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0001);
  
  /*
   * TLV t(000f) -- Unknown
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x000f);
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
  
  /*
   * TLV t(000c) -- Invitation message
   */
  curbyte += aim_puttlv_str(newpacket->data+curbyte, 0x000c, strlen(msg), msg);

  /*
   * TLV t(2711) -- Container for room information 
   */
  curbyte += aimutil_put16(newpacket->data+curbyte, 0x2711);
  curbyte += aimutil_put16(newpacket->data+curbyte, 3+strlen(roomname)+2);
  curbyte += aimutil_put16(newpacket->data+curbyte, exchange);
  curbyte += aimutil_put8(newpacket->data+curbyte, strlen(roomname));
  curbyte += aimutil_putstr(newpacket->data+curbyte, roomname, strlen(roomname));
  curbyte += aimutil_put16(newpacket->data+curbyte, instance);

  newpacket->commandlen = curbyte;
  newpacket->lock = 0;
  aim_tx_enqueue(sess, newpacket);

  return (sess->snac_nextid++);
}
Commit	Line	Data
9de3ca7e	1	/*
	2	* aim_chat.c
	3	*
aa6efcfd	4	* Routines for the Chat service.
9de3ca7e	5	*
	6	*/
	7
37ee990e	8	#define FAIM_INTERNAL
a25832e6	9	#include <faim/aim.h>
9de3ca7e	10
78b3fb13	11	faim_export char aim_chat_getname(struct aim_conn_t conn)
0c20631f	12	{
	13	if (!conn)
	14	return NULL;
	15	if (conn->type != AIM_CONN_TYPE_CHAT)
	16	return NULL;
	17
	18	return (char )conn->priv; / yuck ! */
	19	}
	20
78b3fb13	21	faim_export struct aim_conn_t aim_chat_getconn(struct aim_session_t sess, char *name)
0c20631f	22	{
040457cc	23	struct aim_conn_t *cur;
	24
	25	faim_mutex_lock(&sess->connlistlock);
	26	for (cur = sess->connlist; cur; cur = cur->next) {
	27	if (cur->type != AIM_CONN_TYPE_CHAT)
	28	continue;
9d2a3582	29	if (!cur->priv) {
	30	printf("faim: chat: chat connection with no name! (fd = %d)\n", cur->fd);
	31	continue;
	32	}
040457cc	33	if (strcmp((char *)cur->priv, name) == 0)
	34	break;
	35	}
	36	faim_mutex_unlock(&sess->connlistlock);
0c20631f	37
040457cc	38	return cur;
0c20631f	39	}
0c20631f	40
78b3fb13	41	faim_export int aim_chat_attachname(struct aim_conn_t conn, char roomname)
0c20631f	42	{
	43	if (!conn \|\| !roomname)
	44	return -1;
	45
9d2a3582	46	if (conn->priv)
	47	free(conn->priv);
	48
	49	conn->priv = strdup(roomname);
0c20631f	50
	51	return 0;
	52	}
	53
78b3fb13	54	faim_export unsigned long aim_chat_send_im(struct aim_session_t *sess,
	55	struct aim_conn_t *conn,
	56	char *msg)
0c20631f	57	{
	58
	59	int curbyte,i;
5b79dc93	60	struct command_tx_struct *newpacket;
37ee990e	61	struct aim_msgcookie_t *cookie;
0c20631f	62
	63	if (!sess \|\| !conn \|\| !msg)
	64	return 0;
	65
b69540e3	66	if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 1152)))
5b79dc93	67	return -1;
0c20631f	68
5b79dc93	69	newpacket->lock = 1; /* lock struct */
0c20631f	70
0c20631f	71	curbyte = 0;
5b79dc93	72	curbyte += aim_putsnac(newpacket->data+curbyte,
0c20631f	73	0x000e, 0x0005, 0x0000, sess->snac_nextid);
	74
	75	/*
	76	* Generate a random message cookie
0c20631f	77	*/
0c20631f	78	for (i=0;i<8;i++)
5ac21963	79	curbyte += aimutil_put8(newpacket->data+curbyte, (u_char) rand());
0c20631f	80
37ee990e	81	cookie = aim_mkcookie(newpacket->data+curbyte-8, AIM_COOKIETYPE_CHAT, NULL);
	82	cookie->data = strdup(conn->priv); /* chat hack dependent */
	83
	84	aim_cachecookie(sess, cookie);
7392c79f	85
0c20631f	86	/*
	87	* metaTLV start. -- i assume this is a metaTLV. it could be the
	88	* channel ID though.
	89	*/
5b79dc93	90	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0003);
0c20631f	91
	92	/*
	93	* Type 1: Unknown. Blank.
	94	*/
5b79dc93	95	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0001);
5b79dc93	96	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
0c20631f	97
	98	/*
	99	* Type 6: Unknown. Blank.
	100	*/
5b79dc93	101	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0006);
5b79dc93	102	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
0c20631f	103
	104	/*
	105	* Type 5: Message block. Contains more TLVs.
	106	*
	107	* This could include other information... We just
	108	* put in a message TLV however.
	109	*
	110	*/
5b79dc93	111	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0005);
5b79dc93	112	curbyte += aimutil_put16(newpacket->data+curbyte, strlen(msg)+4);
0c20631f	113
	114	/*
	115	* SubTLV: Type 1: Message
	116	*/
5b79dc93	117	curbyte += aim_puttlv_str(newpacket->data+curbyte, 0x0001, strlen(msg), msg);
0c20631f	118
5b79dc93	119	newpacket->commandlen = curbyte;
0c20631f	120
5b79dc93	121	newpacket->lock = 0;
5b79dc93	122	aim_tx_enqueue(sess, newpacket);
0c20631f	123
	124	return (sess->snac_nextid++);
	125	}
	126
9de3ca7e	127	/*
0c20631f	128	* Join a room of name roomname. This is the first
	129	* step to joining an already created room. It's
	130	* basically a Service Request for family 0x000e,
	131	* with a little added on to specify the exchange
	132	* and room name.
9de3ca7e	133	*
9de3ca7e	134	*/
78b3fb13	135	faim_export unsigned long aim_chat_join(struct aim_session_t *sess,
	136	struct aim_conn_t *conn,
	137	u_short exchange,
	138	const char *roomname)
9de3ca7e	139	{
5b79dc93	140	struct command_tx_struct *newpacket;
0c20631f	141	int i;
	142
	143	if (!sess \|\| !conn \|\| !roomname)
	144	return 0;
9de3ca7e	145
b69540e3	146	if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 10+9+strlen(roomname)+2)))
5b79dc93	147	return -1;
a25832e6	148
5b79dc93	149	newpacket->lock = 1;
9de3ca7e	150
5b79dc93	151	i = aim_putsnac(newpacket->data, 0x0001, 0x0004, 0x0000, sess->snac_nextid);
9de3ca7e	152
5b79dc93	153	i+= aimutil_put16(newpacket->data+i, 0x000e);
0c20631f	154
	155	/*
	156	* this is techinally a TLV, but we can't use normal functions
	157	* because we need the extraneous nulls and other weird things.
	158	*/
5b79dc93	159	i+= aimutil_put16(newpacket->data+i, 0x0001);
	160	i+= aimutil_put16(newpacket->data+i, 2+1+strlen(roomname)+2);
	161	i+= aimutil_put16(newpacket->data+i, exchange);
	162	i+= aimutil_put8(newpacket->data+i, strlen(roomname));
9f20a4e3	163	i+= aimutil_putstr(newpacket->data+i, roomname, strlen(roomname));
9f20a4e3	164	i+= aimutil_put16(newpacket->data+i, 0x0000); /* instance? */
9de3ca7e	165
0c20631f	166	/*
	167	* Chat hack.
	168	*
	169	* XXX: A problem occurs here if we request a channel
	170	* join but it fails....pendingjoin will be nonnull
	171	* even though the channel is never going to get a
	172	* redirect!
	173	*
	174	*/
9f20a4e3	175	sess->pendingjoin = strdup(roomname);
9f20a4e3	176	sess->pendingjoinexchange = exchange;
0c20631f	177
5b79dc93	178	newpacket->lock = 0;
5b79dc93	179	aim_tx_enqueue(sess, newpacket);
9de3ca7e	180
1ea867e3	181	aim_cachesnac(sess, 0x0001, 0x0004, 0x0000, roomname, strlen(roomname)+1);
9de3ca7e	182
1ea867e3	183	return sess->snac_nextid;
0c20631f	184	}
0c20631f	185
78b3fb13	186	faim_internal int aim_chat_readroominfo(u_char buf, struct aim_chat_roominfo outinfo)
0c20631f	187	{
	188	int namelen = 0;
	189	int i = 0;
	190
	191	if (!buf \|\| !outinfo)
	192	return 0;
	193
	194	outinfo->exchange = aimutil_get16(buf+i);
	195	i += 2;
	196
	197	namelen = aimutil_get8(buf+i);
	198	i += 1;
	199
	200	outinfo->name = (char *)malloc(namelen+1);
	201	memcpy(outinfo->name, buf+i, namelen);
	202	outinfo->name[namelen] = '\0';
	203	i += namelen;
	204
	205	outinfo->instance = aimutil_get16(buf+i);
	206	i += 2;
	207
	208	return i;
78b3fb13	209	}
0c20631f	210
	211
	212	/*
	213	* General room information. Lots of stuff.
	214	*
	215	* Values I know are in here but I havent attached
	216	* them to any of the 'Unknown's:
	217	* - Language (English)
	218	*
aa6efcfd	219	* SNAC 000e/0002
0c20631f	220	*/
78b3fb13	221	faim_internal int aim_chat_parse_infoupdate(struct aim_session_t *sess,
78b3fb13	222	struct command_rx_struct *command)
0c20631f	223	{
f1a5efe0	224	struct aim_userinfo_s *userinfo = NULL;
0c20631f	225	rxcallback_t userfunc=NULL;
	226	int ret = 1, i = 0;
	227	int usercount = 0;
	228	u_char detaillevel = 0;
f1a5efe0	229	char *roomname = NULL;
0c20631f	230	struct aim_chat_roominfo roominfo;
	231	u_short tlvcount = 0;
	232	struct aim_tlvlist_t *tlvlist;
f1a5efe0	233	char *roomdesc = NULL;
aa6efcfd	234	unsigned short unknown_c9 = 0;
	235	unsigned long creationtime = 0;
	236	unsigned short maxmsglen = 0;
	237	unsigned short unknown_d2 = 0, unknown_d5 = 0;
0c20631f	238
	239	i = 10;
	240	i += aim_chat_readroominfo(command->data+i, &roominfo);
	241
	242	detaillevel = aimutil_get8(command->data+i);
	243	i++;
aa6efcfd	244
	245	if (detaillevel != 0x02) {
	246	if (detaillevel == 0x01)
313a06b7	247	printf("faim: chat_roomupdateinfo: detail level 1 not supported\n");
aa6efcfd	248	else
	249	printf("faim: chat_roomupdateinfo: unknown detail level %d\n", detaillevel);
	250	return 1;
	251	}
0c20631f	252
	253	tlvcount = aimutil_get16(command->data+i);
	254	i += 2;
	255
	256	/*
	257	* Everything else are TLVs.
	258	*/
	259	tlvlist = aim_readtlvchain(command->data+i, command->commandlen-i);
	260
	261	/*
	262	* TLV type 0x006a is the room name in Human Readable Form.
	263	*/
	264	if (aim_gettlv(tlvlist, 0x006a, 1))
	265	roomname = aim_gettlv_str(tlvlist, 0x006a, 1);
	266
	267	/*
	268	* Type 0x006f: Number of occupants.
	269	*/
1ea867e3	270	if (aim_gettlv(tlvlist, 0x006f, 1))
1ea867e3	271	usercount = aim_gettlv16(tlvlist, 0x006f, 1);
0c20631f	272
	273	/*
	274	* Type 0x0073: Occupant list.
	275	*/
aa6efcfd	276	if (aim_gettlv(tlvlist, 0x0073, 1)) {
	277	int curoccupant = 0;
	278	struct aim_tlv_t *tmptlv;
	279
	280	tmptlv = aim_gettlv(tlvlist, 0x0073, 1);
0c20631f	281
aa6efcfd	282	/* Allocate enough userinfo structs for all occupants */
	283	userinfo = calloc(usercount, sizeof(struct aim_userinfo_s));
	284
	285	i = 0;
	286	while (curoccupant < usercount)
	287	i += aim_extractuserinfo(tmptlv->value+i, &userinfo[curoccupant++]);
	288	}
0c20631f	289
0c20631f	290	/*
aa6efcfd	291	* Type 0x00c9: Unknown. (2 bytes)
0c20631f	292	*/
1ea867e3	293	if (aim_gettlv(tlvlist, 0x00c9, 1))
1ea867e3	294	unknown_c9 = aim_gettlv16(tlvlist, 0x00c9, 1);
0c20631f	295
0c20631f	296	/*
aa6efcfd	297	* Type 0x00ca: Creation time (4 bytes)
0c20631f	298	*/
1ea867e3	299	if (aim_gettlv(tlvlist, 0x00ca, 1))
1ea867e3	300	creationtime = aim_gettlv32(tlvlist, 0x00ca, 1);
0c20631f	301
	302	/*
	303	* Type 0x00d1: Maximum Message Length
	304	*/
1ea867e3	305	if (aim_gettlv(tlvlist, 0x00d1, 1))
1ea867e3	306	maxmsglen = aim_gettlv16(tlvlist, 0x00d1, 1);
0c20631f	307
0c20631f	308	/*
aa6efcfd	309	* Type 0x00d2: Unknown. (2 bytes)
0c20631f	310	*/
1ea867e3	311	if (aim_gettlv(tlvlist, 0x00d2, 1))
1ea867e3	312	unknown_d2 = aim_gettlv16(tlvlist, 0x00d2, 1);
0c20631f	313
	314	/*
	315	* Type 0x00d3: Room Description
	316	*/
	317	if (aim_gettlv(tlvlist, 0x00d3, 1))
	318	roomdesc = aim_gettlv_str(tlvlist, 0x00d3, 1);
	319
	320	/*
aa6efcfd	321	* Type 0x00d5: Unknown. (1 byte)
0c20631f	322	*/
1ea867e3	323	if (aim_gettlv(tlvlist, 0x00d5, 1))
1ea867e3	324	unknown_d5 = aim_gettlv8(tlvlist, 0x00d5, 1);
0c20631f	325
0c20631f	326
1ea867e3	327	if ((userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_ROOMINFOUPDATE))) {
aa6efcfd	328	ret = userfunc(sess,
	329	command,
	330	&roominfo,
	331	roomname,
	332	usercount,
	333	userinfo,
	334	roomdesc,
	335	unknown_c9,
	336	creationtime,
	337	maxmsglen,
	338	unknown_d2,
	339	unknown_d5);
	340	}
0c20631f	341	free(roominfo.name);
	342	free(userinfo);
	343	free(roomname);
	344	free(roomdesc);
	345	aim_freetlvchain(&tlvlist);
	346
	347	return ret;
	348	}
	349
78b3fb13	350	faim_internal int aim_chat_parse_joined(struct aim_session_t *sess,
78b3fb13	351	struct command_rx_struct *command)
0c20631f	352	{
	353	struct aim_userinfo_s *userinfo = NULL;
	354	rxcallback_t userfunc=NULL;
	355	int i = 10, curcount = 0, ret = 1;
	356
aa6efcfd	357	while (i < command->commandlen) {
	358	curcount++;
	359	userinfo = realloc(userinfo, curcount * sizeof(struct aim_userinfo_s));
	360	i += aim_extractuserinfo(command->data+i, &userinfo[curcount-1]);
	361	}
0c20631f	362
1ea867e3	363	if ((userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_USERJOIN))) {
aa6efcfd	364	ret = userfunc(sess,
	365	command,
	366	curcount,
	367	userinfo);
	368	}
0c20631f	369
	370	free(userinfo);
	371
	372	return ret;
	373	}
	374
78b3fb13	375	faim_internal int aim_chat_parse_leave(struct aim_session_t *sess,
78b3fb13	376	struct command_rx_struct *command)
0c20631f	377	{
	378
	379	struct aim_userinfo_s *userinfo = NULL;
	380	rxcallback_t userfunc=NULL;
	381	int i = 10, curcount = 0, ret = 1;
	382
aa6efcfd	383	while (i < command->commandlen) {
	384	curcount++;
	385	userinfo = realloc(userinfo, curcount * sizeof(struct aim_userinfo_s));
	386	i += aim_extractuserinfo(command->data+i, &userinfo[curcount-1]);
	387	}
0c20631f	388
1ea867e3	389	if ((userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_USERLEAVE))) {
aa6efcfd	390	ret = userfunc(sess,
	391	command,
	392	curcount,
	393	userinfo);
	394	}
0c20631f	395
	396	free(userinfo);
	397
	398	return ret;
	399	}
	400
	401	/*
	402	* We could probably include this in the normal ICBM parsing
	403	* code as channel 0x0003, however, since only the start
	404	* would be the same, we might as well do it here.
	405	*/
78b3fb13	406	faim_internal int aim_chat_parse_incoming(struct aim_session_t *sess,
78b3fb13	407	struct command_rx_struct *command)
0c20631f	408	{
	409	struct aim_userinfo_s userinfo;
	410	rxcallback_t userfunc=NULL;
	411	int ret = 1, i = 0, z = 0;
fd0b7da6	412	unsigned char cookie[8];
0c20631f	413	int channel;
	414	struct aim_tlvlist_t *outerlist;
	415	char *msg = NULL;
fd0b7da6	416	struct aim_msgcookie_t *ck;
0c20631f	417
	418	memset(&userinfo, 0x00, sizeof(struct aim_userinfo_s));
	419
	420	i = 10; /* skip snac */
	421
	422	/*
7392c79f	423	* ICBM Cookie. Cache it.
0c20631f	424	*/
	425	for (z=0; z<8; z++,i++)
	426	cookie[z] = command->data[i];
	427
fd0b7da6	428	if ((ck = aim_uncachecookie(sess, cookie, AIM_COOKIETYPE_CHAT))) {
	429	if (ck->data)
	430	free(ck->data);
	431	free(ck);
	432	}
7392c79f	433
0c20631f	434	/*
	435	* Channel ID
	436	*
	437	* Channels 1 and 2 are implemented in the normal ICBM
	438	* parser.
	439	*
	440	* We only do channel 3 here.
	441	*
	442	*/
	443	channel = aimutil_get16(command->data+i);
	444	i += 2;
	445
aa6efcfd	446	if (channel != 0x0003) {
	447	printf("faim: chat_incoming: unknown channel! (0x%04x)\n", channel);
	448	return 1;
	449	}
0c20631f	450
	451	/*
	452	* Start parsing TLVs right away.
	453	*/
	454	outerlist = aim_readtlvchain(command->data+i, command->commandlen-i);
	455
	456	/*
	457	* Type 0x0003: Source User Information
	458	*/
aa6efcfd	459	if (aim_gettlv(outerlist, 0x0003, 1)) {
	460	struct aim_tlv_t *userinfotlv;
	461
	462	userinfotlv = aim_gettlv(outerlist, 0x0003, 1);
	463	aim_extractuserinfo(userinfotlv->value, &userinfo);
	464	}
0c20631f	465
	466	/*
	467	* Type 0x0001: Unknown.
	468	*/
	469	if (aim_gettlv(outerlist, 0x0001, 1))
	470	;
	471
	472	/*
	473	* Type 0x0005: Message Block. Conains more TLVs.
	474	*/
	475	if (aim_gettlv(outerlist, 0x0005, 1))
	476	{
	477	struct aim_tlvlist_t *innerlist;
	478	struct aim_tlv_t *msgblock;
	479
	480	msgblock = aim_gettlv(outerlist, 0x0005, 1);
	481	innerlist = aim_readtlvchain(msgblock->value, msgblock->length);
	482
	483	/*
	484	* Type 0x0001: Message.
	485	*/
	486	if (aim_gettlv(innerlist, 0x0001, 1))
	487	msg = aim_gettlv_str(innerlist, 0x0001, 1);
	488
	489	aim_freetlvchain(&innerlist);
	490	}
	491
	492	userfunc = aim_callhandler(command->conn, AIM_CB_FAM_CHT, AIM_CB_CHT_INCOMINGMSG);
	493	if (userfunc)
	494	{
	495	ret = userfunc(sess,
	496	command,
	497	&userinfo,
	498	msg);
	499	}
	500	free(msg);
	501	aim_freetlvchain(&outerlist);
	502
	503	return ret;
	504	}
	505
78b3fb13	506	faim_export unsigned long aim_chat_clientready(struct aim_session_t *sess,
78b3fb13	507	struct aim_conn_t *conn)
0c20631f	508	{
5b79dc93	509	struct command_tx_struct *newpacket;
0c20631f	510	int i;
0c20631f	511
b69540e3	512	if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 0x20)))
5b79dc93	513	return -1;
	514
	515	newpacket->lock = 1;
0c20631f	516
5b79dc93	517	i = aim_putsnac(newpacket->data, 0x0001, 0x0002, 0x0000, sess->snac_nextid);
0c20631f	518
5b79dc93	519	i+= aimutil_put16(newpacket->data+i, 0x000e);
5b79dc93	520	i+= aimutil_put16(newpacket->data+i, 0x0001);
0c20631f	521
5b79dc93	522	i+= aimutil_put16(newpacket->data+i, 0x0004);
5b79dc93	523	i+= aimutil_put16(newpacket->data+i, 0x0001);
0c20631f	524
5b79dc93	525	i+= aimutil_put16(newpacket->data+i, 0x0001);
5b79dc93	526	i+= aimutil_put16(newpacket->data+i, 0x0003);
0c20631f	527
5b79dc93	528	i+= aimutil_put16(newpacket->data+i, 0x0004);
5b79dc93	529	i+= aimutil_put16(newpacket->data+i, 0x0686);
0c20631f	530
5b79dc93	531	newpacket->lock = 0;
5b79dc93	532	aim_tx_enqueue(sess, newpacket);
0c20631f	533
	534	return (sess->snac_nextid++);
	535	}
	536
78b3fb13	537	faim_export int aim_chat_leaveroom(struct aim_session_t sess, char name)
0c20631f	538	{
040457cc	539	struct aim_conn_t *conn;
0c20631f	540
040457cc	541	if ((conn = aim_chat_getconn(sess, name)))
9d2a3582	542	aim_conn_close(conn);
040457cc	543
	544	if (!conn)
	545	return -1;
	546	return 0;
0c20631f	547	}
	548
	549	/*
	550	* conn must be a BOS connection!
	551	*/
78b3fb13	552	faim_export unsigned long aim_chat_invite(struct aim_session_t *sess,
	553	struct aim_conn_t *conn,
	554	char *sn,
	555	char *msg,
	556	u_short exchange,
	557	char *roomname,
	558	u_short instance)
0c20631f	559	{
5b79dc93	560	struct command_tx_struct *newpacket;
0c20631f	561	int i,curbyte=0;
37ee990e	562	struct aim_msgcookie_t *cookie;
37ee990e	563	struct aim_invite_priv *priv;
0c20631f	564
0c20631f	565	if (!sess \|\| !conn \|\| !sn \|\| !msg \|\| !roomname)
9d2a3582	566	return -1;
	567
	568	if (conn->type != AIM_CONN_TYPE_BOS)
	569	return -1;
0c20631f	570
b69540e3	571	if (!(newpacket = aim_tx_new(AIM_FRAMETYPE_OSCAR, 0x0002, conn, 1152+strlen(sn)+strlen(roomname)+strlen(msg))))
5b79dc93	572	return -1;
	573
	574	newpacket->lock = 1;
0c20631f	575
5b79dc93	576	curbyte = aim_putsnac(newpacket->data, 0x0004, 0x0006, 0x0000, sess->snac_nextid);
0c20631f	577
	578	/*
	579	* Cookie
	580	*/
	581	for (i=0;i<8;i++)
5b79dc93	582	curbyte += aimutil_put8(newpacket->data+curbyte, (u_char)rand());
fd0b7da6	583
fd0b7da6	584	/* XXX this should get uncached by the unwritten 'invite accept' handler */
37ee990e	585	if(!(priv = calloc(sizeof(struct aim_invite_priv), 1)))
	586	return -1;
	587	priv->sn = strdup(sn);
	588	priv->roomname = strdup(roomname);
	589	priv->exchange = exchange;
	590	priv->instance = instance;
	591
	592	if(!(cookie = aim_mkcookie(newpacket->data+curbyte-8, AIM_COOKIETYPE_INVITE, priv)))
	593	return -1;
	594	aim_cachecookie(sess, cookie);
0c20631f	595
	596	/*
	597	* Channel (2)
	598	*/
5b79dc93	599	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0002);
0c20631f	600
	601	/*
	602	* Dest sn
	603	*/
5b79dc93	604	curbyte += aimutil_put8(newpacket->data+curbyte, strlen(sn));
5b79dc93	605	curbyte += aimutil_putstr(newpacket->data+curbyte, sn, strlen(sn));
0c20631f	606
	607	/*
	608	* TLV t(0005)
	609	*/
5b79dc93	610	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0005);
5b79dc93	611	curbyte += aimutil_put16(newpacket->data+curbyte, 0x28+strlen(msg)+0x04+0x03+strlen(roomname)+0x02);
0c20631f	612
	613	/*
	614	* Unknown info
	615	*/
5b79dc93	616	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
	617	curbyte += aimutil_put16(newpacket->data+curbyte, 0x3131);
	618	curbyte += aimutil_put16(newpacket->data+curbyte, 0x3538);
	619	curbyte += aimutil_put16(newpacket->data+curbyte, 0x3446);
	620	curbyte += aimutil_put16(newpacket->data+curbyte, 0x4100);
	621	curbyte += aimutil_put16(newpacket->data+curbyte, 0x748f);
	622	curbyte += aimutil_put16(newpacket->data+curbyte, 0x2420);
	623	curbyte += aimutil_put16(newpacket->data+curbyte, 0x6287);
	624	curbyte += aimutil_put16(newpacket->data+curbyte, 0x11d1);
	625	curbyte += aimutil_put16(newpacket->data+curbyte, 0x8222);
	626	curbyte += aimutil_put16(newpacket->data+curbyte, 0x4445);
	627	curbyte += aimutil_put16(newpacket->data+curbyte, 0x5354);
	628	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
0c20631f	629
	630	/*
	631	* TLV t(000a) -- Unknown
	632	*/
5b79dc93	633	curbyte += aimutil_put16(newpacket->data+curbyte, 0x000a);
	634	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0002);
	635	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0001);
0c20631f	636
	637	/*
	638	* TLV t(000f) -- Unknown
	639	*/
5b79dc93	640	curbyte += aimutil_put16(newpacket->data+curbyte, 0x000f);
5b79dc93	641	curbyte += aimutil_put16(newpacket->data+curbyte, 0x0000);
0c20631f	642
	643	/*
	644	* TLV t(000c) -- Invitation message
	645	*/
5b79dc93	646	curbyte += aim_puttlv_str(newpacket->data+curbyte, 0x000c, strlen(msg), msg);
0c20631f	647
	648	/*
	649	* TLV t(2711) -- Container for room information
	650	*/
5b79dc93	651	curbyte += aimutil_put16(newpacket->data+curbyte, 0x2711);
	652	curbyte += aimutil_put16(newpacket->data+curbyte, 3+strlen(roomname)+2);
	653	curbyte += aimutil_put16(newpacket->data+curbyte, exchange);
	654	curbyte += aimutil_put8(newpacket->data+curbyte, strlen(roomname));
	655	curbyte += aimutil_putstr(newpacket->data+curbyte, roomname, strlen(roomname));
	656	curbyte += aimutil_put16(newpacket->data+curbyte, instance);
	657
	658	newpacket->commandlen = curbyte;
	659	newpacket->lock = 0;
	660	aim_tx_enqueue(sess, newpacket);
0c20631f	661
a25832e6	662	return (sess->snac_nextid++);
9de3ca7e	663	}