1
0
mirror of https://gitlab.xiph.org/xiph/ezstream.git synced 2024-12-04 14:46:31 -05:00
ezstream/src/ezstream.c

357 lines
8.4 KiB
C
Raw Normal View History

/* example.c: Demonstration of the libshout API. */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <shout/shout.h>
#include <getopt.h>
#include "configfile.h"
EZCONFIG *pezConfig = NULL;
typedef struct tag_ID3Tag {
char tag[3];
char trackName[30];
char artistName[30];
char albumName[30];
char year[3];
char comment[30];
char genre;
} ID3Tag;
void usage() {
fprintf(stdout, "usage: ezstream -h -c ezstream.xml\n");
fprintf(stdout, "where :\n");
fprintf(stdout, " -h = display this help\n");
fprintf(stdout, " -c = ezstream config file\n");
exit(1);
}
int strrcmp(char *s, char *sub)
{
int slen = strlen(s);
int sublen = strlen(sub);
if (sublen > slen) {
return 1;
}
return memcmp(s + slen - sublen, sub, sublen);
}
int urlParse(char *url, char *hostname, int *port, char *mountname)
{
char *p1;
char *p2;
char *p3;
char tmpPort[25] = "";
if (strncmp(url, "http://", strlen("http://"))) {
printf("Invalid URL, must be of the form http://server:port/mountpoint\n");
return 0;
}
p1 = url + strlen("http://");
p2 = strchr(p1, ':');
if (!p2) {
printf("Invalid URL, must be of the form http://server:port/mountpoint\n");
return 0;
}
strncpy(hostname, p1, p2-p1);
p2++;
p3 = strchr(p2, '/');
if (!p3) {
printf("Invalid URL, must be of the form http://server:port/mountpoint\n");
return 0;
}
memset(tmpPort, '\000', sizeof(tmpPort));
strncpy(tmpPort, p2, p3-p2);
*port = atoi(tmpPort);
strcpy(mountname, p3);
return 1;
}
int streamFile(shout_t *shout, char *fileName) {
FILE *filepstream = NULL;
char buff[4096];
long read, ret, total;
ID3Tag id3tag;
printf("Streaming %s\n", fileName);
if (!strcmp(pezConfig->fileName, "stdin")) {
filepstream = stdin;
}
else {
filepstream = fopen(fileName, "rb");
}
if (!filepstream) {
printf("Cannot open %s\n", fileName);
return 0;
}
if (pezConfig->format == MP3_FORMAT) {
/* Look for the ID3 tag */
memset(&id3tag, '\000', sizeof(id3tag));
fseek(filepstream, -128L, SEEK_END);
fread(&id3tag, 1, sizeof(id3tag), filepstream);
if (!strncmp(id3tag.tag, "TAG", strlen("TAG"))) {
/* We have an Id3 tag */
shout_metadata_t *pmetadata = shout_metadata_new();
char songInfo[135] = "";
sprintf(songInfo, "%s - %s", id3tag.artistName, id3tag.trackName);
shout_metadata_add(pmetadata, "song", songInfo);
shout_set_metadata(shout, pmetadata);
shout_metadata_free(pmetadata);
}
rewind(filepstream);
}
total = 0;
while (!feof(filepstream)) {
read = fread(buff, 1, sizeof(buff), filepstream);
total = total + read;
if (read > 0) {
ret = shout_send(shout, buff, read);
if (ret != SHOUTERR_SUCCESS) {
printf("DEBUG: Send error: %s\n", shout_get_error(shout));
break;
}
shout_delay(shout);
} else {
break;
}
shout_sync(shout);
}
fclose(filepstream);
filepstream = NULL;
return 1;
}
int streamPlaylist(shout_t *shout, char *fileName) {
FILE *filep = NULL;
char streamFileName[8096] = "";
int loop = 1;
filep = fopen(fileName, "r");
if (filep == 0) {
printf("Cannot open %s\n", fileName);
return(0);
}
while (loop) {
while (!feof(filep)) {
memset(streamFileName, '\000', sizeof(streamFileName));
fgets(streamFileName, sizeof(streamFileName), filep);
streamFileName[strlen(streamFileName)-1] = '\000';
if (strlen(streamFileName) > 0) {
/* Skip entries that begin with a # */
if (strncmp(streamFileName, "#", 1)) {
streamFile(shout, streamFileName);
}
}
}
rewind(filep);
}
return(1);
}
int main(int argc, char **argv)
{
char c;
char *configFile = NULL;
char *host = NULL;
int port = 0;
char *mount = NULL;
shout_t *shout;
pezConfig = getEZConfig();
shout_init();
while ((c = getopt(argc, argv, "hc:")) != -1) {
switch (c) {
case 'c':
configFile = optarg;
break;
case 'h':
usage();
break;
default:
break;
}
}
if (!configFile) {
printf("You must supply a config file\n");
usage();
}
else {
parseConfig(configFile);
}
if (pezConfig->URL) {
host = (char *)malloc(strlen(pezConfig->URL) +1);
memset(host, '\000', strlen(pezConfig->URL) +1);
mount = (char *)malloc(strlen(pezConfig->URL) +1);
memset(mount, '\000', strlen(pezConfig->URL) +1);
if (!urlParse(pezConfig->URL, host, &port, mount)) {
exit(0);
}
}
if ((host == NULL)) {
printf("server is required\n");
usage();
}
if ((port == 0)) {
printf("port is required\n");
usage();
}
if ((pezConfig->password == NULL)) {
printf("-p password is required\n");
usage();
}
if ((mount == NULL)) {
printf("mountpoint is required\n");
usage();
}
if ((pezConfig->fileName == NULL)) {
printf("-f fileName is required\n");
usage();
}
if (pezConfig->format == 0) {
printf("You must specify a format type of MP3 or OGGVORBIS\n");
}
if (!(shout = shout_new())) {
printf("Could not allocate shout_t\n");
return 1;
}
if (shout_set_host(shout, host) != SHOUTERR_SUCCESS) {
printf("Error setting hostname: %s\n", shout_get_error(shout));
return 1;
}
if (shout_set_protocol(shout, SHOUT_PROTOCOL_HTTP) != SHOUTERR_SUCCESS) {
printf("Error setting protocol: %s\n", shout_get_error(shout));
return 1;
}
if (shout_set_port(shout, port) != SHOUTERR_SUCCESS) {
printf("Error setting port: %s\n", shout_get_error(shout));
return 1;
}
if (shout_set_password(shout, pezConfig->password) != SHOUTERR_SUCCESS) {
printf("Error setting password: %s\n", shout_get_error(shout));
return 1;
}
if (shout_set_mount(shout, mount) != SHOUTERR_SUCCESS) {
printf("Error setting mount: %s\n", shout_get_error(shout));
return 1;
}
if (shout_set_user(shout, "source") != SHOUTERR_SUCCESS) {
printf("Error setting user: %s\n", shout_get_error(shout));
return 1;
}
if (pezConfig->format == MP3_FORMAT) {
if (shout_set_format(shout, SHOUT_FORMAT_MP3) != SHOUTERR_SUCCESS) {
printf("Error setting user: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->format == OGGVORBIS_FORMAT) {
if (shout_set_format(shout, SHOUT_FORMAT_VORBIS) != SHOUTERR_SUCCESS) {
printf("Error setting user: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverName) {
if (shout_set_name(shout, pezConfig->serverName) != SHOUTERR_SUCCESS) {
printf("Error setting server name: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverURL) {
if (shout_set_url(shout, pezConfig->serverURL) != SHOUTERR_SUCCESS) {
printf("Error setting server url: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverGenre) {
if (shout_set_genre(shout, pezConfig->serverGenre) != SHOUTERR_SUCCESS) {
printf("Error setting server genre: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverDescription) {
if (shout_set_description(shout, pezConfig->serverDescription) != SHOUTERR_SUCCESS) {
printf("Error setting server description: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverBitrate) {
if (shout_set_audio_info(shout, SHOUT_AI_BITRATE, pezConfig->serverBitrate) != SHOUTERR_SUCCESS) {
printf("Error setting server bitrate: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverChannels) {
if (shout_set_audio_info(shout, SHOUT_AI_CHANNELS, pezConfig->serverChannels) != SHOUTERR_SUCCESS) {
printf("Error setting server channels: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverSamplerate) {
if (shout_set_audio_info(shout, SHOUT_AI_SAMPLERATE, pezConfig->serverSamplerate) != SHOUTERR_SUCCESS) {
printf("Error setting server samplerate: %s\n", shout_get_error(shout));
return 1;
}
}
if (pezConfig->serverQuality) {
if (shout_set_audio_info(shout, SHOUT_AI_QUALITY, pezConfig->serverQuality) != SHOUTERR_SUCCESS) {
printf("Error setting server quality: %s\n", shout_get_error(shout));
return 1;
}
}
if (shout_set_public(shout, pezConfig->serverPublic) != SHOUTERR_SUCCESS) {
printf("Error setting server public flag: %s\n", shout_get_error(shout));
return 1;
}
printf("Connecting to %s...", pezConfig->URL);
if (shout_open(shout) == SHOUTERR_SUCCESS) {
printf("SUCCESS.\n");
while (1) {
if (!strrcmp(pezConfig->fileName, ".m3u")) {
streamPlaylist(shout, pezConfig->fileName);
}
else {
streamFile(shout, pezConfig->fileName);
}
}
} else {
printf("FAILED: %s\n", shout_get_error(shout));
}
shout_close(shout);
shout_shutdown();
if (host) {
free(host);
}
if (mount) {
free(mount);
}
return 0;
}