Source date handler improvement

package.json

@@ -972,6 +972,11 @@
 				"title": "Upload and replace",
 				"category": "IBM i"
 			},
+			{
+				"command": "code-for-ibmi.member.newDateSearch",
+				"title": "Apply Source Date Filter",
+				"category": "IBM i"
+			},
 			{
 				"command": "code-for-ibmi.refreshIFSBrowser",
 				"title": "Refresh IFS List",
@@ -1734,6 +1739,7 @@
 		"node-ssh": "^11.1.1",
 		"source-map-support": "^0.5.21",
 		"tmp": "^0.2.1",
+		"vscode-diff": "^2.0.2",
 		"xml2js": "^0.4.23"
 	},
 	"extensionDependencies": [

src/Instance.ts

@@ -8,7 +8,7 @@ import path from 'path';
 
 const CompileTools = require(`./api/CompileTools`);
 
-import {Terminal} from './api/terminal';
+import {Terminal} from './api/Terminal';
 const Deployment = require(`./api/Deployment`);
 
 import { CustomUI, Field } from './api/CustomUI';

src/api/IBMi.ts

@@ -622,13 +622,7 @@ export default class IBMi {
   }
 
   async sendQsh(options: CommandData) {
-    let qshCommand;
-
-    if (Array.isArray(options.command)) {
-      qshCommand = options.command.join(`;`);
-    } else {
-      qshCommand = options.command;
-    }
+    const qshCommand = options.command;
 
     options.stdin = qshCommand;
 

src/api/Terminal.ts

@@ -111,7 +111,7 @@ export namespace Terminal {
             }
           },
           setDimensions: (dim: vscode.TerminalDimensions) => {
-            channel.setWindow(dim.rows, dim.columns, `500`, `500`);
+            channel.setWindow(String(dim.rows), dim.columns, `500`, `500`);
           },
         },
       });

src/filesystems/qsys/complex/content.js

@@ -9,7 +9,8 @@ const tmpFile = util.promisify(tmp.file);
 const writeFileAsync = util.promisify(fs.writeFile);
 
 const DEFAULT_RECORD_LENGTH = 80;
-let { allSourceDates, recordLengths, getAliasName } = require(`./data`);
+const Handler = require(`./handler`);
+let { baseSource, recordLengths, getAliasName, baseDates } = require(`./data`);
 
 module.exports = class IBMiContent {
   /**
@@ -39,11 +40,11 @@ module.exports = class IBMiContent {
     if (recordLengths[alias] === undefined) {
       const result = await content.runSQL(`SELECT LENGTH(srcdta) as LENGTH FROM ${aliasPath} limit 1`);
       if (result.length > 0) {
-        recordLengths[alias] = result[0].LENGTH;
+        recordLengths[alias] = Number(result[0].LENGTH);
       } else {
         const result = await content.runSQL(`SELECT row_length-12 as LENGTH FROM QSYS2.SYSTABLES WHERE TABLE_SCHEMA = '${lib}' and TABLE_NAME = '${spf}' limit 1`);
         if (result.length > 0) {
-          recordLengths[alias] = result[0].LENGTH;
+          recordLengths[alias] = Number(result[0].LENGTH);
         } else {
           recordLengths[alias] = DEFAULT_RECORD_LENGTH;
         }
@@ -66,7 +67,8 @@ module.exports = class IBMiContent {
       .map(row => row.SRCDTA)
       .join(`\n`);
 
-    allSourceDates[alias] = sourceDates;
+    baseDates[alias] = sourceDates;
+    baseSource[alias] = body;
 
     return body;
 
@@ -87,7 +89,6 @@ module.exports = class IBMiContent {
     const tempLib = connection.config.tempLibrary;
     const alias = getAliasName(lib, spf, mbr);
     const aliasPath = `${tempLib}.${alias}`;
-    const sourceDates = allSourceDates[alias];
 
     const client = connection.client;
     const tempRmt = connection.getTempRemote(lib + spf + mbr);
@@ -98,6 +99,8 @@ module.exports = class IBMiContent {
 
     const decimalSequence = sourceData.length >= 10000;
 
+    const newDates = Handler.calcNewSourceDates(alias, body);
+
     let rows = [],
       sequence = 0;
     for (let i = 0; i < sourceData.length; i++) {
@@ -107,7 +110,7 @@ module.exports = class IBMiContent {
       }
 
       rows.push(
-        `(${sequence}, ${sourceDates[i] ? sourceDates[i].padEnd(6, `0`) : `0`}, '${this.escapeString(sourceData[i])}')`,
+        `(${sequence}, ${newDates[i] ? newDates[i].padEnd(6, `0`) : `0`}, '${this.escapeString(sourceData[i])}')`,
       );
     }
 
@@ -127,7 +130,9 @@ module.exports = class IBMiContent {
     await connection.remoteCommand(
       `QSYS/RUNSQLSTM SRCSTMF('${tempRmt}') COMMIT(*NONE) NAMING(*SQL)`,
     );
-
+
+    baseSource[alias] = body;
+    baseDates[alias] = newDates;
   }
 
   /**

src/filesystems/qsys/complex/data.js

@@ -5,7 +5,11 @@ module.exports = {
   },
 
   /** @type {{[path: string]: string[]}} */
-  allSourceDates: {},
+  baseDates: {},
+
+  /** @type {{[path: string]: string}} */
+  baseSource: {},
+
   /** @type {{[path: string]: number}} */
-  recordLengths: {},
+  recordLengths: {}
 };