Draft implementation of FDO_SYS:fetch

component-samples/device/src/main/java/org/fidoalliance/fdo/sample/FdoSysDeviceModule.java

@@ -335,6 +335,12 @@ private void fetch(String fetchFileName, int mtu) throws IOException {
 
     String fileName = fetchFileName;
     logger.info("Filename " + fileName);
+
+    ServiceInfoKeyValuePair kvPair = new ServiceInfoKeyValuePair();
+    kvPair.setKeyName(FdoSys.FETCHFILE);
+    kvPair.setValue(Mapper.INSTANCE.writeValue(fileName));
+    queue.add(kvPair);
+
     if (!Path.of(fetchFileName).isAbsolute()) {
       fileName = Path.of(getAppData(), fetchFileName).toString();
     }

protocol/src/main/java/org/fidoalliance/fdo/protocol/db/FdoSysOwnerModule.java

@@ -3,9 +3,14 @@
 
 package org.fidoalliance.fdo.protocol.db;
 
+import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
 import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.nio.file.StandardOpenOption;
 import java.sql.Blob;
 import java.sql.SQLException;
 import java.util.Map;
@@ -43,6 +48,7 @@ public class FdoSysOwnerModule implements ServiceInfoModule {
 
 
   private final LoggerService logger = new LoggerService(FdoSysOwnerModule.class);
+  private String fetchFileName;
 
   @Override
   public String getName() {
@@ -103,6 +109,11 @@ public void receive(ServiceInfoModuleState state, ServiceInfoKeyValuePair kvPair
           }
         }
         break;
+      case FdoSys.FETCHFILE:
+        if (state.isActive()) {
+          fetchFileName = Mapper.INSTANCE.readValue(kvPair.getValue(), String.class);
+        }
+        break;
       case FdoSys.DATA:
         if (state.isActive()) {
           byte[] data = Mapper.INSTANCE.readValue(kvPair.getValue(), byte[].class);
@@ -174,6 +185,11 @@ protected boolean infoReady(FdoSysModuleExtra extra) {
         && extra.getFilter().containsKey(DevMod.KEY_ARCH);
   }
 
+  private String getAppData() throws IOException {
+    File file = new File(System.getProperty("app-data.dir"));
+    return file.getCanonicalPath();
+  }
+
   protected boolean checkFilter(Map<String, String> devMap, Map<String, String> filterMap) {
     return !devMap.entrySet().containsAll(filterMap.entrySet());
   }
@@ -187,7 +203,17 @@ protected void onStatusCb(ServiceInfoModuleState state, FdoSysModuleExtra extra,
   protected void onFetch(ServiceInfoModuleState state, FdoSysModuleExtra extra,
       byte[] data) throws IOException {
 
-    logger.warn(new String(data, StandardCharsets.US_ASCII));
+    Path path = Paths.get(getAppData(), fetchFileName);
+    try {
+      if (Files.exists(path)) {
+        Files.write(path, data, StandardOpenOption.APPEND);
+      } else {
+        Files.write(path, data, StandardOpenOption.CREATE_NEW);
+      }
+    } catch (IOException e) {
+      logger.error("Error writing to file: " + e.getMessage());
+    }
+
   }
 
   protected void onEot(ServiceInfoModuleState state, FdoSysModuleExtra extra, EotResult result)

protocol/src/main/java/org/fidoalliance/fdo/protocol/serviceinfo/FdoSys.java

@@ -17,6 +17,7 @@ public final class FdoSys {
   public static final String DATA = NAME + ":data";
   public static final String EOT = NAME + ":eot";
   public static final String FILEDESC = NAME + ":filedesc";
+  public static final String FETCHFILE = NAME + ":fetchfile";
   public static final String WRITE = NAME + ":write";
   public static final String KEEP_ALIVE = NAME + ":keepalive";
   public static final String RET_CODE = NAME + ":retcode";