fix: test broken

Author: stanley2058

src/api.js

@@ -354,7 +354,7 @@ export class Api {
           await this.store.persistDoc(room, docid, ydoc)
         } else logWorker(`skip persisting room: ${room} due to no changes`)
         await promise.all([
-          storeReferences ? this.store.deleteReferences(room, docid, storeReferences) : promise.resolve(),
+          storeReferences && changed ? this.store.deleteReferences(room, docid, storeReferences) : promise.resolve(),
           this.redis.multi()
             .xTrim(task.stream, 'MINID', lastId - this.redisMinMessageLifetime)
             .xAdd(this.redisWorkerStreamName, '*', { compact: task.stream })

tests/api.tests.js

@@ -75,6 +75,7 @@ export const testWorker = async tc => {
   let streamexists = true
   while (streamexists) {
     streamexists = (await client.redis.exists(stream)) === 1
+    await promise.wait(10)
   }
   const { ydoc: loadedDoc } = await client.getDoc(room, docid)
   t.assert(loadedDoc.getMap().get('key1') === 'val1')