Next.js BFF：マルチプロバイダーウェアラブルデータアグリゲーター

# .env.local
OURA_CLIENT_ID=your_oura_client_id
OURA_CLIENT_SECRET=your_oura_client_secret
GARMIN_CLIENT_ID=your_garmin_client_id
GARMIN_CLIENT_SECRET=your_garmin_client_secret

# セッションCookieの暗号化用
NEXTAUTH_SECRET=generate_a_strong_secret_key

DATABASE_URL=your_database_connection_string

// schema.prisma
model Account {
  id                String  @id @default(cuid())
  userId            String
  type              String
  provider          String
  providerAccountId String
  refresh_token     String?
  access_token      String?
  expires_at        Int?
  token_type        String?
  scope             String?
  id_token          String?
  session_state     String?

  user User @relation(fields: [userId], references: [id], onDelete: Cascade)

  @@unique([provider, providerAccountId])
}

model User {
  id            String    @id @default(cuid())
  name          String?
  email         String?   @unique
  accounts      Account[]
}

// pages/api/auth/[...nextauth].js
import NextAuth from 'next-auth';
import OuraProvider from 'next-auth/providers/oura'; // カスタムまたはコミュニティプロバイダーを想定
import GarminProvider from 'next-auth/providers/garmin'; // カスタムまたはコミュニティプロバイダーを想定

// 注：公式プロバイダーが存在しない場合、カスタムプロバイダー設定を作成する必要がある場合があります。
// これは概念的な例です。

export default NextAuth({
  providers: [
    // Oura プロバイダー設定
    {
      id: "oura",
      name: "Oura",
      type: "oauth",
      version: "2.0",
      authorization: {
        url: "https://cloud.ouraring.com/oauth/authorize",
        params: { scope: "personal sleep" }, // 必要なスコープをリクエスト
      },
      token: "https://api.ouraring.com/oauth/token",
      userinfo: "https://api.ouraring.com/v2/usercollection/personal_info",
      clientId: process.env.OURA_CLIENT_ID,
      clientSecret: process.env.OURA_CLIENT_SECRET,
      profile(profile) {
        // プロフィールデータをユーザーオブジェクトにマッピング
        return {
          id: profile.id,
          email: profile.email,
        };
      },
    },
    // Garmin プロバイダーは同様の構造に従います
    // ...
  ],
  // ... 他のNextAuth設定（データベースアダプターなど）
});

// components/ConnectButton.jsx
import { signIn } from 'next-auth/react';

const ConnectButton = ({ providerId, children }) => {
  return (
    <button onClick={() => signIn(providerId)}>
      {children}
    </button>
  );
};

// ページでの使用
<ConnectButton providerId="oura">Connect Oura</ConnectButton>

// types/health.ts
export interface UnifiedSleepRecord {
  source: 'garmin' | 'oura';
  date: string; // YYYY-MM-DD
  totalSleepSeconds: number;
  deepSleepSeconds: number;
  lightSleepSeconds: number;
  remSleepSeconds: number;
  awakeSeconds: number;
  sleepScore?: number;
}

// lib/normalization.js

/**

* Oura V2睡眠データを正規化します。
* @param {Object} ouraData - Oura APIの睡眠エンドポイントからの生データオブジェクト。
* @returns {UnifiedSleepRecord}
*/
export function normalizeOuraSleep(ouraData) {
  return {
    source: 'oura',
    date: ouraData.day,
    totalSleepSeconds: ouraData.deep + ouraData.rem + ouraData.light,
    deepSleepSeconds: ouraData.deep,
    lightSleepSeconds: ouraData.light,
    remSleepSeconds: ouraData.rem,
    awakeSeconds: ouraData.awake,
    sleepScore: ouraData.score,
  };
}

/**
* Garmin Health API睡眠データを正規化します。
* @param {Object} garminData - Garmin APIからの生データオブジェクト。
* @returns {UnifiedSleepRecord}
*/
export function normalizeGarminSleep(garminData) {
  return {
    source: 'garmin',
    date: garminData.calendarDate,
    totalSleepSeconds: garminData.deepSleepDurationInSeconds + garminData.lightSleepDurationInSeconds + garminData.remSleepInSeconds,
    deepSleepSeconds: garminData.deepSleepDurationInSeconds,
    lightSleepSeconds: garminData.lightSleepDurationInSeconds,
    remSleepSeconds: garminData.remSleepInSeconds,
    awakeSeconds: garminData.awakeDurationInSeconds,
    sleepScore: garminData.sleepScores?.overall?.value, // パスは異なる場合があります
  };
}

// pages/api/webhooks/[provider].js
import { buffer } from 'micro';
import crypto from 'crypto';

// これは署名検証に不可欠です
export const config = {
  api: {
    bodyParser: false,
  },
};

const handler = async (req, res) => {
  if (req.method !== 'POST') {
    res.setHeader('Allow', 'POST');
    return res.status(405).end('Method Not Allowed');
  }

  const { provider } = req.query;
  const rawBody = await buffer(req);

  try {
    if (provider === 'oura') {
      const signature = req.headers['x-oura-signature'];
      const secret = process.env.OURA_WEBHOOK_SECRET; // Ouraダッシュボードで構成するシークレット
      
      const isValid = verifyOuraSignature(signature, rawBody, secret);
      if (!isValid) {
        return res.status(401).json({ message: 'Invalid signature' });
      }
      
      console.log('Oura webhook verified. Processing...');
      // TODO: ウェブフックペイロードを処理し、新しいデータを取得して、正規化してDBに保存します。

    } else if (provider === 'garmin') {
      // Garmin ウェブフック検証ロジックはここに記述します。
      // 通常、同様のHMAC-SHA256署名チェックが必要です。
      console.log('Garmin webhook received. Processing...');
    }

    res.status(200).json({ message: 'Webhook received' });
  } catch (error) {
    res.status(500).json({ message: `Webhook error: ${error.message}` });
  }
};

/**
* OuraからのHMAC署名を検証します。
* @param {string} signatureHeader - 'x-oura-signature'ヘッダーの値。
* @param {Buffer} body - 生のリクエストボディ。
* @param {string} secret - Ouraアプリケーションのクライアントシークレット。
* @returns {boolean}
*/
function verifyOuraSignature(signatureHeader, body, secret) {
  if (!signatureHeader) return false;
  
  const hmac = crypto.createHmac('sha256', secret);
  const digest = Buffer.from(hmac.update(body).digest('hex'), 'utf8');
  const signature = Buffer.from(signatureHeader, 'utf8');

  return crypto.timingSafeEqual(digest, signature);
}

export default handler;

// pages/api/dashboard/sleep.js
import { getSession } from 'next-auth/react';
import { PrismaClient } from '@prisma/client';

const prisma = new PrismaClient();

export default async function handler(req, res) {
  const session = await getSession({ req });

  if (!session) {
    return res.status(401).json({ error: 'Unauthorized' });
  }

  // ここで、ログインしているユーザーのために保存した正規化された睡眠データを取得します
  const userSleepData = await prisma.unifiedSleepRecord.findMany({
    where: {
      userId: session.user.id,
    },
    orderBy: {
      date: 'desc',
    },
    take: 30, // 過去30日分を取得
  });

  res.status(200).json(userSleepData);
}