@@ -69,7 +69,7 @@ def guestfs_instance(self):
6969def guest_local_file (gfs , remote_file ):
7070 with NamedTemporaryFile () as temp :
7171 gfs .download (remote_file , temp .name )
72- yield temp .name
72+ yield remote_file , temp .name
7373
7474
7575class FilesystemHook (Hook ):
@@ -147,8 +147,9 @@ def walk_capture(self, node):
147147 self .context .trigger ('filesystem_new_inode' , inode = inode )
148148 # download and execute trigger on local file
149149 if InodeType (inode .inode_type ) == InodeType .REG :
150- with guest_local_file (self .gfs , str (node )) as local_file :
151- self .context .trigger ('filesystem_new_file' , filepath = local_file , inode = inode )
150+ with guest_local_file (self .gfs , str (node )) as (remote_file , local_file ):
151+ self .context .trigger ('filesystem_new_file' , guest_filepath = remote_file , local_filepath = local_file ,
152+ inode = inode )
152153 # walk
153154 if self .gfs .is_dir (str (node )):
154155 entries = self .list_entries (node )
@@ -162,7 +163,7 @@ def walk_capture(self, node):
162163 return inode
163164
164165 def process_new_file (self , event ):
165- filepath = event .filepath
166+ filepath = event .local_filepath
166167 inode = event .inode
167168 # determine MIME type
168169 mime_type = subprocess .check_output (['file' , '-bi' , filepath ]).decode ().rstrip ()
0 commit comments