Importing Data

... ,product:featuredReview... ,"{ ""id"": 123 }"

... ,product:keywords... ,tablet|pad|android

import { InitialData, LanguageCode } from '@vendure/core';export const initialData: InitialData = {    paymentMethods: [        {            name: 'Standard Payment',            handler: {                code: 'dummy-payment-handler',                arguments: [{ name: 'automaticSettle', value: 'false' }],            },        },    ],    roles: [        {            code: 'administrator',            description: 'Administrator',            permissions: [                Permission.CreateCatalog,                Permission.ReadCatalog,                Permission.UpdateCatalog,                Permission.DeleteCatalog,                Permission.CreateSettings,                Permission.ReadSettings,                Permission.UpdateSettings,                Permission.DeleteSettings,                Permission.CreateCustomer,                Permission.ReadCustomer,                Permission.UpdateCustomer,                Permission.DeleteCustomer,                Permission.CreateCustomerGroup,                Permission.ReadCustomerGroup,                Permission.UpdateCustomerGroup,                Permission.DeleteCustomerGroup,                Permission.CreateOrder,                Permission.ReadOrder,                Permission.UpdateOrder,                Permission.DeleteOrder,                Permission.CreateSystem,                Permission.ReadSystem,                Permission.UpdateSystem,                Permission.DeleteSystem,            ],        },    ],    defaultLanguage: LanguageCode.en,    countries: [        { name: 'Austria', code: 'AT', zone: 'Europe' },        { name: 'Malaysia', code: 'MY', zone: 'Asia' },        { name: 'United Kingdom', code: 'GB', zone: 'Europe' },    ],    defaultZone: 'Europe',    taxRates: [        { name: 'Standard Tax', percentage: 20 },        { name: 'Reduced Tax', percentage: 10 },        { name: 'Zero Tax', percentage: 0 },    ],    shippingMethods: [{ name: 'Standard Shipping', price: 500 }, { name: 'Express Shipping', price: 1000 }],    collections: [        {            name: 'Electronics',            filters: [                {                    code: 'facet-value-filter',                    args: { facetValueNames: ['Electronics'], containsAny: false },                },            ],            assetPaths: ['jakob-owens-274337-unsplash.jpg'],        },    ],};

