Merge pull request #5271 from ballerina-platform/update-ftp

[master] Update ftp file api used in the BBEs
ballerina-platform · Mar 27, 2024 · 976a3c2 · 976a3c2
2 parents c37c200 + 399d273
commit 976a3c2
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/examples/ftp-service-receive-file/ftp_service_receive_file.bal b/examples/ftp-service-receive-file/ftp_service_receive_file.bal
@@ -26,7 +26,7 @@ service on fileListener {
         // after the last polling was called.
         foreach ftp:FileInfo addedFile in event.addedFiles {
             // Get the newly added file from the FTP server as a `byte[]` stream.
-            stream<byte[] & readonly, io:Error?> fileStream = check caller->get(addedFile.path);
+            stream<byte[] & readonly, io:Error?> fileStream = check caller->get(addedFile.pathDecoded);
 
             // Write the content to a file.
             check io:fileWriteBlocksFromStream(string `./local/${addedFile.name}`, fileStream);

diff --git a/examples/ftp-service-send-file/ftp_service_send_file.bal b/examples/ftp-service-send-file/ftp_service_send_file.bal
@@ -25,7 +25,7 @@ service on fileListener {
         foreach ftp:FileInfo addedFile in event.addedFiles {
             // The `ftp:Caller` can be used to append another file to the added files in the server.
             stream<io:Block, io:Error?> fileStream = check io:fileReadBlocksAsStream("./local/appendFile.txt", 7);
-            check caller->append(addedFile.path, fileStream);
+            check caller->append(addedFile.pathDecoded, fileStream);
             check fileStream.close();
         }
     }

diff --git a/examples/sftp-service-receive-file/sftp_service_receive_file.bal b/examples/sftp-service-receive-file/sftp_service_receive_file.bal
@@ -32,7 +32,7 @@ service on fileListener {
         // after the last polling was called.
         foreach ftp:FileInfo addedFile in event.addedFiles {
             // Get the newly added file from the SFTP server as a `byte[]` stream.
-            stream<byte[] & readonly, io:Error?> fileStream = check caller->get(addedFile.path);
+            stream<byte[] & readonly, io:Error?> fileStream = check caller->get(addedFile.pathDecoded);
 
             // Write the content to a file.
             check io:fileWriteBlocksFromStream(string `./local/${addedFile.name}`, fileStream);

diff --git a/examples/sftp-service-send-file/sftp_service_send_file.bal b/examples/sftp-service-send-file/sftp_service_send_file.bal
@@ -33,7 +33,7 @@ service on fileListener {
         foreach ftp:FileInfo addedFile in event.addedFiles {
             // The `ftp:Caller` can be used to append another file to the added files in the server.
             stream<io:Block, io:Error?> fileStream = check io:fileReadBlocksAsStream("./local/appendFile.txt", 7);
-            check caller->append(addedFile.path, fileStream);
+            check caller->append(addedFile.pathDecoded, fileStream);
             check fileStream.close();
         }
     }