import pygst
pygst.require('0.10')
import farstream, gst, gobject, sys

loop = gobject.MainLoop()
pipeline = gst.Pipeline()

conference = gst.element_factory_make ("fsrtpconference")
sdes = conference.get_property("sdes")
conference.set_property ("sdes",conference.get_property("sdes").copy().set_value("cname", sys.argv[1] + "@1.2.3.4"))
pipeline.add (conference)

session = conference.new_session (farstream.MEDIA_TYPE_VIDEO)
participant = conference.new_participant ()
stream = session.new_stream (participant, farstream.DIRECTION_BOTH)
stream.set_transmitter("multicast")

stream.set_remote_codecs([farstream.Codec(96, "H263-1998",
                                         farstream.MEDIA_TYPE_VIDEO,
                                         90000)])
candidate = farstream.Candidate()
candidate.ip = "224.0.0.110"
candidate.port = 3442
candidate.component_id = farstream.COMPONENT_RTP
candidate.proto = farstream.NETWORK_PROTOCOL_UDP
candidate.type = farstream.CANDIDATE_TYPE_MULTICAST
candidate.ttl = 1

candidate2 = candidate.copy()
candidate2.port = 3443
candidate2.component_id = farstream.COMPONENT_RTCP
stream.force_remote_candidates ([candidate, candidate2])

videosource = gst.parse_bin_from_description (sys.argv[2] + " ! videoscale", True)
pipeline.add (videosource)
videosource.get_pad ("src").link(session.get_property ("sink-pad"))

funnel = False
def _src_pad_added (stream, pad, codec, pipeline):
    global funnel
    print "src pad %s added for stream %s %s" % (pad.get_name(), stream.get_property("participant").get_property("cname"), codec.to_string())
    if not funnel:
        funnel = gst.element_factory_make("funnel")
        videosink = gst.element_factory_make ("xvimagesink")
        pipeline.add(funnel)
        pipeline.add(videosink)
        funnel.set_state (gst.STATE_PLAYING)
        videosink.set_state (gst.STATE_PLAYING)
        funnel.link(videosink)
    pad.link (funnel.get_pad ("sink%d"))

stream.connect ("src-pad-added", _src_pad_added, pipeline)

pipeline.set_state(gst.STATE_PLAYING)
loop.run()