Skip to content

Commit 6ac08c3

Browse files
committed
fix(blob): allow for container overrides
1 parent 4e74d93 commit 6ac08c3

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

servc/svc/com/http/blob.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
import os
33
from io import BytesIO
44
from multiprocessing import Process
5-
from typing import Dict, List
5+
from typing import Dict, List, Tuple
66

77
from flask import jsonify, request, send_file
88
from werkzeug.utils import secure_filename
@@ -48,8 +48,8 @@ def __init__(
4848

4949
self._uploadcontainer = config.get("uploadcontainer") or "uploads"
5050

51-
def get_upload_file_path(self, extra_params: Dict, fname: str) -> str:
52-
return secure_filename(fname)
51+
def get_upload_file_path(self, extra_params: Dict, fname: str) -> Tuple[str, str]:
52+
return self._uploadcontainer, secure_filename(fname)
5353

5454
def _postMessage(self, extra_params: Dict | None = None):
5555
if request.method == "POST" and len(list(request.files)) > 0:
@@ -59,11 +59,11 @@ def _postMessage(self, extra_params: Dict | None = None):
5959

6060
for filekey in list(request.files):
6161
file = request.files[filekey]
62-
remote_filename = self.get_upload_file_path(extra_params, file.filename)
62+
container, remote_filename = self.get_upload_file_path(extra_params, file.filename)
6363

6464
if file.filename != "":
6565
self._blobStorage.put_file(
66-
self._uploadcontainer, remote_filename, file.stream.read()
66+
container, remote_filename, file.stream.read()
6767
)
6868
extra_params["files"].append(remote_filename)
6969

0 commit comments

Comments
 (0)