Scheduled cloud function

router.post('/database/events/create', async (req, res) => {
    const {eventName, service, startTime, endTime, destinations, autoSource} = req.body;

    if (!autoSource) return res.status(200).send({success: true});

    const capability = (await databases.listDocuments(process.env.APPWRITE_DATABASE_ID ?? '', process.env.APPWRITE_DATABASE_SERVICE ?? '')).documents.find((document) => document.serviceName === service)?.capability;
    if (!capability) return res.status(500).send({success: false, message: 'Invalid service'});

    const source = (await databases.listDocuments(process.env.APPWRITE_DATABASE_ID ?? '', process.env.APPWRITE_DATABASE_INPUT_DEFINITIONS ?? '')).documents.filter((document) => document.capabilities == capability && document.available == true)[0];
    if (!source) return res.status(500).send({success: false, message: 'Invalid source'});

    await functions.createExecution(
        process.env.APPWRITE_FUNCTIONS_SCHEDULER_ID ?? '',
        JSON.stringify(
            {
                destinations,
                source
            }
        ),
        false,
        '/',
        ExecutionMethod.POST,
        {
            "x-appwrite-request-signature": generateRequestSignature({destinations, source})
        },
        new Date(startTime).toISOString()
    )
        .then((res) => {
            logger.info(`Scheduled function execution for '${eventName}' at ${startTime} was created`);
            // TODO: Update TV Event Document in database to add executionId
            // await databases.updateDocument()
        })
        .catch((err) => logger.error(`Failed to create scheduled function execution for '${eventName}' -> ${err.message}`));

    res.status(200).send({success: true});
});