source: roaraudio/roarclients/roarmonhttp.c @ 5961:06e7fd9e4c25

Last change on this file since 5961:06e7fd9e4c25 was 5961:06e7fd9e4c25, checked in by phi, 10 years ago

Updates of copyright and license headers

File size: 9.8 KB
Line 
1//roarmonhttp.c:
2
3/*
4 *      Copyright (C) Philipp 'ph3-der-loewe' Schafft - 2008-2014
5 *
6 *  This file is part of roarclients a part of RoarAudio,
7 *  a cross-platform sound system for both, home and professional use.
8 *  See README for details.
9 *
10 *  This file is free software; you can redistribute it and/or modify
11 *  it under the terms of the GNU General Public License version 3
12 *  as published by the Free Software Foundation.
13 *
14 *  RoarAudio is distributed in the hope that it will be useful,
15 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
16 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17 *  GNU General Public License for more details.
18 *
19 *  You should have received a copy of the GNU General Public License
20 *  along with this software; see the file COPYING.  If not, write to
21 *  the Free Software Foundation, 51 Franklin Street, Fifth Floor,
22 *  Boston, MA 02110-1301, USA.
23 *
24 */
25
26/* ckport options:
27 * ckport: ignore-symbol: alarm of target win32
28 *           checked by configure. Needed to clear timeout some small HTTPds implement
29 *           to avoid problems with bad CGI scripts.
30 */
31
32#include <roaraudio.h>
33
34#if defined(ROAR_HAVE_SETENV) || defined(ROAR_HAVE_PUTENV)
35#define _CAN_SET_ENV
36#endif
37
38#define BUFSIZE 1024
39
40void usage (void) {
41 printf("roarmonhttp [OPTIONS]...\n");
42
43 printf("\nOptions:\n\n");
44
45 printf("  --server    SERVER    - Set server hostname\n"
46        "  --rate  -R  RATE      - Set sample rate\n"
47        "  --bits  -B  BITS      - Set bits per sample\n"
48        "  --chans -C  CHANNELS  - Set number of channels\n"
49        "  --codec -E  CODEC     - Set the codec\n"
50        "  --aiprofile PROFILE   - Set audio profile\n"
51        "  --rel-id ID           - Set ID of relative stream\n"
52        "  --inetd               - Start in inetd mode (STDIN and STDOUT connected to socket)\n"
53        "  --help                - Show this help\n"
54       );
55
56}
57
58void print_header (int codec, int rate, int channels) {
59 const char * mime;
60
61 mime = roar_codec2mime(codec);
62
63 if ( mime == NULL )
64  mime = "application/octet-stream";
65
66 printf("Content-type: %s\r\n", mime);
67 printf("ice-audio-info: ice-samplerate=%i;ice-channels=%i\r\n", rate, channels);
68 printf("icy-pub:0\r\n");
69 printf("Server: RoarAudio (roarmonhttp $Revision$)\r\n");
70 printf("\r\n");
71
72 fflush(stdout);
73}
74
75int stream (struct roar_vio_calls * dest, struct roar_vio_calls * src) {
76 struct roar_vio_select vios[2];
77 struct roar_buffer *ring = NULL, *cur;
78 ssize_t len;
79 size_t  todo;
80 int alive = 1;
81 void * data;
82 int ret;
83
84 if ( roar_vio_nonblock(src,  ROAR_SOCKET_NONBLOCK) == -1 ) {
85  ROAR_WARN("stream(dest=%p, src=%p): Can not set source stream non-blocking: %s",
86            dest, src, roar_error2str(roar_error));
87 }
88 if ( roar_vio_nonblock(dest, ROAR_SOCKET_NONBLOCK) == -1 ) {
89  ROAR_WARN("stream(dest=%p, src=%p): Can not set destination stream non-blocking: %s",
90            dest, src, roar_error2str(roar_error));
91 }
92
93 ROAR_VIO_SELECT_SETVIO(&(vios[0]), src,  ROAR_VIO_SELECT_READ);
94 ROAR_VIO_SELECT_SETVIO(&(vios[1]), dest, ROAR_VIO_SELECT_WRITE);
95
96 while (alive) {
97  ret = roar_vio_select(vios, ring != NULL ? 2 : 1, NULL, NULL);
98  if ( ret == -1 ) {
99   alive = 0;
100  } else if ( ret == 0 ) {
101   // nothing happend.
102  } else {
103   if ( vios[0].eventsa & ROAR_VIO_SELECT_READ ) { // we can read!
104    if ( roar_buffer_new_data(&cur, BUFSIZE, &data) == -1 )
105     return -1;
106
107    len = roar_vio_read(src, data, BUFSIZE);
108
109    switch (len) {
110     case  0:
111     case -1:
112       roar_buffer_free(cur);
113       cur = NULL;
114
115       if ( ring != NULL )
116        roar_buffer_free(ring);
117
118       ring = NULL;
119
120       return -1;
121      break;
122    }
123
124    if ( cur != NULL ) {
125     if ( roar_buffer_set_len(cur, len) == -1 )
126      return -1;
127
128     if ( ring == NULL ) {
129      ring = cur;
130     } else {
131      if ( roar_buffer_moveinto(ring, &cur) == -1 ) {
132       ROAR_ERR("stream(dest=%p, src=%p): Can not append buffer to ring: %s",
133                dest, src, roar_error2str(roar_error));
134       roar_buffer_free(ring);
135       roar_buffer_free(cur);
136       return -1;
137      }
138     }
139    }
140   } else if ( (vios[1].eventsa & ROAR_VIO_SELECT_WRITE) && ring != NULL ) { // we can write!
141    if ( roar_buffer_get_data(ring, &data) == -1 )
142     return -1;
143
144    if ( roar_buffer_get_len(ring, &todo) == -1 )
145     return -1;
146
147    len = roar_vio_write(dest, data, todo);
148
149    if ( len < 1 ) {
150     if ( roar_error != ROAR_ERROR_AGAIN ) {
151      roar_buffer_free(ring);
152      return -1;
153     }
154    }
155
156    if ( (ssize_t)todo == len ) { // we wrote all of the pkg
157     if ( roar_buffer_next(&ring) == -1 )
158      return -1;
159    } else {
160     if ( roar_buffer_set_offset(ring, len) == -1 )
161      return -1;
162    }
163
164   }
165  }
166 }
167
168 return 0;
169}
170
171#ifdef _CAN_SET_ENV
172int parse_http (int * gopher) {
173 struct roar_keyval kv;
174 char buf[1024];
175 char * qs = buf, *str;
176 ssize_t len;
177 int dir = ROAR_DIR_MONITOR;
178
179 if ( (len = read(ROAR_STDIN, buf, 1023)) == -1 )
180  return -1;
181
182 buf[len] = 0;
183
184 if ( strncmp(buf, "GET /", 5) ) {
185  if ( strncmp(buf, "SOURCE /", 8) ) {
186   if ( buf[0] != '/' ) {
187    return -1;
188   } else {
189    *gopher = 1;
190   }
191  } else {
192   dir = ROAR_DIR_PLAY;
193   qs += 3;
194  }
195 }
196
197 if ( !*gopher ) {
198  qs += 5;
199
200  if ( (str = strstr(qs, " ")) == NULL )
201   return -1;
202
203  *str = 0;
204 } else {
205  if ( (str = strstr(qs, "\r")) != NULL )
206   *str = 0;
207  if ( (str = strstr(qs, "\n")) != NULL )
208   *str = 0;
209 }
210
211 for (; *qs != '?'; qs++)
212  if ( !*qs )
213   break;
214
215 if ( *qs == '?' )
216  qs++;
217
218 if ( !*gopher )
219  printf("HTTP/1.0 200 OK\r\n");
220// printf("QS: %s\r\n", qs);
221
222 fflush(stdout);
223
224 kv.key   = "QUERY_STRING";
225 kv.value = qs;
226
227 roar_env_set(&kv);
228
229 return dir;
230}
231#endif
232
233int main (int argc, char * argv[]) {
234 struct roar_audio_info info;
235 int    rel_id   = -1;
236 int    sflags   = ROAR_FLAG_NONE;
237// int    codec    = ROAR_CODEC_DEFAULT;
238 const char * server   = NULL;
239 int    i;
240 const char * k, * v;
241 const char * qs;
242 char * qs_buf;
243 char * c;
244 char * sp0 = NULL, * sp1 = NULL;
245 int dir = ROAR_DIR_MONITOR;
246 int gopher = 0;
247 struct roar_connection    con;
248 struct roar_stream        s;
249 struct roar_vio_calls   * vio;
250
251#ifdef ROAR_HAVE_ALARM
252 alarm(0); // reset alarm timers from httpd
253#endif
254
255 if ( roar_profile2info(&info, "default") == -1 )
256  return 1;
257
258 info.codec = ROAR_CODEC_OGG_VORBIS;
259
260 for (i = 1; i < argc; i++) {
261  k = argv[i];
262  if ( !strcmp(k, "--inetd") ) {
263#ifdef _CAN_SET_ENV
264   if ( (dir = parse_http(&gopher)) == -1 )
265    return 1;
266#else
267   return 1;
268#endif
269  } else if ( !strcmp(k, "--server") ) {
270   ROAR_CKHAVEARGS(1);
271   roar_libroar_set_server(argv[++i]);
272  } else if ( !strcmp(k, "--codec") || !strcmp(k, "-E") ) {
273   ROAR_CKHAVEARGS(1);
274   info.codec = roar_str2codec(argv[++i]);
275  } else if ( !strcmp(k, "--rate") || !strcmp(k, "-r") || !strcmp(k, "-R") ) {
276   ROAR_CKHAVEARGS(1);
277   info.rate = roar_str2rate(argv[++i]);
278  } else if ( !strcmp(k, "--bits") || !strcmp(k, "-B") ) {
279   ROAR_CKHAVEARGS(1);
280   info.bits = roar_str2bits(argv[++i]);
281  } else if ( !strcmp(k, "--channels") || !strcmp(k, "--chans") || !strcmp(k, "-C") ) {
282   ROAR_CKHAVEARGS(1);
283   info.channels = roar_str2channels(argv[++i]);
284  } else if ( !strcmp(k, "--aiprofile") ) {
285   ROAR_CKHAVEARGS(1);
286   if ( roar_profile2info(&info, argv[++i]) == -1 ) {
287    fprintf(stderr, "Error: Can not load audio profile: %s: %s\n", argv[i], roar_error2str(roar_error));
288    return 1;
289   }
290  } else if ( !strcmp(k, "--rel-id") ) {
291   ROAR_CKHAVEARGS(1);
292   rel_id = atoi(argv[++i]);
293  } else if ( !strcmp(k, "--help") && !strcmp(k, "-h") ) {
294   usage();
295   return 0;
296  } else {
297   ROAR_ERR("Unknown parameter: %s", k);
298   usage();
299   return 1;
300  }
301 }
302
303 qs = roar_env_get("QUERY_STRING");
304 if ( qs == NULL )
305  qs = "";
306 c = qs_buf = roar_mm_strdup(qs);
307 if ( c == NULL )
308  return 1;
309
310 c = roar_mm_strtok_r(c, "&", &sp0);
311
312 while (c != NULL) {
313  k = roar_mm_strtok_r(c,    "=", &sp1);
314  v = roar_mm_strtok_r(NULL, "=", &sp1);
315
316  if ( !strcmp(k, "codec") ) {
317   if ( (info.codec = roar_str2codec(v)) == ROAR_AUDIO_INFO_INVALID )
318    return 1;
319  } else if ( !strcmp(k, "channels") ) {
320   info.channels = roar_str2channels(v);
321  } else if ( !strcmp(k, "rate") ) {
322   info.rate = roar_str2rate(v);
323  } else if ( !strcmp(k, "bits") ) {
324   info.bits = roar_str2bits(v);
325  } else if ( !strcmp(k, "aiprofile") ) {
326   if ( roar_profile2info(&info, v) == -1 )
327    return 1;
328  } else if ( !strcmp(k, "rel-id") || !strcmp(k, "relid") ) {
329   rel_id = atoi(v);
330  } else if ( !strcmp(k, "set-flag") ) {
331   if ( !strcmp(v, "meta") ) {
332    sflags |= ROAR_FLAG_META;
333   } else if ( !strcmp(v, "cleanmeta") ) {
334    sflags |= ROAR_FLAG_CLEANMETA;
335   } else if ( !strcmp(v, "prethru") ) {
336    sflags |= ROAR_FLAG_PRETHRU;
337   } else {
338    return 1;
339   }
340  } else if ( !strcmp(k, "dir") ) {
341   if ( (dir = roar_str2dir(v)) == -1 )
342    return 1;
343  } else {
344   return 1;
345  }
346
347  c = roar_mm_strtok_r(NULL, "&", &sp0);
348 }
349
350 roar_mm_free(qs_buf);
351
352 if ( roar_simple_connect(&con, server, "roarmonhttp") == -1 ) {
353  return 10;
354 }
355
356 if ( roar_stream_new_by_info(&s, &info) == -1 ) {
357  roar_disconnect(&con);
358  return 20;
359 }
360
361 if ( rel_id != -1 ) {
362  if ( roar_stream_set_rel_id(&s, rel_id) ) {
363   roar_disconnect(&con);
364   return 21;
365  }
366 }
367
368 if ( roar_stream_connect(&con, &s, dir, -1) == -1 ) {
369  roar_disconnect(&con);
370  return 11;
371 }
372
373 if ( sflags != ROAR_FLAG_NONE ) {
374  if ( roar_stream_set_flags(&con, &s, sflags, ROAR_SET_FLAG) == -1 ) {
375   roar_disconnect(&con);
376   return 14;
377  }
378 }
379
380 if ( roar_stream_exec(&con, &s) == -1 ) {
381  roar_disconnect(&con);
382  return 12;
383 }
384
385 if ( (vio = roar_get_connection_vio2(&con)) == NULL )
386  return 1;
387
388 if ( !gopher )
389  print_header(info.codec, info.rate, info.channels);
390
391/*
392 while((i = read(fh, buf, BUFSIZE)))
393  if (write(out, buf, i) != i)
394   break;
395*/
396
397 switch (dir) {
398  case ROAR_DIR_PLAY:
399    stream(vio, roar_stdin);
400   break;
401  case ROAR_DIR_MONITOR:
402  case ROAR_DIR_THRU:
403    stream(roar_stdout, vio);
404   break;
405 }
406
407 roar_vio_close(vio);
408
409 return 0;
410}
411
412//ll
Note: See TracBrowser for help on using the repository browser.