Skip to content

Cleaned up server scripts #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
andersevenrud wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Cleaned up server scripts #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
39 changes: 20 additions & 19 deletions server.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,36 +1,37 @@
const bodyParser = require('body-parser');
const {discovery, checkFileInfo, getFile, putFile} = require('./wopi');

// Methods OS.js server requires
module.exports = (core, proc) => {
const {routeAuthenticated, route} = core.make('osjs/express');
const OFFICE_BASE_URL = core.configuration.office['collabora_online'];
const vfs = core.make('osjs/vfs');
core.app.use(bodyParser.raw({limit: '1000000kb'}));
const {routeAuthenticated, route} = core.make('osjs/express');
let userInfo;

const withHooks = (fn) => async (req, res) => {
const vfsWithSession = (method, ...args) => vfs
.call({method, user: {username: userInfo.username}}, ...args);

try {
await fn({req, res, core, vfs, vfsWithSession, userInfo});
} catch (e) {
res.status(500).end();
console.error(e);
}
};

return {
init: async () => {
routeAuthenticated(
'GET',
proc.resource('/discovery'),
async (req, res) => {
userInfo = req.session.user;
discovery({OFFICE_BASE_URL, req, res});
}
withHooks((args) => {
userInfo = args.req.session.user;
return discovery(args);
})
);

route('GET', '/wopi/files/:fileId', async (req, res) => {
checkFileInfo({req, res, vfs, userInfo});
});

route('GET', '/wopi/files/:fileId/contents', async (req, res) => {
getFile({req, res, vfs, userInfo});
});

route('POST', '/wopi/files/:fileId/contents', async (req, res) => {
putFile({req, res, vfs, userInfo});
});
route('GET', '/wopi/files/:fileId', withHooks(checkFileInfo));
route('GET', '/wopi/files/:fileId/contents', withHooks(getFile));
route('POST', '/wopi/files/:fileId/contents', withHooks(putFile));
},
};
};
195 changes: 88 additions & 107 deletions wopi.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,69 +6,73 @@ const fs = require('fs');
const {Readable} = require('stream');
const {encrypt, decrypt} = require('./crypto');

