Method execute

keepercommander/commands/record.py:2597–2662

(self, params, **kwargs)

        return trash_unshare_parser

    def execute(self, params, **kwargs):
        orphaned_records = self.get_orphaned_records(params)
        if len(orphaned_records) == 0:
            logging.info('Trash is empty')
            return

        records = kwargs.get('records')
        if not isinstance(records, (tuple, list)):
            records = None
        if not records:
            logging.info('records parameter is empty.')
            return

        to_restore = set()
        for rec in records:
            if rec in orphaned_records:
                to_restore.add(rec)
            else:
                title_pattern = re.compile(fnmatch.translate(rec), re.IGNORECASE)
                for record_uid, del_rec in orphaned_records.items():
                    if record_uid in to_restore:
                        continue
                    record = vault.KeeperRecord.load(params, del_rec)
                    if title_pattern.match(record.title):
                        to_restore.add(record_uid)

        if len(to_restore) == 0:
            logging.info('There are no records to unshare')
            return

        if not kwargs.get('force'):
            answer = base.user_choice(f'Do you want to remove shares from {len(to_restore)} record(s)?', 'yn', default='n')
            if answer.lower() == 'y':
                answer = 'yes'
            if answer.lower() != 'yes':
                return

        record_shares = api.get_record_shares(params, to_restore, True)
        if record_shares:
            remove_shares = []   # type: List[record_pb2.SharedRecord]
            for record_share in record_shares:
                if 'shares' in record_share:
                    shares = record_share['shares']
                    if 'user_permissions' in shares:
                        for user_permission in shares['user_permissions']:
                            if user_permission.get('owner') is False:
                                rs_rq = record_pb2.SharedRecord()
                                rs_rq.toUsername = user_permission['username']
                                rs_rq.recordUid = utils.base64_url_decode(record_share['record_uid'])
                                remove_shares.append(rs_rq)

            while len(remove_shares) > 0:
                chunk = remove_shares[:900]
                remove_shares = remove_shares[900:]
                rsu_rq = record_pb2.RecordShareUpdateRequest()
                rsu_rq.removeSharedRecord.extend(chunk)

                rsu_rs = api.communicate_rest(params, rsu_rq, 'vault/records_share_update',