Zweiter Schritt weg von Supabase. Sämtliche 49 Lesezugriffe und alle
Mutationen laufen jetzt über lib/db statt über die REST-Schicht: Kysely auf
einem pg-Pool, jede Abfrage in einer Transaktion, in der zuerst
app.user_id gesetzt wird. Die Anmeldung hängt noch an GoTrue — sie liefert
die Kennung, die in withUser() geht. Damit war der Umbau in zwei Hälften
teilbar und die Anwendung durchgehend lauffähig.
Was dabei ersatzlos verschwindet:
- fetchAllRows. Es gab die Funktion nur, weil PostgREST jede Antwort bei
1000 Zeilen still abschneidet und ein Bericht dann leise falsch war.
Am direkten Zugang ist eine Abfrage eine Abfrage.
- sanitizeIlikeTerm samt Test. Sie entschärfte Zeichen, die in der
Filtersyntax strukturelle Bedeutung hatten; jetzt wird der Suchbegriff
als Parameter gebunden und ein Komma ist ein Komma. Die Lücke ist nicht
abgesichert, sondern weg.
- lib/supabase/admin.ts. Der Dienstschlüssel, der RLS aushebelte, hatte
genau einen Aufrufer — den nächtlichen Lauf. Der benutzt jetzt dieselbe
Rolle ohne BYPASSRLS und ruft eine SECURITY-DEFINER-Funktion auf, die
selbst prüft, was sie tut. Es gibt keinen privilegierten Zugang mehr.
Nebenbei besser geworden, weil der direkte Zugang es erlaubt:
- Eine Seite ist eine Transaktion. Das Layout etwa liest Profil,
Planstellen, Standorte, Entwürfe und Notizen auf einem einheitlichen
Lesestand statt in fünf unabhängigen Anfragen.
- Der Bereichsfilter der Mitarbeiterliste ist ein EXISTS statt einer
eingebetteten Ressource mit !inner — eine Person mit mehreren
Zuordnungen über die Zeit erschien dort mehrfach.
- Seitenweise Listen sortieren zusätzlich nach id. Bei gleichem Nachnamen
oder gleichem Zeitstempel war die Reihenfolge vorher unbestimmt, und
dieselbe Zeile konnte auf zwei Seiten erscheinen oder auf keiner.
- Angehörige werden in der Datenbank gezählt statt alle Zeilen zu holen.
- Namen an Ereigniszeilen kommen aus einem Join statt aus einem
Nachschlag, der ausserhalb der Transaktion lag.
Der Statusfilter ist mitgezogen: dieselbe Regel wie deriveStatusAsOf,
Klausel für Klausel, jetzt als Kysely-Ausdruck. Der Integrationstest, der
beide über den gesamten Bestand vergleicht, läuft weiter — mit eigener
Verbindung, denn geprüft wird die Bedingung, nicht die Berechtigung.
Zwei Fehler auf dem Weg, beide vom Typprüfer gefangen: apply_due_pending_
changes() nimmt kein Argument, wurde von callFunction aber mit jsonb
aufgerufen — Postgres hätte keine passende Signatur gefunden. Und der
Sicherheitstest lädt jetzt Module mit `import "server-only"`, was ausserhalb
der Server-Übersetzung wirft.
Typecheck, Lint, Build und 180 Tests sind grün. Ungeprüft bleibt der Lauf
gegen eine echte Datenbank — dafür fehlt eine DATABASE_URL.
124 lines
4.3 KiB
TypeScript
124 lines
4.3 KiB
TypeScript
import type { Tx } from "./db";
|
||
import type { Database } from "./supabase/types";
|
||
|
||
// Die Organisation ist ein Baum, keine drei Tabellen mehr. Alles, was früher
|
||
// aus divisions/departments/teams zusammengesteckt wurde, ergibt sich jetzt
|
||
// aus org_units.parent_id — und damit funktioniert es auch für eine fünfte
|
||
// Ebene, ohne dass hier etwas zu ändern wäre.
|
||
|
||
export type OrgUnitType = "Gesellschaft" | "Bereich" | "Abteilung" | "Team";
|
||
|
||
export type OrgUnit = {
|
||
id: string;
|
||
org_number: string;
|
||
name: string;
|
||
parent_id: string | null;
|
||
unit_type: OrgUnitType;
|
||
};
|
||
|
||
type Location = Database["public"]["Tables"]["locations"]["Row"];
|
||
|
||
export type OrgMaps = {
|
||
units: Map<string, OrgUnit>;
|
||
/** Tiefensuche ab der Wurzel: eine Einheit steht immer hinter ihrem Elternteil. */
|
||
unitList: OrgUnit[];
|
||
/** Abstand zur Wurzel; die Wurzel selbst hat 0. */
|
||
depthOf: Map<string, number>;
|
||
childrenOf: Map<string | null, OrgUnit[]>;
|
||
locations: Map<string, Location>;
|
||
locationList: Location[];
|
||
};
|
||
|
||
// Die Referenzdaten sind winzig (60 Einheiten, 5 Standorte) — sie werden
|
||
// ganz geladen und im Speicher verknüpft, statt je Zeile nachzuschlagen.
|
||
export async function loadOrgMaps(tx: Tx): Promise<OrgMaps> {
|
||
const [units, locations] = await Promise.all([
|
||
tx
|
||
.selectFrom("org_units")
|
||
.select(["id", "org_number", "name", "parent_id", "unit_type"])
|
||
.orderBy("org_number")
|
||
.execute(),
|
||
tx.selectFrom("locations").selectAll().orderBy("name").execute(),
|
||
]);
|
||
|
||
return buildOrgMaps(units as OrgUnit[], locations as Location[]);
|
||
}
|
||
|
||
/** Der reine Teil: aus den Zeilen den Baum bauen, ohne Datenbank. */
|
||
export function buildOrgMaps(units: OrgUnit[], locations: Location[]): OrgMaps {
|
||
const childrenOf = new Map<string | null, OrgUnit[]>();
|
||
for (const u of units) {
|
||
const list = childrenOf.get(u.parent_id) ?? [];
|
||
list.push(u);
|
||
childrenOf.set(u.parent_id, list);
|
||
}
|
||
for (const list of childrenOf.values()) list.sort((a, b) => a.name.localeCompare(b.name, "de"));
|
||
|
||
const unitList: OrgUnit[] = [];
|
||
const depthOf = new Map<string, number>();
|
||
const walk = (parentId: string | null, depth: number) => {
|
||
for (const u of childrenOf.get(parentId) ?? []) {
|
||
unitList.push(u);
|
||
depthOf.set(u.id, depth);
|
||
walk(u.id, depth + 1);
|
||
}
|
||
};
|
||
walk(null, 0);
|
||
|
||
return {
|
||
units: new Map(units.map((u) => [u.id, u])),
|
||
unitList,
|
||
depthOf,
|
||
childrenOf,
|
||
locations: new Map(locations.map((l) => [l.id, l])),
|
||
locationList: locations,
|
||
};
|
||
}
|
||
|
||
/** Wurzel zuerst, die Einheit selbst zuletzt. */
|
||
export function ancestorsOf(maps: OrgMaps, unitId: string | null | undefined): OrgUnit[] {
|
||
const chain: OrgUnit[] = [];
|
||
const seen = new Set<string>();
|
||
let current = unitId ? maps.units.get(unitId) : undefined;
|
||
while (current && !seen.has(current.id)) {
|
||
seen.add(current.id);
|
||
chain.unshift(current);
|
||
current = current.parent_id ? maps.units.get(current.parent_id) : undefined;
|
||
}
|
||
return chain;
|
||
}
|
||
|
||
/** Die Einheit und alles darunter — die Menge, die ein Filter „Bereich X" meint. */
|
||
export function subtreeOf(maps: OrgMaps, unitId: string): string[] {
|
||
const out: string[] = [];
|
||
const queue = [unitId];
|
||
const seen = new Set<string>();
|
||
while (queue.length > 0) {
|
||
const id = queue.shift()!;
|
||
if (seen.has(id)) continue;
|
||
seen.add(id);
|
||
out.push(id);
|
||
for (const child of maps.childrenOf.get(id) ?? []) queue.push(child.id);
|
||
}
|
||
return out;
|
||
}
|
||
|
||
/**
|
||
* „Produktion › Fertigung › Montage". Die Gesellschaft bleibt weg: sie steht
|
||
* über allem und trägt in einer Zeile nichts bei.
|
||
*/
|
||
export function breadcrumbLabel(maps: OrgMaps, unitId: string | null | undefined): string {
|
||
const chain = ancestorsOf(maps, unitId).filter((u) => u.unit_type !== "Gesellschaft");
|
||
return chain.map((u) => u.name).join(" › ") || "–";
|
||
}
|
||
|
||
/** Die oberste Einheit unterhalb der Gesellschaft — das, was früher „Bereich" hiess. */
|
||
export function divisionOf(maps: OrgMaps, unitId: string | null | undefined): OrgUnit | undefined {
|
||
return ancestorsOf(maps, unitId).find((u) => u.unit_type !== "Gesellschaft");
|
||
}
|
||
|
||
/** Die Einheit selbst, wenn sie nicht die Gesellschaft ist. */
|
||
export function unitOf(maps: OrgMaps, unitId: string | null | undefined): OrgUnit | undefined {
|
||
return unitId ? maps.units.get(unitId) : undefined;
|
||
}
|