OpenAI

# Coreflux REST_API template — OpenAI
# Auth: Authorization Bearer {value.json.api_token}
# BASE_ADDRESS: https://api.openai.com

DEFINE ROUTE OpenAiRestApi WITH TYPE REST_API
    ADD REST_API_CONFIG
        WITH BASE_ADDRESS "https://api.openai.com"
        WITH ENABLE_CLIENT "true"
        WITH USE_SSL "true"
        WITH REQUEST_TIMEOUT '60'
        WITH DEFAULT_CONTENT_TYPE "application/json"
    ADD EVENT PostResponses
        WITH SOURCE_TOPIC "ai/openai/responses/post"
        WITH DESTINATION_TOPIC "ai/openai/responses/post/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/v1/responses"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"
        WITH BODY "{payload}"
    ADD EVENT PostEmbeddings
        WITH SOURCE_TOPIC "ai/openai/embeddings/post"
        WITH DESTINATION_TOPIC "ai/openai/embeddings/post/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/v1/embeddings"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"
        WITH BODY "{payload}"
    ADD EVENT PostChatCompletions
        WITH SOURCE_TOPIC "ai/openai/chat/completions/post"
        WITH DESTINATION_TOPIC "ai/openai/chat/completions/post/response"
        WITH METHOD "POST"
        WITH ENDPOINT "/v1/chat/completions"
        WITH HEADERS
            ADD "Accept" "application/json"
            ADD "Content-Type" "application/json"
            ADD "Authorization" "Bearer {value.json.api_token}"
        WITH BODY "{payload}"