format_mp3.c 20.3 KB
Newer Older
1
/* -*- c-basic-offset: 4; -*- */
2 3 4 5 6 7 8 9 10 11 12 13
/* Icecast
 *
 * This program is distributed under the GNU General Public License, version 2.
 * A copy of this license is included with this source.
 *
 * Copyright 2000-2004, Jack Moffitt <jack@xiph.org, 
 *                      Michael Smith <msmith@xiph.org>,
 *                      oddsock <oddsock@xiph.org>,
 *                      Karl Heyes <karl@xiph.org>
 *                      and others (see AUTHORS for details).
 */

Michael Smith's avatar
Michael Smith committed
14 15
/* format_mp3.c
**
16
** format plugin for mp3
Michael Smith's avatar
Michael Smith committed
17 18 19
**
*/

20 21 22 23
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

Michael Smith's avatar
Michael Smith committed
24 25 26
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
Karl Heyes's avatar
Karl Heyes committed
27 28 29
#ifdef HAVE_STRINGS_H
# include <strings.h>
#endif
Michael Smith's avatar
Michael Smith committed
30 31

#include "refbuf.h"
32 33
#include "source.h"
#include "client.h"
Michael Smith's avatar
Michael Smith committed
34 35 36

#include "stats.h"
#include "format.h"
37 38 39 40 41 42
#include "httpp/httpp.h"

#include "logging.h"

#include "format_mp3.h"

Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
43 44 45
#ifdef WIN32
#define strcasecmp stricmp
#define strncasecmp strnicmp
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
46
#define snprintf _snprintf
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
47 48
#endif

49 50
#define CATMODULE "format-mp3"

51 52 53
/* Note that this seems to be 8192 in shoutcast - perhaps we want to be the
 * same for compability with crappy clients?
 */
54
#define ICY_METADATA_INTERVAL 16000
Michael Smith's avatar
Michael Smith committed
55

56
static void format_mp3_free_plugin(format_plugin_t *self);
Karl Heyes's avatar
Karl Heyes committed
57 58 59 60
static refbuf_t *mp3_get_filter_meta (source_t *source);
static refbuf_t *mp3_get_no_meta (source_t *source);

static int  format_mp3_create_client_data (source_t *source, client_t *client);
61
static void free_mp3_client_data (client_t *client);
62
static int format_mp3_write_buf_to_client(client_t *client);
Karl Heyes's avatar
Karl Heyes committed
63
static void write_mp3_to_file (struct source_tag *source, refbuf_t *refbuf);
64
static void mp3_set_tag (format_plugin_t *plugin, const char *tag, const char *in_value, const char *charset);
65
static void format_mp3_apply_settings(client_t *client, format_plugin_t *format, mount_proxy *mount);
Karl Heyes's avatar
Karl Heyes committed
66

67 68

typedef struct {
69
   unsigned int interval;
Michael Smith's avatar
Michael Smith committed
70
   int metadata_offset;
Karl Heyes's avatar
Karl Heyes committed
71 72 73
   unsigned int since_meta_block;
   int in_metadata;
   refbuf_t *associated;
74
} mp3_client_data;
Ed "oddsock" Zaleski's avatar
Ed "oddsock" Zaleski committed
75

