Datenbank

.github/workflows/auto-merge-staging-into-main.yml

@@ -61,4 +61,16 @@ jobs:
           curl -H "Content-Type: application/json" \
           -X POST \
           -d "{\"content\": \"🚨 Auto-Merge fehlgeschlagen! Bitte manuell prüfen: https://github.com/${{ github.repository }}/actions/runs/${{ github.run_id }}\"}" \
+          ${{ secrets.DISCORD_WEBHOOK_URL }}
+
+  notify_success:
+    needs: merge
+    if: success()
+    runs-on: ubuntu-latest
+    steps:
+      - name: Send Discord notification on success
+        run: |
+          curl -H "Content-Type: application/json" \
+          -X POST \
+          -d "{\"content\": \"✅ Auto-Merge ausgeführt! Ergebnis jetzt auf [GitHub](https://github.com/${{ github.repository }}/actions/runs/${{ github.run_id }}) und [online-energieausweis.org](https://online-energieausweis.org) einsehen.\"}" \
           ${{ secrets.DISCORD_WEBHOOK_URL }}

.github/workflows/prevent-wrong-pr.yml

@@ -13,8 +13,6 @@ jobs:
     steps:
       - name: Prevent dev merges
         run: |
-          echo "${{ github.head_ref }}";
-          echo "${{ github.base_ref }}";
           if [[ "${{ github.head_ref }}" == "dev" ]]; then
             echo "ERROR: Merging 'dev' into '${{ github.base_ref }}' is forbidden!"
             exit 1
@@ -23,8 +21,6 @@ jobs:
       - name: Allow only staging into main
         if: github.base_ref == 'main'
         run: |
-          echo "${{ github.head_ref }}";
-          echo "${{ github.base_ref }}";
           if [[ "${{ github.head_ref }}" != "staging" ]]; then
             echo "ERROR: Only 'staging' branch is allowed to merge into 'main'. Current: '${{ github.head_ref }}'"
             exit 1

Makefile

@@ -10,7 +10,7 @@ PERSISTENT_DIR := $(HOME)/persistent/$(APP_NAME)
 BACKUP_FILENAME := $(HOME)/backups/$(shell date +"%Y-%m-%d_%H-%M-%S").sql.gz
 
 online-energieausweis:
-	NODE_ENV="development" bun run dev --host
+	bun run dev --host
 
 dev: database online-energieausweis
 
@@ -30,7 +30,6 @@ run-database: stop-database
 	docker volume create $(DB_VOLUME)
 	docker build -t $(DB_CONTAINER_NAME) .
 	docker run -d --name $(DB_CONTAINER_NAME) \
-		--restart=always \
 		-e POSTGRES_USER=$(DB_USER) \
 		-e POSTGRES_PASSWORD=$(DB_PASSWORD) \
 		-p $(DB_PORT):5432 \
@@ -72,4 +71,4 @@ prod: install-dependencies prisma-studio backup-database-cronjob update-dwd-klim
 
 backup-database-cronjob:
 	- pm2 delete daily-db-backup
-	pm2 start bash --name "daily-db-backup" --no-autorestart --cron "0 0 * * *" -- backup-database.bash
+	pm2 start bash --name "daily-db-backup" --cron "0 0 * * *" -- backup-database.bash

docker-compose.yml

@@ -2,7 +2,6 @@ version: '3'
 services:
   database:
     build: ./
-    restart: always
     env_file:
       - .env
     ports:

prisma/migrations/20250429143447_log/migration.sql

@@ -0,0 +1,10 @@
+-- CreateTable
+CREATE TABLE "Log" (
+    "id" SERIAL NOT NULL,
+    "level" TEXT NOT NULL,
+    "message" TEXT NOT NULL,
+    "meta" JSONB NOT NULL,
+    "timestamp" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "Log_pkey" PRIMARY KEY ("id")
+);

prisma/migrations/20250429145532_messages/migration.sql

