import gobject
import pygst
pygst.require('0.10')
import gst
import os

class GST_Mjpeg:
    def __init__(self):
        self.header = 'HTTP/1.1 200 OK\r\nContent-Type: multipart/x-mixed-replace;boundary=ThisRandomString\r\n\r\n'

        print 'creating GST object'

        source = 'v4l2src'

        source = 'videotestsrc'
        source_filter = 'video/x-raw-yuv,width=640,height=480,framerate=15/1'

        jpegenc = 'jpegenc'
        multipartmux = 'multipartmux'

        tcpserversink = 'tcpserversink host=127.0.0.1 port=5001 name=tcpserversink'


        line = [source, source_filter, jpegenc, multipartmux, tcpserversink]
        line = ' ! '.join(line)

        self.pipeline = gst.parse_launch(line)
        self.pipeline.set_state(gst.STATE_PLAYING)

        tcp = self.pipeline.get_by_name('tcpserversink')

        tcp.connect('client-added', self.client_added)


    def client_added(self, sink, fd):
        print "client added"
        os.write(fd, self.header)

my_gst = GST_Mjpeg()

loop = gobject.MainLoop()
gobject.threads_init()
context = loop.get_context()
while 1:
    context.iteration(True)