Compare commits

..

8 Commits

Author SHA1 Message Date
710227a49a feat(ui): polish domains list subscription/status display 2026-03-05 17:06:29 +00:00
b72176b276 Merge pull request 'fix(actions): use plesk bin site for suspend/unsuspend domain state' (#20) from fix/domain-actions-use-site-cli into master
Reviewed-on: http://gitea.lan:3000/robbond/pleskSaas/pulls/20
2026-03-05 17:03:55 +00:00
81b0617390 fix(actions): use plesk bin site for suspend/unsuspend domain state 2026-03-05 16:59:40 +00:00
757e8953be Merge pull request 'fix(plesk): use subscription --unsuspend for unsuspend action' (#19) from fix/plesk-unsuspend-command into master
Reviewed-on: http://gitea.lan:3000/robbond/pleskSaas/pulls/19
2026-03-05 16:04:42 +00:00
c528392682 fix(plesk): use subscription --unsuspend for unsuspend action 2026-03-05 16:04:11 +00:00
a678713d1d Merge pull request 'fix(actions): unsuspend using canonical subscription identifier + refresh status' (#18) from fix/unsuspend-verify-and-refresh into master
Reviewed-on: http://gitea.lan:3000/robbond/pleskSaas/pulls/18
2026-03-05 14:27:56 +00:00
033d816d42 fix(actions): unsuspend using canonical subscription identifier + refresh status 2026-03-05 14:26:58 +00:00
a22fc2c4d2 Merge pull request 'fix(actions): send and use subscription_id for domain suspend/unsuspend' (#17) from fix/actions-use-subscription-id into master
Reviewed-on: http://gitea.lan:3000/robbond/pleskSaas/pulls/17
2026-03-05 14:20:34 +00:00
4 changed files with 169 additions and 19 deletions

View File

@@ -5,8 +5,8 @@ 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";
@@ -23,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 {
@@ -75,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
@@ -94,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,
@@ -117,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,
}, },
}); });

View File

@@ -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())}

View File

@@ -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");
@@ -618,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">
@@ -645,7 +673,14 @@ export function DashboardControls({
<button <button
onClick={() => onDomainAction(domain, "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"
> >
@@ -653,7 +688,16 @@ export function DashboardControls({
</button> </button>
<button <button
onClick={() => onDomainAction(domain, "unsuspend")} 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" className="rounded border border-emerald-300 px-2 py-1 text-xs text-emerald-700 disabled:cursor-not-allowed disabled:opacity-60"
> >
Unsuspend Unsuspend

View File

@@ -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,
]); ]);
} }