/*
 * Copyright (C) 2008 The Android Open Source Project
 *
 * 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.
 */

/*
**	mountd server support
*/

#include "mountd.h"
#include "ASEC.h"

#include <cutils/properties.h>
#include <cutils/sockets.h>

#include <pthread.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/socket.h>

#include <private/android_filesystem_config.h>


// current client file descriptor
static int sFD = -1;

// to synchronize writing to client
static pthread_mutex_t sWriteMutex = PTHREAD_MUTEX_INITIALIZER;

// path for media that failed to mount before the runtime is connected
static char* sDeferredUnmountableMediaPath = NULL;

// last asec msg before the runtime was connected
static char* sAsecDeferredMessage = NULL;
static char* sAsecDeferredArgument = NULL;

static int Write(const char* message)
{
    int result = -1;

    pthread_mutex_lock(&sWriteMutex);
    
    LOG_SERVER("Write: %s\n", message);
    if (sFD >= 0)
        result = write(sFD, message, strlen(message) + 1);

    pthread_mutex_unlock(&sWriteMutex); 
    
    return result;
}

static int Write2(const char* message, const char* data)
{
    int result = -1;

    char* buffer = (char *)alloca(strlen(message) + strlen(data) + 1);
    if (!buffer)
    {
        LOG_ERROR("alloca failed in Write2\n");
        return -1;
    }

    strcpy(buffer, message);
    strcat(buffer, data);
    return Write(buffer);
}

static void SendStatus()
{
    Write(IsMassStorageConnected() ? MOUNTD_UMS_CONNECTED : MOUNTD_UMS_DISCONNECTED);
    Write(IsMassStorageEnabled() ? MOUNTD_UMS_ENABLED : MOUNTD_UMS_DISABLED);
}

static void DoCommand(const char* command)
{
    LOG_SERVER("DoCommand %s\n", command);
    
    if (strcmp(command, MOUNTD_ENABLE_UMS) == 0)
    {
        EnableMassStorage(true);
        Write(MOUNTD_UMS_ENABLED);
     }
    else if (strcmp(command, MOUNTD_DISABLE_UMS) == 0) 
    {
        EnableMassStorage(false);
        Write(MOUNTD_UMS_DISABLED);
    }
    else if (strcmp(command, MOUNTD_SEND_STATUS) == 0)
    {
        SendStatus();
    }
    else if (strncmp(command, MOUNTD_MOUNT_MEDIA, strlen(MOUNTD_MOUNT_MEDIA)) == 0)
    {
        const char* path = command + strlen(MOUNTD_MOUNT_MEDIA);
        MountMedia(path);
    }
    else if (strncmp(command, MOUNTD_EJECT_MEDIA, strlen(MOUNTD_EJECT_MEDIA)) == 0)
    {
        const char* path = command + strlen(MOUNTD_EJECT_MEDIA);
        UnmountMedia(path);
    } 
    else if (strncmp(command, ASEC_CMD_ENABLE, strlen(ASEC_CMD_ENABLE)) == 0) {
        LOG_ASEC("Got ASEC_CMD_ENABLE\n");
	// XXX: SAN: Impliment
    }
    else if (strncmp(command, ASEC_CMD_DISABLE, strlen(ASEC_CMD_DISABLE)) == 0) {
        LOG_ASEC("Got ASEC_CMD_DISABLE\n");
	// XXX: SAN: Impliment
    }
    else if (strncmp(command, ASEC_CMD_SEND_STATUS, strlen(ASEC_CMD_SEND_STATUS)) == 0) {
        LOG_ASEC("Got ASEC_CMD_SEND_STATUS\n");
	// XXX: SAN: Impliment
    }
    else
        LOGE("unknown command %s\n", command);
}

int RunServer()
{
    int socket = android_get_control_socket(MOUNTD_SOCKET);
    if (socket < 0) {
        LOGE("Obtaining file descriptor for socket '%s' failed: %s",
             MOUNTD_SOCKET, strerror(errno));
        return -1;
    }

    if (listen(socket, 4) < 0) {
        LOGE("Unable to listen on file descriptor '%d' for socket '%s': %s",
             socket, MOUNTD_SOCKET, strerror(errno));
        return -1;
    }

    while (1)
    {
        struct sockaddr addr;
        socklen_t alen;
        struct ucred cred;
        socklen_t size;
        
        alen = sizeof(addr);
        sFD = accept(socket, &addr, &alen);
        if (sFD < 0)
            continue;
            
        if (sDeferredUnmountableMediaPath) {
            NotifyMediaState(sDeferredUnmountableMediaPath, MEDIA_UNMOUNTABLE, false);
            free(sDeferredUnmountableMediaPath);
            sDeferredUnmountableMediaPath = NULL;
        }

        if (sAsecDeferredMessage) {
    
            if (Write2(sAsecDeferredMessage, sAsecDeferredArgument) < 0)
                LOG_ERROR("Failed to deliver deferred ASEC msg to framework\n");
            free(sAsecDeferredMessage);
            free(sAsecDeferredArgument);
            sAsecDeferredMessage = sAsecDeferredArgument = NULL;
        }

        while (1)
        {    
            char    buffer[101];
            int result = read(sFD, buffer, sizeof(buffer) - 1);
            if (result > 0)
            {
                int start = 0;
                int i;
                // command should be zero terminated, but just in case
                buffer[result] = 0;
                for (i = 0; i < result; i++) 
                {
                    if (buffer[i] == 0) 
                    {
                        DoCommand(buffer + start);
                        start = i + 1;
                    }                   
                }
            }
            else
            {
                close(sFD);
                sFD = -1;
                break;
            }
        }
    }  

    // should never get here
    return 0;
}

