From 1cafec96bcbdf385ec15c59b7c9ee3f3b41fb48a Mon Sep 17 00:00:00 2001
From: Hitesh Wadhwani <hiteshwadhwani1403@gmail.com>
Date: Tue, 8 Oct 2024 16:37:59 +0530
Subject: [PATCH 1/6] added monetdb to FE

---
 apps/web/public/icons/monetdb.png             | Bin 0 -> 9389 bytes
 apps/web/src/components/forms/monetdb.tsx     | 303 ++++++++++++++++++
 apps/web/src/hooks/useDatasource.ts           |   1 +
 .../[workspaceId]/data-sources/new/index.tsx  |   7 +-
 .../data-sources/new/monetdb.tsx              |  63 ++++
 5 files changed, 373 insertions(+), 1 deletion(-)
 create mode 100644 apps/web/public/icons/monetdb.png
 create mode 100644 apps/web/src/components/forms/monetdb.tsx
 create mode 100644 apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx

diff --git a/apps/web/public/icons/monetdb.png b/apps/web/public/icons/monetdb.png
new file mode 100644
index 0000000000000000000000000000000000000000..8ea1d10f0e8fc55c35c97d2426675d1b1f380502
GIT binary patch
literal 9389
zcmeHt<x?9@v^E5{;2x}4aVr!G6f4$3DbOEU+&#EANRXmIN+}+^rD$;i1c%~MptzRe
z!9wuM`{Dg3?%WT%J3Dh`_UxQJ_U!ZN-CK1sVkTlNEG#ljjaPb)>)`(zg!qqhrBPKL
z78aL}<}0Q50XYY`Bq21v+Xo;H_WnaWsftvJgRY8ESVVCmw)AgwDU?EJ?TRjx+Fvg0
z9X4o(oIAz4m7q;hgBD#X<IuCtE(W!YFHunusb-3*qC~_UgYGmOL|lr>brRl34h|}*
zqd8w)yLs5}JM)u24u1XWegCtq^XxYNAw`h_%FRU)Q4@}<Od$nRB<#kgB2=1J1aJ^C
zYp~;5;SfRDUD?Aapk)91g}OYO$=Ewy<!tFh#!+HTVKrk(%kmquDAFL!9UYMb;de2M
zGw+oE9AQKEla`rrlu<omh2>bJo1zQZQR{h|NKt%H4>Do(b)7tr1ypG{A6|+wc%>}c
zb;98s@t-1B1Q;xVR$CyzRO$g_m+&bfwcrrqQ$(3nrUO3DHOV^C32Q0RH3~nevYZH7
z!+ZOp8!j23fZAnWgwb%pigJhUhfo3IT|@UW8kaeE?EBzsF6bup3~pWzdabjD8%2y(
z!>mgYJ&MA_R<yQmM8XCn=%eocSPm*I@mxfzxsv182&3p{(qn*S9FJ1r@HiaR`*_{0
zP5|pF9t+ODBAlckXe6ZP&GscH6~?kAo;N(?t1e=5U7(#+^?n~~i`Cs5pCL(peTPEO
zBF=ZatBXG!_tdV}RGfPHje8Gx{K{ge;fMVCe}owig!{jqlltg#!9=K6QUg(+1(h-e
zf}6Evo;VUId>V-JP&ISBQKVG@$V?5rw+(pX9#LJ7OFF>f?wzCvEZ_&zoAb9bk5Wqh
z{+gzkWUEHQ8qZvj9}blOHt{J-TPqCmVC9EdQLm6eYs+2`C*iON?CXlw`~L`T#ww2N
zN<1ihrgfqN==p}#A5mhdXXS9=j2k!JQ<XKFjxZ(Qf^nv};z_q};bUGO10+7k0(oCZ
zzf^Mr<DgYvs!BIgj;7?U%|{4@=koEvCyqbevBmj=>g1+H|5)G-QRu8fr)jGCf0<Sx
zGmwAN=T!kRfUgJn30K3cN*NB<R&@nL>uUn@)I?Tq)`XxvN(W>OWUaI+v_!0{q%;_k
zl**B?f#+<bMX3RGEcu2HtdRUpn$eU}70F0kuVRWDr4fM}#!?Jqb{$vR=s;Z>18|NU
zFBGoFmJH8Q5^VFJxz<sFKRlti7KwsVyB+_oA=9C?fMy|YV)VF(wlpkLA#!7;=;q0G
z29R~3QTU!B-gg{<+UFOMi`cxgWZ4^?Oi}kPf~Isy_Hq_Mj8f^<2OeTvu%6MD;VNkL
z`MBjE1F9~oyW+&$QfBrG!30PKmMT|*Sho};N7h=(w7`~nu%&23R|bf{jFtq;>!#Qp
z<e-}ZbwBKR>?Fc-Gug0@=#6N8@lwnkD&rPeX!?D<9eEM(9V2o#l!xop%<#Q=ts295
z8v2|RtXWx3COoikdV^B3eDhGpkcTg``Krc7Ct@oHAZ7oA%Lx!BC+hbv51G@1g&_<I
zl?-s9t-o$UlDmenIvwc0TuGH!7igh2&XXy1`7fMG&iMAGBTEe+1JXKA9*D3@2L6j+
z8vsH9m+<cgFK42duFnOBneq5;Tn9PFpg9sa$WNB8q64a8lVGgh6KDk9y()!C56Q%S
zx2C-5KM`nkF%9b~ge!pQJ%PJQ0meU6ED~3IUhq3cN9$yjM3EJCoBb})a(A4P-y-E)
zLNJ)Y)(*Qkp<2nn9*_y}gWf$OZAbaTRRQlfX(u?@(AOhdscB-JTjPVLK9!vR;koyw
z^<DCs9#EqBKz+6X$ecQHnyWYXT#%%3O2Iaq&)eiS7F5A}Mrg3K+!sZIIF6EhGEy%R
z&!@d6^hwX*?q)#WeQL#ui-0`_yylt%dm7BK6dj+9jzPxN$*GVIw>}M#t!OM6S9N6w
zO^^JlR^SSVzmZ_LrVumdm~_z4`A0~};BS{MSg81%q-!3Qz9=ydHYazRyNh+dXG8Uy
zWn5~b=`HW;h;0K)nU45q`yAjrHC0Uqn(R2*uA(19?XZmV;`Q?U^#gDWR=k87algAB
zr`5%%2sdK`#}h4GKm0nBrivvyZ@5-aTK0K<-XF9sukx7#Ww;a*vf6;PhYCCP387oC
z`XWSR%Rcn}Lv!P)6X}_thUb{>d%Ta~^ly$Em$QD=$%Au4NQ!gzyE5;diSM{!b+63>
z<xh!_JrgI4m?|?xQ&-rk>yP|iXA7WEo`NlyGgAehAsWB{bQ;kRb$W*EkKo&6x1wU`
z2e^WlPGvlz8+RznO@G1Fd(AuI`8$%IKp3-nJl5ch4vV4DT(I!1((mF4g0C+!ReD_B
z2>0&ETGSvS?MizBe;vZqSMd9%gpM~6_|DT3Ybl>6x;aqoIMhziZ9Ap0ERw*}DA-nu
zC4)Tswhu2)y5n!vcTGR&%pczV9v5x>XBgl%bYT>_<5l6R!H&~cLTkAG>Y<2lR6>dZ
z(sAzP`qYB6gCp_LAly0B5VHRMto$9ye`F#`6&83a&G;r<El$(#Ir#=u#`5rnB*^uy
zKZs^L9t5seTCAlxWX=Foep&&XXr>Xo+p-9I5Xy=+lgy8=V-F|Abr5XBB6<Drb?Vzv
z?(YYrLbXWkfyD6Uc$oJT8%GImYX!K2)&xUTo>B&f)QWW!gmSI>A=kg+85`sB4UqSH
z>6t@2Ao7LB=0ufaa*_wtp@dO+U!PuTse9Y%j1P0c-s}InENtFrNctD~t$@r0XSI8{
zPbXG{d>FbvQv%*vnQwX8f5kiTL`S6(LL5{)g+gJ(kxRmZ)WQ)xXJ$3$e=PYvB&;Kd
z4o$1W8+Y@Gb_br48diUZL;tlhdbz2VrpYG}hQ)I;uwEDEi=|e|rI4hC8z-Wsy{5hH
zI{^K;CU+&0yUf>aCp4pT9DY678EzoYEd>%TK2Zg~MbLWnZ}U~SO3%TgjumhEOL$hR
zRcSksNo$=b`>Xz=p-1&ozS(ZH{_-6>)q1V@vGzo*00XMMX)%o+_U8q)C`g%*wQp;e
zv)$tEH9ptVL#N;lk3emv$iPW=lt?}57S-hkhx+PPzFI2XFc*Q3u`v#}QgBQ<4d!zh
z1*YqlgQ%dY3k%4XkY-$2dyR8iQc8|q#a<4Z&qm7U{^iW2N96U&Pd>g&jc7aaNbkLI
zj-8Jp+#jv3?>pC#-#xfvx%7wB;1FEp?c9?l4fdGVr5oM<2^d=1PG0f-@+9Do>rBc*
zN=?)9c|3_830NU~S~>f`G&v!^R%sE(KEbELq(EDxNv`->;XL$uuOnu%WA8;lcG<6Y
zs@*FZWsdm$R!0@Rv;q%d2>ogeO>>ZT#xlS9x^nZ|V0?rx!GhFCOlu%sf%Bt&!?+%|
z0B4MdViNw4JoNzu9Xt0NpQSsa$yUQyJ^C+HRfTF04jvO%c*}o(OtW2T_1~^)KyZtU
zbAi|j1B7iRnt;;Gn=zoMGPrj#`Mb)4tz^K>J}fzx+}?F!k4?~<&NdnM@aG)%S^sM)
z4Tvs+SlIj?vCff2{2lP{>2uTj%&FWJHf8h&77N-H)S6-4@0y6`v&ySy{u(U~kuo<;
zFUA?zOGW|S&z0gc0d~_2#R`uhwTa(CCBriZ3D;-76=2Of5z=q9x&Hk4B%zIKQEQ2z
zi)NSqMYKq)Wwism`djYCBF}IfN!~`XYJzWX_xgOb@p#RfMC~@P&>I$W4`28`+a-lb
zJd`;GZ-!8*i=bxj93eIw$Q!o1+}dZ-@gILne8rtIjOG{4X|;9wby`8X6n&j#uYV1z
zzQcFx5<q5aACW_`R+b`gx;(<p?g@UTNr*t7t)Cxha=|*pt2gKem7VEuvb(F-N;VX-
zr&t_9s3%8<;p!{enlcu&=YuznB*IvjqkB7~Z8P!FZk{q=mn7{j>gnlnUg6ThJKbA1
zeg0uqqM9Jb6eU@l&2r^rMB;2>8FSw7ozgF9k|d&^vJYA%ZtC)9U*zXK7xv-$w9U-E
za2>7PRB_V1)-U>c{f4yn>jRFEGKRG~Z!<rwgCDq>>_g)If2?f-?Teo_C7<Z+%6AJa
z7@QHmnDnntj(F$4^1Ir>`1(T)Vp9pAnX0wTkYjwE{b+x9w?)F=*gmTpf~44KGyS*?
zmZU$!bQ=o%4`JN58A<|8p?78z7nj$!ph(;p2hW52Z@a>vL%|;y$}q8*bb<kbaw0_B
z!WwmX;OSxdA3v_tZyHa}$D;<GFG@SnOZUxpvQ~i1EyO)hq)z`)E}zRczcpUop;d@+
z;3$N1*T0)*4qTC2qPVR|4yN(}BVw`?xx2gmi^ZK|r+PhV%w&O&;Pw{nJfPJN(#O!I
z?~Jqf1V`sQ2yP{G$fWfzoZz?&yd#-nJ{!(B=LaVFJ+r}i5>C-bV4-3LCfieP?=623
z$9HNWtW^!XwV81H1b4sV-qOG3ff-G6?2K@Q&!_C<V)exyFQlnKBdecKg|Mu@<8}tr
zn|s3Ganx}h@U_>n-*Nte%j5i?o`y`P9G@wjTu;#a34074PfDbm7H3sNj7a!4M_$VF
zmgH*zYHiH_q$bVl+)xm8fR2TuW(#<H)k9c(X+GzW;Crt{m7?OyN&4tfG}X*!zkU^9
zLM$^=*Pby8T8OjzeM^a1%bI^4&hGGps5kDh;t%Fre5Wf%-O$yb+1JL6mH!}a6?A#@
zAN;{OAY@f?xu=#^GW-I^`U}%X;;{$?#+QaePs#+iC<M@I?{VV@N~L5?7|jW71OH}E
z$w)teSLx^VkGC0NLbTUpo?UuiBm9|cY`UAU&*8LIJ&r6}0^yYP*Uy>}P0BC))=G_e
z$FlJW-)?UkJz8Xmvjwb+uSPRU{gMrMAB=R3heyq!53%#qga&mr(G-Kbyy4s0F*&l#
zde?%SK^!}>lO4M&*aCiDR6h+ZEWBhHqO*_IV+(lLfz(<2_0iAQ2an@La$f;tm^8D`
zsJPI+`mGBnhKU!Va9Ro4=n#wAwYX@ZaLilHK3PyvT(7`xL)XA0h;iP?98psJGf`-!
z@5KTv{lqep4^bL*;|sIX(?UbYNaOh0iCo@M#}2d$om<!k8trBvZE)-tmCmC@rB~--
zc=t5f)tOJBE>I3x-+QTZH=O74ZY|PAv%lL<GqRd!2mU0yyJFYMWnK^6OYJaona{Hh
zZ)OxlBnS2%>0BtO_t>&~!+P0%h9=<f#Vt=LB>7?$nISWuNqhAvDErRYoCE{!pNspd
zSK0B4%XO$m2<Xn>Zm8#KqjjLTC-9R0=qd+@KK>#6^~Iz&W}ndMkF^4RN|G##QyFjc
z!W>%uQzJdyK(zxKNsFb}7UB$9JcQ-7Nl=0kJ&&e!gxtJEmG%l1O+od^bTnml1VwYO
zl57(GGf46;_=qws&wlvxr3uelmP24inJJWYOV<G_6RXDRBwh|}<r+1M!k^KGM6Xz`
zKvH0a=%>Y_S2J6^L$#~~00+MeUhQUvq@^gB7XoYeIXV`+0!X5m5qbkRXkTdZ9~_G~
zXu+MT_2zKMvj$az3|CmeuF;JRfW3j_h-2EEz8$}Ac?m%O!6tT_S_b0-%d6!J+4^II
zkP|b>o$Axm@xG_WK3f5AMS;Vgf+L$48pW05HcC;$u|7F9vhB9Dq831w|H20nAvyvw
zls2J;g@a&ljxFd{Poj|=TcH$&A&>ulnIr#r>?*vN{ORxg)mr-4gOh=el%L2$(ZrdH
zWM#+nFmDgKn0Bixm^UPh<EI1MZQBPm`;==NxB2Zoo9JZ(F3#qIPk0x}PH!2upUjLl
zUCKz?=Gz$Wh0ApYUkL_TgOFs(VM+R=B}SOT1C}$UEH*mB*nan^5!VL|Jr@g66GDfs
z-(Z?sriAV6c<WuuOtQHx<Fx~T<8kG|1#R(xE;#R2Uqfcj7~~^CMY^My6#xWLA1mK9
zR>0jt#3ui4(x3Au<$-$?cH!p7%-^Ng1X_q!rq~p_XI_2|cmHYl*m6GJoaor8-+A--
zd%YV_9WJkD-}7?qZll#|u-kUaV|4{ONIX}_vYiV5+l*gXJEg`xAS$hP70k7_cI3w3
z)fJ@S`nuXqV@#htAB+t<3UgWNsnrS=V+Fs(XjTJK%Elrq)|5p5?*5LhLc}1yKFDse
z6vDkcJBs=$kU>4!8rgTG#R**2$Ks4*n*Qhf6a$QgJu+x>QTx188vA%kaALLMB3g5T
zxeXYcGGLZAbGE#GGpAVnGZ||`=xdbs@KNN<_)DO=fHUA^MKR^URWwuJGsD*j-47?i
z3_o<bUkr+lYmJDs5ruE8UJjQ^w|~LeG(4pX*mQT1lpz+uwi)0q_B@E5{`rK@6Vxkn
z<=5PQUu5VBf@-QF-^ELbrgd$b0Svp&LaEdv<geaz)tx=&!VPTiOhaQE?K<y0wp40$
z0#aUMi(%%-dXFDamnDldI`y5Og4AA0U)YWOgtyK+@*(A_tn~<~_f|$9uHK9YnEv+g
zME*0EPu7T0|2bY5jJNqSD=l3bsP|7{CM`mp+xH7=ApR_K=@M0r4aDiSRL;bUk8L>+
zT%l8bBee8lm{~%g?9p78sd>~2hQrpbLo<Xx3>ce`b(c3^%PD62ml~ES%}TqYJ#pEA
zyHZb`>P5xHledREwI<k1d<ch%Uc%0*D5N@Th3WUpDWpB1D=5-{eb&KWeU=9S@#4Lc
z<bN{77{qPJxcnlJ_xAs8%mJ%sVz3MxnK=)_?sWB_FBl_(motO;8)$*&gl$ei2NE9t
zSV<F^KWaYlA~9=r-nI}O*=XLI55S&}1*2@XuA-H@oz#YT3QLQEO9GOWGIsRV<v#^h
zt81^hC7k|cAMh5-+#VU-GC!;972<6;Nj#f(usyf#1*CYFMu_b%sCbx!H?D23jh?9T
zHbEZUX0lX~Y!dbPoytj7+7GQ>7~`?&(uZscw;Ohq(wCN;Nll*Y0jvSV`#A?3J1gXY
z^Zvbd3^?nrKv!rX=-8@?>GlUyt4Km;NrXDgukQCuG3G#F?khQQAAH|svJuU^mhV4W
zBTa1BBe`AuS1ZTt$*e*k!C^iEhi@DwX6L3`d~vm1@*7I2B}%-*@J<lxB$_9Q3DL3T
z^`qmb3(0=7u{d342a_K8L#YurJyGAlYu*vr0cpHB;v}i}1XbN>eL8-nW`-AT0dXVi
zu#M)RP<nx45IMt}jld3~pe-AtBh4@ABtrSW(F#$GlB)+aF)5A1e{<Zclq%ax^+El2
zDdbqfEANV%T%VQ5v>Ph^qLOXi6{_%D`y)fN5j%OmQk{^c2u=TLv|oE*RB6rf)?&4j
z)vY>jnGeWW*+@+HN5w_-ft_W#Dq>`0nZwNj%WZsAn?jv*#Xw*TF?2A>yB*gzdNnY?
zEcNMZw=0T#*^Mu$6vg@UGB<@iiQ&ed3_J2qlR(^aUFuj!=VtZKiU7aOzA102UdqkB
zeYU7w!gBZVbNUP^j&C<J;GKm;MRupK9`6Q}QYeJNt)faaSCb>L1_=5Q4T=8O+R43=
zADUoSSr|p_;AE{}9<%eZRz8RfhzQ~ca7o)`dO!e4+o0pMtY+-$U6PhsOIdp%%nP$)
z1Rky$Au&0V8PidS`x4e;QKm6Z$g`dH2jBX3x*Iuaa!T7Ho3)&CiCXy^^XDZp#Jw(T
zCWoAgF30ZIJHl;PR~@ENbKPAJYF7y^lOS<|uSV}rY(z74LW3%bf+hR2vHLhp*upu&
zAYby5-?dx?v}lymf;M7Pb<gDqdz7{)H+(aXz#ZfZjbmb2SLz%B4iU8{5d@b-ZkwMK
z$vtZhd_?0H3|Bkx50CF>)5pB*KapqbFx5x*PN#lw5X7@F1_Zx<MHVdB*x1SqCZ%<s
zonulsyzXJFpb#_&2&9?x7sgq&scI;8Jz?Or|H2gb@`NQM!aug*N83jLpTnyGrCS+G
znE@51qbRuzaZ!6#Ew6jNnPe)50j?4X(rMg`-UE!nNw6=clp5;uy(UIRGAduW02332
z#4|fd>MehgQeIfj7vDsvdLPwq5*_;;$r8}^0R+-HDJ6-bw{byk5FT(@{;}A<V6D7=
z`OmBtHVW|EiZ3JkZFU(3u{U>2lP3}Ui}HP?fDy4`U>*plHH}y~HBo*ZohSp;D-F2+
z;9>+k<lOIQNcR?Jpce7izu0d*V56^~AckIkyMRE^DJ{bea$g{yM01-EITH&tHpwyR
z903G8J(5*a3=UVs^5O=Q_xFiB4k`oCzU~YymmrEDv*VqDd{YDdbNGg%VgW`r<3<8e
z5+4<O@z@YOp^EdTFT?cFk`G8BjQI1Mli>^`Q5!`vz_%=yU)S9=cI^qqaN7c?3$v-l
zf;E5i8D}u-xsNv_V@Tilq+y~!am})&hZfj}Drf8&b`Hu+{P&*UQeHW{*ePay(cO3c
zOhd&dzQyi!O@-o8z4yNf=2mB`81)Yvy(T07csyaw8M!!oW=l;5J)asHy-)ptGE6qE
zf|CXpzS9fD-or5O(R|1V8vQ;0GOKz+J95DPC(48?Kxc<PKu4UmU;@&PTIlNQQtl)$
z&ifg4i97r&fy~Ju;BJm++SgT48)=VliOf-Gnp=iCW2*AZc6&wMveLUyjV?2`uZvkW
z$pBi?<%tFF<UFlR`{HHlHt5HK2VRx`ewiEKk%UpNYWjiwu(aR?ZCQqSSJ9fsi=_6k
z%vvw2@C|(6Ksv%%@jPg54yF4oxNmD@R>>q^LRcLL*>~bTAk!Y(-3caEMW4;_F8}NS
z<2o-OgM^Oh9vL>ObtN>3=SGC`h%MPS&0NsT{ptf80_5si%h^<PAhY<_`Ffrh91@)s
zX6aWIxy#MVIlLh{^X_W{{VNY?!H%8Ce+c|No@tN97)8PB4QGt5Rjb^(^ZKWvoKEse
z14Qt!nC^$@m3P=3Z6#+Od?MrtpBz}~qv@k|bL|2==+Ns{^?GK^(YAJQaEML1uFGK@
zM>6dk*hB?yVqQ{RC^-|WKlM<hZyiC2kR+_U$169@uc7&t0tpYmeycrI85;M%-0j1%
zFWaUm?<o*gy#-uvC`FOPLbDR+N(V*Uzg7siD{;*{dCb`<VntgzYPLOjj`OjWfylpZ
zKdk<!aBRn}{$`iT3%v~L;r>ow21rp8fGvBEjPJ3jki-+{1CyU}y;Xm%BKn4RI~NQ8
zMDg3s7w4v`!a37{YP&${wGmoKc+l{R@?-xCE1@>SYkNnwxFWXKkAR!4mFf5qZFD{l
zLTB+z;NPfhm-VuIeZ;XdV8M?e65M_wQSf{3u+{R9F>Gqo;>8Z7V+t339WiW|@^YvN
zx6$aOpZOoj!P5~c^NJ(z3&C?8oXEfr^e*xS%T9-CK2Cjlwt=rCw3*C>@60c!9d4ip
zEu;yb<YlCjpS0e2IW9swPlUq<ZK|d4ljL<dlS$~0iixJXxVo&L%oVsdIeN-Hx*M(Z
zD!x$a{DwxLR7`(ad|B+*V1{Un0hSgxx2Y&}*k3kEAaN)r{iSJUGE-o0ouflX^YQ2v
z!GsI7f~`!C944w3NE2alhOlECVh_IU9-^%LXs4&&7S%y%N#{;K@N@&)3l4el_B^|+
zV)NM(8qAjykv{)$6fio`@dxE%WBG<u!cS?FC!kv)<?YXO+vo@hDOSn+HD3zJ5Q3SD
zzX4_}KF{pjL8P<USUX{KbT@mZ4Xh@^0{u+TPtSM+dqnHd4_XbSEBx-!n|31jQ$bpy
zTe)EzB<3+(pYD2RP=^z3qd`Mg@qPNE(pbI~eMgP!j4-c0U}Cqybhr16v5!cx+}Zme
z|KbBm7|lK*D7vg6cGk8h!pKn3Ce%AIY<XFxX+w|35MkTGDGCZ<3RXGc4tvr$@1EqU
zpS3Znta<3Ab&{<^lBBsCzZa~lD|kf76)EQ~%*BIFoW4|8_MZLDdqVf>*I9(v**8s)
zhf1|X8??r%R;dOPQ>fZ|XYt27qgi20(vkA4Ao01;xWORf4!heJfB8jnWUW-qxdg|K
zxn1DKkJd}``j}Qc0S4=KH082BaOJ7FrB82`bLL%<b*RyyzIVm9V|tyR;!><C_O8(@
zD6WA07mg;8Vi{>hKxDs)0m4$6(Ru4*y*jQ<%eoV6Y2zs6pauB$AZ(?TAk|d)*}4CE
zXt%o(FR?qYy6+~ulkuWs0D@g7*m%NP{9+<hGUNw}6`#$0L!edyRljbXT9N}yKF+oT
ztRpk0+G)c#?#V}Nq)7x@7jMn#D@~S6U6|=(IajT@XA3W2XCm0L&3xaObB@DX&E$04
zE+S`442X92FIp=nuGBO}4xZy}aupbZ?P71b&CmyG&q7FMv_F~gsNZYF_f0InbNMmO
z=96P7ChZYKcn$O(tyDF~$uA}@3uN^6*P1kUlP4PKq~LkOs4rM1$aseQ3V|SQLu-$f
z1!3SCI*@j^@f(KDgf!fSAROsB+~aBJp5mpp_3TZDx;3lXb)OZaRXXfD(*MNP^Oz*p
zZ;*N{D&30C&-KTgLEy^(m+G78O*1SR^@E*a)jVo?xdm%<(Uq!Ya)JG?boTAIySDmk
z2f<2xPP>e`pr~V&dS}*|3C_}^>~t45h2&U;XM7&dGN(hrfIFbcn&z*66J-mYe^Th#
zqNr9e3U1{olr&2AMyowLP(GDqlX-UVqeJ_tUlIjct<^rPqx>W9ZpdgooWBMI>!a)m
zOm);Mg17I9qguyPhm_;U8^8Yf5_iUa9$i`LBPGb9S32Krw#eZwzojeDH~Q2NK6f`f
z^}=m)GuqqMV$#&SJA7^TU6ZS*g^xtfe`ZE24mzfP`L@mZeFoMDl~=9Xd8jK}+gEw3
z_ilOtlcwLhtUR%F%B+~qQ6!B`2>n)4P<ssa1_t!mj()R;zHhU856Mgf>1?}&xaE*l
zIuUn9?7S&kAKF;)w?RkCtq|~Bekh-zSiX02G))D1@OL>)UN}|X*MeIo#r#sh`G6hS
zg6Nz1c4rfyy!9cli~OHsa0A2Sf+?~k;KPLPnYrU=GTd$Rt2F9B?jPkzl1$90r0Dv`
z1hsNDlP3ElBD&=Y@&lJvBf}Hqg44uhHCDj!bULUFepsz|li{Iw^H1|cJ~4RWephmh
zj&(BHEC6)vfW|?;3*_d<iAQqKiK;U+bjhL$JgCe&wq*iBtUXq<)+*#rLkT|HoguAi
zOE};Ok6>Q1rQNqVX<6IQz=vE)^6u!?HM!k;)_uN1$JLLLh5M{W`Uc>ukJGi-o!OHJ
z%E<{GsE%~$$43C`Tj{xxp>ic9G|302>f2@S4=J;_*?SN|xMksUiy6%8Ex~X$u_n{v
zIzc^K&fFt(OAxwhx)vO?T5<5S8CNf<1#e5pgQHawA^p^DhatFI^|3nR2q+5tY>ENe
zsHyytC-Lg{44W)`VKt+SU|m=_T+{wN!Ms9Xl9qk^rS2z(00~l@SQb&Vm{87QGA#8k
z{|CV1?U-=ie)L8@PV!CwSi=!G$4Rx2pn;Nq=1;QFUS4R_tn|I^0DC5CL`b)^y8u%P
zAB3odtoLQU(oGb5BhknSnumf>@<nZ5_%j!Y=58I>W!vQBtZg>YS*jD?Z|Jm&By0gn
zAfe{5YcdcgWag@Atf`>g%c?pUCG<!rQ71puBw5SC9FJ8_FWjp?eod6x+E@H2m`C(Z
zh8Jr^xJ<1kcoOU^QZ5I{&S=xdEDA<Q-}d(Vxj(3bZ<yC|{HVbR^Z!M&cX-uIa>5$_
zxiyaoOQ3fta3{mlzmV<xSq)DQb#$1g#+_97hr#(je#`%-_}oGsnMV%~Ue^~FuIrOi
Qj~gsa)wi#zlr1Cv2Z>C}O#lD@

literal 0
HcmV?d00001

diff --git a/apps/web/src/components/forms/monetdb.tsx b/apps/web/src/components/forms/monetdb.tsx
new file mode 100644
index 00000000..8b8866cf
--- /dev/null
+++ b/apps/web/src/components/forms/monetdb.tsx
@@ -0,0 +1,303 @@
+import type { PostgreSQLDataSource } from '@briefer/database'
+import Link from 'next/link'
+import { useEffect } from 'react'
+import { useForm } from 'react-hook-form'
+
+import FormError from './formError'
+import FileUploadInput from './FileUploadInput'
+import { readFile } from '@/utils/file'
+import { GATEWAY_IP } from '@/utils/info'
+import Spin from '../Spin'
+
+export type PostgreSQLDataSourceInput = PostgreSQLDataSource & {
+  password: string
+  cert?: string
+}
+
+type PostgreSQLDataSourceFormValues = Omit<
+  PostgreSQLDataSourceInput,
+  'cert'
+> & {
+  password: string
+  cert: File
+}
+
+type PostgreSQLFormProps = {
+  onSubmit: (values: PostgreSQLDataSourceInput) => Promise<void>
+  postgreSQLDataSource?: PostgreSQLDataSource | null
+  workspaceId: string
+}
+
+export default function MonetDBForm({
+  postgreSQLDataSource,
+  onSubmit,
+  workspaceId,
+}: PostgreSQLFormProps) {
+  const isEditing = Boolean(postgreSQLDataSource)
+
+  const { register, handleSubmit, formState, reset, control } =
+    useForm<PostgreSQLDataSourceFormValues>({
+      mode: 'onChange',
+      defaultValues: { readOnly: true },
+    })
+
+  useEffect(() => {
+    if (postgreSQLDataSource) {
+      reset(postgreSQLDataSource)
+    }
+  }, [postgreSQLDataSource, reset])
+
+  const onSubmitHandler = handleSubmit(async (data) => {
+    const certFile = data.cert
+    let certContent = undefined as string | undefined
+    if (certFile) {
+      certContent = await readFile(certFile, 'hex')
+    }
+
+    await onSubmit({
+      ...data,
+      cert: certContent,
+    })
+  })
+
+  return (
+    <form className="px-4 sm:p-6 lg:p-12" onSubmit={onSubmitHandler} noValidate>
+      <div className="space-y-12">
+        <div className="border-b border-gray-900/10 pb-8">
+          <h2 className="text-lg font-semibold leading-7 text-gray-900">
+            {postgreSQLDataSource ? 'Edit' : 'New'} PostgreSQL data source
+          </h2>
+          <p className="mt-1 text-sm leading-6 text-gray-500">
+            {postgreSQLDataSource ? 'Edit' : 'Add'} a PostgreSQL database for
+            Briefer to pull data from. Our fixed IP address is{' '}
+            <code className="bg-gray-100 px-1 py-0.5 rounded-md text-red-500 text-xs">
+              {GATEWAY_IP()}
+            </code>
+            .
+          </p>
+
+          <div className="mt-10 grid grid-cols-1 gap-x-6 gap-y-2 sm:grid-cols-10">
+            <div className="col-span-full">
+              <label
+                htmlFor="name"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                Display name
+              </label>
+              <div className="mt-2">
+                <input
+                  {...register('name', {
+                    required: {
+                      value: true,
+                      message: 'Display name is required.',
+                    },
+                  })}
+                  type="text"
+                  name="name"
+                  placeholder="My PostgreSQL database"
+                  required
+                  className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
+                />
+                <FormError msg={formState.errors.name?.message} />
+              </div>
+            </div>
+
+            <div className="col-span-7">
+              <label
+                htmlFor="host"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                Host
+              </label>
+              <div className="mt-2">
+                <input
+                  {...register('host', {
+                    required: { value: true, message: 'Host is required.' },
+                  })}
+                  type="text"
+                  name="host"
+                  placeholder="example.com"
+                  required
+                  className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
+                />
+                <FormError msg={formState.errors.host?.message} />
+              </div>
+            </div>
+
+            <div className="col-span-3">
+              <label
+                htmlFor="port"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                Port
+              </label>
+              <div className="mt-2">
+                <input
+                  {...register('port', {
+                    required: { value: true, message: 'Port is required.' },
+                    validate: (v: any) => {
+                      v = parseInt(v)
+                      if (isNaN(v)) return 'Port must be a number.'
+                      return true
+                    },
+                  })}
+                  type="number"
+                  name="port"
+                  placeholder="5432"
+                  required
+                  className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
+                />
+                <FormError msg={formState.errors.port?.message} />
+              </div>
+            </div>
+
+            <div className="col-span-4">
+              <label
+                htmlFor="database"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                Database name
+              </label>
+              <div className="mt-2">
+                <input
+                  {...register('database', {
+                    required: {
+                      value: true,
+                      message: 'Database is required.',
+                    },
+                  })}
+                  type="text"
+                  name="database"
+                  placeholder="db"
+                  required
+                  className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
+                />
+                <FormError msg={formState.errors.database?.message} />
+              </div>
+            </div>
+
+            <div className="col-span-3">
+              <label
+                htmlFor="username"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                Username
+              </label>
+              <div className="mt-2">
+                <input
+                  {...register('username', {
+                    required: {
+                      value: true,
+                      message: 'Username is required.',
+                    },
+                  })}
+                  type="text"
+                  name="username"
+                  placeholder="postgres"
+                  required
+                  className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
+                />
+                <FormError msg={formState.errors.username?.message} />
+              </div>
+            </div>
+
+            <div className="col-span-3">
+              <label
+                htmlFor="password"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                Password
+              </label>
+              <div className="mt-2">
+                <input
+                  {...register('password', {
+                    required: {
+                      value: !isEditing,
+                      message: 'Password is required.',
+                    },
+                  })}
+                  type="password"
+                  name="password"
+                  required={!isEditing}
+                  className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
+                />
+                {isEditing && !Boolean(formState.errors.password) && (
+                  <span className="block text-sm text-gray-900 empty:before:content-['\200b'] pt-1 pb-1">
+                    Leave empty to keep previous password
+                  </span>
+                )}
+                <FormError msg={formState.errors.password?.message} />
+              </div>
+            </div>
+            <div className="col-span-full">
+              <label
+                htmlFor="cert"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                SSL Cert
+              </label>
+              <FileUploadInput
+                label={
+                  isEditing
+                    ? 'Upload a new SSL cert, leave empty if not needed'
+                    : 'Upload a SSL cert, leave empty if not needed'
+                }
+                subLabel={
+                  isEditing
+                    ? 'or drag and drop, leave empty to keep previous cert'
+                    : 'or drag and drop'
+                }
+                control={control}
+                {...register('cert')}
+              />
+            </div>
+
+            <div className="col-span-full">
+              <label
+                htmlFor="notes"
+                className="block text-sm font-medium leading-6 text-gray-900"
+              >
+                Notes
+              </label>
+              <div className="mt-2">
+                <textarea
+                  {...register('notes', { required: false })}
+                  name="notes"
+                  rows={3}
+                  className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
+                  defaultValue={''}
+                />
+              </div>
+              <p className="mt-3 text-sm leading-6 text-gray-600">
+                Add any notes about this database you may want others to be
+                aware of.
+              </p>
+            </div>
+          </div>
+        </div>
+      </div>
+
+      <div className="mt-6 flex items-center justify-end gap-x-4">
+        <Link
+          href={`/workspaces/${workspaceId}/data-sources`}
+          className="text-sm font-semibold leading-6 text-gray-600 border border-gray-400 px-6 py-1.5 rounded-sm shadow-sm hover:bg-gray-50"
+        >
+          Cancel
+        </Link>
+        <button
+          type="submit"
+          className="flex items-center justify-center gap-x-2 rounded-sm shadow-sm bg-primary-200 px-6 py-2.5 text-sm font-semibold hover:bg-primary-300 border-stone-950 disabled:bg-gray-300 disabled:cursor-not-allowed"
+          disabled={formState.isSubmitting}
+        >
+          {formState.isSubmitting ? (
+            <>
+              <Spin /> Validating
+            </>
+          ) : (
+            'Save'
+          )}
+        </button>
+      </div>
+    </form>
+  )
+}
diff --git a/apps/web/src/hooks/useDatasource.ts b/apps/web/src/hooks/useDatasource.ts
index 8c03c64c..7812fe2b 100644
--- a/apps/web/src/hooks/useDatasource.ts
+++ b/apps/web/src/hooks/useDatasource.ts
@@ -94,6 +94,7 @@ export const useNewDataSource = (workspaceId: string) => {
         | 'mysql'
         | 'trino'
         | 'sqlserver'
+        | 'monetdb'
     ): Promise<DataSource> => {
       if (!workspaceId) {
         throw new Error('Missing workspaceId')
diff --git a/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/index.tsx b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/index.tsx
index e2ed056c..6eb00e79 100644
--- a/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/index.tsx
+++ b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/index.tsx
@@ -34,7 +34,7 @@ const DataSourceBlock = ({ name, icon, href }: DataSourceBlockProps) => {
       href={href}
       className="py-5 px-6 w-36 h-36 border border-gray-200 rounded-md flex flex-col items-center justify-between bg-gray-50 hover:bg-ceramic-50 hover:border-gray-300"
     >
-      <img src={icon} alt="" className="h-16 w-16" />
+      <img src={icon} alt="" className="h-16 w-16 object-contain" />
       <span className="text-md">{name}</span>
     </Link>
   )
@@ -98,6 +98,11 @@ export default function DataSourcesPage() {
               name="Trino"
               href={`/workspaces/${workspaceId}/data-sources/new/trino`}
             />
+            <DataSourceBlock
+              icon="/icons/monetdb.png"
+              name="MonetDB"
+              href={`/workspaces/${workspaceId}/data-sources/new/monetdb`}
+            />
 
             <button
               onClick={onToggleFiles}
diff --git a/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx
new file mode 100644
index 00000000..321620ff
--- /dev/null
+++ b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx
@@ -0,0 +1,63 @@
+import Layout from '@/components/Layout'
+import { useRouter } from 'next/router'
+import {
+  CircleStackIcon,
+  Cog8ToothIcon,
+  PlusCircleIcon,
+} from '@heroicons/react/24/outline'
+import {
+  PostgreSQLDataSourceInput,
+} from '@/components/forms/postgresql'
+import { useCallback } from 'react'
+import { useNewDataSource } from '@/hooks/useDatasource'
+import { useStringQuery } from '@/hooks/useQueryArgs'
+import MonetDBForm from '@/components/forms/monetdb'
+
+const pagePath = (workspaceId: string) => [
+  { name: 'Configurations', icon: Cog8ToothIcon, href: '#', current: false },
+  {
+    name: 'Data sources',
+    icon: CircleStackIcon,
+    href: `/workspaces/${workspaceId}/data-sources`,
+    current: false,
+  },
+  {
+    name: 'Add MonetDB data source',
+    icon: PlusCircleIcon,
+    href: '#',
+    current: true,
+  },
+]
+
+export default function NewDataSourceMonetDBPage() {
+  const router = useRouter()
+  const workspaceId = useStringQuery('workspaceId')
+
+  const newDataSource = useNewDataSource(workspaceId)
+
+  const onSubmit = useCallback(
+    async (data: PostgreSQLDataSourceInput) => {
+      try {
+        const ds = await newDataSource(data, 'psql')
+        if (ds.data.connStatus === 'offline') {
+          router.push(
+            `/workspaces/${workspaceId}/data-sources?offline=${ds.data.id}`
+          )
+        } else {
+          router.push(`/workspaces/${workspaceId}/data-sources`)
+        }
+      } catch {
+        alert('Something went wrong')
+      }
+    },
+    [workspaceId]
+  )
+
+  return (
+    <Layout pagePath={pagePath(workspaceId)} hideOnboarding>
+      <div className="w-full overflow-scroll">
+        <MonetDBForm workspaceId={workspaceId} onSubmit={onSubmit} />
+      </div>
+    </Layout>
+  )
+}

From 19a22ee72b653c067949e86ca4f4cfd885f6bb8f Mon Sep 17 00:00:00 2001
From: Hitesh Wadhwani <hiteshwadhwani1403@gmail.com>
Date: Tue, 8 Oct 2024 18:43:20 +0530
Subject: [PATCH 2/6] added monetdb to db-packages

---
 packages/database/prisma/schema.prisma       |  24 +++
 packages/database/src/datasources/index.ts   |  39 +++++
 packages/database/src/datasources/monetdb.ts | 149 +++++++++++++++++++
 3 files changed, 212 insertions(+)
 create mode 100644 packages/database/src/datasources/monetdb.ts

diff --git a/packages/database/prisma/schema.prisma b/packages/database/prisma/schema.prisma
index eb81f99d..cce56693 100644
--- a/packages/database/prisma/schema.prisma
+++ b/packages/database/prisma/schema.prisma
@@ -259,6 +259,29 @@ model TrinoDataSource {
   workspace   Workspace @relation(fields: [workspaceId], references: [id], onDelete: Cascade)
 }
 
+model MonetDBDataSource {
+  id             String     @id @default(dbgenerated("gen_random_uuid()")) @db.Uuid
+  name           String
+  host           String
+  port           String
+  database       String
+  username       String
+  password       String
+  notes          String
+  readOnly       Boolean    @default(true)
+  cert           String?
+  structure      String?
+  isDemo         Boolean    @default(false)
+  createdAt      DateTime   @default(now())
+  updatedAt      DateTime   @default(now()) @updatedAt
+  connStatus     ConnStatus @default(online)
+  connError      String?
+  lastConnection DateTime?
+
+  workspaceId String    @db.Uuid
+  workspace   Workspace @relation(fields: [workspaceId], references: [id], onDelete: Cascade)
+}
+
 model User {
   id             String   @id @default(dbgenerated("gen_random_uuid()")) @db.Uuid
   name           String   @default("")
@@ -369,6 +392,7 @@ model Workspace {
   mySQLDataSources     MySQLDataSource[]
   sqlServerDataSources SQLServerDataSource[]
   trinoDataSources     TrinoDataSource[]
+  monetDBDataSources   MonetDBDataSource[]
   environmentVariables EnvironmentVariable[]
 }
 
diff --git a/packages/database/src/datasources/index.ts b/packages/database/src/datasources/index.ts
index 7b3034a4..afde7e66 100644
--- a/packages/database/src/datasources/index.ts
+++ b/packages/database/src/datasources/index.ts
@@ -9,6 +9,7 @@ import * as oracle from './oracle.js'
 import * as mysql from './mysql.js'
 import * as trino from './trino.js'
 import * as sqlserver from './sqlserver.js'
+import * as monetdb from './monetdb.js'
 import { DataSourceStructureStateV2 } from '@briefer/types'
 import { z } from 'zod'
 
@@ -40,6 +41,7 @@ export type DataSource =
   | { type: 'mysql'; data: MySQLDataSource }
   | { type: 'trino'; data: TrinoDataSource }
   | { type: 'sqlserver'; data: SQLServerDataSource }
+  | { type: 'monetdb'; data: monetdb.MonetDBDataSource }
 
 export type DataSourceType = DataSource['type']
 
@@ -139,6 +141,12 @@ export async function getDatasource(
         .then((data): DataSource | null =>
           data ? { type: 'sqlserver', data } : null
         )
+    case 'monetdb':
+      return monetdb
+        .getMonetDbDataSource(workspaceId, id)
+        .then((data): DataSource | null =>
+          data ? { type: 'monetdb', data } : null
+        )
   }
 }
 
@@ -196,6 +204,19 @@ export async function getDatasourcePassword(
     case 'bigquery':
     case 'athena':
       return ''
+    case 'monetdb':
+      return prisma()
+        .monetDBDataSource.findFirstOrThrow({
+          where: {
+            id: datasource.data.id,
+          },
+          select: {
+            password: true,
+          },
+        })
+        .then((row) =>
+          row.password !== null ? decrypt(row.password, encryptionKey) : ''
+        )
   }
 }
 
@@ -285,6 +306,12 @@ export async function getDatabaseURL(
       )
       return `mssql+pymssql://${ds.data.username}:${password}@${ds.data.host}:${ds.data.port}/${ds.data.database}`
     }
+    case 'monetdb': {
+      const password = encodeURIComponent(
+        await getDatasourcePassword(ds, encryptionKey)
+      )
+      return `monetdb://${ds.data.host}:${ds.data.port}/${ds.data.database}?user=${ds.data.username}&password=${password}`
+    }
   }
 }
 
@@ -339,6 +366,18 @@ export async function getCredentialsInfo(
         sslrootcert: decrypt(mysql.cert, encryptionKey),
       }
     }
+    case 'monetdb': {
+      const monetdb = await prisma().monetDBDataSource.findFirstOrThrow({
+        where: { id: ds.data.id },
+      })
+      if (!monetdb.cert) {
+        return null
+      }
+
+      return {
+        sslrootcert: decrypt(monetdb.cert, encryptionKey),
+      }
+    }
   }
 }
 
diff --git a/packages/database/src/datasources/monetdb.ts b/packages/database/src/datasources/monetdb.ts
new file mode 100644
index 00000000..a3bfb0b9
--- /dev/null
+++ b/packages/database/src/datasources/monetdb.ts
@@ -0,0 +1,149 @@
+import { MonetDBDataSource as PrismaMonetDBDataSource } from '@prisma/client'
+
+import { DataSource } from './index.js'
+import prisma from '../index.js'
+import { decrypt, encrypt } from './crypto.js'
+
+export type MonetDBDataSource = Omit<
+    PrismaMonetDBDataSource,
+  | 'createdAt'
+  | 'updatedAt'
+  | 'lastConnection'
+  | 'password'
+  | 'cert'
+  | 'structure'
+> & {
+  createdAt: string
+  updatedAt: string
+  lastConnection: string | null
+}
+
+function toMonedDbDataSource(
+  pdataSource: PrismaMonetDBDataSource
+): MonetDBDataSource {
+  return {
+    id: pdataSource.id,
+    name: pdataSource.name,
+    host: pdataSource.isDemo ? '' : pdataSource.host,
+    port: pdataSource.isDemo ? '' : pdataSource.port,
+    database: pdataSource.isDemo ? '' : pdataSource.database,
+    username: pdataSource.isDemo ? '' : pdataSource.username,
+    notes: pdataSource.notes,
+    workspaceId: pdataSource.workspaceId,
+    readOnly: pdataSource.readOnly,
+    isDemo: pdataSource.isDemo,
+    createdAt: pdataSource.createdAt.toISOString(),
+    updatedAt: pdataSource.updatedAt.toISOString(),
+    connStatus: pdataSource.connStatus,
+    connError: pdataSource.connError,
+    lastConnection: pdataSource.lastConnection?.toISOString() ?? null,
+  }
+}
+
+export async function getMonetDbCert(
+  ds: MonetDBDataSource,
+  encryptionKey: string
+): Promise<Buffer | null> {
+  const cert = await prisma()
+    .monetDBDataSource.findUnique({
+      where: { id: ds.id },
+      select: { cert: true },
+    })
+    .then((row) => row?.cert)
+
+  if (!cert) {
+    return null
+  }
+
+  const hex = decrypt(cert, encryptionKey)
+  return Buffer.from(hex, 'hex')
+}
+
+export async function getMonetDbPassword(
+  ds: MonetDBDataSource,
+  encryptionKey: string
+): Promise<string> {
+  const password = await prisma()
+    .monetDBDataSource.findUnique({
+      where: { id: ds.id },
+      select: { password: true },
+    })
+    .then((row) => row?.password)
+
+  if (!password) {
+    throw new Error(`Fail to fetch password for datasource ${ds.id}`)
+  }
+
+  return decrypt(password, encryptionKey)
+}
+
+export async function listMonetDbDataSources(
+  workspaceId: string
+): Promise<DataSource[]> {
+  const fromDB = await prisma().monetDBDataSource.findMany({
+    where: { workspaceId },
+  })
+
+  return fromDB.map(
+    (pd): DataSource => ({ type: 'monetdb', data: toMonedDbDataSource(pd) })
+  )
+}
+
+export async function updateMonedDbDataSource(
+  data: Partial<Omit<PrismaMonetDBDataSource, 'createdAt' | 'updatedAt'>>,
+  encryptionKey: string
+): Promise<MonetDBDataSource> {
+  return prisma()
+    .monetDBDataSource.update({
+      where: { id: data.id },
+      data: {
+        ...data,
+        password: data.password
+          ? encrypt(data.password, encryptionKey)
+          : undefined,
+        cert: data.cert ? encrypt(data.cert, encryptionKey) : undefined,
+      },
+    })
+    .then(toMonedDbDataSource)
+}
+
+export async function createMonetDbDataSource(
+  data: Omit<
+  PrismaMonetDBDataSource,
+    'id' | 'createdAt' | 'updatedAt' | 'structure' | 'isDemo'
+  >,
+  encryptionKey: string
+): Promise<MonetDBDataSource> {
+  return prisma()
+    .monetDBDataSource.create({
+      data: {
+        ...data,
+        password: encrypt(data.password, encryptionKey),
+        cert: data.cert ? encrypt(data.cert, encryptionKey) : undefined,
+      },
+    })
+    .then(toMonedDbDataSource)
+}
+
+export async function getMonetDbDataSource(
+  workspaceId: string,
+  id: string
+): Promise<MonetDBDataSource | null> {
+  const fromDB = await prisma().monetDBDataSource.findUnique({
+    where: { workspaceId, id },
+  })
+  if (!fromDB) {
+    return null
+  }
+
+  return toMonedDbDataSource(fromDB)
+}
+
+export async function deleteMonetDbDataSource(
+  workspaceId: string,
+  id: string
+): Promise<MonetDBDataSource> {
+  return toMonedDbDataSource(
+    await prisma().monetDBDataSource.delete({ where: { workspaceId, id } })
+  )
+}

From fea126a56a823ff259c1aa0df2d124e4d3db9cfd Mon Sep 17 00:00:00 2001
From: Hitesh Wadhwani <hiteshwadhwani1403@gmail.com>
Date: Wed, 9 Oct 2024 21:13:11 +0530
Subject: [PATCH 3/6] fixed

---
 packages/database/src/datasources/index.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/packages/database/src/datasources/index.ts b/packages/database/src/datasources/index.ts
index f8c8a1af..56e69f7c 100644
--- a/packages/database/src/datasources/index.ts
+++ b/packages/database/src/datasources/index.ts
@@ -34,6 +34,7 @@ export type MySQLDataSource = mysql.MySQLDataSource
 export type TrinoDataSource = trino.TrinoDataSource
 export type SQLServerDataSource = sqlserver.SQLServerDataSource
 export type SnowflakeDataSource = snowflake.SnowflakeDataSource
+export type MonetDBDataSource = monetdb.MonetDBDataSource
 
 export type DataSource =
   | { type: 'psql'; data: PostgreSQLDataSource }
@@ -44,7 +45,7 @@ export type DataSource =
   | { type: 'mysql'; data: MySQLDataSource }
   | { type: 'trino'; data: TrinoDataSource }
   | { type: 'sqlserver'; data: SQLServerDataSource }
-  | { type: 'monetdb'; data: monetdb.MonetDBDataSource }
+  | { type: 'monetdb'; data: MonetDBDataSource }
   | { type: 'snowflake'; data: SnowflakeDataSource }
 
 export type DataSourceType = DataSource['type']
@@ -59,6 +60,7 @@ export const DataSourceType = z.enum([
   'sqlserver',
   'trino',
   'snowflake',
+  'monetdb',
 ] as const)
 
 // Ensure Zod enum stays in sync with `DataSourceType`
@@ -88,6 +90,7 @@ export async function listDataSources(
     sqlserver.listSQLServerDataSources(workspaceId),
     trino.listTrinoDataSources(workspaceId),
     snowflake.listSnowflakeDataSources(workspaceId),
+    monetdb.listMonetDbDataSources(workspaceId),
   ])
 
   return dbs.reduce((acc, cur) => acc.concat(cur), [])

From 090b56a72e9f7e226d7a98fc98ac2ea241a0a4cd Mon Sep 17 00:00:00 2001
From: Hitesh Wadhwani <hiteshwadhwani1403@gmail.com>
Date: Wed, 9 Oct 2024 23:02:59 +0530
Subject: [PATCH 4/6] api updated

---
 apps/api/src/auth/token.ts                    |  4 ++
 apps/api/src/datasources/index.ts             |  6 ++
 apps/api/src/datasources/monetdb.ts           | 46 ++++++++++++++
 apps/api/src/datasources/structure.ts         | 22 +++++++
 apps/api/src/python/query/index.ts            | 13 ++++
 apps/api/src/python/query/monetdb.ts          | 63 +++++++++++++++++++
 apps/api/src/python/query/sqlalchemy.ts       |  3 +-
 .../workspace/data-sources/data-source.ts     | 16 +++++
 .../workspace/data-sources/index.ts           | 32 ++++++++++
 packages/database/src/datasources/index.ts    |  1 +
 10 files changed, 205 insertions(+), 1 deletion(-)
 create mode 100644 apps/api/src/datasources/monetdb.ts
 create mode 100644 apps/api/src/python/query/monetdb.ts

diff --git a/apps/api/src/auth/token.ts b/apps/api/src/auth/token.ts
index e3e14ffd..6a39f4bc 100644
--- a/apps/api/src/auth/token.ts
+++ b/apps/api/src/auth/token.ts
@@ -318,5 +318,9 @@ export const isAuthorizedForDataSource = async (
       const result = await prisma().snowflakeDataSource.findFirst(query)
       return result !== null
     }
+    case 'monetdb': {
+      const result = await prisma().monetDBDataSource.findFirst(query)
+      return result !== null
+    }
   }
 }
diff --git a/apps/api/src/datasources/index.ts b/apps/api/src/datasources/index.ts
index 38f40ee1..3243b7dd 100644
--- a/apps/api/src/datasources/index.ts
+++ b/apps/api/src/datasources/index.ts
@@ -8,6 +8,7 @@ import * as mysql from './mysql.js'
 import * as trino from './trino.js'
 import * as sqlserver from './sqlserver.js'
 import * as snowflake from './snowflake.js'
+import * as monetdb from "./monetdb"
 import { DataSourceConnectionError } from '@briefer/types'
 
 export async function ping(ds: DataSource): Promise<DataSource> {
@@ -40,6 +41,9 @@ export async function ping(ds: DataSource): Promise<DataSource> {
     case 'snowflake':
       result = await snowflake.ping(ds.data)
       break
+    case "monetdb":
+      result = await monetdb.ping(ds.data)
+      break
   }
 
   return result
@@ -78,5 +82,7 @@ export async function updateConnStatus(
       return trino.updateConnStatus(ds.data, status)
     case 'snowflake':
       return snowflake.updateConnStatus(ds.data, status)
+    case "monetdb":
+      return monetdb.updateConnStatus(ds.data, status)
   }
 }
diff --git a/apps/api/src/datasources/monetdb.ts b/apps/api/src/datasources/monetdb.ts
new file mode 100644
index 00000000..b6e746ee
--- /dev/null
+++ b/apps/api/src/datasources/monetdb.ts
@@ -0,0 +1,46 @@
+import { config } from '../config/index.js'
+import prisma, { DataSource, MonetDBDataSource } from '@briefer/database'
+import { DataSourceStatus } from './index.js'
+import { pingMonetDb } from '../python/query/monetdb.js'
+
+export async function ping(ds: MonetDBDataSource): Promise<DataSource> {
+  const lastConnection = new Date()
+  const err = await pingMonetDb(ds, config().DATASOURCES_ENCRYPTION_KEY)
+
+  if (!err) {
+    return updateConnStatus(ds, {
+      connStatus: 'online',
+      lastConnection,
+    })
+  }
+
+  return updateConnStatus(ds, { connStatus: 'offline', connError: err })
+}
+
+export async function updateConnStatus(
+  ds: MonetDBDataSource,
+  status: DataSourceStatus
+): Promise<DataSource> {
+  const newDs = await prisma().monetDBDataSource.update({
+    where: { id: ds.id },
+    data: {
+      connStatus: status.connStatus,
+      lastConnection:
+        status.connStatus === 'online' ? status.lastConnection : undefined,
+      connError:
+        status.connStatus === 'offline'
+          ? JSON.stringify(status.connError)
+          : undefined,
+    },
+  })
+
+  return {
+    type: "monetdb",
+    data: {
+      ...ds,
+      connStatus: newDs.connStatus,
+      lastConnection: newDs.lastConnection?.toISOString() ?? null,
+      connError: newDs.connError,
+    },
+  }
+}
diff --git a/apps/api/src/datasources/structure.ts b/apps/api/src/datasources/structure.ts
index f4736695..bb6316cf 100644
--- a/apps/api/src/datasources/structure.ts
+++ b/apps/api/src/datasources/structure.ts
@@ -23,6 +23,7 @@ import { getOracleSchema } from '../python/query/oracle.js'
 import { getBigQuerySchema } from '../python/query/bigquery.js'
 import { getTrinoSchema } from '../python/query/trino.js'
 import { getSnowflakeSchema } from '../python/query/snowflake.js'
+import { getMonetDBSchema } from '../python/query/monetdb.js'
 import { getAthenaSchema } from './athena.js'
 import { getMySQLSchema } from './mysql.js'
 import { z } from 'zod'
@@ -127,6 +128,14 @@ async function getFromCache(
         })
       ).structure
       break
+    case "monetdb":
+      encrypted = (
+        await prisma().monetDBDataSource.findUniqueOrThrow({
+          where: { id: dataSourceId },
+          select: { structure: true },
+        })
+      ).structure
+      break
   }
 
   if (encrypted === null) {
@@ -307,6 +316,13 @@ async function _refreshDataSourceStructure(
           onTable
         )
         break
+      case "monetdb":
+        finalStructure = await getMonetDBSchema(
+          dataSource.config.data,
+          config().DATASOURCES_ENCRYPTION_KEY,
+          onTable
+        )
+        break
     }
 
     await updateQueue.onIdle()
@@ -461,6 +477,12 @@ async function persist(ds: APIDataSource): Promise<APIDataSource> {
           data: { structure },
         })
         return ds
+      case "monetdb":
+        await prisma().monetDBDataSource.update({
+          where: { id: ds.config.data.id },
+          data: { structure },
+        })
+        return ds
     }
   })()
 }
diff --git a/apps/api/src/python/query/index.ts b/apps/api/src/python/query/index.ts
index a4e16b6c..5b3b710e 100644
--- a/apps/api/src/python/query/index.ts
+++ b/apps/api/src/python/query/index.ts
@@ -21,6 +21,7 @@ import { makeSnowflakeQuery } from './snowflake.js'
 import { updateConnStatus } from '../../datasources/index.js'
 import { getJupyterManager } from '../../jupyter/index.js'
 import { makeSQLServerQuery } from './sqlserver.js'
+import { makeMonetDBQuery } from './monetdb'
 
 export async function makeSQLQuery(
   workspaceId: string,
@@ -144,6 +145,18 @@ export async function makeSQLQuery(
         onProgress
       )
       break
+    case "monetdb":
+      result = await makeMonetDBQuery(
+        workspaceId,
+        sessionId,
+        queryId,
+        dataframeName,
+        datasource.data,
+        encryptionKey,
+        sql,
+        onProgress
+      )
+      break
   }
 
   result[0].then(async (r) => {
diff --git a/apps/api/src/python/query/monetdb.ts b/apps/api/src/python/query/monetdb.ts
new file mode 100644
index 00000000..e5b59912
--- /dev/null
+++ b/apps/api/src/python/query/monetdb.ts
@@ -0,0 +1,63 @@
+import { v4 as uuidv4 } from 'uuid'
+import {
+  PostgreSQLDataSource,
+  RedshiftDataSource,
+  getDatabaseURL,
+} from '@briefer/database'
+import {
+  DataSourceStructure,
+  RunQueryResult,
+  SuccessRunQueryResult,
+} from '@briefer/types'
+import {
+  getSQLAlchemySchema,
+  makeSQLAlchemyQuery,
+  pingSQLAlchemy,
+} from './sqlalchemy.js'
+import { OnTable } from '../../datasources/structure.js'
+
+export async function makeMonetDBQuery(
+  workspaceId: string,
+  sessionId: string,
+  queryId: string,
+  dataframeName: string,
+  datasource: PostgreSQLDataSource | RedshiftDataSource,
+  encryptionKey: string,
+  sql: string,
+  onProgress: (result: SuccessRunQueryResult) => void
+): Promise<[Promise<RunQueryResult>, () => Promise<void>]> {
+  const databaseUrl = await getDatabaseURL(
+    { type: "monetdb", data: datasource },
+    encryptionKey
+  )
+
+  const jobId = uuidv4()
+  const query = `${sql}  -- Briefer jobId: ${jobId}`
+
+  return makeSQLAlchemyQuery(
+    workspaceId,
+    sessionId,
+    dataframeName,
+    databaseUrl,
+    "monetdb",
+    jobId,
+    query,
+    queryId,
+    onProgress
+  )
+}
+
+export function pingMonetDb(
+  ds: PostgreSQLDataSource | RedshiftDataSource,
+  encryptionKey: string
+): Promise<null | Error> {
+  return pingSQLAlchemy({ type: "monetdb", data: ds }, encryptionKey, null)
+}
+
+export function getMonetDBSchema(
+  ds: PostgreSQLDataSource | RedshiftDataSource,
+  encryptionKey: string,
+  onTable: OnTable
+): Promise<DataSourceStructure> {
+  return getSQLAlchemySchema({ type: "monetdb", data: ds }, encryptionKey, null, onTable)
+}
diff --git a/apps/api/src/python/query/sqlalchemy.ts b/apps/api/src/python/query/sqlalchemy.ts
index 69dccacb..5c1919db 100644
--- a/apps/api/src/python/query/sqlalchemy.ts
+++ b/apps/api/src/python/query/sqlalchemy.ts
@@ -24,7 +24,8 @@ export async function makeSQLAlchemyQuery(
     | 'psql'
     | 'redshift'
     | 'trino'
-    | 'snowflake',
+    | 'snowflake'
+    | "monetdb",
   jobId: string,
   query: string,
   queryId: string,
diff --git a/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts b/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts
index db4bab5d..603d849e 100644
--- a/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts
+++ b/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts
@@ -29,6 +29,7 @@ import {
   getSnowflakeDataSource,
   updateSnowflakeDataSource,
   deleteSnowflakeDataSource,
+  getMonetDbDataSource
 } from '@briefer/database'
 import { z } from 'zod'
 import { getParam } from '../../../../utils/express.js'
@@ -148,6 +149,20 @@ const dataSourceRouter = (socketServer: IOServer) => {
         notes: z.string(),
       }),
     }),
+    z.object({
+      type: z.literal('monetdb'),
+      data: z.object({
+        name: z.string().min(1),
+        host: z.string().min(1),
+        port: z.string().min(1),
+        database: z.string().min(1),
+        username: z.string().min(1),
+        password: z.string().min(1),
+        notes: z.string(),
+        readOnly: z.boolean(),
+        cert: z.string().optional(),
+      }),
+    }),
   ])
 
   router.put('/', async (req, res) => {
@@ -171,6 +186,7 @@ const dataSourceRouter = (socketServer: IOServer) => {
         getSQLServerDataSource(workspaceId, dataSourceId),
         getTrinoDataSource(workspaceId, dataSourceId),
         getSnowflakeDataSource(workspaceId, dataSourceId),
+        getMonetDbDataSource(workspaceId, dataSourceId),
       ])
     ).find((e) => e !== null)
     if (!existingDb) {
diff --git a/apps/api/src/v1/workspaces/workspace/data-sources/index.ts b/apps/api/src/v1/workspaces/workspace/data-sources/index.ts
index 3389ab15..a589179d 100644
--- a/apps/api/src/v1/workspaces/workspace/data-sources/index.ts
+++ b/apps/api/src/v1/workspaces/workspace/data-sources/index.ts
@@ -112,6 +112,20 @@ const dataSourcePayload = z.union([
       notes: z.string(),
     }),
   }),
