From e7d038544bd80f5085cf6df07011fb700ac9d76c Mon Sep 17 00:00:00 2001
From: cgeek <cem.moreau@gmail.com>
Date: Mon, 22 Aug 2022 13:01:28 +0200
Subject: [PATCH] fix(1434): put back value of `expires_on`, not `expired_on`
---
.../leveldb/indexers/LevelMIndexExpiresOnIndexer.ts | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/app/lib/dal/indexDAL/leveldb/indexers/LevelMIndexExpiresOnIndexer.ts b/app/lib/dal/indexDAL/leveldb/indexers/LevelMIndexExpiresOnIndexer.ts
index 2548c87d1..eee21312e 100644
--- a/app/lib/dal/indexDAL/leveldb/indexers/LevelMIndexExpiresOnIndexer.ts
+++ b/app/lib/dal/indexDAL/leveldb/indexers/LevelMIndexExpiresOnIndexer.ts
@@ -91,12 +91,12 @@ export class LevelMIndexExpiresOnIndexer extends LevelDBDataIndex<
const values: MindexEntry[] = Underscore.values(
newStateByPub
).map((entries) => reduce(entries));
- const byExpiredOn = reduceGroupBy(values, "expired_on");
+ const byExpiresOnForExpired = reduceGroupBy(values, "expires_on");
await Promise.all(
- Underscore.keys(byExpiredOn).map(async (expiresOn) =>
+ Underscore.keys(byExpiresOnForExpired).map(async (expiresOn) =>
this.addAllKeysToExpiresOn(
pint(expiresOn),
- byExpiredOn[expiresOn].map((e) => e.pub)
+ byExpiresOnForExpired[expiresOn].map((e) => e.pub)
)
)
);
@@ -112,7 +112,9 @@ export class LevelMIndexExpiresOnIndexer extends LevelDBDataIndex<
entry = [];
}
for (const pub of pubkeys) {
- entry.push(pub);
+ if (!entry.includes(pub)) {
+ entry.push(pub);
+ }
}
await this.put(key, entry);
}
--
GitLab