import simplegeo, time

from simplegeo.models import Record

key = ''
secret = ''
layer = 'co.mager.test.tickers'

places = simplegeo.places.Client(key, secret)
storage = simplegeo.Client(key, secret)


def create_records(businesses, ticker):
    records = []

    for business in businesses:
        record = {}
        record['layer'] = layer
        record['created'] = string(time.time())
        record['id'] = business.to_dict()['id']
        record['lat'] = business.to_dict()['geometry']['coordinates'][1]
        record['lon'] = business.to_dict()['geometry']['coordinates'][0]
        record.update(business.to_dict()['properties'])

        record['ticker'] = ticker

        record = Record(**record)
        records.append(record)

    storage.add_records(layer, records)
    print "You just imported %s records into Storage" % len(records)

def get_businesses(lat, lon, q, ticker=None):
    businesses = places.search(lat, lon, query=q)
    create_records(businesses, ticker)


if __name__ == '__main__':
    lon = -73.988559
    lat = 40.745726
    q = "Banana Republic"
    ticker = "GAP"
    get_businesses(lat, lon, q, ticker)