All files / dist/src utils.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.validateConfig = exports.runServer = exports.getRoutesListOutput = exports.onRestapifyInstanceError = exports.getInstanceOverviewOutput = exports.consoleError = exports.getMethodOutput = void 0;
const chalk = require("chalk");
const boxen = require("boxen");
const jsonschema_1 = require("jsonschema");
const restapify_1 = require("restapify");
const getMethodOutput = (method) => {
    let methodOutput;
    switch (method) {
        case 'DELETE':
            methodOutput = chalk.red;
            break;
        case 'POST':
            methodOutput = chalk.yellow;
            break;
        case 'PUT':
            methodOutput = chalk.blue;
            break;
        case 'PATCH':
            methodOutput = chalk.gray;
            break;
        default:
        case 'GET':
            methodOutput = chalk.green;
            break;
    }
    let methodName = method;
    let methodNameLength = method.length;
    for (let index = 0; index < (6 - methodNameLength); index += 1) {
        methodName += ' ';
    }
    methodOutput = methodOutput.bold(`${methodName}`);
    return methodOutput;
};
exports.getMethodOutput = getMethodOutput;
const consoleError = (message) => {
    const errorPrepend = chalk.red.bold.underline('❌ERROR:');
    console.log(`${errorPrepend} ${message}`);
};
exports.consoleError = consoleError;
const getInstanceOverviewOutput = (port, apiBaseURL) => {
    const runningTitle = chalk.magenta('🚀 Restapify is running:');
    const apiBaseURLTitle = chalk.bold('- 📦API base url:');
    const apiBaseURLLink = chalk.blueBright(`http://localhost:${port}${apiBaseURL}`);
    const dashboardURLTitle = chalk.bold('- 🎛 Dashboard:');
    const dashboardURLLink = chalk.blueBright(`http://localhost:${port}/restapify`);
    const apiBaseURLOutput = `${apiBaseURLTitle} ${apiBaseURLLink}`;
    const dashboardURLOutput = `${dashboardURLTitle} ${dashboardURLLink}`;
    return boxen(`${runningTitle}\n\n${apiBaseURLOutput}\n${dashboardURLOutput} `, { padding: 1, borderColor: 'magenta' });
};
exports.getInstanceOverviewOutput = getInstanceOverviewOutput;
const onRestapifyInstanceError = (error, instanceData) => {
    const { rootDir, port, apiBaseUrl } = instanceData;
    if (error.startsWith('MISS:ROOT_DIR')) {
        exports.consoleError(`The given folder ${rootDir} doesn't exist!`);
    }
    else if (error.startsWith('MISS:PORT')) {
        exports.consoleError(`port ${port} is already in use!`);
    }
    else if (error.startsWith('INV:API_BASEURL')) {
        exports.consoleError(`Impossible to use ${apiBaseUrl} as the API base URL since it's already needed for internal purposes!`);
    }
    else if (error.startsWith('INV:JSON_FILE')) {
        const filePath = error.split(' ')[1];
        exports.consoleError(`Impossible to parse the JSON file ${filePath}!`);
    }
};
exports.onRestapifyInstanceError = onRestapifyInstanceError;
const getRoutesListOutput = (routesList, apiBaseUrl) => {
    let output = '';
    routesList.forEach(servedRoute => {
        let methodOutput = exports.getMethodOutput(servedRoute.method);
        output += `\n${methodOutput} ${apiBaseUrl}${servedRoute.route}`;
    });
    return output;
};
exports.getRoutesListOutput = getRoutesListOutput;
const runServer = (config) => {
    const RestapifyInstance = new restapify_1.default(config);
    RestapifyInstance.on('server:start', () => {
        console.log(`\n🏗 Try to serve on port ${RestapifyInstance.port}`);
    });
    RestapifyInstance.onError(({ error }) => {
        exports.onRestapifyInstanceError(error, {
            rootDir: RestapifyInstance.rootDir,
            apiBaseUrl: RestapifyInstance.apiBaseUrl,
            port: RestapifyInstance.port
        });
    });
    RestapifyInstance.on('start', () => {
        const servedRoutesOutput = exports.getRoutesListOutput(RestapifyInstance.getServedRoutes(), RestapifyInstance.apiBaseUrl);
        console.log(servedRoutesOutput);
        console.log(exports.getInstanceOverviewOutput(RestapifyInstance.port, RestapifyInstance.apiBaseUrl));
    });
    RestapifyInstance.on('server:restart', () => {
        console.log(chalk.green('✅ API updated!'));
    });
    RestapifyInstance.run();
};
exports.runServer = runServer;
const validateConfig = (config) => {
    const jsonValidor = new jsonschema_1.Validator();
    const CONFIG_FILE_SCHEMA = {
        type: 'object',
        rootDir: { type: 'string' },
        apiBaseUrl: { type: 'string' },
        port: { type: 'number' },
        states: {
            properties: {
                route: 'string',
                method: 'string',
                state: 'string'
            },
            required: ['route', 'method', 'state']
        },
        required: ['rootDir']
    };
    return jsonValidor.validate(config, CONFIG_FILE_SCHEMA);
};
exports.validateConfig = validateConfig;