#!/usr/bin/python

import json
import time
import pymysql.cursors
import pymysql
from datetime import date
from couchbase.cluster import Cluster, ClusterOptions
from couchbase_core.cluster import PasswordAuthenticator

today = date.today()

cluster = Cluster('couchbase://docs.gigminds.com', ClusterOptions(PasswordAuthenticator('admin', 'Tanya@12')))
cb = cluster.bucket('default')
cb_coll = cb.default_collection()

db = pymysql.connect (host="cldy-hub-db-prod-do-user-1524670-0.a.db.ondigitalocean.com",
                     user="doadmin",
                     passwd="jmbly6e4obtma5z0",
                     db="defaultdb",
                     port=25060,
                     charset='utf8mb4',
                     cursorclass=pymysql.cursors.DictCursor)

with db.cursor() as cursor:
    sql = "SELECT `id`, `person_id`, `uuid`, `resume_json` FROM resumes WHERE length(`resume_json`) > 200 and created_at > curdate() - 1;"
    cursor.execute(sql)
    records = cursor.fetchall()
    for record in records:
        jsonData = json.loads(record['resume_json'])
        
        resume = jsonData['ResumeParserData']
        resume['type'] = 'resume'
        resume['id'] = record['uuid'] if resume['Email'][0]['EmailAddress'] == '' else resume['Email'][0]['EmailAddress'].lower()
        resume['id'] = resume['id']+'.resume'
        resume['created_at'] = time.ctime()
        resume['uuid'] = record['uuid']
        resume['db_id'] = record['id']
        resume['db_person_id'] = record['person_id']
        resume['email'] = resume['Email'][0]['EmailAddress'].lower()
        cb_coll.upsert(resume['id'], resume)
        print(resume['uuid'])