Merge pull request #205 from parodos-dev/dl/members-api

Integrate members API

plugins/parodos/src/api/fetchAccessRequests.ts

@@ -0,0 +1,26 @@
+import { FetchApi } from '@backstage/core-plugin-api';
+import { AccessRequest, accessRequests } from '../models/project';
+import * as urls from '../urls';
+
+export async function fetchAccessRequests(
+  fetch: FetchApi['fetch'],
+  baseUrl: string,
+  filter?: { projectId?: string; username?: string },
+): Promise<AccessRequest[]> {
+  const response = await fetch(`${baseUrl}${urls.Projects}/access/pending`);
+  const data = await response.json();
+
+  if ('error' in data) {
+    throw new Error(`${data.error}: ${data.path}`);
+  }
+
+  const requests = accessRequests.parse(data);
+
+  return filter
+    ? requests.filter(
+        request =>
+          (filter.projectId ? request.projectId === filter.projectId : true) &&
+          (filter.username ? request.username === filter.username : true),
+      )
+    : requests;
+}

plugins/parodos/src/api/fetchProjectMembers.ts

@@ -0,0 +1,20 @@
+import { FetchApi } from '@backstage/core-plugin-api';
+import { projectMembers } from '../models/project';
+import * as urls from '../urls';
+
+export async function fetchProjectMembers(
+  fetch: FetchApi['fetch'],
+  baseUrl: string,
+  projectId: string,
+) {
+  const response = await fetch(
+    `${baseUrl}${urls.Projects}/${projectId}/members`,
+  );
+  const data = await response.json();
+
+  if ('error' in data) {
+    throw new Error(`${data.error}: ${data.path}`);
+  }
+
+  return projectMembers.parse(data);
+}

plugins/parodos/src/api/removeUserFromProject.ts

@@ -0,0 +1,22 @@
+import { FetchApi } from '@backstage/core-plugin-api';
+import * as urls from '../urls';
+
+export async function removeUserFromProject(
+  fetch: FetchApi['fetch'],
+  baseUrl: string,
+  projectId: string,
+  users: string[],
+) {
+  const response = await fetch(
+    `${baseUrl}${urls.Projects}/${projectId}/users`,
+    {
+      method: 'DELETE',
+      body: JSON.stringify(users),
+    },
+  );
+  const data = await response.json();
+
+  if ('error' in data) {
+    throw new Error(`${data.error}: ${data.path}`);
+  }
+}

plugins/parodos/src/api/responseOnAccessRequest.ts

@@ -0,0 +1,26 @@
+import { FetchApi } from '@backstage/core-plugin-api';
+import { AccessStatus } from '../models/project';
+import * as urls from '../urls';
+
+export async function responseOnAccessRequest(
+  fetch: FetchApi['fetch'],
+  baseUrl: string,
+  requestId: string,
+  payload: { comment?: string; status: AccessStatus },
+) {
+  const response = await fetch(
+    `${baseUrl}${urls.Projects}/access/${requestId}/status`,
+    {
+      method: 'POST',
+      body: JSON.stringify({ ...payload, comment: payload.comment || '' }),
+    },
+  );
+  if (response.status !== 204) {
+    if (response.status === 400) {
+      const data = await response.json();
+      throw new Error(`${response.status}: ${data.message}`);
+    }
+
+    throw new Error(`${response.status}`);
+  }
+}

plugins/parodos/src/api/updateUserRole.ts

@@ -0,0 +1,23 @@
+import { FetchApi } from '@backstage/core-plugin-api';
+import { AccessRole } from '../models/project';
+import * as urls from '../urls';
+
+export async function updateUserRole(
+  fetch: FetchApi['fetch'],
+  baseUrl: string,
+  projectId: string,
+  payload: { username: string; roles: AccessRole[] }[],
+) {
+  const response = await fetch(
+    `${baseUrl}${urls.Projects}/${projectId}/users`,
+    {
+      method: 'POST',
+      body: JSON.stringify(payload),
+    },
+  );
+  const data = await response.json();
+
+  if ('error' in data) {
+    throw new Error(`${data.error}: ${data.path}`);
+  }
+}