Merge branch 'edge' into chore_update-vite-6

Author: koji

.cursorignore

@@ -83,12 +83,22 @@ api/docs/dist/v2/
 *.sublime-workspace
 
 # build artifacts
+api-client/dist/
 app/dist/
 app-shell/dist/
 app-shell-odd/dist/
 components/lib
 discovery-client/lib
 labware-designer/dist/
 labware-library/dist/
+opentrons-ai-client/dist/
 protocol-designer/dist/
-opentrons-ai-client/dist/
+react-api-client/dist/
+shared-data/lib/
+step-generation/lib/
+
+# docker
+Dockerfile
+DOCKER.md
+docker-compose.yml
+.dockerignore

.github/workflows/analyses-snapshot-lint.yaml

@@ -35,3 +35,6 @@ jobs:
       - name: ruff-check
         working-directory: ./analyses-snapshot-testing
         run: make ruff-check
+      - name: unit tests
+        working-directory: ./analyses-snapshot-testing
+        run: make unit-test

.github/workflows/analyses-snapshot-test.yaml

@@ -105,9 +105,6 @@ jobs:
       - name: Sync the project
         working-directory: ./analyses-snapshot-testing
         run: make ci-setup
-      - name: Install Opentrons
-        working-directory: ./analyses-snapshot-testing
-        run: make install-ot
       - uses: actions/download-artifact@v4
         with:
           name: chunks
@@ -145,9 +142,6 @@ jobs:
       - name: Sync the project
         working-directory: ./analyses-snapshot-testing
         run: make ci-setup
-      - name: Install Opentrons
-        working-directory: ./analyses-snapshot-testing
-        run: make install-ot
       - name: Download All Analysis Results
         uses: actions/download-artifact@v4
         with:
@@ -191,6 +185,8 @@ jobs:
           body: 'This PR was requested on the PR https://github.com/${{ github.repository }}/pull/${{ github.event.pull_request.number }}'
           branch: 'analyses-snapshot-testing/heal-${{ github.event.pull_request.head.ref }}'
           base: ${{ github.event.pull_request.head.ref }}
+          add-paths: |
+            analyses-snapshot-testing/tests/__snapshots__/analyses_snapshot_test/
 
       - name: Comment on feature PR
         if: always() && steps.create_pull_request.outcome == 'success' && github.event_name == 'pull_request'
@@ -214,3 +210,5 @@ jobs:
           body: 'The edge overnight analyses snapshot test is failing. This PR was opened to alert us to the failure.'
           branch: 'analyses-snapshot-testing/heal-edge'
           base: edge
+          add-paths: |
+            analyses-snapshot-testing/tests/__snapshots__/analyses_snapshot_test/

.github/workflows/docs-build-deploy.yaml

@@ -20,7 +20,7 @@ defaults:
     shell: bash
 
 jobs:
-  sandbox-build-and-deploy-flex-manual:
+  sandbox-build-and-deploy-mkdocs-site:
     timeout-minutes: 5
     runs-on: 'ubuntu-24.04'
     permissions:
@@ -45,13 +45,13 @@ jobs:
       - name: Sync the project
         working-directory: ./docs
         run: make setup
-      - name: Build Flex Manual
+      - name: Build Docs Site
         working-directory: ./docs
-        run: make build-flex-manual
-      - name: Deploy Flex Manual to Sandbox
+        run: make build
+      - name: Deploy Docs Site to Sandbox
         working-directory: ./docs
-        run: make deploy-flex-manual BRANCH=${{ env.BRANCH }}
+        run: make deploy BRANCH=${{ env.BRANCH }}
       - name: Output URL to Summary
         run: |
-          echo "## Flex Manual deployed to sandbox" >> $GITHUB_STEP_SUMMARY
-          echo "<http://sandbox.docs.s3-website.us-east-2.amazonaws.com/${{ env.BRANCH }}/flex-manual/>" >> $GITHUB_STEP_SUMMARY
+          echo "## Docs site deployed to sandbox" >> $GITHUB_STEP_SUMMARY
+          echo "<http://sandbox.docs.s3-website.us-east-2.amazonaws.com/${{ env.BRANCH }}/>" >> $GITHUB_STEP_SUMMARY

abr-testing/abr_testing/automation/gopro.py

