Skip to content

Commit 164e5a7

Browse files
committed
nits
1 parent 9e7a8f5 commit 164e5a7

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

spec/PostgresStorageAdapter.spec.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,7 @@ describe_only_db('postgres')('PostgresStorageAdapter', () => {
437437
const qs = "SELECT format('%I.%I(%s)', ns.nspname, p.proname, oidvectortypes(p.proargtypes)) FROM pg_proc p INNER JOIN pg_namespace ns ON (p.pronamespace = ns.oid) WHERE p.proname = 'idempotency_delete_expired_records'";
438438
const foundFunction = await client.one(qs);
439439
expect(foundFunction.format).toBe("public.idempotency_delete_expired_records()");
440-
await adapter.deleteIdempodencyFunction();
440+
await adapter.deleteIdempotencyFunction();
441441
await client.none(qs);
442442
});
443443
});

src/Adapters/Storage/Postgres/PostgresStorageAdapter.js

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2407,17 +2407,17 @@ export class PostgresStorageAdapter implements StorageAdapter {
24072407
? fieldNames.map((fieldName, index) => `lower($${index + 3}:name) varchar_pattern_ops`)
24082408
: fieldNames.map((fieldName, index) => `$${index + 3}:name`);
24092409
const qs = `CREATE INDEX IF NOT EXISTS $1:name ON $2:name (${constraintPatterns.join()})`;
2410-
const setIdempodencyFunction = options.setIdempodencyFunction !== undefined ? options.setIdempodencyFunction : false;
2411-
if (setIdempodencyFunction) {
2412-
await this.ensureIdempodencyFunctionExists(options);
2410+
const setIdempotencyFunction = options.setIdempotencyFunction !== undefined ? options.setIdempotencyFunction : false;
2411+
if (setIdempotencyFunction) {
2412+
await this.ensureIdempotencyFunctionExists(options);
24132413
}
24142414
await conn.none(qs, [indexNameOptions.name, className, ...fieldNames])
24152415
.catch(error => {
24162416
throw error;
24172417
});
24182418
}
24192419
2420-
async deleteIdempodencyFunction(
2420+
async deleteIdempotencyFunction(
24212421
options?: Object = {}
24222422
): Promise<any> {
24232423
const conn = options.conn !== undefined ? options.conn : this._client;
@@ -2429,7 +2429,7 @@ export class PostgresStorageAdapter implements StorageAdapter {
24292429
});
24302430
}
24312431
2432-
async ensureIdempodencyFunctionExists(
2432+
async ensureIdempotencyFunctionExists(
24332433
options?: Object = {}
24342434
): Promise<any> {
24352435
const conn = options.conn !== undefined ? options.conn : this._client;

src/Controllers/DatabaseController.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1771,7 +1771,7 @@ class DatabaseController {
17711771
});
17721772
} else if (this.adapter instanceof PostgresStorageAdapter) {
17731773
const options = this.idempotencyOptions;
1774-
options.setIdempodencyFunction = true;
1774+
options.setIdempotencyFunction = true;
17751775
await this.adapter
17761776
.ensureIndex('_Idempotency', requiredIdempotencyFields, ['expire'], 'ttl', false, options)
17771777
.catch(error => {

0 commit comments

Comments
 (0)