vendure/packages/dev-server/load-testing/init-load-test.ts

// tslint:disable-next-line:no-reference
/// <reference path="../../core/typings.d.ts" />
import { bootstrap, VendureConfig } from '@vendure/core';
import { populate } from '@vendure/core/cli/populate';
import { BaseProductRecord } from '@vendure/core/dist/data-import/providers/import-parser/import-parser';
import stringify from 'csv-stringify';
import fs from 'fs';
import path from 'path';

import { clearAllTables } from '../../core/mock-data/clear-all-tables';
import { initialData } from '../../core/mock-data/data-sources/initial-data';
import { populateCustomers } from '../../core/mock-data/populate-customers';
import { devConfig } from '../dev-config';

import { getLoadTestConfig, getMysqlConnectionOptions, getProductCount, getProductCsvFilePath } from './load-test-config';

// tslint:disable:no-console

/**
 * A script used to populate a database with test data for load testing.
 */
if (require.main === module) {
    // Running from command line
    isDatabasePopulated()
        .then(isPopulated => {
            if (!isPopulated) {
                const count = getProductCount();
                const config = getLoadTestConfig('bearer');
                const csvFile = getProductCsvFilePath();
                return clearAllTables(config.dbConnectionOptions, true)
                    .then(() => {
                        if (!fs.existsSync(csvFile)) {
                            return generateProductsCsv(count);
                        }
                    })
                    .then(() => populate(() => bootstrap(config),
                        path.join(__dirname, '../../create/assets/initial-data.json'),
                        csvFile,
                        path.join(__dirname, './data-sources'),
                    ))
                    .then(async app => {
                        console.log('populating customers...');
                        await populateCustomers(10, config as any, true);
                        return app.close();
                    });
            } else {
                console.log('Database is already populated!');
            }
        })
        .then(
            () => process.exit(0),
            err => {
                console.log(err);
                process.exit(1);
            },
        );
}

/**
 * Tests to see whether the load test database is already populated.
 */
function isDatabasePopulated(): Promise<boolean> {
    const mysql = require('mysql');
    const count = getProductCount();
    const mysqlConnectionOptions = getMysqlConnectionOptions(count);
    const connection = mysql.createConnection({
        host: mysqlConnectionOptions.host,
        user: mysqlConnectionOptions.username,
        password: mysqlConnectionOptions.password,
        database: mysqlConnectionOptions.database,
    });

    return new Promise<boolean>((resolve, reject) => {
        connection.connect((error: any) => {
            if (error) {
                reject(error);
                return;
            }

            connection.query('SELECT COUNT(id) as prodCount FROM product', (err: any, results: any) => {
                if (err) {
                    if (err.code === 'ER_NO_SUCH_TABLE') {
                        resolve(false);
                        return;
                    }
                    reject(err);
                    return;
                }
                resolve(results[0].prodCount === count);
            });
        });
    });

}

/**
 * Generates a CSV file of test product data which can then be imported into Vendure.
 */
function generateProductsCsv(productCount: number = 100): Promise<void> {
    const result: BaseProductRecord[] = [];

    const stringifier = stringify({
        delimiter: ',',
    });

    const data: string[] = [];

    console.log(`Generating ${productCount} rows of test product data...`);

    stringifier.on('readable', () => {
        let row;
        // tslint:disable-next-line:no-conditional-assignment
        while (row = stringifier.read()) {
            data.push(row);
        }
    });

    return new Promise((resolve, reject) => {
        const csvFile = getProductCsvFilePath();
        stringifier.on('error', (err: any) => {
            reject(err.message);
        });
        stringifier.on('finish', async () => {
            fs.writeFileSync(csvFile, data.join(''));
            console.log(`Done! Saved to ${csvFile}`);
            resolve();
        });
        generateMockData(productCount, row => stringifier.write(row));
        stringifier.end();
    });
}

function generateMockData(productCount: number, writeFn: (row: string[]) => void) {
    const headers: Array<keyof BaseProductRecord> = [
        'name',
        'slug',
        'description',
        'assets',
        'facets',
        'optionGroups',
        'optionValues',
        'sku',
        'price',
        'taxCategory',
        'variantAssets',
        'variantFacets',
    ];

    writeFn(headers);

    const categories = getCategoryNames();

    for (let i = 1; i <= productCount; i++) {
        const outputRow: BaseProductRecord = {
            name: `Product ${i}`,
            slug: `product-${i}`,
            description: generateProductDescription(),
            assets: 'product-image.jpg',
            facets: `category:${categories[i % categories.length]}`,
            optionGroups: '',
            optionValues: '',
            sku: `PRODID${i}`,
            price: (Math.random() * 1000).toFixed(2),
            taxCategory: 'standard',
            variantAssets: '',
            variantFacets: '',
        };
        writeFn(Object.values(outputRow) as string[]);
    }
}

