Skip to content

Commit

Permalink
Upload version 1.2.4502
Browse files Browse the repository at this point in the history
  • Loading branch information
Roger Urscheler committed Oct 30, 2018
1 parent 08ba39c commit 104cbce
Show file tree
Hide file tree
Showing 8 changed files with 55,499 additions and 0 deletions.
210 changes: 210 additions & 0 deletions FileUpload.js
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,210 @@
///////////////////////////////////////////////////////////////////////////////////////////////
// FileUpload for Circuit Node.js
///////////////////////////////////////////////////////////////////////////////////////////////

/* eslint-env node, es6 */
/*global navigator*/

var nodeUrl = require('url');
var fs = require('fs');
var https = require('https');
var NodeSDK = require('./NodeSDK');

module.exports = function FileUpload(config) {
'use strict';

var MAX_FILE_COUNT = 10;
var MAX_FILE_SIZE = 50000000;
var stat = 0;

var logger = NodeSDK.logger;
var _config = config || {};

function isFileOK(file) {
//TODO optimize for async flow
var error = null;

if (file.path) {
if (!fs.existsSync(file.path)) {
error = new Error('[FileUpload] file not found');
}
stat = fs.statSync(file.path);
if (stat.size > MAX_FILE_SIZE) {
error = new Error('[FileUpload] max file size exceeded');
}
} else if (file.buffer) {
stat = { size: file.buffer.length };
if (stat.size > MAX_FILE_SIZE) {
error = new Error('[FileUpload] max file size exceeded');
}
} else {
error = new Error('[FileUpload] no file provided');
}
if (file.type === 'application/json') {
logger.debug('[FileUpload]: replace file type ', file.type);
file.type = 'text/plain'; //upload json files as text files
}
return error;
}

function urlToOptions(url, file, stat, opts) {
logger.debug('[FileUpload] urlToOptions', url, file, stat);
var parts = nodeUrl.parse(url);
var options = {
rejectUnauthorized: NodeSDK.rejectUnauthorized,
agent: NodeSDK.proxyAgent,
host: parts.hostname,
port: (parts.port) ? parts.port : '443',
path: parts.path,
method: 'POST',
headers: {
'User-Agent': navigator.userAgent,
'Cookie': _config.cookie,
'Content-Disposition': 'attachment; filename="' + file.name + '"',
'Content-Length': stat.size,
'Content-Type': file.type
}
};

if (opts) {
opts.convId && (options.headers['x-conversation'] = opts.convId);
opts.rtcSessionId && (options.headers['x-rtcsession'] = opts.rtcSessionId);
}

logger.debug('[FileUpload] options', options);
return options;
}

function uploadFile(file, url, opts) {
return new Promise(function (resolve, reject) {
var error = isFileOK(file);
if (error) {
reject(error);
return;
}
var options = urlToOptions(url, file, stat, opts);
var req = https.request(options, function (res) {
if (!res) {
logger.error('[FileUpload]: no res in https callback');
error = new Error('[FileUpload]: no res in https callback');
reject(error);
}
logger.debug('[FileUpload]: https callback', res.statusCode, res.statusMessage, res.headers);
if (res.statusCode !== 200) {
logger.error('[FileUpload]: status code: ' + res.statusCode, res.statusMessage);
error = new Error('[FileUpload]: status code ' + res.statusCode, res.statusMessage);
reject(error);
}
var body = '';
res.on('data', function (d) {
logger.debug('[FileUpload]: result on data', d);
body += d;
});
res.on('end', function () {
logger.debug('[FileUpload]: result on end', body.toString('utf8'));
resolve(body);
});
res.on('error', function (e) {
logger.debug('[FileUpload]: result on error', e);
reject(e);
});
});

if (file.path) {
var readStream = fs.createReadStream(file.path);
readStream.on('data', function (chunk) {
logger.debug('[FileUpload]: readStream on data', file.path, chunk);
req.write(chunk);
});
readStream.on('end', function () {
logger.debug('[FileUpload]: readStream on end ', file.path);
req.end();
});

req.on('error', function (e) {
logger.debug('[FileUpload]: request on error', file.path, e);
reject(e);
});
} else if (file.buffer) {
req.end(file.buffer);
}
});
}

this.uploadFiles = function (files, domain) {
domain = domain || _config.domain;
logger.debug('[FileUpload] node SDK uploadFiles: ', files, domain);

if (files.length > MAX_FILE_COUNT) {
return Promise.reject('[FileUpload]: Exceeded maximum of %d% files per message', MAX_FILE_COUNT);
}

var result = [];

// Find large images that need to be resized
var resizePromises = [];
/*
files.forEach(function (file) {
// Even create a thumbnail for small images
if (circuit.Utils.isSupportedImage && circuit.Utils.isSupportedImage(file.type)) {
resizePromises.push(createThumbnail(file));
logger.warning('[FileUpload]: node SDK does not yet support creation of thumbnails');
}
});
*/

return Promise.all(resizePromises)
.then(function (blobs) {
// Add the blob's (thumbnails) to the list of files to be upoaded
files = files.concat(blobs);

// Sequentially (but async) upload the files. Once all files are
// uploaded, resolve the Promise passing the upload results.
var itemId = null;
return files.reduce(function (sequence, file) {
return sequence.then(function () {
var url = 'https://' + domain + '/fileapi?itemid=' + (itemId || 'NULL');
return uploadFile(file, url)
.then(function (res) {
var resp = JSON.parse(res)[0];
itemId = itemId || resp.id;
var attachmentMetaData = {
fileId: resp.fileid.slice(-1)[0],
fileName: file.name,
itemId: itemId,
mimeType: resp.mimeType || file.type,
size: file.size
};
result.push(attachmentMetaData);
return result;
});
});
}, Promise.resolve());
});
};

this.uploadWhiteboardFile = function (file, rtcSessionId) {
logger.debug('[FileUpload] node SDK uploadWhiteboardFile: ', file);

var url = 'https://' + _config.domain + '/fileapi';
var opts = {
rtcSessionId: rtcSessionId
};

return uploadFile(file, url, opts)
.then(function (res) {
var resp = JSON.parse(res)[0];
var fileUrl = url + '?fileid=' + resp.id;
var fileName = file.name;
var attachmentMetaData = {
fileId: resp.id,
fileName: fileName,
mimeType: resp.mimeType || file.type,
size: file.size,
url: fileUrl,
deleteUrl: fileUrl
};
return attachmentMetaData;
});
};
};
50 changes: 50 additions & 0 deletions NodeSDK.js
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,50 @@
///////////////////////////////////////////////////////////////////////////////////////////////
// Global settings for Circuit Node.js
///////////////////////////////////////////////////////////////////////////////////////////////

