Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions apps/docs/components/icons.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -1643,6 +1643,17 @@ export function RB2BIcon(props: SVGProps<SVGSVGElement>) {
)
}

export function RampIcon(props: SVGProps<SVGSVGElement>) {
return (
<svg {...props} xmlns='http://www.w3.org/2000/svg' viewBox='0 0 69.5 59'>
<path
d='M69.5,58.7V59l-37.9,0v-0.3c5.5-3.1,9.2-6.2,12.6-9.5h15.6L69.5,58.7z M60.2,9.4L50.6,0h-0.3c0,0,0.2,17.5-16,33.5 C18.5,49.1,0,49.2,0,49.2v0.3L9.8,59c0,0,18.3,0.2,34.4-15.7C60.3,27.6,60.2,9.4,60.2,9.4z'
fill='currentColor'
/>
</svg>
)
}

export function RedditIcon(props: SVGProps<SVGSVGElement>) {
return (
<svg
Expand Down
2 changes: 2 additions & 0 deletions apps/docs/components/ui/icon-mapping.ts
Original file line number Diff line number Diff line change
Expand Up @@ -158,6 +158,7 @@ import {
QdrantIcon,
QuiverIcon,
RailwayIcon,
RampIcon,
RB2BIcon,
RDSIcon,
RedditIcon,
Expand Down Expand Up @@ -397,6 +398,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
qdrant: QdrantIcon,
quiver: QuiverIcon,
railway: RailwayIcon,
ramp: RampIcon,
rb2b: RB2BIcon,
rds: RDSIcon,
reddit: RedditIcon,
Expand Down
1 change: 1 addition & 0 deletions apps/docs/content/docs/en/integrations/meta.json
Original file line number Diff line number Diff line change
Expand Up @@ -158,6 +158,7 @@
"qdrant",
"quiver",
"railway",
"ramp",
"rb2b",
"rds",
"reddit",
Expand Down
649 changes: 649 additions & 0 deletions apps/docs/content/docs/en/integrations/ramp.mdx

Large diffs are not rendered by default.

141 changes: 141 additions & 0 deletions apps/sim/app/api/tools/ramp/upload-receipt/route.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,141 @@
import { createLogger } from '@sim/logger'
import { getErrorMessage } from '@sim/utils/errors'
import { generateId } from '@sim/utils/id'
import { type NextRequest, NextResponse } from 'next/server'
import { rampUploadReceiptContract } from '@/lib/api/contracts/tools/ramp'
import { parseRequest } from '@/lib/api/server'
import { checkInternalAuth } from '@/lib/auth/hybrid'
import { generateRequestId } from '@/lib/core/utils/request'
import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
import { processFilesToUserFiles, type RawFileInput } from '@/lib/uploads/utils/file-utils'
import { downloadFileFromStorage } from '@/lib/uploads/utils/file-utils.server'
import { assertToolFileAccess } from '@/app/api/files/authorization'
import { extractRampError } from '@/tools/ramp/utils'

export const dynamic = 'force-dynamic'

const logger = createLogger('RampUploadReceiptAPI')

const RAMP_RECEIPTS_URL = 'https://api.ramp.com/developer/v1/receipts'

/**
* Builds the multipart body for Ramp's receipt upload endpoint. Ramp expects
* metadata parts with `Content-Disposition: form-data` and the receipt image
* as a part named `receipt` with `Content-Disposition: attachment`.
*/
function buildReceiptMultipartBody(
boundary: string,
fields: Record<string, string>,
file: { name: string; type: string; buffer: Buffer }
): Buffer {
const parts: Buffer[] = []

for (const [name, value] of Object.entries(fields)) {
const safeValue = value.replace(/[\r\n]/g, '')
parts.push(
Buffer.from(
`--${boundary}\r\nContent-Disposition: form-data; name="${name}"\r\n\r\n${safeValue}\r\n`
)
)
}
Comment thread
waleedlatif1 marked this conversation as resolved.

const safeFileName = file.name.replace(/[\r\n"]/g, '_')
const safeContentType = file.type.replace(/[\r\n]/g, '') || 'application/octet-stream'
parts.push(
Buffer.from(
`--${boundary}\r\nContent-Disposition: attachment; name="receipt"; filename="${safeFileName}"\r\nContent-Type: ${safeContentType}\r\n\r\n`
)
)
parts.push(file.buffer)
parts.push(Buffer.from(`\r\n--${boundary}--\r\n`))

return Buffer.concat(parts)
}

export const POST = withRouteHandler(async (request: NextRequest) => {
const requestId = generateRequestId()

try {
const authResult = await checkInternalAuth(request, { requireWorkflowId: false })

if (!authResult.success || !authResult.userId) {
logger.warn(`[${requestId}] Unauthorized Ramp receipt upload attempt: ${authResult.error}`)
return NextResponse.json(
{ success: false, error: authResult.error || 'Authentication required' },
{ status: 401 }
)
}

const parsed = await parseRequest(rampUploadReceiptContract, request, {})
if (!parsed.success) return parsed.response
const validatedData = parsed.data.body

const userFiles = processFilesToUserFiles(
[validatedData.file as RawFileInput],
requestId,
logger
)

if (userFiles.length === 0) {
return NextResponse.json({ success: false, error: 'Invalid file input' }, { status: 400 })
}

const userFile = userFiles[0]
logger.info(
`[${requestId}] Downloading receipt file: ${userFile.name} (${userFile.size} bytes)`
)

const denied = await assertToolFileAccess(userFile.key, authResult.userId, requestId, logger)
if (denied) return denied
const fileBuffer = await downloadFileFromStorage(userFile, requestId, logger)

const fields: Record<string, string> = {
idempotency_key: generateId(),
user_id: validatedData.userId,
}
if (validatedData.transactionId) {
fields.transaction_id = validatedData.transactionId
}

const boundary = `----sim-ramp-receipt-${generateId()}`
const body = buildReceiptMultipartBody(boundary, fields, {
name: userFile.name,
type: userFile.type || 'application/octet-stream',
buffer: fileBuffer,
})

logger.info(`[${requestId}] Uploading receipt to Ramp (${fileBuffer.length} bytes)`)

const response = await fetch(RAMP_RECEIPTS_URL, {
method: 'POST',
headers: {
Authorization: `Bearer ${validatedData.accessToken}`,
'Content-Type': `multipart/form-data; boundary=${boundary}`,
},
body: new Uint8Array(body),
})

const data = await response.json().catch(() => ({}))

if (!response.ok) {
const errorMessage = extractRampError(data, 'Failed to upload receipt to Ramp')
logger.error(`[${requestId}] Ramp API error:`, { status: response.status, data })
return NextResponse.json({ success: false, error: errorMessage }, { status: response.status })
}

logger.info(`[${requestId}] Receipt uploaded successfully: ${data.id}`)

return NextResponse.json({
success: true,
output: {
receiptId: data.id,
},
})
} catch (error) {
logger.error(`[${requestId}] Unexpected error:`, error)
return NextResponse.json(
{ success: false, error: getErrorMessage(error, 'Unknown error') },
{ status: 500 }
)
}
})
Loading
Loading