1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
# -*- coding: utf-8 -*-
__author__ = 'lundberg'
from meetingtools.ac import ac_api_client
from django.core.cache import cache
import logging
from datetime import datetime, timedelta
def get_owner(api, acc, sco):
default_folders = ['Shared Templates', 'Shared Content', 'User Content', 'Shared Meetings', 'User Meetings',
'{tree-type-account-custom}', 'Forced Recordings', 'Chat Transcripts']
key = 'ac:owner:%s/%s' % (acc, sco.get('sco-id'))
owner = cache.get(key)
if owner is None:
fid = sco.get('folder-id')
if not fid:
return None
folder_id = int(fid)
r = api.request('sco-info', {'sco-id': folder_id}, False)
if r.status_code() == 'no-data':
return None
parent = r.et.xpath("//sco")[0]
if parent:
if parent.findtext('name') in default_folders:
owner = {
'name': sco.findtext('name'),
'sco_id': sco.get('sco-id'),
# If the object is a child of a default_folder we need the parent to set as owner
'parent_name': parent.findtext('name'),
'parent_sco_id': parent.get('sco-id')
}
else:
owner = get_owner(api, acc, parent)
if owner is not None:
cache.set(key, owner, 30)
return owner
def import_acc(acc, since=0):
result = []
with ac_api_client(acc) as api:
if since > 0:
then = datetime.now()-timedelta(seconds=since)
then = then.replace(microsecond=0)
r = api.request('report-bulk-objects',
{'filter-out-type': 'meeting', 'filter-gt-date-modified': then.isoformat()})
else:
r = api.request('report-bulk-objects', {'filter-out-type': 'meeting'})
if r:
nr = 0
for row in r.et.xpath("//row"):
sco_id = row.get('sco-id')
byte_count = api.get_byte_count(sco_id)
if byte_count or byte_count == 0:
sco_element = api.get_sco_info(sco_id)
if not sco_element.get('source-sco-id'): # Object is not a reference
owner = get_owner(api, acc, sco_element)
permissions = api.get_permissions(sco_id)
item = {
'byte_count': byte_count,
'sco-id': row.get('sco-id'),
'type': row.get('icon'),
'name': row.findtext('name'),
'created': row.findtext('date-created'),
'modified': row.findtext('date-modified'),
'owner': owner['name'],
'owner_sco_id': owner['sco_id'],
'owner_parent': owner['parent_name'],
'permissions': permissions
}
result.append(item)
nr += 1
logging.info("%s: Imported %d objects." % (acc, nr))
return result
|
