Method sync_down

keepercommander/pedm/admin_plugin.py:360–523

(self, *, reload: bool = False)

            self._approvals.put_entities(approvals)

    def sync_down(self, *, reload: bool = False) -> None:
        if reload:
            self.storage.reset()
            self._populate_data = True

        task = RebuildTask(self._populate_data)
        setting = self.storage.settings.get_entity('PEDM_SYNC_TOKEN')
        if setting is None:
            setting = admin_storage.PedmAdminSettings(key='PEDM_SYNC_TOKEN', value='')
        token: bytes = b''
        if isinstance(setting.value, str) and len(setting.value) > 0:
            token = utils.base64_url_decode(setting.value)

        deployments: List[ admin_storage.PedmStorageDeployment] = []
        delete_deployments: List[str] = []
        policies: List[admin_storage.PedmStoragePolicy] = []
        delete_policies: List[str] = []
        agents: List[admin_storage.PedmStorageAgent] = []
        delete_agents: List[str] = []
        collections: List[admin_storage.PedmStorageCollection] = []
        delete_collections: List[str] = []
        collection_links: List[admin_storage.PedmStorageCollectionLink] = []
        delete_collection_links: List[Tuple[str, str]] = []
        approvals: List[admin_storage.PedmStorageApproval] = []
        delete_approvals: List[str] = []
        approval_status: List[admin_storage.PedmStorageApprovalStatus] = []

        sync_rq = pedm_pb2.GetPedmDataRequest()
        done = False
        while not done:
            sync_rq.continuationToken = token
            sync_rs = api.execute_router(self.params,'pedm/sync_pedm_data', sync_rq, rs_type=pedm_pb2.GetPedmDataResponse)
            assert sync_rs is not None
            if sync_rs.resetCache:
                self.storage.reset()

            token = sync_rs.continuationToken
            done = not sync_rs.hasMore

            for ra in sync_rs.removedAgents:
                agent_uid = utils.base64_url_encode(ra)
                delete_agents.append(agent_uid)

            for rp in sync_rs.removedPolicies:
                policy_uid = utils.base64_url_encode(rp)
                delete_policies.append(policy_uid)

            for rd in sync_rs.removedDeployments:
                deployment_uid = utils.base64_url_encode(rd)
                delete_deployments.append(deployment_uid)

            for rc in sync_rs.removedCollection:
                collection_uid = utils.base64_url_encode(rc)
                delete_collections.append(collection_uid)

            for rcl in sync_rs.removedCollectionLink:
                collection_uid = utils.base64_url_encode(rcl.collectionUid)
                link_uid = utils.base64_url_encode(rcl.linkUid)