haiwen/seahub
1
0
Fork 0
mirror of https://github.com/haiwen/seahub.git synced 2025-07-10 21:54:33 +00:00
Code Issues Releases Wiki Activity

send activity email when org register

Browse Source
This commit is contained in:
lian 2025-04-02 16:14:00 +08:00
parent 09581a961a
commit 04f948f7e4
3 changed files with 107 additions and 82 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
seahub/organizations/views.py
View File

@ -6,16 +6,14 @@ import json
from urllib.parse import urlparse
from constance import config
from django.conf import settings
from django.contrib import messages
from django.contrib.sites.shortcuts import get_current_site
from django.urls import reverse
from django.core.cache import cache
from django.utils.translation import gettext_lazy as _
from django.http import HttpResponse, Http404, HttpResponseRedirect
from django.shortcuts import render
from django.utils.crypto import get_random_string
from django.core.cache import cache
from django.shortcuts import render
from django.http import HttpResponse, Http404, HttpResponseRedirect
import seaserv
from seaserv import ccnet_api
@ -38,7 +36,7 @@ from seahub.organizations.settings import ORG_AUTO_URL_PREFIX, \
ORG_ENABLE_ADMIN_INVITE_USER
from seahub.organizations.utils import get_or_create_invitation_link
from seahub.subscription.utils import subscription_check
from constance import config
from registration.models import RegistrationProfile
# Get an instance of a logger
@ -47,46 +45,58 @@ logger = logging.getLogger(__name__)
ENABLE_MULTI_ADFS = getattr(settings, 'ENABLE_MULTI_ADFS', False)
########## ccnet rpc wrapper
# ccnet rpc wrapper
def create_org(org_name, url_prefix, creator):
return seaserv.create_org(org_name, url_prefix, creator)
def count_orgs():
return seaserv.ccnet_threaded_rpc.count_orgs()
def get_org_by_url_prefix(url_prefix):
return seaserv.ccnet_threaded_rpc.get_org_by_url_prefix(url_prefix)
def set_org_user(org_id, username, is_staff=False):
return seaserv.ccnet_threaded_rpc.add_org_user(org_id, username,
int(is_staff))
def unset_org_user(org_id, username):
return seaserv.ccnet_threaded_rpc.remove_org_user(org_id, username)
def org_user_exists(org_id, username):
return seaserv.ccnet_threaded_rpc.org_user_exists(org_id, username)
def get_org_groups(org_id, start, limit):
return seaserv.ccnet_threaded_rpc.get_org_groups(org_id, start, limit)
def get_org_id_by_group(group_id):
return seaserv.ccnet_threaded_rpc.get_org_id_by_group(group_id)
def remove_org_group(org_id, group_id, username):
remove_group_common(group_id, username)
seaserv.ccnet_threaded_rpc.remove_org_group(org_id, group_id)
def is_org_staff(org_id, username):
return seaserv.ccnet_threaded_rpc.is_org_staff(org_id, username)
def set_org_staff(org_id, username):
return seaserv.ccnet_threaded_rpc.set_org_staff(org_id, username)
def unset_org_staff(org_id, username):
return seaserv.ccnet_threaded_rpc.unset_org_staff(org_id, username)
########## seafile rpc wrapper
# seafile rpc wrapper
def get_org_user_self_usage(org_id, username):
"""
@ -96,17 +106,21 @@ def get_org_user_self_usage(org_id, username):
"""
return seaserv.seafserv_threaded_rpc.get_org_user_quota_usage(org_id, username)
def get_org_user_quota(org_id, username):
return seaserv.seafserv_threaded_rpc.get_org_user_quota(org_id, username)
def get_org_quota(org_id):
return seaserv.seafserv_threaded_rpc.get_org_quota(org_id)
def is_org_repo(org_id, repo_id):
return True if seaserv.seafserv_threaded_rpc.get_org_id_by_repo_id(
repo_id) == org_id else False
########## views
# views
@login_required_ajax
def org_add(request):
"""Handle ajax request to add org, and create org owner.
@ -149,6 +163,7 @@ def org_add(request):
return HttpResponse(json.dumps({'error': str(err_msg)}),
status=400, content_type=content_type)
def gen_org_url_prefix(max_trial=None):
"""Generate organization url prefix automatically.
If ``max_trial`` is large than 0, then re-try that times if failed.
@ -183,6 +198,7 @@ def gen_org_url_prefix(max_trial=None):
logger.warning("Failed to generate org url prefix, retry: %d" % max_trial)
return None
def org_register(request):
"""Allow a new user to register an organization account. A new
organization will be created associate with that user.
@ -217,8 +233,19 @@ def org_register(request):
org_name = form.cleaned_data['org_name']
url_prefix = form.cleaned_data['url_prefix']
new_user = User.objects.create_user(email, password,
is_staff=False, is_active=True)
username = email
site = get_current_site(request)
if bool(config.ACTIVATE_AFTER_REGISTRATION) is True:
new_user = RegistrationProfile.objects.create_active_user(username, email,
password, site,
send_email=False)
else:
# create inactive user, user can be activated by admin,
# or through activated email
new_user = RegistrationProfile.objects.create_inactive_user(username, email,
password, site,
send_email=config.REGISTRATION_SEND_MAIL)
create_org(org_name, url_prefix, new_user.username)
new_org = get_org_by_url_prefix(url_prefix)
org_created.send(sender=None, org=new_org)
@ -226,11 +253,13 @@ def org_register(request):
if name:
Profile.objects.add_or_update(new_user.username, name)
# login the user
if new_user.is_active:
new_user.backend = settings.AUTHENTICATION_BACKENDS[0]
login(request, new_user)
return HttpResponseRedirect(reverse('libraries'))
else:
return HttpResponseRedirect(reverse('registration_complete'))
else:
form = OrgRegistrationForm()
@ -245,9 +274,9 @@ def org_register(request):
'service_url_remaining': service_url_remaining,
'org_auto_url_prefix': ORG_AUTO_URL_PREFIX,
'strong_pwd_required': config.USER_STRONG_PASSWORD_REQUIRED
})
@login_required
@org_staff_required
def react_fake_view(request, **kwargs):
@ -271,6 +300,7 @@ def react_fake_view(request, **kwargs):
'sys_enable_encrypted_library': config.ENABLE_ENCRYPTED_LIBRARY
})
@login_required
def org_associate(request, token):
"""Associate user with coresponding org.

