index.cjs 237 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569457045714572457345744575457645774578457945804581458245834584458545864587458845894590459145924593459445954596459745984599460046014602460346044605460646074608460946104611461246134614461546164617461846194620462146224623462446254626462746284629463046314632463346344635463646374638463946404641464246434644464546464647464846494650465146524653465446554656465746584659466046614662466346644665466646674668466946704671467246734674467546764677467846794680468146824683468446854686468746884689469046914692469346944695469646974698469947004701470247034704470547064707470847094710471147124713471447154716471747184719472047214722472347244725472647274728472947304731473247334734473547364737473847394740474147424743474447454746474747484749475047514752475347544755475647574758475947604761476247634764476547664767476847694770477147724773477447754776477747784779478047814782478347844785478647874788478947904791479247934794479547964797479847994800480148024803480448054806480748084809481048114812481348144815481648174818481948204821482248234824482548264827482848294830483148324833483448354836483748384839484048414842484348444845484648474848484948504851485248534854485548564857485848594860486148624863486448654866486748684869487048714872487348744875487648774878487948804881488248834884488548864887488848894890489148924893489448954896489748984899490049014902490349044905490649074908490949104911491249134914491549164917491849194920492149224923492449254926492749284929493049314932493349344935493649374938493949404941494249434944494549464947494849494950495149524953495449554956495749584959496049614962496349644965496649674968496949704971497249734974497549764977497849794980498149824983498449854986498749884989499049914992499349944995499649974998499950005001500250035004500550065007500850095010501150125013501450155016501750185019502050215022502350245025502650275028502950305031503250335034503550365037503850395040504150425043504450455046504750485049505050515052505350545055505650575058505950605061506250635064506550665067506850695070507150725073507450755076507750785079508050815082508350845085508650875088508950905091509250935094509550965097509850995100510151025103510451055106510751085109511051115112511351145115511651175118511951205121512251235124512551265127512851295130513151325133513451355136513751385139514051415142514351445145514651475148514951505151515251535154515551565157515851595160516151625163516451655166516751685169517051715172517351745175517651775178517951805181518251835184518551865187518851895190519151925193519451955196519751985199520052015202520352045205520652075208520952105211521252135214521552165217521852195220522152225223522452255226522752285229523052315232523352345235523652375238523952405241524252435244524552465247524852495250525152525253525452555256525752585259526052615262526352645265526652675268526952705271527252735274527552765277527852795280528152825283528452855286528752885289529052915292529352945295529652975298529953005301530253035304530553065307530853095310531153125313531453155316531753185319532053215322532353245325532653275328532953305331533253335334533553365337533853395340534153425343534453455346534753485349535053515352535353545355535653575358535953605361536253635364536553665367536853695370537153725373537453755376537753785379538053815382538353845385538653875388538953905391539253935394539553965397539853995400540154025403540454055406540754085409541054115412541354145415541654175418541954205421542254235424542554265427542854295430543154325433543454355436543754385439544054415442544354445445544654475448544954505451545254535454545554565457545854595460546154625463546454655466546754685469547054715472547354745475547654775478547954805481548254835484548554865487548854895490549154925493549454955496549754985499550055015502550355045505550655075508550955105511551255135514551555165517551855195520552155225523552455255526552755285529553055315532553355345535553655375538553955405541554255435544554555465547554855495550555155525553555455555556555755585559556055615562556355645565556655675568556955705571557255735574557555765577557855795580558155825583558455855586558755885589559055915592559355945595559655975598559956005601560256035604560556065607560856095610561156125613561456155616561756185619562056215622562356245625562656275628562956305631563256335634563556365637563856395640564156425643564456455646564756485649565056515652565356545655565656575658565956605661566256635664566556665667566856695670567156725673567456755676567756785679568056815682568356845685568656875688568956905691569256935694569556965697569856995700570157025703570457055706570757085709571057115712571357145715571657175718571957205721572257235724572557265727572857295730573157325733573457355736573757385739574057415742574357445745574657475748574957505751575257535754575557565757575857595760576157625763576457655766576757685769577057715772577357745775577657775778577957805781578257835784578557865787578857895790579157925793579457955796579757985799580058015802580358045805580658075808580958105811581258135814581558165817581858195820582158225823582458255826582758285829583058315832583358345835583658375838583958405841584258435844584558465847584858495850585158525853585458555856585758585859586058615862586358645865586658675868586958705871587258735874587558765877587858795880588158825883588458855886588758885889589058915892589358945895589658975898589959005901590259035904590559065907590859095910591159125913591459155916591759185919592059215922592359245925592659275928592959305931593259335934593559365937593859395940594159425943594459455946594759485949595059515952595359545955595659575958595959605961596259635964596559665967596859695970597159725973597459755976597759785979598059815982598359845985598659875988598959905991599259935994599559965997599859996000600160026003600460056006600760086009601060116012601360146015601660176018601960206021602260236024602560266027602860296030603160326033603460356036603760386039604060416042604360446045604660476048604960506051605260536054605560566057605860596060606160626063606460656066606760686069607060716072607360746075607660776078607960806081608260836084608560866087608860896090609160926093609460956096609760986099610061016102610361046105610661076108610961106111611261136114611561166117611861196120612161226123612461256126612761286129613061316132613361346135613661376138613961406141614261436144614561466147614861496150615161526153615461556156615761586159616061616162616361646165616661676168616961706171617261736174617561766177617861796180618161826183618461856186618761886189619061916192619361946195619661976198619962006201620262036204620562066207620862096210621162126213621462156216621762186219622062216222622362246225622662276228622962306231623262336234623562366237623862396240624162426243624462456246624762486249625062516252625362546255625662576258625962606261626262636264626562666267626862696270627162726273627462756276627762786279628062816282628362846285628662876288628962906291629262936294629562966297629862996300630163026303630463056306630763086309631063116312631363146315631663176318631963206321632263236324632563266327632863296330633163326333633463356336633763386339634063416342634363446345634663476348634963506351635263536354635563566357635863596360636163626363636463656366636763686369637063716372637363746375637663776378637963806381638263836384638563866387638863896390639163926393639463956396639763986399640064016402640364046405640664076408640964106411641264136414641564166417641864196420642164226423642464256426642764286429643064316432643364346435643664376438643964406441644264436444644564466447644864496450645164526453645464556456645764586459646064616462646364646465646664676468646964706471647264736474647564766477647864796480648164826483648464856486648764886489649064916492649364946495649664976498649965006501650265036504650565066507650865096510651165126513651465156516651765186519652065216522652365246525652665276528652965306531653265336534653565366537653865396540654165426543654465456546654765486549655065516552655365546555655665576558655965606561656265636564656565666567656865696570657165726573657465756576657765786579658065816582658365846585658665876588658965906591659265936594659565966597659865996600660166026603660466056606660766086609
  1. "use strict";
  2. var __create = Object.create;
  3. var __defProp = Object.defineProperty;
  4. var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
  5. var __getOwnPropNames = Object.getOwnPropertyNames;
  6. var __getProtoOf = Object.getPrototypeOf;
  7. var __hasOwnProp = Object.prototype.hasOwnProperty;
  8. var __defNormalProp = (obj, key, value) => key in obj ? __defProp(obj, key, { enumerable: true, configurable: true, writable: true, value }) : obj[key] = value;
  9. var __name = (target, value) => __defProp(target, "name", { value, configurable: true });
  10. var __glob = (map) => (path) => {
  11. var fn = map[path];
  12. if (fn) return fn();
  13. throw new Error("Module not found in bundle: " + path);
  14. };
  15. var __esm = (fn, res) => function __init() {
  16. return fn && (res = (0, fn[__getOwnPropNames(fn)[0]])(fn = 0)), res;
  17. };
  18. var __export = (target, all) => {
  19. for (var name in all)
  20. __defProp(target, name, { get: all[name], enumerable: true });
  21. };
  22. var __copyProps = (to, from, except, desc) => {
  23. if (from && typeof from === "object" || typeof from === "function") {
  24. for (let key of __getOwnPropNames(from))
  25. if (!__hasOwnProp.call(to, key) && key !== except)
  26. __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
  27. }
  28. return to;
  29. };
  30. var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__getProtoOf(mod)) : {}, __copyProps(
  31. // If the importer is in node compatibility mode or this is not an ESM
  32. // file that has been converted to a CommonJS file using a Babel-
  33. // compatible transform (i.e. "__esModule" has not been set), then set
  34. // "default" to the CommonJS "module.exports" for node compatibility.
  35. isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target,
  36. mod
  37. ));
  38. var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
  39. var __publicField = (obj, key, value) => __defNormalProp(obj, typeof key !== "symbol" ? key + "" : key, value);
  40. // src/utils/is-ctor.js
  41. function isCtor(value) {
  42. if (!value) return false;
  43. return typeof value === "function" && "prototype" in value;
  44. }
  45. var init_is_ctor = __esm({
  46. "src/utils/is-ctor.js"() {
  47. "use strict";
  48. __name(isCtor, "isCtor");
  49. }
  50. });
  51. // src/utils/is-promise.js
  52. function isPromise(value) {
  53. if (!value) return false;
  54. if (typeof value !== "object") return false;
  55. return typeof value.then === "function";
  56. }
  57. var init_is_promise = __esm({
  58. "src/utils/is-promise.js"() {
  59. "use strict";
  60. __name(isPromise, "isPromise");
  61. }
  62. });
  63. // src/utils/capitalize.js
  64. function capitalize(string) {
  65. if (!string || typeof string !== "string") return string;
  66. return string.charAt(0).toUpperCase() + string.slice(1);
  67. }
  68. var init_capitalize = __esm({
  69. "src/utils/capitalize.js"() {
  70. "use strict";
  71. __name(capitalize, "capitalize");
  72. }
  73. });
  74. // src/utils/clone-deep.js
  75. function cloneDeep(value) {
  76. if (!value) return value;
  77. const types = [Number, String, Boolean];
  78. let result;
  79. types.forEach((type) => {
  80. if (value instanceof type) result = type(value);
  81. });
  82. if (result === void 0) {
  83. if (Array.isArray(value)) {
  84. result = [];
  85. value.forEach((child, index) => {
  86. result[index] = cloneDeep(child);
  87. });
  88. } else if (typeof value === "object") {
  89. if ("nodeType" in value && value.nodeType && "cloneNode" in value && typeof value.cloneNode === "function") {
  90. result = value.cloneNode(true);
  91. } else if (!("prototype" in value) || !value.prototype) {
  92. if (value instanceof Date) {
  93. result = new Date(value);
  94. } else if (value.constructor && value.constructor.name === "Object") {
  95. result = {};
  96. for (const key in value) {
  97. result[key] = cloneDeep(value[key]);
  98. }
  99. } else {
  100. result = value;
  101. }
  102. } else {
  103. result = value;
  104. }
  105. } else {
  106. result = value;
  107. }
  108. }
  109. return result;
  110. }
  111. var init_clone_deep = __esm({
  112. "src/utils/clone-deep.js"() {
  113. "use strict";
  114. __name(cloneDeep, "cloneDeep");
  115. }
  116. });
  117. // src/utils/singularize.js
  118. function singularize(noun) {
  119. if (!noun || typeof noun !== "string") return noun;
  120. const endings = {
  121. ves: "fe",
  122. ies: "y",
  123. i: "us",
  124. zes: "ze",
  125. ses: "s",
  126. es: "e",
  127. s: ""
  128. };
  129. return noun.replace(
  130. new RegExp(`(${Object.keys(endings).join("|")})$`),
  131. (r) => endings[r]
  132. );
  133. }
  134. var init_singularize = __esm({
  135. "src/utils/singularize.js"() {
  136. "use strict";
  137. __name(singularize, "singularize");
  138. }
  139. });
  140. // src/utils/is-deep-equal.js
  141. function isDeepEqual(firstValue, secondValue) {
  142. const cached = /* @__PURE__ */ new WeakMap();
  143. const compare = /* @__PURE__ */ __name((a, b) => {
  144. if (a === null || b === null) return a === b;
  145. if (typeof a !== "object" || typeof b !== "object") return a === b;
  146. const dataTypeA = Array.isArray(a) ? "array" : "object";
  147. const dataTypeB = Array.isArray(b) ? "array" : "object";
  148. if (dataTypeA !== dataTypeB) return false;
  149. const keysA = Object.keys(a);
  150. const keysB = Object.keys(b);
  151. if (keysA.length !== keysB.length) return false;
  152. const symbolsA = Object.getOwnPropertySymbols(a);
  153. const symbolsB = Object.getOwnPropertySymbols(b);
  154. if (symbolsA.length !== symbolsB.length) return false;
  155. let setForA = cached.get(a);
  156. if (setForA == null) {
  157. setForA = /* @__PURE__ */ new Set();
  158. cached.set(a, setForA);
  159. } else if (setForA.has(b)) {
  160. return true;
  161. }
  162. setForA.add(b);
  163. let setForB = cached.get(b);
  164. if (setForB == null) {
  165. setForB = /* @__PURE__ */ new Set();
  166. cached.set(b, setForB);
  167. } else if (setForB.has(a)) {
  168. return true;
  169. }
  170. setForB.add(a);
  171. const propertyNamesA = [...keysA, ...symbolsA];
  172. for (const propertyNameA of propertyNamesA) {
  173. if (!Object.prototype.hasOwnProperty.call(b, propertyNameA)) return false;
  174. const propertyValueA = a[propertyNameA];
  175. const propertyValueB = b[propertyNameA];
  176. if (!compare(propertyValueA, propertyValueB)) return false;
  177. }
  178. return true;
  179. }, "compare");
  180. return compare(firstValue, secondValue);
  181. }
  182. var init_is_deep_equal = __esm({
  183. "src/utils/is-deep-equal.js"() {
  184. "use strict";
  185. __name(isDeepEqual, "isDeepEqual");
  186. }
  187. });
  188. // src/utils/get-ctor-name.js
  189. function getCtorName(value) {
  190. if (value === null) return "Null";
  191. if (value === void 0) return "Undefined";
  192. return value.constructor && value.constructor.name || void 0;
  193. }
  194. var init_get_ctor_name = __esm({
  195. "src/utils/get-ctor-name.js"() {
  196. "use strict";
  197. __name(getCtorName, "getCtorName");
  198. }
  199. });
  200. // src/utils/is-pure-object.js
  201. function isPureObject(value) {
  202. return Boolean(
  203. typeof value === "object" && value && !Array.isArray(value) && (!value.constructor || value.constructor && value.constructor.name === "Object")
  204. );
  205. }
  206. var init_is_pure_object = __esm({
  207. "src/utils/is-pure-object.js"() {
  208. "use strict";
  209. __name(isPureObject, "isPureObject");
  210. }
  211. });
  212. // src/errors/not-implemented-error.js
  213. var import_js_format, _NotImplementedError, NotImplementedError;
  214. var init_not_implemented_error = __esm({
  215. "src/errors/not-implemented-error.js"() {
  216. "use strict";
  217. import_js_format = require("@e22m4u/js-format");
  218. _NotImplementedError = class _NotImplementedError extends import_js_format.Errorf {
  219. };
  220. __name(_NotImplementedError, "NotImplementedError");
  221. NotImplementedError = _NotImplementedError;
  222. }
  223. });
  224. // src/errors/invalid-argument-error.js
  225. var import_js_format2, _InvalidArgumentError, InvalidArgumentError;
  226. var init_invalid_argument_error = __esm({
  227. "src/errors/invalid-argument-error.js"() {
  228. "use strict";
  229. import_js_format2 = require("@e22m4u/js-format");
  230. _InvalidArgumentError = class _InvalidArgumentError extends import_js_format2.Errorf {
  231. };
  232. __name(_InvalidArgumentError, "InvalidArgumentError");
  233. InvalidArgumentError = _InvalidArgumentError;
  234. }
  235. });
  236. // src/errors/invalid-operator-value-error.js
  237. var import_js_format3, _InvalidOperatorValueError, InvalidOperatorValueError;
  238. var init_invalid_operator_value_error = __esm({
  239. "src/errors/invalid-operator-value-error.js"() {
  240. "use strict";
  241. import_js_format3 = require("@e22m4u/js-format");
  242. _InvalidOperatorValueError = class _InvalidOperatorValueError extends Error {
  243. /**
  244. * Constructor.
  245. *
  246. * @param {string} operator
  247. * @param {string} expected
  248. * @param {*} value
  249. */
  250. constructor(operator, expected, value) {
  251. super(
  252. (0, import_js_format3.format)(
  253. "Condition of {%s: ...} should have %s, but %v was given.",
  254. operator,
  255. expected,
  256. value
  257. )
  258. );
  259. }
  260. };
  261. __name(_InvalidOperatorValueError, "InvalidOperatorValueError");
  262. InvalidOperatorValueError = _InvalidOperatorValueError;
  263. }
  264. });
  265. // src/errors/index.js
  266. var init_errors = __esm({
  267. "src/errors/index.js"() {
  268. "use strict";
  269. init_not_implemented_error();
  270. init_invalid_argument_error();
  271. init_invalid_operator_value_error();
  272. }
  273. });
  274. // src/utils/like-to-regexp.js
  275. function likeToRegexp(pattern, isCaseInsensitive = false) {
  276. if (typeof pattern !== "string") {
  277. throw new InvalidArgumentError(
  278. "The first argument of `likeToRegexp` should be a String, but %v was given.",
  279. pattern
  280. );
  281. }
  282. const regexSpecials = "-[]{}()*+?.\\^$|";
  283. let regexString = "";
  284. let isEscaping = false;
  285. for (const char of pattern) {
  286. if (isEscaping) {
  287. regexString += regexSpecials.includes(char) ? `\\${char}` : char;
  288. isEscaping = false;
  289. } else if (char === "\\") {
  290. isEscaping = true;
  291. } else if (char === "%") {
  292. regexString += ".*";
  293. } else if (char === "_") {
  294. regexString += ".";
  295. } else if (regexSpecials.includes(char)) {
  296. regexString += `\\${char}`;
  297. } else {
  298. regexString += char;
  299. }
  300. }
  301. if (isEscaping) {
  302. regexString += "\\\\";
  303. }
  304. const flags = isCaseInsensitive ? "i" : "";
  305. return new RegExp(`^${regexString}$`, flags);
  306. }
  307. var init_like_to_regexp = __esm({
  308. "src/utils/like-to-regexp.js"() {
  309. "use strict";
  310. init_errors();
  311. __name(likeToRegexp, "likeToRegexp");
  312. }
  313. });
  314. // src/utils/string-to-regexp.js
  315. function stringToRegexp(pattern, flags = void 0) {
  316. if (pattern instanceof RegExp) {
  317. return new RegExp(pattern, flags);
  318. }
  319. let regex = "";
  320. for (let i = 0, n = pattern.length; i < n; i++) {
  321. const char = pattern.charAt(i);
  322. if (char === "%") {
  323. regex += ".*";
  324. } else {
  325. regex += char;
  326. }
  327. }
  328. return new RegExp(regex, flags);
  329. }
  330. var init_string_to_regexp = __esm({
  331. "src/utils/string-to-regexp.js"() {
  332. "use strict";
  333. __name(stringToRegexp, "stringToRegexp");
  334. }
  335. });
  336. // src/utils/get-value-by-path.js
  337. function getValueByPath(obj, path, orElse = void 0) {
  338. if (!obj || typeof obj !== "object") return orElse;
  339. if (!path || typeof path !== "string") return orElse;
  340. const keys = path.split(".");
  341. let value = obj;
  342. for (const key of keys) {
  343. if (typeof value === "object" && value !== null && key in value) {
  344. value = value[key];
  345. } else {
  346. value = orElse;
  347. break;
  348. }
  349. }
  350. return value;
  351. }
  352. var init_get_value_by_path = __esm({
  353. "src/utils/get-value-by-path.js"() {
  354. "use strict";
  355. __name(getValueByPath, "getValueByPath");
  356. }
  357. });
  358. // src/utils/transform-promise.js
  359. function transformPromise(valueOrPromise, transformer) {
  360. return isPromise(valueOrPromise) ? valueOrPromise.then(transformer) : transformer(valueOrPromise);
  361. }
  362. var init_transform_promise = __esm({
  363. "src/utils/transform-promise.js"() {
  364. "use strict";
  365. init_is_promise();
  366. __name(transformPromise, "transformPromise");
  367. }
  368. });
  369. // src/utils/select-object-keys.js
  370. function selectObjectKeys(obj, keys) {
  371. if (!obj || typeof obj !== "object" || Array.isArray(obj))
  372. throw new InvalidArgumentError(
  373. "The first argument of selectObjectKeys should be an Object, but %v was given.",
  374. obj
  375. );
  376. if (!Array.isArray(keys))
  377. throw new InvalidArgumentError(
  378. "The second argument of selectObjectKeys should be an Array of String, but %v was given.",
  379. keys
  380. );
  381. keys.forEach((key) => {
  382. if (typeof key !== "string")
  383. throw new InvalidArgumentError(
  384. "The second argument of selectObjectKeys should be an Array of String, but %v was given.",
  385. key
  386. );
  387. });
  388. const result = {};
  389. const allKeys = Object.keys(obj);
  390. allKeys.forEach((key) => {
  391. if (keys.includes(key)) result[key] = obj[key];
  392. });
  393. return result;
  394. }
  395. var init_select_object_keys = __esm({
  396. "src/utils/select-object-keys.js"() {
  397. "use strict";
  398. init_errors();
  399. __name(selectObjectKeys, "selectObjectKeys");
  400. }
  401. });
  402. // src/utils/exclude-object-keys.js
  403. function excludeObjectKeys(obj, keys) {
  404. if (typeof obj !== "object" || !obj || Array.isArray(obj))
  405. throw new InvalidArgumentError(
  406. "Cannot exclude keys from a non-Object value, %v was given.",
  407. obj
  408. );
  409. const result = { ...obj };
  410. keys = Array.isArray(keys) ? keys : [keys];
  411. keys.forEach((key) => delete result[key]);
  412. return result;
  413. }
  414. var init_exclude_object_keys = __esm({
  415. "src/utils/exclude-object-keys.js"() {
  416. "use strict";
  417. init_errors();
  418. __name(excludeObjectKeys, "excludeObjectKeys");
  419. }
  420. });
  421. // src/utils/model-name-to-model-key.js
  422. function modelNameToModelKey(modelName) {
  423. if (!modelName || typeof modelName !== "string" || /\s/.test(modelName))
  424. throw new InvalidArgumentError(
  425. "The model name should be a non-empty String without spaces, but %v was given.",
  426. modelName
  427. );
  428. if (modelName.toLowerCase() !== "model")
  429. modelName = modelName.replace(/[-_]?Model$/, "").replace(/[-_](MODEL|model)$/, "");
  430. return modelName.toLowerCase().replace(/[-_]/g, "");
  431. }
  432. var init_model_name_to_model_key = __esm({
  433. "src/utils/model-name-to-model-key.js"() {
  434. "use strict";
  435. init_errors();
  436. __name(modelNameToModelKey, "modelNameToModelKey");
  437. }
  438. });
  439. // src/utils/get-decorator-target-type.js
  440. function getDecoratorTargetType(target, propertyKey, descriptorOrIndex) {
  441. const isCtor2 = typeof target === "function";
  442. const isParameter = typeof descriptorOrIndex === "number";
  443. const isProperty = propertyKey != null && descriptorOrIndex == null;
  444. const isMethod = propertyKey != null && descriptorOrIndex != null;
  445. const D = DecoratorTargetType;
  446. if (isCtor2) {
  447. if (isParameter)
  448. return propertyKey ? D.STATIC_METHOD_PARAMETER : D.CONSTRUCTOR_PARAMETER;
  449. if (isProperty) return D.STATIC_PROPERTY;
  450. if (isMethod) return D.STATIC_METHOD;
  451. return D.CONSTRUCTOR;
  452. } else {
  453. if (isParameter) return D.INSTANCE_METHOD_PARAMETER;
  454. if (isProperty) return D.INSTANCE_PROPERTY;
  455. if (isMethod) return D.INSTANCE_METHOD;
  456. return D.INSTANCE;
  457. }
  458. }
  459. var DecoratorTargetType;
  460. var init_get_decorator_target_type = __esm({
  461. "src/utils/get-decorator-target-type.js"() {
  462. "use strict";
  463. DecoratorTargetType = {
  464. CONSTRUCTOR: "constructor",
  465. INSTANCE: "instance",
  466. STATIC_METHOD: "staticMethod",
  467. INSTANCE_METHOD: "instanceMethod",
  468. STATIC_PROPERTY: "staticProperty",
  469. INSTANCE_PROPERTY: "instanceProperty",
  470. CONSTRUCTOR_PARAMETER: "constructorParameter",
  471. STATIC_METHOD_PARAMETER: "staticMethodParameter",
  472. INSTANCE_METHOD_PARAMETER: "instanceMethodParameter"
  473. };
  474. __name(getDecoratorTargetType, "getDecoratorTargetType");
  475. }
  476. });
  477. // src/utils/index.js
  478. var init_utils = __esm({
  479. "src/utils/index.js"() {
  480. "use strict";
  481. init_is_ctor();
  482. init_is_promise();
  483. init_capitalize();
  484. init_clone_deep();
  485. init_singularize();
  486. init_is_deep_equal();
  487. init_get_ctor_name();
  488. init_is_pure_object();
  489. init_like_to_regexp();
  490. init_string_to_regexp();
  491. init_get_value_by_path();
  492. init_transform_promise();
  493. init_select_object_keys();
  494. init_exclude_object_keys();
  495. init_model_name_to_model_key();
  496. init_get_decorator_target_type();
  497. }
  498. });
  499. // src/filter/slice-clause-tool.js
  500. var import_js_service, _SliceClauseTool, SliceClauseTool;
  501. var init_slice_clause_tool = __esm({
  502. "src/filter/slice-clause-tool.js"() {
  503. "use strict";
  504. import_js_service = require("@e22m4u/js-service");
  505. init_errors();
  506. _SliceClauseTool = class _SliceClauseTool extends import_js_service.Service {
  507. /**
  508. * Slice.
  509. *
  510. * @param {object[]} entities
  511. * @param {number|undefined} skip
  512. * @param {number|undefined} limit
  513. * @returns {object[]}
  514. */
  515. slice(entities, skip = void 0, limit = void 0) {
  516. if (!Array.isArray(entities))
  517. throw new InvalidArgumentError(
  518. "The first argument of SliceClauseTool.slice should be an Array, but %v was given.",
  519. entities
  520. );
  521. if (skip != null && typeof skip !== "number")
  522. throw new InvalidArgumentError(
  523. 'The provided option "skip" should be a Number, but %v was given.',
  524. skip
  525. );
  526. if (limit != null && typeof limit !== "number")
  527. throw new InvalidArgumentError(
  528. 'The provided option "limit" should be a Number, but %v was given.',
  529. limit
  530. );
  531. skip = skip || 0;
  532. limit = limit || entities.length;
  533. return entities.slice(skip, skip + limit);
  534. }
  535. /**
  536. * Validate skip clause.
  537. *
  538. * @param {number|undefined} skip
  539. */
  540. static validateSkipClause(skip) {
  541. if (skip == null) return;
  542. if (typeof skip !== "number")
  543. throw new InvalidArgumentError(
  544. 'The provided option "skip" should be a Number, but %v was given.',
  545. skip
  546. );
  547. }
  548. /**
  549. * Validate limit clause.
  550. *
  551. * @param {number|undefined} limit
  552. */
  553. static validateLimitClause(limit) {
  554. if (limit == null) return;
  555. if (typeof limit !== "number")
  556. throw new InvalidArgumentError(
  557. 'The provided option "limit" should be a Number, but %v was given.',
  558. limit
  559. );
  560. }
  561. };
  562. __name(_SliceClauseTool, "SliceClauseTool");
  563. SliceClauseTool = _SliceClauseTool;
  564. }
  565. });
  566. // src/filter/order-clause-tool.js
  567. function compareFn(a, b) {
  568. let undefinedA, undefinedB;
  569. for (let i = 0, l = this.length; i < l; i++) {
  570. const aVal = getValueByPath(a, this[i].key);
  571. const bVal = getValueByPath(b, this[i].key);
  572. undefinedB = bVal === void 0 && aVal !== void 0;
  573. undefinedA = aVal === void 0 && bVal !== void 0;
  574. if (undefinedB || aVal > bVal) {
  575. return this[i].reverse;
  576. } else if (undefinedA || aVal < bVal) {
  577. return -1 * this[i].reverse;
  578. }
  579. }
  580. return 0;
  581. }
  582. var import_js_service2, _OrderClauseTool, OrderClauseTool;
  583. var init_order_clause_tool = __esm({
  584. "src/filter/order-clause-tool.js"() {
  585. "use strict";
  586. import_js_service2 = require("@e22m4u/js-service");
  587. init_utils();
  588. init_errors();
  589. _OrderClauseTool = class _OrderClauseTool extends import_js_service2.Service {
  590. /**
  591. * Sort.
  592. *
  593. * @param {object[]} entities
  594. * @param {string|string[]|undefined} clause
  595. */
  596. sort(entities, clause) {
  597. if (clause == null) return;
  598. if (Array.isArray(clause) === false) clause = [clause];
  599. if (!clause.length) return;
  600. const mapping = [];
  601. clause.forEach((key, index) => {
  602. if (!key || typeof key !== "string")
  603. throw new InvalidArgumentError(
  604. 'The provided option "order" should be a non-empty String or an Array of non-empty String, but %v was given.',
  605. key
  606. );
  607. let reverse = 1;
  608. const matches = key.match(/\s+(A|DE)SC$/i);
  609. if (matches) {
  610. key = key.replace(/\s+(A|DE)SC/i, "");
  611. if (matches[1].toLowerCase() === "de") reverse = -1;
  612. }
  613. mapping[index] = { key, reverse };
  614. });
  615. entities.sort(compareFn.bind(mapping));
  616. }
  617. /**
  618. * Validate order clause.
  619. *
  620. * @param {string|string[]|undefined} clause
  621. */
  622. static validateOrderClause(clause) {
  623. if (clause == null) return;
  624. if (Array.isArray(clause) === false) clause = [clause];
  625. if (!clause.length) return;
  626. clause.forEach((field) => {
  627. if (!field || typeof field !== "string")
  628. throw new InvalidArgumentError(
  629. 'The provided option "order" should be a non-empty String or an Array of non-empty String, but %v was given.',
  630. field
  631. );
  632. });
  633. }
  634. /**
  635. * Normalize order clause.
  636. *
  637. * @param {string|string[]|undefined} clause
  638. * @returns {string[]|undefined}
  639. */
  640. static normalizeOrderClause(clause) {
  641. if (clause == null) return;
  642. if (Array.isArray(clause) === false) clause = [clause];
  643. if (!clause.length) return;
  644. clause.forEach((field) => {
  645. if (!field || typeof field !== "string")
  646. throw new InvalidArgumentError(
  647. 'The provided option "order" should be a non-empty String or an Array of non-empty String, but %v was given.',
  648. field
  649. );
  650. });
  651. return clause;
  652. }
  653. };
  654. __name(_OrderClauseTool, "OrderClauseTool");
  655. OrderClauseTool = _OrderClauseTool;
  656. __name(compareFn, "compareFn");
  657. }
  658. });
  659. // src/filter/operator-clause-tool.js
  660. var import_js_service3, _OperatorClauseTool, OperatorClauseTool;
  661. var init_operator_clause_tool = __esm({
  662. "src/filter/operator-clause-tool.js"() {
  663. "use strict";
  664. import_js_service3 = require("@e22m4u/js-service");
  665. init_utils();
  666. init_errors();
  667. _OperatorClauseTool = class _OperatorClauseTool extends import_js_service3.Service {
  668. /**
  669. * Compare.
  670. *
  671. * @param {*} val1 The 1st value
  672. * @param {*} val2 The 2nd value
  673. * @param {*} noTypeConversion
  674. * @returns {number} 0: =, positive: >, negative <
  675. */
  676. compare(val1, val2, noTypeConversion = false) {
  677. if (val1 === val2) {
  678. return 0;
  679. }
  680. if (val1 == null || val2 == null) {
  681. return val1 == val2 ? 0 : NaN;
  682. }
  683. const type1 = typeof val1;
  684. const type2 = typeof val2;
  685. if (type1 === "object" || type2 === "object") {
  686. return isDeepEqual(val1, val2) ? 0 : NaN;
  687. }
  688. if ((type1 === "number" || type1 === "string" || type1 === "boolean") && (type2 === "number" || type2 === "string" || type2 === "boolean")) {
  689. if (noTypeConversion && type1 !== type2) {
  690. return NaN;
  691. }
  692. const num1 = Number(val1);
  693. const num2 = Number(val2);
  694. if (!isNaN(num1) && !isNaN(num2)) {
  695. return num1 - num2;
  696. }
  697. }
  698. if (type1 === "string" && type2 === "string") {
  699. if (val1 > val2) return 1;
  700. if (val1 < val2) return -1;
  701. return 0;
  702. }
  703. return NaN;
  704. }
  705. /**
  706. * Test all operators.
  707. *
  708. * @param {object} clause
  709. * @param {*} value
  710. * @returns {boolean|undefined}
  711. */
  712. testAll(clause, value) {
  713. if (!clause || typeof clause !== "object" || Array.isArray(clause))
  714. throw new InvalidArgumentError(
  715. "The first argument of OperatorUtils.testAll should be an Object, but %v was given.",
  716. clause
  717. );
  718. const operatorMap = {
  719. eq: this.testEqNeq,
  720. neq: this.testEqNeq,
  721. gt: this.testGtLt,
  722. gte: this.testGtLt,
  723. lt: this.testGtLt,
  724. lte: this.testGtLt,
  725. inq: this.testInq,
  726. nin: this.testNin,
  727. between: this.testBetween,
  728. exists: this.testExists,
  729. like: this.testLike,
  730. nlike: this.testNlike,
  731. ilike: this.testIlike,
  732. nilike: this.testNilike,
  733. regexp: this.testRegexp
  734. };
  735. const clauseKeys = Object.keys(clause);
  736. const knownOperators = clauseKeys.filter((key) => operatorMap[key]);
  737. if (knownOperators.length === 0) {
  738. return void 0;
  739. }
  740. return knownOperators.every((op) => {
  741. const singleOpClause = { [op]: clause[op] };
  742. if (op === "regexp" && "flags" in clause) {
  743. singleOpClause.flags = clause.flags;
  744. }
  745. const testFn = operatorMap[op];
  746. const result = testFn.call(this, singleOpClause, value);
  747. return result;
  748. });
  749. }
  750. /**
  751. * Test eq/neq operator.
  752. *
  753. * @example
  754. * ```ts
  755. * {
  756. * eq: 'foo',
  757. * }
  758. * ```
  759. *
  760. * @example
  761. * ```ts
  762. * {
  763. * neq: 'foo',
  764. * }
  765. * ```
  766. *
  767. * @param {object} clause
  768. * @param {*} value
  769. * @returns {boolean|undefined}
  770. */
  771. testEqNeq(clause, value) {
  772. if (!clause || typeof clause !== "object")
  773. throw new InvalidArgumentError(
  774. "The first argument of OperatorUtils.testEqNeq should be an Object, but %v was given.",
  775. clause
  776. );
  777. if ("eq" in clause) return this.compare(clause.eq, value, true) === 0;
  778. if ("neq" in clause) return this.compare(clause.neq, value, true) !== 0;
  779. }
  780. /**
  781. * Test lt/gt/lte/gte operator.
  782. *
  783. * @example
  784. * ```ts
  785. * {
  786. * lt: 10,
  787. * }
  788. * ```
  789. *
  790. * @example
  791. * ```ts
  792. * {
  793. * lte: 10,
  794. * }
  795. * ```
  796. *
  797. * @example
  798. * ```ts
  799. * {
  800. * gt: 10,
  801. * }
  802. * ```
  803. *
  804. * @example
  805. * ```ts
  806. * {
  807. * gte: 10,
  808. * }
  809. * ```
  810. *
  811. * @param {object} clause
  812. * @param {*} value
  813. * @returns {boolean|undefined}
  814. */
  815. testGtLt(clause, value) {
  816. if (!clause || typeof clause !== "object")
  817. throw new InvalidArgumentError(
  818. "The first argument of OperatorUtils.testGtLt should be an Object, but %v was given.",
  819. clause
  820. );
  821. if ("gt" in clause) return this.compare(value, clause.gt) > 0;
  822. if ("gte" in clause) return this.compare(value, clause.gte) >= 0;
  823. if ("lt" in clause) return this.compare(value, clause.lt) < 0;
  824. if ("lte" in clause) return this.compare(value, clause.lte) <= 0;
  825. }
  826. /**
  827. * Test inc operator.
  828. *
  829. * @example
  830. * ```ts
  831. * {
  832. * inc: ['foo', 'bar'],
  833. * }
  834. * ```
  835. *
  836. * @param {object} clause
  837. * @param {*} value
  838. * @returns {boolean|undefined}
  839. */
  840. testInq(clause, value) {
  841. if (!clause || typeof clause !== "object")
  842. throw new InvalidArgumentError(
  843. "The first argument of OperatorUtils.testInq should be an Object, but %v was given.",
  844. clause
  845. );
  846. if ("inq" in clause && clause.inq !== void 0) {
  847. if (!clause.inq || !Array.isArray(clause.inq)) {
  848. throw new InvalidOperatorValueError(
  849. "inq",
  850. "an Array of possible values",
  851. clause.inq
  852. );
  853. }
  854. for (let i = 0; i < clause.inq.length; i++) {
  855. if (this.compare(clause.inq[i], value, true) === 0) {
  856. return true;
  857. }
  858. }
  859. return false;
  860. }
  861. }
  862. /**
  863. * Test nin operator.
  864. *
  865. * @example
  866. * ```ts
  867. * {
  868. * nin: ['foo', 'bar'],
  869. * }
  870. * ```
  871. *
  872. * @param {object} clause
  873. * @param {*} value
  874. * @returns {boolean|undefined}
  875. */
  876. testNin(clause, value) {
  877. if (!clause || typeof clause !== "object")
  878. throw new InvalidArgumentError(
  879. "The first argument of OperatorUtils.testNin should be an Object, but %v was given.",
  880. clause
  881. );
  882. if ("nin" in clause && clause.nin !== void 0) {
  883. if (!clause.nin || !Array.isArray(clause.nin)) {
  884. throw new InvalidOperatorValueError(
  885. "nin",
  886. "an Array of possible values",
  887. clause.nin
  888. );
  889. }
  890. return clause.nin.every((element) => {
  891. return this.compare(element, value, true) !== 0;
  892. });
  893. }
  894. }
  895. /**
  896. * Test between operator.
  897. *
  898. * @example
  899. * ```ts
  900. * {
  901. * between: [10, 20],
  902. * }
  903. * ```
  904. *
  905. * @param {object} clause
  906. * @param {*} value
  907. * @returns {boolean|undefined}
  908. */
  909. testBetween(clause, value) {
  910. if (!clause || typeof clause !== "object")
  911. throw new InvalidArgumentError(
  912. "The first argument of OperatorUtils.testBetween should be an Object, but %v was given.",
  913. clause
  914. );
  915. if ("between" in clause && clause.between !== void 0) {
  916. if (!Array.isArray(clause.between) || clause.between.length !== 2) {
  917. throw new InvalidOperatorValueError(
  918. "between",
  919. "an Array of 2 elements",
  920. clause.between
  921. );
  922. }
  923. return this.testGtLt({ gte: clause.between[0] }, value) && this.testGtLt({ lte: clause.between[1] }, value);
  924. }
  925. }
  926. /**
  927. * Test exists operator.
  928. *
  929. * @example
  930. * ```ts
  931. * {
  932. * exists: true,
  933. * }
  934. * ```
  935. *
  936. * @param {object} clause
  937. * @param {*} value
  938. * @returns {boolean|undefined}
  939. */
  940. testExists(clause, value) {
  941. if (!clause || typeof clause !== "object")
  942. throw new InvalidArgumentError(
  943. "The first argument of OperatorUtils.testExists should be an Object, but %v was given.",
  944. clause
  945. );
  946. if ("exists" in clause && clause.exists !== void 0) {
  947. if (typeof clause.exists !== "boolean") {
  948. throw new InvalidOperatorValueError(
  949. "exists",
  950. "a Boolean",
  951. clause.exists
  952. );
  953. }
  954. return clause.exists ? value !== void 0 : value === void 0;
  955. }
  956. }
  957. /**
  958. * Test like operator.
  959. *
  960. * @example
  961. * ```ts
  962. * {
  963. * like: 'foo',
  964. * }
  965. * ```
  966. *
  967. * @param {object} clause
  968. * @param {*} value
  969. * @returns {boolean|undefined}
  970. */
  971. testLike(clause, value) {
  972. if (!clause || typeof clause !== "object" || Array.isArray(clause))
  973. throw new InvalidArgumentError(
  974. "The first argument of OperatorUtils.testLike should be an Object, but %v was given.",
  975. clause
  976. );
  977. if ("like" in clause && clause.like !== void 0) {
  978. if (typeof clause.like !== "string")
  979. throw new InvalidOperatorValueError("like", "a String", clause.like);
  980. return likeToRegexp(clause.like).test(value);
  981. }
  982. }
  983. /**
  984. * Test nlike operator.
  985. *
  986. * @example
  987. * ```ts
  988. * {
  989. * nlike: 'foo',
  990. * }
  991. * ```
  992. *
  993. * @param {object} clause
  994. * @param {*} value
  995. * @returns {boolean|undefined}
  996. */
  997. testNlike(clause, value) {
  998. if (!clause || typeof clause !== "object" || Array.isArray(clause))
  999. throw new InvalidArgumentError(
  1000. "The first argument of OperatorUtils.testNlike should be an Object, but %v was given.",
  1001. clause
  1002. );
  1003. if ("nlike" in clause && clause.nlike !== void 0) {
  1004. if (typeof clause.nlike !== "string") {
  1005. throw new InvalidOperatorValueError("nlike", "a String", clause.nlike);
  1006. }
  1007. return !likeToRegexp(clause.nlike).test(value);
  1008. }
  1009. }
  1010. /**
  1011. * Test ilike operator.
  1012. *
  1013. * @example
  1014. * ```ts
  1015. * {
  1016. * ilike: 'foo',
  1017. * }
  1018. * ```
  1019. *
  1020. * @param {object} clause
  1021. * @param {*} value
  1022. * @returns {boolean|undefined}
  1023. */
  1024. testIlike(clause, value) {
  1025. if (!clause || typeof clause !== "object" || Array.isArray(clause))
  1026. throw new InvalidArgumentError(
  1027. "The first argument of OperatorUtils.testIlike should be an Object, but %v was given.",
  1028. clause
  1029. );
  1030. if ("ilike" in clause && clause.ilike !== void 0) {
  1031. if (typeof clause.ilike !== "string") {
  1032. throw new InvalidOperatorValueError("ilike", "a String", clause.ilike);
  1033. }
  1034. return likeToRegexp(clause.ilike, true).test(value);
  1035. }
  1036. }
  1037. /**
  1038. * Test nilike operator.
  1039. *
  1040. * @example
  1041. * ```ts
  1042. * {
  1043. * nilike: 'foo',
  1044. * }
  1045. * ```
  1046. *
  1047. * @param {object} clause
  1048. * @param {*} value
  1049. * @returns {boolean|undefined}
  1050. */
  1051. testNilike(clause, value) {
  1052. if (!clause || typeof clause !== "object" || Array.isArray(clause))
  1053. throw new InvalidArgumentError(
  1054. "The first argument of OperatorUtils.testNilike should be an Object, but %v was given.",
  1055. clause
  1056. );
  1057. if ("nilike" in clause && clause.nilike !== void 0) {
  1058. if (typeof clause.nilike !== "string") {
  1059. throw new InvalidOperatorValueError(
  1060. "nilike",
  1061. "a String",
  1062. clause.nilike
  1063. );
  1064. }
  1065. return !likeToRegexp(clause.nilike, true).test(value);
  1066. }
  1067. }
  1068. /**
  1069. * Test regexp.
  1070. *
  1071. * @example
  1072. * ```ts
  1073. * {
  1074. * regexp: 'foo.*',
  1075. * }
  1076. * ```
  1077. *
  1078. * @example
  1079. * ```ts
  1080. * {
  1081. * regexp: 'foo.*',
  1082. * flags: 'i',
  1083. * }
  1084. * ```
  1085. *
  1086. * @param {object} clause
  1087. * @param {*} value
  1088. * @returns {boolean|undefined}
  1089. */
  1090. testRegexp(clause, value) {
  1091. if (!clause || typeof clause !== "object")
  1092. throw new InvalidArgumentError(
  1093. "The first argument of OperatorUtils.testRegexp should be an Object, but %v was given.",
  1094. clause
  1095. );
  1096. if ("regexp" in clause && clause.regexp !== void 0) {
  1097. if (typeof clause.regexp !== "string" && !(clause.regexp instanceof RegExp)) {
  1098. throw new InvalidOperatorValueError(
  1099. "regexp",
  1100. "a String",
  1101. clause.regexp
  1102. );
  1103. }
  1104. const flags = clause.flags || void 0;
  1105. if (flags && typeof flags !== "string")
  1106. throw new InvalidArgumentError(
  1107. "RegExp flags should be a String, but %v was given.",
  1108. clause.flags
  1109. );
  1110. if (!value || typeof value !== "string") return false;
  1111. const regExp = stringToRegexp(clause.regexp, flags);
  1112. return !!value.match(regExp);
  1113. }
  1114. }
  1115. };
  1116. __name(_OperatorClauseTool, "OperatorClauseTool");
  1117. OperatorClauseTool = _OperatorClauseTool;
  1118. }
  1119. });
  1120. // src/filter/where-clause-tool.js
  1121. var import_js_service4, _WhereClauseTool, WhereClauseTool;
  1122. var init_where_clause_tool = __esm({
  1123. "src/filter/where-clause-tool.js"() {
  1124. "use strict";
  1125. import_js_service4 = require("@e22m4u/js-service");
  1126. init_errors();
  1127. init_operator_clause_tool();
  1128. init_utils();
  1129. _WhereClauseTool = class _WhereClauseTool extends import_js_service4.Service {
  1130. /**
  1131. * Filter by where clause.
  1132. *
  1133. * @example
  1134. * ```
  1135. * const entities = [
  1136. * {foo: 1, bar: 'a'},
  1137. * {foo: 2, bar: 'b'},
  1138. * {foo: 3, bar: 'b'},
  1139. * {foo: 4, bar: 'b'},
  1140. * ];
  1141. *
  1142. * const result = filterByWhereClause(entities, {
  1143. * foo: {gt: 2},
  1144. * bar: 'b',
  1145. * });
  1146. *
  1147. * console.log(result);
  1148. * // [
  1149. * // {foo: 3, bar: 'b'},
  1150. * // {foo: 4, bar: 'b'},
  1151. * // ];
  1152. *
  1153. * ```
  1154. *
  1155. * @param {object[]} entities
  1156. * @param {WhereClause|undefined} where
  1157. * @returns {object[]}
  1158. */
  1159. filter(entities, where = void 0) {
  1160. if (!Array.isArray(entities))
  1161. throw new InvalidArgumentError(
  1162. "The first argument of WhereClauseTool.filter should be an Array of Object, but %v was given.",
  1163. entities
  1164. );
  1165. if (where == null) return entities;
  1166. return entities.filter(this._createFilter(where));
  1167. }
  1168. /**
  1169. * Create where filter.
  1170. *
  1171. * @param {WhereClause} whereClause
  1172. * @returns {Function}
  1173. */
  1174. _createFilter(whereClause) {
  1175. if (typeof whereClause !== "object" || Array.isArray(whereClause))
  1176. throw new InvalidArgumentError(
  1177. 'The provided option "where" should be an Object, but %v was given.',
  1178. whereClause
  1179. );
  1180. const keys = Object.keys(whereClause);
  1181. return (data) => {
  1182. if (typeof data !== "object")
  1183. throw new InvalidArgumentError(
  1184. "The first argument of WhereClauseTool.filter should be an Array of Object, but %v was given.",
  1185. data
  1186. );
  1187. return keys.every((key) => {
  1188. if (key === "and" && key in whereClause) {
  1189. const andClause = whereClause[key];
  1190. if (Array.isArray(andClause))
  1191. return andClause.every((clause) => this._createFilter(clause)(data));
  1192. } else if (key === "or" && key in whereClause) {
  1193. const orClause = whereClause[key];
  1194. if (Array.isArray(orClause))
  1195. return orClause.some((clause) => this._createFilter(clause)(data));
  1196. }
  1197. const value = getValueByPath(data, key);
  1198. const matcher = whereClause[key];
  1199. if (this._test(matcher, value)) return true;
  1200. });
  1201. };
  1202. }
  1203. /**
  1204. * Value testing.
  1205. *
  1206. * @param {*} example
  1207. * @param {*} value
  1208. * @returns {boolean}
  1209. */
  1210. _test(example, value) {
  1211. if (example === value) {
  1212. return true;
  1213. }
  1214. if (example === null) {
  1215. return value === null;
  1216. }
  1217. if (example === void 0) {
  1218. return value === void 0;
  1219. }
  1220. if (example instanceof RegExp) {
  1221. if (typeof value === "string") {
  1222. return example.test(value);
  1223. }
  1224. if (Array.isArray(value)) {
  1225. return value.some((el) => typeof el === "string" && example.test(el));
  1226. }
  1227. return false;
  1228. }
  1229. if (isPureObject(example)) {
  1230. const operatorsTest = this.getService(OperatorClauseTool).testAll(
  1231. example,
  1232. value
  1233. );
  1234. if (operatorsTest !== void 0) {
  1235. if ("neq" in example && Array.isArray(value)) {
  1236. return !value.some((el) => isDeepEqual(el, example.neq));
  1237. }
  1238. return operatorsTest;
  1239. }
  1240. }
  1241. if (Array.isArray(value)) {
  1242. const isElementMatched = value.some((el) => isDeepEqual(el, example));
  1243. if (isElementMatched) return true;
  1244. }
  1245. return isDeepEqual(example, value);
  1246. }
  1247. /**
  1248. * Validate where clause.
  1249. *
  1250. * @param {WhereClause|undefined} clause
  1251. */
  1252. static validateWhereClause(clause) {
  1253. if (clause == null || typeof clause === "function") return;
  1254. if (typeof clause !== "object" || Array.isArray(clause))
  1255. throw new InvalidArgumentError(
  1256. 'The provided option "where" should be an Object, but %v was given.',
  1257. clause
  1258. );
  1259. }
  1260. };
  1261. __name(_WhereClauseTool, "WhereClauseTool");
  1262. WhereClauseTool = _WhereClauseTool;
  1263. }
  1264. });
  1265. // src/definition/model/relations/relation-type.js
  1266. var RelationType;
  1267. var init_relation_type = __esm({
  1268. "src/definition/model/relations/relation-type.js"() {
  1269. "use strict";
  1270. RelationType = {
  1271. BELONGS_TO: "belongsTo",
  1272. HAS_ONE: "hasOne",
  1273. HAS_MANY: "hasMany",
  1274. REFERENCES_MANY: "referencesMany"
  1275. };
  1276. }
  1277. });
  1278. // src/definition/model/relations/relation-definition.js
  1279. var init_relation_definition = __esm({
  1280. "src/definition/model/relations/relation-definition.js"() {
  1281. "use strict";
  1282. }
  1283. });
  1284. // src/definition/model/relations/relations-definition-validator.js
  1285. var import_js_service5, _RelationsDefinitionValidator, RelationsDefinitionValidator;
  1286. var init_relations_definition_validator = __esm({
  1287. "src/definition/model/relations/relations-definition-validator.js"() {
  1288. "use strict";
  1289. import_js_service5 = require("@e22m4u/js-service");
  1290. init_relation_type();
  1291. init_relation_type();
  1292. init_errors();
  1293. _RelationsDefinitionValidator = class _RelationsDefinitionValidator extends import_js_service5.Service {
  1294. /**
  1295. * Validate.
  1296. *
  1297. * @param {string} modelName
  1298. * @param {object} relDefs
  1299. */
  1300. validate(modelName, relDefs) {
  1301. if (!modelName || typeof modelName !== "string")
  1302. throw new InvalidArgumentError(
  1303. "The first argument of RelationsDefinitionValidator.validate should be a non-empty String, but %v was given.",
  1304. modelName
  1305. );
  1306. if (!relDefs || typeof relDefs !== "object" || Array.isArray(relDefs))
  1307. throw new InvalidArgumentError(
  1308. 'The provided option "relations" of the model %v should be an Object, but %v was given.',
  1309. modelName,
  1310. relDefs
  1311. );
  1312. const relNames = Object.keys(relDefs);
  1313. relNames.forEach((relName) => {
  1314. const relDef = relDefs[relName];
  1315. this._validateRelation(modelName, relName, relDef);
  1316. });
  1317. }
  1318. /**
  1319. * Validate relation.
  1320. *
  1321. * @param {string} modelName
  1322. * @param {string} relName
  1323. * @param {object} relDef
  1324. */
  1325. _validateRelation(modelName, relName, relDef) {
  1326. if (!modelName || typeof modelName !== "string")
  1327. throw new InvalidArgumentError(
  1328. "The first argument of RelationsDefinitionValidator._validateRelation should be a non-empty String, but %v was given.",
  1329. modelName
  1330. );
  1331. if (!relName || typeof relName !== "string")
  1332. throw new InvalidArgumentError(
  1333. "The relation name of the model %v should be a non-empty String, but %v was given.",
  1334. modelName,
  1335. relName
  1336. );
  1337. if (!relDef || typeof relDef !== "object" || Array.isArray(relDef))
  1338. throw new InvalidArgumentError(
  1339. "The relation %v of the model %v should be an Object, but %v was given.",
  1340. relName,
  1341. modelName,
  1342. relDef
  1343. );
  1344. if (!relDef.type || !Object.values(RelationType).includes(relDef.type))
  1345. throw new InvalidArgumentError(
  1346. 'The relation %v of the model %v requires the option "type" to have one of relation types: %l, but %v was given.',
  1347. relName,
  1348. modelName,
  1349. Object.values(RelationType),
  1350. relDef.type
  1351. );
  1352. this._validateBelongsTo(modelName, relName, relDef);
  1353. this._validateHasOne(modelName, relName, relDef);
  1354. this._validateHasMany(modelName, relName, relDef);
  1355. this._validateReferencesMany(modelName, relName, relDef);
  1356. }
  1357. /**
  1358. * Validate "belongsTo".
  1359. *
  1360. * @example The regular "belongsTo" relation.
  1361. * ```
  1362. * {
  1363. * type: RelationType.BELONGS_TO,
  1364. * model: 'model',
  1365. * foreignKey: 'modelId', // optional
  1366. * }
  1367. * ```
  1368. *
  1369. * @example The polymorphic "belongsTo" relation.
  1370. * ```
  1371. * {
  1372. * type: RelationType.BELONGS_TO,
  1373. * polymorphic: true,
  1374. * foreignKey: 'referenceId', // optional
  1375. * discriminator: 'referenceType', // optional
  1376. * }
  1377. * ```
  1378. *
  1379. * @param {string} modelName
  1380. * @param {string} relName
  1381. * @param {object} relDef
  1382. * @private
  1383. */
  1384. _validateBelongsTo(modelName, relName, relDef) {
  1385. if (relDef.type !== RelationType.BELONGS_TO) return;
  1386. if (relDef.polymorphic) {
  1387. if (typeof relDef.polymorphic !== "boolean")
  1388. throw new InvalidArgumentError(
  1389. 'The relation %v of the model %v has the type "belongsTo", so it expects the option "polymorphic" to be a Boolean, but %v was given.',
  1390. relName,
  1391. modelName,
  1392. relDef.polymorphic
  1393. );
  1394. if (relDef.foreignKey && typeof relDef.foreignKey !== "string")
  1395. throw new InvalidArgumentError(
  1396. 'The relation %v of the model %v is a polymorphic "belongsTo" relation, so it expects the provided option "foreignKey" to be a String, but %v was given.',
  1397. relName,
  1398. modelName,
  1399. relDef.foreignKey
  1400. );
  1401. if (relDef.discriminator && typeof relDef.discriminator !== "string")
  1402. throw new InvalidArgumentError(
  1403. 'The relation %v of the model %v is a polymorphic "belongsTo" relation, so it expects the provided option "discriminator" to be a String, but %v was given.',
  1404. relName,
  1405. modelName,
  1406. relDef.discriminator
  1407. );
  1408. } else {
  1409. if (!relDef.model || typeof relDef.model !== "string")
  1410. throw new InvalidArgumentError(
  1411. 'The relation %v of the model %v has the type "belongsTo", so it requires the option "model" to be a non-empty String, but %v was given.',
  1412. relName,
  1413. modelName,
  1414. relDef.model
  1415. );
  1416. if (relDef.foreignKey && typeof relDef.foreignKey !== "string")
  1417. throw new InvalidArgumentError(
  1418. 'The relation %v of the model %v has the type "belongsTo", so it expects the provided option "foreignKey" to be a String, but %v was given.',
  1419. relName,
  1420. modelName,
  1421. relDef.foreignKey
  1422. );
  1423. if (relDef.discriminator)
  1424. throw new InvalidArgumentError(
  1425. 'The relation %v of the model %v is a non-polymorphic "belongsTo" relation, so it should not have the option "discriminator" to be provided.',
  1426. relName,
  1427. modelName
  1428. );
  1429. }
  1430. }
  1431. /**
  1432. * Validate "hasOne".
  1433. *
  1434. * @example The regular "hasOne" relation.
  1435. * ```
  1436. * {
  1437. * type: RelationType.HAS_ONE,
  1438. * model: 'model',
  1439. * foreignKey: 'modelId',
  1440. * }
  1441. * ```
  1442. *
  1443. * @example The polymorphic "hasOne" relation with a target relation name.
  1444. * ```
  1445. * {
  1446. * type: RelationType.HAS_ONE,
  1447. * model: 'model',
  1448. * polymorphic: 'reference',
  1449. * }
  1450. * ```
  1451. *
  1452. * @example The polymorphic "hasOne" relation with target relation keys.
  1453. * ```
  1454. * {
  1455. * type: RelationType.HAS_ONE,
  1456. * model: 'model',
  1457. * polymorphic: true,
  1458. * foreignKey: 'referenceId',
  1459. * discriminator: 'referenceType',
  1460. * }
  1461. * ```
  1462. *
  1463. * @param {string} modelName
  1464. * @param {string} relName
  1465. * @param {object} relDef
  1466. * @private
  1467. */
  1468. _validateHasOne(modelName, relName, relDef) {
  1469. if (relDef.type !== RelationType.HAS_ONE) return;
  1470. if (!relDef.model || typeof relDef.model !== "string")
  1471. throw new InvalidArgumentError(
  1472. 'The relation %v of the model %v has the type "hasOne", so it requires the option "model" to be a non-empty String, but %v was given.',
  1473. relName,
  1474. modelName,
  1475. relDef.model
  1476. );
  1477. if (relDef.polymorphic) {
  1478. if (typeof relDef.polymorphic === "string") {
  1479. if (relDef.foreignKey)
  1480. throw new InvalidArgumentError(
  1481. 'The relation %v of the model %v has the option "polymorphic" with a String value, so it should not have the option "foreignKey" to be provided.',
  1482. relName,
  1483. modelName
  1484. );
  1485. if (relDef.discriminator)
  1486. throw new InvalidArgumentError(
  1487. 'The relation %v of the model %v has the option "polymorphic" with a String value, so it should not have the option "discriminator" to be provided.',
  1488. relName,
  1489. modelName
  1490. );
  1491. } else if (typeof relDef.polymorphic === "boolean") {
  1492. if (!relDef.foreignKey || typeof relDef.foreignKey !== "string")
  1493. throw new InvalidArgumentError(
  1494. 'The relation %v of the model %v has the option "polymorphic" with "true" value, so it requires the option "foreignKey" to be a non-empty String, but %v was given.',
  1495. relName,
  1496. modelName,
  1497. relDef.foreignKey
  1498. );
  1499. if (!relDef.discriminator || typeof relDef.discriminator !== "string")
  1500. throw new InvalidArgumentError(
  1501. 'The relation %v of the model %v has the option "polymorphic" with "true" value, so it requires the option "discriminator" to be a non-empty String, but %v was given.',
  1502. relName,
  1503. modelName,
  1504. relDef.discriminator
  1505. );
  1506. } else {
  1507. throw new InvalidArgumentError(
  1508. 'The relation %v of the model %v has the type "hasOne", so it expects the provided option "polymorphic" to be a String or a Boolean, but %v was given.',
  1509. relName,
  1510. modelName,
  1511. relDef.polymorphic
  1512. );
  1513. }
  1514. } else {
  1515. if (!relDef.foreignKey || typeof relDef.foreignKey !== "string")
  1516. throw new InvalidArgumentError(
  1517. 'The relation %v of the model %v has the type "hasOne", so it requires the option "foreignKey" to be a non-empty String, but %v was given.',
  1518. relName,
  1519. modelName,
  1520. relDef.foreignKey
  1521. );
  1522. if (relDef.discriminator)
  1523. throw new InvalidArgumentError(
  1524. 'The relation %v of the model %v is a non-polymorphic "hasOne" relation, so it should not have the option "discriminator" to be provided.',
  1525. relName,
  1526. modelName
  1527. );
  1528. }
  1529. }
  1530. /**
  1531. * Validate "hasMany".
  1532. *
  1533. * @example The regular "hasMany" relation.
  1534. * ```
  1535. * {
  1536. * type: RelationType.HAS_MANY,
  1537. * model: 'model',
  1538. * foreignKey: 'modelId',
  1539. * }
  1540. * ```
  1541. *
  1542. * @example The polymorphic "hasMany" relation with a target relation name.
  1543. * ```
  1544. * {
  1545. * type: RelationType.HAS_MANY,
  1546. * model: 'model',
  1547. * polymorphic: 'reference',
  1548. * }
  1549. * ```
  1550. *
  1551. * @example The polymorphic "hasMany" relation with target relation keys.
  1552. * ```
  1553. * {
  1554. * type: RelationType.HAS_MANY,
  1555. * model: 'model',
  1556. * polymorphic: true,
  1557. * foreignKey: 'referenceId',
  1558. * discriminator: 'referenceType',
  1559. * }
  1560. * ```
  1561. *
  1562. * @param {string} modelName
  1563. * @param {string} relName
  1564. * @param {object} relDef
  1565. * @private
  1566. */
  1567. _validateHasMany(modelName, relName, relDef) {
  1568. if (relDef.type !== RelationType.HAS_MANY) return;
  1569. if (!relDef.model || typeof relDef.model !== "string")
  1570. throw new InvalidArgumentError(
  1571. 'The relation %v of the model %v has the type "hasMany", so it requires the option "model" to be a non-empty String, but %v was given.',
  1572. relName,
  1573. modelName,
  1574. relDef.model
  1575. );
  1576. if (relDef.polymorphic) {
  1577. if (typeof relDef.polymorphic === "string") {
  1578. if (relDef.foreignKey)
  1579. throw new InvalidArgumentError(
  1580. 'The relation %v of the model %v has the option "polymorphic" with a String value, so it should not have the option "foreignKey" to be provided.',
  1581. relName,
  1582. modelName
  1583. );
  1584. if (relDef.discriminator)
  1585. throw new InvalidArgumentError(
  1586. 'The relation %v of the model %v has the option "polymorphic" with a String value, so it should not have the option "discriminator" to be provided.',
  1587. relName,
  1588. modelName
  1589. );
  1590. } else if (typeof relDef.polymorphic === "boolean") {
  1591. if (!relDef.foreignKey || typeof relDef.foreignKey !== "string")
  1592. throw new InvalidArgumentError(
  1593. 'The relation %v of the model %v has the option "polymorphic" with "true" value, so it requires the option "foreignKey" to be a non-empty String, but %v was given.',
  1594. relName,
  1595. modelName,
  1596. relDef.foreignKey
  1597. );
  1598. if (!relDef.discriminator || typeof relDef.discriminator !== "string")
  1599. throw new InvalidArgumentError(
  1600. 'The relation %v of the model %v has the option "polymorphic" with "true" value, so it requires the option "discriminator" to be a non-empty String, but %v was given.',
  1601. relName,
  1602. modelName,
  1603. relDef.discriminator
  1604. );
  1605. } else {
  1606. throw new InvalidArgumentError(
  1607. 'The relation %v of the model %v has the type "hasMany", so it expects the provided option "polymorphic" to be a String or a Boolean, but %v was given.',
  1608. relName,
  1609. modelName,
  1610. relDef.polymorphic
  1611. );
  1612. }
  1613. } else {
  1614. if (!relDef.foreignKey || typeof relDef.foreignKey !== "string")
  1615. throw new InvalidArgumentError(
  1616. 'The relation %v of the model %v has the type "hasMany", so it requires the option "foreignKey" to be a non-empty String, but %v was given.',
  1617. relName,
  1618. modelName,
  1619. relDef.foreignKey
  1620. );
  1621. if (relDef.discriminator)
  1622. throw new InvalidArgumentError(
  1623. 'The relation %v of the model %v is a non-polymorphic "hasMany" relation, so it should not have the option "discriminator" to be provided.',
  1624. relName,
  1625. modelName
  1626. );
  1627. }
  1628. }
  1629. /**
  1630. * Validate "referencesMany".
  1631. *
  1632. * @example
  1633. * ```
  1634. * {
  1635. * type: RelationType.REFERENCES_MANY,
  1636. * model: 'model',
  1637. * foreignKey: 'modelIds', // optional
  1638. * }
  1639. * ```
  1640. *
  1641. * @param {string} modelName
  1642. * @param {string} relName
  1643. * @param {object} relDef
  1644. * @private
  1645. */
  1646. _validateReferencesMany(modelName, relName, relDef) {
  1647. if (relDef.type !== RelationType.REFERENCES_MANY) return;
  1648. if (!relDef.model || typeof relDef.model !== "string")
  1649. throw new InvalidArgumentError(
  1650. 'The relation %v of the model %v has the type "referencesMany", so it requires the option "model" to be a non-empty String, but %v was given.',
  1651. relName,
  1652. modelName,
  1653. relDef.model
  1654. );
  1655. if (relDef.foreignKey && typeof relDef.foreignKey !== "string")
  1656. throw new InvalidArgumentError(
  1657. 'The relation %v of the model %v has the type "referencesMany", so it expects the provided option "foreignKey" to be a String, but %v was given.',
  1658. relName,
  1659. modelName,
  1660. relDef.foreignKey
  1661. );
  1662. if (relDef.discriminator)
  1663. throw new InvalidArgumentError(
  1664. 'The relation %v of the model %v has the type "referencesMany", so it should not have the option "discriminator" to be provided.',
  1665. relName,
  1666. modelName
  1667. );
  1668. }
  1669. };
  1670. __name(_RelationsDefinitionValidator, "RelationsDefinitionValidator");
  1671. RelationsDefinitionValidator = _RelationsDefinitionValidator;
  1672. }
  1673. });
  1674. // src/definition/model/relations/index.js
  1675. var init_relations = __esm({
  1676. "src/definition/model/relations/index.js"() {
  1677. "use strict";
  1678. init_relation_type();
  1679. init_relation_definition();
  1680. init_relations_definition_validator();
  1681. }
  1682. });
  1683. // src/definition/model/properties/data-type.js
  1684. var DataType;
  1685. var init_data_type = __esm({
  1686. "src/definition/model/properties/data-type.js"() {
  1687. "use strict";
  1688. DataType = {
  1689. ANY: "any",
  1690. STRING: "string",
  1691. NUMBER: "number",
  1692. BOOLEAN: "boolean",
  1693. ARRAY: "array",
  1694. OBJECT: "object"
  1695. };
  1696. }
  1697. });
  1698. // src/definition/model/properties/property-definition.js
  1699. var init_property_definition = __esm({
  1700. "src/definition/model/properties/property-definition.js"() {
  1701. "use strict";
  1702. }
  1703. });
  1704. // src/definition/model/properties/property-uniqueness.js
  1705. var PropertyUniqueness;
  1706. var init_property_uniqueness = __esm({
  1707. "src/definition/model/properties/property-uniqueness.js"() {
  1708. "use strict";
  1709. PropertyUniqueness = {
  1710. STRICT: "strict",
  1711. SPARSE: "sparse",
  1712. NON_UNIQUE: "nonUnique"
  1713. };
  1714. }
  1715. });
  1716. // src/definition/model/properties/property-validator/property-validator.js
  1717. var init_property_validator = __esm({
  1718. "src/definition/model/properties/property-validator/property-validator.js"() {
  1719. "use strict";
  1720. }
  1721. });
  1722. // src/definition/model/properties/property-validator/builtin/regexp-validator.js
  1723. function regexpValidator(value, options, context) {
  1724. if (value == null || options === false) return true;
  1725. if (typeof options !== "string" && !(options instanceof RegExp))
  1726. throw new InvalidArgumentError(
  1727. 'The validator %v requires the "options" argument as a String or RegExp, but %v was given.',
  1728. context.validatorName,
  1729. options
  1730. );
  1731. if (typeof value === "string") {
  1732. const regexp = stringToRegexp(options);
  1733. return regexp.test(value);
  1734. }
  1735. throw new InvalidArgumentError(
  1736. "The property validator %v requires a String value, but %v was given.",
  1737. context.validatorName,
  1738. value
  1739. );
  1740. }
  1741. var init_regexp_validator = __esm({
  1742. "src/definition/model/properties/property-validator/builtin/regexp-validator.js"() {
  1743. "use strict";
  1744. init_utils();
  1745. init_errors();
  1746. __name(regexpValidator, "regexpValidator");
  1747. }
  1748. });
  1749. // src/definition/model/properties/property-validator/builtin/max-length-validator.js
  1750. function maxLengthValidator(value, options, context) {
  1751. if (value == null || options === false) return true;
  1752. if (typeof options !== "number")
  1753. throw new InvalidArgumentError(
  1754. 'The validator %v requires the "options" argument as a Number, but %v was given.',
  1755. context.validatorName,
  1756. options
  1757. );
  1758. if (typeof value === "string" || Array.isArray(value))
  1759. return value.length <= options;
  1760. throw new InvalidArgumentError(
  1761. "The property validator %v requires a String or an Array value, but %v was given.",
  1762. context.validatorName,
  1763. value
  1764. );
  1765. }
  1766. var init_max_length_validator = __esm({
  1767. "src/definition/model/properties/property-validator/builtin/max-length-validator.js"() {
  1768. "use strict";
  1769. init_errors();
  1770. __name(maxLengthValidator, "maxLengthValidator");
  1771. }
  1772. });
  1773. // src/definition/model/properties/property-validator/builtin/min-length-validator.js
  1774. function minLengthValidator(value, options, context) {
  1775. if (value == null || options === false) return true;
  1776. if (typeof options !== "number")
  1777. throw new InvalidArgumentError(
  1778. 'The validator %v requires the "options" argument as a Number, but %v was given.',
  1779. context.validatorName,
  1780. options
  1781. );
  1782. if (typeof value === "string" || Array.isArray(value))
  1783. return value.length >= options;
  1784. throw new InvalidArgumentError(
  1785. "The property validator %v requires a String or an Array value, but %v was given.",
  1786. context.validatorName,
  1787. value
  1788. );
  1789. }
  1790. var init_min_length_validator = __esm({
  1791. "src/definition/model/properties/property-validator/builtin/min-length-validator.js"() {
  1792. "use strict";
  1793. init_errors();
  1794. __name(minLengthValidator, "minLengthValidator");
  1795. }
  1796. });
  1797. // src/definition/model/properties/property-validator/builtin/index.js
  1798. var init_builtin = __esm({
  1799. "src/definition/model/properties/property-validator/builtin/index.js"() {
  1800. "use strict";
  1801. init_regexp_validator();
  1802. init_max_length_validator();
  1803. init_min_length_validator();
  1804. }
  1805. });
  1806. // src/definition/model/properties/property-validator/property-validator-registry.js
  1807. var import_js_service6, _PropertyValidatorRegistry, PropertyValidatorRegistry;
  1808. var init_property_validator_registry = __esm({
  1809. "src/definition/model/properties/property-validator/property-validator-registry.js"() {
  1810. "use strict";
  1811. import_js_service6 = require("@e22m4u/js-service");
  1812. init_builtin();
  1813. init_builtin();
  1814. init_builtin();
  1815. init_errors();
  1816. _PropertyValidatorRegistry = class _PropertyValidatorRegistry extends import_js_service6.Service {
  1817. /**
  1818. * Validators.
  1819. *
  1820. * @type {object}
  1821. */
  1822. _validators = {
  1823. maxLength: maxLengthValidator,
  1824. minLength: minLengthValidator,
  1825. regexp: regexpValidator
  1826. };
  1827. /**
  1828. * Add validator.
  1829. *
  1830. * @param {string} name
  1831. * @param {Function} validator
  1832. * @returns {PropertyValidatorRegistry}
  1833. */
  1834. addValidator(name, validator) {
  1835. if (!name || typeof name !== "string")
  1836. throw new InvalidArgumentError(
  1837. "A name of the property validator must be a non-empty String, but %v was given.",
  1838. name
  1839. );
  1840. if (name in this._validators)
  1841. throw new InvalidArgumentError(
  1842. "The property validator %v is already defined.",
  1843. name
  1844. );
  1845. if (typeof validator !== "function")
  1846. throw new InvalidArgumentError(
  1847. "The property validator %v must be a Function, but %v was given.",
  1848. name,
  1849. validator
  1850. );
  1851. this._validators[name] = validator;
  1852. return this;
  1853. }
  1854. /**
  1855. * Has validator.
  1856. *
  1857. * @param {string} name
  1858. * @returns {boolean}
  1859. */
  1860. hasValidator(name) {
  1861. return Boolean(this._validators[name]);
  1862. }
  1863. /**
  1864. * Get validator.
  1865. *
  1866. * @param {string} name
  1867. * @returns {Function}
  1868. */
  1869. getValidator(name) {
  1870. const validator = this._validators[name];
  1871. if (!validator)
  1872. throw new InvalidArgumentError(
  1873. "The property validator %v is not defined.",
  1874. name
  1875. );
  1876. return validator;
  1877. }
  1878. };
  1879. __name(_PropertyValidatorRegistry, "PropertyValidatorRegistry");
  1880. PropertyValidatorRegistry = _PropertyValidatorRegistry;
  1881. }
  1882. });
  1883. // src/definition/model/properties/property-validator/index.js
  1884. var init_property_validator2 = __esm({
  1885. "src/definition/model/properties/property-validator/index.js"() {
  1886. "use strict";
  1887. init_property_validator();
  1888. init_property_validator_registry();
  1889. }
  1890. });
  1891. // src/definition/model/properties/property-transformer/property-transformer.js
  1892. var init_property_transformer = __esm({
  1893. "src/definition/model/properties/property-transformer/property-transformer.js"() {
  1894. "use strict";
  1895. }
  1896. });
  1897. // src/definition/model/properties/property-transformer/builtin/trim-transformer.js
  1898. function trimTransformer(value, options, context) {
  1899. if (value == null) return value;
  1900. if (typeof value === "string") return value.trim();
  1901. throw new InvalidArgumentError(
  1902. "The property transformer %v requires a String value, but %v was given.",
  1903. context.transformerName,
  1904. value
  1905. );
  1906. }
  1907. var init_trim_transformer = __esm({
  1908. "src/definition/model/properties/property-transformer/builtin/trim-transformer.js"() {
  1909. "use strict";
  1910. init_errors();
  1911. __name(trimTransformer, "trimTransformer");
  1912. }
  1913. });
  1914. // src/definition/model/properties/property-transformer/builtin/to-lower-case-transformer.js
  1915. function toLowerCaseTransformer(value, options, context) {
  1916. if (value == null) return value;
  1917. if (typeof value === "string") return value.toLowerCase();
  1918. throw new InvalidArgumentError(
  1919. "The property transformer %v requires a String value, but %v was given.",
  1920. context.transformerName,
  1921. value
  1922. );
  1923. }
  1924. var init_to_lower_case_transformer = __esm({
  1925. "src/definition/model/properties/property-transformer/builtin/to-lower-case-transformer.js"() {
  1926. "use strict";
  1927. init_errors();
  1928. __name(toLowerCaseTransformer, "toLowerCaseTransformer");
  1929. }
  1930. });
  1931. // src/definition/model/properties/property-transformer/builtin/to-upper-case-transformer.js
  1932. function toUpperCaseTransformer(value, options, context) {
  1933. if (value == null) return value;
  1934. if (typeof value === "string") return value.toUpperCase();
  1935. throw new InvalidArgumentError(
  1936. "The property transformer %v requires a String value, but %v was given.",
  1937. context.transformerName,
  1938. value
  1939. );
  1940. }
  1941. var init_to_upper_case_transformer = __esm({
  1942. "src/definition/model/properties/property-transformer/builtin/to-upper-case-transformer.js"() {
  1943. "use strict";
  1944. init_errors();
  1945. __name(toUpperCaseTransformer, "toUpperCaseTransformer");
  1946. }
  1947. });
  1948. // src/definition/model/properties/property-transformer/builtin/index.js
  1949. var init_builtin2 = __esm({
  1950. "src/definition/model/properties/property-transformer/builtin/index.js"() {
  1951. "use strict";
  1952. init_trim_transformer();
  1953. init_to_lower_case_transformer();
  1954. init_to_upper_case_transformer();
  1955. }
  1956. });
  1957. // src/definition/model/properties/property-transformer/property-transformer-registry.js
  1958. var import_js_service7, _PropertyTransformerRegistry, PropertyTransformerRegistry;
  1959. var init_property_transformer_registry = __esm({
  1960. "src/definition/model/properties/property-transformer/property-transformer-registry.js"() {
  1961. "use strict";
  1962. import_js_service7 = require("@e22m4u/js-service");
  1963. init_builtin2();
  1964. init_builtin2();
  1965. init_builtin2();
  1966. init_errors();
  1967. _PropertyTransformerRegistry = class _PropertyTransformerRegistry extends import_js_service7.Service {
  1968. /**
  1969. * Transformers.
  1970. *
  1971. * @type {object}
  1972. */
  1973. _transformers = {
  1974. trim: trimTransformer,
  1975. toUpperCase: toUpperCaseTransformer,
  1976. toLowerCase: toLowerCaseTransformer
  1977. };
  1978. /**
  1979. * Add transformer.
  1980. *
  1981. * @param {string} name
  1982. * @param {Function} transformer
  1983. * @returns {PropertyTransformerRegistry}
  1984. */
  1985. addTransformer(name, transformer) {
  1986. if (!name || typeof name !== "string")
  1987. throw new InvalidArgumentError(
  1988. "A name of the property transformer must be a non-empty String, but %v was given.",
  1989. name
  1990. );
  1991. if (name in this._transformers)
  1992. throw new InvalidArgumentError(
  1993. "The property transformer %v is already defined.",
  1994. name
  1995. );
  1996. if (typeof transformer !== "function")
  1997. throw new InvalidArgumentError(
  1998. "The property transformer %v must be a Function, but %v was given.",
  1999. name,
  2000. transformer
  2001. );
  2002. this._transformers[name] = transformer;
  2003. return this;
  2004. }
  2005. /**
  2006. * Has transformer.
  2007. *
  2008. * @param {string} name
  2009. * @returns {boolean}
  2010. */
  2011. hasTransformer(name) {
  2012. return Boolean(this._transformers[name]);
  2013. }
  2014. /**
  2015. * Get transformer.
  2016. *
  2017. * @param {string} name
  2018. * @returns {Function}
  2019. */
  2020. getTransformer(name) {
  2021. const transformer = this._transformers[name];
  2022. if (!transformer)
  2023. throw new InvalidArgumentError(
  2024. "The property transformer %v is not defined.",
  2025. name
  2026. );
  2027. return transformer;
  2028. }
  2029. };
  2030. __name(_PropertyTransformerRegistry, "PropertyTransformerRegistry");
  2031. PropertyTransformerRegistry = _PropertyTransformerRegistry;
  2032. }
  2033. });
  2034. // src/definition/model/properties/property-transformer/index.js
  2035. var init_property_transformer2 = __esm({
  2036. "src/definition/model/properties/property-transformer/index.js"() {
  2037. "use strict";
  2038. init_property_transformer();
  2039. init_property_transformer_registry();
  2040. }
  2041. });
  2042. // src/definition/definition-registry.js
  2043. var import_js_service8, _DefinitionRegistry, DefinitionRegistry;
  2044. var init_definition_registry = __esm({
  2045. "src/definition/definition-registry.js"() {
  2046. "use strict";
  2047. import_js_service8 = require("@e22m4u/js-service");
  2048. init_utils();
  2049. init_errors();
  2050. init_model();
  2051. init_definition();
  2052. _DefinitionRegistry = class _DefinitionRegistry extends import_js_service8.Service {
  2053. /**
  2054. * Datasources.
  2055. *
  2056. * @type {object}
  2057. */
  2058. _datasources = {};
  2059. /**
  2060. * Models.
  2061. *
  2062. * @type {object}
  2063. */
  2064. _models = {};
  2065. /**
  2066. * Add datasource.
  2067. *
  2068. * @param {object} datasourceDef
  2069. */
  2070. addDatasource(datasourceDef) {
  2071. this.getService(DatasourceDefinitionValidator).validate(datasourceDef);
  2072. const name = datasourceDef.name;
  2073. if (name in this._datasources)
  2074. throw new InvalidArgumentError(
  2075. "The datasource %v is already defined.",
  2076. name
  2077. );
  2078. this._datasources[name] = datasourceDef;
  2079. }
  2080. /**
  2081. * Has datasource.
  2082. *
  2083. * @param {string} name
  2084. * @returns {boolean}
  2085. */
  2086. hasDatasource(name) {
  2087. return Boolean(this._datasources[name]);
  2088. }
  2089. /**
  2090. * Get datasource.
  2091. *
  2092. * @param {string} name
  2093. * @returns {object}
  2094. */
  2095. getDatasource(name) {
  2096. const datasourceDef = this._datasources[name];
  2097. if (!datasourceDef)
  2098. throw new InvalidArgumentError("The datasource %v is not defined.", name);
  2099. return datasourceDef;
  2100. }
  2101. /**
  2102. * Add model.
  2103. *
  2104. * @param {object} modelDef
  2105. */
  2106. addModel(modelDef) {
  2107. this.getService(ModelDefinitionValidator).validate(modelDef);
  2108. const modelKey = modelNameToModelKey(modelDef.name);
  2109. if (modelKey in this._models)
  2110. throw new InvalidArgumentError(
  2111. "The model %v is already defined.",
  2112. modelDef.name
  2113. );
  2114. this._models[modelKey] = modelDef;
  2115. }
  2116. /**
  2117. * Has model.
  2118. *
  2119. * @param {string} name
  2120. * @returns {boolean}
  2121. */
  2122. hasModel(name) {
  2123. const modelKey = modelNameToModelKey(name);
  2124. return Boolean(this._models[modelKey]);
  2125. }
  2126. /**
  2127. * Get model.
  2128. *
  2129. * @param {string} name
  2130. * @returns {object}
  2131. */
  2132. getModel(name) {
  2133. const modelKey = modelNameToModelKey(name);
  2134. const modelDef = this._models[modelKey];
  2135. if (!modelDef)
  2136. throw new InvalidArgumentError("The model %v is not defined.", name);
  2137. return modelDef;
  2138. }
  2139. };
  2140. __name(_DefinitionRegistry, "DefinitionRegistry");
  2141. DefinitionRegistry = _DefinitionRegistry;
  2142. }
  2143. });
  2144. // src/definition/model/model-definition-utils.js
  2145. var import_js_service9, import_js_empty_values, DEFAULT_PRIMARY_KEY_PROPERTY_NAME, _ModelDefinitionUtils, ModelDefinitionUtils;
  2146. var init_model_definition_utils = __esm({
  2147. "src/definition/model/model-definition-utils.js"() {
  2148. "use strict";
  2149. import_js_service9 = require("@e22m4u/js-service");
  2150. init_properties();
  2151. init_utils();
  2152. init_utils();
  2153. import_js_empty_values = require("@e22m4u/js-empty-values");
  2154. init_errors();
  2155. init_definition_registry();
  2156. DEFAULT_PRIMARY_KEY_PROPERTY_NAME = "id";
  2157. _ModelDefinitionUtils = class _ModelDefinitionUtils extends import_js_service9.Service {
  2158. /**
  2159. * Get primary key as property name.
  2160. *
  2161. * @param {string} modelName
  2162. * @returns {string}
  2163. */
  2164. getPrimaryKeyAsPropertyName(modelName) {
  2165. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2166. const propNames = Object.keys(propDefs).filter((propName) => {
  2167. const propDef = propDefs[propName];
  2168. return propDef && typeof propDef === "object" && propDef.primaryKey;
  2169. });
  2170. if (propNames.length < 1) {
  2171. const isDefaultPrimaryKeyAlreadyInUse = Object.keys(propDefs).includes(
  2172. DEFAULT_PRIMARY_KEY_PROPERTY_NAME
  2173. );
  2174. if (isDefaultPrimaryKeyAlreadyInUse)
  2175. throw new InvalidArgumentError(
  2176. 'The property name %v of the model %v is defined as a regular property. In this case, a primary key should be defined explicitly. Do use the option "primaryKey" to specify the primary key.',
  2177. DEFAULT_PRIMARY_KEY_PROPERTY_NAME,
  2178. modelName
  2179. );
  2180. return DEFAULT_PRIMARY_KEY_PROPERTY_NAME;
  2181. }
  2182. return propNames[0];
  2183. }
  2184. /**
  2185. * Get primary key as column name.
  2186. *
  2187. * @param {string} modelName
  2188. * @returns {string}
  2189. */
  2190. getPrimaryKeyAsColumnName(modelName) {
  2191. const pkPropName = this.getPrimaryKeyAsPropertyName(modelName);
  2192. let pkColName;
  2193. try {
  2194. pkColName = this.getColumnNameByPropertyName(modelName, pkPropName);
  2195. } catch (error) {
  2196. if (!(error instanceof InvalidArgumentError)) throw error;
  2197. }
  2198. if (pkColName === void 0) return pkPropName;
  2199. return pkColName;
  2200. }
  2201. /**
  2202. * Get table name by model name.
  2203. *
  2204. * @param {string} modelName
  2205. * @returns {string}
  2206. */
  2207. getTableNameByModelName(modelName) {
  2208. var _a;
  2209. const modelDef = this.getService(DefinitionRegistry).getModel(modelName);
  2210. return (_a = modelDef.tableName) != null ? _a : modelName;
  2211. }
  2212. /**
  2213. * Get column name by property name.
  2214. *
  2215. * @param {string} modelName
  2216. * @param {string} propertyName
  2217. * @returns {string}
  2218. */
  2219. getColumnNameByPropertyName(modelName, propertyName) {
  2220. var _a;
  2221. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2222. const propDef = propDefs[propertyName];
  2223. if (!propDef)
  2224. throw new InvalidArgumentError(
  2225. "The model %v does not have the property %v.",
  2226. modelName,
  2227. propertyName
  2228. );
  2229. if (propDef && typeof propDef === "object")
  2230. return (_a = propDef.columnName) != null ? _a : propertyName;
  2231. return propertyName;
  2232. }
  2233. /**
  2234. * Get default property value.
  2235. *
  2236. * @param {string} modelName
  2237. * @param {string} propertyName
  2238. * @returns {*}
  2239. */
  2240. getDefaultPropertyValue(modelName, propertyName) {
  2241. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2242. const propDef = propDefs[propertyName];
  2243. if (!propDef)
  2244. throw new InvalidArgumentError(
  2245. "The model %v does not have the property %v.",
  2246. modelName,
  2247. propertyName
  2248. );
  2249. if (propDef && typeof propDef === "object")
  2250. return propDef.default instanceof Function ? propDef.default() : propDef.default;
  2251. }
  2252. /**
  2253. * Set default values for empty properties.
  2254. *
  2255. * @param {string} modelName
  2256. * @param {object} modelData
  2257. * @param {boolean|undefined} onlyProvidedProperties
  2258. * @returns {object}
  2259. */
  2260. setDefaultValuesToEmptyProperties(modelName, modelData, onlyProvidedProperties = false) {
  2261. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2262. const propNames = onlyProvidedProperties ? Object.keys(modelData) : Object.keys(propDefs);
  2263. const extendedData = cloneDeep(modelData);
  2264. const emptyValuesService = this.getService(import_js_empty_values.EmptyValuesService);
  2265. propNames.forEach((propName) => {
  2266. const propDef = propDefs[propName];
  2267. const propValue = extendedData[propName];
  2268. const propType = propDef != null ? this.getDataTypeFromPropertyDefinition(propDef) : DataType.ANY;
  2269. const isEmpty = emptyValuesService.isEmptyByType(propType, propValue);
  2270. if (!isEmpty) return;
  2271. if (propDef && typeof propDef === "object" && propDef.default !== void 0) {
  2272. extendedData[propName] = this.getDefaultPropertyValue(
  2273. modelName,
  2274. propName
  2275. );
  2276. }
  2277. });
  2278. return extendedData;
  2279. }
  2280. /**
  2281. * Convert property names to column names.
  2282. *
  2283. * @param {string} modelName
  2284. * @param {object} modelData
  2285. * @returns {object}
  2286. */
  2287. convertPropertyNamesToColumnNames(modelName, modelData) {
  2288. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2289. const propNames = Object.keys(propDefs);
  2290. const convertedData = cloneDeep(modelData);
  2291. propNames.forEach((propName) => {
  2292. if (!(propName in convertedData)) return;
  2293. const colName = this.getColumnNameByPropertyName(modelName, propName);
  2294. let propValue = convertedData[propName];
  2295. const propDef = propDefs[propName];
  2296. if (propValue !== null && typeof propValue === "object" && !Array.isArray(propValue) && propDef !== null && typeof propDef === "object" && propDef.type === DataType.OBJECT && propDef.model) {
  2297. propValue = this.convertPropertyNamesToColumnNames(
  2298. propDef.model,
  2299. propValue
  2300. );
  2301. }
  2302. if (Array.isArray(propValue) && propDef !== null && typeof propDef === "object" && propDef.type === DataType.ARRAY && propDef.itemModel) {
  2303. propValue = propValue.map((el) => {
  2304. return el !== null && typeof el === "object" && !Array.isArray(el) ? this.convertPropertyNamesToColumnNames(propDef.itemModel, el) : el;
  2305. });
  2306. }
  2307. delete convertedData[propName];
  2308. convertedData[colName] = propValue;
  2309. });
  2310. return convertedData;
  2311. }
  2312. /**
  2313. * Convert column names to property names.
  2314. *
  2315. * @param {string} modelName
  2316. * @param {object} tableData
  2317. * @returns {object}
  2318. */
  2319. convertColumnNamesToPropertyNames(modelName, tableData) {
  2320. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2321. const propNames = Object.keys(propDefs);
  2322. const convertedData = cloneDeep(tableData);
  2323. propNames.forEach((propName) => {
  2324. const colName = this.getColumnNameByPropertyName(modelName, propName);
  2325. if (!(colName in convertedData)) return;
  2326. let colValue = convertedData[colName];
  2327. const propDef = propDefs[propName];
  2328. if (colValue !== null && typeof colValue === "object" && !Array.isArray(colValue) && propDef !== null && typeof propDef === "object" && propDef.type === DataType.OBJECT && propDef.model) {
  2329. colValue = this.convertColumnNamesToPropertyNames(
  2330. propDef.model,
  2331. colValue
  2332. );
  2333. }
  2334. if (Array.isArray(colValue) && propDef !== null && typeof propDef === "object" && propDef.type === DataType.ARRAY && propDef.itemModel) {
  2335. colValue = colValue.map((el) => {
  2336. return el !== null && typeof el === "object" && !Array.isArray(el) ? this.convertColumnNamesToPropertyNames(propDef.itemModel, el) : el;
  2337. });
  2338. }
  2339. delete convertedData[colName];
  2340. convertedData[propName] = colValue;
  2341. });
  2342. return convertedData;
  2343. }
  2344. /**
  2345. * Get data type by property name.
  2346. *
  2347. * @param {string} modelName
  2348. * @param {string} propertyName
  2349. * @returns {string}
  2350. */
  2351. getDataTypeByPropertyName(modelName, propertyName) {
  2352. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2353. const propDef = propDefs[propertyName];
  2354. if (!propDef) {
  2355. const pkPropName = this.getPrimaryKeyAsPropertyName(modelName);
  2356. if (pkPropName === propertyName) return DataType.ANY;
  2357. throw new InvalidArgumentError(
  2358. "The model %v does not have the property %v.",
  2359. modelName,
  2360. propertyName
  2361. );
  2362. }
  2363. if (typeof propDef === "string") return propDef;
  2364. return propDef.type;
  2365. }
  2366. /**
  2367. * Get data type from property definition.
  2368. *
  2369. * @param {object} propDef
  2370. * @returns {string}
  2371. */
  2372. getDataTypeFromPropertyDefinition(propDef) {
  2373. if ((!propDef || typeof propDef !== "object") && !Object.values(DataType).includes(propDef)) {
  2374. throw new InvalidArgumentError(
  2375. 'The argument "propDef" of the ModelDefinitionUtils.getDataTypeFromPropertyDefinition should be an Object or the DataType enum, but %v was given.',
  2376. propDef
  2377. );
  2378. }
  2379. if (typeof propDef === "string") return propDef;
  2380. const dataType = propDef.type;
  2381. if (!Object.values(DataType).includes(dataType))
  2382. throw new InvalidArgumentError(
  2383. 'The given Object to the ModelDefinitionUtils.getDataTypeFromPropertyDefinition should have the "type" property with one of values: %l, but %v was given.',
  2384. Object.values(DataType),
  2385. propDef.type
  2386. );
  2387. return dataType;
  2388. }
  2389. /**
  2390. * Get own properties definition of primary keys.
  2391. *
  2392. * @param {string} modelName
  2393. * @returns {object}
  2394. */
  2395. getOwnPropertiesDefinitionOfPrimaryKeys(modelName) {
  2396. var _a;
  2397. const modelDef = this.getService(DefinitionRegistry).getModel(modelName);
  2398. const propDefs = (_a = modelDef.properties) != null ? _a : {};
  2399. const pkPropNames = Object.keys(propDefs).filter((propName) => {
  2400. const propDef = propDefs[propName];
  2401. return typeof propDef === "object" && propDef.primaryKey;
  2402. });
  2403. return pkPropNames.reduce((a, k) => ({ ...a, [k]: propDefs[k] }), {});
  2404. }
  2405. /**
  2406. * Get own properties definition without primary keys.
  2407. *
  2408. * @param {string} modelName
  2409. * @returns {object}
  2410. */
  2411. getOwnPropertiesDefinitionWithoutPrimaryKeys(modelName) {
  2412. var _a;
  2413. const modelDef = this.getService(DefinitionRegistry).getModel(modelName);
  2414. const propDefs = (_a = modelDef.properties) != null ? _a : {};
  2415. return Object.keys(propDefs).reduce((result, propName) => {
  2416. const propDef = propDefs[propName];
  2417. if (typeof propDef === "object" && propDef.primaryKey) return result;
  2418. return { ...result, [propName]: propDef };
  2419. }, {});
  2420. }
  2421. /**
  2422. * Get properties definition in base model hierarchy.
  2423. *
  2424. * @param {string} modelName
  2425. * @returns {object}
  2426. */
  2427. getPropertiesDefinitionInBaseModelHierarchy(modelName) {
  2428. let pkPropDefs = {};
  2429. let regularPropDefs = {};
  2430. const recursion = /* @__PURE__ */ __name((currModelName, prevModelName = void 0) => {
  2431. if (currModelName === prevModelName)
  2432. throw new InvalidArgumentError(
  2433. "The model %v has a circular inheritance.",
  2434. currModelName
  2435. );
  2436. if (Object.keys(pkPropDefs).length === 0)
  2437. pkPropDefs = this.getOwnPropertiesDefinitionOfPrimaryKeys(currModelName);
  2438. regularPropDefs = {
  2439. ...this.getOwnPropertiesDefinitionWithoutPrimaryKeys(currModelName),
  2440. ...regularPropDefs
  2441. };
  2442. const modelDef = this.getService(DefinitionRegistry).getModel(currModelName);
  2443. if (modelDef.base) recursion(modelDef.base, currModelName);
  2444. }, "recursion");
  2445. recursion(modelName);
  2446. return { ...pkPropDefs, ...regularPropDefs };
  2447. }
  2448. /**
  2449. * Get own relations definition.
  2450. *
  2451. * @param {string} modelName
  2452. * @returns {object}
  2453. */
  2454. getOwnRelationsDefinition(modelName) {
  2455. var _a;
  2456. const modelDef = this.getService(DefinitionRegistry).getModel(modelName);
  2457. return (_a = modelDef.relations) != null ? _a : {};
  2458. }
  2459. /**
  2460. * Get relations definition in base model hierarchy.
  2461. *
  2462. * @param {string} modelName
  2463. * @returns {object}
  2464. */
  2465. getRelationsDefinitionInBaseModelHierarchy(modelName) {
  2466. let result = {};
  2467. const recursion = /* @__PURE__ */ __name((currModelName, prevModelName = void 0) => {
  2468. var _a;
  2469. if (currModelName === prevModelName)
  2470. throw new InvalidArgumentError(
  2471. "The model %v has a circular inheritance.",
  2472. currModelName
  2473. );
  2474. const modelDef = this.getService(DefinitionRegistry).getModel(currModelName);
  2475. const ownRelDefs = (_a = modelDef.relations) != null ? _a : {};
  2476. result = { ...ownRelDefs, ...result };
  2477. if (modelDef.base) recursion(modelDef.base, currModelName);
  2478. }, "recursion");
  2479. recursion(modelName);
  2480. return result;
  2481. }
  2482. /**
  2483. * Get relation definition by name.
  2484. *
  2485. * @param {string} modelName
  2486. * @param {string} relationName
  2487. * @returns {object}
  2488. */
  2489. getRelationDefinitionByName(modelName, relationName) {
  2490. const relDefs = this.getRelationsDefinitionInBaseModelHierarchy(modelName);
  2491. const relNames = Object.keys(relDefs);
  2492. let foundDef;
  2493. for (const relName of relNames) {
  2494. if (relName === relationName) {
  2495. foundDef = relDefs[relName];
  2496. break;
  2497. }
  2498. }
  2499. if (!foundDef)
  2500. throw new InvalidArgumentError(
  2501. "The model %v does not have relation name %v.",
  2502. modelName,
  2503. relationName
  2504. );
  2505. return foundDef;
  2506. }
  2507. /**
  2508. * Exclude object keys by relation names.
  2509. *
  2510. * @param {string} modelName
  2511. * @param {object} modelData
  2512. * @returns {object}
  2513. */
  2514. excludeObjectKeysByRelationNames(modelName, modelData) {
  2515. if (!modelData || typeof modelData !== "object" || Array.isArray(modelData))
  2516. throw new InvalidArgumentError(
  2517. "The second argument of ModelDefinitionUtils.excludeObjectKeysByRelationNames should be an Object, but %v was given.",
  2518. modelData
  2519. );
  2520. const relDefs = this.getRelationsDefinitionInBaseModelHierarchy(modelName);
  2521. const relNames = Object.keys(relDefs);
  2522. return excludeObjectKeys(modelData, relNames);
  2523. }
  2524. /**
  2525. * Get model name of property value if defined.
  2526. *
  2527. * @param {string} modelName
  2528. * @param {string} propertyName
  2529. * @returns {string|undefined}
  2530. */
  2531. getModelNameOfPropertyValueIfDefined(modelName, propertyName) {
  2532. if (!modelName || typeof modelName !== "string")
  2533. throw new InvalidArgumentError(
  2534. 'Parameter "modelName" of ModelDefinitionUtils.getModelNameOfPropertyValueIfDefined requires a non-empty String, but %v was given.',
  2535. modelName
  2536. );
  2537. if (!propertyName || typeof propertyName !== "string")
  2538. throw new InvalidArgumentError(
  2539. 'Parameter "propertyName" of ModelDefinitionUtils.getModelNameOfPropertyValueIfDefined requires a non-empty String, but %v was given.',
  2540. propertyName
  2541. );
  2542. const propDefs = this.getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2543. const propDef = propDefs[propertyName];
  2544. if (!propDef) return void 0;
  2545. if (propDef && typeof propDef === "object") {
  2546. if (propDef.type === DataType.OBJECT) return propDef.model || void 0;
  2547. if (propDef.type === DataType.ARRAY)
  2548. return propDef.itemModel || void 0;
  2549. }
  2550. return void 0;
  2551. }
  2552. };
  2553. __name(_ModelDefinitionUtils, "ModelDefinitionUtils");
  2554. ModelDefinitionUtils = _ModelDefinitionUtils;
  2555. }
  2556. });
  2557. // src/definition/model/properties/property-uniqueness-validator.js
  2558. var import_js_service10, import_js_empty_values2, _PropertyUniquenessValidator, PropertyUniquenessValidator;
  2559. var init_property_uniqueness_validator = __esm({
  2560. "src/definition/model/properties/property-uniqueness-validator.js"() {
  2561. "use strict";
  2562. init_data_type();
  2563. import_js_service10 = require("@e22m4u/js-service");
  2564. init_utils();
  2565. import_js_empty_values2 = require("@e22m4u/js-empty-values");
  2566. init_property_uniqueness();
  2567. init_errors();
  2568. init_model_definition_utils();
  2569. _PropertyUniquenessValidator = class _PropertyUniquenessValidator extends import_js_service10.Service {
  2570. /**
  2571. * Validate.
  2572. *
  2573. * @param {Function} countMethod
  2574. * @param {string} methodName
  2575. * @param {string} modelName
  2576. * @param {object} modelData
  2577. * @param {*} modelId
  2578. * @returns {Promise<undefined>}
  2579. */
  2580. async validate(countMethod, methodName, modelName, modelData, modelId = void 0) {
  2581. if (typeof countMethod !== "function")
  2582. throw new InvalidArgumentError(
  2583. 'The parameter "countMethod" of the PropertyUniquenessValidator must be a Function, but %v was given.',
  2584. countMethod
  2585. );
  2586. if (!methodName || typeof methodName !== "string")
  2587. throw new InvalidArgumentError(
  2588. 'The parameter "methodName" of the PropertyUniquenessValidator must be a non-empty String, but %v was given.',
  2589. methodName
  2590. );
  2591. if (!modelName || typeof modelName !== "string")
  2592. throw new InvalidArgumentError(
  2593. 'The parameter "modelName" of the PropertyUniquenessValidator must be a non-empty String, but %v was given.',
  2594. modelName
  2595. );
  2596. if (!isPureObject(modelData))
  2597. throw new InvalidArgumentError(
  2598. "The data of the model %v should be an Object, but %v was given.",
  2599. modelName,
  2600. modelData
  2601. );
  2602. const propDefs = this.getService(
  2603. ModelDefinitionUtils
  2604. ).getPropertiesDefinitionInBaseModelHierarchy(modelName);
  2605. const isPartial = methodName === "patch" || methodName === "patchById";
  2606. const propNames = Object.keys(isPartial ? modelData : propDefs);
  2607. const idProp = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  2608. modelName
  2609. );
  2610. const createError = /* @__PURE__ */ __name((propName, propValue) => new InvalidArgumentError(
  2611. "An existing document of the model %v already has the property %v with the value %v and should be unique.",
  2612. modelName,
  2613. propName,
  2614. propValue
  2615. ), "createError");
  2616. let willBeReplaced = void 0;
  2617. const emptyValuesService = this.getService(import_js_empty_values2.EmptyValuesService);
  2618. for (const propName of propNames) {
  2619. const propDef = propDefs[propName];
  2620. if (!propDef || typeof propDef === "string" || !propDef.unique || propDef.unique === PropertyUniqueness.NON_UNIQUE) {
  2621. continue;
  2622. }
  2623. const propValue = modelData[propName];
  2624. if (propDef.unique === PropertyUniqueness.SPARSE) {
  2625. const propType = propDef.type || DataType.ANY;
  2626. const isEmpty = emptyValuesService.isEmptyByType(propType, propValue);
  2627. if (isEmpty) continue;
  2628. }
  2629. if (methodName === "create") {
  2630. const count = await countMethod({ [propName]: propValue });
  2631. if (count > 0) throw createError(propName, propValue);
  2632. } else if (methodName === "replaceById") {
  2633. const count = await countMethod({
  2634. [idProp]: { neq: modelId },
  2635. [propName]: propValue
  2636. });
  2637. if (count > 0) throw createError(propName, propValue);
  2638. } else if (methodName === "replaceOrCreate") {
  2639. const idFromData = modelData[idProp];
  2640. if (willBeReplaced == null && idFromData != null) {
  2641. const count = await countMethod({ [idProp]: idFromData });
  2642. willBeReplaced = count > 0;
  2643. }
  2644. if (willBeReplaced) {
  2645. const count = await countMethod({
  2646. [idProp]: { neq: idFromData },
  2647. [propName]: propValue
  2648. });
  2649. if (count > 0) throw createError(propName, propValue);
  2650. } else {
  2651. const count = await countMethod({ [propName]: propValue });
  2652. if (count > 0) throw createError(propName, propValue);
  2653. }
  2654. } else if (methodName === "patch") {
  2655. const count = await countMethod({ [propName]: propValue });
  2656. if (count > 0) throw createError(propName, propValue);
  2657. } else if (methodName === "patchById") {
  2658. const count = await countMethod({
  2659. [idProp]: { neq: modelId },
  2660. [propName]: propValue
  2661. });
  2662. if (count > 0) throw createError(propName, propValue);
  2663. } else {
  2664. throw new InvalidArgumentError(
  2665. "The PropertyUniquenessValidator does not support the adapter method %v.",
  2666. methodName
  2667. );
  2668. }
  2669. }
  2670. }
  2671. };
  2672. __name(_PropertyUniquenessValidator, "PropertyUniquenessValidator");
  2673. PropertyUniquenessValidator = _PropertyUniquenessValidator;
  2674. }
  2675. });
  2676. // src/definition/model/properties/primary-keys-definition-validator.js
  2677. var import_js_service11, _PrimaryKeysDefinitionValidator, PrimaryKeysDefinitionValidator;
  2678. var init_primary_keys_definition_validator = __esm({
  2679. "src/definition/model/properties/primary-keys-definition-validator.js"() {
  2680. "use strict";
  2681. import_js_service11 = require("@e22m4u/js-service");
  2682. init_errors();
  2683. init_model_definition_utils();
  2684. _PrimaryKeysDefinitionValidator = class _PrimaryKeysDefinitionValidator extends import_js_service11.Service {
  2685. /**
  2686. * Validate.
  2687. *
  2688. * @param {string} modelName
  2689. * @param {object} propDefs
  2690. */
  2691. validate(modelName, propDefs) {
  2692. const propNames = Object.keys(propDefs).filter((propName) => {
  2693. const propDef = propDefs[propName];
  2694. return propDef && typeof propDef === "object" && propDef.primaryKey;
  2695. });
  2696. if (propNames.length < 1) {
  2697. const isDefaultPrimaryKeyAlreadyInUse = Object.keys(propDefs).includes(DEFAULT_PRIMARY_KEY_PROPERTY_NAME);
  2698. if (isDefaultPrimaryKeyAlreadyInUse)
  2699. throw new InvalidArgumentError(
  2700. 'The property name %v of the model %v is defined as a regular property. In this case, a primary key should be defined explicitly. Do use the option "primaryKey" to specify the primary key.',
  2701. DEFAULT_PRIMARY_KEY_PROPERTY_NAME,
  2702. modelName
  2703. );
  2704. return;
  2705. }
  2706. if (propNames.length > 1)
  2707. throw new InvalidArgumentError(
  2708. "The model definition %v should not have multiple primary keys, but %v keys given.",
  2709. modelName,
  2710. propNames.length
  2711. );
  2712. const pkPropName = propNames[0];
  2713. const pkPropDef = propDefs[pkPropName];
  2714. if (pkPropDef && typeof pkPropDef === "object" && pkPropDef.default !== void 0) {
  2715. throw new InvalidArgumentError(
  2716. "Do not specify a default value for the primary key %v of the model %v.",
  2717. pkPropName,
  2718. modelName
  2719. );
  2720. }
  2721. }
  2722. };
  2723. __name(_PrimaryKeysDefinitionValidator, "PrimaryKeysDefinitionValidator");
  2724. PrimaryKeysDefinitionValidator = _PrimaryKeysDefinitionValidator;
  2725. }
  2726. });
  2727. // src/definition/model/properties/properties-definition-validator.js
  2728. var import_js_service12, _PropertiesDefinitionValidator, PropertiesDefinitionValidator;
  2729. var init_properties_definition_validator = __esm({
  2730. "src/definition/model/properties/properties-definition-validator.js"() {
  2731. "use strict";
  2732. import_js_service12 = require("@e22m4u/js-service");
  2733. init_data_type();
  2734. init_utils();
  2735. init_property_uniqueness();
  2736. init_errors();
  2737. init_property_validator2();
  2738. init_property_transformer2();
  2739. init_primary_keys_definition_validator();
  2740. _PropertiesDefinitionValidator = class _PropertiesDefinitionValidator extends import_js_service12.Service {
  2741. /**
  2742. * Validate.
  2743. *
  2744. * @param {string} modelName
  2745. * @param {object} propDefs
  2746. */
  2747. validate(modelName, propDefs) {
  2748. if (!modelName || typeof modelName !== "string")
  2749. throw new InvalidArgumentError(
  2750. "The first argument of PropertiesDefinitionValidator.validate should be a non-empty String, but %v was given.",
  2751. modelName
  2752. );
  2753. if (!propDefs || typeof propDefs !== "object" || Array.isArray(propDefs)) {
  2754. throw new InvalidArgumentError(
  2755. 'The provided option "properties" of the model %v should be an Object, but %v was given.',
  2756. modelName,
  2757. propDefs
  2758. );
  2759. }
  2760. const propNames = Object.keys(propDefs);
  2761. propNames.forEach((propName) => {
  2762. const propDef = propDefs[propName];
  2763. this._validateProperty(modelName, propName, propDef);
  2764. });
  2765. this.getService(PrimaryKeysDefinitionValidator).validate(
  2766. modelName,
  2767. propDefs
  2768. );
  2769. }
  2770. /**
  2771. * Validate property.
  2772. *
  2773. * @param {string} modelName
  2774. * @param {string} propName
  2775. * @param {object} propDef
  2776. */
  2777. _validateProperty(modelName, propName, propDef) {
  2778. if (!modelName || typeof modelName !== "string")
  2779. throw new InvalidArgumentError(
  2780. "The first argument of PropertiesDefinitionValidator._validateProperty should be a non-empty String, but %v was given.",
  2781. modelName
  2782. );
  2783. if (!propName || typeof propName !== "string")
  2784. throw new InvalidArgumentError(
  2785. "The property name of the model %v should be a non-empty String, but %v was given.",
  2786. modelName,
  2787. propName
  2788. );
  2789. if (!propDef)
  2790. throw new InvalidArgumentError(
  2791. "The property %v of the model %v should have a property definition, but %v was given.",
  2792. propName,
  2793. modelName,
  2794. propDef
  2795. );
  2796. if (typeof propDef === "string") {
  2797. if (!Object.values(DataType).includes(propDef))
  2798. throw new InvalidArgumentError(
  2799. "In case of a short property definition, the property %v of the model %v should have one of data types: %l, but %v was given.",
  2800. propName,
  2801. modelName,
  2802. Object.values(DataType),
  2803. propDef
  2804. );
  2805. return;
  2806. }
  2807. if (!propDef || typeof propDef !== "object" || Array.isArray(propDef)) {
  2808. throw new InvalidArgumentError(
  2809. "In case of a full property definition, the property %v of the model %v should be an Object, but %v was given.",
  2810. propName,
  2811. modelName,
  2812. propDef
  2813. );
  2814. }
  2815. if (!propDef.type || !Object.values(DataType).includes(propDef.type))
  2816. throw new InvalidArgumentError(
  2817. 'The property %v of the model %v requires the option "type" to have one of data types: %l, but %v was given.',
  2818. propName,
  2819. modelName,
  2820. Object.values(DataType),
  2821. propDef.type
  2822. );
  2823. if (propDef.itemType && !Object.values(DataType).includes(propDef.itemType)) {
  2824. throw new InvalidArgumentError(
  2825. 'The provided option "itemType" of the property %v in the model %v should have one of data types: %l, but %v was given.',
  2826. propName,
  2827. modelName,
  2828. Object.values(DataType),
  2829. propDef.itemType
  2830. );
  2831. }
  2832. if (propDef.itemModel && typeof propDef.itemModel !== "string") {
  2833. throw new InvalidArgumentError(
  2834. 'The provided option "itemModel" of the property %v in the model %v should be a String, but %v was given.',
  2835. propName,
  2836. modelName,
  2837. propDef.itemModel
  2838. );
  2839. }
  2840. if (propDef.model && typeof propDef.model !== "string")
  2841. throw new InvalidArgumentError(
  2842. 'The provided option "model" of the property %v in the model %v should be a String, but %v was given.',
  2843. propName,
  2844. modelName,
  2845. propDef.model
  2846. );
  2847. if (propDef.primaryKey && typeof propDef.primaryKey !== "boolean")
  2848. throw new InvalidArgumentError(
  2849. 'The provided option "primaryKey" of the property %v in the model %v should be a Boolean, but %v was given.',
  2850. propName,
  2851. modelName,
  2852. propDef.primaryKey
  2853. );
  2854. if (propDef.columnName && typeof propDef.columnName !== "string")
  2855. throw new InvalidArgumentError(
  2856. 'The provided option "columnName" of the property %v in the model %v should be a String, but %v was given.',
  2857. propName,
  2858. modelName,
  2859. propDef.columnName
  2860. );
  2861. if (propDef.columnType && typeof propDef.columnType !== "string")
  2862. throw new InvalidArgumentError(
  2863. 'The provided option "columnType" of the property %v in the model %v should be a String, but %v was given.',
  2864. propName,
  2865. modelName,
  2866. propDef.columnType
  2867. );
  2868. if (propDef.required && typeof propDef.required !== "boolean")
  2869. throw new InvalidArgumentError(
  2870. 'The provided option "required" of the property %v in the model %v should be a Boolean, but %v was given.',
  2871. propName,
  2872. modelName,
  2873. propDef.required
  2874. );
  2875. if (propDef.required && propDef.default !== void 0)
  2876. throw new InvalidArgumentError(
  2877. 'The property %v of the model %v is a required property, so it should not have the option "default" to be provided.',
  2878. propName,
  2879. modelName
  2880. );
  2881. if (propDef.primaryKey && propDef.required)
  2882. throw new InvalidArgumentError(
  2883. 'The property %v of the model %v is a primary key, so it should not have the option "required" to be provided.',
  2884. propName,
  2885. modelName
  2886. );
  2887. if (propDef.primaryKey && propDef.default !== void 0)
  2888. throw new InvalidArgumentError(
  2889. 'The property %v of the model %v is a primary key, so it should not have the option "default" to be provided.',
  2890. propName,
  2891. modelName
  2892. );
  2893. if (propDef.itemType && propDef.type !== DataType.ARRAY)
  2894. throw new InvalidArgumentError(
  2895. 'The property %v of the model %v has a non-array type, so it should not have the option "itemType" to be provided.',
  2896. propName,
  2897. modelName,
  2898. propDef.type
  2899. );
  2900. if (propDef.itemModel && propDef.type !== DataType.ARRAY)
  2901. throw new InvalidArgumentError(
  2902. 'The option "itemModel" is not supported for %s property type, so the property %v of the model %v should not have the option "itemModel" to be provided.',
  2903. capitalize(propDef.type),
  2904. propName,
  2905. modelName
  2906. );
  2907. if (propDef.itemModel && propDef.itemType !== DataType.OBJECT) {
  2908. if (propDef.itemType) {
  2909. throw new InvalidArgumentError(
  2910. 'The provided option "itemModel" requires the option "itemType" to be explicitly set to Object, but the property %v of the model %v has specified item type as %s.',
  2911. propName,
  2912. modelName,
  2913. capitalize(propDef.itemType)
  2914. );
  2915. } else {
  2916. throw new InvalidArgumentError(
  2917. 'The provided option "itemModel" requires the option "itemType" to be explicitly set to Object, but the property %v of the model %v does not have specified item type.',
  2918. propName,
  2919. modelName
  2920. );
  2921. }
  2922. }
  2923. if (propDef.model && propDef.type !== DataType.OBJECT)
  2924. throw new InvalidArgumentError(
  2925. 'The option "model" is not supported for %s property type, so the property %v of the model %v should not have the option "model" to be provided.',
  2926. capitalize(propDef.type),
  2927. propName,
  2928. modelName
  2929. );
  2930. if (propDef.validate != null) {
  2931. const propertyValidatorRegistry = this.getService(
  2932. PropertyValidatorRegistry
  2933. );
  2934. if (propDef.validate && typeof propDef.validate === "string") {
  2935. if (!propertyValidatorRegistry.hasValidator(propDef.validate))
  2936. throw new InvalidArgumentError(
  2937. "The property validator %v is not found.",
  2938. propDef.validate
  2939. );
  2940. } else if (propDef.validate && typeof propDef.validate === "function") {
  2941. } else if (Array.isArray(propDef.validate)) {
  2942. for (const validatorOrName of propDef.validate) {
  2943. if (validatorOrName && typeof validatorOrName === "string") {
  2944. if (!propertyValidatorRegistry.hasValidator(validatorOrName))
  2945. throw new InvalidArgumentError(
  2946. "The property validator %v is not found.",
  2947. validatorOrName
  2948. );
  2949. } else if (validatorOrName && typeof validatorOrName === "function") {
  2950. } else {
  2951. throw new InvalidArgumentError(
  2952. 'The provided option "validate" for the property %v in the model %v has an Array value that should contain validator names or validator functions, but %v was given.',
  2953. propName,
  2954. modelName,
  2955. validatorOrName
  2956. );
  2957. }
  2958. }
  2959. } else if (typeof propDef.validate === "object") {
  2960. Object.keys(propDef.validate).forEach((validatorName) => {
  2961. if (!propertyValidatorRegistry.hasValidator(validatorName))
  2962. throw new InvalidArgumentError(
  2963. "The property validator %v is not found.",
  2964. validatorName
  2965. );
  2966. });
  2967. } else {
  2968. throw new InvalidArgumentError(
  2969. 'The provided option "validate" for the property %v in the model %v should be either a validator name, a validator function, an array of validator names or functions, or an object mapping validator names to their arguments, but %v was given.',
  2970. propName,
  2971. modelName,
  2972. propDef.validate
  2973. );
  2974. }
  2975. }
  2976. if (propDef.transform != null) {
  2977. const propertyTransformerRegistry = this.getService(
  2978. PropertyTransformerRegistry
  2979. );
  2980. if (propDef.transform && typeof propDef.transform === "string") {
  2981. if (!propertyTransformerRegistry.hasTransformer(propDef.transform))
  2982. throw new InvalidArgumentError(
  2983. "The property transformer %v is not found.",
  2984. propDef.transform
  2985. );
  2986. } else if (propDef.transform && typeof propDef.transform === "function") {
  2987. } else if (Array.isArray(propDef.transform)) {
  2988. for (const transformerOrName of propDef.transform) {
  2989. if (transformerOrName && typeof transformerOrName === "string") {
  2990. if (!propertyTransformerRegistry.hasTransformer(transformerOrName))
  2991. throw new InvalidArgumentError(
  2992. "The property transformer %v is not found.",
  2993. transformerOrName
  2994. );
  2995. } else if (transformerOrName && typeof transformerOrName === "function") {
  2996. } else {
  2997. throw new InvalidArgumentError(
  2998. 'The provided option "transform" for the property %v in the model %v has an Array value that should contain transformer names or transformer functions, but %v was given.',
  2999. propName,
  3000. modelName,
  3001. transformerOrName
  3002. );
  3003. }
  3004. }
  3005. } else if (typeof propDef.transform === "object") {
  3006. Object.keys(propDef.transform).forEach((transformerName) => {
  3007. if (!propertyTransformerRegistry.hasTransformer(transformerName))
  3008. throw new InvalidArgumentError(
  3009. "The property transformer %v is not found.",
  3010. transformerName
  3011. );
  3012. });
  3013. } else {
  3014. throw new InvalidArgumentError(
  3015. 'The provided option "transform" for the property %v in the model %v should be either a transformer name, a transformer function, an array of transformer names or functions, or an object mapping transformer names to their arguments, but %v was given.',
  3016. propName,
  3017. modelName,
  3018. propDef.transform
  3019. );
  3020. }
  3021. }
  3022. if (propDef.unique) {
  3023. if (typeof propDef.unique !== "boolean" && !Object.values(PropertyUniqueness).includes(propDef.unique)) {
  3024. throw new InvalidArgumentError(
  3025. 'The provided option "unique" of the property %v in the model %v should be a Boolean or one of values: %l, but %v was given.',
  3026. propName,
  3027. modelName,
  3028. Object.values(PropertyUniqueness),
  3029. propDef.unique
  3030. );
  3031. }
  3032. }
  3033. if (propDef.unique && propDef.primaryKey)
  3034. throw new InvalidArgumentError(
  3035. 'The property %v of the model %v is a primary key, so it should not have the option "unique" to be provided.',
  3036. propName,
  3037. modelName
  3038. );
  3039. }
  3040. };
  3041. __name(_PropertiesDefinitionValidator, "PropertiesDefinitionValidator");
  3042. PropertiesDefinitionValidator = _PropertiesDefinitionValidator;
  3043. }
  3044. });
  3045. // src/definition/model/properties/index.js
  3046. var init_properties = __esm({
  3047. "src/definition/model/properties/index.js"() {
  3048. "use strict";
  3049. init_data_type();
  3050. init_property_definition();
  3051. init_property_uniqueness();
  3052. init_property_validator2();
  3053. init_property_transformer2();
  3054. init_property_uniqueness_validator();
  3055. init_properties_definition_validator();
  3056. init_primary_keys_definition_validator();
  3057. }
  3058. });
  3059. // src/definition/model/model-definition.js
  3060. var init_model_definition = __esm({
  3061. "src/definition/model/model-definition.js"() {
  3062. "use strict";
  3063. }
  3064. });
  3065. // src/definition/model/model-data-validator.js
  3066. var import_js_service13, import_js_empty_values3, _ModelDataValidator, ModelDataValidator;
  3067. var init_model_data_validator = __esm({
  3068. "src/definition/model/model-data-validator.js"() {
  3069. "use strict";
  3070. import_js_service13 = require("@e22m4u/js-service");
  3071. init_properties();
  3072. init_utils();
  3073. init_utils();
  3074. import_js_empty_values3 = require("@e22m4u/js-empty-values");
  3075. init_errors();
  3076. init_properties();
  3077. init_model_definition_utils();
  3078. _ModelDataValidator = class _ModelDataValidator extends import_js_service13.Service {
  3079. /**
  3080. * Validate.
  3081. *
  3082. * @param {string} modelName
  3083. * @param {object} modelData
  3084. * @param {boolean} isPartial
  3085. * @returns {undefined}
  3086. */
  3087. validate(modelName, modelData, isPartial = false) {
  3088. if (!isPureObject(modelData))
  3089. throw new InvalidArgumentError(
  3090. "The data of the model %v should be an Object, but %v was given.",
  3091. modelName,
  3092. modelData
  3093. );
  3094. const propDefs = this.getService(
  3095. ModelDefinitionUtils
  3096. ).getPropertiesDefinitionInBaseModelHierarchy(modelName);
  3097. const propNames = Object.keys(isPartial ? modelData : propDefs);
  3098. propNames.forEach((propName) => {
  3099. const propDef = propDefs[propName];
  3100. if (!propDef) return;
  3101. this._validatePropertyValue(
  3102. modelName,
  3103. propName,
  3104. propDef,
  3105. modelData[propName]
  3106. );
  3107. });
  3108. }
  3109. /**
  3110. * Validate property value.
  3111. *
  3112. * @param {string} modelName
  3113. * @param {string} propName
  3114. * @param {string|object} propDef
  3115. * @param {*} propValue
  3116. * @returns {undefined}
  3117. */
  3118. _validatePropertyValue(modelName, propName, propDef, propValue) {
  3119. const propType = this.getService(ModelDefinitionUtils).getDataTypeFromPropertyDefinition(
  3120. propDef
  3121. );
  3122. const isEmpty = this.getService(import_js_empty_values3.EmptyValuesService).isEmptyByType(
  3123. propType,
  3124. propValue
  3125. );
  3126. if (isEmpty) {
  3127. const isRequired = typeof propDef === "string" ? false : Boolean(propDef.required);
  3128. if (!isRequired) return;
  3129. throw new InvalidArgumentError(
  3130. "The property %v of the model %v is required, but %v was given.",
  3131. propName,
  3132. modelName,
  3133. propValue
  3134. );
  3135. }
  3136. this._validateValueByPropertyType(modelName, propName, propDef, propValue);
  3137. this._validateValueByPropertyValidators(
  3138. modelName,
  3139. propName,
  3140. propDef,
  3141. propValue
  3142. );
  3143. }
  3144. /**
  3145. * Validate value by property type.
  3146. *
  3147. * @param {string} modelName
  3148. * @param {string} propName
  3149. * @param {string|object} propDef
  3150. * @param {*} propValue
  3151. * @param {boolean} isArrayValue
  3152. * @returns {undefined}
  3153. */
  3154. _validateValueByPropertyType(modelName, propName, propDef, propValue, isArrayValue = false) {
  3155. var _a;
  3156. let expectingType;
  3157. if (isArrayValue) {
  3158. if (typeof propDef === "object") {
  3159. expectingType = (_a = propDef.itemType) != null ? _a : DataType.ANY;
  3160. } else {
  3161. expectingType = DataType.ANY;
  3162. }
  3163. } else {
  3164. expectingType = typeof propDef !== "string" ? propDef.type : propDef;
  3165. }
  3166. const createError = /* @__PURE__ */ __name((expected) => {
  3167. const pattern = isArrayValue ? "The array property %v of the model %v must have %s element, but %s was given." : "The property %v of the model %v must have %s, but %s was given.";
  3168. const ctorName = getCtorName(propValue);
  3169. const givenStr = ctorName != null ? ctorName : typeof propValue;
  3170. return new InvalidArgumentError(
  3171. pattern,
  3172. propName,
  3173. modelName,
  3174. expected,
  3175. givenStr
  3176. );
  3177. }, "createError");
  3178. switch (expectingType) {
  3179. // STRING
  3180. case DataType.STRING:
  3181. if (typeof propValue !== "string") throw createError("a String");
  3182. break;
  3183. // NUMBER
  3184. case DataType.NUMBER:
  3185. if (typeof propValue !== "number") throw createError("a Number");
  3186. break;
  3187. // BOOLEAN
  3188. case DataType.BOOLEAN:
  3189. if (typeof propValue !== "boolean") throw createError("a Boolean");
  3190. break;
  3191. // ARRAY
  3192. case DataType.ARRAY:
  3193. if (!Array.isArray(propValue)) throw createError("an Array");
  3194. propValue.forEach(
  3195. (value) => this._validateValueByPropertyType(
  3196. modelName,
  3197. propName,
  3198. propDef,
  3199. value,
  3200. true
  3201. )
  3202. );
  3203. break;
  3204. // OBJECT
  3205. case DataType.OBJECT: {
  3206. if (!isPureObject(propValue)) throw createError("an Object");
  3207. if (typeof propDef === "object") {
  3208. const modelOptionField = isArrayValue ? "itemModel" : "model";
  3209. const modelOptionValue = propDef[modelOptionField];
  3210. if (modelOptionValue) this.validate(modelOptionValue, propValue);
  3211. }
  3212. break;
  3213. }
  3214. }
  3215. }
  3216. /**
  3217. * Validate value by property validators.
  3218. *
  3219. * @param {string} modelName
  3220. * @param {string} propName
  3221. * @param {string|object} propDef
  3222. * @param {*} propValue
  3223. * @returns {undefined}
  3224. */
  3225. _validateValueByPropertyValidators(modelName, propName, propDef, propValue) {
  3226. if (typeof propDef === "string" || propDef.validate == null) return;
  3227. const validateDef = propDef.validate;
  3228. const validatorRegistry = this.getService(PropertyValidatorRegistry);
  3229. const createError = /* @__PURE__ */ __name((validatorName) => {
  3230. if (validatorName) {
  3231. return new InvalidArgumentError(
  3232. "The property %v of the model %v has the invalid value %v that caught by the property validator %v.",
  3233. propName,
  3234. modelName,
  3235. propValue,
  3236. validatorName
  3237. );
  3238. } else {
  3239. return new InvalidArgumentError(
  3240. "The property %v of the model %v has the invalid value %v that caught by a property validator.",
  3241. propName,
  3242. modelName,
  3243. propValue
  3244. );
  3245. }
  3246. }, "createError");
  3247. const validateBy = /* @__PURE__ */ __name((validatorOrName, validatorOptions = void 0) => {
  3248. let validatorName, validatorFn;
  3249. if (typeof validatorOrName === "string") {
  3250. validatorName = validatorOrName;
  3251. validatorFn = validatorRegistry.getValidator(validatorName);
  3252. } else if (typeof validatorOrName === "function") {
  3253. validatorName = validatorOrName.name && validatorOrName.name !== "validate" ? validatorOrName.name : void 0;
  3254. validatorFn = validatorOrName;
  3255. } else {
  3256. throw new InvalidArgumentError(
  3257. "Validator must be a non-empty String or a Function, but %v was given.",
  3258. validatorOrName
  3259. );
  3260. }
  3261. const context = { validatorName, modelName, propName };
  3262. const valid = validatorFn(propValue, validatorOptions, context);
  3263. if (valid instanceof Promise) {
  3264. if (validatorName) {
  3265. throw new InvalidArgumentError(
  3266. "Asynchronous property validators are not supported, but the property %v of the model %v has the property validator %v that returns a Promise.",
  3267. propName,
  3268. modelName,
  3269. validatorName
  3270. );
  3271. } else {
  3272. throw new InvalidArgumentError(
  3273. "Asynchronous property validators are not supported, but the property %v of the model %v has a property validator that returns a Promise.",
  3274. propName,
  3275. modelName
  3276. );
  3277. }
  3278. } else if (valid !== true) {
  3279. throw createError(validatorName);
  3280. }
  3281. }, "validateBy");
  3282. if (validateDef && typeof validateDef === "string") {
  3283. validateBy(validateDef);
  3284. } else if (validateDef && typeof validateDef === "function") {
  3285. validateBy(validateDef);
  3286. } else if (Array.isArray(validateDef)) {
  3287. validateDef.forEach((validatorOrName) => {
  3288. if (!validatorOrName || typeof validatorOrName !== "string" && typeof validatorOrName !== "function") {
  3289. throw new InvalidArgumentError(
  3290. 'The provided option "validate" for the property %v in the model %v has an Array value that should contain validator names or validator functions, but %v was given.',
  3291. propName,
  3292. modelName,
  3293. validatorOrName
  3294. );
  3295. }
  3296. validateBy(validatorOrName);
  3297. });
  3298. } else if (validateDef !== null && typeof validateDef === "object") {
  3299. Object.keys(validateDef).forEach((validatorName) => {
  3300. const validatorOptions = validateDef[validatorName];
  3301. validateBy(validatorName, validatorOptions);
  3302. });
  3303. } else {
  3304. throw new InvalidArgumentError(
  3305. 'The provided option "validate" for the property %v in the model %v should be either a validator name, a validator function, an array of validator names or functions, or an object mapping validator names to their arguments, but %v was given.',
  3306. propName,
  3307. modelName,
  3308. validateDef
  3309. );
  3310. }
  3311. }
  3312. };
  3313. __name(_ModelDataValidator, "ModelDataValidator");
  3314. ModelDataValidator = _ModelDataValidator;
  3315. }
  3316. });
  3317. // src/definition/model/model-data-sanitizer.js
  3318. var import_js_service14, _ModelDataSanitizer, ModelDataSanitizer;
  3319. var init_model_data_sanitizer = __esm({
  3320. "src/definition/model/model-data-sanitizer.js"() {
  3321. "use strict";
  3322. import_js_service14 = require("@e22m4u/js-service");
  3323. init_errors();
  3324. init_model_definition_utils();
  3325. _ModelDataSanitizer = class _ModelDataSanitizer extends import_js_service14.Service {
  3326. /**
  3327. * Validate.
  3328. *
  3329. * @param {string} modelName
  3330. * @param {object} modelData
  3331. * @returns {object}
  3332. */
  3333. sanitize(modelName, modelData) {
  3334. if (!modelName || typeof modelName !== "string")
  3335. throw new InvalidArgumentError(
  3336. "The first argument of ModelDataSanitizer.sanitize should be a string, but %v was given.",
  3337. modelName
  3338. );
  3339. if (!modelData || typeof modelData !== "object")
  3340. throw new InvalidArgumentError(
  3341. "The second argument of ModelDataSanitizer.sanitize should be an Object, but %v was given.",
  3342. modelData
  3343. );
  3344. return this.getService(
  3345. ModelDefinitionUtils
  3346. ).excludeObjectKeysByRelationNames(modelName, modelData);
  3347. }
  3348. };
  3349. __name(_ModelDataSanitizer, "ModelDataSanitizer");
  3350. ModelDataSanitizer = _ModelDataSanitizer;
  3351. }
  3352. });
  3353. // src/definition/model/model-data-transformer.js
  3354. var import_js_service15, import_js_empty_values4, _ModelDataTransformer, ModelDataTransformer;
  3355. var init_model_data_transformer = __esm({
  3356. "src/definition/model/model-data-transformer.js"() {
  3357. "use strict";
  3358. import_js_service15 = require("@e22m4u/js-service");
  3359. init_utils();
  3360. init_utils();
  3361. init_utils();
  3362. import_js_empty_values4 = require("@e22m4u/js-empty-values");
  3363. init_errors();
  3364. init_model_definition_utils();
  3365. init_properties();
  3366. _ModelDataTransformer = class _ModelDataTransformer extends import_js_service15.Service {
  3367. /**
  3368. * Transform.
  3369. *
  3370. * @param {string} modelName
  3371. * @param {object} modelData
  3372. * @param {boolean} isPartial
  3373. * @returns {object|Promise<object>}
  3374. */
  3375. transform(modelName, modelData, isPartial = false) {
  3376. if (!isPureObject(modelData))
  3377. throw new InvalidArgumentError(
  3378. "The data of the model %v should be an Object, but %v was given.",
  3379. modelName,
  3380. modelData
  3381. );
  3382. const emptyValuesService = this.getService(import_js_empty_values4.EmptyValuesService);
  3383. const modelDefinitionUtils = this.getService(ModelDefinitionUtils);
  3384. const propDefs = modelDefinitionUtils.getPropertiesDefinitionInBaseModelHierarchy(
  3385. modelName
  3386. );
  3387. const propNames = Object.keys(isPartial ? modelData : propDefs);
  3388. const transformedData = cloneDeep(modelData);
  3389. return propNames.reduce((transformedDataOrPromise, propName) => {
  3390. const propDef = propDefs[propName];
  3391. if (!propDef) return transformedDataOrPromise;
  3392. const propType = modelDefinitionUtils.getDataTypeFromPropertyDefinition(propDef);
  3393. const propValue = modelData[propName];
  3394. const isEmpty = emptyValuesService.isEmptyByType(propType, propValue);
  3395. if (isEmpty) return transformedDataOrPromise;
  3396. const newPropValueOrPromise = this._transformPropertyValue(
  3397. modelName,
  3398. propName,
  3399. propDef,
  3400. propValue
  3401. );
  3402. return transformPromise(newPropValueOrPromise, (newPropValue) => {
  3403. return transformPromise(transformedDataOrPromise, (resolvedData) => {
  3404. if (newPropValue !== propValue) resolvedData[propName] = newPropValue;
  3405. return resolvedData;
  3406. });
  3407. });
  3408. }, transformedData);
  3409. }
  3410. /**
  3411. * Transform property value.
  3412. *
  3413. * @param {string} modelName
  3414. * @param {string} propName
  3415. * @param {string|object} propDef
  3416. * @param {*} propValue
  3417. * @returns {*|Promise<*>}
  3418. */
  3419. _transformPropertyValue(modelName, propName, propDef, propValue) {
  3420. if (typeof propDef === "string" || propDef.transform == null)
  3421. return propValue;
  3422. const transformDef = propDef.transform;
  3423. const transformerRegistry = this.getService(PropertyTransformerRegistry);
  3424. const transformFn = /* @__PURE__ */ __name((value, transformerOrName, transformerOptions = void 0) => {
  3425. let transformerName, transformerFn;
  3426. if (typeof transformerOrName === "string") {
  3427. transformerName = transformerOrName;
  3428. transformerFn = transformerRegistry.getTransformer(transformerName);
  3429. } else if (typeof transformerOrName === "function") {
  3430. transformerName = transformerOrName.name && transformerOrName.name !== "transform" ? transformerOrName.name : void 0;
  3431. transformerFn = transformerOrName;
  3432. } else {
  3433. throw new InvalidArgumentError(
  3434. "Transformer must be a non-empty String or a Function, but %v was given.",
  3435. transformerOrName
  3436. );
  3437. }
  3438. const context = { transformerName, modelName, propName };
  3439. return transformerFn(value, transformerOptions, context);
  3440. }, "transformFn");
  3441. if (transformDef && typeof transformDef === "string") {
  3442. return transformFn(propValue, transformDef);
  3443. } else if (transformDef && typeof transformDef === "function") {
  3444. return transformFn(propValue, transformDef);
  3445. } else if (Array.isArray(transformDef)) {
  3446. return transformDef.reduce((valueOrPromise, transformerOrName) => {
  3447. if (!transformerOrName || typeof transformerOrName !== "string" && typeof transformerOrName !== "function") {
  3448. throw new InvalidArgumentError(
  3449. 'The provided option "transform" for the property %v in the model %v has an Array value that should contain transformer names or transformer functions, but %v was given.',
  3450. propName,
  3451. modelName,
  3452. transformerOrName
  3453. );
  3454. }
  3455. return transformPromise(valueOrPromise, (value) => {
  3456. return transformFn(value, transformerOrName);
  3457. });
  3458. }, propValue);
  3459. } else if (transformDef !== null && typeof transformDef === "object") {
  3460. return Object.keys(transformDef).reduce(
  3461. (valueOrPromise, transformerName) => {
  3462. const transformerOptions = transformDef[transformerName];
  3463. return transformPromise(valueOrPromise, (value) => {
  3464. return transformFn(value, transformerName, transformerOptions);
  3465. });
  3466. },
  3467. propValue
  3468. );
  3469. } else {
  3470. throw new InvalidArgumentError(
  3471. 'The provided option "transform" for the property %v in the model %v should be either a transformer name, a transformer function, an array of transformer names or functions, or an object mapping transformer names to their arguments, but %v was given.',
  3472. propName,
  3473. modelName,
  3474. transformDef
  3475. );
  3476. }
  3477. }
  3478. };
  3479. __name(_ModelDataTransformer, "ModelDataTransformer");
  3480. ModelDataTransformer = _ModelDataTransformer;
  3481. }
  3482. });
  3483. // src/definition/model/model-definition-validator.js
  3484. var import_js_service16, _ModelDefinitionValidator, ModelDefinitionValidator;
  3485. var init_model_definition_validator = __esm({
  3486. "src/definition/model/model-definition-validator.js"() {
  3487. "use strict";
  3488. import_js_service16 = require("@e22m4u/js-service");
  3489. init_errors();
  3490. init_relations();
  3491. init_properties();
  3492. _ModelDefinitionValidator = class _ModelDefinitionValidator extends import_js_service16.Service {
  3493. /**
  3494. * Validate.
  3495. *
  3496. * @param {object} modelDef
  3497. */
  3498. validate(modelDef) {
  3499. if (!modelDef || typeof modelDef !== "object" || Array.isArray(modelDef))
  3500. throw new InvalidArgumentError(
  3501. "The model definition should be an Object, but %v was given.",
  3502. modelDef
  3503. );
  3504. if (!modelDef.name || typeof modelDef.name !== "string")
  3505. throw new InvalidArgumentError(
  3506. 'The model definition requires the option "name" as a non-empty String, but %v was given.',
  3507. modelDef.name
  3508. );
  3509. if (modelDef.datasource && typeof modelDef.datasource !== "string")
  3510. throw new InvalidArgumentError(
  3511. 'The provided option "datasource" of the model %v should be a String, but %v was given.',
  3512. modelDef.name,
  3513. modelDef.datasource
  3514. );
  3515. if (modelDef.base && typeof modelDef.base !== "string")
  3516. throw new InvalidArgumentError(
  3517. 'The provided option "base" of the model %v should be a String, but %v was given.',
  3518. modelDef.name,
  3519. modelDef.base
  3520. );
  3521. if (modelDef.tableName && typeof modelDef.tableName !== "string")
  3522. throw new InvalidArgumentError(
  3523. 'The provided option "tableName" of the model %v should be a String, but %v was given.',
  3524. modelDef.name,
  3525. modelDef.tableName
  3526. );
  3527. if (modelDef.properties) {
  3528. if (typeof modelDef.properties !== "object" || Array.isArray(modelDef.properties)) {
  3529. throw new InvalidArgumentError(
  3530. 'The provided option "properties" of the model %v should be an Object, but %v was given.',
  3531. modelDef.name,
  3532. modelDef.properties
  3533. );
  3534. }
  3535. this.getService(PropertiesDefinitionValidator).validate(
  3536. modelDef.name,
  3537. modelDef.properties
  3538. );
  3539. }
  3540. if (modelDef.relations) {
  3541. if (typeof modelDef.relations !== "object" || Array.isArray(modelDef.relations)) {
  3542. throw new InvalidArgumentError(
  3543. 'The provided option "relations" of the model %v should be an Object, but %v was given.',
  3544. modelDef.name,
  3545. modelDef.relations
  3546. );
  3547. }
  3548. this.getService(RelationsDefinitionValidator).validate(
  3549. modelDef.name,
  3550. modelDef.relations
  3551. );
  3552. }
  3553. }
  3554. };
  3555. __name(_ModelDefinitionValidator, "ModelDefinitionValidator");
  3556. ModelDefinitionValidator = _ModelDefinitionValidator;
  3557. }
  3558. });
  3559. // src/definition/model/index.js
  3560. var init_model = __esm({
  3561. "src/definition/model/index.js"() {
  3562. "use strict";
  3563. init_relations();
  3564. init_properties();
  3565. init_model_definition();
  3566. init_model_data_validator();
  3567. init_model_data_sanitizer();
  3568. init_model_data_transformer();
  3569. init_model_definition_utils();
  3570. init_model_definition_validator();
  3571. }
  3572. });
  3573. // src/definition/datasource/datasource-definition-validator.js
  3574. var import_js_service17, _DatasourceDefinitionValidator, DatasourceDefinitionValidator;
  3575. var init_datasource_definition_validator = __esm({
  3576. "src/definition/datasource/datasource-definition-validator.js"() {
  3577. "use strict";
  3578. import_js_service17 = require("@e22m4u/js-service");
  3579. init_errors();
  3580. _DatasourceDefinitionValidator = class _DatasourceDefinitionValidator extends import_js_service17.Service {
  3581. /**
  3582. * Validate.
  3583. *
  3584. * @param {object} datasourceDef
  3585. */
  3586. validate(datasourceDef) {
  3587. if (!datasourceDef || typeof datasourceDef !== "object")
  3588. throw new InvalidArgumentError(
  3589. "The datasource definition should be an Object, but %v was given.",
  3590. datasourceDef
  3591. );
  3592. if (!datasourceDef.name || typeof datasourceDef.name !== "string")
  3593. throw new InvalidArgumentError(
  3594. 'The datasource definition requires the option "name" as a non-empty String, but %v was given.',
  3595. datasourceDef.name
  3596. );
  3597. if (!datasourceDef.adapter || typeof datasourceDef.adapter !== "string")
  3598. throw new InvalidArgumentError(
  3599. 'The datasource %v requires the option "adapter" as a non-empty String, but %v was given.',
  3600. datasourceDef.name,
  3601. datasourceDef.adapter
  3602. );
  3603. }
  3604. };
  3605. __name(_DatasourceDefinitionValidator, "DatasourceDefinitionValidator");
  3606. DatasourceDefinitionValidator = _DatasourceDefinitionValidator;
  3607. }
  3608. });
  3609. // src/definition/datasource/index.js
  3610. var init_datasource = __esm({
  3611. "src/definition/datasource/index.js"() {
  3612. "use strict";
  3613. init_datasource_definition_validator();
  3614. }
  3615. });
  3616. // src/definition/index.js
  3617. var init_definition = __esm({
  3618. "src/definition/index.js"() {
  3619. "use strict";
  3620. init_model();
  3621. init_datasource();
  3622. init_definition_registry();
  3623. }
  3624. });
  3625. // src/filter/fields-clause-tool.js
  3626. var import_js_service18, _FieldsClauseTool, FieldsClauseTool;
  3627. var init_fields_clause_tool = __esm({
  3628. "src/filter/fields-clause-tool.js"() {
  3629. "use strict";
  3630. import_js_service18 = require("@e22m4u/js-service");
  3631. init_utils();
  3632. init_errors();
  3633. init_definition();
  3634. _FieldsClauseTool = class _FieldsClauseTool extends import_js_service18.Service {
  3635. /**
  3636. * Filter.
  3637. *
  3638. * @param {object|object[]} input
  3639. * @param {string} modelName
  3640. * @param {string|string[]|undefined} clause
  3641. * @returns {object|object[]}
  3642. */
  3643. filter(input, modelName, clause) {
  3644. const isArray = Array.isArray(input);
  3645. let entities = isArray ? input : [input];
  3646. entities.forEach((entity) => {
  3647. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  3648. throw new InvalidArgumentError(
  3649. "The first argument of FieldsClauseTool.filter should be an Object or an Array of Object, but %v was given.",
  3650. entity
  3651. );
  3652. });
  3653. if (!modelName || typeof modelName !== "string")
  3654. throw new InvalidArgumentError(
  3655. "The second argument of FieldsClauseTool.filter should be a non-empty String, but %v was given.",
  3656. modelName
  3657. );
  3658. if (clause == null) return input;
  3659. const fields = Array.isArray(clause) ? clause.slice() : [clause];
  3660. if (!fields.length) return input;
  3661. fields.forEach((field) => {
  3662. if (!field || typeof field !== "string")
  3663. throw new InvalidArgumentError(
  3664. 'The provided option "fields" should be a non-empty String or an Array of non-empty String, but %v was given.',
  3665. field
  3666. );
  3667. });
  3668. const pkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  3669. modelName
  3670. );
  3671. if (fields.indexOf(pkPropName) === -1) fields.push(pkPropName);
  3672. entities = entities.map((entity) => selectObjectKeys(entity, fields));
  3673. return isArray ? entities : entities[0];
  3674. }
  3675. /**
  3676. * Validate fields clause.
  3677. *
  3678. * @param {string|string[]|undefined} clause
  3679. */
  3680. static validateFieldsClause(clause) {
  3681. if (clause == null) return;
  3682. const fields = Array.isArray(clause) ? clause : [clause];
  3683. if (!fields.length) return;
  3684. fields.forEach((field) => {
  3685. if (!field || typeof field !== "string")
  3686. throw new InvalidArgumentError(
  3687. 'The provided option "fields" should be a non-empty String or an Array of non-empty String, but %v was given.',
  3688. field
  3689. );
  3690. });
  3691. }
  3692. /**
  3693. * Normalize fields clause.
  3694. *
  3695. * @param {string|string[]|undefined} clause
  3696. * @returns {string[]|undefined}
  3697. */
  3698. static normalizeFieldsClause(clause) {
  3699. if (clause == null) return;
  3700. const fields = Array.isArray(clause) ? clause : [clause];
  3701. if (!fields.length) return;
  3702. fields.forEach((field) => {
  3703. if (!field || typeof field !== "string")
  3704. throw new InvalidArgumentError(
  3705. 'The provided option "fields" should be a non-empty String or an Array of non-empty String, but %v was given.',
  3706. field
  3707. );
  3708. });
  3709. return fields;
  3710. }
  3711. };
  3712. __name(_FieldsClauseTool, "FieldsClauseTool");
  3713. FieldsClauseTool = _FieldsClauseTool;
  3714. }
  3715. });
  3716. // src/adapter/decorator/inclusion-decorator.js
  3717. var import_js_service19, _InclusionDecorator, InclusionDecorator;
  3718. var init_inclusion_decorator = __esm({
  3719. "src/adapter/decorator/inclusion-decorator.js"() {
  3720. "use strict";
  3721. init_adapter();
  3722. import_js_service19 = require("@e22m4u/js-service");
  3723. init_filter();
  3724. init_errors();
  3725. _InclusionDecorator = class _InclusionDecorator extends import_js_service19.Service {
  3726. /**
  3727. * Decorate.
  3728. *
  3729. * @param {Adapter} adapter
  3730. */
  3731. decorate(adapter) {
  3732. if (!adapter || !(adapter instanceof Adapter))
  3733. throw new InvalidArgumentError(
  3734. "The first argument of InclusionDecorator.decorate should be an Adapter instance, but %v was given.",
  3735. adapter
  3736. );
  3737. const tool = adapter.getService(IncludeClauseTool);
  3738. const includeTo = /* @__PURE__ */ __name((...args) => tool.includeTo(...args), "includeTo");
  3739. const create = adapter.create;
  3740. adapter.create = async function(modelName, modelData, filter) {
  3741. const retvalData = await create.call(this, modelName, modelData, filter);
  3742. if (filter && typeof filter === "object" && filter.include)
  3743. await includeTo([retvalData], modelName, filter.include);
  3744. return retvalData;
  3745. };
  3746. const replaceById = adapter.replaceById;
  3747. adapter.replaceById = async function(modelName, id, modelData, filter) {
  3748. const retvalData = await replaceById.call(
  3749. this,
  3750. modelName,
  3751. id,
  3752. modelData,
  3753. filter
  3754. );
  3755. if (filter && typeof filter === "object" && filter.include)
  3756. await includeTo([retvalData], modelName, filter.include);
  3757. return retvalData;
  3758. };
  3759. const replaceOrCreate = adapter.replaceOrCreate;
  3760. adapter.replaceOrCreate = async function(modelName, modelData, filter) {
  3761. const retvalData = await replaceOrCreate.call(
  3762. this,
  3763. modelName,
  3764. modelData,
  3765. filter
  3766. );
  3767. if (filter && typeof filter === "object" && filter.include)
  3768. await includeTo([retvalData], modelName, filter.include);
  3769. return retvalData;
  3770. };
  3771. const patchById = adapter.patchById;
  3772. adapter.patchById = async function(modelName, id, modelData, filter) {
  3773. const retvalData = await patchById.call(
  3774. this,
  3775. modelName,
  3776. id,
  3777. modelData,
  3778. filter
  3779. );
  3780. if (filter && typeof filter === "object" && filter.include)
  3781. await includeTo([retvalData], modelName, filter.include);
  3782. return retvalData;
  3783. };
  3784. const find = adapter.find;
  3785. adapter.find = async function(modelName, filter) {
  3786. const modelItems = await find.call(this, modelName, filter);
  3787. if (filter && typeof filter === "object" && filter.include)
  3788. await includeTo(modelItems, modelName, filter.include);
  3789. return modelItems;
  3790. };
  3791. const findById = adapter.findById;
  3792. adapter.findById = async function(modelName, id, filter) {
  3793. const retvalData = await findById.call(this, modelName, id, filter);
  3794. if (filter && typeof filter === "object" && filter.include)
  3795. await includeTo([retvalData], modelName, filter.include);
  3796. return retvalData;
  3797. };
  3798. }
  3799. };
  3800. __name(_InclusionDecorator, "InclusionDecorator");
  3801. InclusionDecorator = _InclusionDecorator;
  3802. }
  3803. });
  3804. // src/adapter/decorator/default-values-decorator.js
  3805. var import_js_service20, _DefaultValuesDecorator, DefaultValuesDecorator;
  3806. var init_default_values_decorator = __esm({
  3807. "src/adapter/decorator/default-values-decorator.js"() {
  3808. "use strict";
  3809. init_adapter();
  3810. import_js_service20 = require("@e22m4u/js-service");
  3811. init_errors();
  3812. init_definition();
  3813. _DefaultValuesDecorator = class _DefaultValuesDecorator extends import_js_service20.Service {
  3814. /**
  3815. * Decorate.
  3816. *
  3817. * @param {Adapter} adapter
  3818. */
  3819. decorate(adapter) {
  3820. if (!adapter || !(adapter instanceof Adapter))
  3821. throw new InvalidArgumentError(
  3822. "The first argument of DefaultValuesDecorator.decorate should be an Adapter instance, but %v was given.",
  3823. adapter
  3824. );
  3825. const utils = adapter.getService(ModelDefinitionUtils);
  3826. const setDefaults = /* @__PURE__ */ __name((...args) => utils.setDefaultValuesToEmptyProperties(...args), "setDefaults");
  3827. const create = adapter.create;
  3828. adapter.create = function(modelName, modelData, filter) {
  3829. modelData = setDefaults(modelName, modelData);
  3830. return create.call(this, modelName, modelData, filter);
  3831. };
  3832. const replaceById = adapter.replaceById;
  3833. adapter.replaceById = function(modelName, id, modelData, filter) {
  3834. modelData = setDefaults(modelName, modelData);
  3835. return replaceById.call(this, modelName, id, modelData, filter);
  3836. };
  3837. const replaceOrCreate = adapter.replaceOrCreate;
  3838. adapter.replaceOrCreate = function(modelName, modelData, filter) {
  3839. modelData = setDefaults(modelName, modelData);
  3840. return replaceOrCreate.call(this, modelName, modelData, filter);
  3841. };
  3842. const patch = adapter.patch;
  3843. adapter.patch = function(modelName, modelData, where) {
  3844. modelData = setDefaults(modelName, modelData, true);
  3845. return patch.call(this, modelName, modelData, where);
  3846. };
  3847. const patchById = adapter.patchById;
  3848. adapter.patchById = function(modelName, id, modelData, filter) {
  3849. modelData = setDefaults(modelName, modelData, true);
  3850. return patchById.call(this, modelName, id, modelData, filter);
  3851. };
  3852. const find = adapter.find;
  3853. adapter.find = async function(modelName, filter) {
  3854. const modelItems = await find.call(this, modelName, filter);
  3855. return modelItems.map((modelItem) => setDefaults(modelName, modelItem));
  3856. };
  3857. const findById = adapter.findById;
  3858. adapter.findById = async function(modelName, id, filter) {
  3859. const retvalData = await findById.call(this, modelName, id, filter);
  3860. return setDefaults(modelName, retvalData);
  3861. };
  3862. }
  3863. };
  3864. __name(_DefaultValuesDecorator, "DefaultValuesDecorator");
  3865. DefaultValuesDecorator = _DefaultValuesDecorator;
  3866. }
  3867. });
  3868. // src/adapter/decorator/data-sanitizing-decorator.js
  3869. var import_js_service21, _DataSanitizingDecorator, DataSanitizingDecorator;
  3870. var init_data_sanitizing_decorator = __esm({
  3871. "src/adapter/decorator/data-sanitizing-decorator.js"() {
  3872. "use strict";
  3873. init_adapter();
  3874. import_js_service21 = require("@e22m4u/js-service");
  3875. init_errors();
  3876. init_definition();
  3877. _DataSanitizingDecorator = class _DataSanitizingDecorator extends import_js_service21.Service {
  3878. /**
  3879. * Decorate.
  3880. *
  3881. * @param {Adapter} adapter
  3882. */
  3883. decorate(adapter) {
  3884. if (!adapter || !(adapter instanceof Adapter))
  3885. throw new InvalidArgumentError(
  3886. "The first argument of DataSanitizingDecorator.decorate should be an Adapter instance, but %v was given.",
  3887. adapter
  3888. );
  3889. const sanitizer = adapter.getService(ModelDataSanitizer);
  3890. const sanitize = /* @__PURE__ */ __name((...args) => sanitizer.sanitize(...args), "sanitize");
  3891. const create = adapter.create;
  3892. adapter.create = async function(modelName, modelData, filter) {
  3893. modelData = sanitize(modelName, modelData);
  3894. return create.call(this, modelName, modelData, filter);
  3895. };
  3896. const replaceById = adapter.replaceById;
  3897. adapter.replaceById = async function(modelName, id, modelData, filter) {
  3898. modelData = sanitize(modelName, modelData);
  3899. return replaceById.call(this, modelName, id, modelData, filter);
  3900. };
  3901. const replaceOrCreate = adapter.replaceOrCreate;
  3902. adapter.replaceOrCreate = async function(modelName, modelData, filter) {
  3903. modelData = sanitize(modelName, modelData);
  3904. return replaceOrCreate.call(this, modelName, modelData, filter);
  3905. };
  3906. const patch = adapter.patch;
  3907. adapter.patch = async function(modelName, modelData, where) {
  3908. modelData = sanitize(modelName, modelData);
  3909. return patch.call(this, modelName, modelData, where);
  3910. };
  3911. const patchById = adapter.patchById;
  3912. adapter.patchById = async function(modelName, id, modelData, filter) {
  3913. modelData = sanitize(modelName, modelData);
  3914. return patchById.call(this, modelName, id, modelData, filter);
  3915. };
  3916. }
  3917. };
  3918. __name(_DataSanitizingDecorator, "DataSanitizingDecorator");
  3919. DataSanitizingDecorator = _DataSanitizingDecorator;
  3920. }
  3921. });
  3922. // src/adapter/decorator/data-validation-decorator.js
  3923. var import_js_service22, _DataValidationDecorator, DataValidationDecorator;
  3924. var init_data_validation_decorator = __esm({
  3925. "src/adapter/decorator/data-validation-decorator.js"() {
  3926. "use strict";
  3927. init_adapter();
  3928. import_js_service22 = require("@e22m4u/js-service");
  3929. init_errors();
  3930. init_definition();
  3931. _DataValidationDecorator = class _DataValidationDecorator extends import_js_service22.Service {
  3932. /**
  3933. * Decorate.
  3934. *
  3935. * @param {Adapter} adapter
  3936. */
  3937. decorate(adapter) {
  3938. if (!adapter || !(adapter instanceof Adapter))
  3939. throw new InvalidArgumentError(
  3940. "The first argument of DataValidationDecorator.decorate should be an Adapter instance, but %v was given.",
  3941. adapter
  3942. );
  3943. const validator = this.getService(ModelDataValidator);
  3944. const create = adapter.create;
  3945. adapter.create = function(modelName, modelData, filter) {
  3946. validator.validate(modelName, modelData);
  3947. return create.call(this, modelName, modelData, filter);
  3948. };
  3949. const replaceById = adapter.replaceById;
  3950. adapter.replaceById = function(modelName, id, modelData, filter) {
  3951. validator.validate(modelName, modelData);
  3952. return replaceById.call(this, modelName, id, modelData, filter);
  3953. };
  3954. const replaceOrCreate = adapter.replaceOrCreate;
  3955. adapter.replaceOrCreate = function(modelName, modelData, filter) {
  3956. validator.validate(modelName, modelData);
  3957. return replaceOrCreate.call(this, modelName, modelData, filter);
  3958. };
  3959. const patch = adapter.patch;
  3960. adapter.patch = function(modelName, modelData, where) {
  3961. validator.validate(modelName, modelData, true);
  3962. return patch.call(this, modelName, modelData, where);
  3963. };
  3964. const patchById = adapter.patchById;
  3965. adapter.patchById = function(modelName, id, modelData, filter) {
  3966. validator.validate(modelName, modelData, true);
  3967. return patchById.call(this, modelName, id, modelData, filter);
  3968. };
  3969. }
  3970. };
  3971. __name(_DataValidationDecorator, "DataValidationDecorator");
  3972. DataValidationDecorator = _DataValidationDecorator;
  3973. }
  3974. });
  3975. // src/adapter/decorator/fields-filtering-decorator.js
  3976. var import_js_service23, _FieldsFilteringDecorator, FieldsFilteringDecorator;
  3977. var init_fields_filtering_decorator = __esm({
  3978. "src/adapter/decorator/fields-filtering-decorator.js"() {
  3979. "use strict";
  3980. init_adapter();
  3981. import_js_service23 = require("@e22m4u/js-service");
  3982. init_filter();
  3983. init_errors();
  3984. _FieldsFilteringDecorator = class _FieldsFilteringDecorator extends import_js_service23.Service {
  3985. /**
  3986. * Decorate.
  3987. *
  3988. * @param {Adapter} adapter
  3989. */
  3990. decorate(adapter) {
  3991. if (!adapter || !(adapter instanceof Adapter))
  3992. throw new InvalidArgumentError(
  3993. "The first argument of FieldsFilteringDecorator.decorate should be an Adapter instance, but %v was given.",
  3994. adapter
  3995. );
  3996. const tool = adapter.getService(FieldsClauseTool);
  3997. const selectFields = /* @__PURE__ */ __name((...args) => tool.filter(...args), "selectFields");
  3998. const create = adapter.create;
  3999. adapter.create = async function(modelName, modelData, filter) {
  4000. let result = await create.call(this, modelName, modelData, filter);
  4001. if (filter && typeof filter === "object" && filter.fields)
  4002. result = selectFields(result, modelName, filter.fields);
  4003. return result;
  4004. };
  4005. const replaceById = adapter.replaceById;
  4006. adapter.replaceById = async function(modelName, id, modelData, filter) {
  4007. let result = await replaceById.call(
  4008. this,
  4009. modelName,
  4010. id,
  4011. modelData,
  4012. filter
  4013. );
  4014. if (filter && typeof filter === "object" && filter.fields)
  4015. result = selectFields(result, modelName, filter.fields);
  4016. return result;
  4017. };
  4018. const replaceOrCreate = adapter.replaceOrCreate;
  4019. adapter.replaceOrCreate = async function(modelName, modelData, filter) {
  4020. let result = await replaceOrCreate.call(
  4021. this,
  4022. modelName,
  4023. modelData,
  4024. filter
  4025. );
  4026. if (filter && typeof filter === "object" && filter.fields)
  4027. result = selectFields(result, modelName, filter.fields);
  4028. return result;
  4029. };
  4030. const patchById = adapter.patchById;
  4031. adapter.patchById = async function(modelName, id, modelData, filter) {
  4032. let result = await patchById.call(this, modelName, id, modelData, filter);
  4033. if (filter && typeof filter === "object" && filter.fields)
  4034. result = selectFields(result, modelName, filter.fields);
  4035. return result;
  4036. };
  4037. const find = adapter.find;
  4038. adapter.find = async function(modelName, filter) {
  4039. let result = await find.call(this, modelName, filter);
  4040. if (filter && typeof filter === "object" && filter.fields)
  4041. result = selectFields(result, modelName, filter.fields);
  4042. return result;
  4043. };
  4044. const findById = adapter.findById;
  4045. adapter.findById = async function(modelName, id, filter) {
  4046. let result = await findById.call(this, modelName, id, filter);
  4047. if (filter && typeof filter === "object" && filter.fields)
  4048. result = selectFields(result, modelName, filter.fields);
  4049. return result;
  4050. };
  4051. }
  4052. };
  4053. __name(_FieldsFilteringDecorator, "FieldsFilteringDecorator");
  4054. FieldsFilteringDecorator = _FieldsFilteringDecorator;
  4055. }
  4056. });
  4057. // src/adapter/decorator/data-transformation-decorator.js
  4058. var import_js_service24, _DataTransformationDecorator, DataTransformationDecorator;
  4059. var init_data_transformation_decorator = __esm({
  4060. "src/adapter/decorator/data-transformation-decorator.js"() {
  4061. "use strict";
  4062. init_adapter();
  4063. import_js_service24 = require("@e22m4u/js-service");
  4064. init_errors();
  4065. init_definition();
  4066. _DataTransformationDecorator = class _DataTransformationDecorator extends import_js_service24.Service {
  4067. /**
  4068. * Decorate.
  4069. *
  4070. * @param {Adapter} adapter
  4071. */
  4072. decorate(adapter) {
  4073. if (!adapter || !(adapter instanceof Adapter))
  4074. throw new InvalidArgumentError(
  4075. "The first argument of DataTransformerDecorator.decorate should be an Adapter instance, but %v was given.",
  4076. adapter
  4077. );
  4078. const transformer = this.getService(ModelDataTransformer);
  4079. const create = adapter.create;
  4080. adapter.create = async function(modelName, modelData, filter) {
  4081. modelData = await transformer.transform(modelName, modelData);
  4082. return create.call(this, modelName, modelData, filter);
  4083. };
  4084. const replaceById = adapter.replaceById;
  4085. adapter.replaceById = async function(modelName, id, modelData, filter) {
  4086. modelData = await transformer.transform(modelName, modelData);
  4087. return replaceById.call(this, modelName, id, modelData, filter);
  4088. };
  4089. const replaceOrCreate = adapter.replaceOrCreate;
  4090. adapter.replaceOrCreate = async function(modelName, modelData, filter) {
  4091. modelData = await transformer.transform(modelName, modelData);
  4092. return replaceOrCreate.call(this, modelName, modelData, filter);
  4093. };
  4094. const patch = adapter.patch;
  4095. adapter.patch = async function(modelName, modelData, where) {
  4096. modelData = await transformer.transform(modelName, modelData, true);
  4097. return patch.call(this, modelName, modelData, where);
  4098. };
  4099. const patchById = adapter.patchById;
  4100. adapter.patchById = async function(modelName, id, modelData, filter) {
  4101. modelData = await transformer.transform(modelName, modelData, true);
  4102. return patchById.call(this, modelName, id, modelData, filter);
  4103. };
  4104. }
  4105. };
  4106. __name(_DataTransformationDecorator, "DataTransformationDecorator");
  4107. DataTransformationDecorator = _DataTransformationDecorator;
  4108. }
  4109. });
  4110. // src/adapter/decorator/property-uniqueness-decorator.js
  4111. var import_js_service25, _PropertyUniquenessDecorator, PropertyUniquenessDecorator;
  4112. var init_property_uniqueness_decorator = __esm({
  4113. "src/adapter/decorator/property-uniqueness-decorator.js"() {
  4114. "use strict";
  4115. init_adapter();
  4116. import_js_service25 = require("@e22m4u/js-service");
  4117. init_errors();
  4118. init_definition();
  4119. _PropertyUniquenessDecorator = class _PropertyUniquenessDecorator extends import_js_service25.Service {
  4120. /**
  4121. * Decorate.
  4122. *
  4123. * @param {Adapter} adapter
  4124. */
  4125. decorate(adapter) {
  4126. if (!adapter || !(adapter instanceof Adapter))
  4127. throw new InvalidArgumentError(
  4128. "The first argument of PropertyUniquenessDecorator.decorate should be an Adapter instance, but %v was given.",
  4129. adapter
  4130. );
  4131. const validator = this.getService(PropertyUniquenessValidator);
  4132. const create = adapter.create;
  4133. adapter.create = async function(modelName, modelData, filter) {
  4134. const countMethod = adapter.count.bind(adapter, modelName);
  4135. await validator.validate(countMethod, "create", modelName, modelData);
  4136. return create.call(this, modelName, modelData, filter);
  4137. };
  4138. const replaceById = adapter.replaceById;
  4139. adapter.replaceById = async function(modelName, id, modelData, filter) {
  4140. const countMethod = adapter.count.bind(adapter, modelName);
  4141. await validator.validate(
  4142. countMethod,
  4143. "replaceById",
  4144. modelName,
  4145. modelData,
  4146. id
  4147. );
  4148. return replaceById.call(this, modelName, id, modelData, filter);
  4149. };
  4150. const replaceOrCreate = adapter.replaceOrCreate;
  4151. adapter.replaceOrCreate = async function(modelName, modelData, filter) {
  4152. const countMethod = adapter.count.bind(adapter, modelName);
  4153. await validator.validate(
  4154. countMethod,
  4155. "replaceOrCreate",
  4156. modelName,
  4157. modelData
  4158. );
  4159. return replaceOrCreate.call(this, modelName, modelData, filter);
  4160. };
  4161. const patch = adapter.patch;
  4162. adapter.patch = async function(modelName, modelData, where) {
  4163. const countMethod = adapter.count.bind(adapter, modelName);
  4164. await validator.validate(countMethod, "patch", modelName, modelData);
  4165. return patch.call(this, modelName, modelData, where);
  4166. };
  4167. const patchById = adapter.patchById;
  4168. adapter.patchById = async function(modelName, id, modelData, filter) {
  4169. const countMethod = adapter.count.bind(adapter, modelName);
  4170. await validator.validate(
  4171. countMethod,
  4172. "patchById",
  4173. modelName,
  4174. modelData,
  4175. id
  4176. );
  4177. return patchById.call(this, modelName, id, modelData, filter);
  4178. };
  4179. }
  4180. };
  4181. __name(_PropertyUniquenessDecorator, "PropertyUniquenessDecorator");
  4182. PropertyUniquenessDecorator = _PropertyUniquenessDecorator;
  4183. }
  4184. });
  4185. // src/adapter/decorator/index.js
  4186. var init_decorator = __esm({
  4187. "src/adapter/decorator/index.js"() {
  4188. "use strict";
  4189. init_inclusion_decorator();
  4190. init_default_values_decorator();
  4191. init_data_sanitizing_decorator();
  4192. init_data_validation_decorator();
  4193. init_fields_filtering_decorator();
  4194. init_data_transformation_decorator();
  4195. init_property_uniqueness_decorator();
  4196. }
  4197. });
  4198. // src/adapter/adapter.js
  4199. var import_js_service26, ADAPTER_CLASS_NAME, _Adapter, Adapter;
  4200. var init_adapter = __esm({
  4201. "src/adapter/adapter.js"() {
  4202. "use strict";
  4203. import_js_service26 = require("@e22m4u/js-service");
  4204. init_errors();
  4205. init_decorator();
  4206. init_decorator();
  4207. init_decorator();
  4208. init_decorator();
  4209. init_decorator();
  4210. init_decorator();
  4211. init_decorator();
  4212. ADAPTER_CLASS_NAME = "Adapter";
  4213. _Adapter = class _Adapter extends import_js_service26.Service {
  4214. /**
  4215. * Settings.
  4216. *
  4217. * @type {object|undefined}
  4218. */
  4219. _settings;
  4220. /**
  4221. * Settings.
  4222. *
  4223. * @returns {object|undefined}
  4224. */
  4225. get settings() {
  4226. return this._settings;
  4227. }
  4228. /**
  4229. * Constructor.
  4230. *
  4231. * @param {object|undefined} container
  4232. * @param {object|undefined} settings
  4233. */
  4234. constructor(container = void 0, settings = void 0) {
  4235. super(container);
  4236. this._settings = settings;
  4237. if (this.constructor !== _Adapter) {
  4238. this.getService(DataSanitizingDecorator).decorate(this);
  4239. this.getService(DefaultValuesDecorator).decorate(this);
  4240. this.getService(DataTransformationDecorator).decorate(this);
  4241. this.getService(DataValidationDecorator).decorate(this);
  4242. this.getService(PropertyUniquenessDecorator).decorate(this);
  4243. this.getService(FieldsFilteringDecorator).decorate(this);
  4244. this.getService(InclusionDecorator).decorate(this);
  4245. }
  4246. }
  4247. /**
  4248. * Create.
  4249. *
  4250. * @param {string} modelName
  4251. * @param {object} modelData
  4252. * @param {object|undefined} filter
  4253. * @returns {Promise<object>}
  4254. */
  4255. create(modelName, modelData, filter = void 0) {
  4256. throw new NotImplementedError(
  4257. "%s.create is not implemented.",
  4258. this.constructor.name
  4259. );
  4260. }
  4261. /**
  4262. * Replace by id.
  4263. *
  4264. * @param {string} modelName
  4265. * @param {number|string} id
  4266. * @param {object} modelData
  4267. * @param {object|undefined} filter
  4268. * @returns {Promise<object>}
  4269. */
  4270. replaceById(modelName, id, modelData, filter = void 0) {
  4271. throw new NotImplementedError(
  4272. "%s.replaceById is not implemented.",
  4273. this.constructor.name
  4274. );
  4275. }
  4276. /**
  4277. * Replace or create.
  4278. *
  4279. * @param {string} modelName
  4280. * @param {object} modelData
  4281. * @param {object|undefined} filter
  4282. * @returns {Promise<object>}
  4283. */
  4284. replaceOrCreate(modelName, modelData, filter = void 0) {
  4285. throw new NotImplementedError(
  4286. "%s.replaceOrCreate is not implemented.",
  4287. this.constructor.name
  4288. );
  4289. }
  4290. /**
  4291. * Patch.
  4292. *
  4293. * @param {string} modelName
  4294. * @param {object} modelData
  4295. * @param {object|undefined} where
  4296. * @returns {Promise<number>}
  4297. */
  4298. patch(modelName, modelData, where = void 0) {
  4299. throw new NotImplementedError(
  4300. "%s.patch is not implemented.",
  4301. this.constructor.name
  4302. );
  4303. }
  4304. /**
  4305. * Patch by id.
  4306. *
  4307. * @param {string} modelName
  4308. * @param {number|string} id
  4309. * @param {object} modelData
  4310. * @param {object|undefined} filter
  4311. * @returns {Promise<object>}
  4312. */
  4313. patchById(modelName, id, modelData, filter = void 0) {
  4314. throw new NotImplementedError(
  4315. "%s.patchById is not implemented.",
  4316. this.constructor.name
  4317. );
  4318. }
  4319. /**
  4320. * Find.
  4321. *
  4322. * @param {string} modelName
  4323. * @param {object|undefined} filter
  4324. * @returns {Promise<object[]>}
  4325. */
  4326. find(modelName, filter = void 0) {
  4327. throw new NotImplementedError(
  4328. "%s.find is not implemented.",
  4329. this.constructor.name
  4330. );
  4331. }
  4332. /**
  4333. * Find by id.
  4334. *
  4335. * @param {string} modelName
  4336. * @param {number|string} id
  4337. * @param {object|undefined} filter
  4338. * @returns {Promise<object>}
  4339. */
  4340. findById(modelName, id, filter = void 0) {
  4341. throw new NotImplementedError(
  4342. "%s.findById is not implemented.",
  4343. this.constructor.name
  4344. );
  4345. }
  4346. /**
  4347. * Delete.
  4348. *
  4349. * @param {string} modelName
  4350. * @param {object|undefined} where
  4351. * @returns {Promise<number>}
  4352. */
  4353. delete(modelName, where = void 0) {
  4354. throw new NotImplementedError(
  4355. "%s.delete is not implemented.",
  4356. this.constructor.name
  4357. );
  4358. }
  4359. /**
  4360. * Delete by id.
  4361. *
  4362. * @param {string} modelName
  4363. * @param {number|string} id
  4364. * @returns {Promise<boolean>}
  4365. */
  4366. deleteById(modelName, id) {
  4367. throw new NotImplementedError(
  4368. "%s.deleteById is not implemented.",
  4369. this.constructor.name
  4370. );
  4371. }
  4372. /**
  4373. * Exists.
  4374. *
  4375. * @param {string} modelName
  4376. * @param {number|string} id
  4377. * @returns {Promise<boolean>}
  4378. */
  4379. exists(modelName, id) {
  4380. throw new NotImplementedError(
  4381. "%s.exists is not implemented.",
  4382. this.constructor.name
  4383. );
  4384. }
  4385. /**
  4386. * Count.
  4387. *
  4388. * @param {string} modelName
  4389. * @param {object|undefined} where
  4390. * @returns {Promise<number>}
  4391. */
  4392. count(modelName, where = void 0) {
  4393. throw new NotImplementedError(
  4394. "%s.count is not implemented.",
  4395. this.constructor.name
  4396. );
  4397. }
  4398. };
  4399. __name(_Adapter, "Adapter");
  4400. /**
  4401. * Kind.
  4402. *
  4403. * @type {string}
  4404. */
  4405. __publicField(_Adapter, "kinds", [...import_js_service26.Service.kinds, ADAPTER_CLASS_NAME]);
  4406. Adapter = _Adapter;
  4407. }
  4408. });
  4409. // src/adapter/builtin/memory-adapter.js
  4410. var memory_adapter_exports = {};
  4411. __export(memory_adapter_exports, {
  4412. MemoryAdapter: () => MemoryAdapter
  4413. });
  4414. var _MemoryAdapter, MemoryAdapter;
  4415. var init_memory_adapter = __esm({
  4416. "src/adapter/builtin/memory-adapter.js"() {
  4417. "use strict";
  4418. init_adapter();
  4419. init_utils();
  4420. init_utils();
  4421. init_definition();
  4422. init_filter();
  4423. init_filter();
  4424. init_filter();
  4425. init_errors();
  4426. init_definition();
  4427. _MemoryAdapter = class _MemoryAdapter extends Adapter {
  4428. /**
  4429. * Tables.
  4430. *
  4431. * @type {Map<string, Map<number, Record<string, any>>>}
  4432. */
  4433. _tables = /* @__PURE__ */ new Map();
  4434. /**
  4435. * Last ids.
  4436. *
  4437. * @type {Map<string, number>}
  4438. */
  4439. _lastIds = /* @__PURE__ */ new Map();
  4440. /**
  4441. * Get table or create.
  4442. *
  4443. * @param {string} modelName
  4444. * @returns {Map<number, object>}
  4445. */
  4446. _getTableOrCreate(modelName) {
  4447. const tableName = this.getService(ModelDefinitionUtils).getTableNameByModelName(modelName);
  4448. let table = this._tables.get(tableName);
  4449. if (table) return table;
  4450. table = /* @__PURE__ */ new Map();
  4451. this._tables.set(tableName, table);
  4452. return table;
  4453. }
  4454. /**
  4455. * Gen next id value.
  4456. *
  4457. * @param {string} modelName
  4458. * @param {string} propName
  4459. * @returns {number}
  4460. */
  4461. _genNextIdValue(modelName, propName) {
  4462. var _a;
  4463. const propType = this.getService(
  4464. ModelDefinitionUtils
  4465. ).getDataTypeByPropertyName(modelName, propName);
  4466. if (propType !== DataType.ANY && propType !== DataType.NUMBER)
  4467. throw new InvalidArgumentError(
  4468. "The memory adapter able to generate only Number identifiers, but the primary key %v of the model %v is defined as %s. Do provide your own value for the %v property, or change the type in the primary key definition to a Number that will be generated automatically.",
  4469. propName,
  4470. modelName,
  4471. capitalize(propType),
  4472. propName
  4473. );
  4474. const tableName = this.getService(ModelDefinitionUtils).getTableNameByModelName(modelName);
  4475. const lastId = (_a = this._lastIds.get(tableName)) != null ? _a : 0;
  4476. const nextId = lastId + 1;
  4477. this._lastIds.set(tableName, nextId);
  4478. const table = this._getTableOrCreate(modelName);
  4479. const existedIds = Array.from(table.keys());
  4480. if (existedIds.includes(nextId))
  4481. return this._genNextIdValue(modelName, propName);
  4482. return nextId;
  4483. }
  4484. /**
  4485. * Create
  4486. *
  4487. * @param {string} modelName
  4488. * @param {object} modelData
  4489. * @param {object|undefined} filter
  4490. * @returns {Promise<object>}
  4491. */
  4492. // eslint-disable-next-line no-unused-vars
  4493. async create(modelName, modelData, filter = void 0) {
  4494. const pkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  4495. modelName
  4496. );
  4497. let idValue = modelData[pkPropName];
  4498. if (idValue == null || idValue === "" || idValue === 0) {
  4499. idValue = this._genNextIdValue(modelName, pkPropName);
  4500. }
  4501. const table = this._getTableOrCreate(modelName);
  4502. if (table.has(idValue))
  4503. throw new InvalidArgumentError(
  4504. "The value %v of the primary key %v already exists in the model %v.",
  4505. idValue,
  4506. pkPropName,
  4507. modelName
  4508. );
  4509. modelData = cloneDeep(modelData);
  4510. modelData[pkPropName] = idValue;
  4511. const tableData = this.getService(
  4512. ModelDefinitionUtils
  4513. ).convertPropertyNamesToColumnNames(modelName, modelData);
  4514. table.set(idValue, tableData);
  4515. return this.getService(
  4516. ModelDefinitionUtils
  4517. ).convertColumnNamesToPropertyNames(modelName, tableData);
  4518. }
  4519. /**
  4520. * Replace by id.
  4521. *
  4522. * @param {string} modelName
  4523. * @param {string|number} id
  4524. * @param {object} modelData
  4525. * @param {object|undefined} filter
  4526. * @returns {Promise<object>}
  4527. */
  4528. // eslint-disable-next-line no-unused-vars
  4529. async replaceById(modelName, id, modelData, filter = void 0) {
  4530. const table = this._getTableOrCreate(modelName);
  4531. const isExists = table.has(id);
  4532. const pkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  4533. modelName
  4534. );
  4535. if (!isExists)
  4536. throw new InvalidArgumentError(
  4537. "The value %v of the primary key %v does not exist in the model %v.",
  4538. id,
  4539. pkPropName,
  4540. modelName
  4541. );
  4542. modelData = cloneDeep(modelData);
  4543. modelData[pkPropName] = id;
  4544. const tableData = this.getService(
  4545. ModelDefinitionUtils
  4546. ).convertPropertyNamesToColumnNames(modelName, modelData);
  4547. table.set(id, tableData);
  4548. return this.getService(
  4549. ModelDefinitionUtils
  4550. ).convertColumnNamesToPropertyNames(modelName, tableData);
  4551. }
  4552. /**
  4553. * Replace or create.
  4554. *
  4555. * @param {string} modelName
  4556. * @param {object} modelData
  4557. * @param {object|undefined} filter
  4558. * @returns {Promise<object>}
  4559. */
  4560. // eslint-disable-next-line no-unused-vars
  4561. async replaceOrCreate(modelName, modelData, filter = void 0) {
  4562. const pkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  4563. modelName
  4564. );
  4565. let idValue = modelData[pkPropName];
  4566. if (idValue == null || idValue === "" || idValue === 0) {
  4567. idValue = this._genNextIdValue(modelName, pkPropName);
  4568. }
  4569. const table = this._getTableOrCreate(modelName);
  4570. modelData = cloneDeep(modelData);
  4571. modelData[pkPropName] = idValue;
  4572. const tableData = this.getService(
  4573. ModelDefinitionUtils
  4574. ).convertPropertyNamesToColumnNames(modelName, modelData);
  4575. table.set(idValue, tableData);
  4576. return this.getService(
  4577. ModelDefinitionUtils
  4578. ).convertColumnNamesToPropertyNames(modelName, tableData);
  4579. }
  4580. /**
  4581. * Patch.
  4582. *
  4583. * @param {string} modelName
  4584. * @param {object} modelData
  4585. * @param {object|undefined} where
  4586. * @returns {Promise<number>}
  4587. */
  4588. async patch(modelName, modelData, where = void 0) {
  4589. const table = this._getTableOrCreate(modelName);
  4590. const tableItems = Array.from(table.values());
  4591. if (!tableItems.length) return 0;
  4592. let modelItems = tableItems.map(
  4593. (tableItem) => this.getService(ModelDefinitionUtils).convertColumnNamesToPropertyNames(
  4594. modelName,
  4595. tableItem
  4596. )
  4597. );
  4598. if (where && typeof where === "object")
  4599. modelItems = this.getService(WhereClauseTool).filter(modelItems, where);
  4600. const size = modelItems.length;
  4601. const pkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  4602. modelName
  4603. );
  4604. modelData = cloneDeep(modelData);
  4605. delete modelData[pkPropName];
  4606. modelItems.forEach((existingModelData) => {
  4607. const mergedModelData = Object.assign({}, existingModelData, modelData);
  4608. const mergedTableData = this.getService(
  4609. ModelDefinitionUtils
  4610. ).convertPropertyNamesToColumnNames(modelName, mergedModelData);
  4611. const idValue = existingModelData[pkPropName];
  4612. table.set(idValue, mergedTableData);
  4613. });
  4614. return size;
  4615. }
  4616. /**
  4617. * Patch by id.
  4618. *
  4619. * @param {string} modelName
  4620. * @param {string|number} id
  4621. * @param {object} modelData
  4622. * @param {object|undefined} filter
  4623. * @returns {Promise<object>}
  4624. */
  4625. // eslint-disable-next-line no-unused-vars
  4626. async patchById(modelName, id, modelData, filter = void 0) {
  4627. const table = this._getTableOrCreate(modelName);
  4628. const existingTableData = table.get(id);
  4629. const pkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  4630. modelName
  4631. );
  4632. if (existingTableData == null)
  4633. throw new InvalidArgumentError(
  4634. "The value %v of the primary key %v does not exist in the model %v.",
  4635. id,
  4636. pkPropName,
  4637. modelName
  4638. );
  4639. modelData = cloneDeep(modelData);
  4640. delete modelData[pkPropName];
  4641. const existingModelData = this.getService(
  4642. ModelDefinitionUtils
  4643. ).convertColumnNamesToPropertyNames(modelName, existingTableData);
  4644. const mergedModelData = Object.assign({}, existingModelData, modelData);
  4645. const mergedTableData = this.getService(
  4646. ModelDefinitionUtils
  4647. ).convertPropertyNamesToColumnNames(modelName, mergedModelData);
  4648. table.set(id, mergedTableData);
  4649. return this.getService(
  4650. ModelDefinitionUtils
  4651. ).convertColumnNamesToPropertyNames(modelName, mergedTableData);
  4652. }
  4653. /**
  4654. * Find.
  4655. *
  4656. * @param {string} modelName
  4657. * @param {object|undefined} filter
  4658. * @returns {Promise<object[]>}
  4659. */
  4660. async find(modelName, filter = void 0) {
  4661. const table = this._getTableOrCreate(modelName);
  4662. const tableItems = Array.from(table.values());
  4663. let modelItems = tableItems.map(
  4664. (tableItem) => this.getService(ModelDefinitionUtils).convertColumnNamesToPropertyNames(
  4665. modelName,
  4666. tableItem
  4667. )
  4668. );
  4669. if (filter && typeof filter === "object") {
  4670. if (filter.where)
  4671. modelItems = this.getService(WhereClauseTool).filter(
  4672. modelItems,
  4673. filter.where
  4674. );
  4675. if (filter.skip || filter.limit)
  4676. modelItems = this.getService(SliceClauseTool).slice(
  4677. modelItems,
  4678. filter.skip,
  4679. filter.limit
  4680. );
  4681. if (filter.order)
  4682. this.getService(OrderClauseTool).sort(modelItems, filter.order);
  4683. }
  4684. return modelItems;
  4685. }
  4686. /**
  4687. * Find by id.
  4688. *
  4689. * @param {string} modelName
  4690. * @param {string|number} id
  4691. * @param {object|undefined} filter
  4692. * @returns {Promise<object>}
  4693. */
  4694. // eslint-disable-next-line no-unused-vars
  4695. async findById(modelName, id, filter = void 0) {
  4696. const table = this._getTableOrCreate(modelName);
  4697. const tableData = table.get(id);
  4698. const pkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  4699. modelName
  4700. );
  4701. if (!tableData)
  4702. throw new InvalidArgumentError(
  4703. "The value %v of the primary key %v does not exist in the model %v.",
  4704. id,
  4705. pkPropName,
  4706. modelName
  4707. );
  4708. return this.getService(
  4709. ModelDefinitionUtils
  4710. ).convertColumnNamesToPropertyNames(modelName, tableData);
  4711. }
  4712. /**
  4713. * Delete.
  4714. *
  4715. * @param {string} modelName
  4716. * @param {object|undefined} where
  4717. * @returns {Promise<number>}
  4718. */
  4719. async delete(modelName, where = void 0) {
  4720. const table = this._getTableOrCreate(modelName);
  4721. const tableItems = Array.from(table.values());
  4722. if (!tableItems.length) return 0;
  4723. let modelItems = tableItems.map(
  4724. (tableItem) => this.getService(ModelDefinitionUtils).convertColumnNamesToPropertyNames(
  4725. modelName,
  4726. tableItem
  4727. )
  4728. );
  4729. if (where && typeof where === "object")
  4730. modelItems = this.getService(WhereClauseTool).filter(modelItems, where);
  4731. const size = modelItems.length;
  4732. const idPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  4733. modelName
  4734. );
  4735. modelItems.forEach((modelData) => {
  4736. const idValue = modelData[idPropName];
  4737. table.delete(idValue);
  4738. });
  4739. return size;
  4740. }
  4741. /**
  4742. * Delete by id.
  4743. *
  4744. * @param {string} modelName
  4745. * @param {string|number} id
  4746. * @returns {Promise<boolean>}
  4747. */
  4748. async deleteById(modelName, id) {
  4749. const table = this._getTableOrCreate(modelName);
  4750. const isExists = table.has(id);
  4751. table.delete(id);
  4752. return isExists;
  4753. }
  4754. /**
  4755. * Exists.
  4756. *
  4757. * @param {string} modelName
  4758. * @param {string|number} id
  4759. * @returns {Promise<boolean>}
  4760. */
  4761. async exists(modelName, id) {
  4762. const table = this._getTableOrCreate(modelName);
  4763. return table.has(id);
  4764. }
  4765. /**
  4766. * Count.
  4767. *
  4768. * @param {string} modelName
  4769. * @param {object|undefined} where
  4770. * @returns {Promise<number>}
  4771. */
  4772. async count(modelName, where = void 0) {
  4773. const table = this._getTableOrCreate(modelName);
  4774. const tableItems = Array.from(table.values());
  4775. let modelItems = tableItems.map(
  4776. (tableItem) => this.getService(ModelDefinitionUtils).convertColumnNamesToPropertyNames(
  4777. modelName,
  4778. tableItem
  4779. )
  4780. );
  4781. if (where && typeof where === "object")
  4782. modelItems = this.getService(WhereClauseTool).filter(modelItems, where);
  4783. return modelItems.length;
  4784. }
  4785. };
  4786. __name(_MemoryAdapter, "MemoryAdapter");
  4787. MemoryAdapter = _MemoryAdapter;
  4788. }
  4789. });
  4790. // import("./builtin/**/*-adapter.js") in src/adapter/adapter-loader.js
  4791. var globImport_builtin_adapter_js;
  4792. var init_ = __esm({
  4793. 'import("./builtin/**/*-adapter.js") in src/adapter/adapter-loader.js'() {
  4794. globImport_builtin_adapter_js = __glob({
  4795. "./builtin/memory-adapter.js": () => Promise.resolve().then(() => (init_memory_adapter(), memory_adapter_exports))
  4796. });
  4797. }
  4798. });
  4799. // src/adapter/adapter-loader.js
  4800. function findAdapterCtorInModule(module2) {
  4801. let adapterCtor;
  4802. if (!module2 || typeof module2 !== "object" || Array.isArray(module2)) return;
  4803. for (const ctor of Object.values(module2)) {
  4804. if (typeof ctor === "function" && Array.isArray(ctor.kinds) && Adapter.kinds.includes(ADAPTER_CLASS_NAME)) {
  4805. adapterCtor = ctor;
  4806. break;
  4807. }
  4808. }
  4809. return adapterCtor;
  4810. }
  4811. var import_js_service27, _AdapterLoader, AdapterLoader;
  4812. var init_adapter_loader = __esm({
  4813. "src/adapter/adapter-loader.js"() {
  4814. "use strict";
  4815. init_adapter();
  4816. import_js_service27 = require("@e22m4u/js-service");
  4817. init_adapter();
  4818. init_errors();
  4819. init_();
  4820. _AdapterLoader = class _AdapterLoader extends import_js_service27.Service {
  4821. /**
  4822. * Load by name.
  4823. *
  4824. * @param {string} adapterName
  4825. * @param {object|undefined} settings
  4826. * @returns {Promise<Adapter>}
  4827. */
  4828. async loadByName(adapterName, settings = void 0) {
  4829. if (!adapterName || typeof adapterName !== "string")
  4830. throw new InvalidArgumentError(
  4831. "The adapter name should be a non-empty String, but %v was given.",
  4832. adapterName
  4833. );
  4834. let adapterCtor;
  4835. try {
  4836. const module2 = await globImport_builtin_adapter_js(`./builtin/${adapterName}-adapter.js`);
  4837. adapterCtor = findAdapterCtorInModule(module2);
  4838. } catch (e) {
  4839. }
  4840. if (!adapterCtor)
  4841. try {
  4842. const module2 = await Promise.resolve().then(() => __toESM(require(`@e22m4u/js-repository-${adapterName}-adapter`)));
  4843. adapterCtor = findAdapterCtorInModule(module2);
  4844. } catch (e) {
  4845. }
  4846. if (!adapterCtor)
  4847. throw new InvalidArgumentError(
  4848. "The adapter %v is not found.",
  4849. adapterName
  4850. );
  4851. return new adapterCtor(this.container, settings);
  4852. }
  4853. };
  4854. __name(_AdapterLoader, "AdapterLoader");
  4855. AdapterLoader = _AdapterLoader;
  4856. __name(findAdapterCtorInModule, "findAdapterCtorInModule");
  4857. }
  4858. });
  4859. // src/adapter/adapter-registry.js
  4860. var import_js_service28, _AdapterRegistry, AdapterRegistry;
  4861. var init_adapter_registry = __esm({
  4862. "src/adapter/adapter-registry.js"() {
  4863. "use strict";
  4864. init_adapter();
  4865. import_js_service28 = require("@e22m4u/js-service");
  4866. init_adapter_loader();
  4867. init_definition();
  4868. _AdapterRegistry = class _AdapterRegistry extends import_js_service28.Service {
  4869. /**
  4870. * Adapters.
  4871. *
  4872. * @type {object}
  4873. */
  4874. _adapters = {};
  4875. /**
  4876. * Get adapter.
  4877. *
  4878. * @param {string} datasourceName
  4879. * @returns {Promise<Adapter>}
  4880. */
  4881. async getAdapter(datasourceName) {
  4882. let adapter = this._adapters[datasourceName];
  4883. if (adapter) return adapter;
  4884. const datasource = this.getService(DefinitionRegistry).getDatasource(datasourceName);
  4885. const adapterName = datasource.adapter;
  4886. adapter = await this.getService(AdapterLoader).loadByName(
  4887. adapterName,
  4888. datasource
  4889. );
  4890. this._adapters[datasourceName] = adapter;
  4891. return adapter;
  4892. }
  4893. };
  4894. __name(_AdapterRegistry, "AdapterRegistry");
  4895. AdapterRegistry = _AdapterRegistry;
  4896. }
  4897. });
  4898. // src/adapter/index.js
  4899. var init_adapter2 = __esm({
  4900. "src/adapter/index.js"() {
  4901. "use strict";
  4902. init_adapter();
  4903. init_adapter_loader();
  4904. init_adapter_registry();
  4905. }
  4906. });
  4907. // src/repository/repository.js
  4908. var import_js_service29, _Repository, Repository;
  4909. var init_repository = __esm({
  4910. "src/repository/repository.js"() {
  4911. "use strict";
  4912. import_js_service29 = require("@e22m4u/js-service");
  4913. init_adapter2();
  4914. init_adapter2();
  4915. init_errors();
  4916. init_definition();
  4917. _Repository = class _Repository extends import_js_service29.Service {
  4918. /**
  4919. * Model name.
  4920. *
  4921. * @type {string}
  4922. */
  4923. _modelName;
  4924. /**
  4925. * Model name.
  4926. *
  4927. * @returns {string}
  4928. */
  4929. get modelName() {
  4930. return this._modelName;
  4931. }
  4932. /**
  4933. * Datasource name.
  4934. *
  4935. * @type {string}
  4936. */
  4937. _datasourceName;
  4938. /**
  4939. * Datasource name.
  4940. *
  4941. * @returns {string}
  4942. */
  4943. get datasourceName() {
  4944. return this._datasourceName;
  4945. }
  4946. /**
  4947. * Constructor.
  4948. *
  4949. * @typedef {import('@e22m4u/js-service').ServiceContainer} ServiceContainer
  4950. * @param {ServiceContainer} container
  4951. * @param {string} modelName
  4952. */
  4953. constructor(container, modelName) {
  4954. super(container);
  4955. this._modelName = modelName;
  4956. const modelDef = this.getService(DefinitionRegistry).getModel(modelName);
  4957. const datasourceName = modelDef.datasource;
  4958. if (!datasourceName)
  4959. throw new InvalidArgumentError(
  4960. "The model %v does not have a specified datasource.",
  4961. modelName
  4962. );
  4963. this._datasourceName = datasourceName;
  4964. }
  4965. /**
  4966. * Get adapter.
  4967. *
  4968. * @returns {Adapter}
  4969. */
  4970. async getAdapter() {
  4971. return this.getService(AdapterRegistry).getAdapter(this.datasourceName);
  4972. }
  4973. /**
  4974. * Create.
  4975. *
  4976. * @param {object} data
  4977. * @param {object|undefined} filter
  4978. * @returns {Promise<object>}
  4979. */
  4980. async create(data, filter = void 0) {
  4981. const adapter = await this.getAdapter();
  4982. return adapter.create(this.modelName, data, filter);
  4983. }
  4984. /**
  4985. * Replace by id.
  4986. *
  4987. * @param {number|string} id
  4988. * @param {object} data
  4989. * @param {object|undefined} filter
  4990. * @returns {Promise<object>}
  4991. */
  4992. async replaceById(id, data, filter = void 0) {
  4993. const adapter = await this.getAdapter();
  4994. return adapter.replaceById(this.modelName, id, data, filter);
  4995. }
  4996. /**
  4997. * Replace or create.
  4998. *
  4999. * @param {object} data
  5000. * @param {object|undefined} filter
  5001. * @returns {Promise<object>}
  5002. */
  5003. async replaceOrCreate(data, filter = void 0) {
  5004. const adapter = await this.getAdapter();
  5005. return adapter.replaceOrCreate(this.modelName, data, filter);
  5006. }
  5007. /**
  5008. * Patch.
  5009. *
  5010. * @param {object} data
  5011. * @param {object|undefined} where
  5012. * @returns {Promise<number>}
  5013. */
  5014. async patch(data, where = void 0) {
  5015. const adapter = await this.getAdapter();
  5016. return adapter.patch(this.modelName, data, where);
  5017. }
  5018. /**
  5019. * Patch by id.
  5020. *
  5021. * @param {number|string} id
  5022. * @param {object} data
  5023. * @param {object|undefined} filter
  5024. * @returns {Promise<object>}
  5025. */
  5026. async patchById(id, data, filter = void 0) {
  5027. const adapter = await this.getAdapter();
  5028. return adapter.patchById(this.modelName, id, data, filter);
  5029. }
  5030. /**
  5031. * Find.
  5032. *
  5033. * @param {object|undefined} filter
  5034. * @returns {Promise<object[]>}
  5035. */
  5036. async find(filter = void 0) {
  5037. const adapter = await this.getAdapter();
  5038. return adapter.find(this.modelName, filter);
  5039. }
  5040. /**
  5041. * Find one.
  5042. *
  5043. * @param {object|undefined} filter
  5044. * @returns {Promise<object|undefined>}
  5045. */
  5046. async findOne(filter = void 0) {
  5047. const adapter = await this.getAdapter();
  5048. filter = filter != null ? filter : {};
  5049. filter.limit = 1;
  5050. const result = await adapter.find(this.modelName, filter);
  5051. return result.length ? result[0] : void 0;
  5052. }
  5053. /**
  5054. * Find by id.
  5055. *
  5056. * @param {number|string} id
  5057. * @param {object|undefined} filter
  5058. * @returns {Promise<object>}
  5059. */
  5060. async findById(id, filter = void 0) {
  5061. const adapter = await this.getAdapter();
  5062. return adapter.findById(this.modelName, id, filter);
  5063. }
  5064. /**
  5065. * Delete.
  5066. *
  5067. * @param {object|undefined} where
  5068. * @returns {Promise<number>}
  5069. */
  5070. async delete(where = void 0) {
  5071. const adapter = await this.getAdapter();
  5072. return adapter.delete(this.modelName, where);
  5073. }
  5074. /**
  5075. * Delete by id.
  5076. *
  5077. * @param {number|string} id
  5078. * @returns {Promise<boolean>}
  5079. */
  5080. async deleteById(id) {
  5081. const adapter = await this.getAdapter();
  5082. return adapter.deleteById(this.modelName, id);
  5083. }
  5084. /**
  5085. * Exists.
  5086. *
  5087. * @param {number|string} id
  5088. * @returns {Promise<boolean>}
  5089. */
  5090. async exists(id) {
  5091. const adapter = await this.getAdapter();
  5092. return adapter.exists(this.modelName, id);
  5093. }
  5094. /**
  5095. * Count.
  5096. *
  5097. * @param {object|undefined} where
  5098. * @returns {Promise<number>}
  5099. */
  5100. async count(where = void 0) {
  5101. const adapter = await this.getAdapter();
  5102. return adapter.count(this.modelName, where);
  5103. }
  5104. };
  5105. __name(_Repository, "Repository");
  5106. Repository = _Repository;
  5107. }
  5108. });
  5109. // src/repository/repository-registry.js
  5110. var import_js_service30, _RepositoryRegistry, RepositoryRegistry;
  5111. var init_repository_registry = __esm({
  5112. "src/repository/repository-registry.js"() {
  5113. "use strict";
  5114. import_js_service30 = require("@e22m4u/js-service");
  5115. init_repository();
  5116. init_utils();
  5117. init_errors();
  5118. _RepositoryRegistry = class _RepositoryRegistry extends import_js_service30.Service {
  5119. /**
  5120. * Repositories.
  5121. *
  5122. * @type {object}
  5123. */
  5124. _repositories = {};
  5125. /**
  5126. * Repository ctor.
  5127. *
  5128. * @type {typeof Repository}
  5129. * @private
  5130. */
  5131. _repositoryCtor = Repository;
  5132. /**
  5133. * Set repository ctor.
  5134. *
  5135. * @param {typeof Repository} ctor
  5136. */
  5137. setRepositoryCtor(ctor) {
  5138. if (!ctor || typeof ctor !== "function" || !(ctor.prototype instanceof Repository)) {
  5139. throw new InvalidArgumentError(
  5140. "The first argument of RepositoryRegistry.setRepositoryCtor must inherit from Repository class, but %v was given.",
  5141. ctor
  5142. );
  5143. }
  5144. this._repositoryCtor = ctor;
  5145. }
  5146. /**
  5147. * Get repository.
  5148. *
  5149. * @param {string} modelName
  5150. * @returns {Repository}
  5151. */
  5152. getRepository(modelName) {
  5153. const modelKey = modelNameToModelKey(modelName);
  5154. let repository = this._repositories[modelKey];
  5155. if (repository) return repository;
  5156. repository = new this._repositoryCtor(this.container, modelName);
  5157. this._repositories[modelKey] = repository;
  5158. return repository;
  5159. }
  5160. };
  5161. __name(_RepositoryRegistry, "RepositoryRegistry");
  5162. RepositoryRegistry = _RepositoryRegistry;
  5163. }
  5164. });
  5165. // src/repository/index.js
  5166. var init_repository2 = __esm({
  5167. "src/repository/index.js"() {
  5168. "use strict";
  5169. init_repository();
  5170. init_repository_registry();
  5171. }
  5172. });
  5173. // src/relations/has-one-resolver.js
  5174. var import_js_service31, _HasOneResolver, HasOneResolver;
  5175. var init_has_one_resolver = __esm({
  5176. "src/relations/has-one-resolver.js"() {
  5177. "use strict";
  5178. import_js_service31 = require("@e22m4u/js-service");
  5179. init_utils();
  5180. init_definition();
  5181. init_errors();
  5182. init_repository2();
  5183. init_definition();
  5184. _HasOneResolver = class _HasOneResolver extends import_js_service31.Service {
  5185. /**
  5186. * Include to.
  5187. *
  5188. * @param {object[]} entities
  5189. * @param {string} sourceName
  5190. * @param {string} targetName
  5191. * @param {string} relationName
  5192. * @param {string} foreignKey
  5193. * @param {object|undefined} scope
  5194. * @returns {Promise<void>}
  5195. */
  5196. async includeTo(entities, sourceName, targetName, relationName, foreignKey, scope = void 0) {
  5197. if (!entities || !Array.isArray(entities))
  5198. throw new InvalidArgumentError(
  5199. 'The parameter "entities" of HasOneResolver.includeTo requires an Array of Object, but %v was given.',
  5200. entities
  5201. );
  5202. if (!sourceName || typeof sourceName !== "string")
  5203. throw new InvalidArgumentError(
  5204. 'The parameter "sourceName" of HasOneResolver.includeTo requires a non-empty String, but %v was given.',
  5205. sourceName
  5206. );
  5207. if (!targetName || typeof targetName !== "string")
  5208. throw new InvalidArgumentError(
  5209. 'The parameter "targetName" of HasOneResolver.includeTo requires a non-empty String, but %v was given.',
  5210. targetName
  5211. );
  5212. if (!relationName || typeof relationName !== "string")
  5213. throw new InvalidArgumentError(
  5214. 'The parameter "relationName" of HasOneResolver.includeTo requires a non-empty String, but %v was given.',
  5215. relationName
  5216. );
  5217. if (!foreignKey || typeof foreignKey !== "string")
  5218. throw new InvalidArgumentError(
  5219. 'The parameter "foreignKey" of HasOneResolver.includeTo requires a non-empty String, but %v was given.',
  5220. foreignKey
  5221. );
  5222. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5223. throw new InvalidArgumentError(
  5224. 'The provided parameter "scope" of HasOneResolver.includeTo should be an Object, but %v was given.',
  5225. scope
  5226. );
  5227. const sourcePkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5228. sourceName
  5229. );
  5230. const sourceIds = [];
  5231. entities.forEach((entity) => {
  5232. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  5233. throw new InvalidArgumentError(
  5234. 'The parameter "entities" of HasOneResolver.includeTo requires an Array of Object, but %v was given.',
  5235. entity
  5236. );
  5237. const sourceId = entity[sourcePkPropName];
  5238. if (sourceIds.includes(sourceId)) return;
  5239. sourceIds.push(sourceId);
  5240. });
  5241. const promises = [];
  5242. const targetRepository = this.getService(RepositoryRegistry).getRepository(targetName);
  5243. scope = scope ? cloneDeep(scope) : {};
  5244. const targetBySourceId = /* @__PURE__ */ new Map();
  5245. sourceIds.forEach((sourceId) => {
  5246. const filter = cloneDeep(scope);
  5247. filter.where = {
  5248. and: [{ [foreignKey]: sourceId }, ...scope.where ? [scope.where] : []]
  5249. };
  5250. filter.limit = 1;
  5251. promises.push(
  5252. targetRepository.find(filter).then((result) => {
  5253. if (result.length) targetBySourceId.set(sourceId, result[0]);
  5254. })
  5255. );
  5256. });
  5257. await Promise.all(promises);
  5258. Array.from(targetBySourceId.keys()).forEach((sourceId) => {
  5259. const sources = entities.filter((v) => v[sourcePkPropName] === sourceId);
  5260. sources.forEach((v) => v[relationName] = targetBySourceId.get(sourceId));
  5261. });
  5262. }
  5263. /**
  5264. * Include polymorphic to.
  5265. *
  5266. * @param {object[]} entities
  5267. * @param {string} sourceName
  5268. * @param {string} targetName
  5269. * @param {string} relationName
  5270. * @param {string} foreignKey
  5271. * @param {string} discriminator
  5272. * @param {object|undefined} scope
  5273. * @returns {Promise<void>}
  5274. */
  5275. async includePolymorphicTo(entities, sourceName, targetName, relationName, foreignKey, discriminator, scope = void 0) {
  5276. if (!entities || !Array.isArray(entities))
  5277. throw new InvalidArgumentError(
  5278. 'The parameter "entities" of HasOneResolver.includePolymorphicTo requires an Array of Object, but %v was given.',
  5279. entities
  5280. );
  5281. if (!sourceName || typeof sourceName !== "string")
  5282. throw new InvalidArgumentError(
  5283. 'The parameter "sourceName" of HasOneResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5284. sourceName
  5285. );
  5286. if (!targetName || typeof targetName !== "string")
  5287. throw new InvalidArgumentError(
  5288. 'The parameter "targetName" of HasOneResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5289. targetName
  5290. );
  5291. if (!relationName || typeof relationName !== "string")
  5292. throw new InvalidArgumentError(
  5293. 'The parameter "relationName" of HasOneResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5294. relationName
  5295. );
  5296. if (!foreignKey || typeof foreignKey !== "string")
  5297. throw new InvalidArgumentError(
  5298. 'The parameter "foreignKey" of HasOneResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5299. foreignKey
  5300. );
  5301. if (!discriminator || typeof discriminator !== "string")
  5302. throw new InvalidArgumentError(
  5303. 'The parameter "discriminator" of HasOneResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5304. discriminator
  5305. );
  5306. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5307. throw new InvalidArgumentError(
  5308. 'The provided parameter "scope" of HasOneResolver.includePolymorphicTo should be an Object, but %v was given.',
  5309. scope
  5310. );
  5311. const sourcePkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5312. sourceName
  5313. );
  5314. const sourceIds = [];
  5315. entities.forEach((entity) => {
  5316. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  5317. throw new InvalidArgumentError(
  5318. 'The parameter "entities" of HasOneResolver.includePolymorphicTo requires an Array of Object, but %v was given.',
  5319. entity
  5320. );
  5321. const sourceId = entity[sourcePkPropName];
  5322. if (sourceIds.includes(sourceId)) return;
  5323. sourceIds.push(sourceId);
  5324. });
  5325. const promises = [];
  5326. const targetRepository = this.getService(RepositoryRegistry).getRepository(targetName);
  5327. scope = scope ? cloneDeep(scope) : {};
  5328. const targetBySourceId = /* @__PURE__ */ new Map();
  5329. sourceIds.forEach((sourceId) => {
  5330. const filter = cloneDeep(scope);
  5331. filter.where = {
  5332. and: [
  5333. { [foreignKey]: sourceId, [discriminator]: sourceName },
  5334. ...scope.where ? [scope.where] : []
  5335. ]
  5336. };
  5337. filter.limit = 1;
  5338. promises.push(
  5339. targetRepository.find(filter).then((result) => {
  5340. if (result.length) targetBySourceId.set(sourceId, result[0]);
  5341. })
  5342. );
  5343. });
  5344. await Promise.all(promises);
  5345. Array.from(targetBySourceId.keys()).forEach((sourceId) => {
  5346. const sources = entities.filter((v) => v[sourcePkPropName] === sourceId);
  5347. sources.forEach((v) => v[relationName] = targetBySourceId.get(sourceId));
  5348. });
  5349. }
  5350. /**
  5351. * Include polymorphic by relation name.
  5352. *
  5353. * @param {object[]} entities
  5354. * @param {string} sourceName
  5355. * @param {string} targetName
  5356. * @param {string} relationName
  5357. * @param {string} targetRelationName
  5358. * @param {object|undefined} scope
  5359. * @returns {Promise<void>}
  5360. */
  5361. async includePolymorphicByRelationName(entities, sourceName, targetName, relationName, targetRelationName, scope = void 0) {
  5362. if (!entities || !Array.isArray(entities))
  5363. throw new InvalidArgumentError(
  5364. 'The parameter "entities" of HasOneResolver.includePolymorphicByRelationName requires an Array of Object, but %v was given.',
  5365. entities
  5366. );
  5367. if (!sourceName || typeof sourceName !== "string")
  5368. throw new InvalidArgumentError(
  5369. 'The parameter "sourceName" of HasOneResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5370. sourceName
  5371. );
  5372. if (!targetName || typeof targetName !== "string")
  5373. throw new InvalidArgumentError(
  5374. 'The parameter "targetName" of HasOneResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5375. targetName
  5376. );
  5377. if (!relationName || typeof relationName !== "string")
  5378. throw new InvalidArgumentError(
  5379. 'The parameter "relationName" of HasOneResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5380. relationName
  5381. );
  5382. if (!targetRelationName || typeof targetRelationName !== "string")
  5383. throw new InvalidArgumentError(
  5384. 'The parameter "targetRelationName" of HasOneResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5385. targetRelationName
  5386. );
  5387. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5388. throw new InvalidArgumentError(
  5389. 'The provided parameter "scope" of HasOneResolver.includePolymorphicByRelationName should be an Object, but %v was given.',
  5390. scope
  5391. );
  5392. const targetRelationDef = this.getService(
  5393. ModelDefinitionUtils
  5394. ).getRelationDefinitionByName(targetName, targetRelationName);
  5395. if (targetRelationDef.type !== RelationType.BELONGS_TO)
  5396. throw new InvalidArgumentError(
  5397. 'The relation %v of the model %v is a polymorphic "hasOne" relation, so it requires the target relation %v to be a polymorphic "belongsTo", but %v type was given.',
  5398. relationName,
  5399. sourceName,
  5400. targetRelationName,
  5401. targetRelationDef.type
  5402. );
  5403. if (!targetRelationDef.polymorphic)
  5404. throw new InvalidArgumentError(
  5405. 'The relation %v of the model %v is a polymorphic "hasOne" relation, so it requires the target relation %v to be a polymorphic too.',
  5406. relationName,
  5407. sourceName,
  5408. targetRelationName
  5409. );
  5410. const foreignKey = targetRelationDef.foreignKey || `${targetRelationName}Id`;
  5411. const discriminator = targetRelationDef.discriminator || `${targetRelationName}Type`;
  5412. return this.includePolymorphicTo(
  5413. entities,
  5414. sourceName,
  5415. targetName,
  5416. relationName,
  5417. foreignKey,
  5418. discriminator,
  5419. scope
  5420. );
  5421. }
  5422. };
  5423. __name(_HasOneResolver, "HasOneResolver");
  5424. HasOneResolver = _HasOneResolver;
  5425. }
  5426. });
  5427. // src/relations/has-many-resolver.js
  5428. var import_js_service32, _HasManyResolver, HasManyResolver;
  5429. var init_has_many_resolver = __esm({
  5430. "src/relations/has-many-resolver.js"() {
  5431. "use strict";
  5432. import_js_service32 = require("@e22m4u/js-service");
  5433. init_utils();
  5434. init_definition();
  5435. init_errors();
  5436. init_repository2();
  5437. init_definition();
  5438. _HasManyResolver = class _HasManyResolver extends import_js_service32.Service {
  5439. /**
  5440. * Include to.
  5441. *
  5442. * @param {object[]} entities
  5443. * @param {string} sourceName
  5444. * @param {string} targetName
  5445. * @param {string} relationName
  5446. * @param {string} foreignKey
  5447. * @param {object|undefined} scope
  5448. * @returns {Promise<void>}
  5449. */
  5450. async includeTo(entities, sourceName, targetName, relationName, foreignKey, scope = void 0) {
  5451. if (!entities || !Array.isArray(entities))
  5452. throw new InvalidArgumentError(
  5453. 'The parameter "entities" of HasManyResolver.includeTo requires an Array of Object, but %v was given.',
  5454. entities
  5455. );
  5456. if (!sourceName || typeof sourceName !== "string")
  5457. throw new InvalidArgumentError(
  5458. 'The parameter "sourceName" of HasManyResolver.includeTo requires a non-empty String, but %v was given.',
  5459. sourceName
  5460. );
  5461. if (!targetName || typeof targetName !== "string")
  5462. throw new InvalidArgumentError(
  5463. 'The parameter "targetName" of HasManyResolver.includeTo requires a non-empty String, but %v was given.',
  5464. targetName
  5465. );
  5466. if (!relationName || typeof relationName !== "string")
  5467. throw new InvalidArgumentError(
  5468. 'The parameter "relationName" of HasManyResolver.includeTo requires a non-empty String, but %v was given.',
  5469. relationName
  5470. );
  5471. if (!foreignKey || typeof foreignKey !== "string")
  5472. throw new InvalidArgumentError(
  5473. 'The parameter "foreignKey" of HasManyResolver.includeTo requires a non-empty String, but %v was given.',
  5474. foreignKey
  5475. );
  5476. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5477. throw new InvalidArgumentError(
  5478. 'The provided parameter "scope" of HasManyResolver.includeTo should be an Object, but %v was given.',
  5479. scope
  5480. );
  5481. const sourcePkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5482. sourceName
  5483. );
  5484. const sourceIds = [];
  5485. entities.forEach((entity) => {
  5486. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  5487. throw new InvalidArgumentError(
  5488. 'The parameter "entities" of HasManyResolver.includeTo requires an Array of Object, but %v was given.',
  5489. entity
  5490. );
  5491. const sourceId = entity[sourcePkPropName];
  5492. if (sourceIds.includes(sourceId)) return;
  5493. sourceIds.push(sourceId);
  5494. });
  5495. const promises = [];
  5496. const targetRepository = this.getService(RepositoryRegistry).getRepository(targetName);
  5497. scope = scope ? cloneDeep(scope) : {};
  5498. const targetsBySourceId = /* @__PURE__ */ new Map();
  5499. sourceIds.forEach((sourceId) => {
  5500. const filter = cloneDeep(scope);
  5501. filter.where = {
  5502. and: [{ [foreignKey]: sourceId }, ...scope.where ? [scope.where] : []]
  5503. };
  5504. promises.push(
  5505. targetRepository.find(filter).then((result) => {
  5506. var _a;
  5507. if (result.length) {
  5508. let targets = (_a = targetsBySourceId.get(sourceId)) != null ? _a : [];
  5509. targets = [...targets, ...result];
  5510. targetsBySourceId.set(sourceId, targets);
  5511. }
  5512. })
  5513. );
  5514. });
  5515. await Promise.all(promises);
  5516. entities.forEach((entity) => {
  5517. var _a;
  5518. const sourceId = entity[sourcePkPropName];
  5519. entity[relationName] = (_a = targetsBySourceId.get(sourceId)) != null ? _a : [];
  5520. });
  5521. }
  5522. /**
  5523. * Include polymorphic to.
  5524. *
  5525. * @param {object[]} entities
  5526. * @param {string} sourceName
  5527. * @param {string} targetName
  5528. * @param {string} relationName
  5529. * @param {string} foreignKey
  5530. * @param {string} discriminator
  5531. * @param {object|undefined} scope
  5532. * @returns {Promise<void>}
  5533. */
  5534. async includePolymorphicTo(entities, sourceName, targetName, relationName, foreignKey, discriminator, scope = void 0) {
  5535. if (!entities || !Array.isArray(entities))
  5536. throw new InvalidArgumentError(
  5537. 'The parameter "entities" of HasManyResolver.includePolymorphicTo requires an Array of Object, but %v was given.',
  5538. entities
  5539. );
  5540. if (!sourceName || typeof sourceName !== "string")
  5541. throw new InvalidArgumentError(
  5542. 'The parameter "sourceName" of HasManyResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5543. sourceName
  5544. );
  5545. if (!targetName || typeof targetName !== "string")
  5546. throw new InvalidArgumentError(
  5547. 'The parameter "targetName" of HasManyResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5548. targetName
  5549. );
  5550. if (!relationName || typeof relationName !== "string")
  5551. throw new InvalidArgumentError(
  5552. 'The parameter "relationName" of HasManyResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5553. relationName
  5554. );
  5555. if (!foreignKey || typeof foreignKey !== "string")
  5556. throw new InvalidArgumentError(
  5557. 'The parameter "foreignKey" of HasManyResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5558. foreignKey
  5559. );
  5560. if (!discriminator || typeof discriminator !== "string")
  5561. throw new InvalidArgumentError(
  5562. 'The parameter "discriminator" of HasManyResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5563. discriminator
  5564. );
  5565. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5566. throw new InvalidArgumentError(
  5567. 'The provided parameter "scope" of HasManyResolver.includePolymorphicTo should be an Object, but %v was given.',
  5568. scope
  5569. );
  5570. const sourcePkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5571. sourceName
  5572. );
  5573. const sourceIds = [];
  5574. entities.forEach((entity) => {
  5575. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  5576. throw new InvalidArgumentError(
  5577. 'The parameter "entities" of HasManyResolver.includePolymorphicTo requires an Array of Object, but %v was given.',
  5578. entity
  5579. );
  5580. const sourceId = entity[sourcePkPropName];
  5581. if (sourceIds.includes(sourceId)) return;
  5582. sourceIds.push(sourceId);
  5583. });
  5584. const promises = [];
  5585. const targetRepository = this.getService(RepositoryRegistry).getRepository(targetName);
  5586. scope = scope ? cloneDeep(scope) : {};
  5587. const targetsBySourceId = /* @__PURE__ */ new Map();
  5588. sourceIds.forEach((sourceId) => {
  5589. const filter = cloneDeep(scope);
  5590. filter.where = {
  5591. and: [
  5592. { [foreignKey]: sourceId, [discriminator]: sourceName },
  5593. ...scope.where ? [scope.where] : []
  5594. ]
  5595. };
  5596. promises.push(
  5597. targetRepository.find(filter).then((result) => {
  5598. var _a;
  5599. if (result.length) {
  5600. let targets = (_a = targetsBySourceId.get(sourceId)) != null ? _a : [];
  5601. targets = [...targets, ...result];
  5602. targetsBySourceId.set(sourceId, targets);
  5603. }
  5604. })
  5605. );
  5606. });
  5607. await Promise.all(promises);
  5608. entities.forEach((entity) => {
  5609. var _a;
  5610. const sourceId = entity[sourcePkPropName];
  5611. entity[relationName] = (_a = targetsBySourceId.get(sourceId)) != null ? _a : [];
  5612. });
  5613. }
  5614. /**
  5615. * Include polymorphic by relation name.
  5616. *
  5617. * @param {object[]} entities
  5618. * @param {string} sourceName
  5619. * @param {string} targetName
  5620. * @param {string} relationName
  5621. * @param {string} targetRelationName
  5622. * @param {object|undefined} scope
  5623. * @returns {Promise<void>}
  5624. */
  5625. async includePolymorphicByRelationName(entities, sourceName, targetName, relationName, targetRelationName, scope = void 0) {
  5626. if (!entities || !Array.isArray(entities))
  5627. throw new InvalidArgumentError(
  5628. 'The parameter "entities" of HasManyResolver.includePolymorphicByRelationName requires an Array of Object, but %v was given.',
  5629. entities
  5630. );
  5631. if (!sourceName || typeof sourceName !== "string")
  5632. throw new InvalidArgumentError(
  5633. 'The parameter "sourceName" of HasManyResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5634. sourceName
  5635. );
  5636. if (!targetName || typeof targetName !== "string")
  5637. throw new InvalidArgumentError(
  5638. 'The parameter "targetName" of HasManyResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5639. targetName
  5640. );
  5641. if (!relationName || typeof relationName !== "string")
  5642. throw new InvalidArgumentError(
  5643. 'The parameter "relationName" of HasManyResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5644. relationName
  5645. );
  5646. if (!targetRelationName || typeof targetRelationName !== "string")
  5647. throw new InvalidArgumentError(
  5648. 'The parameter "targetRelationName" of HasManyResolver.includePolymorphicByRelationName requires a non-empty String, but %v was given.',
  5649. targetRelationName
  5650. );
  5651. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5652. throw new InvalidArgumentError(
  5653. 'The provided parameter "scope" of HasManyResolver.includePolymorphicByRelationName should be an Object, but %v was given.',
  5654. scope
  5655. );
  5656. const targetRelationDef = this.getService(
  5657. ModelDefinitionUtils
  5658. ).getRelationDefinitionByName(targetName, targetRelationName);
  5659. if (targetRelationDef.type !== RelationType.BELONGS_TO)
  5660. throw new InvalidArgumentError(
  5661. 'The relation %v of the model %v is a polymorphic "hasMany" relation, so it requires the target relation %v to be a polymorphic "belongsTo", but %v type was given.',
  5662. relationName,
  5663. sourceName,
  5664. targetRelationName,
  5665. targetRelationDef.type
  5666. );
  5667. if (!targetRelationDef.polymorphic)
  5668. throw new InvalidArgumentError(
  5669. 'The relation %v of the model %v is a polymorphic "hasMany" relation, so it requires the target relation %v to be a polymorphic too.',
  5670. relationName,
  5671. sourceName,
  5672. targetRelationName
  5673. );
  5674. const foreignKey = targetRelationDef.foreignKey || `${targetRelationName}Id`;
  5675. const discriminator = targetRelationDef.discriminator || `${targetRelationName}Type`;
  5676. return this.includePolymorphicTo(
  5677. entities,
  5678. sourceName,
  5679. targetName,
  5680. relationName,
  5681. foreignKey,
  5682. discriminator,
  5683. scope
  5684. );
  5685. }
  5686. };
  5687. __name(_HasManyResolver, "HasManyResolver");
  5688. HasManyResolver = _HasManyResolver;
  5689. }
  5690. });
  5691. // src/relations/belongs-to-resolver.js
  5692. var import_js_service33, _BelongsToResolver, BelongsToResolver;
  5693. var init_belongs_to_resolver = __esm({
  5694. "src/relations/belongs-to-resolver.js"() {
  5695. "use strict";
  5696. import_js_service33 = require("@e22m4u/js-service");
  5697. init_utils();
  5698. init_utils();
  5699. init_errors();
  5700. init_repository2();
  5701. init_definition();
  5702. _BelongsToResolver = class _BelongsToResolver extends import_js_service33.Service {
  5703. /**
  5704. * Include to.
  5705. *
  5706. * @param {object[]} entities
  5707. * @param {string} sourceName
  5708. * @param {string} targetName
  5709. * @param {string} relationName
  5710. * @param {string|undefined} foreignKey
  5711. * @param {object|undefined} scope
  5712. * @returns {Promise<void>}
  5713. */
  5714. async includeTo(entities, sourceName, targetName, relationName, foreignKey = void 0, scope = void 0) {
  5715. if (!entities || !Array.isArray(entities))
  5716. throw new InvalidArgumentError(
  5717. 'The parameter "entities" of BelongsToResolver.includeTo requires an Array of Object, but %v was given.',
  5718. entities
  5719. );
  5720. if (!sourceName || typeof sourceName !== "string")
  5721. throw new InvalidArgumentError(
  5722. 'The parameter "sourceName" of BelongsToResolver.includeTo requires a non-empty String, but %v was given.',
  5723. sourceName
  5724. );
  5725. if (!targetName || typeof targetName !== "string")
  5726. throw new InvalidArgumentError(
  5727. 'The parameter "targetName" of BelongsToResolver.includeTo requires a non-empty String, but %v was given.',
  5728. targetName
  5729. );
  5730. if (!relationName || typeof relationName !== "string")
  5731. throw new InvalidArgumentError(
  5732. 'The parameter "relationName" of BelongsToResolver.includeTo requires a non-empty String, but %v was given.',
  5733. relationName
  5734. );
  5735. if (foreignKey && typeof foreignKey !== "string")
  5736. throw new InvalidArgumentError(
  5737. 'The provided parameter "foreignKey" of BelongsToResolver.includeTo should be a String, but %v was given.',
  5738. foreignKey
  5739. );
  5740. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5741. throw new InvalidArgumentError(
  5742. 'The provided parameter "scope" of BelongsToResolver.includeTo should be an Object, but %v was given.',
  5743. scope
  5744. );
  5745. if (foreignKey == null) foreignKey = `${relationName}Id`;
  5746. const targetIds = entities.reduce((acc, entity) => {
  5747. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  5748. throw new InvalidArgumentError(
  5749. 'The parameter "entities" of BelongsToResolver.includeTo requires an Array of Object, but %v was given.',
  5750. entity
  5751. );
  5752. const targetId = entity[foreignKey];
  5753. return targetId != null ? [...acc, targetId] : acc;
  5754. }, []);
  5755. const targetRepository = this.getService(RepositoryRegistry).getRepository(targetName);
  5756. const targetPkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5757. targetName
  5758. );
  5759. scope = scope ? cloneDeep(scope) : {};
  5760. const filter = cloneDeep(scope);
  5761. filter.where = {
  5762. and: [
  5763. { [targetPkPropName]: { inq: targetIds } },
  5764. ...scope.where ? [scope.where] : []
  5765. ]
  5766. };
  5767. const targets = await targetRepository.find(filter);
  5768. entities.forEach((entity) => {
  5769. const target = targets.find(
  5770. (e) => e[targetPkPropName] === entity[foreignKey]
  5771. );
  5772. if (target) entity[relationName] = target;
  5773. });
  5774. }
  5775. /**
  5776. * Include polymorphic to.
  5777. *
  5778. * @param {object[]} entities
  5779. * @param {string} sourceName
  5780. * @param {string} relationName
  5781. * @param {string|undefined} foreignKey
  5782. * @param {string|undefined} discriminator
  5783. * @param {object|undefined} scope
  5784. * @returns {Promise<void>}
  5785. */
  5786. async includePolymorphicTo(entities, sourceName, relationName, foreignKey = void 0, discriminator = void 0, scope = void 0) {
  5787. if (!entities || !Array.isArray(entities))
  5788. throw new InvalidArgumentError(
  5789. 'The parameter "entities" of BelongsToResolver.includePolymorphicTo requires an Array of Object, but %v was given.',
  5790. entities
  5791. );
  5792. if (!sourceName || typeof sourceName !== "string")
  5793. throw new InvalidArgumentError(
  5794. 'The parameter "sourceName" of BelongsToResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5795. sourceName
  5796. );
  5797. if (!relationName || typeof relationName !== "string")
  5798. throw new InvalidArgumentError(
  5799. 'The parameter "relationName" of BelongsToResolver.includePolymorphicTo requires a non-empty String, but %v was given.',
  5800. relationName
  5801. );
  5802. if (foreignKey && typeof foreignKey !== "string")
  5803. throw new InvalidArgumentError(
  5804. 'The provided parameter "foreignKey" of BelongsToResolver.includePolymorphicTo should be a String, but %v was given.',
  5805. foreignKey
  5806. );
  5807. if (discriminator && typeof discriminator !== "string")
  5808. throw new InvalidArgumentError(
  5809. 'The provided parameter "discriminator" of BelongsToResolver.includePolymorphicTo should be a String, but %v was given.',
  5810. discriminator
  5811. );
  5812. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5813. throw new InvalidArgumentError(
  5814. 'The provided parameter "scope" of BelongsToResolver.includePolymorphicTo should be an Object, but %v was given.',
  5815. scope
  5816. );
  5817. if (foreignKey == null) {
  5818. const singularRelationName = singularize(relationName);
  5819. foreignKey = `${singularRelationName}Id`;
  5820. }
  5821. if (discriminator == null) {
  5822. const singularRelationName = singularize(relationName);
  5823. discriminator = `${singularRelationName}Type`;
  5824. }
  5825. const targetIdsByTargetName = {};
  5826. entities.forEach((entity) => {
  5827. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  5828. throw new InvalidArgumentError(
  5829. 'The parameter "entities" of BelongsToResolver.includePolymorphicTo requires an Array of Object, but %v was given.',
  5830. entity
  5831. );
  5832. const targetId = entity[foreignKey];
  5833. const targetName = entity[discriminator];
  5834. if (targetId == null || targetName == null) return;
  5835. if (targetIdsByTargetName[targetName] == null)
  5836. targetIdsByTargetName[targetName] = [];
  5837. if (!targetIdsByTargetName[targetName].includes(targetId))
  5838. targetIdsByTargetName[targetName].push(targetId);
  5839. });
  5840. const promises = [];
  5841. const targetNames = Object.keys(targetIdsByTargetName);
  5842. scope = scope ? cloneDeep(scope) : {};
  5843. const targetEntitiesByTargetNames = {};
  5844. targetNames.forEach((targetName) => {
  5845. let targetRepository;
  5846. try {
  5847. targetRepository = this.getService(RepositoryRegistry).getRepository(targetName);
  5848. } catch (error) {
  5849. if (error instanceof InvalidArgumentError) {
  5850. if (error.message === `The model "${targetName}" is not defined.` || error.message === `The model "${targetName}" does not have a specified datasource.`) {
  5851. return;
  5852. }
  5853. } else {
  5854. throw error;
  5855. }
  5856. }
  5857. const targetPkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5858. targetName
  5859. );
  5860. const targetFilter = cloneDeep(scope);
  5861. const targetIds = targetIdsByTargetName[targetName];
  5862. targetFilter.where = {
  5863. and: [
  5864. { [targetPkPropName]: { inq: targetIds } },
  5865. ...scope.where ? [scope.where] : []
  5866. ]
  5867. };
  5868. const promise = targetRepository.find(targetFilter).then((result) => {
  5869. var _a;
  5870. targetEntitiesByTargetNames[targetName] = [
  5871. ...(_a = targetEntitiesByTargetNames[targetName]) != null ? _a : [],
  5872. ...result
  5873. ];
  5874. });
  5875. promises.push(promise);
  5876. });
  5877. await Promise.all(promises);
  5878. entities.forEach((entity) => {
  5879. var _a;
  5880. const targetId = entity[foreignKey];
  5881. const targetName = entity[discriminator];
  5882. if (targetId == null || targetName == null || targetEntitiesByTargetNames[targetName] == null) {
  5883. return;
  5884. }
  5885. const targetEntities = (_a = targetEntitiesByTargetNames[targetName]) != null ? _a : [];
  5886. const targetPkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5887. targetName
  5888. );
  5889. const target = targetEntities.find((e) => e[targetPkPropName] === targetId);
  5890. if (target) entity[relationName] = target;
  5891. });
  5892. }
  5893. };
  5894. __name(_BelongsToResolver, "BelongsToResolver");
  5895. BelongsToResolver = _BelongsToResolver;
  5896. }
  5897. });
  5898. // src/relations/references-many-resolver.js
  5899. var import_js_service34, _ReferencesManyResolver, ReferencesManyResolver;
  5900. var init_references_many_resolver = __esm({
  5901. "src/relations/references-many-resolver.js"() {
  5902. "use strict";
  5903. import_js_service34 = require("@e22m4u/js-service");
  5904. init_utils();
  5905. init_utils();
  5906. init_errors();
  5907. init_repository2();
  5908. init_definition();
  5909. _ReferencesManyResolver = class _ReferencesManyResolver extends import_js_service34.Service {
  5910. /**
  5911. * Include to.
  5912. *
  5913. * @param {object[]} entities
  5914. * @param {string} sourceName
  5915. * @param {string} targetName
  5916. * @param {string} relationName
  5917. * @param {string|undefined} foreignKey
  5918. * @param {object|undefined} scope
  5919. * @returns {Promise<void>}
  5920. */
  5921. async includeTo(entities, sourceName, targetName, relationName, foreignKey = void 0, scope = void 0) {
  5922. if (!entities || !Array.isArray(entities))
  5923. throw new InvalidArgumentError(
  5924. 'The parameter "entities" of ReferencesManyResolver.includeTo requires an Array of Object, but %v was given.',
  5925. entities
  5926. );
  5927. if (!sourceName || typeof sourceName !== "string")
  5928. throw new InvalidArgumentError(
  5929. 'The parameter "sourceName" of ReferencesManyResolver.includeTo requires a non-empty String, but %v was given.',
  5930. sourceName
  5931. );
  5932. if (!targetName || typeof targetName !== "string")
  5933. throw new InvalidArgumentError(
  5934. 'The parameter "targetName" of ReferencesManyResolver.includeTo requires a non-empty String, but %v was given.',
  5935. targetName
  5936. );
  5937. if (!relationName || typeof relationName !== "string")
  5938. throw new InvalidArgumentError(
  5939. 'The parameter "relationName" of ReferencesManyResolver.includeTo requires a non-empty String, but %v was given.',
  5940. relationName
  5941. );
  5942. if (foreignKey && typeof foreignKey !== "string")
  5943. throw new InvalidArgumentError(
  5944. 'The provided parameter "foreignKey" of ReferencesManyResolver.includeTo should be a String, but %v was given.',
  5945. foreignKey
  5946. );
  5947. if (scope && (typeof scope !== "object" || Array.isArray(scope)))
  5948. throw new InvalidArgumentError(
  5949. 'The provided parameter "scope" of ReferencesManyResolver.includeTo should be an Object, but %v was given.',
  5950. scope
  5951. );
  5952. if (foreignKey == null) {
  5953. const singularRelationName = singularize(relationName);
  5954. foreignKey = `${singularRelationName}Ids`;
  5955. }
  5956. const targetIds = entities.reduce((acc, entity) => {
  5957. if (!entity || typeof entity !== "object" || Array.isArray(entity))
  5958. throw new InvalidArgumentError(
  5959. 'The parameter "entities" of ReferencesManyResolver.includeTo requires an Array of Object, but %v was given.',
  5960. entity
  5961. );
  5962. const ids = entity[foreignKey];
  5963. if (Array.isArray(ids))
  5964. ids.forEach((id) => {
  5965. if (id == null || acc.includes(id)) return;
  5966. acc.push(id);
  5967. });
  5968. return acc;
  5969. }, []);
  5970. const targetRepository = this.getService(RepositoryRegistry).getRepository(targetName);
  5971. const targetPkPropName = this.getService(ModelDefinitionUtils).getPrimaryKeyAsPropertyName(
  5972. targetName
  5973. );
  5974. scope = scope ? cloneDeep(scope) : {};
  5975. const filter = cloneDeep(scope);
  5976. filter.where = {
  5977. and: [
  5978. { [targetPkPropName]: { inq: targetIds } },
  5979. ...scope.where ? [scope.where] : []
  5980. ]
  5981. };
  5982. const targets = await targetRepository.find(filter);
  5983. entities.forEach((entity) => {
  5984. const ids = entity[foreignKey];
  5985. entity[relationName] = [];
  5986. if (Array.isArray(ids))
  5987. targets.forEach((target) => {
  5988. const targetId = target[targetPkPropName];
  5989. if (ids.includes(targetId)) entity[relationName].push(target);
  5990. });
  5991. });
  5992. }
  5993. };
  5994. __name(_ReferencesManyResolver, "ReferencesManyResolver");
  5995. ReferencesManyResolver = _ReferencesManyResolver;
  5996. }
  5997. });
  5998. // src/relations/index.js
  5999. var init_relations2 = __esm({
  6000. "src/relations/index.js"() {
  6001. "use strict";
  6002. init_has_one_resolver();
  6003. init_has_many_resolver();
  6004. init_belongs_to_resolver();
  6005. init_references_many_resolver();
  6006. }
  6007. });
  6008. // src/filter/include-clause-tool.js
  6009. var import_js_service35, _IncludeClauseTool, IncludeClauseTool;
  6010. var init_include_clause_tool = __esm({
  6011. "src/filter/include-clause-tool.js"() {
  6012. "use strict";
  6013. import_js_service35 = require("@e22m4u/js-service");
  6014. init_definition();
  6015. init_relations2();
  6016. init_relations2();
  6017. init_where_clause_tool();
  6018. init_order_clause_tool();
  6019. init_slice_clause_tool();
  6020. init_errors();
  6021. init_relations2();
  6022. init_fields_clause_tool();
  6023. init_definition();
  6024. init_relations2();
  6025. _IncludeClauseTool = class _IncludeClauseTool extends import_js_service35.Service {
  6026. /**
  6027. * Include to.
  6028. *
  6029. * @param {object[]} entities
  6030. * @param {string} modelName
  6031. * @param {IncludeClause|undefined} clause
  6032. * @returns {Promise<void>}
  6033. */
  6034. async includeTo(entities, modelName, clause) {
  6035. clause = _IncludeClauseTool.normalizeIncludeClause(clause);
  6036. const promises = [];
  6037. clause.forEach((inclusion) => {
  6038. const relDef = this.getService(
  6039. ModelDefinitionUtils
  6040. ).getRelationDefinitionByName(modelName, inclusion.relation);
  6041. switch (relDef.type) {
  6042. // BELONGS_TO
  6043. case RelationType.BELONGS_TO:
  6044. if (relDef.polymorphic) {
  6045. promises.push(
  6046. this.getService(BelongsToResolver).includePolymorphicTo(
  6047. entities,
  6048. modelName,
  6049. inclusion.relation,
  6050. relDef.foreignKey,
  6051. relDef.discriminator,
  6052. inclusion.scope
  6053. )
  6054. );
  6055. } else {
  6056. promises.push(
  6057. this.getService(BelongsToResolver).includeTo(
  6058. entities,
  6059. modelName,
  6060. relDef.model,
  6061. inclusion.relation,
  6062. relDef.foreignKey,
  6063. inclusion.scope
  6064. )
  6065. );
  6066. }
  6067. break;
  6068. // HAS_ONE
  6069. case RelationType.HAS_ONE:
  6070. if (relDef.polymorphic && typeof relDef.polymorphic === "string") {
  6071. promises.push(
  6072. this.getService(HasOneResolver).includePolymorphicByRelationName(
  6073. entities,
  6074. modelName,
  6075. relDef.model,
  6076. inclusion.relation,
  6077. relDef.polymorphic,
  6078. inclusion.scope
  6079. )
  6080. );
  6081. } else if (relDef.polymorphic) {
  6082. promises.push(
  6083. this.getService(HasOneResolver).includePolymorphicTo(
  6084. entities,
  6085. modelName,
  6086. relDef.model,
  6087. inclusion.relation,
  6088. relDef.foreignKey,
  6089. relDef.discriminator,
  6090. inclusion.scope
  6091. )
  6092. );
  6093. } else {
  6094. promises.push(
  6095. this.getService(HasOneResolver).includeTo(
  6096. entities,
  6097. modelName,
  6098. relDef.model,
  6099. inclusion.relation,
  6100. relDef.foreignKey,
  6101. inclusion.scope
  6102. )
  6103. );
  6104. }
  6105. break;
  6106. // HAS_MANY
  6107. case RelationType.HAS_MANY:
  6108. if (relDef.polymorphic && typeof relDef.polymorphic === "string") {
  6109. promises.push(
  6110. this.getService(HasManyResolver).includePolymorphicByRelationName(
  6111. entities,
  6112. modelName,
  6113. relDef.model,
  6114. inclusion.relation,
  6115. relDef.polymorphic,
  6116. inclusion.scope
  6117. )
  6118. );
  6119. } else if (relDef.polymorphic) {
  6120. promises.push(
  6121. this.getService(HasManyResolver).includePolymorphicTo(
  6122. entities,
  6123. modelName,
  6124. relDef.model,
  6125. inclusion.relation,
  6126. relDef.foreignKey,
  6127. relDef.discriminator,
  6128. inclusion.scope
  6129. )
  6130. );
  6131. } else {
  6132. promises.push(
  6133. this.getService(HasManyResolver).includeTo(
  6134. entities,
  6135. modelName,
  6136. relDef.model,
  6137. inclusion.relation,
  6138. relDef.foreignKey,
  6139. inclusion.scope
  6140. )
  6141. );
  6142. }
  6143. break;
  6144. case RelationType.REFERENCES_MANY:
  6145. promises.push(
  6146. this.getService(ReferencesManyResolver).includeTo(
  6147. entities,
  6148. modelName,
  6149. relDef.model,
  6150. inclusion.relation,
  6151. relDef.foreignKey,
  6152. inclusion.scope
  6153. )
  6154. );
  6155. break;
  6156. default:
  6157. throw new InvalidArgumentError(
  6158. "The relation type %v does not have an inclusion resolver.",
  6159. relDef.type
  6160. );
  6161. }
  6162. });
  6163. await Promise.all(promises);
  6164. }
  6165. /**
  6166. * Validate include clause.
  6167. *
  6168. * @param {IncludeClause|undefined} clause
  6169. */
  6170. static validateIncludeClause(clause) {
  6171. if (clause == null) {
  6172. } else if (clause && typeof clause === "string") {
  6173. } else if (Array.isArray(clause)) {
  6174. const relNames = [];
  6175. clause.flat(Infinity).forEach((el) => {
  6176. this.validateIncludeClause(el);
  6177. if (typeof el === "string") {
  6178. relNames.push(el);
  6179. } else if (typeof el === "object") {
  6180. Object.keys(el).forEach((key) => {
  6181. if (Object.prototype.hasOwnProperty.call(el, key))
  6182. relNames.push(key);
  6183. });
  6184. }
  6185. });
  6186. const duplicateNames = relNames.filter(
  6187. (name, i) => relNames.indexOf(name) !== i
  6188. );
  6189. if (duplicateNames.length)
  6190. throw new InvalidArgumentError(
  6191. 'The provided option "include" has duplicates of %v.',
  6192. duplicateNames[0]
  6193. );
  6194. } else if (typeof clause === "object") {
  6195. if ("relation" in clause) {
  6196. if (!clause.relation || typeof clause.relation !== "string")
  6197. throw new InvalidArgumentError(
  6198. 'The provided option "relation" should be a non-empty String, but %v was given.',
  6199. clause.relation
  6200. );
  6201. if ("scope" in clause && clause) this.validateScopeClause(clause.scope);
  6202. } else {
  6203. Object.keys(clause).forEach((key) => {
  6204. if (!Object.prototype.hasOwnProperty.call(clause, key)) return;
  6205. this.validateIncludeClause(key);
  6206. this.validateIncludeClause(clause[key]);
  6207. });
  6208. }
  6209. } else {
  6210. throw new InvalidArgumentError(
  6211. 'The provided option "include" should have a non-empty String, an Object or an Array, but %v was given.',
  6212. clause
  6213. );
  6214. }
  6215. }
  6216. /**
  6217. * Validate scope clause.
  6218. *
  6219. * @param {object|undefined} clause
  6220. */
  6221. static validateScopeClause(clause) {
  6222. if (clause == null) return;
  6223. if (typeof clause !== "object" || Array.isArray(clause))
  6224. throw new InvalidArgumentError(
  6225. 'The provided option "scope" should be an Object, but %v was given.',
  6226. clause
  6227. );
  6228. if (clause.where != null) {
  6229. WhereClauseTool.validateWhereClause(clause.where);
  6230. }
  6231. if (clause.order != null) {
  6232. OrderClauseTool.validateOrderClause(clause.order);
  6233. }
  6234. if (clause.skip != null) {
  6235. SliceClauseTool.validateSkipClause(clause.skip);
  6236. }
  6237. if (clause.limit != null) {
  6238. SliceClauseTool.validateLimitClause(clause.limit);
  6239. }
  6240. if (clause.fields != null) {
  6241. FieldsClauseTool.validateFieldsClause(clause.fields);
  6242. }
  6243. if (clause.include != null) {
  6244. _IncludeClauseTool.validateIncludeClause(clause.include);
  6245. }
  6246. }
  6247. /**
  6248. * Normalize include clause.
  6249. *
  6250. * @param {IncludeClause|undefined} clause
  6251. * @returns {object[]}
  6252. */
  6253. static normalizeIncludeClause(clause) {
  6254. let result = [];
  6255. if (clause == null) {
  6256. return result;
  6257. } else if (clause && typeof clause === "string") {
  6258. result.push({ relation: clause });
  6259. } else if (Array.isArray(clause)) {
  6260. clause.flat(Infinity).forEach((el) => {
  6261. el = this.normalizeIncludeClause(el);
  6262. result = [...result, ...el];
  6263. });
  6264. const relNames = result.map((v) => v.relation);
  6265. const duplicateNames = relNames.filter(
  6266. (name, i) => relNames.indexOf(name) !== i
  6267. );
  6268. if (duplicateNames.length)
  6269. throw new InvalidArgumentError(
  6270. 'The provided option "include" has duplicates of %v.',
  6271. duplicateNames[0]
  6272. );
  6273. } else if (typeof clause === "object") {
  6274. if ("relation" in clause) {
  6275. if (!clause.relation || typeof clause.relation !== "string")
  6276. throw new InvalidArgumentError(
  6277. 'The provided option "relation" should be a non-empty String, but %v was given.',
  6278. clause.relation
  6279. );
  6280. const normalized = { relation: clause.relation };
  6281. const scope = this.normalizeScopeClause(clause.scope);
  6282. if (scope) normalized.scope = scope;
  6283. result.push(normalized);
  6284. } else {
  6285. Object.keys(clause).forEach((key) => {
  6286. if (!Object.prototype.hasOwnProperty.call(clause, key)) return;
  6287. this.validateIncludeClause(key);
  6288. const normalized = { relation: key };
  6289. const include = this.normalizeIncludeClause(clause[key]);
  6290. if (include.length) normalized.scope = { include };
  6291. result.push(normalized);
  6292. });
  6293. }
  6294. } else {
  6295. throw new InvalidArgumentError(
  6296. 'The provided option "include" should have a non-empty String, an Object or an Array, but %v was given.',
  6297. clause
  6298. );
  6299. }
  6300. return result;
  6301. }
  6302. /**
  6303. * Normalize scope clause.
  6304. *
  6305. * @param {object|undefined} clause
  6306. * @returns {object|undefined}
  6307. */
  6308. static normalizeScopeClause(clause) {
  6309. if (clause == null) return;
  6310. if (typeof clause !== "object" || Array.isArray(clause))
  6311. throw new InvalidArgumentError(
  6312. 'The provided option "scope" should be an Object, but %v was given.',
  6313. clause
  6314. );
  6315. const result = {};
  6316. if (clause.where != null) {
  6317. WhereClauseTool.validateWhereClause(clause.where);
  6318. result.where = clause.where;
  6319. }
  6320. if (clause.order != null) {
  6321. OrderClauseTool.validateOrderClause(clause.order);
  6322. result.order = clause.order;
  6323. }
  6324. if (clause.skip != null) {
  6325. SliceClauseTool.validateSkipClause(clause.skip);
  6326. result.skip = clause.skip;
  6327. }
  6328. if (clause.limit != null) {
  6329. SliceClauseTool.validateLimitClause(clause.limit);
  6330. result.limit = clause.limit;
  6331. }
  6332. if (clause.fields != null) {
  6333. FieldsClauseTool.validateFieldsClause(clause.fields);
  6334. result.fields = clause.fields;
  6335. }
  6336. if (clause.include != null) {
  6337. result.include = this.normalizeIncludeClause(clause.include);
  6338. }
  6339. if (Object.keys(result).length) return result;
  6340. return void 0;
  6341. }
  6342. };
  6343. __name(_IncludeClauseTool, "IncludeClauseTool");
  6344. IncludeClauseTool = _IncludeClauseTool;
  6345. }
  6346. });
  6347. // src/filter/index.js
  6348. var init_filter = __esm({
  6349. "src/filter/index.js"() {
  6350. "use strict";
  6351. init_slice_clause_tool();
  6352. init_order_clause_tool();
  6353. init_where_clause_tool();
  6354. init_fields_clause_tool();
  6355. init_include_clause_tool();
  6356. init_operator_clause_tool();
  6357. }
  6358. });
  6359. // src/index.js
  6360. var index_exports = {};
  6361. __export(index_exports, {
  6362. ADAPTER_CLASS_NAME: () => ADAPTER_CLASS_NAME,
  6363. Adapter: () => Adapter,
  6364. AdapterLoader: () => AdapterLoader,
  6365. AdapterRegistry: () => AdapterRegistry,
  6366. BelongsToResolver: () => BelongsToResolver,
  6367. DEFAULT_PRIMARY_KEY_PROPERTY_NAME: () => DEFAULT_PRIMARY_KEY_PROPERTY_NAME,
  6368. DataType: () => DataType,
  6369. DatabaseSchema: () => DatabaseSchema,
  6370. DatasourceDefinitionValidator: () => DatasourceDefinitionValidator,
  6371. DecoratorTargetType: () => DecoratorTargetType,
  6372. DefinitionRegistry: () => DefinitionRegistry,
  6373. FieldsClauseTool: () => FieldsClauseTool,
  6374. HasManyResolver: () => HasManyResolver,
  6375. HasOneResolver: () => HasOneResolver,
  6376. IncludeClauseTool: () => IncludeClauseTool,
  6377. InvalidArgumentError: () => InvalidArgumentError,
  6378. InvalidOperatorValueError: () => InvalidOperatorValueError,
  6379. ModelDataSanitizer: () => ModelDataSanitizer,
  6380. ModelDataTransformer: () => ModelDataTransformer,
  6381. ModelDataValidator: () => ModelDataValidator,
  6382. ModelDefinitionUtils: () => ModelDefinitionUtils,
  6383. ModelDefinitionValidator: () => ModelDefinitionValidator,
  6384. NotImplementedError: () => NotImplementedError,
  6385. OperatorClauseTool: () => OperatorClauseTool,
  6386. OrderClauseTool: () => OrderClauseTool,
  6387. PrimaryKeysDefinitionValidator: () => PrimaryKeysDefinitionValidator,
  6388. PropertiesDefinitionValidator: () => PropertiesDefinitionValidator,
  6389. PropertyTransformerRegistry: () => PropertyTransformerRegistry,
  6390. PropertyUniqueness: () => PropertyUniqueness,
  6391. PropertyUniquenessValidator: () => PropertyUniquenessValidator,
  6392. PropertyValidatorRegistry: () => PropertyValidatorRegistry,
  6393. ReferencesManyResolver: () => ReferencesManyResolver,
  6394. RelationType: () => RelationType,
  6395. RelationsDefinitionValidator: () => RelationsDefinitionValidator,
  6396. Repository: () => Repository,
  6397. RepositoryRegistry: () => RepositoryRegistry,
  6398. SliceClauseTool: () => SliceClauseTool,
  6399. WhereClauseTool: () => WhereClauseTool,
  6400. capitalize: () => capitalize,
  6401. cloneDeep: () => cloneDeep,
  6402. excludeObjectKeys: () => excludeObjectKeys,
  6403. getCtorName: () => getCtorName,
  6404. getDecoratorTargetType: () => getDecoratorTargetType,
  6405. getValueByPath: () => getValueByPath,
  6406. isCtor: () => isCtor,
  6407. isDeepEqual: () => isDeepEqual,
  6408. isPromise: () => isPromise,
  6409. isPureObject: () => isPureObject,
  6410. likeToRegexp: () => likeToRegexp,
  6411. modelNameToModelKey: () => modelNameToModelKey,
  6412. selectObjectKeys: () => selectObjectKeys,
  6413. singularize: () => singularize,
  6414. stringToRegexp: () => stringToRegexp,
  6415. transformPromise: () => transformPromise
  6416. });
  6417. module.exports = __toCommonJS(index_exports);
  6418. init_utils();
  6419. init_errors();
  6420. init_filter();
  6421. init_adapter2();
  6422. // src/database-schema.js
  6423. var import_js_service36 = require("@e22m4u/js-service");
  6424. init_repository2();
  6425. init_definition();
  6426. init_repository2();
  6427. var _DatabaseSchema = class _DatabaseSchema extends import_js_service36.Service {
  6428. /**
  6429. * Define datasource.
  6430. *
  6431. * @param {object} datasourceDef
  6432. * @returns {this}
  6433. */
  6434. defineDatasource(datasourceDef) {
  6435. this.getService(DefinitionRegistry).addDatasource(datasourceDef);
  6436. return this;
  6437. }
  6438. /**
  6439. * Define model.
  6440. *
  6441. * @param {object} modelDef
  6442. * @returns {this}
  6443. */
  6444. defineModel(modelDef) {
  6445. this.getService(DefinitionRegistry).addModel(modelDef);
  6446. return this;
  6447. }
  6448. /**
  6449. * Get repository.
  6450. *
  6451. * @param {string} modelName
  6452. * @returns {Repository}
  6453. */
  6454. getRepository(modelName) {
  6455. return this.getService(RepositoryRegistry).getRepository(modelName);
  6456. }
  6457. };
  6458. __name(_DatabaseSchema, "DatabaseSchema");
  6459. var DatabaseSchema = _DatabaseSchema;
  6460. // src/index.js
  6461. init_relations2();
  6462. init_definition();
  6463. init_repository2();
  6464. // Annotate the CommonJS export names for ESM import in node:
  6465. 0 && (module.exports = {
  6466. ADAPTER_CLASS_NAME,
  6467. Adapter,
  6468. AdapterLoader,
  6469. AdapterRegistry,
  6470. BelongsToResolver,
  6471. DEFAULT_PRIMARY_KEY_PROPERTY_NAME,
  6472. DataType,
  6473. DatabaseSchema,
  6474. DatasourceDefinitionValidator,
  6475. DecoratorTargetType,
  6476. DefinitionRegistry,
  6477. FieldsClauseTool,
  6478. HasManyResolver,
  6479. HasOneResolver,
  6480. IncludeClauseTool,
  6481. InvalidArgumentError,
  6482. InvalidOperatorValueError,
  6483. ModelDataSanitizer,
  6484. ModelDataTransformer,
  6485. ModelDataValidator,
  6486. ModelDefinitionUtils,
  6487. ModelDefinitionValidator,
  6488. NotImplementedError,
  6489. OperatorClauseTool,
  6490. OrderClauseTool,
  6491. PrimaryKeysDefinitionValidator,
  6492. PropertiesDefinitionValidator,
  6493. PropertyTransformerRegistry,
  6494. PropertyUniqueness,
  6495. PropertyUniquenessValidator,
  6496. PropertyValidatorRegistry,
  6497. ReferencesManyResolver,
  6498. RelationType,
  6499. RelationsDefinitionValidator,
  6500. Repository,
  6501. RepositoryRegistry,
  6502. SliceClauseTool,
  6503. WhereClauseTool,
  6504. capitalize,
  6505. cloneDeep,
  6506. excludeObjectKeys,
  6507. getCtorName,
  6508. getDecoratorTargetType,
  6509. getValueByPath,
  6510. isCtor,
  6511. isDeepEqual,
  6512. isPromise,
  6513. isPureObject,
  6514. likeToRegexp,
  6515. modelNameToModelKey,
  6516. selectObjectKeys,
  6517. singularize,
  6518. stringToRegexp,
  6519. transformPromise
  6520. });