Add initial code to get PuppetDB node data

Signed-off-by: Tomas Dabasinskas <tomas@dabasinskas.net>

plugins/puppetdb/src/api/PuppetDbClient.ts

@@ -0,0 +1,66 @@
+/*
+ * Copyright 2022 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 { PuppetDbApi, PuppetDbNode } from './types';
+import { DiscoveryApi, FetchApi } from '@backstage/core-plugin-api';
+import { ResponseError } from '@backstage/errors';
+
+export class PuppetDbClient implements PuppetDbApi {
+  discoveryApi: DiscoveryApi;
+  fetchApi: FetchApi;
+
+  constructor({
+    discoveryApi,
+    fetchApi,
+  }: {
+    discoveryApi: DiscoveryApi;
+    fetchApi: FetchApi;
+  }) {
+    this.discoveryApi = discoveryApi;
+    this.fetchApi = fetchApi;
+  }
+
+  private async callApi<T>(
+    path: string,
+    query: { [key in string]: any },
+  ): Promise<T | undefined> {
+    const apiUrl = `${await this.discoveryApi.getBaseUrl('proxy')}/puppetdb`;
+    const response = await this.fetchApi.fetch(
+      `${apiUrl}/${path}?${new URLSearchParams(query).toString()}`,
+      {
+        headers: {
+          'Content-Type': 'application/json',
+        },
+      },
+    );
+    if (response.ok) {
+      return (await response.json()) as T;
+    }
+    throw await ResponseError.fromResponse(response);
+  }
+
+  async getPuppetDbNode(
+    puppetDbCertName: string,
+  ): Promise<PuppetDbNode | undefined> {
+    if (!puppetDbCertName) {
+      throw new Error('PuppetDB certname is required');
+    }
+
+    return this.callApi(
+      `/pdb/query/v4/nodes/${encodeURIComponent(puppetDbCertName)}`,
+      {},
+    );
+  }
+}

plugins/puppetdb/src/api/index.ts

@@ -0,0 +1,18 @@
+/*
+ * Copyright 2022 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.
+ */
+export type { PuppetDbNode } from './types';
+export { puppetDbApiRef } from './types';
+export { PuppetDbClient } from './PuppetDbClient';

plugins/puppetdb/src/api/types.ts

@@ -0,0 +1,94 @@
+/*
+ * Copyright 2022 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 { createApiRef } from '@backstage/core-plugin-api';
+
+/**
+ * A node in PuppetDB.
+ */
+export type PuppetDbNode = {
+  /**
+   * The name of the node that the report was received from.
+   */
+  certname: string;
+  /**
+   * The environment for the last received catalog.
+   */
+  catalog_environment: string;
+  /**
+   * The environment for the last received fact set.
+   */
+  facts_environment: string;
+  /**
+   * The environment for the last received report.
+   */
+  report_environment: string;
+  /**
+   * The last time a catalog was received. Timestamps are always ISO-8601 compatible date/time strings.
+   */
+  catalog_timestamp: string;
+  /**
+   * The last time a fact set was received. Timestamps are always ISO-8601 compatible date/time strings.
+   */
+  facts_timestamp: string;
+  /**
+   * The last time a report run was complete. Timestamps are always ISO-8601 compatible date/time strings.
+   */
+  report_timestamp: string;
+  /**
+   * The status of the latest report. Possible values come from Puppet's report status.
+   */
+  latest_report_status: string;
+  /**
+   * Indicates whether the most recent report for the node was a noop run.
+   */
+  latest_report_noop: boolean;
+  /**
+   * Indicates whether the most recent report for the node contained noop events.
+   */
+  latest_report_noop_pending: boolean;
+  /**
+   * A flag indicating whether the latest report for the node included events that remediated configuration drift.
+   */
+  latest_report_corrective_change: boolean;
+  /**
+   * Cached catalog status of the last puppet run for the node. Possible values are explicitly_requested, on_failure, not_used or null.
+   */
+  cached_catalog_status: string;
+  /**
+   * A hash of the latest report for the node.
+   */
+  latest_report_hash: string;
+  /**
+   * The job id associated with the latest report.
+   */
+  latest_report_job_id?: string;
+  /**
+   * Indicates whether the node is currently in the deactivated state.
+   */
+  deactivated?: boolean;
+  /**
+   * Indicates whether the node is currently in the expired state.
+   */
+  expired?: boolean;
+};
+
+export const puppetDbApiRef = createApiRef<PuppetDbApi>({
+  id: 'plugin.puppetdb.service',
+});
+
+export type PuppetDbApi = {
+  getPuppetDbNode(puppetDbCertName: string): Promise<PuppetDbNode | undefined>;
+};