Karl Heyes's avatar
Karl Heyes committed
76
int format_mp3_get_plugin (source_t *source)
Michael Smith's avatar
Michael Smith committed
77
{
78
    const char *metadata;
79
    format_plugin_t *plugin;
Michael Smith's avatar
Michael Smith committed
80
    mp3_state *state = calloc(1, sizeof(mp3_state));
Karl Heyes's avatar
Karl Heyes committed
81
    refbuf_t *meta;
Michael Smith's avatar
Michael Smith committed
82

83
    plugin = (format_plugin_t *)calloc(1, sizeof(format_plugin_t));
Michael Smith's avatar
Michael Smith committed
84

85
    plugin->type = FORMAT_TYPE_GENERIC;
Karl Heyes's avatar
Karl Heyes committed
86
    plugin->get_buffer = mp3_get_no_meta;
87
    plugin->write_buf_to_client = format_mp3_write_buf_to_client;
Karl Heyes's avatar
Karl Heyes committed
88
    plugin->write_buf_to_file = write_mp3_to_file;
89
    plugin->create_client_data = format_mp3_create_client_data;
90
    plugin->free_plugin = format_mp3_free_plugin;
91
    plugin->set_tag = mp3_set_tag;
92
    plugin->apply_settings = format_mp3_apply_settings;
93 94 95 96 97 98

    plugin->contenttype = httpp_getvar (source->parser, "content-type");
    if (plugin->contenttype == NULL) {
        /* We default to MP3 audio for old clients without content types */
        plugin->contenttype = "audio/mpeg";
    }
Michael Smith's avatar
Michael Smith committed
99

100
    plugin->_state = state;
Michael Smith's avatar
Michael Smith committed
101

102 103
    /* initial metadata needs to be blank for sending to clients and for
       comparing with new metadata */
104 105
    meta = refbuf_new (17);
    memcpy (meta->data, "\001StreamTitle='';", 17);
Karl Heyes's avatar
Karl Heyes committed
106
    state->metadata = meta;
107
    state->interval = -1;
Michael Smith's avatar
Michael Smith committed
108

Karl Heyes's avatar
Karl Heyes committed
109 110 111 112
    metadata = httpp_getvar (source->parser, "icy-metaint");
    if (metadata)
    {
        state->inline_metadata_interval = atoi (metadata);
113 114 115 116
        if (state->inline_metadata_interval > 0)
        {
            state->offset = 0;
            plugin->get_buffer = mp3_get_filter_meta;
117
            state->interval = state->inline_metadata_interval;
118
        }
Karl Heyes's avatar
Karl Heyes committed
119 120 121
    }
    source->format = plugin;
    thread_mutex_create (&state->url_lock);
122

Karl Heyes's avatar
Karl Heyes committed
123
    return 0;
Michael Smith's avatar
Michael Smith committed
124 125
}

126

127
static void mp3_set_tag (format_plugin_t *plugin, const char *tag, const char *in_value, const char *charset)
Michael Smith's avatar
Michael Smith committed
128
{
Karl Heyes's avatar
Karl Heyes committed
129 130 131 132
    mp3_state *source_mp3 = plugin->_state;
    unsigned int len;
    const char meta[] = "StreamTitle='";
    int size = sizeof (meta) + 1;
133
    char *value;
Karl Heyes's avatar
Karl Heyes committed
134

135
    if (tag==NULL || in_value == NULL)
Karl Heyes's avatar
Karl Heyes committed
136 137 138 139
        return;

    /* protect against multiple updaters */
    thread_mutex_lock (&source_mp3->url_lock);
140 141 142 143 144 145 146 147

    value = util_conv_string (in_value, charset, plugin->charset);
    if (value == NULL)
        value = strdup (in_value);

    len = strlen (value)+1;
    size += len;

Karl Heyes's avatar
Karl Heyes committed
148
    if (strcmp (tag, "title") == 0 || strcmp (tag, "song") == 0)
149
    {
150 151 152 153 154
        free (source_mp3->url_title);
        free (source_mp3->url_artist);
        source_mp3->url_artist = NULL;
        source_mp3->url_title = value;
        source_mp3->update_metadata = 1;
Karl Heyes's avatar
Karl Heyes committed
155 156 157
    }
    else if (strcmp (tag, "artist") == 0)
    {
158 159 160
        free (source_mp3->url_artist);
        source_mp3->url_artist = value;
        source_mp3->update_metadata = 1;
Karl Heyes's avatar
Karl Heyes committed
161
    }
162 163
    else
        free (value);
Karl Heyes's avatar
Karl Heyes committed
164 165
    thread_mutex_unlock (&source_mp3->url_lock);
}
166 167


