Edit mongodb provider

.gitignore

@@ -11,3 +11,4 @@ il.json
 test1.db
 report.json
 cache
+cachefiles

ExternalCommands/external.fly.ws.js

@@ -0,0 +1,32 @@
+import SourceCommand from "./../renderEngine/Command/Source/BaseClasses/SourceCommand.js";
+import ICommandResult from "./../renderEngine/Models/ICommandResult.js";
+export default class FlyCommand extends SourceCommand {
+  /**
+   * @param {object} flyIl
+   */
+  constructor(flyIl) {
+    super(flyIl);
+  }
+
+  /**
+   * @param {string} sourceName
+   * @param {IContext} context
+   * @returns {Promise<ICommandResult>}
+   */
+  async _loadDataAsync(sourceName, context) {
+    const [connectionName, command] = await Promise.all([
+      this.connectionName.getValueAsync(context),
+      this.toCustomFormatHtmlAsync(context),
+    ]);
+    const inputs = {
+      command,
+      dmnid: context.domainId,
+    };
+    const encoder = new TextEncoder();
+    const byteMessage = encoder.encode(JSON.stringify(inputs));
+    const parameters = {
+      byteMessage,
+    };
+    return await context.loadDataAsync(sourceName, connectionName, parameters);
+  }
+}

Models/Connection/ConnectionInfo.js

