Medplum

// SPDX-FileCopyrightText: Copyright Orangebot, Inc. and Medplum contributors // SPDX-License-Identifier: Apache-2.0 import type { WithId } from '@medplum/core'; import { ContentType, createReference, getReferenceString } from '@medplum/core'; import type { AccessPolicy, Binary, Bot, Project, ProjectMembership, Reference } from '@medplum/fhirtypes'; import type { Request, Response } from 'express'; import { body } from 'express-validator'; import { Readable } from 'node:stream'; import { getConfig } from '../config/loader'; import { getAuthenticatedContext } from '../context'; import type { Repository } from '../fhir/repo'; import { getSystemRepo } from '../fhir/repo'; import { getBinaryStorage } from '../storage/loader'; import { makeValidationMiddleware } from '../util/validator'; export const createBotValidator = makeValidationMiddleware([ body('name').notEmpty().withMessage('Bot name is required'), ]); const defaultBotCode = `import { BotEvent, MedplumClient } from '@medplum/core'; export async function handler(medplum: MedplumClient, event: BotEvent): Promise<any> { // Your code here } `; export async function createBotHandler(req: Request, res: Response): Promise<void> { const ctx = getAuthenticatedContext(); const bot = await createBot(ctx.repo, { ...req.body, project: ctx.project, }); res.status(201).json(bot); } export interface CreateBotRequest { readonly project: Project; readonly name: string; readonly description?: string; readonly accessPolicy?: Reference<AccessPolicy>; readonly runtimeVersion?: 'awslambda' | 'vmcontext'; } export async function createBot(repo: Repository, request: CreateBotRequest): Promise<WithId<Bot>> { const filename = 'index.ts'; const contentType = ContentType.TYPESCRIPT; const binary = await repo.createResource<Binary>({ resourceType: 'Binary', contentType, }); await getBinaryStorage().writeBinary(binary, filename, contentType, Readable.from(defaultBotCode)); const bot = await repo.createResource<Bot>({ meta: { project: request.project.id, }, resourceType: 'Bot', name: request.name, description: request.description, runtimeVersion: request.runtimeVersion ?? getConfig().defaultBotRuntimeVersion, sourceCode: { contentType, title: filename, url: getReferenceString(binary), }, }); const systemRepo = getSystemRepo(); await systemRepo.createResource<ProjectMembership>({ meta: { project: request.project.id, }, resourceType: 'ProjectMembership', project: createReference(request.project), user: createReference(bot), profile: createReference(bot), accessPolicy: request.accessPolicy, }); return bot; }