diff --git a/packages/components/credentials/DeepseekApi.credential.ts b/packages/components/credentials/DeepseekApi.credential.ts new file mode 100644 index 00000000000..8b8999a8666 --- /dev/null +++ b/packages/components/credentials/DeepseekApi.credential.ts @@ -0,0 +1,23 @@ +import { INodeCredential, INodeParams } from '../src/Interface' + +class DeepseekApi implements INodeCredential { + label: string + name: string + version: number + inputs: INodeParams[] + + constructor() { + this.label = 'DeepseekAI API' + this.name = 'deepseekApi' + this.version = 1.0 + this.inputs = [ + { + label: 'DeepseekAI API Key', + name: 'deepseekApiKey', + type: 'password' + } + ] + } +} + +module.exports = { credClass: DeepseekApi } diff --git a/packages/components/models.json b/packages/components/models.json index f48efba9e0f..5e03a86ca6d 100644 --- a/packages/components/models.json +++ b/packages/components/models.json @@ -572,6 +572,19 @@ } ] }, + { + "name": "deepseek", + "models": [ + { + "label": "deepseek-chat", + "name": "deepseek-chat" + }, + { + "label": "deepseek-coder", + "name": "deepseek-coder" + } + ] + }, { "name": "chatOpenAI", "models": [ diff --git a/packages/components/nodes/chatmodels/Deepseek/Deepseek.ts b/packages/components/nodes/chatmodels/Deepseek/Deepseek.ts new file mode 100644 index 00000000000..d65f3732a55 --- /dev/null +++ b/packages/components/nodes/chatmodels/Deepseek/Deepseek.ts @@ -0,0 +1,197 @@ +import { BaseCache } from '@langchain/core/caches' +import { BaseChatModelParams } from '@langchain/core/language_models/chat_models' +import { ChatOpenAI, LegacyOpenAIInput, OpenAIChatInput } from '@langchain/openai' +import type { ClientOptions } from 'openai' +import { ICommonObject, INode, INodeData, INodeOptionsValue, INodeParams } from '../../../src/Interface' +import { getModels, MODEL_TYPE } from '../../../src/modelLoader' +import { getBaseClasses, getCredentialData, getCredentialParam } from '../../../src/utils' + +class Deepseek_ChatModels implements INode { + readonly baseURL: string = 'https://api.deepseek.com' + label: string + name: string + version: number + type: string + icon: string + category: string + description: string + baseClasses: string[] + credential: INodeParams + inputs: INodeParams[] + + constructor() { + this.label = 'ChatDeepseek' + this.name = 'chatDeepseek' + this.version = 1.0 + this.type = 'chatDeepseek' + this.icon = 'deepseek.svg' + this.category = 'Chat Models' + this.description = 'Wrapper around Deepseek large language models that use the Chat endpoint' + this.baseClasses = [this.type, ...getBaseClasses(ChatOpenAI)] + this.credential = { + label: 'Connect Credential', + name: 'credential', + type: 'credential', + credentialNames: ['deepseekApi'] + } + this.inputs = [ + { + label: 'Cache', + name: 'cache', + type: 'BaseCache', + optional: true + }, + { + label: 'Model Name', + name: 'modelName', + type: 'asyncOptions', + loadMethod: 'listModels', + default: 'deepseek-chat' + }, + { + 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: 'Timeout', + name: 'timeout', + type: 'number', + step: 1, + optional: true, + additionalParams: true + }, + { + label: 'Stop Sequence', + name: 'stopSequence', + type: 'string', + rows: 4, + optional: true, + description: 'List of stop words to use when generating. Use comma to separate multiple stop words.', + additionalParams: true + }, + { + label: 'Base Options', + name: 'baseOptions', + type: 'json', + optional: true, + additionalParams: true, + description: 'Additional options to pass to the Deepseek client. This should be a JSON object.' + } + ] + } + + //@ts-ignore + loadMethods = { + async listModels(): Promise { + return await getModels(MODEL_TYPE.CHAT, 'deepseek') + } + } + + async init(nodeData: INodeData, _: string, options: ICommonObject): Promise { + 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 timeout = nodeData.inputs?.timeout as string + const stopSequence = nodeData.inputs?.stopSequence 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('deepseekApiKey', credentialData, nodeData) + + const cache = nodeData.inputs?.cache as BaseCache + + const obj: Partial & BaseChatModelParams & { configuration?: ClientOptions & LegacyOpenAIInput } = { + temperature: parseFloat(temperature), + modelName, + openAIApiKey, + streaming: streaming ?? true + } + + if (maxTokens) obj.maxTokens = parseInt(maxTokens, 10) + if (topP) obj.topP = parseFloat(topP) + if (frequencyPenalty) obj.frequencyPenalty = parseFloat(frequencyPenalty) + if (presencePenalty) obj.presencePenalty = parseFloat(presencePenalty) + if (timeout) obj.timeout = parseInt(timeout, 10) + if (cache) obj.cache = cache + if (stopSequence) { + const stopSequenceArray = stopSequence.split(',').map((item) => item.trim()) + obj.stop = stopSequenceArray + } + + 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 ChatDeepseek node.") + parsedBaseOptions.baseURL = undefined + } + } catch (exception) { + throw new Error('Invalid JSON in the BaseOptions: ' + exception) + } + } + + const model = new ChatOpenAI({ + ...obj, + configuration: { + baseURL: this.baseURL, + ...parsedBaseOptions + } + }) + return model + } +} + +module.exports = { nodeClass: Deepseek_ChatModels } diff --git a/packages/components/nodes/chatmodels/Deepseek/deepseek.svg b/packages/components/nodes/chatmodels/Deepseek/deepseek.svg new file mode 100644 index 00000000000..a20f65c1a3e --- /dev/null +++ b/packages/components/nodes/chatmodels/Deepseek/deepseek.svg @@ -0,0 +1,30 @@ + + + + + + + +