Skip to content

Commit ceec24f

Browse files
committed
dedup
1 parent 40cbdc0 commit ceec24f

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

src/Controllers/DatabaseController.js

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1760,18 +1760,18 @@ class DatabaseController {
17601760
throw error;
17611761
});
17621762

1763-
if (this.adapter instanceof MongoStorageAdapter) {
1764-
await this.adapter
1765-
.ensureIndex('_Idempotency', requiredIdempotencyFields, ['expire'], 'ttl', false, {
1763+
const isMongoAdapter = this.adapter instanceof MongoStorageAdapter;
1764+
const isPostgresAdapter = this.adapter instanceof PostgresStorageAdapter;
1765+
if (isMongoAdapter || isPostgresAdapter) {
1766+
let options = {};
1767+
if (isMongoAdapter) {
1768+
options = {
17661769
ttl: 0,
1767-
})
1768-
.catch(error => {
1769-
logger.warn('Unable to create TTL index for idempotency expire date: ', error);
1770-
throw error;
1771-
});
1772-
} else if (this.adapter instanceof PostgresStorageAdapter) {
1773-
const options = this.idempotencyOptions;
1774-
options.setIdempotencyFunction = true;
1770+
}
1771+
} else if (isPostgresAdapter) {
1772+
options = this.idempotencyOptions;
1773+
options.setIdempotencyFunction = true;
1774+
}
17751775
await this.adapter
17761776
.ensureIndex('_Idempotency', requiredIdempotencyFields, ['expire'], 'ttl', false, options)
17771777
.catch(error => {

0 commit comments

Comments
 (0)