mirror of
https://github.com/freedombox/FreedomBox.git
synced 2026-01-21 07:55:00 +00:00
a233bbfd9b
- Helps in retrieving an operation that is currently running. - Prevent starting an operation that is already running. Tests: - Unit tests work. - Installing, uninstalling an app works. - For upgrading an app works. - Running background diagnostics works. - Updating tor configuration works. - Updating torproxy configuration works. Signed-off-by: Sunil Mohan Adapa <sunil@medhas.org> Reviewed-by: James Valleroy <jvalleroy@mailbox.org>
110 lines
3.5 KiB
Python
110 lines
3.5 KiB
Python
# SPDX-License-Identifier: AGPL-3.0-or-later
|
|
"""FreedomBox app for configuring Tor."""
|
|
|
|
import logging
|
|
|
|
from django.utils.translation import gettext_noop
|
|
from django.views.generic.edit import FormView
|
|
|
|
from plinth import app as app_module
|
|
from plinth import operation as operation_module
|
|
from plinth.modules import tor
|
|
from plinth.views import AppView
|
|
|
|
from . import privileged
|
|
from . import utils as tor_utils
|
|
from .forms import TorForm
|
|
|
|
config_process = None
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class TorAppView(AppView):
|
|
"""Show Tor app main page."""
|
|
|
|
app_id = 'tor'
|
|
template_name = 'tor.html'
|
|
form_class = TorForm
|
|
prefix = 'tor'
|
|
|
|
status = None
|
|
|
|
def get_initial(self):
|
|
"""Return the values to fill in the form."""
|
|
if not self.status:
|
|
self.status = tor_utils.get_status()
|
|
|
|
initial = super().get_initial()
|
|
initial.update(self.status)
|
|
return initial
|
|
|
|
def get_context_data(self, *args, **kwargs):
|
|
"""Add additional context data for template."""
|
|
if not self.status:
|
|
self.status = tor_utils.get_status()
|
|
|
|
context = super().get_context_data(*args, **kwargs)
|
|
context['status'] = self.status
|
|
return context
|
|
|
|
def form_valid(self, form):
|
|
"""Configure tor app on successful form submission."""
|
|
operation_module.manager.new('tor-configuration', self.app_id,
|
|
gettext_noop('Updating configuration'),
|
|
_apply_changes,
|
|
[form.initial, form.cleaned_data],
|
|
show_notification=False)
|
|
# Skip check for 'Settings unchanged' message by calling grandparent
|
|
return super(FormView, self).form_valid(form)
|
|
|
|
|
|
def _apply_changes(old_status, new_status):
|
|
"""Try to apply changes and handle errors."""
|
|
logger.info('tor: applying configuration changes')
|
|
exception_to_update = None
|
|
message = None
|
|
try:
|
|
__apply_changes(old_status, new_status)
|
|
except Exception as exception:
|
|
exception_to_update = exception
|
|
message = gettext_noop('Error configuring app: {error}').format(
|
|
error=exception)
|
|
else:
|
|
message = gettext_noop('Configuration updated.')
|
|
|
|
logger.info('tor: configuration changes completed')
|
|
operation = operation_module.Operation.get_operation()
|
|
operation.on_update(message, exception_to_update)
|
|
|
|
|
|
def __apply_changes(old_status, new_status):
|
|
"""Apply the changes."""
|
|
arguments = {}
|
|
app = app_module.App.get('tor')
|
|
is_enabled = app.is_enabled()
|
|
|
|
if old_status['relay_enabled'] != new_status['relay_enabled']:
|
|
arguments['relay'] = new_status['relay_enabled']
|
|
|
|
if old_status['bridge_relay_enabled'] != \
|
|
new_status['bridge_relay_enabled']:
|
|
arguments['bridge_relay'] = new_status['bridge_relay_enabled']
|
|
|
|
if old_status['hs_enabled'] != new_status['hs_enabled']:
|
|
arguments['hidden_service'] = new_status['hs_enabled']
|
|
|
|
if old_status['use_upstream_bridges'] != \
|
|
new_status['use_upstream_bridges']:
|
|
arguments['use_upstream_bridges'] = new_status['use_upstream_bridges']
|
|
|
|
if old_status['upstream_bridges'] != new_status['upstream_bridges']:
|
|
arguments['upstream_bridges'] = new_status['upstream_bridges']
|
|
|
|
if arguments:
|
|
privileged.configure(**arguments)
|
|
|
|
if is_enabled:
|
|
privileged.restart()
|
|
status = tor_utils.get_status()
|
|
tor.update_hidden_service_domain(status)
|