@@ -0,0 +1,64 @@
+-- CreateTable
+CREATE TABLE "Attachment" (
+    "id" TEXT NOT NULL,
+    "name" TEXT,
+    "kategorie" TEXT,
+    "mime" TEXT NOT NULL,
+
+    CONSTRAINT "Attachment_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "Message" (
+    "id" TEXT NOT NULL,
+    "content" TEXT NOT NULL,
+    "sender_id" TEXT NOT NULL,
+    "reply_to_id" TEXT,
+    "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updated_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "Message_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "_AttachmentToMessage" (
+    "A" TEXT NOT NULL,
+    "B" TEXT NOT NULL,
+
+    CONSTRAINT "_AttachmentToMessage_AB_pkey" PRIMARY KEY ("A","B")
+);
+
+-- CreateTable
+CREATE TABLE "_recipients" (
+    "A" VARCHAR(11) NOT NULL,
+    "B" TEXT NOT NULL,
+
+    CONSTRAINT "_recipients_AB_pkey" PRIMARY KEY ("A","B")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Attachment_id_key" ON "Attachment"("id");
+
+-- CreateIndex
+CREATE INDEX "_AttachmentToMessage_B_index" ON "_AttachmentToMessage"("B");
+
+-- CreateIndex
+CREATE INDEX "_recipients_B_index" ON "_recipients"("B");
+
+-- AddForeignKey
+ALTER TABLE "Message" ADD CONSTRAINT "Message_sender_id_fkey" FOREIGN KEY ("sender_id") REFERENCES "benutzer"("id") ON DELETE RESTRICT ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Message" ADD CONSTRAINT "Message_reply_to_id_fkey" FOREIGN KEY ("reply_to_id") REFERENCES "Message"("id") ON DELETE SET NULL ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "_AttachmentToMessage" ADD CONSTRAINT "_AttachmentToMessage_A_fkey" FOREIGN KEY ("A") REFERENCES "Attachment"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "_AttachmentToMessage" ADD CONSTRAINT "_AttachmentToMessage_B_fkey" FOREIGN KEY ("B") REFERENCES "Message"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "_recipients" ADD CONSTRAINT "_recipients_A_fkey" FOREIGN KEY ("A") REFERENCES "benutzer"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "_recipients" ADD CONSTRAINT "_recipients_B_fkey" FOREIGN KEY ("B") REFERENCES "Message"("id") ON DELETE CASCADE ON UPDATE CASCADE;

prisma/migrations/20250429151551_conversations/migration.sql

@@ -0,0 +1,56 @@
+/*
+  Warnings:
+
+  - You are about to drop the column `created_at` on the `Message` table. All the data in the column will be lost.
+  - You are about to drop the column `updated_at` on the `Message` table. All the data in the column will be lost.
+  - You are about to drop the `_recipients` table. If the table is not empty, all the data it contains will be lost.
+  - Added the required column `conversation_id` to the `Message` table without a default value. This is not possible if the table is not empty.
+
+*/
+-- DropForeignKey
+ALTER TABLE "_recipients" DROP CONSTRAINT "_recipients_A_fkey";
+
+-- DropForeignKey
+ALTER TABLE "_recipients" DROP CONSTRAINT "_recipients_B_fkey";
+
+-- AlterTable
+ALTER TABLE "Message" DROP COLUMN "created_at",
+DROP COLUMN "updated_at",
+ADD COLUMN     "conversation_id" TEXT NOT NULL,
+ADD COLUMN     "sentAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP;
+
+-- DropTable
+DROP TABLE "_recipients";
+
+-- CreateTable
+CREATE TABLE "Conversation" (
+    "id" TEXT NOT NULL,
+    "name" TEXT,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL
+);
+
+-- CreateTable
+CREATE TABLE "Participant" (
+    "id" TEXT NOT NULL,
+    "benutzer_id" TEXT NOT NULL,
+    "conversation_id" TEXT NOT NULL,
+    "joined_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "Participant_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Conversation_id_key" ON "Conversation"("id");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Participant_benutzer_id_conversation_id_key" ON "Participant"("benutzer_id", "conversation_id");
+
+-- AddForeignKey
+ALTER TABLE "Message" ADD CONSTRAINT "Message_conversation_id_fkey" FOREIGN KEY ("conversation_id") REFERENCES "Conversation"("id") ON DELETE RESTRICT ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Participant" ADD CONSTRAINT "Participant_benutzer_id_fkey" FOREIGN KEY ("benutzer_id") REFERENCES "benutzer"("id") ON DELETE RESTRICT ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Participant" ADD CONSTRAINT "Participant_conversation_id_fkey" FOREIGN KEY ("conversation_id") REFERENCES "Conversation"("id") ON DELETE RESTRICT ON UPDATE CASCADE;

prisma/schema/Attachment.prisma

@@ -0,0 +1,9 @@
+model Attachment {
+	id String @id @unique @default(uuid())
+	
+	name									String?
+	kategorie 						String?
+	mime		String
+
+	attached_to_messages Message[]
+}

prisma/schema/Benutzer.prisma

@@ -49,7 +49,10 @@ model Benutzer {
   BearbeiteteTickets       Tickets[]                  @relation("BearbeiteteTickets")
 	events Event[]
 
-  @@map("benutzer")
+	conversations Participant[]
+	messages Message[]
+
+	@@map("benutzer")
 }
 
 

prisma/schema/Conversation.prisma

@@ -0,0 +1,9 @@
+model Conversation {
+  id String @unique @default(cuid())
+
+  name         String?
+  participants Participant[]
+  messages     Message[]
+  createdAt    DateTime      @default(now())
+  updatedAt    DateTime      @updatedAt
+}

prisma/schema/Log.prisma

@@ -0,0 +1,7 @@
+model Log {
+	id Int @id @default(autoincrement())
+	level String
+	message String
+	meta Json
+	timestamp DateTime @default(now())
+}

prisma/schema/Message.prisma

@@ -0,0 +1,17 @@
+model Message {
+  id String @id @default(cuid())
+
+  attachments Attachment[]
+
+  reply_to_id String? // Nullable because not all messages are replies
+  reply_to    Message?  @relation("MessageReplies", fields: [reply_to_id], references: [id])
+  replies     Message[] @relation("MessageReplies")
+
+  content         String
+  sender_id       String
+  conversation_id String
+  sentAt          DateTime @default(now())
+
+  sender       Benutzer     @relation(fields: [sender_id], references: [id])
+  conversation Conversation @relation(fields: [conversation_id], references: [id])
+}

prisma/schema/Participant.prisma

@@ -0,0 +1,11 @@
+model Participant {
+  id              String   @id @default(cuid())
+  benutzer_id     String
+  conversation_id String
+  joined_at       DateTime @default(now())
+
+  benutzer     Benutzer     @relation(fields: [benutzer_id], references: [id])
+  conversation Conversation @relation(fields: [conversation_id], references: [id])
+
+  @@unique([benutzer_id, conversation_id])
+}

server.ts

@@ -2,6 +2,7 @@ import express from 'express';
 import { H, Handlers } from '@highlight-run/node'
 // @ts-ignore
 import { handler as ssrHandler } from './dist/server/entry.mjs';
+import { server } from "./src/ws/server";
 
 const highlightConfig = {
 	projectID: '1jdkoe52',

src/astro-typesafe-api-caller.ts

@@ -22,17 +22,17 @@ export const createCaller = createCallerFactory({
     "bedarfsausweis-wohnen/[id]": await import("../src/pages/api/bedarfsausweis-wohnen/[id].ts"),
     "bedarfsausweis-wohnen": await import("../src/pages/api/bedarfsausweis-wohnen/index.ts"),
     "bilder/[id]": await import("../src/pages/api/bilder/[id].ts"),
-    "geg-nachweis-gewerbe/[id]": await import("../src/pages/api/geg-nachweis-gewerbe/[id].ts"),
-    "geg-nachweis-gewerbe": await import("../src/pages/api/geg-nachweis-gewerbe/index.ts"),
     "geg-nachweis-wohnen/[id]": await import("../src/pages/api/geg-nachweis-wohnen/[id].ts"),
     "geg-nachweis-wohnen": await import("../src/pages/api/geg-nachweis-wohnen/index.ts"),
+    "geg-nachweis-gewerbe/[id]": await import("../src/pages/api/geg-nachweis-gewerbe/[id].ts"),
+    "geg-nachweis-gewerbe": await import("../src/pages/api/geg-nachweis-gewerbe/index.ts"),
     "objekt": await import("../src/pages/api/objekt/index.ts"),
     "rechnung/[id]": await import("../src/pages/api/rechnung/[id].ts"),
     "rechnung/anfordern": await import("../src/pages/api/rechnung/anfordern.ts"),
     "rechnung": await import("../src/pages/api/rechnung/index.ts"),
-    "ticket": await import("../src/pages/api/ticket/index.ts"),
     "user": await import("../src/pages/api/user/index.ts"),
     "user/self": await import("../src/pages/api/user/self.ts"),
+    "ticket": await import("../src/pages/api/ticket/index.ts"),
     "verbrauchsausweis-wohnen/[id]": await import("../src/pages/api/verbrauchsausweis-wohnen/[id].ts"),
     "verbrauchsausweis-wohnen": await import("../src/pages/api/verbrauchsausweis-wohnen/index.ts"),
     "verbrauchsausweis-gewerbe/[id]": await import("../src/pages/api/verbrauchsausweis-gewerbe/[id].ts"),

src/client/lib/lesen.ts

@@ -1,15 +0,0 @@
-import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants.js";
-import { Benutzer } from "#lib/client/prisma.js";
-import { api } from "astro-typesafe-api/client";
-import Cookies from "js-cookie";
-
-export async function benutzerLesen(benutzerId: string): Promise<Benutzer> {
-    const benutzer = await api.user.GET.fetch({ id: benutzerId }
-        , {
-        headers: {
-            Authorization: `Bearer ${Cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)}`
-        }
-    });
-
-    return benutzer[0];
-}

src/client/lib/speichern.ts

@@ -1,5 +1,5 @@
 import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants.js";
-import { Aufnahme, Benutzer, Objekt } from "#lib/client/prisma.js";
+import { Aufnahme, Objekt } from "#lib/client/prisma.js";
 import { api } from "astro-typesafe-api/client";
 import Cookies from "js-cookie";
 
@@ -161,32 +161,4 @@ export async function objektSpeichern(objekt: Objekt & { id?: string }): Promise
 
 		return id;
 	}
-}
-
-export async function benutzerSpeichern(benutzer: Partial<Benutzer>): Promise<string> {
-	const completeBenutzer: Benutzer = {
-		id: benutzer.id,
-		name: benutzer.name ?? null,
-		email: benutzer.email,
-		passwort: "",
-		adresse: benutzer.adresse ?? null,
-		anrede: benutzer.anrede ?? null,
-		firma: benutzer.firma ?? null,
-		vorname: benutzer.vorname ?? null,
-		ort: benutzer.ort ?? null,
-		plz: benutzer.plz ?? null,
-		profilbild: benutzer.profilbild ?? null,
-		telefon: benutzer.telefon ?? null,
-		updated_at: new Date(), 
-		verified: benutzer.verified ?? false,
-	};
-
-	await api.user.POST.fetch(completeBenutzer
-		, {
-		headers: {
-			Authorization: `Bearer ${Cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)}`
-		}
-	});
-
-	return benutzer.id;
 }

src/components/Abrechnung/AbrechungTable.svelte

@@ -1,109 +0,0 @@
-<script lang="ts">
-	import { BedarfsausweisWohnen, Enums, Rechnung, VerbrauchsausweisGewerbe, VerbrauchsausweisWohnen } from "#lib/server/prisma.js";
-	import moment from "moment";
-	import { format } from "sharp";
-
-	export let bestellungen: (Rechnung & {
-		verbrauchsausweis_wohnen: VerbrauchsausweisWohnen | null,
-		verbrauchsausweis_gewerbe: VerbrauchsausweisGewerbe | null,
-		bedarfsausweis_wohnen: BedarfsausweisWohnen | null,
-	})[];
-	export let provisionen: Record<Enums.Ausweisart, number>;
-	export let partnerCodeErstesMal: Date;
-
-	const bestellungenNachMonat: Record<string, (typeof bestellungen)> = {};
-	for (const bestellung of bestellungen) {
-		const monat = moment(bestellung.created_at).format("Y-m");
-		if (monat in bestellungenNachMonat) {
-			bestellungenNachMonat[monat].push(bestellung)
-		} else {
-			bestellungenNachMonat[monat] = [bestellung]
-		}
-	}
-
-	// Wir brauchen alle Monate zwischen dem ersten Mal, dass der partner_code benutzt wurde bis zum heutigen Zeitpunkt.
-	const months: Record<string, string> = {
-		"01": "Januar", "02": "Februar", "03": "März", "04": "April",
-		"05": "Mai", "06": "Juni", "07": "Juli", "08": "August",
-		"09": "September", "10": "Oktober", "11": "November", "12": "Dezember"
-	};
-
-	function getMonthlyPeriods(minTime?: Date): moment.Moment[] {
-		const min = minTime ? moment(minTime) : moment();
-		const start = min.clone().startOf('month');
-
-		const end = moment().add(1, 'month').startOf('month');
-
-		const monthsArray: moment.Moment[] = [];
-		const current = start.clone();
-
-		while (current.isBefore(end)) {
-			monthsArray.push(current.clone());
-			current.add(1, 'month');
-		}
-
-		return monthsArray.reverse(); // Most recent month first
-	}
-
-	const periods = getMonthlyPeriods(partnerCodeErstesMal)
-</script>
-
-	{#each periods as dt}
-		{@const jahrMonat = dt.format("Y-m")}
-		{#if jahrMonat in bestellungenNachMonat && bestellungenNachMonat[jahrMonat].length > 0}
-			<!-- Echo dropdown foreach month. -->
-			{@const provisionMonat = bestellungenNachMonat[jahrMonat].reduce((acc, bestellung) => {
-				if (bestellung.verbrauchsausweis_wohnen) {
-					return acc + provisionen[Enums.Ausweisart.VerbrauchsausweisWohnen];
-				}
-				if (bestellung.bedarfsausweis_wohnen) {
-					return acc + provisionen[Enums.Ausweisart.BedarfsausweisWohnen];
-				}
-				if (bestellung.verbrauchsausweis_gewerbe) {
-					return acc + provisionen[Enums.Ausweisart.VerbrauchsausweisGewerbe];
-				}
-
-				return acc;
-			}) * 1.19}
-			
-			<div onclick="$(this).nextUntil('.dropdown_month').filter('table').toggle(); $('#betrag_gesamt').html('Abrechnungsbetrag $month_name: <b>$provision_month €</b>')" class='dropdown_month'>
-				<p>$month_name $year_name - Klicke, um Tabelle anzuzeigen</p>
-				<a target='_blank' rel='noreferrer noopener' href='/user/abrechnung/pdf.php?month={dt.format("m")}&year={dt.format("Y")}'>PDF Ansehen</a>
-			</div>
-			<table id='QTT' style='margin-top: 0 !important; display:none;'>
-				<thead>
-					<tr>
-						<td style='text-align:center;'>ID</td>
-						<td style='text-align:center;'>DATUM</td>
-						<td style='width:11em;text-align:center;'>GEBÄUDEADRESSE </td>
-						<td style='width:11em;text-align:center;'>PLZ </td>
-						<td style='width:11em;text-align:center;'>ORT </td>
-						<td style='text-align:center;'>AUSWEIS</td>
-						<td style='width:5em;text-align:center;'>BETRAG NETTO</td>
-					</tr>
-				</thead>
-				<tbody>
-			{#each bestellungenNachMonat[jahrMonat] as bestellung}
-					{@const provisionBestellung = bestellung.verbrauchsausweis_wohnen ? provisionen[Enums.Ausweisart.VerbrauchsausweisWohnen] : bestellung.verbrauchsausweis_gewerbe ? provisionen[Enums.Ausweisart.VerbrauchsausweisGewerbe] : provisionen[Enums.Ausweisart.BedarfsausweisWohnen]}
-					<tr>
-						<td style='width:1em;text-align:center;'>{bestellung.id}</td>	
-						<td style='width:9em;text-align:center;font-weight:bold;'>{moment(bestellung.created_at).format("Y/m/d")}</td>
-						<td style='width:8em;text-align:left;'>{bestellung["objekt_strasse"]}</td>
-						<td style='width:5em;text-align:center;'>{bestellung["objekt_plz"]}</td>
-						<td style='width:6em;text-align:left;'>{bestellung["objekt_ort"]}</td>
-						<td style='width:3em;text-align:center;'>{bestellung['ausweisart']}</td>
-						<td style='width:8em;text-align:right;'>{provisionBestellung} €</td>
-					</tr>
-			{/each}
-		</table>
-		{/if}
-	{/each}
-<!-- foreach ($period as $dt) {
-	$year_month = $dt->format("Y-m");
-	$month_name = $months[$dt->format("m")];
-	if ((new DateTime(date("m/d/Y", strtotime($EEtimestamp))))->format("d") - (new DateTime(date("m/d/Y", strtotime($SStimestamp))))->format("d") == 1) {
-		$Pall = $dt->format("d/m/Y")  . ' bis ' . (new DateTime($today))->format("d/m/Y");
-	} -->
-
-	
-<!-- } -->

src/components/Dashboard/DashboardAusweis.svelte

@@ -327,20 +327,18 @@
 		</div>
 		<div class="badge badge-accent font-semibold text-black text-m">
 			{#if ausweis.ausweistyp === Enums.AusweisTyp.Beratung || ausweis.ausweistyp === Enums.AusweisTyp.BeratungXL}
-					mit Beratung 
+					mit Beratung
 				{:else if ausweis.ausweistyp === Enums.AusweisTyp.Offline || ausweis.ausweistyp === Enums.AusweisTyp.OfflineXL}
-					Offline 
+					Offline
 				{/if}
-			{#if (rechnung?.services ?? []).length > 0}
-			{#if rechnung}
-				<span class="text-sm italic">({rechnung.services})</span>
-			{/if}
-			{/if}
 		</div>
 		<div class="mb-4 flex flex-row items-center gap-4">
 			<div class="w-full border rounded-lg my-2">
 				<div class="bg-green-600 h-4 rounded-lg" class:bg-red-600={progress == 33} class:bg-primary={progress == 66} style="width: {progress}%;"></div>
 			</div>
+			<span class="text-sm font-semibold text-base-content"
+				>{progress}%</span
+			>
 		</div>
 		{#await calculations then calculations}
 			<div class="flex flex-col mb-4">
@@ -518,17 +516,17 @@
 				{#if ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen}
 					<a
 					class="button text-sm"
-					href="/energieausweis-erstellen/verbrauchsausweis-wohngebaeude?ausweis_id={ausweis.id}&typ={AusstellungsTyp.Speichern}"
+					href="/energieausweis-erstellen/verbrauchsausweis-wohngebaeude?ausweis_id={ausweis.id}"
 					>Formular</a>
 				{:else if ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe}
 					<a
 					class="button text-sm"
-					href="/energieausweis-erstellen/verbrauchsausweis-gewerbe?ausweis_id={ausweis.id}&typ={AusstellungsTyp.Speichern}"
+					href="/energieausweis-erstellen/verbrauchsausweis-gewerbe?ausweis_id={ausweis.id}"
 					>Formular</a>
 				{:else if ausweisart === Enums.Ausweisart.BedarfsausweisWohnen}
 					<a
 					class="button text-sm"
-					href="/energieausweis-erstellen/bedarfsausweis-wohngebaeude?ausweis_id={ausweis.id}&typ={AusstellungsTyp.Speichern}"
+					href="/energieausweis-erstellen/bedarfsausweis-wohngebaeude?ausweis_id={ausweis.id}"
 					>Formular</a>
 				{/if}
 			{/if}
@@ -685,7 +683,7 @@
 				{aufnahme.aussenwand_min_12cm_gedaemmt ? "Außenwand min. 12cm gedämmt" : ""}
 			</div>
 			<div class="text-xs space-y-1 p-2">
-				<span class="font-semibold">Hiermit bestätige ich {benutzer.vorname} {benutzer.name} als Besteller:</span><br>
+				<span class="font-semibold">Hiermit bestätige ich {benutzer.vorname} {benutzer.name} als Besteller folgende Angaben:</span><br>
 				{#if ausweis.pruefpunkt_heizungsalter}
 				<div>Das Heizungsalter ist jünger als 3 Jahre. Es betrifft einen Heizungstausch ohne energetische Verbesserung.</div>
 				{/if}

src/components/Dashboard/DashboardSidebar.svelte

@@ -70,7 +70,6 @@
 					</div>
 				</div>
 			{/if}
-			<a href="/dashboard/abrechnung" class="button ">Conversions</a>
 		</div>
 		
 		<hr class="border-gray-600" />

src/generated/zod/attachment.ts

@@ -0,0 +1,8 @@
+import * as z from "zod"
+
+export const AttachmentSchema = z.object({
+  id: z.string(),
+  name: z.string().nullish(),
+  kategorie: z.string().nullish(),
+  mime: z.string(),
+})

src/generated/zod/conversation.ts

@@ -0,0 +1,8 @@
+import * as z from "zod"
+
+export const ConversationSchema = z.object({
+  id: z.string(),
+  name: z.string().nullish(),
+  createdAt: z.date(),
+  updatedAt: z.date(),
+})

src/generated/zod/index.ts

@@ -1,16 +1,21 @@
 export * from "./anteilshaber"
 export * from "./apirequests"
+export * from "./attachment"
 export * from "./aufnahme"
 export * from "./bedarfsausweisgewerbe"
 export * from "./bedarfsausweiswohnen"
 export * from "./benutzer"
 export * from "./bild"
+export * from "./conversation"
 export * from "./event"
 export * from "./gegeinpreisung"
 export * from "./gegnachweisgewerbe"
 export * from "./gegnachweiswohnen"
 export * from "./klimafaktoren"
+export * from "./log"
+export * from "./message"
 export * from "./objekt"
+export * from "./participant"
 export * from "./postleitzahlen"
 export * from "./rechnung"
 export * from "./refreshtokens"

src/generated/zod/log.ts

@@ -0,0 +1,15 @@
+import * as z from "zod"
+
+// Helper schema for JSON fields
+type Literal = boolean | number | string
+type Json = Literal | { [key: string]: Json } | Json[]
+const literalSchema = z.union([z.string(), z.number(), z.boolean()])
+const jsonSchema: z.ZodSchema<Json> = z.lazy(() => z.union([literalSchema, z.array(jsonSchema), z.record(jsonSchema)]))
+
+export const LogSchema = z.object({
+  id: z.number().int(),
+  level: z.string(),
+  message: z.string(),
+  meta: jsonSchema,
+  timestamp: z.date(),
+})

src/generated/zod/message.ts

@@ -0,0 +1,10 @@
+import * as z from "zod"
+
+export const MessageSchema = z.object({
+  id: z.string(),
+  reply_to_id: z.string().nullish(),
+  content: z.string(),
+  sender_id: z.string(),
+  conversation_id: z.string(),
+  sentAt: z.date(),
+})

src/generated/zod/participant.ts

@@ -0,0 +1,8 @@
+import * as z from "zod"
+
+export const ParticipantSchema = z.object({
+  id: z.string(),
+  benutzer_id: z.string(),
+  conversation_id: z.string(),
+  joined_at: z.date(),
+})

src/layouts/AusweisLayoutDaten.astro

@@ -102,13 +102,6 @@ const { title } = Astro.props;
 
 <html lang="de">
 	<head>
-<!-- Google Tag Manager -->
-<script>(function(w,d,s,l,i){w[l]=w[l]||[];w[l].push({'gtm.start':
-new Date().getTime(),event:'gtm.js'});var f=d.getElementsByTagName(s)[0],
-j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
-'https://www.googletagmanager.com/gtm.js?id='+i+dl;f.parentNode.insertBefore(j,f);
-})(window,document,'script','dataLayer','GTM-59QKHH8');</script>
-<!-- End Google Tag Manager -->
 		<meta charset="UTF-8" />
 		<meta name="viewport" content="width=device-width" />
 		<link rel="icon" type="image/svg+xml" href="/favicon.jpg" />
@@ -154,11 +147,6 @@ j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
 	</head>
 
 	<body>
-<!-- Google Tag Manager (noscript) -->
-<noscript><iframe src="https://www.googletagmanager.com/ns.html?id=GTM-59QKHH8"
-height="0" width="0" style="display:none;visibility:hidden"></iframe></noscript>
-<!-- End Google Tag Manager (noscript) -->
-
 		<Header {user} />
 
 		<main

src/layouts/AusweisLayoutDatenImmowelt.astro

@@ -0,0 +1,157 @@
+---
+import "../style/global.css";
+import "../style/formular.css";
+import "../../svelte-dialogs.config";
+import Header from "#components/design/header/AusweisHeaderImmowelt.astro";
+import Footer from "#components/design/footer/Footer.astro";
+import { NotificationWrapper } from "@ibcornelsen/ui";
+
+export interface Props {
+	title: string;
+}
+
+const { title } = Astro.props;
+---
+
+<script>
+	window.addEventListener("scroll", (event) => {
+		let scroll = window.scrollY;
+
+		console.log(scroll);
+		if (scroll >= 400) {
+			document
+				.getElementById("skala")
+				?.classList.add(
+					"2xl:fixed",
+					"2xl:py-4",
+					"2xl:top-0",
+					"2xl:z-20"
+				);
+			document.getElementById("skala")?.classList.remove("w-full");
+
+			document.getElementById("skala").style.borderBottom =
+				"3px solid #e6e6e6";
+
+			document.getElementById("performance-box").style.maxWidth =
+				"688.5px";
+			document.getElementById("progress-box").style.maxWidth = "688.5px";
+
+			document
+				.getElementById("formInput-1")
+				?.classList.add("2xl:mt-[370px]");
+		} else {
+			document
+				.getElementById("skala")
+				?.classList.remove(
+					"2xl:fixed",
+					"2xl:py-4",
+					"2xl:top-0",
+					"2xl:z-20"
+				);
+			document.getElementById("skala")?.classList.add("w-full");
+
+			document.getElementById("skala").style.borderBottom = "none";
+
+			document
+				.getElementById("formInput-1")
+				?.classList.remove("2xl:mt-[370px]");
+		}
+	});
+</script>
+
+<html lang="de">
+	<head>
+		<meta charset="UTF-8" />
+		<meta name="viewport" content="width=device-width" />
+		<link rel="icon" type="image/svg+xml" href="/favicon.jpg" />
+
+		<meta
+			name="description"
+			content="✅ Jetzt Ihren Energieausweis online erstellen. Erhalten Sie Ihren online Energieausweis rechtssicher und nach aktueller GEG (vormals EnEV) vom Diplom Ingenieur geprüft."
+		/>
+		<link rel="canonical" href="https://online-energieausweis.org/" />
+
+		<meta property="og:locale" content="de_DE" />
+		<meta property="og:type" content="website" />
+		<meta
+			property="og:title"
+			content="Energieausweis online erstellen - Online Energieausweis"
+		/>
+		<meta
+			property="og:description"
+			content="✅ Jetzt Ihren Energieausweis online erstellen. Erhalten Sie Ihren online Energieausweis rechtssicher und nach aktueller GEG (vormals EnEV) vom Diplom Ingenieur geprüft."
+		/>
+		<meta property="og:url" content="https://online-energieausweis.org/" />
+		<meta
+			property="og:site_name"
+			content="Energieausweis online erstellen"
+		/>
+
+		<meta name="twitter:card" content="summary_large_image" />
+		<meta
+			name="twitter:description"
+			content="✅ Jetzt Ihren Energieausweis online erstellen. Erhalten Sie Ihren online Energieausweis rechtssicher und nach aktueller GEG (vormals EnEV) vom Diplom Ingenieur geprüft."
+		/>
+		<meta
+			name="twitter:title"
+			content="Energieausweis online erstellen - Online Energieausweis"
+		/>
+		<meta
+			name="twitter:image"
+			content="https://online-energieausweis.org/images/energieausweis-online-erstellen.jpg"
+		/>
+		<title>
+			{title || "Energieausweis online erstellen - Online Energieausweis"}
+		</title>
+	</head>
+
+	<body>
+		<Header />
+
+		<main
+			class="w-full p-0 grid
+			xs:grid-cols-[minmax(1fr)] xs:gap-1 xs:p-0
+			sm:grid-cols-[minmax(1fr)] sm:gap-1 sm:p-0
+			md:grid-cols-[minmax(1fr)] md:gap-2 md:p-0
+			lg:grid-cols-[minmax(1fr)] lg:gap-3 lg:p-4
+			xl:grid-cols-[minmax(1fr)] xl:gap-4 xl:p-6
+			2xl:grid-cols-[minmax(1fr)] 2xl:gap-5 2xl:p-6"
+		>
+			<article class="box rounded-tl-none p-2 lg:p-12">
+				<slot />
+			</article>
+		</main>
+
+		<Footer />
+		<NotificationWrapper client:load />
+	</body>
+</html>
+
+<style is:global lang="postcss">
+	body {
+		min-height: 100vh;
+		width:100%;
+	}
+
+	article {
+		p, h1, h2, h3, h4, h5, h6 {
+			@apply text-base-content;
+		}
+	}
+
+
+
+
+	.headline {
+		@apply text-lg;
+	}
+
+	.radio-inline {
+		@apply flex flex-row gap-2;
+	}
+
+	.checkbox-inline {
+		@apply flex flex-row gap-2;
+	}
+
+</style>

src/layouts/AusweisLayoutDatenImmowelt2.astro

@@ -0,0 +1,156 @@
+---
+import "../style/global.css";
+import "../style/formular.css";
+import "../../svelte-dialogs.config"
+import Header from "#components/design/header/AusweisHeaderImmowelt2.astro";
+import Footer from "#components/design/footer/Footer.astro";
+import { NotificationWrapper } from "@ibcornelsen/ui";
+
+export interface Props {
+	title: string;
+}
+
+const { title } = Astro.props;
+---
+<script>
+window.addEventListener("scroll", (event) => {
+    let scroll = window.scrollY;
+
+
+
+console.log(scroll);
+	if(scroll>=400){
+
+		document.getElementById('skala')?.classList.add('2xl:fixed','2xl:py-4','2xl:top-0','2xl:z-20');
+		document.getElementById('skala')?.classList.remove('w-full');
+
+
+		document.getElementById('skala').style.borderBottom = "3px solid #e6e6e6";
+
+
+		document.getElementById('performance-box').style.maxWidth = "688.5px";
+		document.getElementById('progress-box').style.maxWidth = "688.5px";
+
+		document.getElementById('formInput-1')?.classList.add('2xl:mt-[370px]');
+		
+
+
+
+	}else{
+
+		document.getElementById('skala')?.classList.remove('2xl:fixed','2xl:py-4','2xl:top-0','2xl:z-20');
+		document.getElementById('skala')?.classList.add('w-full');
+		
+		document.getElementById('skala').style.borderBottom = "none";
+
+		document.getElementById('formInput-1')?.classList.remove('2xl:mt-[370px]');
+
+
+
+
+	}
+    
+
+});
+
+</script>
+
+<!DOCTYPE html>
+<html lang="de">
+	<head>
+		<meta charset="UTF-8" />
+		<meta name="viewport" content="width=device-width" />
+		<link rel="icon" type="image/svg+xml" href="/favicon.jpg" />
+
+		<meta
+			name="description"
+			content="✅ Jetzt Ihren Energieausweis online erstellen. Erhalten Sie Ihren online Energieausweis rechtssicher und nach aktueller GEG (vormals EnEV) vom Diplom Ingenieur geprüft."
+		/>
+		<link rel="canonical" href="https://online-energieausweis.org/" />
+
+		<meta property="og:locale" content="de_DE" />
+		<meta property="og:type" content="website" />
+		<meta
+			property="og:title"
+			content="Energieausweis online erstellen - Online Energieausweis"
+		/>
+		<meta
+			property="og:description"
+			content="✅ Jetzt Ihren Energieausweis online erstellen. Erhalten Sie Ihren online Energieausweis rechtssicher und nach aktueller GEG (vormals EnEV) vom Diplom Ingenieur geprüft."
+		/>
+		<meta property="og:url" content="https://online-energieausweis.org/" />
+		<meta property="og:site_name" content="Energieausweis online erstellen" />
+
+		<meta name="twitter:card" content="summary_large_image" />
+		<meta
+			name="twitter:description"
+			content="✅ Jetzt Ihren Energieausweis online erstellen. Erhalten Sie Ihren online Energieausweis rechtssicher und nach aktueller GEG (vormals EnEV) vom Diplom Ingenieur geprüft."
+		/>
+		<meta
+			name="twitter:title"
+			content="Energieausweis online erstellen - Online Energieausweis"
+		/>
+		<meta
+			name="twitter:image"
+			content="https://online-energieausweis.org/images/energieausweis-online-erstellen.jpg"
+		/>
+		<title>
+			{title || 'Energieausweis online erstellen - Online Energieausweis'}
+		</title>
+	</head>
+
+	<body>
+			
+		<Header />
+	
+		<main
+			class="w-full p-0 grid
+			xs:grid-cols-[minmax(1fr)] xs:gap-1 xs:p-0
+			sm:grid-cols-[minmax(1fr)] sm:gap-1 sm:p-0
+			md:grid-cols-[minmax(1fr)] md:gap-2 md:p-0
+			lg:grid-cols-[minmax(1fr)] lg:gap-3 lg:p-4
+			xl:grid-cols-[minmax(1fr)] xl:gap-4 xl:p-6
+			2xl:grid-cols-[minmax(1fr)] 2xl:gap-5 2xl:p-6
+		">
+
+
+		<article class="box rounded-tl-none p-2 lg:p-12">
+		<slot />
+		</article>
+ 
+		</main>
+	
+		<Footer />
+		<NotificationWrapper client:load />
+
+	</body>
+</html>
+
+<style is:global lang="postcss">
+	body {
+		min-height: 100vh;
+		width:100%;
+	}
+
+	article {
+		p, h1, h2, h3, h4, h5, h6 {
+			@apply text-base-content;
+		}
+	}
+
+
+
+
+	.headline {
+		@apply text-lg;
+	}
+
+	.radio-inline {
+		@apply flex flex-row gap-2;
+	}
+
+	.checkbox-inline {
+		@apply flex flex-row gap-2;
+	}
+
+</style>

src/layouts/AusweisLayoutDatenPartner.astro

@@ -85,14 +85,6 @@ window.addEventListener("scroll", () => {
 <!DOCTYPE html>
 <html lang="de">
 	<head>
-<!-- Google Tag Manager -->
-<script>(function(w,d,s,l,i){w[l]=w[l]||[];w[l].push({'gtm.start':
-new Date().getTime(),event:'gtm.js'});var f=d.getElementsByTagName(s)[0],
-j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
-'https://www.googletagmanager.com/gtm.js?id='+i+dl;f.parentNode.insertBefore(j,f);
-})(window,document,'script','dataLayer','GTM-59QKHH8');</script>
-<!-- End Google Tag Manager -->
-
 		<meta charset="UTF-8" />
 		<meta name="viewport" content="width=device-width" />
 		<link rel="icon" type="image/svg+xml" href="/favicon.jpg" />
@@ -135,11 +127,7 @@ j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
 	</head>
 
 	<body>
-<!-- Google Tag Manager (noscript) -->
-<noscript><iframe src="https://www.googletagmanager.com/ns.html?id=GTM-59QKHH8"
-height="0" width="0" style="display:none;visibility:hidden"></iframe></noscript>
-<!-- End Google Tag Manager (noscript) -->
-
+			
 		<AusweisHeaderPartner {tab}/>
 	
 		<main class="w-full p-0 grid grid-cols-1 rounded-none">
@@ -148,6 +136,7 @@ height="0" width="0" style="display:none;visibility:hidden"></iframe></noscript>
 
 		<article class="p-0 lg:px-20 lg:py-12">
 		<slot />
+		<div style="height: 450px;"></div>
 		</article>
 		
 		</main>

src/layouts/AusweisLayoutPruefung.astro

@@ -37,14 +37,6 @@ const { title } = Astro.props;
 <!DOCTYPE html>
 <html lang="de">
 	<head>
-<!-- Google Tag Manager -->
-<script>(function(w,d,s,l,i){w[l]=w[l]||[];w[l].push({'gtm.start':
-new Date().getTime(),event:'gtm.js'});var f=d.getElementsByTagName(s)[0],
-j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
-'https://www.googletagmanager.com/gtm.js?id='+i+dl;f.parentNode.insertBefore(j,f);
-})(window,document,'script','dataLayer','GTM-59QKHH8');</script>
-<!-- End Google Tag Manager -->
-
 		<meta charset="UTF-8" />
 		<meta name="viewport" content="width=device-width" />
 		<link rel="icon" type="image/svg+xml" href="/favicon.jpg" />
@@ -87,10 +79,6 @@ j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
 	</head>
 
 	<body>
-<!-- Google Tag Manager (noscript) -->
-<noscript><iframe src="https://www.googletagmanager.com/ns.html?id=GTM-59QKHH8"
-height="0" width="0" style="display:none;visibility:hidden"></iframe></noscript>
-<!-- End Google Tag Manager (noscript) -->
 			
 		<Header {user} />
 	

src/layouts/Layout.astro

@@ -98,15 +98,6 @@ window.addEventListener("scroll", (event) => {
 <!DOCTYPE html>
 <html lang="de">
 	<head>
-<!-- Google Tag Manager -->
-<script>(function(w,d,s,l,i){w[l]=w[l]||[];w[l].push({'gtm.start':
-new Date().getTime(),event:'gtm.js'});var f=d.getElementsByTagName(s)[0],
-j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
-'https://www.googletagmanager.com/gtm.js?id='+i+dl;f.parentNode.insertBefore(j,f);
-})(window,document,'script','dataLayer','GTM-59QKHH8');</script>
-<!-- End Google Tag Manager -->
-
-
 		<meta charset="UTF-8" />
 		<meta name="viewport" content="width=device-width" />
 		<link rel="icon" type="image/svg+xml" href="/favicon.jpg" />
@@ -120,10 +111,6 @@ j=d.createElement(s),dl=l!='dataLayer'?'&l='+l:'';j.async=true;j.src=
 	</head>
 
 	<body>
-<!-- Google Tag Manager (noscript) -->
-<noscript><iframe src="https://www.googletagmanager.com/ns.html?id=GTM-59QKHH8"
-height="0" width="0" style="display:none;visibility:hidden"></iframe></noscript>
-<!-- End Google Tag Manager (noscript) -->
 			
 		<Header {user} />
 	

src/lib/pdf/pdfVerbrauchsausweisGewerbe.ts

@@ -199,28 +199,19 @@ export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewe
 	
 	if (bild) {
 		const file = await getS3File("ibc-images", `${bild.id}.jpg`);
+
 		if (file) {
 			let image: PDFImage;
-			image = await pdf.embedJpg(file);
-	
-			const originalWidth = image.width;
-			const originalHeight = image.height;
-	
-			// Calculate the scaling factor to fit within the maximum dimensions while maintaining proportions
-			const scaleFactor = Math.min(111 / originalWidth, 138 / originalHeight);
-	
-			const scaledWidth = originalWidth * scaleFactor;
-			const scaledHeight = originalHeight * scaleFactor;
-	
+			image = await pdf.embedJpg(file)
 			pages[0].drawImage(image, {
 				x: 460.5,
-				y: (height - 289 - scaledHeight) + 138, // Adjust y to align the image properly
-				width: scaledWidth,
-				height: scaledHeight
-			});
+				y: height - 289,
+				width: 111,
+				height: 138
+			})
 		}
 	}
-
+	
 		// Checkmark Verbrauchsausweis.
 		pages[0].drawText("x", {
 			x: 41,
@@ -369,25 +360,25 @@ export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewe
 
 		if (endenergieverbrauchTranslationPercentage > 0.5) {
 			page.drawText("Endenergieverbrauch Wärme", {
-				x: endenergieverbrauchTranslationX - margin - font.widthOfTextAtSize("Endenergieverbrauch Wärme", 10) - (pfeilWidth / 2),
+				x: endenergieverbrauchTranslationX - margin - font.widthOfTextAtSize("Endenergieverbrauch Wärme", 10),
 				y: height - 191,
 				size: 10
 			})
 
 			page.drawText(endEnergieVerbrauchGesamtText, {
-				x: endenergieverbrauchTranslationX - margin - bold.widthOfTextAtSize(endEnergieVerbrauchGesamtText, 10) - (pfeilWidth / 2),
+				x: endenergieverbrauchTranslationX - margin - bold.widthOfTextAtSize(endEnergieVerbrauchGesamtText, 10),
 				y: height - 205,
 				size: 10,
 				font: bold
 			})
 		} else {
 			page.drawText("Endenergieverbrauch Wärme", {
-				x: endenergieverbrauchTranslationX + pfeilWidth + margin  + (pfeilWidth / 2),
+				x: endenergieverbrauchTranslationX + pfeilWidth + margin,
 				y: height - 191,
 				size: 10
 			})
 			page.drawText(endEnergieVerbrauchGesamtText, {
-				x: endenergieverbrauchTranslationX + pfeilWidth + margin  + (pfeilWidth / 2),
+				x: endenergieverbrauchTranslationX + pfeilWidth + margin,
 				y: height - 205,
 				size: 10,
 				font: bold
@@ -398,13 +389,13 @@ export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewe
 
 		if (vergleichsWertWaermeTranslationPercentage > 0.5) {
 			page.drawText("Vergleichswert Wärme", {
-				x: vergleichsWertWaermeTranslationX - margin - font.widthOfTextAtSize("Vergleichswert Wärme", 10) - (pfeilWidth / 2),
+				x: vergleichsWertWaermeTranslationX - margin - font.widthOfTextAtSize("Vergleichswert Wärme", 10),
 				y: height - 275,
 				size: 10
 			})
 
 			page.drawText(vergleichswertWaermeText, {
-				x: vergleichsWertWaermeTranslationX - margin - bold.widthOfTextAtSize(vergleichswertWaermeText, 10) - (pfeilWidth / 2),
+				x: vergleichsWertWaermeTranslationX - margin - bold.widthOfTextAtSize(vergleichswertWaermeText, 10),
 				y: height - 289,
 				size: 10,
 				font: bold
@@ -431,7 +422,7 @@ export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewe
 		})
 
 		page.drawImage(pfeilNachOben, {
-			x: vergleichsWertStromTranslationX, 
+			x: vergleichsWertStromTranslationX,
 			y: height - 437,
 			width: pfeilWidth,
 			height: 30
@@ -441,25 +432,25 @@ export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewe
 
 		if (stromVerbrauchTranslationPercentage > 0.5) {
 			page.drawText("Endenergieverbrauch Strom", {
-				x: stromVerbrauchTranslationX - margin - font.widthOfTextAtSize("Endenergieverbrauch Strom", 10) - (pfeilWidth / 2),
+				x: stromVerbrauchTranslationX - margin - font.widthOfTextAtSize("Endenergieverbrauch Strom", 10),
 				y: height - 335,
 				size: 10
 			})
 
 			page.drawText(stromVerbrauchGesamtText, {
-				x: stromVerbrauchTranslationX - margin - bold.widthOfTextAtSize(stromVerbrauchGesamtText, 10) - (pfeilWidth / 2),
+				x: stromVerbrauchTranslationX - margin - bold.widthOfTextAtSize(stromVerbrauchGesamtText, 10),
 				y: height - 349,
 				size: 10,
 				font: bold
 			})
 		} else {
 			page.drawText("Endenergieverbrauch Strom", {
-				x: stromVerbrauchTranslationX + pfeilWidth + margin + (pfeilWidth / 2),
+				x: stromVerbrauchTranslationX + pfeilWidth + margin,
 				y: height - 335,
 				size: 10
 			})
 			page.drawText(stromVerbrauchGesamtText, {
-				x: stromVerbrauchTranslationX + pfeilWidth + margin + (pfeilWidth / 2),
+				x: stromVerbrauchTranslationX + pfeilWidth + margin,
 				y: height - 349,
 				size: 10,
 				font: bold
@@ -484,12 +475,12 @@ export async function pdfVerbrauchsausweisGewerbe(ausweis: VerbrauchsausweisGewe
 			})
 		} else {
 			page.drawText("Vergleichswert Strom", {
-				x: vergleichsWertStromTranslationX + pfeilWidth + margin  + (pfeilWidth / 2),
+				x: vergleichsWertStromTranslationX + pfeilWidth + margin,
 				y: height - 420,
 				size: 10
 			})
 			page.drawText(vergleichswertStromText, {
-				x: vergleichsWertStromTranslationX + pfeilWidth + margin + (pfeilWidth / 2),
+				x: vergleichsWertStromTranslationX + pfeilWidth + margin,
 				y: height - 434,
 				size: 10,
 				font: bold

src/lib/pdf/pdfVerbrauchsausweisWohnen.ts

@@ -59,23 +59,13 @@ export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohne
 
 		if (file) {
 			let image: PDFImage;
-			image = await pdf.embedJpg(file);
-
-			const originalWidth = image.width;
-			const originalHeight = image.height;
-
-			// Calculate the scaling factor to fit within the maximum dimensions while maintaining proportions
-			const scaleFactor = Math.min(111 / originalWidth, 138 / originalHeight);
-
-			const scaledWidth = originalWidth * scaleFactor;
-			const scaledHeight = originalHeight * scaleFactor;
-
+			image = await pdf.embedJpg(file)
 			pages[0].drawImage(image, {
 				x: 460.5,
-				y: (height - 289 - scaledHeight) + 138, // Adjust y to align the image properly
-				width: scaledWidth,
-				height: scaledHeight
-			});
+				y: height - 289,
+				width: 111,
+				height: 138
+			})
 		}
 	}
 
@@ -343,7 +333,7 @@ export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohne
 		}
 
 		page.drawImage(pfeilNachUnten, {
-			x: endenergieverbrauchTranslationX - (pfeilWidth / 2),
+			x: endenergieverbrauchTranslationX,
 			y: height - 212,
 			width: pfeilWidth,
 			height: 30
@@ -380,7 +370,7 @@ export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohne
 		}
 
 		page.drawImage(pfeilNachOben, {
-			x: primaerenergieverbrauchTranslationX - (pfeilWidth / 2),
+			x: primaerenergieverbrauchTranslationX,
 			y: height - 297,
 			width: pfeilWidth,
 			height: 30
@@ -505,7 +495,7 @@ export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohne
 
 	const addVerbrauch = addVerbrauchGenerator();
 
-	if (ausweis.warmwasser_enthalten !== true) {
+	if (!ausweis.warmwasser_enthalten) {
 		// Mit Warmwasserzuschlag
 		addVerbrauch(
 			moment(ausweis.startdatum).format("MM.YYYY"),
@@ -555,7 +545,7 @@ export async function pdfVerbrauchsausweisWohnen(ausweis: VerbrauchsausweisWohne
 			"Warmwasserzuschlag",
 			berechnungen?.primaerfaktorww.toString(),
 			Math.round(berechnungen?.energieVerbrauchWarmwasser_1 || 0).toString(),
-			Math.round(berechnungen?.energieVerbrauchWarmwasser_1 || 0).toString(), 
+			Math.round(berechnungen?.energieVerbrauchWarmwasser_1 || 0).toString(),
 			"0",
 			"0"
 		);

src/lib/server/user.ts

@@ -1,27 +1,9 @@
 import { API_ACCESS_TOKEN_COOKIE_NAME } from "#lib/constants.js";
 import { checkAuthorizationHeader, checkAuthorizationHeaderNoThrow } from "#lib/middleware/authorization.js";
 import { AstroGlobal } from "astro";
-import { Enums } from "#lib/client/prisma.js";
-import { prisma } from "#lib/server/prisma.js";
 
 export function getCurrentUser(Astro: AstroGlobal) {
 	const accessToken = Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value;
 
 	return checkAuthorizationHeaderNoThrow(`Bearer ${accessToken}`)
-}
-
-export async function getOtherUser(Astro: AstroGlobal, userId : string) {
-	const accessToken = Astro.cookies.get(API_ACCESS_TOKEN_COOKIE_NAME)?.value;
-
-	let currentUser = await checkAuthorizationHeaderNoThrow(`Bearer ${accessToken}`)
-
-	if (currentUser?.rolle == Enums.BenutzerRolle.ADMIN) {
-		const user = await prisma.benutzer.findUnique({
-			where: {
-				id: userId
-			}
-		})
-		return user;
-	}
-	return null;
 }

src/modules/BedarfsausweisWohnen/BedarfsausweisWohnenModule.svelte

@@ -57,8 +57,7 @@
 			"bedarfsausweis-wohnen.ausweis"
 		);
 		if (localStorageAusweis) {
-			ausweis = JSON.parse(localStorageAusweis)
-			ausweis.ausweistyp = ausweistyp;
+			ausweis = JSON.parse(localStorageAusweis);
 		}
 
 		const localStorageAufnahme = localStorage.getItem(
@@ -148,7 +147,6 @@
 			{ausweisart}
 			{partner_code}
 			showWeiter={false}
-			{ausweistyp}
 			{form}
 			{skala}
 		></ButtonWeiterHilfe>
@@ -284,7 +282,6 @@
 		{ausweisart}
 		{partner_code}
 		showWeiter={true}
-		{ausweistyp}
 		{form}
 		{skala}
 	></ButtonWeiterHilfe>

src/modules/ChatModule.svelte

@@ -0,0 +1,18 @@
+<script lang="ts">
+	const socket = new WebSocket("http://localhost:8080");
+
+	socket.on("open", () => {
+		console.log("Connected to WebSocket");
+		
+		socket.send("Hello")
+	})
+
+	socket.on("message", (data) => {
+		console.log(data);
+		
+	})
+</script>
+
+<div>
+
+</div>

src/modules/KundendatenModule.svelte

@@ -32,12 +32,8 @@
 	import { getMaximumDevitationInPercent } from "#client/lib/helpers.js";
 	import { endEnergieVerbrauchVerbrauchsausweis_2016_Client } from "#lib/Berechnungen/VerbrauchsausweisWohnen/VerbrauchsausweisWohnen_2016_Client.js";
 	import { endEnergieVerbrauchVerbrauchsausweisGewerbe_2016_Client } from "#lib/Berechnungen/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbe_2016_Client.js";
-	import { benutzerSpeichern } from "#client/lib/speichern.js";
-	import { benutzerLesen } from "#client/lib/lesen.js";
-    import { exclude } from "#lib/exclude.js";
-	
+		
 	export let user: Partial<BenutzerClient>;
-	export let impersonatedUser: Partial<BenutzerClient> | null = null;
 	export let ausweis: VerbrauchsausweisWohnenClient | VerbrauchsausweisGewerbe | BedarfsausweisWohnen;
 	export let aufnahme: AufnahmeClient;
 	export let objekt: ObjektClient;
@@ -63,10 +59,6 @@
 		ort = rechnung?.ort || localStorage.getItem("kundendaten.ort") || user.ort || "";
 		zusatzzeile = rechnung?.zusatzzeile || localStorage.getItem("kundendaten.zusatzzeile") || ""
 		telefon = rechnung?.telefon || localStorage.getItem("kundendaten.telefon") || user.telefon || "";
-	} else if (impersonatedUser) {
-		vorname = impersonatedUser.vorname || "";
-		name = impersonatedUser.name || "";
-		telefon = impersonatedUser.telefon || "";
 	}
 
 	let abweichende_versand_adresse = JSON.parse(localStorage.getItem("kundendaten.abweichende_versand_adresse") || "false")
@@ -241,7 +233,7 @@
 		}
 	}
 
-	async function speichern(authuser = null) {
+	async function speichern() {
 		loginAction = speichern;
 		if (!await validateAccessTokenClient()) {
 			loginOverlayHidden = false;
@@ -257,23 +249,6 @@
 			} else {
 				result = await ausweisSpeichern(ausweis, objekt, aufnahme, bilder, unterlagen, ausweisart)
 			}
-
-			if (authuser) {
-				user = await benutzerLesen(authuser.id);
-			}
-
-			let resultUser: Awaited<ReturnType<typeof benutzerSpeichern>> | Awaited<ReturnType<typeof benutzerSpeichern>> | null = null;
-			const { passwort, ...baseUser } = impersonatedUser ?? user;
-
-			const benutzerObjekt = {
-				...baseUser,
-				name,
-				vorname,
-				telefon
-			};
-
-			resultUser = await benutzerSpeichern(benutzerObjekt);
-
 		} catch(e) {
 			addNotification({
 				dismissable: true,
@@ -294,7 +269,7 @@
 		}
 	}
 
-	async function bestellen(authuser = null) {
+	async function bestellen() {
 		if (!form.checkValidity()) {
 			addNotification({
 				dismissable: true,
@@ -337,22 +312,6 @@
 			}
 		}
 
-		if (authuser) {
-			user = await benutzerLesen(authuser.id);
-		}
-
-		let resultUser: Awaited<ReturnType<typeof benutzerSpeichern>> | Awaited<ReturnType<typeof benutzerSpeichern>> | null = null;
-		const { passwort, ...baseUser } = impersonatedUser ?? user;
-		
-		const benutzerObjekt = {
-			...baseUser,
-			name,
-			vorname,
-			telefon
-		};
-
-		resultUser = await benutzerSpeichern(benutzerObjekt);
-
 		if (rechnung && rechnung.status === "paid") {
 			window.location.href = "/dashboard"
 			return;
@@ -1113,7 +1072,7 @@ sm:grid-cols-[min-content_min-content_min-content] sm:justify-self-end sm:mt-8"
 
 			
 
-			<button class="order-2 button" type="button" on:click={() => speichern()}>Speichern</button>
+			<button class="order-2 button" type="button" on:click={speichern}>Speichern</button>
 
 			{#if rechnung && rechnung.status === "paid"}
 				<!-- Von einer GEG Anfrage sollte man sowieso nicht noch mal auf die Kundendaten Seite gelangen, also brauchen wir das hier nicht. -->
@@ -1121,7 +1080,7 @@ sm:grid-cols-[min-content_min-content_min-content] sm:justify-self-end sm:mt-8"
 					class="order-1 sm:order-2 button cursor-pointer"
 					data-cy="bestellen"
 					type="button"
-					on:click={() => bestellen()}>Absenden</button
+					on:click={bestellen}>Absenden</button
 				>
 			{:else}
 				{#if gegAnfrage}
@@ -1136,7 +1095,7 @@ sm:grid-cols-[min-content_min-content_min-content] sm:justify-self-end sm:mt-8"
 						class="order-1 sm:order-2 button cursor-pointer"
 						data-cy="bestellen"
 						type="button"
-						on:click={() => bestellen()}>Kostenpflichtig bestellen</button
+						on:click={bestellen}>Kostenpflichtig bestellen</button
 					>
 				{/if}
 			{/if}

src/modules/VerbrauchsausweisGewerbe/VerbrauchsausweisGewerbeModule.svelte

@@ -63,7 +63,6 @@
 		const localStorageAusweis = localStorage.getItem("verbrauchsausweis-gewerbe.ausweis");
 		if (localStorageAusweis) {
 			ausweis = JSON.parse(localStorageAusweis)
-			ausweis.ausweistyp = ausweistyp;
 		}
 
 		const localStorageAufnahme = localStorage.getItem("verbrauchsausweis-gewerbe.aufnahme");
@@ -129,7 +128,6 @@
 		bind:blockLocalStorageSync
 		ausweisart={Enums.Ausweisart.VerbrauchsausweisGewerbe}
 		showWeiter={false}
-		{ausweistyp}
 		{form}
 		{partner_code}
 		{skala}
@@ -247,7 +245,6 @@
 			bind:blockLocalStorageSync
 			ausweisart={Enums.Ausweisart.VerbrauchsausweisGewerbe}
 			showWeiter={true}
-			{ausweistyp}
 			{form}
 			{partner_code}
 			{skala}

src/pages/api/admin/ausstellen.ts

@@ -17,6 +17,7 @@ import { APIError, defineApiRoute } from "astro-typesafe-api/server";
 import { z } from "astro:content";
 import { transport } from "#lib/mail.js";
 import {Attachment} from "nodemailer/lib/mailer/index.js";
+import { BASE_URI } from "#lib/constants.js";
 import { getAnsichtsausweis, getDatenblatt, getAushang } from "#lib/server/ausweis.js";
 import { PutObjectCommand } from "@aws-sdk/client-s3";
 import { s3Client } from "#lib/s3.js";
@@ -33,6 +34,7 @@ import {
 	getVerbrauchsausweisWohnenKomplett,
 } from "#lib/server/db.js";
 import { PDFDocument } from "pdf-lib";
+import * as fs from 'fs';
 
 export const GET = defineApiRoute({
 	input: z.object({
@@ -327,14 +329,14 @@ export const GET = defineApiRoute({
 	
 	<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${
 		post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""
-	} <b>Bitte beachten Sie unsere neue Bankverbindung.</b> Bitte geben Sie als Verwendungszweck die Rechnungsnummer an (siehe unten). Vielen Dank.</p>
+	} Nachfolgend finden Sie unsere Bankverbindung. Bitte geben Sie als Verwendungszweck die Rechnungsnummer an (siehe unten). Vielen Dank.</p>
 	
 	<br>
 	<table>
-	<tr><td>Kreditinstitut</td><td>:</td><td>\t Volksbank eG</td>
+	<tr><td>Kreditinstitut</td><td>:</td><td>\t Commerzbank AG</td>
 	<tr><td>Empfänger</td><td>:</td><td>\t IB Cornelsen</td>
-	<tr><td>IBAN</td><td>:<td>\t DE13 2519 3331 7209 0731 00</td>
-	<tr><td>BIC</td><td>:</td><td>\t GENODEF1PAT</td>
+	<tr><td>IBAN</td><td>:<td>\t DE81 2004 0000 0348 6008 00</td>
+	<tr><td>BIC</td><td>:</td><td>\t COBADEFFXXX</td>
 	<tr><td>Betrag</td><td>:</td><td>\t <b>${rechnung.betrag}€</b></td>
 	<tr><td>Verwendungszweck</td><td>:</td><td>\t <b>${voucherNumber}</b></td>
 	</table>

src/pages/api/admin/bedarfsausweis-ausstellen.ts

@@ -197,7 +197,7 @@ export const POST = defineApiRoute({
 				let filename: string;
 
 				if (type === "Ausweis") {
-					filename = `ID_${ausweis.id}_Energieausweis.pdf`
+					filename = `ID_${ausweis.id}_Ausweis.pdf`
 				} else {
 					filename = `ID_${ausweis.id}_${name}`;
 				}
@@ -212,7 +212,7 @@ export const POST = defineApiRoute({
 
 				const command = new PutObjectCommand({
 					Bucket: "ibc-pdfs",
-					Key: filename,
+					Key: name,
 					Body: buffer,
 					ACL: "private",
 				});
@@ -336,14 +336,14 @@ export const POST = defineApiRoute({
 	
 	<p>im Anhang finden Sie Ihren geprüften Energieusweis inkl. Rechnung als PDF-Datei. ${
 		post ? "Zusätzlich haben wir Ihren Ausweis per Post verschickt" : ""
-	} <b>Bitte beachten Sie unsere neue Bankverbindung.</b> Bitte geben Sie als Verwendungszweck die Rechnungsnummer an (siehe unten). Vielen Dank.</p>
+	} Nachfolgend finden Sie unsere Bankverbindung. Bitte geben Sie als Verwendungszweck die Rechnungsnummer an (siehe unten). Vielen Dank.</p>
 	
 	<br>
 	<table>
-	<tr><td>Kreditinstitut</td><td>:</td><td>\t Volksbank eG</td>
+	<tr><td>Kreditinstitut</td><td>:</td><td>\t Commerzbank AG</td>
 	<tr><td>Empfänger</td><td>:</td><td>\t IB Cornelsen</td>
-	<tr><td>IBAN</td><td>:<td>\t DE13 2519 3331 7209 0731 00</td>
-	<tr><td>BIC</td><td>:</td><td>\t GENODEF1PAT</td>
+	<tr><td>IBAN</td><td>:<td>\t DE81 2004 0000 0348 6008 00</td>
+	<tr><td>BIC</td><td>:</td><td>\t COBADEFFXXX</td>
 	<tr><td>Betrag</td><td>:</td><td>\t <b>${rechnung.betrag}€</b></td>
 	<tr><td>Verwendungszweck</td><td>:</td><td>\t <b>${voucherNumber}</b></td>
 	</table>

src/pages/api/user/index.ts

@@ -5,17 +5,18 @@ import { adminMiddleware, authorizationMiddleware } from "#lib/middleware/author
 import { hashPassword } from "#lib/password.js";
 import { createLexOfficeCustomer } from "#lib/server/lexoffice.js";
 import { sendRegisterMail } from "#lib/server/mail/registrierung.js";
-import { Benutzer, prisma } from "#lib/server/prisma.js";
+import { prisma } from "#lib/server/prisma.js";
 import { APIError, defineApiRoute } from "astro-typesafe-api/server";
 import { BenutzerSchema } from "src/generated/zod/benutzer.js";
 import { z } from "zod";
-import { Enums } from "#lib/client/prisma.js";
 
 export const POST = defineApiRoute({
 	input: BenutzerSchema.omit({
+		id: true,
 		lex_office_id: true,
 		rolle: true,
-		created_at: true
+		created_at: true,
+		updated_at: true
 	}),
 	middleware: authorizationMiddleware,
 	async fetch(input, context, user) {
@@ -23,36 +24,24 @@ export const POST = defineApiRoute({
 			// TODO: Email wurde geändert, neue Bestätigunsmail schicken.
 		}
 
-		const updateData: any = {};
-		updateData.id = user.id;
-		if (input.adresse) updateData.adresse = input.adresse;
-		if (input.anrede) updateData.anrede = input.anrede;
-		if (input.email) updateData.email = input.email;
-		if (input.firma) updateData.firma = input.firma;
-		if (input.name) updateData.name = input.name;
-		if (input.vorname) updateData.vorname = input.vorname;
-		if (input.ort) updateData.ort = input.ort;
-		if (input.passwort.length != 0) updateData.passwort = hashPassword(input.passwort);
-		if (input.plz) updateData.plz = input.plz;
-		if (input.profilbild) updateData.profilbild = input.profilbild;
-		if (input.telefon) updateData.telefon = input.telefon;
-		if (input.verified) updateData.telefon = input.verified;
-
-		//Only Admin can update other users
-		if (user.rolle == Enums.BenutzerRolle.ADMIN && input.id != user.id) {
-			updateData.id = input.id;
-		} else if(user.rolle != Enums.BenutzerRolle.ADMIN && input.id != user.id){
-			return;
-		}
-
 		await prisma.benutzer.update({
 			where: {
-				id: updateData.id
+				id: user.id
 			},
-			data: updateData
-		});
-
-		
+			data: {
+				adresse: input.adresse,
+				anrede: input.anrede,
+				email: input.email,
+				firma: input.firma,
+				name: input.name,
+				vorname: input.vorname,
+				ort: input.ort,
+				passwort: hashPassword(input.passwort),
+				plz: input.plz,
+				profilbild: input.profilbild,
+				telefon: input.telefon,
+			}
+		})
 	},
 })
 
@@ -64,14 +53,9 @@ export const GET = defineApiRoute({
 		email: z.string()
 	})),
 	output: z.array(BenutzerSchema),
-	middleware: authorizationMiddleware,
+	middleware: adminMiddleware,
 	async fetch(input, context, admin) {
 		if ("id" in input) {
-			//Only Admin can read other users
-			if (admin.rolle != Enums.BenutzerRolle.ADMIN && input.id != admin.id) {
-				return;
-			}
-
 			const user = await prisma.benutzer.findUnique({
 				where: {
 					id: input.id
@@ -84,11 +68,6 @@ export const GET = defineApiRoute({
 
 			return [user];
 		} else {
-			//Only admin can read many users
-			if (admin.rolle != Enums.BenutzerRolle.ADMIN ) {
-				return;
-			}
-
 			const users = await prisma.benutzer.findMany({
 				where: {
 					email: {

src/pages/chat.astro

@@ -0,0 +1,8 @@
+---
+import Layout from "#layouts/Layout.astro";
+import ChatModule from "#modules/ChatModule.svelte";
+---
+
+<Layout title="Websockets">
+	<ChatModule client:only></ChatModule>
+</Layout>

src/pages/dashboard/abrechnung/index.astro

@@ -1,334 +0,0 @@
----
-import AbrechungTable from "#components/Abrechnung/AbrechungTable.svelte";
-import { Enums, prisma } from "#lib/server/prisma";
-import { getCurrentUser } from "#lib/server/user";
-import moment from "moment";
-
-
-const start = moment(Astro.url.searchParams.get("start"))
-const end = moment(Astro.url.searchParams.get("end"))
-
-let startdatum = start.toDate();
-let enddatum = end.toDate();
-
-const benutzer = await getCurrentUser(Astro)
-
-if (!benutzer) {
-	return Astro.redirect("/404")
-}
-
-const provisionen={
-	[Enums.Ausweisart.VerbrauchsausweisWohnen]: 10,
-	[Enums.Ausweisart.BedarfsausweisWohnen]: 10,
-	[Enums.Ausweisart.VerbrauchsausweisGewerbe]: 10,
-}
-
-// $kommission = db()->one("SELECT abr_va, abr_ba, abr_vanw FROM users WHERE resellercode = :resellercode", ["resellercode" => $resellercode]);
-// Select every entry from database where user was involved.
-let bestellungen;
-if (start.isValid() && end.isValid()) {
-	bestellungen = await prisma.rechnung.findMany({
-		where: {
-			partner_code: "immowelt",
-			OR: [{
-				verbrauchsausweis_gewerbe: {
-					ausgestellt: true
-				}
-			},
-		{
-				bedarfsausweis_wohnen: {
-					ausgestellt: true
-				}
-			},
-		{
-				verbrauchsausweis_wohnen: {
-					ausgestellt: true
-				}
-			}],
-			AND: [{
-				created_at: {
-					gte: startdatum
-				},
-			}, {
-				created_at: {
-					lte: enddatum
-				},
-			}]
-		},
-		orderBy: {
-			created_at: "desc"
-		},
-		include: {
-			bedarfsausweis_wohnen: true,
-			verbrauchsausweis_gewerbe: true,
-			verbrauchsausweis_wohnen: true
-		}
-	});
-} else {
-	bestellungen = await prisma.rechnung.findMany({
-		where: {
-			partner_code: "immowelt",
-			OR: [{
-				verbrauchsausweis_gewerbe: {
-					ausgestellt: true
-				}
-			},
-		{
-				bedarfsausweis_wohnen: {
-					ausgestellt: true
-				}
-			},
-		{
-				verbrauchsausweis_wohnen: {
-					ausgestellt: true
-				}
-			}]
-		},
-		orderBy: {
-			created_at: "desc"
-		},
-		include: {
-			bedarfsausweis_wohnen: true,
-			verbrauchsausweis_gewerbe: true,
-			verbrauchsausweis_wohnen: true
-		}
-	});
-}
-
-// Wann wurde der partner_code zum ersten mal benutzt?
-const partnerCodeErstesMal = (await prisma.rechnung.findFirst({
-	select: {
-		created_at: true
-	},
-	where: {
-		partner_code: "immowelt",
-		OR: [{
-				verbrauchsausweis_gewerbe: {
-					ausgestellt: true
-				}
-			},
-		{
-				bedarfsausweis_wohnen: {
-					ausgestellt: true
-				}
-			},
-		{
-				verbrauchsausweis_wohnen: {
-					ausgestellt: true
-				}
-			}],
-			created_at: {
-				gte: moment().set("year", 2020).set("dayOfYear", 1).toDate()
-			}
-	},
-	orderBy: {
-		created_at: "asc"
-	}
-}))?.created_at
-
-let provision = 0;
-const ausweisarten: string[] = [];
-for (const bestellung of bestellungen) {
-	if (bestellung.verbrauchsausweis_wohnen) {
-		ausweisarten.push(Enums.Ausweisart.VerbrauchsausweisWohnen)
-		provision += provisionen[Enums.Ausweisart.VerbrauchsausweisWohnen]
-	}
-	if (bestellung.bedarfsausweis_wohnen) {
-		ausweisarten.push(Enums.Ausweisart.BedarfsausweisWohnen)
-		provision += provisionen[Enums.Ausweisart.BedarfsausweisWohnen]
-	}
-	if (bestellung.verbrauchsausweis_gewerbe) {
-		ausweisarten.push(Enums.Ausweisart.VerbrauchsausweisGewerbe)
-		provision += provisionen[Enums.Ausweisart.VerbrauchsausweisGewerbe]
-	}
-}
-
----
-
-
-<!doctype html>
-<html lang="de">
-
-<head>
-	<meta charset="utf-8">
-	<title>Reporting | online-energieausweis.org</title>
-	<meta charset="utf-8">
-	<link rel="stylesheet" href="https://stackpath.bootstrapcdn.com/bootstrap/4.1.3/css/bootstrap.min.css" integrity="sha384-MCw98/SFnGE8fJT3GXwEOngsV7Zt27NXFoaoApmYm81iuXoPkFOJwJ8ERdknLPMO" crossorigin="anonymous">
-	<script type="text/javascript" src="https://cdn.jsdelivr.net/jquery/latest/jquery.min.js"></script>
-	<script type="text/javascript" src="https://cdn.jsdelivr.net/momentjs/latest/moment.min.js"></script>
-	<script type="text/javascript" src="https://cdn.jsdelivr.net/npm/daterangepicker/daterangepicker.min.js"></script>
-	<link rel="stylesheet" type="text/css" href="https://cdn.jsdelivr.net/npm/daterangepicker/daterangepicker.css" />
-	<link rel="stylesheet" href="./main.css">
-	<script src="https://cdnjs.cloudflare.com/ajax/libs/popper.js/1.14.3/umd/popper.min.js" integrity="sha384-ZMP7rVo3mIykV+2+9J3UJ46jBk0WLaUAdn689aCwoqbBJiSnjAK/l8WvCWPIPm49" crossorigin="anonymous"></script>
-	<script src="https://stackpath.bootstrapcdn.com/bootstrap/4.1.3/js/bootstrap.min.js" integrity="sha384-ChfqqxuZUCnJSK3+MXmPNIyE6ZbWh2IMqE241rYiqJxyMiZ6OW/JmZQ5stwEULTy" crossorigin="anonymous"></script>
-</head>
-
-<style>
-	body {
-		font-family: arial;
-	}
-
-	#inputwrap {
-		position: fixed;
-		top: 0;
-		left: 10%;
-		width: 70%;
-		padding-top: 10px;
-		padding-bottom: 10px;
-		background: #fff;
-	}
-
-	#cal {
-		margin-right: 10px !important;
-	}
-
-	#demo {
-		width: 76%;
-		display: inline-block;
-	}
-
-	table tr,
-	td {
-		border: 0.1em solid #000;
-		padding: 0;
-		margin: 0;
-	}
-
-	#QTT {
-		border-collapse: collapse;
-		width: 70%;
-		margin-top: 8em;
-		margin-left: 10%;
-		table-layout: auto;
-	}
-
-	#QTT thead td {
-		background: #ff7d26;
-		font-weight: bold;
-	}
-
-	#QTT tr:nth-child(even) {
-		background-color: #f2f2f2;
-	}
-
-	#QTT td {
-		padding: 0.4em 0.4em 0.4em 0.4em;
-		text-align: right;
-	}
-
-	#logo1 {
-		display: inline-block;
-		margin-right: 1em;
-		margin-top: -3px;
-	}
-
-	#logo2 {
-		width: 18%;
-		margin-bottom: 0.5em;
-		float: right;
-		padding-top: -1px;
-		margin-right: -5px;
-	}
-</style>
-
-
-
-<div id='inputwrap' class='form-group' >
-	<div style='display:flex; justify-content: space-between; align-items:center;'>
-<img id='logo1' src='https://widget.ib-cornelsen.de/OEA_WIDGETS/img/IBC-logo.png' alt='IBCornelsen' />  
-<h5 style='margin-top: 10px;'><b>Erziehlte Conversions von {benutzer.email}</b></h5>
-</div>
-<input type='text' id='demo' class='form-control' name='demo' value='' placeholder='Bitte Zeitraum auswählen' />
-</div>
-
-<AbrechungTable bestellungen={bestellungen} {provisionen} {partnerCodeErstesMal}></AbrechungTable>
-
-
-<div id="total" class="footer">
-	<div class="inner">
-		<div>
-			<p id="betrag_gesamt">Abrechnungsbetrag gesamt: <b>{provision} €</b></p>
-		</div>
-		<a target='_blank' rel='noreferrer noopener' href=`/user/abrechnung/pdf.php?month=${moment().subtract(1, "month").get("month")}&year=${moment().subtract(1, "month").get("year")}`>PDF für letzten Monat generieren.</a>
-	</div>
-</div>
-
-<script type="text/javascript">
-	$('#demo').daterangepicker({
-		"showDropdowns": true,
-		"minYear": 2019,
-		ranges: {
-			'Heute': [moment(), moment()],
-			'Gestern': [moment().subtract(1, 'days'), moment().subtract(1, 'days')],
-			'letzte 7 Tage': [moment().subtract(6, 'days'), moment()],
-			'letzte 30 Tage': [moment().subtract(29, 'days'), moment()],
-			'dieser Monat': [moment().startOf('month'), moment().endOf('month')],
-			'letzter Monat': [moment().subtract(1, 'month').startOf('month'), moment().subtract(1, 'month').endOf('month')]
-		},
-		"locale": {
-			"format": "DD/MM/YYYY",
-			"separator": " - ",
-			"applyLabel": "Übernehmen",
-			"cancelLabel": "Abrechen",
-			"fromLabel": "Von",
-			"toLabel": "Bis",
-			"customRangeLabel": "Benutzerdefiniert",
-			"weekLabel": "W",
-			"daysOfWeek": [
-				"So",
-				"Mo",
-				"Di",
-				"Mi",
-				"Do",
-				"Fr",
-				"Sa"
-			],
-			"monthNames": [
-				"Januar",
-				"Februar",
-				"März",
-				"April",
-				"Mai",
-				"Juni",
-				"Juli",
-				"August",
-				"September",
-				"Oktober",
-				"November",
-				"Dezember"
-			],
-			"firstDay": 1
-		},
-		"autoUpdateInput": false,
-		"alwaysShowCalendars": true,
-		"startDate": "<?php echo $day_start_display; ?>",
-		"endDate": "<?php echo $day_end_display; ?>",
-		"minDate": "01/10/2019"
-	}, function(start, end, label) {
-		var Pstart = start.format('MM/DD/YYYY');
-		var Pend = end.format('MM/DD/YYYY');
-
-		$("#start").val(Pstart);
-		$("#end").val(Pend);
-
-		$('#FO').submit();
-
-	});
-
-	// $("#demo").val(`Conversions im Zeitraum: <?php echo $Pall; ?>`);
-</script>
-
-
-<body>
-	<form id='FO' method='GET' action='index.php'>
-		<input type="hidden" id="start" name="start" value='' />
-		<input type="hidden" id="end" name="end" value='' />
-	</form>
-
-	<script>
-
-	</script>
-
-</body>
-
-</html>

src/pages/dashboard/objekte/index.astro

@@ -50,9 +50,9 @@ if (user.rolle === Enums.BenutzerRolle.USER) {
 	// SELECT id, updated_at FROM "GEGNachweisGewerbe" WHERE created_at >= ${date} AND bestellt = ${true}
 
 	result =
-		await prisma.$queryRaw`SELECT id, updated_at FROM "VerbrauchsausweisWohnen" WHERE ausgestellt = ${false} AND bestellt = ${true} UNION ALL
-			SELECT id, updated_at FROM "VerbrauchsausweisGewerbe" WHERE ausgestellt = ${false} AND bestellt = ${true} UNION ALL 
-			SELECT id, updated_at FROM "BedarfsausweisWohnen" WHERE ausgestellt = ${false} AND bestellt = ${true} UNION ALL
+		await prisma.$queryRaw`SELECT id, updated_at FROM "VerbrauchsausweisWohnen" UNION ALL
+			SELECT id, updated_at FROM "VerbrauchsausweisGewerbe" UNION ALL 
+			SELECT id, updated_at FROM "BedarfsausweisWohnen" UNION ALL
 			SELECT id, updated_at FROM "BedarfsausweisGewerbe" UNION ALL 
 			SELECT id, updated_at FROM "GEGNachweisWohnen" UNION ALL 
 			SELECT id, updated_at FROM "GEGNachweisGewerbe"

src/pages/energieausweis-erstellen/bezahlung.astro

@@ -3,11 +3,10 @@ import { getAusweisartFromId } from "#components/Ausweis/types";
 import AusweisLayoutPruefung from "#layouts/AusweisLayoutPruefung.astro";
 import { getPrismaAusweisAdapter } from "#lib/server/ausweis";
 import { Enums } from "#lib/server/prisma";
-import { getCurrentUser, getOtherUser } from "#lib/server/user";
+import { getCurrentUser } from "#lib/server/user";
 import KundendatenModule from "#modules/KundendatenModule.svelte";
 import { PaymentStatus } from "@mollie/api-client";
 import { AusweisTyp } from "src/generated/enums";
-import { BenutzerClient } from "#components/Ausweis/types.js";
 
 const uid = Astro.url.searchParams.get("uid")
 
@@ -46,16 +45,8 @@ if (!ausweis) {
 if (ausweis.rechnung.status === PaymentStatus.paid) {
 	return Astro.redirect("/dashboard")
 }
-
-let impersonatedUser: Partial<BenutzerClient> | null = null;
-
-if (user){
-	if (user.id !== ausweis.benutzer_id && ausweis.benutzer_id !== undefined){
-		impersonatedUser = await getOtherUser(Astro, ausweis.benutzer_id) || {}
-	}
-}
 ---
 
 <AusweisLayoutPruefung title="Energieausweis Bezahlung">
-	<KundendatenModule {user} {impersonatedUser} {ausweis} objekt={ausweis.aufnahme.objekt} rechnung={ausweis.rechnung} aufnahme={ausweis.aufnahme} bilder={ausweis.aufnahme.bilder} {ausweisart} ausweistyp={AusweisTyp.Standard} aktiveBezahlmethode={Enums.Bezahlmethoden.paypal} client:only></KundendatenModule>
+	<KundendatenModule {user} {ausweis} objekt={ausweis.aufnahme.objekt} rechnung={ausweis.rechnung} aufnahme={ausweis.aufnahme} bilder={ausweis.aufnahme.bilder} {ausweisart} ausweistyp={AusweisTyp.Standard} aktiveBezahlmethode={Enums.Bezahlmethoden.paypal} client:only></KundendatenModule>
 </AusweisLayoutPruefung>

src/pages/heap-snapshot.astro

@@ -1,19 +0,0 @@
----
-import { getHeapSnapshot } from "v8";
-import * as fs from "fs";
-
-// Create a named heap snapshot
-const snapshotStream = getHeapSnapshot();
-const fileName = `heap-${Date.now()}.heapsnapshot`;
-const fileStream = fs.createWriteStream(fileName);
-
-snapshotStream.pipe(fileStream);
-
-fileStream.on("finish", () => {
-  console.log(`Heap snapshot saved to ${fileName}`);
-});
-
-fileStream.on("error", (err) => {
-  console.error("Error writing heap snapshot:", err);
-});
----

src/pages/kundendaten.astro

@@ -3,10 +3,9 @@
 import KundendatenModule from "#modules/KundendatenModule.svelte";
 import AusweisLayout from "#layouts/AusweisLayoutPruefung.astro";
 import { Enums } from "#lib/client/prisma";
-import { getCurrentUser, getOtherUser } from "#lib/server/user";
+import { getCurrentUser } from "#lib/server/user";
 import { getAusweisartFromId } from "#components/Ausweis/types";
 import { getAufnahme, getBedarfsausweisWohnen, getBilder, getObjekt, getRechnung, getUnterlagen, getVerbrauchsausweisGewerbe, getVerbrauchsausweisWohnen } from "#lib/server/db";
-import { BenutzerClient } from "#components/Ausweis/types.js";
 
 // Man sollte nur auf diese Seite kommen, wenn ein Ausweis bereits vorliegt und in der Datenbank abgespeichert wurde.
 
@@ -71,16 +70,9 @@ if (!params.has("ausweis") || !params.has("aufnahme") || !params.has("objekt") |
 	}
 }
 
-let impersonatedUser: Partial<BenutzerClient> | null = null;
-
-if (user){
-	if (user.id !== ausweis.benutzer_id && ausweis.benutzer_id !== undefined){
-		impersonatedUser = await getOtherUser(Astro, ausweis.benutzer_id) || {}
-	}
-}
 ---
 
 <AusweisLayout title="Kundendaten Aufnehmen - IBCornelsen">
-	<KundendatenModule {user} {impersonatedUser} {ausweis} {objekt} {aufnahme} {bilder} {rechnung} {ausweisart} {unterlagen} {partner_code} aktiveBezahlmethode={Enums.Bezahlmethoden.paypal} client:only ></KundendatenModule>
+	<KundendatenModule {user} {ausweis} {objekt} {aufnahme} {bilder} {rechnung} {ausweisart} {unterlagen} {partner_code} aktiveBezahlmethode={Enums.Bezahlmethoden.paypal} client:only ></KundendatenModule>
 </AusweisLayout>
 

src/pages/pdf/ansichtsausweis.ts

@@ -45,23 +45,14 @@ export const GET: APIRoute = async (Astro) => {
 	user = await getCurrentUser(Astro)
 
 	let pdf: Uint8Array<ArrayBufferLike> | null = null;
-
-	if (ausweis.ausgestellt) {
-		if (/[A-Z]{2}[0-9]{8}/.test(ausweis.id)) {
-			const id = ausweis.id.match(/[A-Z]{2}([0-9]{8})/) as RegExpMatchArray
-			// Dieser Ausweis wurde mit der alten Version erstellt, das PDF sollte bereits existieren.
-			pdf = await getS3File("ibc-pdfs", `ID_${id[1]}_Energieausweis.pdf`)
-		} else {
-			pdf = await getS3File("ibc-pdfs", `ID_${ausweis.id}_Energieausweis.pdf`)
-		}
-	} else {
-		if (ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen) {
-			pdf = await pdfVerbrauchsausweisWohnen(ausweis as VerbrauchsausweisWohnenClient, aufnahme, objekt, bilder, user, !ausweis.ausgestellt);
-		} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe) {
-			pdf = await pdfVerbrauchsausweisGewerbe(ausweis as VerbrauchsausweisGewerbeClient, aufnahme, objekt, bilder, user, !ausweis.ausgestellt);
-		} else if (ausweisart === Enums.Ausweisart.BedarfsausweisWohnen) {
-			//todo
-		}
+	if (/[A-Z]{2}[0-9]{8}/.test(ausweis.id)) {
+		const id = ausweis.id.match(/[A-Z]{2}([0-9]{8})/) as RegExpMatchArray
+		// Dieser Ausweis wurde mit der alten Version erstellt, das PDF sollte bereits existieren.
+		pdf = await getS3File("ibc-pdfs", `ID_${id[1]}_Energieausweis.pdf`)
+	} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisWohnen) {
+		pdf = await pdfVerbrauchsausweisWohnen(ausweis as VerbrauchsausweisWohnenClient, aufnahme, objekt, bilder, user, !ausweis.ausgestellt);
+	} else if (ausweisart === Enums.Ausweisart.VerbrauchsausweisGewerbe) {
+		pdf = await pdfVerbrauchsausweisGewerbe(ausweis as VerbrauchsausweisGewerbeClient, aufnahme, objekt, bilder, user, !ausweis.ausgestellt);
 	}
 
 	return new Response(pdf, {

src/server/logger.ts

@@ -0,0 +1,36 @@
+import { prisma } from "#lib/server/prisma.js";
+import winston from "winston";
+import Transport from "winston-transport";
+
+class DatabaseTransport extends Transport {
+	constructor() {
+		super();
+	}
+
+	async log(info: any, callback: () => void) {
+		setImmediate(() => {
+			this.emit("logged", info);
+		});
+
+		const { level, message, ...meta } = info;
+
+		await prisma.log.create({
+			data: {
+				level,
+				message,
+				meta: JSON.stringify(meta),
+			},
+		});
+
+		callback();
+	}
+}
+
+export const logger = winston.createLogger({
+	level: "info",
+	format: winston.format.json(),
+	transports: [new DatabaseTransport(), new winston.transports.Console({
+		handleExceptions: true,
+		handleRejections: true,
+	})]
+});

src/ws/server.ts

@@ -0,0 +1,30 @@
+import { logger } from '#server/logger.js';
+import { WebSocketServer } from 'ws';
+
+const server = new WebSocketServer({ port: 8080 });
+
+
+
+server.on('connection', (ws, req) => {
+  logger.info("Client connected to websocket", {
+		ip: req.socket.remoteAddress
+	})
+
+  ws.on('message', (message) => {
+    logger.info("Received websocket message", {
+			message
+		});
+
+    ws.send(`Server received: ${message}`);
+  });
+
+  ws.on('close', () => {
+    logger.info('Client disconnected', {
+			ip: req.socket.remoteAddress
+		});
+  });
+});
+
+logger.info(`Websocket server listening on port ${8080}`)
+
+export { server };

src/ws/types.ts

@@ -0,0 +1,60 @@
+import { Conversation, Message } from "#lib/client/prisma.js";
+
+export type WebsocketClientToServerMessage =
+	| {
+			type: "messages/get";
+			payload: {
+				conversation_id: string;
+				filters?: {
+					after?: Date;
+					before?: Date;
+				};
+			};
+	  }
+	| {
+			type: "message/send";
+			payload: {
+				conversation_id: string;
+				content: string;
+				reply_to_id?: string;
+			};
+	  }
+	| {
+			type: "conversations/get";
+			payload: {
+				includeMessages?: boolean;
+			};
+	  }
+	| {
+			type: "conversation/create";
+			payload: {
+				participant_ids: string[]; // includes sender
+				name?: string; // optional for group
+			};
+	  };
+
+/* ---------------------------- Server to client ---------------------------- */
+
+export type WebsocketServerToClientMessage =
+	| {
+			type: "messages/list";
+			payload: {
+				conversation_id: string;
+				messages: Message[];
+			};
+	  }
+	| {
+			type: "message/new";
+			payload: Message;
+	  }
+	| {
+			type: "conversations/list";
+			payload: Conversation[];
+	  }
+	| {
+			type: "error";
+			payload: {
+				code: string;
+				message: string;
+			};
+	  };