Compare commits
15 Commits
e52aea9dd3
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
755f46a66c | ||
|
|
83f3b45d6e | ||
|
|
4f957d4da6 | ||
|
|
f6360edef3 | ||
|
|
28fc22fcd8 | ||
|
|
c881d660e2 | ||
|
|
90287e098e | ||
|
|
1d4cae35a5 | ||
| 3f771bf7b0 | |||
|
|
f1179ddc09 | ||
| e78902d79f | |||
|
|
7b4a179428 | ||
|
|
5ef9735ea5 | ||
|
|
03eeef5c69 | ||
|
|
fa685e6ba9 |
@@ -1,7 +1,7 @@
|
||||
{
|
||||
"name": "scan-wave",
|
||||
"private": true,
|
||||
"version": "0.0.1",
|
||||
"version": "0.0.2",
|
||||
"type": "module",
|
||||
"scripts": {
|
||||
"dev": "vite dev",
|
||||
|
||||
@@ -6,12 +6,14 @@
|
||||
let {
|
||||
onSuccess,
|
||||
onError,
|
||||
onDisconnect,
|
||||
disabled = false,
|
||||
size = 'default',
|
||||
variant = 'primary'
|
||||
} = $props<{
|
||||
onSuccess?: (token: string) => void;
|
||||
onError?: (error: string) => void;
|
||||
onDisconnect?: () => void;
|
||||
disabled?: boolean;
|
||||
size?: 'small' | 'default' | 'large';
|
||||
variant?: 'primary' | 'secondary';
|
||||
@@ -23,6 +25,9 @@
|
||||
|
||||
onMount(async () => {
|
||||
await authManager.checkConnection();
|
||||
if (authState.isConnected && authState.token) {
|
||||
onSuccess?.(authState.token);
|
||||
}
|
||||
});
|
||||
|
||||
async function handleConnect() {
|
||||
@@ -41,6 +46,7 @@
|
||||
|
||||
async function handleDisconnect() {
|
||||
await authManager.disconnectGoogle();
|
||||
onDisconnect?.();
|
||||
}
|
||||
|
||||
// Size classes
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
import { google } from 'googleapis';
|
||||
import { getAuthenticatedClient } from '../auth/server.js';
|
||||
import { GoogleSheet } from './types.ts';
|
||||
import { GoogleSheet } from './types';
|
||||
|
||||
// Type for sheet data
|
||||
export interface SheetData {
|
||||
@@ -51,25 +51,48 @@ export async function getRecentSpreadsheets(
|
||||
* Get data from a Google Sheet
|
||||
* @param refreshToken - Google refresh token
|
||||
* @param spreadsheetId - ID of the spreadsheet
|
||||
* @param range - Cell range to retrieve (default: A1:Z10)
|
||||
* @param range - Optional cell range. If not provided, it will fetch the entire first sheet.
|
||||
* @returns Sheet data as a 2D array
|
||||
*/
|
||||
export async function getSpreadsheetData(
|
||||
refreshToken: string,
|
||||
spreadsheetId: string,
|
||||
range: string = 'A1:Z10'
|
||||
refreshToken: string,
|
||||
spreadsheetId: string,
|
||||
range?: string
|
||||
): Promise<SheetData> {
|
||||
const oauth = getAuthenticatedClient(refreshToken);
|
||||
const sheets = google.sheets({ version: 'v4', auth: oauth });
|
||||
const oauth = getAuthenticatedClient(refreshToken);
|
||||
const sheets = google.sheets({ version: 'v4', auth: oauth });
|
||||
|
||||
const response = await sheets.spreadsheets.values.get({
|
||||
spreadsheetId,
|
||||
range
|
||||
});
|
||||
let effectiveRange = range;
|
||||
|
||||
return {
|
||||
values: response.data.values || []
|
||||
};
|
||||
// If no range is provided, get the name of the first sheet and use that as the range
|
||||
// to fetch all its content.
|
||||
if (!effectiveRange) {
|
||||
try {
|
||||
const info = await getSpreadsheetInfo(refreshToken, spreadsheetId);
|
||||
const firstSheetName = info.sheets?.[0]?.properties?.title;
|
||||
|
||||
if (firstSheetName) {
|
||||
// To use a sheet name as a range, it must be quoted if it contains spaces or special characters.
|
||||
effectiveRange = `'${firstSheetName}'`;
|
||||
} else {
|
||||
// Fallback if sheet name can't be determined.
|
||||
effectiveRange = 'A1:Z1000'; // A sensible default for a large preview
|
||||
}
|
||||
} catch (error) {
|
||||
console.error(`Failed to get sheet info for spreadsheet ${spreadsheetId}`, error);
|
||||
// Fallback if the info call fails
|
||||
effectiveRange = 'A1:Z1000';
|
||||
}
|
||||
}
|
||||
|
||||
const response = await sheets.spreadsheets.values.get({
|
||||
spreadsheetId,
|
||||
range: effectiveRange
|
||||
});
|
||||
|
||||
return {
|
||||
values: response.data.values || []
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<h1 class="text-3xl font-bold text-center mb-2">ScanWave</h1>
|
||||
<h2 class="text-lg text-gray-600 text-center mb-8">Make entrance to your events a breeze.</h2>
|
||||
<div class="flex space-x-4 w-full justify-center">
|
||||
<a href="/private/home" class="bg-blue-600 hover:bg-blue-700 text-white font-bold py-3 px-8 rounded-full shadow-none border border-gray-300 w-64 text-center transition">
|
||||
<a href="/private/home" class="bg-blue-600 hover:bg-blue-700 text-white font-bold py-3 px-8 rounded-full shadow-none border border-gray-300 w-64 text-center transition" data-sveltekit-reload>
|
||||
Get started
|
||||
</a>
|
||||
</div>
|
||||
|
||||
@@ -17,7 +17,7 @@
|
||||
</script>
|
||||
|
||||
<nav class="border-b border-gray-300 bg-gray-50 p-2 text-gray-900">
|
||||
<div class="container mx-auto max-w-2xl p-2">
|
||||
<div class="container mx-auto max-w-4xl p-2">
|
||||
<div class="flex items-center justify-between">
|
||||
<a href="/private/home" class="text-lg font-bold" aria-label="ScanWave Home">ScanWave</a>
|
||||
|
||||
@@ -32,7 +32,7 @@
|
||||
</nav>
|
||||
|
||||
|
||||
<div class="container mx-auto max-w-2xl bg-white p-2">
|
||||
<div class="container mx-auto max-w-4xl bg-white p-2">
|
||||
<QueryClientProvider client={queryClient}>
|
||||
{@render children()}
|
||||
</QueryClientProvider>
|
||||
|
||||
@@ -2,17 +2,18 @@ import { json } from '@sveltejs/kit';
|
||||
import type { RequestHandler } from './$types';
|
||||
import { googleSheetsServer } from '$lib/google/sheets/server.js';
|
||||
|
||||
export const GET: RequestHandler = async ({ params, request }) => {
|
||||
export const GET: RequestHandler = async ({ params, request, url }) => {
|
||||
try {
|
||||
const { sheetId } = params;
|
||||
const authHeader = request.headers.get('authorization');
|
||||
|
||||
const range = url.searchParams.get('range') || undefined;
|
||||
|
||||
if (!authHeader?.startsWith('Bearer ')) {
|
||||
return json({ error: 'Missing or invalid authorization header' }, { status: 401 });
|
||||
}
|
||||
|
||||
const refreshToken = authHeader.slice(7);
|
||||
const sheetData = await googleSheetsServer.getSpreadsheetData(refreshToken, sheetId, 'A1:Z10');
|
||||
const sheetData = await googleSheetsServer.getSpreadsheetData(refreshToken, sheetId, range);
|
||||
|
||||
return json(sheetData);
|
||||
} catch (error) {
|
||||
|
||||
@@ -57,7 +57,7 @@
|
||||
{$debouncedSearch ? `Search Results: "${$debouncedSearch}"` : 'All Events'}
|
||||
</h1>
|
||||
|
||||
<div class="grid grid-cols-1 md:grid-cols-2 gap-4 max-w-2xl mx-auto mb-10">
|
||||
<div class="grid grid-cols-1 sm:grid-cols-2 xl:grid-cols-3 gap-4 mx-auto mb-10">
|
||||
{#if isLoading}
|
||||
<!-- Loading placeholders -->
|
||||
{#each Array(4) as _}
|
||||
|
||||
@@ -1,6 +1,5 @@
|
||||
<script lang="ts">
|
||||
import { onMount } from 'svelte';
|
||||
import { isTokenValid, getUserInfo, revokeToken } from '$lib/google/auth/client.js';
|
||||
import type { GoogleSheet } from '$lib/google/sheets/types.ts';
|
||||
import { goto } from '$app/navigation';
|
||||
import { toast } from '$lib/stores/toast.js';
|
||||
@@ -16,19 +15,11 @@
|
||||
let { data } = $props();
|
||||
|
||||
// Step management
|
||||
let currentStep = $state(0); // Start at step 0 for Google auth check
|
||||
const totalSteps = 4; // Increased to include auth step
|
||||
let currentStep = $state(0);
|
||||
const totalSteps = 4;
|
||||
|
||||
// Step 0: Google Auth
|
||||
let authData = $state({
|
||||
isConnected: false,
|
||||
checking: true,
|
||||
connecting: false,
|
||||
showCancelOption: false,
|
||||
token: null as string | null,
|
||||
error: null as string | null,
|
||||
userEmail: null as string | null
|
||||
});
|
||||
let isGoogleConnected = $state(false);
|
||||
|
||||
// Step 1: Event Details
|
||||
let eventData = $state({
|
||||
@@ -42,13 +33,13 @@
|
||||
selectedSheet: null as GoogleSheet | null,
|
||||
sheetData: [] as string[][],
|
||||
columnMapping: {
|
||||
name: 0, // Initialize to 0 (no column selected)
|
||||
name: 0,
|
||||
surname: 0,
|
||||
email: 0,
|
||||
confirmation: 0
|
||||
},
|
||||
loading: false,
|
||||
expandedSheetList: true // Add this flag to control sheet list expansion
|
||||
expandedSheetList: true
|
||||
});
|
||||
|
||||
// Step 3: Email
|
||||
@@ -62,189 +53,11 @@
|
||||
let errors = $state<Record<string, string>>({});
|
||||
|
||||
onMount(async () => {
|
||||
// Check Google auth status on mount
|
||||
await checkGoogleAuth();
|
||||
|
||||
if (currentStep === 2) {
|
||||
await loadRecentSheets();
|
||||
}
|
||||
});
|
||||
|
||||
// Google Auth functions
|
||||
async function checkGoogleAuth() {
|
||||
authData.checking = true;
|
||||
try {
|
||||
const accessToken = localStorage.getItem('google_access_token');
|
||||
const refreshToken = localStorage.getItem('google_refresh_token');
|
||||
|
||||
if (accessToken && refreshToken) {
|
||||
// Check if token is still valid
|
||||
const isValid = await isTokenValid(accessToken);
|
||||
authData.isConnected = isValid;
|
||||
authData.token = accessToken;
|
||||
|
||||
if (isValid) {
|
||||
// Fetch user info
|
||||
await fetchUserInfo(accessToken);
|
||||
}
|
||||
} else {
|
||||
authData.isConnected = false;
|
||||
authData.userEmail = null;
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error checking Google auth:', error);
|
||||
authData.isConnected = false;
|
||||
authData.error = 'Error checking Google connection';
|
||||
authData.userEmail = null;
|
||||
} finally {
|
||||
authData.checking = false;
|
||||
}
|
||||
}
|
||||
|
||||
async function connectToGoogle() {
|
||||
authData.error = '';
|
||||
authData.connecting = true;
|
||||
|
||||
try {
|
||||
// Open popup window for OAuth
|
||||
const popup = window.open(
|
||||
'/auth/google',
|
||||
'google-auth',
|
||||
'width=500,height=600,scrollbars=yes,resizable=yes,left=' +
|
||||
Math.round(window.screen.width / 2 - 250) +
|
||||
',top=' +
|
||||
Math.round(window.screen.height / 2 - 300)
|
||||
);
|
||||
|
||||
if (!popup) {
|
||||
authData.error = 'Failed to open popup window. Please allow popups for this site.';
|
||||
authData.connecting = false;
|
||||
return;
|
||||
}
|
||||
|
||||
let authCompleted = false;
|
||||
let popupTimer: number | null = null;
|
||||
let cancelTimeout: number | null = null;
|
||||
|
||||
// Store current timestamp to detect changes in localStorage
|
||||
const startTimestamp = localStorage.getItem('google_auth_timestamp') || '0';
|
||||
|
||||
// Poll localStorage for auth completion
|
||||
const pollInterval = setInterval(() => {
|
||||
try {
|
||||
const currentTimestamp = localStorage.getItem('google_auth_timestamp');
|
||||
|
||||
// If timestamp has changed, auth is complete
|
||||
if (currentTimestamp && currentTimestamp !== startTimestamp) {
|
||||
handleAuthSuccess();
|
||||
}
|
||||
} catch (e) {
|
||||
console.error('Error checking auth timestamp:', e);
|
||||
}
|
||||
}, 500); // Poll every 500ms
|
||||
|
||||
// Common handler for authentication success
|
||||
function handleAuthSuccess() {
|
||||
if (authCompleted) return; // Prevent duplicate handling
|
||||
|
||||
authCompleted = true;
|
||||
authData.connecting = false;
|
||||
authData.showCancelOption = false;
|
||||
|
||||
// Clean up timers
|
||||
clearInterval(pollInterval);
|
||||
if (popupTimer) clearTimeout(popupTimer);
|
||||
if (cancelTimeout) clearTimeout(cancelTimeout);
|
||||
|
||||
// Update auth state
|
||||
setTimeout(checkGoogleAuth, 100);
|
||||
}
|
||||
|
||||
// Clean up function to handle all cleanup in one place
|
||||
const cleanUp = () => {
|
||||
clearInterval(pollInterval);
|
||||
if (popupTimer) clearTimeout(popupTimer);
|
||||
if (cancelTimeout) clearTimeout(cancelTimeout);
|
||||
authData.connecting = false;
|
||||
};
|
||||
|
||||
// Set a timeout for initial auth check
|
||||
popupTimer = setTimeout(() => {
|
||||
// Only check if auth isn't already completed
|
||||
if (!authCompleted) {
|
||||
cleanUp();
|
||||
// Check if tokens were stored by the popup before it was closed
|
||||
setTimeout(checkGoogleAuth, 100);
|
||||
}
|
||||
}, 30 * 1000) as unknown as number; // Reduced from 60s to 30s
|
||||
|
||||
// Show cancel option sooner
|
||||
cancelTimeout = setTimeout(() => {
|
||||
if (!authCompleted) {
|
||||
authData.showCancelOption = true;
|
||||
}
|
||||
}, 10 * 1000) as unknown as number; // Reduced from 20s to 10s
|
||||
|
||||
// Final cleanup timeout
|
||||
setTimeout(() => {
|
||||
if (!authCompleted) {
|
||||
cleanUp();
|
||||
}
|
||||
}, 60 * 1000); // Reduced from 3min to 1min
|
||||
} catch (error) {
|
||||
console.error('Error connecting to Google:', error);
|
||||
authData.error = 'Failed to connect to Google';
|
||||
authData.connecting = false;
|
||||
}
|
||||
}
|
||||
|
||||
function cancelGoogleAuth() {
|
||||
authData.connecting = false;
|
||||
authData.showCancelOption = false;
|
||||
}
|
||||
|
||||
async function fetchUserInfo(accessToken: string) {
|
||||
try {
|
||||
// Use the new getUserInfo function from our lib
|
||||
const userData = await getUserInfo(accessToken);
|
||||
if (userData) {
|
||||
authData.userEmail = userData.email;
|
||||
} else {
|
||||
authData.userEmail = null;
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error fetching user info:', error);
|
||||
authData.userEmail = null;
|
||||
}
|
||||
}
|
||||
|
||||
async function disconnectGoogle() {
|
||||
try {
|
||||
// First revoke the token at Google using our API
|
||||
const accessToken = localStorage.getItem('google_access_token');
|
||||
if (accessToken) {
|
||||
await revokeToken(accessToken);
|
||||
}
|
||||
|
||||
// Remove tokens from local storage
|
||||
localStorage.removeItem('google_access_token');
|
||||
localStorage.removeItem('google_refresh_token');
|
||||
|
||||
// Update auth state
|
||||
authData.isConnected = false;
|
||||
authData.token = null;
|
||||
authData.userEmail = null;
|
||||
|
||||
// Clear any selected sheets data
|
||||
sheetsData.availableSheets = [];
|
||||
sheetsData.selectedSheet = null;
|
||||
sheetsData.sheetData = [];
|
||||
} catch (error) {
|
||||
console.error('Error disconnecting from Google:', error);
|
||||
authData.error = 'Failed to disconnect from Google';
|
||||
}
|
||||
}
|
||||
|
||||
// Step navigation
|
||||
function nextStep() {
|
||||
if (validateCurrentStep()) {
|
||||
@@ -265,7 +78,7 @@
|
||||
let isValid = true;
|
||||
|
||||
if (currentStep === 0) {
|
||||
if (!authData.isConnected) {
|
||||
if (!isGoogleConnected) {
|
||||
toast.error('Please connect your Google account to continue');
|
||||
errors.auth = 'Please connect your Google account to continue';
|
||||
return false;
|
||||
@@ -359,8 +172,8 @@
|
||||
}
|
||||
|
||||
try {
|
||||
// Use the new unified API endpoint
|
||||
const response = await fetch(`/private/api/google/sheets/${sheet.id}/data`, {
|
||||
// Use the new unified API endpoint, requesting only a preview range
|
||||
const response = await fetch(`/private/api/google/sheets/${sheet.id}/data?range=A1:Z10`, {
|
||||
method: 'GET',
|
||||
headers: {
|
||||
Authorization: `Bearer ${localStorage.getItem('google_refresh_token')}`
|
||||
@@ -437,13 +250,13 @@
|
||||
|
||||
// Computed values
|
||||
let canProceed = $derived(() => {
|
||||
if (currentStep === 0) return authData.isConnected;
|
||||
if (currentStep === 1) return eventData.name && eventData.date;
|
||||
if (currentStep === 0) return isGoogleConnected;
|
||||
if (currentStep === 1) return !!(eventData.name && eventData.date);
|
||||
if (currentStep === 2) {
|
||||
const { name, surname, email, confirmation } = sheetsData.columnMapping;
|
||||
return sheetsData.selectedSheet && name && surname && email && confirmation;
|
||||
return !!(sheetsData.selectedSheet && name && surname && email && confirmation);
|
||||
}
|
||||
if (currentStep === 3) return emailData.subject && emailData.body;
|
||||
if (currentStep === 3) return !!(emailData.subject && emailData.body);
|
||||
return false;
|
||||
});
|
||||
</script>
|
||||
@@ -455,16 +268,9 @@
|
||||
<div class="mb-4 rounded border border-gray-300 bg-white p-6">
|
||||
{#if currentStep === 0}
|
||||
<GoogleAuthStep
|
||||
onSuccess={(token) => {
|
||||
authData.error = null;
|
||||
authData.token = token;
|
||||
authData.isConnected = true;
|
||||
setTimeout(checkGoogleAuth, 100);
|
||||
}}
|
||||
onError={(error) => {
|
||||
authData.error = error;
|
||||
authData.isConnected = false;
|
||||
}}
|
||||
onSuccess={() => (isGoogleConnected = true)}
|
||||
onDisconnect={() => (isGoogleConnected = false)}
|
||||
onError={(err) => toast.error(err)}
|
||||
/>
|
||||
{:else if currentStep === 1}
|
||||
<EventDetailsStep bind:eventData />
|
||||
@@ -485,7 +291,7 @@
|
||||
<StepNavigation
|
||||
{currentStep}
|
||||
{totalSteps}
|
||||
{canProceed}
|
||||
canProceed={canProceed()}
|
||||
{loading}
|
||||
{prevStep}
|
||||
{nextStep}
|
||||
|
||||
@@ -2,9 +2,10 @@
|
||||
import GoogleAuthButton from '$lib/components/GoogleAuthButton.svelte';
|
||||
|
||||
// Props
|
||||
let { onSuccess, onError } = $props<{
|
||||
let { onSuccess, onError, onDisconnect } = $props<{
|
||||
onSuccess?: (token: string) => void;
|
||||
onError?: (error: string) => void;
|
||||
onDisconnect?: () => void;
|
||||
}>();
|
||||
</script>
|
||||
|
||||
@@ -15,11 +16,12 @@
|
||||
To create events and import participants from Google Sheets, you need to connect your Google account.
|
||||
</p>
|
||||
|
||||
<GoogleAuthButton
|
||||
size="large"
|
||||
variant="primary"
|
||||
onSuccess={onSuccess}
|
||||
onError={onError}
|
||||
/>
|
||||
<GoogleAuthButton
|
||||
size="large"
|
||||
variant="primary"
|
||||
{onSuccess}
|
||||
{onError}
|
||||
{onDisconnect}
|
||||
/>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
@@ -115,6 +115,8 @@
|
||||
}
|
||||
|
||||
syncingParticipants = true;
|
||||
const previousCount = participants.length; // Capture count before sync
|
||||
|
||||
try {
|
||||
// Fetch sheet data
|
||||
const response = await fetch(`/private/api/google/sheets/${event.sheet_id}/data`, {
|
||||
@@ -136,35 +138,64 @@
|
||||
|
||||
if (rows.length === 0) throw new Error('No data found in sheet');
|
||||
|
||||
// Extract participant data based on column mapping
|
||||
const names: string[] = [];
|
||||
const surnames: string[] = [];
|
||||
const emails: string[] = [];
|
||||
// --- Start of new logic to handle duplicates ---
|
||||
|
||||
// Skip header row (start from index 1)
|
||||
// First, extract all potential participants from the sheet
|
||||
const potentialParticipants = [];
|
||||
for (let i = 1; i < rows.length; i++) {
|
||||
const row = rows[i];
|
||||
if (row.length > 0) {
|
||||
const name = row[event.name_column - 1] || '';
|
||||
const surname = row[event.surname_column - 1] || '';
|
||||
const email = row[event.email_column - 1] || '';
|
||||
const email = (row[event.email_column - 1] || '').trim();
|
||||
const confirmation = row[event.confirmation_column - 1] || '';
|
||||
|
||||
// Only add if the row has meaningful data (not all empty) AND confirmation is TRUE
|
||||
const isConfirmed =
|
||||
confirmation.toString().toLowerCase() === 'true' ||
|
||||
confirmation.toString().toLowerCase() === 'yes' ||
|
||||
confirmation === '1' ||
|
||||
confirmation === 'x';
|
||||
|
||||
if ((name.trim() || surname.trim() || email.trim()) && isConfirmed) {
|
||||
names.push(name.trim());
|
||||
surnames.push(surname.trim());
|
||||
emails.push(email.trim());
|
||||
if ((name.trim() || surname.trim() || email) && isConfirmed) {
|
||||
potentialParticipants.push({ name: name.trim(), surname: surname.trim(), email });
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Create a map to count occurrences of each unique participant combination
|
||||
const participantCounts = new Map<string, number>();
|
||||
for (const p of potentialParticipants) {
|
||||
const key = `${p.name}|${p.surname}|${p.email}`.toLowerCase(); // Create a unique key
|
||||
participantCounts.set(key, (participantCounts.get(key) || 0) + 1);
|
||||
}
|
||||
|
||||
// Create final arrays, modifying duplicate surnames to be unique
|
||||
const names: string[] = [];
|
||||
const surnames: string[] = [];
|
||||
const emails: string[] = [];
|
||||
const processedParticipants = new Map<string, number>();
|
||||
|
||||
for (const p of potentialParticipants) {
|
||||
const key = `${p.name}|${p.surname}|${p.email}`.toLowerCase();
|
||||
let finalSurname = p.surname;
|
||||
|
||||
// If this participant is a duplicate
|
||||
if (participantCounts.get(key)! > 1) {
|
||||
const count = (processedParticipants.get(key) || 0) + 1;
|
||||
processedParticipants.set(key, count);
|
||||
|
||||
// If it's not the first occurrence, append a counter to the surname
|
||||
if (count > 1) {
|
||||
finalSurname = `${p.surname} (${count})`;
|
||||
}
|
||||
}
|
||||
|
||||
names.push(p.name);
|
||||
surnames.push(finalSurname);
|
||||
emails.push(p.email); // Keep the original email
|
||||
}
|
||||
// --- End of new logic ---
|
||||
|
||||
// Call database function to add participants
|
||||
const { error: syncError } = await data.supabase.rpc('participants_add_bulk', {
|
||||
p_event: eventId,
|
||||
@@ -177,16 +208,23 @@
|
||||
|
||||
// Reload participants
|
||||
await loadParticipants();
|
||||
|
||||
// Show success message with count of synced participants
|
||||
const previousCount = participants.length;
|
||||
const newCount = names.length;
|
||||
const addedCount = Math.max(0, participants.length - previousCount);
|
||||
|
||||
toast.success(
|
||||
`Successfully synced participants. ${newCount} entries processed, ${addedCount} new participants added.`,
|
||||
5000
|
||||
);
|
||||
|
||||
// Show success message with accurate count of changes
|
||||
const newCount = participants.length;
|
||||
const diff = newCount - previousCount;
|
||||
const processedCount = names.length;
|
||||
|
||||
let message = `Sync complete. ${processedCount} confirmed entries processed from the sheet.`;
|
||||
|
||||
if (diff > 0) {
|
||||
message += ` ${diff} new participants added.`;
|
||||
} else if (diff < 0) {
|
||||
message += ` ${-diff} participants removed.`;
|
||||
} else {
|
||||
message += ` No changes to the participant list.`;
|
||||
}
|
||||
|
||||
toast.success(message, 6000);
|
||||
} catch (err) {
|
||||
console.error('Error syncing participants:', err);
|
||||
toast.error(`Failed to sync participants: ${err instanceof Error ? err.message : 'Unknown error'}`);
|
||||
|
||||
@@ -1,87 +1,66 @@
|
||||
/// <reference lib="webworker" />
|
||||
/// <reference types="@sveltejs/kit" />
|
||||
import { build, files, version } from '$service-worker';
|
||||
|
||||
// Create a unique cache name for this deployment
|
||||
const CACHE = `cache-${version}`;
|
||||
declare const self: ServiceWorkerGlobalScope;
|
||||
|
||||
const CACHE = `cache-${version}`;
|
||||
const ASSETS = [
|
||||
...build, // the app itself
|
||||
...files // everything in `static`
|
||||
...build,
|
||||
...files
|
||||
];
|
||||
|
||||
self.addEventListener('install', (event) => {
|
||||
// Create a new cache and add all files to it
|
||||
async function addFilesToCache() {
|
||||
const cache = await caches.open(CACHE);
|
||||
await cache.addAll(ASSETS);
|
||||
}
|
||||
self.addEventListener('install', (event: ExtendableEvent) => {
|
||||
const addFilesToCache = async () => {
|
||||
const cache = await caches.open(CACHE);
|
||||
await cache.addAll(ASSETS);
|
||||
};
|
||||
|
||||
event.waitUntil(addFilesToCache());
|
||||
console.log(`[SW] Installing new service worker, cache name: ${CACHE}`);
|
||||
|
||||
event.waitUntil(addFilesToCache());
|
||||
self.skipWaiting();
|
||||
});
|
||||
|
||||
self.addEventListener('activate', (event) => {
|
||||
// Remove previous cached data from disk
|
||||
async function deleteOldCaches() {
|
||||
for (const key of await caches.keys()) {
|
||||
if (key !== CACHE) await caches.delete(key);
|
||||
}
|
||||
}
|
||||
self.addEventListener('activate', (event: ExtendableEvent) => {
|
||||
const deleteOldCaches = async () => {
|
||||
for (const key of await caches.keys()) {
|
||||
if (key !== CACHE) await caches.delete(key);
|
||||
console.log("[SW] Removing old service worker")
|
||||
}
|
||||
};
|
||||
|
||||
event.waitUntil(deleteOldCaches());
|
||||
event.waitUntil(deleteOldCaches());
|
||||
self.clients.claim();
|
||||
});
|
||||
|
||||
self.addEventListener('fetch', (event) => {
|
||||
// ignore POST requests etc
|
||||
if (event.request.method !== 'GET') return;
|
||||
self.addEventListener('fetch', (event: FetchEvent) => {
|
||||
if (event.request.method !== 'GET') return;
|
||||
|
||||
async function respond() {
|
||||
const url = new URL(event.request.url);
|
||||
|
||||
// Skip caching for auth routes
|
||||
if (url.pathname.startsWith('/auth/')) {
|
||||
return fetch(event.request);
|
||||
}
|
||||
// For navigation requests, always fetch from the network to ensure
|
||||
// server-side authentication checks are performed.
|
||||
if (event.request.mode === 'navigate') {
|
||||
event.respondWith(fetch(event.request));
|
||||
return;
|
||||
}
|
||||
|
||||
const cache = await caches.open(CACHE);
|
||||
// For other requests (e.g., static assets), use a cache-first strategy.
|
||||
const respond = async () => {
|
||||
const cache = await caches.open(CACHE);
|
||||
|
||||
// `build`/`files` can always be served from the cache
|
||||
if (ASSETS.includes(url.pathname)) {
|
||||
const response = await cache.match(url.pathname);
|
||||
const cachedResponse = await cache.match(event.request);
|
||||
if (cachedResponse) {
|
||||
return cachedResponse;
|
||||
}
|
||||
|
||||
if (response) {
|
||||
return response;
|
||||
}
|
||||
}
|
||||
try {
|
||||
return await fetch(event.request);
|
||||
} catch {
|
||||
// If the network fails, and it's not in the cache, it will fail,
|
||||
// which is the expected behavior for non-navigation requests.
|
||||
return new Response('Not found', { status: 404 });
|
||||
}
|
||||
};
|
||||
|
||||
// for everything else, try the network first, but
|
||||
// fall back to the cache if we're offline
|
||||
try {
|
||||
const response = await fetch(event.request);
|
||||
|
||||
// if we're offline, fetch can return a value that is not a Response
|
||||
// instead of throwing - and we can't pass this non-Response to respondWith
|
||||
if (!(response instanceof Response)) {
|
||||
throw new Error('invalid response from fetch');
|
||||
}
|
||||
|
||||
// Do not cache private pages
|
||||
if (response.status === 200 && !url.pathname.startsWith('/private')) {
|
||||
cache.put(event.request, response.clone());
|
||||
}
|
||||
|
||||
return response;
|
||||
} catch (err) {
|
||||
const response = await cache.match(event.request);
|
||||
|
||||
if (response) {
|
||||
return response;
|
||||
}
|
||||
|
||||
// if there's no cache, then just error out
|
||||
// as there is nothing we can do to respond to this request
|
||||
throw err;
|
||||
}
|
||||
}
|
||||
|
||||
event.respondWith(respond());
|
||||
});
|
||||
event.respondWith(respond());
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user