mirror of
https://github.com/jhd3197/ServerKit.git
synced 2026-10-30 00:27:11 +09:00
Juan Denis
55d8fb1e44
328 more routes used a JSON body as a dict straight from
request.get_json(), so a body of null, [] or a bare string crashed them
into a 500. Bare reads become json_object(); the
'get_json(silent=True) or {}' reads of action routes become
json_object(optional=True), which still treats a missing body as {}.
Routes that take arrays or pass the body through untouched are left
alone. The full backend suite shows no new failures.
Also carries three files' bare section citations (apps, backups,
notifications) and the extended citation guard, which needed them.
76 lines
2.9 KiB
Python
76 lines
2.9 KiB
Python
# Bucket: PER-APP. Volume routes gate on the shared app-access seam
|
|
# (can_access_app for reads, can_edit_app for attach/detach mutations).
|
|
"""Per-app managed volume API — attach/list/detach first-class persistent
|
|
volumes for an application. Mounted under ``/api/v1/apps`` alongside the main
|
|
apps blueprint (routes are ``/<app_id>/volumes*``).
|
|
"""
|
|
from flask import Blueprint, request, jsonify
|
|
from flask_jwt_extended import jwt_required
|
|
|
|
from app.services.volume_service import VolumeService, VolumeError
|
|
from app.api._access import require_app
|
|
from app.api._request import json_object
|
|
|
|
app_volumes_bp = Blueprint('app_volumes', __name__)
|
|
|
|
|
|
@app_volumes_bp.route('/<int:app_id>/volumes', methods=['GET'])
|
|
@jwt_required()
|
|
def list_volumes(app_id):
|
|
app = require_app(app_id)
|
|
volumes = [v.to_dict(live=live) for v, live in VolumeService.list_for_app(app)]
|
|
return jsonify({'volumes': volumes})
|
|
|
|
|
|
@app_volumes_bp.route('/<int:app_id>/volumes', methods=['POST'])
|
|
@jwt_required()
|
|
def attach_volume(app_id):
|
|
app = require_app(app_id, write=True)
|
|
data = json_object()
|
|
try:
|
|
volume = VolumeService.create(
|
|
app,
|
|
name=data.get('name'),
|
|
mount_path=data.get('mount_path'),
|
|
driver=data.get('driver') or 'local',
|
|
read_only=bool(data.get('read_only')),
|
|
)
|
|
except VolumeError as e:
|
|
return jsonify({'error': str(e)}), 400
|
|
live = None
|
|
return jsonify({'volume': volume.to_dict(live=live)}), 201
|
|
|
|
|
|
@app_volumes_bp.route('/<int:app_id>/volumes/<int:volume_id>', methods=['DELETE'])
|
|
@jwt_required()
|
|
def detach_volume(app_id, volume_id):
|
|
app = require_app(app_id, write=True)
|
|
volume = VolumeService.get(volume_id)
|
|
if not volume or volume.application_id != app.id:
|
|
return jsonify({'error': 'Volume not found'}), 404
|
|
wipe = str(request.args.get('wipe', '')).lower() in ('1', 'true', 'yes')
|
|
try:
|
|
VolumeService.delete(volume, wipe=wipe)
|
|
except VolumeError as e:
|
|
return jsonify({'error': str(e)}), 400
|
|
return jsonify({'success': True, 'wiped': wipe})
|
|
|
|
|
|
@app_volumes_bp.route('/<int:app_id>/volumes/convert', methods=['POST'])
|
|
@jwt_required()
|
|
def convert_bind_mount(app_id):
|
|
"""Create a managed volume and copy an existing host directory's contents
|
|
into it. (Deviates from the plan's ``/<vid>/convert`` — a convert creates a
|
|
new volume, so there is no prior vid.)"""
|
|
app = require_app(app_id, write=True)
|
|
data = json_object()
|
|
host_path = data.get('host_path')
|
|
mount_path = data.get('mount_path')
|
|
if not host_path or not mount_path:
|
|
return jsonify({'error': 'host_path and mount_path are required'}), 400
|
|
try:
|
|
volume = VolumeService.convert_bind_mount(app, host_path, mount_path, name=data.get('name'))
|
|
except VolumeError as e:
|
|
return jsonify({'error': str(e)}), 400
|
|
return jsonify({'volume': volume.to_dict()}), 201
|