test.py

__author__ = 'Shwetha'


from cloudant.client import Cloudant
import sys
import time
import serial
import re
ser = serial.Serial('/dev/ttyACM0', 9600)

masterdict={}

def commonCreation(key):
     return masterdict[key]


client = Cloudant('06867603-146b-43d1-b8d9-454f272fdc02-bluemix','cacca3cc252cb10645410c6e42a7ebb0c4a6382bb0dfa940b029d1de3285fa64',url='https://06867603-146b-43d1-b8d9-454f272fdc02-bluemix:cacca3cc252cb10645410c6e42a7ebb0c4a6382bb0dfa940b029d1de3285fa64@06867603-146b-43d1-b8d9-454f272fdc02-bluemix.cloudant.com')

# Connect to the server
client.connect()

# Perform client tasks...
session = client.session()


def update(key):
     if 'parking' in client.all_dbs():
          my_database = client['parking']
          selector = {'zipcode': zipcode,'pno':rpino,'_id':id}
          docs = my_database.get_query_result(selector,raw_result=True, limit=100)
          # print len(docs['docs'])
          if len(docs['docs']) == 0:
               print "no docs"
               data = commonCreation(key)
               # Create a document using the Database API
               my_document = my_database.create_document(data)
          else:
               for doc in docs['docs']:
                    #  print "insidd docs"
                    my_doc=my_database[doc['_id']]
                    print my_doc['status'], statuss
                    if my_doc['status'] != statuss:
                         my_doc['status'] = statuss
                         my_doc.save()

     else:
          print "there"
          my_database = client.create_database('parking')
          if my_database.exists():
               print 'Table creation SUCCESS!!'
               # Create document content data
          data = commonCreation(key)
          # Create a document using the Database API
          my_document = my_database.create_document(data)





# def checkForUpdate:

if 'parking' in client.all_dbs():
    #Reading data into local dictionary
    my_daata = client['parking']
    for doc in my_daata:
        pin= str(doc['zipcode']) + str(doc['pno'])  + str(doc['_id'])
        masterdict[pin] = doc['status']





while True:
    serInp =  ser.readline()
    serInp = serInp.strip()
    print serInp
    inps = serInp.split("_")
    if len(inps) == 4:
         id = inps[2]
         zipcode = inps[3]
         rpino = inps[1]
         statuss = inps[0]
         key = id + zipcode + rpino
         if key in masterdict:
              if masterdict[key]['status'] != statuss:
                   masterdict[key]['status'] = statuss
                   update(key);
         else:
              masterdict[key] = {'_id':id,'zipcode':zipcode,'pno':rpino,'status':statuss}
              update(key);






client.disconnect()