External/portabase
1
0
Fork 0
mirror of https://github.com/Portabase/portabase.git synced 2026-07-14 11:16:13 +02:00
Code Issues Packages Projects Releases Wiki Activity

feat: set default notification channel

Browse Source
This commit is contained in:
charles-gauthereau
2026-03-25 22:19:41 +01:00
parent 61b1a2e724
commit a8e11ebef7
2 changed files with 46 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/db/schema/01_setting.ts
+1
View File
@@ -26,6 +26,7 @@ export const setting = pgTable("settings", {
export const settingRelations = relations(setting, ({one, many}) => ({ export const settingRelations = relations(setting, ({one, many}) => ({
storageChannel: one(storageChannel, {fields: [setting.defaultStorageChannelId], references: [storageChannel.id]}), storageChannel: one(storageChannel, {fields: [setting.defaultStorageChannelId], references: [storageChannel.id]}),
notificationChannel: one(notificationChannel, {fields: [setting.defaultNotificationChannelId], references: [notificationChannel.id]}),
})); }));
src/features/notifications/helpers.ts
+45 -7
View File
@@ -1,17 +1,55 @@
import { DatabaseWith } from "@/db/schema/07_database"; import { DatabaseWith } from "@/db/schema/07_database";
import { EventKind, EventPayload } from "@/features/notifications/types"; import { EventKind, EventPayload } from "@/features/notifications/types";
import { dispatchNotification } from "@/features/notifications/dispatch"; import { dispatchNotification } from "@/features/notifications/dispatch";
import {db} from "@/db";
import {eq} from "drizzle-orm";
import * as drizzleDb from "@/db";
export async function sendNotificationsBackupRestore(database: DatabaseWith, event: EventKind) { export async function sendNotificationsBackupRestore(database: DatabaseWith, event: EventKind) {
if (!database.alertPolicies || database.alertPolicies.length === 0) { // if (!database.alertPolicies || database.alertPolicies.length === 0) {
// return [];
// }
//
// const activePolicies = database.alertPolicies.filter(policy =>
// policy.enabled && policy.eventKinds.includes(event)
// );
//
// const settings = await db.query.setting.findFirst({
// where: eq(drizzleDb.schemas.setting.name, "system"),
// with: {notificationChannel: true},
// });
//
// const defaultPolicy = settings?.notificationChannel
// ? [{
// id: null,
// notificationChannelId: settings.notificationChannel.id,
// enabled: settings.notificationChannel.enabled,
// }]
// : [];
const settings = await db.query.setting.findFirst({
where: eq(drizzleDb.schemas.setting.name, "system"),
with: { notificationChannel: true },
});
const defaultPolicy = settings?.notificationChannel
? [{
id: null,
notificationChannelId: settings.notificationChannel.id,
enabled: settings.notificationChannel.enabled,
}]
: [];
const policiesToUse = (database.alertPolicies && database.alertPolicies.length > 0)
? database.alertPolicies.filter(policy => policy.enabled && policy.eventKinds.includes(event))
: defaultPolicy;
if (!policiesToUse || policiesToUse.length === 0) {
return []; return [];
} }
const activePolicies = database.alertPolicies.filter(policy => const promises = policiesToUse.map(alertPolicy => {
policy.enabled && policy.eventKinds.includes(event)
);
const promises = activePolicies.map(alertPolicy => {
const date = new Date(); const date = new Date();
let level: "info" | "critical" = "info"; let level: "info" | "critical" = "info";
let message = ""; let message = "";
@@ -56,7 +94,7 @@ export async function sendNotificationsBackupRestore(database: DatabaseWith, eve
}, },
}; };
return dispatchNotification(payload, alertPolicy.id, undefined, undefined); return dispatchNotification(payload, alertPolicy.id == null ? undefined : alertPolicy.id, alertPolicy.id ? undefined : alertPolicy.notificationChannelId, undefined);
}); });