def process(queue) :
    url = '/zong'
    get = json.loads(queue)
    print(get)
    if 'text' in get and 'sender' in get:
        num = get['number']	
        print(num)
        #op = 'zong'
        subtxt = get['text']
        #subtxt =subtxt.replace("'",'')
       # meta_data = get['meta_data']
       # smpp = ''meta_data.split('?')
       # print('smpp - split length' + len(smpp))
        append_to_log('/mmatcher/sms/log/' + url + '.log', get['sender'] + ' - ' + get['text'])					
        print(subtxt)
        subtxt = subtxt.lower()
        if subtxt == 'sub m' :
                subtxt = subtxt.replace('sub m','sub bus')
        elif subtxt == 'sub off' :
                subtxt = subtxt.replace('sub off','unsub')
        elif subtxt == 'sub free off' :
                subtxt = subtxt.replace('sub free off','unsub')
        elif subtxt == 'off sub' :
                subtxt = subtxt.replace('off sub','unsub')
        elif subtxt == 'sub' :
                subtxt = subtxt.replace('sub','sub bus')
        print(subtxt)                         
        body = web.start(subtxt, get['sender'].replace('+',''), url.replace('/',''))        
        logBody = body                
        filename = datetime.now().strftime('/log/' + url + '_sms_usage-%Y%m%U%d.log')
        append_to_log('/mmatcher/sms' + filename, get['sender'] + ' !|! ' + subtxt + ' !|! ' +  logBody + ' !|! '+num)
    else:
            body = 'The command was not recognized. To sell, send SELL<space> your item to 289. To buy, send BUY<space>your item to 289. Send H to 289 for help.'
    smsc.send('zong',get['sender'].replace('+',''), body)

def start(xml):
	from mmodules import web
	txt, usr = decode(xml)
	sms = web.start(txt, usr, 'clickatell')
	xml = encode(usr, sms)
	if xml:
		out = send(xml)
	return usr, txt, sms

	def test_024_add_interest(self):
		self.assertEqual(web.start('no tst1', test_user), 'Your interest I1 is added and currently has no matches. Matches will arrive on SMS later.')

	def test_121_delete_interests2(self):
		rng = range(1, 10)
		self.assertEqual(web.start(''.join(['d{}|'.format(x) for x in rng])[:-1], test_user2).split('\n'),
						['Interest {} has been deleted.'.format(x) for x in rng])

	def test_113_list_interests(self):
		self.assertEqual(web.start('i', test_user), 'I1:buying unittestingtestcases(9)')

	def test_111_add_interests2(self):
		rng = range(1, 10)
		self.assertEqual(web.start(''.join('selling unittestingtestcases for {}|'.format(x+10) for x in rng)[:-1], test_user2).split('\n'),
						['Your interest I{} is added and currently has 1 match. More matches will arrive on SMS later.'.format(x) for x in rng])

	def test_098_list_matches(self):
		rng = [10,9,7,5,3,1]
		self.assertEqual(set(re.sub(r'I1M\d0?:', 'I1M?:', web.start('i1', test_user)).split('\n')),
						{'I1M?:selling unittestingtestcases for {}'.format(x) for x in rng})

	def test_095_add_interest2(self):
		self.assertEqual(web.start('selling unittestingtestcases for 10', test_user2), 'Your interest I2 is added and currently has 1 match. More matches will arrive on SMS later.')

	def test_064_no_matches(self):
		self.assertEqual(web.start('i2', test_user), 'There is no interest I2.\nYour interests are:\nI1:buying unittestingtestcases')

	def test_061_add_interest(self):
		self.assertEqual(web.start('a1 buying unittestingtestcases', test_user), 'Your interest I1 is added with 1 day validity. It currently has no matches. Matches will arrive on SMS later.')

	def test_043_add_interest(self):
		self.assertEqual(web.start('a0 tst', test_user), 'Your interest I7 is added with 0 days validity. It currently has no matches. Matches will arrive on SMS later.')

	def test_041_delete_interest(self):
		self.assertEqual(web.start('d3|d7', test_user), 'Interest 3 has been deleted.\nInterest 7 has been deleted.')

	def test_032_list_interests(self):
		self.assertEqual(set(web.start('i', test_user).split('\n')),
						{'I{}:no tst{}'.format(x, x) for x in range(14,0,-1)})

	def test_031_add_interests(self):
		rng = range(2, 15)
		self.assertEqual(web.start(''.join('no tst{}|'.format(x) for x in rng)[:-1], test_user).split('\n'),
						['Your interest I{} is added and currently has no matches. Matches will arrive on SMS later.'.format(x) for x in rng])

	def test_02_list_interests(self):
		self.assertEqual(web.start('i', test_user), 'I1:no tst1')

	def test_084_list_interests(self):
		self.assertEqual(web.start('i', test_user2), 'I1:selling unittestingtestcases for 1(1)')

	def test_092_list_interests2(self):
		self.assertEqual(set(web.start('i', test_user2).split('\n')),
						{'I{}:selling unittestingtestcases for {}(1)'.format(x, x) for x in [9,7,5,3,1]})

	def test_071_register2(self):
		self.assertEqual(web.start('s', test_user2), "Thank you for subscribing to mmatcher.com.\nFor instructions on how to use mmatcher reply 'H' to this message.")

	def test_096_list_interests2(self):
		self.assertEqual(set(web.start('i', test_user2).split('\n')),
						{'I{}:selling unittestingtestcases for {}(1)'.format(x,y) for x,y in [(9,9),(7,7),(5,5),(3,3),(2,10),(1,1)]})

	def test_073_add_interest(self):
		self.assertEqual(web.start('a10 selling unittestingtestcases for 1', test_user2), 'Your interest I1 is added with 10 days validity. It currently has 1 match. More matches will arrive on SMS later.')