function getCategoryNames() {
    const allNames = initialData.collections.reduce((all, c) => [...all, ...c.facetNames], [] as string[]);
    return Array.from(new Set(allNames));
}

const parts = [
    `Now equipped with seventh-generation Intel Core processors`,
    `Laptop is snappier than ever`,
    `From daily tasks like launching apps and opening files to more advanced computing`,
    `You can power through your day thanks to faster SSDs and Turbo Boost processing up to 3.6GHz`,
    `Discover a truly immersive viewing experience with this monitor curved more deeply than any other`,
    `Wrapping around your field of vision the 1,800 R screencreates a wider field of view`,
    `This pc is optimised for gaming, and is also VR ready`,
    `The Intel Core-i7 CPU and High Performance GPU give the computer the raw power it needs to function at a high level`,
    `Boost your PC storage with this internal hard drive, designed just for desktop and all-in-one PCs`,
    `Let all your colleagues know that you are typing on this exclusive, colorful klicky-klacky keyboard`,
    `Solid conductors eliminate strand-interaction distortion and reduce jitter`,
    `As the surface is made of high-purity silver`,
    `the performance is very close to that of a solid silver cable`,
    `but priced much closer to solid copper cable`,
    `With its nostalgic design and simple point-and-shoot functionality`,
    `the Instant Camera is the perfect pick to get started with instant photography`,
    `This lens is a Di type lens using an optical system with improved multi-coating designed to function with digital SLR cameras as well as film cameras`,
    `Capture vivid, professional-style photographs with help from this lightweight tripod`,
    `The adjustable-height tripod makes it easy to achieve reliable stability`,
    `Just the right angle when going after that award-winning shot`,
    `Featuring a full carbon chassis - complete with cyclocross-specific carbon fork`,
    `It's got the low weight, exceptional efficiency and brilliant handling`,
    `You'll need to stay at the front of the pack`,
    `When you're working out you need a quality rope that doesn't tangle at every couple of jumps`,
    `Training gloves designed for optimum training`,
    `Our gloves promote proper punching technique because they are conformed to the natural shape of your fist`,
    `Dense, innovative two-layer foam provides better shock absorbency`,
    `Full padding on the front, back and wrist to promote proper punching technique`,
    `With tons of space inside (for max. 4 persons), full head height throughout`,
    `This tent offers you everything you need`,
    `Based on the 1970s iconic shape, but made to a larger 69cm size`,
    `These skateboards are great for beginners to learn the foot spacing required`,
    `Perfect for all-day cruising`,
    `This football features high-contrast graphics for high-visibility during play`,
    `Its machine-stitched tpu casing offers consistent performance`,
    `With its ultra-light, uber-responsive magic foam`,
    `The Running Shoe is ready to push you to victories both large and small`,
    `A spiky yet elegant house cactus`,
    `Perfect for the home or office`,
    `Origin and habitat: Probably native only to the Andes of Peru`,
    `Gloriously elegant`,
    `It can go along with any interior as it is a neutral color and the most popular Phalaenopsis overall`,
    `2 to 3 foot stems host large white flowers that can last for over 2 months`,
    `Excellent semi-evergreen bonsai`,
    `Indoors or out but needs some winter protection`,
    `All trees sent will leave the nursery in excellent condition and will be of equal quality or better than the photograph shown`,
    `Placing it at home or office can bring you fortune and prosperity`,
    `Guards your house and ward off ill fortune`,
    `Hand trowel for garden cultivating hammer finish epoxy-coated head`,
    `For improved resistance to rust, scratches, humidity and alkalines in the soil`,
    `A charming vintage white wooden chair`,
    `Featuring an extremely spherical pink balloon`,
    `The balloon may be detached and used for other purposes`,
    `This premium, tan-brown bonded leather seat is part of the 'chill' sofa range`,
    `The lever activated recline feature makes it easy to adjust to any position`,
    `This smart, bustle back design with rounded tight padded arms has been designed with your comfort in mind`,
    `This well-padded chair has foam pocket sprung seat cushions and fibre-filled back cushions`,
    `Modern tapered white polycotton pendant shade with a metallic silver chrome interior`,
    `For maximum light reflection`,
    `Reversible gimble so it can be used as a ceiling shade or as a lamp shade`,
];
function generateProductDescription(): string {
    const take = Math.ceil(Math.random() * 4);
    return shuffle(parts).slice(0, take)
        .join('. ');
}

/**
 * Returns new copy of array in random order.
 * https://stackoverflow.com/a/6274381/772859
 */
function shuffle<T>(arr: T[]): T[] {
    const a = arr.slice();
    for (let i = a.length - 1; i > 0; i--) {
        const j = Math.floor(Math.random() * (i + 1));
        [a[i], a[j]] = [a[j], a[i]];
    }
    return a;
}