@@ -59,6 +59,7 @@ export default class ConnectionInfo {
   convertJSONToDataSet(content) {
     if (content?.sources && Array.isArray(content?.sources)) {
       let retVal = [];
+
       content.sources.forEach((source) => {
         retVal.push(source.data);
       });

Models/Connection/ConnectionUtil.js

@@ -8,6 +8,7 @@ import MongoConnectionInfo from "./MongoConnectionInfo.js";
 import SqliteConnectionInfo from "./SqLiteConnectionInfo.js";
 import MySqlConnectionInfo from "./MySqlConnectionInfo.js";
 import SocketConnectionInfo from "./SocketConnectionInfo.js";
+import WebConnectionInfo from "./WebConnectionInfo.js";
 export default class ConnectionUtil {
   /**
    * @param {NodeJS.Dict<any>} settings
@@ -54,6 +55,9 @@ export default class ConnectionUtil {
             connection = new SocketConnectionInfo(parts[2], settings[item]);
             break;
           }
+          case "web" : {
+            connection = new WebConnectionInfo(parts[2],settings[item])
+          }
           default: {
             if (parts[1] == "ws") {
               continue;

Models/Connection/IMongoSettingData.js

@@ -1,12 +1,12 @@
 export default class IMongoSettingData {
-  /** @type {string} */
-  dataBase;
   /** @type {string}*/
-  endpoint;
-  /** @type {string}*/
-  collection;
-  /** @type {string}*/
-  method;
-  /**@type {object} */
-  query;
+  address;
+  /** @type {?string}*/
+  databaseName;
+  /** @type {?string}*/
+  collectionName;
+    /** @type {string}*/
+    method;
+    /**@type {object} */
+    query;
 }

Models/Connection/MongoConnectionInfo.js

@@ -5,11 +5,13 @@ import CancellationToken from "../../renderEngine/Cancellation/CancellationToken
 import Request from "./../request.js";
 import IMongoSettingData from "./IMongoSettingData.js";
 import BasisCoreException from "../Exceptions/BasisCoreException.js";
+import IRoutingRequest from "../IRoutingRequest.js";
+import { http } from "winston";
 export default class MongoConnectionInfo extends ConnectionInfo {
+  /**@type {MongoClient}  */
+  client;
   /** @type {IMongoSettingData} */
   settings;
-  /**@param {MongoClient} client */
-  client;
 
   /**
    * @param {string} name
@@ -18,8 +20,8 @@ export default class MongoConnectionInfo extends ConnectionInfo {
    */
   constructor(name, settings) {
     super(name);
+    this.client = new MongoClient(settings.address);
     this.settings = settings;
-    this.client = new MongoClient(this.settings.endpoint);
   }
 
   /**
@@ -30,34 +32,69 @@ export default class MongoConnectionInfo extends ConnectionInfo {
   async loadDataAsync(parameters, cancellationToken) {
     try {
       await this.client.connect();
-      const db = this.client.db(this.settings.dataBase);
-      const collection = db.collection(this.settings.collection);
+      const { collectionName, dbname } = parameters;
+      const db = this.client.db(dbname);
+      const collection = db.collection(collectionName);
       if (typeof collection[this.settings.method] != "function") {
         throw new BasisCoreException("invalid method");
       }
-      const result = await collection[this.settings.method](this.settings.query)
+      const result = await collection[this.settings.method](
+        this.settings.query
+      );
       return new DataSourceCollection([await result.toArray()]);
     } catch (err) {
       throw err;
-   }
-    finally {
-    await this.client.close();
+    } finally {
+      await this.client.close();
     }
   }
+  /**
+   * Insert a document into a MongoDB collection.
+   * @param {string} sourceName
+   * @param {string} connectionName
+   * @param {string} databaseName
+   * @param {string} collectionName
+   * @param {Object} data
+   * @returns {Promise<Object>}
+   */
+  async insertAsync(
+    sourceName,
+    connectionName,
+    databaseName,
+    collectionName,
+    data
+  ) {
+    try {
+      if (!databaseName) {
+        databaseName = this.settings.databaseName;
+      }
+      await this.client.connect();
 
+      const database = client.db(databaseName);
+      const collection = database.collection(collectionName);
+
+      const result = await collection.insertOne(data);
+      await client.close();
+      return result._id;
+    } catch (error) {
+      throw new Error(
+        `Error in loading data for '${sourceName}' source command from '${connectionName}' connection: ${error.message}`
+      );
+    }
+  }
   /**
    * @param {Request} request
    * @param {BinaryContent[]} fileContents
    * @returns {Promise<Response>}
    */
   async testConnectionAsync() {
-    try{
-      await this.client.connect()
-      return true
-    }catch(err){
-      return false
-    }finally{
-      await this.client.close()
+    try {
+      await this.client.connect();
+      return true;
+    } catch (err) {
+      return false;
+    } finally {
+      await this.client.close();
     }
   }
 }

Models/Connection/SqlConnectionInfo.js

@@ -26,10 +26,9 @@ export default class SqlConnectionInfo extends ConnectionInfo {
           ? `;requestTimeout=${this.settings.requestTimeout}`
           : "")
     );
-    this.connectionPool.connect().catch((err)=>{
-      console.log("error in connect",this.name,err)
-    })
-
+    this.connectionPool.connect().catch((err) => {
+      console.log("error in connect", this.name, err);
+    });
   }
 
   /**
@@ -70,9 +69,9 @@ export default class SqlConnectionInfo extends ConnectionInfo {
    */
   async getRoutingDataAsync(request, cancellationToken) {
     const params = new sql.Table();
-    params.columns.add("ParamType", sql.NVarChar(50));  
-    params.columns.add("ParamName", sql.NVarChar(100)); 
-    params.columns.add("ParamValue", sql.NVarChar());   
+    params.columns.add("ParamType", sql.NVarChar(50));
+    params.columns.add("ParamName", sql.NVarChar(100));
+    params.columns.add("ParamValue", sql.NVarChar());
 
     for (const type in request) {
       const group = request[type];
@@ -82,9 +81,9 @@ export default class SqlConnectionInfo extends ConnectionInfo {
           for (const key in query) {
             params.rows.add(name, key, query[key]?.toString());
           }
-        } else if(name === "json"){
+        } else if (name === "json") {
           params.rows.add(type, name, JSON.stringify(group[name]));
-        }else {
+        } else {
           params.rows.add(type, name, group[name]?.toString());
         }
       }

Models/Connection/WebConnectionInfo.js

@@ -0,0 +1,41 @@
+import WebSettingData from "./WebSettingData.js";
+import ConnectionInfo from "./ConnectionInfo.js";
+import DataSourceCollection from "../../renderEngine/Source/DataSourceCollection.js";
+import CancellationToken from "../../renderEngine/Cancellation/CancellationToken.js";
+import BasisCoreException from "../Exceptions/BasisCoreException.js";
+
+export default class WebConnectionInfo extends ConnectionInfo {
+  /** @type {string} */
+  url;
+  /**
+   * @param {string} name
+   * @param {WebSettingData} settings
+   */
+  constructor(name, settings) {
+    super(name);
+    this.url = settings.url;
+  }
+
+  /**
+   * @param {NodeJS.Dict<object|string|number>} parameters
+   * @param {CancellationToken} cancellationToken
+   * @returns {Promise<DataSourceCollection>}
+   */
+  async loadDataAsync(parameters, cancellationToken) {
+    try {
+      let body = new URLSearchParams(parameters);
+      const response = await fetch(url, {
+        method: "POST",
+        body: body,
+        headers: {
+          "Content-Type": "application/x-www-form-urlencoded",
+        },
+      });
+      return new DataSourceCollection(await response.json());
+    } catch (error) {
+      return new BasisCoreException(
+        "Failed to fetch request from url " + this.url
+      );
+    }
+  }
+}

Models/Connection/WebSettingData.js

@@ -0,0 +1,5 @@
+export default class WebSettingData {
+    /** @type {string} */
+    url;
+  }
+

Models/Index4Response.js

@@ -1,7 +1,6 @@
 import fs from "fs";
 import { StatusCodes } from "http-status-codes";
 import RequestBaseResponse from "./requestBaseResponse.js";
-import im from "imagemagick";
 import path from "path";
 import Pako from "pako";
 import Util from "../Util.js";
@@ -44,6 +43,8 @@ export default class Index4Response extends RequestBaseResponse {
         size,
         setting.deform
       );
+      const dirPath = path.dirname(destinationPath);
+      Index4Response._createDirectoryIfNotExist(dirPath)
       await fs.promises.writeFile(destinationPath, newContent);
       finalPath = destinationPath;
       if (gzip) {
@@ -157,7 +158,7 @@ static _mackWebpAsync(content, quality) {
   static _createDirectoryIfNotExist(filePath) {
     const pathDirectory = path.dirname(filePath);
     if (!fs.existsSync(pathDirectory)) {
-      fs.mkdirSync(pathDirectory);
+      fs.mkdirSync(pathDirectory,{recursive : true});
     }
   }
 

endPoint/h2HttpHostEndPoint.js

@@ -259,4 +259,4 @@ export default class H2HttpHostEndPoint extends SecureHttpHostEndPoint {
       next();
     }
   }
-}
+}

endPoint/httpHostEndPoint.js

@@ -354,4 +354,4 @@ class HttpHostEndPoint extends HostEndPoint {
     console.log(`server ip ${this._ip} and port ${this._port} killed`);
   }
 }
-export default HttpHostEndPoint;
+export default HttpHostEndPoint;

endPoint/nonSecureHttpHostEndPoint.js

@@ -90,4 +90,4 @@ export default class NonSecureHttpHostEndPoint extends HttpHostEndPoint {
     });
     return this._server;
   }
-}
+}

endPoint/secureHttpHostEndPoint.js

@@ -104,4 +104,4 @@ export default class SecureHttpHostEndPoint extends HttpHostEndPoint {
       .on("tlsClientError", (er) => console.error(er));
     return this._server;
   }
-}
+}