Karl Heyes's avatar
Karl Heyes committed
168 169 170 171 172 173
static void filter_shoutcast_metadata (source_t *source, char *metadata, unsigned int meta_len)
{
    if (metadata)
    {
        char *end, *p;
        int len;
174

Karl Heyes's avatar
Karl Heyes committed
175
        do
176
        {
Karl Heyes's avatar
Karl Heyes committed
177 178 179
            metadata++;
            if (strncmp (metadata, "StreamTitle='", 13))
                break;
Karl Heyes's avatar
Karl Heyes committed
180
            if ((end = strstr (metadata+13, "\';")) == NULL)
Karl Heyes's avatar
Karl Heyes committed
181 182 183 184 185 186
                break;
            len = (end - metadata) - 13;
            p = calloc (1, len+1);
            if (p)
            {
                memcpy (p, metadata+13, len);
187
                logging_playlist (source->mount, p, source->listeners);
188
                stats_event_conv (source->mount, "title", p, source->format->charset);
Karl Heyes's avatar
Karl Heyes committed
189 190 191 192 193 194
                yp_touch (source->mount);
                free (p);
            }
        } while (0);
    }
}
195

Michael Smith's avatar
Michael Smith committed
196

197 198 199 200
static void format_mp3_apply_settings (client_t *client, format_plugin_t *format, mount_proxy *mount)
{
    mp3_state *source_mp3 = format->_state;

201 202 203 204 205 206 207 208 209 210 211 212
    source_mp3->interval = -1;
    free (format->charset);
    format->charset = NULL;

    if (mount)
    {
        if (mount->mp3_meta_interval > 0)
            source_mp3->interval = mount->mp3_meta_interval;
        if (mount->charset)
            format->charset = strdup (mount->charset);
    }
    if (source_mp3->interval <= 0)
213
    {
214
        const char *metadata = httpp_getvar (client->parser, "icy-metaint");
215
        source_mp3->interval = ICY_METADATA_INTERVAL;
216 217 218 219 220 221 222
        if (metadata)
        {
            int interval = atoi (metadata);
            if (interval > 0)
                source_mp3->interval = interval;
        }
    }
223 224 225 226 227 228

    if (format->charset == NULL)
        format->charset = strdup ("ISO8859-1");

    DEBUG1 ("sending metadata interval %d", source_mp3->interval);
    DEBUG1 ("charset %s", format->charset);
229 230 231
}


Karl Heyes's avatar
Karl Heyes committed
232 233 234
/* called from the source thread when the metadata has been updated.
 * The artist title are checked and made ready for clients to send
 */
235
static void mp3_set_title (source_t *source)
Karl Heyes's avatar
Karl Heyes committed
236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262
{
    const char meta[] = "StreamTitle='";
    int size;
    unsigned char len_byte;
    refbuf_t *p;
    unsigned int len = sizeof(meta) + 2; /* the StreamTitle, quotes, ; and null */
    mp3_state *source_mp3 = source->format->_state;

    /* make sure the url data does not disappear from under us */
    thread_mutex_lock (&source_mp3->url_lock);

    /* work out message length */
    if (source_mp3->url_artist)
        len += strlen (source_mp3->url_artist);
    if (source_mp3->url_title)
        len += strlen (source_mp3->url_title);
    if (source_mp3->url_artist && source_mp3->url_title)
        len += 3;
#define MAX_META_LEN 255*16
    if (len > MAX_META_LEN)
    {
        thread_mutex_unlock (&source_mp3->url_lock);
        WARN1 ("Metadata too long at %d chars", len);
        return;
    }
    /* work out the metadata len byte */
    len_byte = (len-1) / 16 + 1;
Michael Smith's avatar
Michael Smith committed
263

Karl Heyes's avatar
Karl Heyes committed
264 265
    /* now we know how much space to allocate, +1 for the len byte */
    size = len_byte * 16 + 1;
Michael Smith's avatar
Michael Smith committed
266

Karl Heyes's avatar
Karl Heyes committed
267 268 269 270
    p = refbuf_new (size);
    if (p)
    {
        mp3_state *source_mp3 = source->format->_state;
Michael Smith's avatar
Michael Smith committed
271

Karl Heyes's avatar
Karl Heyes committed
272 273 274 275 276 277 278 279
        memset (p->data, '\0', size);
        if (source_mp3->url_artist && source_mp3->url_title)
            snprintf (p->data, size, "%c%s%s - %s';", len_byte, meta,
                    source_mp3->url_artist, source_mp3->url_title);
        else
            snprintf (p->data, size, "%c%s%s';", len_byte, meta,
                    source_mp3->url_title);
        filter_shoutcast_metadata (source, p->data, size);
Michael Smith's avatar
Michael Smith committed
280

Karl Heyes's avatar
Karl Heyes committed
281 282 283 284
        refbuf_release (source_mp3->metadata);
        source_mp3->metadata = p;
    }
    thread_mutex_unlock (&source_mp3->url_lock);
Michael Smith's avatar
Michael Smith committed
285 286
}

