Skip to content
Snippets Groups Projects
Commit a3f7abd4 authored by Cédric Moreau's avatar Cédric Moreau
Browse files

[fix] dao: peers collection could contain empty peers

parent 812d32c8
No related branches found
No related tags found
No related merge requests found
...@@ -8,6 +8,11 @@ export class LokiPeer extends LokiCollectionManager<DBPeer> implements PeerDAO { ...@@ -8,6 +8,11 @@ export class LokiPeer extends LokiCollectionManager<DBPeer> implements PeerDAO {
super(loki, 'peer', ['pubkey']) super(loki, 'peer', ['pubkey'])
} }
async init(): Promise<void> {
await super.init();
this.cleanEmptyPeers()
}
cleanCache(): void { cleanCache(): void {
} }
...@@ -84,6 +89,14 @@ export class LokiPeer extends LokiCollectionManager<DBPeer> implements PeerDAO { ...@@ -84,6 +89,14 @@ export class LokiPeer extends LokiCollectionManager<DBPeer> implements PeerDAO {
.remove() .remove()
} }
async cleanEmptyPeers(): Promise<void> {
this.collection
.chain()
.find({})
.where(p => !p.endpoints || !p.endpoints.length)
.remove()
}
async getPeersWithEndpointsLike(ep: string): Promise<DBPeer[]> { async getPeersWithEndpointsLike(ep: string): Promise<DBPeer[]> {
return this.collection return this.collection
.chain() .chain()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment