@@ -266,34 +266,37 @@ func (h *testSessionFsHandler) ReadFile(request *rpc.SessionFSReadFileRequest) (
266266 return & rpc.SessionFSReadFileResult {Content : string (content )}, nil
267267}
268268
269- func (h * testSessionFsHandler ) WriteFile (request * rpc.SessionFSWriteFileRequest ) error {
269+ func (h * testSessionFsHandler ) WriteFile (request * rpc.SessionFSWriteFileRequest ) ( * rpc. SessionFSWriteFileResult , error ) {
270270 path := providerPath (h .root , h .sessionID , request .Path )
271271 if err := os .MkdirAll (filepath .Dir (path ), 0o755 ); err != nil {
272- return err
272+ return nil , err
273273 }
274274 mode := os .FileMode (0o666 )
275275 if request .Mode != nil {
276276 mode = os .FileMode (uint32 (* request .Mode ))
277277 }
278- return os .WriteFile (path , []byte (request .Content ), mode )
278+ return & rpc. SessionFSWriteFileResult {}, os .WriteFile (path , []byte (request .Content ), mode )
279279}
280280
281- func (h * testSessionFsHandler ) AppendFile (request * rpc.SessionFSAppendFileRequest ) error {
281+ func (h * testSessionFsHandler ) AppendFile (request * rpc.SessionFSAppendFileRequest ) ( * rpc. SessionFSAppendFileResult , error ) {
282282 path := providerPath (h .root , h .sessionID , request .Path )
283283 if err := os .MkdirAll (filepath .Dir (path ), 0o755 ); err != nil {
284- return err
284+ return nil , err
285285 }
286286 mode := os .FileMode (0o666 )
287287 if request .Mode != nil {
288288 mode = os .FileMode (uint32 (* request .Mode ))
289289 }
290290 f , err := os .OpenFile (path , os .O_CREATE | os .O_WRONLY | os .O_APPEND , mode )
291291 if err != nil {
292- return err
292+ return nil , err
293293 }
294294 defer f .Close ()
295295 _ , err = f .WriteString (request .Content )
296- return err
296+ if err != nil {
297+ return nil , err
298+ }
299+ return & rpc.SessionFSAppendFileResult {}, nil
297300}
298301
299302func (h * testSessionFsHandler ) Exists (request * rpc.SessionFSExistsRequest ) (* rpc.SessionFSExistsResult , error ) {
@@ -312,26 +315,26 @@ func (h *testSessionFsHandler) Stat(request *rpc.SessionFSStatRequest) (*rpc.Ses
312315 if err != nil {
313316 return nil , err
314317 }
315- ts := info .ModTime ().UTC (). Format ( time . RFC3339 )
318+ ts := info .ModTime ().UTC ()
316319 return & rpc.SessionFSStatResult {
317320 IsFile : ! info .IsDir (),
318321 IsDirectory : info .IsDir (),
319- Size : float64 ( info .Size () ),
322+ Size : info .Size (),
320323 Mtime : ts ,
321324 Birthtime : ts ,
322325 }, nil
323326}
324327
325- func (h * testSessionFsHandler ) Mkdir (request * rpc.SessionFSMkdirRequest ) error {
328+ func (h * testSessionFsHandler ) Mkdir (request * rpc.SessionFSMkdirRequest ) ( * rpc. SessionFSMkdirResult , error ) {
326329 path := providerPath (h .root , h .sessionID , request .Path )
327330 mode := os .FileMode (0o777 )
328331 if request .Mode != nil {
329332 mode = os .FileMode (uint32 (* request .Mode ))
330333 }
331334 if request .Recursive != nil && * request .Recursive {
332- return os .MkdirAll (path , mode )
335+ return & rpc. SessionFSMkdirResult {}, os .MkdirAll (path , mode )
333336 }
334- return os .Mkdir (path , mode )
337+ return & rpc. SessionFSMkdirResult {}, os .Mkdir (path , mode )
335338}
336339
337340func (h * testSessionFsHandler ) Readdir (request * rpc.SessionFSReaddirRequest ) (* rpc.SessionFSReaddirResult , error ) {
@@ -365,28 +368,28 @@ func (h *testSessionFsHandler) ReaddirWithTypes(request *rpc.SessionFSReaddirWit
365368 return & rpc.SessionFSReaddirWithTypesResult {Entries : result }, nil
366369}
367370
368- func (h * testSessionFsHandler ) Rm (request * rpc.SessionFSRmRequest ) error {
371+ func (h * testSessionFsHandler ) Rm (request * rpc.SessionFSRmRequest ) ( * rpc. SessionFSRmResult , error ) {
369372 path := providerPath (h .root , h .sessionID , request .Path )
370373 if request .Recursive != nil && * request .Recursive {
371374 err := os .RemoveAll (path )
372375 if err != nil && request .Force != nil && * request .Force && os .IsNotExist (err ) {
373- return nil
376+ return & rpc. SessionFSRmResult {}, nil
374377 }
375- return err
378+ return & rpc. SessionFSRmResult {}, err
376379 }
377380 err := os .Remove (path )
378381 if err != nil && request .Force != nil && * request .Force && os .IsNotExist (err ) {
379- return nil
382+ return & rpc. SessionFSRmResult {}, nil
380383 }
381- return err
384+ return & rpc. SessionFSRmResult {}, err
382385}
383386
384- func (h * testSessionFsHandler ) Rename (request * rpc.SessionFSRenameRequest ) error {
387+ func (h * testSessionFsHandler ) Rename (request * rpc.SessionFSRenameRequest ) ( * rpc. SessionFSRenameResult , error ) {
385388 dest := providerPath (h .root , h .sessionID , request .Dest )
386389 if err := os .MkdirAll (filepath .Dir (dest ), 0o755 ); err != nil {
387- return err
390+ return nil , err
388391 }
389- return os .Rename (
392+ return & rpc. SessionFSRenameResult {}, os .Rename (
390393 providerPath (h .root , h .sessionID , request .Src ),
391394 dest ,
392395 )
0 commit comments