ReactでサーバーサイドOura Ringデータ取得: Next.js & React Queryチュートリアル

// lib/session.js
import { getIronSession } from 'iron-session';

const sessionOptions = {
  password: process.env.APP_SECRET,
  cookieName: 'oura-session',
  cookieOptions: {
    secure: process.env.NODE_ENV === 'production',
    httpOnly: true,
  },
};

export function getSession(req, res) {
  return getIronSession(req, res, sessionOptions);
}

// app/api/auth/login/oura/route.js
import { NextResponse } from 'next/server';

export async function GET() {
  const authUrl = new URL('https://cloud.ouraring.com/oauth/authorize');
  authUrl.searchParams.set('client_id', process.env.NEXT_PUBLIC_OURA_CLIENT_ID);
  authUrl.searchParams.set('redirect_uri', `${process.env.NEXT_PUBLIC_APP_URL}/api/auth/callback/oura`);
  authUrl.searchParams.set('response_type', 'code');
  authUrl.searchParams.set('scope', 'daily'); // 日々の睡眠、アクティビティ、読みどきデータをリクエスト

  return NextResponse.redirect(authUrl.toString());
}

// app/api/auth/callback/oura/route.js
import { NextResponse } from 'next/server';
import { getIronSession } from 'iron-session';

export async function GET(request) {
  const { searchParams } = new URL(request.url);
  const code = searchParams.get('code');

  if (!code) {
    // エラーを処理：コードが提供されなかった場合
    return NextResponse.redirect(new URL('/?error=oauth_error', request.url));
  }

  // コードをアクセストークンと交換
  const tokenResponse = await fetch('https://api.ouraring.com/oauth/token', {
    method: 'POST',
    headers: {
      'Content-Type': 'application/x-www-form-urlencoded',
    },
    body: new URLSearchParams({
      grant_type: 'authorization_code',
      code: code,
      redirect_uri: `${process.env.NEXT_PUBLIC_APP_URL}/api/auth/callback/oura`,
      client_id: process.env.OURA_CLIENT_ID,
      client_secret: process.env.OURA_CLIENT_SECRET,
    }),
  });

  if (!tokenResponse.ok) {
    // エラーを処理：トークンの取得に失敗した場合
    console.error('Failed to exchange code for token:', await tokenResponse.text());
    return NextResponse.redirect(new URL('/?error=token_exchange_failed', request.url));
  }

  const tokenData = await tokenResponse.json();

  // トークンを暗号化してcookieに保存
  const session = await getIronSession(request.cookies, new NextResponse().cookies, {
      password: process.env.APP_SECRET,
      cookieName: 'oura-session'
  });

  session.accessToken = tokenData.access_token;
  await session.save();

  // ダッシュボードページにリダイレクト
  return NextResponse.redirect(new URL('/dashboard', request.url));
}

// app/api/oura/daily-summary/route.js
import { NextResponse } from 'next/server';
import { getIronSession } from 'iron-session';
import { cookies } from 'next/headers';

export async function GET() {
  const session = await getIronSession(cookies(), {
    password: process.env.APP_SECRET,
    cookieName: 'oura-session',
  });

  if (!session.accessToken) {
    return NextResponse.json({ error: 'Not authenticated' }, { status: 401 });
  }

  // YYYY-MM-DD形式で昨日の日付を取得
  const yesterday = new Date();
  yesterday.setDate(yesterday.getDate() - 1);
  const dateStr = yesterday.toISOString().split('T');

  const ouraResponse = await fetch(
    `https://api.ouraring.com/v2/usercollection/daily_activity?start_date=${dateStr}&end_date=${dateStr}`,
    {
      headers: {
        'Authorization': `Bearer ${session.accessToken}`,
      },
    }
  );

  if (!ouraResponse.ok) {
    console.error('Oura API Error:', await ouraResponse.text());
    return NextResponse.json({ error: 'Failed to fetch data from Oura' }, { status: ouraResponse.status });
  }

  const ouraData = await ouraResponse.json();
  return NextResponse.json(ouraData);
}

// app/providers.js
'use client';

import { QueryClient, QueryClientProvider } from '@tanstack/react-query';
import { ReactQueryDevtools } from '@tanstack/react-query-devtools';
import { useState } from 'react';

export default function Providers({ children }) {
  const [queryClient] = useState(() => new QueryClient());

  return (
    <QueryClientProvider client={queryClient}>
      {children}
      <ReactQueryDevtools initialIsOpen={false} />
    </QueryClientProvider>
  );
}

// app/layout.js
import Providers from './providers';

