docs/docs-importer/main.js

230 lines
5.2 KiB
JavaScript
Raw Normal View History

2018-02-28 22:53:06 +01:00
'use strict';
const recursive = require('recursive-readdir');
const ora = require('ora');
const inquirer = require('inquirer');
const preferences = require('preferences');
const fs = require('fs');
const request = require('request').defaults({
jar: true
});
// Load preferences
const prefs = new preferences('com.sismics.docs.importer',{
2018-03-01 12:28:29 +01:00
importer: {
daemon: false
}
2018-02-28 22:53:06 +01:00
}, {
encrypt: false,
format: 'yaml'
});
// Welcome message
console.log('Sismics Docs Importer 1.0.0, https://www.sismicsdocs.com' +
'\n\n' +
'This program let you import files from your system to Sismics Docs' +
'\n');
// Ask for the base URL
const askBaseUrl = () => {
inquirer.prompt([
{
type: 'input',
name: 'baseUrl',
message: 'What is the base URL of your Docs? (eg. https://docs.mycompany.com)',
default: prefs.importer.baseUrl
}
]).then(answers => {
// Save base URL
prefs.importer.baseUrl = answers.baseUrl;
// Test base URL
const spinner = ora({
text: 'Checking connection to Docs',
spinner: 'flips'
}).start();
request(answers.baseUrl + '/api/app', function (error, response) {
if (!response || response.statusCode !== 200) {
spinner.fail('Connection to Docs failed: ' + error);
askBaseUrl();
return;
}
spinner.succeed('Connection OK');
askCredentials();
});
});
};
askBaseUrl();
// Ask for credentials
const askCredentials = () => {
console.log('');
inquirer.prompt([
{
type: 'input',
name: 'username',
message: 'Account\'s username?',
default: prefs.importer.username
},
{
type: 'password',
name: 'password',
message: 'Account\'s password?',
default: prefs.importer.password
}
]).then(answers => {
// Save credentials
prefs.importer.username = answers.username;
prefs.importer.password = answers.password;
// Test credentials
const spinner = ora({
text: 'Checking connection to Docs',
spinner: 'flips'
}).start();
request.post({
url: prefs.importer.baseUrl + '/api/user/login',
form: {
username: answers.username,
password: answers.password,
remember: true
}
}, function (error, response) {
2018-03-01 12:28:29 +01:00
if (error || !response || response.statusCode !== 200) {
2018-02-28 22:53:06 +01:00
spinner.fail('Username or password incorrect');
askCredentials();
return;
}
spinner.succeed('Authentication OK');
askPath();
});
});
};
// Ask for the path
const askPath = () => {
console.log('');
inquirer.prompt([
{
type: 'input',
name: 'path',
message: 'What is the folder path you want to import?',
default: prefs.importer.path
}
]).then(answers => {
// Save path
prefs.importer.path = answers.path;
// Test path
const spinner = ora({
text: 'Checking import path',
spinner: 'flips'
}).start();
2018-03-01 12:28:29 +01:00
fs.lstat(answers.path, (error, stats) => {
if (error || !stats.isDirectory()) {
2018-02-28 22:53:06 +01:00
spinner.fail('Please enter a valid directory path');
2018-03-01 12:28:29 +01:00
askPath();
2018-02-28 22:53:06 +01:00
return;
}
2018-03-01 12:28:29 +01:00
fs.access(answers.path, fs.W_OK | fs.R_OK, (error) => {
if (error) {
spinner.fail('This directory is not writable');
askPath();
return;
}
recursive(answers.path, function (error, files) {
spinner.succeed(files.length + ' files in this directory');
askDaemon();
});
2018-02-28 22:53:06 +01:00
});
});
});
};
2018-03-01 12:28:29 +01:00
// Ask for daemon mode
const askDaemon = () => {
console.log('');
inquirer.prompt([
{
type: 'confirm',
name: 'daemon',
message: 'Do you want to run the importer in daemon mode (it will poll the input directory for new files, import and delete them)?',
default: prefs.importer.daemon === true
}
]).then(answers => {
// Save daemon
prefs.importer.daemon = answers.daemon;
start();
});
};
// Start the import
const start = () => {
if (prefs.importer.daemon) {
console.log('\nPolling the input folder for new files...');
let resolve = () => {
importFiles(true, () => {
setTimeout(resolve, 30000);
});
};
resolve();
} else {
importFiles(false, () => {});
}
};
// Import the files
const importFiles = (remove, filesImported) => {
recursive(prefs.importer.path, function (error, files) {
if (files.length === 0) {
filesImported();
return;
}
let index = 0;
let resolve = () => {
const file = files[index++];
if (file) {
importFile(file, remove, resolve);
} else {
filesImported();
}
};
resolve();
});
};
// Import a file
const importFile = (file, remove, resolve) => {
const spinner = ora({
text: 'Importing: ' + file,
spinner: 'flips'
}).start();
request.put({
url: prefs.importer.baseUrl + '/api/file',
formData: {
file: fs.createReadStream(file)
}
}, function (error, response) {
if (error || !response || response.statusCode !== 200) {
spinner.fail('Upload failed for ' + file + ': ' + error);
resolve();
return;
}
spinner.succeed('Upload successful for ' + file);
if (remove) {
fs.unlinkSync(file);
}
resolve();
});
};