budibase/packages/worker/src/utilities/appService.ts

import fetch from "node-fetch"
import { constants, tenancy } from "@budibase/backend-core"
import { checkSlashesInUrl } from "../utilities"
import env from "../environment"

async function makeAppRequest(url: string, method: string, body: any) {
  if (env.isTest()) {
    return
  }
  const request: any = { headers: {} }
  request.headers[constants.Header.API_KEY] = env.INTERNAL_API_KEY
  if (tenancy.isTenantIdSet()) {
    request.headers[constants.Header.TENANT_ID] = tenancy.getTenantId()
  }
  if (body) {
    request.headers["Content-Type"] = "application/json"
    request.body = JSON.stringify(body)
  }
  request.method = method
  return fetch(checkSlashesInUrl(env.APPS_URL + url), request)
}

export async function syncUserInApps(userId: string) {
  const response = await makeAppRequest(
    `/api/users/metadata/sync/${userId}`,
    "POST",
    {}
  )
  if (response && response.status !== 200) {
    throw "Unable to sync user."
  }
}

export async function removeUserFromApp(userId: string, appId: string) {
  const response = await makeAppRequest(
    `/api/users/metadata/${userId}/app/${appId}`,
    "DELETE",
    undefined
  )
  if (response && response.status !== 200) {
    throw "Unable to delete user from app."
  }
}