mirror of
https://github.com/Pardus-LiderAhenk/ahenk
synced 2024-11-22 15:32:19 +03:00
5K size limit has been added to get file content task
This commit is contained in:
parent
1e9c4af168
commit
58a7e84fc9
2 changed files with 17 additions and 6 deletions
|
@ -462,3 +462,5 @@ class Util:
|
||||||
|
|
||||||
return desktop_env
|
return desktop_env
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -23,21 +23,30 @@ class GetFileContent(AbstractPlugin):
|
||||||
if self.is_exist(file_path):
|
if self.is_exist(file_path):
|
||||||
self.logger.info("File exists: " + file_path)
|
self.logger.info("File exists: " + file_path)
|
||||||
is_file_exists = True
|
is_file_exists = True
|
||||||
file_content = self.read_file(file_path)
|
# if the file size is less than 5K
|
||||||
self.context.create_response(code=self.message_code.TASK_PROCESSED.value,
|
file_size = self.get_size(file_path) / 1024
|
||||||
message='Dosya içeriği başarıyla alındı..',
|
if file_size <= 5:
|
||||||
data=json.dumps({'file_exists': is_file_exists, 'file_content': file_content}),
|
file_content = self.read_file(file_path)
|
||||||
content_type=self.get_content_type().APPLICATION_JSON.value)
|
self.context.create_response(code=self.message_code.TASK_PROCESSED.value,
|
||||||
|
message='Dosya içeriği başarıyla alındı..',
|
||||||
|
data=json.dumps({'file_exists': is_file_exists, 'file_content': file_content}),
|
||||||
|
content_type=self.get_content_type().APPLICATION_JSON.value)
|
||||||
|
else:
|
||||||
|
self.logger.error("File size is too large. File Size: {0}K ".format(str(file_size)))
|
||||||
|
self.context.create_response(code=self.message_code.TASK_ERROR.value,
|
||||||
|
message='Dosya içeriği getirilemedi. Dosya boyutu çok büyük.',
|
||||||
|
content_type=self.get_content_type().APPLICATION_JSON.value)
|
||||||
|
|
||||||
else:
|
else:
|
||||||
self.context.create_response(code=self.message_code.TASK_PROCESSED.value,
|
self.context.create_response(code=self.message_code.TASK_PROCESSED.value,
|
||||||
message='Dosya bulunamadı..',
|
message='Dosya bulunamadı..',
|
||||||
content_type=self.get_content_type().APPLICATION_JSON.value)
|
content_type=self.get_content_type().APPLICATION_JSON.value)
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
self.logger.error(str(e))
|
self.logger.error(str(e))
|
||||||
self.context.create_response(code=self.message_code.TASK_ERROR.value,
|
self.context.create_response(code=self.message_code.TASK_ERROR.value,
|
||||||
message='Dosya içeriği alınırken hata oluştu: {0}'.format(str(e)))
|
message='Dosya içeriği alınırken hata oluştu: {0}'.format(str(e)))
|
||||||
|
|
||||||
|
|
||||||
def handle_task(task, context):
|
def handle_task(task, context):
|
||||||
plugin = GetFileContent(task, context)
|
plugin = GetFileContent(task, context)
|
||||||
plugin.handle_task()
|
plugin.handle_task()
|
||||||
|
|
Loading…
Reference in a new issue