console/src/lib/stores/database.ts

import { derived, get, writable } from 'svelte/store';
import { page } from '$app/stores';
import { type Models, Query } from '@appwrite.io/console';
import { sdk } from '$lib/stores/sdk';
import { headerAlert } from '$lib/stores/headerAlert';
import BackupDatabase from '$lib/components/backupDatabaseAlert.svelte';
import { shouldShowNotification } from '$lib/helpers/notifications';
import { isCloud } from '$lib/system';
import { currentPlan } from '$lib/stores/organization';
import { ProfileMode, resolvedProfile } from '$lib/profiles/index.svelte';

export const database = derived(page, ($page) => $page.data?.database as Models.Database);

export const backupsBannerId = 'banner:databaseBackups';

export const showPolicyAlert = writable<boolean>(false);

export async function checkForDatabaseBackupPolicies(
    region: string,
    projectId: string,
    database: Models.Database
) {
    // fast path: not the valid profile to show this!
    if (resolvedProfile.id !== ProfileMode.CONSOLE) return;

    // fast path: return if user dismissed the banner.
    if (!shouldShowNotification(backupsBannerId)) return;

    let total = 0;
    const backupsEnabled = get(currentPlan)?.backupsEnabled ?? true;

    if (isCloud && backupsEnabled) {
        try {
            const policies = await sdk
                .forProject(region, projectId)
                .backups.listPolicies([Query.limit(1), Query.equal('resourceId', database.$id)]);

            total = policies.total;
        } catch (e) {
            // ignore, backups not allowed on free plan error.
        }
    }

    showPolicyAlert.set(total <= 0);

    if (!total) {
        headerAlert.add({
            id: backupsBannerId,
            component: BackupDatabase,
            show: true,
            importance: 1
        });
    }
}

function createSubNavigationTrigger() {
    const subscribers = new Set<() => void>();

    return {
        subscribe: (callback: () => void) => {
            subscribers.add(callback);
            return () => {
                subscribers.delete(callback);
            };
        },
        update: () => {
            subscribers.forEach((callback) => callback());
        }
    };
}

export const subNavigation = createSubNavigationTrigger();