Implement more stuff

This commit is contained in:
Fang-Pen Lin
2025-11-25 08:54:11 -08:00
parent 126c3be606
commit 66ecddc584
7 changed files with 94 additions and 56 deletions
@@ -11,8 +11,8 @@ import {
validateOCIConnectionCredentials validateOCIConnectionCredentials
} from "@app/ee/services/app-connections/oci"; } from "@app/ee/services/app-connections/oci";
import { getOracleDBConnectionListItem, OracleDBConnectionMethod } from "@app/ee/services/app-connections/oracledb"; import { getOracleDBConnectionListItem, OracleDBConnectionMethod } from "@app/ee/services/app-connections/oracledb";
import { TGatewayServiceFactory } from "@app/ee/services/gateway/gateway-service";
import { TGatewayV2ServiceFactory } from "@app/ee/services/gateway-v2/gateway-v2-service"; import { TGatewayV2ServiceFactory } from "@app/ee/services/gateway-v2/gateway-v2-service";
import { TGatewayServiceFactory } from "@app/ee/services/gateway/gateway-service";
import { TLicenseServiceFactory } from "@app/ee/services/license/license-service"; import { TLicenseServiceFactory } from "@app/ee/services/license/license-service";
import { SECRET_ROTATION_CONNECTION_MAP } from "@app/ee/services/secret-rotation-v2/secret-rotation-v2-maps"; import { SECRET_ROTATION_CONNECTION_MAP } from "@app/ee/services/secret-rotation-v2/secret-rotation-v2-maps";
import { SECRET_SCANNING_DATA_SOURCE_CONNECTION_MAP } from "@app/ee/services/secret-scanning-v2/secret-scanning-v2-maps"; import { SECRET_SCANNING_DATA_SOURCE_CONNECTION_MAP } from "@app/ee/services/secret-scanning-v2/secret-scanning-v2-maps";
@@ -78,11 +78,6 @@ import {
getCloudflareConnectionListItem, getCloudflareConnectionListItem,
validateCloudflareConnectionCredentials validateCloudflareConnectionCredentials
} from "./cloudflare/cloudflare-connection-fns"; } from "./cloudflare/cloudflare-connection-fns";
import { DNSMadeEasyConnectionMethod } from "./dns-made-easy/dns-made-easy-connection-enum";
import {
getDNSMadeEasyConnectionListItem,
validateDNSMadeEasyConnectionCredentials
} from "./dns-made-easy/dns-made-easy-connection-fns";
import { import {
DatabricksConnectionMethod, DatabricksConnectionMethod,
getDatabricksConnectionListItem, getDatabricksConnectionListItem,
@@ -93,6 +88,11 @@ import {
getDigitalOceanConnectionListItem, getDigitalOceanConnectionListItem,
validateDigitalOceanConnectionCredentials validateDigitalOceanConnectionCredentials
} from "./digital-ocean"; } from "./digital-ocean";
import { DNSMadeEasyConnectionMethod } from "./dns-made-easy/dns-made-easy-connection-enum";
import {
getDNSMadeEasyConnectionListItem,
validateDNSMadeEasyConnectionCredentials
} from "./dns-made-easy/dns-made-easy-connection-fns";
import { FlyioConnectionMethod, getFlyioConnectionListItem, validateFlyioConnectionCredentials } from "./flyio"; import { FlyioConnectionMethod, getFlyioConnectionListItem, validateFlyioConnectionCredentials } from "./flyio";
import { GcpConnectionMethod, getGcpConnectionListItem, validateGcpConnectionCredentials } from "./gcp"; import { GcpConnectionMethod, getGcpConnectionListItem, validateGcpConnectionCredentials } from "./gcp";
import { getGitHubConnectionListItem, GitHubConnectionMethod, validateGitHubConnectionCredentials } from "./github"; import { getGitHubConnectionListItem, GitHubConnectionMethod, validateGitHubConnectionCredentials } from "./github";
@@ -402,6 +402,8 @@ export const getAppConnectionMethodName = (method: TAppConnection["method"]) =>
case OktaConnectionMethod.ApiToken: case OktaConnectionMethod.ApiToken:
case LaravelForgeConnectionMethod.ApiToken: case LaravelForgeConnectionMethod.ApiToken:
return "API Token"; return "API Token";
case DNSMadeEasyConnectionMethod.APIKeySecret:
return "API Key & Secret";
case PostgresConnectionMethod.UsernameAndPassword: case PostgresConnectionMethod.UsernameAndPassword:
case MsSqlConnectionMethod.UsernameAndPassword: case MsSqlConnectionMethod.UsernameAndPassword:
case MySqlConnectionMethod.UsernameAndPassword: case MySqlConnectionMethod.UsernameAndPassword:
@@ -15,8 +15,8 @@ import {
TOracleDBConnectionInput, TOracleDBConnectionInput,
TValidateOracleDBConnectionCredentialsSchema TValidateOracleDBConnectionCredentialsSchema
} from "@app/ee/services/app-connections/oracledb"; } from "@app/ee/services/app-connections/oracledb";
import { TGatewayServiceFactory } from "@app/ee/services/gateway/gateway-service";
import { TGatewayV2ServiceFactory } from "@app/ee/services/gateway-v2/gateway-v2-service"; import { TGatewayV2ServiceFactory } from "@app/ee/services/gateway-v2/gateway-v2-service";
import { TGatewayServiceFactory } from "@app/ee/services/gateway/gateway-service";
import { TAppConnectionDALFactory } from "@app/services/app-connection/app-connection-dal"; import { TAppConnectionDALFactory } from "@app/services/app-connection/app-connection-dal";
import { TSqlConnectionConfig } from "@app/services/app-connection/shared/sql/sql-connection-types"; import { TSqlConnectionConfig } from "@app/services/app-connection/shared/sql/sql-connection-types";
import { SecretSync } from "@app/services/secret-sync/secret-sync-enums"; import { SecretSync } from "@app/services/secret-sync/secret-sync-enums";
@@ -106,6 +106,12 @@ import {
TDigitalOceanConnectionInput, TDigitalOceanConnectionInput,
TValidateDigitalOceanCredentialsSchema TValidateDigitalOceanCredentialsSchema
} from "./digital-ocean"; } from "./digital-ocean";
import {
TDNSMadeEasyConnection,
TDNSMadeEasyConnectionConfig,
TDNSMadeEasyConnectionInput,
TValidateDNSMadeEasyConnectionCredentialsSchema
} from "./dns-made-easy/dns-made-easy-connection-types";
import { import {
TFlyioConnection, TFlyioConnection,
TFlyioConnectionConfig, TFlyioConnectionConfig,
@@ -279,6 +285,7 @@ export type TAppConnection = { id: string } & (
| TGitLabConnection | TGitLabConnection
| TCloudflareConnection | TCloudflareConnection
| TBitbucketConnection | TBitbucketConnection
| TDNSMadeEasyConnection
| TZabbixConnection | TZabbixConnection
| TRailwayConnection | TRailwayConnection
| TChecklyConnection | TChecklyConnection
@@ -328,6 +335,7 @@ export type TAppConnectionInput = { id: string } & (
| TGitLabConnectionInput | TGitLabConnectionInput
| TCloudflareConnectionInput | TCloudflareConnectionInput
| TBitbucketConnectionInput | TBitbucketConnectionInput
| TDNSMadeEasyConnectionInput
| TZabbixConnectionInput | TZabbixConnectionInput
| TRailwayConnectionInput | TRailwayConnectionInput
| TChecklyConnectionInput | TChecklyConnectionInput
@@ -395,6 +403,7 @@ export type TAppConnectionConfig =
| TGitLabConnectionConfig | TGitLabConnectionConfig
| TCloudflareConnectionConfig | TCloudflareConnectionConfig
| TBitbucketConnectionConfig | TBitbucketConnectionConfig
| TDNSMadeEasyConnectionConfig
| TZabbixConnectionConfig | TZabbixConnectionConfig
| TRailwayConnectionConfig | TRailwayConnectionConfig
| TChecklyConnectionConfig | TChecklyConnectionConfig
@@ -439,6 +448,7 @@ export type TValidateAppConnectionCredentialsSchema =
| TValidateGitLabConnectionCredentialsSchema | TValidateGitLabConnectionCredentialsSchema
| TValidateCloudflareConnectionCredentialsSchema | TValidateCloudflareConnectionCredentialsSchema
| TValidateBitbucketConnectionCredentialsSchema | TValidateBitbucketConnectionCredentialsSchema
| TValidateDNSMadeEasyConnectionCredentialsSchema
| TValidateZabbixConnectionCredentialsSchema | TValidateZabbixConnectionCredentialsSchema
| TValidateRailwayConnectionCredentialsSchema | TValidateRailwayConnectionCredentialsSchema
| TValidateChecklyConnectionCredentialsSchema | TValidateChecklyConnectionCredentialsSchema
@@ -1,3 +1,3 @@
export enum DNSMadeEasyConnectionMethod { export enum DNSMadeEasyConnectionMethod {
APIKey = "api-key" APIKeySecret = "api-key-secret"
} }
@@ -1,6 +1,7 @@
import { AxiosError } from "axios"; import { AxiosError } from "axios";
import { request } from "@app/lib/config/request"; import { request } from "@app/lib/config/request";
import { crypto } from "@app/lib/crypto/cryptography";
import { BadRequestError } from "@app/lib/errors"; import { BadRequestError } from "@app/lib/errors";
import { AppConnection } from "@app/services/app-connection/app-connection-enums"; import { AppConnection } from "@app/services/app-connection/app-connection-enums";
import { IntegrationUrls } from "@app/services/integration-auth/integration-list"; import { IntegrationUrls } from "@app/services/integration-auth/integration-list";
@@ -12,11 +13,42 @@ import {
TDNSMadeEasyZone TDNSMadeEasyZone
} from "./dns-made-easy-connection-types"; } from "./dns-made-easy-connection-types";
interface DNSMadeEasyApiResponse {
totalRecords: number;
totalPages: number;
data: Array<{
id: number;
name: string;
[key: string]: unknown;
}>;
page: number;
}
export const makeDNSMadeEasyAuthHeaders = (
apiKey: string,
apiSecret: string,
currentDate: Date = new Date()
): Record<string, string> => {
// Format date as "Day, DD Mon YYYY HH:MM:SS GMT" (e.g., "Mon, 01 Jan 2024 12:00:00 GMT")
const requestDate = currentDate.toUTCString();
// Generate HMAC-SHA1 signature
const hmac = crypto.nativeCrypto.createHmac("sha1", apiSecret);
hmac.update(requestDate);
const hmacSignature = hmac.digest("hex");
return {
"x-dnsme-apiKey": apiKey,
"x-dnsme-hmac": hmacSignature,
"x-dnsme-requestDate": requestDate
};
};
export const getDNSMadeEasyConnectionListItem = () => { export const getDNSMadeEasyConnectionListItem = () => {
return { return {
name: "DNS Made Easy" as const, name: "DNS Made Easy" as const,
app: AppConnection.DNSMadeEasy as const, app: AppConnection.DNSMadeEasy as const,
methods: Object.values(DNSMadeEasyConnectionMethod) as [DNSMadeEasyConnectionMethod.APIKey] methods: Object.values(DNSMadeEasyConnectionMethod) as [DNSMadeEasyConnectionMethod.APIKeySecret]
}; };
}; };
@@ -27,7 +59,7 @@ export const listDNSMadeEasyZones = async (appConnection: TDNSMadeEasyConnection
// Authentication: Use API key and secret from appConnection.credentials // Authentication: Use API key and secret from appConnection.credentials
// Return format: Array of { id: string, name: string } // Return format: Array of { id: string, name: string }
if (appConnection.method !== DNSMadeEasyConnectionMethod.APIKey) { if (appConnection.method !== DNSMadeEasyConnectionMethod.APIKeySecret) {
throw new Error("Unsupported DNS Made Easy connection method"); throw new Error("Unsupported DNS Made Easy connection method");
} }
@@ -35,56 +67,42 @@ export const listDNSMadeEasyZones = async (appConnection: TDNSMadeEasyConnection
credentials: { apiKey, apiSecret } credentials: { apiKey, apiSecret }
} = appConnection; } = appConnection;
// TODO: Make API request to DNS Made Easy try {
// const { data } = await request.get<{ data: { id: number; name: string }[] }>( // TODO:
// `${IntegrationUrls.DNS_MADE_EASY_API_URL}/V2.0/dns/managed`, const allZones: TDNSMadeEasyZone[] = [];
// { return allZones;
// headers: { } catch (error: unknown) {
// "x-dnsme-apiKey": apiKey, if (error instanceof AxiosError) {
// "x-dnsme-hmac": generateHMAC(apiSecret, ...), throw new BadRequestError({
// "x-dnsme-requestDate": requestDate, // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
// Accept: "application/json" message: `Failed to list DNS Made Easy zones: ${error.response?.data?.error?.[0] || error.message || "Unknown error"}`
// } });
// } }
// ); throw new BadRequestError({
message: "Unable to list DNS Made Easy zones"
// TODO: Transform response data to match TDNSMadeEasyZone format });
// return data.data.map((zone) => ({ }
// name: zone.name,
// id: zone.id.toString()
// }));
throw new Error("Not implemented: listDNSMadeEasyZones");
}; };
export const validateDNSMadeEasyConnectionCredentials = async (config: TDNSMadeEasyConnectionConfig) => { export const validateDNSMadeEasyConnectionCredentials = async (config: TDNSMadeEasyConnectionConfig) => {
// TODO: Implement DNS Made Easy credentials validation if (config.method !== DNSMadeEasyConnectionMethod.APIKeySecret) {
// This should call the DNS Made Easy API to validate the API key and secret
// Example API endpoint: GET https://api.dnsmadeeasy.com/V2.0/account
// Authentication: Use API key and secret from config.credentials
if (config.method !== DNSMadeEasyConnectionMethod.APIKey) {
throw new Error("Unsupported DNS Made Easy connection method"); throw new Error("Unsupported DNS Made Easy connection method");
} }
const { apiKey, apiSecret } = config.credentials; const { apiKey, apiSecret } = config.credentials;
try { try {
// TODO: Make API request to validate credentials const resp = await request.get(`${IntegrationUrls.DNS_MADE_EASY_API_URL}/V2.0/dns/managed/`, {
// const resp = await request.get(`${IntegrationUrls.DNS_MADE_EASY_API_URL}/V2.0/account`, { headers: {
// headers: { ...makeDNSMadeEasyAuthHeaders(apiKey, apiSecret),
// "x-dnsme-apiKey": apiKey, Accept: "application/json"
// "x-dnsme-hmac": generateHMAC(apiSecret, ...), }
// "x-dnsme-requestDate": requestDate, });
// Accept: "application/json" if (resp.status !== 200) {
// } throw new BadRequestError({
// }); message: "Unable to validate connection: Invalid API credentials provided."
// TODO: Validate response });
// if (resp.data === null || !resp.data.id) { }
// throw new BadRequestError({
// message: "Unable to validate connection: Invalid API credentials provided."
// });
// }
} catch (error: unknown) { } catch (error: unknown) {
if (error instanceof AxiosError) { if (error instanceof AxiosError) {
throw new BadRequestError({ throw new BadRequestError({
@@ -21,13 +21,13 @@ const BaseDNSMadeEasyConnectionSchema = BaseAppConnectionSchema.extend({
}); });
export const DNSMadeEasyConnectionSchema = BaseDNSMadeEasyConnectionSchema.extend({ export const DNSMadeEasyConnectionSchema = BaseDNSMadeEasyConnectionSchema.extend({
method: z.literal(DNSMadeEasyConnectionMethod.APIKey), method: z.literal(DNSMadeEasyConnectionMethod.APIKeySecret),
credentials: DNSMadeEasyConnectionApiKeyCredentialsSchema credentials: DNSMadeEasyConnectionApiKeyCredentialsSchema
}); });
export const SanitizedDNSMadeEasyConnectionSchema = z.discriminatedUnion("method", [ export const SanitizedDNSMadeEasyConnectionSchema = z.discriminatedUnion("method", [
BaseDNSMadeEasyConnectionSchema.extend({ BaseDNSMadeEasyConnectionSchema.extend({
method: z.literal(DNSMadeEasyConnectionMethod.APIKey), method: z.literal(DNSMadeEasyConnectionMethod.APIKeySecret),
credentials: DNSMadeEasyConnectionApiKeyCredentialsSchema.pick({ apiKey: true }) credentials: DNSMadeEasyConnectionApiKeyCredentialsSchema.pick({ apiKey: true })
}).describe(JSON.stringify({ title: `${APP_CONNECTION_NAME_MAP[AppConnection.DNSMadeEasy]} (API Key)` })) }).describe(JSON.stringify({ title: `${APP_CONNECTION_NAME_MAP[AppConnection.DNSMadeEasy]} (API Key)` }))
]); ]);
@@ -35,7 +35,7 @@ export const SanitizedDNSMadeEasyConnectionSchema = z.discriminatedUnion("method
export const ValidateDNSMadeEasyConnectionCredentialsSchema = z.discriminatedUnion("method", [ export const ValidateDNSMadeEasyConnectionCredentialsSchema = z.discriminatedUnion("method", [
z.object({ z.object({
method: z method: z
.literal(DNSMadeEasyConnectionMethod.APIKey) .literal(DNSMadeEasyConnectionMethod.APIKeySecret)
.describe(AppConnections.CREATE(AppConnection.DNSMadeEasy).method), .describe(AppConnections.CREATE(AppConnection.DNSMadeEasy).method),
credentials: DNSMadeEasyConnectionApiKeyCredentialsSchema.describe( credentials: DNSMadeEasyConnectionApiKeyCredentialsSchema.describe(
AppConnections.CREATE(AppConnection.DNSMadeEasy).credentials AppConnections.CREATE(AppConnection.DNSMadeEasy).credentials
@@ -3,7 +3,11 @@ import z from "zod";
import { DiscriminativePick } from "@app/lib/types"; import { DiscriminativePick } from "@app/lib/types";
import { AppConnection } from "../app-connection-enums"; import { AppConnection } from "../app-connection-enums";
import { DNSMadeEasyConnectionSchema, CreateDNSMadeEasyConnectionSchema } from "./dns-made-easy-connection-schema"; import {
CreateDNSMadeEasyConnectionSchema,
DNSMadeEasyConnectionSchema,
ValidateDNSMadeEasyConnectionCredentialsSchema
} from "./dns-made-easy-connection-schema";
export type TDNSMadeEasyConnection = z.infer<typeof DNSMadeEasyConnectionSchema>; export type TDNSMadeEasyConnection = z.infer<typeof DNSMadeEasyConnectionSchema>;
@@ -11,6 +15,8 @@ export type TDNSMadeEasyConnectionInput = z.infer<typeof CreateDNSMadeEasyConnec
app: AppConnection.DNSMadeEasy; app: AppConnection.DNSMadeEasy;
}; };
export type TValidateDNSMadeEasyConnectionCredentialsSchema = typeof ValidateDNSMadeEasyConnectionCredentialsSchema;
export type TDNSMadeEasyConnectionConfig = DiscriminativePick< export type TDNSMadeEasyConnectionConfig = DiscriminativePick<
TDNSMadeEasyConnectionInput, TDNSMadeEasyConnectionInput,
"method" | "app" | "credentials" "method" | "app" | "credentials"
@@ -105,7 +105,9 @@ export enum IntegrationUrls {
GCP_CLOUD_PLATFORM_SCOPE = "https://www.googleapis.com/auth/cloud-platform", GCP_CLOUD_PLATFORM_SCOPE = "https://www.googleapis.com/auth/cloud-platform",
GITHUB_USER_INSTALLATIONS = "https://api.github.com/user/installations", GITHUB_USER_INSTALLATIONS = "https://api.github.com/user/installations",
CHEF_API_URL = "https://api.chef.io" CHEF_API_URL = "https://api.chef.io",
DNS_MADE_EASY_API_URL = "https://api.dnsmadeeasy.com/V2.0",
DNS_MADE_EASY_SANDBOX_API_URL = "https://api.sandbox.dnsmadeeasy.com/V2.0"
} }
export const getIntegrationOptions = async () => { export const getIntegrationOptions = async () => {