// This val creates a webhook endpoint to receive health data from an iOS app and insert it into a Supabase database. // We'll use the Supabase JavaScript client to interact with the database. /** @jsxImportSource https://esm.sh/react */ import React from "https://esm.sh/react"; import { renderToString } from "https://esm.sh/react-dom/server"; import { createClient } from 'https://esm.sh/@supabase/supabase-js@2'; // Initialize Supabase client const supabaseUrl = Deno.env.get('SUPABASE_PERSONAL_URL'); const supabaseKey = Deno.env.get('SUPABASE_PERSONAL_KEY'); if (!supabaseUrl || !supabaseKey) { throw new Error('Supabase URL and Key must be set as environment variables'); } const supabase = createClient(supabaseUrl, supabaseKey); export default async function server(request: Request): Promise { console.log(`Received ${request.method} request`); try { if (request.method === 'POST') { // Parse the JSON payload from the request body let payload; try { payload = await request.json(); } catch (error) { console.error('Error parsing JSON:', error); return new Response('Invalid JSON payload', { status: 400 }); } console.log('Received payload:', payload); // Process and insert the data let insertedCount = 0; let errors = []; if (payload.data && payload.data.metrics) { for (const metric of payload.data.metrics) { for (const dataPoint of metric.data) { const healthData = { date: new Date(dataPoint.date).toISOString(), metric_type: metric.name, data: { units: metric.units, value: dataPoint.qty }, source: dataPoint.source }; const { data, error } = await supabase .from('health_data') .insert(healthData); if (error) { console.error('Error inserting data:', JSON.stringify(error)); errors.push(error.message); } else { insertedCount++; } } } } else { // If the payload doesn't match the expected structure, insert it as-is const { data, error } = await supabase .from('health_data') .insert({ date: new Date().toISOString(), data: payload, metric_type: 'unknown', source: 'iOS App' }); if (error) { console.error('Error inserting data:', JSON.stringify(error)); errors.push(error.message); } else { insertedCount++; } } if (errors.length > 0) { return new Response(`Errors inserting data: ${errors.join(', ')}`, { status: 500 }); } console.log(`${insertedCount} data points inserted successfully`); return new Response(`${insertedCount} health data points inserted successfully`, { status: 200 }); } else if (request.method === 'GET') { // Handle GET requests (e.g., for testing) let latestUpdate = null; let errorMessage = null; const { data, error } = await supabase .from('health_data') .select('date') .order('date', { ascending: false }) .limit(1); if (error) { console.error('Error fetching latest data:', error); errorMessage = `Error fetching latest data: ${error.message}`; } else if (data && data.length > 0) { latestUpdate = new Date(data[0].date); } const App = () => ( Health Data Webhook

Health Data Webhook

This webhook is active. Send POST requests to submit data.

{latestUpdate ? (

Most recent health update: {latestUpdate.toLocaleString()}

) : (

No health updates found.

)} {errorMessage && (

Error: {errorMessage}

)}

View source: {import.meta.url.replace("esm.town", "val.town")}

); return new Response(renderToString(), { status: 200, headers: { "Content-Type": "text/html", }, }); } else { // Handle other HTTP methods return new Response('Method Not Allowed', { status: 405 }); } } catch (error) { console.error('Error processing request:', error.stack || error); return new Response('Error processing request', { status: 400 }); } }

healthwebhook

Versions

v0