feat(cli): use domain and pipeline status text for animation (#157)

* update status text

Signed-off-by: Joshua Li <joshuali925@gmail.com>

* update readme command

Signed-off-by: Joshua Li <joshuali925@gmail.com>

---------

Signed-off-by: Joshua Li <joshuali925@gmail.com>

Author: joshuali925

aws/cli-installer/README.md

@@ -5,12 +5,7 @@ Deploy the [Observability Stack](https://github.com/opensearch-project/observabi
 ## Quick Start
 
 ```bash
-git clone https://github.com/opensearch-project/observability-stack.git
-cd observability-stack/aws/cli-installer && npm install
-
-node bin/cli-installer.mjs --managed \
-  --pipeline-name obs-stack-<your-alias> \
-  --region us-east-1
+bash -c "$(curl -fsSL https://raw.githubusercontent.com/opensearch-project/observability-stack/main/install.sh)" -- --deployment-target=aws
 ```
 
 Takes ~15 minutes. When complete, the CLI prints a dashboard URL — open it and you're in.

aws/cli-installer/src/aws.mjs

@@ -3,6 +3,7 @@ import {
   OpenSearchClient,
   CreateDomainCommand,
   DescribeDomainCommand,
+  DescribeDomainChangeProgressCommand,
   ListDomainNamesCommand,
   DescribeDomainsCommand,
   AddDirectQueryDataSourceCommand,
@@ -30,6 +31,7 @@ import {
   ListPipelinesCommand,
   CreatePipelineCommand,
   GetPipelineCommand,
+  GetPipelineChangeProgressCommand,
 } from '@aws-sdk/client-osis';
 import {
   ResourceGroupsTaggingAPIClient,
@@ -272,7 +274,17 @@ async function createManagedDomain(cfg) {
   while (Date.now() - start < maxWait) {
     try {
       const desc = await client.send(new DescribeDomainCommand({ DomainName: cfg.osDomainName }));
-      const endpoint = desc.DomainStatus?.Endpoint;
+      const ds = desc.DomainStatus || {};
+      const endpoint = ds.Endpoint;
+
+      // Feed real stage progress into the owl animation
+      try {
+        const cp = await client.send(new DescribeDomainChangeProgressCommand({ DomainName: cfg.osDomainName }));
+        const stages = cp.ChangeProgressStatus?.ChangeProgressStages || [];
+        const current = stages.find((s) => s.Status === 'IN_PROGRESS') || stages.findLast((s) => s.Status === 'COMPLETED');
+        anim.setDomainStatus(current?.Description || current?.Name || 'Initializing...');
+      } catch { /* change progress may not be available yet */ }
+
       if (endpoint) {
         cfg.opensearchEndpoint = `https://${endpoint}`;
         anim.stop();
@@ -570,6 +582,15 @@ export async function createOsiPipeline(cfg, pipelineYaml) {
     try {
       const resp = await client.send(new GetPipelineCommand({ PipelineName: cfg.pipelineName }));
       const status = resp.Pipeline?.Status;
+
+      // Feed real stage progress into the fish animation
+      try {
+        const cp = await client.send(new GetPipelineChangeProgressCommand({ PipelineName: cfg.pipelineName }));
+        const stages = cp.ChangeProgressStatuses?.[0]?.ChangeProgressStages || [];
+        const current = stages.find((s) => s.Status === 'IN_PROGRESS') || stages.findLast((s) => s.Status === 'COMPLETED');
+        anim.setDomainStatus(current?.Description || current?.Name || 'Initializing...');
+      } catch { /* change progress may not be available yet */ }
+
       if (status === 'ACTIVE') {
         const urls = resp.Pipeline?.IngestEndpointUrls || [];
         cfg.ingestEndpoints = urls;

aws/cli-installer/src/ui.mjs

@@ -495,60 +495,46 @@ function createWordRotator() {
   };
 }
 
-// Owl searching through data — for OpenSearch domain provisioning
-const OPENSEARCH_FRAMES = [
-  [
-    '',
-    "        ,___,",
-    '        {o,o}    ◇ searching...',
-    '        /)__)',
-    '        -"-"-    ◇ ◇ ◇',
-    null,
-    '',
-  ],
-  [
-    '',
-    "        ,___,",
-    '        {O,o}      ◈ indexing...',
-    '        /)__)',
-    '        -"-"-      ◈ ◈ ◈',
-    null,
-    '',
-  ],
-  [
-    '',
-    "        ,___,",
-    '        {o,O}        ◆ mapping...',
-    '        /)__)',
-    '        -"-"-        ◆ ◆ ◆',
-    null,
-    '',
-  ],
-  [
+// Owl eye patterns cycle for animation even when status text is static
+const OWL_EYES = ['{o,o}', '{O,o}', '{o,O}', '{O,O}'];
+const OWL_GEMS = ['◇', '◈', '◆', '★'];
+
+function buildOwlFrame(frameIdx, statusText) {
+  const eyes = OWL_EYES[frameIdx % OWL_EYES.length];
+  const gem = OWL_GEMS[frameIdx % OWL_GEMS.length];
+  const label = statusText || 'provisioning...';
+  const drift = (frameIdx % 4) * 2;
+  const pad = ' '.repeat(drift);
+  return [
     '',
-    "        ,___,",
-    '        {O,O}  ★ found it!',
-    '        /)__)',
-    '        -"-"-  ★ ★ ★',
+    `        ,___,`,
+    `        ${eyes}${pad}  ${gem} ${label}`,
+    `        /)__)`,
+    `        -"-"-${pad}  ${gem} ${gem} ${gem}`,
     null,
     '',
-  ],
-];
+  ];
+}
 
 // Fish swimming back and forth through the pipeline
 const FISH_RIGHT = '><(((º>';
 const FISH_LEFT = '<º)))><';
 const PIPE_WIDTH = 36;
 
-function buildPipelineFrame(pos, goingRight, caption) {
+function buildPipelineFrame(pos, goingRight, caption, statusText) {
   const fish = goingRight ? FISH_RIGHT : FISH_LEFT;
   const lane = ' '.repeat(PIPE_WIDTH);
   const row = lane.slice(0, pos) + fish + lane.slice(pos + fish.length);
   const pipe = '═'.repeat(PIPE_WIDTH);
+  const label = statusText || '';
+  const padded = label.length < PIPE_WIDTH
+    ? ' ' + label + ' '.repeat(PIPE_WIDTH - label.length - 1)
+    : ' ' + label.slice(0, PIPE_WIDTH - 1);
   return [
     '',
     `  ${pipe}`,
     `  ${row}`,
+    `  ${padded}`,
     `  ${pipe}`,
     `  ${caption}`,
     '',
@@ -575,16 +561,17 @@ export function createAsciiAnimation(type) {
 
   // OpenSearch state
   let osFrame = 0;
+  let domainStatus = '';
 
   const getWord = createWordRotator();
 
   function getFrame() {
     const word = getWord();
     if (isOpenSearch) {
-      return OPENSEARCH_FRAMES[(osFrame++) % OPENSEARCH_FRAMES.length]
+      return buildOwlFrame(osFrame++, domainStatus)
         .map((l) => l === null ? `      ${word}` : l);
     }
-    const frame = buildPipelineFrame(fishPos, goingRight, word);
+    const frame = buildPipelineFrame(fishPos, goingRight, word, domainStatus);
     if (goingRight) { fishPos++; if (fishPos >= maxPos) goingRight = false; }
     else { fishPos--; if (fishPos <= 0) goingRight = true; }
     return frame;
@@ -624,6 +611,8 @@ export function createAsciiAnimation(type) {
     },
     /** Update the status text shown below the art */
     setStatus(fn) { statusFn = fn; },
+    /** Update the domain status label shown next to the owl */
+    setDomainStatus(text) { domainStatus = text; },
     stop() { cleanup(); },
   };
 }