Skip to content

Commit b9a3bcb

Browse files
committed
Update PublicKeysRepository.ts
1 parent 0fe9728 commit b9a3bcb

1 file changed

Lines changed: 16 additions & 5 deletions

File tree

src/src/db/repositories/PublicKeysRepository.ts

Lines changed: 16 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,12 @@
1-
import { AnyBulkWriteOperation, Binary, ClientSession, Collection, Db, Document, Filter, } from 'mongodb';
1+
import {
2+
AnyBulkWriteOperation,
3+
Binary,
4+
ClientSession,
5+
Collection,
6+
Db,
7+
Document,
8+
Filter,
9+
} from 'mongodb';
210
import { OPNetCollections } from '../indexes/required/IndexedCollection.js';
311
import { PublicKeyDocument } from '../interfaces/PublicKeyDocument.js';
412
import { ExtendedBaseRepository } from './ExtendedBaseRepository.js';
@@ -384,11 +392,14 @@ export class PublicKeysRepository extends ExtendedBaseRepository<PublicKeyDocume
384392

385393
private async getKeyInfoFromContracts(
386394
key: string,
395+
isPublicKey: boolean,
387396
): Promise<PublicKeyWithMLDSA | IPubKeyNotFoundError> {
388397
try {
389-
const filter: Filter<IContractDocument> = {
390-
$or: [{ contractAddress: key }, { contractPublicKey: new Binary(fromHex(key)) }],
391-
};
398+
const filter: Filter<IContractDocument> = isPublicKey
399+
? {
400+
contractPublicKey: new Binary(fromHex(key)),
401+
}
402+
: { contractAddress: key };
392403

393404
const resp = await this.getContractCollection().findOne(filter, {
394405
projection: {
@@ -482,7 +493,7 @@ export class PublicKeysRepository extends ExtendedBaseRepository<PublicKeyDocume
482493
};
483494
}
484495

485-
return await this.getKeyInfoFromContracts(key);
496+
return await this.getKeyInfoFromContracts(key, isPublicKey);
486497
}
487498
}
488499

0 commit comments

Comments
 (0)