update: object params from positional params.

This commit is contained in:
Darshan
2026-01-08 14:10:19 +05:30
parent dfffe3487e
commit 83a3533fbd
7 changed files with 60 additions and 57 deletions
+3 -3
View File
@@ -27,9 +27,9 @@ export async function checkForDatabaseBackupPolicies(
if (isCloud && backupsEnabled) {
try {
const policies = await sdk
.forProject(region, projectId)
.backups.listPolicies([Query.limit(1), Query.equal('resourceId', database.$id)]);
const policies = await sdk.forProject(region, projectId).backups.listPolicies({
queries: [Query.limit(1), Query.equal('resourceId', database.$id)]
});
total = policies.total;
} catch (e) {
@@ -93,12 +93,14 @@ async function fetchPolicies(databases: Models.DatabaseList, params: RouteParams
try {
const { policies } = await sdk
.forProject(params.region, params.project)
.backups.listPolicies([
// TODO: are all needed!?
// Query.limit(3),
Query.equal('resourceType', 'database'),
Query.equal('resourceId', database.$id)
]);
.backups.listPolicies({
queries: [
// TODO: are all needed!?
// Query.limit(3),
Query.equal('resourceType', 'database'),
Query.equal('resourceId', database.$id)
]
});
if (policies.length > 0) {
databasePolicies[database.$id] = policies;
@@ -122,12 +124,14 @@ async function fetchLastBackups(databases: Models.DatabaseList, params: RoutePar
try {
const { archives } = await sdk
.forProject(params.region, params.project)
.backups.listArchives([
Query.limit(1),
Query.orderDesc('$createdAt'),
Query.equal('resourceType', 'database'),
Query.equal('resourceId', database.$id)
]);
.backups.listArchives({
queries: [
Query.limit(1),
Query.orderDesc('$createdAt'),
Query.equal('resourceType', 'database'),
Query.equal('resourceId', database.$id)
]
});
if (archives.length > 0) {
lastBackups[database.$id] = timeFromNow(archives[0].$createdAt);
@@ -61,16 +61,14 @@
const totalPoliciesPromise = totalPolicies.map((policy) => {
cronExpression(policy);
return sdk
.forProject(page.params.region, page.params.project)
.backups.createPolicy(
ID.unique(),
['databases'],
policy.retained,
policy.schedule,
policy.label,
resourceId
);
return sdk.forProject(page.params.region, page.params.project).backups.createPolicy({
policyId: ID.unique(),
services: ['databases'],
retention: policy.retained,
schedule: policy.schedule,
name: policy.label,
resourceId
});
});
await Promise.all(totalPoliciesPromise);
@@ -66,9 +66,10 @@
const createManualBackup = async () => {
try {
await sdk
.forProject(page.params.region, page.params.project)
.backups.createArchive(['databases'], data.database.$id);
await sdk.forProject(page.params.region, page.params.project).backups.createArchive({
services: ['databases'],
resourceId: data.database.$id
});
await invalidate(Dependencies.BACKUPS);
addNotification({
type: 'success',
@@ -119,16 +120,14 @@
const totalPoliciesPromise = totalPolicies.map((policy) => {
cronExpression(policy);
return sdk
.forProject(page.params.region, page.params.project)
.backups.createPolicy(
ID.unique(),
['databases'],
policy.retained,
policy.schedule,
policy.label,
data.database.$id
);
return sdk.forProject(page.params.region, page.params.project).backups.createPolicy({
policyId: ID.unique(),
services: ['databases'],
retention: policy.retained,
schedule: policy.schedule,
name: policy.label,
resourceId: data.database.$id
});
});
try {
@@ -23,23 +23,23 @@ export const load = async ({ params, url, route, depends, parent }) => {
if (isCloud && backupsEnabled) {
try {
[backups, policies] = await Promise.all([
sdk
.forProject(params.region, params.project)
.backups.listArchives([
sdk.forProject(params.region, params.project).backups.listArchives({
queries: [
Query.limit(limit),
Query.offset(offset),
Query.orderDesc('$createdAt'),
Query.equal('resourceType', 'database'),
Query.equal('resourceId', params.database)
]),
]
}),
sdk
.forProject(params.region, params.project)
.backups.listPolicies([
sdk.forProject(params.region, params.project).backups.listPolicies({
queries: [
Query.orderDesc('$createdAt'),
Query.equal('resourceType', 'database'),
Query.equal('resourceId', params.database)
])
]
})
]);
} catch (e) {
// ignore
@@ -39,9 +39,9 @@
async function deletePolicy() {
try {
await sdk
.forProject(page.params.region, page.params.project)
.backups.deletePolicy(selectedPolicy.$id);
await sdk.forProject(page.params.region, page.params.project).backups.deletePolicy({
policyId: selectedPolicy.$id
});
addNotification({
type: 'success',
message: 'Backup policy has been deleted'
@@ -115,7 +115,7 @@
try {
await sdk
.forProject(page.params.region, page.params.project)
.backups.deleteArchive(archiveId);
.backups.deleteArchive({ archiveId });
addNotification({
type: 'success',
@@ -135,7 +135,9 @@
async function deleteBackups(batchDelete: DeleteOperation): Promise<DeleteOperationState> {
const result = await batchDelete((archiveId) =>
sdk.forProject(page.params.region, page.params.project).backups.deleteArchive(archiveId)
sdk
.forProject(page.params.region, page.params.project)
.backups.deleteArchive({ archiveId })
);
try {
@@ -160,12 +162,12 @@
try {
await sdk
.forProject(page.params.region, page.params.project)
.backups.createRestoration(
selectedBackup.$id,
['databases'],
newDatabaseInfo.id ?? ID.unique(),
newDatabaseInfo.name
);
.backups.createRestoration({
archiveId: selectedBackup.$id,
services: ['databases'],
newResourceId: newDatabaseInfo.id ?? ID.unique(),
newResourceName: newDatabaseInfo.name
});
await invalidate(Dependencies.BACKUPS);
addNotification({