diff --git a/src/backend/tests/cache/cache.test.ts b/src/backend/tests/cache/cache.test.ts index d2580efb..795cf5e3 100644 --- a/src/backend/tests/cache/cache.test.ts +++ b/src/backend/tests/cache/cache.test.ts @@ -166,7 +166,7 @@ describe('#Caching', function () { const test = new TestScrobbler(); await test.initialize(); const plays = generatePlays(100); - test.queueScrobble(plays, 'testSource'); + await test.queueScrobble(plays, 'testSource'); const queued = test.queuedScrobbles.map(x => x.play); await sleep(101); const dirContents = await promises.readdir('.'); diff --git a/src/backend/tests/scrobbler/scrobblers.test.ts b/src/backend/tests/scrobbler/scrobblers.test.ts index f860aa52..f6b4f47b 100644 --- a/src/backend/tests/scrobbler/scrobblers.test.ts +++ b/src/backend/tests/scrobbler/scrobblers.test.ts @@ -515,7 +515,7 @@ describe('Upstream Scrobbles', function() { playDate: dayjs() }); - testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); assert.isTrue(testScrobbler.shouldRefreshScrobble()); }); @@ -524,7 +524,7 @@ describe('Upstream Scrobbles', function() { playDate: dayjs().subtract(120, 'seconds') }); - testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); assert.isTrue(testScrobbler.shouldRefreshScrobble()); }); @@ -535,7 +535,7 @@ describe('Upstream Scrobbles', function() { playDate: dayjs().subtract(80, 'seconds') }); - testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); assert.isTrue(testScrobbler.shouldRefreshScrobble()); }); @@ -545,7 +545,7 @@ describe('Upstream Scrobbles', function() { playDate: dayjs().subtract(80, 'seconds') }); - testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); assert.isFalse(testScrobbler.shouldRefreshScrobble()); }); }); @@ -602,7 +602,7 @@ describe('Scrobble client uses transform plays correctly', function() { const newScrobble = generatePlay({ track: 'my cool track' }); - testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); expect(testScrobbler.queuedScrobbles[0].play.data.track).is.eq('my cool track'); testScrobbler.scrobbleSleep = 100; testScrobbler.initScrobbleMonitoring().catch(console.error); @@ -678,7 +678,7 @@ describe('Manages scrobble queue', function() { const newScrobble = generatePlay({ playDate: normalizedWithMixedDur[normalizedWithMixedDur.length - 3].data.playDate.add(3, 'seconds') }); - testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); const res = await Promise.race([pEvent(testScrobbler.emitter, 'scrobble'), sleep(3000)]); assert.isDefined(res); @@ -694,13 +694,13 @@ describe('Manages scrobble queue', function() { const dupScrobble = clone(newScrobble); dupScrobble.data.playDate = newScrobble.data.playDate.add(2, 'seconds'); - testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); const res = await Promise.race([pEvent(testScrobbler.emitter, 'scrobble'), sleep(1500)]); assert.isDefined(res); assert.isDefined(res.data); - testScrobbler.queueScrobble(dupScrobble, 'test'); + await testScrobbler.queueScrobble(dupScrobble, 'test'); const resDup = await Promise.race([pEvent(testScrobbler.emitter, 'scrobble'), sleep(1100)]); assert.isUndefined(resDup); @@ -715,8 +715,8 @@ describe('Manages scrobble queue', function() { const dupScrobble = clone(newScrobble); dupScrobble.data.playDate = newScrobble.data.playDate.add(2, 'seconds'); - testScrobbler.queueScrobble(newScrobble, 'test'); - testScrobbler.queueScrobble(dupScrobble, 'test'); + await testScrobbler.queueScrobble(newScrobble, 'test'); + await testScrobbler.queueScrobble(dupScrobble, 'test'); const res = await Promise.race([pEvent(testScrobbler.emitter, 'scrobble'), sleep(1500)]); assert.isDefined(res); @@ -742,7 +742,7 @@ describe('Manages scrobble queue', function() { testScrobbler.scrobbleDelay = 600; - testScrobbler.queueScrobble([newScrobble1, newScrobble2, newScrobble3], 'test'); + await testScrobbler.queueScrobble([newScrobble1, newScrobble2, newScrobble3], 'test'); await pEvent(testScrobbler.emitter, 'scrobble'); const initial = dayjs(); await pEvent(testScrobbler.emitter, 'scrobble');