#!/usr/bin/python



from __future__ import absolute_import, print_function, unicode_literals



from optparse import OptionParser, make_option

import os

import sys

import socket

import uuid

import dbus

import dbus.service

import dbus.mainloop.glib

try:

  from gi.repository import GObject

except ImportError:

  import gobject as GObject



import mraa

import time



x = mraa.Gpio(13)

x.dir(mraa.DIR_OUT)

redPin = mraa.Pwm(21)

greenPin = mraa.Pwm(20)

bluePin = mraa.Pwm(0)

redPin.enable(True)

greenPin.enable(True)

bluePin.enable(True)





class Profile(dbus.service.Object):

	fd = -1



    

	@dbus.service.method("org.bluez.Profile1",

					in_signature="", out_signature="")

	def Release(self):

		print("Release")

		mainloop.quit()



	@dbus.service.method("org.bluez.Profile1",

					in_signature="", out_signature="")

	def Cancel(self):

		print("Cancel")



	@dbus.service.method("org.bluez.Profile1",

				in_signature="oha{sv}", out_signature="")

	def NewConnection(self, path, fd, properties):

		self.fd = fd.take()

		print("NewConnection(%s, %d)" % (path, self.fd))



		server_sock = socket.fromfd(self.fd, socket.AF_UNIX, socket.SOCK_STREAM)

		server_sock.setblocking(1)

		server_sock.send("This is Edison SPP loopback test\nAll data will be loopback\nPlease start:\n")



		try:

		    while True:

		        data = server_sock.recv(1024)
		        print(data)
		    	#print len(data)
		        data = int(data)
			print(type(data))

		  
				##########RGB LED code 
		    	if data == 1:
		    		#red
		    		redPin.write(0)
		    		greenPin.write(1)
		    		bluePin.write(1)

		    	elif data == 2:
		    		#green
		    		greenPin.write(0)
		    		redPin.write(1)
		    		bluePin.write(1)

		    	elif data == 3:
		    		#blue
		    		bluePin.write(0)
		    		redPin.write(1)
		    		greenPin.write(1)

		    	elif data == 4:
		    		#yellow
		    		redPin.write(0)
		    		greenPin.write(0.8)
		    		bluePin.write(1)

		    	elif data == 5:
		    		#pink
		    		redPin.write(.1)
		    		bluePin.write(.3)
		    		greenPin.write(.9)

		    	elif data == 6:
		    		#purple
		    		redPin.write(0.7)
		    		bluePin.write(0.1)
		    		greenPin.write(1)

		    	elif data == 7:
		    		#white
		    		redPin.write(.9)
		    		greenPin.write(0.7)
		    		bluePin.write(0.3)

		    	elif data == 8:
		    		#blue green
		    		bluePin.write(1)
		    		greenPin.write(.5)
		    		redPin.write(1)

		    	elif data == 9:
		    		#green
		    		redPin.write(1)
		    		bluePin.write(1)
		    		greenPin.write(0)

		    	elif data == 10:
		    		#orange
		    		redPin.write(0)
		    		greenPin.write(0.9)
		    		bluePin.write(1)

		    	elif data == 11:
		    		#yellow green
		    		redPin.write(0)
		    		greenPin.write(0.5)
		    		bluePin.write(1)

		    	else:

		    		redPin.write(1)
		    		greenPin.write(1)
		    		bluePin.write(1)

		    		print("off")

		        #########end of RGB LED code 



			server_sock.send("looping back: %s\n" % data)




		except IOError:

		    pass



		server_sock.close()

		print("all done")




	@dbus.service.method("org.bluez.Profile1",

				in_signature="o", out_signature="")

	def RequestDisconnection(self, path):

		print("RequestDisconnection(%s)" % (path))



		if (self.fd > 0):

			os.close(self.fd)

			self.fd = -1



if __name__ == '__main__':

	dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)



	bus = dbus.SystemBus()



	manager = dbus.Interface(bus.get_object("org.bluez",

				"/org/bluez"), "org.bluez.ProfileManager1")



	option_list = [

			make_option("-C", "--channel", action="store",

					type="int", dest="channel",

					default=None),

			]



	parser = OptionParser(option_list=option_list)



	(options, args) = parser.parse_args()



	options.uuid = "1101"

	options.psm = "3"

	options.role = "server"

	options.name = "Edison SPP Loopback"

	options.service = "spp char loopback"

	options.path = "/foo/bar/profile"

	options.auto_connect = False

	options.record = ""



	profile = Profile(bus, options.path)



	mainloop = GObject.MainLoop()



	opts = {

			"AutoConnect" :	options.auto_connect,

		}



	if (options.name):

		opts["Name"] = options.name



	if (options.role):

		opts["Role"] = options.role



	if (options.psm is not None):

		opts["PSM"] = dbus.UInt16(options.psm)



	if (options.channel is not None):

		opts["Channel"] = dbus.UInt16(options.channel)



	if (options.record):

		opts["ServiceRecord"] = options.record



	if (options.service):

		opts["Service"] = options.service



	if not options.uuid:

		options.uuid = str(uuid.uuid4())



	manager.RegisterProfile(options.path, options.uuid, opts)



	mainloop.run()