import redis
from pickle import dumps
import datetime
import os
import time

if os.name =='nt':
    root = "//WDsentinel/share/CorpCDOs"
elif os.name == 'posix':
    root = '/home/share/CorpCDOs'

dealsfile = os.path.join(root, "scripts", "deals_to_price.txt")
q = redis.Redis(unix_socket_path='/var/run/redis/redis.sock')
workdate = str(datetime.date.today())

while True:
    if os.path.exists(dealsfile):
        with open(dealsfile) as fh:
            for line in fh:
                dealname, reinvflag = line.rstrip().split("\t")
                q.rpush("tasks", dumps(("build_portfolio", [workdate, dealname, reinvflag]), protocol=2))
        os.unlink(dealsfile)
    time.sleep(3)