+  z.object({
+    type: z.literal('monetdb'),
+    data: z.object({
+      name: z.string().min(1),
+      host: z.string().min(1),
+      port: z.string().min(1),
+      database: z.string().min(1),
+      username: z.string().min(1),
+      password: z.string().min(1),
+      notes: z.string(),
+      readOnly: z.boolean(),
+      cert: z.string().optional(),
+    }),
+  }),
 ])
 
 export type DataSourcePayload = z.infer<typeof dataSourcePayload>
@@ -287,6 +301,22 @@ const dataSourcesRouter = (socketServer: IOServer) => {
             dsRes = { type: 'snowflake', data: ds }
             break
           }
+          case "monetdb": {
+            const payload = {
+              ...data.data,
+              workspaceId,
+              cert: data.data.cert ?? null,
+              connStatus: 'offline' as const,
+              connError: JSON.stringify(neverPingedError),
+              lastConnection: null,
+            }
+            const ds = await createPSQLDataSource(
+              payload,
+              config().DATASOURCES_ENCRYPTION_KEY
+            )
+            dsRes = { type: 'psql', data: ds }
+            break
+          }
         }
 
         return dsRes
@@ -301,6 +331,7 @@ const dataSourcesRouter = (socketServer: IOServer) => {
           case 'athena':
           case 'sqlserver':
           case 'snowflake':
+          case "monetdb":
           case 'trino':
             return null
           case 'oracle': {
@@ -373,6 +404,7 @@ const dataSourcesRouter = (socketServer: IOServer) => {
         getDatasource(workspaceId, dataSourceId, 'sqlserver'),
         getDatasource(workspaceId, dataSourceId, 'trino'),
         getDatasource(workspaceId, dataSourceId, 'snowflake'),
+        getDatasource(workspaceId, dataSourceId, "monetdb")
       ])
     ).find((e) => e !== null)
 
