Add custom Capacitor plugin-socket

Author: haslinghuis

android/app/src/main/java/betaflight/configurator/MainActivity.java

@@ -1,5 +1,6 @@
 package betaflight.configurator;
 
 import com.getcapacitor.BridgeActivity;
+import betaflight.configurator.plugin.SocketPlugin;
 
 public class MainActivity extends BridgeActivity {}

android/app/src/main/java/betaflight/configurator/plugin/SocketPlugin.java

@@ -0,0 +1,72 @@
+package betaflight.configurator.plugin;
+
+import android.util.Log;
+
+import com.getcapacitor.JSObject;
+import com.getcapacitor.Plugin;
+import com.getcapacitor.PluginCall;
+import com.getcapacitor.annotation.CapacitorPlugin;
+
+import java.io.*;
+import java.net.Socket;
+
+@CapacitorPlugin(name = "SocketPlugin")
+public class SocketPlugin extends Plugin {
+    private Socket socket;
+    private BufferedReader reader;
+    private BufferedWriter writer;
+
+    @PluginMethod
+    public void connect(PluginCall call) {
+        String ip = call.getString("ip");
+        int port = call.getInt("port");
+        try {
+            socket = new Socket(ip, port);
+            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
+            writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
+            JSObject ret = new JSObject();
+            ret.put("success", true);
+            call.resolve(ret);
+        } catch (Exception e) {
+            call.reject("Connection failed: " + e.getMessage());
+        }
+    }
+
+    @PluginMethod
+    public void send(PluginCall call) {
+        String data = call.getString("data");
+        try {
+            writer.write(data);
+            writer.flush();
+            JSObject ret = new JSObject();
+            ret.put("success", true);
+            call.resolve(ret);
+        } catch (Exception e) {
+            call.reject("Send failed: " + e.getMessage());
+        }
+    }
+
+    @PluginMethod
+    public void receive(PluginCall call) {
+        try {
+            String data = reader.readLine();
+            JSObject ret = new JSObject();
+            ret.put("data", data);
+            call.resolve(ret);
+        } catch (Exception e) {
+            call.reject("Receive failed: " + e.getMessage());
+        }
+    }
+
+    @PluginMethod
+    public void disconnect(PluginCall call) {
+        try {
+            if (socket != null) socket.close();
+            JSObject ret = new JSObject();
+            ret.put("success", true);
+            call.resolve(ret);
+        } catch (Exception e) {
+            call.reject("Disconnect failed: " + e.getMessage());
+        }
+    }
+}

capacitor-plugin-socket/package.json

@@ -0,0 +1,16 @@
+{
+  "name": "capacitor-plugin-socket",
+  "version": "1.0.0",
+  "description": "A Capacitor plugin for handling raw TCP sockets.",
+  "main": "index.js",
+  "scripts": {
+    "build": "tsc"
+  },
+  "keywords": ["capacitor", "plugin", "tcp", "socket"],
+  "author": "Your Name",
+  "license": "MIT",
+  "devDependencies": {
+    "@capacitor/core": "latest",
+    "typescript": "^5.0.0"
+  }
+}

capacitor-plugin-socket/src/definitions.ts

@@ -0,0 +1,6 @@
+export interface SocketPlugin {
+  connect(options: { ip: string; port: number }): Promise<{ success: boolean }>;
+  send(options: { data: string }): Promise<{ success: boolean }>;
+  receive(): Promise<{ data: string }>;
+  disconnect(): Promise<{ success: boolean }>;
+}

capacitor-plugin-socket/src/index.ts

@@ -0,0 +1,8 @@
+import { registerPlugin } from '@capacitor/core';
+
+const SocketPlugin = registerPlugin('SocketPlugin', {
+  web: () => import('./web').then(m => new m.SocketPluginWeb()),
+});
+
+export * from './definitions';
+export { SocketPlugin };

capacitor-plugin-socket/src/web.ts

@@ -0,0 +1,24 @@
+import { WebPlugin } from '@capacitor/core';
+import { SocketPlugin } from './definitions';
+
+export class SocketPluginWeb extends WebPlugin implements SocketPlugin {
+  async connect(options: { ip: string; port: number }): Promise<{ success: boolean }> {
+    console.log('Web implementation does not support raw TCP sockets.', options);
+    return { success: false };
+  }
+
+  async send(options: { data: string }): Promise<{ success: boolean }> {
+    console.log('Web implementation does not support raw TCP sockets.', options);
+    return { success: false };
+  }
+
+  async receive(): Promise<{ data: string }> {
+    console.log('Web implementation does not support raw TCP sockets.');
+    return { data: '' };
+  }
+
+  async disconnect(): Promise<{ success: boolean }> {
+    console.log('Web implementation does not support raw TCP sockets.');
+    return { success: false };
+  }
+}