| import os |
| import base64 |
| import datetime |
| from xos.config import Config |
| from synchronizers.openstack.openstacksyncstep import OpenStackSyncStep |
| from xos.logger import observer_logger as logger |
| from synchronizers.new_base.modelaccessor import * |
| |
| #class SyncRoles(OpenStackSyncStep): |
| # provides=[User] |
| # requested_interval=0 |
| # observes=User |
| # |
| # def fetch_pending(self, deleted): |
| # if (deleted): |
| # # users marked as deleted |
| # return User.deleted_objects.all() |
| # else: |
| # # disabled users that haven't been updated in over a week |
| # one_week_ago = datetime.datetime.now() - datetime.timedelta(days=7) |
| # return User.objects.filter(is_active=False, updated__gt=one_week_ago) |
| # |
| # def sync_record(self, user): |
| # user.delete() |