Fixing sync execution

Open-EO · Jan 21, 2025 · 9079011 · 9079011
1 parent 65430d0
commit 9079011
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/src/ogc/connection.js b/src/ogc/connection.js
@@ -42,9 +42,9 @@ class OgcConnection extends Connection {
 			if (Array.isArray(spec.jobControlOptions) && spec.jobControlOptions.includes("async-execute")) {
 				mode = 'async';
 			}
-			return Boolean(spec && spec.ogcapi);
+			return Boolean(spec/* && spec.ogcapi*/);
 		});
-		let requestBody = Migrate.executeSync(openEO);
+		let requestBody = Migrate.executeSync(this, openEO);
 		let headers = {};
 		if (mode === 'async') {
 			headers.Prefer = 'respond-async';

diff --git a/src/ogc/migrate.js b/src/ogc/migrate.js
@@ -161,20 +161,21 @@ class OgcMigrate {
    * Executes an OGC API process synchronously.
    * 
    * @todo Check whether implementation still works
+   * @param {Connection} connection 
    * @param {object} requestBody
    * @returns {object}
    */
-  static executeSync(requestBody) {
+  static executeSync(connection, requestBody) {
     const graph = Object.values(requestBody.process.process_graph);
     const valid = graph.every(node => {
-      let spec = OgcMigrate.connection.processes.get(node.process_id);
+      let spec = connection.processes.get(node.process_id);
       return Boolean(spec && (spec.ogcapi || spec.id === 'load_collection'));
     });
     if (!valid) {
 			throw new Error('Process must consist only of OGC Processes and Collections');
     }
 
-    const parser = new PgParser(requestBody.process, OgcMigrate.connection.getBaseUrl());
+    const parser = new PgParser(requestBody.process, connection.getBaseUrl());
     return parser.parse();
   }