Compare commits
10 Commits
fix/subdom
...
feature/ui
| Author | SHA1 | Date | |
|---|---|---|---|
| 710227a49a | |||
| b72176b276 | |||
| 81b0617390 | |||
| 757e8953be | |||
| c528392682 | |||
| a678713d1d | |||
| 033d816d42 | |||
| a22fc2c4d2 | |||
| 825bf8dc84 | |||
| 2c52d89dc9 |
@@ -5,13 +5,14 @@ import { assertAgencyAdmin, getRouteAgencyContextOrThrow } from "@/lib/agency";
|
|||||||
import { assertRateLimit } from "@/lib/api/rate-limit";
|
import { assertRateLimit } from "@/lib/api/rate-limit";
|
||||||
import { assertSameOrigin } from "@/lib/api/security";
|
import { assertSameOrigin } from "@/lib/api/security";
|
||||||
import {
|
import {
|
||||||
suspendPleskSubscription,
|
parseSubscriptionStatusDetailsFromInfo,
|
||||||
unsuspendPleskSubscription,
|
pleskCliCall,
|
||||||
} from "@/lib/plesk/client";
|
} from "@/lib/plesk/client";
|
||||||
import { createSupabaseRouteClient } from "@/lib/supabase/route";
|
import { createSupabaseRouteClient } from "@/lib/supabase/route";
|
||||||
|
|
||||||
const actionSchema = z.object({
|
const actionSchema = z.object({
|
||||||
action: z.enum(["suspend", "unsuspend"]),
|
action: z.enum(["suspend", "unsuspend"]),
|
||||||
|
subscription_id: z.string().uuid().optional(),
|
||||||
});
|
});
|
||||||
|
|
||||||
export async function POST(
|
export async function POST(
|
||||||
@@ -22,7 +23,11 @@ export async function POST(
|
|||||||
let context: Awaited<ReturnType<typeof getRouteAgencyContextOrThrow>> | null =
|
let context: Awaited<ReturnType<typeof getRouteAgencyContextOrThrow>> | null =
|
||||||
null;
|
null;
|
||||||
let domain: { id: string; subscription_id: string | null } | null = null;
|
let domain: { id: string; subscription_id: string | null } | null = null;
|
||||||
let subscription: { id: string; plesk_subscription_id: string } | null = null;
|
let subscription: {
|
||||||
|
id: string;
|
||||||
|
plesk_subscription_id: string;
|
||||||
|
plesk_instance_id: string;
|
||||||
|
} | null = null;
|
||||||
let requestedAction: "suspend" | "unsuspend" | null = null;
|
let requestedAction: "suspend" | "unsuspend" | null = null;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
@@ -32,7 +37,8 @@ export async function POST(
|
|||||||
assertAgencyAdmin(context);
|
assertAgencyAdmin(context);
|
||||||
assertRateLimit(`plesk-domain-action:${context.userId}`, 10, 60_000);
|
assertRateLimit(`plesk-domain-action:${context.userId}`, 10, 60_000);
|
||||||
|
|
||||||
const { action } = actionSchema.parse(await req.json());
|
const payload = actionSchema.parse(await req.json());
|
||||||
|
const { action } = payload;
|
||||||
requestedAction = action;
|
requestedAction = action;
|
||||||
|
|
||||||
const { data: domainRow, error: domainError } = await supabase
|
const { data: domainRow, error: domainError } = await supabase
|
||||||
@@ -46,21 +52,23 @@ export async function POST(
|
|||||||
throw new Error("Domain not found");
|
throw new Error("Domain not found");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const resolvedSubscriptionId =
|
||||||
|
payload.subscription_id ??
|
||||||
|
(domainRow.subscription_id ? String(domainRow.subscription_id) : null);
|
||||||
|
|
||||||
domain = {
|
domain = {
|
||||||
id: String(domainRow.id),
|
id: String(domainRow.id),
|
||||||
subscription_id: domainRow.subscription_id
|
subscription_id: resolvedSubscriptionId,
|
||||||
? String(domainRow.subscription_id)
|
|
||||||
: null,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
if (!domain.subscription_id) {
|
if (!resolvedSubscriptionId) {
|
||||||
throw new Error("Domain is not linked to a subscription");
|
throw new Error("Domain is not linked to a subscription");
|
||||||
}
|
}
|
||||||
|
|
||||||
const { data: subscriptionRow, error: subscriptionError } = await supabase
|
const { data: subscriptionRow, error: subscriptionError } = await supabase
|
||||||
.from("plesk_subscriptions")
|
.from("plesk_subscriptions")
|
||||||
.select("id, plesk_subscription_id, plesk_instance_id")
|
.select("id, plesk_subscription_id, plesk_instance_id")
|
||||||
.eq("id", domain.subscription_id)
|
.eq("id", resolvedSubscriptionId)
|
||||||
.eq("agency_id", context.agencyId)
|
.eq("agency_id", context.agencyId)
|
||||||
.single();
|
.single();
|
||||||
|
|
||||||
@@ -71,6 +79,7 @@ export async function POST(
|
|||||||
subscription = {
|
subscription = {
|
||||||
id: String(subscriptionRow.id),
|
id: String(subscriptionRow.id),
|
||||||
plesk_subscription_id: String(subscriptionRow.plesk_subscription_id),
|
plesk_subscription_id: String(subscriptionRow.plesk_subscription_id),
|
||||||
|
plesk_instance_id: String(subscriptionRow.plesk_instance_id),
|
||||||
};
|
};
|
||||||
|
|
||||||
const { data: instance, error: instanceError } = await supabase
|
const { data: instance, error: instanceError } = await supabase
|
||||||
@@ -90,18 +99,100 @@ export async function POST(
|
|||||||
encryptedSecret: instance.encrypted_secret,
|
encryptedSecret: instance.encrypted_secret,
|
||||||
} as const;
|
} as const;
|
||||||
|
|
||||||
if (action === "suspend") {
|
const domainIdentifier = subscription.plesk_subscription_id;
|
||||||
await suspendPleskSubscription(
|
const siteArgs =
|
||||||
connection,
|
action === "suspend"
|
||||||
subscription.plesk_subscription_id,
|
? ["--suspend", domainIdentifier]
|
||||||
);
|
: ["--on", domainIdentifier];
|
||||||
} else {
|
|
||||||
await unsuspendPleskSubscription(
|
console.info("[domain_action] site CLI", {
|
||||||
connection,
|
action,
|
||||||
subscription.plesk_subscription_id,
|
command: "site",
|
||||||
|
args: siteArgs,
|
||||||
|
domain_id: domain.id,
|
||||||
|
subscription_id: subscription.id,
|
||||||
|
});
|
||||||
|
|
||||||
|
const siteResult = await pleskCliCall(connection, "site", siteArgs);
|
||||||
|
|
||||||
|
console.info("[domain_action] site CLI result", {
|
||||||
|
code: siteResult.code,
|
||||||
|
stdout: siteResult.stdout,
|
||||||
|
stderr: siteResult.stderr,
|
||||||
|
});
|
||||||
|
|
||||||
|
const fallbackStatus = action === "suspend" ? "suspended" : "active";
|
||||||
|
let refreshedStatus = fallbackStatus;
|
||||||
|
let refreshedStatusRaw: string | null = null;
|
||||||
|
let refreshErrorMessage: string | null = null;
|
||||||
|
|
||||||
|
try {
|
||||||
|
const infoResult = await pleskCliCall(connection, "subscription", [
|
||||||
|
"--info",
|
||||||
|
domainIdentifier,
|
||||||
|
]);
|
||||||
|
|
||||||
|
console.info("[domain_action] subscription info result", {
|
||||||
|
code: infoResult.code,
|
||||||
|
stdout: infoResult.stdout,
|
||||||
|
stderr: infoResult.stderr,
|
||||||
|
});
|
||||||
|
|
||||||
|
const parsed = parseSubscriptionStatusDetailsFromInfo(
|
||||||
|
infoResult.stdout ?? "",
|
||||||
);
|
);
|
||||||
|
refreshedStatus = parsed.status;
|
||||||
|
refreshedStatusRaw = parsed.statusRaw;
|
||||||
|
|
||||||
|
if (
|
||||||
|
action === "unsuspend" &&
|
||||||
|
refreshedStatus === "suspended" &&
|
||||||
|
(refreshedStatusRaw ?? "").toLowerCase().includes("subscriber")
|
||||||
|
) {
|
||||||
|
throw new Error(
|
||||||
|
"Domain remains suspended because its subscriber/customer account is suspended.",
|
||||||
|
);
|
||||||
|
}
|
||||||
|
} catch (refreshError) {
|
||||||
|
refreshErrorMessage =
|
||||||
|
refreshError instanceof Error
|
||||||
|
? refreshError.message.slice(0, 1000)
|
||||||
|
: "subscription_status_refresh_failed";
|
||||||
|
|
||||||
|
await supabase.from("actions_log").insert({
|
||||||
|
agency_id: context.agencyId,
|
||||||
|
actor_user_id: context.userId,
|
||||||
|
target_type: "plesk_subscription",
|
||||||
|
target_id: subscription.id,
|
||||||
|
action: "subscription_status_refresh_failed",
|
||||||
|
status: "failed",
|
||||||
|
error_message: refreshErrorMessage,
|
||||||
|
metadata: {
|
||||||
|
subscription_id: subscription.id,
|
||||||
|
plesk_subscription_id: subscription.plesk_subscription_id,
|
||||||
|
plesk_instance_id: subscription.plesk_instance_id,
|
||||||
|
source: "domain_action",
|
||||||
|
domain_id: domain.id,
|
||||||
|
},
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
await supabase
|
||||||
|
.from("plesk_subscriptions")
|
||||||
|
.update({
|
||||||
|
status: refreshedStatus,
|
||||||
|
status_raw: refreshedStatusRaw,
|
||||||
|
last_status_sync_at: new Date().toISOString(),
|
||||||
|
})
|
||||||
|
.eq("id", subscription.id)
|
||||||
|
.eq("agency_id", context.agencyId);
|
||||||
|
|
||||||
|
await supabase
|
||||||
|
.from("plesk_domains")
|
||||||
|
.update({ status: refreshedStatus })
|
||||||
|
.eq("agency_id", context.agencyId)
|
||||||
|
.eq("subscription_id", subscription.id);
|
||||||
|
|
||||||
await supabase.from("actions_log").insert({
|
await supabase.from("actions_log").insert({
|
||||||
agency_id: context.agencyId,
|
agency_id: context.agencyId,
|
||||||
actor_user_id: context.userId,
|
actor_user_id: context.userId,
|
||||||
@@ -113,6 +204,8 @@ export async function POST(
|
|||||||
domain_id: domain.id,
|
domain_id: domain.id,
|
||||||
subscription_id: subscription.id,
|
subscription_id: subscription.id,
|
||||||
plesk_subscription_id: subscription.plesk_subscription_id,
|
plesk_subscription_id: subscription.plesk_subscription_id,
|
||||||
|
refreshed_status: refreshedStatus,
|
||||||
|
refresh_error: refreshErrorMessage,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
@@ -154,6 +154,19 @@ export default async function DashboardPage() {
|
|||||||
]),
|
]),
|
||||||
);
|
);
|
||||||
|
|
||||||
|
const subscriptionDisplayNameById = new Map<string, string>(
|
||||||
|
(domainSubscriptions ?? [])
|
||||||
|
.filter((subscription: any) => subscription?.id)
|
||||||
|
.map((subscription: any) => [
|
||||||
|
String(subscription.id),
|
||||||
|
String(
|
||||||
|
subscription?.name ||
|
||||||
|
subscription?.plesk_subscription_id ||
|
||||||
|
subscription?.id,
|
||||||
|
),
|
||||||
|
]),
|
||||||
|
);
|
||||||
|
|
||||||
const subscriptionStatusByExternalId = new Map<string, string | null>(
|
const subscriptionStatusByExternalId = new Map<string, string | null>(
|
||||||
(domainSubscriptions ?? [])
|
(domainSubscriptions ?? [])
|
||||||
.filter((subscription: any) =>
|
.filter((subscription: any) =>
|
||||||
@@ -278,6 +291,10 @@ export default async function DashboardPage() {
|
|||||||
return {
|
return {
|
||||||
...domain,
|
...domain,
|
||||||
status: joinedStatus ?? "unknown",
|
status: joinedStatus ?? "unknown",
|
||||||
|
subscription_name: domain.subscription_id
|
||||||
|
? (subscriptionDisplayNameById.get(domain.subscription_id) ??
|
||||||
|
null)
|
||||||
|
: null,
|
||||||
};
|
};
|
||||||
})}
|
})}
|
||||||
autoSyncByInstance={Object.fromEntries(autoSyncByInstance.entries())}
|
autoSyncByInstance={Object.fromEntries(autoSyncByInstance.entries())}
|
||||||
|
|||||||
@@ -32,6 +32,7 @@ type Domain = {
|
|||||||
id: string;
|
id: string;
|
||||||
plesk_instance_id: string;
|
plesk_instance_id: string;
|
||||||
subscription_id: string | null;
|
subscription_id: string | null;
|
||||||
|
subscription_name?: string | null;
|
||||||
domain_name: string;
|
domain_name: string;
|
||||||
status: string | null;
|
status: string | null;
|
||||||
hosting_type: string | null;
|
hosting_type: string | null;
|
||||||
@@ -72,6 +73,23 @@ function getDomainStatusBadge(status: string | null) {
|
|||||||
return "bg-slate-100 text-slate-600";
|
return "bg-slate-100 text-slate-600";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function formatDomainStatusLabel(status: string | null) {
|
||||||
|
const normalized = (status ?? "unknown").toLowerCase();
|
||||||
|
|
||||||
|
if (normalized.includes("suspend")) return "Suspended";
|
||||||
|
if (normalized.includes("disabled")) return "Disabled";
|
||||||
|
if (normalized.includes("expired")) return "Expired";
|
||||||
|
if (
|
||||||
|
normalized.includes("active") ||
|
||||||
|
normalized.includes("ok") ||
|
||||||
|
normalized.includes("enabled")
|
||||||
|
) {
|
||||||
|
return "Active";
|
||||||
|
}
|
||||||
|
|
||||||
|
return "Unknown";
|
||||||
|
}
|
||||||
|
|
||||||
function isDomainSuspended(status: string | null) {
|
function isDomainSuspended(status: string | null) {
|
||||||
const normalized = (status ?? "unknown").toLowerCase();
|
const normalized = (status ?? "unknown").toLowerCase();
|
||||||
return normalized.includes("suspend") || normalized.includes("disabled");
|
return normalized.includes("suspend") || normalized.includes("disabled");
|
||||||
@@ -239,13 +257,23 @@ export function DashboardControls({
|
|||||||
}
|
}
|
||||||
|
|
||||||
async function onDomainAction(
|
async function onDomainAction(
|
||||||
domainId: string,
|
domain: Domain,
|
||||||
action: "suspend" | "unsuspend",
|
action: "suspend" | "unsuspend",
|
||||||
) {
|
) {
|
||||||
|
if (!domain.subscription_id) {
|
||||||
|
setMessage(
|
||||||
|
"Domain is not linked to a subscription yet. Run Sync Now (or backfill links) and try again.",
|
||||||
|
);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
setLoading(true);
|
setLoading(true);
|
||||||
setMessage(null);
|
setMessage(null);
|
||||||
try {
|
try {
|
||||||
await runRequest(`/api/plesk/domains/${domainId}/action`, { action });
|
await runRequest(`/api/plesk/domains/${domain.id}/action`, {
|
||||||
|
action,
|
||||||
|
subscription_id: domain.subscription_id,
|
||||||
|
});
|
||||||
setMessage("Domain action completed.");
|
setMessage("Domain action completed.");
|
||||||
window.location.reload();
|
window.location.reload();
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
@@ -608,16 +636,26 @@ export function DashboardControls({
|
|||||||
{domain.domain_name}
|
{domain.domain_name}
|
||||||
</a>
|
</a>
|
||||||
{domain.subscription_id ? (
|
{domain.subscription_id ? (
|
||||||
<p className="text-xs font-normal text-slate-500">
|
<p
|
||||||
Subscription: {domain.subscription_id}
|
className="text-xs font-normal text-slate-500"
|
||||||
|
title={`Subscription UUID: ${domain.subscription_id}`}
|
||||||
|
>
|
||||||
|
Subscription: {domain.subscription_name ?? "Linked"}
|
||||||
</p>
|
</p>
|
||||||
) : null}
|
) : (
|
||||||
|
<p
|
||||||
|
className="text-xs font-normal text-amber-700"
|
||||||
|
title="Run sync to link this domain to a subscription"
|
||||||
|
>
|
||||||
|
Subscription: Unlinked
|
||||||
|
</p>
|
||||||
|
)}
|
||||||
</td>
|
</td>
|
||||||
<td className="px-2 py-2">
|
<td className="px-2 py-2">
|
||||||
<span
|
<span
|
||||||
className={`inline-flex rounded px-2 py-0.5 text-xs font-medium ${getDomainStatusBadge(domain.status)}`}
|
className={`inline-flex rounded px-2 py-0.5 text-xs font-medium ${getDomainStatusBadge(domain.status)}`}
|
||||||
>
|
>
|
||||||
{domain.status ?? "unknown"}
|
{formatDomainStatusLabel(domain.status)}
|
||||||
</span>
|
</span>
|
||||||
</td>
|
</td>
|
||||||
<td className="px-2 py-2">
|
<td className="px-2 py-2">
|
||||||
@@ -633,19 +671,33 @@ export function DashboardControls({
|
|||||||
<td className="px-2 py-2">
|
<td className="px-2 py-2">
|
||||||
<div className="flex gap-2">
|
<div className="flex gap-2">
|
||||||
<button
|
<button
|
||||||
onClick={() => onDomainAction(domain.id, "suspend")}
|
onClick={() => onDomainAction(domain, "suspend")}
|
||||||
disabled={
|
disabled={
|
||||||
loading || isDomainSuspended(domain.status)
|
loading ||
|
||||||
|
!domain.subscription_id ||
|
||||||
|
isDomainSuspended(domain.status)
|
||||||
|
}
|
||||||
|
title={
|
||||||
|
!domain.subscription_id
|
||||||
|
? "Not linked to a subscription yet — run sync"
|
||||||
|
: undefined
|
||||||
}
|
}
|
||||||
className="rounded border border-rose-300 px-2 py-1 text-xs text-rose-700 disabled:cursor-not-allowed disabled:opacity-60"
|
className="rounded border border-rose-300 px-2 py-1 text-xs text-rose-700 disabled:cursor-not-allowed disabled:opacity-60"
|
||||||
>
|
>
|
||||||
Suspend
|
Suspend
|
||||||
</button>
|
</button>
|
||||||
<button
|
<button
|
||||||
onClick={() =>
|
onClick={() => onDomainAction(domain, "unsuspend")}
|
||||||
onDomainAction(domain.id, "unsuspend")
|
disabled={
|
||||||
|
loading ||
|
||||||
|
!domain.subscription_id ||
|
||||||
|
isDomainActive(domain.status)
|
||||||
|
}
|
||||||
|
title={
|
||||||
|
!domain.subscription_id
|
||||||
|
? "Not linked to a subscription yet — run sync"
|
||||||
|
: undefined
|
||||||
}
|
}
|
||||||
disabled={loading || isDomainActive(domain.status)}
|
|
||||||
className="rounded border border-emerald-300 px-2 py-1 text-xs text-emerald-700 disabled:cursor-not-allowed disabled:opacity-60"
|
className="rounded border border-emerald-300 px-2 py-1 text-xs text-emerald-700 disabled:cursor-not-allowed disabled:opacity-60"
|
||||||
>
|
>
|
||||||
Unsuspend
|
Unsuspend
|
||||||
|
|||||||
@@ -289,7 +289,7 @@ export async function unsuspendPleskSubscription(
|
|||||||
subscriptionName: string,
|
subscriptionName: string,
|
||||||
) {
|
) {
|
||||||
return pleskCliCall(connection, "subscription", [
|
return pleskCliCall(connection, "subscription", [
|
||||||
"--webspace-on",
|
"--unsuspend",
|
||||||
subscriptionName,
|
subscriptionName,
|
||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user