mirror of
https://github.com/GNS3/gns3-server.git
synced 2026-11-05 06:41:13 +02:00
api endpoint implemented
This commit is contained in:
1 parent
0fdeb34f1a
commit
b74ebafb8f
9 files changed
+383
-1
No files matched your search
@@ -35,7 +35,7 @@ from gns3server.db.repositories.templates import TemplatesRepository
|
||||
from gns3server.services.templates import TemplatesService
|
||||
from gns3server.db.repositories.rbac import RbacRepository
|
||||
from gns3server.db.repositories.images import ImagesRepository
|
||||
from gns3server.controller.controller_error import ControllerError
|
||||
from gns3server.controller.controller_error import ControllerError, ControllerBadRequestError
|
||||
from gns3server.utils.images import get_builtin_disks
|
||||
|
||||
from .dependencies.authentication import get_current_active_user
|
||||
@@ -230,3 +230,57 @@ async def duplicate_template(
|
||||
|
||||
template = await TemplatesService(templates_repo).duplicate_template(template_id)
|
||||
return template
|
||||
|
||||
@router.get("/{template_id}/base-config/{filename}")
|
||||
async def get_base_config(
|
||||
template_id: UUID,
|
||||
filename: str,
|
||||
templates_repo: TemplatesRepository = Depends(get_repository(TemplatesRepository)),
|
||||
):
|
||||
service = TemplatesService(templates_repo)
|
||||
|
||||
await service.get_template(template_id)
|
||||
|
||||
content = service.get_file(str(template_id), filename)
|
||||
|
||||
return {
|
||||
"template_id": str(template_id),
|
||||
"filename": os.path.basename(filename),
|
||||
"content": content
|
||||
}
|
||||
|
||||
|
||||
@router.put("/{template_id}/base-config/{filename}")
|
||||
async def update_base_config(
|
||||
template_id: UUID,
|
||||
filename: str,
|
||||
body: dict,
|
||||
templates_repo: TemplatesRepository = Depends(get_repository(TemplatesRepository)),
|
||||
):
|
||||
if not body or "content" not in body:
|
||||
raise ControllerBadRequestError("Missing 'content' field")
|
||||
|
||||
service = TemplatesService(templates_repo)
|
||||
|
||||
await service.get_template(template_id)
|
||||
|
||||
service.update_file(str(template_id), filename, body["content"])
|
||||
|
||||
return {
|
||||
"template_id": str(template_id),
|
||||
"filename": os.path.basename(filename),
|
||||
"content": body["content"]
|
||||
}
|
||||
|
||||
|
||||
@router.get("/{template_id}/base-configs")
|
||||
async def list_base_configs(
|
||||
template_id: UUID,
|
||||
templates_repo: TemplatesRepository = Depends(get_repository(TemplatesRepository)),
|
||||
):
|
||||
service = TemplatesService(templates_repo)
|
||||
|
||||
await service.get_template(template_id)
|
||||
|
||||
return service.list_files(str(template_id))
|
||||
|
||||
@@ -49,6 +49,9 @@ class TemplatesRepository(BaseRepository):
|
||||
|
||||
super().__init__(db_session)
|
||||
|
||||
def configs_path(self) -> str:
|
||||
return os.path.join(os.getcwd(), "configs")
|
||||
|
||||
async def get_template(self, template_id: UUID) -> Union[None, models.Template]:
|
||||
|
||||
query = select(models.Template).\
|
||||
|
||||
@@ -174,6 +174,9 @@ class TemplatesService:
|
||||
if builtin_template["template_id"] == template_id:
|
||||
return jsonable_encoder(builtin_template)
|
||||
|
||||
def _base_path(self):
|
||||
return self._templates_repo.configs_path()
|
||||
|
||||
async def get_templates(self) -> List[dict]:
|
||||
|
||||
templates = []
|
||||
@@ -336,3 +339,45 @@ class TemplatesService:
|
||||
self._controller.notification.controller_emit("template.deleted", {"template_id": str(template_id)})
|
||||
else:
|
||||
raise ControllerNotFoundError(f"Template '{template_id}' not found")
|
||||
|
||||
def _template_path(self, template_id: str) -> str:
|
||||
return os.path.join(self._base_path(), str(template_id))
|
||||
|
||||
def list_files(self, template_id: str):
|
||||
path = self._template_path(template_id)
|
||||
|
||||
if not os.path.exists(path):
|
||||
return []
|
||||
|
||||
return [
|
||||
{"filename": f}
|
||||
for f in sorted(os.listdir(path))
|
||||
if os.path.isfile(os.path.join(path, f))
|
||||
]
|
||||
|
||||
def get_file(self, template_id: str, filename: str):
|
||||
safe_filename = os.path.basename(filename)
|
||||
path = os.path.join(self._template_path(template_id), safe_filename)
|
||||
|
||||
if not os.path.isfile(path):
|
||||
raise ControllerNotFoundError(f"File '{safe_filename}' not found")
|
||||
|
||||
try:
|
||||
with open(path, encoding="utf-8", errors="ignore") as f:
|
||||
return f.read()
|
||||
except OSError as e:
|
||||
raise ControllerError(str(e))
|
||||
|
||||
def update_file(self, template_id: str, filename: str, content: str):
|
||||
safe_filename = os.path.basename(filename)
|
||||
|
||||
dir_path = self._template_path(template_id)
|
||||
path = os.path.join(dir_path, safe_filename)
|
||||
|
||||
os.makedirs(dir_path, exist_ok=True)
|
||||
|
||||
try:
|
||||
with open(path, "w", encoding="utf-8") as f:
|
||||
f.write(content)
|
||||
except OSError as e:
|
||||
raise ControllerError(str(e))
|
||||
Reference in new issue
Block a user