diff options
Diffstat (limited to 'email-common-use/email-utilities.c')
| -rwxr-xr-x | email-common-use/email-utilities.c | 1722 |
1 files changed, 1079 insertions, 643 deletions
diff --git a/email-common-use/email-utilities.c b/email-common-use/email-utilities.c index 5cebaf9..d5ba501 100755 --- a/email-common-use/email-utilities.c +++ b/email-common-use/email-utilities.c @@ -1,643 +1,1079 @@ -/*
-* email-service
-*
-* Copyright (c) 2000 - 2011 Samsung Electronics Co., Ltd. All rights reserved.
-*
-* Contact: Kyuho Jo <kyuho.jo@samsung.com>, Sunghyun Kwon <sh0701.kwon@samsung.com>
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
-
-/*
- * email-utilities.c
- *
- * Created on: 2012. 3. 6.
- * Author: kyuho.jo@samsung.com
- */
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <ctype.h>
-#include <errno.h>
-#include <sys/time.h>
-#include <sys/vfs.h>
-#include <unistd.h>
-#include <malloc.h>
-#include <pthread.h>
-#include <regex.h>
-
-#include "c-client.h"
-
-#include "email-types.h"
-#include "email-internal-types.h"
-#include "email-utilities.h"
-
-INTERNAL_FUNC void* em_malloc(unsigned len)
-{
- /* EM_DEBUG_LOG("Memory allocation size[%d] bytes", len); */
- void *p = NULL;
-
- if (len <= 0) {
- EM_DEBUG_EXCEPTION("len should be positive.[%d]", len);
- return NULL;
- }
-
- p = malloc(len);
-
- if (p)
- memset(p, 0x00, len);
- else
- EM_DEBUG_EXCEPTION("malloc failed");
- return p;
-}
-
-/* remove left space, tab, CR, L */
-INTERNAL_FUNC char *em_trim_left(char *str)
-{
- char *p, *temp_buffer = NULL;
-
- /* EM_DEBUG_FUNC_BEGIN() */
- if (!str) return NULL;
-
- p = str;
- while (*p && (*p == ' ' || *p == '\t' || *p == LF || *p == CR)) p++;
-
- if (!*p) return NULL;
-
- temp_buffer = EM_SAFE_STRDUP(p);
-
- strncpy(str, temp_buffer, strlen(str));
- str[strlen(temp_buffer)] = NULL_CHAR;
-
- EM_SAFE_FREE(temp_buffer);
-
- return str;
-}
-
-/* remove right space, tab, CR, L */
-INTERNAL_FUNC char *em_trim_right(char *str)
-{
- char *p;
-
- /* EM_DEBUG_FUNC_BEGIN() */
- if (!str) return NULL;
-
- p = str+strlen(str)-1;
- while (((int)p >= (int)str) && (*p == ' ' || *p == '\t' || *p == LF || *p == CR))
- *p --= '\0';
-
- if ((int) p < (int)str)
- return NULL;
-
- return str;
-}
-
-INTERNAL_FUNC char* em_upper_string(char *str)
-{
- char *p = str;
- while (*p) {
- *p = toupper(*p);
- p++;
- }
- return str;
-}
-
-INTERNAL_FUNC char* em_lower_string(char *str)
-{
- char *p = str;
- while (*p) {
- *p = tolower(*p);
- p++;
- }
- return str;
-}
-
-INTERNAL_FUNC int em_upper_path(char *path)
-{
- int i = 0, is_utf7 = 0, len = path ? (int)strlen(path) : -1;
- for (; i < len; i++) {
- if (path[i] == '&' || path[i] == 5) {
- is_utf7 = 1;
- }
- else {
- if (is_utf7) {
- if (path[i] == '-') is_utf7 = 0;
- }
- else {
- path[i] = toupper(path[i]);
- }
- }
- }
-
- return 1;
-}
-
-INTERNAL_FUNC void em_skip_whitespace(char *addr_str, char **pAddr)
-{
- EM_DEBUG_FUNC_BEGIN("addr_str[%p]", addr_str);
-
- if (!addr_str)
- return ;
- char *str = addr_str;
- char ptr[strlen(str)+1] ;
- int i, j = 0;
-
- str = addr_str ;
- for (i = 0; str[i] != NULL_CHAR ; i++) {
- if (str[i] != SPACE && str[i] != TAB && str[i] != CR && str[i] != LF)
- ptr[j++] = str[i];
- }
- ptr[j] = NULL_CHAR;
-
- *pAddr = EM_SAFE_STRDUP(ptr);
- EM_DEBUG_FUNC_END("ptr[%s]", ptr);
-}
-
-INTERNAL_FUNC char* em_skip_whitespace_without_strdup(char *source_string)
-{
- EM_DEBUG_FUNC_BEGIN("source_string[%p]", source_string);
-
- if (!source_string)
- return NULL;
- int i;
-
- for (i = 0; source_string[i] != NULL_CHAR ; i++) {
- if (source_string[i] != SPACE) /* || source_string[i] != TAB || source_string[i] != CR || source_string[i] || LF) */
- break;
- }
-
- EM_DEBUG_FUNC_END("i[%d]", i);
- return source_string + i;
-}
-
-INTERNAL_FUNC char* em_replace_string(char *source_string, char *old_string, char *new_string)
-{
- EM_DEBUG_FUNC_BEGIN();
- char *result_buffer = NULL;
- char *p = NULL;
- int buffer_length = 0;
-
- EM_IF_NULL_RETURN_VALUE(source_string, NULL);
- EM_IF_NULL_RETURN_VALUE(old_string, NULL);
- EM_IF_NULL_RETURN_VALUE(new_string, NULL);
-
- p = strstr(source_string, old_string);
-
- if (p == NULL) {
- EM_DEBUG_EXCEPTION("old_string not found in source_string");
- EM_DEBUG_FUNC_END("return NULL");
- return NULL;
- }
-
- buffer_length = strlen(source_string) + 1024;
- result_buffer = (char *)em_malloc(buffer_length);
-
- if (!result_buffer) {
- EM_DEBUG_EXCEPTION("em_malloc failed");
- return NULL;
- }
-
- strncpy(result_buffer, source_string, p - source_string);
- snprintf(result_buffer + strlen(result_buffer), buffer_length - strlen(result_buffer), "%s%s", new_string, p + strlen(old_string));
-
- EM_DEBUG_FUNC_END("result_buffer[%s]", result_buffer);
- return result_buffer;
-}
-
-/* Memory clean up */
-#include <sys/mman.h>
-
-/* #define GETSP() ({ unsigned int sp; asm volatile ("mov %0, sp " : "=r"(sp)); sp;}) */
-#define BUF_SIZE 256
-#define PAGE_SIZE (1 << 12)
-#define _ALIGN_UP(addr, size) (((addr)+((size)-1))&(~((size)-1)))
-#define _ALIGN_DOWN(addr, size) ((addr)&(~((size)-1)))
-#define PAGE_ALIGN(addr) _ALIGN_DOWN(addr, PAGE_SIZE)
-
-int stack_trim(void)
-{
- /*
- char buf[BUF_SIZE];
- FILE *file;
- unsigned int stacktop;
- int found = 0;
- unsigned int sp;
-
- asm volatile ("mov %0, sp " : "=r"(sp));
-
- sprintf(buf, "/proc/%d/maps", getpid());
- file = fopen(buf, "r");
- while (fgets(buf, BUF_SIZE, file) != NULL) {
- if (strstr(buf, "[stack]")) {
- found = 1;
- break;
- }
- }
-
- fclose(file);
-
- if (found) {
- sscanf(buf, "%x-", &stacktop);
- if (madvise((void *)PAGE_ALIGN(stacktop), PAGE_ALIGN(sp)-stacktop, MADV_DONTNEED) < 0)
- perror("stack madvise fail");
- }
- */
- return 1;
-}
-
-INTERNAL_FUNC void em_flush_memory()
-{
- EM_DEBUG_FUNC_BEGIN();
- /* flush memory in heap */
- malloc_trim(0);
-
- /* flush memory in stack */
- stack_trim();
-
- /* flush memory for sqlite */
- emstorage_flush_db_cache();
- EM_DEBUG_FUNC_END();
-}
-
-#define DATE_TIME_STRING_LEGNTH 14
-
-INTERNAL_FUNC char *em_get_extension_from_file_path(char *source_file_path, int *err_code)
-{
- EM_DEBUG_FUNC_BEGIN("source_file_path[%s]", source_file_path);
- int err = EMF_ERROR_NONE, pos_on_string = 0;
- char *extension = NULL;
-
- if (!source_file_path) {
- EM_DEBUG_EXCEPTION("Invalid Parameter");
- err = EMF_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- pos_on_string = strlen(source_file_path) - 1;
-
- while(pos_on_string > 0 && source_file_path[pos_on_string--] != '.') ;
-
- if(pos_on_string > 0)
- extension = source_file_path + pos_on_string + 2;
-
- EM_DEBUG_LOG("*extension [%s] pos_on_string [%d]", extension, pos_on_string);
-
-FINISH_OFF:
- if (err_code)
- *err_code = err;
- EM_DEBUG_FUNC_END();
- return extension;
-}
-
-INTERNAL_FUNC int em_get_encoding_type_from_file_path(const char *input_file_path, char **output_encoding_type)
-{
- EM_DEBUG_FUNC_BEGIN("input_file_path[%d], output_encoding_type[%p]", input_file_path, output_encoding_type);
- int err = EMF_ERROR_NONE;
- int pos_of_filename = 0;
- int pos_of_dot = 0;
- int enf_of_string = 0;
- int result_string_length = 0;
- char *filename = NULL;
- char *result_encoding_type = NULL;
-
- if (!input_file_path || !output_encoding_type) {
- EM_DEBUG_EXCEPTION("Invalid Parameter");
- err = EMF_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- enf_of_string = pos_of_filename = strlen(input_file_path) - 1;
-
- while(pos_of_filename >= 0 && input_file_path[pos_of_filename--] != '/') {
- if(input_file_path[pos_of_filename] == '.')
- pos_of_dot = pos_of_filename;
- }
-
- if(pos_of_filename != 0)
- pos_of_filename += 2;
-
- filename = (char*)input_file_path + pos_of_filename;
-
- if(pos_of_dot != 0 && pos_of_dot > pos_of_filename)
- result_string_length = pos_of_dot - pos_of_filename;
- else
- result_string_length = enf_of_string - pos_of_filename;
-
- EM_DEBUG_LOG("pos_of_dot [%d], pos_of_filename [%d], enf_of_string[%d],result_string_length [%d]", pos_of_dot, pos_of_filename, enf_of_string, result_string_length);
-
- if( !(result_encoding_type = em_malloc(sizeof(char) * (result_string_length + 1))) ) {
- EM_DEBUG_EXCEPTION("EMF_ERROR_OUT_OF_MEMORY");
- err = EMF_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
-
- memcpy(result_encoding_type, input_file_path + pos_of_filename, result_string_length);
-
- EM_DEBUG_LOG("*result_encoding_type [%s]", result_encoding_type);
-
- *output_encoding_type = result_encoding_type;
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int em_get_content_type_from_extension_string(const char *extension_string, int *err_code)
-{
- EM_DEBUG_FUNC_BEGIN("extension_string[%s]", extension_string);
- int i = 0, err = EMF_ERROR_NONE, result_content_type = TYPEAPPLICATION;
- char *image_extension[] = { "jpeg", "jpg", "png", "gif", "bmp", "pic", "agif", "tif", "wbmp" , NULL};
-
- if (!extension_string) {
- EM_DEBUG_EXCEPTION("Invalid Parameter");
- err = EMF_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- while(image_extension[i]) {
- EM_DEBUG_LOG("image_extension[%d] [%s]", i, image_extension[i]);
- if(strcasecmp(image_extension[i], extension_string) == 0) {
- result_content_type = TYPEIMAGE;
- break;
- }
- i++;
- }
-
-FINISH_OFF:
- if (err_code)
- *err_code = err;
- EM_DEBUG_FUNC_END();
- return result_content_type;
-}
-
-#define EMAIL_ACCOUNT_RGEX "([a-z0-9!#$%&'*+/=?^_`{|}~-]+.)*[a-z0-9!#$%&'*+/=?^_`{|}~-]+"
-#define EMAIL_DOMAIN_RGEX "([a-z0-9!#$%&'*+/=?^_`{|}~-]+.)+[a-z0-9!#$%&'*+/=?^_`{|}~-]+"
-
-#define EMAIL_ADDR_RGEX "[[:space:]]*<"EMAIL_ACCOUNT_RGEX"@"EMAIL_DOMAIN_RGEX">[[:space:]]*"
-#define EMAIL_ALIAS_RGEX "([[:space:]]*\"[^\"]*\")?"EMAIL_ADDR_RGEX
-#define EMAIL_ALIAS_LIST_RGEX "^("EMAIL_ALIAS_RGEX"[;,])*"EMAIL_ALIAS_RGEX"[;,]?[[:space:]]*$"
-
-#define EMAIL_ADDR_WITHOUT_BRACKET_RGEX "[[:space:]]*"EMAIL_ACCOUNT_RGEX"@"EMAIL_DOMAIN_RGEX"[[:space:]]*"
-#define EMAIL_ALIAS_WITHOUT_BRACKET_RGEX "([[:space:]]*\"[^\"]*\")?"EMAIL_ADDR_WITHOUT_BRACKET_RGEX
-#define EMAIL_ALIAS_LIST_WITHOUT_BRACKET_RGEX "("EMAIL_ALIAS_WITHOUT_BRACKET_RGEX"[;,])*"EMAIL_ADDR_WITHOUT_BRACKET_RGEX"[;,]?[[:space:]]*$"
-
-INTERNAL_FUNC int em_verify_email_address(char *address, int without_bracket, int *err_code)
-{
- EM_DEBUG_FUNC_BEGIN("address[%s] without_bracket[%d]", address, without_bracket);
-
- /* this following code verfies the email alias string using reg. exp. */
- regex_t alias_list_regex = {0};
- int ret = false, error = EMF_ERROR_NONE;
- char *reg_rule = NULL;
-
- if(!address || strlen(address) == 0) {
- EM_DEBUG_EXCEPTION("EMF_ERROR_INVALID_PARAM");
- if (err_code)
- *err_code = EMF_ERROR_INVALID_PARAM;
- return false;
- }
-
- if(without_bracket)
- reg_rule = EMAIL_ALIAS_LIST_WITHOUT_BRACKET_RGEX;
- else
- reg_rule = EMAIL_ALIAS_LIST_RGEX;
-
- if (regcomp(&alias_list_regex, reg_rule, REG_ICASE | REG_EXTENDED)) {
- EM_DEBUG_EXCEPTION("email alias regex unrecognized");
- if (err_code)
- *err_code = EMF_ERROR_UNKNOWN;
- return false;
- }
-
- int alias_len = strlen(address) + 1;
- regmatch_t pmatch[alias_len];
-
- bzero(pmatch, alias_len);
-
- if (regexec(&alias_list_regex, address, alias_len, pmatch, 0) == REG_NOMATCH)
- EM_DEBUG_LOG("failed :[%s]", address);
- else {
- EM_DEBUG_LOG("success :[%s]", address);
- ret = true;
- }
-
- regfree(&alias_list_regex);
-
- if (err_code)
- *err_code = error;
-
- EM_DEBUG_FUNC_END("ret [%d]", ret);
- return ret;
-}
-
-INTERNAL_FUNC int em_verify_email_address_of_mail_data(emf_mail_data_t *mail_data, int without_bracket, int *err_code)
-{
- EM_DEBUG_FUNC_BEGIN("mail_data[%p] without_bracket[%d]", mail_data, without_bracket);
- char *address_array[4] = { mail_data->full_address_from, mail_data->full_address_to, mail_data->full_address_cc, mail_data->full_address_bcc};
- int ret = false, err = EMF_ERROR_NONE, i;
-
- /* check for email_address validation */
- for (i = 0; i < 4; i++) {
- if (address_array[i] && address_array[i][0] != 0) {
- if (!em_verify_email_address(address_array[i] , without_bracket, &err)) {
- err = EMF_ERROR_INVALID_ADDRESS;
- EM_DEBUG_EXCEPTION("Invalid Email Address [%d][%s]", i, address_array[i]);
- goto FINISH_OFF;
- }
- }
- }
- ret = true;
-FINISH_OFF:
- EM_DEBUG_FUNC_END("ret [%d]", ret);
- return ret;
-}
-
-INTERNAL_FUNC int em_verify_email_address_of_mail_tbl(emstorage_mail_tbl_t *input_mail_tbl, int input_without_bracket)
-{
- EM_DEBUG_FUNC_BEGIN("input_mail_tbl[%p] input_without_bracket[%d]", input_mail_tbl, input_without_bracket);
- char *address_array[4] = { input_mail_tbl->full_address_to, input_mail_tbl->full_address_cc, input_mail_tbl->full_address_bcc, input_mail_tbl->full_address_from};
- int err = EMF_ERROR_NONE, i;
-
- /* check for email_address validation */
- for (i = 0; i < 4; i++) {
- if (address_array[i] && address_array[i][0] != 0) {
- if (!em_verify_email_address(address_array[i] , input_without_bracket, &err)) {
- err = EMF_ERROR_INVALID_ADDRESS;
- EM_DEBUG_EXCEPTION("Invalid Email Address [%d][%s]", i, address_array[i]);
- goto FINISH_OFF;
- }
- }
- }
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int em_find_tag_for_thread_view(char *subject, int *result)
-{
- EM_DEBUG_FUNC_BEGIN();
- int error_code = EMF_ERROR_NONE;
- char *copy_of_subject = NULL;
-
- EM_IF_NULL_RETURN_VALUE(subject, EMF_ERROR_INVALID_PARAM);
- EM_IF_NULL_RETURN_VALUE(result, EMF_ERROR_INVALID_PARAM);
-
- *result = FALSE;
-
- copy_of_subject = EM_SAFE_STRDUP(subject);
-
- if (copy_of_subject == NULL) {
- EM_DEBUG_EXCEPTION("strdup is failed.");
- goto FINISH_OFF;
- }
-
- em_upper_string(copy_of_subject);
- EM_DEBUG_LOG("em_upper_string result : %s\n", copy_of_subject);
-
- if (strstr(copy_of_subject, "RE:") == NULL) {
- if (strstr(copy_of_subject, "FWD:") == NULL) {
- if (strstr(copy_of_subject, "FW:") != NULL)
- *result = TRUE;
- }
- else
- *result = TRUE;
- }
- else
- *result = TRUE;
-
-FINISH_OFF:
- EM_SAFE_FREE(copy_of_subject);
-
- EM_DEBUG_FUNC_END("result : %d", *result);
-
- return error_code;
-}
-
-INTERNAL_FUNC int em_find_pos_stripped_subject_for_thread_view(char *subject, char *stripped_subject)
-{
- EM_DEBUG_FUNC_BEGIN();
- int error_code = EMF_ERROR_NONE;
- int gap;
- char *copy_of_subject = NULL, *curpos = NULL, *result;
-
- EM_IF_NULL_RETURN_VALUE(subject, EMF_ERROR_INVALID_PARAM);
- EM_IF_NULL_RETURN_VALUE(stripped_subject, EMF_ERROR_INVALID_PARAM);
-
- copy_of_subject = EM_SAFE_STRDUP(subject);
-
- if (copy_of_subject == NULL) {
- EM_DEBUG_EXCEPTION("strdup is failed");
- goto FINISH_OFF;
- }
-
- em_upper_string(copy_of_subject);
- curpos = copy_of_subject;
-
- EM_DEBUG_LOG("em_upper_string result : %s", copy_of_subject);
-
- while ((result = strstr(curpos, "RE:")) != NULL) {
- curpos = result + 3;
- EM_DEBUG_LOG("RE result : %s", curpos);
- }
-
- while ((result = strstr(curpos, "FWD:")) != NULL) {
- curpos = result + 4;
- EM_DEBUG_LOG("FWD result : %s", curpos);
- }
-
- while ((result = strstr(curpos, "FW:")) != NULL) {
- curpos = result + 3;
- EM_DEBUG_LOG("FW result : %s", curpos);
- }
-
- while (curpos != NULL && *curpos == ' ') {
- curpos++;
- }
-
- gap = curpos - copy_of_subject;
-
- strcpy(stripped_subject, subject + gap);
-
-FINISH_OFF:
- EM_SAFE_FREE(copy_of_subject);
-
- if (error_code == EMF_ERROR_NONE && stripped_subject)
- EM_DEBUG_LOG("result[%s]", stripped_subject);
-
- EM_DEBUG_FUNC_END("error_code[%d]", error_code);
- return error_code;
-}
-
-
-/*
- * encoding base64
- */
-INTERNAL_FUNC int em_encode_base64(char *src, unsigned long src_len, char **enc, unsigned long* enc_len, int *err_code)
-{
- EM_DEBUG_FUNC_BEGIN();
-
- unsigned char *content;
- int ret = true, err = EMF_ERROR_NONE;
-
- if (err_code != NULL) {
- *err_code = EMF_ERROR_NONE;
- }
-
- content = rfc822_binary(src, src_len, enc_len);
-
- if (content)
- *enc = (char *)content;
- else {
- err = EMF_ERROR_UNKNOWN;
- ret = false;
- }
-
- if (err_code)
- *err_code = err;
-
- EM_DEBUG_FUNC_END();
- return ret;
-}
-
-/*
- * decoding base64
- */
-INTERNAL_FUNC int em_decode_base64(unsigned char *enc_text, unsigned long enc_len, char **dec_text, unsigned long* dec_len, int *err_code)
-{
- unsigned char *text = enc_text;
- unsigned long size = enc_len;
- unsigned char *content;
- int ret = true, err = EMF_ERROR_NONE;
-
- if (err_code != NULL) {
- *err_code = EMF_ERROR_NONE;
- }
-
- EM_DEBUG_FUNC_BEGIN();
-
- content = rfc822_base64(text, size, dec_len);
- if (content)
- *dec_text = (char *)content;
- else
- {
- err = EMF_ERROR_UNKNOWN;
- ret = false;
- }
-
- if (err_code)
- *err_code = err;
-
- return ret;
-}
+/* +* email-service +* +* Copyright (c) 2000 - 2011 Samsung Electronics Co., Ltd. All rights reserved. +* +* Contact: Kyuho Jo <kyuho.jo@samsung.com>, Sunghyun Kwon <sh0701.kwon@samsung.com> +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +* +*/ + +/* + * email-utilities.c + * + * Created on: 2012. 3. 6. + * Author: kyuho.jo@samsung.com + */ +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <ctype.h> +#include <errno.h> +#include <sys/time.h> +#include <sys/vfs.h> +#include <unistd.h> +#include <malloc.h> +#include <pthread.h> +#include <regex.h> + +#include "c-client.h" + +#include "email-types.h" +#include "email-internal-types.h" +#include "email-utilities.h" + +INTERNAL_FUNC void* em_malloc(int len) +{ + /* EM_DEBUG_LOG("Memory allocation size[%d] bytes", len); */ + if (len <= 0) { + EM_DEBUG_EXCEPTION("len should be positive.[%d]", len); + return NULL; + } + + void *p = calloc(1,len); + if (!p) + EM_DEBUG_PERROR("malloc failed"); + + return p; +} + + +INTERNAL_FUNC void* em_memdup(void* src, int len) +{ + /* EM_DEBUG_LOG("Memory allocation size[%d] bytes", len); */ + if (len <= 0) { + EM_DEBUG_EXCEPTION("len should be positive.[%d]", len); + return NULL; + } + + void *p = calloc(1,len); + if (!p) + EM_DEBUG_EXCEPTION("malloc failed"); + + memcpy(p, src, len); + + return p; +} + + +/* remove left space, tab, CR, L */ +INTERNAL_FUNC char *em_trim_left(char *str) +{ + char *p, *temp_buffer = NULL; + + /* EM_DEBUG_FUNC_BEGIN() */ + if (!str) return NULL; + + p = str; + while (*p && (*p == ' ' || *p == '\t' || *p == LF || *p == CR)) p++; + + if (!*p) return NULL; + + temp_buffer = EM_SAFE_STRDUP(p); + + strncpy(str, temp_buffer, strlen(str)); + str[strlen(temp_buffer)] = NULL_CHAR; + + EM_SAFE_FREE(temp_buffer); + + return str; +} + +/* remove right space, tab, CR, L */ +INTERNAL_FUNC char *em_trim_right(char *str) +{ + char *p; + + /* EM_DEBUG_FUNC_BEGIN() */ + if (!str) return NULL; + + p = str+strlen(str)-1; + while (((int)p >= (int)str) && (*p == ' ' || *p == '\t' || *p == LF || *p == CR)) + *p --= '\0'; + + if ((int) p < (int)str) + return NULL; + + return str; +} + +INTERNAL_FUNC char* em_upper_string(char *str) +{ + char *p = str; + while (*p) { + *p = toupper(*p); + p++; + } + return str; +} + +INTERNAL_FUNC char* em_lower_string(char *str) +{ + char *p = str; + while (*p) { + *p = tolower(*p); + p++; + } + return str; +} + +INTERNAL_FUNC int em_upper_path(char *path) +{ + int i = 0, is_utf7 = 0, len = path ? (int)strlen(path) : -1; + for (; i < len; i++) { + if (path[i] == '&' || path[i] == 5) { + is_utf7 = 1; + } + else { + if (is_utf7) { + if (path[i] == '-') is_utf7 = 0; + } + else { + path[i] = toupper(path[i]); + } + } + } + + return 1; +} + +INTERNAL_FUNC void em_skip_whitespace(char *addr_str, char **pAddr) +{ + EM_DEBUG_FUNC_BEGIN("addr_str[%p]", addr_str); + + if (!addr_str) + return ; + char *str = addr_str; + char ptr[strlen(str)+1] ; + int i, j = 0; + + str = addr_str ; + for (i = 0; str[i] != NULL_CHAR ; i++) { + if (str[i] != SPACE && str[i] != TAB && str[i] != CR && str[i] != LF) + ptr[j++] = str[i]; + } + ptr[j] = NULL_CHAR; + + *pAddr = EM_SAFE_STRDUP(ptr); + EM_DEBUG_FUNC_END("ptr[%s]", ptr); +} + +INTERNAL_FUNC char* em_skip_whitespace_without_strdup(char *source_string) +{ + EM_DEBUG_FUNC_BEGIN("source_string[%p]", source_string); + + if (!source_string) + return NULL; + int i; + + for (i = 0; source_string[i] != NULL_CHAR ; i++) { + if (source_string[i] != SPACE) /* || source_string[i] != TAB || source_string[i] != CR || source_string[i] || LF) */ + break; + } + + EM_DEBUG_FUNC_END("i[%d]", i); + return source_string + i; +} + + +INTERNAL_FUNC char* em_replace_all_string(char *source_string, char *old_string, char *new_string) +{ + EM_DEBUG_FUNC_BEGIN(); + char *result_buffer = NULL; + char *p = NULL; + int i = 0, count = 0; + int old_str_length = 0; + int new_str_length = 0; + + EM_IF_NULL_RETURN_VALUE(source_string, NULL); + EM_IF_NULL_RETURN_VALUE(old_string, NULL); + EM_IF_NULL_RETURN_VALUE(new_string, NULL); + + old_str_length = strlen(old_string); + new_str_length = strlen(new_string); + + if (old_str_length != new_str_length) { + for (i = 0; source_string[i] != '\0';) { + if (memcmp(&source_string[i], old_string, old_str_length) == 0) { + count++; + i += old_str_length; + } else { + i++; + } + } + } else { + i = strlen(source_string); + } + + result_buffer = (char *)malloc(i + 1 + count*(new_str_length-old_str_length)); + if (result_buffer == NULL) + return NULL; + + p = result_buffer; + while (*source_string) { + if (memcmp(source_string, old_string, old_str_length) == 0) { + memcpy(p, new_string, new_str_length); + p += new_str_length; + source_string += old_str_length; + } else { + *p++ = *source_string++; + } + } + *p = '\0'; + + EM_DEBUG_FUNC_END("result_buffer : %s", result_buffer); + return result_buffer; +} + +INTERNAL_FUNC char* em_replace_string(char *source_string, char *old_string, char *new_string) +{ + EM_DEBUG_FUNC_BEGIN(); + char *result_buffer = NULL; + char *p = NULL; + int buffer_length = 0; + + EM_IF_NULL_RETURN_VALUE(source_string, NULL); + EM_IF_NULL_RETURN_VALUE(old_string, NULL); + EM_IF_NULL_RETURN_VALUE(new_string, NULL); + + p = strstr(source_string, old_string); + + if (p == NULL) { + EM_DEBUG_EXCEPTION("old_string not found in source_string"); + EM_DEBUG_FUNC_END("return NULL"); + return NULL; + } + + buffer_length = strlen(source_string) + 1024; + result_buffer = (char *)em_malloc(buffer_length); + + if (!result_buffer) { + EM_DEBUG_EXCEPTION("em_malloc failed"); + return NULL; + } + + strncpy(result_buffer, source_string, p - source_string); + snprintf(result_buffer + strlen(result_buffer), buffer_length - strlen(result_buffer), "%s%s", new_string, p + strlen(old_string)); + + EM_DEBUG_FUNC_END("result_buffer[%s]", result_buffer); + return result_buffer; +} + +/* Memory clean up */ +#include <sys/mman.h> + +/* #define GETSP() ({ unsigned int sp; asm volatile ("mov %0, sp " : "=r"(sp)); sp;}) */ +#define BUF_SIZE 256 +#define PAGE_SIZE (1 << 12) +#define _ALIGN_UP(addr, size) (((addr)+((size)-1))&(~((size)-1))) +#define _ALIGN_DOWN(addr, size) ((addr)&(~((size)-1))) +#define PAGE_ALIGN(addr) _ALIGN_DOWN(addr, PAGE_SIZE) + +int stack_trim(void) +{ + /* + char buf[BUF_SIZE]; + FILE *file; + unsigned int stacktop; + int found = 0; + unsigned int sp; + + asm volatile ("mov %0, sp " : "=r"(sp)); + + sprintf(buf, "/proc/%d/maps", getpid()); + file = fopen(buf, "r"); + while (fgets(buf, BUF_SIZE, file) != NULL) { + if (strstr(buf, "[stack]")) { + found = 1; + break; + } + } + + fclose(file); + + if (found) { + sscanf(buf, "%x-", &stacktop); + if (madvise((void *)PAGE_ALIGN(stacktop), PAGE_ALIGN(sp)-stacktop, MADV_DONTNEED) < 0) + perror("stack madvise fail"); + } + */ + return 1; +} + +INTERNAL_FUNC void em_flush_memory() +{ + EM_DEBUG_FUNC_BEGIN(); + /* flush memory in heap */ + malloc_trim(0); + + /* flush memory in stack */ + stack_trim(); + + /* flush memory for sqlite */ + emstorage_flush_db_cache(); + EM_DEBUG_FUNC_END(); +} + +INTERNAL_FUNC int em_get_file_name_and_extension_from_file_path(char *input_source_file_path, char **output_file_name, char **output_extension) +{ + EM_DEBUG_FUNC_BEGIN("input_source_file_path[%s], output_file_name [%p], output_extension [%p]", input_source_file_path, output_file_name, output_extension); + int err = EMAIL_ERROR_NONE; + int pos_on_string = 0; + int file_name_length = 0; + int extention_length = 0; + char *start_pos_of_file_name = NULL; + char *end_pos_of_file_name = NULL; + char *dot_pos_of_file_path = NULL; + char *end_pos_of_file_path = NULL; + char file_name_string[MAX_PATH] = { 0, }; + char extension_string[MAX_PATH] = { 0, }; + + if (!input_source_file_path || !output_file_name || !output_extension) { + EM_DEBUG_EXCEPTION("Invalid Parameter"); + err = EMAIL_ERROR_INVALID_PARAM; + goto FINISH_OFF; + } + + pos_on_string = strlen(input_source_file_path) - 1; + end_pos_of_file_path = input_source_file_path + pos_on_string; + end_pos_of_file_name = end_pos_of_file_path; + + while(pos_on_string >= 0 && input_source_file_path[pos_on_string] != '/') { + if(input_source_file_path[pos_on_string] == '.') { + if(dot_pos_of_file_path == NULL) { + end_pos_of_file_name = input_source_file_path + pos_on_string; + dot_pos_of_file_path = end_pos_of_file_name; + } + } + pos_on_string--; + } + + pos_on_string++; + + if(pos_on_string >= 0) { + start_pos_of_file_name = input_source_file_path + pos_on_string; + file_name_length = end_pos_of_file_name - start_pos_of_file_name; + memcpy(file_name_string, start_pos_of_file_name, file_name_length); + } + + if(dot_pos_of_file_path != NULL) { + extention_length = (end_pos_of_file_path + 1) - (dot_pos_of_file_path + 1); + memcpy(extension_string, dot_pos_of_file_path + 1, extention_length); + } + + EM_DEBUG_LOG("*file_name_string [%s] pos_on_string [%d]", file_name_string, pos_on_string); + + *output_file_name = EM_SAFE_STRDUP(file_name_string); + *output_extension = EM_SAFE_STRDUP(extension_string); + +FINISH_OFF: + EM_DEBUG_FUNC_END("err = [%d]", err); + return err; +} + +INTERNAL_FUNC char *em_get_extension_from_file_path(char *source_file_path, int *err_code) +{ + EM_DEBUG_FUNC_BEGIN("source_file_path[%s]", source_file_path); + int err = EMAIL_ERROR_NONE, pos_on_string = 0; + char *extension = NULL; + + if (!source_file_path) { + EM_DEBUG_EXCEPTION("Invalid Parameter"); + err = EMAIL_ERROR_INVALID_PARAM; + goto FINISH_OFF; + } + + pos_on_string = strlen(source_file_path) - 1; + + while(pos_on_string > 0 && source_file_path[pos_on_string--] != '.') ; + + if(pos_on_string > 0) + extension = source_file_path + pos_on_string + 2; + + EM_DEBUG_LOG("*extension [%s] pos_on_string [%d]", extension, pos_on_string); + +FINISH_OFF: + if (err_code) + *err_code = err; + EM_DEBUG_FUNC_END(); + return extension; +} + +INTERNAL_FUNC int em_get_encoding_type_from_file_path(const char *input_file_path, char **output_encoding_type) +{ + EM_DEBUG_FUNC_BEGIN("input_file_path[%d], output_encoding_type[%p]", input_file_path, output_encoding_type); + int err = EMAIL_ERROR_NONE; + int pos_of_filename = 0; + int pos_of_dot = 0; + int enf_of_string = 0; + int result_string_length = 0; + char *filename = NULL; + char *result_encoding_type = NULL; + + if (!input_file_path || !output_encoding_type) { + EM_DEBUG_EXCEPTION("Invalid Parameter"); + err = EMAIL_ERROR_INVALID_PARAM; + goto FINISH_OFF; + } + + enf_of_string = pos_of_filename = strlen(input_file_path); + + while(pos_of_filename >= 0 && input_file_path[pos_of_filename--] != '/') { + if(input_file_path[pos_of_filename] == '.') + pos_of_dot = pos_of_filename; + } + + if(pos_of_filename != 0) + pos_of_filename += 2; + + filename = (char*)input_file_path + pos_of_filename; + + if(pos_of_dot != 0 && pos_of_dot > pos_of_filename) + result_string_length = pos_of_dot - pos_of_filename; + else + result_string_length = enf_of_string - pos_of_filename; + + EM_DEBUG_LOG("pos_of_dot [%d], pos_of_filename [%d], enf_of_string[%d],result_string_length [%d]", pos_of_dot, pos_of_filename, enf_of_string, result_string_length); + + if( !(result_encoding_type = em_malloc(sizeof(char) * (result_string_length + 1))) ) { + EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY"); + err = EMAIL_ERROR_OUT_OF_MEMORY; + goto FINISH_OFF; + } + + memcpy(result_encoding_type, input_file_path + pos_of_filename, result_string_length); + + EM_DEBUG_LOG("*result_encoding_type [%s]", result_encoding_type); + + *output_encoding_type = result_encoding_type; + +FINISH_OFF: + EM_DEBUG_FUNC_END("err [%d]", err); + return err; +} + +INTERNAL_FUNC int em_get_content_type_from_extension_string(const char *extension_string, int *err_code) +{ + EM_DEBUG_FUNC_BEGIN("extension_string[%s]", extension_string); + int i = 0, err = EMAIL_ERROR_NONE, result_content_type = TYPEAPPLICATION; + char *image_extension[] = { "jpeg", "jpg", "png", "gif", "bmp", "pic", "agif", "tif", "wbmp" , NULL}; + + if (!extension_string) { + EM_DEBUG_EXCEPTION("Invalid Parameter"); + err = EMAIL_ERROR_INVALID_PARAM; + goto FINISH_OFF; + } + + while(image_extension[i]) { + EM_DEBUG_LOG("image_extension[%d] [%s]", i, image_extension[i]); + if(strcasecmp(image_extension[i], extension_string) == 0) { + result_content_type = TYPEIMAGE; + break; + } + i++; + } + +FINISH_OFF: + if (err_code) + *err_code = err; + EM_DEBUG_FUNC_END(); + return result_content_type; +} + +#define EMAIL_ACCOUNT_RGEX "([a-z0-9!#$%&'*+/=?^_`{|}~-]+.)*[a-z0-9!#$%&'*+/=?^_`{|}~-]+" +#define EMAIL_DOMAIN_RGEX "([a-z0-9!#$%&'*+/=?^_`{|}~-]+.)+[a-z0-9!#$%&'*+/=?^_`{|}~-]+" + +#define EMAIL_ADDR_RGEX "[[:space:]]*<"EMAIL_ACCOUNT_RGEX"@"EMAIL_DOMAIN_RGEX">[[:space:]]*" +#define EMAIL_ALIAS_RGEX "([[:space:]]*\"[^\"]*\")?"EMAIL_ADDR_RGEX +#define EMAIL_ALIAS_LIST_RGEX "^("EMAIL_ALIAS_RGEX"[;,])*"EMAIL_ALIAS_RGEX"[;,]?[[:space:]]*$" + +#define EMAIL_ADDR_WITHOUT_BRACKET_RGEX "[[:space:]]*"EMAIL_ACCOUNT_RGEX"@"EMAIL_DOMAIN_RGEX"[[:space:]]*" +#define EMAIL_ALIAS_WITHOUT_BRACKET_RGEX "([[:space:]]*\"[^\"]*\")?"EMAIL_ADDR_WITHOUT_BRACKET_RGEX +#define EMAIL_ALIAS_LIST_WITHOUT_BRACKET_RGEX "("EMAIL_ALIAS_WITHOUT_BRACKET_RGEX"[;,])*"EMAIL_ADDR_WITHOUT_BRACKET_RGEX"[;,]?[[:space:]]*$" + +INTERNAL_FUNC int em_verify_email_address(char *address, int without_bracket, int *err_code) +{ + EM_DEBUG_FUNC_BEGIN("address[%s] without_bracket[%d]", address, without_bracket); + + /* this following code verfies the email alias string using reg. exp. */ + regex_t alias_list_regex = {0}; + int ret = false, error = EMAIL_ERROR_NONE; + char *reg_rule = NULL; + + if(!address || strlen(address) == 0) { + EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM"); + if (err_code) + *err_code = EMAIL_ERROR_INVALID_PARAM; + return false; + } + + if(without_bracket) + reg_rule = EMAIL_ALIAS_LIST_WITHOUT_BRACKET_RGEX; + else + reg_rule = EMAIL_ALIAS_LIST_RGEX; + + if (regcomp(&alias_list_regex, reg_rule, REG_ICASE | REG_EXTENDED)) { + EM_DEBUG_EXCEPTION("email alias regex unrecognized"); + if (err_code) + *err_code = EMAIL_ERROR_UNKNOWN; + return false; + } + + int alias_len = strlen(address) + 1; + regmatch_t pmatch[alias_len]; + + bzero(pmatch, alias_len); + + if (regexec(&alias_list_regex, address, alias_len, pmatch, 0) == REG_NOMATCH) + EM_DEBUG_LOG("failed :[%s]", address); + else { + EM_DEBUG_LOG("success :[%s]", address); + ret = true; + } + + regfree(&alias_list_regex); + + if (err_code) + *err_code = error; + + EM_DEBUG_FUNC_END("ret [%d]", ret); + return ret; +} + +INTERNAL_FUNC int em_verify_email_address_of_mail_data(email_mail_data_t *mail_data, int without_bracket, int *err_code) +{ + EM_DEBUG_FUNC_BEGIN("mail_data[%p] without_bracket[%d]", mail_data, without_bracket); + char *address_array[4] = { mail_data->full_address_from, mail_data->full_address_to, mail_data->full_address_cc, mail_data->full_address_bcc}; + int ret = false, err = EMAIL_ERROR_NONE, i; + + /* check for email_address validation */ + for (i = 0; i < 4; i++) { + if (address_array[i] && address_array[i][0] != 0) { + if (!em_verify_email_address(address_array[i] , without_bracket, &err)) { + err = EMAIL_ERROR_INVALID_ADDRESS; + EM_DEBUG_EXCEPTION("Invalid Email Address [%d][%s]", i, address_array[i]); + goto FINISH_OFF; + } + } + } + ret = true; +FINISH_OFF: + EM_DEBUG_FUNC_END("ret [%d]", ret); + return ret; +} + +INTERNAL_FUNC int em_verify_email_address_of_mail_tbl(emstorage_mail_tbl_t *input_mail_tbl, int input_without_bracket) +{ + EM_DEBUG_FUNC_BEGIN("input_mail_tbl[%p] input_without_bracket[%d]", input_mail_tbl, input_without_bracket); + char *address_array[4] = { input_mail_tbl->full_address_to, input_mail_tbl->full_address_cc, input_mail_tbl->full_address_bcc, input_mail_tbl->full_address_from}; + int err = EMAIL_ERROR_NONE, i; + + /* check for email_address validation */ + for (i = 0; i < 4; i++) { + if (address_array[i] && address_array[i][0] != 0) { + if (!em_verify_email_address(address_array[i] , input_without_bracket, &err)) { + err = EMAIL_ERROR_INVALID_ADDRESS; + EM_DEBUG_EXCEPTION("Invalid Email Address [%d][%s]", i, address_array[i]); + goto FINISH_OFF; + } + } + } + +FINISH_OFF: + EM_DEBUG_FUNC_END("err [%d]", err); + return err; +} + +INTERNAL_FUNC int em_find_tag_for_thread_view(char *subject, int *result) +{ + EM_DEBUG_FUNC_BEGIN(); + int error_code = EMAIL_ERROR_NONE; + char *copy_of_subject = NULL; + + EM_IF_NULL_RETURN_VALUE(subject, EMAIL_ERROR_INVALID_PARAM); + EM_IF_NULL_RETURN_VALUE(result, EMAIL_ERROR_INVALID_PARAM); + + *result = FALSE; + + copy_of_subject = EM_SAFE_STRDUP(subject); + + if (copy_of_subject == NULL) { + EM_DEBUG_EXCEPTION("strdup is failed."); + goto FINISH_OFF; + } + + em_upper_string(copy_of_subject); + EM_DEBUG_LOG("em_upper_string result : %s\n", copy_of_subject); + + if (strstr(copy_of_subject, "RE:") == NULL) { + if (strstr(copy_of_subject, "FWD:") == NULL) { + if (strstr(copy_of_subject, "FW:") != NULL) + *result = TRUE; + } + else + *result = TRUE; + } + else + *result = TRUE; + +FINISH_OFF: + EM_SAFE_FREE(copy_of_subject); + + EM_DEBUG_FUNC_END("result : %d", *result); + + return error_code; +} + +INTERNAL_FUNC int em_find_pos_stripped_subject_for_thread_view(char *subject, char *stripped_subject) +{ + EM_DEBUG_FUNC_BEGIN(); + int error_code = EMAIL_ERROR_NONE; + int gap; + char *copy_of_subject = NULL, *curpos = NULL, *result; + + EM_IF_NULL_RETURN_VALUE(subject, EMAIL_ERROR_INVALID_PARAM); + EM_IF_NULL_RETURN_VALUE(stripped_subject, EMAIL_ERROR_INVALID_PARAM); + + copy_of_subject = EM_SAFE_STRDUP(subject); + + if (copy_of_subject == NULL) { + EM_DEBUG_EXCEPTION("strdup is failed"); + goto FINISH_OFF; + } + + em_upper_string(copy_of_subject); + curpos = copy_of_subject; + + EM_DEBUG_LOG("em_upper_string result : %s", copy_of_subject); + + while ((result = strstr(curpos, "RE:")) != NULL) { + curpos = result + 3; + EM_DEBUG_LOG("RE result : %s", curpos); + } + + while ((result = strstr(curpos, "FWD:")) != NULL) { + curpos = result + 4; + EM_DEBUG_LOG("FWD result : %s", curpos); + } + + while ((result = strstr(curpos, "FW:")) != NULL) { + curpos = result + 3; + EM_DEBUG_LOG("FW result : %s", curpos); + } + + while (curpos != NULL && *curpos == ' ') { + curpos++; + } + + gap = curpos - copy_of_subject; + + strcpy(stripped_subject, subject + gap); + +FINISH_OFF: + EM_SAFE_FREE(copy_of_subject); + + if (error_code == EMAIL_ERROR_NONE && stripped_subject) + EM_DEBUG_LOG("result[%s]", stripped_subject); + + EM_DEBUG_FUNC_END("error_code[%d]", error_code); + return error_code; +} + + +/* + * encoding base64 + */ +INTERNAL_FUNC int em_encode_base64(char *src, unsigned long src_len, char **enc, unsigned long* enc_len, int *err_code) +{ + EM_DEBUG_FUNC_BEGIN(); + + unsigned char *content; + int ret = true, err = EMAIL_ERROR_NONE; + + if (err_code != NULL) { + *err_code = EMAIL_ERROR_NONE; + } + + content = rfc822_binary(src, src_len, enc_len); + + if (content) + *enc = (char *)content; + else { + err = EMAIL_ERROR_UNKNOWN; + ret = false; + } + + if (err_code) + *err_code = err; + + EM_DEBUG_FUNC_END(); + return ret; +} + +/* + * decoding base64 + */ +INTERNAL_FUNC int em_decode_base64(unsigned char *enc_text, unsigned long enc_len, char **dec_text, unsigned long* dec_len, int *err_code) +{ + unsigned char *text = enc_text; + unsigned long size = enc_len; + unsigned char *content; + int ret = true, err = EMAIL_ERROR_NONE; + + if (err_code != NULL) { + *err_code = EMAIL_ERROR_NONE; + } + + EM_DEBUG_FUNC_BEGIN(); + + content = rfc822_base64(text, size, dec_len); + if (content) + *dec_text = (char *)content; + else + { + err = EMAIL_ERROR_UNKNOWN; + ret = false; + } + + if (err_code) + *err_code = err; + + return ret; +} + +INTERNAL_FUNC int em_get_account_server_type_by_account_id(int account_id, email_account_server_t* account_server_type, int flag, int *error) +{ + EM_DEBUG_FUNC_BEGIN(); + emstorage_account_tbl_t *account_tbl_data = NULL; + int ret = false; + int err= EMAIL_ERROR_NONE; + + if (account_server_type == NULL ) { + EM_DEBUG_EXCEPTION("account_server_type is NULL"); + err = EMAIL_ERROR_INVALID_PARAM; + ret = false; + goto FINISH_OFF; + } + + if( !emstorage_get_account_by_id(account_id, WITHOUT_OPTION, &account_tbl_data, false, &err)) { + EM_DEBUG_EXCEPTION ("emstorage_get_account_by_id failed [%d] ", err); + ret = false; + goto FINISH_OFF; + } + + if ( flag == false ) { /* sending server */ + *account_server_type = account_tbl_data->outgoing_server_type; + } else if ( flag == true ) { /* receiving server */ + *account_server_type = account_tbl_data->incoming_server_type; + } + + ret = true; + +FINISH_OFF: + if ( account_tbl_data != NULL ) { + emstorage_free_account(&account_tbl_data, 1, NULL); + } + if ( error != NULL ) { + *error = err; + } + + return ret; +} + +#include <vconf.h> +#include <dbus/dbus.h> + +#define ACTIVE_SYNC_HANDLE_INIT_VALUE (-1) +#define ACTIVE_SYNC_HANDLE_BOUNDARY (-100000000) + + +INTERNAL_FUNC int em_get_handle_for_activesync(int *handle, int *error) +{ + EM_DEBUG_FUNC_BEGIN(); + + static int next_handle = 0; + int ret = false; + int err = EMAIL_ERROR_NONE; + + if ( handle == NULL ) { + EM_DEBUG_EXCEPTION("em_get_handle_for_activesync failed : handle is NULL"); + err = EMAIL_ERROR_INVALID_PARAM; + goto FINISH_OFF; + } + + if ( vconf_get_int(VCONFKEY_EMAIL_SERVICE_ACTIVE_SYNC_HANDLE, &next_handle) != 0 ) { + EM_DEBUG_EXCEPTION("vconf_get_int failed"); + if ( next_handle != 0 ) { + err = EMAIL_ERROR_GCONF_FAILURE; + goto FINISH_OFF; + } + } + + EM_DEBUG_LOG(">>>>>> VCONFKEY_EMAIL_SERVICE_ACTIVE_SYNC_HANDLE : get lastest handle[%d]", next_handle); + + /* set the value of the handle for active sync */ + next_handle--; + if ( next_handle < ACTIVE_SYNC_HANDLE_BOUNDARY ) { + next_handle = ACTIVE_SYNC_HANDLE_INIT_VALUE; + } + if ( vconf_set_int(VCONFKEY_EMAIL_SERVICE_ACTIVE_SYNC_HANDLE, next_handle) != 0) { + EM_DEBUG_EXCEPTION("vconf_set_int failed"); + err = EMAIL_ERROR_GCONF_FAILURE; + goto FINISH_OFF; + } + ret = true; + *handle = next_handle; + EM_DEBUG_LOG(">>>>>> return next handle[%d]", *handle); + +FINISH_OFF: + if ( error != NULL ) { + *error = err; + } + + return ret; +} + +INTERNAL_FUNC int em_send_notification_to_active_sync_engine(int subType, ASNotiData *data) +{ + EM_DEBUG_FUNC_BEGIN("subType [%d], data [%p]", subType, data); + + DBusConnection *connection; + DBusMessage *signal = NULL; + DBusError error; + const char *nullString = ""; + int i = 0; + + dbus_error_init (&error); + connection = dbus_bus_get(DBUS_BUS_SYSTEM, &error); + + if(connection == NULL) + goto FINISH_OFF; + + signal = dbus_message_new_signal("/User/Email/ActiveSync", EMAIL_ACTIVE_SYNC_NOTI, "email"); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &subType, DBUS_TYPE_INVALID); + switch ( subType ) { + case ACTIVE_SYNC_NOTI_SEND_MAIL: + EM_DEBUG_LOG("handle:[%d]", data->send_mail.handle); + EM_DEBUG_LOG("account_id:[%d]", data->send_mail.account_id); + EM_DEBUG_LOG("mail_id:[%d]", data->send_mail.mail_id); + EM_DEBUG_LOG("options.priority:[%d]", data->send_mail.options.priority); + EM_DEBUG_LOG("options.keep_local_copy:[%d]", data->send_mail.options.keep_local_copy); + EM_DEBUG_LOG("options.req_delivery_receipt:[%d]", data->send_mail.options.req_delivery_receipt); + EM_DEBUG_LOG("options.req_read_receipt:[%d]", data->send_mail.options.req_read_receipt); + /* download_limit, block_address, block_subject might not be needed */ + EM_DEBUG_LOG("options.download_limit:[%d]", data->send_mail.options.download_limit); + EM_DEBUG_LOG("options.block_address:[%d]", data->send_mail.options.block_address); + EM_DEBUG_LOG("options.block_subject:[%d]", data->send_mail.options.block_subject); + EM_DEBUG_LOG("options.display_name_from:[%s]", data->send_mail.options.display_name_from); + EM_DEBUG_LOG("options.reply_with_body:[%d]", data->send_mail.options.reply_with_body); + EM_DEBUG_LOG("options.forward_with_files:[%d]", data->send_mail.options.forward_with_files); + EM_DEBUG_LOG("options.add_myname_card:[%d]", data->send_mail.options.add_myname_card); + EM_DEBUG_LOG("options.add_signature:[%d]", data->send_mail.options.add_signature); + EM_DEBUG_LOG("options.signature:[%s]", data->send_mail.options.signature); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.handle), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.account_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.mail_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.priority), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.keep_local_copy), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.req_delivery_receipt), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.req_read_receipt), DBUS_TYPE_INVALID); + if ( data->send_mail.options.display_name_from == NULL ) + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(nullString), DBUS_TYPE_INVALID); + else + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->send_mail.options.display_name_from), DBUS_TYPE_INVALID); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.reply_with_body), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.forward_with_files), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.add_myname_card), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->send_mail.options.add_signature), DBUS_TYPE_INVALID); + if ( data->send_mail.options.signature == NULL ) + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(nullString), DBUS_TYPE_INVALID); + else + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->send_mail.options.signature), DBUS_TYPE_INVALID); + + break; + case ACTIVE_SYNC_NOTI_SEND_SAVED: /* publish a send notification to ASE (active sync engine) */ + EM_DEBUG_EXCEPTION("Not support yet : subType[ACTIVE_SYNC_NOTI_SEND_SAVED]", subType); + break; + case ACTIVE_SYNC_NOTI_SEND_REPORT: + EM_DEBUG_EXCEPTION("Not support yet : subType[ACTIVE_SYNC_NOTI_SEND_REPORT]", subType); + break; + case ACTIVE_SYNC_NOTI_SYNC_HEADER: + EM_DEBUG_LOG("handle:[%d]", data->sync_header.handle); + EM_DEBUG_LOG("account_id:[%d]", data->sync_header.account_id); + EM_DEBUG_LOG("mailbox_id:[%d]", data->sync_header.mailbox_id); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->sync_header.handle ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->sync_header.account_id ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->sync_header.mailbox_id ), DBUS_TYPE_INVALID); + break; + case ACTIVE_SYNC_NOTI_DOWNLOAD_BODY: /* publish a download body notification to ASE */ + EM_DEBUG_LOG("handle:[%d]", data->download_body.handle); + EM_DEBUG_LOG("account_id:[%d]", data->download_body.account_id); + EM_DEBUG_LOG("mail_id:[%d]", data->download_body.mail_id); + EM_DEBUG_LOG("with_attachment:[%d]", data->download_body.with_attachment); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_body.handle ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_body.account_id ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_body.mail_id ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_body.with_attachment ), DBUS_TYPE_INVALID); + break; + case ACTIVE_SYNC_NOTI_DOWNLOAD_ATTACHMENT: + EM_DEBUG_LOG("handle:[%d]", data->download_attachment.handle); + EM_DEBUG_LOG("account_id:[%d]", data->download_attachment.account_id ); + EM_DEBUG_LOG("mail_id:[%d]", data->download_attachment.mail_id); + EM_DEBUG_LOG("with_attachment:[%d]", data->download_attachment.attachment_order ); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_attachment.handle ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_attachment.account_id ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_attachment.mail_id ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->download_attachment.attachment_order), DBUS_TYPE_INVALID); + break; + case ACTIVE_SYNC_NOTI_VALIDATE_ACCOUNT: + EM_DEBUG_EXCEPTION("Not support yet : subType[ACTIVE_SYNC_NOTI_VALIDATE_ACCOUNT]", subType); + break; + case ACTIVE_SYNC_NOTI_CANCEL_JOB: + EM_DEBUG_LOG("account_id:[%d]", data->cancel_job.account_id ); + EM_DEBUG_LOG("handle to cancel:[%d]", data->cancel_job.handle); + EM_DEBUG_LOG("cancel_type:[%d]", data->cancel_job.cancel_type); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->cancel_job.account_id ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->cancel_job.handle ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->cancel_job.cancel_type ), DBUS_TYPE_INVALID); + break; + case ACTIVE_SYNC_NOTI_SEARCH_ON_SERVER: + EM_DEBUG_LOG("account_id:[%d]", data->search_mail_on_server.account_id ); + EM_DEBUG_LOG("mailbox_id:[%d]", data->search_mail_on_server.mailbox_id ); + EM_DEBUG_LOG("search_filter_count:[%d]", data->search_mail_on_server.search_filter_count ); + EM_DEBUG_LOG("handle to cancel:[%d]", data->search_mail_on_server.handle); + + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.account_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.mailbox_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.search_filter_count), DBUS_TYPE_INVALID); + for(i = 0; i < data->search_mail_on_server.search_filter_count; i++) { + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.search_filter_list[i].search_filter_type), DBUS_TYPE_INVALID); + switch(data->search_mail_on_server.search_filter_list[i].search_filter_type) { + case EMAIL_SEARCH_FILTER_TYPE_MESSAGE_NO : + case EMAIL_SEARCH_FILTER_TYPE_UID : + case EMAIL_SEARCH_FILTER_TYPE_SIZE_LARSER : + case EMAIL_SEARCH_FILTER_TYPE_SIZE_SMALLER : + case EMAIL_SEARCH_FILTER_TYPE_FLAGS_ANSWERED : + case EMAIL_SEARCH_FILTER_TYPE_FLAGS_DELETED : + case EMAIL_SEARCH_FILTER_TYPE_FLAGS_DRAFT : + case EMAIL_SEARCH_FILTER_TYPE_FLAGS_FLAGED : + case EMAIL_SEARCH_FILTER_TYPE_FLAGS_RECENT : + case EMAIL_SEARCH_FILTER_TYPE_FLAGS_SEEN : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.search_filter_list[i].search_filter_key_value.integer_type_key_value), DBUS_TYPE_INVALID); + break; + + case EMAIL_SEARCH_FILTER_TYPE_BCC : + case EMAIL_SEARCH_FILTER_TYPE_CC : + case EMAIL_SEARCH_FILTER_TYPE_FROM : + case EMAIL_SEARCH_FILTER_TYPE_KEYWORD : + case EMAIL_SEARCH_FILTER_TYPE_SUBJECT : + case EMAIL_SEARCH_FILTER_TYPE_TO : + case EMAIL_SEARCH_FILTER_TYPE_MESSAGE_ID : + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->search_mail_on_server.search_filter_list[i].search_filter_key_value.string_type_key_value), DBUS_TYPE_INVALID); + break; + + case EMAIL_SEARCH_FILTER_TYPE_SENT_DATE_BEFORE : + case EMAIL_SEARCH_FILTER_TYPE_SENT_DATE_ON : + case EMAIL_SEARCH_FILTER_TYPE_SENT_DATE_SINCE : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.search_filter_list[i].search_filter_key_value.time_type_key_value), DBUS_TYPE_INVALID); + break; + default : + EM_DEBUG_EXCEPTION("Invalid filter type [%d]", data->search_mail_on_server.search_filter_list[i].search_filter_type); + break; + } + } + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.handle), DBUS_TYPE_INVALID); + break; + + case ACTIVE_SYNC_NOTI_CLEAR_RESULT_OF_SEARCH_ON_SERVER : + EM_DEBUG_LOG("account_id:[%d]", data->clear_result_of_search_mail_on_server.account_id ); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->search_mail_on_server.account_id), DBUS_TYPE_INVALID); + break; + + case ACTIVE_SYNC_NOTI_EXPUNGE_MAILS_DELETED_FLAGGED : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->expunge_mails_deleted_flagged.mailbox_id ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->expunge_mails_deleted_flagged.on_server ), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->expunge_mails_deleted_flagged.handle ), DBUS_TYPE_INVALID); + break; + + case ACTIVE_SYNC_NOTI_RESOLVE_RECIPIENT : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->get_resolve_recipients.account_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->get_resolve_recipients.email_address), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->get_resolve_recipients.handle), DBUS_TYPE_INVALID); + break; + + case ACTIVE_SYNC_NOTI_VALIDATE_CERTIFICATE : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->validate_certificate.account_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->validate_certificate.email_address), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->validate_certificate.handle), DBUS_TYPE_INVALID); + break; + + case ACTIVE_SYNC_NOTI_ADD_MAILBOX : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->add_mailbox.account_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->add_mailbox.mailbox_path), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->add_mailbox.mailbox_alias), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->add_mailbox.handle), DBUS_TYPE_INVALID); + break; + + case ACTIVE_SYNC_NOTI_RENAME_MAILBOX : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->rename_mailbox.account_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->rename_mailbox.mailbox_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->rename_mailbox.mailbox_name), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_STRING, &(data->rename_mailbox.mailbox_alias), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->rename_mailbox.handle), DBUS_TYPE_INVALID); + break; + + case ACTIVE_SYNC_NOTI_DELETE_MAILBOX : + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->delete_mailbox.account_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->delete_mailbox.mailbox_id), DBUS_TYPE_INVALID); + dbus_message_append_args(signal, DBUS_TYPE_INT32, &(data->delete_mailbox.handle), DBUS_TYPE_INVALID); + break; + + default: + EM_DEBUG_EXCEPTION("Invalid Notification type of Active Sync : subType[%d]", subType); + return FAILURE; + } + + if(!dbus_connection_send (connection, signal, NULL)) { + EM_DEBUG_EXCEPTION("dbus_connection_send is failed"); + return FAILURE; + } else + EM_DEBUG_LOG("dbus_connection_send is successful"); + + dbus_connection_flush(connection); + +FINISH_OFF: + + if(signal) + dbus_message_unref(signal); + + EM_DEBUG_FUNC_END(); + return true; +} |