import { bootstrap, DefaultJobQueuePlugin } from '@vendure/core';import { populate } from '@vendure/core/cli';import path from "path";import { config } from './vendure-config';import { initialData } from './my-initial-data';const productsCsvFile = path.join(__dirname, 'path/to/products.csv')const populateConfig = {    ...config,    plugins: (config.plugins || []).filter(        // Remove your JobQueuePlugin during populating to avoid        // generating lots of unnecessary jobs as the Collections get created.        plugin => plugin !== DefaultJobQueuePlugin,    ),}populate(    () => bootstrap(populateConfig),    initialData,    productsCsvFile,    'my-channel-token' // optional - used to assign imported )                      // entities to the specified Channel    .then(app => {        return app.close();    })    .then(        () => process.exit(0),        err => {            console.log(err);            process.exit(1);        },    );

import { populate } from '@vendure/core/cli';import { bootstrap, VendureConfig } from '@vendure/core';import path from 'path';import { config } from './vendure-config';populate(    () => bootstrap({        ...config,        importExportOptions: {            importAssetsDir: path.join(                require.resolve('@vendure/create/assets/products.csv'),                '../images'            ),        },        dbConnectionOptions: {...config.dbConnectionOptions, synchronize: true}    }),    require('@vendure/create/assets/initial-data.json'),    require.resolve('@vendure/create/assets/products.csv'))    .then(app => app.close())    .catch(err => {        console.log(err);        process.exit(1);    });

import { INestApplicationContext } from '@nestjs/common';import {    ProductVariantService,    TransactionalConnection,    LanguageCode,    RequestContext,    RequestContextService,    bootstrapWorker,    ConfigService,    ID,    User,    SearchService,} from '@vendure/core';import { config } from './vendure-config';async function createNewVariantService() {    // We use the bootstrapWorker() function instead of bootstrap() because we don't    // need to start the server, we just need access to the services.    const { app } = await bootstrapWorker(config);    // Most service methods require a RequestContext, so we'll create one here.    const ctx = await getSuperadminContext(app);    // Get the ProductVariantService instance from the application    const productVariantService = app.get(ProductVariantService);    // To reindex after importing products    const searchService = app.get(SearchService);    // Example: Creating a new ProductVariant for an existing product with ID 1    const productId = '1' as ID;    // Create input data for the new variant    const variantInput = {        productId,        translations: [            {                languageCode: LanguageCode.en,                name: 'New Variant 1',            },        ],        sku: 'NEW-VARIANT-001',        // Specify additional variant properties...    };    // Create the variant    const newVariants = await productVariantService.create(ctx, [variantInput]);    console.log('Created new product variants:', newVariants);    // Rebuild search index to include the new variant    await searchService.reindex(ctx);    await app.close();}/** * Creates a RequestContext configured for the default Channel with the activeUser set * as the superadmin user. */export async function getSuperadminContext(app: INestApplicationContext): Promise<RequestContext> {    const {superadminCredentials} = app.get(ConfigService).authOptions;    const superAdminUser = await app.get(TransactionalConnection)        .getRepository(User)        .findOneOrFail({where: {identifier: superadminCredentials.identifier}});    return app.get(RequestContextService).create({        apiType: 'admin',        user: superAdminUser,    });}

import { INestApplicationContext } from '@nestjs/common';import {    bootstrapWorker,    ConfigService,    Importer,    LanguageCode,    ParsedProductWithVariants,    RequestContext, RequestContextService,    TransactionalConnection, User,    SearchService,} from '@vendure/core';import { createClient, OldCommerceProduct } from '@old-commerce/client';import { config } from './vendure-config';if (require.main === module) {    importData().then(        () => process.exit(0),        err => {            console.log(err);            process.exit(1);        },    );}async function importData() {    // We use the bootstrapWorker() function instead of bootstrap() because we don't     // need to start the server, we just need access to the services.    const {app} = await bootstrapWorker(config);    // Create an instace of the client we'll be using to interact with the    // OldCommerce API    const client = createClient({        // OldCommerce client config    });    // Let's grab a reference to each of the Vendure services we'll need.    const importer = app.get(Importer);    // Most service methods require a RequestContext, so we'll create one here.    const ctx = await getSuperadminContext(app);    // To reindex after importing products    const searchService = app.get(SearchService);    // Fetch all the products to import from the OldCommerce API    const productsToImport: OldCommerceProduct[] = await client.getAllProducts();    // Transform the OldCommerce products into the format expected by the Importer    const importRows: ParsedProductWithVariants[] = productsToImport.map(product => ({        product: {            translations: [                {                    languageCode: LanguageCode.en,                    name: product.name,                    slug: product.slug,                    description: product.description,                    customFields: {},                },            ],            assetPaths: product.images.map(image => image.sourceUrl),            facets: [],            optionGroups: product.options.map(option => ({                translations: [                    {                        languageCode: LanguageCode.en,                        name: option.name,                        values: option.values.map(value => value.name),                    },                ],            })),        },        variants: product.variations.map(variation => {            const optionValues = variation.options.map(option => option.value);            return {                sku: variation.productCode,                price: variation.price,                stockOnHand: variation.stock,                translations: [{languageCode: LanguageCode.en, optionValues}],            };        }),    }));    // Import the products    await importer.importProducts(ctx, importRows, progress => {        console.log(`Imported ${progress.imported} of ${importRows.length} products`);    });    // Rebuild search index     await searchService.reindex(ctx);    // Close the app    await app.close();}/** * Creates a RequestContext configured for the default Channel with the activeUser set * as the superadmin user. */export async function getSuperadminContext(app: INestApplicationContext): Promise<RequestContext> {    const {superadminCredentials} = app.get(ConfigService).authOptions;    const superAdminUser = await app.get(TransactionalConnection)        .getRepository(User)        .findOneOrFail({where: {identifier: superadminCredentials.identifier}});    return app.get(RequestContextService).create({        apiType: 'admin',        user: superAdminUser,    });}