"""Connect user feed to subaccount video rejection feeds."""

import csv

import stream

# add creds and set WRITE = True to do actual changes
APP_KEY = ''
APP_SECRET = ''
WRITE = False

# use the following query to generate a csv file named 'rows.csv'
"""
select
    vc.id,
    v.vendor_id,
    s.subaccount_id,
    s.subaccount_name,
    s.date_created,
    s.date_deleted
from art_relations.vend_contact vc
join art_relations.vendor v
on v.vendor_id = vc.vendor_id
join art_relations.subaccount s
on s.vendor_id = v.vendor_id
where vc.login = :email;
"""


def main():
    """Entrypoint function."""
    client = stream.connect(
        APP_KEY,
        APP_SECRET,
        location='us-east'
    )
    with open('rows.csv') as csvfile:
        reader = csv.DictReader(csvfile)
        for row in reader:
            if row['date_deleted']:
                continue
            user_feed_group = 'user_email_notifications'
            user_feed_id = f"alw_{row['id']}"
            subaccount_feed_group = 'label_video_product_rejection'
            subaccount_feed_id = f"subaccount_{row['subaccount_id']}"
            print(user_feed_group)
            print(user_feed_id)
            print(subaccount_feed_group)
            print(subaccount_feed_id)
            if WRITE:
                user_feed = client.feed(
                    user_feed_group,
                    user_feed_id
                )
                result = user_feed.follow(
                    subaccount_feed_group,
                    subaccount_feed_id
                )
                print(result)
            else:
                print('skipping write step')
            print('')


if __name__ == '__main__':
    main()