planetstack/openstack_observer/steps/sync_users.py

   1 import os
   2 import base64
   3 import hashlib
   4 from django.db.models import F, Q
   5 from planetstack.config import Config
   6 from observer.openstacksyncstep import OpenStackSyncStep
   7 from core.models.user import User
   8 from core.models.userdeployments import  UserDeployment
   9 from observer.steps.sync_user_deployments import SyncUserDeployment
  10
  11 class SyncUsers(OpenStackSyncStep):
  12     provides=[User]
  13     requested_interval=0
  14
  15     def sync_record(self, user):
  16         for user_deployment in UserDeployment.objects.filter(user=user):
  17             # bump the 'updated' field so user account are updated across
  18             # deployments.
  19             user_deployment.save()
  20
  21     def delete_record(self, user):
  22         user_deployment_deleter = SyncUserDeployment().delete_record
  23         for user_deployment in UserDeployment.objects.filter(user=user):
  24             user_deployment_deleter(user_deployment)