@@ -0,0 +1,254 @@
+"""Classes for controlling GoPros."""
+import requests
+from typing import Dict, Union
+from urllib.parse import urlparse
+import subprocess
+import time
+import argparse
+import os
+import json
+import sys
+import platform
+
+
+def connect_to_wifi(network_name: str, password: str) -> bool:
+    """Connect to a Wi-Fi network on macOS or Windows."""
+    system = platform.system()
+
+    if system == "Darwin":  # macOS
+        airport_cmd = (
+            "/System/Library/PrivateFrameworks/Apple80211.framework"
+            "/Versions/Current/Resources/airport"
+        )
+        print("🔍 [macOS] Scanning for available Wi-Fi networks...\n")
+        try:
+            subprocess.run([airport_cmd, "-s"], check=True)
+        except FileNotFoundError:
+            print("❌ 'airport' tool not found.")
+            return False
+        except subprocess.CalledProcessError as e:
+            print(f"❌ Error scanning networks: {e.stderr if e.stderr else str(e)}")
+            return False
+
+        try:
+            subprocess.run(
+                ["networksetup", "-setairportnetwork", "en0", network_name, password],
+                check=True,
+                capture_output=True,
+                text=True,
+            )
+
+            # Wait and verify connection
+            time.sleep(5)  # give it a few seconds to connect
+            result = subprocess.run(
+                ["netsh", "wlan", "show", "interfaces"],
+                capture_output=True,
+                text=True,
+            )
+
+            if network_name in result.stdout:
+                print(f"✅ Connected to '{network_name}' on macOS")
+                return True
+            else:
+                print(f"❌ Attempted to connect, but not connected to '{network_name}'.")
+                return False
+        except subprocess.CalledProcessError as e:
+            print(
+                f"""❌ Failed to connect to '{network_name}':
+                {e.stderr.strip() if e.stderr else str(e)}"""
+            )
+            return False
+    elif system == "Windows":
+        print(
+            f"🔍 [Windows] Attempting to connect to Wi-Fi network '{network_name}'...\n"
+        )
+        try:
+            # Create Wi-Fi profile XML
+            profile_xml = f"""<?xml version="1.0"?>
+<WLANProfile xmlns="http://www.microsoft.com/networking/WLAN/profile/v1">
+    <name>{network_name}</name>
+    <SSIDConfig>
+        <SSID>
+            <name>{network_name}</name>
+        </SSID>
+    </SSIDConfig>
+    <connectionType>ESS</connectionType>
+    <connectionMode>manual</connectionMode>
+    <MSM>
+        <security>
+            <authEncryption>
+                <authentication>WPA2PSK</authentication>
+                <encryption>AES</encryption>
+                <useOneX>false</useOneX>
+            </authEncryption>
+            <sharedKey>
+                <keyType>passPhrase</keyType>
+                <protected>false</protected>
+                <keyMaterial>{password}</keyMaterial>
+            </sharedKey>
+        </security>
+    </MSM>
+</WLANProfile>"""
+
+            profile_path = os.path.join(
+                os.getenv("TEMP", "/tmp"), f"{network_name}.xml"
+            )
+
+            with open(profile_path, "w") as f:
+                f.write(profile_xml)
+
+            subprocess.run(
+                ["netsh", "wlan", "add", "profile", f"filename={profile_path}"],
+                check=True,
+                capture_output=True,
+                text=True,
+            )
+            subprocess.run(
+                ["netsh", "wlan", "connect", f"name={network_name}"],
+                check=True,
+                capture_output=True,
+                text=True,
+            )
+            # Wait and verify connection
+            time.sleep(5)  # give it a few seconds to connect
+            result = subprocess.run(
+                ["netsh", "wlan", "show", "interfaces"],
+                capture_output=True,
+                text=True,
+            )
+
+            if network_name in result.stdout:
+                print(f"✅ Connected to '{network_name}' on Windows")
+                return True
+            else:
+                print(f"❌ Attempted to connect, but not connected to '{network_name}'.")
+                return False
+        except subprocess.CalledProcessError as e:
+            print(
+                f"""❌ Failed to connect to '{network_name}':
+                {e.stderr.strip() if e.stderr else str(e)}"""
+            )
+            return False
+        except Exception as e:
+            print(f"❌ Unexpected error: {e}")
+            return False
+    else:
+        print(f"❌ Unsupported operating system: {system}")
+        return False
+
+
+class GoProCamera:
+    """Commands for GoPro Control."""
+
+    def __init__(self, ip_address: str) -> None:
+        """Connect to GoPro."""
+        parsed = urlparse(f"http://{ip_address}")
+        self.ip = parsed.hostname  # Strips port if given
+        self.control_url = f"http://{self.ip}:8080/gp/gpControl"
+        self.status_url = f"{self.control_url}:8080/status"
+        self.media_url = f"http://{self.ip}:8080/gopro/media/list"
+
+    def start_recording(self) -> Dict[str, Union[str, bool]]:
+        """Start Recording."""
+        print("📷 Started Recording")
+        return self._send_command("command/shutter", {"p": "1"})
+
+    def stop_recording(self) -> Dict[str, Union[str, bool]]:
+        """Stop Recording."""
+        print("🎬 Stopped Recording.")
+        return self._send_command("command/shutter", {"p": "0"})
+
+    def get_status(self) -> Dict[str, Union[str | bool]]:
+        """Get status of gopro."""
+        try:
+            r = requests.get(self.status_url, timeout=3)
+            return r.json() if r.ok else {"error": r.text}
+        except Exception as e:
+            return {"error": str(e)}
+
+    def get_files(self) -> int:
+        """Get all files."""
+        print("📂 Getting Files.")
+        self.stop_recording()
+        time.sleep(5)
+        total_files = 0
+        try:
+            response = requests.get(self.media_url, timeout=5)
+            response.raise_for_status()
+            media_data = response.json()
+            try:
+                total_files = len(media_data["media"][0])
+            except IndexError:
+                total_files = 0
+            print(f"total files {total_files}")
+        except Exception as e:
+            print(f"Error: {e}")
+        return total_files
+
+    def delete_files(self) -> None:
+        """Delete Files."""
+        delete_url = f"http://{self.ip}/gp/gpControl/command/storage/delete/all"
+        total_files = self.get_files()
+        if total_files > 0:
+            try:
+                response = requests.get(delete_url, timeout=60)
+                if response.status_code == 200:
+                    print("🗑️ Deleted Files.")
+            except Exception as e:
+                print(f"Failed to delete files. Status code: {e}")
+
+    def _send_command(
+        self, endpoint: str, params: Dict[str, Union[str | bool]]
+    ) -> Dict[str, Union[str | bool]]:
+        """Send command."""
+        url = f"{self.control_url}/{endpoint}"
+        try:
+            r = requests.get(url, params=params, timeout=3)
+            r.raise_for_status()
+            return {"success": True}
+        except requests.RequestException as e:
+            return {"error": str(e)}
+
+
+def run(storage_directory: str) -> None:
+    """Run script."""
+    ip_json_file = os.path.join(storage_directory, "IPs.json")
+    try:
+        ip_file = json.load(open(ip_json_file))
+        robot_dict = ip_file.get("ip_address_list")
+    except FileNotFoundError:
+        print(f"Add .json file with robot IPs to: {storage_directory}.")
+        sys.exit()
+    # Build dictionary: robot -> password (only if password exists and is not empty)
+    robot_passwords = {
+        values[0]: values[-1]
+        for _, values in robot_dict.items()
+        if len(values) >= 3 and values[-1]
+    }
+    gopro_ip = "10.5.5.9:8080"
+    for robot, password in robot_passwords.items():
+        connected = connect_to_wifi(robot, password)
+        if connected:
+            camera = GoProCamera(gopro_ip)
+            camera.stop_recording()
+            camera.delete_files()
+        for robot, password in robot_passwords.items():
+            connected = connect_to_wifi(robot, password)
+            if connected:
+                camera = GoProCamera(gopro_ip)
+                camera.start_recording()
+
+
+if __name__ == "__main__":
+    """Connect to GoPros, Erase Footage and Start Recording."""
+    parser = argparse.ArgumentParser(description="Read run logs on google drive.")
+    parser.add_argument(
+        "storage_directory",
+        metavar="STORAGE_DIRECTORY",
+        type=str,
+        nargs=1,
+        help="Path to long term storage directory for run logs.",
+    )
+    args = parser.parse_args()
+    storage_directory = args.storage_directory[0]
+    run(storage_directory)

