mirror of
https://github.com/dgtlmoon/changedetection.io.git
synced 2025-11-30 13:23:28 +00:00
cde42c8a49
Some checks failed
Build and push containers / metadata (push) Has been cancelled
Build and push containers / build-push-containers (push) Has been cancelled
Publish Python 🐍distribution 📦 to PyPI and TestPyPI / Build distribution 📦 (push) Has been cancelled
Publish Python 🐍distribution 📦 to PyPI and TestPyPI / Test the built 📦 package works basically. (push) Has been cancelled
Publish Python 🐍distribution 📦 to PyPI and TestPyPI / Publish Python 🐍 distribution 📦 to PyPI (push) Has been cancelled
ChangeDetection.io App Test / lint-code (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-10 (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-11 (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-12 (push) Has been cancelled
ChangeDetection.io App Test / test-application-3-13 (push) Has been cancelled
83 lines
3.4 KiB
Python
83 lines
3.4 KiB
Python
import copy
|
|
import functools
|
|
from flask import request, abort
|
|
from loguru import logger
|
|
from . import api_schema
|
|
from ..model import watch_base
|
|
|
|
# Build a JSON Schema atleast partially based on our Watch model
|
|
watch_base_config = watch_base()
|
|
schema = api_schema.build_watch_json_schema(watch_base_config)
|
|
|
|
schema_create_watch = copy.deepcopy(schema)
|
|
schema_create_watch['required'] = ['url']
|
|
del schema_create_watch['properties']['last_viewed']
|
|
|
|
schema_update_watch = copy.deepcopy(schema)
|
|
schema_update_watch['additionalProperties'] = False
|
|
|
|
# Tag schema is also based on watch_base since Tag inherits from it
|
|
schema_tag = copy.deepcopy(schema)
|
|
schema_create_tag = copy.deepcopy(schema_tag)
|
|
schema_create_tag['required'] = ['title']
|
|
schema_update_tag = copy.deepcopy(schema_tag)
|
|
schema_update_tag['additionalProperties'] = False
|
|
|
|
schema_notification_urls = copy.deepcopy(schema)
|
|
schema_create_notification_urls = copy.deepcopy(schema_notification_urls)
|
|
schema_create_notification_urls['required'] = ['notification_urls']
|
|
schema_delete_notification_urls = copy.deepcopy(schema_notification_urls)
|
|
schema_delete_notification_urls['required'] = ['notification_urls']
|
|
|
|
@functools.cache
|
|
def get_openapi_spec():
|
|
"""Lazy load OpenAPI spec and dependencies only when validation is needed."""
|
|
import os
|
|
import yaml # Lazy import - only loaded when API validation is actually used
|
|
from openapi_core import OpenAPI # Lazy import - saves ~10.7 MB on startup
|
|
|
|
spec_path = os.path.join(os.path.dirname(__file__), '../../docs/api-spec.yaml')
|
|
with open(spec_path, 'r') as f:
|
|
spec_dict = yaml.safe_load(f)
|
|
_openapi_spec = OpenAPI.from_dict(spec_dict)
|
|
return _openapi_spec
|
|
|
|
def validate_openapi_request(operation_id):
|
|
"""Decorator to validate incoming requests against OpenAPI spec."""
|
|
def decorator(f):
|
|
@functools.wraps(f)
|
|
def wrapper(*args, **kwargs):
|
|
try:
|
|
# Skip OpenAPI validation for GET requests since they don't have request bodies
|
|
if request.method.upper() != 'GET':
|
|
# Lazy import - only loaded when actually validating a request
|
|
from openapi_core.contrib.flask import FlaskOpenAPIRequest
|
|
|
|
spec = get_openapi_spec()
|
|
openapi_request = FlaskOpenAPIRequest(request)
|
|
result = spec.unmarshal_request(openapi_request)
|
|
if result.errors:
|
|
from werkzeug.exceptions import BadRequest
|
|
error_details = []
|
|
for error in result.errors:
|
|
error_details.append(str(error))
|
|
raise BadRequest(f"OpenAPI validation failed: {error_details}")
|
|
except BadRequest:
|
|
# Re-raise BadRequest exceptions (validation failures)
|
|
raise
|
|
except Exception as e:
|
|
# If OpenAPI spec loading fails, log but don't break existing functionality
|
|
logger.critical(f"OpenAPI validation warning for {operation_id}: {e}")
|
|
abort(500)
|
|
return f(*args, **kwargs)
|
|
return wrapper
|
|
return decorator
|
|
|
|
# Import all API resources
|
|
from .Watch import Watch, WatchHistory, WatchSingleHistory, CreateWatch, WatchFavicon
|
|
from .Tags import Tags, Tag
|
|
from .Import import Import
|
|
from .SystemInfo import SystemInfo
|
|
from .Notifications import Notifications
|
|
|