fix(basic.gblib): CONVERT keyword coded.
This commit is contained in:
parent
e4be1600f0
commit
9b1eae2972
1 changed files with 79 additions and 0 deletions
|
@ -349,6 +349,9 @@ export class SystemKeywords {
|
|||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* Creates a folder in the bot instance drive.
|
||||
*
|
||||
|
@ -494,6 +497,82 @@ export class SystemKeywords {
|
|||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Converts a drive file from a place to another .
|
||||
*
|
||||
* Supported sources csv, doc, docx, odp, ods, odt, pot, potm, potx, pps,
|
||||
* ppsx, ppsxm, ppt, pptm, pptx, rtf, xls, xlsx
|
||||
*
|
||||
* @example
|
||||
*
|
||||
* CONVERT "customers.xlsx" TO "reports\" + today + ".pdf"
|
||||
*
|
||||
*/
|
||||
public async convert(src, dest) {
|
||||
|
||||
let [baseUrl, client] = await this.internalGetDriveClient();
|
||||
const botId = this.min.instance.botId;
|
||||
|
||||
// Normalizes all slashes.
|
||||
|
||||
src = src.replace(/\\/gi, '/');
|
||||
dest = dest.replace(/\\/gi, '/');
|
||||
|
||||
// Determines full path at source and destination.
|
||||
|
||||
const root = urlJoin(`/${botId}.gbai/${botId}.gbdata`);
|
||||
const srcPath = urlJoin(root, src);
|
||||
const dstPath = urlJoin(`/${botId}.gbai/${botId}.gbdata`, dest);
|
||||
|
||||
// Checks if the destination contains subfolders that
|
||||
// need to be created.
|
||||
|
||||
let folder;
|
||||
if (dest.indexOf('/') !== -1) {
|
||||
const pathOnly = path.dirname(dest);
|
||||
folder = await this.createFolder(pathOnly);
|
||||
}
|
||||
else {
|
||||
folder = await client.api(
|
||||
`${baseUrl}/drive/root:/${root}`)
|
||||
.get();
|
||||
}
|
||||
|
||||
// Performs the conversion operation getting a reference
|
||||
// to the source and calling /content on drive API.
|
||||
|
||||
try {
|
||||
|
||||
const res = await client
|
||||
.api(`${baseUrl}/drive/root:/${srcPath}:/content?format=pdf`)
|
||||
.get();
|
||||
|
||||
const streamToString = (stream) => {
|
||||
const chunks = []
|
||||
return new Promise((resolve, reject) => {
|
||||
stream.on('data', chunk => chunks.push(chunk))
|
||||
stream.on('error', reject)
|
||||
stream.on('end', () => resolve(Buffer.concat(chunks)))
|
||||
})
|
||||
}
|
||||
|
||||
const result = await streamToString(res);
|
||||
|
||||
await client
|
||||
.api(`${baseUrl}/drive/root:/${dstPath}:/content`)
|
||||
.put(result);
|
||||
|
||||
} catch (error) {
|
||||
|
||||
if (error.code === "itemNotFound") {
|
||||
GBLog.info(`BASIC: CONVERT source file not found: ${srcPath}.`);
|
||||
} else if (error.code === "nameAlreadyExists") {
|
||||
GBLog.info(`BASIC: CONVERT destination file already exists: ${dstPath}.`);
|
||||
}
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Generate a secure and unique password.
|
||||
*
|
||||
|
|
Loading…
Add table
Reference in a new issue