//native
type Personio = {
clientId: string
clientSecret: string
}
type Base64 = string
/**
* Upload Document
* This endpoint is responsible for uploading documents for the company employees.
The Documents endpoint has a rate limit of 60 requests per minute.
*/
export async function main(
auth: Personio,
body: {
title: string
comment?: string
employee_id: number
category_id: number
date?: string
file: {
base64: Base64
type:
| 'image/png'
| 'image/jpeg'
| 'image/gif'
| 'application/pdf'
| 'appication/json'
| 'text/csv'
| 'text/plain'
| 'audio/mpeg'
| 'audio/wav'
| 'video/mp4'
name: string
}
},
X_Personio_Partner_ID?: string,
X_Personio_App_ID?: string
) {
const url = new URL(`https://api.personio.de/v1/company/documents`)
const formData = new FormData()
for (const [k, v] of Object.entries(body)) {
if (v !== undefined && v !== '') {
if (['file'].includes(k)) {
const { base64, type, name } = v as {
base64: Base64
type: string
name: string
}
formData.append(
k,
new Blob([Uint8Array.from(atob(base64), (m) => m.codePointAt(0)!)], {
type
}),
name
)
} else {
formData.append(k, String(v))
}
}
}
const response = await fetch(url, {
method: 'POST',
headers: {
...(X_Personio_Partner_ID ? { 'X-Personio-Partner-ID': X_Personio_Partner_ID } : {}),
...(X_Personio_App_ID ? { 'X-Personio-App-ID': X_Personio_App_ID } : {}),
Authorization: 'Bearer ' + (await getOAuthToken(auth, 'https://api.personio.de/oauth2/token'))
},
body: formData
})
if (!response.ok) {
const text = await response.text()
throw new Error(`${response.status} ${text}`)
}
return await response.json()
}
async function getOAuthToken(auth: Personio, tokenUrl: string): Promise<string> {
const params = new URLSearchParams({
grant_type: 'client_credentials',
client_id: auth.clientId,
client_secret: auth.clientSecret
})
const response = await fetch(tokenUrl, {
method: 'POST',
headers: {
Authorization: 'Basic ' + btoa(`${auth.clientId}:${auth.clientSecret}`),
'Content-Type': 'application/x-www-form-urlencoded'
},
body: params.toString()
})
if (!response.ok) {
const text = await response.text()
throw new Error(`OAuth token request failed: ${response.status} ${text}`)
}
const data = await response.json()
return data.access_token
}
Submitted by hugo697 235 days ago