google sheet idempotency

src/lib/utils/googleSheets.ts

@@ -1,7 +1,7 @@
 import { google } from "googleapis";
 import { GOOGLE_SHEETS_KEY, GOOGLE_SHEETS_EMAIL, GOOGLE_SHEETS_ID } from '$env/static/private';
 
-export async function saveMemberToGoogleSheet(name: string, email: string, membershipType: string) {
+export async function saveMemberToGoogleSheet(id: string, name: string, email: string, membershipType: string) {
  let jwtClient = new google.auth.JWT(
  GOOGLE_SHEETS_EMAIL,
  null,
@@ -22,24 +22,48 @@ export async function saveMemberToGoogleSheet(name: string, email: string, membe
  let sheets = google.sheets('v4');
 
  let data = [
- [name, email, membershipType, new Date()]
+ [id, name, email, membershipType, new Date()]
  ];
 
  const body = {
  values: data,
  };
 
+ // Check if data already exists
+ const range = "raw_data!A:E";
+ const existingData = await sheets.spreadsheets.values.get({
+ auth: jwtClient,
+ spreadsheetId: GOOGLE_SHEETS_ID,
+ range,
+ });
+
+ if (existingData) {
+ const existingValues = existingData.data.values;
+
+ // Check if data already exists in the spreadsheet based on the ID field
+ const exists = existingValues.some((row) => {
+ const [existingId] = row;
+ return existingId === id;
+ });
+
+ // Skip append if data already exists
+ if (exists) {
+ console.log("Data already exists in spreadsheet");
+ return;
+ }
+ }
+
  sheets.spreadsheets.values.append({
  auth: jwtClient,
  spreadsheetId: GOOGLE_SHEETS_ID,
- range: "raw_data!A2:D2",
+ range: "raw_data!A2:E2",
  valueInputOption: "RAW",
  resource: body
  }, function (err, response) {
  if (err) {
  console.log('The API returned an error: ' + err);
  } else {
- console.log(response);
+ console.log('Data saved to google sheet: ' + data);
  }
  });
 

src/routes/membership/+page.server.js

@@ -1,24 +1,20 @@
 /** @type {import('./$types').Actions} */
 import { redirect } from '@sveltejs/kit';
-import { ENCRYPTION_KEY, INITIALIZATION_VECTOR } from '$env/static/private';
-
 
-import { saveMemberToGoogleSheet } from "$lib/utils/googleSheets";
+// @ts-ignore
+import { ENCRYPTION_KEY, INITIALIZATION_VECTOR } from '$env/static/private';
 
 // @ts-ignore
 const prices = { year: 330, year_reduced: 220, semester: 215, semester_reduced: 150 };
 
 
-
-
-
-
 async function encryptFormData(formData) {
  const name = formData.get("name").toString();
  const email = formData.get("email").toString();
  const membershipType = formData.get("membershipType").toString();
+ const id = formData.get("id").toString();
 
- const json = JSON.stringify({ name, email, membershipType });
+ const json = JSON.stringify({ id, name, email, membershipType });
 
  const encoder = new TextEncoder();
  const encryptionKey = encoder.encode(ENCRYPTION_KEY);
@@ -39,6 +35,7 @@ export const actions = {
  payWithVipps: async (event) => {
  console.log("paying with vipps");
  const formData = await event.request.formData();
+ formData.append("id", crypto.randomUUID());
  const encryptedFormData = await encryptFormData(formData);
 
 

src/routes/membership/registrationComplete/+page.server.ts

@@ -1,5 +1,6 @@
 /** @type {import('./$types').PageLoad} */
 import { ENCRYPTION_KEY, INITIALIZATION_VECTOR } from '$env/static/private';
+import { saveMemberToGoogleSheet } from '$lib/utils/googleSheets';
 
 async function decryptFormData(data) {
  const encoder = new TextEncoder();
@@ -15,8 +16,9 @@ async function decryptFormData(data) {
 
 export async function load({ url }) {
  const data: string = url.searchParams.get('data');
-
  const decryptedJson = await decryptFormData(data);
 
- console.log(decryptedJson)
+ const { id, name, email, membershipType } = decryptedJson;
+
+ await saveMemberToGoogleSheet(id, name, email, membershipType);
 }