Data Analytics

const express = require('express');
const axios = require('axios');
const AWS = require('aws-sdk');

const app = express();
app.use(express.json());

// Configure AWS SDK
AWS.config.update({ region: process.env.AWS_REGION });
const s3 = new AWS.S3();
const BUCKET = process.env.S3_BUCKET_NAME;

app.post('/webhooks', async (req, res) => {
	// Retrieve the verification ID from the request body
	const verificationId = req.body['verificationId'];

	// Generate an access token
	const createTokenResponse = await axios.post(
		'https://api.soharhealth.com/oauth/token',
		{
			client_id: process.env.SOHAR_CLIENT_ID,
			client_secret: process.env.SOHAR_CLIENT_SECRET
		}
	);

	const accessToken = createTokenResponse.data.access_token;

	// Retrieve details of the completed verification
	const getVerificationResponse = await axios.get(
		`https://api.soharhealth.com/v2/verifications/${verificationId}`,
		{
			headers: {
				'Authorization': `Bearer ${accessToken}`
			}
		}
	);

	const verificationData = getVerificationResponse.data;

	// Save to Amazon S3
	const timestamp = new Date().toISOString();
	const folder = timestamp.split('T')[0].replace(/-/g, '/'); // "2025/06/01"
	const key = `sohar-data/${folder}/${verificationId}.json`;

	await s3.putObject({
	  Bucket: BUCKET,
	  Key: key,
	  Body: JSON.stringify(verificationData),
	  ContentType: 'application/json',
	}).promise();

	console.log(`Saved JSON to S3: ${key}`);
	res.status(200).send({ success: true });
});

app.listen(3000, () => console.log(`Listening on port 3000`));