Karl Heyes's avatar
Karl Heyes committed
287 288 289 290 291 292

/* send the appropriate metadata, and return the number of bytes written
 * which is 0 or greater.  Check the client in_metadata value afterwards
 * to see if all metadata has been sent
 */
static int send_mp3_metadata (client_t *client, refbuf_t *associated)
293
{
294
    int ret = 0;
295
    char *metadata;
Karl Heyes's avatar
Karl Heyes committed
296 297 298 299 300 301
    int meta_len;
    mp3_client_data *client_mp3 = client->format_data;

    /* If there is a change in metadata then send it else
     * send a single zero value byte in its place
     */
302
    if (associated && associated != client_mp3->associated)
Karl Heyes's avatar
Karl Heyes committed
303
    {
304 305
        metadata = associated->data + client_mp3->metadata_offset;
        meta_len = associated->len - client_mp3->metadata_offset;
Karl Heyes's avatar
Karl Heyes committed
306 307 308
    }
    else
    {
309 310 311 312 313 314 315 316 317 318 319
        if (associated)
        {
            metadata = "\0";
            meta_len = 1;
        }
        else
        {
            char *meta = "\001StreamTitle='';";
            metadata = meta + client_mp3->metadata_offset;
            meta_len = 17 - client_mp3->metadata_offset;
        }
Karl Heyes's avatar
Karl Heyes committed
320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343
    }
    ret = client_send_bytes (client, metadata, meta_len);

    if (ret == meta_len)
    {
        client_mp3->associated = associated;
        client_mp3->metadata_offset = 0;
        client_mp3->in_metadata = 0;
        client_mp3->since_meta_block = 0;
        return ret;
    }
    if (ret > 0)
        client_mp3->metadata_offset += ret;
    else
        ret = 0;
    client_mp3->in_metadata = 1;

    return ret;
}


/* Handler for writing mp3 data to a client, taking into account whether
 * client has requested shoutcast style metadata updates
 */
344
static int format_mp3_write_buf_to_client(client_t *client)
Karl Heyes's avatar
Karl Heyes committed
345 346 347 348
{
    int ret, written = 0;
    mp3_client_data *client_mp3 = client->format_data;
    refbuf_t *refbuf = client->refbuf;
Karl Heyes's avatar
Karl Heyes committed
349 350
    char *buf = refbuf->data + client->pos;
    unsigned int len = refbuf->len - client->pos;
Michael Smith's avatar
Michael Smith committed
351

Karl Heyes's avatar
Karl Heyes committed
352 353 354 355 356 357 358
    do
    {
        /* send any unwritten metadata to the client */
        if (client_mp3->in_metadata)
        {
            refbuf_t *associated = refbuf->associated;
            ret = send_mp3_metadata (client, associated);
Michael Smith's avatar
Michael Smith committed
359

Karl Heyes's avatar
Karl Heyes committed
360 361 362
            if (client_mp3->in_metadata)
                break;
            written += ret;
Michael Smith's avatar
Michael Smith committed
363
        }
Karl Heyes's avatar
Karl Heyes committed
364
        /* see if we need to send the current metadata to the client */
365
        if (client_mp3->interval)
Karl Heyes's avatar
Karl Heyes committed
366
        {
367
            unsigned int remaining = client_mp3->interval -
Karl Heyes's avatar
Karl Heyes committed
368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393
                client_mp3->since_meta_block;

            /* sending the metadata block */
            if (remaining <= len)
            {
                /* send any mp3 before the metadata block */
                if (remaining)
                {
                    ret = client_send_bytes (client, buf, remaining);

                    if (ret > 0)
                    {
                        client_mp3->since_meta_block += ret;
                        client->pos += ret;
                    }
                    if (ret < (int)remaining)
                        break;
                    written += ret;
                }
                ret = send_mp3_metadata (client, refbuf->associated);
                if (client_mp3->in_metadata)
                    break;
                written += ret;
                /* change buf and len */
                buf += remaining;
                len -= remaining;
394 395 396
                /* limit how much mp3 we send if using small intervals */
                if (len > client_mp3->interval)
                    len = client_mp3->interval;
Karl Heyes's avatar
Karl Heyes committed
397
            }
398
        }
Karl Heyes's avatar
Karl Heyes committed
399 400 401 402
        /* write any mp3, maybe after the metadata block */
        if (len)
        {
            ret = client_send_bytes (client, buf, len);
403

Karl Heyes's avatar
Karl Heyes committed
404 405 406 407 408 409 410 411 412 413 414
            if (ret > 0)
            {
                client_mp3->since_meta_block += ret;
                client->pos += ret;
            }
            if (ret < (int)len)
                break;
            written += ret;
        }
        ret = 0;
    } while (0);
415

Karl Heyes's avatar
Karl Heyes committed
416 417 418
    if (ret > 0)
        written += ret;
    return written;
419 420 421
}

