importer.py 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213
  1. import json
  2. import os
  3. from tempfile import TemporaryDirectory
  4. from zipfile import BadZipFile, ZipFile
  5. from django.core.files.uploadedfile import SimpleUploadedFile
  6. from django.utils.translation import gettext as _, gettext_lazy
  7. from ..models import Theme
  8. from .css import create_css
  9. from .forms import (
  10. ThemeCssUrlManifest,
  11. ThemeManifest,
  12. create_css_file_manifest,
  13. create_media_file_manifest,
  14. )
  15. from .media import create_media
  16. from .tasks import build_theme_css, update_remote_css_size
  17. INVALID_MANIFEST_ERROR = gettext_lazy(
  18. '"manifest.json" contained by ZIP file is not a valid theme manifest file.'
  19. )
  20. class ThemeImportError(BaseException):
  21. pass
  22. class InvalidThemeManifest(ThemeImportError):
  23. def __init__(self):
  24. super().__init__(INVALID_MANIFEST_ERROR)
  25. def import_theme(name, parent, zipfile):
  26. with TemporaryDirectory() as tmp_dir:
  27. extract_zipfile_to_tmp_dir(zipfile, tmp_dir)
  28. validate_zipfile_contains_single_directory(tmp_dir)
  29. theme_dir = os.path.join(tmp_dir, os.listdir(tmp_dir)[0])
  30. cleaned_manifest = clean_theme_contents(theme_dir)
  31. theme = create_theme_from_manifest(name, parent, cleaned_manifest)
  32. try:
  33. create_css_from_manifest(theme_dir, theme, cleaned_manifest["css"])
  34. create_media_from_manifest(theme_dir, theme, cleaned_manifest["media"])
  35. except Exception:
  36. theme.delete()
  37. raise InvalidThemeManifest()
  38. else:
  39. for css in theme.css.filter(url__isnull=False):
  40. update_remote_css_size.delay(css.pk)
  41. build_theme_css.delay(theme.pk)
  42. return theme
  43. def extract_zipfile_to_tmp_dir(zipfile, tmp_dir):
  44. try:
  45. ZipFile(zipfile).extractall(tmp_dir)
  46. except BadZipFile:
  47. raise ThemeImportError(_("Uploaded ZIP file could not be extracted."))
  48. def validate_zipfile_contains_single_directory(tmp_dir):
  49. dir_contents = os.listdir(tmp_dir)
  50. if not len(dir_contents):
  51. raise ThemeImportError(_("Uploaded ZIP file is empty."))
  52. if len(dir_contents) > 1:
  53. raise ThemeImportError(_("Uploaded ZIP file should contain single directory."))
  54. if not os.path.isdir(os.path.join(tmp_dir, dir_contents[0])):
  55. raise ThemeImportError(_("Uploaded ZIP file didn't contain a directory."))
  56. def clean_theme_contents(theme_dir):
  57. manifest = read_manifest(theme_dir)
  58. return clean_manifest(theme_dir, manifest)
  59. def read_manifest(theme_dir):
  60. try:
  61. with open(os.path.join(theme_dir, "manifest.json")) as fp:
  62. return json.load(fp)
  63. except FileNotFoundError:
  64. raise ThemeImportError(
  65. _('Uploaded ZIP file didn\'t contain a "manifest.json".')
  66. )
  67. except json.decoder.JSONDecodeError:
  68. raise ThemeImportError(
  69. _('"manifest.json" contained by ZIP file is not a valid JSON file.')
  70. )
  71. else:
  72. return manifest
  73. def clean_manifest(theme_dir, manifest):
  74. if not isinstance(manifest, dict):
  75. raise InvalidThemeManifest()
  76. form = ThemeManifest(manifest)
  77. if not form.is_valid():
  78. raise InvalidThemeManifest()
  79. cleaned_manifest = form.cleaned_data.copy()
  80. cleaned_manifest["css"] = clean_css_list(theme_dir, manifest.get("css"))
  81. cleaned_manifest["media"] = clean_media_list(theme_dir, manifest.get("media"))
  82. return cleaned_manifest
  83. def clean_css_list(theme_dir, manifest):
  84. if not isinstance(manifest, list):
  85. raise InvalidThemeManifest()
  86. theme_css_dir = os.path.join(theme_dir, "css")
  87. if not os.path.isdir(theme_css_dir):
  88. raise InvalidThemeManifest()
  89. cleaned_data = []
  90. for item in manifest:
  91. cleaned_data.append(clean_css_list_item(theme_css_dir, item))
  92. return cleaned_data
  93. def clean_css_list_item(theme_css_dir, item):
  94. if not isinstance(item, dict):
  95. raise InvalidThemeManifest()
  96. if item.get("url"):
  97. return clean_css_url(item)
  98. if item.get("path"):
  99. return clean_css_file(theme_css_dir, item)
  100. raise InvalidThemeManifest()
  101. def clean_css_url(data):
  102. form = ThemeCssUrlManifest(data)
  103. if not form.is_valid():
  104. raise InvalidThemeManifest()
  105. return form.cleaned_data
  106. def clean_css_file(theme_css_dir, data):
  107. file_manifest = create_css_file_manifest(theme_css_dir)
  108. if data.get("path"):
  109. data["path"] = os.path.join(theme_css_dir, str(data["path"]))
  110. form = file_manifest(data)
  111. if not form.is_valid():
  112. raise InvalidThemeManifest()
  113. return form.cleaned_data
  114. def clean_media_list(theme_dir, manifest):
  115. if not isinstance(manifest, list):
  116. raise InvalidThemeManifest()
  117. theme_media_dir = os.path.join(theme_dir, "media")
  118. if not os.path.isdir(theme_media_dir):
  119. raise InvalidThemeManifest()
  120. cleaned_data = []
  121. for item in manifest:
  122. cleaned_data.append(clean_media_list_item(theme_media_dir, item))
  123. return cleaned_data
  124. def clean_media_list_item(theme_media_dir, data):
  125. if not isinstance(data, dict):
  126. raise InvalidThemeManifest()
  127. file_manifest = create_media_file_manifest(theme_media_dir)
  128. if data.get("path"):
  129. data["path"] = os.path.join(theme_media_dir, str(data["path"]))
  130. form = file_manifest(data)
  131. if not form.is_valid():
  132. raise InvalidThemeManifest()
  133. return form.cleaned_data
  134. def create_theme_from_manifest(name, parent, cleaned_data):
  135. return Theme.objects.create(
  136. name=name or cleaned_data["name"],
  137. parent=parent,
  138. version=cleaned_data["version"],
  139. author=cleaned_data["author"],
  140. url=cleaned_data["url"],
  141. )
  142. def create_css_from_manifest(tmp_dir, theme, manifest):
  143. for item in manifest:
  144. if "url" in item:
  145. theme.css.create(**item, order=theme.css.count())
  146. else:
  147. with open(item["path"], "rb") as fp:
  148. file_obj = SimpleUploadedFile(
  149. item["name"], fp.read(), content_type="text/css"
  150. )
  151. create_css(theme, file_obj)
  152. def create_media_from_manifest(tmp_dir, theme, manifest):
  153. for item in manifest:
  154. with open(item["path"], "rb") as fp:
  155. file_obj = SimpleUploadedFile(
  156. item["name"], fp.read(), content_type=item["type"]
  157. )
  158. create_media(theme, file_obj)