外部連携設計——
App & OAuth

import express from 'express'; import { Client } from '@hubspot/api-client'; const app = express(); const CLIENT_ID = process.env.HUBSPOT_CLIENT_ID; const CLIENT_SECRET = process.env.HUBSPOT_CLIENT_SECRET; const REDIRECT_URI = process.env.HUBSPOT_REDIRECT_URI; const SCOPES = ['crm.objects.contacts.read', 'crm.objects.contacts.write', 'crm.objects.deals.read']; // Step 1: HubSpot の認可ページにリダイレクト app.get('/auth/hubspot', (req, res) => { const authUrl = new URL('https://app.hubspot.com/oauth/authorize'); authUrl.searchParams.set('client_id', CLIENT_ID); authUrl.searchParams.set('redirect_uri', REDIRECT_URI); authUrl.searchParams.set('scope', SCOPES.join(' ')); authUrl.searchParams.set('state', generateCsrfToken(req)); // CSRF 対策 res.redirect(authUrl.toString()); }); // Step 3 & 4: コールバック処理 app.get('/auth/hubspot/callback', async (req, res) => { const { code, state } = req.query; // CSRF 検証 if (!verifyCsrfToken(req, state)) { return res.status(403).send('Invalid state'); } // code → トークン交換 const tokenResponse = await fetch('https://api.hubapi.com/oauth/v1/token', { method: 'POST', headers: { 'Content-Type': 'application/x-www-form-urlencoded' }, body: new URLSearchParams({ grant_type: 'authorization_code', client_id: CLIENT_ID, client_secret: CLIENT_SECRET, redirect_uri: REDIRECT_URI, code, }), }); const tokens = await tokenResponse.json(); // { access_token, refresh_token, expires_in: 21600, hub_id, hub_domain } // Step 5: トークンを DB に保存 await saveTokens(tokens.hub_id, { accessToken: tokens.access_token, refreshToken: tokens.refresh_token, expiresAt: Date.now() + tokens.expires_in * 1000, hubDomain: tokens.hub_domain, }); res.redirect('/dashboard'); });

async function getValidAccessToken(portalId) { const stored = await db.getTokens(portalId); // 有効期限の5分前に更新 const needsRefresh = stored.expiresAt - Date.now() < 5 * 60 * 1000; if (!needsRefresh) return stored.accessToken; // リフレッシュトークンで新しいアクセストークンを取得 const res = await fetch('https://api.hubapi.com/oauth/v1/token', { method: 'POST', headers: { 'Content-Type': 'application/x-www-form-urlencoded' }, body: new URLSearchParams({ grant_type: 'refresh_token', client_id: CLIENT_ID, client_secret: CLIENT_SECRET, refresh_token: stored.refreshToken, }), }); const newTokens = await res.json(); // 更新されたトークンを DB に保存 await db.updateTokens(portalId, { accessToken: newTokens.access_token, expiresAt: Date.now() + newTokens.expires_in * 1000, }); return newTokens.access_token; } // 使用例：ポータル ID を指定して API クライアントを生成 async function getClientForPortal(portalId) { const accessToken = await getValidAccessToken(portalId); return new Client({ accessToken }); }

app.post('/webhook/hubspot', verifySignature, async (req, res) => { res.status(200).json({ received: true }); for (const event of req.body) { if (event.subscriptionType === 'app.uninstall') { const { portalId } = event; // トークンを削除 await db.deleteTokens(portalId); // そのポータルのユーザーデータを削除（GDPR 対応） await db.deletePortalData(portalId); console.log(`Portal ${portalId} uninstalled and data cleaned up`); } } });