/*  The oSIP library implements the Session Initiation Protocol (SIP -rfc3261-)  Copyright (C) 2001,2002,2003  Aymeric MOIZARD jack@atosc.org    This library is free software; you can redistribute it and/or  modify it under the terms of the GNU Lesser General Public  License as published by the Free Software Foundation; either  version 2.1 of the License, or (at your option) any later version.    This library is distributed in the hope that it will be useful,  but WITHOUT ANY WARRANTY; without even the implied warranty of  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU  Lesser General Public License for more details.    You should have received a copy of the GNU Lesser General Public  License along with this library; if not, write to the Free Software  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA*/#include <stdio.h>#include <stdlib.h>#include <osipparser2/osip_port.h>#include <osipparser2/osip_message.h>#include "parser.h"intosip_body_init (osip_body_t ** body){  *body = (osip_body_t *) osip_malloc (sizeof (osip_body_t));  if (*body == NULL)    return -1;  (*body)->body = NULL;  (*body)->content_type = NULL;  (*body)->headers = (osip_list_t *) osip_malloc (sizeof (osip_list_t));  if ((*body)->headers == NULL)    {      osip_free (*body);      *body = NULL;      return -1;    }  osip_list_init ((*body)->headers);  return 0;}/* fill the body of message.                              *//* INPUT : char *buf | pointer to the start of body.      *//* OUTPUT: osip_message_t *sip | structure to save results.        *//* returns -1 on error. */intosip_message_set_body (osip_message_t * sip, const char *buf){  osip_body_t *body;  int i;  i = osip_body_init (&body);  if (i != 0)    return -1;  i = osip_body_parse (body, buf);  if (i != 0)    {      osip_body_free (body);      return -1;    }#ifdef USE_TMP_BUFFER  sip->message_property = 2;#endif  osip_list_add (sip->bodies, body, -1);  return 0;}intosip_body_clone (const osip_body_t * body, osip_body_t ** dest){  int pos;  int i;  osip_body_t *copy;  if (body == NULL)    return -1;  i = osip_body_init (&copy);  if (i != 0)    return -1;  copy->body = osip_strdup (body->body);  if (body->content_type != NULL)    {      i = osip_content_type_clone (body->content_type, &(copy->content_type));      if (i != 0)	goto bc_error1;    }  {    osip_header_t *header;    osip_header_t *header2;    pos = 0;    while (!osip_list_eol (body->headers, pos))      {	header = (osip_header_t *) osip_list_get (body->headers, pos);	i = osip_header_clone (header, &header2);	if (i != 0)	  goto bc_error1;	osip_list_add (copy->headers, header2, -1);	/* insert as last element */	pos++;      }  }  *dest = copy;  return 0;bc_error1:  osip_body_free (copy);  return -1;}/* returns the pos of body header.                   *//* INPUT : int pos | pos of body header.             *//* INPUT : osip_message_t *sip | sip message.                 *//* OUTPUT: osip_body_t *body | structure to save results. *//* returns -1 on error. */intosip_message_get_body (const osip_message_t * sip, int pos, osip_body_t ** dest){  osip_body_t *body;  *dest = NULL;  if (osip_list_size (sip->bodies) <= pos)    return -1;			/* does not exist */  body = (osip_body_t *) osip_list_get (sip->bodies, pos);  *dest = body;  return pos;}intosip_body_set_contenttype (osip_body_t * body, const char *hvalue){  int i;  if (body == NULL)    return -1;  if (hvalue == NULL)    return -1;  i = osip_content_type_init (&(body->content_type));  if (i != 0)    return -1;  i = osip_content_type_parse (body->content_type, hvalue);  if (i != 0)    {      osip_content_type_free (body->content_type);      body->content_type = NULL;      return -1;    }  return 0;}intosip_body_set_header (osip_body_t * body, const char *hname, const char *hvalue){  osip_header_t *h;  int i;  if (body == NULL)    return -1;  if (hname == NULL)    return -1;  if (hvalue == NULL)    return -1;  i = osip_header_init (&h);  if (i != 0)    return -1;  h->hname = osip_strdup (hname);  h->hvalue = osip_strdup (hvalue);  osip_list_add (body->headers, h, -1);  return 0;}/* fill the body of message.                              *//* INPUT : char *buf | pointer to the start of body.      *//* OUTPUT: osip_message_t *sip | structure to save results.        *//* returns -1 on error. */intosip_message_set_body_mime (osip_message_t * sip, const char *buf){  osip_body_t *body;  int i;  i = osip_body_init (&body);  if (i != 0)    return -1;  i = osip_body_parse_mime (body, buf);  if (i != 0)    {      osip_body_free (body);      return -1;    }#ifdef USE_TMP_BUFFER  sip->message_property = 2;#endif  osip_list_add (sip->bodies, body, -1);  return 0;}intosip_body_parse_header (osip_body_t * body, const char *start_of_osip_body_header,		   const char **next_body){  const char *start_of_line;  const char *end_of_line;  const char *colon_index;  char *hname;  char *hvalue;  int i;  *next_body = NULL;  start_of_line = start_of_osip_body_header;  for (;;)    {      i = __osip_find_next_crlf (start_of_line, &end_of_line);      if (i == -1)	return -1;		/* error case: no end of body found */      /* find the headere name */      colon_index = strchr (start_of_line, ':');      if (colon_index == NULL)	return -1;		/* this is also an error case */      if (colon_index - start_of_line + 1 < 2)	return -1;      hname = (char *) osip_malloc (colon_index - start_of_line + 1);      if (hname == NULL)	return -1;      osip_strncpy (hname, start_of_line, colon_index - start_of_line);      osip_clrspace (hname);      if ((end_of_line - 2) - colon_index < 2)	return -1;      hvalue = (char *) osip_malloc ((end_of_line - 2) - colon_index);      if (hvalue == NULL)	{	  osip_free (hname);	  return -1;	}      osip_strncpy (hvalue, colon_index + 1, (end_of_line - 2) - colon_index - 1);      osip_clrspace (hvalue);      /* really store the header in the sip structure */      /* i = osip_message_set__header(sip, hname, hvalue); */      if (strncmp (hname, "content-type", 12) == 0)	i = osip_body_set_contenttype (body, hvalue);      else	i = osip_body_set_header (body, hname, hvalue);      osip_free (hname);      osip_free (hvalue);      if (i == -1)	return -1;      if (strncmp (end_of_line, CRLF, 2) == 0	  || strncmp (end_of_line, "\n", 1) == 0	  || strncmp (end_of_line, "\r", 1) == 0)	{	  *next_body = end_of_line;	  return 0;	}      start_of_line = end_of_line;    }}intosip_body_parse (osip_body_t * body, const char *start_of_body){  int i;  if (body == NULL)    return -1;  if (start_of_body == NULL)    return -1;  if (body->headers == NULL)    return -1;  /*  i = __osip_find_next_crlfcrlf(start_of_body, &end_of_body);     if (i==-1) return -1;      body->body = (char *)osip_malloc(end_of_body-start_of_body+1);     osip_strncpy(body->body, start_of_body, end_of_body-start_of_body);   */  i = strlen (start_of_body);  body->body = (char *) osip_malloc (i + 1);  if (body->body == NULL)    return -1;  osip_strncpy (body->body, start_of_body, i);  return 0;}intosip_body_parse_mime (osip_body_t * body, const char *start_of_body){  const char *end_of_osip_body_header;  const char *start_of_osip_body_header;  int i;  if (body == NULL)    return -1;  if (start_of_body == NULL)    return -1;  if (body->headers == NULL)    return -1;  start_of_osip_body_header = start_of_body;  i = osip_body_parse_header (body, start_of_osip_body_header, &end_of_osip_body_header);  if (i == -1)    return -1;  start_of_osip_body_header = end_of_osip_body_header;  /* set the real start of body */  if (strncmp (start_of_osip_body_header, CRLF, 2) == 0)    start_of_osip_body_header = start_of_osip_body_header + 2;  else    {      if ((strncmp (start_of_osip_body_header, "\n", 1) == 0)	  || (strncmp (start_of_osip_body_header, "\r", 1) == 0))	start_of_osip_body_header = start_of_osip_body_header + 1;      else	return -1;		/* message does not end with CRLFCRLF, CRCR or LFLF */    }  end_of_osip_body_header = end_of_osip_body_header + strlen (end_of_osip_body_header);  body->body =    (char *) osip_malloc (end_of_osip_body_header - start_of_osip_body_header + 1);  if (body->body == NULL)    return -1;  osip_strncpy (body->body, start_of_osip_body_header,	    end_of_osip_body_header - start_of_osip_body_header);  return 0;}/* returns the body as a string.          *//* INPUT : osip_body_t *body | body.  *//* returns null on error. */intosip_body_to_str (const osip_body_t * body, char **dest){  char *tmp_body;  char *tmp;  char *ptr;  int pos;  int i;  unsigned length;  *dest = NULL;  if (body == NULL)    return -1;  if (body->body == NULL)    return -1;  if (body->headers == NULL)    return -1;  length = strlen (body->body) + (osip_list_size (body->headers) * 40);  tmp_body = (char *) osip_malloc (length);  if (tmp_body == NULL)    return -1;  ptr = tmp_body;		/* save the initial address of the string */  if (body->content_type != NULL)    {      osip_strncpy (tmp_body, "content-type: ", 14);      tmp_body = tmp_body + strlen (tmp_body);      i = osip_content_type_to_str (body->content_type, &tmp);      if (i == -1)	{	  osip_free (ptr);	  return -1;	}      if (length < tmp_body - ptr + strlen (tmp) + 4)	{	  int len;	  len = tmp_body - ptr;	  length = length + strlen (tmp) + 4;	  ptr = realloc (ptr, length);	  tmp_body = ptr + len;	}      osip_strncpy (tmp_body, tmp, strlen (tmp));      osip_free (tmp);      tmp_body = tmp_body + strlen (tmp_body);      osip_strncpy (tmp_body, CRLF, 2);      tmp_body = tmp_body + 2;    }  pos = 0;  while (!osip_list_eol (body->headers, pos))    {      osip_header_t *header;      header = (osip_header_t *) osip_list_get (body->headers, pos);      i = osip_header_to_str (header, &tmp);      if (i == -1)	{	  osip_free (ptr);	  return -1;	}      if (length < tmp_body - ptr + strlen (tmp) + 4)	{	  int len;	  len = tmp_body - ptr;	  length = length + strlen (tmp) + 4;	  ptr = realloc (ptr, length);	  tmp_body = ptr + len;	}      osip_strncpy (tmp_body, tmp, strlen (tmp));      osip_free (tmp);      tmp_body = tmp_body + strlen (tmp_body);      osip_strncpy (tmp_body, CRLF, 2);      tmp_body = tmp_body + 2;      pos++;    }  if ((osip_list_size (body->headers) > 0) || (body->content_type != NULL))    {      osip_strncpy (tmp_body, CRLF, 2);      tmp_body = tmp_body + 2;    }  if (length < tmp_body - ptr + strlen (body->body) + 4)    {      int len;      len = tmp_body - ptr;      length = length + strlen (body->body) + 4;      ptr = realloc (ptr, length);      tmp_body = ptr + len;    }  osip_strncpy (tmp_body, body->body, strlen (body->body));  tmp_body = tmp_body + strlen (body->body);  /* end of this body */  *dest = ptr;  return 0;}/* deallocates a body structure.  *//* INPUT : osip_body_t *body | body.  */voidosip_body_free (osip_body_t * body){  if (body == NULL)    return;  osip_free (body->body);  if (body->content_type != NULL)    {      osip_content_type_free (body->content_type);    }  {    osip_header_t *header;    while (!osip_list_eol (body->headers, 0))      {	header = (osip_header_t *) osip_list_get (body->headers, 0);	osip_list_remove (body->headers, 0);	osip_header_free (header);      }    osip_free (body->headers);  }  osip_free (body);}