#!/usr/bin/env python
# **********************************************************************
#
# Copyright (c) 2003-2006 ZeroC, Inc. All rights reserved.
#
# This copy of Ice is licensed to you under the terms described in the
# ICE_LICENSE file included in this distribution.
#
# **********************************************************************

import sys, os, traceback, Ice

slice_dir = os.getenv('ICEPY_HOME', '')
if len(slice_dir) == 0 or not os.path.exists(os.path.join(slice_dir, 'slice')):
    slice_dir = os.getenv('ICE_HOME', '')
if len(slice_dir) == 0 or not os.path.exists(os.path.join(slice_dir, 'slice')):
    slice_dir = os.path.join('/', 'usr', 'share')
if not os.path.exists(os.path.join(slice_dir, 'slice')):
    print sys.argv[0] + ': Slice directory not found. Define ICEPY_HOME or ICE_HOME.'
    sys.exit(1)

Ice.loadSlice('-I' + slice_dir + '/slice Queue.ice')
import Demo

def menu():
    print "Enter /quit to exit."

class Publisher(Ice.Application):
    def run(self, args):
	queue = Demo.QueuePrx.checkedCast(self.communicator().propertyToProxy('Queue.Proxy'))
	if not queue:
	    print args[0] + ": invalid proxy"
	    return False

	print "Type a message and hit return to queue a message."
	menu()

	line = None
	try:
	    while 1:
		line = raw_input("==> ")
		if len(line) != 0:
		    if line[0] == '/':
			if line == "/quit":
			    break
			menu()
		    else:
		        queue.add(line)
	except KeyboardInterrupt:
	    return False
	except EOFError:
	    return False
	except Ice.Exception, ex:
	    print ex

	return True

app = Publisher()
sys.exit(app.main(sys.argv, "config.client"))