2 files changed, 171 insertions, 0 deletions

diff --git a/tests/helpers/network.mjs b/tests/helpers/network.mjs
new file mode 100644
index 0000000..e4d5086
--- /dev/null
+++ b/tests/helpers/network.mjs
@@ -0,0 +1,89 @@
+import { execSync } from 'child_process';
+
+const ESP32_IP = process.env.TOLLGATE_IP || '192.168.4.1';
+const TIMEOUT = 5000;
+
+export function curl(args, expectStatus = null) {
+  const cmd = `curl -s -o /dev/null -w "%{http_code}" --connect-timeout 5 --max-time ${TIMEOUT/1000} ${args}`;
+  try {
+    const result = execSync(cmd, { encoding: 'utf8', timeout: TIMEOUT + 2000 }).trim();
+    if (expectStatus && result !== String(expectStatus)) {
+      throw new Error(`Expected HTTP ${expectStatus}, got ${result}`);
+    }
+    return result;
+  } catch (e) {
+    if (e.status === 'ETIMEDOUT' || e.killed) return 'TIMEOUT';
+    throw e;
+  }
+}
+
+export function curlBody(url) {
+  const cmd = `curl -s --connect-timeout 5 --max-time ${TIMEOUT/1000} "${url}"`;
+  try {
+    return execSync(cmd, { encoding: 'utf8', timeout: TIMEOUT + 2000 });
+  } catch {
+    return null;
+  }
+}
+
+export function getPortalIP() { return ESP32_IP; }
+
+export function canPing(host = '8.8.8.8', count = 2) {
+  try {
+    const result = execSync(`ping -c ${count} -W 2 -I wlp59s0 ${host}`, { encoding: 'utf8', timeout: 10000 });
+    return result.includes('0% packet loss') || result.includes('1 packets transmitted');
+  } catch {
+    return false;
+  }
+}
+
+export function canResolve(domain = 'google.com') {
+  try {
+    const result = execSync(`nslookup ${domain} ${ESP32_IP}`, { encoding: 'utf8', timeout: 10000 });
+    return result.includes('Address') && !result.includes('NXDOMAIN');
+  } catch (e) {
+    const result = e.stdout || '';
+    return result.includes('Address') && !result.includes('NXDOMAIN');
+  }
+}
+
+export function dnsResolvesToSelf(domain = 'google.com') {
+  try {
+    const result = execSync(`nslookup ${domain} ${ESP32_IP}`, { encoding: 'utf8', timeout: 10000 });
+    return result.includes(ESP32_IP);
+  } catch (e) {
+    return e.stdout && e.stdout.includes(ESP32_IP);
+  }
+}
+
+export function connectToAP(ssid, password = '') {
+  try {
+    if (password) {
+      execSync(`nmcli dev wifi connect "${ssid}" password "${password}" ifname wlan0`, { timeout: 30000 });
+    } else {
+      execSync(`nmcli dev wifi connect "${ssid}" ifname wlan0`, { timeout: 30000 });
+    }
+    return true;
+  } catch {
+    return false;
+  }
+}
+
+export function disconnectAP() {
+  try {
+    execSync('nmcli dev disconnect wlan0 2>/dev/null || true', { timeout: 10000 });
+    return true;
+  } catch {
+    return false;
+  }
+}
+
+export function getWifiInterface() {
+  try {
+    const result = execSync('nmcli -t -f DEVICE,TYPE dev status', { encoding: 'utf8' });
+    const line = result.split('\n').find(l => l.includes('wifi'));
+    return line ? line.split(':')[0] : null;
+  } catch {
+    return null;
+  }
+}
diff --git a/tests/helpers/serial.mjs b/tests/helpers/serial.mjs
new file mode 100644
index 0000000..306b552
--- /dev/null
+++ b/tests/helpers/serial.mjs
@@ -0,0 +1,82 @@
+import { SerialPort } from 'serialport';
+import { ReadlineParser } from '@serialport/parser-readline';
+import { execSync } from 'child_process';
+
+const DEFAULT_BAUD = 115200;
+const BOOT_TIMEOUT = 30000;
+
+export async function execSerial(portPath, command, timeoutMs = 5000) {
+  return new Promise((resolve, reject) => {
+    const port = new SerialPort({ path: portPath, baudRate: DEFAULT_BAUD });
+    const parser = port.pipe(new ReadlineParser());
+    const lines = [];
+    let resolved = false;
+
+    const timer = setTimeout(() => {
+      if (!resolved) { resolved = true; port.close(); resolve(lines.join('\n')); }
+    }, timeoutMs);
+
+    parser.on('data', (line) => {
+      lines.push(line);
+      if (line.includes('___END___') && !resolved) {
+        resolved = true;
+        clearTimeout(timer);
+        port.close();
+        resolve(lines.join('\n'));
+      }
+    });
+
+    port.on('open', () => {
+      port.write(command + '\n');
+    });
+
+    port.on('error', (err) => {
+      if (!resolved) { resolved = true; clearTimeout(timer); reject(err); }
+    });
+  });
+}
+
+export async function waitForBoot(portPath, timeoutMs = BOOT_TIMEOUT) {
+  return new Promise((resolve, reject) => {
+    const port = new SerialPort({ path: portPath, baudRate: DEFAULT_BAUD });
+    const parser = port.pipe(new ReadlineParser());
+    const timer = setTimeout(() => {
+      port.close();
+      reject(new Error('Boot timeout'));
+    }, timeoutMs);
+
+    parser.on('data', (line) => {
+      if (line.includes('TollGate services started') || line.includes('WiFi AP+STA started')) {
+        clearTimeout(timer);
+        setTimeout(() => { port.close(); resolve(true); }, 500);
+      }
+    });
+
+    port.on('error', (err) => {
+      clearTimeout(timer);
+      reject(err);
+    });
+  });
+}
+
+export async function readSerial(portPath, durationMs = 3000) {
+  return new Promise((resolve, reject) => {
+    const port = new SerialPort({ path: portPath, baudRate: DEFAULT_BAUD });
+    const parser = port.pipe(new ReadlineParser());
+    const lines = [];
+
+    const timer = setTimeout(() => {
+      port.close();
+      resolve(lines.join('\n'));
+    }, durationMs);
+
+    parser.on('data', (line) => lines.push(line));
+    port.on('error', (err) => { clearTimeout(timer); reject(err); });
+  });
+}
+
+export function resetDevice(portPath) {
+  try {
+    execSync(`python3 -m esptool --port ${portPath} run 2>/dev/null`, { timeout: 5000 });
+  } catch {}
+}