plugins/puppetdb/src/components/PuppetDbNodeCard/PuppetDbNodeCard.tsx

@@ -0,0 +1,49 @@
+/*
+ * Copyright 2022 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 React from 'react';
+import useAsync from 'react-use/lib/useAsync';
+import { Progress, ResponseErrorPanel } from '@backstage/core-components';
+import { InfoCard } from '@backstage/core-components';
+import { useApi } from '@backstage/core-plugin-api';
+import { puppetDbApiRef } from '../../api';
+
+type PuppetDbNodeCardProps = {
+  certName: string;
+};
+
+export const PuppetDbNodeCard = (props: PuppetDbNodeCardProps) => {
+  const { certName } = props;
+  const puppetDbApi = useApi(puppetDbApiRef);
+
+  const { value, loading, error } = useAsync(async () => {
+    return puppetDbApi.getPuppetDbNode(certName);
+  }, [puppetDbApi, certName]);
+
+  if (loading) {
+    return <Progress />;
+  } else if (error) {
+    return <ResponseErrorPanel error={error} />;
+  }
+
+  return (
+    <InfoCard
+      title="PuppetDB Node"
+      subheader={`Details about PuppetDB node ${certName}`}
+    >
+      <text>${JSON.stringify(value)}</text>
+    </InfoCard>
+  );
+};

plugins/puppetdb/src/components/PuppetDbNodeCard/index.ts

@@ -0,0 +1,16 @@
+/*
+ * Copyright 2022 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.
+ */
+export { PuppetDbNodeCard } from './PuppetDbNodeCard';

plugins/puppetdb/src/components/PuppetDbTab/PuppetDbTab.tsx

@@ -22,6 +22,7 @@ import {
 import { useEntity } from '@backstage/plugin-catalog-react';
 import { isPuppetDbAvailable } from '../../plugin';
 import { ANNOTATION_PUPPET_CERTNAME } from '../../constants';
+import { PuppetDbNodeCard } from '../PuppetDbNodeCard';
 
 export const PuppetDbTab = () => {
   const { entity } = useEntity();
@@ -32,10 +33,13 @@ export const PuppetDbTab = () => {
     );
   }
 
+  // @ts-ignore
+  const certName = entity.metadata.annotations[ANNOTATION_PUPPET_CERTNAME];
+
   return (
     <Page themeId="tool">
       <Content>
-        <text>TODO: Implement PuppetDB plugin</text>
+        <PuppetDbNodeCard certName={certName} />
       </Content>
     </Page>
   );

plugins/puppetdb/src/plugin.ts

@@ -14,13 +14,17 @@
  * limitations under the License.
  */
 import {
+  createApiFactory,
   createPlugin,
   createRoutableExtension,
+  discoveryApiRef,
+  fetchApiRef,
 } from '@backstage/core-plugin-api';
 
 import { rootRouteRef } from './routes';
 import { Entity } from '@backstage/catalog-model';
 import { ANNOTATION_PUPPET_CERTNAME } from './constants';
+import { puppetDbApiRef, PuppetDbClient } from './api';
 
 /**
  * Create the PuppetDB frontend plugin.
@@ -28,9 +32,20 @@ import { ANNOTATION_PUPPET_CERTNAME } from './constants';
  */
 export const puppetdbPlugin = createPlugin({
   id: 'puppetdb',
-  routes: {
-    root: rootRouteRef,
-  },
+  apis: [
+    createApiFactory({
+      api: puppetDbApiRef,
+      deps: {
+        discoveryApi: discoveryApiRef,
+        fetchApi: fetchApiRef,
+      },
+      factory: ({ discoveryApi, fetchApi }) =>
+        new PuppetDbClient({
+          discoveryApi,
+          fetchApi,
+        }),
+    }),
+  ],
 });
 
 /**