Fix parsing compute envs for ocean-node system tests.

.github/workflows/ci.yml

@@ -85,6 +85,7 @@ jobs:
       - name: Run Barge
         working-directory: ${{ github.workspace }}/barge
         run: |
+          export NODE_VERSION=pr-950
           bash -x start_ocean.sh --with-typesense 2>&1 > start_ocean.log &
       - run: npm ci
       - run: npm run build

metadata/simpleComputeDataset.json

@@ -42,8 +42,8 @@
       "compute": {
         "allowRawAlgorithm": false,
         "allowNetworkAccess": true,
-        "publisherTrustedAlgorithmPublishers": [],
-        "publisherTrustedAlgorithms": []
+        "publisherTrustedAlgorithmPublishers": ["*"],
+        "publisherTrustedAlgorithms": ["*"]
       }
     }
   ],

package.json

@@ -46,8 +46,8 @@
   "dependencies": {
     "@oasisprotocol/sapphire-paratime": "^1.3.2",
     "@oceanprotocol/contracts": "^2.3.1",
-    "@oceanprotocol/ddo-js": "^0.0.8",
-    "@oceanprotocol/lib": "^4.1.3",
+    "@oceanprotocol/ddo-js": "^0.1.0",
+    "@oceanprotocol/lib": "^4.1.4",
     "commander": "^13.1.0",
     "cross-fetch": "^3.1.5",
     "crypto-js": "^4.1.1",

src/cli.ts

@@ -225,6 +225,10 @@ export async function createCLI() {
 
       const proceed = options.accept;
       if (!proceed) {
+        if (!process.stdin.isTTY) {
+          console.error(chalk.red('Cannot prompt for confirmation (non-TTY). Use "--accept true" to skip.'));
+          process.exit(1);
+        }
         const rl = createInterface({ input, output });
         const confirmation = await rl.question(`\nProceed with payment for starting compute job at price ${amount} in tokens from address ${initResp.payment.token}? (y/n): `);
         rl.close();

test/consumeFlow.test.ts

@@ -57,7 +57,7 @@ describe("Ocean CLI Publishing", function() {
 		const jsonMatch = output.match(/did:op:[a-f0-9]{64}/);
         if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find did in the output");
 		}
 
 		try {
@@ -81,7 +81,7 @@ describe("Ocean CLI Publishing", function() {
 		const jsonMatch = output.match(/did:op:[a-f0-9]{64}/);
         if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find did in the output");
 		}
 
 		try {
@@ -104,7 +104,7 @@ describe("Ocean CLI Publishing", function() {
         const jsonMatch = output.match(/did:op:[a-f0-9]{64}/);
         if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find did in the output");
 		}
 
 		try {
@@ -127,7 +127,7 @@ describe("Ocean CLI Publishing", function() {
         const jsonMatch = output.match(/did:op:[a-f0-9]{64}/);
         if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find did in the output");
 		}
 
 		try {
@@ -145,7 +145,7 @@ describe("Ocean CLI Publishing", function() {
 		const jsonMatch = output.match(/s*([\s\S]*)/);
 		if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find ddo in the output");
 		}
 
         try {
@@ -162,7 +162,7 @@ describe("Ocean CLI Publishing", function() {
 		const jsonMatch = output.match(/s*([\s\S]*)/);
 		if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find ddo in the output");
 		}
 
         try {
@@ -179,7 +179,7 @@ describe("Ocean CLI Publishing", function() {
 		const jsonMatch = output.match(/s*([\s\S]*)/);
 		if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find ddo in the output");
 		}
 
         try {
@@ -196,7 +196,7 @@ describe("Ocean CLI Publishing", function() {
 		const jsonMatch = output.match(/s*([\s\S]*)/);
 		if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find ddo in the output");
 		}
 
         try {

test/paidComputeFlow.test.ts

@@ -15,7 +15,7 @@
     let computeDatasetDid: string;
     let jsAlgoDid: string;
     let computeEnvId: string;
     let resources: any;
     let computeJobId: string;
     let agreementId: string;
 
@@ -89,7 +89,7 @@
 		const jsonMatch = output.match(/s*([\s\S]*)/);
 		if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find ddo in the output");
 		}
 
         try {
@@ -106,7 +106,7 @@
 		const jsonMatch = output.match(/s*([\s\S]*)/);
 		if (!jsonMatch) {
 			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
+			throw new Error("Could not find ddo in the output");
 		}
 
         try {
@@ -125,18 +125,12 @@
 			console.error("Raw output:", output);
 			throw new Error("Could not find compute environments in the output");
 		}
-        const match = jsonMatch[0].match(/Exiting compute environments:\s*(.*)/s);
-        const result = match ? match[1].trim() : null;
-        if (!result) {
-			console.error("Raw output:", output);
-			throw new Error("Could not find compute environments in the output");
-		}
-
+
 		let environments;
 		try {
-			environments = eval(result);
+			environments = eval(jsonMatch[1]);
 		} catch (error) {
-			console.error(`Extracted output: ${jsonMatch[0]} and final result: ${result}`);
+			console.error(`Extracted output: ${jsonMatch[0]} and final result: ${jsonMatch[1]}`);
 			throw new Error("Failed to parse the extracted output:\n" + error);
 		}