#NEWLINE# @ flow . EventHandler ( ) #NEWLINE# def ProcessMessage( self , message = None , event = None ) : #NEWLINE# #INDENT# 'Process the new file and add to the file store.' #NEWLINE# _ = event #NEWLINE# vfs_urn = message . payload #NEWLINE# vfs_fd = aff4 . FACTORY . Open ( vfs_fd , mode = 'rw' , token = self . token ) #NEWLINE# filestore_fd = aff4 . FACTORY . Create ( filestore . FileStore . PATH , 'FileStore' , mode = 'w' , token = self . token ) #NEWLINE# filestore_fd . AddFile ( vfs_fd ) #NEWLINE# vfs_fd . Flush ( sync = False )