/* GStreamer * Copyright (C) <1999> Erik Walthinsen * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. */ #ifdef HAVE_CONFIG_H #include "config.h" #endif #include "gstshout2.h" #include #include /* elementfactory information */ static GstElementDetails shout2send_details = { "An Icecast plugin", "Sink/Network", "LGPL", "Sends data to an icecast server", VERSION, "Wim Taymans , Pedro Corte-Real ", "(C) 2000", }; unsigned int audio_format = 100; /* Shout2send signals and args */ enum { /* FILL ME */ LAST_SIGNAL }; enum { ARG_0, ARG_IP, /* the ip of the server */ ARG_PORT, /* the encoder port number on the server */ ARG_PASSWORD, /* the encoder password on the server */ ARG_PUBLIC, /* is this stream public? */ ARG_NAME, /* Name of the stream */ ARG_DESCRIPTION, /* Description of the stream */ ARG_GENRE, /* Genre of the stream */ ARG_PROTOCOL, /* Protocol to connect with */ ARG_MOUNT, /* mountpoint of stream (icecast only) */ ARG_URL, /* Url of stream (I'm guessing) */ }; static GstPadTemplate* sink_template_factory (void) { static GstPadTemplate *template = NULL; if (!template) { template = gst_pad_template_new ( "sink", GST_PAD_SINK, GST_PAD_ALWAYS, gst_caps_new ( "shout2send_sink", "application/ogg", NULL), gst_caps_new ( "shout2send_sink", "audio/mpeg", gst_props_new ( "layer", GST_PROPS_INT_RANGE (1, 3), NULL )), NULL); } return template; } static void gst_shout2send_class_init (GstShout2sendClass *klass); static void gst_shout2send_init (GstShout2send *shout2send); static void gst_shout2send_chain (GstPad *pad, GstData *_data); static GstPadLinkReturn gst_shout2send_connect (GstPad *pad, GstCaps *caps); static void gst_shout2send_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_shout2send_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static GstElementStateReturn gst_shout2send_change_state (GstElement *element); static GstElementClass *parent_class = NULL; /*static guint gst_shout2send_signals[LAST_SIGNAL] = { 0 }; */ #define GST_TYPE_SHOUT_PROTOCOL (gst_shout2send_protocol_get_type()) static GType gst_shout2send_protocol_get_type (void) { static GType shout2send_protocol_type = 0; static GEnumValue shout2send_protocol[] = { { SHOUT2SEND_PROTOCOL_ICE, "1", "Ice Protocol"}, { SHOUT2SEND_PROTOCOL_XAUDIOCAST, "2", "Xaudiocast Protocol (icecast 1.3.x)"}, { SHOUT2SEND_PROTOCOL_ICY, "3", "Icy Protocol (ShoutCast)"}, { SHOUT2SEND_PROTOCOL_HTTP, "4", "Http Protocol (icecast 2.x)"}, {0, NULL, NULL}, }; if (!shout2send_protocol_type) { shout2send_protocol_type = g_enum_register_static ("GstShout2SendProtocol", shout2send_protocol); } return shout2send_protocol_type; } GType gst_shout2send_get_type(void) { static GType shout2send_type = 0; if (!shout2send_type) { static const GTypeInfo shout2send_info = { sizeof(GstShout2sendClass), NULL, NULL, (GClassInitFunc)gst_shout2send_class_init, NULL, NULL, sizeof(GstShout2send), 0, (GInstanceInitFunc)gst_shout2send_init, }; shout2send_type = g_type_register_static(GST_TYPE_ELEMENT, "GstShout2send", &shout2send_info, 0); } return shout2send_type; } static void gst_shout2send_class_init (GstShout2sendClass *klass) { GObjectClass *gobject_class; GstElementClass *gstelement_class; gobject_class = (GObjectClass*)klass; gstelement_class = (GstElementClass*)klass; parent_class = g_type_class_ref(GST_TYPE_ELEMENT); g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_IP, g_param_spec_string("ip","ip","ip", NULL, G_PARAM_READWRITE)); /* CHECKME */ g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_PORT, g_param_spec_int("port","port","port", 1,G_MAXUSHORT,8000,G_PARAM_READWRITE)); /* CHECKME */ g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_PASSWORD, g_param_spec_string("password","password","password", NULL, G_PARAM_READWRITE)); /* CHECKME */ /* metadata */ g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_NAME, g_param_spec_string("name","name","name", NULL, G_PARAM_READWRITE)); /* CHECKME */ g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_DESCRIPTION, g_param_spec_string("description","description","description", NULL, G_PARAM_READWRITE)); /* CHECKME */ g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_GENRE, g_param_spec_string("genre","genre","genre", NULL, G_PARAM_READWRITE)); /* CHECKME */ g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_PROTOCOL, g_param_spec_enum ("protocol", "protocol", "Connection Protocol to use", GST_TYPE_SHOUT_PROTOCOL, SHOUT2SEND_PROTOCOL_HTTP, G_PARAM_READWRITE)); /* icecast only */ g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_MOUNT, g_param_spec_string("mount","mount","mount", NULL, G_PARAM_READWRITE)); /* CHECKME */ g_object_class_install_property(G_OBJECT_CLASS(klass), ARG_URL, g_param_spec_string("url","url","url", NULL, G_PARAM_READWRITE)); /* CHECKME */ gobject_class->set_property = gst_shout2send_set_property; gobject_class->get_property = gst_shout2send_get_property; gstelement_class->change_state = gst_shout2send_change_state; } static void gst_shout2send_init (GstShout2send *shout2send) { shout2send->sinkpad = gst_pad_new_from_template (sink_template_factory (), "sink"); gst_element_add_pad(GST_ELEMENT(shout2send),shout2send->sinkpad); gst_pad_set_chain_function(shout2send->sinkpad,gst_shout2send_chain); gst_pad_set_link_function (shout2send->sinkpad, gst_shout2send_connect); shout2send->ip = g_strdup ("127.0.0.1"); shout2send->port = 8000; shout2send->password = g_strdup ("hackme"); shout2send->name = g_strdup (""); shout2send->description = g_strdup (""); shout2send->genre = g_strdup (""); shout2send->mount = g_strdup (""); shout2send->url = g_strdup (""); shout2send->protocol = SHOUT2SEND_PROTOCOL_HTTP; } static void gst_shout2send_chain (GstPad *pad, GstData *_data) { GstBuffer *buf = GST_BUFFER (_data); GstShout2send *shout2send; glong ret; g_return_if_fail(pad != NULL); g_return_if_fail(GST_IS_PAD(pad)); g_return_if_fail(buf != NULL); shout2send = GST_SHOUT2SEND (GST_OBJECT_PARENT (pad)); g_return_if_fail (shout2send != NULL); g_return_if_fail (GST_IS_SHOUT2SEND (shout2send)); ret = shout_send (shout2send->conn, GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf)); if (ret != SHOUTERR_SUCCESS) { g_warning ("send error: %s...\n", shout_get_error(shout2send->conn)); } shout_sync (shout2send->conn); gst_buffer_unref (buf); } static void gst_shout2send_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec) { GstShout2send *shout2send; /* it's not null if we got it, but it might not be ours */ g_return_if_fail(GST_IS_SHOUT2SEND(object)); shout2send = GST_SHOUT2SEND(object); switch (prop_id) { case ARG_IP: if (shout2send->ip) g_free (shout2send->ip); shout2send->ip = g_strdup (g_value_get_string (value)); break; case ARG_PORT: shout2send->port = g_value_get_int (value); break; case ARG_PASSWORD: if (shout2send->password) g_free (shout2send->password); shout2send->password = g_strdup (g_value_get_string (value)); break; case ARG_NAME: /* Name of the stream */ if (shout2send->name) g_free (shout2send->name); shout2send->name = g_strdup (g_value_get_string (value)); break; case ARG_DESCRIPTION: /* Description of the stream */ if (shout2send->description) g_free (shout2send->description); shout2send->description = g_strdup (g_value_get_string (value)); break; case ARG_GENRE: /* Genre of the stream */ if (shout2send->genre) g_free (shout2send->genre); shout2send->genre = g_strdup (g_value_get_string (value)); break; case ARG_PROTOCOL: /* protocol to connect with */ shout2send->protocol = g_value_get_enum (value); break; case ARG_MOUNT: /* mountpoint of stream (icecast only) */ if (shout2send->mount) g_free (shout2send->mount); shout2send->mount = g_strdup (g_value_get_string (value)); break; case ARG_URL: /* Url of the stream (I'm guessing) */ if (shout2send->url) g_free (shout2send->url); shout2send->url = g_strdup (g_value_get_string (value)); break; default: break; } } static void gst_shout2send_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec) { GstShout2send *shout2send; /* it's not null if we got it, but it might not be ours */ g_return_if_fail(GST_IS_SHOUT2SEND(object)); shout2send = GST_SHOUT2SEND(object); switch (prop_id) { case ARG_IP: g_value_set_string (value, shout2send->ip); break; case ARG_PORT: g_value_set_int (value, shout2send->port); break; case ARG_PASSWORD: g_value_set_string (value, shout2send->password); break; case ARG_NAME: /* Name of the stream */ g_value_set_string (value, shout2send->name); break; case ARG_DESCRIPTION: /* Description of the stream */ g_value_set_string (value, shout2send->description); break; case ARG_GENRE: /* Genre of the stream */ g_value_set_string (value, shout2send->genre); break; case ARG_PROTOCOL: /* protocol to connect with */ g_value_set_enum (value, shout2send->protocol); break; case ARG_MOUNT: /* mountpoint of stream (icecast only) */ g_value_set_string (value, shout2send->mount); break; case ARG_URL: /* Url of stream (I'm guessing) */ g_value_set_string (value, shout2send->url); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } static GstPadLinkReturn gst_shout2send_connect (GstPad *pad, GstCaps *caps) { if (!strcmp(gst_caps_get_mime (caps), "audio/mpeg")) { audio_format = SHOUT_FORMAT_MP3; return GST_PAD_LINK_OK; } if (!strcmp(gst_caps_get_mime (caps), "application/ogg")) { audio_format = SHOUT_FORMAT_VORBIS; return GST_PAD_LINK_OK; } else { return GST_PAD_LINK_REFUSED; } } static GstElementStateReturn gst_shout2send_change_state (GstElement *element) { GstShout2send *shout2send; guint major, minor, micro; gshort proto = 3; gchar *version_string; g_return_val_if_fail (GST_IS_SHOUT2SEND (element), GST_STATE_FAILURE); shout2send = GST_SHOUT2SEND(element); GST_DEBUG ("state pending %d", GST_STATE_PENDING (element)); /* if going down into NULL state, close the file if it's open */ switch (GST_STATE_TRANSITION (element)) { case GST_STATE_NULL_TO_READY: shout2send->conn = shout_new(); switch (shout2send->protocol) { case SHOUT2SEND_PROTOCOL_ICE: proto = SHOUT_PROTOCOL_ICE; break; case SHOUT2SEND_PROTOCOL_XAUDIOCAST: proto = SHOUT_PROTOCOL_XAUDIOCAST; break; case SHOUT2SEND_PROTOCOL_ICY: proto = SHOUT_PROTOCOL_ICY; break; case SHOUT2SEND_PROTOCOL_HTTP: proto = SHOUT_PROTOCOL_HTTP; break; } if (shout_set_protocol(shout2send->conn, proto) != SHOUTERR_SUCCESS) { g_error ("Error setting protocol: %s\n", shout_get_error(shout2send->conn)); } /* --- FIXME: shout requires an ip, and fails if it is given a host. */ /* may want to put convert_to_ip(shout2send->ip) here */ if (shout_set_host(shout2send->conn, shout2send->ip) != SHOUTERR_SUCCESS) { g_error ("Error setting host: %s\n", shout_get_error(shout2send->conn)); } /* --- */ if (shout_set_port(shout2send->conn, shout2send->port) != SHOUTERR_SUCCESS) { g_error ("Error setting port: %s\n", shout_get_error(shout2send->conn)); } if(shout_set_password(shout2send->conn, shout2send->password) != SHOUTERR_SUCCESS) { g_error ("Error setting password: %s\n", shout_get_error(shout2send->conn)); } if (shout_set_name(shout2send->conn, shout2send->name) != SHOUTERR_SUCCESS) { g_error ("Error setting name: %s\n", shout_get_error(shout2send->conn)); } if (shout_set_description(shout2send->conn, shout2send->description) != SHOUTERR_SUCCESS) { g_error ("Error setting name: %s\n", shout_get_error(shout2send->conn)); } if (shout_set_genre(shout2send->conn, shout2send->genre) != SHOUTERR_SUCCESS) { g_error ("Error setting name: %s\n", shout_get_error(shout2send->conn)); } if (shout_set_mount(shout2send->conn, shout2send->mount) != SHOUTERR_SUCCESS) { g_error ("Error setting mount point: %s\n", shout_get_error(shout2send->conn)); } if (shout_set_user(shout2send->conn, "source") != SHOUTERR_SUCCESS) { g_error ("Error setting user: %s\n", shout_get_error(shout2send->conn)); } gst_version(&major,&minor,µ); version_string = g_strdup_printf("GStreamer %d.%d.%d", major,minor,micro); if (shout_set_agent(shout2send->conn, version_string) != SHOUTERR_SUCCESS) { g_error ("Error setting agent: %s\n", shout_get_error(shout2send->conn)); } g_free (version_string); break; case GST_STATE_READY_TO_PAUSED: /* This sets the format acording to the capabilities of what we are being given as input. */ if (shout_set_format(shout2send->conn, audio_format) != SHOUTERR_SUCCESS) { g_error ("Error setting connection format: %s\n", shout_get_error(shout2send->conn)); } if (shout_open (shout2send->conn) == SHOUTERR_SUCCESS) { g_print ("connected to server...\n"); } else { g_warning ("Couldn't connect to server: %s", shout_get_error(shout2send->conn)); shout_close (shout2send->conn); shout_free (shout2send->conn); return GST_STATE_FAILURE; } break; case GST_STATE_PAUSED_TO_READY: shout_close (shout2send->conn); shout_free (shout2send->conn); break; default: break; } /* if we haven't failed already, give the parent class a chance to ;-) */ if (GST_ELEMENT_CLASS (parent_class)->change_state) return GST_ELEMENT_CLASS (parent_class)->change_state (element); return GST_STATE_SUCCESS; } static gboolean plugin_init (GModule *module, GstPlugin *plugin) { GstElementFactory *factory; factory = gst_element_factory_new("shout2send", GST_TYPE_SHOUT2SEND, &shout2send_details); g_return_val_if_fail(factory != NULL, FALSE); gst_element_factory_add_pad_template (factory, sink_template_factory ()); gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory)); return TRUE; } GstPluginDesc plugin_desc = { GST_VERSION_MAJOR, GST_VERSION_MINOR, "shout2send", plugin_init };