mirror of
https://github.com/wahyd4/links.git
synced 2026-08-08 21:04:53 +10:00
Removing debugging loggings
This commit is contained in:
@@ -20,16 +20,10 @@ class ImageCollectionViewSet(viewsets.ModelViewSet):
|
||||
files = request.FILES.getlist('file')
|
||||
storage = R2Storage()
|
||||
|
||||
logger.debug(f"Processing upload request for collection {collection.id}")
|
||||
logger.debug(f"Number of files: {len(files)}")
|
||||
|
||||
uploaded_images = []
|
||||
for file in files:
|
||||
try:
|
||||
logger.info(os.environ.get('R2_ENDPOINT_URL'))
|
||||
logger.debug(f"Processing file: {file.name}")
|
||||
logger.debug(f"File size: {file.size}")
|
||||
logger.debug(f"Content type: {file.content_type}")
|
||||
|
||||
# Generate unique file key
|
||||
file_key = f"images/{collection.id}/{uuid.uuid4()}/{file.name}"
|
||||
@@ -57,7 +51,6 @@ class ImageCollectionViewSet(viewsets.ModelViewSet):
|
||||
size=file.size
|
||||
)
|
||||
|
||||
logger.debug(f"Created image record: {image.id}")
|
||||
uploaded_images.append(ImageSerializer(image).data)
|
||||
|
||||
except Exception as e:
|
||||
|
||||
@@ -8,7 +8,6 @@ logger = logging.getLogger(__name__)
|
||||
|
||||
class R2Storage:
|
||||
def __init__(self):
|
||||
logger.debug(f"Initializing R2Storage with endpoint: {settings.R2_ENDPOINT_URL}")
|
||||
self.client = boto3.client('s3',
|
||||
endpoint_url=settings.R2_ENDPOINT_URL,
|
||||
aws_access_key_id=settings.R2_ACCESS_KEY_ID,
|
||||
@@ -17,20 +16,15 @@ class R2Storage:
|
||||
region_name='auto'
|
||||
)
|
||||
self.bucket = settings.R2_BUCKET_NAME
|
||||
logger.debug(f"Using bucket: {self.bucket}")
|
||||
|
||||
def upload_file(self, file_obj, key, content_type=None):
|
||||
"""Upload a file to R2"""
|
||||
try:
|
||||
logger.debug(f"Starting file upload: {key}")
|
||||
logger.debug(f"File object type: {type(file_obj)}")
|
||||
|
||||
# Reset file pointer and read content
|
||||
file_obj.seek(0)
|
||||
file_content = file_obj.read()
|
||||
|
||||
logger.debug(f"File content size: {len(file_content) if file_content else 'None'}")
|
||||
|
||||
if not file_content:
|
||||
raise ValueError("File content is empty")
|
||||
|
||||
@@ -41,8 +35,6 @@ class R2Storage:
|
||||
'ContentType': content_type or 'application/octet-stream',
|
||||
}
|
||||
|
||||
logger.debug(f"Uploading to R2 with extra args: {extra_args}")
|
||||
|
||||
self.client.upload_fileobj(
|
||||
file_data,
|
||||
self.bucket,
|
||||
@@ -50,7 +42,6 @@ class R2Storage:
|
||||
ExtraArgs=extra_args
|
||||
)
|
||||
|
||||
logger.debug(f"Successfully uploaded file: {key}")
|
||||
return key
|
||||
|
||||
except Exception as e:
|
||||
@@ -70,7 +61,6 @@ class R2Storage:
|
||||
},
|
||||
ExpiresIn=expires_in # URL expires in 1 hour by default
|
||||
)
|
||||
logger.debug(f"Generated signed URL for {key}")
|
||||
return url
|
||||
except Exception as e:
|
||||
logger.error(f"Failed to generate signed URL: {str(e)}")
|
||||
|
||||
Reference in New Issue
Block a user