1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
#!/usr/bin/python
#
# Copyright (C) 2015, 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/
#
#
# Register a service specified by command line with an RVI node.
# Print out a message when the service gets invoked.
#
import sys
from rvilib import RVI
import getopt
def usage():
print "Usage:", sys.argv[0], "[-n <rvi_url>] <service_name>"
print " <rvi_url> URL of Service Edge on a local RVI node."
print " Default: http://localhost:9001"
print " <service_name> URL of Service to register"
print
print "The RVI Service Edge URL can be found in"
print "[backend,vehicle].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."
print
print "Example: ./rvi_service.py -n http://rvi1.nginfotpdx.net:9001 /test/some_service"
sys.exit(255)
#
# Our general handler, registered with rvi.register_service() below.
#
# You can also explicitly name the arguments, but then
# the sender has to match the argument names.
# For example:
# rvi_call.py http://localhost:9001 jlr.com/vin/test a=1 b=2 c=3 ->
# def service(a,b,c)
#
def service_invoked(**args):
print
print "Service invoked!"
print "args:", args
print
sys.stdout.write("Press enter to quit: ")
sys.stdout.flush()
return ['ok']
def services_available(**args):
print
print "Services available!"
print "args:", args
print
sys.stdout.write("Press enter to quit: ")
sys.stdout.flush()
return ['ok']
def services_unavailable(**args):
print
print "Services unavailable!"
print "args:", args
print
sys.stdout.write("Press enter to quit: ")
sys.stdout.flush()
return ['ok']
#
# Check that we have the correct arguments
#
opts, args= getopt.getopt(sys.argv[1:], "n:")
rvi_node_url = "http://localhost:9001"
for o, a in opts:
if o == "-n":
rvi_node_url = a
else:
usage()
if len(args) != 1:
usage()
service_name = args[0]
# Setup a connection to the local RVI node
rvi = RVI(rvi_node_url)
# Starting the thread that handles incoming calls is
# not really necessary since register_service will do it for us.
rvi.start_serve_thread()
rvi.set_services_available_callback(services_available)
rvi.set_services_unavailable_callback(services_unavailable)
# Register our service and invoke 'service_invoked' if we
# get an incoming JSON-RPC call to it from the RVI node
#
full_service_name = rvi.register_service(service_name, service_invoked)
print "RVI General Service."
print "RVI node URL: ", rvi_node_url
print "Service: ", full_service_name
raw_input('Press enter to quit: ')
rvi.unregister_service(service_name)
rvi.shutdown()
sys.exit(0)
|