/* eslint-env node, es6 */
/*eslint strict: ["error", "never"]*/

/**
* Object defining Node.js SDK specific options.
* @class NodeSDK
*/
var NodeSDK = {};

/**
* If true, the server certificate is verified against the list of supplied CAs.
* An error event is emitted if verification fails; err.code contains the OpenSSL
* error code. Default: false.
* Only applicable to Node.js SDK.
* @property rejectUnauthorized
* @type Boolean
* @example
* NodeSDK.rejectUnauthorized = true;
*/
NodeSDK.rejectUnauthorized = false;

/**
* HttpsProxyAgent object as defined in https://www.npmjs.com/package/https-proxy-agent.
* Agent will be used on HTTP(S) request and WebSocket connection within Node SDK.
* Only applicable to Node.js SDK.
* @property proxyAgent
* @type Object
* @example
* // export http_proxy=http://172.20.1.100:8080
* var HttpsProxyAgent = require('https-proxy-agent');
* NodeSDK.proxyAgent = new HttpsProxyAgent(url.parse(process.env.http_proxy));
*/
NodeSDK.proxyAgent = undefined;

// Dummy logger. Overwritten by application using Circuit.setLogger
NodeSDK.logger = {
debug: function () {},
info: function () {},
warning: function () {},
warn: function () {},
error: function () {}
};

module.exports = NodeSDK;


23 changes: 23 additions & 0 deletions WebSocket.js
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
///////////////////////////////////////////////////////////////////////////////////////////////
// WebSocket for Circuit Node.js
///////////////////////////////////////////////////////////////////////////////////////////////

/* eslint-env node, es6 */
/*global */

var NodeWebSocket = require('ws');
var NodeSDK = require('./NodeSDK');

module.exports = function (target, cookie) {
'use strict';
var logger = NodeSDK.logger;
var wsOptions = {
headers: {
Cookie: cookie
},
rejectUnauthorized: NodeSDK.rejectUnauthorized,
agent: NodeSDK.proxyAgent
};
logger.debug('[WebSocket]: Initiated websocket with ' + JSON.stringify(wsOptions));
return new NodeWebSocket(target, wsOptions);
};
Loading

0 comments on commit 104cbce

Please sign in to comment.