Merge pull request #113 from DeterminateSystems/update-detsys-ts-status-page

Update detsys-ts (status page changes)

Author: lucperkins

dist/index.js

@@ -93735,7 +93735,7 @@ const external_node_path_namespaceObject = __WEBPACK_EXTERNAL_createRequire(impo
 const external_node_stream_promises_namespaceObject = __WEBPACK_EXTERNAL_createRequire(import.meta.url)("node:stream/promises");
 ;// CONCATENATED MODULE: external "node:zlib"
 const external_node_zlib_namespaceObject = __WEBPACK_EXTERNAL_createRequire(import.meta.url)("node:zlib");
-;// CONCATENATED MODULE: ./node_modules/.pnpm/github.com+DeterminateSystems+detsys-ts@9d66d2c89c150f796165fdcc20b3be538807c0f4_46ybmzqhaua4eiwu3nj2qm63te/node_modules/detsys-ts/dist/index.js
+;// CONCATENATED MODULE: ./node_modules/.pnpm/github.com+DeterminateSystems+detsys-ts@fe64ba33b4bdeec0991bb65ae00420bf68b9954c_ler7zqcm5mrt635umsvjcuxcmy/node_modules/detsys-ts/dist/index.js
 var __defProp = Object.defineProperty;
 var __export = (target, all) => {
   for (var name in all)
@@ -94072,7 +94072,7 @@ var IdsHost = class {
   setPrioritizedUrls(urls) {
     this.prioritizedURLs = urls;
   }
-  async getRootUrl() {
+  async getDynamicRootUrl() {
     const idsHost = process.env["IDS_HOST"];
     if (idsHost !== void 0) {
       try {
@@ -94093,9 +94093,17 @@ var IdsHost = class {
       );
     }
     if (url === void 0) {
-      url = new URL(DEFAULT_IDS_HOST);
+      return void 0;
+    } else {
+      return new URL(url);
     }
-    return new URL(url);
+  }
+  async getRootUrl() {
+    const url = await this.getDynamicRootUrl();
+    if (url === void 0) {
+      return new URL(DEFAULT_IDS_HOST);
+    }
+    return url;
   }
   async getDiagnosticsUrl() {
     if (this.runtimeDiagnosticsUrl === "") {
@@ -94406,6 +94414,7 @@ var STATE_KEY_EXECUTION_PHASE = "detsys_action_execution_phase";
 var STATE_KEY_NIX_NOT_FOUND = "detsys_action_nix_not_found";
 var STATE_NOT_FOUND = "not-found";
 var DIAGNOSTIC_ENDPOINT_TIMEOUT_MS = 3e4;
+var CHECK_IN_ENDPOINT_TIMEOUT_MS = 5e3;
 var DetSysAction = class {
   determineExecutionPhase() {
     const currentPhase = core.getState(STATE_KEY_EXECUTION_PHASE);
@@ -94428,6 +94437,8 @@ var DetSysAction = class {
     this.exceptionAttachments = /* @__PURE__ */ new Map();
     this.nixStoreTrust = "unknown";
     this.strictMode = getBool("_internal-strict-mode");
+    this.features = {};
+    this.featureEventMetadata = /* @__PURE__ */ new Map();
     this.events = [];
     this.client = got_dist_source.extend({
       retry: {
@@ -94537,11 +94548,13 @@ var DetSysAction = class {
     return this.identity;
   }
   recordEvent(eventName, context = {}) {
+    const prefixedName = eventName === "$feature_flag_called" ? eventName : `${this.actionOptions.eventPrefix}${eventName}`;
     this.events.push({
-      event_name: `${this.actionOptions.eventPrefix}${eventName}`,
+      event_name: prefixedName,
       context,
       correlation: this.identity,
       facts: this.facts,
+      features: this.featureEventMetadata,
       timestamp: /* @__PURE__ */ new Date(),
       uuid: (0,external_node_crypto_namespaceObject.randomUUID)()
     });
@@ -94577,6 +94590,7 @@ var DetSysAction = class {
   }
   async executeAsync() {
     try {
+      await this.checkIn();
       process.env.DETSYS_CORRELATION = JSON.stringify(
         this.getCorrelationHashes()
       );
@@ -94624,6 +94638,94 @@ var DetSysAction = class {
       await this.complete();
     }
   }
+  async checkIn() {
+    const checkin = await this.requestCheckIn();
+    if (checkin === void 0) {
+      return;
+    }
+    this.features = checkin.options;
+    for (const [key, feature] of Object.entries(this.features)) {
+      this.featureEventMetadata.set(key, feature.variant);
+    }
+    const impactSymbol = /* @__PURE__ */ new Map([
+      ["none", "\u26AA"],
+      ["maintenance", "\u{1F6E0}\uFE0F"],
+      ["minor", "\u{1F7E1}"],
+      ["major", "\u{1F7E0}"],
+      ["critical", "\u{1F534}"]
+    ]);
+    const defaultImpactSymbol = "\u{1F535}";
+    if (checkin.status !== null) {
+      const summaries = [];
+      for (const incident of checkin.status.incidents) {
+        summaries.push(
+          `${impactSymbol.get(incident.impact) || defaultImpactSymbol} ${incident.status.replace("_", " ")}: ${incident.name} (${incident.shortlink})`
+        );
+      }
+      for (const maintenance of checkin.status.scheduled_maintenances) {
+        summaries.push(
+          `${impactSymbol.get(maintenance.impact) || defaultImpactSymbol} ${maintenance.status.replace("_", " ")}: ${maintenance.name} (${maintenance.shortlink})`
+        );
+      }
+      if (summaries.length > 0) {
+        core.info(
+          // Bright red, Bold, Underline
+          `${"\x1B[0;31m"}${"\x1B[1m"}${"\x1B[4m"}${checkin.status.page.name} Status`
+        );
+        for (const notice of summaries) {
+          core.info(notice);
+        }
+        core.info(`See: ${checkin.status.page.url}`);
+        core.info(``);
+      }
+    }
+  }
+  getFeature(name) {
+    if (!this.features.hasOwnProperty(name)) {
+      return void 0;
+    }
+    const result = this.features[name];
+    if (result === void 0) {
+      return void 0;
+    }
+    this.recordEvent("$feature_flag_called", {
+      $feature_flag: name,
+      $feature_flag_response: result.variant
+    });
+    return result;
+  }
+  /**
+   * Check in to install.determinate.systems, to accomplish three things:
+   *
+   * 1. Preflight the server selected from IdsHost, to increase the chances of success.
+   * 2. Fetch any incidents and maintenance events to let users know in case things are weird.
+   * 3. Get feature flag data so we can gently roll out new features.
+   */
+  async requestCheckIn() {
+    for (let attemptsRemaining = 5; attemptsRemaining > 0; attemptsRemaining--) {
+      const checkInUrl = await this.getCheckInUrl();
+      if (checkInUrl === void 0) {
+        return void 0;
+      }
+      try {
+        core.debug(`Preflighting via ${checkInUrl}`);
+        checkInUrl.searchParams.set("ci", "github");
+        checkInUrl.searchParams.set(
+          "correlation",
+          JSON.stringify(this.identity)
+        );
+        return await this.client.get(checkInUrl, {
+          timeout: {
+            request: CHECK_IN_ENDPOINT_TIMEOUT_MS
+          }
+        }).json();
+      } catch (e) {
+        core.debug(`Error checking in: ${stringifyError2(e)}`);
+        this.idsHost.markCurrentHostBroken();
+      }
+    }
+    return void 0;
+  }
   /**
    * Fetch an artifact, such as a tarball, from the location determined by the
    * `source-*` inputs. If `source-binary` is specified, this will return a path
@@ -94701,6 +94803,14 @@ var DetSysAction = class {
     this.recordEvent(`complete_${this.executionPhase}`);
     await this.submitEvents();
   }
+  async getCheckInUrl() {
+    const checkInUrl = await this.idsHost.getDynamicRootUrl();
+    if (checkInUrl === void 0) {
+      return void 0;
+    }
+    checkInUrl.pathname += "check-in";
+    return checkInUrl;
+  }
   async getSourceUrl() {
     const p = this.sourceParameters;
     if (p.url) {