static void format_mp3_free_plugin(format_plugin_t *self)
Michael Smith's avatar
Michael Smith committed
422
{
423
    /* free the plugin instance */
Michael Smith's avatar
Michael Smith committed
424
    mp3_state *state = self->_state;
Michael Smith's avatar
Michael Smith committed
425

Karl Heyes's avatar
Karl Heyes committed
426 427 428
    thread_mutex_destroy (&state->url_lock);
    free (state->url_artist);
    free (state->url_title);
429
    free (self->charset);
Karl Heyes's avatar
Karl Heyes committed
430
    refbuf_release (state->metadata);
431
    refbuf_release (state->read_data);
Michael Smith's avatar
Michael Smith committed
432
    free(state);
433
    free(self);
Michael Smith's avatar
Michael Smith committed
434 435
}

Karl Heyes's avatar
Karl Heyes committed
436

437 438 439 440 441 442
/* This does the actual reading, making sure the read data is packaged in
 * blocks of 1400 bytes (near the common MTU size). This is because many
 * incoming streams come in small packets which could waste a lot of 
 * bandwidth with many listeners due to headers and such like.
 */
static int complete_read (source_t *source)
Michael Smith's avatar
Michael Smith committed
443
{
Karl Heyes's avatar
Karl Heyes committed
444
    int bytes;
445
    format_plugin_t *format = source->format;
446 447 448
    mp3_state *source_mp3 = format->_state;
    char *buf;
    refbuf_t *refbuf;
449

450 451 452 453 454 455 456 457
#define REFBUF_SIZE 1400

    if (source_mp3->read_data == NULL)
    {
        source_mp3->read_data = refbuf_new (REFBUF_SIZE); 
        source_mp3->read_count = 0;
    }
    buf = source_mp3->read_data->data + source_mp3->read_count;
458

459
    bytes = client_read_bytes (source->client, buf, REFBUF_SIZE-source_mp3->read_count);
460
    if (bytes < 0)
Karl Heyes's avatar
Karl Heyes committed
461
    {
462 463 464 465 466 467
        if (source->client->con->error)
        {
            refbuf_release (source_mp3->read_data);
            source_mp3->read_data = NULL;
        }
        return 0;
Karl Heyes's avatar
Karl Heyes committed
468
    }
469 470 471
    source_mp3->read_count += bytes;
    refbuf = source_mp3->read_data;
    refbuf->len = source_mp3->read_count;
472
    format->read_bytes += bytes;
473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498

    if (source_mp3->read_count < REFBUF_SIZE)
    {
        if (source_mp3->read_count == 0)
        {
            refbuf_release (source_mp3->read_data);
            source_mp3->read_data = NULL;
        }
        return 0;
    }
    return 1;
}


/* read an mp3 stream which does not have shoutcast style metadata */
static refbuf_t *mp3_get_no_meta (source_t *source)
{
    refbuf_t *refbuf;
    mp3_state *source_mp3 = source->format->_state;

    if (complete_read (source) == 0)
        return NULL;

    refbuf = source_mp3->read_data;
    source_mp3->read_data = NULL;

Karl Heyes's avatar
Karl Heyes committed
499 500 501 502 503
    if (source_mp3->update_metadata)
    {
        mp3_set_title (source);
        source_mp3->update_metadata = 0;
    }
504 505 506 507
    refbuf->associated = source_mp3->metadata;
    refbuf_addref (source_mp3->metadata);
    refbuf->sync_point = 1;
    return refbuf;
Karl Heyes's avatar
Karl Heyes committed
508
}
509 510


