Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 23 additions & 0 deletions packages/components/credentials/EUrouterApi.credential.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
import { INodeCredential, INodeParams } from '../src/Interface'

class EUrouterApi implements INodeCredential {
label: string
name: string
version: number
inputs: INodeParams[]

constructor() {
this.label = 'EUrouter API'
this.name = 'eUrouterApi'
this.version = 1.0
this.inputs = [
{
label: 'EUrouter API Key',
name: 'eUrouterApiKey',
type: 'password'
}
]
}
}

module.exports = { credClass: EUrouterApi }
181 changes: 181 additions & 0 deletions packages/components/nodes/chatmodels/ChatEUrouter/ChatEUrouter.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,181 @@
import { BaseCache } from '@langchain/core/caches'
import { ChatOpenAI, ChatOpenAIFields } from '@langchain/openai'
import { ICommonObject, INode, INodeData, INodeParams } from '../../../src/Interface'
import { getBaseClasses, getCredentialData, getCredentialParam } from '../../../src/utils'

class ChatEUrouter_ChatModels implements INode {
readonly baseURL: string = 'https://api.eurouter.ai/api/v1'
label: string
name: string
version: number
type: string
icon: string
category: string
description: string
baseClasses: string[]
credential: INodeParams
inputs: INodeParams[]

constructor() {
this.label = 'EUrouter'
this.name = 'chatEUrouter'
this.version = 1.0
this.type = 'ChatEUrouter'
this.icon = 'eurouter.svg'
this.category = 'Chat Models'
this.description = 'EU-hosted, GDPR-friendly AI gateway with access to 68+ models via OpenAI-compatible API'
this.baseClasses = [this.type, ...getBaseClasses(ChatOpenAI)]
this.credential = {
label: 'Connect Credential',
name: 'credential',
type: 'credential',
credentialNames: ['eUrouterApi']
}
this.inputs = [
{
label: 'Cache',
name: 'cache',
type: 'BaseCache',
optional: true
},
{
label: 'Model Name',
name: 'modelName',
type: 'string',
default: 'claude-sonnet-4-6',
description:
'Enter the model name (e.g., claude-sonnet-4-6, claude-opus-4-6, deepseek-r1, mistral-large-3). See https://www.eurouter.ai/models for the full catalog.'
},
{
label: 'Temperature',
name: 'temperature',
type: 'number',
step: 0.1,
default: 0.7,
optional: true
},
{
label: 'Streaming',
name: 'streaming',
type: 'boolean',
default: true,
optional: true,
additionalParams: true
},
{
label: 'Max Tokens',
name: 'maxTokens',
type: 'number',
step: 1,
optional: true,
additionalParams: true
},
{
label: 'Top Probability',
name: 'topP',
type: 'number',
step: 0.1,
optional: true,
additionalParams: true
},
{
label: 'Frequency Penalty',
name: 'frequencyPenalty',
type: 'number',
step: 0.1,
optional: true,
additionalParams: true
},
{
label: 'Presence Penalty',
name: 'presencePenalty',
type: 'number',
step: 0.1,
optional: true,
additionalParams: true
},
{
label: 'Base Options',
name: 'baseOptions',
type: 'json',
optional: true,
additionalParams: true,
description: 'Additional options to pass to the EUrouter client. This should be a JSON object.'
}
]
}

async init(nodeData: INodeData, _: string, options: ICommonObject): Promise<any> {
const temperature = nodeData.inputs?.temperature as string
const modelName = nodeData.inputs?.modelName as string
const maxTokens = nodeData.inputs?.maxTokens as string
const topP = nodeData.inputs?.topP as string
const frequencyPenalty = nodeData.inputs?.frequencyPenalty as string
const presencePenalty = nodeData.inputs?.presencePenalty as string
const streaming = nodeData.inputs?.streaming as boolean
const baseOptions = nodeData.inputs?.baseOptions

if (nodeData.inputs?.credentialId) {
nodeData.credential = nodeData.inputs?.credentialId
}
const credentialData = await getCredentialData(nodeData.credential ?? '', options)
const openAIApiKey = getCredentialParam('eUrouterApiKey', credentialData, nodeData)

if (!openAIApiKey || openAIApiKey.trim() === '') {
throw new Error(
'EUrouter API Key is missing or empty. Please provide a valid EUrouter API key in the credential configuration.'
)
}

if (!modelName || modelName.trim() === '') {
throw new Error(
'Model Name is required. Please enter a valid model name (e.g., claude-sonnet-4-6, claude-opus-4-6, deepseek-r1).'
)
}

const cache = nodeData.inputs?.cache as BaseCache

const obj: ChatOpenAIFields = {
temperature: parseFloat(temperature),
modelName,
openAIApiKey,
apiKey: openAIApiKey,
streaming: streaming ?? true
}

if (maxTokens) obj.maxTokens = parseInt(maxTokens, 10)
Comment thread
DavidLoDico marked this conversation as resolved.
if (topP) obj.topP = parseFloat(topP)
if (frequencyPenalty) obj.frequencyPenalty = parseFloat(frequencyPenalty)
if (presencePenalty) obj.presencePenalty = parseFloat(presencePenalty)
if (cache) obj.cache = cache

let parsedBaseOptions: any | undefined = undefined

if (baseOptions) {
try {
parsedBaseOptions = typeof baseOptions === 'object' ? baseOptions : JSON.parse(baseOptions)
if (parsedBaseOptions.baseURL) {
console.warn("The 'baseURL' parameter is not allowed when using the ChatEUrouter node.")
delete parsedBaseOptions.baseURL
}
Comment thread
DavidLoDico marked this conversation as resolved.
} catch (exception) {
throw new Error('Invalid JSON in the BaseOptions: ' + exception)
}
}

const model = new ChatOpenAI({
...obj,
configuration: {
baseURL: this.baseURL,
defaultHeaders: {
'HTTP-Referer': 'https://flowiseai.com',
'X-EUrouter-Title': 'Flowise',
},
...parsedBaseOptions
}
})
return model
}
}

module.exports = { nodeClass: ChatEUrouter_ChatModels }
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
3 changes: 2 additions & 1 deletion packages/server/src/utils/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1489,7 +1489,8 @@ export const isFlowValidForStream = (reactFlowNodes: IReactFlowNode[], endingNod
'chatFireworks',
'ChatSambanova',
'chatBaiduWenxin',
'chatCometAPI'
'chatCometAPI',
'chatEUrouter'
],
LLMs: ['azureOpenAI', 'openAI', 'ollama']
}
Expand Down