Scheduled Export of a file in CSV format into a shared folder through MID Server

[Teja31]

Scheduled Export of a file in CSV format into a shared folder through MID Server

[Service Manager]

Hi Ankur,

Could you help with mid server script include ?

Midserver - Scrip Include

var CSMIDServerRemoteFileImport = Class.create();
CSMIDServerRemoteFileImport.prototype = {
initialize: function() {
//this.debug = probe.getParameter("debug");
this.debug = true;
this.logMsg("Starting MID Server File Transfer");
this.charset = "UTF-8";
this.LINE_FEED = "\r\n";


this.boundary = "===" + new Date().getTime() + "===";
this.probeParameters = this._getProbeParameters();
},

getRemoteFileAndUploadToInstance: function() {
var url = this._getInstanceConnectionURL();
var conn = this._getURLConnection(url);
var file = this._getFile();
var response = this._writeFile(conn, file);
if (response != 200)
throw "HTTP response " + response;
this.logMsg("HTTP response " + response, "debug");

ms.log("Completed MID Server File Transfer");
return response;
},

_getProbeParameters: function() {
var probeObj = {};
probeObj.instance = probe.getParameter("instance");
probeObj.instanceUser = ms.getConfigParameter("mid.instance.username");
probeObj.instancePassword = ms.getConfigParameter("mid.instance.password");

probeObj.filePath = probe.getParameter("filePath");
probeObj.targetImportSet = probe.getParameter("targetImportSet");
return probeObj;
},

_getInstanceConnectionURL: function() {
return this._joinParams(this.probeParameters.instance + "sys_import.do", [
this._encodeParam('sysparm_import_set_tablename', this.probeParameters.targetImportSet),
this._encodeParam('sysparm_transform_after_load', 'true')
]);
},

_encodeParam: function (k, v) {
return k + "=" + Packages.java.net.URLEncoder.encode(v);
},

_joinParams: function (base, arr) {
return base + '?' + arr.join('&');
},
_getURLConnection: function(url) {
if (ms.getConfigParameter("mid.proxy.use_proxy") == 'true') {
Packages.java.lang.System.setProperty("https.proxyHost", ms.getConfigParameter("mid.proxy.host"));
Packages.java.lang.System.setProperty("http.proxyHost", ms.getConfigParameter("mid.proxy.host"));
Packages.java.lang.System.setProperty("https.proxyPort", ms.getConfigParameter("mid.proxy.port"));
Packages.java.lang.System.setProperty("http.proxyPort", ms.getConfigParameter("mid.proxy.port"));
}
var conn = new Packages.java.net.URL(url).openConnection();
this.logMsg("Sending to : " + url, "debug");

var userpass = new java.lang.String(this.probeParameters.instanceUser + ":" + this.probeParameters.instancePassword);
var basicAuth = "Basic " + (new Packages.javax.xml.bind.DatatypeConverter.printBase64Binary(userpass.getBytes()) + '');
conn.setRequestProperty("Authorization", basicAuth);
conn.setDoOutput(true);
conn.setRequestMethod("POST");
conn.setUseCaches(false);

conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + this.boundary);
conn.setRequestProperty("User-Agent", "MID Server POST");

return conn;

},

_getFile: function() {
return new Packages.java.io.File(this.probeParameters.filePath);
},

_writeFile: function(conn, uploadFile) {

var outputStream = conn.getOutputStream();
var writer = new Packages.java.io.PrintWriter(new Packages.java.io.OutputStreamWriter(outputStream, this.charset), true);
var fieldName = 'file';
var fileName = uploadFile.getName();

this.logMsg("Sending file : " + fileName, "debug");

writer.append("--" + this.boundary).append(this.LINE_FEED);
writer.append("Content-Disposition: form-data; name=\"" + fieldName + "\"; filename=\"" + fileName + "\"").append(this.LINE_FEED);
writer.append("Content-Type: " + Packages.java.net.URLConnection.guessContentTypeFromName(fileName)).append(this.LINE_FEED);
writer.append("Content-Transfer-Encoding: binary").append(this.LINE_FEED);
writer.append(this.LINE_FEED).flush();

this._writeFileData(uploadFile, outputStream);

writer.append(this.LINE_FEED).flush();
writer.append(this.LINE_FEED).flush();
writer.append("--" + this.boundary + "--").append(this.LINE_FEED);
writer.close();
return conn.getResponseCode();
},


_writeFileData: function(uploadFile, outputStream) {
var inputStream = new Packages.java.io.FileInputStream(uploadFile);

var data = new Packages.java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, 4096);
var bytesRead = 0;
while ((bytesRead = inputStream.read(data)) != -1) {
outputStream.write(data, 0, bytesRead);
outputStream.flush();
}
inputStream.close();
},


logMsg: function(message, logType) {
logType = logType || 'info';
var prefixStr = "*** MID Server Remote File";
if (logType == 'info' || logType == 'error') {
ms.log(prefixStr + " " + logType.toUpperCase() + "*** " + message);
}
if (this.debug && logType == 'debug') {
ms.log(" DEBUG *** " + message);
}
},

type: 'CSMIDServerRemoteFileImport'
};

Script Include

var CSRemoteFileImport = Class.create();

CSRemoteFileImport.prototype = {

initialize: function(remoteFileImportGR) {

this.debug = true; //add a property at later date
if(!remoteFileImportGR) {
this.logMsg("Attempted to get file from MID server but no record was defined", 'debug');
return;
}
this.record = remoteFileImportGR; //set our record to be the current record passed in
},

createEccQueueOutput : function(){
this.logMsg("Creating ECC Queue entry for: " + this.record.getDisplayValue() + "https://https://dev60321.service-now.com" + gs.getProperty('glide.servlet.uri'), 'debug');

var jsProbe = this.getJSProbe();
jsProbe.create();
this.record.u_last_run_datetime = gs.nowDateTime();
this.record.update();
},

getJSProbe: function () {
var jsProbe = new JavascriptProbe(this.record.u_mid_server.name);
//jsProbe.setSource(this.type);
jsProbe.setName(this.type);
jsProbe.addParameter("filePath", this.record.u_file_path);
jsProbe.addParameter("targetImportSet", this.record.u_import_table.name);
jsProbe.addParameter("instance", gs.getProperty("glide.servlet.uri"));

if(this.debug) {
jsProbe.setParameter("debug", this.debug);
}

jsProbe.setJavascript("var remoteFileImport = new CSMIDServerRemoteFileImport(); \nremoteFileImport.getRemoteFileAndUploadToInstance()");

return jsProbe;
},

logMsg : function(message, msgType) {
var msgSrc = "Remote File Importer";
if(this.debug && msgType == 'debug') {
gs.info('DEBUG: ' + message, msgSrc);
}
else if(msgType == 'info' || msgType == '') {
gs.log('INFO: ' + message, msgSrc);
}
else {
gs.print(message);
}
},

type: "CSRemoteFileImport"
};

CSRemoteFileImport.filterImportTables = function() {
//Ref qual to only show import tables
var t = new TableUtils("sys_import_set_row");
var ta = t.getTableExtensions();
var jst = j2js(ta);
return 'nameIN' + jst + '';
};

[Shraddha Kadam]

Hello,

Do you find some solution related to this ?

I have same requirement. If you got the solution, could you please explain the procedure.

Thank you.

[Teja31]

Do you have any idea on that script ?I found some of the links in community which has this information, But I'm not able to understand completely from that link(s).

https://community.servicenow.com/community?id=community_question&sys_id=4ab8c361db5cdbc01dcaf3231f9619e5

Thanks,

Teja