Merge pull request #1 from WSPluta/wallet-debug

Wallet debug

Author: WSPluta

command_spec.yaml

@@ -31,15 +31,15 @@ steps:
     shell: bash
     timeoutInSeconds: 300
     command: |
-      cd /workspace/oci-multiplayer
+      cd /workspace/save-the-wildlife
       adb_wallet_password="$(openssl rand -base64 12)_$RANDOM"
       oci db autonomous-database generate-wallet --autonomous-database-id ${adb_id} --file "/workspace/oci-multiplayer/deploy/k8s/base/score/wallet.zip" --password "$adb_wallet_password"
   - type: Command
     name: "Custom Kustomize with versions"
     shell: bash
     timeoutInSeconds: 300
     command: |
-      cd /workspace/oci-multiplayer
+      cd /workspace/save-the-wildlife
       redis_password=$(oci secrets secret-bundle get --secret-id ${redis_password_id} --query 'data."secret-bundle-content".content' | tr -d '\"' | base64 -d)
       adb_admin_password=$(oci secrets secret-bundle get --secret-id ${adb_admin_password_id} --query 'data."secret-bundle-content".content' | tr -d '\"' | base64 -d)
       npx zx scripts/kustom.mjs ${region_key} $redis_password $adb_admin_password ${adb_service}
@@ -73,4 +73,4 @@ steps:
     timeoutInSeconds: 100
     command: |
       LB_PUBLIC_IP=$(kubectl get svc ingress-nginx-controller -n ingress-nginx --template="{{range .status.loadBalancer.ingress}}{{.ip}}{{end}}")
-      echo "http://$LB_PUBLIC_IP/"
+      echo "http://$LB_PUBLIC_IP/"

scripts/deploy.mjs

@@ -105,11 +105,15 @@ async function createDBConfigFiles(
 }
 
 async function setScoreApplicationProperties(adbName, adbPassword) {
+  const properties = await readEnvJson();
+
+  const adbDisplayName = properties.adbDisplayName;
+
   const pwdOutput = (await $`pwd`).stdout.trim();
   await cd(`${pwdOutput}/deploy/k8s/base/score`);
   try {
     let { stdout, exitCode, stderr } =
-      await $`sed s/TEMPLATE_ADB_SERVICE/${adbName.toLowerCase()}_high/ application.properties.template | sed s/TEMPLATE_ADB_PASSWORD/${adbPassword}/ > application.properties`;
+      await $`sed s/TEMPLATE_ADB_SERVICE/${adbDisplayName}/ application.properties.template | sed s/TEMPLATE_ADB_PASSWORD/${adbPassword}/ > application.properties`;
     if (exitCode !== 0) {
       exitWithError(`Error creating application.properties: ${stderr}`);
     }
@@ -130,7 +134,7 @@ async function downloadWallet(
 ) {
   const adbs = await listAdbDatabases(compartmentId);
   const adb = adbs.find(
-    (db) => db["db-name"].toLowerCase() === name.toLowerCase()
+    (db) => db["display-name"].toLowerCase() === name.toLowerCase()
   );
   await downloadAdbWallet(adb.id, walletFilePath, walletPassword);
 }

scripts/lib/oci.mjs

@@ -46,6 +46,38 @@ export async function listAdbDatabases(compartmentId) {
   }
 }
 
+export async function listAdbDatabasesbyname(adbName,compartmentId) {
+    try {
+        const { stdout, exitCode, stderr } = await $`oci db autonomous-database list --all --compartment-id ${compartmentId} --display-name ${adbName}`;
+        if (exitCode !== 0) {
+            console.error("Error:", stderr);
+            return; 
+        }
+
+        const response = JSON.parse(stdout.trim());
+        // console.log("Full API Response:", response);
+
+        const connectionStrings = response.data[0]['connection-strings'];
+
+        if (typeof connectionStrings === 'object' && connectionStrings !== null) {
+
+            // Finding the 'HIGH' consumer group in profiles array
+            const highConsumerGroupDisplayName = connectionStrings.profiles.find(profile => profile['consumer-group'] === "HIGH");
+            if (highConsumerGroupDisplayName) {
+                const adbDisplayName = highConsumerGroupDisplayName['display-name'];
+                // console.log("adbDisplayName:", adbDisplayName);
+                return adbDisplayName;
+            } else {
+                console.error("Error: No 'HIGH' consumer group found in the response.");
+            }
+        } else {
+            console.error("Error: 'connection-strings' is not an object in the response.");
+        }
+    } catch (error) {
+        console.error("Error:", error);
+    }
+}
+
 export async function downloadAdbWallet(adbId, walletFilePath, walletPassword) {
   try {
     const { stdout, exitCode, stderr } =
@@ -124,6 +156,27 @@ export async function searchCompartmentIdByName(compartmentName) {
   }
 }
 
+export async function searchAdbIdByName(adbName, compartmentId) {
+    if (!adbName) {
+      exitWithError("ADB name required");
+    }
+    try {
+      const { stdout, exitCode, stderr } =
+        await $`oci db autonomous-database list --compartment-id ${compartmentId} --query "data[?\"display-name\"=='${adbName}'].id"`;
+      if (exitCode !== 0) {
+        exitWithError(stderr);
+      }
+      const adbIds = JSON.parse(stdout.trim());
+      if (adbIds.length === 0) {
+        exitWithError("ADB name not found");
+      }
+      const adbId = adbIds[0];
+      return adbId;
+    } catch (error) {
+      exitWithError(error.stderr);
+    }
+  }
+
 export async function uploadApiKeyFile(userId, publicKeyPath) {
   if (!userId) {
     exitWithError("User ID required");

scripts/setenv.mjs

@@ -13,6 +13,7 @@ import {
   getRegions,
   getTenancyId,
   searchCompartmentIdByName,
+  listAdbDatabasesbyname,
 } from "./lib/oci.mjs";
 import { createSelfSignedCert } from "./lib/tls.mjs";
 import {
@@ -140,13 +141,19 @@ async function adbDetails() {
     "Autonomous Database password"
   );
 
+  const adbDisplayName = await listAdbDatabasesbyname(adbName, adbCompartmentId);
+
+
   properties = {
     ...properties,
     adbCompartmentId,
     adbCompartmentName,
     adbName,
     adbPassword,
+    adbDisplayName,
   };
+//   console.log("Properties:", properties);
+
 }
 
 async function printRegionNames(regions) {