Oura MCP Server
by monuit
client.ts•8.77 kB
import axios, { AxiosInstance, AxiosError } from 'axios';
import { getValidAccessToken } from '../oauth/handler.js';
import { logger } from '../utils/logger.js';
import {
OuraApiResponse,
OuraPersonalInfoResponse,
OuraDailySleepResponse,
OuraDailyActivityResponse,
OuraDailyReadinessResponse,
OuraHeartRateResponse,
OuraWorkoutResponse,
OuraSleepResponse,
OuraTagResponse,
OuraRingConfigurationResponse,
} from './types.js';
const OURA_API_BASE_URL = 'https://api.ouraring.com/v2';
// Rate limit tracking
interface RateLimitInfo {
limit: number;
remaining: number;
reset: number;
}
let rateLimitInfo: RateLimitInfo | null = null;
/**
* Creates an authenticated Oura API client
*/
async function createClient(): Promise<AxiosInstance> {
const accessToken = await getValidAccessToken();
const client = axios.create({
baseURL: OURA_API_BASE_URL,
headers: {
Authorization: `Bearer ${accessToken}`,
'Content-Type': 'application/json',
},
timeout: 30000,
});
// Add response interceptor to track rate limits
client.interceptors.response.use(
(response) => {
const limit = response.headers['x-ratelimit-limit'];
const remaining = response.headers['x-ratelimit-remaining'];
const reset = response.headers['x-ratelimit-reset'];
if (limit && remaining && reset) {
rateLimitInfo = {
limit: parseInt(limit, 10),
remaining: parseInt(remaining, 10),
reset: parseInt(reset, 10),
};
if (rateLimitInfo.remaining < 100) {
console.warn(`[OuraClient] Rate limit warning: ${rateLimitInfo.remaining}/${rateLimitInfo.limit} remaining`);
}
}
return response;
},
(error: AxiosError) => {
if (error.response?.status === 429) {
logger.error('Rate limit exceeded');
throw new Error('Rate limit exceeded. Please try again later.');
}
throw error;
}
);
return client;
}
/**
* Gets the current rate limit information
*/
export function getRateLimitInfo(): RateLimitInfo | null {
return rateLimitInfo;
}
/**
* Fetches personal information
*/
export async function getPersonalInfo(): Promise<OuraPersonalInfoResponse> {
const client = await createClient();
try {
const response = await client.get<OuraPersonalInfoResponse>('/usercollection/personal_info');
return response.data;
} catch (error) {
logger.error('Failed to fetch personal info:', error);
throw handleApiError(error);
}
}
/**
* Fetches daily sleep data
*/
export async function getDailySleep(
startDate: string,
endDate?: string
): Promise<OuraDailySleepResponse[]> {
const client = await createClient();
try {
const params: Record<string, string> = { start_date: startDate };
if (endDate) {
params.end_date = endDate;
}
const response = await client.get<OuraApiResponse<OuraDailySleepResponse>>('/usercollection/daily_sleep', {
params,
});
return response.data.data;
} catch (error) {
logger.error('Failed to fetch daily sleep:', error);
throw handleApiError(error);
}
}
/**
* Fetches daily activity data
*/
export async function getDailyActivity(
startDate: string,
endDate?: string
): Promise<OuraDailyActivityResponse[]> {
const client = await createClient();
try {
const params: Record<string, string> = { start_date: startDate };
if (endDate) {
params.end_date = endDate;
}
const response = await client.get<OuraApiResponse<OuraDailyActivityResponse>>('/usercollection/daily_activity', {
params,
});
return response.data.data;
} catch (error) {
logger.error('Failed to fetch daily activity:', error);
throw handleApiError(error);
}
}
/**
* Fetches daily readiness data
*/
export async function getDailyReadiness(
startDate: string,
endDate?: string
): Promise<OuraDailyReadinessResponse[]> {
const client = await createClient();
try {
const params: Record<string, string> = { start_date: startDate };
if (endDate) {
params.end_date = endDate;
}
const response = await client.get<OuraApiResponse<OuraDailyReadinessResponse>>('/usercollection/daily_readiness', {
params,
});
return response.data.data;
} catch (error) {
logger.error('Failed to fetch daily readiness:', error);
throw handleApiError(error);
}
}
/**
* Fetches heart rate data
*/
export async function getHeartRate(
startDatetime: string,
endDatetime?: string
): Promise<OuraHeartRateResponse[]> {
const client = await createClient();
try {
const params: Record<string, string> = { start_datetime: startDatetime };
if (endDatetime) {
params.end_datetime = endDatetime;
}
const response = await client.get<OuraApiResponse<OuraHeartRateResponse>>('/usercollection/heartrate', {
params,
});
return response.data.data;
} catch (error) {
logger.error('Failed to fetch heart rate:', error);
throw handleApiError(error);
}
}
/**
* Fetches workout data
*/
export async function getWorkouts(
startDate: string,
endDate?: string
): Promise<OuraWorkoutResponse[]> {
const client = await createClient();
try {
const params: Record<string, string> = { start_date: startDate };
if (endDate) {
params.end_date = endDate;
}
const response = await client.get<OuraApiResponse<OuraWorkoutResponse>>('/usercollection/workout', {
params,
});
return response.data.data;
} catch (error) {
logger.error('Failed to fetch workouts:', error);
throw handleApiError(error);
}
}
/**
* Fetches sleep period data (detailed)
*/
export async function getSleepPeriods(
startDate: string,
endDate?: string
): Promise<OuraSleepResponse[]> {
const client = await createClient();
try {
const params: Record<string, string> = { start_date: startDate };
if (endDate) {
params.end_date = endDate;
}
const response = await client.get<OuraApiResponse<OuraSleepResponse>>('/usercollection/sleep', {
params,
});
return response.data.data;
} catch (error) {
logger.error('Failed to fetch sleep periods:', error);
throw handleApiError(error);
}
}
/**
* Fetches tags data
*/
export async function getTags(
startDate: string,
endDate?: string
): Promise<OuraTagResponse[]> {
const client = await createClient();
try {
const params: Record<string, string> = { start_date: startDate };
if (endDate) {
params.end_date = endDate;
}
const response = await client.get<OuraApiResponse<OuraTagResponse>>('/usercollection/tag', {
params,
});
return response.data.data;
} catch (error) {
logger.error('Failed to fetch tags:', error);
throw handleApiError(error);
}
}
/**
* Fetches ring configuration
*/
export async function getRingConfiguration(): Promise<OuraRingConfigurationResponse[]> {
const client = await createClient();
try {
const response = await client.get<OuraApiResponse<OuraRingConfigurationResponse>>('/usercollection/ring_configuration');
return response.data.data;
} catch (error) {
logger.error('Failed to fetch ring configuration:', error);
throw handleApiError(error);
}
}
/**
* Handles API errors and converts them to user-friendly messages
*/
function handleApiError(error: unknown): Error {
if (axios.isAxiosError(error)) {
const axiosError = error as AxiosError<{ error?: string; message?: string }>;
if (axiosError.response) {
const status = axiosError.response.status;
const errorMessage = axiosError.response.data?.error || axiosError.response.data?.message;
switch (status) {
case 401:
return new Error('Authentication failed. Please re-authenticate with Oura.');
case 403:
return new Error('Access forbidden. Check your OAuth scopes.');
case 404:
return new Error('Requested data not found.');
case 429:
return new Error('Rate limit exceeded. Please try again later.');
case 500:
case 502:
case 503:
return new Error('Oura API is temporarily unavailable. Please try again later.');
default:
return new Error(errorMessage || `Oura API error: ${status}`);
}
}
if (axiosError.code === 'ECONNABORTED') {
return new Error('Request timeout. Please try again.');
}
if (axiosError.code === 'ENOTFOUND' || axiosError.code === 'ECONNREFUSED') {
return new Error('Unable to connect to Oura API. Check your internet connection.');
}
return new Error(`Network error: ${axiosError.message}`);
}
return error instanceof Error ? error : new Error('Unknown error occurred');
}
Latest Blog Posts
- MCP Moves to the Linux Foundation: Neutral Stewardship for Agentic InfrastructureBy Om-Shree-0709 on .mcpanthropicLinux Foundation
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/monuit/oura-mcp-server'
If you have feedback or need assistance with the MCP directory API, please join our Discord server