gradido/backend/src/federation/client/1_0/FederationClient.ts

/* eslint-disable @typescript-eslint/no-unsafe-member-access */
/* eslint-disable @typescript-eslint/no-unsafe-return */
/* eslint-disable @typescript-eslint/no-unsafe-assignment */
import { FederatedCommunity as DbFederatedCommunity } from '@entity/FederatedCommunity'
import { GraphQLError } from 'graphql'
import { gql } from 'graphql-request'

import { GraphQLGetClient } from '@/federation/client/GraphQLGetClient'
import { backendLogger as logger } from '@/server/logger'

export class FederationClient {
  public async requestGetPublicKey(dbCom: DbFederatedCommunity): Promise<string | undefined> {
    let endpoint = dbCom.endPoint.endsWith('/') ? dbCom.endPoint : dbCom.endPoint + '/'
    endpoint = `${endpoint}${dbCom.apiVersion}/`
    logger.info(`requestGetPublicKey with endpoint='${endpoint}'...`)

    const graphQLClient = GraphQLGetClient.getInstance(endpoint)
    logger.debug(`graphQLClient=${JSON.stringify(graphQLClient)}`)
    const query = gql`
      query {
        getPublicKey {
          publicKey
        }
      }
    `
    const variables = {}
    try {
      const { data, errors, extensions, headers, status } = await graphQLClient.rawRequest(
        query,
        variables,
      )
      logger.debug(`Response-Data:`, data, errors, extensions, headers, status)
      if (data) {
        logger.debug(`Response-PublicKey:`, data.getPublicKey.publicKey)
        logger.info(`requestGetPublicKey processed successfully`)
        return data.getPublicKey.publicKey
      }
      logger.warn(`requestGetPublicKey processed without response data`)
    } catch (err) {
      if (err instanceof GraphQLError) {
        logger.error(`RawRequest-Error on ${endpoint} with message ${err.message}`)
      }
      throw new Error(`Request-Error in requestGetPublicKey.`)
    }
  }
}