Compare commits
155 Commits
1.27.2
..
d24fb0e0f5
| Author | SHA1 | Date | |
|---|---|---|---|
| d24fb0e0f5 | |||
| 59fca60134 | |||
| c8a39e62eb | |||
| b1ca199b85 | |||
| 3354ad1f68 | |||
| 960b681ab9 | |||
| e99b371d5d | |||
| ba7f5edc33 | |||
| 3aa7b4874e | |||
| 8ade4c2f7a | |||
| 67be62a869 | |||
| 5a8d20047f | |||
| 74d4ee49cc | |||
| e8b583d4c6 | |||
| f57fa4cc20 | |||
| b0f72584e2 | |||
| 2bbc780c0b | |||
| 15a1bbe771 | |||
| 9965ce2d2c | |||
| 89f309abd2 | |||
| f134948685 | |||
| 1e525b90a9 | |||
| 63a516e7d6 | |||
| 2399ca9bf9 | |||
| c48ccd5334 | |||
| e2f8fc9c6d | |||
| fac658e52c | |||
| d6a65dd59a | |||
| cbc8acf6f6 | |||
| 31de477f26 | |||
| 19b6e633df | |||
| b98f821c98 | |||
| 5421de4e80 | |||
| a7a0044fc5 | |||
| 36552b3886 | |||
| a766c4dbe8 | |||
| 8126781b77 | |||
| a6a66d7499 | |||
| 1c0b67693d | |||
| ce6bb6b23b | |||
| 0b8176db2e | |||
| 3a299a040a | |||
| 3c5206139b | |||
| 6c53f39a28 | |||
| 64d8f47174 | |||
| f5f3246e89 | |||
| ad8961ab82 | |||
| c2c8630c82 | |||
| dce9e1fc71 | |||
| 2b84bab1d0 | |||
| 303583daa1 | |||
| d07b2ffbfb | |||
| 335800c44b | |||
| 5766cfde47 | |||
| 2ed3fcc0f9 | |||
| bf72295615 | |||
| 6b860f8ea5 | |||
| 2fa2fa547b | |||
| 3de956872c | |||
| 1c8e3992d6 | |||
| e6e9e141c8 | |||
| f8ece06ee8 | |||
| 149a351bfd | |||
| 0164717b8e | |||
| 104952bfc3 | |||
| f96241c8d1 | |||
| ac6b534f58 | |||
| 06910cd69a | |||
| a48ba520fc | |||
| 9f18aa5890 | |||
| ab3bd84f3b | |||
| f829cd5a4c | |||
| 0f2bf95b71 | |||
| 6a307016ec | |||
| 51017ef8fa | |||
| 05560534bc | |||
| c882173e78 | |||
| 1d94211428 | |||
| 37357080d8 | |||
| 5afa13ac92 | |||
| 416cad1c8f | |||
| b5f83b7163 | |||
| 20cfb5f345 | |||
| 88c96b95f2 | |||
| f6c500b02a | |||
| d702cd8716 | |||
| 329cdd4838 | |||
| 1b70024a29 | |||
| 58206853ee | |||
| 6356398c40 | |||
| 8519922d78 | |||
| 5ac0654fd4 | |||
| 6c07a81b4f | |||
| ba45b4f961 | |||
| 280de82a52 | |||
| 6022e2d879 | |||
| 1996efcc0d | |||
| 80569119cb | |||
| 98e71d4e8a | |||
| fec7191ac2 | |||
| 9b1085f206 | |||
| b35d175a5c | |||
| 7f5fb022ac | |||
| 2d3314ab18 | |||
| 8b489f013d | |||
| 16ce5506d8 | |||
| e440bf8372 | |||
| 607db267e6 | |||
| 352ca64e09 | |||
| f2b735da6e | |||
| 6f7cfb713e | |||
| 103b703ee9 | |||
| daf8b1dce6 | |||
| c088affd74 | |||
| ecc727c991 | |||
| 632569fa5d | |||
| 6c6cbb7396 | |||
| 5e6bfdf77e | |||
| 35e5e18b79 | |||
| c0e8c6bd84 | |||
| 64541b76c5 | |||
| f65b9262cb | |||
| 2765d0548e | |||
| 951f810ce5 | |||
| d2c177d448 | |||
| 299727a7b4 | |||
| b97976b2c5 | |||
| 20241661ff | |||
| ad5c0bea67 | |||
| 80a44277bc | |||
| 5c2b5affc9 | |||
| cd99743d1e | |||
| b39432be1a | |||
| 03f9a33e54 | |||
| 699a9c1e76 | |||
| 4dfd02291e | |||
| e7ca485a88 | |||
| 8319cbfe17 | |||
| 4a023e9f10 | |||
| 4100f96dc6 | |||
| ca24f098e4 | |||
| 80dcd62199 | |||
| 0cfd3da728 | |||
| e141851a87 | |||
| 89ec67999b | |||
| ec38daaedc | |||
| 45c0826a84 | |||
| 45a383cf85 | |||
| 90aff209f9 | |||
| 13528e91e9 | |||
| 04179d633c | |||
| 0a241305d3 | |||
| 31565a0bc4 | |||
| af747417d3 | |||
| c6606c4151 |
@@ -35,6 +35,7 @@ SCHNEIDER_AUTH_HEADER=auth
|
|||||||
|
|
||||||
# SSO
|
# SSO
|
||||||
SSO_SERVER_BASE_URL=https://login.naturschutz.rlp.de
|
SSO_SERVER_BASE_URL=https://login.naturschutz.rlp.de
|
||||||
|
OAUTH_CODE_VERIFIER=CHANGE_ME
|
||||||
OAUTH_CLIENT_ID=CHANGE_ME
|
OAUTH_CLIENT_ID=CHANGE_ME
|
||||||
OAUTH_CLIENT_SECRET=CHANGE_ME
|
OAUTH_CLIENT_SECRET=CHANGE_ME
|
||||||
PROPAGATION_SECRET=CHANGE_ME
|
PROPAGATION_SECRET=CHANGE_ME
|
||||||
|
|||||||
+36
@@ -0,0 +1,36 @@
|
|||||||
|
# Nutze ein schlankes Python-Image
|
||||||
|
FROM python:3.13-slim-trixie
|
||||||
|
|
||||||
|
ENV PYTHONUNBUFFERED 1
|
||||||
|
|
||||||
|
WORKDIR /konova
|
||||||
|
|
||||||
|
# Installiere System-Abhängigkeiten
|
||||||
|
RUN apt-get update && apt-get install -y --no-install-recommends \
|
||||||
|
gdal-bin redis-server nginx \
|
||||||
|
&& rm -rf /var/lib/apt/lists/* # Platz sparen
|
||||||
|
|
||||||
|
# Erstelle benötigte Verzeichnisse & setze Berechtigungen
|
||||||
|
RUN mkdir -p /var/log/nginx /var/log/gunicorn /var/lib/nginx /tmp/nginx_client_body \
|
||||||
|
&& touch /var/log/nginx/access.log /var/log/nginx/error.log \
|
||||||
|
&& chown -R root:root /var/log/nginx /var/lib/nginx /tmp/nginx_client_body
|
||||||
|
|
||||||
|
# Kopiere und installiere Python-Abhängigkeiten
|
||||||
|
COPY ./requirements.txt /konova/
|
||||||
|
RUN pip install --upgrade pip && pip install --no-cache-dir -r requirements.txt
|
||||||
|
|
||||||
|
# Entferne Standard-Nginx-Site und ersetze sie durch eigene Config
|
||||||
|
RUN rm -rf /etc/nginx/sites-enabled/default
|
||||||
|
COPY ./nginx.conf /etc/nginx/conf.d
|
||||||
|
|
||||||
|
# Kopiere restliche Projektdateien
|
||||||
|
COPY . /konova/
|
||||||
|
|
||||||
|
# Sammle statische Dateien
|
||||||
|
RUN python manage.py collectstatic --noinput
|
||||||
|
|
||||||
|
# Exponiere Ports
|
||||||
|
#EXPOSE 80 6379 8000
|
||||||
|
|
||||||
|
# Setze Entrypoint
|
||||||
|
ENTRYPOINT ["/konova/docker-entrypoint.sh"]
|
||||||
@@ -4,6 +4,7 @@ the database postgresql and the css library bootstrap as well as the icon packag
|
|||||||
fontawesome for a modern look, following best practices from the industry.
|
fontawesome for a modern look, following best practices from the industry.
|
||||||
|
|
||||||
## Background processes
|
## Background processes
|
||||||
|
### !!! For non-docker run
|
||||||
Konova uses celery for background processing. To start the worker you need to run
|
Konova uses celery for background processing. To start the worker you need to run
|
||||||
```shell
|
```shell
|
||||||
$ celery -A konova worker -l INFO
|
$ celery -A konova worker -l INFO
|
||||||
@@ -18,3 +19,58 @@ Technical documention is provided in the projects git wiki.
|
|||||||
A user documentation is not available (and not needed, yet).
|
A user documentation is not available (and not needed, yet).
|
||||||
|
|
||||||
|
|
||||||
|
# Docker
|
||||||
|
To run the docker-compose as expected, you need to take the following steps:
|
||||||
|
|
||||||
|
1. Create a database containing docker, using an appropriate Dockerfile, e.g. the following
|
||||||
|
```
|
||||||
|
version: '3.3'
|
||||||
|
services:
|
||||||
|
postgis:
|
||||||
|
image: postgis/postgis
|
||||||
|
restart: always
|
||||||
|
container_name: postgis-docker
|
||||||
|
ports:
|
||||||
|
- 5433:5432
|
||||||
|
volumes:
|
||||||
|
- db-volume:/var/lib/postgresql/data
|
||||||
|
environment:
|
||||||
|
- POSTGRES_PASSWORD=postgres
|
||||||
|
- POSTGRES_USER=postgres
|
||||||
|
networks:
|
||||||
|
- db-network-bridge
|
||||||
|
|
||||||
|
networks:
|
||||||
|
db-network-bridge:
|
||||||
|
driver: "bridge"
|
||||||
|
|
||||||
|
volumes:
|
||||||
|
db-volume:
|
||||||
|
```
|
||||||
|
This Dockerfile creates a Docker container running postgresql and postgis, creates the default superuser postgres,
|
||||||
|
creates a named volume for persisting the database and creates a new network bridge, which **must be used by any other
|
||||||
|
container, which wants to write/read on this database**.
|
||||||
|
|
||||||
|
2. Make sure the name of the network bridge above matches the network in the konova docker-compose.yml
|
||||||
|
3. Get into the running postgis container (`docker exec -it postgis-docker bash`) and create new databases, users and so on. Make sure the database `konova` exists now!
|
||||||
|
4. Replace all `CHANGE_ME_xy` values inside of konova/docker-compose.yml for your installation. Make sure the `SSO_HOST` holds the proper SSO host, e.g. for the arnova project `arnova.example.org` (Arnova must be installed and the webserver configured as well, of course)
|
||||||
|
5. Take a look on konova/settings.py and konova/sub_settings/django_settings.py. Again: Replace all occurences of `CHANGE_ME` with proper values for your installation.
|
||||||
|
1. Make sure you have the proper host strings added to `ALLOWED_HOSTS` inside of django_settings.py.
|
||||||
|
6. Build and run the docker setup using `docker-compose build` and `docker-compose start` from the main directory of this project (where the docker-compose.yml lives)
|
||||||
|
7. Run migrations! To do so, get into the konova service container (`docker exec -it konova-docker bash`) and run the needed commands (`python manage.py makemigrations LIST_OF_ALL_MIGRATABLE_APPS`, then `python manage.py migrate`)
|
||||||
|
8. Run the setup command `python manage.py setup` and follow the instructions on the CLI
|
||||||
|
9. To enable **SMTP** mail support, make sure your host machine (the one where the docker container run) has the postfix service configured properly. Make sure the `mynetworks` variable is xtended using the docker network bridge ip, created in the postgis container and used by the konova services.
|
||||||
|
1. **Hint**: You can find out this easily by trying to perform a test mail in the running konova web application (which will fail, of course). Then take a look to the latest entries in `/var/log/mail.log` on your host machine. The failed IP will be displayed there.
|
||||||
|
2. **Please note**: This installation guide is based on SMTP using postfix!
|
||||||
|
3. Restart the postfix service on your host machine to reload the new configuration (`service postfix restart`)
|
||||||
|
10. Finally, make sure your host machine webserver passes incoming requests properly to the docker nginx webserver of konova. A proper nginx config for the host machine may look like this:
|
||||||
|
```
|
||||||
|
server {
|
||||||
|
server_name konova.domain.org;
|
||||||
|
|
||||||
|
location / {
|
||||||
|
proxy_pass http://localhost:KONOVA_NGINX_DOCKER_PORT/;
|
||||||
|
proxy_set_header Host $host;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
@@ -39,9 +39,6 @@ class ExternalIdentifierAdmin(admin.ModelAdmin):
|
|||||||
"external_id",
|
"external_id",
|
||||||
"internal_id",
|
"internal_id",
|
||||||
]
|
]
|
||||||
readonly_fields = [
|
|
||||||
"created",
|
|
||||||
]
|
|
||||||
|
|
||||||
admin.site.register(APIUserToken, APITokenAdmin)
|
admin.site.register(APIUserToken, APITokenAdmin)
|
||||||
admin.site.register(OAuthToken, OAuthTokenAdmin)
|
admin.site.register(OAuthToken, OAuthTokenAdmin)
|
||||||
|
|||||||
+22
-31
@@ -1,9 +1,7 @@
|
|||||||
import datetime
|
|
||||||
import json
|
import json
|
||||||
from datetime import timedelta
|
from datetime import timedelta
|
||||||
|
|
||||||
import requests
|
import requests
|
||||||
from authlib.oauth2.rfc6749 import OAuth2Token
|
|
||||||
from django.core.exceptions import ObjectDoesNotExist
|
from django.core.exceptions import ObjectDoesNotExist
|
||||||
from django.db import models
|
from django.db import models
|
||||||
from django.utils import timezone
|
from django.utils import timezone
|
||||||
@@ -80,25 +78,27 @@ class OAuthToken(UuidModel):
|
|||||||
return str(self.access_token)
|
return str(self.access_token)
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def create_from_oauth2_token(oauth2_token: OAuth2Token):
|
def from_access_token_response(access_token_data: str, received_on):
|
||||||
"""
|
"""
|
||||||
Creates an OAuthToken based on retrieved access token data (OAuth2.0 specification)
|
Creates an OAuthToken based on retrieved access token data (OAuth2.0 specification)
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
oauth2_token (str): OAuth2.0 response data
|
access_token_data (str): OAuth2.0 response data
|
||||||
|
received_on (): Timestamp when the response has been received
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
|
|
||||||
"""
|
"""
|
||||||
oauth_token = OAuthToken()
|
oauth_token = OAuthToken()
|
||||||
|
data = json.loads(access_token_data)
|
||||||
|
|
||||||
oauth_token.access_token = oauth2_token.get("access_token")
|
oauth_token.access_token = data.get("access_token")
|
||||||
oauth_token.refresh_token = oauth2_token.get("refresh_token")
|
oauth_token.refresh_token = data.get("refresh_token")
|
||||||
oauth_token.expires_on = datetime.datetime.fromtimestamp(oauth2_token.get("expires_at"))
|
|
||||||
|
|
||||||
assert (oauth_token.access_token is not None and
|
expires_on = received_on + timedelta(
|
||||||
oauth_token.refresh_token is not None and
|
seconds=(data.get("expires_in") + OAuthToken.ASSUMED_LATENCY)
|
||||||
oauth_token.expires_on is not None)
|
)
|
||||||
|
oauth_token.expires_on = expires_on
|
||||||
|
|
||||||
return oauth_token
|
return oauth_token
|
||||||
|
|
||||||
@@ -155,34 +155,25 @@ class OAuthToken(UuidModel):
|
|||||||
|
|
||||||
return user
|
return user
|
||||||
|
|
||||||
def revoke(self) -> None:
|
def revoke(self) -> int:
|
||||||
""" Revokes the OAuth2 token of the user
|
""" Revokes the OAuth2 token of the user
|
||||||
|
|
||||||
(/o/revoke_token/ indeed removes the corresponding access token on provider side and invalidates the
|
(/o/revoke_token/ indeed removes the corresponding access token on provider side and invalidates the
|
||||||
submitted refresh token in one step)
|
submitted refresh token in one step)
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
|
revocation_status_code (int): HTTP status code for revocation of refresh_token
|
||||||
"""
|
"""
|
||||||
revoke_url = f"{SSO_SERVER_BASE}o/revoke_token/"
|
revoke_url = f"{SSO_SERVER_BASE}o/revoke_token/"
|
||||||
token_types = [
|
token = self.refresh_token
|
||||||
(self.refresh_token, "refresh_token"),
|
revocation_status_code = requests.post(
|
||||||
(self.access_token, "access_token"),
|
revoke_url,
|
||||||
]
|
data={
|
||||||
status_codes = []
|
'token': token,
|
||||||
for entry in token_types:
|
'token_type_hint': "refresh_token",
|
||||||
status_codes.append(
|
},
|
||||||
requests.post(
|
auth=(OAUTH_CLIENT_ID, OAUTH_CLIENT_SECRET),
|
||||||
revoke_url,
|
).status_code
|
||||||
data={
|
|
||||||
'token': entry[0],
|
|
||||||
'token_type_hint': entry[1],
|
|
||||||
},
|
|
||||||
auth=(OAUTH_CLIENT_ID, OAUTH_CLIENT_SECRET),
|
|
||||||
).status_code
|
|
||||||
)
|
|
||||||
|
|
||||||
assert len(status_codes) == 2
|
|
||||||
assert status_codes[0] == 200 and status_codes[1] == 200
|
|
||||||
|
|
||||||
|
return revocation_status_code
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,21 @@
|
|||||||
|
services:
|
||||||
|
konova:
|
||||||
|
external_links:
|
||||||
|
- postgis:db
|
||||||
|
- arnova-nginx-server:arnova
|
||||||
|
build: .
|
||||||
|
image: "ksp/konova:x.y"
|
||||||
|
container_name: "konova-docker"
|
||||||
|
command: ./docker-entrypoint.sh
|
||||||
|
restart: always
|
||||||
|
volumes:
|
||||||
|
- /data/apps/konova/uploaded_files:/konova_uploaded_files
|
||||||
|
ports:
|
||||||
|
- "1337:80"
|
||||||
|
|
||||||
|
# Instead of an own, new network, we need to connect to the existing one, which is provided by the postgis container
|
||||||
|
# NOTE: THIS NETWORK MUST EXIST
|
||||||
|
networks:
|
||||||
|
default:
|
||||||
|
name: postgis_nat_it_backend
|
||||||
|
external: true
|
||||||
Executable
+27
@@ -0,0 +1,27 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
set -e # Beende Skript bei Fehlern
|
||||||
|
set -o pipefail # Fehler in Pipelines nicht ignorieren
|
||||||
|
|
||||||
|
# Starte Redis
|
||||||
|
redis-server --daemonize yes
|
||||||
|
|
||||||
|
# Starte Celery Worker im Hintergrund
|
||||||
|
celery -A konova worker --loglevel=info &
|
||||||
|
|
||||||
|
# Starte Nginx als Hintergrundprozess
|
||||||
|
nginx -g "daemon off;" &
|
||||||
|
|
||||||
|
# Setze Gunicorn Worker-Anzahl (Standard: (2*CPUs)+1)
|
||||||
|
WORKERS=${GUNICORN_WORKERS:-$((2 * $(nproc) + 1))}
|
||||||
|
|
||||||
|
# Stelle sicher, dass Logs existieren
|
||||||
|
mkdir -p /var/log/gunicorn
|
||||||
|
touch /var/log/gunicorn/access.log /var/log/gunicorn/error.log
|
||||||
|
|
||||||
|
# Starte Gunicorn als Hauptprozess
|
||||||
|
exec gunicorn --workers="$WORKERS" konova.wsgi:application \
|
||||||
|
--bind=0.0.0.0:8000 \
|
||||||
|
--access-logfile /var/log/gunicorn/access.log \
|
||||||
|
--error-logfile /var/log/gunicorn/error.log \
|
||||||
|
--access-logformat '%({x-real-ip}i)s via %(h)s %(l)s %(u)s %(t)s "%(r)s" %(s)s %(b)s "%(f)s" "%(a)s"'
|
||||||
@@ -191,11 +191,10 @@ STATICFILES_DIRS = [
|
|||||||
]
|
]
|
||||||
|
|
||||||
# EMAIL (see https://docs.djangoproject.com/en/dev/topics/email/)
|
# EMAIL (see https://docs.djangoproject.com/en/dev/topics/email/)
|
||||||
|
|
||||||
# CHANGE_ME !!! ONLY FOR DEVELOPMENT !!!
|
|
||||||
if DEBUG:
|
if DEBUG:
|
||||||
|
# ONLY FOR DEVELOPMENT NEEDED
|
||||||
EMAIL_BACKEND = 'django.core.mail.backends.filebased.EmailBackend'
|
EMAIL_BACKEND = 'django.core.mail.backends.filebased.EmailBackend'
|
||||||
EMAIL_FILE_PATH = '/tmp/app-messages' # change this to a proper location
|
EMAIL_FILE_PATH = '/tmp/app-messages'
|
||||||
|
|
||||||
DEFAULT_FROM_EMAIL = env("DEFAULT_FROM_EMAIL") # The default email address for the 'from' element
|
DEFAULT_FROM_EMAIL = env("DEFAULT_FROM_EMAIL") # The default email address for the 'from' element
|
||||||
SERVER_EMAIL = DEFAULT_FROM_EMAIL # The default email sender address, which is used by Django to send errors via mail
|
SERVER_EMAIL = DEFAULT_FROM_EMAIL # The default email sender address, which is used by Django to send errors via mail
|
||||||
|
|||||||
@@ -12,6 +12,8 @@ SSO_SERVER_BASE = env("SSO_SERVER_BASE_URL")
|
|||||||
SSO_SERVER = f"{SSO_SERVER_BASE}sso/"
|
SSO_SERVER = f"{SSO_SERVER_BASE}sso/"
|
||||||
|
|
||||||
# OAuth settings
|
# OAuth settings
|
||||||
|
OAUTH_CODE_VERIFIER = env("OAUTH_CODE_VERIFIER")
|
||||||
|
|
||||||
OAUTH_CLIENT_ID = env("OAUTH_CLIENT_ID")
|
OAUTH_CLIENT_ID = env("OAUTH_CLIENT_ID")
|
||||||
OAUTH_CLIENT_SECRET = env("OAUTH_CLIENT_SECRET")
|
OAUTH_CLIENT_SECRET = env("OAUTH_CLIENT_SECRET")
|
||||||
|
|
||||||
|
|||||||
@@ -8,9 +8,6 @@ Created on: 09.11.20
|
|||||||
import secrets
|
import secrets
|
||||||
import string
|
import string
|
||||||
|
|
||||||
from authlib.common.security import generate_token as authlib_generate_token
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def generate_token(length: int = 64) -> str:
|
def generate_token(length: int = 64) -> str:
|
||||||
""" Shortcut for default generating of e.g. API token
|
""" Shortcut for default generating of e.g. API token
|
||||||
@@ -18,7 +15,11 @@ def generate_token(length: int = 64) -> str:
|
|||||||
Returns:
|
Returns:
|
||||||
token (str)
|
token (str)
|
||||||
"""
|
"""
|
||||||
return authlib_generate_token(length)
|
return generate_random_string(
|
||||||
|
length=length,
|
||||||
|
use_numbers=True,
|
||||||
|
use_letters_lc=True
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
def generate_random_string(length: int, use_numbers: bool = False, use_letters_lc: bool = False, use_letters_uc: bool = False) -> str:
|
def generate_random_string(length: int, use_numbers: bool = False, use_letters_lc: bool = False, use_letters_uc: bool = False) -> str:
|
||||||
|
|||||||
@@ -180,24 +180,6 @@ class GeometryProcessor:
|
|||||||
is_area_valid = geom.area > 1 # > 1m² (SRID:25832)
|
is_area_valid = geom.area > 1 # > 1m² (SRID:25832)
|
||||||
return is_area_valid
|
return is_area_valid
|
||||||
|
|
||||||
@staticmethod
|
|
||||||
def is_valid_geometry(geom: gdal.OGRGeometry) -> bool:
|
|
||||||
""" Checks whether the geometry is technically valid
|
|
||||||
|
|
||||||
Args:
|
|
||||||
geom (OGRGeometry): The geom
|
|
||||||
|
|
||||||
Returns:
|
|
||||||
|
|
||||||
"""
|
|
||||||
try:
|
|
||||||
# Check geometry validity by triggering some low cost processing like centroid calculation
|
|
||||||
geom.centroid
|
|
||||||
geom.boundary
|
|
||||||
return True
|
|
||||||
except gdal.GDALException as e:
|
|
||||||
return False
|
|
||||||
|
|
||||||
|
|
||||||
class GeoJsonValidator:
|
class GeoJsonValidator:
|
||||||
""" GeoJson Validator validates geojson (e.g. from API or form input)
|
""" GeoJson Validator validates geojson (e.g. from API or form input)
|
||||||
@@ -277,10 +259,10 @@ class GeoJsonValidator:
|
|||||||
"""
|
"""
|
||||||
features = self._input_geojson.get("features", [])
|
features = self._input_geojson.get("features", [])
|
||||||
|
|
||||||
is_input_geojson_empty_str = len(self._input_geojson) == 0
|
is_input_geojson_empty = len(self._input_geojson) == 0
|
||||||
no_features_in_input_found = len(features) == 0
|
no_features_in_input_found = len(features) == 0
|
||||||
|
|
||||||
if not is_input_geojson_empty_str and no_features_in_input_found:
|
if not is_input_geojson_empty and no_features_in_input_found:
|
||||||
# check if _input_geojson is a feature itself
|
# check if _input_geojson is a feature itself
|
||||||
if self.__is_geojson_feature():
|
if self.__is_geojson_feature():
|
||||||
features = [
|
features = [
|
||||||
@@ -288,9 +270,6 @@ class GeoJsonValidator:
|
|||||||
"geometry": self._input_geojson
|
"geometry": self._input_geojson
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
elif self.__is_geojson_featurecollection():
|
|
||||||
# special case if empty featurecollection received
|
|
||||||
pass
|
|
||||||
else:
|
else:
|
||||||
self.__add_error("Input does not seem to be geojson")
|
self.__add_error("Input does not seem to be geojson")
|
||||||
return
|
return
|
||||||
@@ -326,10 +305,6 @@ class GeoJsonValidator:
|
|||||||
g = gdal.OGRGeometry(feature_geom, srs=self._srs)
|
g = gdal.OGRGeometry(feature_geom, srs=self._srs)
|
||||||
if g.empty:
|
if g.empty:
|
||||||
continue
|
continue
|
||||||
|
|
||||||
if not GeometryProcessor.is_valid_geometry(g):
|
|
||||||
raise AssertionError(_("This feature holds malicious parts and can not be processed!"))
|
|
||||||
|
|
||||||
g = GeometryProcessor.cast_to_rlp_srid(g)
|
g = GeometryProcessor.cast_to_rlp_srid(g)
|
||||||
if not GeometryProcessor.is_valid_25832(g):
|
if not GeometryProcessor.is_valid_25832(g):
|
||||||
raise AssertionError(_("This feature does not hold valid EPSG:25832 coordinates:\n {}".format(g.geojson)))
|
raise AssertionError(_("This feature does not hold valid EPSG:25832 coordinates:\n {}".format(g.geojson)))
|
||||||
@@ -375,13 +350,3 @@ class GeoJsonValidator:
|
|||||||
has_coordinates = self._input_geojson.get("coordinates", None) is not None
|
has_coordinates = self._input_geojson.get("coordinates", None) is not None
|
||||||
has_properties = self._input_geojson.get("properties", None) is not None
|
has_properties = self._input_geojson.get("properties", None) is not None
|
||||||
return has_type and has_coordinates and has_properties
|
return has_type and has_coordinates and has_properties
|
||||||
|
|
||||||
def __is_geojson_featurecollection(self):
|
|
||||||
""" Checks whether _input_geojson is a geojson featurecollection
|
|
||||||
|
|
||||||
Returns:
|
|
||||||
|
|
||||||
"""
|
|
||||||
is_fc_type = self._input_geojson.get("type", None) == "FeatureCollection"
|
|
||||||
has_feature_attribute = isinstance(self._input_geojson.get("features", None), list)
|
|
||||||
return is_fc_type and has_feature_attribute
|
|
||||||
@@ -29,7 +29,6 @@ class LogoutView(View):
|
|||||||
oauth_token = user.oauth_token
|
oauth_token = user.oauth_token
|
||||||
if oauth_token:
|
if oauth_token:
|
||||||
oauth_token.revoke()
|
oauth_token.revoke()
|
||||||
oauth_token.delete()
|
|
||||||
except AttributeError:
|
except AttributeError:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|||||||
+75
-61
@@ -7,52 +7,33 @@ Created on: 26.04.24
|
|||||||
"""
|
"""
|
||||||
import base64
|
import base64
|
||||||
import hashlib
|
import hashlib
|
||||||
|
from urllib.parse import urlencode
|
||||||
|
|
||||||
from authlib.common.security import generate_token
|
import requests
|
||||||
from authlib.integrations.base_client import OAuthError
|
|
||||||
from authlib.integrations.django_client import OAuth
|
|
||||||
|
|
||||||
from django.contrib.auth import login
|
from django.contrib.auth import login
|
||||||
from django.http import HttpRequest, HttpResponse
|
from django.http import HttpRequest
|
||||||
from django.shortcuts import redirect
|
from django.shortcuts import redirect
|
||||||
from django.urls import reverse
|
from django.urls import reverse
|
||||||
|
from django.utils.timezone import now
|
||||||
from django.views import View
|
from django.views import View
|
||||||
|
|
||||||
from api.models import OAuthToken
|
from api.models import OAuthToken
|
||||||
from konova.sub_settings.django_settings import BASE_URL
|
from konova.sub_settings.django_settings import BASE_URL
|
||||||
from konova.sub_settings.sso_settings import SSO_SERVER_BASE, OAUTH_CLIENT_ID, OAUTH_CLIENT_SECRET
|
from konova.sub_settings.sso_settings import SSO_SERVER_BASE, OAUTH_CODE_VERIFIER, OAUTH_CLIENT_ID, OAUTH_CLIENT_SECRET
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
_OAUTH = OAuth()
|
|
||||||
_OAUTH.register(
|
|
||||||
name="sso",
|
|
||||||
client_id=OAUTH_CLIENT_ID,
|
|
||||||
client_secret=OAUTH_CLIENT_SECRET,
|
|
||||||
authorize_url=f"{SSO_SERVER_BASE}o/authorize/",
|
|
||||||
access_token_url=f"{SSO_SERVER_BASE}o/token/",
|
|
||||||
code_challenge_method="S256",
|
|
||||||
client_kwargs={},
|
|
||||||
)
|
|
||||||
|
|
||||||
class OAuthLoginView(View):
|
class OAuthLoginView(View):
|
||||||
""" View for OAuth2 login step
|
"""
|
||||||
|
Starts OAuth Login procedure
|
||||||
|
-> AnonymousUser is redirected to SSO component using specific parameters
|
||||||
|
-> After successful login (in SSO component), user will be redirected to a specific callback url (OAuthCallbackView)
|
||||||
|
-> Callback view uses retrieved authorization token to get a proper access token from SSO component
|
||||||
|
-> SSO component answers with access token
|
||||||
|
-> OAuthCallbackView uses token in Authorization header to access user data of logged-in user in SSO component
|
||||||
|
-> OAuthCallbackView creates/updates user
|
||||||
|
-> OAuthCallbackView logs in user and redirects to default home view
|
||||||
|
|
||||||
"""
|
"""
|
||||||
def get(self, request: HttpRequest, *args, **kwargs):
|
|
||||||
redirect_uri = f'{BASE_URL}{reverse("oauth-callback")}'
|
|
||||||
|
|
||||||
# create new PKCE-Verifier
|
|
||||||
code_verifier, code_challenge = self.__create_code_challenge()
|
|
||||||
|
|
||||||
# keep verifier in session, so it can be read out for callback
|
|
||||||
request.session["oauth_code_verifier"] = code_verifier
|
|
||||||
|
|
||||||
return _OAUTH.sso.authorize_redirect(
|
|
||||||
request,
|
|
||||||
redirect_uri,
|
|
||||||
code_verifier=code_verifier,
|
|
||||||
)
|
|
||||||
|
|
||||||
def __create_code_challenge(self):
|
def __create_code_challenge(self):
|
||||||
"""
|
"""
|
||||||
@@ -63,49 +44,82 @@ class OAuthLoginView(View):
|
|||||||
Returns:
|
Returns:
|
||||||
|
|
||||||
"""
|
"""
|
||||||
code_verifier = generate_token(128)
|
code_verifier = OAUTH_CODE_VERIFIER
|
||||||
|
|
||||||
code_challenge = hashlib.sha256(code_verifier.encode('utf-8')).digest()
|
code_challenge = hashlib.sha256(code_verifier.encode('utf-8')).digest()
|
||||||
code_challenge = base64.urlsafe_b64encode(code_challenge).decode('utf-8').replace('=', '')
|
code_challenge = base64.urlsafe_b64encode(code_challenge).decode('utf-8').replace('=', '')
|
||||||
return code_verifier, code_challenge
|
return code_verifier, code_challenge
|
||||||
|
|
||||||
|
def get(self, request: HttpRequest, *args, **kwargs):
|
||||||
|
"""
|
||||||
|
Redirects user to OAuth SSO webservice for credential based login there
|
||||||
|
|
||||||
|
Args:
|
||||||
|
request ():
|
||||||
|
*args ():
|
||||||
|
**kwargs ():
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
|
||||||
|
"""
|
||||||
|
oauth_authentication_code_url = f"{SSO_SERVER_BASE}o/authorize/"
|
||||||
|
redirect_uri = f'{BASE_URL}{reverse("oauth-callback")}'
|
||||||
|
|
||||||
|
code_verifier, code_challenge = self.__create_code_challenge()
|
||||||
|
|
||||||
|
urlencode_params = urlencode(
|
||||||
|
{
|
||||||
|
"response_type": "code",
|
||||||
|
"code_challenge": code_challenge,
|
||||||
|
"code_challenge_method": "S256",
|
||||||
|
"client_id": OAUTH_CLIENT_ID,
|
||||||
|
"redirect_uri": redirect_uri,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
url = f"{oauth_authentication_code_url}?{urlencode_params}"
|
||||||
|
return redirect(url)
|
||||||
|
|
||||||
|
|
||||||
class OAuthCallbackView(View):
|
class OAuthCallbackView(View):
|
||||||
""" View for OAuth2 callback step
|
"""
|
||||||
|
Callback view for OAuth2.0 authentication token.
|
||||||
|
Authentication tokens will be exchanged for access token.
|
||||||
|
Access Token will be used for fetching user data from SSO component.
|
||||||
|
User data will be used for creating/updating user data inside this app.
|
||||||
|
User will be logged-in and redirected to default home view.
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def get(self, request: HttpRequest, *args, **kwargs):
|
def get(self, request: HttpRequest, *args, **kwargs):
|
||||||
# Get code verifier (created on oatuh-login step) from session
|
authentication_code = request.GET.get("code")
|
||||||
code_verifier = request.session.pop(
|
oauth_acces_token_url = f"{SSO_SERVER_BASE}o/token/"
|
||||||
"oauth_code_verifier",
|
|
||||||
None,
|
callback_url = f'{BASE_URL}{reverse("oauth-callback")}'
|
||||||
|
|
||||||
|
params = {
|
||||||
|
"grant_type": "authorization_code",
|
||||||
|
"code": authentication_code,
|
||||||
|
"redirect_uri": callback_url,
|
||||||
|
"code_verifier": OAUTH_CODE_VERIFIER,
|
||||||
|
"client_id": OAUTH_CLIENT_ID,
|
||||||
|
"client_secret": OAUTH_CLIENT_SECRET
|
||||||
|
}
|
||||||
|
access_code_response = requests.post(
|
||||||
|
oauth_acces_token_url,
|
||||||
|
data=params
|
||||||
)
|
)
|
||||||
if not code_verifier:
|
received_on = now()
|
||||||
return HttpResponse(
|
|
||||||
"PKCE code_verifier missing or is invalid.",
|
|
||||||
status=400,
|
|
||||||
)
|
|
||||||
|
|
||||||
try:
|
access_code_response_body = access_code_response.content.decode("utf-8")
|
||||||
token = _OAUTH.sso.authorize_access_token(
|
status_code_invalid = access_code_response.status_code != 200
|
||||||
request
|
if status_code_invalid:
|
||||||
)
|
raise RuntimeError(f"OAuth access token could not be fetched: {access_code_response.text}")
|
||||||
except OAuthError as e:
|
|
||||||
print(e)
|
|
||||||
return HttpResponse(
|
|
||||||
"OAuth-Login failed while authorizing with OAuth.",
|
|
||||||
status=400,
|
|
||||||
)
|
|
||||||
try:
|
|
||||||
oauth_token = OAuthToken.create_from_oauth2_token(token)
|
|
||||||
except AssertionError:
|
|
||||||
return HttpResponse(
|
|
||||||
"OAuth-Login failed due to unexpected token content.",
|
|
||||||
status=400,
|
|
||||||
)
|
|
||||||
|
|
||||||
|
oauth_token = OAuthToken.from_access_token_response(access_code_response_body, received_on)
|
||||||
oauth_token.save()
|
oauth_token.save()
|
||||||
user = oauth_token.update_and_get_user()
|
user = oauth_token.update_and_get_user()
|
||||||
user.oauth_replace_token(oauth_token)
|
user.oauth_replace_token(oauth_token)
|
||||||
|
|
||||||
login(request, user)
|
login(request, user)
|
||||||
return redirect("home")
|
return redirect("home")
|
||||||
|
|
||||||
|
|||||||
Binary file not shown.
@@ -45,7 +45,7 @@ msgid ""
|
|||||||
msgstr ""
|
msgstr ""
|
||||||
"Project-Id-Version: PACKAGE VERSION\n"
|
"Project-Id-Version: PACKAGE VERSION\n"
|
||||||
"Report-Msgid-Bugs-To: \n"
|
"Report-Msgid-Bugs-To: \n"
|
||||||
"POT-Creation-Date: 2026-09-17 16:25+0200\n"
|
"POT-Creation-Date: 2026-09-13 12:06+0200\n"
|
||||||
"PO-Revision-Date: YEAR-MO-DA HO:MI+ZONE\n"
|
"PO-Revision-Date: YEAR-MO-DA HO:MI+ZONE\n"
|
||||||
"Last-Translator: FULL NAME <EMAIL@ADDRESS>\n"
|
"Last-Translator: FULL NAME <EMAIL@ADDRESS>\n"
|
||||||
"Language-Team: LANGUAGE <LL@li.org>\n"
|
"Language-Team: LANGUAGE <LL@li.org>\n"
|
||||||
@@ -2012,11 +2012,7 @@ msgstr "In Zwischenablage kopiert"
|
|||||||
msgid "Search"
|
msgid "Search"
|
||||||
msgstr "Suchen"
|
msgstr "Suchen"
|
||||||
|
|
||||||
#: konova/utils/geometry/geometry_validator.py:328
|
#: konova/utils/geometry/geometry_validator.py:311
|
||||||
msgid "This feature holds malicious parts and can not be processed!"
|
|
||||||
msgstr "Teile der Geometrie sind ungültig und können nicht verarbeitet werden!"
|
|
||||||
|
|
||||||
#: konova/utils/geometry/geometry_validator.py:332
|
|
||||||
msgid ""
|
msgid ""
|
||||||
"This feature does not hold valid EPSG:25832 coordinates:\n"
|
"This feature does not hold valid EPSG:25832 coordinates:\n"
|
||||||
" {}"
|
" {}"
|
||||||
@@ -2024,7 +2020,7 @@ msgstr ""
|
|||||||
"Dieses Feature enthält keine validen EPSG:25832 Koordinaten:\n"
|
"Dieses Feature enthält keine validen EPSG:25832 Koordinaten:\n"
|
||||||
" {}"
|
" {}"
|
||||||
|
|
||||||
#: konova/utils/geometry/geometry_validator.py:340
|
#: konova/utils/geometry/geometry_validator.py:319
|
||||||
msgid "Only surfaces allowed. Points or lines must be buffered."
|
msgid "Only surfaces allowed. Points or lines must be buffered."
|
||||||
msgstr ""
|
msgstr ""
|
||||||
"Nur Flächen erlaubt. Punkte oder Linien müssen zu Flächen gepuffert werden."
|
"Nur Flächen erlaubt. Punkte oder Linien müssen zu Flächen gepuffert werden."
|
||||||
|
|||||||
+25
@@ -0,0 +1,25 @@
|
|||||||
|
server {
|
||||||
|
listen 80;
|
||||||
|
client_max_body_size 25M;
|
||||||
|
|
||||||
|
location / {
|
||||||
|
proxy_pass http://127.0.0.1:8000;
|
||||||
|
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
|
||||||
|
proxy_set_header X-Real-IP $remote_addr;
|
||||||
|
proxy_set_header Host $host;
|
||||||
|
proxy_redirect off;
|
||||||
|
proxy_cache_bypass $http_upgrade;
|
||||||
|
}
|
||||||
|
|
||||||
|
location /static/ {
|
||||||
|
alias /konova/static/;
|
||||||
|
access_log /var/log/nginx/access.log;
|
||||||
|
autoindex off;
|
||||||
|
types {
|
||||||
|
text/css css;
|
||||||
|
application/javascript js;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
error_log /var/log/nginx/error.log;
|
||||||
|
}
|
||||||
@@ -1,7 +1,6 @@
|
|||||||
amqp==5.3.1
|
amqp==5.3.1
|
||||||
asgiref==3.12.1
|
asgiref==3.12.1
|
||||||
async-timeout==5.0.1
|
async-timeout==5.0.1
|
||||||
Authlib==1.8.0
|
|
||||||
beautifulsoup4==4.15.0
|
beautifulsoup4==4.15.0
|
||||||
billiard==4.2.4
|
billiard==4.2.4
|
||||||
cached-property==2.0.1
|
cached-property==2.0.1
|
||||||
@@ -31,7 +30,6 @@ gunicorn==26.2.0
|
|||||||
idna==3.19
|
idna==3.19
|
||||||
importlib_metadata==9.0.1
|
importlib_metadata==9.0.1
|
||||||
itsdangerous==2.2.0
|
itsdangerous==2.2.0
|
||||||
joserfc==1.7.5
|
|
||||||
jwcrypto==1.6.0
|
jwcrypto==1.6.0
|
||||||
kombu==5.6.2
|
kombu==5.6.2
|
||||||
oauthlib==3.3.1
|
oauthlib==3.3.1
|
||||||
|
|||||||
Reference in New Issue
Block a user