Invoice Downloader MCP Server

Pricing

Pay per event

Invoice Downloader MCP Server

MCP server for AI agents to download invoices from cloud platforms (Vercel, DigitalOcean, Railway). Automates monthly invoice collection for accounting. Integrates with Claude, GPT, and other AI assistants via Model Context Protocol.

Pricing

Pay per event

Rating

0.0

(0)

Developer

Anton D

Maintained by Community

Actor stats

Bookmarked

Total users

Monthly active users

3 days ago

Last modified

Web Search MCP Server

abotapi/ai-search-mcp-server

An Apify MCP Server that provides real-time web search capabilities for AI agents via the Model Context Protocol (MCP).

AbotAPI

Time MCP Server

agentify/time-mcp-server

An MCP server implementing the Model Context Protocol (MCP) for time-related operations.

agentify

Firecrawl MCP Server

agentify/firecrawl-mcp-server

A Model Context Protocol (MCP) server implementation that integrates with Firecrawl MCP for web scraping capabilities

agentify

315

Invoice Collector MCP

devaditya/invoice-collector-mcp

Automates invoice collection from Razorpay, PayPal, and Stripe. Generates PDF/JSON exports, emails reports automatically, and supports AI-ready MCP mode for agent workflows.

lalithhh

TextFormatter MCP Server

agentify/textformatter-mcp-server

A Model Context Protocol (MCP) server providing advanced text transformation, formatting, and analysis tools for AI workflows and automation.

agentify

LinkedIn MCP Server - AI Assistant

alizarin_refrigerator-owner/linkedin-mcp-server

Model Context Protocol server for LinkedIn automation. Enable AI assistants to search profiles, send messages & manage connections programmatically.

John Rippy

Excel Mcp Server

lovely_radiologist/excel-mcp-server

Vivek Gaur

GitHub MCP Server 🐙 - AI Agent Connector

10emmmm/github-mcp-server

Connect AI Agents (Claude, Cursor) to your private GitHub repos via MCP (Model Context Protocol). Secure, pay-per-event, and runs via SSE.

AJ4N3NZ0

Playwright MCP Server

jiri.spilka/playwright-mcp-server

A Model Context Protocol (MCP) server that provides browser automation capabilities using Playwright

Jiří Spilka

138

Mindmap MCP Server

agentify/mindmap-mcp-server

A Model Context Protocol (MCP) server for converting Markdown content to interactive mindmaps.

agentify

{ "title": "Invoice Downloader MCP Server Input", "type": "object", "schemaVersion": 1, "properties": { "vercel": { "title": "Vercel Credentials", "type": "object", "description": "Login credentials for Vercel", "editor": "json" }, "digitalocean": { "title": "DigitalOcean Credentials", "type": "object", "description": "Login credentials for DigitalOcean", "editor": "json" }, "railway": { "title": "Railway Credentials", "type": "object", "description": "Login credentials for Railway", "editor": "json" }, "headless": { "title": "Headless Mode", "type": "boolean", "description": "Run browser in headless mode", "default": true, "editor": "checkbox" }, "proxyConfiguration": { "title": "Proxy Configuration", "type": "object", "description": "Proxy settings for web scraping", "editor": "proxy", "sectionCaption": "Proxy configuration" } } }

{ "actorSpecification": 1, "name": "invoice-downloader-mcp", "title": "Invoice Downloader MCP Server", "description": "MCP server for AI agents to download invoices from SaaS platforms. Supports Vercel, DigitalOcean, and Railway.", "version": "1.0", "buildTag": "latest", "usesStandbyMode": true, "minMemoryMbytes": 1024, "maxMemoryMbytes": 4096, "webServerMcpPath": "/mcp", "meta": { "templateId": "typescript-mcp" }, "input": "./INPUT_SCHEMA.json", "dockerfile": "./Dockerfile", "readme": "./README.md", "storages": { "dataset": { "actorSpecification": 1, "title": "Downloaded Invoices", "views": { "overview": { "title": "Invoice Overview", "transformation": { "fields": ["platform", "invoiceId", "date", "amount", "currency", "pdfUrl"] }, "display": { "component": "table", "properties": { "platform": { "label": "Platform", "format": "text" }, "invoiceId": { "label": "Invoice ID", "format": "text" }, "date": { "label": "Date", "format": "date" }, "amount": { "label": "Amount", "format": "number" }, "currency": { "label": "Currency", "format": "text" }, "pdfUrl": { "label": "PDF URL", "format": "link" } } } } } } } }

{ "pricingModel": "PAY_PER_EVENT", "events": [ { "name": "invoice-listed", "displayName": "Invoices Listed", "priceUsd": 0.01, "description": "Charged when invoices are listed from a platform" }, { "name": "invoice-downloaded", "displayName": "Invoice Downloaded", "priceUsd": 0.03, "description": "Charged when an invoice PDF is successfully downloaded" } ] }

# Dockerfile for Invoice Downloader MCP Server # Uses Playwright for browser automation FROM apify/actor-node-playwright-chrome:20 # Copy package files COPY package*.json ./ # Install ALL dependencies (including devDependencies for build) RUN npm ci --include=dev # Copy source code COPY . ./ # Build TypeScript RUN npm run build # Prune dev dependencies for smaller final image RUN npm prune --omit=dev # Run the actor CMD ["npm", "start"]

1#!/usr/bin/env node 2import { readFileSync } from 'fs'; 3import { join } from 'path'; 4import { homedir } from 'os'; 5 6const BUILD_ID = process.argv[2] || 'UhW5urc6SWbLPNzkE'; 7const authPath = join(homedir(), '.apify', 'auth.json'); 8const { token } = JSON.parse(readFileSync(authPath, 'utf8')); 9 10const resp = await fetch(`https://api.apify.com/v2/actor-builds/${BUILD_ID}?token=${token}`); 11const data = await resp.json(); 12 13console.log('Build:', data.data.buildNumber); 14console.log('Status:', data.data.status); 15console.log('Started:', data.data.startedAt); 16console.log('Finished:', data.data.finishedAt || 'In progress...'); 17 18if (data.data.status === 'FAILED') { 19 console.log('\nError:', data.data.stats?.computeUnits || 'Check console for details'); 20}

{ "name": "invoice-downloader-mcp", "version": "1.0.0", "description": "MCP server for AI agents to download invoices from SaaS platforms (Vercel, DigitalOcean, Railway)", "type": "module", "main": "dist/main.js", "scripts": { "start": "node dist/main.js", "build": "tsc", "dev": "tsx src/main.ts", "test": "vitest run" }, "author": "OpenClaw", "license": "MIT", "dependencies": { "@modelcontextprotocol/sdk": "^1.0.4", "apify": "^3.1.0", "playwright": "^1.42.0", "zod": "^3.22.4" }, "devDependencies": { "@types/node": "^20.11.0", "tsx": "^4.7.0", "typescript": "^5.3.0", "vitest": "^1.2.0" }, "engines": { "node": ">=18.0.0" } }

