D4
/
d4-core
mirror of https://github.com/D4-project/d4-core
2
0
Fork 0
Code Issues Releases Wiki Activity

chg: [default module 254] cleaning

visu-type
Terrtia 2019-03-13 10:40:59 +01:00
parent d6d11fecc3
commit 5f1afd92d6
No known key found for this signature in database
GPG Key ID: 1E1B1F50D84613D0
1 changed files with 2 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
server/workers/workers_2/meta_types_modules/MetaTypesDefault.py
View File

@ -22,6 +22,7 @@ class MetaTypesDefault:
self.type_name = json_file['type'] self.type_name = json_file['type']
self.save_path = None self.save_path = None
self.buffer = b'' self.buffer = b''
self.file_rotation_mode = True
self.parse_json(json_file) self.parse_json(json_file)
def test(self): def test(self):
@ -29,8 +30,6 @@ class MetaTypesDefault:
######## JSON PARSER ######## ######## JSON PARSER ########
def parse_json(self, json_file): def parse_json(self, json_file):
self.save_file_on_disk = True
self.file_rotation_mode = True
self.file_rotation = False self.file_rotation = False
self.file_separator = b'\n' self.file_separator = b'\n'
self.filename = b''.join([self.type_name.encode(), b'.txt']) self.filename = b''.join([self.type_name.encode(), b'.txt'])
@ -38,8 +37,7 @@ class MetaTypesDefault:
######## PROCESS FUNCTIONS ######## ######## PROCESS FUNCTIONS ########
def process_data(self, data): def process_data(self, data):
# save data on disk # save data on disk
if self.is_file_saved_on_disk(): self.save_rotate_file(data)
self.save_data_to_file(data)
######## CORE FUNCTIONS ######## ######## CORE FUNCTIONS ########
@ -50,7 +48,6 @@ class MetaTypesDefault:
else: else:
return False return False
# # TODO: update for non rotate_file mode
def save_json_file(self, json_file): def save_json_file(self, json_file):
self.set_last_time_saved(time.time()) #time_file self.set_last_time_saved(time.time()) #time_file
self.set_last_saved_date(datetime.datetime.now().strftime("%Y%m%d%H%M%S")) #date_file self.set_last_saved_date(datetime.datetime.now().strftime("%Y%m%d%H%M%S")) #date_file
@ -62,10 +59,6 @@ class MetaTypesDefault:
# update save path for 254 files type # update save path for 254 files type
self.set_save_path( os.path.join(self.get_save_dir(), self.get_filename()) ) self.set_save_path( os.path.join(self.get_save_dir(), self.get_filename()) )
def save_data_to_file(self, data):
if self.is_file_rotation_mode():
self.save_rotate_file(data)
def save_rotate_file(self, data): def save_rotate_file(self, data):
if not self.get_file_rotation(): if not self.get_file_rotation():
@ -113,10 +106,6 @@ class MetaTypesDefault:
with open(self.get_save_path(), 'ab') as f: with open(self.get_save_path(), 'ab') as f:
f.write(data) f.write(data)
def save_same_directory(self, data):
pass
def reconstruct_data(self, data): def reconstruct_data(self, data):
# add buffer to data # add buffer to data
if not is_empty_buffer(): if not is_empty_buffer():
@ -214,12 +203,6 @@ class MetaTypesDefault:
else: else:
return False return False
def is_file_saved_on_disk(self):
if self.save_file_on_disk:
return True
else:
return False
def is_file_rotation_mode(self): def is_file_rotation_mode(self):
if self.file_rotation_mode: if self.file_rotation_mode:
return True return True
@ -272,5 +255,3 @@ class MetaTypesDefault:
if not os.path.isdir(dir_path): if not os.path.isdir(dir_path):
os.makedirs(dir_path) os.makedirs(dir_path)
self.save_path = save_path self.save_path = save_path
##############