Karl Heyes's avatar
Karl Heyes committed
511 512 513 514 515 516 517 518 519 520 521
/* read mp3 data with inlined metadata from the source. Filter out the
 * metadata so that the mp3 data itself is store on the queue and the
 * metadata is is associated with it
 */
static refbuf_t *mp3_get_filter_meta (source_t *source)
{
    refbuf_t *refbuf;
    format_plugin_t *plugin = source->format;
    mp3_state *source_mp3 = plugin->_state;
    unsigned char *src;
    unsigned int bytes, mp3_block;
522

523 524 525 526 527
    if (complete_read (source) == 0)
        return NULL;

    refbuf = source_mp3->read_data;
    source_mp3->read_data = NULL;
528
    src = (unsigned char *)refbuf->data;
529

Karl Heyes's avatar
Karl Heyes committed
530 531 532 533 534 535
    if (source_mp3->update_metadata)
    {
        mp3_set_title (source);
        source_mp3->update_metadata = 0;
    }
    /* fill the buffer with the read data */
536
    bytes = source_mp3->read_count;
Karl Heyes's avatar
Karl Heyes committed
537 538 539 540
    refbuf->len = 0;
    while (bytes > 0)
    {
        unsigned int metadata_remaining;
541

Karl Heyes's avatar
Karl Heyes committed
542
        mp3_block = source_mp3->inline_metadata_interval - source_mp3->offset;
543

Karl Heyes's avatar
Karl Heyes committed
544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560
        /* is there only enough to account for mp3 data */
        if (bytes <= mp3_block)
        {
            refbuf->len += bytes;
            source_mp3->offset += bytes;
            break;
        }
        /* we have enough data to get to the metadata
         * block, but only transfer upto it */
        if (mp3_block)
        {
            src += mp3_block;
            bytes -= mp3_block;
            refbuf->len += mp3_block;
            source_mp3->offset += mp3_block;
            continue;
        }
561

Karl Heyes's avatar
Karl Heyes committed
562 563 564 565 566 567 568 569
        /* process the inline metadata, len == 0 indicates not seen any yet */
        if (source_mp3->build_metadata_len == 0)
        {
            memset (source_mp3->build_metadata, 0,
                    sizeof (source_mp3->build_metadata));
            source_mp3->build_metadata_offset = 0;
            source_mp3->build_metadata_len = 1 + (*src * 16);
        }
570

Karl Heyes's avatar
Karl Heyes committed
571 572 573 574 575 576 577 578 579 580 581 582 583 584
        /* do we have all of the metatdata block */
        metadata_remaining = source_mp3->build_metadata_len -
            source_mp3->build_metadata_offset;
        if (bytes < metadata_remaining)
        {
            memcpy (source_mp3->build_metadata +
                    source_mp3->build_metadata_offset, src, bytes);
            source_mp3->build_metadata_offset += bytes;
            break;
        }
        /* copy all bytes except the last one, that way we 
         * know a null byte terminates the message */
        memcpy (source_mp3->build_metadata + source_mp3->build_metadata_offset,
                src, metadata_remaining-1);
585

Karl Heyes's avatar
Karl Heyes committed
586 587 588
        /* overwrite metadata in the buffer */
        bytes -= metadata_remaining;
        memmove (src, src+metadata_remaining, bytes);
589

590 591 592
        /* assign metadata if it's greater than 1 byte, and the text has changed */
        if (source_mp3->build_metadata_len > 1 &&
                strcmp (source_mp3->build_metadata+1, source_mp3->metadata->data+1) != 0)
Karl Heyes's avatar
Karl Heyes committed
593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610
        {
            refbuf_t *meta = refbuf_new (source_mp3->build_metadata_len);
            memcpy (meta->data, source_mp3->build_metadata,
                    source_mp3->build_metadata_len);

            DEBUG1("shoutcast metadata %.4080s", meta->data+1);
            if (strncmp (meta->data+1, "StreamTitle=", 12) == 0)
            {
                filter_shoutcast_metadata (source, source_mp3->build_metadata,
                        source_mp3->build_metadata_len);
                refbuf_release (source_mp3->metadata);
                source_mp3->metadata = meta;
            }
            else
            {
                ERROR0 ("Incorrect metadata format, ending stream");
                source->running = 0;
                refbuf_release (refbuf);
611
                refbuf_release (meta);
Karl Heyes's avatar
Karl Heyes committed
612
                return NULL;
613 614
            }
        }
Karl Heyes's avatar
Karl Heyes committed
615 616
        source_mp3->offset = 0;
        source_mp3->build_metadata_len = 0;
617
    }
Karl Heyes's avatar
Karl Heyes committed
618 619 620 621 622
    /* the data we have just read may of just been metadata */
    if (refbuf->len == 0)
    {
        refbuf_release (refbuf);
        return NULL;
623
    }
Karl Heyes's avatar
Karl Heyes committed
624 625
    refbuf->associated = source_mp3->metadata;
    refbuf_addref (source_mp3->metadata);
626
    refbuf->sync_point = 1;
Michael Smith's avatar
Michael Smith committed
627

Karl Heyes's avatar
Karl Heyes committed
628
    return refbuf;
Michael Smith's avatar
Michael Smith committed
629 630
}

