From 05db5333968012abb18ea9e41c825c1e23b3f93f Mon Sep 17 00:00:00 2001
From: Henry <hzj94@hotmail.com>
Date: Fri, 15 Dec 2023 18:59:11 +0000
Subject: [PATCH 1/4] add mistral

---
 .../GoogleGenerativeAI.credential.ts          |   3 +-
 .../credentials/MistralApi.credential.ts      |  25 +++
 .../ChatGoogleGenerativeAI.ts                 |   3 +-
 .../chatmodels/ChatMistral/ChatMistral.ts     | 151 ++++++++++++++++++
 .../chatmodels/ChatMistral/mistralai.png      | Bin 0 -> 4542 bytes
 .../MistralEmbedding/MistralEmbedding.ts      |  95 +++++++++++
 .../embeddings/MistralEmbedding/mistralai.png | Bin 0 -> 4542 bytes
 packages/components/package.json              |   1 +
 packages/server/src/utils/index.ts            |   1 +
 9 files changed, 276 insertions(+), 3 deletions(-)
 create mode 100644 packages/components/credentials/MistralApi.credential.ts
 create mode 100644 packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
 create mode 100644 packages/components/nodes/chatmodels/ChatMistral/mistralai.png
 create mode 100644 packages/components/nodes/embeddings/MistralEmbedding/MistralEmbedding.ts
 create mode 100644 packages/components/nodes/embeddings/MistralEmbedding/mistralai.png

