Renamed files http consumer, provider and http file consumer

assemblee-virtuelle · Dec 12, 2023 · 960a206 · 960a206
1 parent 969d1c1
commit 960a206
Show file tree

Hide file tree

Showing 12 changed files with 44 additions and 38 deletions.
diff --git a/engine/services/technicalComponentDirectory.js b/engine/services/technicalComponentDirectory.js
@@ -12,7 +12,8 @@ module.exports = {
     cacheNosql: require('../workspaceComponentExecutor/cacheNosql.js'),
     gouvFrInverseGeo: require('../workspaceComponentExecutor/gouvFrInverseGeo.js'),
     restApiGet: require('../workspaceComponentExecutor/restApiGet.js'),
-    restApiPost: require('../workspaceComponentExecutor/restApiPost.js'),
+    restApiPost: require('../workspaceComponentExecutor/httpProvider.js'),
+    httpProvider: require('../workspaceComponentExecutor/httpProvider.js'),
     // xmlToObject: require('./workspaceComponentExecutor/xmlToObject.js'),
     framcalcGetCsv: require('../workspaceComponentExecutor/framcalcGetCsv.js'),
     gouvFrGeoLocaliser: require('../workspaceComponentExecutor/gouvFrGeoLocaliser.js'),
@@ -22,7 +23,8 @@ module.exports = {
     filter: require('../workspaceComponentExecutor/filter.js'),
     upload: require('../workspaceComponentExecutor/upload.js'),
     scrapper: require('../workspaceComponentExecutor/scrapper/scrapper.js'),
-    httpGet: require('../workspaceComponentExecutor/restGetFile.js'),
+    httpGet: require('../workspaceComponentExecutor/httpFileConsumer.js'),
+    httpFileConsumer: require('../workspaceComponentExecutor/httpFileConsumer.js'),
     sqlConnector: require('../workspaceComponentExecutor/sqlConnecteur.js'),
     mongoConnector: require('../workspaceComponentExecutor/MongoDB.js'),
     influxdbConnector: require('../workspaceComponentExecutor/influxdb.js'),
@@ -33,7 +35,8 @@ module.exports = {
     valueFromPath: require('../workspaceComponentExecutor/valueFromPath.js'),
     unicity: require('../workspaceComponentExecutor/unicity.js'),
     propertiesMatrix: require('../workspaceComponentExecutor/propertiesMatrix.js'),
-    postConsumer: require('../workspaceComponentExecutor/postConsumer.js'),
+    postConsumer: require('../workspaceComponentExecutor/httpConsumer.js'),
+    httpConsumer: require('../workspaceComponentExecutor/httpConsumer.js'),
     keyToArray: require('../workspaceComponentExecutor/keyToArray.js'),
     sftpConsumer: require('../workspaceComponentExecutor/sftpConsumer.js'),
     flat: require('../workspaceComponentExecutor/flat.js'),

diff --git a/...orkspaceComponentExecutor/postConsumer.js → ...orkspaceComponentExecutor/httpConsumer.js b/...orkspaceComponentExecutor/postConsumer.js → ...orkspaceComponentExecutor/httpConsumer.js
@@ -4,7 +4,7 @@ const fs = require('fs');
 const https = require('https');
 const fileLib = require('../../core/lib/file_lib.js')
 
-class PostConsumer {
+class HttpConsumer {
   constructor () {
     this.fetch = require('node-fetch');
     this.stringReplacer = require('../utils/stringReplacer.js');
@@ -298,4 +298,4 @@ class PostConsumer {
   }
 }
 
-module.exports = new PostConsumer()
+module.exports = new HttpConsumer()
diff --git a/...workspaceComponentExecutor/restGetFile.js → ...paceComponentExecutor/httpFileConsumer.js b/...workspaceComponentExecutor/restGetFile.js → ...paceComponentExecutor/httpFileConsumer.js
@@ -1,5 +1,5 @@
 'use strict';
-class HttpGet {
+class HttpFileConsumer {
   constructor () {
     this.url = require('url')
     this.http = require('http')
@@ -68,4 +68,4 @@ class HttpGet {
     return this.makeRequest('GET', data.specificData.url, data.specificData.contentType,flowdata, pullParams)
   }
 }
-module.exports = new HttpGet()
+module.exports = new HttpFileConsumer()
diff --git a/...workspaceComponentExecutor/restApiPost.js → ...orkspaceComponentExecutor/httpProvider.js b/...workspaceComponentExecutor/restApiPost.js → ...orkspaceComponentExecutor/httpProvider.js
@@ -1,8 +1,8 @@
 'use strict'
-class RestApiPost {
+class HttpProvider {
   constructor () {
     this.stepNode = false
-    this.workspace_component_lib = require('../../core/lib/workspace_component_lib')
+    this.workspace_component_lib = require('../../core/lib/workspace_component_lib.js')
     this.data2xml = require('data2xml')
     this.dataTraitment = require('../../core/dataTraitmentLibrary/index.js')
     this.json2yaml = require('json2yaml')
@@ -22,4 +22,4 @@ class RestApiPost {
   }
 }
 
-module.exports = new RestApiPost()
+module.exports = new HttpProvider()
diff --git a/main/client/static/application.html b/main/client/static/application.html
@@ -111,7 +111,7 @@
   <script type="riot/tag" src="tag/editorComponents/dataFlow/framacalc-get-csv-editor.tag"></script>
   <script type="riot/tag" src="tag/editorComponents/dataFlow/google-get-json-editor.tag"></script>
   <script type="riot/tag" src="tag/editorComponents/dataFlow/rest-api-post-editor.tag"></script>
-  <script type="riot/tag" src="tag/editorComponents/dataFlow/post-consumer-editor.tag"></script>
+  <script type="riot/tag" src="tag/editorComponents/dataFlow/http-consumer-editor.tag"></script>
 
   <script type="riot/tag" src="tag/editorComponents/files/upload-editor.tag"></script>
   <script type="riot/tag" src="tag/editorComponents/files/rest-get-editor.tag"></script>

diff --git a/...ponents/dataFlow/post-consumer-editor.tag → ...ponents/dataFlow/http-consumer-editor.tag b/...ponents/dataFlow/post-consumer-editor.tag → ...ponents/dataFlow/http-consumer-editor.tag
@@ -1,4 +1,4 @@
-<post-consumer-editor>
+<http-consumer-editor>
   <!-- bouton aide -->
   <div class="contenaireH" style="margin-left:97%">
     <a href="https://github.com/assemblee-virtuelle/Semantic-Bus/wiki/Composant:-HTTP-Consumer" target="_blank"><img src="./image/help.png" alt="Aide" width="25px" height="25px"></a>
@@ -165,4 +165,4 @@
     display: none;
   }
   </style>
-</post-consumer-editor>
+</http-consumer-editor>
diff --git a/...ponents/dataFlow/rest-api-post-editor.tag → ...ponents/dataFlow/http-provider-editor.tag b/...ponents/dataFlow/rest-api-post-editor.tag → ...ponents/dataFlow/http-provider-editor.tag
@@ -1,4 +1,4 @@
-<rest-api-post-editor>
+<http-provider-editor>
   <!-- bouton aide -->
   <div class="contenaireH" style="margin-left:97%">
     <a href="https://github.com/assemblee-virtuelle/Semantic-Bus/wiki/Composant:-HTTP-Provider" target="_blank"><img src="./image/help.png" alt="Aide" width="25px" height="25px"></a>
@@ -131,4 +131,4 @@
       color:rgb(180,180,180);
     }
   </style>
-</rest-api-post-editor>
+</http-provider-editor>
diff --git a/...ditorComponents/files/rest-get-editor.tag → ...nents/files/http-file-consumer-editor.tag b/...ditorComponents/files/rest-get-editor.tag → ...nents/files/http-file-consumer-editor.tag
@@ -1,4 +1,4 @@
-<rest-get-editor>
+<http-file-consumer-editor>
   <!-- bouton aide -->
   <div class="containerH" style="margin-left:97%">
     <a href="https://github.com/assemblee-virtuelle/Semantic-Bus/wiki/Composant:-File-consumer" target="_blank"><img src="./image/help.png" alt="Aide" width="25px" height="25px"></a>

diff --git a/main/server/services/technicalComponentDirectory.js b/main/server/services/technicalComponentDirectory.js
@@ -12,7 +12,8 @@ module.exports = {
   cacheNosql: require('../workspaceComponentInitialize/cacheNosql.js'),
   gouvFrInverseGeo: require('../workspaceComponentInitialize/gouvFrInverseGeo.js'),
   restApiGet: require('../workspaceComponentInitialize/restApiGet.js'),
-  restApiPost: require('../workspaceComponentInitialize/restApiPost.js'),
+  restApiPost: require('../workspaceComponentInitialize/httpProvider.js'),
+  httpProvider: require('../workspaceComponentInitialize/httpProvider.js'),
   // xmlToObject: require('./workspaceComponentInitialize/xmlToObject.js'),
   framcalcGetCsv: require('../workspaceComponentInitialize/framcalcGetCsv.js'),
   gouvFrGeoLocaliser: require('../workspaceComponentInitialize/gouvFrGeoLocaliser.js'),
@@ -22,7 +23,8 @@ module.exports = {
   filter: require('../workspaceComponentInitialize/filter.js'),
   upload: require('../workspaceComponentInitialize/upload.js'),
   scrapper: require('../workspaceComponentInitialize/scrapper.js'),
-  httpGet: require('../workspaceComponentInitialize/restGetFile.js'),
+  httpGet: require('../workspaceComponentInitialize/httpFileConsumer.js'),
+  httpFileConsumer: require('../workspaceComponentInitialize/httpFileConsumer.js'),
   sqlConnector: require('../workspaceComponentInitialize/sqlConnecteur.js'),
   mongoConnector: require('../workspaceComponentInitialize/MongoDB.js'),
   influxdbConnector: require('../workspaceComponentInitialize/influxdb.js'),
@@ -33,7 +35,8 @@ module.exports = {
   valueFromPath: require('../workspaceComponentInitialize/valueFromPath.js'),
   unicity: require('../workspaceComponentInitialize/unicity.js'),
   propertiesMatrix: require('../workspaceComponentInitialize/propertiesMatrix.js'),
-  postConsumer: require('../workspaceComponentInitialize/postConsumer.js'),
+  postConsumer: require('../workspaceComponentInitialize/httpConsumer.js'),
+  httpConsumer: require('../workspaceComponentInitialize/httpConsumer.js'),
   keyToArray: require('../workspaceComponentInitialize/keyToArray.js'),
   sftpConsumer: require('../workspaceComponentInitialize/sftpConsumer.js'),
   flat: require('../workspaceComponentInitialize/flat.js'),
@@ -64,17 +67,17 @@ module.exports = {
     return directory
   },
 
-  initialise: function (router, unSafeRouteur,engineTracer) {
+  initialise: function (router, unSafeRouteur, engineTracer) {
     // console.log('initialise')
-    this.restApiPost.initialise(unSafeRouteur,engineTracer) // NO SECURE CHANGE ROUTER
-    this.restApiGet.initialise(unSafeRouteur,engineTracer) // NO SECURE CHANGE ROUTER
-    this.upload.initialise(router,engineTracer)
-    this.cacheNosql.initialise(router,engineTracer) // NO SECURE CHANGE ROUTER
+    this.httpProvider.initialise(unSafeRouteur, engineTracer) // NO SECURE CHANGE ROUTER
+    this.restApiGet.initialise(unSafeRouteur, engineTracer) // NO SECURE CHANGE ROUTER
+    this.upload.initialise(router, engineTracer)
+    this.cacheNosql.initialise(router, engineTracer) // NO SECURE CHANGE ROUTER
   },
 
-  setAmqp : function (channel){
+  setAmqp: function (channel) {
     // console.log('setAmqp')
-    this.restApiPost.setAmqp(channel);
+    this.httpProvider.setAmqp(channel)
     this.upload.setAmqp(channel)
   }
 }
diff --git a/...kspaceComponentInitialize/postConsumer.js → ...kspaceComponentInitialize/httpConsumer.js b/...kspaceComponentInitialize/postConsumer.js → ...kspaceComponentInitialize/httpConsumer.js
@@ -1,9 +1,9 @@
 'use strict';
-class PostConsumer {
+class HttpConsumer {
   constructor () {
     this.type = 'HTTP consumer'
     this.description = 'Appeler une API HTTP; Executer une requête HTTP.'
-    this.editor = 'post-consumer-editor'
+    this.editor = 'http-consumer-editor'
     this.graphIcon = 'Post_consumer.svg'
     this.tags = [
       'http://semantic-bus.org/data/tags/outComponents',
@@ -13,4 +13,4 @@ class PostConsumer {
   }
 }
 
-module.exports = new PostConsumer()
+module.exports = new HttpConsumer()
diff --git a/...rkspaceComponentInitialize/restGetFile.js → ...ceComponentInitialize/httpFileConsumer.js b/...rkspaceComponentInitialize/restGetFile.js → ...ceComponentInitialize/httpFileConsumer.js
@@ -1,14 +1,14 @@
 'use strict';
-class HttpGet {
+class HttpFileConsumer {
   constructor () {
-    this.type = 'File consumer'
+    this.type = 'HTTP File Consumer'
     this.description = 'Interroger un fichier mis à disposition sur une API REST avec une requete GET.'
-    this.editor = 'rest-get-editor'
+    this.editor = 'http-file-consumer-editor'
     this.graphIcon = 'File_consumer.svg'
     this.tags = [
       'http://semantic-bus.org/data/tags/inComponents',
       'http://semantic-bus.org/data/tags/fileComponents'
     ]
   }
 }
-module.exports = new HttpGet()
+module.exports = new HttpFileConsumer()
diff --git a/...rkspaceComponentInitialize/restApiPost.js → ...kspaceComponentInitialize/httpProvider.js b/...rkspaceComponentInitialize/restApiPost.js → ...kspaceComponentInitialize/httpProvider.js
@@ -2,7 +2,7 @@
 
 const { v4: uuidv4 } = require('uuid');
 const MODE = 'AMQP' // MODE could be AMQP when all workflow will migrate over V1
-class RestApiPost {
+class HttpProvider {
   constructor() {
     this.type = 'HTTP provider'
     this.description = `Mettre à disposition une API HTTP; Permettre à votre workflow d'être appelé par une requete HTTP.`
@@ -14,9 +14,9 @@ class RestApiPost {
         'http://semantic-bus.org/data/tags/APIComponents'
       ],
       this.stepNode = false
-    this.workspace_component_lib = require('../../../core/lib/workspace_component_lib')
-    this.workspace_lib = require('../../../core/lib/workspace_lib')
-    this.fragment_lib = require('../../../core/lib/fragment_lib')
+    this.workspace_component_lib = require('../../../core/lib/workspace_component_lib.js')
+    this.workspace_lib = require('../../../core/lib/workspace_lib.js')
+    this.fragment_lib = require('../../../core/lib/fragment_lib.js')
     this.data2xml = require('data2xml');
     this.xmlJS = require('xml-js');
     this.dataTraitment = require('../../../core/dataTraitmentLibrary/index.js')
@@ -294,4 +294,4 @@ class RestApiPost {
   }
 }
 
-module.exports = new RestApiPost()
+module.exports = new HttpProvider()