paging.ts

/*
Wire up directly with Keycloak and use the Services
To run:
npm run ts-build
npm run ts-watch
node dist/test/integrated/batchworker/paging.js
*/

import InitKeystone from '../keystonejs/init';
import {
  getRecords,
  parseJsonString,
  transformAllRefID,
  removeEmpty,
  removeKeys,
  syncRecords,
} from '../../../batch/feed-worker';
import { o } from '../util';
import { BatchService } from '../../../services/keystone/batch-service';
import { newEnvironmentID, newProductID } from '../../../services/identifiers';

(async () => {
  const keystone = await InitKeystone();
  console.log('K = ' + keystone);

  const ns = 'platform';
  const skipAccessControl = false;

  const identity = {
    id: null,
    username: 'sample_username',
    namespace: ns,
    roles: JSON.stringify(['api-owner']),
    scopes: [],
    userId: null,
  } as any;

  const ctx = keystone.createContext({
    skipAccessControl,
    authentication: { item: identity },
  });

  if (false) {
    const json = {
      name: 'Refactor Time Test2',
      namespace: ns,
      environments: [
        {
          name: 'stage',
          appId: '0A021EB0',
          //services: [] as any,
          //services: ['a-service-for-refactortime'],
          // services: ['a-service-for-refactortime', 'a-service-for-aps-moh-proto'],
        },
      ] as any,
    };
    const res = await syncRecords(ctx, 'Product', null, json);
    o(res);
  }
  if (false) {
    for (let i = 0; i < 1000; i++) {
      const appId = newProductID();
      console.log(appId);
      const json = {
        name: 'Refactor Time Test 4',
        appId: appId,
        namespace: ns,
        environments: [
          {
            name: 'stage',
            appId: newEnvironmentID(),
            services: [] as any,
          },
        ],
      };
      const res = await syncRecords(ctx, 'Product', appId, json);
      o(res);
    }
  }

  const batchService = new BatchService(ctx);

  const res = await batchService.listAllPages('allProducts', [
    'name',
    'namespace',
    'dataset { title }',
    'createdAt',
  ]);
  //console.log(res);
  await keystone.disconnect();
})();