export default function RootLayout({ children }) {
  return (
    <html lang="en">
      <body>
        <Providers>{children}</Providers>
      </body>
    </html>
  );
}

// app/dashboard/page.js
'use client';
import { useQuery } from '@tanstack/react-query';

const fetchOuraData = async () => {
  const res = await fetch('/api/oura/daily-summary');
  if (!res.ok) {
    throw new Error('Network response was not ok');
  }
  return res.json();
};

export default function Dashboard() {
  const { data, isLoading, isError, error } = useQuery({
    queryKey: ['ouraDailySummary'],
    queryFn: fetchOuraData,
  });

  if (isLoading) {
    return <span>Loading...</span>;
  }

  if (isError) {
    return <span>Error: {error.message}</span>;
  }

  // APIが期待される形式でデータを返すと想定
  const summary = data?.data?.[0];

  if (!summary) {
    return <span>昨日のデータがありません。</span>
  }

  return (
    <div>
      <h1>{summary.day}のOuraデイリースマリー</h1>
      <h2>読みどきスコア: {summary.score}</h2>
      <ul>
        <li>アクティビティスコア: {summary.contributors?.activity_balance}</li>
        <li>睡眠スコア: {summary.contributors?.recovery_index}</li>
      </ul>
    </div>
  );
}

// app/dashboard/page.js (App RouterでのSSR対応版)
import { QueryClient, dehydrate } from '@tanstack/react-query';
import { getIronSession } from 'iron-session';
import { cookies } from 'next/headers';
import Hydrate from '@/components/Hydrate'; // シンプルな水和コンポーネント
import DashboardClient from './DashboardClient'; // クライアントコンポーネント部分

// これはデータ取得関数で、サーバーから呼び出せる
const fetchOuraData = async (accessToken) => {
    if (!accessToken) throw new Error('Not Authenticated');

    const yesterday = new Date();
    yesterday.setDate(yesterday.getDate() - 1);
    const dateStr = yesterday.toISOString().split('T')[0];

    const ouraResponse = await fetch(
        `https://api.ouraring.com/v2/usercollection/daily_activity?start_date=${dateStr}&end_date=${dateStr}`,
        {
            headers: { 'Authorization': `Bearer ${accessToken}` },
        }
    );
    if (!ouraResponse.ok) throw new Error('Failed to fetch from Oura API');
    return ouraResponse.json();
};

export default async function DashboardPage() {
    const queryClient = new QueryClient();

    const session = await getIronSession(cookies(), {
        password: process.env.APP_SECRET,
        cookieName: 'oura-session',
    });
    
    // サーバーでクエリをプリフェッチ
    await queryClient.prefetchQuery({
        queryKey: ['ouraDailySummary'],
        queryFn: () => fetchOuraData(session.accessToken),
    });
    
    const dehydratedState = dehydrate(queryClient);

    return (
        <Hydrate state={dehydratedState}>
            <DashboardClient />
        </Hydrate>
    );
}

// components/Hydrate.js
'use client';
import { Hydrate as RQHydrate } from '@tanstack/react-query';

function Hydrate(props) {
  return <RQHydrate {...props} />;
}

export default Hydrate;


// app/dashboard/DashboardClient.js (以前のページロジックを含む)
'use client';
import { useQuery } from '@tanstack/react-query';

// バックグラウンド更新用のクライアントサイドフェッチャーが必要にりましたが、初期読み込み時には呼び出されません
const clientFetchOuraData = async () => {
    const res = await fetch('/api/oura/daily-summary'); // プロキシを使用
    if (!res.ok) {
      throw new Error('Network response was not ok');
    }
    return res.json();
};

export default function DashboardClient() {
  // このフックはクライアントでキャッシュ内のデータを即座に見つけます！
  const { data, isLoading, isError, error } = useQuery({
    queryKey: ['ouraDailySummary'],
    queryFn: clientFetchOuraData, 
  });

  // このUIロジックは同じまま
  if (isLoading) return <span>Loading...</span>; // 最初の読み込みではこれは表示されません
  if (isError) return <span>Error: {error.message}</span>;
  
  const summary = data?.data?.[0];

  if (!summary) return <span>昨日のデータがありません。</span>;

  return (
    <div>
      <h1>{summary.day}のOuraデイリースマリー</h1>
      <h2>読みどきスコア: {summary.score}</h2>
      <ul>
        <li>アクティビティスコア: {summary.contributors?.activity_balance}</li>
        <li>睡眠スコア: {summary.contributors?.recovery_index}</li>
      </ul>
    </div>
  );
}