ipaaca-iu-injector.py

#!/usr/bin/env python

# This file is part of IPAACA, the
#  "Incremental Processing Architecture
#   for Artificial Conversational Agents".	
#
# Copyright (c) 2009-2013 Sociable Agents Group
#                         CITEC, Bielefeld University	
#
# http://opensource.cit-ec.de/projects/ipaaca/
# http://purl.org/net/ipaaca
#
# This file may be licensed under the terms of of the
# GNU Lesser General Public License Version 3 (the ``LGPL''),
# or (at your option) any later version.
#
# Software distributed under the License is distributed
# on an ``AS IS'' basis, WITHOUT WARRANTY OF ANY KIND, either
# express or implied. See the LGPL for the specific language
# governing rights and limitations.
#
# You should have received a copy of the LGPL along with this
# program. If not, go to http://www.gnu.org/licenses/lgpl.html
# or write to the Free Software Foundation, Inc.,
# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.	
#
# The development of this software was supported by the
# Excellence Cluster EXC 277 Cognitive Interaction Technology.
# The Excellence Cluster EXC 277 is a grant of the Deutsche
# Forschungsgemeinschaft (DFG) in the context of the German
# Excellence Initiative.

import logging
import sys
import time
import os
import platform

import ipaaca

def my_update_handler(iu, event_type, local):
	print(event_type+': '+str(iu))

if len(sys.argv)<2:
	print "Please use the program as follows:"
	print " "+sys.argv[0]+" [--class IU|Message] [--timeout <sec>] <categoryname> [<payloadkey> <payloadvalue>] [<k2> <v2>] ..."
	sys.exit(1)

iu_class = 'Message'
timeout = 3.0
idx = 1
keep_going = True
while keep_going:
	keep_going = False
	if sys.argv[idx]=='--class':
		t = sys.argv[idx+1]
		if t in ['Message', 'IU']:
			iu_class = t
		else:
			print "Unknown IU class: "+t
			sys.exit(1)
		idx += 2
		keep_going = True
	elif sys.argv[idx]=='--timeout':
		timeout = float(sys.argv[idx+1])
		idx += 2
		keep_going = True

cate = sys.argv[idx]
idx += 1
pl={}
while len(sys.argv)>idx+1:
	pl[sys.argv[idx]] = sys.argv[idx+1]
	idx+=2

try:
	print "Sending "+iu_class+" of category "+cate
	print " with payload "+str(pl)

	ob = ipaaca.OutputBuffer('IUInjector')
	ob.register_handler(my_update_handler)
	iu_top = ipaaca.IU(cate)
	iu_top.payload = pl
	ob.add(iu_top)
	print iu_class+" sent."

	if iu_class=="IU":
		print "Waiting "+str(timeout)+" sec for remote modifications..."
		time.sleep(timeout)
	else:
		time.sleep(0.1)
	print "done."

except KeyboardInterrupt:
	pass

if platform.system() == 'Windows':
	os._exit(0)
else:
	sys.exit(0)