diff --git a/packages/database/src/datasources/index.ts b/packages/database/src/datasources/index.ts
index 56e69f7c..44752d89 100644
--- a/packages/database/src/datasources/index.ts
+++ b/packages/database/src/datasources/index.ts
@@ -24,6 +24,7 @@ export * from './sqlserver.js'
 export * from './crypto.js'
 export * from './trino.js'
 export * from './snowflake.js'
+export * from "./monetdb.js"
 
 export type BigQueryDataSource = bq.BigQueryDataSource
 export type PostgreSQLDataSource = psql.PostgreSQLDataSource

From 0e687f965e1c4c5339abd00b4c9ab917d440d73a Mon Sep 17 00:00:00 2001
From: Hitesh Wadhwani <hiteshwadhwani1403@gmail.com>
Date: Thu, 10 Oct 2024 01:01:19 +0530
Subject: [PATCH 5/6] fixed

---
 ai/requirements.txt                    | 3 ++-
 apps/api/jupyter-requirements.txt      | 3 ++-
 apps/api/src/datasources/index.ts      | 2 +-
 apps/api/src/python/query/index.ts     | 2 +-
 apps/api/src/python/writeback/index.ts | 1 +
 5 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/ai/requirements.txt b/ai/requirements.txt
index fe88a21c..1470ab01 100644
--- a/ai/requirements.txt
+++ b/ai/requirements.txt
@@ -18,4 +18,5 @@ redshift-connector==2.0.917
 mysqlclient==2.2.4
 trino==0.329.0
 snowflake-connector-python==3.12.2
