/* the Music Player Daemon (MPD)
 * (c)2003-2004 by Warren Dukes (shank@mercury.chem.pitt.edu)
 * This project's homepage is: http://www.musicpd.org
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program 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 General Public License for more details.
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

#include "interface.h"
#include "command.h"
#include "playlist.h"
#include "directory.h"
#include "tables.h"
#include "player.h"
#include "listen.h"
#include "conf.h"
#include "path.h"
#include "playerData.h"
#include "stats.h"
#include "sig_handlers.h"
#include "audio.h"
#include "volume.h"
#include "log.h"
#include "permission.h"

#include <stdio.h>
#include <sys/select.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <fcntl.h>
#include <pwd.h>
#include <grp.h>
#include <unistd.h>

#define SYSTEM_CONFIG_FILE_LOCATION	"/etc/mpd.conf"
#define USER_CONFIG_FILE_LOCATION	"/.mpdconf"

typedef struct _Options {
        char * portStr;
        char * musicDirArg;
        char * playlistDirArg;
        char * logFile;
        char * errorFile;
        char * usr;
        char * dbFile;
        int daemon;
        int createDB;
} Options;

void usage(char * argv[]) {
        ERROR("usage:\n");
        ERROR("   %s [options] <port> <music dir> <playlist dir> <log file> <error file>\n",argv[0]);
        ERROR("   %s [options] <conf file>\n",argv[0]);
        ERROR("   %s [options]   (searches for ~%s then %s)\n",
                        argv[0],USER_CONFIG_FILE_LOCATION,
                        SYSTEM_CONFIG_FILE_LOCATION);
        ERROR("\n");
        ERROR("options:\n");
        ERROR("   --help           this usage statement\n");
        ERROR("   --no-daemon      don't detach from console\n");
        ERROR("   --create-db      force (re)creation database\n");
        ERROR("   --no-create-db   don't create database\n");
        ERROR("   --verbose        verbose logging\n");
        ERROR("   --version        prints version information\n");
}

void version() {
        ERROR("mpd (MPD: Music Player Daemon) %s\n",VERSION);
        ERROR("\n");
        ERROR("Copyright (C) 2003 Warren Dukes <shank@mercury.chem.pitt.edu>\n");
        ERROR("This is free software; see the source for copying conditions.  There is NO\n");
        ERROR("warranty; not even MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.\n");
}

void parseOptions(int argc, char ** argv, Options * options) {
        int argcLeft = argc;

        options->usr = NULL;
        options->daemon = 1;
        options->createDB = 0;
        options->dbFile = NULL;

        if(argc>1) {
                int i = 1;
                while(i<argc) {
                        if(strncmp(argv[i],"--",2)==0) {
                                if(strcmp(argv[i],"--help")==0) {
                                        usage(argv);
                                        exit(0);
                                }
                                else if(strcmp(argv[i],"--no-daemon")==0) {
                                        options->daemon = 0;
                                        argcLeft--;
                                }
                                else if(strcmp(argv[i],"--create-db")==0) {
                                        options->createDB = 1;
                                        argcLeft--;
                                }
                                else if(strcmp(argv[i],"--no-create-db")==0) {
                                        options->createDB = -1;
                                        argcLeft--;
                                }
                                else if(strcmp(argv[i],"--verbose")==0) {
                                        logLevel = LOG_LEVEL_DEBUG;
                                        argcLeft--;
                                }
                                else if(strcmp(argv[i],"--version")==0) {
                                        version();
                                        exit(0);
                                }
                                else {
                                        myfprintf(stderr,"unknown command line option: %s\n",argv[i]);
                                        exit(-1);
                                }
                        }
                        else break;
                        i++;
                }
        }

        if(argcLeft==6) {
                options->portStr = argv[argc-5];
                options->musicDirArg = argv[argc-4];
                options->playlistDirArg = argv[argc-3];
                options->logFile = argv[argc-2];
                options->errorFile = argv[argc-1];
                return;
        }
        else if(argcLeft<=2) {
                char ** conf = NULL;
                if(argcLeft==2) conf = readConf(argv[argc-1]);
                if(argcLeft==1) {
                        FILE * fp;
                        char * homedir = getenv("HOME");
                        char userfile[MAXPATHLEN+1] = "";
                        if(homedir && (strlen(homedir)+
                                                strlen(USER_CONFIG_FILE_LOCATION)) <
                                        MAXPATHLEN) {
                                strcpy(userfile,homedir);
                                strcat(userfile,USER_CONFIG_FILE_LOCATION);
                        }
                        if(strlen(userfile) && (fp=fopen(userfile,"r"))) {
                                fclose(fp);
                                conf = readConf(userfile);
                        }
                        else if((fp=fopen(SYSTEM_CONFIG_FILE_LOCATION,"r"))) {
                                fclose(fp);
                                conf = readConf(SYSTEM_CONFIG_FILE_LOCATION);
                        }
                }
                if(conf) {
                        options->portStr = conf[CONF_PORT];
                        options->musicDirArg = conf[CONF_MUSIC_DIRECTORY];
                        options->playlistDirArg = conf[CONF_PLAYLIST_DIRECTORY];
                        options->logFile = conf[CONF_LOG_FILE];
                        options->errorFile = conf[CONF_ERROR_FILE];
                        options->usr = conf[CONF_USER];
                        if(conf[CONF_DB_FILE]) {
                                options->dbFile = conf[CONF_DB_FILE];
                        }
                        return;
                }
        }

        usage(argv);
        exit(-1);
}

int main(int argc, char * argv[]) {
        int port, uid, gid;
        struct stat st;
        FILE * out;
        FILE * err;
        Options options;
        int i;

        for(i=0;i<FD_SETSIZE;i++) {
                switch(i) {
                        case STDIN_FILENO:
                        case STDOUT_FILENO:
                        case STDERR_FILENO:
                                break;
                        default:
                                close(i);
                }
        }

        initConf();

        parseOptions(argc,argv,&options);

        initStats();
        initLog();

        if((port = atoi(options.portStr))<0) {
                ERROR("problem with port number\n");
                return -1;
        }

        if((listenSocket = establish(port))<0) {
                ERROR("error binding port\n");
                return -1;
        }

        /*
         * lose privileges as early as possible
         */

        /* change uid */
        if (options.usr && strlen(options.usr)) {
#ifdef _BSD_SOURCE
                gid_t gid_list[NGROUPS_MAX];
#endif

                /* get uid */
                struct passwd * userpwd;
                if ((userpwd = getpwnam(options.usr)) == NULL) {
                        ERROR("no such user: %s\n", options.usr);
                        return -1;
                }
                uid = userpwd->pw_uid;
                gid = userpwd->pw_gid;

                if(setgid(gid) == -1) {
                        ERROR("cannot setgid of user %s: %s\n", options.usr,
                                        strerror(errno));
                        return -1;
                }

#ifdef _BSD_SOURCE
                /* init suplementary groups 
                 * (must be done before we change our uid)
                 */
                if (initgroups(options.usr, gid) == -1) {
                        ERROR("cannot init suplementary groups "
                                        "of user %s: %s\n", options.usr, 
                                        strerror(errno));
                }
                else if(getgroups(NGROUPS_MAX, gid_list) == -1) {
                        ERROR("cannot get groups "
                                        "of user %s: %s\n", options.usr, 
                                        strerror(errno));
                        return -1;
                }
                else if(setgroups(NGROUPS_MAX, gid_list) == -1) {
                        ERROR("cannot set groups "
                                        "of user %s: %s\n", options.usr, 
                                        strerror(errno));
                        return -1;
                }
#endif

                /* set uid */
                if (setuid(uid) == -1) {
                        ERROR("cannot change to uid of user "
                                        "%s: %s\n", options.usr, 
                                        strerror(errno));
                        return -1;
                }

        }

        if(NULL==(out=fopen(options.logFile,"a"))) {
                ERROR("problem opening file \"%s\" for writing\n",
                                options.logFile);
                return -1;
        }

        if(NULL==(err=fopen(options.errorFile,"a"))) {
                ERROR("problem opening file \"%s\" for writing\n",
                                options.errorFile);
                return -1;
        }

	initPaths();
	initPermissions();

        if(options.playlistDirArg[0]=='/') {
                strcpy(playlistDir,options.playlistDirArg);
        }
        else {
                getcwd(playlistDir,MAXPATHLEN-strlen(options.playlistDirArg)-1);
                if(playlistDir[strlen(playlistDir)-1]!='/') {
                        strcat(playlistDir,"/");
                }
                strcat(playlistDir,options.playlistDirArg);
        }
        if(playlistDir[strlen(playlistDir)-1]!='/') {
                strcat(playlistDir,"/");
        }
        if((stat(playlistDir,&st))<0) {
                ERROR("problem stat'ing \"%s\"\n",options.playlistDirArg);
                return -1;
        }
        if(!S_ISDIR(st.st_mode)) {
                ERROR("\"%s\" is not a directory\n",options.playlistDirArg);
                return -1;
        }

        if(options.musicDirArg[0]=='/') {
                strcpy(musicDir,options.musicDirArg);
        }
        else {
                getcwd(musicDir,MAXPATHLEN-strlen(options.musicDirArg)-1);
                if(musicDir[strlen(musicDir)-1]!='/') strcat(musicDir,"/");
                strcat(musicDir,options.musicDirArg);
        }
        if(musicDir[strlen(musicDir)-1]!='/') strcat(musicDir,"/");
        if((stat(musicDir,&st))<0) {
                ERROR("problem stat'ing \"%s\"\n",options.musicDirArg);
                return -1;
        }
        if(!S_ISDIR(st.st_mode)) {
                ERROR("\"%s\" is not a directory\n",options.musicDirArg);
                return -1;
        }

        initTables();
        initPlaylist();

        if(!options.dbFile) {	
                strncpy(directorydb,playlistDir,MAXPATHLEN);
                strncat(directorydb,"/.mpddb",MAXPATHLEN-strlen(playlistDir));
        }
        else strncpy(directorydb,options.dbFile,MAXPATHLEN);
        if(options.createDB>0 || readDirectoryDB()<0) {
                if(options.createDB<0) {
                        ERROR("can't open db file and using \"--no-create-db\""
                                        " command line option\n");
                        exit(-1);
                }
                initMp3Directory();
                if(writeDirectoryDB()<0) {
                        ERROR("problem opening db for reading or writing\n");
                        exit(-1);
                }
        }

        initCommands();
        initAudioDriver();
        initPlayerData();
        initVolume();
        initInterfaces();

        close(STDIN_FILENO);
        if(options.daemon) {
                int pid;

                fflush(NULL);
                pid = fork();
                if(pid>0) _exit(0);
                else if(pid<0) {
                        ERROR("problems fork'ing for daemon!\n");
                        exit(-1);
                }

                if(chdir("/")<0) {
                        ERROR("problems changing to root directory\n");
                        exit(-1);
                }

                if(setsid()<0) {
                        ERROR("problems setsid'ing\n");
                        exit(-1);
                }

                if(close(STDOUT_FILENO)) {
                        fprintf(err,"problems closing stdout : %s\n",
                                        strerror(errno));
                        exit(-1);
                }

                if(close(STDERR_FILENO)) {
                        fprintf(err,"problems closing stderr : %s\n",
                                        strerror(errno));
                        exit(-1);
                }

                if(dup2(fileno(out),STDOUT_FILENO)<0) {
                        fprintf(err,"problems dup2 stdout : %s\n",
                                        strerror(errno));
                        exit(-1);
                }

                if(dup2(fileno(err),STDERR_FILENO)<0) {
                        fprintf(err,"problems dup2 stderr : %s\n",
                                        strerror(errno));
                        exit(-1);
                }

                myfprintfStdLogMode(out,err);

                fflush(NULL);
                pid = fork();
                if(pid>0) _exit(0);
                else if(pid<0) {
                        ERROR("problems fork'ing for daemon!\n");
                        exit(-1);
                }
        }
        else {
                fclose(out);
                fclose(err);
        }

        /* lets redirect stdin to dev null as a work around for libao bug */
        {
                int fd = open("/dev/null",O_RDONLY);
                if(fd<0) {
                        ERROR("not able to open /dev/null to redirect stdin: "
                                        "%s\n",strerror(errno));
                        exit(-1);
                }
                if(dup2(fd,STDIN_FILENO)<0) {
                        ERROR("problems dup2's stdin for redirection: "
                                        "%s\n",strerror(errno));
                        exit(-1);
                }
        }

        openVolumeDevice();
        initSigHandlers();
        readPlaylistState();

        while(COMMAND_RETURN_KILL!=doIOForInterfaces()) {
                syncPlayerAndPlaylist();
                closeOldInterfaces();
        }

        finishSigHandlers();

        savePlaylistState();
        playerKill();

        freeAllInterfaces();
        close(listenSocket);
        closeMp3Directory();
        closeTables();
        finishPlaylist();
        freePlayerData();
        finishAudioDriver();
        finishVolume();
	finishPaths();
	finishPermissions();
        finishCommands();

        return 0;
}