Move connections into kernel

Author: malcolm-sparkfun

kernel/src/kernel.ts

@@ -2,6 +2,8 @@ import { BaseKernel } from '@jupyterlite/kernel';
 import { KernelMessage } from '@jupyterlab/services';
 import { ServiceContainer } from './services/ServiceContainer';
 
+const reconnectString: string = "%connect%"
+
 export class EmbeddedKernel extends BaseKernel {
 
   constructor(options: any, private serviceContainer: ServiceContainer) {
@@ -58,6 +60,17 @@ export class EmbeddedKernel extends BaseKernel {
     console.log("GOT CODE AT KERNEL LEVEL: ", code);
     console.log("Type of CODE AT KERNEL LEVEL: ", typeof code);
 
+    console.log('Before reconnect check');
+    if (code.includes(reconnectString)) {
+      // Reconnect the device or connect for the first time
+      console.log('Reconnect command detected, reconnecting device...');
+      await this.serviceContainer.deviceService.disconnect();
+      console.log('Device disconnected');
+      await this.serviceContainer.deviceService.connect();
+      console.log('Device connected');
+    }
+    console.log('After reconnect check');
+
     try {
       console.log("[Kernel] executeRequest - Checking transport");
       const transport = this.serviceContainer.deviceService.getTransport();

kernel/src/services/DeviceService.ts

@@ -1,7 +1,5 @@
 import { Transport } from 'esptool-js';
 
-const reconnectString: string = "%connect%"
-
 export class DeviceService {
   private port: SerialPort | null = null;
   private transport: Transport | null = null;
@@ -124,17 +122,6 @@ export class DeviceService {
   }
 
   async sendCommand(code: string): Promise<boolean> {
-    console.log('Before reconnect check');
-    if (code.includes(reconnectString)) {
-      // Reconnect the device or connect for the first time
-      console.log('Reconnect command detected, reconnecting device...');
-      await this.disconnect();
-      console.log('Device disconnected');
-      await this.connect();
-      console.log('Device connected');
-    }
-    console.log('After reconnect check');
-
     if (!this.transport || !this.transport.device.writable) {
       return false;
     }