feat: add rest apis

Author: whdalsrnt

pkg/pip_requirements.txt

@@ -1 +1,2 @@
 spaceone-api
+python-multipart

src/setup.py

@@ -26,6 +26,6 @@
     author_email="[email protected]",
     license="Apache License 2.0",
     packages=find_packages(),
-    install_requires=["spaceone-core", "spaceone-api"],
+    install_requires=["spaceone-core", "spaceone-api", "python-multipart"],
     zip_safe=False,
 )

src/spaceone/file_manager/conf/global_conf.py

@@ -1,3 +1,5 @@
+REST_TITLE = "REST API for File Manager"
+
 DATABASE_AUTO_CREATE_INDEX = True
 DATABASES = {
     "default": {

src/spaceone/file_manager/conf/router_conf.py

@@ -0,0 +1,8 @@
+ROUTER = [
+    {
+        "router_path": "spaceone.file_manager.interface.rest.files:router",
+        "router_options": {
+            "prefix": "/files",
+        },
+    },
+]

src/spaceone/file_manager/interface/rest/files.py

@@ -0,0 +1,67 @@
+import logging
+
+from fastapi import Request, Depends, File, UploadFile
+from fastapi.concurrency import run_in_threadpool
+from fastapi_utils.cbv import cbv
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from fastapi_utils.inferring_router import InferringRouter
+from spaceone.core.fastapi.api import BaseAPI, exception_handler
+from spaceone.file_manager.manager.file_connector_manager import FileConnectorManager
+
+from spaceone.file_manager.service.file_service import FileService
+
+_LOGGER = logging.getLogger(__name__)
+_AUTH_SCHEME = HTTPBearer(auto_error=False)
+
+router = InferringRouter(include_in_schema=False)
+
+
+@cbv(router)
+class Files(BaseAPI):
+    token: HTTPAuthorizationCredentials = Depends(_AUTH_SCHEME)
+    service = "file-manager"
+
+    @router.post("/public/upload")
+    @exception_handler
+    async def upload_public_file(self, request: Request, file: UploadFile = File(...)):
+        metadata = {
+            "token": self.token.credentials,
+        }
+
+        params = {
+            "name": file.filename,
+            "resource_group": "SYSTEM",
+        }
+
+        file_svc = FileService(metadata)
+        response: dict = await run_in_threadpool(file_svc.add, params)
+
+        file_id = response.get("file_id")
+
+        file_conn_mgr = FileConnectorManager()
+        # Update File
+        # file_id = file_vo.file_id
+
+        return response
+
+    @router.get("/public/{file_id}")
+    @exception_handler
+    async def download_public_file(self, request: Request, file_id: str):
+        metadata = {
+            "token": self.token.credentials,
+        }
+
+        params = {
+            "file_id": file_id,
+        }
+
+        file_svc = FileService(metadata)
+        response: dict = await run_in_threadpool(file_svc.get, params)
+
+        file_id = response.get("file_id")
+
+        file_conn_mgr = FileConnectorManager()
+        # Update File
+        # file_id = file_vo.file_id
+
+        return response

src/spaceone/file_manager/model/file/request.py

@@ -16,10 +16,6 @@
 
 class FileAddRequest(BaseModel):
     name: str
-    file_type: Union[str, None] = None
-    reference: Union[dict, None] = None
-    file_binary: Union[bytes, None] = None
-    tags: Union[dict, None] = None
     resource_group: ResourceGroup
     domain_id: Union[str, None] = None
     workspace_id: Union[str, None] = None

src/spaceone/file_manager/service/file_service.py

@@ -64,10 +64,6 @@ def add(self, params: FileAddRequest) -> Union[FileResponse, dict]:
 
         file_vo = self.file_mgr.create_file(params.dict())
 
-        file_conn_mgr = FileConnectorManager()
-        # Update File
-        # file_id = file_vo.file_id
-
         # Update Download URL
         # /files/public/{file_id}
         # /files/domain/{domain_id}/{file_id}