1/** 2 * Invoice Downloader MCP Server - Apify Actor Entry Point 3 * 4 * This Actor runs as an MCP server that AI agents can connect to 5 * for downloading invoices from SaaS platforms. 6 * 7 * Supports: Vercel, DigitalOcean, Railway 8 */ 9 10import { Actor, log } from 'apify'; 11import http from 'http'; 12import { InvoiceDownloaderServer } from './server.js'; 13import { ActorInput } from './types.js'; 14import { logger } from './utils/logger.js'; 15import { closeBrowser } from './utils/browser.js'; 16 17// Check if running in standby mode (MCP server mode) 18const isStandbyMode = process.env.APIFY_META_ORIGIN === 'STANDBY'; 19const port = parseInt(process.env.ACTOR_WEB_SERVER_PORT || '8080', 10); 20 21async function main() { 22 await Actor.init(); 23 24 try { 25 const input = await Actor.getInput<ActorInput>() ?? {}; 26 27 // Validate we have at least one platform configured 28 const configuredPlatforms = ['vercel', 'digitalocean', 'railway'].filter( 29 p => input[p as keyof ActorInput] 30 ); 31 32 if (configuredPlatforms.length === 0) { 33 log.warning('No platform credentials configured. Add credentials for at least one platform.'); 34 } else { 35 log.info(`Configured platforms: ${configuredPlatforms.join(', ')}`); 36 } 37 38 if (isStandbyMode) { 39 // Run as HTTP MCP server for standby mode 40 await runHttpServer(input, port); 41 } else { 42 // Run as stdio MCP server for direct usage 43 await runStdioServer(input); 44 } 45 } catch (error) { 46 log.error('Actor failed', { error: String(error) }); 47 throw error; 48 } finally { 49 await closeBrowser(); 50 await Actor.exit(); 51 } 52} 53 54async function runStdioServer(input: ActorInput) { 55 logger.info('Starting stdio MCP server'); 56 const server = new InvoiceDownloaderServer(input); 57 58 // Handle graceful shutdown 59 process.on('SIGINT', async () => { 60 await server.close(); 61 process.exit(0); 62 }); 63 64 process.on('SIGTERM', async () => { 65 await server.close(); 66 process.exit(0); 67 }); 68 69 await server.run(); 70} 71 72async function runHttpServer(input: ActorInput, port: number) { 73 logger.info(`Starting HTTP MCP server on port ${port}`); 74 75 // Import the SSE transport for HTTP mode 76 const { SSEServerTransport } = await import('@modelcontextprotocol/sdk/server/sse.js'); 77 const { Server } = await import('@modelcontextprotocol/sdk/server/index.js'); 78 const { 79 CallToolRequestSchema, 80 ListToolsRequestSchema 81 } = await import('@modelcontextprotocol/sdk/types.js'); 82 83 // Create server instance for each connection 84 const createServerInstance = () => { 85 const invoiceServer = new InvoiceDownloaderServer(input); 86 return invoiceServer; 87 }; 88 89 // HTTP server for SSE/MCP 90 const httpServer = http.createServer(async (req, res) => { 91 // CORS headers 92 res.setHeader('Access-Control-Allow-Origin', '*'); 93 res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS'); 94 res.setHeader('Access-Control-Allow-Headers', 'Content-Type, Authorization'); 95 96 if (req.method === 'OPTIONS') { 97 res.writeHead(200); 98 res.end(); 99 return; 100 } 101 102 const url = new URL(req.url || '/', `http://localhost:${port}`); 103 104 // Health check 105 if (url.pathname === '/health' || url.pathname === '/') { 106 res.writeHead(200, { 'Content-Type': 'application/json' }); 107 res.end(JSON.stringify({ 108 status: 'ok', 109 server: 'invoice-downloader-mcp', 110 version: '1.0.0', 111 })); 112 return; 113 } 114 115 // MCP endpoint (SSE) 116 if (url.pathname === '/mcp' || url.pathname === '/sse') { 117 logger.info('New MCP connection'); 118 119 // SSE headers 120 res.writeHead(200, { 121 'Content-Type': 'text/event-stream', 122 'Cache-Control': 'no-cache', 123 'Connection': 'keep-alive', 124 }); 125 126 const serverInstance = createServerInstance(); 127 const transport = new SSEServerTransport('/mcp', res); 128 129 try { 130 await (serverInstance as any).server.connect(transport); 131 } catch (err) { 132 logger.error('MCP connection error', { error: String(err) }); 133 res.end(); 134 } 135 136 req.on('close', async () => { 137 logger.info('MCP connection closed'); 138 await serverInstance.close(); 139 }); 140 141 return; 142 } 143 144 // 404 for other paths 145 res.writeHead(404, { 'Content-Type': 'application/json' }); 146 res.end(JSON.stringify({ error: 'Not found' })); 147 }); 148 149 // Handle POST requests for MCP messages 150 httpServer.on('request', (req, res) => { 151 if (req.method === 'POST' && (req.url === '/mcp' || req.url === '/sse')) { 152 let body = ''; 153 req.on('data', chunk => { body += chunk; }); 154 req.on('end', () => { 155 // Handle incoming MCP messages 156 logger.debug('Received MCP message', { length: body.length }); 157 }); 158 } 159 }); 160 161 httpServer.listen(port, () => { 162 logger.info(`MCP server listening on http://0.0.0.0:${port}`); 163 logger.info(`MCP endpoint: http://0.0.0.0:${port}/mcp`); 164 }); 165 166 // Keep server running 167 await new Promise<void>((resolve) => { 168 process.on('SIGTERM', () => { 169 httpServer.close(() => resolve()); 170 }); 171 }); 172} 173 174main().catch((err) => { 175 log.error('Unhandled error', { error: String(err) }); 176 process.exit(1); 177});

