WIP

e2e/src/api/specs/sync.e2e-spec.ts

@@ -0,0 +1,85 @@
+import { LoginResponseDto, login, signUpAdmin } from '@immich/sdk';
+import { loginDto, signupDto } from 'src/fixtures';
+import { errorDto } from 'src/responses';
+import { app, utils } from 'src/utils';
+import request from 'supertest';
+import { beforeAll, describe, expect, it } from 'vitest';
+
+describe('/sync', () => {
+  let admin: LoginResponseDto;
+
+  beforeAll(async () => {
+    await utils.resetDatabase();
+    await signUpAdmin({ signUpDto: signupDto.admin });
+    admin = await login({ loginCredentialDto: loginDto.admin });
+  });
+
+  describe('GET /sync/acknowledge', () => {
+    it('should require authentication', async () => {
+      const { status, body } = await request(app).post('/sync/acknowledge');
+      expect(status).toBe(401);
+      expect(body).toEqual(errorDto.unauthorized);
+    });
+
+    it('should require a valid timestamp', async () => {
+      const { status, body } = await request(app)
+        .post('/sync/acknowledge')
+        .set('Authorization', `Bearer ${admin.accessToken}`)
+        .send({
+          type: 'AssetOwner',
+          timestamp: '2024-10-31 25:25:25',
+        });
+      expect(status).toBe(400);
+      expect(body).toEqual(errorDto.badRequest(['timestamp must be a valid ISO 8601 date string']));
+    });
+
+    it('should work', async () => {
+      const { status } = await request(app)
+        .post('/sync/acknowledge')
+        .set('Authorization', `Bearer ${admin.accessToken}`)
+        .send({
+          type: 'AssetOwner',
+          timestamp: '2024-10-23T21:01:07.732Z',
+        });
+      expect(status).toBe(204);
+    });
+  });
+
+  describe('GET /sync/stream', () => {
+    it('should require authentication', async () => {
+      const { status, body } = await request(app).post('/sync/stream');
+      expect(status).toBe(401);
+      expect(body).toEqual(errorDto.unauthorized);
+    });
+
+    it('should reject invalid types', async () => {
+      const { status, body } = await request(app)
+        .post('/sync/stream')
+        .set('Authorization', `Bearer ${admin.accessToken}`)
+        .send({ types: ['invalid'] });
+      expect(status).toBe(400);
+      expect(body).toEqual(
+        errorDto.badRequest([expect.stringContaining('each value in types must be one of the following values')]),
+      );
+    });
+
+    it('should require at least one type', async () => {
+      const { status, body } = await request(app)
+        .post('/sync/stream')
+        .set('Authorization', `Bearer ${admin.accessToken}`)
+        .send({ types: [] });
+      expect(status).toBe(400);
+      expect(body).toEqual(errorDto.badRequest());
+    });
+
+    it('should accept a valid type', async () => {
+      const response = await request(app)
+        .post('/sync/stream')
+        .set('Authorization', `Bearer ${admin.accessToken}`)
+        .send({ types: ['AssetOwnerV1'] });
+      expect(response.status).toBe(200);
+      expect(response.get('Content-Type')).toBe('application/jsonlines+json; charset=utf-8');
+      expect(response.body).toEqual('');
+    });
+  });
+});