feat: adds posthog and railway integrations

Author: jess-daniel

index.ts

@@ -61,6 +61,7 @@ import { intercomIntegration } from './src/integrations/intercom.js';
 import { hubspotIntegration } from './src/integrations/hubspot.js';
 import { youtubeIntegration } from './src/integrations/youtube.js';
 import { cursorIntegration } from './src/integrations/cursor.js';
+import { posthogIntegration } from './src/integrations/posthog.js';
 
 /**
  * Default MCP Client with all integrations pre-configured
@@ -128,9 +129,9 @@ export const client = createMCPClient({
     hubspotIntegration(),
     youtubeIntegration(),
     cursorIntegration(),
+    posthogIntegration(),
   ],
   // Fetch configured integrations from server since default client has all integrations
   // but only some may be configured on the server with OAuth credentials
   useServerConfig: true,
 });
-

package.json

@@ -1,6 +1,6 @@
 {
   "name": "integrate-sdk",
-  "version": "0.9.28",
+  "version": "0.9.29",
   "description": "Type-safe 3rd party integration SDK for the Integrate MCP server",
   "type": "module",
   "main": "./dist/index.js",

src/adapters/base-handler.ts

@@ -16,6 +16,35 @@ import { createLogger, type LogContext } from '../utils/logger.js';
 const SERVER_LOG_CONTEXT: LogContext = 'server';
 const logger = createLogger('OAuthHandler', SERVER_LOG_CONTEXT);
 
+const OAUTH_CONFIG_FIELDS = new Set([
+  'clientId', 'clientSecret', 'scopes', 'optionalScopes', 'redirectUri',
+  'client_id', 'client_secret', 'scope', 'optional_scope', 'redirect_uri',
+  'provider',
+]);
+
+function getForwardableProviderConfig(config?: Record<string, any>): Record<string, string> {
+  if (!config) {
+    return {};
+  }
+
+  return Object.fromEntries(
+    Object.entries(config)
+      .filter(([key, value]) => value !== undefined && value !== null && !OAUTH_CONFIG_FIELDS.has(key))
+      .map(([key, value]) => [key, String(value)])
+  );
+}
+
+function getStoredProviderConfig(config?: Record<string, any>): Record<string, unknown> | undefined {
+  const baseUrl = config?.baseUrl || config?.apiBaseUrl;
+  if (!baseUrl) {
+    return undefined;
+  }
+
+  return {
+    baseUrl: String(baseUrl),
+  };
+}
+
 /**
  * MCP Server URL - managed by Integrate
  */
@@ -370,18 +399,9 @@ export class OAuthHandler {
     // Add provider-specific config parameters (e.g., Notion's 'owner' parameter)
     // Fields already handled explicitly above — skip them if they accidentally
     // appear in the provider-specific config (e.g., from a ...config spread)
-    const OAUTH_FIELDS = new Set([
-      'clientId', 'clientSecret', 'scopes', 'optionalScopes', 'redirectUri',
-      'client_id', 'client_secret', 'scope', 'optional_scope', 'redirect_uri',
-      'provider',
-    ]);
-
-    if (providerConfig.config) {
-      for (const [key, value] of Object.entries(providerConfig.config)) {
-        if (value !== undefined && value !== null && !OAUTH_FIELDS.has(key)) {
-          url.searchParams.set(key, String(value));
-        }
-      }
+    const extraConfig = getForwardableProviderConfig(providerConfig.config);
+    for (const [key, value] of Object.entries(extraConfig)) {
+      url.searchParams.set(key, value);
     }
 
     // Forward to MCP server
@@ -530,6 +550,7 @@ export class OAuthHandler {
         client_id: providerConfig.clientId,
         client_secret: providerConfig.clientSecret,
         redirect_uri: providerConfig.redirectUri,
+        ...getForwardableProviderConfig(providerConfig.config),
       }),
     });
 
@@ -559,6 +580,7 @@ export class OAuthHandler {
           scopes: result.scopes
             ? result.scopes.flatMap((s: string) => s.split(' ').filter(Boolean))
             : result.scopes,
+          providerConfig: getStoredProviderConfig(providerConfig.config),
         };
 
         // Prefer email returned directly from the callback response (e.g. Google id_token),
@@ -755,6 +777,13 @@ export class OAuthHandler {
       body.subdomain = providerConfig.config.subdomain;
     }
 
+    const extraConfig = getForwardableProviderConfig(providerConfig.config);
+    for (const [key, value] of Object.entries(extraConfig)) {
+      if (body[key] === undefined) {
+        body[key] = value;
+      }
+    }
+
     // Forward to MCP server for token refresh
     const url = new URL('/oauth/refresh', this.serverUrl);
 
@@ -790,6 +819,7 @@ export class OAuthHandler {
           scopes: result.scopes
             ? result.scopes.flatMap((s: string) => s.split(' ').filter(Boolean))
             : result.scopes,
+          providerConfig: getStoredProviderConfig(providerConfig.config),
         };
 
         const email = result.email || await fetchUserEmail(refreshRequest.provider, tokenData);

src/client.ts

@@ -33,6 +33,7 @@ import type { GmailIntegrationClient } from "./integrations/gmail-client.js";
 import type { NotionIntegrationClient } from "./integrations/notion-client.js";
 import type { SlackIntegrationClient } from "./integrations/slack-client.js";
 import type { LinearIntegrationClient } from "./integrations/linear-client.js";
+import type { RailwayIntegrationClient } from "./integrations/railway-client.js";
 import type { VercelIntegrationClient } from "./integrations/vercel-client.js";
 import type { ZendeskIntegrationClient } from "./integrations/zendesk-client.js";
 import type { StripeIntegrationClient } from "./integrations/stripe-client.js";
@@ -53,6 +54,7 @@ import type { IntercomIntegrationClient } from "./integrations/intercom-client.j
 import type { HubSpotIntegrationClient } from "./integrations/hubspot-client.js";
 import type { YouTubeIntegrationClient } from "./integrations/youtube-client.js";
 import type { CursorIntegrationClient } from "./integrations/cursor-client.js";
+import type { PostHogIntegrationClient } from "./integrations/posthog-client.js";
 import type { ServerIntegrationClient } from "./integrations/server-client.js";
 import { TriggerClient } from "./triggers/client.js";
 import { OAuthManager } from "./oauth/manager.js";
