Update examples to d5fc156f6fd9df0dfe9cce66c0e1dc083bf448d2 (#17)

Signed-off-by: Michael Carroll <[email protected]>

Author: mjcarroll

.gitignore

@@ -5,3 +5,4 @@ bazel-**
 compile_commands.json
 MODULE.bazel.lock
 .env
+package-lock.json

MODULE.bazel

@@ -11,13 +11,13 @@ archive_override(
 )
 
 # Direct dependencies
-bazel_dep(name = "abseil-cpp", version = "20250127.1", repo_name = "com_google_absl")
+bazel_dep(name = "abseil-cpp", version = "20250512.1", repo_name = "com_google_absl")
 bazel_dep(name = "abseil-py", version = "2.1.0", repo_name = "com_google_absl_py")
 bazel_dep(name = "bazel_skylib", version = "1.8.0")
 bazel_dep(name = "googletest", version = "1.17.0", repo_name = "com_google_googletest")
 bazel_dep(name = "grpc", version = "1.73.1", repo_name = "com_github_grpc_grpc")
 bazel_dep(name = "platforms", version = "1.0.0")
-bazel_dep(name = "protobuf", version = "30.1", repo_name = "com_google_protobuf")
+bazel_dep(name = "protobuf", version = "31.1", repo_name = "com_google_protobuf")
 bazel_dep(name = "rules_go", version = "0.55.1", repo_name = "io_bazel_rules_go")
 bazel_dep(name = "rules_pkg", version = "1.1.0")
 bazel_dep(name = "rules_python", version = "1.4.1")
@@ -31,10 +31,10 @@ llvm.toolchain(
 )
 
 non_module_deps = use_extension("@ai_intrinsic_sdks//bazel:non_module_deps.bzl", "non_module_deps_ext")
-use_repo(non_module_deps, "com_googleapis_storage_chrome_linux_amd64_sysroot")
+use_repo(non_module_deps, "intrinsic_llvm_sysroot")
 
 llvm.sysroot(
-    label = "@com_googleapis_storage_chrome_linux_amd64_sysroot//:all_files",
+    label = "@intrinsic_llvm_sysroot//:all_files",
     targets = ["linux-x86_64"],
 )
 use_repo(llvm, "llvm_toolchain")

services/angular-hmi/README.md

@@ -3,7 +3,7 @@
 This example implements a service-based HMI for Flowstate.
 
 > [!IMPORTANT]
-> This HMI service is based on the ["Create an HMI service"](https://flowstate.intrinsic.ai/docs/guides/build_with_code/develop_a_service/implement_service_scenarios/create_hmi_service/) guide in the Flowstate documentation.
+> This HMI service is based on the ["Create an HMI service"](https://flowstate.intrinsic.ai/docs/assets/create_new_assets/create_services/implement_service_scenarios/create_hmi_service/) guide in the Flowstate documentation.
 
 ## Features
 
@@ -70,5 +70,3 @@ It should generate a `.tar` ready to be deployed, take note of the output locati
 ```sh
 inctl service install bazel-bin/services/angular-hmi/hmi_angular_service.bundle.tar --org=ORGANIZATION_NAME --address="workcell.lan:17080"
 ```
-
-

services/hmi/BUILD

@@ -14,6 +14,7 @@ go_binary(
     srcs = ["server.go"],
     data = [":frontend_files"],
     deps = [
+        "@ai_intrinsic_sdks//intrinsic/assets/services/proto/v1:system_service_state_go_grpc_proto",
         "@ai_intrinsic_sdks//intrinsic/executive/proto:behavior_tree_go_proto",
         "@ai_intrinsic_sdks//intrinsic/executive/proto:executive_execution_mode_go_proto",
         "@ai_intrinsic_sdks//intrinsic/executive/proto:executive_service_go_grpc_proto",

services/hmi/README.md

@@ -3,7 +3,7 @@
 This example implements a service-based HMI for Flowstate.
 
 > [!IMPORTANT]
-> This HMI service is based on the ["Create an HMI service"](https://flowstate.intrinsic.ai/docs/guides/build_with_code/develop_a_service/implement_service_scenarios/create_hmi_service/) guide in the Flowstate documentation.
+> This HMI service is based on the ["Create an HMI service"](https://flowstate.intrinsic.ai/docs/assets/create_new_assets/create_services/implement_service_scenarios/create_hmi_service/) guide in the Flowstate documentation.
 > Follows the steps in the guide to install the HMI service in your solution.
 
 ## Features
@@ -12,6 +12,7 @@ This example implements a service-based HMI for Flowstate.
 * stop execution
 * pause/resume execution
 * view execution status (inluding errors)
+* query and modify the state of service instances in a solution
 
 ## Test locally
 

services/hmi/frontend/index.html

@@ -19,34 +19,45 @@ <h1 class="title">HMI</h1>
     <div class="box">
       Select a behavior tree to execute:
       <select id="bt-list">
-        <option value="">Select an option</option> 
+        <option value="">Select an option</option>
       </select>
     </div>
     <button disabled class="button is-success" id="start">
       Start Process
     </button>
     <button disabled class="button is-danger" id="stop">Stop</button>
+    <div class="box" style="margin-top: 32px">
+      <button class="button" id="states-list" style="margin-bottom: 16px">
+        List/refresh service states
+      </button>
+      <div id="service-states" class="content"></div>
+    </div>
+    <div style="display: none" class="notification" id="state-result"></div>
   </div>
 </section>
 
 <script>
   let operationId = "";
   let behaviorTreeName = "";
   let showStatus = false;
+  let states = [];
 
   const startEl = document.getElementById("start");
   const stopEl = document.getElementById("stop");
   const statusEl = document.getElementById("status");
   const resultEl = document.getElementById("result");
   const btListEl = document.getElementById("bt-list");
+  const serviceStatesEl = document.getElementById("service-states");
+  const listStatesEl = document.getElementById("states-list");
   refreshStatus();
 
+
   btListEl.addEventListener('mousedown', async () => {
     // Clear existing options.
-    btListEl.innerHTML = '<option value="">Select an option</option>'; 
+    btListEl.innerHTML = '<option value="">Select an option</option>';
 
     // Add all currently saved behavior trees in solution.
-    const options = await getBehaviorTrees(); 
+    const options = await getBehaviorTrees();
     options.forEach(optionText => {
       const option = document.createElement('option');
       option.value = optionText;
@@ -66,6 +77,10 @@ <h1 class="title">HMI</h1>
     start(behaviorTreeName);
   });
 
+  listStatesEl.addEventListener("click", async () => {
+    states = await listServiceStates();
+  });
+
   async function refreshStatus() {
     if (!behaviorTreeName){
       statusEl.textContent = "UNSPECIFIED";
@@ -87,7 +102,7 @@ <h1 class="title">HMI</h1>
             stopEl.disabled = true;
           }
         } else {
-          startEl.disabled = true;
+          startEl.disabled = false;
           stopEl.disabled = true;
         }
 
@@ -110,8 +125,87 @@ <h1 class="title">HMI</h1>
         operationId = "";
       }
     }
-      // Refresh the current status every second.
-      setTimeout(refreshStatus, 1000);
+
+    if (states.length > 0) {
+      let str = `
+<table>
+  <thead>
+    <tr>
+      <th>Name</th>
+      <th>State</th>
+      <th>Enable</th>
+      <th>Disable</th>
+      <th>Restart</th>
+    </tr>
+  </thead>
+  <tbody>
+`;
+      states.forEach(function(state) {
+        let row = '<tr>'
+        row += '<td>' + state.name + '</td>';
+        row += '<td>' + state.state.stateCode + '</td>';
+        row += `<td><button class="button" id="enable-${state.name}">Enable</button></td>`;
+        row += `<td><button class="button" id="disable-${state.name}">Disable</button></td>`;
+        row += `<td><button class="button" id="restart-${state.name}">Restart</button></td>`;
+        row += '</tr>';
+        str += row;
+      });
+      str += `
+      </tbody>
+      </table>
+      `;
+      serviceStatesEl.innerHTML = str;
+      states.forEach(function(state) {
+        addStateManagementHandlers(state.name);
+      })
+    }
+
+    // Refresh the current status every second.
+    setTimeout(refreshStatus, 1000);
+  }
+
+  function addStateManagementHandlers(name) {
+    const notificationEl = document.getElementById("state-result");
+    stateHandler(document.getElementById(`enable-${name}`), "enable", name, notificationEl);
+    stateHandler(document.getElementById(`disable-${name}`), "disable", name, notificationEl);
+    stateHandler(document.getElementById(`restart-${name}`), "restart", name, notificationEl);
+  }
+
+  function stateHandler(buttonEl, stateMethod, name, notificationEl) {
+    buttonEl.addEventListener("click", async () => {
+      try {
+          notificationEl.style.display = "none";
+          const req = new Request(`api/serviceStates/${name}/${stateMethod}`, {
+            method: 'POST',
+          });
+          const res = await fetch(req);
+          const s = await res.json();
+          if (s.error) {
+            notificationEl.classList.add('is-danger');
+            notificationEl.classList.remove('is-success');
+            notificationEl.textContent = s.error;
+          } else {
+            notificationEl.classList.remove('is-danger');
+            notificationEl.classList.add('is-success');
+            notificationEl.textContent = `"${stateMethod}" successful.`;
+          }
+          notificationEl.style.display = "block";
+        } catch (e) {
+          notificationEl.classList.add('is-danger');
+          notificationEl.classList.remove('is-success');
+          notificationEl.textContent = `Failed to ${stateMethod} ${name}`;
+          notificationEl.style.display = "block";
+        }
+    })
+  }
+
+  async function listServiceStates() {
+    const res = await fetch("api/serviceStates");
+    const s = await res.json();
+    if(Array.isArray(s['states'])) {
+      return s['states'];
+    }
+    return [];
   }
 
   async function getBehaviorTrees() {
@@ -121,7 +215,7 @@ <h1 class="title">HMI</h1>
       s = await res.json();
       if(Array.isArray(s['names']) && s['names'].length > 0) {
         return s['names'];
-      } 
+      }
     } catch (e) {
       console.log(s.error);
     }