libs/application-generic/src/utils/bridge.ts - next - githubmirror/novu

libs/application-generic/src/utils/bridge.ts
118 строк4 KB
Adam Chmara
feat(api-service,worker): CF step resolver deployment & resolution fixes NV-7100 (#10036)
25 фев 2026, 13:57
25 фев 2026, 13:57ca47b43
import {
  DelayOutput,
  DelayRegularOutput,
  DelayTimedOutput,
  DigestOutput,
  DigestRegularOutput,
  DigestTimedOutput,
} from '@novu/framework/internal';
import { DigestTypeEnum } from '@novu/shared';

export function getDigestType(outputs: DigestOutput): DigestTypeEnum {
  if (isTimedOutput(outputs)) {
    return DigestTypeEnum.TIMED;
  } else if (isLookBackDigestOutput(outputs)) {
    return DigestTypeEnum.BACKOFF;
  }

  return DigestTypeEnum.REGULAR;
}

export const isTimedOutput = (
  outputs: DigestOutput | DelayOutput | undefined
): outputs is DigestTimedOutput | DelayTimedOutput => {
  return (outputs as DigestTimedOutput)?.cron != null;
};

export const isLookBackDigestOutput = (outputs: DigestOutput | DelayOutput): outputs is DigestRegularOutput => {
  return (
    (outputs as DigestRegularOutput)?.lookBackWindow?.amount != null &&
    (outputs as DigestRegularOutput)?.lookBackWindow?.unit != null
  );
};

export const isDynamicOutput = (outputs: DelayOutput | undefined): boolean => {
  return (outputs as { dynamicKey?: string })?.dynamicKey != null;
};

export const isRegularOutput = (
  outputs: DigestOutput | DelayOutput
): outputs is DigestRegularOutput | DelayRegularOutput => {
  return !isTimedOutput(outputs) && !isLookBackDigestOutput(outputs) && !isDynamicOutput(outputs);
};

export const BRIDGE_EXECUTION_ERROR = {
  INVALID_BRIDGE_URL: {
    code: 'InvalidBridgeUrl',
    message: (bridgeUrl: string) => `Invalid bridge URL: ${bridgeUrl}`,
  },
  TUNNEL_NOT_FOUND: {
    code: 'TunnelNotFound',
    message: (url: string) =>
      `Unable to establish tunnel connection to \`${url}\`. Run npx novu@latest dev in Local mode, or ensure your Tunnel app deployment is available.`,
  },
  BRIDGE_ENDPOINT_NOT_FOUND: {
    code: 'BridgeEndpointNotFound',
    message: (url: string) =>
      `Could not connect to Bridge Endpoint at \`${url}\`. Make sure you are running your local app server.`,
  },
  BRIDGE_ENDPOINT_UNAVAILABLE: {
    code: 'BridgeEndpointUnavailable',
    message: (url: string) =>
      `Unable to reach Bridge Endpoint at \`${url}\`. Run npx novu@latest dev in Local mode, or ensure your Bridge app deployment is available.`,
  },
  BRIDGE_METHOD_NOT_CONFIGURED: {
    code: 'BridgeMethodNotConfigured',
    message: (url: string) =>
      `Bridge Endpoint at \`${url}\` is not correctly configured. Ensure your \`@novu/framework\` integration exposes the \`POST\`, \`GET\`, and \`OPTIONS\` methods.`,
  },
  BRIDGE_REQUEST_TIMEOUT: {
    code: 'BridgeRequestTimeout',
    message: (url: string) => `Bridge request timeout for \`${url}\``,
  },
  UNSUPPORTED_PROTOCOL: {
    code: 'UnsupportedProtocol',
    message: (url: string) => `Unsupported protocol for \`${url}\``,
  },
  RESPONSE_READ_ERROR: {
    code: 'ResponseReadError',
    message: (url: string) => `Response body could not be read for \`${url}\``,
  },
  REQUEST_UPLOAD_ERROR: {
    code: 'RequestUploadError',
    message: (url: string) => `Error uploading request body for \`${url}\``,
  },
  REQUEST_CACHE_ERROR: {
    code: 'RequestCacheError',
    message: (url: string) => `Error caching request for \`${url}\``,
  },
  MAXIMUM_REDIRECTS_EXCEEDED: {
    code: 'MaximumRedirectsExceeded',
    message: (url: string) => `Maximum redirects exceeded for \`${url}\``,
  },
  RESPONSE_PARSE_ERROR: {
    code: 'ResponseParseError',
    message: (url: string) => `Bridge URL response code is 2xx, but parsing body failed for \`${url}\``,
  },
  SELF_SIGNED_CERTIFICATE: {
    code: 'SelfSignedCertificate',
    message: (url: string) => `Bridge Endpoint can't use a self signed certificate in production environments.`,
  },
  PAYLOAD_TOO_LARGE: {
    code: 'PayloadTooLarge',
    message: (url: string) => `Payload too large for \`${url}\``,
  },
  BRIDGE_AUTHENTICATION_FAILED: {
    code: 'BridgeAuthenticationFailed',
    message: (url: string) =>
      `Bridge authentication failed for \`${url}\`. Please check your NOVU_SECRET_KEY environment variable.`,
  },
  UNKNOWN_BRIDGE_REQUEST_ERROR: {
    code: 'UnknownBridgeRequestError',
    message: (url: string) => `Unknown bridge request error calling \`${url}\``,
  },
  UNKNOWN_BRIDGE_NON_REQUEST_ERROR: {
    code: 'UnknownBridgeNonRequestError',
    message: (url: string) => `Unknown bridge non-request error calling \`${url}\``,
  },
} satisfies Record<string, { code: string; message: (url: string) => string }>;