username_validation.py

import tool_labs_utils
from pypodio2 import api
from client_settings import *


def main(event_checkin_app=14347171, user_manifest_app=14347585,
         checkin_username_field=109820693, manifest_username_field=109823938,
         associated_user_profile=109824325, associated_event_profile=109850232):
    sql = tool_labs_utils.WMFReplica()  # usage: sql.query(...)
    c = api.OAuthClient(client_id,client_secret,username,password)
    checkins = c.transport.POST('item', 'app', event_checkin_app, 'filter',
                                filters={associated_user_profile: [None]}, limit=500)['items']
    manifest = c.Application.get_items(user_manifest_app, limit=500)['items']

    user_profiles = {}

    # Prepare a manifest dictionary `user_profiles`
    for item in manifest:
        item_id = item['item_id']
        extant_fields = {field['field_id']: list(field['values'][0].values())
                        for field in item['fields']}
        wiki_username = extant_fields[manifest_username_field][0]
        user_profiles[wiki_username] = item_id

    # Now going through and checking for matches against `user_profiles`
    for item in checkins:
        item_id = item['item_id']
        extant_fields = {field['field_id']: list(field['values'][0].values())
                         for field in item['fields']}
        wiki_username = extant_fields[checkin_username_field][0]
        wiki_username = wiki_username[0].upper() + wiki_username[1:]
        wiki_username = wiki_username.replace('_', ' ')

        if wiki_username in user_profiles:

            attributes = {'fields':
                                    [
                                        {'field_id': associated_user_profile,
                                         'values': [{'value': user_profiles[wiki_username]}]
                                        }
                                    ]
                         }
            print(c.Item.update(item_id, attributes))

        else:
            q = 'select user_id from user where user_name = "{0}";' 
            q = q.format(wiki_username)
            if sql.query('enwiki', q, None) != None:
                # create new User Manifest item in Podio
                # retrieve User Manifest item ID; add to `user_profiles` to
                # prevent duplicate creation THEN associate check-in with
                # manifest item

                attributes = {'fields':
                                        [
                                            {'field_id': manifest_username_field,
                                             'values': [{'value': wiki_username}]}
                                        ]
                             }

                create_the_thing = c.Item.create(user_manifest_app, attributes)
                new_id = create_the_thing['item_id']  # hope this works?

                user_profiles[wiki_username] = new_id

                attributes = {'fields':
                                        [
                                            {'field_id': associated_user_profile,
                                             'values': [{'value': user_profiles[wiki_username]}]
                                            }
                                        ]
                             }
                print(c.Item.update(item_id, attributes))


if __name__ == "__main__":
    main()