Skip to content

Commit

Permalink
Update tests to pass
Browse files Browse the repository at this point in the history
  • Loading branch information
darunrs committed Aug 14, 2024
1 parent af00c8b commit c975259
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 57 deletions.
22 changes: 0 additions & 22 deletions runner/src/provisioner/provisioner.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -190,28 +190,6 @@ describe('Provisioner', () => {
});
});

describe('isUserApiProvisioned', () => {
it('returns false if datasource doesnt exists', async () => {
hasuraClient.doesSourceExist = jest.fn().mockReturnValueOnce(false);

await expect(provisioner.isProvisioned(indexerConfig)).resolves.toBe(false);
});

it('returns false if datasource and schema dont exists', async () => {
hasuraClient.doesSourceExist = jest.fn().mockReturnValueOnce(false);
hasuraClient.doesSchemaExist = jest.fn().mockReturnValueOnce(false);

await expect(provisioner.isProvisioned(indexerConfig)).resolves.toBe(false);
});

it('returns true if datasource and schema exists', async () => {
hasuraClient.doesSourceExist = jest.fn().mockReturnValueOnce(true);
hasuraClient.doesSchemaExist = jest.fn().mockReturnValueOnce(true);

await expect(provisioner.isProvisioned(indexerConfig)).resolves.toBe(true);
});
});

describe('provisionUserApi', () => {
it('provisions an API for the user', async () => {
await provisioner.provisionUserApi(indexerConfig);
Expand Down
18 changes: 0 additions & 18 deletions runner/src/provisioner/provisioner.ts
Original file line number Diff line number Diff line change
Expand Up @@ -166,24 +166,6 @@ export default class Provisioner {
);
}

async isProvisioned (indexerConfig: ProvisioningConfig): Promise<boolean> {
const checkProvisioningSpan = this.tracer.startSpan('Check if indexer is provisioned');

const databaseName = indexerConfig.databaseName();
const schemaName = indexerConfig.schemaName();

const sourceExists = await this.hasuraClient.doesSourceExist(databaseName);
if (!sourceExists) {
return false;
}

const schemaExists = await this.hasuraClient.doesSchemaExist(databaseName, schemaName);

checkProvisioningSpan.end();

return schemaExists;
}

async createSchema (databaseName: string, schemaName: string): Promise<void> {
return await wrapError(async () => await this.hasuraClient.createSchema(databaseName, schemaName), 'Failed to create schema');
}
Expand Down
17 changes: 0 additions & 17 deletions runner/src/server/services/data-layer/data-layer-service.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -67,23 +67,6 @@ describe('DataLayerService', () => {
});

describe('StartProvisioningTask', () => {
it('returns FAILED_PRECONDITION if already provisioned', (done) => {
const provisioner = {
isProvisioned: jest.fn().mockResolvedValue(true)
} as unknown as Provisioner;
const tasks = {};
const call = {
request: { accountId: 'testAccount', functionName: 'testFunction', schema: 'testSchema' }
} as unknown as ServerUnaryCall<any, any>;
const callback = (error: any): void => {
expect(error.code).toBe(status.FAILED_PRECONDITION);
expect(error.details).toBe('Data Layer is already provisioned');
done();
};

createDataLayerService(provisioner, tasks).StartProvisioningTask(call, callback);
});

it('should start a new provisioning task', (done) => {
const tasks: Record<any, any> = {};
const provisioner = {
Expand Down

0 comments on commit c975259

Please sign in to comment.