Platform

use Fusio\Worker;
use Fusio\Engine;

return function(Worker\ExecuteRequest $request, Worker\ExecuteContext $context, Engine\ConnectorInterface $connector, Engine\Response\FactoryInterface $response, Engine\DispatcherInterface $dispatcher, LoggerInterface $logger) {
    $connection = $connector->getConnection('my_database');

    // @TODO implement my API endpoint logic

    return $response->build(200, [], [
        'hello' => 'world',
    ]);
};

module.exports = async function(request, context, connector, response, dispatcher, logger) {
    const connection = await connector.getConnection('my_database');

    // @TODO implement my API endpoint logic

    return response.build(200, {}, {
        hello: 'world'
    });
};

def handle(request, context, connector, response, dispatcher, logger):
    connection = connector.get_connection('my_database')

    # @TODO implement my API endpoint logic

    return response.build(200, None, {
        'hello': 'world'
    })

import org.fusioproject.worker.runtime.*;

def handle(ExecuteRequest request, ExecuteContext context, Connector connector, ResponseBuilder response, Dispatcher dispatcher, Logger logger) {
    def connection = connector.getConnection("my_database");

    // @TODO implement my API endpoint logic

    return res.build(200, [:], [
        hello: "world"
    ]);
}