51
thirdpart/registration/models.py
View File

@ -1,19 +1,27 @@
import datetime
import hashlib
import random
import re
import random
import hashlib
import logging
import datetime
from constance import config
from urllib.parse import quote
from django.conf import settings
from django.db import models
# from django.db import transaction
from django.urls import reverse
from django.dispatch import receiver
from django.template.loader import render_to_string
from django.utils.translation import gettext_lazy as _
from seahub.base.accounts import User
from seahub.utils import send_html_email
from seahub.profile.models import Profile
from seahub.utils import send_html_email, get_site_scheme_and_netloc
from registration.signals import user_registered
logger = logging.getLogger(__name__)
SHA1_RE = re.compile('^[a-f0-9]{40}$')
@ -92,14 +100,12 @@ class RegistrationManager(models.Manager):
return self.create_email_user(username, email, password, site,
send_email, is_active=False)
# create_inactive_user = transaction.commit_on_success(create_inactive_user)
def create_active_user(self, username, email, password,
site, send_email=True):
return self.create_email_user(username, email, password, site,
send_email, is_active=True)
# create_inactive_user = transaction.commit_on_success(create_inactive_user)
def create_profile(self, user):
"""
@ -118,7 +124,7 @@ class RegistrationManager(models.Manager):
# Take the first 16 character to avoid errors.
# (1406, "Data too long for column 'activation_key' at row 1")
activation_key = hashlib.sha256(salt+username).hexdigest()[:16]
activation_key = hashlib.sha256(salt+username).hexdigest()[:40]
return self.create(emailuser_id=user.id,
activation_key=activation_key)
@ -232,8 +238,11 @@ class RegistrationProfile(models.Model):
except User.DoesNotExist:
return False
return self.activation_key == self.ACTIVATED or \
(datetime.datetime.fromtimestamp(user.ctime/1000000) + expiration_date <= datetime.datetime.now())
return (
self.activation_key == self.ACTIVATED
or (datetime.datetime.fromtimestamp(user.ctime/1000000) + expiration_date
<= datetime.datetime.now())
)
activation_key_expired.boolean = True
@ -275,10 +284,10 @@ class RegistrationProfile(models.Model):
framework for details regarding these objects' interfaces.
"""
ctx_dict = { 'activation_key': self.activation_key,
ctx_dict = {'activation_key': self.activation_key,
'expiration_days': settings.ACCOUNT_ACTIVATION_DAYS,
'site': site,
'SITE_ROOT': settings.SITE_ROOT }
'SITE_ROOT': settings.SITE_ROOT}
subject = render_to_string('registration/activation_email_subject.txt',
ctx_dict)
# Email subject *must not* contain newlines
@ -297,21 +306,7 @@ class RegistrationProfile(models.Model):
pass
########## signal handlers
import logging
from django.urls import reverse
from django.dispatch import receiver
from urllib.parse import quote
from registration.signals import user_registered
from seahub.utils import get_site_scheme_and_netloc
from constance import config
# Get an instance of a logger
logger = logging.getLogger(__name__)
# signal handlers
def notify_admins_on_activate_request(reg_email):
ctx_dict = {
"site_name": settings.SITE_NAME,
@ -335,6 +330,7 @@ def notify_admins_on_activate_request(reg_email):
except Exception as e:
logger.error(e)
def notify_admins_on_register_complete(reg_email):
ctx_dict = {
"site_name": settings.SITE_NAME,
@ -359,6 +355,7 @@ def notify_admins_on_register_complete(reg_email):
except Exception as e:
logger.error(e)
@receiver(user_registered)
def email_admin_on_registration(sender, **kwargs):
"""Send an email notification to admin when a newly registered user need

4
thirdpart/registration/views.py
View File

@ -92,9 +92,7 @@ def activate(request, backend,
for key, value in list(extra_context.items()):
context[key] = callable(value) and value() or value
return render(request, template_name,
kwargs,
context=context)
return render(request, template_name, context=context)
def register(request, backend, success_url=None, form_class=None,