public-offering
/
pad.pub0.org
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Pad: Use the Stream library to improve readability

pull/5512/head
Richard Hansen 2022-04-15 02:50:25 -04:00
parent 7c6746612c
commit 8442e002f9
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/node/db/Pad.js
View File

@ -327,8 +327,8 @@ class Pad {
* interval as is typical in code. * interval as is typical in code.
*/ */
async getChatMessages(start, end) { async getChatMessages(start, end) {
const entries = await Promise.all( const entries =
[...Array(end + 1 - start).keys()].map((i) => this.getChatMessage(start + i))); await Promise.all(Stream.range(start, end + 1).map(this.getChatMessage.bind(this)));
// sort out broken chat entries // sort out broken chat entries
// it looks like in happened in the past that the chat head was // it looks like in happened in the past that the chat head was
@ -385,8 +385,8 @@ class Pad {
await Promise.all((function* () { await Promise.all((function* () {
yield copyRecord(''); yield copyRecord('');
for (let i = 0; i <= this.head; ++i) yield copyRecord(`:revs:${i}`); yield* Stream.range(0, this.head + 1).map((i) => copyRecord(`:revs:${i}`));
for (let i = 0; i <= this.chatHead; ++i) yield copyRecord(`:chat:${i}`); yield* Stream.range(0, this.chatHead + 1).map((i) => copyRecord(`:chat:${i}`));
yield this.copyAuthorInfoToDestinationPad(destinationID); yield this.copyAuthorInfoToDestinationPad(destinationID);
if (destGroupID) yield db.setSub(`group:${destGroupID}`, ['pads', destinationID], 1); if (destGroupID) yield db.setSub(`group:${destGroupID}`, ['pads', destinationID], 1);
}).call(this)); }).call(this));