1/** 2 * DigitalOcean platform handler for invoice downloading 3 */ 4 5import { Page, BrowserContext } from 'playwright'; 6import { Credentials, Invoice, PlatformHandler } from '../types.js'; 7import { logger } from '../utils/logger.js'; 8import { getBrowser, createContext, safeClick, safeType, waitForNavigation, BrowserOptions } from '../utils/browser.js'; 9 10export class DigitalOceanHandler implements PlatformHandler { 11 readonly platform = 'digitalocean' as const; 12 private context: BrowserContext | null = null; 13 private page: Page | null = null; 14 private isLoggedIn = false; 15 16 constructor(private options: BrowserOptions = {}) {} 17 18 async login(credentials: Credentials): Promise<boolean> { 19 logger.info('Logging into DigitalOcean', { email: credentials.email }); 20 21 try { 22 const browser = await getBrowser(this.options); 23 this.context = await createContext(browser, this.options); 24 this.page = await this.context.newPage(); 25 26 // Navigate to login page 27 await this.page.goto('https://cloud.digitalocean.com/login'); 28 await waitForNavigation(this.page); 29 30 // Enter email 31 await safeType(this.page, 'input[name="email"], input[type="email"]', credentials.email); 32 33 // Enter password 34 await safeType(this.page, 'input[name="password"], input[type="password"]', credentials.password); 35 36 // Click login button 37 await safeClick(this.page, 'button[type="submit"]'); 38 39 await waitForNavigation(this.page); 40 41 // Handle potential 2FA - this would need user interaction 42 const has2FA = await this.page.$('input[name="code"], input[placeholder*="code"]'); 43 if (has2FA) { 44 logger.warn('DigitalOcean account has 2FA enabled - automated login not possible'); 45 throw new Error('Account has 2FA enabled - automated login not supported'); 46 } 47 48 // Check if we're logged in 49 const isOnCloud = await this.page.url().includes('cloud.digitalocean.com'); 50 const hasProjectsOrDashboard = await this.page.$('[data-testid="projects"], .Projects, .Dashboard'); 51 52 if (isOnCloud && hasProjectsOrDashboard) { 53 this.isLoggedIn = true; 54 logger.info('Successfully logged into DigitalOcean'); 55 return true; 56 } 57 58 // Alternative check - look for account menu 59 const accountMenu = await this.page.$('[data-testid="account-menu"], .AccountMenu'); 60 if (accountMenu) { 61 this.isLoggedIn = true; 62 logger.info('Successfully logged into DigitalOcean'); 63 return true; 64 } 65 66 throw new Error('Login failed - could not verify dashboard access'); 67 } catch (error) { 68 logger.error('DigitalOcean login failed', { error: String(error) }); 69 return false; 70 } 71 } 72 73 async listInvoices(): Promise<Invoice[]> { 74 if (!this.page || !this.isLoggedIn) { 75 throw new Error('Not logged in to DigitalOcean'); 76 } 77 78 logger.info('Listing DigitalOcean invoices'); 79 80 // Navigate to billing history 81 await this.page.goto('https://cloud.digitalocean.com/account/billing'); 82 await waitForNavigation(this.page); 83 84 // Click on Billing History tab 85 await this.page.waitForTimeout(2000); 86 const historyTab = await this.page.$('a[href*="billing-history"], button:has-text("Billing History")'); 87 if (historyTab) { 88 await historyTab.click(); 89 await waitForNavigation(this.page); 90 } 91 92 const invoices: Invoice[] = []; 93 94 // Parse invoice table - DigitalOcean uses a table layout 95 const rows = await this.page.$$('table tbody tr, [class*="billing"] [class*="row"]'); 96 97 for (const row of rows) { 98 try { 99 // Different selectors for different DO layouts 100 const dateEl = await row.$('td:first-child, [class*="date"]'); 101 const descEl = await row.$('td:nth-child(2), [class*="description"]'); 102 const amountEl = await row.$('td:nth-child(3), [class*="amount"]'); 103 104 const dateText = dateEl ? await dateEl.textContent() || '' : ''; 105 const descText = descEl ? await descEl.textContent() || '' : ''; 106 const amountText = amountEl ? await amountEl.textContent() || '' : ''; 107 108 if (!dateText || !amountText) continue; 109 110 // Extract invoice ID from row or generate one 111 const rowHtml = await row.innerHTML(); 112 const invoiceIdMatch = rowHtml.match(/invoice[_-]?([a-zA-Z0-9-]+)/i); 113 const invoiceId = invoiceIdMatch?.[1] || `do-${dateText.replace(/\D/g, '')}`; 114 115 // Parse amount 116 const amountMatch = amountText.match(/[\d,]+\.?\d*/); 117 const amount = amountMatch ? parseFloat(amountMatch[0].replace(',', '')) : 0; 118 119 invoices.push({ 120 id: invoiceId, 121 platform: 'digitalocean', 122 date: dateText.trim(), 123 amount, 124 currency: 'USD', // DigitalOcean primarily uses USD 125 status: 'paid', // History items are typically paid 126 description: descText.trim(), 127 }); 128 } catch (err) { 129 logger.warn('Failed to parse DO invoice row', { error: String(err) }); 130 } 131 } 132 133 logger.info(`Found ${invoices.length} DigitalOcean invoices`); 134 return invoices; 135 } 136 137 async downloadInvoice(invoiceId: string): Promise<Buffer> { 138 if (!this.page || !this.isLoggedIn) { 139 throw new Error('Not logged in to DigitalOcean'); 140 } 141 142 logger.info('Downloading DigitalOcean invoice', { invoiceId }); 143 144 // Navigate to billing history 145 await this.page.goto('https://cloud.digitalocean.com/account/billing'); 146 await waitForNavigation(this.page); 147 148 // Wait for billing page to load 149 await this.page.waitForTimeout(2000); 150 151 // Find invoice by ID or look for PDF download links 152 const pdfLinks = await this.page.$$(`a[href*="pdf"], a[href*="invoice"], a[download]`); 153 154 let targetLink = null; 155 for (const link of pdfLinks) { 156 const href = await link.getAttribute('href') || ''; 157 const text = await link.textContent() || ''; 158 if (href.includes(invoiceId) || text.includes(invoiceId)) { 159 targetLink = link; 160 break; 161 } 162 } 163 164 // If not found by ID, try to find by clicking "View Invoice" buttons 165 if (!targetLink) { 166 // Look for a view/download button in the row containing the invoice ID 167 const invoiceRow = await this.page.$(`tr:has-text("${invoiceId}"), [class*="row"]:has-text("${invoiceId}")`); 168 if (invoiceRow) { 169 targetLink = await invoiceRow.$('a[href*="pdf"], button:has-text("Download"), button:has-text("View")'); 170 } 171 } 172 173 if (!targetLink) { 174 throw new Error(`Invoice ${invoiceId} not found or download link unavailable`); 175 } 176 177 // Trigger download 178 const [download] = await Promise.all([ 179 this.page.waitForEvent('download', { timeout: 30000 }), 180 targetLink.click(), 181 ]); 182 183 const buffer = await download.createReadStream().then(stream => { 184 const chunks: Buffer[] = []; 185 return new Promise<Buffer>((resolve, reject) => { 186 stream.on('data', chunk => chunks.push(Buffer.from(chunk))); 187 stream.on('end', () => resolve(Buffer.concat(chunks))); 188 stream.on('error', reject); 189 }); 190 }); 191 192 logger.info('Invoice downloaded', { invoiceId, size: buffer.length }); 193 return buffer; 194 } 195 196 async close(): Promise<void> { 197 if (this.context) { 198 await this.context.close(); 199 this.context = null; 200 this.page = null; 201 this.isLoggedIn = false; 202 } 203 } 204}

1/** 2 * Platform handlers index 3 */ 4 5export { VercelHandler } from './vercel.js'; 6export { DigitalOceanHandler } from './digitalocean.js'; 7export { RailwayHandler } from './railway.js'; 8 9import { VercelHandler } from './vercel.js'; 10import { DigitalOceanHandler } from './digitalocean.js'; 11import { RailwayHandler } from './railway.js'; 12import { Platform, PlatformHandler, Credentials } from '../types.js'; 13import { BrowserOptions } from '../utils/browser.js'; 14 15export function createPlatformHandler( 16 platform: Platform, 17 options: BrowserOptions = {} 18): PlatformHandler { 19 switch (platform) { 20 case 'vercel': 21 return new VercelHandler(options); 22 case 'digitalocean': 23 return new DigitalOceanHandler(options); 24 case 'railway': 25 return new RailwayHandler(options); 26 default: 27 throw new Error(`Unsupported platform: ${platform}`); 28 } 29} 30 31export const SUPPORTED_PLATFORMS: Platform[] = ['vercel', 'digitalocean', 'railway'];

1/** 2 * Railway platform handler for invoice downloading 3 */ 4 5import { Page, BrowserContext } from 'playwright'; 6import { Credentials, Invoice, PlatformHandler } from '../types.js'; 7import { logger } from '../utils/logger.js'; 8import { getBrowser, createContext, safeClick, safeType, waitForNavigation, BrowserOptions } from '../utils/browser.js'; 9 10export class RailwayHandler implements PlatformHandler { 11 readonly platform = 'railway' as const; 12 private context: BrowserContext | null = null; 13 private page: Page | null = null; 14 private isLoggedIn = false; 15 private teamId?: string; 16 17 constructor(private options: BrowserOptions = {}) {} 18 19 async login(credentials: Credentials): Promise<boolean> { 20 logger.info('Logging into Railway', { email: credentials.email }); 21 22 try { 23 const browser = await getBrowser(this.options); 24 this.context = await createContext(browser, this.options); 25 this.page = await this.context.newPage(); 26 27 // Navigate to login page 28 await this.page.goto('https://railway.app/login'); 29 await waitForNavigation(this.page); 30 31 // Railway uses various OAuth options, but also has email login 32 // Click "Login with Email" if available 33 const emailLoginBtn = await this.page.$('button:has-text("Email"), a:has-text("Email")'); 34 if (emailLoginBtn) { 35 await emailLoginBtn.click(); 36 await this.page.waitForTimeout(1000); 37 } 38 39 // Enter email 40 await safeType(this.page, 'input[name="email"], input[type="email"]', credentials.email); 41 42 // Check if password field is visible (Railway might use magic link) 43 const passwordField = await this.page.$('input[name="password"], input[type="password"]'); 44 45 if (passwordField) { 46 await safeType(this.page, 'input[name="password"], input[type="password"]', credentials.password); 47 await safeClick(this.page, 'button[type="submit"]'); 48 } else { 49 // Click continue/submit for magic link 50 await safeClick(this.page, 'button[type="submit"]'); 51 52 // Railway primarily uses magic link authentication 53 logger.warn('Railway uses magic link authentication. Password login may not be available.'); 54 throw new Error('Railway requires magic link login - check your email'); 55 } 56 57 await waitForNavigation(this.page); 58 59 // Check if we're logged in by looking for dashboard 60 const isOnDashboard = await this.page.url().includes('railway.app/') && 61 !(await this.page.url().includes('/login')); 62 63 if (isOnDashboard) { 64 this.isLoggedIn = true; 65 this.teamId = credentials.teamId; 66 logger.info('Successfully logged into Railway'); 67 return true; 68 } 69 70 throw new Error('Login failed - could not reach dashboard'); 71 } catch (error) { 72 logger.error('Railway login failed', { error: String(error) }); 73 return false; 74 } 75 } 76 77 async listInvoices(): Promise<Invoice[]> { 78 if (!this.page || !this.isLoggedIn) { 79 throw new Error('Not logged in to Railway'); 80 } 81 82 logger.info('Listing Railway invoices'); 83 84 // Navigate to billing page 85 const billingUrl = this.teamId 86 ? `https://railway.app/team/${this.teamId}/billing` 87 : 'https://railway.app/account/billing'; 88 89 await this.page.goto(billingUrl); 90 await waitForNavigation(this.page); 91 92 // Wait for page to load 93 await this.page.waitForTimeout(2000); 94 95 const invoices: Invoice[] = []; 96 97 // Railway's billing page structure - look for invoice/usage entries 98 // Try multiple selector strategies 99 const invoiceElements = await this.page.$$( 100 '[class*="invoice"], [class*="billing-item"], table tbody tr, [class*="usage-row"]' 101 ); 102 103 for (const element of invoiceElements) { 104 try { 105 const text = await element.textContent() || ''; 106 107 // Skip if it doesn't look like an invoice entry 108 if (!text.match(/\$[\d,]+\.?\d*/)) continue; 109 110 // Extract date - look for common date patterns 111 const dateMatch = text.match(/(\w+ \d{1,2},? \d{4}|\d{4}-\d{2}-\d{2}|\d{1,2}\/\d{1,2}\/\d{4})/); 112 const date = dateMatch ? dateMatch[1] : new Date().toISOString().split('T')[0]; 113 114 // Extract amount 115 const amountMatch = text.match(/\$?([\d,]+\.?\d*)/); 116 const amount = amountMatch ? parseFloat(amountMatch[1].replace(',', '')) : 0; 117 118 // Try to find invoice ID 119 const regexMatch = text.match(/inv[_-]?([a-zA-Z0-9]+)/i); 120 const dataId = await element.getAttribute('data-id'); 121 const elementId = await element.getAttribute('id'); 122 let invoiceId: string; 123 if (regexMatch && regexMatch[1]) { 124 invoiceId = regexMatch[1]; 125 } else if (dataId) { 126 invoiceId = dataId; 127 } else if (elementId) { 128 invoiceId = elementId; 129 } else { 130 invoiceId = `railway-${Date.now()}-${invoices.length}`; 131 } 132 133 invoices.push({ 134 id: invoiceId, 135 platform: 'railway', 136 date, 137 amount, 138 currency: 'USD', 139 status: 'paid', 140 description: text.substring(0, 100).trim(), 141 }); 142 } catch (err) { 143 logger.warn('Failed to parse Railway invoice element', { error: String(err) }); 144 } 145 } 146 147 logger.info(`Found ${invoices.length} Railway invoices`); 148 return invoices; 149 } 150 151 async downloadInvoice(invoiceId: string): Promise<Buffer> { 152 if (!this.page || !this.isLoggedIn) { 153 throw new Error('Not logged in to Railway'); 154 } 155 156 logger.info('Downloading Railway invoice', { invoiceId }); 157 158 // Navigate to billing page 159 const billingUrl = this.teamId 160 ? `https://railway.app/team/${this.teamId}/billing` 161 : 'https://railway.app/account/billing'; 162 163 await this.page.goto(billingUrl); 164 await waitForNavigation(this.page); 165 await this.page.waitForTimeout(2000); 166 167 // Look for download/view link for this invoice 168 const downloadLink = await this.page.$( 169 `a[href*="${invoiceId}"], a[href*="invoice"][href*="pdf"], button:has-text("Download"):near(:text("${invoiceId}"))` 170 ); 171 172 if (!downloadLink) { 173 // Try clicking on the invoice row to expand/access download 174 const invoiceRow = await this.page.$(`[data-id="${invoiceId}"], tr:has-text("${invoiceId}")`); 175 if (invoiceRow) { 176 await invoiceRow.click(); 177 await this.page.waitForTimeout(1000); 178 179 // Look for download button in expanded view 180 const expandedDownload = await this.page.$('a[href*="pdf"], button:has-text("Download Invoice")'); 181 if (expandedDownload) { 182 const [download] = await Promise.all([ 183 this.page.waitForEvent('download', { timeout: 30000 }), 184 expandedDownload.click(), 185 ]); 186 187 return this.bufferFromDownload(download); 188 } 189 } 190 191 throw new Error(`Invoice ${invoiceId} not found or download link unavailable`); 192 } 193 194 // Trigger download 195 const [download] = await Promise.all([ 196 this.page.waitForEvent('download', { timeout: 30000 }), 197 downloadLink.click(), 198 ]); 199 200 return this.bufferFromDownload(download); 201 } 202 203 private async bufferFromDownload(download: any): Promise<Buffer> { 204 const buffer = await download.createReadStream().then((stream: NodeJS.ReadableStream) => { 205 const chunks: Buffer[] = []; 206 return new Promise<Buffer>((resolve, reject) => { 207 stream.on('data', chunk => chunks.push(Buffer.from(chunk))); 208 stream.on('end', () => resolve(Buffer.concat(chunks))); 209 stream.on('error', reject); 210 }); 211 }); 212 213 logger.info('Invoice downloaded', { size: buffer.length }); 214 return buffer; 215 } 216 217 async close(): Promise<void> { 218 if (this.context) { 219 await this.context.close(); 220 this.context = null; 221 this.page = null; 222 this.isLoggedIn = false; 223 } 224 } 225}

1/** 2 * Vercel platform handler for invoice downloading 3 */ 4 5import { Page, BrowserContext } from 'playwright'; 6import { Credentials, Invoice, PlatformHandler } from '../types.js'; 7import { logger } from '../utils/logger.js'; 8import { getBrowser, createContext, safeClick, safeType, waitForNavigation, BrowserOptions } from '../utils/browser.js'; 9 10export class VercelHandler implements PlatformHandler { 11 readonly platform = 'vercel' as const; 12 private context: BrowserContext | null = null; 13 private page: Page | null = null; 14 private isLoggedIn = false; 15 private teamSlug?: string; 16 17 constructor(private options: BrowserOptions = {}) {} 18 19 async login(credentials: Credentials): Promise<boolean> { 20 logger.info('Logging into Vercel', { email: credentials.email }); 21 22 try { 23 const browser = await getBrowser(this.options); 24 this.context = await createContext(browser, this.options); 25 this.page = await this.context.newPage(); 26 27 // Navigate to login page 28 await this.page.goto('https://vercel.com/login'); 29 await waitForNavigation(this.page); 30 31 // Click "Continue with Email" 32 await safeClick(this.page, 'button:has-text("Continue with Email")'); 33 34 // Enter email 35 await safeType(this.page, 'input[name="email"]', credentials.email); 36 await safeClick(this.page, 'button[type="submit"]'); 37 38 // Wait for password field or magic link message 39 await this.page.waitForTimeout(2000); 40 41 // Check if password login is available 42 const passwordField = await this.page.$('input[type="password"]'); 43 if (passwordField) { 44 await safeType(this.page, 'input[type="password"]', credentials.password); 45 await safeClick(this.page, 'button[type="submit"]'); 46 } else { 47 // Vercel may use magic link - this is a limitation 48 logger.warn('Vercel may be using magic link authentication. Password login may not work for all accounts.'); 49 throw new Error('Vercel account requires magic link login - password authentication not available'); 50 } 51 52 await waitForNavigation(this.page); 53 54 // Check if we're logged in by looking for dashboard elements 55 const isOnDashboard = await this.page.url().includes('vercel.com/'); 56 if (isOnDashboard) { 57 this.isLoggedIn = true; 58 this.teamSlug = credentials.teamSlug; 59 logger.info('Successfully logged into Vercel'); 60 return true; 61 } 62 63 throw new Error('Login failed - could not reach dashboard'); 64 } catch (error) { 65 logger.error('Vercel login failed', { error: String(error) }); 66 return false; 67 } 68 } 69 70 async listInvoices(): Promise<Invoice[]> { 71 if (!this.page || !this.isLoggedIn) { 72 throw new Error('Not logged in to Vercel'); 73 } 74 75 logger.info('Listing Vercel invoices'); 76 77 // Navigate to billing page 78 const billingUrl = this.teamSlug 79 ? `https://vercel.com/${this.teamSlug}/~/settings/billing` 80 : 'https://vercel.com/account/billing'; 81 82 await this.page.goto(billingUrl); 83 await waitForNavigation(this.page); 84 85 // Navigate to invoices section 86 await this.page.goto(billingUrl.replace('/billing', '/billing/invoices')); 87 await waitForNavigation(this.page); 88 89 const invoices: Invoice[] = []; 90 91 // Parse invoice table 92 const rows = await this.page.$$('table tbody tr'); 93 94 for (const row of rows) { 95 try { 96 const cells = await row.$$('td'); 97 if (cells.length >= 4) { 98 const dateText = await cells[0].textContent() || ''; 99 const descText = await cells[1].textContent() || ''; 100 const amountText = await cells[2].textContent() || ''; 101 const statusText = await cells[3].textContent() || ''; 102 103 // Extract invoice ID from download link 104 const downloadLink = await row.$('a[href*="invoice"]'); 105 const href = downloadLink ? await downloadLink.getAttribute('href') : null; 106 const invoiceId = href?.match(/invoice[_-]?([a-zA-Z0-9]+)/)?.[1] || `vercel-${Date.now()}`; 107 108 // Parse amount 109 const amountMatch = amountText.match(/[\d,]+\.?\d*/); 110 const amount = amountMatch ? parseFloat(amountMatch[0].replace(',', '')) : 0; 111 112 // Determine currency 113 const currency = amountText.includes('€') ? 'EUR' : 'USD'; 114 115 // Map status 116 let status: Invoice['status'] = 'unknown'; 117 if (statusText.toLowerCase().includes('paid')) status = 'paid'; 118 else if (statusText.toLowerCase().includes('pending')) status = 'pending'; 119 else if (statusText.toLowerCase().includes('overdue')) status = 'overdue'; 120 121 invoices.push({ 122 id: invoiceId, 123 platform: 'vercel', 124 date: dateText.trim(), 125 amount, 126 currency, 127 status, 128 description: descText.trim(), 129 }); 130 } 131 } catch (err) { 132 logger.warn('Failed to parse invoice row', { error: String(err) }); 133 } 134 } 135 136 logger.info(`Found ${invoices.length} Vercel invoices`); 137 return invoices; 138 } 139 140 async downloadInvoice(invoiceId: string): Promise<Buffer> { 141 if (!this.page || !this.isLoggedIn) { 142 throw new Error('Not logged in to Vercel'); 143 } 144 145 logger.info('Downloading Vercel invoice', { invoiceId }); 146 147 // Navigate to invoices page 148 const billingUrl = this.teamSlug 149 ? `https://vercel.com/${this.teamSlug}/~/settings/billing/invoices` 150 : 'https://vercel.com/account/billing/invoices'; 151 152 await this.page.goto(billingUrl); 153 await waitForNavigation(this.page); 154 155 // Find the download link for this invoice 156 const downloadSelector = `a[href*="${invoiceId}"][href*="pdf"], a[href*="${invoiceId}"][download]`; 157 const downloadLink = await this.page.$(downloadSelector); 158 159 if (!downloadLink) { 160 throw new Error(`Invoice ${invoiceId} not found or download link unavailable`); 161 } 162 163 // Trigger download and capture the response 164 const [download] = await Promise.all([ 165 this.page.waitForEvent('download', { timeout: 30000 }), 166 downloadLink.click(), 167 ]); 168 169 const buffer = await download.createReadStream().then(stream => { 170 const chunks: Buffer[] = []; 171 return new Promise<Buffer>((resolve, reject) => { 172 stream.on('data', chunk => chunks.push(Buffer.from(chunk))); 173 stream.on('end', () => resolve(Buffer.concat(chunks))); 174 stream.on('error', reject); 175 }); 176 }); 177 178 logger.info('Invoice downloaded', { invoiceId, size: buffer.length }); 179 return buffer; 180 } 181 182 async close(): Promise<void> { 183 if (this.context) { 184 await this.context.close(); 185 this.context = null; 186 this.page = null; 187 this.isLoggedIn = false; 188 } 189 } 190}

1/** 2 * MCP Server for Invoice Downloading 3 * Exposes tools for AI agents to download invoices from SaaS platforms 4 */ 5 6import { Server } from '@modelcontextprotocol/sdk/server/index.js'; 7import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js'; 8import { 9 CallToolRequestSchema, 10 ListToolsRequestSchema, 11 Tool, 12} from '@modelcontextprotocol/sdk/types.js'; 13import { Actor } from 'apify'; 14import { z } from 'zod'; 15 16import { Platform, Credentials, ActorInput, Invoice, InvoiceWithPdf } from './types.js'; 17import { createPlatformHandler, SUPPORTED_PLATFORMS } from './platforms/index.js'; 18import { logger } from './utils/logger.js'; 19import { closeBrowser, BrowserOptions } from './utils/browser.js'; 20 21// Tool schemas 22const ListInvoicesSchema = z.object({ 23 platform: z.enum(['vercel', 'digitalocean', 'railway']), 24}); 25 26const DownloadInvoiceSchema = z.object({ 27 platform: z.enum(['vercel', 'digitalocean', 'railway']), 28 invoiceId: z.string(), 29}); 30 31const GetMetadataSchema = z.object({ 32 platform: z.enum(['vercel', 'digitalocean', 'railway']), 33 invoiceId: z.string(), 34}); 35 36// Tool definitions for MCP 37const TOOLS: Tool[] = [ 38 { 39 name: 'list_invoices', 40 description: 'List all invoices from a SaaS platform (Vercel, DigitalOcean, or Railway). Returns invoice IDs, dates, amounts, and status.', 41 inputSchema: { 42 type: 'object', 43 properties: { 44 platform: { 45 type: 'string', 46 enum: ['vercel', 'digitalocean', 'railway'], 47 description: 'The SaaS platform to list invoices from', 48 }, 49 }, 50 required: ['platform'], 51 }, 52 }, 53 { 54 name: 'download_invoice', 55 description: 'Download a specific invoice PDF from a SaaS platform. Returns a URL to the downloaded PDF stored in Apify key-value store.', 56 inputSchema: { 57 type: 'object', 58 properties: { 59 platform: { 60 type: 'string', 61 enum: ['vercel', 'digitalocean', 'railway'], 62 description: 'The SaaS platform to download invoice from', 63 }, 64 invoiceId: { 65 type: 'string', 66 description: 'The ID of the invoice to download (from list_invoices)', 67 }, 68 }, 69 required: ['platform', 'invoiceId'], 70 }, 71 }, 72 { 73 name: 'get_invoice_metadata', 74 description: 'Get detailed metadata for a specific invoice without downloading the PDF.', 75 inputSchema: { 76 type: 'object', 77 properties: { 78 platform: { 79 type: 'string', 80 enum: ['vercel', 'digitalocean', 'railway'], 81 description: 'The SaaS platform', 82 }, 83 invoiceId: { 84 type: 'string', 85 description: 'The ID of the invoice', 86 }, 87 }, 88 required: ['platform', 'invoiceId'], 89 }, 90 }, 91 { 92 name: 'list_platforms', 93 description: 'List all supported platforms and their configuration status.', 94 inputSchema: { 95 type: 'object', 96 properties: {}, 97 }, 98 }, 99]; 100 101export class InvoiceDownloaderServer { 102 private server: Server; 103 private credentials: ActorInput; 104 private browserOptions: BrowserOptions; 105 private invoiceCache: Map<string, Invoice[]> = new Map(); 106 107 constructor(credentials: ActorInput) { 108 this.credentials = credentials; 109 this.browserOptions = { 110 headless: credentials.headless ?? true, 111 }; 112 113 this.server = new Server( 114 { 115 name: 'invoice-downloader-mcp', 116 version: '1.0.0', 117 }, 118 { 119 capabilities: { 120 tools: {}, 121 }, 122 } 123 ); 124 125 this.setupHandlers(); 126 } 127 128 private setupHandlers() { 129 // List available tools 130 this.server.setRequestHandler(ListToolsRequestSchema, async () => ({ 131 tools: TOOLS, 132 })); 133 134 // Handle tool calls 135 this.server.setRequestHandler(CallToolRequestSchema, async (request) => { 136 const { name, arguments: args } = request.params; 137 138 try { 139 switch (name) { 140 case 'list_platforms': 141 return this.handleListPlatforms(); 142 143 case 'list_invoices': { 144 const parsed = ListInvoicesSchema.parse(args); 145 return this.handleListInvoices(parsed.platform); 146 } 147 148 case 'download_invoice': { 149 const parsed = DownloadInvoiceSchema.parse(args); 150 return this.handleDownloadInvoice(parsed.platform, parsed.invoiceId); 151 } 152 153 case 'get_invoice_metadata': { 154 const parsed = GetMetadataSchema.parse(args); 155 return this.handleGetMetadata(parsed.platform, parsed.invoiceId); 156 } 157 158 default: 159 throw new Error(`Unknown tool: ${name}`); 160 } 161 } catch (error) { 162 logger.error(`Tool ${name} failed`, { error: String(error) }); 163 return { 164 content: [ 165 { 166 type: 'text', 167 text: JSON.stringify({ error: String(error) }), 168 }, 169 ], 170 isError: true, 171 }; 172 } 173 }); 174 } 175 176 private handleListPlatforms() { 177 const platforms = SUPPORTED_PLATFORMS.map((p) => ({ 178 name: p, 179 configured: !!this.credentials[p], 180 description: this.getPlatformDescription(p), 181 })); 182 183 return { 184 content: [ 185 { 186 type: 'text', 187 text: JSON.stringify({ platforms }, null, 2), 188 }, 189 ], 190 }; 191 } 192 193 private getPlatformDescription(platform: Platform): string { 194 const descriptions: Record<Platform, string> = { 195 vercel: 'Vercel - Frontend cloud platform', 196 digitalocean: 'DigitalOcean - Cloud infrastructure provider', 197 railway: 'Railway - Modern deployment platform', 198 }; 199 return descriptions[platform]; 200 } 201 202 private async handleListInvoices(platform: Platform) { 203 const creds = this.credentials[platform]; 204 if (!creds) { 205 throw new Error(`No credentials configured for ${platform}. Please provide credentials in Actor input.`); 206 } 207 208 const handler = createPlatformHandler(platform, this.browserOptions); 209 210 try { 211 const loggedIn = await handler.login(creds); 212 if (!loggedIn) { 213 throw new Error(`Failed to login to ${platform}`); 214 } 215 216 const invoices = await handler.listInvoices(); 217 218 // Cache invoices for later metadata lookups 219 this.invoiceCache.set(platform, invoices); 220 221 // Charge for listing 222 await Actor.charge({ eventName: 'invoice-listed' }); 223 224 // Push to dataset 225 await Actor.pushData({ 226 action: 'list_invoices', 227 platform, 228 invoices, 229 fetchedAt: new Date().toISOString(), 230 }); 231 232 return { 233 content: [ 234 { 235 type: 'text', 236 text: JSON.stringify({ 237 platform, 238 totalInvoices: invoices.length, 239 invoices, 240 }, null, 2), 241 }, 242 ], 243 }; 244 } finally { 245 await handler.close(); 246 } 247 } 248 249 private async handleDownloadInvoice(platform: Platform, invoiceId: string) { 250 const creds = this.credentials[platform]; 251 if (!creds) { 252 throw new Error(`No credentials configured for ${platform}`); 253 } 254 255 const handler = createPlatformHandler(platform, this.browserOptions); 256 257 try { 258 const loggedIn = await handler.login(creds); 259 if (!loggedIn) { 260 throw new Error(`Failed to login to ${platform}`); 261 } 262 263 const pdfBuffer = await handler.downloadInvoice(invoiceId); 264 265 // Store PDF in key-value store 266 const key = `${platform}-${invoiceId}.pdf`; 267 const store = await Actor.openKeyValueStore(); 268 await store.setValue(key, pdfBuffer, { contentType: 'application/pdf' }); 269 270 // Get public URL using store ID (available on the store object) 271 const storeId = (store as any).id || 'default'; 272 const pdfUrl = `https://api.apify.com/v2/key-value-stores/${storeId}/records/${key}`; 273 274 // Charge for download 275 await Actor.charge({ eventName: 'invoice-downloaded' }); 276 277 // Get cached metadata if available 278 const cachedInvoices = this.invoiceCache.get(platform); 279 const invoiceMeta = cachedInvoices?.find(i => i.id === invoiceId); 280 281 const result: InvoiceWithPdf = { 282 id: invoiceId, 283 platform, 284 date: invoiceMeta?.date || new Date().toISOString(), 285 amount: invoiceMeta?.amount || 0, 286 currency: invoiceMeta?.currency || 'USD', 287 status: invoiceMeta?.status || 'unknown', 288 pdfUrl, 289 downloadedAt: new Date().toISOString(), 290 }; 291 292 // Push to dataset 293 await Actor.pushData({ 294 action: 'download_invoice', 295 ...result, 296 }); 297 298 return { 299 content: [ 300 { 301 type: 'text', 302 text: JSON.stringify(result, null, 2), 303 }, 304 ], 305 }; 306 } finally { 307 await handler.close(); 308 } 309 } 310 311 private async handleGetMetadata(platform: Platform, invoiceId: string) { 312 // First check cache 313 const cached = this.invoiceCache.get(platform); 314 const cachedInvoice = cached?.find(i => i.id === invoiceId); 315 316 if (cachedInvoice) { 317 return { 318 content: [ 319 { 320 type: 'text', 321 text: JSON.stringify(cachedInvoice, null, 2), 322 }, 323 ], 324 }; 325 } 326 327 // If not cached, need to fetch list first 328 const creds = this.credentials[platform]; 329 if (!creds) { 330 throw new Error(`No credentials configured for ${platform}`); 331 } 332 333 const handler = createPlatformHandler(platform, this.browserOptions); 334 335 try { 336 const loggedIn = await handler.login(creds); 337 if (!loggedIn) { 338 throw new Error(`Failed to login to ${platform}`); 339 } 340 341 const invoices = await handler.listInvoices(); 342 this.invoiceCache.set(platform, invoices); 343 344 const invoice = invoices.find(i => i.id === invoiceId); 345 if (!invoice) { 346 throw new Error(`Invoice ${invoiceId} not found on ${platform}`); 347 } 348 349 return { 350 content: [ 351 { 352 type: 'text', 353 text: JSON.stringify(invoice, null, 2), 354 }, 355 ], 356 }; 357 } finally { 358 await handler.close(); 359 } 360 } 361 362 async run() { 363 const transport = new StdioServerTransport(); 364 await this.server.connect(transport); 365 logger.info('Invoice Downloader MCP Server running'); 366 } 367 368 async close() { 369 await closeBrowser(); 370 await this.server.close(); 371 } 372}

1/** 2 * Type definitions for Invoice Downloader MCP Server 3 */ 4 5export type Platform = 'vercel' | 'digitalocean' | 'railway'; 6 7export interface Credentials { 8 email: string; 9 password: string; 10 teamSlug?: string; 11 teamId?: string; 12} 13 14export interface PlatformCredentials { 15 vercel?: Credentials; 16 digitalocean?: Credentials; 17 railway?: Credentials; 18} 19 20export interface ActorInput { 21 vercel?: Credentials; 22 digitalocean?: Credentials; 23 railway?: Credentials; 24 headless?: boolean; 25 proxyConfiguration?: { 26 useApifyProxy?: boolean; 27 proxyUrls?: string[]; 28 }; 29} 30 31export interface Invoice { 32 id: string; 33 platform: Platform; 34 date: string; 35 period?: string; 36 amount: number; 37 currency: string; 38 status: 'paid' | 'pending' | 'overdue' | 'unknown'; 39 description?: string; 40} 41 42export interface InvoiceWithPdf extends Invoice { 43 pdfUrl?: string; 44 pdfBuffer?: Buffer; 45 downloadedAt: string; 46} 47 48export interface InvoiceListResult { 49 platform: Platform; 50 invoices: Invoice[]; 51 totalCount: number; 52 fetchedAt: string; 53} 54 55export interface DownloadResult { 56 success: boolean; 57 invoice?: InvoiceWithPdf; 58 error?: string; 59} 60 61export interface PlatformHandler { 62 platform: Platform; 63 login(credentials: Credentials): Promise<boolean>; 64 listInvoices(): Promise<Invoice[]>; 65 downloadInvoice(invoiceId: string): Promise<Buffer>; 66 close(): Promise<void>; 67}

1/** 2 * Browser management utilities for Playwright 3 */ 4 5import { chromium, Browser, BrowserContext, Page } from 'playwright'; 6import { logger } from './logger.js'; 7 8export interface BrowserOptions { 9 headless?: boolean; 10 proxy?: { 11 server: string; 12 username?: string; 13 password?: string; 14 }; 15} 16 17let browserInstance: Browser | null = null; 18 19export async function getBrowser(options: BrowserOptions = {}): Promise<Browser> { 20 if (browserInstance && browserInstance.isConnected()) { 21 return browserInstance; 22 } 23 24 logger.info('Launching browser', { headless: options.headless ?? true }); 25 26 browserInstance = await chromium.launch({ 27 headless: options.headless ?? true, 28 args: [ 29 '--no-sandbox', 30 '--disable-setuid-sandbox', 31 '--disable-dev-shm-usage', 32 ], 33 }); 34 35 return browserInstance; 36} 37 38export async function createContext(browser: Browser, options: BrowserOptions = {}): Promise<BrowserContext> { 39 const contextOptions: Parameters<Browser['newContext']>[0] = { 40 viewport: { width: 1280, height: 720 }, 41 userAgent: 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36', 42 locale: 'en-US', 43 timezoneId: 'America/New_York', 44 }; 45 46 if (options.proxy) { 47 contextOptions.proxy = options.proxy; 48 } 49 50 return browser.newContext(contextOptions); 51} 52 53export async function closeBrowser(): Promise<void> { 54 if (browserInstance) { 55 await browserInstance.close(); 56 browserInstance = null; 57 logger.info('Browser closed'); 58 } 59} 60 61/** 62 * Wait for navigation with timeout 63 */ 64export async function waitForNavigation(page: Page, timeout = 30000): Promise<void> { 65 await page.waitForLoadState('networkidle', { timeout }); 66} 67 68/** 69 * Safe click with wait for element 70 */ 71export async function safeClick(page: Page, selector: string, timeout = 10000): Promise<void> { 72 await page.waitForSelector(selector, { timeout }); 73 await page.click(selector); 74} 75 76/** 77 * Safe type with wait for element 78 */ 79export async function safeType(page: Page, selector: string, text: string, timeout = 10000): Promise<void> { 80 await page.waitForSelector(selector, { timeout }); 81 await page.fill(selector, text); 82} 83 84/** 85 * Download file and return buffer 86 */ 87export async function downloadFile(page: Page, clickSelector: string): Promise<Buffer> { 88 const [download] = await Promise.all([ 89 page.waitForEvent('download', { timeout: 30000 }), 90 page.click(clickSelector), 91 ]); 92 93 const buffer = await download.createReadStream().then(stream => { 94 const chunks: Buffer[] = []; 95 return new Promise<Buffer>((resolve, reject) => { 96 stream.on('data', chunk => chunks.push(Buffer.from(chunk))); 97 stream.on('end', () => resolve(Buffer.concat(chunks))); 98 stream.on('error', reject); 99 }); 100 }); 101 102 return buffer; 103}

1/** 2 * Secure logging utility - never logs sensitive data 3 */ 4 5import { log } from 'apify'; 6 7const SENSITIVE_KEYS = ['password', 'token', 'secret', 'key', 'credential', 'auth']; 8 9function sanitize(obj: unknown): unknown { 10 if (typeof obj !== 'object' || obj === null) { 11 return obj; 12 } 13 14 if (Array.isArray(obj)) { 15 return obj.map(sanitize); 16 } 17 18 const sanitized: Record<string, unknown> = {}; 19 for (const [key, value] of Object.entries(obj)) { 20 const lowerKey = key.toLowerCase(); 21 if (SENSITIVE_KEYS.some(k => lowerKey.includes(k))) { 22 sanitized[key] = '[REDACTED]'; 23 } else if (typeof value === 'object') { 24 sanitized[key] = sanitize(value); 25 } else { 26 sanitized[key] = value; 27 } 28 } 29 return sanitized; 30} 31 32export const logger = { 33 info(message: string, data?: Record<string, unknown>) { 34 log.info(message, data ? sanitize(data) as Record<string, unknown> : undefined); 35 }, 36 37 warn(message: string, data?: Record<string, unknown>) { 38 log.warning(message, data ? sanitize(data) as Record<string, unknown> : undefined); 39 }, 40 41 error(message: string, data?: Record<string, unknown>) { 42 log.error(message, data ? sanitize(data) as Record<string, unknown> : undefined); 43 }, 44 45 debug(message: string, data?: Record<string, unknown>) { 46 log.debug(message, data ? sanitize(data) as Record<string, unknown> : undefined); 47 }, 48};

{ "compilerOptions": { "target": "ES2022", "module": "ESNext", "moduleResolution": "bundler", "lib": ["ES2022"], "outDir": "dist", "rootDir": "src", "strict": true, "esModuleInterop": true, "skipLibCheck": true, "forceConsistentCasingInFileNames": true, "resolveJsonModule": true, "declaration": true }, "include": ["src/**/*"], "exclude": ["node_modules", "dist"] }

Invoice Downloader MCP Server

Invoice Downloader MCP Server

Web Search MCP Server

Time MCP Server

Firecrawl MCP Server

Invoice Collector MCP

TextFormatter MCP Server

LinkedIn MCP Server - AI Assistant

Excel Mcp Server

GitHub MCP Server 🐙 - AI Agent Connector

Playwright MCP Server

Mindmap MCP Server

.actor/INPUT_SCHEMA.json

.actor/actor.json

.actor/pay_per_event.json

.gitignore

.nvmrc

Dockerfile

check-build.mjs

get-build-log.mjs

package.json

src/main.ts

src/platforms/digitalocean.ts

src/platforms/index.ts

src/platforms/railway.ts

src/platforms/vercel.ts

src/server.ts

src/types.ts

src/utils/browser.ts

src/utils/logger.ts

tsconfig.json

Invoice Downloader MCP Server

Invoice Downloader MCP Server

You might also like

Web Search MCP Server

Time MCP Server

Firecrawl MCP Server

Invoice Collector MCP

TextFormatter MCP Server

LinkedIn MCP Server - AI Assistant

Excel Mcp Server

GitHub MCP Server 🐙 - AI Agent Connector

Playwright MCP Server

Mindmap MCP Server

.actor/INPUT_SCHEMA.json

.actor/actor.json

.actor/pay_per_event.json

.gitignore

.nvmrc

Dockerfile

check-build.mjs

get-build-log.mjs

package.json

src/main.ts

src/platforms/digitalocean.ts

src/platforms/index.ts

src/platforms/railway.ts

src/platforms/vercel.ts

src/server.ts

src/types.ts

src/utils/browser.ts

src/utils/logger.ts

tsconfig.json