summaryrefslogtreecommitdiff
path: root/meetingtools
diff options
context:
space:
mode:
authorJohan Lundberg <lundberg@nordu.net>2014-03-26 17:55:04 +0100
committerJohan Lundberg <lundberg@nordu.net>2014-03-26 17:55:04 +0100
commitcfac1c6bb348705e95d8299f92f839d9583a4f7b (patch)
tree3a594ef3a86b66d1cac34f94c6bf733856387799 /meetingtools
parentb31bdbb68fee48b31cb933181bd5a6a0c7477afe (diff)
Started content app.
Diffstat (limited to 'meetingtools')
-rw-r--r--meetingtools/apps/content/__init__.py2
-rw-r--r--meetingtools/apps/content/tasks.py79
2 files changed, 81 insertions, 0 deletions
diff --git a/meetingtools/apps/content/__init__.py b/meetingtools/apps/content/__init__.py
new file mode 100644
index 0000000..3250cb8
--- /dev/null
+++ b/meetingtools/apps/content/__init__.py
@@ -0,0 +1,2 @@
+# -*- coding: utf-8 -*-
+__author__ = 'lundberg'
diff --git a/meetingtools/apps/content/tasks.py b/meetingtools/apps/content/tasks.py
new file mode 100644
index 0000000..7b78164
--- /dev/null
+++ b/meetingtools/apps/content/tasks.py
@@ -0,0 +1,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