path: root/server/src/ss_server_ipc.c

/*
 * secure storage
 *
 * Copyright (c) 2000 - 2011 Samsung Electronics Co., Ltd All Rights Reserved 
 *
 * Contact: Kidong Kim <kd0228.kim@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.
 *
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>
#include <unistd.h>
#include <sys/un.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <errno.h>
#include <dirent.h>
#include <sys/ioctl.h>
#include <fcntl.h>

#include "secure_storage.h"
#include "ss_server_ipc.h"
#include "ss_server_main.h"

#ifdef USE_KEY_FILE
#define CONF_FILE_PATH	"/usr/share/secure-storage/config"
#endif // USE_KEY_FILE

char* get_key_file_path()
{
	FILE* fp_conf = NULL;
	char buf[128];
	char* retbuf = NULL;
	char seps[] = " :\n\r\t";
	char* token = NULL;

	retbuf = (char*)malloc(sizeof(char) * 128);
	if(!retbuf)
	{
		SLOGE("[%s] fail to allocate memory.\n", __func__);
		return NULL;
	}
	memset(buf, 0x00, 128);
	memset(retbuf, 0x00, 128);

	if(!(fp_conf = fopen(CONF_FILE_PATH, "r")))
	{
		SLOGE("[%s] Configuration file is not exist\n", __func__);
		free(retbuf);
		return NULL;
	}
	
	while(fgets(buf, 128, fp_conf))
	{
		token = strtok(buf, seps);
		if(!strncmp(token, "MASTER_KEY_PATH", 15))	// master key path
		{
			token = strtok(NULL, seps);	// real path
			break;
		}

		token = NULL;
	}
	fclose(fp_conf);

	if(token)
		strncpy(retbuf, token, 128);
	else {
		if(retbuf != NULL)
			free(retbuf);
		return NULL;
	}

	return retbuf;
}

int check_key_file()
{
	FILE* fp_key = NULL;
	char* key_path = NULL;

	key_path = get_key_file_path();
	if(key_path == NULL)
	{
		SLOGE("[%s] Configuration file is not exist\n", __func__);
		return 0;
	}

	if(!(fp_key = fopen(key_path, "r")))
	{
		SLOGE("[%s] Secret key file is not exist, [%s]\n", __func__, key_path);
		free(key_path);
		return 0;
	}

	free(key_path);
	fclose(fp_key);
	return 1;
}

int make_key_file()
{
	FILE* fp_key = NULL;
	int random_dev = -1;
	int i = 0;
	char tmp_key[1];
	char key[33];
	char* key_path = NULL;

	memset(key, 0x00, 33);

	key_path = get_key_file_path();
	if(key_path == NULL)
	{
		SLOGE("[%s] Configuration file is not exist\n", __func__);
		return 0;
	}

	if((random_dev = open("/dev/urandom", O_RDONLY)) < 0)
	{
		SLOGE("[%s] Random device Open error\n", __func__);
		free(key_path);
		return 0;
	}

	while(i < 32)
	{
		read(random_dev, tmp_key, 1);

		if((tmp_key[0] >= '!') && (tmp_key[0] <= '~')) {
			key[i] = tmp_key[0];
			i++;
		}
	}
SLOGI("key = [%s], [%d]\n", key, strlen(key));

	if(!(fp_key = fopen(key_path, "w")))
	{
		SLOGE("[%s] Secret key file Open error, [%s]\n", __func__, key_path);
		free(key_path);
		close(random_dev);
		return 0;
	}

	fprintf(fp_key, "%s", key);
	chmod(key_path, 0600);
	
	free(key_path);
	fclose(fp_key);
	close(random_dev);
	return 1;
}

/* for executing coverage tool (2009-04-03) */
void SigHandler(int signo)
{
	SLOGI("[%s] Got Signal %d\n", __func__, signo);
	exit(1);
}
/* end */

