/* * Copyright 2021 The Backstage Authors * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ import { Entity, stringifyEntityRef } from '@backstage/catalog-model'; import { ApiHolder, DiscoveryApi, FetchApi, IdentityApi, } from '@backstage/core-plugin-api'; import { createApiRef } from '@backstage/frontend-plugin-api'; import { ResponseError } from '@backstage/errors'; export const bazaarApiRef = createApiRef().with({ id: 'bazaar', }); export interface BazaarApi { updateProject(bazaarProject: any): Promise; addProject(bazaarProject: any): Promise; getProjectById(id: number): Promise; getProjectByRef(entityRef: string): Promise; getMembers(id: number): Promise; deleteMember(id: number, userId: string): Promise; addMember(id: number, userId: string): Promise; getProjects(limit?: number, order?: string): Promise; deleteProject(id: number): Promise; } /** @public */ export const isBazaarAvailable = async ( entity: Entity, context: { apis: ApiHolder }, ): Promise => { const bazaarClient = context.apis.get(bazaarApiRef); if (bazaarClient === undefined) { return false; } const entityRef = stringifyEntityRef({ kind: entity.kind, name: entity.metadata.name, namespace: entity.metadata.namespace, }); const response = await bazaarClient.getProjectByRef(entityRef); const project = await response.json(); return project.data.length > 0; }; export class BazaarClient implements BazaarApi { private readonly identityApi: IdentityApi; private readonly discoveryApi: DiscoveryApi; private readonly fetchApi: FetchApi; constructor(options: { identityApi: IdentityApi; discoveryApi: DiscoveryApi; fetchApi: FetchApi; }) { this.identityApi = options.identityApi; this.discoveryApi = options.discoveryApi; this.fetchApi = options.fetchApi; } async updateProject(bazaarProject: any): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); return await this.fetchApi .fetch(`${baseUrl}/projects`, { method: 'PUT', headers: { Accept: 'application/json', 'Content-Type': 'application/json', }, body: JSON.stringify(bazaarProject), }) .then(resp => resp.json()); } async addProject(bazaarProject: any): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); return await this.fetchApi .fetch(`${baseUrl}/projects`, { method: 'POST', headers: { Accept: 'application/json', 'Content-Type': 'application/json', }, body: JSON.stringify(bazaarProject), }) .then(resp => resp.json()); } async getProjectById(id: number): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); const response = await this.fetchApi.fetch( `${baseUrl}/projects/${encodeURIComponent(id)}`, ); return response.ok ? response : null; } async getProjectByRef(entityRef: string): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); const response = await this.fetchApi.fetch( `${baseUrl}/projects/${encodeURIComponent(entityRef)}`, ); return response.ok ? response : null; } async getMembers(id: number): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); return await this.fetchApi .fetch(`${baseUrl}/projects/${encodeURIComponent(id)}/members`) .then(resp => resp.json()); } async addMember(id: number, userId: string): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); const { picture } = await this.identityApi.getProfileInfo(); await this.fetchApi.fetch( `${baseUrl}/projects/${encodeURIComponent( id, )}/member/${encodeURIComponent(userId)}`, { method: 'PUT', headers: { Accept: 'application/json', 'Content-Type': 'application/json', }, body: JSON.stringify({ picture }), }, ); } async deleteMember(id: number, userId: string): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); await this.fetchApi.fetch( `${baseUrl}/projects/${encodeURIComponent( id, )}/member/${encodeURIComponent(userId)}`, { method: 'DELETE' }, ); } async getProjects(limit?: number, order?: string): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); const params = { ...(limit ? { limit: limit.toString() } : {}), ...(order ? { order } : {}), }; const query = new URLSearchParams(params); const url = `projects?${query.toString()}`; const data = await this.fetchApi.fetch(`${baseUrl}/${url}`); if (!data.ok) { throw await ResponseError.fromResponse(data); } return data.json(); } async deleteProject(id: number): Promise { const baseUrl = await this.discoveryApi.getBaseUrl('bazaar'); await this.fetchApi.fetch(`${baseUrl}/projects/${encodeURIComponent(id)}`, { method: 'DELETE', }); } }