Merge app_registry and backups apps
This commit is contained in:
Roberto Rosario
@@ -1,17 +1,23 @@
|
||||
from __future__ import absolute_import
|
||||
|
||||
from django.db import transaction, DatabaseError
|
||||
from django.utils.translation import ugettext_lazy as _
|
||||
|
||||
from backups.api import AppBackup, ModelBackup
|
||||
from icons.literals import APP
|
||||
from navigation.api import bind_links
|
||||
from common.utils import encapsulate
|
||||
from icons.literals import APP, BACKUPS
|
||||
from job_processor.exceptions import JobQueuePushError
|
||||
from job_processor.models import JobQueue, JobType
|
||||
from project_tools.api import register_tool
|
||||
from project_setup.api import register_setup
|
||||
from navigation.api import bind_links, register_model_list_columns
|
||||
|
||||
from .models import App
|
||||
from .links import app_registry_tool_link, app_list
|
||||
from .api import register_app
|
||||
from .classes import AppBackup, ModelBackup
|
||||
from .exceptions import UnableToRegister
|
||||
from .links import (app_registry_tool_link, app_list, backup_tool_link,
|
||||
restore_tool_link, backup_job_list, backup_job_create, backup_job_edit,
|
||||
backup_job_test)
|
||||
from .models import App, BackupJob
|
||||
|
||||
register_tool(app_registry_tool_link)
|
||||
bind_links(['app_list'], [app_list], menu_name='secondary_menu')
|
||||
@@ -20,6 +26,33 @@ try:
|
||||
app = register_app('app_registry', label=_(u'App registry'), icon=APP)
|
||||
except UnableToRegister:
|
||||
pass
|
||||
else:
|
||||
AppBackup(app, [ModelBackup()])
|
||||
#else:
|
||||
# AppBackup(app, [ModelBackup()])
|
||||
|
||||
# TODO: move to literals
|
||||
BACKUP_JOB_QUEUE_NAME = 'backups_queue'
|
||||
|
||||
|
||||
@transaction.commit_on_success
|
||||
def create_backups_job_queue():
|
||||
global backups_job_queue
|
||||
try:
|
||||
backups_job_queue, created = JobQueue.objects.get_or_create(name=BACKUP_JOB_QUEUE_NAME, defaults={'label': _('Backups'), 'unique_jobs': True})
|
||||
except DatabaseError:
|
||||
transaction.rollback()
|
||||
|
||||
|
||||
create_backups_job_queue()
|
||||
#backup_job_type = JobType('remote_backup', _(u'Remove backup'), do_backup)
|
||||
|
||||
register_setup(backup_tool_link)
|
||||
register_tool(restore_tool_link)
|
||||
bind_links([BackupJob, 'backup_job_list', 'backup_job_create'], [backup_job_list], menu_name='secondary_menu')
|
||||
bind_links([BackupJob, 'backup_job_list', 'backup_job_create'], [backup_job_create], menu_name='sidebar')
|
||||
bind_links([BackupJob], [backup_job_edit, backup_job_test])
|
||||
|
||||
register_model_list_columns(BackupJob, [
|
||||
{'name':_(u'begin date time'), 'attribute': 'begin_datetime'},
|
||||
{'name':_(u'storage module'), 'attribute': 'storage_module.label'},
|
||||
{'name':_(u'apps'), 'attribute': encapsulate(lambda x: u', '.join([unicode(app) for app in x.apps.all()]))},
|
||||
])
|
||||
|
||||
@@ -0,0 +1,300 @@
|
||||
import logging
|
||||
import os
|
||||
|
||||
from django.core.files.base import ContentFile
|
||||
from django.core.files.storage import FileSystemStorage
|
||||
from django.core.management.commands.dumpdata import Command
|
||||
from django.db import router, DEFAULT_DB_ALIAS
|
||||
from django.utils.translation import ugettext_lazy as _
|
||||
from django.utils.translation import ugettext
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
# Data types
|
||||
class ElementDataBase(object):
|
||||
"""
|
||||
The basic unit of a backup, a data type
|
||||
it is produced or consumed by the ElementBackup classes
|
||||
"""
|
||||
def make_filename(self, id):
|
||||
return '%s-%s' % (self.model_backup.app_backup.app.name, id)
|
||||
|
||||
def save(self):
|
||||
"""
|
||||
Must return a file like object
|
||||
"""
|
||||
raise NotImplemented
|
||||
|
||||
def load(self, file_object):
|
||||
"""
|
||||
Must read a file like object and store content
|
||||
"""
|
||||
raise NotImplemented
|
||||
|
||||
|
||||
class Fixture(ElementDataBase):
|
||||
name = 'fixture'
|
||||
|
||||
def __init__(self, model_backup, content):
|
||||
self.model_backup = model_backup
|
||||
self.content = content
|
||||
|
||||
@property
|
||||
def filename(self):
|
||||
return self.make_filename(self.__class__.name)
|
||||
|
||||
def save(self):
|
||||
return ContentFile(name=self.filename, content=self.content)
|
||||
|
||||
#def load(self):
|
||||
|
||||
|
||||
# Element backup
|
||||
class ElementBackupBase(object):
|
||||
"""
|
||||
Sub classes must provide at least:
|
||||
info()
|
||||
backup()
|
||||
restore()
|
||||
"""
|
||||
|
||||
label = _(u'Base backup manager')
|
||||
|
||||
def info(self):
|
||||
"""
|
||||
Must return at least None
|
||||
"""
|
||||
return None
|
||||
|
||||
def link(self, app_backup):
|
||||
self.app_backup = app_backup
|
||||
return self
|
||||
|
||||
def __unicode__(self):
|
||||
return unicode(self.__class__.label)
|
||||
|
||||
|
||||
class ModelBackup(ElementBackupBase):
|
||||
label = _(u'Model fixtures')
|
||||
|
||||
def __init__(self, models=None):
|
||||
self.model_list = models or []
|
||||
|
||||
def info(self):
|
||||
return _(u'models: %s') % (u', '.join(self.model_list) if self.model_list else _(u'All'))
|
||||
|
||||
def backup(self):
|
||||
"""
|
||||
"""
|
||||
#TODO: turn into a generator
|
||||
|
||||
command = Command()
|
||||
if not self.model_list:
|
||||
result = [self.app_backup.app.name]
|
||||
else:
|
||||
result = [u'%s.%s' (self.app_backup.app.name, model) for model in self.model_list]
|
||||
|
||||
#TODO: a single Fixture or a list of Fixtures for each model?
|
||||
#Can't return multiple Fixture until a way to find all of an app's models is found
|
||||
return [Fixture(
|
||||
model_backup=self,
|
||||
content=command.handle(u' '.join(result), format='json', indent=4, using=DEFAULT_DB_ALIAS, exclude=[], user_base_manager=False, use_natural_keys=False)
|
||||
)]
|
||||
|
||||
|
||||
class FileBackup(ElementBackupBase):
|
||||
label = _(u'File copy')
|
||||
|
||||
def __init__(self, storage_class, filepath=None):
|
||||
self.storage_class = storage_class
|
||||
self.filepath = filepath
|
||||
|
||||
def info(self):
|
||||
return _(u'%s from %s') % (self.filepath or _(u'all files'), self.storage_class)
|
||||
|
||||
def backup(self):
|
||||
"""
|
||||
Fetch a file specified by filepath from the Django storage class
|
||||
and return a file like object
|
||||
"""
|
||||
return None
|
||||
|
||||
|
||||
# App config
|
||||
class AppBackup(object):
|
||||
_registry = {}
|
||||
|
||||
STATE_BACKING_UP = 'backing_up'
|
||||
STATE_RESTORING = 'restoring'
|
||||
STATE_IDLE = 'idle'
|
||||
|
||||
STATE_CHOICES = (
|
||||
(STATE_BACKING_UP, _(u'backing up')),
|
||||
(STATE_RESTORING, _(u'restoring')),
|
||||
(STATE_IDLE, _(u'idle')),
|
||||
)
|
||||
|
||||
@classmethod
|
||||
def get(cls, name):
|
||||
return cls._registry[name]
|
||||
|
||||
@classmethod
|
||||
def get_all(cls):
|
||||
return cls._registry.values()
|
||||
|
||||
def __init__(self, app, backup_managers):
|
||||
# app = App instance from app_registry app
|
||||
self.app = app
|
||||
self.backup_managers = [manager.link(self) for manager in backup_managers]
|
||||
self.state = self.__class__.STATE_IDLE
|
||||
self.__class__._registry[app] = self
|
||||
|
||||
def info(self):
|
||||
results = []
|
||||
for manager in self.backup_managers:
|
||||
results.append(u'%s - %s' % (manager, manager.info() or _(u'Nothing')))
|
||||
return u', '.join(results)
|
||||
|
||||
def backup(self, storage_module, dry_run=False):
|
||||
logger.debug('starting')
|
||||
|
||||
self.state = self.__class__.STATE_BACKING_UP
|
||||
for manager in self.backup_managers:
|
||||
result = manager.backup()
|
||||
storage_module.backup(result, dry_run=dry_run)
|
||||
self.state = self.__class__.STATE_IDLE
|
||||
|
||||
def restore(self, storage_module=None):
|
||||
logger.debug('starting')
|
||||
self.state = self.__class__.STATE_RESTORING
|
||||
for manager in self.backup_managers:
|
||||
manager.restore(storage_module.restore())
|
||||
self.state = self.__class__.STATE_IDLE
|
||||
|
||||
def __unicode__(self):
|
||||
return unicode(self.app)
|
||||
|
||||
|
||||
#Storage
|
||||
class StorageModuleBase(object):
|
||||
_registry = {}
|
||||
|
||||
# Local modules depend on hardware on a node and execute in the Scheduler
|
||||
# of a particular node
|
||||
REALM_LOCAL = 'local'
|
||||
|
||||
# Remote modules can be execute by any node in a cluster and are placed
|
||||
# in the JobQueue
|
||||
REALM_REMOTE = 'remote'
|
||||
|
||||
REALM_CHOICES = (
|
||||
(REALM_LOCAL, _(u'local')),
|
||||
(REALM_REMOTE, _(u'remote')),
|
||||
)
|
||||
|
||||
class UnknownStorageModule(Exception):
|
||||
pass
|
||||
|
||||
@classmethod
|
||||
def register(cls, klass):
|
||||
"""
|
||||
Register a subclass of StorageModuleBase to make it available to the
|
||||
UI
|
||||
"""
|
||||
cls._registry[klass.name] = klass
|
||||
|
||||
@classmethod
|
||||
def get_all(cls):
|
||||
return cls._registry.values()
|
||||
|
||||
@classmethod
|
||||
def get(cls, name):
|
||||
try:
|
||||
return cls._registry[name]
|
||||
except KeyError:
|
||||
raise cls.UnknownStorageModule
|
||||
|
||||
@classmethod
|
||||
def get_as_choices(cls):
|
||||
return [(name, unicode(klass.label)) for name, klass in cls._registry.items()]
|
||||
|
||||
def get_arguments(self):
|
||||
return []
|
||||
|
||||
def is_local_realm(self):
|
||||
return self.realm == REALM_LOCAL
|
||||
|
||||
def is_remote_realm(self):
|
||||
return self.realm == REALM_REMOTE
|
||||
|
||||
def backup(self, data, dry_run):
|
||||
raise NotImplemented
|
||||
|
||||
def restore(self):
|
||||
"""
|
||||
Must return data or a file like object
|
||||
"""
|
||||
raise NotImplemented
|
||||
|
||||
def __unicode__(self):
|
||||
return unicode(self.label)
|
||||
|
||||
|
||||
class TestStorage(StorageModuleBase):
|
||||
name = 'test_storage'
|
||||
label = _(u'Test storage module')
|
||||
realm = StorageModuleBase.REALM_LOCAL
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
self.backup_path = kwargs.pop('backup_path', None)
|
||||
self.restore_path = kwargs.pop('restore_path', None)
|
||||
|
||||
def get_arguments(self):
|
||||
return ['backup_path', 'restore_path']
|
||||
|
||||
def backup(self, elements, dry_run):
|
||||
logger.debug('self.backup_path: %s' % self.backup_path)
|
||||
|
||||
for element in elements:
|
||||
content_file = element.save()
|
||||
logger.debug('element.filename: %s' % element.filename)
|
||||
logger.debug('element.content: %s' % element.content)
|
||||
|
||||
def restore(self):
|
||||
print 'restore from path: %s' % self.restore_path
|
||||
return 'sample_data'
|
||||
|
||||
|
||||
class LocalFileSystemStorage(FileSystemStorage):
|
||||
"""
|
||||
Simple wrapper for the stock Django FileSystemStorage class
|
||||
"""
|
||||
name = 'local_filesystem_storage'
|
||||
label = _(u'Local filesystem')
|
||||
realm = StorageModuleBase.REALM_LOCAL
|
||||
|
||||
separator = os.path.sep
|
||||
|
||||
def get_arguments(self):
|
||||
return ['backup_path', 'restore_path']
|
||||
|
||||
def backup(self, elements, dry_run):
|
||||
logger.debug('self.backup_path: %s' % self.backup_path)
|
||||
for element in elements:
|
||||
content_file = element.save()
|
||||
path = self.storage.save(content_file.name, content_file)
|
||||
logger.debug('element.filename: %s' % element.filename)
|
||||
logger.debug('element.content: %s' % element.content)
|
||||
|
||||
def restore(self):
|
||||
print 'restore from path: %s' % self.restore_path
|
||||
return 'sample_data'
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
self.backup_path = kwargs.pop('backup_path', None)
|
||||
self.storage = FileSystemStorage(location=self.backup_path)
|
||||
|
||||
|
||||
StorageModuleBase.register(LocalFileSystemStorage)
|
||||
StorageModuleBase.register(TestStorage)
|
||||
@@ -0,0 +1,20 @@
|
||||
from __future__ import absolute_import
|
||||
|
||||
from django import forms
|
||||
|
||||
from common.widgets import ScrollableCheckboxSelectMultiple
|
||||
|
||||
from .classes import AppBackup
|
||||
from .models import App, BackupJob
|
||||
|
||||
|
||||
def valid_app_choices():
|
||||
# Return app that exist in the app registry and that have been registered for backup
|
||||
return App.live.filter(pk__in=[appbackup.app.pk for appbackup in AppBackup.get_all()])
|
||||
|
||||
|
||||
class BackupJobForm(forms.ModelForm):
|
||||
apps = forms.ModelMultipleChoiceField(queryset=valid_app_choices(), widget=ScrollableCheckboxSelectMultiple())
|
||||
|
||||
class Meta:
|
||||
model = BackupJob
|
||||
@@ -6,7 +6,16 @@ from navigation.api import Link
|
||||
from icons.api import get_icon_name, get_sprite_name
|
||||
from icons.literals import APP
|
||||
|
||||
#from .permissions import PERMISSION_BACKUP_JOB_VIEW, PERMISSION_BACKUP_JOB_CREATE, PERMISSION_BACKUP_JOB_EDIT, PERMISSION_BACKUP_JOB_DELETE
|
||||
from .permissions import PERMISSION_BACKUP_JOB_VIEW, PERMISSION_BACKUP_JOB_CREATE, PERMISSION_BACKUP_JOB_EDIT, PERMISSION_BACKUP_JOB_DELETE
|
||||
|
||||
app_registry_tool_link = Link(text=_(u'Apps'), view='app_list', icon=get_icon_name(APP))#, permissions=[PERMISSION_BACKUP_JOB_VIEW])
|
||||
app_list = Link(text=_(u'app list'), view='app_list', sprite=get_sprite_name(APP))#, permissions=[PERMISSION_BACKUP_JOB_VIEW])
|
||||
|
||||
backup_tool_link = Link(text=_(u'backups'), view='backup_job_list', icon='cd_burn.png', permissions=[PERMISSION_BACKUP_JOB_VIEW])
|
||||
backup_job_list = Link(text=_(u'backup job list'), view='backup_job_list', sprite='cd_burn', permissions=[PERMISSION_BACKUP_JOB_VIEW])
|
||||
backup_job_create = Link(text=_(u'create'), view='backup_job_create', sprite='cd_add', permissions=[PERMISSION_BACKUP_JOB_CREATE])
|
||||
backup_job_edit = Link(text=_(u'edit'), view='backup_job_edit', args='object.pk', sprite='cd_edit', permissions=[PERMISSION_BACKUP_JOB_EDIT])
|
||||
backup_job_test = Link(text=_(u'test'), view='backup_job_test', args='object.pk', sprite='cd_go')#, permissions=[PERMISSION_BACKUP_JOB_TEST])
|
||||
backup_job_delete = Link(text=_(u'delete'), view='backup_job_delete', args='object.pk', sprite='cd_delete', permissions=[PERMISSION_BACKUP_JOB_DELETE])
|
||||
|
||||
restore_tool_link = Link(text=_(u'restore'), view='restore_view', icon='cd_eject.png')#, permissions=[])
|
||||
|
||||
+61
-43
@@ -1,57 +1,21 @@
|
||||
from __future__ import absolute_import
|
||||
|
||||
import datetime
|
||||
import logging
|
||||
|
||||
from django.db import models
|
||||
from django.utils.translation import ugettext_lazy as _
|
||||
from django.utils.translation import ugettext
|
||||
from django.contrib.contenttypes.models import ContentType
|
||||
from django.contrib.contenttypes import generic
|
||||
|
||||
from common.models import TranslatableLabelMixin, LiveObjectMixin
|
||||
|
||||
from .classes import AppBackup, StorageModuleBase
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class TranslatableLabelMixin(models.Model):
|
||||
_labels = {}
|
||||
|
||||
@property
|
||||
def label(self):
|
||||
try:
|
||||
return self.__class__._labels[self.pk]
|
||||
except KeyError:
|
||||
return unicode(self.__class__)
|
||||
|
||||
def __setattr__(self, attr, value):
|
||||
if attr == 'label':
|
||||
self.__class__._labels[self.pk] = value
|
||||
else:
|
||||
return super(TranslatableLabelMixin, self).__setattr__(attr, value)
|
||||
|
||||
def __unicode__(self):
|
||||
return unicode(self.label)
|
||||
|
||||
class Meta:
|
||||
abstract = True
|
||||
|
||||
|
||||
class LiveObjectsManager(models.Manager):
|
||||
def get_query_set(self):
|
||||
return super(LiveObjectsManager, self).get_query_set().filter(pk__in=(entry.pk for entry in self.model._registry))
|
||||
|
||||
|
||||
class LiveObjectMixin(models.Model):
|
||||
_registry = []
|
||||
|
||||
def save(self, *args, **kwargs):
|
||||
super(LiveObjectMixin, self).save(*args, **kwargs)
|
||||
self.__class__._registry.append(self)
|
||||
return self
|
||||
|
||||
live = LiveObjectsManager()
|
||||
objects = models.Manager()
|
||||
|
||||
class Meta:
|
||||
abstract = True
|
||||
|
||||
|
||||
class App(TranslatableLabelMixin, LiveObjectMixin, models.Model):
|
||||
name = models.CharField(max_length=64, verbose_name=_(u'name'), unique=True)
|
||||
icon = models.CharField(max_length=64, verbose_name=_(u'icon'), blank=True)
|
||||
@@ -60,3 +24,57 @@ class App(TranslatableLabelMixin, LiveObjectMixin, models.Model):
|
||||
ordering = ('name', )
|
||||
verbose_name = _(u'app')
|
||||
verbose_name_plural = _(u'apps')
|
||||
|
||||
|
||||
class BackupJob(models.Model):
|
||||
name = models.CharField(max_length=64, verbose_name=_(u'name'))
|
||||
enabled = models.BooleanField(default=True, verbose_name=_(u'enabled'))
|
||||
apps = models.ManyToManyField(App)
|
||||
begin_datetime = models.DateTimeField(verbose_name=_(u'begin date and time'), default=lambda: datetime.datetime.now())
|
||||
|
||||
# * repetition =
|
||||
# day - 1 days
|
||||
# weekly - days of week checkbox
|
||||
# month - day of month, day of week
|
||||
# * repetition option field
|
||||
# * ends
|
||||
# - never
|
||||
# - After # ocurrences
|
||||
# - On date
|
||||
# * end option field
|
||||
# * type
|
||||
# - Full
|
||||
# - Incremental
|
||||
storage_module_name = models.CharField(max_length=32, choices=StorageModuleBase.get_as_choices(), verbose_name=_(u'storage module'))
|
||||
storage_arguments_json = models.TextField(verbose_name=_(u'storage module arguments (in JSON)'), blank=True)
|
||||
|
||||
def __unicode__(self):
|
||||
return self.name
|
||||
|
||||
@property
|
||||
def storage_module(self):
|
||||
return StorageModuleBase.get(self.storage_module_name)
|
||||
|
||||
def backup(self, dry_run=False):
|
||||
logger.debug('starting: %s', self)
|
||||
logger.debug('dry_run: %s' % dry_run)
|
||||
storage_module = self.storage_module
|
||||
#TODO: loads
|
||||
for app in self.apps.all():
|
||||
app_backup = AppBackup.get(app)
|
||||
app_backup.backup(storage_module(backup_path='/tmp'), dry_run=dry_run)
|
||||
|
||||
def save(self, *args, **kwargs):
|
||||
#dump
|
||||
super(BackupJob, self).save(*args, **kwargs)
|
||||
|
||||
@models.permalink
|
||||
def get_absolute_url(self):
|
||||
return ('checkout_info', [self.document.pk])
|
||||
|
||||
class Meta:
|
||||
verbose_name = _(u'document checkout')
|
||||
verbose_name_plural = _(u'document checkouts')
|
||||
|
||||
|
||||
#class BackupJobLog
|
||||
|
||||
@@ -0,0 +1,12 @@
|
||||
from __future__ import absolute_import
|
||||
|
||||
from django.utils.translation import ugettext_lazy as _
|
||||
|
||||
from permissions.models import PermissionNamespace, Permission
|
||||
|
||||
namespace = PermissionNamespace('backups', _(u'Backups'))
|
||||
|
||||
PERMISSION_BACKUP_JOB_VIEW = Permission.objects.register(namespace, 'backup_job_view', _(u'View a backup job'))
|
||||
PERMISSION_BACKUP_JOB_CREATE = Permission.objects.register(namespace, 'backup_job_view', _(u'Create backup jobs'))
|
||||
PERMISSION_BACKUP_JOB_EDIT = Permission.objects.register(namespace, 'backup_job_edit', _(u'Edit an existing backup jobs'))
|
||||
PERMISSION_BACKUP_JOB_DELETE = Permission.objects.register(namespace, 'backup_job_delete', _(u'Delete an existing backup jobs'))
|
||||
@@ -2,4 +2,9 @@ from django.conf.urls.defaults import patterns, url
|
||||
|
||||
urlpatterns = patterns('app_registry.views',
|
||||
url(r'^list/$', 'app_list', (), 'app_list'),
|
||||
url(r'^jobs/list/$', 'backup_job_list', (), 'backup_job_list'),
|
||||
url(r'^jobs/create/$', 'backup_job_create', (), 'backup_job_create'),
|
||||
url(r'^jobs/(?P<backup_job_pk>\d+)/edit/$', 'backup_job_edit', (), 'backup_job_edit'),
|
||||
url(r'^jobs/(?P<backup_job_pk>\d+)/test/$', 'backup_job_test', (), 'backup_job_test'),
|
||||
#url(r'^jobs/(?P<backup_job_pk>\d+)/delete/$', 'backup_job_delete', (), 'backup_job_delete'),
|
||||
)
|
||||
|
||||
+119
-3
@@ -1,12 +1,19 @@
|
||||
from __future__ import absolute_import
|
||||
|
||||
from django.http import HttpResponse, HttpResponseRedirect
|
||||
from django.conf import settings
|
||||
from django.contrib import messages
|
||||
from django.core.urlresolvers import reverse
|
||||
from django.http import HttpResponseRedirect
|
||||
from django.shortcuts import render_to_response, get_object_or_404
|
||||
from django.template import RequestContext
|
||||
from django.utils.translation import ugettext as _
|
||||
from django.core.urlresolvers import reverse
|
||||
|
||||
from .models import App
|
||||
from permissions.models import Permission
|
||||
|
||||
from .classes import AppBackup
|
||||
from .forms import BackupJobForm
|
||||
from .models import App, BackupJob
|
||||
from .permissions import PERMISSION_BACKUP_JOB_VIEW, PERMISSION_BACKUP_JOB_CREATE, PERMISSION_BACKUP_JOB_EDIT
|
||||
|
||||
|
||||
def app_list(request):
|
||||
@@ -21,3 +28,112 @@ def app_list(request):
|
||||
{'name': _(u'icon'), 'attribute': 'icon'},
|
||||
],
|
||||
}, context_instance=RequestContext(request))
|
||||
|
||||
|
||||
def backup_job_list(request):
|
||||
pre_object_list = BackupJob.objects.all()
|
||||
|
||||
try:
|
||||
Permission.objects.check_permissions(request.user, [PERMISSION_BACKUP_JOB_VIEW])
|
||||
except PermissionDenied:
|
||||
# If user doesn't have global permission, get a list of backup jobs
|
||||
# for which he/she does have access use it to filter the
|
||||
# provided object_list
|
||||
final_object_list = AccessEntry.objects.filter_objects_by_access(PERMISSION_BACKUP_JOB_VIEW, request.user, pre_object_list)
|
||||
else:
|
||||
final_object_list = pre_object_list
|
||||
|
||||
context = {
|
||||
'object_list': final_object_list,
|
||||
'title': _(u'backup jobs'),
|
||||
'hide_link': True,
|
||||
#'extra_columns': [
|
||||
# {'name': _(u'info'), 'attribute': 'info'},
|
||||
#],
|
||||
}
|
||||
return render_to_response('generic_list.html', context,
|
||||
context_instance=RequestContext(request))
|
||||
|
||||
|
||||
def backup_job_create(request):
|
||||
Permission.objects.check_permissions(request.user, [PERMISSION_BACKUP_JOB_CREATE])
|
||||
|
||||
if request.method == 'POST':
|
||||
form = BackupJobForm(data=request.POST)
|
||||
if form.is_valid():
|
||||
try:
|
||||
backup_job = form.save()
|
||||
except Exception, exc:
|
||||
messages.error(request, _(u'Error creating backup job; %s') % exc)
|
||||
else:
|
||||
messages.success(request, _(u'Backup job "%s" created successfully.') % backup_job)
|
||||
return HttpResponseRedirect(reverse('backup_job_list'))
|
||||
else:
|
||||
form = BackupJobForm()
|
||||
|
||||
return render_to_response('generic_form.html', {
|
||||
'form': form,
|
||||
'title': _(u'Create backup job')
|
||||
}, context_instance=RequestContext(request))
|
||||
|
||||
|
||||
def backup_job_edit(request, backup_job_pk):
|
||||
backup_job = get_object_or_404(BackupJob, pk=backup_job_pk)
|
||||
try:
|
||||
Permission.objects.check_permissions(request.user, [PERMISSION_BACKUP_JOB_EDIT])
|
||||
except PermissionDenied:
|
||||
AccessEntry.objects.check_access(PERMISSION_BACKUP_JOB_EDIT, request.user, backup_job)
|
||||
|
||||
if request.method == 'POST':
|
||||
form = BackupJobForm(data=request.POST, instance=backup_job)
|
||||
if form.is_valid():
|
||||
try:
|
||||
backup_job = form.save()
|
||||
except Exception, exc:
|
||||
messages.error(request, _(u'Error editing backup job; %s') % exc)
|
||||
else:
|
||||
messages.success(request, _(u'Backup job "%s" edited successfully.') % backup_job)
|
||||
return HttpResponseRedirect(reverse('backup_job_list'))
|
||||
else:
|
||||
form = BackupJobForm(instance=backup_job)
|
||||
|
||||
return render_to_response('generic_form.html', {
|
||||
'form': form,
|
||||
'object': backup_job,
|
||||
'title': _(u'Edit backup job: %s') % backup_job
|
||||
}, context_instance=RequestContext(request))
|
||||
|
||||
|
||||
def backup_job_test(request, backup_job_pk):
|
||||
backup_job = get_object_or_404(BackupJob, pk=backup_job_pk)
|
||||
#try:
|
||||
# Permission.objects.check_permissions(request.user, [PERMISSION_BACKUP_JOB_EDIT])
|
||||
#except PermissionDenied:
|
||||
# AccessEntry.objects.check_access(PERMISSION_BACKUP_JOB_EDIT, request.user, backup_job)
|
||||
|
||||
try:
|
||||
backup_job.backup(dry_run=True)
|
||||
except Exception, exc:
|
||||
if settings.DEBUG:
|
||||
raise
|
||||
else:
|
||||
messages.error(request, _(u'Error testing backup job; %s') % exc)
|
||||
return HttpResponseRedirect(reverse('backup_job_list'))
|
||||
else:
|
||||
messages.success(request, _(u'Test for backup job "%s" finished successfully.') % backup_job)
|
||||
return HttpResponseRedirect(reverse('backup_job_list'))
|
||||
|
||||
|
||||
def backup_view(request):
|
||||
#Permission.objects.check_permissions(request.user, [])
|
||||
|
||||
context = {
|
||||
'object_list': AppBackup.get_all(),
|
||||
'title': _(u'registered apps for backup'),
|
||||
'hide_link': True,
|
||||
'extra_columns': [
|
||||
{'name': _(u'info'), 'attribute': 'info'},
|
||||
],
|
||||
}
|
||||
return render_to_response('generic_list.html', context,
|
||||
context_instance=RequestContext(request))
|
||||
|
||||
Reference in New Issue
Block a user