abr-testing/abr_testing/data_collection/abr_calibration_logs.py

@@ -290,29 +290,14 @@ def run(
     except FileNotFoundError:
         print(f"Add .json file with robot IPs to: {storage_directory}.")
         sys.exit()
-    ip_or_all = ""
-    while not ip_or_all:
-        ip_or_all = input("IP Address or ALL: ")
-        calibration_data = []
-        if ip_or_all.upper() == "ALL":
-            ip_address_list = list(robot_dict.keys())
-            for ip in ip_address_list:
-                saved_file_path, calibration = read_robot_logs.get_calibration_offsets(
-                    ip, storage_directory
-                )
-                calibration_data.append(calibration)
-        else:
-            try:
-                (
-                    saved_file_path,
-                    calibration,
-                ) = read_robot_logs.get_calibration_offsets(
-                    ip_or_all, storage_directory
-                )
-                calibration_data.append(calibration)
-            except Exception:
-                print("Invalid IP try again")
-                ip_or_all = ""
+    calibration_data = []
+    ip_address_list = list(robot_dict.keys())
+    for ip in ip_address_list:
+        saved_file_path, calibration = read_robot_logs.get_calibration_offsets(
+            ip, storage_directory
+        )
+        calibration_data.append(calibration)
+
     try:
         upload_calibration_offsets(
             calibration_data,