async function discovery({OFFICE_BASE_URL, req, res}) {
const filePathHash = encrypt(req.query.id);
let httpClient = OFFICE_BASE_URL.startsWith('https') ? https : http;
let data = '';
let request = httpClient.get(
OFFICE_BASE_URL + '/hosting/discovery',
(response) => {
response.on('data', (chunk) => {
data += chunk.toString();
});
function fetchDiscovery(baseUri, filePathHash) {
const parseResponse = (response, data) => {
if (response.statusCode !== 200) {
const err = new Error('Request failed. Satus Code: ' + response.statusCode);
err.statusCode = response.statusCode;
throw err;
} else if (!response.complete) {
throw new Error('No able to retrieve the discovery.xml file from the Collabora Online server with the submitted address.');
}

let doc = new Dom().parseFromString(data);
if (!doc) {
throw new Error('The retrieved discovery.xml file is not a valid XML file');
}

let mimeType = 'text/plain';
let nodes = xpath.select(
`/wopi-discovery/net-zone/app[@name='${mimeType}']/action`,
doc
);
if (!nodes || nodes.length !== 1) {
throw new Error('The requested mime type is not handled');
}

let onlineUrl = nodes[0].getAttribute('urlsrc');
return {
url: onlineUrl,
token: 'test',
fileId: filePathHash,
};
};

return new Promise((resolve, reject) => {
const httpClient = baseUri.startsWith('https') ? https : http;
const url = baseUri + '/hosting/discovery';

const request = httpClient.get(url, (response) => {
let data = '';
response.on('error', reject);
response.on('data', (chunk) => (data += chunk.toString()));
response.on('end', () => {
let err;
if (response.statusCode !== 200) {
err = 'Request failed. Satus Code: ' + response.statusCode;
response.resume();
res.status(response.statusCode).send(err);
console.log(err);
return;
}
if (!response.complete) {
err =
'No able to retrieve the discovery.xml file from the Collabora Online server with the submitted address.';
res.status(404).send(err);
console.log(err);
return;
}
let doc = new Dom().parseFromString(data);
if (!doc) {
err = 'The retrieved discovery.xml file is not a valid XML file';
res.status(404).send(err);
console.log(err);
return;
}
let mimeType = 'text/plain';
let nodes = xpath.select(
'/wopi-discovery/net-zone/app[@name=\'' + mimeType + '\']/action',
doc
);
if (!nodes || nodes.length !== 1) {
err = 'The requested mime type is not handled';
res.status(404).send(err);
console.log(err);
return;
try {
const parsed = parseResponse(response, data);
resolve(parsed);
} catch (e) {
reject(e);
}
let onlineUrl = nodes[0].getAttribute('urlsrc');
res.json({
url: onlineUrl,
token: 'test',
fileId: filePathHash,
});
});
response.on('error', (err) => {
res.status(404).send('Request error: ' + err);
console.log('Request error: ' + err.message);
});
}
);
request.on('error', (err) => {
res.status(404).send('Request error: ' + err);
console.error(err);
});

request.on('error', reject);
});
}

async function discovery({req, res, core}) {
const baseUri = core.config('office.collabora_online', '');
const filePathHash = encrypt(req.query.id);

try {
const result = await fetchDiscovery(baseUri, filePathHash);
res.json(result);
} catch (e) {
res.status(e.statusCode || 404).send(e.message);
console.error(e);
}
}

/* *
* wopi CheckFileInfo endpoint
*
Expand All @@ -78,46 +82,30 @@ async function discovery({OFFICE_BASE_URL, req, res}) {
* The CheckFileInfo wopi endpoint is triggered by a GET request at
* https://HOSTNAME/wopi/files/<document_id>
*/
async function checkFileInfo({req, res, vfs, userInfo}) {
async function checkFileInfo({req, res, vfsWithSession, userInfo}) {
let fileSize = null;
const origin = 'http://192.168.1.144:8000'; // FIXME
const filePath = decrypt(req.params.fileId);
const fileName = filePath.split('/').pop();
let fileSize = null;

try {
try {
await vfs
.call({method: 'stat', user: {username: userInfo.username}}, filePath)
.then((response) => {
if ('size' in response) {
fileSize = response.size;
} else {
throw new Error();
}
});
} catch{
await vfs
.call(
{method: 'readfile', user: {username: userInfo.username}},
filePath
)
.then((response) => {
fileSize = response.headers['content-length'];
});
}

res.json({
BaseFileName: fileName,
Size: fileSize,
UserId: userInfo.id,
OwnerId: userInfo.username,
UserCanWrite: true,
// UserCanNotWriteRelative: false, // to show Save As button
SupportsUpdate: true,
PostMessageOrigin: 'http://192.168.1.144:8000',
});
} catch (err) {
console.log(err);
const stat = await vfsWithSession('stat', filePath);
if (stat.size) {
fileSize = stat.size;
} else {
const file = await vfsWithSession('readfile', filePath);
fileSize = file.headers['content-length'];
}

res.json({
BaseFileName: fileName,
Size: fileSize,
UserId: userInfo.id,
OwnerId: userInfo.username,
UserCanWrite: true,
// UserCanNotWriteRelative: false, // to show Save As button
SupportsUpdate: true,
PostMessageOrigin: origin,
});
}

/* *
Expand All @@ -127,21 +115,18 @@ async function checkFileInfo({req, res, vfs, userInfo}) {
* The GetFile wopi endpoint is triggered by a request with a GET verb at
* https://HOSTNAME/wopi/files/<document_id>/contents
*/
async function getFile({req, res, vfs, userInfo}) {
async function getFile({req, res, vfs, vfsWithSession, userInfo}) {
const filePath = decrypt(req.params.fileId);

if (filePath.startsWith('myMonster')) {
await vfs
.call({method: 'readfile', user: {username: userInfo.username}}, filePath)
.then((response) => {
response.pipe(res);
});
const response = await vfsWithSession('readfile', filePath);
response.pipe(res);
} else {
const realPath = await vfs.realpath(filePath, {
username: userInfo.username,
});
const fileBuffer = fs.readFileSync(realPath);
res.send(fileBuffer);
const stream = fs.createReadStream(realPath);
stream.pipe(res);
}
}

Expand All @@ -152,15 +137,11 @@ async function getFile({req, res, vfs, userInfo}) {
* The PutFile wopi endpoint is triggered by a request with a POST verb at
* https://HOSTNAME/wopi/files/<document_id>/contents
*/
async function putFile({req, res, vfs, userInfo}) {
async function putFile({req, res, vfsWithSession}) {
if (req.body) {
const filePath = decrypt(req.params.fileId);
const stream = Readable.from(req.body);
await vfs.call(
{method: 'writefile', user: {username: userInfo.username}},
filePath,
stream
);
await vfsWithSession('writefile', filePath, stream);
res.sendStatus(200);
} else {
console.log('Not possible to get the file content.');
Expand Down