repair_team_members.py (AEN 4.0)

repair_team_members.py

from wk_server.base import init as wk_server_init
from wk_server.tasks import add_team_member
import wk_server.database as db

wk_server_init()

users = db.get_users()
for user in users:
  projects = db.get_projects(user, user)
  for p in projects:
      if not p.get('team'):
          continue
      print user['username'], p['name'], p['team']
      for team in p['team']:
          team_member = db.get_user(_id=team)
          print 'adding', user['username'], p['name'], p['team'], team_member['username']
          add_team_member(user['_id'], user['_id'], p['name'], team_member['_id'])