fix(integrations): sync только по сохранённым cfdmApiUrl и токену
Docker / build (push) Failing after 18s

Убран fallback на локальный App Switcher (192.168.x). URL из portal подставляется в форму для сохранения; кнопка sync требует URL в БД.

Co-authored-by: Cursor <[email protected]>
This commit is contained in:
Denozordec
2026-08-01 00:46:28 +07:00
co-authored by Cursor
parent c5198cdd7f
commit d4d59f4b8e
5 changed files with 76 additions and 43 deletions
+25 -6
View File
@@ -1,4 +1,4 @@
import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest' import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest'
import { closeDb } from '@cfdm/db' import { closeDb } from '@cfdm/db'
import { settingsRepository } from '@cfdm/db/repositories/settings' import { settingsRepository } from '@cfdm/db/repositories/settings'
import { resetTestDb } from '@cfdm/db/test-setup' import { resetTestDb } from '@cfdm/db/test-setup'
@@ -191,19 +191,38 @@ describe('settings cfdm sync', () => {
integrationEnabled: true, integrationEnabled: true,
integrationToken: 'shared-token', integrationToken: 'shared-token',
cfdmApiUrl: '', cfdmApiUrl: '',
})
const res = await app.inject({ method: 'POST', url: '/api/settings/cfdm/sync' })
expect(res.statusCode).toBe(502)
const body = res.json() as { ok: boolean; error: string }
expect(body.ok).toBe(false)
expect(body.error).toContain('URL API CFDM')
})
it('uses only saved cfdmApiUrl, not App Switcher defaults', async () => {
settingsRepository.upsert('settings-main', {
integrationEnabled: true,
integrationToken: 'shared-token',
cfdmApiUrl: 'https://cfdm.prod.example',
appSwitcher: { appSwitcher: {
menuLabel: 'Apps', menuLabel: 'Apps',
apps: [ apps: [
{ {
id: 'vps-tracker', id: 'cfdm',
name: 'VPS Tracker', name: 'CFDM',
url: 'http://127.0.0.1:3001', url: 'http://192.168.100.67:6363',
}, },
], ],
}, },
}) })
const fetchMock = vi.fn(async () =>
Response.json({ ok: true, count: 0, bindings: [], fullSync: true }),
)
vi.stubGlobal('fetch', fetchMock)
const res = await app.inject({ method: 'POST', url: '/api/settings/cfdm/sync' }) const res = await app.inject({ method: 'POST', url: '/api/settings/cfdm/sync' })
expect(res.statusCode).toBe(502) expect(res.statusCode).toBe(200)
expect(res.json()).toMatchObject({ ok: false }) const call = fetchMock.mock.calls[0] as [string] | undefined
expect(call?.[0]).toBe('https://cfdm.prod.example/api/v1/integrations/vps-tracker/sync')
}) })
}) })
+3 -5
View File
@@ -4,11 +4,9 @@ import type { VpsTrackerEvent } from '@cfdm/shared/contracts/integration-cfdm'
function resolveCfdmApiBase(): string | null { function resolveCfdmApiBase(): string | null {
const row = settingsRepository.getBySpace() const row = settingsRepository.getBySpace()
if (!row) return null const explicit = row?.cfdmApiUrl?.trim() ?? ''
const explicit = row.cfdmApiUrl?.trim() if (!explicit) return null
if (explicit) return explicit.replace(/\/$/, '') return explicit.replace(/\/$/, '')
const cfdm = settingsRepository.getAppSwitcher().apps.find((a) => a.id === 'cfdm')
return cfdm?.url?.trim().replace(/\/$/, '') ?? null
} }
export async function notifyCfdmVpsEvent( export async function notifyCfdmVpsEvent(
+13 -12
View File
@@ -17,22 +17,20 @@ function isUsableHttpUrl(raw: string): boolean {
} }
} }
/** Только явно сохранённый settings.cfdmApiUrl — без App Switcher / локальных дефолтов. */
function resolveCfdmApiBase(): string | null { function resolveCfdmApiBase(): string | null {
const row = settingsRepository.getBySpace() const row = settingsRepository.getBySpace()
if (!row) return null const explicit = row?.cfdmApiUrl?.trim() ?? ''
const explicit = row.cfdmApiUrl?.trim() if (!explicit) return null
if (explicit && isUsableHttpUrl(explicit)) return explicit.replace(/\/$/, '') if (!isUsableHttpUrl(explicit)) return null
const cfdm = settingsRepository.getAppSwitcher().apps.find((a) => a.id === 'cfdm') return explicit.replace(/\/$/, '')
const fromSwitcher = cfdm?.url?.trim().replace(/\/$/, '') ?? ''
if (fromSwitcher && isUsableHttpUrl(fromSwitcher)) return fromSwitcher
return null
} }
function networkErrorMessage(baseUrl: string, err: unknown): string { function networkErrorMessage(baseUrl: string, err: unknown): string {
const raw = err instanceof Error ? err.message : 'Ошибка сети' const raw = err instanceof Error ? err.message : 'Ошибка сети'
return ( return (
`Не удалось подключиться к CFDM (${baseUrl}): ${raw}. ` + `Не удалось подключиться к CFDM (${baseUrl}): ${raw}. ` +
'Укажите URL API CFDM (доступный с хоста VPS Tracker API) и сохраните.' 'Проверьте, что сохранённый URL API доступен с хоста, где запущен VPS Tracker API.'
) )
} }
@@ -47,10 +45,15 @@ export async function requestCfdmFullSync(): Promise<{
return { return {
ok: false, ok: false,
error: error:
'Укажите URL API CFDM в настройках интеграции (или добавьте приложение cfdm в App Switcher)', 'URL API CFDM не сохранён в настройках интеграции. Укажите продовый URL и нажмите «Сохранить интеграцию».',
}
}
if (!token) {
return {
ok: false,
error: 'Integration token не сохранён. Сгенерируйте/вставьте токен и сохраните интеграцию.',
} }
} }
if (!token) return { ok: false, error: 'Укажите integration token' }
const syncUrl = `${baseUrl}/api/v1/integrations/vps-tracker/sync` const syncUrl = `${baseUrl}/api/v1/integrations/vps-tracker/sync`
@@ -75,7 +78,6 @@ export async function requestCfdmFullSync(): Promise<{
} }
} }
// Pull: CFDM отдаёт bindings в ответе — применяем локально (без обратного push).
if (Array.isArray(body.bindings)) { if (Array.isArray(body.bindings)) {
const parsed = cfdmSyncBindingsBodySchema.safeParse({ const parsed = cfdmSyncBindingsBodySchema.safeParse({
bindings: body.bindings, bindings: body.bindings,
@@ -97,7 +99,6 @@ export async function requestCfdmFullSync(): Promise<{
} }
} }
// Legacy: CFDM уже запушил bindings сам и вернул только count.
settingsRepository.touchIntegrationSync() settingsRepository.touchIntegrationSync()
return { ok: true, count: body.count ?? 0 } return { ok: true, count: body.count ?? 0 }
} catch (err) { } catch (err) {
@@ -1,3 +1,4 @@
import { useEffect } from 'react'
import { useForm, Controller } from 'react-hook-form' import { useForm, Controller } from 'react-hook-form'
import { zodResolver } from '@hookform/resolvers/zod' import { zodResolver } from '@hookform/resolvers/zod'
import { z } from 'zod' import { z } from 'zod'
@@ -31,7 +32,7 @@ function generateToken(): string {
interface CfdmIntegrationFormProps { interface CfdmIntegrationFormProps {
settings?: Settings settings?: Settings
/** URL CFDM из App Switcher — подсказка и fallback, если cfdmApiUrl не сохранён */ /** URL CFDM из App Switcher (portal) — только подсказка для заполнения поля */
fallbackCfdmUrl?: string fallbackCfdmUrl?: string
onSave: (values: { onSave: (values: {
cfdmApiUrl?: string cfdmApiUrl?: string
@@ -49,15 +50,25 @@ export function CfdmIntegrationForm({
isSaving, isSaving,
}: CfdmIntegrationFormProps) { }: CfdmIntegrationFormProps) {
const queryClient = useQueryClient() const queryClient = useQueryClient()
const savedUrl = settings?.cfdmApiUrl?.trim() ?? ''
const switcherUrl = fallbackCfdmUrl?.trim() || ''
const form = useForm<FormValues>({ const form = useForm<FormValues>({
resolver: zodResolver(formSchema), resolver: zodResolver(formSchema),
values: { values: {
cfdmApiUrl: settings?.cfdmApiUrl ?? '', cfdmApiUrl: savedUrl,
integrationToken: '', integrationToken: '',
integrationEnabled: Boolean(settings?.integrationEnabled), integrationEnabled: Boolean(settings?.integrationEnabled),
}, },
}) })
// Если URL ещё не сохранён в settings — подставить prod URL из App Switcher и включить «Сохранить».
useEffect(() => {
if (savedUrl || !switcherUrl) return
if (form.getValues('cfdmApiUrl')?.trim()) return
form.setValue('cfdmApiUrl', switcherUrl, { shouldDirty: true, shouldTouch: true })
}, [savedUrl, switcherUrl, form])
const syncMut = useMutation({ const syncMut = useMutation({
mutationFn: () => api.syncCfdm(), mutationFn: () => api.syncCfdm(),
onSuccess: async (result) => { onSuccess: async (result) => {
@@ -75,18 +86,18 @@ export function CfdmIntegrationForm({
function handleSubmit(values: FormValues) { function handleSubmit(values: FormValues) {
const token = values.integrationToken?.trim() const token = values.integrationToken?.trim()
const url = values.cfdmApiUrl?.trim() ?? ''
onSave({ onSave({
integrationEnabled: values.integrationEnabled, integrationEnabled: values.integrationEnabled,
cfdmApiUrl: values.cfdmApiUrl?.trim() || undefined, // Всегда пишем явное значение — иначе URL не попадает в БД.
cfdmApiUrl: url,
...(token ? { integrationToken: token } : {}), ...(token ? { integrationToken: token } : {}),
}) })
} }
const hasSavedToken = Boolean(settings?.integrationTokenSet) const hasSavedToken = Boolean(settings?.integrationTokenSet)
const hasSavedUrl = Boolean(settings?.cfdmApiUrl?.trim()) const hasSavedUrl = Boolean(savedUrl)
const switcherUrl = fallbackCfdmUrl?.trim() || '' const canSync = hasSavedToken && hasSavedUrl
const canSync =
hasSavedToken || Boolean(settings?.integrationLastSyncAt?.trim())
return ( return (
<form <form
@@ -96,7 +107,7 @@ export function CfdmIntegrationForm({
<FieldGroup className="gap-0"> <FieldGroup className="gap-0">
<SettingRow <SettingRow
title="Принимать синхронизацию" title="Принимать синхронизацию"
description="Разрешить CFDM пушить домены и сервисы (авто-sync). Ручная кнопка работает и без этого." description="Разрешить CFDM пушить домены и сервисы (авто-sync)"
> >
<Controller <Controller
control={form.control} control={form.control}
@@ -114,10 +125,10 @@ export function CfdmIntegrationForm({
title="URL API CFDM" title="URL API CFDM"
description={ description={
hasSavedUrl hasSavedUrl
? 'Сохранён — ручной sync и failover vps_down' ? `Сохранён: ${savedUrl}`
: switcherUrl : switcherUrl
? `Не сохранён — sync пойдёт на App Switcher: ${switcherUrl}` ? `Не сохранён в БД. Подставлен URL из App Switcher — нажмите «Сохранить интеграцию»`
: 'Укажите URL API CFDM (например http://192.168.x.x:6363) и сохраните' : 'Укажите продовый URL API CFDM и сохраните'
} }
labelFor="cfdm-api-url" labelFor="cfdm-api-url"
stacked stacked
@@ -125,7 +136,7 @@ export function CfdmIntegrationForm({
<Input <Input
id="cfdm-api-url" id="cfdm-api-url"
className="w-full" className="w-full"
placeholder={switcherUrl || 'http://192.168.100.67:6363'} placeholder="https://cfdm.example.org"
{...form.register('cfdmApiUrl')} {...form.register('cfdmApiUrl')}
/> />
</SettingRow> </SettingRow>
@@ -173,7 +184,7 @@ export function CfdmIntegrationForm({
description={ description={
settings?.integrationLastSyncAt settings?.integrationLastSyncAt
? `Последний sync: ${new Date(settings.integrationLastSyncAt).toLocaleString('ru-RU')}` ? `Последний sync: ${new Date(settings.integrationLastSyncAt).toLocaleString('ru-RU')}`
: 'Запросить полную выгрузку доменов и сервисов из CFDM' : 'Используются только сохранённые URL и токен'
} }
last last
> >
@@ -185,11 +196,17 @@ export function CfdmIntegrationForm({
disabled={syncMut.isPending || !canSync} disabled={syncMut.isPending || !canSync}
title={ title={
canSync canSync
? 'Синхронизировать по сохранённым credentials' ? `Синхронизировать с ${savedUrl}`
: 'Сначала сохраните integration token' : !hasSavedUrl
? 'Сначала сохраните URL API CFDM'
: 'Сначала сохраните integration token'
} }
onClick={() => { onClick={() => {
if (!canSync) { if (!hasSavedUrl) {
toast.error('Сначала сохраните URL API CFDM (кнопка «Сохранить интеграцию»)')
return
}
if (!hasSavedToken) {
toast.error('Сначала сохраните integration token') toast.error('Сначала сохраните integration token')
return return
} }
@@ -243,11 +243,9 @@ function SettingsIntegrationsPage() {
id="cfdm" id="cfdm"
name="CF Domain Manager" name="CF Domain Manager"
description={ description={
current?.cfdmApiUrl current?.cfdmApiUrl?.trim()
? current.cfdmApiUrl ? current.cfdmApiUrl
: appSwitcher.apps.find((a) => a.id === 'cfdm')?.url : 'URL API не сохранён — укажите продовый домен и сохраните'
? `URL из App Switcher · приём доменов и сервисов`
: 'Приём синхронизации доменов и сервисов'
} }
logo={<GlobeIcon aria-hidden="true" />} logo={<GlobeIcon aria-hidden="true" />}
status={cfdmStatus} status={cfdmStatus}