void SsServerComm(void)
{
	int server_sockfd, client_sockfd;
	int client_len;
	struct sockaddr_un clientaddr, serveraddr;

	struct ucred cr;	// for test client pid. 2009-03-24
	int cl = sizeof(cr);	//
	int temp_len_sock = 0;
	int temp_len_in = 0;

	ReqData_t recv_data = {0, };
	RspData_t send_data = {0, };

	client_len = sizeof(clientaddr);

	server_sockfd = client_sockfd = -1;

	if((server_sockfd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0)
	{
		SLOGE("[%s] Error in function socket()..\n", __func__);
		send_data.rsp_type = SS_SOCKET_ERROR;	// ipc error
		goto Error_exit;
	}

	temp_len_sock = strlen(SS_SOCK_PATH);
	
	bzero(&serveraddr, sizeof(serveraddr));
	serveraddr.sun_family = AF_UNIX;
	strncpy(serveraddr.sun_path, SS_SOCK_PATH, temp_len_sock);
	serveraddr.sun_path[temp_len_sock] = '\0';

	if((bind(server_sockfd, (struct sockaddr*)&serveraddr, sizeof(serveraddr))) < 0)
	{
		unlink("/tmp/SsSocket");
		if((bind(server_sockfd, (struct sockaddr*)&serveraddr, sizeof(serveraddr))) < 0)
		{
			SLOGE("[%s] Error in function bind()..\n", __func__);
			send_data.rsp_type = SS_SOCKET_ERROR;	// ipc error
			goto Error_close_exit;
		}
	}

	if(chmod(SS_SOCK_PATH, S_IRWXU | S_IRWXG | S_IRWXO) != 0)
	{
		send_data.rsp_type = SS_SOCKET_ERROR;
		goto Error_close_exit;
	}

	if((listen(server_sockfd, 5)) < 0)
	{
		SLOGE("[%s] Error in function listen()..\n", __func__);
		send_data.rsp_type = SS_SOCKET_ERROR;	// ipc error
		goto Error_close_exit;
	}

	signal(SIGINT, (void*)SigHandler);
	
	while(1) 
	{
		errno = 0;
		
		if((client_sockfd = accept(server_sockfd, (struct sockaddr*)&clientaddr, (socklen_t*)&client_len)) < 0)
		{
			SLOGE("[%s] Error in function accept()..[%d, %d]\n", __func__, client_sockfd, errno);
			send_data.rsp_type = SS_SOCKET_ERROR;	// ipc error
			goto Error_close_exit;
		}
		
		// for test client pid. 2009-03-24
		if(getsockopt(client_sockfd, SOL_SOCKET, SO_PEERCRED, &cr, (socklen_t*)&cl) != 0)
		{
			SLOGE("[%s] getsockopt() fail\n", __func__);
		}
		// end
		
		if(read(client_sockfd, (char*)&recv_data, sizeof(recv_data)) < 0)
		{
			SLOGE("[%s] Error in function read()..\n", __func__);
			send_data.rsp_type = SS_SOCKET_ERROR;	// ipc error
			goto Error_close_exit;
		}

		temp_len_in = strlen(recv_data.data_infilepath);

		switch(recv_data.req_type)
		{
			case 1:
				send_data.rsp_type = SsServerDataStoreFromFile(cr.pid, recv_data.data_infilepath, recv_data.flag, recv_data.cookie, recv_data.group_id);

				if(send_data.rsp_type == 1)
				{
					strncpy(send_data.data_filepath, recv_data.data_infilepath, MAX_FILENAME_LEN - 1);
					send_data.data_filepath[temp_len_in] = '\0';
				}
				else
				{
					strncpy(send_data.data_filepath, "Error Occured..", MAX_FILENAME_LEN - 1);
					send_data.data_filepath[15] = '\0';
				}

				write(client_sockfd, (char*)&send_data, sizeof(send_data));
				break;
			case 2:
				send_data.rsp_type = SsServerDataStoreFromBuffer(cr.pid, recv_data.buffer, recv_data.count, recv_data.data_infilepath, recv_data.flag, recv_data.cookie, recv_data.group_id);

				if(send_data.rsp_type == 1)
				{
					strncpy(send_data.data_filepath, recv_data.data_infilepath, MAX_FILENAME_LEN - 1);
					send_data.data_filepath[temp_len_in] = '\0';
				}
				else
				{
					strncpy(send_data.data_filepath, "Error Occured..", MAX_FILENAME_LEN - 1);
					send_data.data_filepath[15] = '\0';
				}

				write(client_sockfd, (char*)&send_data, sizeof(send_data));
				break;
			case 3:
				send_data.rsp_type = SsServerDataRead(cr.pid, recv_data.data_infilepath, send_data.buffer, recv_data.count, &(send_data.readLen), recv_data.flag, recv_data.cookie, recv_data.group_id);
			
				if(send_data.rsp_type == 1)
				{
					strncpy(send_data.data_filepath, recv_data.data_infilepath, MAX_FILENAME_LEN - 1);
					send_data.data_filepath[temp_len_in] = '\0';
				}
				else
				{
					strncpy(send_data.data_filepath, "Error Occured..", MAX_FILENAME_LEN - 1);
					send_data.data_filepath[15] = '\0';
				}

				write(client_sockfd, (char*)&send_data, sizeof(send_data));
				break;
			case 4: 
				send_data.rsp_type = SsServerGetInfo(cr.pid, recv_data.data_infilepath, send_data.buffer, recv_data.flag, recv_data.cookie, recv_data.group_id);
				
				if(send_data.rsp_type == 1)
				{
					strncpy(send_data.data_filepath, recv_data.data_infilepath, MAX_FILENAME_LEN - 1);
					send_data.data_filepath[temp_len_in] = '\0';
				}
				else
				{
					strncpy(send_data.data_filepath, "Error Occured..", MAX_FILENAME_LEN - 1);
					send_data.data_filepath[15] = '\0';
				}

				write(client_sockfd, (char*)&send_data, sizeof(send_data));
				break;			
			case 10:
				send_data.rsp_type = SsServerDeleteFile(cr.pid, recv_data.data_infilepath, recv_data.flag, recv_data.cookie, recv_data.group_id);
				
				if(send_data.rsp_type == 1)
				{
					strncpy(send_data.data_filepath, recv_data.data_infilepath, MAX_FILENAME_LEN - 1);
					send_data.data_filepath[temp_len_in] = '\0';
				}
				else
				{
					strncpy(send_data.data_filepath, "Error Occured..", MAX_FILENAME_LEN - 1);
					send_data.data_filepath[15] = '\0';
				}

				write(client_sockfd, (char*)&send_data, sizeof(send_data));
				break;

			default:
				SLOGE("[%s] Input error..Please check request type\n", __func__);
				break;
		}
		close(client_sockfd);
	}
	
Error_close_exit:
	close(server_sockfd);
	
Error_exit:
	strncpy(send_data.data_filepath, "error", MAX_FILENAME_LEN - 1);
	send_data.data_filepath[5] = '\0';

	if(client_sockfd >= 0)
	{
		write(client_sockfd, (char*)&send_data, sizeof(send_data));
		close(client_sockfd);
	}
	else
		SLOGE("[%s] cannot connect to client socket.\n", __func__);
}

int main(void)
{
	SLOGI("[%s] Secure Storage Server Start..\n", __func__);

#ifdef USE_KEY_FILE
	int exist_ret = -1;
	int make_ret = -1;
#endif // USE_KEY_FILE
	DIR* dp = NULL;	// make default directory(if not exist)

	if((dp = opendir(SS_STORAGE_DEFAULT_PATH)) == NULL)
	{
		SLOGI("[%s] directory [%s] is not exist, making now.\n", __func__, SS_STORAGE_DEFAULT_PATH);
		mkdir(SS_STORAGE_DEFAULT_PATH, 0700);
	}
	else
		closedir(dp);

#ifdef USE_KEY_FILE
	exist_ret = check_key_file(); // if 0, there is not key file. Or 1, exist.
	
	if(exist_ret == 0)
	{
		make_ret = make_key_file();

		if(make_ret == 0)
		{
			SLOGE("[%s] Making key file fail. ss-server will be terminated..\n", __func__);
			return 0;
		}
	}
#endif // USE_KEY_FILE

	SsServerComm();

	return 0;
}