/*
- * Copyright (C) 1997-2006 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 1997-2007 Andre Noll <maan@systemlinux.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
#include "server.cmdline.h"
#include "db.h"
#include "server.h"
-#include "afs.h"
+#include "vss.h"
#include "send.h"
#include "rc4.h"
#include <openssl/rc4.h>
#include "string.h"
#include "fd.h"
#include "user_list.h"
+#include "server_command_list.h"
static RC4_KEY rc4_recv_key;
static RC4_KEY rc4_send_key;
extern struct audio_file_selector selectors[];
extern struct sender senders[];
extern char *user_list;
-struct sockaddr_in *in_addr;
-
-static int com_si(int, int, char **);
-static int com_version(int, int, char **);
-static int com_sb(int, int, char **);
-static int com_sc(int, int, char **);
-static int com_stat(int, int, char **);
-static int com_help(int, int, char **);
-static int com_hup(int, int, char **);
-static int com_term(int, int, char **);
-static int com_play(int, int, char **);
-static int com_stop(int, int, char **);
-static int com_pause(int, int, char **);
-static int com_next(int, int, char **);
-static int com_nomore(int, int, char **);
-static int com_chs(int, int, char **);
-static int com_ff(int, int, char **);
-static int com_jmp(int, int, char **);
-static int com_sender(int, int, char **);
-
-
-/* commands that are handled by the server itself */
-static struct server_command cmd_struct[] = {
-{
-.name = "chs",
-.handler = com_chs,
-.perms = DB_READ | DB_WRITE,
-.description = "change the current audio file selector",
-.synopsis = "chs [new_selector]",
-.help =
-"Shutdown the current selector and activate new_selector. If no\n"
-"argument was given, print the name of the current selector.\n"
-},
-
-{
-.name = "ff",
-.handler = com_ff,
-.perms = AFS_READ | AFS_WRITE,
-.description = "jmp amount of time forwards or backwards "
- "in current audio file",
-.synopsis = "ff n[-]",
-.help =
-
-"\tSet the 'R' (reposition request) bit of the afs status flags\n"
-"\tand enqueue a request to jump n seconds forwards or backwards\n"
-"\tin the current audio file.\n"
-"\n"
-"EXAMPLE\n"
-"\n"
-"\t\tff 30-\n"
-"\n"
-"\tjumps 30 seconds backwards.\n"
-
-},
-
-{
-.name = "help",
-.handler = com_help,
-.perms = 0,
-.description = "print help text",
-.synopsis = "help [command]",
-.help =
-
-"Without any arguments, help prints a list of availible commands. When\n"
-"issued with a command name as first argument, print out a description\n"
-"for that command.\n"
-
-},
-
-{
-.name = "hup",
-.handler = com_hup,
-.perms = AFS_WRITE,
-.description = "force reload of config file and log file",
-.synopsis = "hup",
-.help =
-
-"After rereading the config file, a signal is sent to all children\n"
-"which forces them to close/reopen the log file.\n"
-
-},
-
-{
-.name = "jmp",
-.handler = com_jmp,
-.perms = AFS_READ | AFS_WRITE,
-.description = "jmp to given position in current audio file",
-.synopsis = "jmp [n]",
-.help =
-
-"\tSet the 'R' (reposition request) bit of the afs status flags\n"
-"\tand enqueue a request to jump to n% of the current audio file,\n"
-"\twhere 0 <= n <= 100.\n"
-
-},
-
-{
-.name = "next",
-.handler = com_next,
-.perms = AFS_READ | AFS_WRITE,
-.description = "skip rest of current audio file",
-.synopsis = "next",
-.help =
-
-"\tSet the 'N' (next audio file) bit of the afs status flags. When\n"
-"\tplaying, change audio file immediately. Equivalent to stop\n"
-"\tif paused, NOP if stopped.\n"
-
-
-},
-
-{
-.name = "nomore",
-.handler = com_nomore,
-.perms = AFS_READ | AFS_WRITE,
-.description = "stop playing after current audio file",
-.synopsis = "nomore",
-.help =
-
-"Set the 'O' (no more) bit of the afs status flags. This instructs\n"
-"para_server to clear the 'P' (playing) bit as soon as it encounters\n"
-"the 'N' (next audio file) bit being set.\n"
-"\n"
-"Use this command instead of stop if you don't like\n"
-"sudden endings.\n"
-
-},
-
-{
-.name ="pause",
-.handler = com_pause,
-.perms = AFS_READ | AFS_WRITE,
-.description = "pause current audio file",
-.synopsis = "pause",
-.help =
-
-"\tClear the 'P' (playing) bit of the afs status flags.\n"
-
-},
-
-{
-.name = "play",
-.handler = com_play,
-.perms = AFS_READ | AFS_WRITE,
-.description = "start playing or resume playing when paused",
-.synopsis = "play",
-.help =
-
-"\tSet the 'P' (playing) bit of the afs status flags. This\n"
-"\tresults in starting/continuing to stream.\n"
-
-},
-
-{
-.name = "sb",
-.handler = com_sb,
-.perms = AFS_READ,
-.description = "print status bar for current audio file",
-.synopsis = "sb [n]",
-.help =
-
-"Without any arguments, sb continuously prints a status bar of the form\n"
-"\n"
-" 12:34 [56:12] (56%) filename\n"
-"\n"
-"indicating playing time, remaining time, percentage and the name of\n"
-"the file beeing streamed. Use the optional number n to let stat exit\n"
-"after having displayed the status bar n times.\n"
-
-},
-{
-.name = "sc",
-.handler = com_sc,
-.perms = AFS_READ,
-.description = "print name of audio file whenever it changes",
-.synopsis = "sc [n]",
-.help =
-
-"\tsc prints exactly one line (the filename of the audio file\n"
-"\tbeing played) whenever the audio file changes. Stops after\n"
-"\tn iterations, or never if n is not specified.\n"
-
-},
-{
-.name = "sender",
-.handler = com_sender,
-.perms = AFS_READ | AFS_WRITE,
-.description = "control paraslash internal senders",
-.synopsis = "sender [s cmd [arguments]]",
-.help =
-
-"send command cmd to sender s. cmd may be one of the following:\n"
-"help, on, off, add, delete, allow, or deny. Note that not all senders\n"
-"support each command. Try e.g. 'para_client sender http help' for\n"
-"more information about the http sender. If no argument is given,\n"
-"print out a list of all senders that are compiled in.\n"
-
-},
-{
-.name = "si",
-.handler = com_si,
-.perms = 0,
-.description = "print server info",
-.synopsis = "si",
-.help =
-"Print server uptime and other information.\n"
-},
-
-{
-.name = "stat",
-.handler = com_stat,
-.perms = AFS_READ,
-.description = "print status info for current audio file",
-.synopsis = "stat [n]",
-.help =
-
-"\tWithout any arguments, stat continuously prints status messages\n"
-"\tof the audio file being streamed. Use the optional number n\n"
-"\tto let stat exit after having displayed status n times.\n"
-
-},
-
-{
-.name = "stop",
-.handler = com_stop,
-.perms = AFS_READ | AFS_WRITE,
-.description = "stop playing",
-.synopsis = "stop",
-.help =
-
-"\tClear the 'P' (play) bit and set the 'N' bit of the afs status\n"
-"\tflags.\n"
-
-},
-{
-.name = "term",
-.handler = com_term,
-.perms = AFS_READ | AFS_WRITE,
-.description = "terminate para_server",
-.synopsis = "term",
-.help =
-
-"Shuts down the server. Instead of this command, you can also send\n"
-"SIGINT or SIGTERM. It should never be necessary to send SIGKILL.\n"
-
-},
-{
-.name = "version",
-.handler = com_version,
-.perms = 0,
-.description = "print server's version",
-.synopsis = "version",
-.help =
-"Show version and other info\n"
-},
-/* this indicates the end of the list. Do not touch. */
-{
-.name = NULL,
-}
-};
static void dummy(__a_unused int s)
{}
/*
* compute human readable string containing
- * afs_status for given integer value
+ * vss status for given integer value
*/
-static char *afs_status_tohuman(unsigned int flags)
+static char *vss_status_tohuman(unsigned int flags)
{
- if (flags & AFS_PLAYING)
+ if (flags & VSS_PLAYING)
return para_strdup("playing");
- else if (flags & AFS_NEXT)
+ else if (flags & VSS_NEXT)
return para_strdup("stopped");
else
return para_strdup("paused");
/*
* return human readable permission string. Never returns NULL.
*/
-char *cmd_perms_itohuman(unsigned int perms)
+static char *cmd_perms_itohuman(unsigned int perms)
{
- char *msg = para_malloc(7 * sizeof(char));
+ char *msg = para_malloc(5 * sizeof(char));
- msg[0] = perms & DB_READ? 'd' : '-';
- msg[1] = perms & DB_WRITE? 'D' : '-';
- msg[2] = perms & AFS_READ? 'a' : '-';
- msg[3] = perms & AFS_WRITE? 'A' : '-';
+ msg[0] = perms & DB_READ? 'a' : '-';
+ msg[1] = perms & DB_WRITE? 'A' : '-';
+ msg[2] = perms & VSS_READ? 'v' : '-';
+ msg[3] = perms & VSS_WRITE? 'V' : '-';
msg[4] = '\0';
return msg;
}
/*
* Never returns NULL.
*/
-static char *afs_get_status_flags(unsigned int flags)
+static char *vss_get_status_flags(unsigned int flags)
{
char *msg = para_malloc(5 * sizeof(char));
- msg[0] = (flags & AFS_PLAYING)? 'P' : '_';
- msg[1] = (flags & AFS_NOMORE)? 'O' : '_';
- msg[2] = (flags & AFS_NEXT)? 'N' : '_';
- msg[3] = (flags & AFS_REPOS)? 'R' : '_';
+ msg[0] = (flags & VSS_PLAYING)? 'P' : '_';
+ msg[1] = (flags & VSS_NOMORE)? 'O' : '_';
+ msg[2] = (flags & VSS_NEXT)? 'N' : '_';
+ msg[3] = (flags & VSS_REPOS)? 'R' : '_';
msg[4] = '\0';
return msg;
}
/*
* compute status bar string. Never returns NULL
*/
-char *get_sb_string(struct misc_meta_data *nmmd)
+static char *get_sb_string(struct misc_meta_data *nmmd)
{
char *base, *ret;
long long unsigned secs = 0, rsecs = 0, percent = 0;
static char *get_status(struct misc_meta_data *nmmd)
{
char *bar, *ret, mtime[30] = "";
- char *status, *flags; /* afs status info */
+ char *status, *flags; /* vss status info */
char *ut = uptime_str();
long offset = (nmmd->offset + 500) / 1000;
struct timeval now;
strftime(mtime, 29, "%a %b %d %Y", &mtime_tm);
}
/* report real status */
- status = afs_status_tohuman(nmmd->afs_status_flags);
- flags = afs_get_status_flags(nmmd->afs_status_flags);
+ status = vss_status_tohuman(nmmd->vss_status_flags);
+ flags = vss_get_status_flags(nmmd->vss_status_flags);
bar = para_basename(nmmd->filename);
gettimeofday(&now, NULL);
ret = make_message(
return 1;
}
-static int com_sender(int fd, int argc, char **argv)
+int com_sender(int fd, int argc, char **argv)
{
int i, ret;
struct sender_command_data scd;
}
/* server info */
-static int com_si(int fd, int argc, __a_unused char **argv)
+int com_si(int fd, int argc, __a_unused char **argv)
{
int i, ret;
char *ut;
}
/* version */
-static int com_version(int socket_fd, int argc, __a_unused char **argv)
+int com_version(int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
}
/* sc */
-static int com_sc(int socket_fd, int argc, char **argv)
+int com_sc(int socket_fd, int argc, char **argv)
{
char *name = NULL;
int ret, old = 0, count = -1; /* print af change forever */
}
/* sb */
-static int com_sb(int socket_fd, int argc, char **argv)
+int com_sb(int socket_fd, int argc, char **argv)
{
char *sb;
int ret, nr = -1; /* status bar will be printed that many
}
/* stat */
-static int com_stat(int socket_fd, int argc, char **argv)
+int com_stat(int socket_fd, int argc, char **argv)
{
int ret, num = 0;/* status will be printed that many
* times. num <= 0 means: print forever
/* always returns string that must be freed by the caller in handler */
static struct server_command *get_cmd_ptr(char *name, char **handler)
{
- struct server_command *cmd = cmd_struct;
+ struct server_command *cmd;
- for (cmd = cmd_struct; cmd->name; cmd++)
+ for (cmd = server_cmds; cmd->name; cmd++)
if (!strcmp(cmd->name, name)) {
if (handler)
*handler = para_strdup("para_server"); /* server commands */
}
/* help */
-static int com_help(int fd, int argc, char **argv)
+int com_help(int fd, int argc, char **argv)
{
struct server_command *cmd;
char *perms, *handler;
if (argc < 2) {
/* no argument given, print list of commands */
- if ((ret = send_list_of_commands(fd, cmd_struct, "server")) < 0)
+ if ((ret = send_list_of_commands(fd, server_cmds, "server")) < 0)
return ret;
mmd_lock();
handler = para_strdup(selectors[mmd->selector_num].name);
}
perms = cmd_perms_itohuman(cmd->perms);
ret = send_va_buffer(fd,
- "NAME\n\t%s - %s\n"
- "SYNOPSIS\n\t para_client %s\n"
- "DESCRIPTION\n%s\n"
- "HANDLER\n"
- "This command is handled by %s.\n\n"
- "PERMISSIONS\n"
- "Needed privileges for %s: %s\n",
+ "%s - %s\n\n"
+ "handler: %s\n"
+ "permissions: %s\n"
+ "usage: %s\n\n"
+ "%s\n",
argv[1],
cmd->description,
- cmd->synopsis,
- cmd->help,
handler,
- argv[1],
- perms
+ perms,
+ cmd->usage,
+ cmd->help
);
free(perms);
free(handler);
}
/* hup */
-static int com_hup(__a_unused int socket_fd, int argc, __a_unused char **argv)
+int com_hup(__a_unused int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
}
/* term */
-static int com_term(__a_unused int socket_fd, int argc, __a_unused char **argv)
+int com_term(__a_unused int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
return 1;
}
-static int com_play(__a_unused int socket_fd, int argc, __a_unused char **argv)
+int com_play(__a_unused int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
mmd_lock();
- mmd->new_afs_status_flags |= AFS_PLAYING;
- mmd->new_afs_status_flags &= ~AFS_NOMORE;
+ mmd->new_vss_status_flags |= VSS_PLAYING;
+ mmd->new_vss_status_flags &= ~VSS_NOMORE;
mmd_unlock();
return 1;
}
/* stop */
-static int com_stop(__a_unused int socket_fd, int argc, __a_unused char **argv)
+int com_stop(__a_unused int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
mmd_lock();
- mmd->new_afs_status_flags &= ~AFS_PLAYING;
- mmd->new_afs_status_flags &= ~AFS_REPOS;
- mmd->new_afs_status_flags |= AFS_NEXT;
+ mmd->new_vss_status_flags &= ~VSS_PLAYING;
+ mmd->new_vss_status_flags &= ~VSS_REPOS;
+ mmd->new_vss_status_flags |= VSS_NEXT;
mmd_unlock();
return 1;
}
/* pause */
-static int com_pause(__a_unused int socket_fd, int argc, __a_unused char **argv)
+int com_pause(__a_unused int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
mmd_lock();
- if (!afs_paused())
+ if (!vss_paused())
mmd->events++;
- mmd->new_afs_status_flags &= ~AFS_PLAYING;
- mmd->new_afs_status_flags &= ~AFS_NEXT;
+ mmd->new_vss_status_flags &= ~VSS_PLAYING;
+ mmd->new_vss_status_flags &= ~VSS_NEXT;
mmd_unlock();
return 1;
}
-static int com_chs(int fd, int argc, char **argv)
+int com_chs(int fd, int argc, char **argv)
{
int i, ret;
}
/* next */
-static int com_next(__a_unused int socket_fd, int argc, __a_unused char **argv)
+int com_next(__a_unused int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
mmd_lock();
mmd->events++;
- mmd->new_afs_status_flags |= AFS_NEXT;
+ mmd->new_vss_status_flags |= VSS_NEXT;
mmd_unlock();
return 1;
}
/* nomore */
-static int com_nomore(__a_unused int socket_fd, int argc, __a_unused char **argv)
+int com_nomore(__a_unused int socket_fd, int argc, __a_unused char **argv)
{
if (argc != 1)
return -E_COMMAND_SYNTAX;
mmd_lock();
- if (afs_playing() || afs_paused())
- mmd->new_afs_status_flags |= AFS_NOMORE;
+ if (vss_playing() || vss_paused())
+ mmd->new_vss_status_flags |= VSS_NOMORE;
mmd_unlock();
return 1;
}
/* ff */
-static int com_ff(__a_unused int socket_fd, int argc, char **argv)
+int com_ff(__a_unused int socket_fd, int argc, char **argv)
{
long promille;
int ret, backwards = 0;
if (promille < 0)
promille = 0;
if (promille > 1000) {
- mmd->new_afs_status_flags |= AFS_NEXT;
+ mmd->new_vss_status_flags |= VSS_NEXT;
goto out;
}
mmd->repos_request = (mmd->chunks_total * promille) / 1000;
- mmd->new_afs_status_flags |= AFS_REPOS;
- mmd->new_afs_status_flags &= ~AFS_NEXT;
+ mmd->new_vss_status_flags |= VSS_REPOS;
+ mmd->new_vss_status_flags &= ~VSS_NEXT;
mmd->events++;
ret = 1;
out:
}
/* jmp */
-static int com_jmp(__a_unused int socket_fd, int argc, char **argv)
+int com_jmp(__a_unused int socket_fd, int argc, char **argv)
{
long unsigned int i;
int ret;
mmd->repos_request = (mmd->chunks_total * i + 50)/ 100;
PARA_INFO_LOG("sent: %lu, offset before jmp: %lu\n",
mmd->chunks_sent, mmd->offset);
- mmd->new_afs_status_flags |= AFS_REPOS;
- mmd->new_afs_status_flags &= ~AFS_NEXT;
+ mmd->new_vss_status_flags |= VSS_REPOS;
+ mmd->new_vss_status_flags &= ~VSS_NEXT;
ret = 1;
mmd->events++;
out:
return get_cmd_ptr(buf, NULL);
}
-long int para_rand(long unsigned max)
+static long int para_rand(long unsigned max)
{
return (long int) ((max + 0.0) * (random() / (RAND_MAX + 1.0)));
}
RC4(&rc4_send_key, len, indata, outdata);
}
+/**
+ * perform user authentication and execute a command
+ *
+ * \param fd the file descriptor to send output to
+ * \param addr socket address info of peer
+ *
+ * \return EXIT_SUCCESS or EXIT_FAILURE
+ *
+ * Whenever para_server accepts an incoming tcp connection on
+ * the port it listens on, it forks and the resulting child
+ * calls this function.
+ *
+ * An RSA-based challenge/response is used to authenticate
+ * the peer. It that authentication succeeds, a random RC4
+ * session key is generated and sent back to the peer,
+ * encrypted with its RSA public key. From this point on,
+ * all transfers are crypted with this session key.
+ *
+ * Next it is checked if the peer supplied a valid server
+ * command or a command for the audio file selector currently
+ * in use. If yes, and if the user has sufficient
+ * permissions to execute that command, the function calls
+ * the corresponding command handler which does argument
+ * checking and further processing.
+ *
+ * In order to cope with a DOS attacks, a timeout is set up
+ * which terminates the function if the connection was not
+ * authenticated when the timeout expires.
+ *
+ * \sa alarm(2), rc4(3), crypt.c, crypt.h
+ */
int handle_connect(int fd, struct sockaddr_in *addr)
{
int numbytes, ret, argc, use_rc4 = 0;
signal(SIGHUP, SIG_DFL);
signal(SIGUSR1, SIG_IGN);
- in_addr = addr;
challenge_nr = random();
/* send Welcome message */
ret = send_va_buffer(fd, "This is para_server, version "
use_rc4? "rc4" : "auth", u.name);
if ((ret = lookup_user(&u)) < 0)
goto err_out;
- if (!ret) { /* user not found */
- PARA_WARNING_LOG("auth request for unknown user %s\n", u.name);
- ret = -E_BAD_USER;
- goto err_out;
- }
ret = para_encrypt_challenge(u.rsa, challenge_nr, crypt_buf);
if (ret <= 0)
goto err_out;