@@ -196,6 +198,8 @@ type IntegrationNamespaces<TIntegrations extends readonly MCPIntegration[]> = {
   ? "slack"
   : K extends "linear"
   ? "linear"
+  : K extends "railway"
+  ? "railway"
   : K extends "vercel"
   ? "vercel"
   : K extends "zendesk"
@@ -236,12 +240,15 @@ type IntegrationNamespaces<TIntegrations extends readonly MCPIntegration[]> = {
   ? "youtube"
   : K extends "cursor"
   ? "cursor"
+  : K extends "posthog"
+  ? "posthog"
   : never]:
   K extends "github" ? GitHubIntegrationClient :
   K extends "gmail" ? GmailIntegrationClient :
   K extends "notion" ? NotionIntegrationClient :
   K extends "slack" ? SlackIntegrationClient :
   K extends "linear" ? LinearIntegrationClient :
+  K extends "railway" ? RailwayIntegrationClient :
   K extends "vercel" ? VercelIntegrationClient :
   K extends "zendesk" ? ZendeskIntegrationClient :
   K extends "stripe" ? StripeIntegrationClient :
@@ -262,6 +269,7 @@ type IntegrationNamespaces<TIntegrations extends readonly MCPIntegration[]> = {
   K extends "hubspot" ? HubSpotIntegrationClient :
   K extends "youtube" ? YouTubeIntegrationClient :
   K extends "cursor" ? CursorIntegrationClient :
+  K extends "posthog" ? PostHogIntegrationClient :
   never;
 };
 
@@ -495,6 +503,9 @@ export class MCPClientBase<TIntegrations extends readonly MCPIntegration[] = rea
     if (integrationIds.includes("linear")) {
       (this as any).linear = this.createIntegrationProxy("linear");
     }
+    if (integrationIds.includes("railway")) {
+      (this as any).railway = this.createIntegrationProxy("railway");
+    }
     if (integrationIds.includes("vercel")) {
       (this as any).vercel = this.createIntegrationProxy("vercel");
     }
@@ -525,6 +536,9 @@ export class MCPClientBase<TIntegrations extends readonly MCPIntegration[] = rea
     if (integrationIds.includes("gslides")) {
       (this as any).gslides = this.createIntegrationProxy("gslides");
     }
+    if (integrationIds.includes("posthog")) {
+      (this as any).posthog = this.createIntegrationProxy("posthog");
+    }
 
     // Server namespace is always available
     this.server = this.createServerProxy() as any;

src/index.ts

@@ -98,6 +98,9 @@ export type { SlackIntegrationConfig, SlackTools, SlackIntegrationClient } from
 export { linearIntegration } from "./integrations/linear.js";
 export type { LinearIntegrationConfig, LinearTools, LinearIntegrationClient } from "./integrations/linear.js";
 
+export { railwayIntegration } from "./integrations/railway.js";
+export type { RailwayIntegrationConfig, RailwayTools, RailwayScopes, RailwayIntegrationClient } from "./integrations/railway.js";
+
 export { vercelIntegration } from "./integrations/vercel.js";
 export type { VercelIntegrationConfig, VercelTools, VercelIntegrationClient } from "./integrations/vercel.js";
 
@@ -161,6 +164,9 @@ export type { YouTubeIntegrationConfig, YouTubeTools, YouTubeIntegrationClient }
 export { cursorIntegration } from "./integrations/cursor.js";
 export type { CursorIntegrationConfig, CursorTools, CursorIntegrationClient } from "./integrations/cursor.js";
 
+export { posthogIntegration } from "./integrations/posthog.js";
+export type { PostHogIntegrationConfig, PostHogTools, PostHogScopes, PostHogIntegrationClient } from "./integrations/posthog.js";
+
 export { granolaIntegration } from "./integrations/granola.js";
 export type { GranolaIntegrationOptions, GranolaTools } from "./integrations/granola.js";
 

src/integrations/library-metadata.ts

@@ -4,10 +4,12 @@
  */
 
 export type IntegrationCategory =
+  | "Analytics"
   | "Business"
   | "Productivity"
   | "Communication"
   | "Engineering"
+  | "Infrastructure"
   | "Storage"
   | "Other";
 
@@ -18,10 +20,12 @@ type LibraryEntry = {
 
 /** Display order for library section headers (categories not listed sort before "Other"). */
 export const INTEGRATION_CATEGORY_ORDER: readonly IntegrationCategory[] = [
+  "Analytics",
   "Productivity",
   "Business",
   "Communication",
   "Engineering",
+  "Infrastructure",
   "Storage",
   "Other",
 ] as const;
@@ -86,10 +90,18 @@ export const INTEGRATION_LIBRARY_METADATA: Record<string, LibraryEntry> = {
     description: "Manage Polar products, orders, and subscriptions",
     category: "Business",
   },
+  posthog: {
+    description: "Read PostHog organizations, projects, insights, and feature flags",
+    category: "Analytics",
+  },
   ramp: {
     description: "Manage Ramp corporate cards, bills, and spend",
     category: "Business",
   },
+  railway: {
+    description: "Manage Railway workspaces, projects, services, deployments, variables, domains, and volumes",
+    category: "Infrastructure",
+  },
   slack: {
     description: "Send and manage Slack messages and channels",
     category: "Communication",

src/integrations/posthog-client.ts

@@ -0,0 +1,135 @@
+/**
+ * PostHog Integration Client Types
+ * Fully typed interface for PostHog integration methods
+ */
+
+import type { MCPToolCallResponse } from "../protocol/messages.js";
+
+export interface PostHogCurrentUser {
+  id: string;
+  email?: string;
+  first_name?: string;
+  last_name?: string;
+  role?: string;
+  [key: string]: any;
+}
+
+export interface PostHogOrganization {
+  id: string;
+  name: string;
+  slug?: string;
+  membership_level?: string;
+  [key: string]: any;
+}
+
+export interface PostHogProject {
+  id: number | string;
+  name: string;
+  uuid?: string;
+  created_at?: string;
+  updated_at?: string;
+  [key: string]: any;
+}
+
+export interface PostHogInsight {
+  id: number | string;
+  name?: string;
+  short_id?: string;
+  description?: string;
+  [key: string]: any;
+}
+
+export interface PostHogDashboard {
+  id: number | string;
+  name: string;
+  description?: string;
+  [key: string]: any;
+}
+
+export interface PostHogFeatureFlag {
+  id: number | string;
+  key: string;
+  name?: string;
+  active?: boolean;
+  [key: string]: any;
+}
+
+export interface PostHogExperiment {
+  id: number | string;
+  name?: string;
+  feature_flag_key?: string;
+  [key: string]: any;
+}
+
+export interface PostHogAnnotation {
+  id: number | string;
+  content?: string;
+  date_marker?: string;
+  [key: string]: any;
+}
+
+export interface PostHogCohort {
+  id: number | string;
+  name: string;
+  count?: number;
+  [key: string]: any;
+}
+
+export interface PostHogEventDefinition {
+  id: number | string;
+  name: string;
+  description?: string;
+  [key: string]: any;
+}
+
+export interface PostHogPropertyDefinition {
+  id: number | string;
+  name: string;
+  property_type?: string;
+  [key: string]: any;
+}
+
+export interface PostHogPerson {
+  id: string;
+  name?: string;
+  distinct_ids?: string[];
+  properties?: Record<string, any>;
+  [key: string]: any;
+}
+
+export interface PostHogSessionRecording {
+  id: string;
+  start_time?: string;
+  end_time?: string;
+  distinct_id?: string;
+  [key: string]: any;
+}
+
+export interface PostHogIntegrationClient {
+  getCurrentUser(params?: Record<string, never>): Promise<MCPToolCallResponse>;
+  listOrganizations(params?: { limit?: number; offset?: number }): Promise<MCPToolCallResponse>;
+  getOrganization(params: { organization_id: string }): Promise<MCPToolCallResponse>;
+  listProjects(params: { organization_id: string; limit?: number; offset?: number; search?: string }): Promise<MCPToolCallResponse>;
+  getProject(params: { organization_id: string; project_id: string | number }): Promise<MCPToolCallResponse>;
+  runHogqlQuery(params: { project_id: string | number; query: string; name?: string; kind?: string }): Promise<MCPToolCallResponse>;
+  listInsights(params: { project_id: string | number; limit?: number; offset?: number; search?: string; refresh?: boolean; insight?: string; basic?: boolean }): Promise<MCPToolCallResponse>;
+  getInsight(params: { project_id: string | number; insight_id: string | number; refresh?: boolean; from_dashboard?: string | number }): Promise<MCPToolCallResponse>;
+  listDashboards(params: { project_id: string | number; limit?: number; offset?: number; search?: string }): Promise<MCPToolCallResponse>;
+  getDashboard(params: { project_id: string | number; dashboard_id: string | number }): Promise<MCPToolCallResponse>;
+  listFeatureFlags(params: { project_id: string | number; limit?: number; offset?: number; search?: string }): Promise<MCPToolCallResponse>;
+  getFeatureFlag(params: { project_id: string | number; flag_id: string | number }): Promise<MCPToolCallResponse>;
+  listExperiments(params: { project_id: string | number; limit?: number; offset?: number }): Promise<MCPToolCallResponse>;
+  getExperiment(params: { project_id: string | number; experiment_id: string | number }): Promise<MCPToolCallResponse>;
+  listAnnotations(params: { project_id: string | number; limit?: number; offset?: number }): Promise<MCPToolCallResponse>;
+  getAnnotation(params: { project_id: string | number; annotation_id: string | number }): Promise<MCPToolCallResponse>;
+  listCohorts(params: { project_id: string | number; limit?: number; offset?: number }): Promise<MCPToolCallResponse>;
+  getCohort(params: { project_id: string | number; cohort_id: string | number }): Promise<MCPToolCallResponse>;
+  listEventDefinitions(params: { project_id: string | number; limit?: number; offset?: number; search?: string }): Promise<MCPToolCallResponse>;
+  getEventDefinition(params: { project_id: string | number; event_definition_id: string | number }): Promise<MCPToolCallResponse>;
+  listPropertyDefinitions(params: { project_id: string | number; limit?: number; offset?: number; search?: string }): Promise<MCPToolCallResponse>;
+  getPropertyDefinition(params: { project_id: string | number; property_definition_id: string | number }): Promise<MCPToolCallResponse>;
+  listPersons(params: { project_id: string | number; limit?: number; offset?: number; search?: string; email?: string; distinct_id?: string }): Promise<MCPToolCallResponse>;
+  getPerson(params: { project_id: string | number; person_id: string }): Promise<MCPToolCallResponse>;
+  listSessionRecordings(params: { project_id: string | number; limit?: number; offset?: number }): Promise<MCPToolCallResponse>;
+  getSessionRecording(params: { project_id: string | number; recording_id: string }): Promise<MCPToolCallResponse>;
+}