GDC draft

src/connection.js

@@ -8,7 +8,7 @@ const AuthProvider = require('./authprovider');
 const BasicProvider = require('./basicprovider');
 const OidcProvider = require('./oidcprovider');
 
-const Capabilities = require('./capabilities');
+const { GdcCapabilities, Migrate } = require('./gdc');
 const FileTypes = require('./filetypes');
 const UserFile = require('./userfile');
 const Job = require('./job');
@@ -18,6 +18,7 @@ const Service = require('./service');
 const Builder = require('./builder/builder');
 const BuilderNode = require('./builder/node');
 
+
 const CONFORMANCE_RELS = [
  'conformance',
  'http://www.opengis.net/def/rel/ogc/1.0/conformance'
@@ -120,7 +121,8 @@ class Connection {
  }
  }
 
- this.capabilitiesObject = new Capabilities(data);
+ Migrate.connection = this;
+ this.capabilitiesObject = new GdcCapabilities(data);
  return this.capabilitiesObject;
  }
 
@@ -802,6 +804,37 @@ class Connection {
  return await pg.describeUserProcess();
  }
 
+ isOgcProcess(process) {
+ let nodes = Object.values(process.process_graph);
+ return Boolean(nodes.find(node => {
+ let process = this.processes.get(node.process_id);
+ return Utils.isObject(process) && Boolean(process.ogcapi);
+ }));
+ }
+
+ async executeOgcProcess(process, abortController = null) {
+ let openEO = this._normalizeUserProcess(process)
+ let p = Object.values(openEO.process.process_graph).find(v => {
+ let spec = this.processes.get(v.process_id);
+ return Boolean(spec && spec.ogcapi);
+ });
+ let requestBody = Migrate.execute(openEO);
+ console.log(p.process_id, requestBody); // @todo remove
+ let response = await this._post(`/processes/${p.process_id}/execution`, requestBody, Environment.getResponseType(), abortController);
+ let syncResult = {
+ data: response.data,
+ costs: null,
+ type: null,
+ logs: []
+ };
+
+ if (typeof response.headers['content-type'] === 'string') {
+ syncResult.type = response.headers['content-type'];
+ }
+
+ return syncResult;
+ }
+
  /**
  * Executes a process synchronously and returns the result as the response.
  * 
@@ -822,6 +855,9 @@ class Connection {
  budget: budget
  }
  );
+ if (this.isOgcProcess(requestBody.process)) {
+ return this.executeOgcProcess(process, abortController);
+ }
  let response = await this._post('/result', requestBody, Environment.getResponseType(), abortController);
  let syncResult = {
  data: response.data,