diff --git a/packages/components/credentials/GoogleGenerativeAI.credential.ts b/packages/components/credentials/GoogleGenerativeAI.credential.ts
index 9a1f3f28598..e5ad45bfa67 100644
--- a/packages/components/credentials/GoogleGenerativeAI.credential.ts
+++ b/packages/components/credentials/GoogleGenerativeAI.credential.ts
@@ -11,7 +11,8 @@ class GoogleGenerativeAICredential implements INodeCredential {
         this.label = 'Google Generative AI'
         this.name = 'googleGenerativeAI'
         this.version = 1.0
-        this.description = 'Get your <a target="_blank" href="https://ai.google.dev/tutorials/setup">API Key</a> here.'
+        this.description =
+            'You can get your API key from official <a target="_blank" href="https://ai.google.dev/tutorials/setup">page</a> here.'
         this.inputs = [
             {
                 label: 'Google AI API Key',
diff --git a/packages/components/credentials/MistralApi.credential.ts b/packages/components/credentials/MistralApi.credential.ts
new file mode 100644
index 00000000000..a254f6659b3
--- /dev/null
+++ b/packages/components/credentials/MistralApi.credential.ts
@@ -0,0 +1,25 @@
+import { INodeParams, INodeCredential } from '../src/Interface'
+
+class MistralAICredential implements INodeCredential {
+    label: string
+    name: string
+    version: number
+    description: string
+    inputs: INodeParams[]
+
+    constructor() {
+        this.label = 'MistralAI API'
+        this.name = 'mistralAIApi'
+        this.version = 1.0
+        this.description = 'You can get your API key from official <a target="_blank" href="https://console.mistral.ai/">console</a> here.'
+        this.inputs = [
+            {
+                label: 'MistralAI API Key',
+                name: 'mistralAIAPIKey',
+                type: 'password'
+            }
+        ]
+    }
+}
+
+module.exports = { credClass: MistralAICredential }
diff --git a/packages/components/nodes/chatmodels/ChatGoogleGenerativeAI/ChatGoogleGenerativeAI.ts b/packages/components/nodes/chatmodels/ChatGoogleGenerativeAI/ChatGoogleGenerativeAI.ts
index 95ee0575d90..7044645f6c5 100644
--- a/packages/components/nodes/chatmodels/ChatGoogleGenerativeAI/ChatGoogleGenerativeAI.ts
+++ b/packages/components/nodes/chatmodels/ChatGoogleGenerativeAI/ChatGoogleGenerativeAI.ts
@@ -49,8 +49,7 @@ class GoogleGenerativeAI_ChatModels implements INode {
                         name: 'gemini-pro'
                     }
                 ],
-                default: 'gemini-pro',
-                optional: true
+                default: 'gemini-pro'
             },
             {
                 label: 'Temperature',
diff --git a/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts b/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
new file mode 100644
index 00000000000..d9db85cd526
--- /dev/null
+++ b/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
@@ -0,0 +1,151 @@
+import { ICommonObject, INode, INodeData, INodeParams } from '../../../src/Interface'
+import { getBaseClasses, getCredentialData, getCredentialParam } from '../../../src/utils'
+import { BaseCache } from 'langchain/schema'
+import { ChatMistralAI, ChatMistralAIInput } from '@langchain/mistralai'
+
+class ChatMistral_ChatModels implements INode {
+    label: string
+    name: string
+    version: number
+    type: string
+    icon: string
+    category: string
+    description: string
+    baseClasses: string[]
+    credential: INodeParams
+    inputs: INodeParams[]
+
+    constructor() {
+        this.label = 'ChatMistralAI'
+        this.name = 'chatMistralAI'
+        this.version = 1.0
+        this.type = 'ChatMistralAI'
+        this.icon = 'mistralai.png'
+        this.category = 'Chat Models'
+        this.description = 'Wrapper around Mistral large language models that use the Chat endpoint'
+        this.baseClasses = [this.type, ...getBaseClasses(ChatMistralAI)]
+        this.credential = {
+            label: 'Connect Credential',
+            name: 'credential',
+            type: 'credential',
+            credentialNames: ['mistralAIApi']
+        }
+        this.inputs = [
+            {
+                label: 'Cache',
+                name: 'cache',
+                type: 'BaseCache',
+                optional: true
+            },
+            {
+                label: 'Model Name',
+                name: 'modelName',
+                type: 'options',
+                options: [
+                    {
+                        label: 'mistral-tiny',
+                        name: 'mistral-tiny'
+                    },
+                    {
+                        label: 'mistral-small',
+                        name: 'mistral-small'
+                    },
+                    {
+                        label: 'mistral-medium',
+                        name: 'mistral-medium'
+                    }
+                ],
+                default: 'mistral-tiny'
+            },
+            {
+                label: 'Temperature',
+                name: 'temperature',
+                type: 'number',
+                description:
+                    'What sampling temperature to use, between 0.0 and 1.0. Higher values like 0.8 will make the output more random, while lower values like 0.2 will make it more focused and deterministic.',
+                step: 0.1,
+                default: 0.9,
+                optional: true
+            },
+            {
+                label: 'Max Output Tokens',
+                name: 'maxOutputTokens',
+                type: 'number',
+                description: 'The maximum number of tokens to generate in the completion.',
+                step: 1,
+                optional: true,
+                additionalParams: true
+            },
+            {
+                label: 'Top Probability',
+                name: 'topP',
+                type: 'number',
+                description:
+                    'Nucleus sampling, where the model considers the results of the tokens with top_p probability mass. So 0.1 means only the tokens comprising the top 10% probability mass are considered.',
+                step: 0.1,
+                optional: true,
+                additionalParams: true
+            },
+            {
+                label: 'Random Seed',
+                name: 'randomSeed',
+                type: 'number',
+                description: 'The seed to use for random sampling. If set, different calls will generate deterministic results.',
+                step: 1,
+                optional: true,
+                additionalParams: true
+            },
+            {
+                label: 'Safe Mode',
+                name: 'safeMode',
+                type: 'boolean',
+                description: 'Whether to inject a safety prompt before all conversations.',
+                optional: true,
+                additionalParams: true
+            },
+            {
+                label: 'Override Endpoint',
+                name: 'overrideEndpoint',
+                type: 'string',
+                optional: true,
+                additionalParams: true
+            }
+        ]
+    }
+
+    async init(nodeData: INodeData, _: string, options: ICommonObject): Promise<any> {
+        const credentialData = await getCredentialData(nodeData.credential ?? '', options)
+        const apiKey = getCredentialParam('mistralAIAPIKey', credentialData, nodeData)
+
+        const temperature = nodeData.inputs?.temperature as string
+        const modelName = nodeData.inputs?.modelName as string
+        const maxOutputTokens = nodeData.inputs?.maxOutputTokens as string
+        const topP = nodeData.inputs?.topP as string
+        const safeMode = nodeData.inputs?.safeMode as boolean
+        const randomSeed = nodeData.inputs?.safeMode as string
+        const overrideEndpoint = nodeData.inputs?.overrideEndpoint as string
+        // Waiting fix from langchain to enable streaming
+        const streaming = nodeData.inputs?.streaming as boolean
+
+        const cache = nodeData.inputs?.cache as BaseCache
+
+        const obj: ChatMistralAIInput = {
+            apiKey: apiKey,
+            modelName: modelName
+        }
+
+        if (maxOutputTokens) obj.maxTokens = parseInt(maxOutputTokens, 10)
+        if (topP) obj.topP = parseFloat(topP)
+        if (cache) obj.cache = cache
+        if (temperature) obj.temperature = parseFloat(temperature)
+        if (randomSeed) obj.randomSeed = parseFloat(randomSeed)
+        if (safeMode) obj.safeMode = safeMode
+        if (overrideEndpoint) obj.endpoint = overrideEndpoint
+
+        const model = new ChatMistralAI(obj)
+
+        return model
+    }
+}
+
+module.exports = { nodeClass: ChatMistral_ChatModels }
diff --git a/packages/components/nodes/chatmodels/ChatMistral/mistralai.png b/packages/components/nodes/chatmodels/ChatMistral/mistralai.png
new file mode 100644
index 0000000000000000000000000000000000000000..1019f495d4d690dd639aa9f4e5751c403b2eff27
GIT binary patch
literal 4542
zcmb7Hc|4Te+rMWu%*f0z_F}9tmSJp(7$R%7QrXHH8A7DRz9ppW*|Vh3gzPDW?6Rd4
zDoF}ik~Q0VPtViueSV+k{pUS%eLi#D=eo{y&iy^#`#RUzeY-mjU=4KjbpZ$j03hHG
z*c}D50T>j@5U{~PL7)%_I2^&k#Dqj)STGng3mVP32ajdlgWH2fV>z)nb`Ao8fMMg}
z=H%eUa}YQfK_D=23>?9XKrnN#qFFiq-)*-Uz@dN+paTXG0-!hu3<ueL0q}#1gu)<<
z_5Nv0C^!NMV}>%UU_Zn74>JPE1cyOUklhgg0|UomVOa20s|Ejz{^vi5tB^UVY1V)2
zCr{;yx;W(HxAHu%8vx3Zv`o*HEtI(&Wv#j|UnyaJz^-{00OJJAcD60YeXH|ugf;l8
zZy7%ACvFZS7CdguMa#Ex9Vm%=$2San)9t@c*Y9mqMa+njkD8&BEBO@cXc+(qsJ`$&
zUdVkh4n|?4eC%?%n|3ty{N+M%@8XwjeRLk-LsdZfr|UTzR-L?xrU0-p{B=6EY4j{_
z>cP^vjD(uifyQTv0m9Et3JVn%*xj6dSH1tk(@JxtSFPR^X$J9U8V5B2w(Lvw>uR=d
z2yvaO{Au^jziMe#7+WY)zS!o~Jteo<7%w9l+p@W&XLJ_cW*kSiG=FdOlIsdL0Qp&F
zTQTgTcT`(xOqEa6nwHW|DH!0d$MwFJGVSpXc0X|P`<I++$4iY<=}JATy>XR6R#w$+
zv>~HUp1mR9v{$lg!gI{sFU*|y=7t|U#uw<+NxH`Dleny+c!2nzJgz-;F7AGHQMYCM
z+iv{VA&pmi5p{)YmKRjs#qK%Dz_tJAl`<Y_ha;A?bV6g<Mf_PQW=S$|%xb`wc>3$`
zoN&pr{DRn08(LveaE9nl@;`U+UpgDe3@LE8U`Qksr1js_fx?jh1cqP|#By*dC@K*s
zczGO|op{CzWC{u-5Cj3;1xyP|#YK`{ytX``ma&mgo6e`1!6M~8Jllf$iJd+5>1NN3
zCmo|bH$r4@$(~-5418BE`na)n;m*~H@ad<)W5sJO&r@f9eQXS!Z(}Q3*#&&4Y~uwl
zpH`lCr7$&JFV-DN_CRQ<RHXZv6^MwnlJt|r@+6t?yj@2Lac3-C1^0Q(WnOjp(E4#B
z^vW(!Pi$Z<T=THnJY1S2U0YT2fe}#qBA@>JNcHOV6Jplq-8`Po?o7rA{OGHENSn=6
zo$9TxeCSHy(z@}$ru(wX!;GZEYW3wjzJh0M-VH1Hz0AIF)}~cpgTx3fyz#7GpuF)-
z(z_4O=Jj^YFEf3Ytu9>kFU#8NkaP)hpa)S2aj@@AA4I0>D}|)p<~oI=2#`5@5TX3C
z{2~=e*c7q6!u)zK>H@=)_WWep>QTl54VKo$H&P#{KQ!z7#55}Nc{b>mKqa1!Z+N?t
z)IFX%WmUdfe?&Y&fYxx6zWFVvM~`;?^qR=f5v`2NSmgwmI2%-CF0E?G;a(1|kUgwj
z!E9>a$Zb?*9*>?$h-K}<r|qq1zK+l*(Y$uMKyo8v#)R{Wh8NMZLF)oE=PZxeoi9Qk
z$5X#^z1dzo^tM}N^mX!}zp`1^w9{5G9ir?3QFg=2yJ&d?8te9?Aj9=Jj&g=%*8G-=
z{aPU=JB+NOhy$qtfik1vu)o>G$U<-g4vEFH69mo7y*cFMDGF2z`-HqEPGO%4O)b;k
zGy;>624u%cP*pdqUWBjYvDo27ZpF(CjeCN%gSTp8BSY<t^Gr?D<s39r$=Q@Ebu-S?
zyxSs(Ce3xcVV=`@=C!@Mbr4<Fu2*I98^5LOTDynusnWx;#c`J-Z#(qJ@m}hvi_CNN
zSMQ4IyLV5+qgJYg(>@mE=+3kE!<8!al0!tNgAVsg!;&X^W@9|=>3&WWK@&#_hkp!?
zxhUIJ-Q|kr)UJ^db;HE(0_xTp)vX(tlNKYV*0)MLpJwSwNq*DK?2Bc2TvwNEEp^%!
zb+Bc%UdkQgNb~cKn%_!p=TuSgmn|l(-qf*n8#)mpHgEhDo!D01E7s0&;GjtxJ!7@q
z8vVf&(z06hGW&Dwkd$;u*uxTK&Baei?_bO)XGv4eUYc7$qf3iRK1Wz|?DbY_-zozE
zr{Dkp0f93y!4Q8wX9x&54uNDB#Nr7QGw(bOqMW?Bg}qPHfPyAf`!Bem47j%^*Eohw
z*ihFJxJOrWp9E?^=Zu1Aeh;;(<8IE~+CqM;+WtJf&gIgdqUf0%IcuKoA+v50C`KNV
znJeJ!vv<8!!jt<}>|^DSQ{rju0h#`r$lEh_sUOgXa)P2jr!Zp~bvs1rz&77A{b|Q5
z@y_`x!FHL&Py7>{bB@P+73S9C)?@aNP<P-v=U<k`>|>ju6YqDYS+iNQK~ID}65yQq
zk*8Oeoc3H1Y1nExV0zK1Su)dw@yxo`kZG*jojG^A`834;mYa3Tdbg}sqm`6#SN*lx
zb6@gb{FD-iie>A0@`#1Lzmds>b}CwI)J#0u%$<OtML!c#Q_3G^+dv+qICQ&77hBca
zO4j5P-@RXs-fxa|%I{`q(sU%<VHY5Q7^{IP5e`K%Az?_SKdc5Z_CetAWcdqNK_Z1(
z(ZtRn=beyb<}g4I67~&$q+o7w#?dSB?-YsDfbM*Y3q8y(LyUYU%6rq*6X#`AlR~(7
zU6+h~PTgOwWBWpw)}piv&{B9tRZB|lByZ=my(;C2gEQ>nKS(jwDin$7^Su+X34yQ+
zocW^vcaMCqM4T|n;QI;FG4UZ!_8Dyai<rUaC%zQq7+#2(mQ<7cxGvonQ@!e_<KdLC
zY4HnADnB|{hK=%W-@{iSESY$G_@qI@%<A4tNL++HYu5>m8n1H}ZybES=5sB%ZO>xU
zi>G*#t22@xO3=oK?mc+%rSGup<g3j$M2ba^qJ+DmgpK*TrpgT?dv0AY0LnJzdph?H
z|F*W7Q{#et;<>(??1%Ewu6FK?Oe}eXk12h093zZsCdUzzHdrQ7ds(~uMc7VVN2jz(
zXYnP^>+P$=bCF_BEbQAH$NHsjzZzGGC)Su%7^=opJfZokl)C$LO4f9r(bm^~lj=us
zlf6Ho60yD>p?Xy5@S`ef)Wn?B2Vwc|G0y-U`(0pzVU8!pRV~%stqc=YCs(>|i$vQr
z58jkRC+BE^z(NC7h)b`!z=fcamz!S}EGH5#pbgYs$e3Sdk<nRZ{yB85+k^qU=#i}=
z@_l>L2z}g~W&9e;X9>?H@gIaL`I+pfN0GQ}1C2Xv!}meaA9c6i(w5GR!RpKDbToz@
za%71jU?j2aI|__dgc@8qb8p%kw1iX><&zjQBP6E7a__cs3H^c&MRb{vqSrevW+>VD
z3>v)`g4go8ygdDy*l>P~uV%Xmvw5GEsa2|)<_)cb6ZPFBMXhafLu8xIe)!`7I%1R_
z=y^zJm@G36_x)G^0)-<GVDa~d$N<jFK5tQwoKW!tOO&H}51jD|{d2Hu5O++Q7RRna
zg+*}M?|f#{j`ZvH?$Nv<rZX@2E4{EKq5Gk&&-C1PO&?MwrfX%M<Qk7Il>cuXF_Pxg
zb?&aB<{eyv>Llq_ftt9$33U`~x`>(f+@_$)g80^_qt)f@f<1q<#$dvF7P5u!*Ih;P
zjACPp_=7xzmr<%8#%Cthpii|4Gyi@J3v7Ah;%A{+oPDgf<m|DD_c1#sm#3{hfAgoz
z{yKftocnP=DqFBr(SKZy%cG5ArdswBW}XpxF`y>-mll2+;wR*)wX(;c-!jbGw*QAs
z`j!!U#s2bbBJ(kJvQKJQ6*k%*yBva=5UGQ!ab0gCAKW_@o##Dq3Qe_Q>DQe<$cP3=
zIbE^tv~qkCQ${9@S*C<_B6Tj<hj7ZPOHb0}W_3>7Cd`uznw-Lg>dQ5;x71krNt!v7
z)had<{xqygaP-?V_l%}{b^$KRmhLQYDEN9<xBjQ+&W<rjygIIgJC>mec73{F#Bi=x
zPIeR3j)-}Fa8{&jQODEPb8YCc1MtY^J5l>?jb!bOtHY1$4^C(q%5|KV`POWxwxt8@
z*gtL<Dg)0@Q@{aiASM2;^?%a=`?F8&-{LF!<Y!a!5zsVlyU>>l4+ed9Hh-yaE`W;6
z+DDu4kFMaT;r9oY0|FcR)RuC&V13C;WokdW5B=!dhRp{2>{D&o1=JR4<bOy1uO5(~
z;yAFLgfPMXQ+$HA7@Qzc&OWbV5o^{oK=sx%P56tSjEVuf)x?sYL@KM-)XbrAgG${O
ztx{*`_YY3)lC99&**g=Y(3X9-6N{9i7P*)(Q@RztTa8lFqbsi(d>8$O8#t*(d#961
z<^3E;;h8Gx2^9ftEAP`)E5$9zS+<dhMLzmjA-%2CImmrF#yhw(D>lmO#1y9g%?c$k
zyf~=2@4(n}^UDLCUyTi`nl`7qE=t97T(l6~=}Xs>v(^es>qU<_8=T40e<)_S9b2$B
zQ}}tLbqK=p!U9=al7Lc_@Qc8#Wo`C&?$tr2uvq4nfB;DR1^|hG|Ea$J006!})huDa
zJ2dZyrfJis-=8Ss6vu9L@n`IdR>-9?RZ=-`n=YYQ@g{e|Yas+^iq$x$0nD|hKIo)j
z>dYSPL19%oX2Ek`ZfqL$hUVHA`7f%0^z5X9_DeHftqY$Y`O!k&x5yVALn_}eajO`Q
z$rc(POp<ig{oHNgB&5vlEmQ=ZEuNCh+n3`qp*d8*YteIe$IfNK!20e;riS!A*3`or
z9x4G^4qodn^jlXEZu0wn<{nw328i6dobsMuXQuR2Xgb@aFgdolRN`@-%sCu(IQQ-~
zW>Cqx@A!*R%}8Jw+YjD8z|H+DK|yc;k!)ta_ya3PO~@M%tndzP`rn&}1{S<|^z^$%
zB%}CTqw&fP&-G@lb86L%<0AB(n{@=20Bp_Kk%VTilU>|q5Sf)ohEdL5L{(2&Xoa>%
z6_c5AWr{5-J#5mB9@<V#@+q@vT6{&eiKU8G$Q;4rg}9Yib7KZicY$Ir&teK+>Wk2`
z;A~6>C<^CxQj>07I6NpP9TCm_C7XRa(cs+u=*<D|7o<xrhw#``Yy9VxdamL#wjwg!
zCM`>^7RO?T%4HI{obP?wa9j7(3AeAn_>w#<N9fho=W1U2-l>$rT%uRbT$kkdRXe35
zbUj1`=Xg!6IB^OkB^2<-&7&kVny4W*X;+!jcYU)=crDn=F6nPI(EHqI2)3^fO)?`F
znYh1qT7BA2Y31PLd~2g}Wg3=8i^vZ?CVujk2tKB(bMEScoZ-h(`S9rUts%Eg1x;^l
zqnO8<+6f0Pn^;{JW&TRn^EhZXD_%YS=&Ic}-N`Ud>J?9$fHb}g-94%@;#h;_Cx)+^
zm&fWhWRw-+`2B2-3Z_h7N-K@*8VI8d*07y>t9~Cfg1UC~nvt=Kefh<p>GOhkykkrx
z5<$gl4%{{1&%57c5Qv$XoY%TcI<ra-9{~rE^|;mM>Lb6UdoL+VK0U}ckiTqHx51ZU
zmwjXW&11_L&eEgCFq@TP2dU4yzzlh^iUi9p_NpSM8p1Mj^7zmjK?2}Op8*u3nr2;h
Kf#<=y@BRlu0mfYb

literal 0
HcmV?d00001

diff --git a/packages/components/nodes/embeddings/MistralEmbedding/MistralEmbedding.ts b/packages/components/nodes/embeddings/MistralEmbedding/MistralEmbedding.ts
new file mode 100644
index 00000000000..d0a0198c31a
--- /dev/null
+++ b/packages/components/nodes/embeddings/MistralEmbedding/MistralEmbedding.ts
@@ -0,0 +1,95 @@
+import { ICommonObject, INode, INodeData, INodeParams } from '../../../src/Interface'
+import { getBaseClasses, getCredentialData, getCredentialParam } from '../../../src/utils'
+import { MistralAIEmbeddings, MistralAIEmbeddingsParams } from '@langchain/mistralai'
+
+class MistralEmbedding_Embeddings implements INode {
+    label: string
+    name: string
+    version: number
+    type: string
+    icon: string
+    category: string
+    description: string
+    baseClasses: string[]
+    inputs: INodeParams[]
+    credential: INodeParams
+
+    constructor() {
+        this.label = 'MistralAI Embeddings'
+        this.name = 'mistralAI Embeddings'
+        this.version = 1.0
+        this.type = 'MistralAIEmbeddings'
+        this.icon = 'mistralai.png'
+        this.category = 'Embeddings'
+        this.description = 'MistralAI API to generate embeddings for a given text'
+        this.baseClasses = [this.type, ...getBaseClasses(MistralAIEmbeddings)]
+        this.credential = {
+            label: 'Connect Credential',
+            name: 'credential',
+            type: 'credential',
+            credentialNames: ['mistralAIApi']
+        }
+        this.inputs = [
+            {
+                label: 'Model Name',
+                name: 'modelName',
+                type: 'options',
+                options: [
+                    {
+                        label: 'mistral-embed',
+                        name: 'mistral-embed'
+                    }
+                ],
+                default: 'mistral-embed'
+            },
+            {
+                label: 'Batch Size',
+                name: 'batchSize',
+                type: 'number',
+                step: 1,
+                default: 512,
+                optional: true,
+                additionalParams: true
+            },
+            {
+                label: 'Strip New Lines',
+                name: 'stripNewLines',
+                type: 'boolean',
+                default: true,
+                optional: true,
+                additionalParams: true
+            },
+            {
+                label: 'Override Endpoint',
+                name: 'overrideEndpoint',
+                type: 'string',
+                optional: true,
+                additionalParams: true
+            }
+        ]
+    }
+
+    async init(nodeData: INodeData, _: string, options: ICommonObject): Promise<any> {
+        const modelName = nodeData.inputs?.modelName as string
+        const batchSize = nodeData.inputs?.batchSize as string
+        const stripNewLines = nodeData.inputs?.stripNewLines as boolean
+        const overrideEndpoint = nodeData.inputs?.overrideEndpoint as string
+
+        const credentialData = await getCredentialData(nodeData.credential ?? '', options)
+        const apiKey = getCredentialParam('mistralAIAPIKey', credentialData, nodeData)
+
+        const obj: MistralAIEmbeddingsParams = {
+            apiKey: apiKey,
+            modelName: modelName
+        }
+
+        if (batchSize) obj.batchSize = parseInt(batchSize, 10)
+        if (stripNewLines) obj.stripNewLines = stripNewLines
+        if (overrideEndpoint) obj.endpoint = overrideEndpoint
+
+        const model = new MistralAIEmbeddings(obj)
+        return model
+    }
+}
+
+module.exports = { nodeClass: MistralEmbedding_Embeddings }
diff --git a/packages/components/nodes/embeddings/MistralEmbedding/mistralai.png b/packages/components/nodes/embeddings/MistralEmbedding/mistralai.png
new file mode 100644
index 0000000000000000000000000000000000000000..1019f495d4d690dd639aa9f4e5751c403b2eff27
GIT binary patch
literal 4542
zcmb7Hc|4Te+rMWu%*f0z_F}9tmSJp(7$R%7QrXHH8A7DRz9ppW*|Vh3gzPDW?6Rd4
zDoF}ik~Q0VPtViueSV+k{pUS%eLi#D=eo{y&iy^#`#RUzeY-mjU=4KjbpZ$j03hHG
z*c}D50T>j@5U{~PL7)%_I2^&k#Dqj)STGng3mVP32ajdlgWH2fV>z)nb`Ao8fMMg}
z=H%eUa}YQfK_D=23>?9XKrnN#qFFiq-)*-Uz@dN+paTXG0-!hu3<ueL0q}#1gu)<<
z_5Nv0C^!NMV}>%UU_Zn74>JPE1cyOUklhgg0|UomVOa20s|Ejz{^vi5tB^UVY1V)2
zCr{;yx;W(HxAHu%8vx3Zv`o*HEtI(&Wv#j|UnyaJz^-{00OJJAcD60YeXH|ugf;l8
zZy7%ACvFZS7CdguMa#Ex9Vm%=$2San)9t@c*Y9mqMa+njkD8&BEBO@cXc+(qsJ`$&
zUdVkh4n|?4eC%?%n|3ty{N+M%@8XwjeRLk-LsdZfr|UTzR-L?xrU0-p{B=6EY4j{_
z>cP^vjD(uifyQTv0m9Et3JVn%*xj6dSH1tk(@JxtSFPR^X$J9U8V5B2w(Lvw>uR=d
z2yvaO{Au^jziMe#7+WY)zS!o~Jteo<7%w9l+p@W&XLJ_cW*kSiG=FdOlIsdL0Qp&F
zTQTgTcT`(xOqEa6nwHW|DH!0d$MwFJGVSpXc0X|P`<I++$4iY<=}JATy>XR6R#w$+
zv>~HUp1mR9v{$lg!gI{sFU*|y=7t|U#uw<+NxH`Dleny+c!2nzJgz-;F7AGHQMYCM
z+iv{VA&pmi5p{)YmKRjs#qK%Dz_tJAl`<Y_ha;A?bV6g<Mf_PQW=S$|%xb`wc>3$`
zoN&pr{DRn08(LveaE9nl@;`U+UpgDe3@LE8U`Qksr1js_fx?jh1cqP|#By*dC@K*s
zczGO|op{CzWC{u-5Cj3;1xyP|#YK`{ytX``ma&mgo6e`1!6M~8Jllf$iJd+5>1NN3
zCmo|bH$r4@$(~-5418BE`na)n;m*~H@ad<)W5sJO&r@f9eQXS!Z(}Q3*#&&4Y~uwl
zpH`lCr7$&JFV-DN_CRQ<RHXZv6^MwnlJt|r@+6t?yj@2Lac3-C1^0Q(WnOjp(E4#B
z^vW(!Pi$Z<T=THnJY1S2U0YT2fe}#qBA@>JNcHOV6Jplq-8`Po?o7rA{OGHENSn=6
zo$9TxeCSHy(z@}$ru(wX!;GZEYW3wjzJh0M-VH1Hz0AIF)}~cpgTx3fyz#7GpuF)-
z(z_4O=Jj^YFEf3Ytu9>kFU#8NkaP)hpa)S2aj@@AA4I0>D}|)p<~oI=2#`5@5TX3C
z{2~=e*c7q6!u)zK>H@=)_WWep>QTl54VKo$H&P#{KQ!z7#55}Nc{b>mKqa1!Z+N?t
z)IFX%WmUdfe?&Y&fYxx6zWFVvM~`;?^qR=f5v`2NSmgwmI2%-CF0E?G;a(1|kUgwj
z!E9>a$Zb?*9*>?$h-K}<r|qq1zK+l*(Y$uMKyo8v#)R{Wh8NMZLF)oE=PZxeoi9Qk
z$5X#^z1dzo^tM}N^mX!}zp`1^w9{5G9ir?3QFg=2yJ&d?8te9?Aj9=Jj&g=%*8G-=
z{aPU=JB+NOhy$qtfik1vu)o>G$U<-g4vEFH69mo7y*cFMDGF2z`-HqEPGO%4O)b;k
zGy;>624u%cP*pdqUWBjYvDo27ZpF(CjeCN%gSTp8BSY<t^Gr?D<s39r$=Q@Ebu-S?
zyxSs(Ce3xcVV=`@=C!@Mbr4<Fu2*I98^5LOTDynusnWx;#c`J-Z#(qJ@m}hvi_CNN
zSMQ4IyLV5+qgJYg(>@mE=+3kE!<8!al0!tNgAVsg!;&X^W@9|=>3&WWK@&#_hkp!?
zxhUIJ-Q|kr)UJ^db;HE(0_xTp)vX(tlNKYV*0)MLpJwSwNq*DK?2Bc2TvwNEEp^%!
zb+Bc%UdkQgNb~cKn%_!p=TuSgmn|l(-qf*n8#)mpHgEhDo!D01E7s0&;GjtxJ!7@q
z8vVf&(z06hGW&Dwkd$;u*uxTK&Baei?_bO)XGv4eUYc7$qf3iRK1Wz|?DbY_-zozE
zr{Dkp0f93y!4Q8wX9x&54uNDB#Nr7QGw(bOqMW?Bg}qPHfPyAf`!Bem47j%^*Eohw
z*ihFJxJOrWp9E?^=Zu1Aeh;;(<8IE~+CqM;+WtJf&gIgdqUf0%IcuKoA+v50C`KNV
znJeJ!vv<8!!jt<}>|^DSQ{rju0h#`r$lEh_sUOgXa)P2jr!Zp~bvs1rz&77A{b|Q5
z@y_`x!FHL&Py7>{bB@P+73S9C)?@aNP<P-v=U<k`>|>ju6YqDYS+iNQK~ID}65yQq
zk*8Oeoc3H1Y1nExV0zK1Su)dw@yxo`kZG*jojG^A`834;mYa3Tdbg}sqm`6#SN*lx
zb6@gb{FD-iie>A0@`#1Lzmds>b}CwI)J#0u%$<OtML!c#Q_3G^+dv+qICQ&77hBca
zO4j5P-@RXs-fxa|%I{`q(sU%<VHY5Q7^{IP5e`K%Az?_SKdc5Z_CetAWcdqNK_Z1(
z(ZtRn=beyb<}g4I67~&$q+o7w#?dSB?-YsDfbM*Y3q8y(LyUYU%6rq*6X#`AlR~(7
zU6+h~PTgOwWBWpw)}piv&{B9tRZB|lByZ=my(;C2gEQ>nKS(jwDin$7^Su+X34yQ+
zocW^vcaMCqM4T|n;QI;FG4UZ!_8Dyai<rUaC%zQq7+#2(mQ<7cxGvonQ@!e_<KdLC
zY4HnADnB|{hK=%W-@{iSESY$G_@qI@%<A4tNL++HYu5>m8n1H}ZybES=5sB%ZO>xU
zi>G*#t22@xO3=oK?mc+%rSGup<g3j$M2ba^qJ+DmgpK*TrpgT?dv0AY0LnJzdph?H
z|F*W7Q{#et;<>(??1%Ewu6FK?Oe}eXk12h093zZsCdUzzHdrQ7ds(~uMc7VVN2jz(
zXYnP^>+P$=bCF_BEbQAH$NHsjzZzGGC)Su%7^=opJfZokl)C$LO4f9r(bm^~lj=us
zlf6Ho60yD>p?Xy5@S`ef)Wn?B2Vwc|G0y-U`(0pzVU8!pRV~%stqc=YCs(>|i$vQr
z58jkRC+BE^z(NC7h)b`!z=fcamz!S}EGH5#pbgYs$e3Sdk<nRZ{yB85+k^qU=#i}=
z@_l>L2z}g~W&9e;X9>?H@gIaL`I+pfN0GQ}1C2Xv!}meaA9c6i(w5GR!RpKDbToz@
za%71jU?j2aI|__dgc@8qb8p%kw1iX><&zjQBP6E7a__cs3H^c&MRb{vqSrevW+>VD
z3>v)`g4go8ygdDy*l>P~uV%Xmvw5GEsa2|)<_)cb6ZPFBMXhafLu8xIe)!`7I%1R_
z=y^zJm@G36_x)G^0)-<GVDa~d$N<jFK5tQwoKW!tOO&H}51jD|{d2Hu5O++Q7RRna
zg+*}M?|f#{j`ZvH?$Nv<rZX@2E4{EKq5Gk&&-C1PO&?MwrfX%M<Qk7Il>cuXF_Pxg
zb?&aB<{eyv>Llq_ftt9$33U`~x`>(f+@_$)g80^_qt)f@f<1q<#$dvF7P5u!*Ih;P
zjACPp_=7xzmr<%8#%Cthpii|4Gyi@J3v7Ah;%A{+oPDgf<m|DD_c1#sm#3{hfAgoz
z{yKftocnP=DqFBr(SKZy%cG5ArdswBW}XpxF`y>-mll2+;wR*)wX(;c-!jbGw*QAs
z`j!!U#s2bbBJ(kJvQKJQ6*k%*yBva=5UGQ!ab0gCAKW_@o##Dq3Qe_Q>DQe<$cP3=
zIbE^tv~qkCQ${9@S*C<_B6Tj<hj7ZPOHb0}W_3>7Cd`uznw-Lg>dQ5;x71krNt!v7
z)had<{xqygaP-?V_l%}{b^$KRmhLQYDEN9<xBjQ+&W<rjygIIgJC>mec73{F#Bi=x
zPIeR3j)-}Fa8{&jQODEPb8YCc1MtY^J5l>?jb!bOtHY1$4^C(q%5|KV`POWxwxt8@
z*gtL<Dg)0@Q@{aiASM2;^?%a=`?F8&-{LF!<Y!a!5zsVlyU>>l4+ed9Hh-yaE`W;6
z+DDu4kFMaT;r9oY0|FcR)RuC&V13C;WokdW5B=!dhRp{2>{D&o1=JR4<bOy1uO5(~
z;yAFLgfPMXQ+$HA7@Qzc&OWbV5o^{oK=sx%P56tSjEVuf)x?sYL@KM-)XbrAgG${O
ztx{*`_YY3)lC99&**g=Y(3X9-6N{9i7P*)(Q@RztTa8lFqbsi(d>8$O8#t*(d#961
z<^3E;;h8Gx2^9ftEAP`)E5$9zS+<dhMLzmjA-%2CImmrF#yhw(D>lmO#1y9g%?c$k
zyf~=2@4(n}^UDLCUyTi`nl`7qE=t97T(l6~=}Xs>v(^es>qU<_8=T40e<)_S9b2$B
zQ}}tLbqK=p!U9=al7Lc_@Qc8#Wo`C&?$tr2uvq4nfB;DR1^|hG|Ea$J006!})huDa
zJ2dZyrfJis-=8Ss6vu9L@n`IdR>-9?RZ=-`n=YYQ@g{e|Yas+^iq$x$0nD|hKIo)j
z>dYSPL19%oX2Ek`ZfqL$hUVHA`7f%0^z5X9_DeHftqY$Y`O!k&x5yVALn_}eajO`Q
z$rc(POp<ig{oHNgB&5vlEmQ=ZEuNCh+n3`qp*d8*YteIe$IfNK!20e;riS!A*3`or
z9x4G^4qodn^jlXEZu0wn<{nw328i6dobsMuXQuR2Xgb@aFgdolRN`@-%sCu(IQQ-~
zW>Cqx@A!*R%}8Jw+YjD8z|H+DK|yc;k!)ta_ya3PO~@M%tndzP`rn&}1{S<|^z^$%
zB%}CTqw&fP&-G@lb86L%<0AB(n{@=20Bp_Kk%VTilU>|q5Sf)ohEdL5L{(2&Xoa>%
z6_c5AWr{5-J#5mB9@<V#@+q@vT6{&eiKU8G$Q;4rg}9Yib7KZicY$Ir&teK+>Wk2`
z;A~6>C<^CxQj>07I6NpP9TCm_C7XRa(cs+u=*<D|7o<xrhw#``Yy9VxdamL#wjwg!
zCM`>^7RO?T%4HI{obP?wa9j7(3AeAn_>w#<N9fho=W1U2-l>$rT%uRbT$kkdRXe35
zbUj1`=Xg!6IB^OkB^2<-&7&kVny4W*X;+!jcYU)=crDn=F6nPI(EHqI2)3^fO)?`F
znYh1qT7BA2Y31PLd~2g}Wg3=8i^vZ?CVujk2tKB(bMEScoZ-h(`S9rUts%Eg1x;^l
zqnO8<+6f0Pn^;{JW&TRn^EhZXD_%YS=&Ic}-N`Ud>J?9$fHb}g-94%@;#h;_Cx)+^
zm&fWhWRw-+`2B2-3Z_h7N-K@*8VI8d*07y>t9~Cfg1UC~nvt=Kefh<p>GOhkykkrx
z5<$gl4%{{1&%57c5Qv$XoY%TcI<ra-9{~rE^|;mM>Lb6UdoL+VK0U}ckiTqHx51ZU
zmwjXW&11_L&eEgCFq@TP2dU4yzzlh^iUi9p_NpSM8p1Mj^7zmjK?2}Op8*u3nr2;h
Kf#<=y@BRlu0mfYb

literal 0
HcmV?d00001

diff --git a/packages/components/package.json b/packages/components/package.json
index 6bdc908a333..cbc347ff697 100644
--- a/packages/components/package.json
+++ b/packages/components/package.json
@@ -27,6 +27,7 @@
         "@google-ai/generativelanguage": "^0.2.1",
         "@huggingface/inference": "^2.6.1",
         "@langchain/google-genai": "^0.0.3",
+        "@langchain/mistralai": "^0.0.2",
         "@notionhq/client": "^2.2.8",
         "@opensearch-project/opensearch": "^1.2.0",
         "@pinecone-database/pinecone": "^1.1.1",
diff --git a/packages/server/src/utils/index.ts b/packages/server/src/utils/index.ts
index 2bf1c04a4c5..5f12c66ec89 100644
--- a/packages/server/src/utils/index.ts
+++ b/packages/server/src/utils/index.ts
@@ -711,6 +711,7 @@ export const findAvailableConfigs = (reactFlowNodes: IReactFlowNode[], component
 
 /**
  * Check to see if flow valid for stream
+ * TODO: perform check from component level. i.e: set streaming on component, and check here
  * @param {IReactFlowNode[]} reactFlowNodes
  * @param {INodeData} endingNodeData
  * @returns {boolean}

From 5a66d238699212e1a759aa7d86261fbb8f065aeb Mon Sep 17 00:00:00 2001
From: Henry Heng <henryheng@flowiseai.com>
Date: Fri, 15 Dec 2023 23:53:47 +0000
Subject: [PATCH 2/4] Update package.json

---
 packages/components/package.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/packages/components/package.json b/packages/components/package.json
index cbc347ff697..52e59b41edc 100644
--- a/packages/components/package.json
+++ b/packages/components/package.json
@@ -27,7 +27,7 @@
         "@google-ai/generativelanguage": "^0.2.1",
         "@huggingface/inference": "^2.6.1",
         "@langchain/google-genai": "^0.0.3",
-        "@langchain/mistralai": "^0.0.2",
+        "@langchain/mistralai": "^0.0.3",
         "@notionhq/client": "^2.2.8",
         "@opensearch-project/opensearch": "^1.2.0",
         "@pinecone-database/pinecone": "^1.1.1",

From 0707072a3e389dbeddf42a2a339ed40eb58fe6ca Mon Sep 17 00:00:00 2001
From: Henry Heng <henryheng@flowiseai.com>
Date: Fri, 15 Dec 2023 23:54:39 +0000
Subject: [PATCH 3/4] Update ChatMistral.ts

---
 packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts b/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
index d9db85cd526..9e12251fb85 100644
--- a/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
+++ b/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
@@ -124,7 +124,7 @@ class ChatMistral_ChatModels implements INode {
         const safeMode = nodeData.inputs?.safeMode as boolean
         const randomSeed = nodeData.inputs?.safeMode as string
         const overrideEndpoint = nodeData.inputs?.overrideEndpoint as string
-        // Waiting fix from langchain to enable streaming
+        // Waiting fix from langchain + mistral to enable streaming - https://github.com/mistralai/client-js/issues/18
         const streaming = nodeData.inputs?.streaming as boolean
 
         const cache = nodeData.inputs?.cache as BaseCache

From b5dd970460d46741600e12c2daa9fb817bb21eff Mon Sep 17 00:00:00 2001
From: Henry Heng <henryheng@flowiseai.com>
Date: Sun, 17 Dec 2023 19:04:01 +0000
Subject: [PATCH 4/4] Update ChatMistral.ts

---
 packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts | 1 -
 1 file changed, 1 deletion(-)

diff --git a/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts b/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
index 9e12251fb85..2548dd9910a 100644
--- a/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
+++ b/packages/components/nodes/chatmodels/ChatMistral/ChatMistral.ts
@@ -125,7 +125,6 @@ class ChatMistral_ChatModels implements INode {
         const randomSeed = nodeData.inputs?.safeMode as string
         const overrideEndpoint = nodeData.inputs?.overrideEndpoint as string
         // Waiting fix from langchain + mistral to enable streaming - https://github.com/mistralai/client-js/issues/18
-        const streaming = nodeData.inputs?.streaming as boolean
 
         const cache = nodeData.inputs?.cache as BaseCache