CanSender

rusefi · Jan 6, 2024 · 5707eab · 5707eab
1 parent e05d024
commit 5707eab
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 2 deletions.
diff --git a/playback/src/main/java/com/rusefi/io/can/CanSender.java b/playback/src/main/java/com/rusefi/io/can/CanSender.java
@@ -0,0 +1,5 @@
+package com.rusefi.io.can;
+
+public interface CanSender {
+    void send(int id, byte[] payload);
+}
diff --git a/playback/src/main/java/com/rusefi/io/can/PCanHelper.java b/playback/src/main/java/com/rusefi/io/can/PCanHelper.java
@@ -9,7 +9,7 @@ public class PCanHelper {
     public static final TPCANHandle CHANNEL = TPCANHandle.PCAN_USBBUS1;
 
     //    @NotNull
-    public static PCANBasic create() {
+    public static PCANBasic createPCAN() {
         PCANBasic can = new PCANBasic();
         can.initializeAPI();
         return can;
@@ -27,12 +27,22 @@ public static TPCANStatus send(PCANBasic can, int id, byte[] payLoad) {
     }
 
     public static PCANBasic createAndInit() {
-        PCANBasic pcan = create();
+        PCANBasic pcan = createPCAN();
         TPCANStatus initStatus = init(pcan);
         if (initStatus != TPCANStatus.PCAN_ERROR_OK) {
             System.out.println("TPCANStatus " + initStatus);
             System.exit(-1);
         }
         return pcan;
     }
+
+    public static CanSender create() {
+        PCANBasic pcan = createAndInit();
+        return new CanSender() {
+            @Override
+            public void send(int id, byte[] payload) {
+                PCanHelper.send(pcan, id, payload);
+            }
+        };
+    }
 }
diff --git a/playback/src/main/java/com/rusefi/io/can/SocketCANHelper.java b/playback/src/main/java/com/rusefi/io/can/SocketCANHelper.java
@@ -36,4 +36,14 @@ public static void send(int id, byte[] payload, RawCanChannel channel) {
             throw new IllegalStateException(e);
         }
     }
+
+    public static CanSender create() {
+        RawCanChannel canChannel = createSocket();
+        return new CanSender() {
+            @Override
+            public void send(int id, byte[] payload) {
+                SocketCANHelper.send(id, payload, canChannel);
+            }
+        };
+    }
 }