Karl Heyes's avatar
Karl Heyes committed
631 632

static int format_mp3_create_client_data(source_t *source, client_t *client)
633
{
634 635
    mp3_client_data *client_mp3 = calloc(1,sizeof(mp3_client_data));
    mp3_state *source_mp3 = source->format->_state;
636 637 638 639 640
    const char *metadata; 
    /* the +-2 is for overwriting the last set of \r\n */
    unsigned remaining = 4096 - client->refbuf->len + 2;
    char *ptr = client->refbuf->data + client->refbuf->len - 2;
    int bytes;
641

642
    if (client_mp3 == NULL)
Karl Heyes's avatar
Karl Heyes committed
643
        return -1;
644

645 646 647 648 649 650 651 652
    /* hack for flash player, it wants a length */
    if (httpp_getvar(client->parser, "x-flash-version"))
    {
        bytes = snprintf (ptr, remaining, "Content-Length: 347122319\r\n");
        remaining -= bytes;
        ptr += bytes;
    }

653
    client->format_data = client_mp3;
Karl Heyes's avatar
Karl Heyes committed
654
    client->free_client_data = free_mp3_client_data;
655
    metadata = httpp_getvar(client->parser, "icy-metadata");
656 657
    if (metadata && atoi(metadata))
    {
658
        if (source_mp3->interval >= 0)
659 660 661
            client_mp3->interval = source_mp3->interval;
        else
            client_mp3->interval = ICY_METADATA_INTERVAL;
662
        if (client_mp3->interval)
663
        {
664 665 666 667 668 669 670
            bytes = snprintf (ptr, remaining, "icy-metaint:%u\r\n",
                    client_mp3->interval);
            if (bytes > 0)
            {
                remaining -= bytes;
                ptr += bytes;
            }
671
        }
672
    }
673 674 675
    bytes = snprintf (ptr, remaining, "\r\n");
    remaining -= bytes;
    ptr += bytes;
676

677
    client->refbuf->len = 4096 - remaining;
678

Karl Heyes's avatar
Karl Heyes committed
679
    return 0;
680
}
Michael Smith's avatar
Michael Smith committed
681

682 683 684 685 686 687 688 689

static void free_mp3_client_data (client_t *client)
{
    free (client->format_data);
    client->format_data = NULL;
}


Karl Heyes's avatar
Karl Heyes committed
690 691 692 693 694 695 696 697 698 699 700 701
static void write_mp3_to_file (struct source_tag *source, refbuf_t *refbuf)
{
    if (refbuf->len == 0)
        return;
    if (fwrite (refbuf->data, 1, refbuf->len, source->dumpfile) < (size_t)refbuf->len)
    {
        WARN0 ("Write to dump file failed, disabling");
        fclose (source->dumpfile);
        source->dumpfile = NULL;
    }
}