7 Commits

Author SHA1 Message Date
f1fc5eafc3 Merge pull request 'dev' (#47) from dev into main
All checks were successful
Code Analysis and Production Deploy / analyze (push) Has been skipped
Code Analysis and Production Deploy / deploy-production (push) Successful in 3m57s
Code Analysis and Production Deploy / deploy-test (push) Has been skipped
Reviewed-on: #47
2026-08-12 15:25:19 +02:00
Torsten Schulz (local)
7aadb5e215 Version increase
All checks were successful
Code Analysis and Production Deploy / analyze (push) Successful in 9m54s
Code Analysis and Production Deploy / deploy-production (push) Has been skipped
Code Analysis and Production Deploy / deploy-test (push) Successful in 3m23s
2026-08-12 14:16:28 +02:00
Torsten Schulz (local)
76d7000735 optimized design
All checks were successful
Code Analysis and Production Deploy / analyze (push) Successful in 10m8s
Code Analysis and Production Deploy / deploy-production (push) Has been skipped
Code Analysis and Production Deploy / deploy-test (push) Successful in 3m18s
2026-08-12 13:15:14 +02:00
Torsten Schulz (local)
51e59e85ef packages updated
All checks were successful
Code Analysis and Production Deploy / analyze (push) Successful in 10m32s
Code Analysis and Production Deploy / deploy-production (push) Has been skipped
Code Analysis and Production Deploy / deploy-test (push) Successful in 3m50s
2026-08-12 12:22:22 +02:00
Torsten Schulz (local)
0475e3084d lint fehler behoben
Some checks failed
Code Analysis and Production Deploy / analyze (push) Failing after 10m21s
Code Analysis and Production Deploy / deploy-production (push) Has been skipped
Code Analysis and Production Deploy / deploy-test (push) Has been skipped
2026-08-12 12:03:29 +02:00
Torsten Schulz (local)
9889430109 Overwork of design
Some checks failed
Code Analysis and Production Deploy / analyze (push) Failing after 6m5s
Code Analysis and Production Deploy / deploy-production (push) Has been skipped
Code Analysis and Production Deploy / deploy-test (push) Has been skipped
2026-08-12 11:31:22 +02:00
Torsten Schulz (local)
cb89fdd911 Member registration fixed
Some checks failed
Code Analysis and Production Deploy / analyze (push) Failing after 6m17s
Code Analysis and Production Deploy / deploy-production (push) Has been skipped
Code Analysis and Production Deploy / deploy-test (push) Has been skipped
2026-08-12 11:15:07 +02:00
26 changed files with 2828 additions and 791 deletions

View File

@@ -78,12 +78,12 @@ val ensureProductionApiBaseUrl = tasks.register("ensureProductionApiBaseUrl") {
android {
namespace = "de.harheimertc"
compileSdk = 35
compileSdk = 36
defaultConfig {
applicationId = "de.harheimertc"
minSdk = 24
targetSdk = 35
targetSdk = 36
versionCode = androidVersionCode
versionName = androidVersionName
}

Binary file not shown.

View File

@@ -166,6 +166,7 @@ data class MembershipResponse(
val success: Boolean = false,
val message: String? = null,
val downloadUrl: String? = null,
val downloadToken: String? = null,
)
data class LoginRequest(
val email: String,
@@ -660,7 +661,10 @@ interface ApiService {
@Streaming
@GET
suspend fun downloadMembershipPdf(@Url downloadUrl: String): Response<ResponseBody>
suspend fun downloadMembershipPdf(
@Url downloadUrl: String,
@retrofit2.http.Header("X-Membership-Download-Token") downloadToken: String? = null,
): Response<ResponseBody>
@POST("/api/auth/login")
suspend fun login(@Body request: LoginRequest): Response<LoginResponse>

View File

@@ -16,14 +16,16 @@ import de.harheimertc.R
import de.harheimertc.ui.navigation.Destinations
object HarheimerNotifications {
const val DEFAULT_CHANNEL_ID = "harheimer_tc_updates"
// A new ID is intentional: Android does not allow an app update to raise
// the importance of an already-created notification channel.
const val DEFAULT_CHANNEL_ID = "harheimer_tc_updates_v2"
fun createChannels(context: Context) {
if (Build.VERSION.SDK_INT < Build.VERSION_CODES.O) return
val channel = NotificationChannel(
DEFAULT_CHANNEL_ID,
"Harheimer TC",
NotificationManager.IMPORTANCE_DEFAULT,
NotificationManager.IMPORTANCE_HIGH,
).apply {
description = "Benachrichtigungen des Harheimer TC"
}
@@ -47,7 +49,7 @@ object HarheimerNotifications {
.setContentTitle(title)
.setContentText(message)
.setStyle(NotificationCompat.BigTextStyle().bigText(message))
.setPriority(NotificationCompat.PRIORITY_DEFAULT)
.setPriority(NotificationCompat.PRIORITY_HIGH)
.setContentIntent(createContentIntent(context, notificationId, data))
.setAutoCancel(true)
.build()

View File

@@ -9,7 +9,7 @@ import java.io.File
import javax.inject.Inject
import javax.inject.Singleton
data class MembershipDocument(val message: String, val uri: String)
data class MembershipDocument(val message: String, val uri: String? = null)
@Singleton
class MembershipRepository @Inject constructor(
@@ -18,21 +18,33 @@ class MembershipRepository @Inject constructor(
) {
suspend fun submit(request: MembershipRequest): Result<MembershipDocument> = runCatching {
val response = api.generateMembershipPdf(request)
if (!response.isSuccessful) error("HTTP ${response.code()}")
if (!response.isSuccessful) {
val serverMessage = response.errorBody()?.string()
?.let { Regex("\\\"(?:statusMessage|message)\\\"\\s*:\\s*\\\"([^\\\"]+)\\\"").find(it)?.groupValues?.getOrNull(1) ?: it }
?.takeIf { it.isNotBlank() }
error(serverMessage ?: "Der Antrag konnte nicht übermittelt werden (HTTP ${response.code()}).")
}
val body = response.body() ?: error("Leere Antwort")
if (!body.success) error(body.message ?: "Antrag konnte nicht erstellt werden.")
val downloadUrl = body.downloadUrl ?: error("PDF-Download fehlt.")
val documentResponse = api.downloadMembershipPdf(downloadUrl)
if (!documentResponse.isSuccessful) error("PDF konnte nicht heruntergeladen werden.")
val directory = File(context.cacheDir, "membership").apply { mkdirs() }
val file = File(directory, "beitrittserklaerung.pdf")
documentResponse.body()?.byteStream()?.use { input ->
file.outputStream().use { output -> input.copyTo(output) }
} ?: error("Leere PDF-Antwort")
val uri = FileProvider.getUriForFile(context, "${context.packageName}.files", file)
val uri = body.downloadUrl?.let { downloadUrl ->
runCatching {
val documentResponse = api.downloadMembershipPdf(downloadUrl, body.downloadToken)
if (!documentResponse.isSuccessful) error("PDF konnte nicht heruntergeladen werden.")
val directory = File(context.cacheDir, "membership").apply { mkdirs() }
val file = File(directory, "beitrittserklaerung.pdf")
documentResponse.body()?.byteStream()?.use { input ->
file.outputStream().use { output -> input.copyTo(output) }
} ?: error("Leere PDF-Antwort")
FileProvider.getUriForFile(context, "${context.packageName}.files", file).toString()
}.getOrNull()
}
MembershipDocument(
message = body.message ?: "Beitrittsformular erfolgreich erstellt.",
uri = uri.toString(),
message = if (uri == null) {
"${body.message ?: "Mitgliedschaftsantrag erfolgreich übermittelt."} Das PDF konnte nicht auf diesem Gerät gespeichert werden."
} else {
body.message ?: "Beitrittsformular erfolgreich erstellt."
},
uri = uri,
)
}
}

View File

@@ -81,7 +81,10 @@ class MembershipViewModel @Inject constructor(private val repository: Membership
_state.value = _state.value.copy(sending = false, fieldErrors = emptyMap(), message = document.message, pdfUri = document.uri)
}
.onFailure {
_state.value = _state.value.copy(sending = false, error = "Beitrittsformular konnte nicht erstellt werden.")
_state.value = _state.value.copy(
sending = false,
error = it.message ?: "Beitrittsformular konnte nicht erstellt werden.",
)
}
}
}

View File

@@ -8,8 +8,8 @@ LOCAL_API_BASE_URL=https://harheimertc.tsschulz.de/
PRODUCTION_API_BASE_URL=https://harheimertc.de/
# Android app versioning for Play Store uploads
ANDROID_VERSION_CODE=29
ANDROID_VERSION_NAME=0.9.24
ANDROID_VERSION_CODE=32
ANDROID_VERSION_NAME=0.9.27
# Temporary hotfix: disable R8 minification for release to avoid Retrofit generic signature stripping.
RELEASE_MINIFY_ENABLED=false

View File

@@ -1,7 +1,7 @@
<template>
<div class="h-screen flex flex-col overflow-hidden">
<Navigation />
<main class="flex-1 overflow-y-auto pt-20">
<main class="flex-1 overflow-y-auto pt-20 pb-20 sm:pb-0">
<NuxtPage />
</main>
<Footer />

View File

@@ -1,11 +1,11 @@
<template>
<footer class="fixed bottom-0 left-0 right-0 z-40 bg-gray-900 border-t border-gray-800 shadow-2xl">
<div class="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8 py-3">
<div class="flex flex-col sm:flex-row justify-between items-center space-y-2 sm:space-y-0">
<p class="text-sm text-gray-400">
<div class="max-w-7xl mx-auto px-3 sm:px-6 lg:px-8 py-2 sm:py-3">
<div class="flex flex-col sm:flex-row justify-between items-center gap-y-1 sm:gap-y-0">
<p class="text-xs sm:text-sm text-gray-400 whitespace-nowrap">
© {{ currentYear }} Harheimer TC 1954 e.V.
</p>
<div class="flex items-center space-x-6 text-sm relative">
<div class="flex flex-wrap justify-center items-center gap-x-4 gap-y-1 text-xs sm:text-sm relative">
<span
v-if="isLoggedIn && appVersion"
class="text-xs text-gray-600"

View File

@@ -29,9 +29,9 @@
</div>
<!-- Content -->
<div class="relative z-20 max-w-7xl mx-auto">
<div class="relative z-20 max-w-7xl mx-auto px-4 sm:px-6 lg:px-8">
<div class="text-center">
<h1 class="text-5xl sm:text-6xl lg:text-7xl font-display font-bold text-gray-900 mb-6 leading-tight animate-fade-in">
<h1 class="text-4xl sm:text-6xl lg:text-7xl font-display font-bold text-gray-900 mb-6 leading-tight animate-fade-in">
Willkommen beim<br>
<span class="text-primary-600">Harheimer TC</span>
</h1>
@@ -163,4 +163,3 @@ const yearsSinceFounding = new Date().getFullYear() - foundingYear
animation: fadeIn 0.8s ease-out 0.4s both;
}
</style>

View File

@@ -1,7 +1,7 @@
<template>
<section class="py-16 sm:py-20 bg-gray-50">
<section class="py-8 sm:py-10 bg-gray-50">
<div class="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8">
<div class="text-center mb-12">
<div class="text-center mb-6 sm:mb-8">
<h2 class="text-4xl sm:text-5xl font-display font-bold text-gray-900 mb-4">
Kommende Termine
</h2>
@@ -12,7 +12,7 @@
<TermineVorschau />
</div>
<div class="text-center mt-8">
<div class="text-center mt-5 sm:mt-6">
<NuxtLink
to="/termine"
class="inline-flex items-center px-6 py-3 bg-primary-600 hover:bg-primary-700 text-white font-semibold rounded-lg transition-colors"
@@ -32,4 +32,3 @@
import { ArrowRight } from 'lucide-vue-next'
import TermineVorschau from './TermineVorschau.vue'
</script>

View File

@@ -1,9 +1,13 @@
<template>
<section
class="py-16 sm:py-20 bg-white min-h-[32rem]"
class="bg-white"
:class="news.length === 0 && !isLoading ? 'py-8 sm:py-10' : 'py-10 sm:py-12'"
>
<div class="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8">
<div class="text-center mb-16">
<div
class="text-center"
:class="news.length === 0 && !isLoading ? 'mb-6 sm:mb-8' : 'mb-8 sm:mb-10'"
>
<h2 class="text-4xl sm:text-5xl font-display font-bold text-gray-900 mb-4">
Aktuelles
</h2>
@@ -67,7 +71,7 @@
<div
v-else
class="max-w-xl mx-auto text-center bg-gray-50 border border-gray-200 rounded-xl p-8"
class="max-w-xl mx-auto text-center bg-gray-50 border border-gray-200 rounded-xl p-5"
>
<p class="text-gray-700 font-semibold mb-2">
Aktuell keine News
@@ -222,4 +226,3 @@ onUnmounted(() => {
opacity: 0;
}
</style>

View File

@@ -1,7 +1,7 @@
<template>
<section class="py-16 bg-white">
<section class="py-8 sm:py-10 bg-white">
<div class="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8">
<div class="text-center mb-12">
<div class="text-center mb-6 sm:mb-8">
<h2 class="text-3xl font-bold text-gray-900 mb-4">
Nächste Spiele
</h2>
@@ -10,7 +10,7 @@
<!-- Loading State -->
<div
v-if="isLoading"
class="text-center py-8"
class="text-center py-4"
>
<svg
class="w-8 h-8 text-gray-400 mx-auto mb-4 animate-spin"
@@ -33,7 +33,7 @@
<!-- Error State -->
<div
v-else-if="error"
class="text-center py-8"
class="text-center py-4"
>
<svg
class="w-12 h-12 text-gray-400 mx-auto mb-4"
@@ -62,7 +62,7 @@
<!-- Empty State -->
<div
v-else-if="!upcomingGames || upcomingGames.length === 0"
class="text-center py-8"
class="text-center py-4"
>
<svg
class="w-12 h-12 text-gray-400 mx-auto mb-4"

View File

@@ -45,7 +45,7 @@
<div
v-else
class="text-center py-8 bg-gray-50 rounded-lg"
class="text-center py-4 bg-gray-50 rounded-lg"
>
<Calendar
:size="32"
@@ -123,4 +123,3 @@ onMounted(() => {
loadTermine()
})
</script>

View File

@@ -219,7 +219,10 @@
>
<span class="text-sm text-gray-800">{{ team.label }}</span>
</label>
<p v-if="!spielplanTeams.length" class="px-4 py-3 text-sm text-gray-500">
<p
v-if="!spielplanTeams.length"
class="px-4 py-3 text-sm text-gray-500"
>
Noch keine importierten Spielplan-Teams verfügbar.
</p>
</div>

3243
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -1,6 +1,6 @@
{
"name": "harheimertc-website",
"version": "1.8.4",
"version": "1.8.5",
"description": "Moderne Webseite für den Harheimer Tischtennis Club",
"private": true,
"type": "module",
@@ -40,12 +40,12 @@
"jsonwebtoken": "^9.0.2",
"multer": "^2.0.2",
"nodemailer": "^9.0.1",
"nuxt": "^4.1.3",
"nuxt": "^4.5.1",
"pdf-lib": "^1.17.1",
"pdf-parse": "^2.4.5",
"pinia": "^3.0.3",
"quill": "^2.0.2",
"sharp": "^0.34.5",
"quill": "2.0.2",
"sharp": "^0.35.3",
"vue": "^3.5.22"
},
"devDependencies": {

View File

@@ -216,7 +216,7 @@
class="relative z-30 px-4 sm:px-6 lg:px-8"
:class="hasHeroSection ? '-mt-44 sm:-mt-48 lg:-mt-52' : 'mt-8'"
>
<div class="featured-widget-shell max-w-6xl mx-auto rounded-2xl border border-gray-200 bg-white/25 backdrop-blur-md overflow-hidden min-h-[22rem] sm:min-h-[25rem]">
<div class="featured-widget-shell max-w-6xl mx-auto rounded-2xl border border-gray-200 bg-white/25 backdrop-blur-md overflow-hidden">
<HomeSpielplanTeamWidget
v-if="featuredWidgetSection.id === 'spielplan_team'"
:season="featuredWidgetSection.config?.season"
@@ -627,9 +627,15 @@ async function saveEditor() {
background-color: transparent !important;
}
.featured-widget-shell :deep(.py-8),
.featured-widget-shell :deep(.py-10),
.featured-widget-shell :deep(.py-12),
.featured-widget-shell :deep(.py-16),
.featured-widget-shell :deep(.sm\:py-10),
.featured-widget-shell :deep(.sm\:py-12),
.featured-widget-shell :deep(.sm\:py-16),
.featured-widget-shell :deep(.sm\:py-20) {
padding-top: 1.5rem !important;
padding-bottom: 2rem !important;
padding-bottom: 1.5rem !important;
}
</style>

View File

@@ -2,6 +2,7 @@ import fs from 'fs/promises'
import path from 'path'
import { requireUserWithAnyRole } from '../../utils/auth.js'
import { decryptObject } from '../../utils/encryption.js'
import { getServerDataPath } from '../../utils/paths.js'
export default defineEventHandler(async (event) => {
try {
@@ -17,7 +18,7 @@ export default defineEventHandler(async (event) => {
})
}
const dataDir = path.join(process.cwd(), 'server/data/membership-applications')
const dataDir = getServerDataPath('membership-applications')
// Prüfen ob Verzeichnis existiert
try {

View File

@@ -1,5 +1,6 @@
import fs from 'fs/promises'
import path from 'path'
import { createHmac, timingSafeEqual } from 'crypto'
import { getUserFromToken } from '../../../utils/auth.js'
import { getServerDataPath } from '../../../utils/paths.js'
@@ -47,7 +48,27 @@ export default defineEventHandler(async (event) => {
}
}
// Prüfen ob es sich um eine aktuelle Session handelt (innerhalb der letzten 24 Stunden)
// Native apps cannot reliably reuse the httpOnly browser cookie that is
// set when the application is created. They receive the same short-lived
// authorization as a signed response token instead.
const signedDownloadToken = getHeader(event, 'x-membership-download-token')
if (signedDownloadToken) {
try {
const [payload, signature] = signedDownloadToken.split('.')
const secret = process.env.ENCRYPTION_KEY || 'local_development_encryption_key_change_in_production'
const expected = createHmac('sha256', secret).update(payload).digest('base64url')
const validSignature = signature && timingSafeEqual(Buffer.from(signature), Buffer.from(expected))
const decoded = JSON.parse(Buffer.from(payload, 'base64url').toString('utf8'))
const tokenAge = Date.now() - Number(decoded.issuedAt)
if (validSignature && decoded.fileId === fileId && tokenAge >= 0 && tokenAge < 24 * 60 * 60 * 1000) {
isAuthorized = true
}
} catch (_error) {
// Invalid download tokens are treated as unauthorized.
}
}
// Browser clients continue to use the httpOnly cookie.
const downloadToken = getCookie(event, 'download_token')
if (downloadToken) {

View File

@@ -1,11 +1,13 @@
import { exec } from 'child_process'
import { promisify } from 'util'
import { createHmac } from 'crypto'
import fs from 'fs/promises'
import path from 'path'
import { PDFDocument, StandardFonts, rgb } from 'pdf-lib'
import { getDownloadCookieOptionsWithMaxAge } from '../../utils/cookies.js'
import { sendMembershipEmail as sendMembershipEmailUtil } from '../../utils/email-service.js'
import { getProjectPath, getServerDataPath } from '../../utils/paths.js'
import { createMembershipApplication, removeMembershipApplication } from '../../utils/membership-applications.js'
// const require = createRequire(import.meta.url) // Nicht verwendet
const execAsync = promisify(exec)
@@ -310,9 +312,18 @@ function getDataPath(filename) {
return getServerDataPath(filename)
}
function createMembershipDownloadToken(fileId) {
const issuedAt = Date.now()
const payload = Buffer.from(JSON.stringify({ fileId, issuedAt })).toString('base64url')
const secret = process.env.ENCRYPTION_KEY || 'local_development_encryption_key_change_in_production'
const signature = createHmac('sha256', secret).update(payload).digest('base64url')
return `${payload}.${signature}`
}
// Use central email service
export default defineEventHandler(async (event) => {
let application = null
try {
const body = await readBody(event)
@@ -339,6 +350,10 @@ export default defineEventHandler(async (event) => {
isVolljaehrig
}
// Persist the pending application before generating files or sending mail.
// This also makes repeated taps and concurrent requests idempotently fail.
application = await createMembershipApplication(data)
// Eindeutige Datei-ID generieren
const timestamp = Date.now()
const filename = `beitrittserklärung_${timestamp}`
@@ -630,9 +645,11 @@ export default defineEventHandler(async (event) => {
success: true,
message: 'Beitrittsformular erfolgreich aus Template erzeugt und E-Mail gesendet.',
downloadUrl: `/api/membership/download/${filename}.pdf`,
downloadToken: createMembershipDownloadToken(`${filename}.pdf`),
emailSuccess: emailResult.success,
emailMessage: emailResult.message,
usedTemplate: true
usedTemplate: true,
applicationId: application.id
}
}
@@ -690,8 +707,10 @@ export default defineEventHandler(async (event) => {
success: true,
message: 'Beitrittsformular erfolgreich erstellt und E-Mail gesendet.',
downloadUrl: `/api/membership/download/${filename}.pdf`,
downloadToken: createMembershipDownloadToken(`${filename}.pdf`),
emailSuccess: emailResult.success,
emailMessage: emailResult.message,
applicationId: application.id
}
} catch (latexError) {
@@ -726,13 +745,19 @@ export default defineEventHandler(async (event) => {
success: true,
message: 'Beitrittsformular erfolgreich erstellt und E-Mail gesendet (Fallback-Lösung).',
downloadUrl: `/api/membership/download/${fallbackFilename}`,
downloadToken: createMembershipDownloadToken(fallbackFilename),
emailSuccess: emailResult.success,
emailMessage: emailResult.message,
applicationId: application.id
}
}
} catch (error) {
// A failed generation must not leave a pending application that prevents
// the applicant from trying again.
await removeMembershipApplication(application?.id)
console.error('Fehler beim Generieren des PDFs:', error)
if (error?.statusCode) throw error
throw createError({
statusCode: 500,
statusMessage: 'Fehler beim Generieren des PDFs'

View File

@@ -1,8 +1,8 @@
import fs from 'fs/promises'
import path from 'path'
import { requireUserWithAnyRole } from '../../utils/auth.js'
import { decryptObject } from '../../utils/encryption.js'
import { saveMember } from '../../utils/members.js'
import { getServerDataPath } from '../../utils/paths.js'
export default defineEventHandler(async (event) => {
try {
@@ -43,9 +43,7 @@ export default defineEventHandler(async (event) => {
}
// nosemgrep: javascript.lang.security.audit.path-traversal.path-join-resolve-traversal.path-join-resolve-traversal
const dataDir = path.join(process.cwd(), 'server/data/membership-applications')
// nosemgrep: javascript.lang.security.audit.path-traversal.path-join-resolve-traversal.path-join-resolve-traversal
const filePath = path.join(dataDir, `${id}.json`)
const filePath = getServerDataPath('membership-applications', `${id}.json`)
// Antrag laden
const fileContent = await fs.readFile(filePath, 'utf8')
@@ -67,6 +65,7 @@ export default defineEventHandler(async (event) => {
const newMember = {
firstName: decryptedData.vorname,
lastName: decryptedData.nachname,
geburtsdatum: decryptedData.geburtsdatum,
email: decryptedData.email,
phone: decryptedData.telefon_privat || decryptedData.telefon_mobil || '',
address: `${decryptedData.strasse}, ${decryptedData.plz} ${decryptedData.ort}`,

View File

@@ -221,14 +221,23 @@ export function normalizeDate(dateString) {
}
// Check for duplicate member based on firstName, lastName, and geburtsdatum
function findDuplicateMember(members, firstName, lastName, geburtsdatum) {
const normalizedFirstName = (firstName || '').trim().toLowerCase()
const normalizedLastName = (lastName || '').trim().toLowerCase()
function normalizeIdentityPart(value) {
return String(value || '')
.normalize('NFKD')
.replace(/[\u0300-\u036f]/g, '')
.replace(/[^a-zA-Z0-9]+/g, ' ')
.trim()
.toLowerCase()
}
export function findDuplicateMember(members, firstName, lastName, geburtsdatum) {
const normalizedFirstName = normalizeIdentityPart(firstName)
const normalizedLastName = normalizeIdentityPart(lastName)
const normalizedDate = normalizeDate(geburtsdatum)
return members.find(m => {
const mFirstName = (m.firstName || '').trim().toLowerCase()
const mLastName = (m.lastName || '').trim().toLowerCase()
const mFirstName = normalizeIdentityPart(m.firstName)
const mLastName = normalizeIdentityPart(m.lastName)
const mDate = normalizeDate(m.geburtsdatum)
return mFirstName === normalizedFirstName &&
@@ -307,4 +316,3 @@ export async function deleteMember(id) {
await writeMembers(filtered)
return true
}

View File

@@ -0,0 +1,104 @@
import { createHash, randomUUID } from 'crypto'
import { promises as fs } from 'fs'
import { decryptObject, encryptObject } from './encryption.js'
import { readMembers, findDuplicateMember, normalizeDate } from './members.js'
import { getServerDataPath } from './paths.js'
const APPLICATIONS_DIR = getServerDataPath('membership-applications')
const LOCKS_DIR = getServerDataPath('membership-application-locks')
function encryptionKey() {
return process.env.ENCRYPTION_KEY || 'local_development_encryption_key_change_in_production'
}
function normalizeName(value) {
return String(value || '')
.normalize('NFKD')
.replace(/[\u0300-\u036f]/g, '')
.replace(/[^a-zA-Z0-9]+/g, ' ')
.trim()
.toLowerCase()
}
function identityHash(data) {
const identity = [normalizeName(data.vorname), normalizeName(data.nachname), normalizeDate(data.geburtsdatum)].join('|')
return createHash('sha256').update(identity).digest('hex')
}
async function withIdentityLock(hash, operation) {
await fs.mkdir(LOCKS_DIR, { recursive: true })
const lockPath = `${LOCKS_DIR}/${hash}.lock`
let handle
try {
handle = await fs.open(lockPath, 'wx')
} catch (error) {
if (error?.code === 'EEXIST') {
throw createError({ statusCode: 409, statusMessage: 'Für diese Person wird bereits ein Mitgliedschaftsantrag bearbeitet.' })
}
throw error
}
try {
return await operation()
} finally {
await handle.close().catch(() => {})
await fs.unlink(lockPath).catch(() => {})
}
}
async function findMatchingApplication(data) {
try {
const files = await fs.readdir(APPLICATIONS_DIR)
const target = identityHash(data)
for (const file of files.filter(file => file.endsWith('.json'))) {
try {
const application = JSON.parse(await fs.readFile(`${APPLICATIONS_DIR}/${file}`, 'utf8'))
if (application.identityHash === target) return application
if (application.encryptedData) {
const personalData = decryptObject(application.encryptedData, encryptionKey())
if (identityHash(personalData) === target) return application
}
} catch (error) {
console.warn('Mitgliedschaftsantrag konnte bei der Duplikatprüfung nicht gelesen werden:', { file, message: error.message })
}
}
return null
} catch (error) {
if (error?.code !== 'ENOENT') throw error
return null
}
}
export async function createMembershipApplication(data) {
const hash = identityHash(data)
if (!normalizeName(data.vorname) || !normalizeName(data.nachname) || !normalizeDate(data.geburtsdatum)) {
throw createError({ statusCode: 400, statusMessage: 'Vorname, Nachname und ein gültiges Geburtsdatum sind erforderlich.' })
}
return withIdentityLock(hash, async () => {
const members = await readMembers()
if (findDuplicateMember(members, data.vorname, data.nachname, data.geburtsdatum)) {
throw createError({ statusCode: 409, statusMessage: 'Für diese Person besteht bereits eine Mitgliedschaft.' })
}
const existing = await findMatchingApplication(data)
if (existing) {
throw createError({ statusCode: 409, statusMessage: 'Für diese Person liegt bereits ein Mitgliedschaftsantrag vor.' })
}
await fs.mkdir(APPLICATIONS_DIR, { recursive: true })
const application = {
id: randomUUID(),
timestamp: new Date().toISOString(),
status: 'pending',
identityHash: hash,
metadata: { mitgliedschaftsart: data.mitgliedschaftsart },
encryptedData: encryptObject(data, encryptionKey())
}
await fs.writeFile(`${APPLICATIONS_DIR}/${application.id}.json`, `${JSON.stringify(application, null, 2)}\n`, { encoding: 'utf8', flag: 'wx' })
return application
})
}
export async function removeMembershipApplication(applicationId) {
if (!applicationId) return
await fs.unlink(`${APPLICATIONS_DIR}/${applicationId}.json`).catch(error => {
if (error?.code !== 'ENOENT') throw error
})
}

View File

@@ -102,7 +102,7 @@ export function upsertPushToken(user, { token, platform = 'android', appVersion
return user
}
async function sendFcmMessage({ serviceAccount, accessToken, token, title, body, data = {} }) {
async function sendFcmMessage({ serviceAccount, accessToken, token, data = {} }) {
const projectId = projectIdFromServiceAccount(serviceAccount)
if (!projectId) throw new Error('FCM project_id fehlt.')
const response = await fetch(`https://fcm.googleapis.com/v1/projects/${projectId}/messages:send`, {
@@ -114,14 +114,14 @@ async function sendFcmMessage({ serviceAccount, accessToken, token, title, body,
body: JSON.stringify({
message: {
token,
notification: { title, body },
data,
android: {
priority: 'high',
notification: {
channel_id: 'harheimer_tc_updates',
click_action: 'OPEN_NEWS'
}
// Keep this as a data message. With a `notification` payload FCM
// renders background messages itself, bypassing our notification
// channel and HarheimerMessagingService. Data messages use the
// same app-controlled channel while the app is foregrounded and
// backgrounded.
}
}
})
@@ -185,7 +185,7 @@ export async function sendPushToUsers({ title, body, data = {}, predicate, bodyF
const validTokens = []
for (const entry of tokens) {
try {
await sendFcmMessage({ serviceAccount, accessToken, token: entry.token, title, body: userBody, data: payload })
await sendFcmMessage({ serviceAccount, accessToken, token: entry.token, data: payload })
sent += 1
validTokens.push(entry)
} catch (error) {
@@ -206,7 +206,11 @@ export async function sendPushToUsers({ title, body, data = {}, predicate, bodyF
}
}
if (changed) await writeUsers(users)
return { sent, failed, removed, recipients, tokenCount, skipped: false }
const result = { sent, failed, removed, recipients, tokenCount, skipped: false }
// This makes an absent registration immediately visible in the production
// log without exposing tokens or user data.
console.info('FCM Push Ergebnis:', { failureLabel, ...result })
return result
}
export async function sendNewNewsPush(news) {

View File

@@ -0,0 +1,36 @@
import { afterEach, describe, expect, it, vi } from 'vitest'
import { promises as fs } from 'fs'
import os from 'os'
import path from 'path'
const originalAppRoot = process.env.APP_ROOT
const createdRoots = []
afterEach(async () => {
vi.resetModules()
if (originalAppRoot === undefined) delete process.env.APP_ROOT
else process.env.APP_ROOT = originalAppRoot
await Promise.all(createdRoots.splice(0).map(root => fs.rm(root, { recursive: true, force: true })))
})
describe('membership applications', () => {
it('rejects a second pending application with the same name and birth date', async () => {
const root = await fs.mkdtemp(path.join(os.tmpdir(), 'harheimertc-membership-'))
createdRoots.push(root)
await fs.mkdir(path.join(root, 'server', 'data'), { recursive: true })
process.env.APP_ROOT = root
const { createMembershipApplication } = await import('../server/utils/membership-applications.js')
const data = {
vorname: 'Jörg',
nachname: 'Beispiel',
geburtsdatum: '1990-02-03',
mitgliedschaftsart: 'aktiv'
}
const application = await createMembershipApplication(data)
expect(application.status).toBe('pending')
await expect(createMembershipApplication({ ...data, vorname: ' JÖRG ' }))
.rejects.toMatchObject({ statusCode: 409 })
})
})