void SendMassStorageConnected(boolean connected)
{
    Write(connected ? MOUNTD_UMS_CONNECTED : MOUNTD_UMS_DISCONNECTED);
}

void SendUnmountRequest(const char* path)
{
    Write2(MOUNTD_REQUEST_EJECT, path);
}

void NotifyAsecState(AsecState state, const char *argument)
{
    const char *event = NULL;
    const char *status = NULL;
    boolean deferr = true;;

    switch (state) {
        case ASEC_DISABLED:
            event = ASEC_EVENT_DISABLED;
            status = ASEC_STATUS_DISABLED;
            break;
        case ASEC_AVAILABLE:
            event = ASEC_EVENT_AVAILABLE;
            status = ASEC_STATUS_AVAILABLE;
            break;
        case ASEC_BUSY:
            event = ASEC_EVENT_BUSY;
            status = ASEC_STATUS_BUSY;
            deferr = false;
            break;
        case ASEC_FAILED_INTERR:
            event = ASEC_EVENT_FAILED_INTERR;
            status = ASEC_STATUS_FAILED_INTERR;
            break;
        case ASEC_FAILED_NOMEDIA:
            event = ASEC_EVENT_FAILED_NOMEDIA;
            status = ASEC_STATUS_FAILED_NOMEDIA;
            break;
        case ASEC_FAILED_BADMEDIA:
            event = ASEC_EVENT_FAILED_BADMEDIA;
            status = ASEC_STATUS_FAILED_BADMEDIA;
            break;
        case ASEC_FAILED_BADKEY:
            event = ASEC_EVENT_FAILED_BADKEY;
            status = ASEC_STATUS_FAILED_BADKEY;
            break;
        default:
            LOG_ERROR("unknown AsecState %d in NotifyAsecState\n", state);
            return;
    }

    property_set(ASEC_STATUS, status);

    int result = Write2(event, argument);
    if ((result < 0) && deferr) {
        if (sAsecDeferredMessage) 
            free(sAsecDeferredMessage);
        sAsecDeferredMessage = strdup(event);
        if (sAsecDeferredArgument)
            free(sAsecDeferredArgument);
        sAsecDeferredArgument = strdup(argument);
        LOG_ASEC("Deferring event '%s' arg '%s' until framework connects\n", event, argument);
    }
}

void NotifyMediaState(const char* path, MediaState state, boolean readOnly)
{
    const char* event = NULL;
    const char* propertyValue = NULL;
    
    switch (state) {
        case MEDIA_REMOVED:
            event = MOUNTD_MEDIA_REMOVED;
            propertyValue = EXTERNAL_STORAGE_REMOVED;
            break;
        case MEDIA_UNMOUNTED:
            event = MOUNTD_MEDIA_UNMOUNTED;
            propertyValue = EXTERNAL_STORAGE_UNMOUNTED;
            break;
        case MEDIA_MOUNTED:
            event = (readOnly ? MOUNTD_MEDIA_MOUNTED_READ_ONLY : MOUNTD_MEDIA_MOUNTED);
             propertyValue = (readOnly ? EXTERNAL_STORAGE_MOUNTED_READ_ONLY : EXTERNAL_STORAGE_MOUNTED);
           break;
        case MEDIA_SHARED:
            event = MOUNTD_MEDIA_SHARED;
            propertyValue = EXTERNAL_STORAGE_SHARED;
            break;
        case MEDIA_BAD_REMOVAL:
            event = MOUNTD_MEDIA_BAD_REMOVAL;
            propertyValue = EXTERNAL_STORAGE_BAD_REMOVAL;
            break;
        case MEDIA_UNMOUNTABLE:
            event = MOUNTD_MEDIA_UNMOUNTABLE;
            propertyValue = EXTERNAL_STORAGE_UNMOUNTABLE;
            break;
        default:
            LOG_ERROR("unknown MediaState %d in NotifyMediaState\n", state);
            return;
    }
    
    property_set(EXTERNAL_STORAGE_STATE, propertyValue);
    int result = Write2(event, path);
    if (result < 0 && state == MEDIA_UNMOUNTABLE) {
    
        // if we cannot communicate with the runtime, defer this message until the runtime is available
        sDeferredUnmountableMediaPath = strdup(path);
    }
}