Split mobile and ivi emulator into two parts

Signed-off-by: Magnus <mfeuer@jaguarlandrover.com>

1 files changed, 202 insertions, 0 deletions

diff --git a/hvac_demo/hvac_mobile_emulator.py b/hvac_demo/hvac_mobile_emulator.py
new file mode 100755
index 0000000..9f0fc1a
--- /dev/null
+++ b/hvac_demo/hvac_mobile_emulator.py
@@ -0,0 +1,202 @@
+#!/usr/bin/python
+
+#
+# Copyright (C) 2014, Jaguar Land Rover
+#
+# This program is licensed under the terms and conditions of the
+# Mozilla Public License, version 2.0.  The full text of the 
+# Mozilla Public License is at https://www.mozilla.org/MPL/2.0/
+#
+
+#
+# Emulate a mobile device.
+
+#  The emulator connects to Service Edge of the
+#  backend server, and subscribes to HVAC updates (temp, fan speed,
+#  etc) updates from an IVI with a given VIN. The emulator can also
+#  update HVAC values, simulating HVAC GUI input on the mobile device
+#  screen, and send it off to the backend server Service Edge for
+#  further distribution to the targeted IVI.
+#
+#  
+#  Updates entered on the command line are are sent to the backend node
+#  service jlr.com/backend/hvac/subscription_service/publish. This
+#  service will look up VIN targeted by the update and send out the
+#  same data to all services that are subscribing to that VIN.
+#  
+#  The mobile device emulator will subscribe to updated values
+#  published to to the VIN value "ivi_[vin]" where vin is the VIN
+#  number of the IVI.  When a emulator, still in mobile device mode,
+#  sends out an updated value (entered in the python console), it will
+#  publish the value using the vin "mobile_[vin]"
+#
+#  Converesely, an emulator in IVI mode will sbuscribe to
+#  "mobile_[vin]", and publish to "ivi_[vin]".
+#
+#  This setup allows the mobile device emulator to receive updates
+#  entered on the IVI HVAC screen (sent out by the IVI to
+#  "ivi_[vin]"), while the IVI emulator receives updates entered on
+#  the mobile device screen (sent out by the mobile device to
+#  "mobile_[vin]").
+#
+#  The emulator will register with a phone number as a part of its
+#  service name, where the phone number is specified as a command line
+#  argument to the emulator. 
+#
+#  Since the backend RVI node that the emulator connects to has a
+#  service prefix of jlr.com/backend (see priv/backend.config),
+#  the mobile device emulator will have a complete service name of:
+#  jlr.com/backend/mobile/[phone_number]/hvac/publish
+#
+#  The VIN of the IVI to manage is also provided as a 
+#  command line argument.
+#
+# Usage:
+#
+# python hvac_emulator.py <rvi_url> <phone_number> <vin>
+#
+# Example:
+#  Regsiter on Service edge with URL http://127.0.0.1:8811, using
+#  phone number +19491231234 and controlling the IVI with VIN 1234.
+#
+#    python hvac_emulator.py http://127.0.0.1:8811 +19491231234 1234
+#
+
+import sys
+from rvi_json_rpc_server import RVIJSONRPCServer
+import jsonrpclib
+import random
+import threading
+
+# The subscriber service (MQTT server equivalent), that 
+# manages subscriptions and distributes received publish commands to
+# the relevant subscribers.
+#
+SUBSCRIPTION_SERVICE_BASE='jlr.com/backend/subscription_service'
+SUBSCRIBE_SERVICE=SUBSCRIPTION_SERVICE_BASE+'/subscribe'
+PUBLISH_SERVICE=SUBSCRIPTION_SERVICE_BASE+'/publish'
+
+#
+# Publish command is invoked by the 
+# subscriber server above when it receives a publish command
+# from a VIN that this emulator subscribes to.
+#
+def publish(vin, key, value):
+    print
+    print "Publish invoked!"
+    print "vin:", vin 
+    print "key:", key 
+    print "value:", value 
+    print
+    sys.stdout.write("Enter <key> <val> or q to quit: ")
+    sys.stdout.flush()
+    return ['ok']
+
+def usage():
+    print "Usage:", sys.argv[0], " <rvi_url> <phone_number> <vin>"
+    print "  <rvi_url>        URL of RVI Service Edge on local host."
+    print "  <phone_number>   Phone number to register emulator as."
+    print "  <vin>            The VIN that the mobile device is to control."
+    print
+    print "The RVI Service Edge URL can be found in"
+    print "priv/[backend,ivi].config as"
+    print "env -> rvi -> components -> service_edge -> url"
+    print
+    print "The Service Edge URL is also logged as a notice when the"
+    print "RVI node is started."
+    sys.exit(255)
+
+
+# Setup self's server that we will receive incoming calls from service edge on.
+
+#
+# Setup a localhost URL, using a random port, that we will listen to
+# incoming JSON-RPC publish calls on, delivered by our RVI service
+# edge (specified by rvi_url).
+#
+emulator_service_host = 'localhost'
+emulator_service_port = random.randint(20001, 59999)
+emulator_service_url = 'http://'+emulator_service_host + ':' + str(emulator_service_port)
+
+# 
+# Check that we have the correct arguments
+#
+if len(sys.argv) != 4:
+    usage()
+
+[ progname, rvi_url, phone_number, vin ] = sys.argv    
+
+# We are in mobile device mode. Setup the vin numbers for publish
+pub_vin = "mobile_"+vin
+sub_vin = "ivi_"+vin
+
+# Setup the service name we will register with.
+# The complete service name will be: jlr.com/backend/mobile/<phone_nr>/hvac/publish
+emulator_service_name = '/mobile/'+phone_number+'/hvac/publish'
+
+
+# Setup an outbound JSON-RPC connection to the RVI Service Edeg.
+rvi_server = jsonrpclib.Server(rvi_url)
+
+# Register our HVAC mobile emulator service with the RVI Service Edge,
+# allowing the RVI to forward requests to the service name to the
+# given network addresss (URL):
+print "Emulator service URL", emulator_service_url
+
+res = rvi_server.register_service(service = emulator_service_name, 
+                                  network_address = emulator_service_url)
+
+full_emulator_service_name = res['service']
+
+print "Mobile Device Emulator."
+print "Backend RVI node URL:     ", rvi_url
+print "Emulator URL:             ", emulator_service_url
+print "Phone Number:             ", phone_number
+print "VIN:                      ", vin
+print "Full Service Name:        ", full_emulator_service_name
+
+
+# Regsiter self's service with the backend server RVI node
+# See rvi_json_rpc_server.py._dispatch() for details on how
+# ncoming JSON-RPC requests are mapped to local funcitons.
+#
+emulator_service = RVIJSONRPCServer(addr=((emulator_service_host, emulator_service_port)), logRequests = False)
+emulator_service.register_function(publish, emulator_service_name)
+
+# Send of a subscribe to the subscription service running on the
+# backend. See hvac_subscription_service.py.subscribe() for details.
+
+rvi_server.message(calling_service = emulator_service_name,
+                   target = SUBSCRIBE_SERVICE,
+                   timeout = 0,
+                   parameters = [{ u'vin': sub_vin, 
+                                  u'subscribing_service': full_emulator_service_name}])
+
+# Create a thread to handle incoming stuff so that we can do input
+# in order to get new values
+thr = threading.Thread(target=emulator_service.serve_forever)
+thr.start()
+
+while True:
+    line = raw_input('Enter <key> <val> or "q" to quit: ')
+    if line == 'q':
+        emulator_service.shutdown()
+        sys.exit(0)
+
+    # Read a line and split it into a key val pair
+    lst = line.split(' ')
+    if len(lst) != 2:
+        print "Nope", len(lst), lst
+        continue
+    
+    [k, v] = line.split(' ')
+    
+    # Send out update to the subscriber
+    rvi_server.message(calling_service= emulator_service_name,
+                       target = PUBLISH_SERVICE,
+                       timeout = 0,
+                       parameters = [{ u'vin': pub_vin, 
+                                      u'key': k, 
+                                      u'value': v}])
+
+    print('Key {} set to {} for vin{}'. format(k, v, vin))