Omi MCP Server

Instructions

Implementation Reference

• src/index.ts:248-291 (handler)

  Handler function that constructs a POST request to the Omi API to create a new conversation with provided text and metadata.

  async ({ text, user_id, text_source, started_at, finished_at, language, geolocation, text_source_spec }) => {
  	try {
  		const url = `https://api.omi.me/v2/integrations/${APP_ID}/user/conversations?uid=${user_id}`;
  
  		// Construct the body with required parameters
  		const body: Record<string, any> = {
  			text,
  			text_source,
  			language,
  		};
  
  		// Add optional parameters only if they are defined
  		if (started_at) body.started_at = started_at;
  		if (finished_at) body.finished_at = finished_at;
  		if (geolocation) body.geolocation = geolocation;
  		if (text_source_spec) body.text_source_spec = text_source_spec;
  
  		log(`Creating conversation with URL: ${url}`);
  		log(`Request body: ${JSON.stringify(body)}`);
  
  		const response = await fetch(url, {
  			method: 'POST',
  			headers: {
  				Authorization: `Bearer ${API_KEY}`,
  				'Content-Type': 'application/json',
  			},
  			body: JSON.stringify(body),
  		});
  
  		log(`Response status: ${response.status}`);
  
  		if (!response.ok) {
  			const errorText = await response.text();
  			throw new Error(`Failed to create conversation: ${response.status} ${response.statusText} - ${errorText}`);
  		}
  
  		return {
  			content: [{ type: 'text', text: '{}' }],
  		};
  	} catch (error) {
  		log(`Error creating conversation: ${error}`);
  		throw new Error(`Failed to create conversation: ${error instanceof Error ? error.message : String(error)}`);
  	}
  }

• src/index.ts:231-247 (schema)

  Zod input schema defining parameters for creating an Omi conversation, including text, user_id, text_source, optional timestamps, language, geolocation, and text_source_spec.

  	text: z.string().describe('The full text content of the conversation'),
  	user_id: z.string().describe('The user ID to create the conversation for'),
  	text_source: z
  		.enum(['audio_transcript', 'message', 'other_text'])
  		.describe('Source of the text content. Required. Options: "audio_transcript", "message", "other_text".'),
  	started_at: z.string().optional().describe('When the conversation/event started in ISO 8601 format. Optional.'),
  	finished_at: z.string().optional().describe('When the conversation/event ended in ISO 8601 format. Optional.'),
  	language: z.string().default('en').describe('Language code (e.g., "en" for English). Optional, defaults to "en".'),
  	geolocation: z
  		.object({
  			latitude: z.number().describe('Latitude coordinate. Required when geolocation is provided.'),
  			longitude: z.number().describe('Longitude coordinate. Required when geolocation is provided.'),
  		})
  		.optional()
  		.describe('Location data for the conversation. Optional object containing latitude and longitude.'),
  	text_source_spec: z.string().optional().describe('Additional specification about the source. Optional.'),
  },

• src/index.ts:227-292 (registration)

  Registration of the 'create_omi_conversation' tool on the MCP server using server.tool(), including description, input schema, and inline handler.

  server.tool(
  	'create_omi_conversation',
  	'Creates a new Omi conversation with text content and metadata',
  	{
  		text: z.string().describe('The full text content of the conversation'),
  		user_id: z.string().describe('The user ID to create the conversation for'),
  		text_source: z
  			.enum(['audio_transcript', 'message', 'other_text'])
  			.describe('Source of the text content. Required. Options: "audio_transcript", "message", "other_text".'),
  		started_at: z.string().optional().describe('When the conversation/event started in ISO 8601 format. Optional.'),
  		finished_at: z.string().optional().describe('When the conversation/event ended in ISO 8601 format. Optional.'),
  		language: z.string().default('en').describe('Language code (e.g., "en" for English). Optional, defaults to "en".'),
  		geolocation: z
  			.object({
  				latitude: z.number().describe('Latitude coordinate. Required when geolocation is provided.'),
  				longitude: z.number().describe('Longitude coordinate. Required when geolocation is provided.'),
  			})
  			.optional()
  			.describe('Location data for the conversation. Optional object containing latitude and longitude.'),
  		text_source_spec: z.string().optional().describe('Additional specification about the source. Optional.'),
  	},
  	async ({ text, user_id, text_source, started_at, finished_at, language, geolocation, text_source_spec }) => {
  		try {
  			const url = `https://api.omi.me/v2/integrations/${APP_ID}/user/conversations?uid=${user_id}`;
  
  			// Construct the body with required parameters
  			const body: Record<string, any> = {
  				text,
  				text_source,
  				language,
  			};
  
  			// Add optional parameters only if they are defined
  			if (started_at) body.started_at = started_at;
  			if (finished_at) body.finished_at = finished_at;
  			if (geolocation) body.geolocation = geolocation;
  			if (text_source_spec) body.text_source_spec = text_source_spec;
  
  			log(`Creating conversation with URL: ${url}`);
  			log(`Request body: ${JSON.stringify(body)}`);
  
  			const response = await fetch(url, {
  				method: 'POST',
  				headers: {
  					Authorization: `Bearer ${API_KEY}`,
  					'Content-Type': 'application/json',
  				},
  				body: JSON.stringify(body),
  			});
  
  			log(`Response status: ${response.status}`);
  
  			if (!response.ok) {
  				const errorText = await response.text();
  				throw new Error(`Failed to create conversation: ${response.status} ${response.statusText} - ${errorText}`);
  			}
  
  			return {
  				content: [{ type: 'text', text: '{}' }],
  			};
  		} catch (error) {
  			log(`Error creating conversation: ${error}`);
  			throw new Error(`Failed to create conversation: ${error instanceof Error ? error.message : String(error)}`);
  		}
  	}
  );