-
Open Explorer
+
diff --git a/src/components/wrappers/dashboard/projects/project-form/project-form.action.ts b/src/components/wrappers/dashboard/projects/project-form/project-form.action.ts
index 96bcd9b8..af44a47e 100644
--- a/src/components/wrappers/dashboard/projects/project-form/project-form.action.ts
+++ b/src/components/wrappers/dashboard/projects/project-form/project-form.action.ts
@@ -62,7 +62,6 @@ export const createProjectAction = userAction
},
};
} catch (error) {
- console.log(error);
return {
success: false,
actionError: {
diff --git a/src/features/dashboard/backup/columns.tsx b/src/features/dashboard/backup/columns.tsx
index 769bc7b5..d8310ca3 100644
--- a/src/features/dashboard/backup/columns.tsx
+++ b/src/features/dashboard/backup/columns.tsx
@@ -66,10 +66,8 @@ export function backupColumns(
header: "Reference",
cell: ({row}) => {
const fileName = row.original.file
- console.log(row.original)
const reference = row.original.id
const isImported = isImportedFilename(`${fileName}`)
- console.log(isImported)
return isImported ? `${reference} (imported)` : `${reference}`
},
},
@@ -77,7 +75,6 @@ export function backupColumns(
accessorKey: "fileSize",
header: "Size",
cell: ({row}) => {
- console.log(row.original.fileSize)
return formatBytes(row.getValue("fileSize"))
},
},
@@ -163,7 +160,6 @@ export function backupColumns(
} else if (settings.storage == "s3") {
data = await getFileUrlPreSignedS3Action(`backups/${database.project?.slug}/${fileName}`);
}
- console.log(data)
if (data?.data?.success) {
url = data.data.value ?? "";
} else {
diff --git a/src/features/notifications/dispatch.ts b/src/features/notifications/dispatch.ts
index aac39cf1..ece13509 100644
--- a/src/features/notifications/dispatch.ts
+++ b/src/features/notifications/dispatch.ts
@@ -84,7 +84,7 @@ export async function dispatchNotification(
success: false,
channelId: channelId || "",
provider: null,
- error: "Channel not active¬",
+ error: "Channel not active",
};
}
diff --git a/src/features/notifications/helpers.ts b/src/features/notifications/helpers.ts
index c3ab41ca..1f57c573 100644
--- a/src/features/notifications/helpers.ts
+++ b/src/features/notifications/helpers.ts
@@ -1,67 +1,64 @@
-import {DatabaseWith} from "@/db/schema/07_database";
-import {EventKind, EventPayload} from "@/features/notifications/types";
-import {dispatchNotification} from "@/features/notifications/dispatch";
-
+import { DatabaseWith } from "@/db/schema/07_database";
+import { EventKind, EventPayload } from "@/features/notifications/types";
+import { dispatchNotification } from "@/features/notifications/dispatch";
export async function sendNotificationsBackupRestore(database: DatabaseWith, event: EventKind) {
-
- if (database.alertPolicies && database.alertPolicies.length > 0) {
- for (const alertPolicy of database.alertPolicies) {
- if (alertPolicy.enabled) {
-
- const eventKinds = alertPolicy.eventKinds
-
- if (eventKinds.includes(event)) {
-
- const date = new Date()
-
- let level: "info" | "critical" = "info";
- let message = "";
- let error: string | null = null;
-
- switch (event) {
- case "error_backup":
- case "error_restore":
- level = "critical";
- message = `An error occurred during ${event.includes("backup") ? "backup" : "restore"} on ${date.toISOString()}.`;
- error = "Check database connection or agent";
- break;
- case "success_backup":
- case "success_restore":
- level = "info";
- message = `${event.includes("backup") ? "Backup" : "Restore"} completed successfully at ${date.toISOString()}.`;
- break;
- case "weekly_report":
- level = "info";
- message = `Weekly report generated at ${date.toISOString()}.`;
- break;
- }
-
- const titleMap: Record
= {
- error_backup: `Backup Notification`,
- error_restore: `Restore Notification`,
- success_backup: `Backup Notification`,
- success_restore: `Restore Notification`,
- weekly_report: `Weekly Report Notification`,
- };
-
-
- const payload: EventPayload = {
- title: titleMap[event],
- message,
- level: level,
- event: event,
- data: {
- host: database.name,
- id: database.id,
- agentDatabaseId: database.agentDatabaseId,
- error,
- },
- };
- return await dispatchNotification(payload, alertPolicy.id, undefined, undefined);
- }
- }
- }
+ if (!database.alertPolicies || database.alertPolicies.length === 0) {
+ return [];
}
+ const activePolicies = database.alertPolicies.filter(policy =>
+ policy.enabled && policy.eventKinds.includes(event)
+ );
+
+ const promises = activePolicies.map(alertPolicy => {
+ const date = new Date();
+ let level: "info" | "critical" = "info";
+ let message = "";
+ let error: string | null = null;
+
+ switch (event) {
+ case "error_backup":
+ case "error_restore":
+ level = "critical";
+ message = `An error occurred during ${event.includes("backup") ? "backup" : "restore"} on ${date.toISOString()}.`;
+ error = "Check database connection or agent";
+ break;
+ case "success_backup":
+ case "success_restore":
+ level = "info";
+ message = `${event.includes("backup") ? "Backup" : "Restore"} completed successfully at ${date.toISOString()}.`;
+ break;
+ case "weekly_report":
+ level = "info";
+ message = `Weekly report generated at ${date.toISOString()}.`;
+ break;
+ }
+
+ const titleMap: Record = {
+ error_backup: `Backup Notification`,
+ error_restore: `Restore Notification`,
+ success_backup: `Backup Notification`,
+ success_restore: `Restore Notification`,
+ weekly_report: `Weekly Report Notification`,
+ };
+
+ const payload: EventPayload = {
+ title: titleMap[event],
+ message,
+ level: level,
+ event: event,
+ data: {
+ host: database.name,
+ id: database.id,
+ agentDatabaseId: database.agentDatabaseId,
+ error,
+ },
+ };
+
+ return dispatchNotification(payload, alertPolicy.id, undefined, undefined);
+ });
+
+
+ return Promise.all(promises);
}
\ No newline at end of file
diff --git a/src/features/upload/public/upload.action.ts b/src/features/upload/public/upload.action.ts
index 087c34bb..73009084 100644
--- a/src/features/upload/public/upload.action.ts
+++ b/src/features/upload/public/upload.action.ts
@@ -59,7 +59,6 @@ async function uploadLocal(fileName: string, buffer: any) {
await mkdir(path.join(process.cwd(), localDir), {recursive: true});
return await writeFile(path.join(process.cwd(), localDir + fileName), buffer);
} catch (error) {
- console.log("Error occured ", error);
throw new Error("An error occured while importing image");
}
}
diff --git a/src/hooks/use-auto-refresh.tsx b/src/hooks/use-auto-refresh.tsx
index ab53c04a..5574ee31 100644
--- a/src/hooks/use-auto-refresh.tsx
+++ b/src/hooks/use-auto-refresh.tsx
@@ -45,15 +45,12 @@ export function useAutoRefresh(options: UseAutoRefreshOptions) {
try {
payload = JSON.parse(event.data);
- } catch {
- // keep raw payload
- }
+ } catch {}
const shouldRefresh =
options.sse?.shouldRefresh?.(payload) ?? true;
if (shouldRefresh) {
- console.log("Received event source", eventSource);
router.refresh();
}
});
diff --git a/src/lib/auth/auth.ts b/src/lib/auth/auth.ts
index 7ede4d3c..7075a2a9 100644
--- a/src/lib/auth/auth.ts
+++ b/src/lib/auth/auth.ts
@@ -46,11 +46,7 @@ export const auth = betterAuth({
{}
),
});
-
- },
- onPasswordReset: async ({user}, request) => {
- console.log(`Password for user ${user.email} has been reset.`);
- },
+ }
},
emailVerification: {
async sendVerificationEmail({user, token, url}) {
@@ -176,13 +172,12 @@ export const auth = betterAuth({
const role = userCount === 0 ? "owner" : "admin";
- const defaultOrgSlug = "default"; // change this if your default org has a different slug
+ const defaultOrgSlug = "default";
const defaultOrg = await db.query.organization.findFirst({
where: eq(drizzleDb.schemas.organization.slug, defaultOrgSlug),
});
if (defaultOrg) {
- console.log(user)
await db.insert(drizzleDb.schemas.member).values({
userId: user.id,
organizationId: defaultOrg.id,
@@ -295,7 +290,6 @@ export const auth = betterAuth({
};
}
- console.log("sessionId", session.id);
const [aa] = await db
.update(drizzleUser.session)
@@ -303,7 +297,6 @@ export const auth = betterAuth({
.where(eq(drizzleUser.session.id, session.id))
.returning();
- console.log("aaaaa", aa);
return {
...session,
@@ -516,9 +509,7 @@ export const checkSlugOrganization = async (slug: string) => {
});
return status;
- } catch (e) {
- console.log("err", e);
- }
+ } catch {}
};
export const getActiveMember = async () => {
@@ -542,7 +533,5 @@ export const setActiveOrganization = async (slug: string) => {
organizationSlug: slug,
},
});
- } catch (e) {
- console.log("error", e);
- }
+ } catch {}
};
diff --git a/src/lib/tasks/database/index.ts b/src/lib/tasks/database/index.ts
index 03af061a..636596b9 100644
--- a/src/lib/tasks/database/index.ts
+++ b/src/lib/tasks/database/index.ts
@@ -18,7 +18,6 @@ export const retentionCleanTask = async () => {
},
},
});
- console.log(databases);
for (const db of databases) {
if (!db.retentionPolicy) continue; // no policy = skip
@@ -34,7 +33,6 @@ export async function enforceRetention(
databaseId: string,
policy: typeof retentionPolicy.$inferSelect
) {
- console.log(`EnforceRetention: ${policy}`);
switch (policy.type) {
case "count":
diff --git a/src/utils/edge_key.ts b/src/utils/edge_key.ts
index 6c398666..71810957 100644
--- a/src/utils/edge_key.ts
+++ b/src/utils/edge_key.ts
@@ -8,7 +8,6 @@ export async function generateEdgeKey(serverUrl: string, agentId: string): Promi
agentId,
publicKey
};
- console.log(edgeKeyData);
const edgeKeyJson = JSON.stringify(edgeKeyData);
const edgeKeyBuffer = Buffer.from(edgeKeyJson, 'utf-8');
return edgeKeyBuffer.toString('base64').replace(/=+$/, '').replace(/\+/g, '-').replace(/\//g, '_');
diff --git a/src/utils/s3-file-management.ts b/src/utils/s3-file-management.ts
index 3c920602..d2f5701f 100644
--- a/src/utils/s3-file-management.ts
+++ b/src/utils/s3-file-management.ts
@@ -171,22 +171,18 @@ export async function createPresignedUrlToUpload({
return await s3Client.presignedPutObject(bucketName, fileName, expiry);
}
-// Function to create a bucket and make it public
export async function createPublicBucket({bucketName}: { bucketName: string }) {
const s3Client = await getS3Client();
try {
- // Check if the bucket already exists
const exists = await s3Client.bucketExists(bucketName);
if (!exists) {
- // Create the bucket
- await s3Client.makeBucket(bucketName); // Change region if needed
+ await s3Client.makeBucket(bucketName);
console.log(`Bucket ${bucketName} created successfully.`);
} else {
console.log(`Bucket ${bucketName} already exists.`);
}
- // Define a bucket policy for public access
const policy = {
Version: "2012-10-17",
Statement: [
@@ -199,7 +195,6 @@ export async function createPublicBucket({bucketName}: { bucketName: string }) {
],
};
- // Set the policy to the bucket
await s3Client.setBucketPolicy(bucketName, JSON.stringify(policy));
console.log(`Bucket ${bucketName} is now public.`);
} catch (error) {
@@ -242,7 +237,6 @@ export async function createPresignedUrlToDownload({
bucketName,
fileName,
errorMessage: err?.message,
- // stack: err?.stack,
});
throw {error: err.message ?? "Unknown error"};
}