mirror of
				https://github.com/avatao-content/baseimage-tutorial-framework
				synced 2025-11-04 12:22:54 +00:00 
			
		
		
		
	Refactor of writing/reading in SourceCodeEventHandler.handle_event()
This commit is contained in:
		@@ -25,20 +25,25 @@ class SourceCodeEventHandler(EventHandlerBase):
 | 
			
		||||
        if anchor == b'reset':
 | 
			
		||||
            self.file = self.create_initial_state(process_is_running=True)
 | 
			
		||||
        if data['command'] == 'read':
 | 
			
		||||
            with open(self.file, 'r') as ifile:
 | 
			
		||||
                content = ifile.read()
 | 
			
		||||
            data_json['data'] = {
 | 
			
		||||
                'filename': self.filename,
 | 
			
		||||
                'content': content,
 | 
			
		||||
                'language': self.language
 | 
			
		||||
            }
 | 
			
		||||
            return data_json
 | 
			
		||||
            self.read_file(data_json)
 | 
			
		||||
        elif data['command'] == 'write':
 | 
			
		||||
            with open(self.file, 'w') as ofile:
 | 
			
		||||
                ofile.write(data['content'])
 | 
			
		||||
            self.supervisor.stopProcess(self.process_name)
 | 
			
		||||
            self.supervisor.startProcess(self.process_name)
 | 
			
		||||
            return None
 | 
			
		||||
            self.write_file(data)
 | 
			
		||||
        return data_json
 | 
			
		||||
 | 
			
		||||
    def read_file(self, data_json):
 | 
			
		||||
        with open(self.file, 'r') as ifile:
 | 
			
		||||
            content = ifile.read()
 | 
			
		||||
        data_json['data'] = {
 | 
			
		||||
            'filename': self.filename,
 | 
			
		||||
            'content': content,
 | 
			
		||||
            'language': self.language
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
    def write_file(self, data):
 | 
			
		||||
        with open(self.file, 'w') as ofile:
 | 
			
		||||
            ofile.write(data['content'])
 | 
			
		||||
        self.supervisor.stopProcess(self.process_name)
 | 
			
		||||
        self.supervisor.startProcess(self.process_name)
 | 
			
		||||
 | 
			
		||||
    def create_initial_state(self, process_is_running=False):
 | 
			
		||||
        if process_is_running:
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user