import { Kysely } from 'kysely'; import { SyncEntityType, SyncRequestType } from 'src/enum'; import { StackRepository } from 'src/repositories/stack.repository'; import { DB } from 'src/schema'; import { SyncTestContext } from 'test/medium.factory'; import { getKyselyDB } from 'test/utils'; let defaultDatabase: Kysely; const setup = async (db?: Kysely) => { const ctx = new SyncTestContext(db || defaultDatabase); const { auth, user, session } = await ctx.newSyncAuthUser(); return { auth, user, session, ctx }; }; beforeAll(async () => { defaultDatabase = await getKyselyDB(); }); describe(SyncEntityType.StackV1, () => { it('should detect and sync the first stack', async () => { const { auth, user, ctx } = await setup(); const { asset: asset1 } = await ctx.newAsset({ ownerId: user.id }); const { asset: asset2 } = await ctx.newAsset({ ownerId: user.id }); const { stack } = await ctx.newStack({ ownerId: user.id }, [asset1.id, asset2.id]); const response = await ctx.syncStream(auth, [SyncRequestType.StacksV1]); expect(response).toHaveLength(1); expect(response).toEqual([ { ack: expect.stringContaining('StackV1'), data: { id: stack.id, createdAt: (stack.createdAt as Date).toISOString(), updatedAt: (stack.updatedAt as Date).toISOString(), primaryAssetId: stack.primaryAssetId, ownerId: stack.ownerId, }, type: 'StackV1', }, ]); await ctx.syncAckAll(auth, response); await expect(ctx.syncStream(auth, [SyncRequestType.StacksV1])).resolves.toEqual([]); }); it('should detect and sync a deleted stack', async () => { const { auth, user, ctx } = await setup(); const stackRepo = ctx.get(StackRepository); const { asset: asset1 } = await ctx.newAsset({ ownerId: user.id }); const { asset: asset2 } = await ctx.newAsset({ ownerId: user.id }); const { stack } = await ctx.newStack({ ownerId: user.id }, [asset1.id, asset2.id]); await stackRepo.delete(stack.id); const response = await ctx.syncStream(auth, [SyncRequestType.StacksV1]); expect(response).toHaveLength(1); expect(response).toEqual([ { ack: expect.stringContaining('StackDeleteV1'), data: { stackId: stack.id }, type: 'StackDeleteV1', }, ]); await ctx.syncAckAll(auth, response); await expect(ctx.syncStream(auth, [SyncRequestType.StacksV1])).resolves.toEqual([]); }); it('should sync a stack and then an update to that same stack', async () => { const { auth, user, ctx } = await setup(); const stackRepo = ctx.get(StackRepository); const { asset: asset1 } = await ctx.newAsset({ ownerId: user.id }); const { asset: asset2 } = await ctx.newAsset({ ownerId: user.id }); const { stack } = await ctx.newStack({ ownerId: user.id }, [asset1.id, asset2.id]); const response = await ctx.syncStream(auth, [SyncRequestType.StacksV1]); expect(response).toHaveLength(1); await ctx.syncAckAll(auth, response); await stackRepo.update(stack.id, { primaryAssetId: asset2.id }); const newResponse = await ctx.syncStream(auth, [SyncRequestType.StacksV1]); expect(newResponse).toHaveLength(1); expect(newResponse).toEqual([ { ack: expect.stringContaining('StackV1'), data: expect.objectContaining({ id: stack.id, primaryAssetId: asset2.id }), type: 'StackV1', }, ]); await ctx.syncAckAll(auth, newResponse); await expect(ctx.syncStream(auth, [SyncRequestType.StacksV1])).resolves.toEqual([]); }); it('should not sync a stack or stack delete for an unrelated user', async () => { const { auth, ctx } = await setup(); const stackRepo = ctx.get(StackRepository); const { user: user2 } = await ctx.newUser(); const { asset: asset1 } = await ctx.newAsset({ ownerId: user2.id }); const { asset: asset2 } = await ctx.newAsset({ ownerId: user2.id }); const { stack } = await ctx.newStack({ ownerId: user2.id }, [asset1.id, asset2.id]); await expect(ctx.syncStream(auth, [SyncRequestType.StacksV1])).resolves.toEqual([]); await stackRepo.delete(stack.id); await expect(ctx.syncStream(auth, [SyncRequestType.StacksV1])).resolves.toEqual([]); }); });