larvit/smpp-js
3
0
Fork 0
Code Issues Pull Requests 1 Actions Activity

Give the held-message protocol one home in MessageHold #35

Merged
lilleman merged 3 commits from message-hold into main 2026-09-28 01:06:45 +02:00
Conversation 0 Commits 3 Files Changed 5
+13 -15
1 changed files with 13 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 9dda1a6917 - Show all commits
test/session-extras.test.ts
+13 -15
View File
@@ -1502,15 +1502,14 @@ describe('held message bounds', () => {
test('is full at its count, and a re-used sequence number replaces rather than adding', () => { test('is full at its count, and a re-used sequence number replaces rather than adding', () => {
const held = new HeldMessages({ log: silentLog, max: 2, maxOctets: 1_000_000, timeout: 10_000 }); const held = new HeldMessages({ log: silentLog, max: 2, maxOctets: 1_000_000, timeout: 10_000 });
const first = message(1); const first = held.hold(message(1), 1);
held.hold(first); held.hold(message(2), 1);
held.hold(message(2)); held.hold(message(2), 1);
held.hold(message(2));
assert.equal(held.size, 2); assert.equal(held.size, 2);
assert.equal(held.full(), true); assert.equal(held.full(), true);
assert.equal(held.has(first), true); assert.equal(first.isHeld(), true);
held.clear(); held.clear();
}); });
@@ -1519,23 +1518,22 @@ describe('held message bounds', () => {
test('is full at its octet cap, until a message leaves by any way out', () => { test('is full at its octet cap, until a message leaves by any way out', () => {
let now = 0; let now = 0;
const held = new HeldMessages({ log: silentLog, max: 10, maxOctets: 2000, now: () => now, timeout: 10_000 }); const held = new HeldMessages({ log: silentLog, max: 10, maxOctets: 2000, now: () => now, timeout: 10_000 });
const answered = message(1); const answered = held.hold(message(1), 1);
held.hold(answered);
assert.equal(held.full(), false); assert.equal(held.full(), false);
held.hold(message(2)); held.hold(message(2), 1);
assert.equal(held.full(), true); assert.equal(held.full(), true);
held.release(answered); answered.release();
assert.equal(held.full(), false, 'after a release'); assert.equal(held.full(), false, 'after a release');
held.hold(message(3)); held.hold(message(3), 1);
now = 20_000; now = 20_000;
held.sweep(); held.sweep();
now = 0; now = 0;
assert.equal(held.full(), false, 'after a sweep'); assert.equal(held.full(), false, 'after a sweep');
held.hold(message(4)); held.hold(message(4), 1);
held.hold(message(5)); held.hold(message(5), 1);
held.clear(); held.clear();
assert.equal(held.full(), false, 'after a clear'); assert.equal(held.full(), false, 'after a clear');
@@ -1624,11 +1622,11 @@ describe('held message bounds', () => {
let now = 0; let now = 0;
const held = new HeldMessages({ log: silentLog, max: 10, maxOctets: 1_000_000, now: () => now, timeout: 60 }); const held = new HeldMessages({ log: silentLog, max: 10, maxOctets: 1_000_000, now: () => now, timeout: 60 });
held.hold(message(1)); held.hold(message(1), 1);
now = 61; now = 61;
// The next message sweeps the one that expired, so only the new one is still waited for. // The next message sweeps the one that expired, so only the new one is still waited for.
held.hold(message(2)); held.hold(message(2), 1);
assert.equal(held.size, 1); assert.equal(held.size, 1);
@@ -1640,7 +1638,7 @@ describe('held message bounds', () => {
let now = 0; let now = 0;
const held = new HeldMessages({ log: silentLog, max: 10, maxOctets: 1_000_000, now: () => now, timeout: 60 }); const held = new HeldMessages({ log: silentLog, max: 10, maxOctets: 1_000_000, now: () => now, timeout: 60 });
held.hold(message(1)); held.hold(message(1), 1);
const waiting = held.idle(1000, undefined); const waiting = held.idle(1000, undefined);