-snowflake-sqlalchemy==1.6.1
\ No newline at end of file
+snowflake-sqlalchemy==1.6.1
+sqlalchemy-monetdb==2.0.0
diff --git a/apps/api/jupyter-requirements.txt b/apps/api/jupyter-requirements.txt
index cf5f84ff..25f7c1e6 100644
--- a/apps/api/jupyter-requirements.txt
+++ b/apps/api/jupyter-requirements.txt
@@ -56,4 +56,5 @@ openpyxl==3.1.2
 mysqlclient==2.2.4
 pymongo==4.8.0
 snowflake-connector-python==3.12.2
-snowflake-sqlalchemy==1.6.1
\ No newline at end of file
+snowflake-sqlalchemy==1.6.1
+sqlalchemy-monetdb==2.0.0
diff --git a/apps/api/src/datasources/index.ts b/apps/api/src/datasources/index.ts
index 3243b7dd..06bdfc18 100644
--- a/apps/api/src/datasources/index.ts
+++ b/apps/api/src/datasources/index.ts
@@ -8,7 +8,7 @@ import * as mysql from './mysql.js'
 import * as trino from './trino.js'
 import * as sqlserver from './sqlserver.js'
 import * as snowflake from './snowflake.js'
-import * as monetdb from "./monetdb"
+import * as monetdb from "./monetdb.js"
 import { DataSourceConnectionError } from '@briefer/types'
 
 export async function ping(ds: DataSource): Promise<DataSource> {
diff --git a/apps/api/src/python/query/index.ts b/apps/api/src/python/query/index.ts
index 5b3b710e..d66e2e50 100644
--- a/apps/api/src/python/query/index.ts
+++ b/apps/api/src/python/query/index.ts
@@ -21,7 +21,7 @@ import { makeSnowflakeQuery } from './snowflake.js'
 import { updateConnStatus } from '../../datasources/index.js'
 import { getJupyterManager } from '../../jupyter/index.js'
 import { makeSQLServerQuery } from './sqlserver.js'
-import { makeMonetDBQuery } from './monetdb'
+import { makeMonetDBQuery } from './monetdb.js'
 
 export async function makeSQLQuery(
   workspaceId: string,
diff --git a/apps/api/src/python/writeback/index.ts b/apps/api/src/python/writeback/index.ts
index 34a38bb0..222819af 100644
--- a/apps/api/src/python/writeback/index.ts
+++ b/apps/api/src/python/writeback/index.ts
@@ -54,6 +54,7 @@ export async function writeback(
     case 'oracle':
     case 'athena':
     case 'snowflake':
+    case "monetdb":
     case 'trino':
       throw new Error(`${datasource.type} writeback not implemented`)
   }

From 99595b86144c324e58e4b190f154695db1a7677a Mon Sep 17 00:00:00 2001
From: Hitesh Wadhwani <hiteshwadhwani1403@gmail.com>
Date: Thu, 10 Oct 2024 17:44:37 +0530
Subject: [PATCH 6/6] API updated and monetdb dependency added

---
 ai/requirements.txt                           |  2 +-
 apps/api/jupyter-requirements.txt             |  2 +-
 apps/api/src/python/query/monetdb.ts          |  9 ++---
 .../workspace/data-sources/data-source.ts     | 37 +++++++++++++++++-
 .../workspace/data-sources/index.ts           |  5 ++-
 apps/web/src/components/DataSourceIcons.tsx   |  5 +++
 apps/web/src/components/DataSourcesList.tsx   | 26 ++++++++-----
 apps/web/src/components/forms/monetdb.tsx     | 38 +++++++++----------
 apps/web/src/hooks/useDatasource.ts           |  1 +
 .../data-sources/edit/[dataSourceId].tsx      |  8 ++++
 .../data-sources/new/monetdb.tsx              |  9 ++---
 .../environments/current/index.tsx            |  3 +-
 .../migration.sql                             | 26 +++++++++++++
 packages/database/src/datasources/index.ts    |  2 +-
 14 files changed, 126 insertions(+), 47 deletions(-)
 create mode 100644 packages/database/prisma/migrations/20241010071355_introduce_monetdb_datasource/migration.sql

diff --git a/ai/requirements.txt b/ai/requirements.txt
index 1470ab01..96ee400f 100644
--- a/ai/requirements.txt
+++ b/ai/requirements.txt
@@ -19,4 +19,4 @@ mysqlclient==2.2.4
 trino==0.329.0
 snowflake-connector-python==3.12.2
 snowflake-sqlalchemy==1.6.1
-sqlalchemy-monetdb==2.0.0
+sqlalchemy_monetdb==2.0.0
\ No newline at end of file
diff --git a/apps/api/jupyter-requirements.txt b/apps/api/jupyter-requirements.txt
index 25f7c1e6..2fb56903 100644
--- a/apps/api/jupyter-requirements.txt
+++ b/apps/api/jupyter-requirements.txt
@@ -57,4 +57,4 @@ mysqlclient==2.2.4
 pymongo==4.8.0
 snowflake-connector-python==3.12.2
 snowflake-sqlalchemy==1.6.1
-sqlalchemy-monetdb==2.0.0
+sqlalchemy_monetdb==2.0.0
\ No newline at end of file
diff --git a/apps/api/src/python/query/monetdb.ts b/apps/api/src/python/query/monetdb.ts
index e5b59912..f9690fc2 100644
--- a/apps/api/src/python/query/monetdb.ts
+++ b/apps/api/src/python/query/monetdb.ts
@@ -1,7 +1,6 @@
 import { v4 as uuidv4 } from 'uuid'
 import {
-  PostgreSQLDataSource,
-  RedshiftDataSource,
+  MonetDBDataSource,
   getDatabaseURL,
 } from '@briefer/database'
 import {
@@ -21,7 +20,7 @@ export async function makeMonetDBQuery(
   sessionId: string,
   queryId: string,
   dataframeName: string,
-  datasource: PostgreSQLDataSource | RedshiftDataSource,
+  datasource: MonetDBDataSource,
   encryptionKey: string,
   sql: string,
   onProgress: (result: SuccessRunQueryResult) => void
@@ -48,14 +47,14 @@ export async function makeMonetDBQuery(
 }
 
 export function pingMonetDb(
-  ds: PostgreSQLDataSource | RedshiftDataSource,
+  ds: MonetDBDataSource,
   encryptionKey: string
 ): Promise<null | Error> {
   return pingSQLAlchemy({ type: "monetdb", data: ds }, encryptionKey, null)
 }
 
 export function getMonetDBSchema(
-  ds: PostgreSQLDataSource | RedshiftDataSource,
+  ds: MonetDBDataSource,
   encryptionKey: string,
   onTable: OnTable
 ): Promise<DataSourceStructure> {
diff --git a/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts b/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts
index 603d849e..b1739599 100644
--- a/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts
+++ b/apps/api/src/v1/workspaces/workspace/data-sources/data-source.ts
@@ -29,7 +29,9 @@ import {
   getSnowflakeDataSource,
   updateSnowflakeDataSource,
   deleteSnowflakeDataSource,
-  getMonetDbDataSource
+  getMonetDbDataSource,
+  updateMonedDbDataSource,
+  deleteMonetDbDataSource
 } from '@briefer/database'
 import { z } from 'zod'
 import { getParam } from '../../../../utils/express.js'
@@ -43,6 +45,7 @@ import * as mysql from '../../../../datasources/mysql.js'
 import * as sqlserver from '../../../../datasources/sqlserver.js'
 import * as trino from '../../../../datasources/trino.js'
 import * as snowflake from '../../../../datasources/snowflake.js'
+import * as monetDb from "../../../../datasources/monetdb.js"
 import { ping } from '../../../../datasources/index.js'
 import { fetchDataSourceStructure } from '../../../../datasources/structure.js'
 import {
@@ -152,12 +155,13 @@ const dataSourceRouter = (socketServer: IOServer) => {
     z.object({
       type: z.literal('monetdb'),
       data: z.object({
+        id: z.string().min(1),
         name: z.string().min(1),
         host: z.string().min(1),
         port: z.string().min(1),
         database: z.string().min(1),
         username: z.string().min(1),
-        password: z.string().min(1),
+        password: z.string(),
         notes: z.string(),
         readOnly: z.boolean(),
         cert: z.string().optional(),
@@ -341,6 +345,20 @@ const dataSourceRouter = (socketServer: IOServer) => {
         await snowflake.ping(snowflakeDs)
         break
       }
+      case "monetdb": {
+        const monetDbDs = await updateMonedDbDataSource(
+          {
+            ...data.data,
+            id: dataSourceId,
+            password:
+              data.data.password === '' ? undefined : data.data.password,
+          },
+          config().DATASOURCES_ENCRYPTION_KEY
+        )
+
+        await monetDb.ping(monetDbDs)
+        break
+      }
     }
 
     const ds = await getDatasource(workspaceId, dataSourceId, data.type)
@@ -489,6 +507,19 @@ const dataSourceRouter = (socketServer: IOServer) => {
         }
       }
 
+      const targetMonetDb = await recoverFromNotFound(
+        deleteMonetDbDataSource(workspaceId, targetId)
+      )
+      if(targetMonetDb) {
+        return {
+          status: 200,
+          payload: {
+            type: 'monetdb',
+            data: targetMonetDb,
+          },
+        }
+      }
+
       return { status: 404 }
     }
 
@@ -513,6 +544,7 @@ const dataSourceRouter = (socketServer: IOServer) => {
       z.literal('trino'),
       z.literal('sqlserver'),
       z.literal('snowflake'),
+      z.literal("monetdb"),
     ]),
   })
   router.post('/ping', async (req, res) => {
@@ -536,6 +568,7 @@ const dataSourceRouter = (socketServer: IOServer) => {
         return
       }
 
+
       const dsConfig = await ping(dataSource)
 
       await broadcastDataSource(socketServer, {
diff --git a/apps/api/src/v1/workspaces/workspace/data-sources/index.ts b/apps/api/src/v1/workspaces/workspace/data-sources/index.ts
index a589179d..81d9fbbb 100644
--- a/apps/api/src/v1/workspaces/workspace/data-sources/index.ts
+++ b/apps/api/src/v1/workspaces/workspace/data-sources/index.ts
@@ -11,6 +11,7 @@ import {
   createTrinoDataSource,
   createSQLServerDataSource,
   createSnowflakeDataSource,
+  createMonetDbDataSource,
 } from '@briefer/database'
 import { z } from 'zod'
 import { getParam } from '../../../../utils/express.js'
@@ -310,11 +311,11 @@ const dataSourcesRouter = (socketServer: IOServer) => {
               connError: JSON.stringify(neverPingedError),
               lastConnection: null,
             }
-            const ds = await createPSQLDataSource(
+            const ds = await createMonetDbDataSource(
               payload,
               config().DATASOURCES_ENCRYPTION_KEY
             )
-            dsRes = { type: 'psql', data: ds }
+            dsRes = { type: 'monetdb', data: ds }
             break
           }
         }
diff --git a/apps/web/src/components/DataSourceIcons.tsx b/apps/web/src/components/DataSourceIcons.tsx
index 64cd79dd..fef99826 100644
--- a/apps/web/src/components/DataSourceIcons.tsx
+++ b/apps/web/src/components/DataSourceIcons.tsx
@@ -62,6 +62,11 @@ export const DataSourceIcons = ({
         name="Snowflake"
         href={`/workspaces/${workspaceId}/data-sources/new/snowflake`}
       />
+      <DataSourceBlock
+        icon="/icons/monetdb.png"
+        name="MonetDB"
+        href={`/workspaces/${workspaceId}/data-sources/new/monetdb`}
+      />
       <button
         onClick={onCSV}
         className="h-24 w-24 py-3 px-6 border border-gray-200 rounded-md flex flex-col items-center justify-between bg-gray-50 hover:bg-ceramic-50 hover:border-gray-300"
diff --git a/apps/web/src/components/DataSourcesList.tsx b/apps/web/src/components/DataSourcesList.tsx
index 4371b62f..22a532a6 100644
--- a/apps/web/src/components/DataSourcesList.tsx
+++ b/apps/web/src/components/DataSourcesList.tsx
@@ -27,6 +27,8 @@ export const dataSourcePrettyName = (t: DataSourceType): string => {
       return 'Trino'
     case 'snowflake':
       return 'Snowflake'
+    case 'monetdb':
+      return 'MonetDB'
   }
 }
 
@@ -50,6 +52,8 @@ export const databaseImages = (t: DataSourceType): string => {
       return '/icons/trino.png'
     case 'snowflake':
       return '/icons/snowflake.png'
+    case 'monetdb':
+      return '/icons/monetdb.png'
   }
 }
 
@@ -74,6 +78,8 @@ const databaseUrl = (ds: DataSource): string => {
         return 'trino://demodb'
       case 'snowflake':
         return 'snowflake://demodb'
+      case 'monetdb':
+        return 'monetdb://demodb'
     }
   } else {
     switch (ds.type) {
@@ -98,6 +104,8 @@ const databaseUrl = (ds: DataSource): string => {
         )
       case 'snowflake':
         return `snowflake://${ds.data.account}/${ds.data.database}?warehouse=${ds.data.warehouse}`
+      case "monetdb":
+        return `monetdb://${ds.data.host}:${ds.data.port}/${ds.data.database}`
     }
   }
 }
@@ -128,15 +136,15 @@ function LastConnection(props: LastConnectionProps) {
   const lastConnText = props.dataSource.data.isDemo
     ? 'just now'
     : props.dataSource.data.lastConnection === null
-    ? 'never'
-    : differenceInSeconds(
-        new Date(),
-        new Date(props.dataSource.data.lastConnection)
-      ) < 30
-    ? 'just now'
-    : formatDistanceToNow(new Date(props.dataSource.data.lastConnection), {
-        addSuffix: true,
-      })
+      ? 'never'
+      : differenceInSeconds(
+            new Date(),
+            new Date(props.dataSource.data.lastConnection)
+          ) < 30
+        ? 'just now'
+        : formatDistanceToNow(new Date(props.dataSource.data.lastConnection), {
+            addSuffix: true,
+          })
 
   const [statusBallColor, statusBallRippleColor] = useMemo(() => {
     if (props.dataSource.data.isDemo) {
diff --git a/apps/web/src/components/forms/monetdb.tsx b/apps/web/src/components/forms/monetdb.tsx
index 8b8866cf..80c0bf83 100644
--- a/apps/web/src/components/forms/monetdb.tsx
+++ b/apps/web/src/components/forms/monetdb.tsx
@@ -1,4 +1,4 @@
-import type { PostgreSQLDataSource } from '@briefer/database'
+import type { MonetDBDataSource } from '@briefer/database'
 import Link from 'next/link'
 import { useEffect } from 'react'
 import { useForm } from 'react-hook-form'
@@ -9,43 +9,43 @@ import { readFile } from '@/utils/file'
 import { GATEWAY_IP } from '@/utils/info'
 import Spin from '../Spin'
 
-export type PostgreSQLDataSourceInput = PostgreSQLDataSource & {
+export type MonetDbDataSourceInput = MonetDBDataSource & {
   password: string
   cert?: string
 }
 
-type PostgreSQLDataSourceFormValues = Omit<
-  PostgreSQLDataSourceInput,
+type MonetDbDataSourceFormValues = Omit<
+MonetDbDataSourceInput,
   'cert'
 > & {
   password: string
   cert: File
 }
 
-type PostgreSQLFormProps = {
-  onSubmit: (values: PostgreSQLDataSourceInput) => Promise<void>
-  postgreSQLDataSource?: PostgreSQLDataSource | null
+type MonetDbFormProps = {
+  onSubmit: (values: MonetDbDataSourceInput) => Promise<void>
+  monetDbDataSource?: MonetDBDataSource | null
   workspaceId: string
 }
 
 export default function MonetDBForm({
-  postgreSQLDataSource,
+  monetDbDataSource,
   onSubmit,
   workspaceId,
-}: PostgreSQLFormProps) {
-  const isEditing = Boolean(postgreSQLDataSource)
+}: MonetDbFormProps) {
+  const isEditing = Boolean(monetDbDataSource)
 
   const { register, handleSubmit, formState, reset, control } =
-    useForm<PostgreSQLDataSourceFormValues>({
+    useForm<MonetDbDataSourceFormValues>({
       mode: 'onChange',
       defaultValues: { readOnly: true },
     })
 
   useEffect(() => {
-    if (postgreSQLDataSource) {
-      reset(postgreSQLDataSource)
+    if (monetDbDataSource) {
+      reset(monetDbDataSource)
     }
-  }, [postgreSQLDataSource, reset])
+  }, [monetDbDataSource, reset])
 
   const onSubmitHandler = handleSubmit(async (data) => {
     const certFile = data.cert
@@ -65,10 +65,10 @@ export default function MonetDBForm({
       <div className="space-y-12">
         <div className="border-b border-gray-900/10 pb-8">
           <h2 className="text-lg font-semibold leading-7 text-gray-900">
-            {postgreSQLDataSource ? 'Edit' : 'New'} PostgreSQL data source
+            {monetDbDataSource ? 'Edit' : 'New'} MonetDb data source
           </h2>
           <p className="mt-1 text-sm leading-6 text-gray-500">
-            {postgreSQLDataSource ? 'Edit' : 'Add'} a PostgreSQL database for
+            {monetDbDataSource ? 'Edit' : 'Add'} a MonetDb database for
             Briefer to pull data from. Our fixed IP address is{' '}
             <code className="bg-gray-100 px-1 py-0.5 rounded-md text-red-500 text-xs">
               {GATEWAY_IP()}
@@ -94,7 +94,7 @@ export default function MonetDBForm({
                   })}
                   type="text"
                   name="name"
-                  placeholder="My PostgreSQL database"
+                  placeholder="My MonetDb database"
                   required
                   className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
                 />
@@ -143,7 +143,7 @@ export default function MonetDBForm({
                   })}
                   type="number"
                   name="port"
-                  placeholder="5432"
+                  placeholder="50000"
                   required
                   className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
                 />
@@ -193,7 +193,7 @@ export default function MonetDBForm({
                   })}
                   type="text"
                   name="username"
-                  placeholder="postgres"
+                  placeholder="monetdb"
                   required
                   className="block w-full rounded-md border-0 py-3 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-ceramic-200/70 sm:text-md sm:leading-6"
                 />
diff --git a/apps/web/src/hooks/useDatasource.ts b/apps/web/src/hooks/useDatasource.ts
index 389475b1..f817a469 100644
--- a/apps/web/src/hooks/useDatasource.ts
+++ b/apps/web/src/hooks/useDatasource.ts
@@ -98,6 +98,7 @@ export const useNewDataSource = (workspaceId: string) => {
         | 'sqlserver'
         | 'monetdb'
         | 'snowflake'
+        | 'monetdb'
     ): Promise<DataSource> => {
       if (!workspaceId) {
         throw new Error('Missing workspaceId')
diff --git a/apps/web/src/pages/workspaces/[workspaceId]/data-sources/edit/[dataSourceId].tsx b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/edit/[dataSourceId].tsx
index 0dac125f..f6e99f5b 100644
--- a/apps/web/src/pages/workspaces/[workspaceId]/data-sources/edit/[dataSourceId].tsx
+++ b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/edit/[dataSourceId].tsx
@@ -26,6 +26,7 @@ import SQLServerForm from '@/components/forms/sqlserver'
 import SnowflakeForm, {
   SnowflakeDataSourceInput,
 } from '@/components/forms/snowflake'
+import MonetDBForm, { MonetDbDataSourceInput } from '@/components/forms/monetdb'
 
 export default function EditDataSourcePostgresSQLPage() {
   const router = useRouter()
@@ -45,6 +46,7 @@ export default function EditDataSourcePostgresSQLPage() {
         | MySQLDataSourceInput
         | TrinoDataSourceInput
         | SnowflakeDataSourceInput
+        | MonetDbDataSourceInput
     ) => {
       if (!data) {
         return
@@ -144,6 +146,12 @@ export default function EditDataSourcePostgresSQLPage() {
             onSubmit={onSubmit}
             snowflakeDataSource={data.config.data}
           />
+        ) : data && data.config.type === 'monetdb' ? (
+          <MonetDBForm
+            workspaceId={workspaceId}
+            onSubmit={onSubmit}
+            monetDbDataSource={data.config.data}
+          />
         ) : null}
       </div>
     </Layout>
diff --git a/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx
index 321620ff..79b06a9a 100644
--- a/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx
+++ b/apps/web/src/pages/workspaces/[workspaceId]/data-sources/new/monetdb.tsx
@@ -5,13 +5,10 @@ import {
   Cog8ToothIcon,
   PlusCircleIcon,
 } from '@heroicons/react/24/outline'
-import {
-  PostgreSQLDataSourceInput,
-} from '@/components/forms/postgresql'
 import { useCallback } from 'react'
 import { useNewDataSource } from '@/hooks/useDatasource'
 import { useStringQuery } from '@/hooks/useQueryArgs'
-import MonetDBForm from '@/components/forms/monetdb'
+import MonetDBForm, { MonetDbDataSourceInput } from '@/components/forms/monetdb'
 
 const pagePath = (workspaceId: string) => [
   { name: 'Configurations', icon: Cog8ToothIcon, href: '#', current: false },
@@ -36,9 +33,9 @@ export default function NewDataSourceMonetDBPage() {
   const newDataSource = useNewDataSource(workspaceId)
 
   const onSubmit = useCallback(
-    async (data: PostgreSQLDataSourceInput) => {
+    async (data: MonetDbDataSourceInput) => {
       try {
-        const ds = await newDataSource(data, 'psql')
+        const ds = await newDataSource(data, 'monetdb')
         if (ds.data.connStatus === 'offline') {
           router.push(
             `/workspaces/${workspaceId}/data-sources?offline=${ds.data.id}`
diff --git a/apps/web/src/pages/workspaces/[workspaceId]/environments/current/index.tsx b/apps/web/src/pages/workspaces/[workspaceId]/environments/current/index.tsx
index 13111134..0eb6ce34 100644
--- a/apps/web/src/pages/workspaces/[workspaceId]/environments/current/index.tsx
+++ b/apps/web/src/pages/workspaces/[workspaceId]/environments/current/index.tsx
@@ -215,4 +215,5 @@ openpyxl==3.1.2
 mysqlclient==2.2.4
 pymongo==4.8.0
 snowflake-connector-python==3.12.2
-snowflake-sqlalchemy==1.6.1`
+snowflake-sqlalchemy==1.6.1
+sqlalchemy_monetdb==2.0.0`
\ No newline at end of file
diff --git a/packages/database/prisma/migrations/20241010071355_introduce_monetdb_datasource/migration.sql b/packages/database/prisma/migrations/20241010071355_introduce_monetdb_datasource/migration.sql
new file mode 100644
index 00000000..4ff28e5f
--- /dev/null
+++ b/packages/database/prisma/migrations/20241010071355_introduce_monetdb_datasource/migration.sql
@@ -0,0 +1,26 @@
+-- CreateTable
+CREATE TABLE "MonetDBDataSource" (
+    "id" UUID NOT NULL DEFAULT gen_random_uuid(),
+    "name" TEXT NOT NULL,
+    "host" TEXT NOT NULL,
+    "port" TEXT NOT NULL,
+    "database" TEXT NOT NULL,
+    "username" TEXT NOT NULL,
+    "password" TEXT NOT NULL,
+    "notes" TEXT NOT NULL,
+    "readOnly" BOOLEAN NOT NULL DEFAULT true,
+    "cert" TEXT,
+    "structure" TEXT,
+    "isDemo" BOOLEAN NOT NULL DEFAULT false,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "connStatus" "ConnStatus" NOT NULL DEFAULT 'online',
+    "connError" TEXT,
+    "lastConnection" TIMESTAMP(3),
+    "workspaceId" UUID NOT NULL,
+
+    CONSTRAINT "MonetDBDataSource_pkey" PRIMARY KEY ("id")
+);
+
+-- AddForeignKey
+ALTER TABLE "MonetDBDataSource" ADD CONSTRAINT "MonetDBDataSource_workspaceId_fkey" FOREIGN KEY ("workspaceId") REFERENCES "Workspace"("id") ON DELETE CASCADE ON UPDATE CASCADE;
diff --git a/packages/database/src/datasources/index.ts b/packages/database/src/datasources/index.ts
index 44752d89..0537e47e 100644
--- a/packages/database/src/datasources/index.ts
+++ b/packages/database/src/datasources/index.ts
@@ -333,7 +333,7 @@ export async function getDatabaseURL(
       const password = encodeURIComponent(
         await getDatasourcePassword(ds, encryptionKey)
       )
-      return `monetdb://${ds.data.host}:${ds.data.port}/${ds.data.database}?user=${ds.data.username}&password=${password}`
+      return `monetdb://${ds.data.username}:${password}@${ds.data.host}:${ds.data.port}/${ds.data.database}`
     }
     case 'snowflake': {
       const password = encodeURIComponent(