Compare commits
8 Commits
fix/action
...
feature/ui
| Author | SHA1 | Date | |
|---|---|---|---|
| 710227a49a | |||
| b72176b276 | |||
| 81b0617390 | |||
| 757e8953be | |||
| c528392682 | |||
| a678713d1d | |||
| 033d816d42 | |||
| a22fc2c4d2 |
@@ -5,8 +5,8 @@ import { assertAgencyAdmin, getRouteAgencyContextOrThrow } from "@/lib/agency";
|
||||
import { assertRateLimit } from "@/lib/api/rate-limit";
|
||||
import { assertSameOrigin } from "@/lib/api/security";
|
||||
import {
|
||||
suspendPleskSubscription,
|
||||
unsuspendPleskSubscription,
|
||||
parseSubscriptionStatusDetailsFromInfo,
|
||||
pleskCliCall,
|
||||
} from "@/lib/plesk/client";
|
||||
import { createSupabaseRouteClient } from "@/lib/supabase/route";
|
||||
|
||||
@@ -23,7 +23,11 @@ export async function POST(
|
||||
let context: Awaited<ReturnType<typeof getRouteAgencyContextOrThrow>> | 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;
|
||||
|
||||
try {
|
||||
@@ -75,6 +79,7 @@ export async function POST(
|
||||
subscription = {
|
||||
id: String(subscriptionRow.id),
|
||||
plesk_subscription_id: String(subscriptionRow.plesk_subscription_id),
|
||||
plesk_instance_id: String(subscriptionRow.plesk_instance_id),
|
||||
};
|
||||
|
||||
const { data: instance, error: instanceError } = await supabase
|
||||
@@ -94,17 +99,99 @@ export async function POST(
|
||||
encryptedSecret: instance.encrypted_secret,
|
||||
} as const;
|
||||
|
||||
if (action === "suspend") {
|
||||
await suspendPleskSubscription(
|
||||
connection,
|
||||
subscription.plesk_subscription_id,
|
||||
const domainIdentifier = subscription.plesk_subscription_id;
|
||||
const siteArgs =
|
||||
action === "suspend"
|
||||
? ["--suspend", domainIdentifier]
|
||||
: ["--on", domainIdentifier];
|
||||
|
||||
console.info("[domain_action] site CLI", {
|
||||
action,
|
||||
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 ?? "",
|
||||
);
|
||||
} else {
|
||||
await unsuspendPleskSubscription(
|
||||
connection,
|
||||
subscription.plesk_subscription_id,
|
||||
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({
|
||||
agency_id: context.agencyId,
|
||||
@@ -117,6 +204,8 @@ export async function POST(
|
||||
domain_id: domain.id,
|
||||
subscription_id: 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>(
|
||||
(domainSubscriptions ?? [])
|
||||
.filter((subscription: any) =>
|
||||
@@ -278,6 +291,10 @@ export default async function DashboardPage() {
|
||||
return {
|
||||
...domain,
|
||||
status: joinedStatus ?? "unknown",
|
||||
subscription_name: domain.subscription_id
|
||||
? (subscriptionDisplayNameById.get(domain.subscription_id) ??
|
||||
null)
|
||||
: null,
|
||||
};
|
||||
})}
|
||||
autoSyncByInstance={Object.fromEntries(autoSyncByInstance.entries())}
|
||||
|
||||
@@ -32,6 +32,7 @@ type Domain = {
|
||||
id: string;
|
||||
plesk_instance_id: string;
|
||||
subscription_id: string | null;
|
||||
subscription_name?: string | null;
|
||||
domain_name: string;
|
||||
status: string | null;
|
||||
hosting_type: string | null;
|
||||
@@ -72,6 +73,23 @@ function getDomainStatusBadge(status: string | null) {
|
||||
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) {
|
||||
const normalized = (status ?? "unknown").toLowerCase();
|
||||
return normalized.includes("suspend") || normalized.includes("disabled");
|
||||
@@ -618,16 +636,26 @@ export function DashboardControls({
|
||||
{domain.domain_name}
|
||||
</a>
|
||||
{domain.subscription_id ? (
|
||||
<p className="text-xs font-normal text-slate-500">
|
||||
Subscription: {domain.subscription_id}
|
||||
<p
|
||||
className="text-xs font-normal text-slate-500"
|
||||
title={`Subscription UUID: ${domain.subscription_id}`}
|
||||
>
|
||||
Subscription: {domain.subscription_name ?? "Linked"}
|
||||
</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 className="px-2 py-2">
|
||||
<span
|
||||
className={`inline-flex rounded px-2 py-0.5 text-xs font-medium ${getDomainStatusBadge(domain.status)}`}
|
||||
>
|
||||
{domain.status ?? "unknown"}
|
||||
{formatDomainStatusLabel(domain.status)}
|
||||
</span>
|
||||
</td>
|
||||
<td className="px-2 py-2">
|
||||
@@ -645,7 +673,14 @@ export function DashboardControls({
|
||||
<button
|
||||
onClick={() => onDomainAction(domain, "suspend")}
|
||||
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"
|
||||
>
|
||||
@@ -653,7 +688,16 @@ export function DashboardControls({
|
||||
</button>
|
||||
<button
|
||||
onClick={() => onDomainAction(domain, "unsuspend")}
|
||||
disabled={loading || isDomainActive(domain.status)}
|
||||
disabled={
|
||||
loading ||
|
||||
!domain.subscription_id ||
|
||||
isDomainActive(domain.status)
|
||||
}
|
||||
title={
|
||||
!domain.subscription_id
|
||||
? "Not linked to a subscription yet — run sync"
|
||||
: undefined
|
||||
}
|
||||
className="rounded border border-emerald-300 px-2 py-1 text-xs text-emerald-700 disabled:cursor-not-allowed disabled:opacity-60"
|
||||
>
|
||||
Unsuspend
|
||||
|
||||
@@ -289,7 +289,7 @@ export async function unsuspendPleskSubscription(
|
||||
subscriptionName: string,
|
||||
) {
|
||||
return pleskCliCall(connection, "subscription", [
|
||||
"--webspace-on",
|
||||
"--unsuspend",
|
||||
subscriptionName,
|
||||
]);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user