icecast integration

Did you have any luck with this? I have the same need and am willing to cooperate on working on this.

First ideas:
- create a module that makes playlists (files or sql table), which ices reads. The thing is that I don't know how often ices reads (every song or every time through the list)
- write an ices-php handler (yah, jsut a little bit of work) and then write a module with a php script (/scripts) for connecting a module to it.

No more blahblahblah from me just yet.
James

I'm back on the case here:

I'm going to look at ices and ices2 for integration. I'd like to use ices2 as well, however mp3s are likely preferred by the commnity, and there's no way we're going to want to support this thing by ourselves.

I think that the multiple streams request sounds complicated and is likely best left to a second stage; the first stage should be getting drupal and a streamer to coordinate, likely through creation of playlists by drupal for ices.

I'll read the api better, because what might be best for ices2 is to have a pythin script be in charge of the ices playlist side of things, then it can update whenever necessary, maybe parsing a drupal rss feed for songs. It's been a while since I looked at this (and drupal itself) so I'll report later on the absurdity of this.

J

hey this may no be exactly what you had in mind, but i´m running drupal with a modified station module. using mpd as a backend to provide playlists and stream audio in ogg-vorbis to an icecast2 server. plus a patch to the station module which provides a form field for the streaming url for the station particular station. it also requieres the addition of a row called "stream" to the station_program table. so basically users can stream in the server they chose, but they publish the url of their stream when the publish their program. the python script gets called everyhour and it loads the url programed for that hour in mpd. mpd takes care of the streaming to icecast. archiving and all that is still done by the station.module in the normal way.

patch for station.program.module:

--- modules/station/program/station_program.module.orig	2007-02-09 11:13:33.000000000 -0600
+++ modules/station/program/station_program.module	2007-05-30 11:19:39.000000000 -0500
@@ -115,6 +115,14 @@ function station_program_form(&$node) {
     '#maxlength' =>  255,
     '#weight' => -1,
   );
+  $form['stream'] = array(
+    '#type' => 'textfield',
+    '#title' => t('Streaming URL'),
+    '#description' => t("Link to oringinal stream of this program."),
+    '#default_value' => $node->stream,
+    '#maxlength' =>  255,
+    '#weight' => -1,
+  );
   $form['body_filter']['body'] = array(
     '#type' => 'textarea',
     '#title' => t('Body'),
@@ -135,14 +143,19 @@ function station_program_validate(&$node
       form_set_error('url', t('You need to provide a valid URL.'));
     }
   }
+    if ($node->stream) {
+      if (!valid_url($node->stream)) {
+        form_set_error('stream', t('You need to provide a valid URL.'));
+    }
+  }
 }
 
 function station_program_load($node) {
-  return db_fetch_object(db_query('SELECT genre, url FROM {station_program} WHERE vid = %d', $node->vid));
+  return db_fetch_object(db_query('SELECT genre, url, stream FROM {station_program} WHERE vid = %d', $node->vid));
 }
 
 function station_program_insert($node) {
-  db_query("INSERT INTO {station_program} (nid, vid, genre, url) VALUES (%d, %d, '%s', '%s')", $node->nid, $node->vid, $node->genre, $node->url);
+  db_query("INSERT INTO {station_program} (nid, vid, genre, url, stream) VALUES (%d, %d, '%s', '%s', '%s')", $node->nid, $node->vid, $node->genre, $node->url, $node->stream);
 }
 
 function station_program_delete($node) {
@@ -150,7 +163,7 @@ function station_program_delete($node) {
 }
 
 function station_program_update($node) {
-  db_query("UPDATE {station_program} SET genre = '%s', url = '%s' WHERE vid = %d", $node->genre, $node->url, $node->vid);
+  db_query("UPDATE {station_program} SET genre = '%s', url = '%s', stream = '%s' WHERE vid = %d", $node->genre, $node->url, $node->stream, $node->vid);
 }
 
 function station_program_view(&$node, $teaser = FALSE, $page = FALSE) {
@@ -176,6 +189,14 @@ function station_program_view(&$node, $t
         '#weight' => 1,
       );
     }
+    if ($node->stream) {
+      $node->content['streaming'] = array(
+        '#type' => 'item',
+        '#title' => t('Source url for program'),
+        '#value' => l($node->stream, $node->stream),
+        '#weight' => 2,
+      );
+    }
   }
   return $node;
 }
@@ -192,4 +213,4 @@ function station_program_autocomplete($s
   }
   print drupal_to_js($matches);
   exit();
-}
\ No hay ningún carácter de nueva línea al final del fichero
+}

python script:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

### this script sets up and plays a stream scheduled in drupal´s station module
### mysql database configuration. requieres python modules mpdclient2 and MySQLdb, and a patch for drupal ###
myhost = "localhost"
mydb = "drupal51"
myuser = "drupal51"
mypasswd = "drupal51"
playlist = "Juancho_Polo_Valencia"

import mpdclient2
import MySQLdb

def loadStreamInPlaylist(url):
  """loads the streaming url after every entry in the current playlist"""
  num = len(mpd.playlistinfo())
  x=0
  pos=1
  while x<num:
    mpd.add(url)
    list = mpd.playlistinfo()
    stream = list.pop()
    id = int(stream["id"])
    mpd.moveid(id, pos)
    x=x+1
    pos=pos+2

def currentTime():
  """get time in minutes from midnight sunday, because thats how drupal´s station module keeps time"""
  from time import localtime
  from time import strftime
  day = int(strftime("%w", localtime()))
  hour = int(strftime("%H", localtime()))
  now = day*24*60 + hour*60
  return now

def getProgram():
  """get the streaming url for the current program from mysql, requires currentTime"""
  import MySQLdb
  db = MySQLdb.connect(host=myhost, user=myuser, passwd=mypasswd,
db=mydb)
  cursor = db.cursor()
  cursor.execute("SELECT start FROM station_schedule ORDER BY start")
  results = cursor.fetchall()
  starttimes = []
  x = 0
  while x < len(results): 
    starttimes.append(results[x][0])
    x = x+1
  try:
    i = starttimes.index(currentTime())
    time = starttimes[i]
    command = "SELECT program_nid FROM station_schedule where start=" +str(time)
    cursor.execute(command)
    nid = cursor.fetchone()
    command = "SELECT stream FROM station_program where nid=" +str(nid[0])
    cursor.execute(command)
    streamURL = cursor.fetchone()
    return streamURL[0]
  except:
    return(False)
    pass

def cropMPD():
  """cuts everything from the playlist but the current song"""
  try:
    id = int(mpd.currentsong()["id"])
    mpd.moveid(id, 0)
    for i in range(len(mpd.playlistinfo())):
      mpd.delete(1)
  except: 
    mpd.clear()

mpd = mpdclient2.connect()
cropMPD()
mpd.load(playlist)
if not getProgram():
  mpd.play(1) 
else:
  url = getProgram()
  loadStreamInPlaylist(url)
  mpd.play(2)