Function createVariable

packages/server/src/services/variables/index.ts:11–33

(newVariable: Variable, orgId: string)

import { Platform } from '../../Interface'

const createVariable = async (newVariable: Variable, orgId: string) => {
    const appServer = getRunningExpressApp()
    if (appServer.identityManager.getPlatformType() === Platform.CLOUD && newVariable.type === 'runtime')
        throw new InternalFlowiseError(StatusCodes.BAD_REQUEST, 'Cloud platform does not support runtime variables!')
    try {
        const variable = await appServer.AppDataSource.getRepository(Variable).create(newVariable)
        const dbResponse = await appServer.AppDataSource.getRepository(Variable).save(variable)
        await appServer.telemetry.sendTelemetry(
            'variable_created',
            {
                version: await getAppVersion(),
                variableType: variable.type
            },
            orgId
        )
        return dbResponse
    } catch (error) {
        throw new InternalFlowiseError(
            StatusCodes.INTERNAL_SERVER_ERROR,
            `Error: variablesServices.createVariable - ${getErrorMessage(error)}`
        )
    }
}

const deleteVariable = async (variableId: string, workspaceId: string): Promise<any> => {
    try {