gnh1201/welsonjs
1
0
Fork 0
mirror of https://github.com/gnh1201/welsonjs.git synced 2024-11-26 23:41:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #81 from gnh1201/pipe-ipc-file

Browse Source 
Pipe ipc file
This commit is contained in:
Namhyeon Go 2023-09-19 16:32:10 +09:00 committed by GitHub
commit 9080a177f1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 58 additions and 115 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

131
lib/file.js
View File

@ -4,25 +4,18 @@
//
// Common routines. Defines LIB object which contains the API, as well as
// a global console.log function.
// with the PIPE based IPC (lib/pipe-ipc.js)
//
/////////////////////////////////////////////////////////////////////////////////
var LIB = require("lib/std");
var PipeIPC = require("lib/pipe-ipc");
/////////////////////////////////////////////////////////////////////////////////
// Private APIs / Utility functions
/////////////////////////////////////////////////////////////////////////////////
// StreamTypeEnum
// https://learn.microsoft.com/en-us/sql/ado/reference/ado-api/streamtypeenum?view=sql-server-ver16
var adTypeBinary = 1;
var adTypeText = 2;
// SaveOptionsEnum
// https://learn.microsoft.com/en-us/sql/ado/reference/ado-api/saveoptionsenum?view=sql-server-ver16
var adSaveCreateNotExist = 1;
var adSaveCreateOverWrite = 2;
/////////////////////////////////////////////////////////////////////////////////
// fileExists
/////////////////////////////////////////////////////////////////////////////////
@ -61,29 +54,9 @@ function fileGet(FN) {
/////////////////////////////////////////////////////////////////////////////////
function readFile(FN, charset) {
if(typeof(charset) === "undefined") {
var FSO = CreateObject("Scripting.FileSystemObject");
var T = null;
try {
var TS = FSO.OpenTextFile(FN, 1);
if (TS.AtEndOfStream) return "";
T = TS.ReadAll();
TS.Close();
TS = null;
} catch (e) {
console.log("ERROR! " + e.number + ", " + e.description + ", FN=" + FN);
}
FSO = null;
return T;
} else {
var fsT = CreateObject("ADODB.Stream");
fsT.CharSet = charset;
fsT.Open();
fsT.LoadFromFile(FN);
T = fsT.ReadText();
fsT = null;
return T;
}
var pipe = PipeIPC.create();
pipe.setCharset(charset);
return pipe.readTextFromFile(FN);
}
/////////////////////////////////////////////////////////////////////////////////
@ -92,60 +65,12 @@ function readFile(FN, charset) {
/////////////////////////////////////////////////////////////////////////////////
function writeFile(FN, content, charset) {
var Stream_No_UTF8_BOM = function(objStream) {
var _objStream = CreateObject("ADODB.Stream");
_objStream.Type = 1;
_objStream.Mode = 3;
_objStream.Open();
objStream.Position = 3;
objStream.CopyTo(_objStream);
objStream.Flush();
//objStream.Close();
return _objStream;
};
var ok = false;
while (!ok) {
// [lib/file] Can not overwrite a file with ADODB.Stream SaveToFile() #32
require("lib/shell").exec(["del", FN]);
// ascii:Scripting.FileSystemObject, unicode:ADODB.Stream
if (charset) {
console.log("WRITE TO DISK USING ADODB.Stream CHARSET " + charset);
try {
var fsT = CreateObject("ADODB.Stream");
fsT.Type = 2; // save as text/string data.
fsT.Charset = charset; // Specify charset For the source text data.
fsT.Open();
fsT.WriteText(content);
if (charset == "utf-8") {
Stream_No_UTF8_BOM(fsT).SaveToFile(FN, 2); // save as binary to disk
} else {
fsT.SaveToFile(FN, 2); // save as binary to disk
}
fsT.Close();
fsT = null;
ok = true;
} catch (e) {
console.log("ADODB.Stream: ERROR! " + e.number + ", " + e.description + ", FN=" + FN);
}
} else {
console.log("WRITE TO DISK USING OpenTextFile CHARSET ascii");
var FSO = CreateObject("Scripting.FileSystemObject");
try {
var TS = FSO.OpenTextFile(FN, 2, true, 0); // ascii
TS.Write(content);
TS.Close();
TS = null;
ok = true;
} catch (e) {
console.log("OpenTextFile: ERROR! " + e.number + ", " + e.description + ", FN=" + FN);
}
FSO = null;
}
}
return ok;
var pipe = PipeIPC.connect("volatile");
pipe.setCharset(charset);
pipe.startRecorder(FN, PipeIPC.ForWriting);
pipe.write(content);
pipe.destroy();
return true;
}
/////////////////////////////////////////////////////////////////////////////////
@ -154,7 +79,7 @@ function writeFile(FN, content, charset) {
function writeBinaryFile(FN, DATA) {
var BinaryStream = CreateObject("ADODB.Stream");
BinaryStream.Type = adTypeBinary;
BinaryStream.Type = PipeIPC.adTypeBinary;
BinaryStream.Open();
BinaryStream.Write(DATA);
BinaryStream.SaveToFile(FN, adSaveCreateOverWrite);
@ -210,19 +135,26 @@ function deleteFile(FN) {
/////////////////////////////////////////////////////////////////////////////////
function includeFile(FN) {
var fso = CreateObject("Scripting.FileSystemObject");
var fileStream = fso.openTextFile(FN);
var fileData = fileStream.readAll();
fileStream.Close();
eval(fileData);
eval(readFile(FN));
}
function appendFile(FN, content, charset) {
if (fileExists(FN)) {
return writeFile(FN, readFile(FN, charset) + content, charset);
} else {
return writeFile(FN, content, charset);
}
var pipe = PipeIPC.connect("volatile");
pipe.setCharset(charset);
pipe.startRecorder(FN, PipeIPC.ForAppending);
pipe.write(content);
pipe.destroy();
return true;
}
function rotateFile(FN, content, numOfLines, charset) {
var pipe = PipeIPC.connect("volatile");
pipe.setCharset(charset);
pipe.setMaxSentences(numOfLines);
pipe.startRecorder(FN, PipeIPC.ForAppending);
pipe.write(content);
pipe.destroy();
return true;
}
exports.fileExists = fileExists;
@ -237,7 +169,8 @@ exports.deleteFolder = deleteFolder;
exports.deleteFile = deleteFile;
exports.includeFile = includeFile;
exports.appendFile = appendFile;
exports.rotateFile = rotateFile;
exports.VERSIONINFO = "File Lib (file.js) version 0.2.1";
exports.VERSIONINFO = "File Library (file.js) version 0.2.4";
exports.global = global;
exports.require = global.require;

42
lib/pipe-ipc.js
View File

@ -54,7 +54,6 @@ var CdoUTF_7 = "utf-7";
var CdoUTF_8 = "utf-8";
function createUUIDv4() {
sleep(1);
var randomize = Math.random;
return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {
var r = randomize() * 16 | 0, v = c == 'x' ? r : (r & 0x3 | 0x8);
@ -62,6 +61,14 @@ function createUUIDv4() {
});
}
function createFSO() {
return CreateObject("Scripting.FileSystemObject");
}
function createADO() {
return CreateObject("ADODB.Stream");
}
function PipeIPC() {
this.path = "data\\.pipe_:pipename";
this.delimiter = "\r\n";
@ -93,6 +100,9 @@ function PipeIPC() {
};
this.connect = function(pipename, callback) {
if (pipename == "volatile") {
pipename = createUUIDv4().substring(0, 8);
}
this.path = this.path.replace(":pipename", pipename);
//this.openWriter();
this.openReader();
@ -105,7 +115,7 @@ function PipeIPC() {
this.openWriter = function(iomode) {
while (this.writer == null) {
try {
this.writer = CreateObject("Scripting.FileSystemObject").OpenTextFile(this.path, iomode, true, TristateTrue);
this.writer = createFSO().OpenTextFile(this.path, iomode, true, TristateTrue);
} catch (e) {}
}
};
@ -120,7 +130,7 @@ function PipeIPC() {
this.openReader = function() {
while (this.reader == null) {
try {
this.reader = CreateObject("Scripting.FileSystemObject").OpenTextFile(this.path, ForReading, true, TristateTrue);
this.reader = createFSO().OpenTextFile(this.path, ForReading, true, TristateTrue);
} catch (e) {}
}
};
@ -146,7 +156,7 @@ function PipeIPC() {
this.openRecorder = function(iomode) {
while (this.recorder == null) {
try {
this.recorder = CreateObject("Scripting.FileSystemObject").OpenTextFile(this.tmpfile, iomode, true, TristateTrue);
this.recorder = createFSO().OpenTextFile(this.tmpfile, iomode, true, TristateTrue);
} catch (e) {}
}
};
@ -215,7 +225,7 @@ function PipeIPC() {
// define functions
var StripAdoBOM = function(adoObj) {
var newAdoObj = CreateObject("ADODB.Stream");
var newAdoObj = createADO();
newAdoObj.Type = adTypeBinary;
newAdoObj.Mode = adModeReadWrite;
newAdoObj.Open();
@ -229,7 +239,7 @@ function PipeIPC() {
while (!isCommited) {
try {
// Open a temporary file
var fso = CreateObject("Scripting.FileSystemObject").OpenTextFile(src, ForReading, true, TristateTrue);
var fso = createFSO().OpenTextFile(src, ForReading, true, TristateTrue);
var text = fso.ReadAll();
var sentences = text.split(this.delimiter);
var newSentences = [], str = '';
@ -245,7 +255,7 @@ function PipeIPC() {
}
// Convert UTF-16 BOM to UTF-8
var ado = CreateObject("ADODB.Stream");
var ado = createADO();
ado.Type = adTypeText;
ado.Charset = charset;
ado.Open();
@ -255,12 +265,12 @@ function PipeIPC() {
ado.Close();
// Write a new temporary file
/*
var _fso = CreateObject("Scripting.FileSystemObject").OpenTextFile(src, ForWriting, true, TristateTrue);
_fso.Write(str);
_fso.Close();
*/
if (this.maxSentences > 0) {
var handler = createFSO().OpenTextFile(src, ForWriting, true, TristateTrue);
handler.Write(str);
handler.Close();
}
// Close the temporary file
fso.Close();
@ -322,19 +332,19 @@ function PipeIPC() {
this.destroy = function() {
this.close();
CreateObject("Scripting.FileSystemObject").DeleteFile(this.path);
createFSO().DeleteFile(this.path);
};
this.readTextFromFile = function(filename) {
var text = '';
var isLoaded = false;
var isFileExists = CreateObject("Scripting.FileSystemObject").FileExists(filename);
var isFileExists = createFSO().FileExists(filename);
if (isFileExists) {
//console.info("File", filename, "exists");
while (!isLoaded) {
try {
var ado = CreateObject("ADODB.Stream");
var ado = createADO();
ado.CharSet = this.charset;
ado.Open();
ado.LoadFromFile(filename);