test(bulk-import): add repository filtering tests

Signed-off-by: Dominik Augustín <daugusti@redhat.com>

Author: dom-aug

workspaces/bulk-import/plugins/bulk-import-backend/src/service/handlers/repository/repositories.test.ts

@@ -19,7 +19,10 @@ import { AuthorizeResult } from '@backstage/plugin-permission-common';
 import { rest } from 'msw';
 import request from 'supertest';
 
-import { LOCAL_ADDR } from '../../../../__fixtures__/handlers';
+import {
+  CATALOG_API_LOCATIONS_LOCAL_ADDR,
+  LOCAL_ADDR,
+} from '../../../../__fixtures__/handlers';
 import {
   addHandlersForGHTokenAppErrors,
   setupTest,
@@ -137,6 +140,201 @@ describe('repositories', () => {
         ],
       });
     });
+
+    describe('filtering repositories', () => {
+      it('returns all repos when no repos are imported yet', async () => {
+        const { mockCatalogClient } = useTestData();
+
+        const backendServer = await startBackendServer(
+          mockCatalogClient,
+          AuthorizeResult.ALLOW,
+        );
+
+        const response = await request(backendServer).get(
+          '/api/bulk-import/repositories',
+        );
+
+        expect(response.status).toEqual(200);
+        expect(response.body).toEqual({
+          errors: [],
+          repositories: [
+            {
+              defaultBranch: 'master',
+              errors: [],
+              id: 'octocat/animated-happiness',
+              lastUpdate: '2011-01-26T19:14:43Z',
+              name: 'animated-happiness',
+              organization: 'octocat',
+              url: 'http://localhost:8765/octocat/animated-happiness',
+            },
+            {
+              defaultBranch: 'master',
+              errors: [],
+              id: 'octocat/Hello-World',
+              lastUpdate: '2011-01-26T19:14:43Z',
+              name: 'Hello-World',
+              organization: 'octocat',
+              url: 'http://localhost:8765/octocat/Hello-World',
+            },
+            {
+              defaultBranch: 'master',
+              errors: [],
+              id: 'my-user/Lorem-Ipsum',
+              lastUpdate: '2011-01-26T19:14:43Z',
+              name: 'Lorem-Ipsum',
+              organization: 'my-user',
+              url: 'http://localhost:8765/my-user/Lorem-Ipsum',
+            },
+          ],
+          totalCount: 3,
+        });
+      });
+
+      it('returns empty array when there are no repos to be imported', async () => {
+        const { server, mockCatalogClient } = useTestData();
+
+        server.use(
+          rest.get(`${LOCAL_ADDR}/user/repos`, (_, res, ctx) =>
+            res(ctx.status(200), ctx.json([])),
+          ),
+        );
+        server.use(
+          rest.get(`${LOCAL_ADDR}/installation/repositories`, (_, res, ctx) =>
+            res(
+              ctx.status(200),
+              ctx.json({ total_count: 0, repositories: [] }),
+            ),
+          ),
+        );
+
+        const backendServer = await startBackendServer(
+          mockCatalogClient,
+          AuthorizeResult.ALLOW,
+        );
+
+        const response = await request(backendServer).get(
+          '/api/bulk-import/repositories',
+        );
+
+        expect(response.status).toEqual(200);
+        expect(response.body).toEqual({
+          errors: [],
+          repositories: [],
+          totalCount: 0,
+        });
+      });
+
+      it('returns filtered (not yet imported) repos when some repos are already imported', async () => {
+        const { server, mockCatalogClient } = useTestData();
+
+        server.use(
+          rest.get(CATALOG_API_LOCATIONS_LOCAL_ADDR, (_, res, ctx) =>
+            res(
+              ctx.status(200),
+              ctx.json([
+                {
+                  data: {
+                    id: 'imported-hello-world',
+                    target:
+                      'http://localhost:8765/octocat/Hello-World/catalog-info.yaml',
+                    type: 'url',
+                  },
+                },
+              ]),
+            ),
+          ),
+        );
+
+        const backendServer = await startBackendServer(
+          mockCatalogClient,
+          AuthorizeResult.ALLOW,
+        );
+
+        const response = await request(backendServer).get(
+          '/api/bulk-import/repositories',
+        );
+
+        expect(response.status).toEqual(200);
+        expect(response.body).toEqual({
+          errors: [],
+          repositories: [
+            {
+              defaultBranch: 'master',
+              errors: [],
+              id: 'octocat/animated-happiness',
+              lastUpdate: '2011-01-26T19:14:43Z',
+              name: 'animated-happiness',
+              organization: 'octocat',
+              url: 'http://localhost:8765/octocat/animated-happiness',
+            },
+            {
+              defaultBranch: 'master',
+              errors: [],
+              id: 'my-user/Lorem-Ipsum',
+              lastUpdate: '2011-01-26T19:14:43Z',
+              name: 'Lorem-Ipsum',
+              organization: 'my-user',
+              url: 'http://localhost:8765/my-user/Lorem-Ipsum',
+            },
+          ],
+          totalCount: 2,
+        });
+      });
+
+      it('returns empty array when all repos are already imported', async () => {
+        const { server, mockCatalogClient } = useTestData();
+
+        server.use(
+          rest.get(CATALOG_API_LOCATIONS_LOCAL_ADDR, (_, res, ctx) =>
+            res(
+              ctx.status(200),
+              ctx.json([
+                {
+                  data: {
+                    id: 'imported-animated-happiness',
+                    target:
+                      'http://localhost:8765/octocat/animated-happiness/catalog-info.yaml',
+                    type: 'url',
+                  },
+                },
+                {
+                  data: {
+                    id: 'imported-hello-world',
+                    target:
+                      'http://localhost:8765/octocat/Hello-World/catalog-info.yaml',
+                    type: 'url',
+                  },
+                },
+                {
+                  data: {
+                    id: 'imported-lorem-ipsum',
+                    target:
+                      'http://localhost:8765/my-user/Lorem-Ipsum/catalog-info.yaml',
+                    type: 'url',
+                  },
+                },
+              ]),
+            ),
+          ),
+        );
+
+        const backendServer = await startBackendServer(
+          mockCatalogClient,
+          AuthorizeResult.ALLOW,
+        );
+
+        const response = await request(backendServer).get(
+          '/api/bulk-import/repositories',
+        );
+
+        expect(response.status).toEqual(200);
+        expect(response.body).toEqual({
+          errors: [],
+          repositories: [],
+          totalCount: 0,
+        });
+      });
+    });
   });
 
   describe('GET /organizations/{org}/repositories', () => {