#!/usr/bin/python3
import sys, gi, signal
import argparse, socket

gi.require_version('Gst', '1.0')
from gi.repository import Gst, GstNet, GObject

# init GObject & Co. before importing local classes
GObject.threads_init()
Gst.init([])

class Source(object):
	def __init__(self, ip):
		# it works much better with a local file
		pipeline = """
			videotestsrc pattern=ball foreground-color=0x00ff0000 background-color=0x00440000 !
				timeoverlay !
				video/x-raw,format=I420,width=1280,height=720,framerate=25/1,pixel-aspect-ratio=1/1 !
				mux.

			audiotestsrc freq=330 !
				audio/x-raw,format=S16LE,channels=2,layout=interleaved,rate=48000 !
				mux.

			matroskamux name=mux !
				tcpclientsink host={ip} port=10000
		""".format(
			ip=ip
		)

		self.clock = GstNet.NetClientClock.new('voctocore', ip, 9998, 0)
		print('obtained NetClientClock from host', self.clock)

		print('waiting for NetClientClock to sync…')
		self.clock.wait_for_sync(Gst.CLOCK_TIME_NONE)

		print('starting pipeline')
		self.senderPipeline = Gst.parse_launch(pipeline)
		self.senderPipeline.use_clock(self.clock)
		self.src = self.senderPipeline.get_by_name('src')

		# Binding End-of-Stream-Signal on Source-Pipeline
		self.senderPipeline.bus.add_signal_watch()
		self.senderPipeline.bus.connect("message::eos", self.on_eos)
		self.senderPipeline.bus.connect("message::error", self.on_error)

		print("playing")
		self.senderPipeline.set_state(Gst.State.PLAYING)


	def on_eos(self, bus, message):
		print('Received EOS-Signal')
		sys.exit(1)

	def on_error(self, bus, message):
		print('Received Error-Signal')
		(error, debug) = message.parse_error()
		print('Error-Details: #%u: %s' % (error.code, debug))
		sys.exit(1)

def main():
	signal.signal(signal.SIGINT, signal.SIG_DFL)

	parser = argparse.ArgumentParser(description='Voctocore Remote-Source')
	parser.add_argument('host')

	args = parser.parse_args()
	print('Resolving hostname '+args.host)
	addrs = [ str(i[4][0]) for i in socket.getaddrinfo(args.host, None) ]
	if len(addrs) == 0:
		print('Found no IPs')
		sys.exit(1)

	print('Using IP '+addrs[0])

	src = Source(addrs[0])
	mainloop = GObject.MainLoop()
	try:
		mainloop.run()
	except KeyboardInterrupt:
		print('Terminated via Ctrl-C')


if __name__ == '__main__':
	main()