add predefined_token in initial_datas #6
|
@ -7,9 +7,9 @@ from utils import credtools
|
||||||
from django.conf import settings
|
from django.conf import settings
|
||||||
from django.core.management.base import BaseCommand
|
from django.core.management.base import BaseCommand
|
||||||
from django.contrib.auth import get_user_model
|
from django.contrib.auth import get_user_model
|
||||||
from decouple import config
|
|
||||||
from idhub.models import Schemas
|
from idhub.models import Schemas
|
||||||
from oidc4vp.models import Organization
|
from oidc4vp.models import Organization
|
||||||
|
from webhook.models import Token
|
||||||
|
|
||||||
|
|
||||||
User = get_user_model()
|
User = get_user_model()
|
||||||
|
@ -20,9 +20,13 @@ class Command(BaseCommand):
|
||||||
DOMAIN = settings.DOMAIN
|
DOMAIN = settings.DOMAIN
|
||||||
OIDC_ORGS = settings.OIDC_ORGS
|
OIDC_ORGS = settings.OIDC_ORGS
|
||||||
|
|
||||||
|
def add_arguments(self, parser):
|
||||||
|
parser.add_argument('predefined_token', nargs='?', default='', type=str, help='predefined token')
|
||||||
|
|
||||||
def handle(self, *args, **kwargs):
|
def handle(self, *args, **kwargs):
|
||||||
ADMIN_EMAIL = settings.INITIAL_ADMIN_EMAIL
|
ADMIN_EMAIL = settings.INITIAL_ADMIN_EMAIL
|
||||||
ADMIN_PASSWORD = settings.INITIAL_ADMIN_PASSWORD
|
ADMIN_PASSWORD = settings.INITIAL_ADMIN_PASSWORD
|
||||||
|
self.predefined_token = kwargs['predefined_token']
|
||||||
|
|
||||||
self.create_admin_users(ADMIN_EMAIL, ADMIN_PASSWORD)
|
self.create_admin_users(ADMIN_EMAIL, ADMIN_PASSWORD)
|
||||||
if settings.CREATE_TEST_USERS:
|
if settings.CREATE_TEST_USERS:
|
||||||
|
@ -45,6 +49,9 @@ class Command(BaseCommand):
|
||||||
su = User.objects.create_superuser(email=email, password=password)
|
su = User.objects.create_superuser(email=email, password=password)
|
||||||
su.save()
|
su.save()
|
||||||
|
|
||||||
|
tk = Token.objects.filter(token=self.predefined_token).first()
|
||||||
|
if self.predefined_token and not tk:
|
||||||
|
Token.objects.create(token=self.predefined_token)
|
||||||
|
|
||||||
def create_users(self, email, password):
|
def create_users(self, email, password):
|
||||||
u = User.objects.create(email=email, password=password)
|
u = User.objects.create(email=email, password=password)
|
||||||
|
|
|
@ -684,6 +684,14 @@ class VerificableCredential(models.Model):
|
||||||
if self.status == self.Status.ISSUED:
|
if self.status == self.Status.ISSUED:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
supported = False
|
||||||
|
for name in self.schema.get_schema.get("name"):
|
||||||
|
if name.get("value") in settings.SUPPORTED_CREDENTIALS:
|
||||||
|
supported = True
|
||||||
|
|
||||||
|
if not supported:
|
||||||
|
return
|
||||||
|
|
||||||
self.subject_did = did
|
self.subject_did = did
|
||||||
self.issued_on = datetime.datetime.now().astimezone(pytz.utc)
|
self.issued_on = datetime.datetime.now().astimezone(pytz.utc)
|
||||||
|
|
||||||
|
|
|
@ -5,6 +5,7 @@ from django.utils.translation import gettext_lazy as _
|
||||||
from django.views.decorators.csrf import csrf_exempt
|
from django.views.decorators.csrf import csrf_exempt
|
||||||
from django.views.generic.edit import DeleteView
|
from django.views.generic.edit import DeleteView
|
||||||
from django.views.generic.base import View
|
from django.views.generic.base import View
|
||||||
|
from django.core.cache import cache
|
||||||
from django.http import JsonResponse
|
from django.http import JsonResponse
|
||||||
from django_tables2 import SingleTableView
|
from django_tables2 import SingleTableView
|
||||||
from pyvckit.verify import verify_vp, verify_vc
|
from pyvckit.verify import verify_vp, verify_vc
|
||||||
|
@ -20,6 +21,10 @@ from webhook.tables import TokensTable
|
||||||
@csrf_exempt
|
@csrf_exempt
|
||||||
def webhook_verify(request):
|
def webhook_verify(request):
|
||||||
if request.method == 'POST':
|
if request.method == 'POST':
|
||||||
|
user = User.objects.filter(is_admin=True).first()
|
||||||
|
if not cache.get("KEY_DIDS") or not user.accept_gdpr:
|
||||||
|
return JsonResponse({'error': 'Temporary out of service'}, status=400)
|
||||||
|
|
||||||
auth_header = request.headers.get('Authorization')
|
auth_header = request.headers.get('Authorization')
|
||||||
if not auth_header or not auth_header.startswith('Bearer '):
|
if not auth_header or not auth_header.startswith('Bearer '):
|
||||||
return JsonResponse({'error': 'Invalid or missing token'}, status=401)
|
return JsonResponse({'error': 'Invalid or missing token'}, status=401)
|
||||||
|
@ -56,6 +61,10 @@ def webhook_verify(request):
|
||||||
@csrf_exempt
|
@csrf_exempt
|
||||||
def webhook_issue(request):
|
def webhook_issue(request):
|
||||||
if request.method == 'POST':
|
if request.method == 'POST':
|
||||||
|
user = User.objects.filter(is_admin=True).first()
|
||||||
|
if not cache.get("KEY_DIDS") or not user.accept_gdpr:
|
||||||
|
return JsonResponse({'error': 'Temporary out of service'}, status=400)
|
||||||
|
|
||||||
auth_header = request.headers.get('Authorization')
|
auth_header = request.headers.get('Authorization')
|
||||||
if not auth_header or not auth_header.startswith('Bearer '):
|
if not auth_header or not auth_header.startswith('Bearer '):
|
||||||
return JsonResponse({'error': 'Invalid or missing token'}, status=401)
|
return JsonResponse({'error': 'Invalid or missing token'}, status=401)
|
||||||
|
@ -89,7 +98,6 @@ def webhook_issue(request):
|
||||||
if not schema:
|
if not schema:
|
||||||
return JsonResponse({'error': 'Invalid credential'}, status=400)
|
return JsonResponse({'error': 'Invalid credential'}, status=400)
|
||||||
|
|
||||||
user = User.objects.filter(is_admin=True).first()
|
|
||||||
cred = VerificableCredential(
|
cred = VerificableCredential(
|
||||||
csv_data=vc,
|
csv_data=vc,
|
||||||
issuer_did=did,
|
issuer_did=did,
|
||||||
|
@ -100,6 +108,9 @@ def webhook_issue(request):
|
||||||
cred.set_type()
|
cred.set_type()
|
||||||
vc_signed = cred.issue(did, domain=request.get_host(), save=save)
|
vc_signed = cred.issue(did, domain=request.get_host(), save=save)
|
||||||
|
|
||||||
|
if not vc_signed:
|
||||||
|
return JsonResponse({'error': 'Invalid credential'}, status=400)
|
||||||
|
|
||||||
return JsonResponse({'status': 'success', "data": vc_signed}, status=200)
|
return JsonResponse({'status': 'success', "data": vc_signed}, status=200)
|
||||||
|
|
||||||
return JsonResponse({'status': 'fail'}, status=200)
|
return JsonResponse({'status': 'fail'}, status=200)
|
||||||
|
|
Loading…
Reference in a new issue