chore(core): Add a test plugin for issue 1433

Relates to #1433

packages/dev-server/test-plugins/fill-buffer-plugin.ts

@@ -0,0 +1,62 @@
+import { Mutation, Query, Resolver } from '@nestjs/graphql';
+import {
+    CollectionService,
+    Ctx,
+    Logger,
+    PluginCommonModule,
+    ProductVariantService,
+    RequestContext,
+    VendurePlugin,
+} from '@vendure/core';
+import gql from 'graphql-tag';
+
+@Resolver()
+class FillBufferResolver {
+    constructor(
+        private productVariantService: ProductVariantService,
+        private collectionService: CollectionService,
+    ) {}
+
+    @Mutation()
+    async fillBuffer(@Ctx() ctx: RequestContext) {
+        const { items: variants } = await this.productVariantService.findAll(ctx);
+        const { items: collections } = await this.collectionService.findAll(ctx);
+        const limit = 2000;
+        for (let i = 0; i < limit; i++) {
+            const variant = variants[i % variants.length];
+            await this.productVariantService.update(ctx, [
+                {
+                    id: variant.id,
+                    enabled: !variant.enabled,
+                },
+            ]);
+            const collection = collections[i % collections.length];
+            await this.collectionService.update(ctx, {
+                id: collection.id,
+                isPrivate: !collection.isPrivate,
+            });
+            if (i % 100 === 0) {
+                Logger.info(`Updated ${i} / ${limit} items...`);
+            }
+        }
+        Logger.info(`Done!`);
+        return true;
+    }
+}
+
+/**
+ * Plugin to create a lot of buffered jobs to test help investigate and fix
+ * issue https://github.com/vendure-ecommerce/vendure/issues/1433
+ */
+@VendurePlugin({
+    imports: [PluginCommonModule],
+    adminApiExtensions: {
+        schema: gql`
+            extend type Mutation {
+                fillBuffer: Boolean!
+            }
+        `,
+        resolvers: [FillBufferResolver],
+    },
+})
+export class FillBufferPlugin {}