has-one-resolver.spec.js 74 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274
  1. import {expect} from 'chai';
  2. import {format} from '@e22m4u/format';
  3. import {DataType} from '../definition/index.js';
  4. import {RelationType} from '../definition/index.js';
  5. import {HasOneResolver} from './has-one-resolver.js';
  6. import {RepositoriesSchema} from '../schema/index.js';
  7. import {DEFAULT_PRIMARY_KEY_PROPERTY_NAME as DEF_PK} from '../definition/index.js';
  8. describe('HasOneResolver', function () {
  9. describe('includeTo', function () {
  10. it('requires the "entities" parameter to be an array', async function () {
  11. const S = new RepositoriesSchema();
  12. const R = S.getService(HasOneResolver);
  13. const error = v =>
  14. format(
  15. 'The parameter "entities" of HasOneResolver.includeTo requires ' +
  16. 'an Array of Object, but %s given.',
  17. v,
  18. );
  19. const throwable = v =>
  20. R.includeTo(
  21. v,
  22. 'sourceName',
  23. 'targetName',
  24. 'relationName',
  25. 'foreignKey',
  26. );
  27. await expect(throwable('')).to.be.rejectedWith(error('""'));
  28. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  29. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  30. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  31. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  32. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  33. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  34. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  35. });
  36. it('requires elements of the "entities" parameter to be an Object', async function () {
  37. const S = new RepositoriesSchema();
  38. S.defineModel({name: 'source'});
  39. const R = S.getService(HasOneResolver);
  40. const error = v =>
  41. format(
  42. 'The parameter "entities" of HasOneResolver.includeTo requires ' +
  43. 'an Array of Object, but %s given.',
  44. v,
  45. );
  46. const throwable = v =>
  47. R.includeTo([v], 'source', 'target', 'relationName', 'foreignKey');
  48. await expect(throwable('')).to.be.rejectedWith(error('""'));
  49. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  50. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  51. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  52. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  53. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  54. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  55. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  56. });
  57. it('requires the "sourceName" parameter to be a non-empty string', async function () {
  58. const S = new RepositoriesSchema();
  59. const R = S.getService(HasOneResolver);
  60. const error = v =>
  61. format(
  62. 'The parameter "sourceName" of HasOneResolver.includeTo requires ' +
  63. 'a non-empty String, but %s given.',
  64. v,
  65. );
  66. const throwable = v =>
  67. R.includeTo([], v, 'targetName', 'relationName', 'foreignKey');
  68. await expect(throwable('')).to.be.rejectedWith(error('""'));
  69. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  70. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  71. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  72. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  73. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  74. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  75. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  76. });
  77. it('requires the "targetName" parameter to be a non-empty string', async function () {
  78. const S = new RepositoriesSchema();
  79. const R = S.getService(HasOneResolver);
  80. const error = v =>
  81. format(
  82. 'The parameter "targetName" of HasOneResolver.includeTo requires ' +
  83. 'a non-empty String, but %s given.',
  84. v,
  85. );
  86. const throwable = v =>
  87. R.includeTo([], 'sourceName', v, 'relationName', 'foreignKey');
  88. await expect(throwable('')).to.be.rejectedWith(error('""'));
  89. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  90. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  91. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  92. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  93. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  94. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  95. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  96. });
  97. it('requires the "relationName" parameter to be a non-empty string', async function () {
  98. const S = new RepositoriesSchema();
  99. const R = S.getService(HasOneResolver);
  100. const error = v =>
  101. format(
  102. 'The parameter "relationName" of HasOneResolver.includeTo requires ' +
  103. 'a non-empty String, but %s given.',
  104. v,
  105. );
  106. const throwable = v =>
  107. R.includeTo([], 'sourceName', 'targetName', v, 'foreignKey');
  108. await expect(throwable('')).to.be.rejectedWith(error('""'));
  109. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  110. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  111. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  112. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  113. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  114. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  115. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  116. });
  117. it('requires the "foreignKey" parameter to be a non-empty string', async function () {
  118. const S = new RepositoriesSchema();
  119. const R = S.getService(HasOneResolver);
  120. const error = v =>
  121. format(
  122. 'The parameter "foreignKey" of HasOneResolver.includeTo requires ' +
  123. 'a non-empty String, but %s given.',
  124. v,
  125. );
  126. const throwable = v =>
  127. R.includeTo([], 'sourceName', 'targetName', 'relationName', v);
  128. await expect(throwable('')).to.be.rejectedWith(error('""'));
  129. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  130. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  131. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  132. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  133. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  134. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  135. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  136. });
  137. it('requires the provided parameter "scope" to be an object', async function () {
  138. const S = new RepositoriesSchema();
  139. const R = S.getService(HasOneResolver);
  140. const error = v =>
  141. format(
  142. 'The provided parameter "scope" of HasOneResolver.includeTo ' +
  143. 'should be an Object, but %s given.',
  144. v,
  145. );
  146. const throwable = v =>
  147. R.includeTo(
  148. [],
  149. 'sourceName',
  150. 'targetName',
  151. 'relationName',
  152. 'foreignKey',
  153. v,
  154. );
  155. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  156. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  157. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  158. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  159. });
  160. it('throws an error if a target model is not found', async function () {
  161. const S = new RepositoriesSchema();
  162. S.defineModel({name: 'source'});
  163. const R = S.getService(HasOneResolver);
  164. const promise = R.includeTo(
  165. [],
  166. 'source',
  167. 'target',
  168. 'relationName',
  169. 'foreignKey',
  170. );
  171. await expect(promise).to.be.rejectedWith(
  172. 'The model "target" is not defined',
  173. );
  174. });
  175. it('throws an error if a target model does not have datasource', async function () {
  176. const S = new RepositoriesSchema();
  177. S.defineModel({name: 'source'});
  178. S.defineModel({name: 'target'});
  179. const R = S.getService(HasOneResolver);
  180. const promise = R.includeTo(
  181. [],
  182. 'source',
  183. 'target',
  184. 'relationName',
  185. 'foreignKey',
  186. );
  187. await expect(promise).to.be.rejectedWith(
  188. 'The model "target" does not have a specified datasource.',
  189. );
  190. });
  191. it('does not throw an error if a relation target is not exist', async function () {
  192. const S = new RepositoriesSchema();
  193. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  194. S.defineModel({name: 'source', datasource: 'datasource'});
  195. S.defineModel({name: 'target', datasource: 'datasource'});
  196. const sourceRel = S.getRepository('source');
  197. const source = await sourceRel.create({});
  198. const R = S.getService(HasOneResolver);
  199. await R.includeTo([source], 'source', 'target', 'child', 'parentId');
  200. expect(source).to.be.eql({
  201. [DEF_PK]: source[DEF_PK],
  202. });
  203. });
  204. it('includes if a primary key is not defined in the source model', async function () {
  205. const S = new RepositoriesSchema();
  206. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  207. S.defineModel({name: 'source', datasource: 'datasource'});
  208. S.defineModel({name: 'target', datasource: 'datasource'});
  209. const sourceRep = S.getRepository('source');
  210. const targetRep = S.getRepository('target');
  211. const source = await sourceRep.create({});
  212. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  213. const target = await targetRep.create({parentId: source[DEF_PK]});
  214. expect(target).to.be.eql({
  215. [DEF_PK]: target[DEF_PK],
  216. parentId: source[DEF_PK],
  217. });
  218. const R = S.getService(HasOneResolver);
  219. await R.includeTo([source], 'source', 'target', 'child', 'parentId');
  220. expect(source).to.be.eql({
  221. [DEF_PK]: source[DEF_PK],
  222. child: {
  223. id: target[DEF_PK],
  224. parentId: source[DEF_PK],
  225. },
  226. });
  227. });
  228. it('includes if the source model has a custom primary key', async function () {
  229. const S = new RepositoriesSchema();
  230. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  231. S.defineModel({
  232. name: 'source',
  233. datasource: 'datasource',
  234. properties: {
  235. myId: {
  236. type: DataType.NUMBER,
  237. primaryKey: true,
  238. },
  239. },
  240. });
  241. S.defineModel({name: 'target', datasource: 'datasource'});
  242. const sourceRep = S.getRepository('source');
  243. const targetRep = S.getRepository('target');
  244. const source = await sourceRep.create({});
  245. expect(source).to.be.eql({myId: source.myId});
  246. const target = await targetRep.create({parentId: source.myId});
  247. expect(target).to.be.eql({
  248. [DEF_PK]: target[DEF_PK],
  249. parentId: source.myId,
  250. });
  251. const R = S.getService(HasOneResolver);
  252. await R.includeTo([source], 'source', 'target', 'child', 'parentId');
  253. expect(source).to.be.eql({
  254. myId: source.myId,
  255. child: {
  256. [DEF_PK]: target[DEF_PK],
  257. parentId: source.myId,
  258. },
  259. });
  260. });
  261. it('includes if the target model has a custom primary key', async function () {
  262. const S = new RepositoriesSchema();
  263. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  264. S.defineModel({name: 'source', datasource: 'datasource'});
  265. S.defineModel({
  266. name: 'target',
  267. datasource: 'datasource',
  268. properties: {
  269. myId: {
  270. type: DataType.NUMBER,
  271. primaryKey: true,
  272. },
  273. },
  274. });
  275. const sourceRep = S.getRepository('source');
  276. const targetRep = S.getRepository('target');
  277. const source = await sourceRep.create({});
  278. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  279. const target = await targetRep.create({parentId: source[DEF_PK]});
  280. expect(target).to.be.eql({
  281. myId: target.myId,
  282. parentId: source[DEF_PK],
  283. });
  284. const R = S.getService(HasOneResolver);
  285. await R.includeTo([source], 'source', 'target', 'child', 'parentId');
  286. expect(source).to.be.eql({
  287. [DEF_PK]: source[DEF_PK],
  288. child: {
  289. myId: target.myId,
  290. parentId: source[DEF_PK],
  291. },
  292. });
  293. });
  294. it('uses a where clause of the given scope to filter the relation target', async function () {
  295. const S = new RepositoriesSchema();
  296. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  297. S.defineModel({name: 'source', datasource: 'datasource'});
  298. S.defineModel({name: 'target', datasource: 'datasource'});
  299. const sourceRep = S.getRepository('source');
  300. const targetRep = S.getRepository('target');
  301. const source = await sourceRep.create({});
  302. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  303. const target1 = await targetRep.create({
  304. featured: false,
  305. parentId: source[DEF_PK],
  306. });
  307. expect(target1).to.be.eql({
  308. [DEF_PK]: target1[DEF_PK],
  309. featured: false,
  310. parentId: source[DEF_PK],
  311. });
  312. const target2 = await targetRep.create({
  313. featured: true,
  314. parentId: source[DEF_PK],
  315. });
  316. expect(target2).to.be.eql({
  317. [DEF_PK]: target2[DEF_PK],
  318. featured: true,
  319. parentId: source[DEF_PK],
  320. });
  321. const R = S.getService(HasOneResolver);
  322. await R.includeTo([source], 'source', 'target', 'child', 'parentId', {
  323. where: {featured: false},
  324. });
  325. expect(source).to.be.eql({
  326. [DEF_PK]: source[DEF_PK],
  327. child: {
  328. [DEF_PK]: target1[DEF_PK],
  329. featured: false,
  330. parentId: source[DEF_PK],
  331. },
  332. });
  333. await R.includeTo([source], 'source', 'target', 'child', 'parentId', {
  334. where: {featured: true},
  335. });
  336. expect(source).to.be.eql({
  337. [DEF_PK]: source[DEF_PK],
  338. child: {
  339. [DEF_PK]: target2[DEF_PK],
  340. featured: true,
  341. parentId: source[DEF_PK],
  342. },
  343. });
  344. });
  345. it('uses a fields clause of the given scope to filter the relation target', async function () {
  346. const S = new RepositoriesSchema();
  347. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  348. S.defineModel({name: 'source', datasource: 'datasource'});
  349. S.defineModel({name: 'target', datasource: 'datasource'});
  350. const sourceRep = S.getRepository('source');
  351. const targetRep = S.getRepository('target');
  352. const source = await sourceRep.create({});
  353. expect(source).to.be.eql({
  354. [DEF_PK]: source[DEF_PK],
  355. });
  356. const target = await targetRep.create({
  357. foo: 'fooVal',
  358. bar: 'barVal',
  359. parentId: source[DEF_PK],
  360. });
  361. expect(target).to.be.eql({
  362. [DEF_PK]: target[DEF_PK],
  363. foo: target.foo,
  364. bar: target.bar,
  365. parentId: source[DEF_PK],
  366. });
  367. const R = S.getService(HasOneResolver);
  368. await R.includeTo([source], 'source', 'target', 'child', 'parentId', {
  369. fields: [DEF_PK, 'bar'],
  370. });
  371. expect(source).to.be.eql({
  372. [DEF_PK]: source[DEF_PK],
  373. child: {
  374. [DEF_PK]: target[DEF_PK],
  375. bar: target.bar,
  376. },
  377. });
  378. });
  379. it('uses an include clause of the given scope to resolve target relations', async function () {
  380. const S = new RepositoriesSchema();
  381. S.defineDatasource({
  382. name: 'datasource',
  383. adapter: 'memory',
  384. });
  385. S.defineModel({
  386. name: 'modelA',
  387. datasource: 'datasource',
  388. properties: {
  389. id: {
  390. type: DataType.NUMBER,
  391. primaryKey: true,
  392. },
  393. source: {
  394. type: DataType.STRING,
  395. default: 'modelA',
  396. },
  397. },
  398. relations: {
  399. child: {
  400. type: RelationType.HAS_ONE,
  401. model: 'modelB',
  402. foreignKey: 'parentId',
  403. },
  404. },
  405. });
  406. S.defineModel({
  407. name: 'modelB',
  408. datasource: 'datasource',
  409. properties: {
  410. id: {
  411. type: DataType.NUMBER,
  412. primaryKey: true,
  413. },
  414. source: {
  415. type: DataType.STRING,
  416. default: 'modelB',
  417. },
  418. },
  419. relations: {
  420. child: {
  421. type: RelationType.HAS_ONE,
  422. model: 'modelC',
  423. foreignKey: 'parentId',
  424. },
  425. },
  426. });
  427. S.defineModel({
  428. name: 'modelC',
  429. datasource: 'datasource',
  430. properties: {
  431. id: {
  432. type: DataType.NUMBER,
  433. primaryKey: true,
  434. },
  435. source: {
  436. type: DataType.STRING,
  437. default: 'modelC',
  438. },
  439. },
  440. });
  441. const aRep = S.getRepository('modelA');
  442. const bRep = S.getRepository('modelB');
  443. const cRep = S.getRepository('modelC');
  444. const a = await aRep.create({});
  445. const b = await bRep.create({parentId: a.id});
  446. const c = await cRep.create({parentId: b.id});
  447. expect(a).to.be.eql({
  448. id: a.id,
  449. source: 'modelA',
  450. });
  451. expect(b).to.be.eql({
  452. id: b.id,
  453. source: 'modelB',
  454. parentId: a.id,
  455. });
  456. expect(c).to.be.eql({
  457. id: c.id,
  458. source: 'modelC',
  459. parentId: b.id,
  460. });
  461. const R = S.getService(HasOneResolver);
  462. await R.includeTo([a], 'modelA', 'modelB', 'child', 'parentId', {
  463. include: 'child',
  464. });
  465. expect(a).to.be.eql({
  466. id: a.id,
  467. source: 'modelA',
  468. child: {
  469. id: b.id,
  470. source: 'modelB',
  471. parentId: a.id,
  472. child: {
  473. id: c.id,
  474. source: 'modelC',
  475. parentId: b.id,
  476. },
  477. },
  478. });
  479. });
  480. it('does not break the "and" operator of the given "where" clause', async function () {
  481. const S = new RepositoriesSchema();
  482. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  483. S.defineModel({name: 'source', datasource: 'datasource'});
  484. S.defineModel({name: 'target', datasource: 'datasource'});
  485. const sourceRep = S.getRepository('source');
  486. const targetRep = S.getRepository('target');
  487. const source = await sourceRep.create({});
  488. expect(source).to.be.eql({
  489. [DEF_PK]: source[DEF_PK],
  490. });
  491. const target1 = await targetRep.create({
  492. featured: false,
  493. parentId: source[DEF_PK],
  494. });
  495. expect(target1).to.be.eql({
  496. [DEF_PK]: target1[DEF_PK],
  497. featured: false,
  498. parentId: source[DEF_PK],
  499. });
  500. const target2 = await targetRep.create({
  501. featured: true,
  502. parentId: source[DEF_PK],
  503. });
  504. expect(target2).to.be.eql({
  505. [DEF_PK]: target2[DEF_PK],
  506. featured: true,
  507. parentId: source[DEF_PK],
  508. });
  509. const R = S.getService(HasOneResolver);
  510. await R.includeTo([source], 'source', 'target', 'child', 'parentId', {
  511. where: {and: [{featured: false}]},
  512. });
  513. expect(source).to.be.eql({
  514. [DEF_PK]: source[DEF_PK],
  515. child: {
  516. [DEF_PK]: target1[DEF_PK],
  517. featured: false,
  518. parentId: source[DEF_PK],
  519. },
  520. });
  521. delete source.child;
  522. await R.includeTo([source], 'source', 'target', 'child', 'parentId', {
  523. where: {and: [{featured: true}]},
  524. });
  525. expect(source).to.be.eql({
  526. [DEF_PK]: source[DEF_PK],
  527. child: {
  528. [DEF_PK]: target2[DEF_PK],
  529. featured: true,
  530. parentId: source[DEF_PK],
  531. },
  532. });
  533. });
  534. });
  535. describe('includePolymorphicTo', function () {
  536. it('requires the "entities" parameter to be an array', async function () {
  537. const S = new RepositoriesSchema();
  538. const R = S.getService(HasOneResolver);
  539. const error = v =>
  540. format(
  541. 'The parameter "entities" of HasOneResolver.includePolymorphicTo requires ' +
  542. 'an Array of Object, but %s given.',
  543. v,
  544. );
  545. const throwable = v =>
  546. R.includePolymorphicTo(
  547. v,
  548. 'sourceName',
  549. 'targetName',
  550. 'relationName',
  551. 'foreignKey',
  552. 'discriminator',
  553. );
  554. await expect(throwable('')).to.be.rejectedWith(error('""'));
  555. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  556. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  557. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  558. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  559. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  560. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  561. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  562. });
  563. it('requires elements of the "entities" parameter to be an Object', async function () {
  564. const S = new RepositoriesSchema();
  565. S.defineModel({name: 'source'});
  566. const R = S.getService(HasOneResolver);
  567. const error = v =>
  568. format(
  569. 'The parameter "entities" of HasOneResolver.includePolymorphicTo requires ' +
  570. 'an Array of Object, but %s given.',
  571. v,
  572. );
  573. const throwable = v =>
  574. R.includePolymorphicTo(
  575. [v],
  576. 'source',
  577. 'target',
  578. 'relationName',
  579. 'foreignKey',
  580. 'discriminator',
  581. );
  582. await expect(throwable('')).to.be.rejectedWith(error('""'));
  583. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  584. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  585. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  586. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  587. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  588. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  589. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  590. });
  591. it('requires the "sourceName" parameter to be a non-empty string', async function () {
  592. const S = new RepositoriesSchema();
  593. const R = S.getService(HasOneResolver);
  594. const error = v =>
  595. format(
  596. 'The parameter "sourceName" of HasOneResolver.includePolymorphicTo requires ' +
  597. 'a non-empty String, but %s given.',
  598. v,
  599. );
  600. const throwable = v =>
  601. R.includePolymorphicTo(
  602. [],
  603. v,
  604. 'targetName',
  605. 'relationName',
  606. 'foreignKey',
  607. 'discriminator',
  608. );
  609. await expect(throwable('')).to.be.rejectedWith(error('""'));
  610. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  611. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  612. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  613. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  614. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  615. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  616. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  617. });
  618. it('requires the "targetName" parameter to be a non-empty string', async function () {
  619. const S = new RepositoriesSchema();
  620. const R = S.getService(HasOneResolver);
  621. const error = v =>
  622. format(
  623. 'The parameter "targetName" of HasOneResolver.includePolymorphicTo requires ' +
  624. 'a non-empty String, but %s given.',
  625. v,
  626. );
  627. const throwable = v =>
  628. R.includePolymorphicTo(
  629. [],
  630. 'sourceName',
  631. v,
  632. 'relationName',
  633. 'foreignKey',
  634. 'discriminator',
  635. );
  636. await expect(throwable('')).to.be.rejectedWith(error('""'));
  637. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  638. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  639. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  640. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  641. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  642. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  643. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  644. });
  645. it('requires the "relationName" parameter to be a non-empty string', async function () {
  646. const S = new RepositoriesSchema();
  647. const R = S.getService(HasOneResolver);
  648. const error = v =>
  649. format(
  650. 'The parameter "relationName" of HasOneResolver.includePolymorphicTo requires ' +
  651. 'a non-empty String, but %s given.',
  652. v,
  653. );
  654. const throwable = v =>
  655. R.includePolymorphicTo(
  656. [],
  657. 'sourceName',
  658. 'targetName',
  659. v,
  660. 'foreignKey',
  661. 'discriminator',
  662. );
  663. await expect(throwable('')).to.be.rejectedWith(error('""'));
  664. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  665. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  666. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  667. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  668. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  669. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  670. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  671. });
  672. it('requires the "foreignKey" parameter to be a non-empty string', async function () {
  673. const S = new RepositoriesSchema();
  674. const R = S.getService(HasOneResolver);
  675. const error = v =>
  676. format(
  677. 'The parameter "foreignKey" of HasOneResolver.includePolymorphicTo requires ' +
  678. 'a non-empty String, but %s given.',
  679. v,
  680. );
  681. const throwable = v =>
  682. R.includePolymorphicTo(
  683. [],
  684. 'sourceName',
  685. 'targetName',
  686. 'relationName',
  687. v,
  688. 'discriminator',
  689. );
  690. await expect(throwable('')).to.be.rejectedWith(error('""'));
  691. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  692. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  693. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  694. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  695. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  696. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  697. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  698. });
  699. it('requires the "discriminator" parameter to be a non-empty string', async function () {
  700. const S = new RepositoriesSchema();
  701. const R = S.getService(HasOneResolver);
  702. const error = v =>
  703. format(
  704. 'The parameter "discriminator" of HasOneResolver.includePolymorphicTo requires ' +
  705. 'a non-empty String, but %s given.',
  706. v,
  707. );
  708. const throwable = v =>
  709. R.includePolymorphicTo(
  710. [],
  711. 'sourceName',
  712. 'targetName',
  713. 'relationName',
  714. 'foreignKey',
  715. v,
  716. );
  717. await expect(throwable('')).to.be.rejectedWith(error('""'));
  718. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  719. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  720. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  721. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  722. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  723. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  724. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  725. });
  726. it('requires the provided parameter "scope" to be an object', async function () {
  727. const S = new RepositoriesSchema();
  728. const R = S.getService(HasOneResolver);
  729. const error = v =>
  730. format(
  731. 'The provided parameter "scope" of HasOneResolver.includePolymorphicTo ' +
  732. 'should be an Object, but %s given.',
  733. v,
  734. );
  735. const throwable = v =>
  736. R.includePolymorphicTo(
  737. [],
  738. 'sourceName',
  739. 'targetName',
  740. 'relationName',
  741. 'foreignKey',
  742. 'discriminator',
  743. v,
  744. );
  745. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  746. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  747. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  748. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  749. });
  750. it('throws an error if the given target model is not found', async function () {
  751. const S = new RepositoriesSchema();
  752. S.defineModel({name: 'source'});
  753. const R = S.getService(HasOneResolver);
  754. const entity = {[DEF_PK]: 1};
  755. const promise = R.includePolymorphicTo(
  756. [entity],
  757. 'source',
  758. 'target',
  759. 'child',
  760. 'parentId',
  761. 'parentType',
  762. );
  763. await expect(promise).to.be.rejectedWith(
  764. 'The model "target" is not defined',
  765. );
  766. });
  767. it('throws an error if the given target model does not have a datasource', async function () {
  768. const S = new RepositoriesSchema();
  769. S.defineModel({name: 'source'});
  770. S.defineModel({name: 'target'});
  771. const R = S.getService(HasOneResolver);
  772. const entity = {[DEF_PK]: 1};
  773. const promise = R.includePolymorphicTo(
  774. [entity],
  775. 'source',
  776. 'target',
  777. 'child',
  778. 'parentId',
  779. 'parentType',
  780. );
  781. await expect(promise).to.be.rejectedWith(
  782. 'The model "target" does not have a specified datasource.',
  783. );
  784. });
  785. it('does not throw an error if a relation target is not found', async function () {
  786. const S = new RepositoriesSchema();
  787. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  788. S.defineModel({name: 'source', datasource: 'datasource'});
  789. S.defineModel({name: 'target', datasource: 'datasource'});
  790. const sourceRel = S.getRepository('source');
  791. const source = await sourceRel.create({});
  792. expect(source).to.be.eql({
  793. [DEF_PK]: source[DEF_PK],
  794. });
  795. const R = S.getService(HasOneResolver);
  796. await R.includePolymorphicTo(
  797. [source],
  798. 'source',
  799. 'target',
  800. 'child',
  801. 'parentId',
  802. 'parentType',
  803. );
  804. expect(source).to.be.eql({
  805. [DEF_PK]: source[DEF_PK],
  806. });
  807. });
  808. it('does not include an entity with a not matched discriminator value', async function () {
  809. const S = new RepositoriesSchema();
  810. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  811. S.defineModel({name: 'source', datasource: 'datasource'});
  812. S.defineModel({name: 'target', datasource: 'datasource'});
  813. const sourceRel = S.getRepository('source');
  814. const targetRel = S.getRepository('target');
  815. const source = await sourceRel.create({});
  816. expect(source).to.be.eql({
  817. [DEF_PK]: source[DEF_PK],
  818. });
  819. const target = await targetRel.create({
  820. parentId: source[DEF_PK],
  821. parentType: 'unknown',
  822. });
  823. expect(target).to.be.eql({
  824. [DEF_PK]: target[DEF_PK],
  825. parentId: source[DEF_PK],
  826. parentType: 'unknown',
  827. });
  828. const R = S.getService(HasOneResolver);
  829. await R.includePolymorphicTo(
  830. [source],
  831. 'source',
  832. 'target',
  833. 'child',
  834. 'parentId',
  835. 'parentType',
  836. );
  837. expect(source).to.be.eql({
  838. [DEF_PK]: source[DEF_PK],
  839. });
  840. });
  841. it('includes if a primary key is not defined in the source model', async function () {
  842. const S = new RepositoriesSchema();
  843. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  844. S.defineModel({name: 'source', datasource: 'datasource'});
  845. S.defineModel({name: 'target', datasource: 'datasource'});
  846. const sourceRep = S.getRepository('source');
  847. const targetRep = S.getRepository('target');
  848. const source = await sourceRep.create({});
  849. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  850. const target = await targetRep.create({
  851. parentId: source[DEF_PK],
  852. parentType: 'source',
  853. });
  854. expect(target).to.be.eql({
  855. [DEF_PK]: target[DEF_PK],
  856. parentId: source[DEF_PK],
  857. parentType: target.parentType,
  858. });
  859. const R = S.getService(HasOneResolver);
  860. await R.includePolymorphicTo(
  861. [source],
  862. 'source',
  863. 'target',
  864. 'child',
  865. 'parentId',
  866. 'parentType',
  867. );
  868. expect(source).to.be.eql({
  869. [DEF_PK]: source[DEF_PK],
  870. child: {
  871. id: target[DEF_PK],
  872. parentId: source[DEF_PK],
  873. parentType: target.parentType,
  874. },
  875. });
  876. });
  877. it('includes if the source model has a custom primary key', async function () {
  878. const S = new RepositoriesSchema();
  879. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  880. S.defineModel({
  881. name: 'source',
  882. datasource: 'datasource',
  883. properties: {
  884. myId: {
  885. type: DataType.NUMBER,
  886. primaryKey: true,
  887. },
  888. },
  889. });
  890. S.defineModel({name: 'target', datasource: 'datasource'});
  891. const sourceRep = S.getRepository('source');
  892. const targetRep = S.getRepository('target');
  893. const source = await sourceRep.create({});
  894. expect(source).to.be.eql({myId: source.myId});
  895. const target = await targetRep.create({
  896. parentId: source.myId,
  897. parentType: 'source',
  898. });
  899. expect(target).to.be.eql({
  900. [DEF_PK]: target[DEF_PK],
  901. parentId: source.myId,
  902. parentType: target.parentType,
  903. });
  904. const R = S.getService(HasOneResolver);
  905. await R.includePolymorphicTo(
  906. [source],
  907. 'source',
  908. 'target',
  909. 'child',
  910. 'parentId',
  911. 'parentType',
  912. );
  913. expect(source).to.be.eql({
  914. myId: source.myId,
  915. child: {
  916. [DEF_PK]: target[DEF_PK],
  917. parentId: source.myId,
  918. parentType: target.parentType,
  919. },
  920. });
  921. });
  922. it('includes if the target model has a custom primary key', async function () {
  923. const S = new RepositoriesSchema();
  924. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  925. S.defineModel({name: 'source', datasource: 'datasource'});
  926. S.defineModel({
  927. name: 'target',
  928. datasource: 'datasource',
  929. properties: {
  930. myId: {
  931. type: DataType.NUMBER,
  932. primaryKey: true,
  933. },
  934. },
  935. });
  936. const sourceRep = S.getRepository('source');
  937. const targetRep = S.getRepository('target');
  938. const source = await sourceRep.create({});
  939. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  940. const target = await targetRep.create({
  941. parentId: source[DEF_PK],
  942. parentType: 'source',
  943. });
  944. expect(target).to.be.eql({
  945. myId: target.myId,
  946. parentId: source[DEF_PK],
  947. parentType: target.parentType,
  948. });
  949. const R = S.getService(HasOneResolver);
  950. await R.includePolymorphicTo(
  951. [source],
  952. 'source',
  953. 'target',
  954. 'child',
  955. 'parentId',
  956. 'parentType',
  957. );
  958. expect(source).to.be.eql({
  959. [DEF_PK]: source[DEF_PK],
  960. child: {
  961. myId: target.myId,
  962. parentId: source[DEF_PK],
  963. parentType: target.parentType,
  964. },
  965. });
  966. });
  967. it('uses a where clause of the given scope to filter the relation target', async function () {
  968. const S = new RepositoriesSchema();
  969. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  970. S.defineModel({name: 'source', datasource: 'datasource'});
  971. S.defineModel({name: 'target', datasource: 'datasource'});
  972. const sourceRep = S.getRepository('source');
  973. const targetRep = S.getRepository('target');
  974. const source = await sourceRep.create({});
  975. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  976. const target1 = await targetRep.create({
  977. featured: false,
  978. parentId: source[DEF_PK],
  979. parentType: 'source',
  980. });
  981. expect(target1).to.be.eql({
  982. [DEF_PK]: target1[DEF_PK],
  983. featured: false,
  984. parentId: source[DEF_PK],
  985. parentType: target1.parentType,
  986. });
  987. const target2 = await targetRep.create({
  988. featured: true,
  989. parentId: source[DEF_PK],
  990. parentType: 'source',
  991. });
  992. expect(target2).to.be.eql({
  993. [DEF_PK]: target2[DEF_PK],
  994. featured: true,
  995. parentId: source[DEF_PK],
  996. parentType: target2.parentType,
  997. });
  998. const R = S.getService(HasOneResolver);
  999. await R.includePolymorphicTo(
  1000. [source],
  1001. 'source',
  1002. 'target',
  1003. 'child',
  1004. 'parentId',
  1005. 'parentType',
  1006. {where: {featured: false}},
  1007. );
  1008. expect(source).to.be.eql({
  1009. [DEF_PK]: source[DEF_PK],
  1010. child: {
  1011. [DEF_PK]: target1[DEF_PK],
  1012. featured: false,
  1013. parentId: source[DEF_PK],
  1014. parentType: target1.parentType,
  1015. },
  1016. });
  1017. await R.includePolymorphicTo(
  1018. [source],
  1019. 'source',
  1020. 'target',
  1021. 'child',
  1022. 'parentId',
  1023. 'parentType',
  1024. {where: {featured: true}},
  1025. );
  1026. expect(source).to.be.eql({
  1027. [DEF_PK]: source[DEF_PK],
  1028. child: {
  1029. [DEF_PK]: target2[DEF_PK],
  1030. featured: true,
  1031. parentId: source[DEF_PK],
  1032. parentType: target2.parentType,
  1033. },
  1034. });
  1035. });
  1036. it('uses a fields clause of the given scope to filter the relation target', async function () {
  1037. const S = new RepositoriesSchema();
  1038. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1039. S.defineModel({name: 'source', datasource: 'datasource'});
  1040. S.defineModel({name: 'target', datasource: 'datasource'});
  1041. const sourceRep = S.getRepository('source');
  1042. const targetRep = S.getRepository('target');
  1043. const source = await sourceRep.create({});
  1044. expect(source).to.be.eql({
  1045. [DEF_PK]: source[DEF_PK],
  1046. });
  1047. const target = await targetRep.create({
  1048. foo: 'fooVal',
  1049. bar: 'barVal',
  1050. parentId: source[DEF_PK],
  1051. parentType: 'source',
  1052. });
  1053. expect(target).to.be.eql({
  1054. [DEF_PK]: target[DEF_PK],
  1055. foo: target.foo,
  1056. bar: target.bar,
  1057. parentId: source[DEF_PK],
  1058. parentType: target.parentType,
  1059. });
  1060. const R = S.getService(HasOneResolver);
  1061. await R.includePolymorphicTo(
  1062. [source],
  1063. 'source',
  1064. 'target',
  1065. 'child',
  1066. 'parentId',
  1067. 'parentType',
  1068. {fields: [DEF_PK, 'bar']},
  1069. );
  1070. expect(source).to.be.eql({
  1071. [DEF_PK]: source[DEF_PK],
  1072. child: {
  1073. [DEF_PK]: target[DEF_PK],
  1074. bar: target.bar,
  1075. },
  1076. });
  1077. });
  1078. it('uses an include clause of the given scope to resolve target relations', async function () {
  1079. const S = new RepositoriesSchema();
  1080. S.defineDatasource({
  1081. name: 'datasource',
  1082. adapter: 'memory',
  1083. });
  1084. S.defineModel({
  1085. name: 'modelA',
  1086. datasource: 'datasource',
  1087. properties: {
  1088. id: {
  1089. type: DataType.NUMBER,
  1090. primaryKey: true,
  1091. },
  1092. source: {
  1093. type: DataType.STRING,
  1094. default: 'modelA',
  1095. },
  1096. },
  1097. relations: {
  1098. child: {
  1099. type: RelationType.HAS_ONE,
  1100. model: 'modelB',
  1101. polymorphic: true,
  1102. foreignKey: 'parentId',
  1103. discriminator: 'parentType',
  1104. },
  1105. },
  1106. });
  1107. S.defineModel({
  1108. name: 'modelB',
  1109. datasource: 'datasource',
  1110. properties: {
  1111. id: {
  1112. type: DataType.NUMBER,
  1113. primaryKey: true,
  1114. },
  1115. source: {
  1116. type: DataType.STRING,
  1117. default: 'modelB',
  1118. },
  1119. },
  1120. relations: {
  1121. child: {
  1122. type: RelationType.HAS_ONE,
  1123. model: 'modelC',
  1124. polymorphic: true,
  1125. foreignKey: 'parentId',
  1126. discriminator: 'parentType',
  1127. },
  1128. },
  1129. });
  1130. S.defineModel({
  1131. name: 'modelC',
  1132. datasource: 'datasource',
  1133. properties: {
  1134. id: {
  1135. type: DataType.NUMBER,
  1136. primaryKey: true,
  1137. },
  1138. source: {
  1139. type: DataType.STRING,
  1140. default: 'modelC',
  1141. },
  1142. },
  1143. });
  1144. const aRep = S.getRepository('modelA');
  1145. const bRep = S.getRepository('modelB');
  1146. const cRep = S.getRepository('modelC');
  1147. const a = await aRep.create({});
  1148. const b = await bRep.create({parentId: a.id, parentType: 'modelA'});
  1149. const c = await cRep.create({parentId: b.id, parentType: 'modelB'});
  1150. expect(a).to.be.eql({
  1151. id: a.id,
  1152. source: 'modelA',
  1153. });
  1154. expect(b).to.be.eql({
  1155. id: b.id,
  1156. source: 'modelB',
  1157. parentId: a.id,
  1158. parentType: 'modelA',
  1159. });
  1160. expect(c).to.be.eql({
  1161. id: c.id,
  1162. source: 'modelC',
  1163. parentId: b.id,
  1164. parentType: 'modelB',
  1165. });
  1166. const R = S.getService(HasOneResolver);
  1167. await R.includePolymorphicTo(
  1168. [a],
  1169. 'modelA',
  1170. 'modelB',
  1171. 'child',
  1172. 'parentId',
  1173. 'parentType',
  1174. {include: 'child'},
  1175. );
  1176. expect(a).to.be.eql({
  1177. id: a.id,
  1178. source: 'modelA',
  1179. child: {
  1180. id: b.id,
  1181. source: 'modelB',
  1182. parentId: a.id,
  1183. parentType: 'modelA',
  1184. child: {
  1185. id: c.id,
  1186. source: 'modelC',
  1187. parentId: b.id,
  1188. parentType: 'modelB',
  1189. },
  1190. },
  1191. });
  1192. });
  1193. it('does not break the "and" operator of the given "where" clause', async function () {
  1194. const S = new RepositoriesSchema();
  1195. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1196. S.defineModel({name: 'source', datasource: 'datasource'});
  1197. S.defineModel({name: 'target', datasource: 'datasource'});
  1198. const sourceRep = S.getRepository('source');
  1199. const targetRep = S.getRepository('target');
  1200. const source = await sourceRep.create({});
  1201. expect(source).to.be.eql({
  1202. [DEF_PK]: source[DEF_PK],
  1203. });
  1204. const target1 = await targetRep.create({
  1205. featured: false,
  1206. parentId: source[DEF_PK],
  1207. parentType: 'source',
  1208. });
  1209. expect(target1).to.be.eql({
  1210. [DEF_PK]: target1[DEF_PK],
  1211. featured: false,
  1212. parentId: source[DEF_PK],
  1213. parentType: target1.parentType,
  1214. });
  1215. const target2 = await targetRep.create({
  1216. featured: true,
  1217. parentId: source[DEF_PK],
  1218. parentType: 'source',
  1219. });
  1220. expect(target2).to.be.eql({
  1221. [DEF_PK]: target2[DEF_PK],
  1222. featured: true,
  1223. parentId: source[DEF_PK],
  1224. parentType: target2.parentType,
  1225. });
  1226. const R = S.getService(HasOneResolver);
  1227. await R.includePolymorphicTo(
  1228. [source],
  1229. 'source',
  1230. 'target',
  1231. 'child',
  1232. 'parentId',
  1233. 'parentType',
  1234. {where: {and: [{featured: false}]}},
  1235. );
  1236. expect(source).to.be.eql({
  1237. [DEF_PK]: source[DEF_PK],
  1238. child: {
  1239. [DEF_PK]: target1[DEF_PK],
  1240. featured: false,
  1241. parentId: source[DEF_PK],
  1242. parentType: target1.parentType,
  1243. },
  1244. });
  1245. delete source.child;
  1246. await R.includePolymorphicTo(
  1247. [source],
  1248. 'source',
  1249. 'target',
  1250. 'child',
  1251. 'parentId',
  1252. 'parentType',
  1253. {where: {and: [{featured: true}]}},
  1254. );
  1255. expect(source).to.be.eql({
  1256. [DEF_PK]: source[DEF_PK],
  1257. child: {
  1258. [DEF_PK]: target2[DEF_PK],
  1259. featured: true,
  1260. parentId: source[DEF_PK],
  1261. parentType: target2.parentType,
  1262. },
  1263. });
  1264. });
  1265. });
  1266. describe('includePolymorphicByRelationName', function () {
  1267. it('requires the "entities" parameter to be an array', async function () {
  1268. const S = new RepositoriesSchema();
  1269. const R = S.getService(HasOneResolver);
  1270. const error = v =>
  1271. format(
  1272. 'The parameter "entities" of HasOneResolver.includePolymorphicByRelationName requires ' +
  1273. 'an Array of Object, but %s given.',
  1274. v,
  1275. );
  1276. const throwable = v =>
  1277. R.includePolymorphicByRelationName(
  1278. v,
  1279. 'sourceName',
  1280. 'targetName',
  1281. 'relationName',
  1282. 'targetRelationName',
  1283. );
  1284. await expect(throwable('')).to.be.rejectedWith(error('""'));
  1285. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  1286. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  1287. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  1288. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  1289. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  1290. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  1291. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  1292. });
  1293. it('requires elements of the "entities" parameter to be an Object', async function () {
  1294. const S = new RepositoriesSchema();
  1295. S.defineModel({name: 'source'});
  1296. S.defineModel({
  1297. name: 'target',
  1298. relations: {
  1299. parent: {
  1300. type: RelationType.BELONGS_TO,
  1301. polymorphic: true,
  1302. },
  1303. },
  1304. });
  1305. const R = S.getService(HasOneResolver);
  1306. const error = v =>
  1307. format(
  1308. 'The parameter "entities" of HasOneResolver.includePolymorphicTo requires ' +
  1309. 'an Array of Object, but %s given.',
  1310. v,
  1311. );
  1312. const throwable = v =>
  1313. R.includePolymorphicByRelationName(
  1314. [v],
  1315. 'source',
  1316. 'target',
  1317. 'child',
  1318. 'parent',
  1319. );
  1320. await expect(throwable('')).to.be.rejectedWith(error('""'));
  1321. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  1322. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  1323. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  1324. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  1325. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  1326. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  1327. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  1328. });
  1329. it('requires the "sourceName" parameter to be a non-empty string', async function () {
  1330. const S = new RepositoriesSchema();
  1331. const R = S.getService(HasOneResolver);
  1332. const error = v =>
  1333. format(
  1334. 'The parameter "sourceName" of HasOneResolver.includePolymorphicByRelationName requires ' +
  1335. 'a non-empty String, but %s given.',
  1336. v,
  1337. );
  1338. const throwable = v =>
  1339. R.includePolymorphicByRelationName(
  1340. [],
  1341. v,
  1342. 'targetName',
  1343. 'relationName',
  1344. 'targetRelationName',
  1345. );
  1346. await expect(throwable('')).to.be.rejectedWith(error('""'));
  1347. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  1348. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  1349. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  1350. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  1351. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  1352. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  1353. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  1354. });
  1355. it('requires the "targetName" parameter to be a non-empty string', async function () {
  1356. const S = new RepositoriesSchema();
  1357. const R = S.getService(HasOneResolver);
  1358. const error = v =>
  1359. format(
  1360. 'The parameter "targetName" of HasOneResolver.includePolymorphicByRelationName requires ' +
  1361. 'a non-empty String, but %s given.',
  1362. v,
  1363. );
  1364. const throwable = v =>
  1365. R.includePolymorphicByRelationName(
  1366. [],
  1367. 'sourceName',
  1368. v,
  1369. 'relationName',
  1370. 'targetRelationName',
  1371. );
  1372. await expect(throwable('')).to.be.rejectedWith(error('""'));
  1373. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  1374. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  1375. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  1376. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  1377. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  1378. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  1379. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  1380. });
  1381. it('requires the "relationName" parameter to be a non-empty string', async function () {
  1382. const S = new RepositoriesSchema();
  1383. const R = S.getService(HasOneResolver);
  1384. const error = v =>
  1385. format(
  1386. 'The parameter "relationName" of HasOneResolver.includePolymorphicByRelationName requires ' +
  1387. 'a non-empty String, but %s given.',
  1388. v,
  1389. );
  1390. const throwable = v =>
  1391. R.includePolymorphicByRelationName(
  1392. [],
  1393. 'sourceName',
  1394. 'targetName',
  1395. v,
  1396. 'targetRelationName',
  1397. );
  1398. await expect(throwable('')).to.be.rejectedWith(error('""'));
  1399. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  1400. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  1401. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  1402. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  1403. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  1404. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  1405. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  1406. });
  1407. it('requires the "targetRelationName" parameter to be a non-empty string', async function () {
  1408. const S = new RepositoriesSchema();
  1409. const R = S.getService(HasOneResolver);
  1410. const error = v =>
  1411. format(
  1412. 'The parameter "targetRelationName" of HasOneResolver.includePolymorphicByRelationName requires ' +
  1413. 'a non-empty String, but %s given.',
  1414. v,
  1415. );
  1416. const throwable = v =>
  1417. R.includePolymorphicByRelationName(
  1418. [],
  1419. 'sourceName',
  1420. 'targetName',
  1421. 'relationName',
  1422. v,
  1423. );
  1424. await expect(throwable('')).to.be.rejectedWith(error('""'));
  1425. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  1426. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  1427. await expect(throwable(false)).to.be.rejectedWith(error('false'));
  1428. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  1429. await expect(throwable({})).to.be.rejectedWith(error('Object'));
  1430. await expect(throwable(undefined)).to.be.rejectedWith(error('undefined'));
  1431. await expect(throwable(null)).to.be.rejectedWith(error('null'));
  1432. });
  1433. it('requires the provided parameter "scope" to be an object', async function () {
  1434. const S = new RepositoriesSchema();
  1435. const R = S.getService(HasOneResolver);
  1436. const error = v =>
  1437. format(
  1438. 'The provided parameter "scope" of HasOneResolver.includePolymorphicByRelationName ' +
  1439. 'should be an Object, but %s given.',
  1440. v,
  1441. );
  1442. const throwable = v =>
  1443. R.includePolymorphicByRelationName(
  1444. [],
  1445. 'sourceName',
  1446. 'targetName',
  1447. 'relationName',
  1448. 'targetRelationName',
  1449. v,
  1450. );
  1451. await expect(throwable('str')).to.be.rejectedWith(error('"str"'));
  1452. await expect(throwable(10)).to.be.rejectedWith(error('10'));
  1453. await expect(throwable(true)).to.be.rejectedWith(error('true'));
  1454. await expect(throwable([])).to.be.rejectedWith(error('Array'));
  1455. });
  1456. it('throws an error if the given target model is not found', async function () {
  1457. const S = new RepositoriesSchema();
  1458. S.defineModel({name: 'source'});
  1459. const R = S.getService(HasOneResolver);
  1460. const entity = {[DEF_PK]: 1};
  1461. const promise = R.includePolymorphicByRelationName(
  1462. [entity],
  1463. 'source',
  1464. 'target',
  1465. 'child',
  1466. 'parent',
  1467. );
  1468. await expect(promise).to.be.rejectedWith(
  1469. 'The model "target" is not defined',
  1470. );
  1471. });
  1472. it('throws an error if the given target model does not have the given relation name', async function () {
  1473. const S = new RepositoriesSchema();
  1474. S.defineModel({name: 'source'});
  1475. S.defineModel({name: 'target'});
  1476. const R = S.getService(HasOneResolver);
  1477. const entity = {[DEF_PK]: 1};
  1478. const promise = R.includePolymorphicByRelationName(
  1479. [entity],
  1480. 'source',
  1481. 'target',
  1482. 'child',
  1483. 'parent',
  1484. );
  1485. await expect(promise).to.be.rejectedWith(
  1486. 'The model "target" does not have relation name "parent".',
  1487. );
  1488. });
  1489. it('throws an error if the target relation is not "belongsTo"', async function () {
  1490. const S = new RepositoriesSchema();
  1491. S.defineModel({name: 'source'});
  1492. S.defineModel({
  1493. name: 'target',
  1494. relations: {
  1495. parent: {
  1496. type: RelationType.REFERENCES_MANY,
  1497. model: 'source',
  1498. },
  1499. },
  1500. });
  1501. const R = S.getService(HasOneResolver);
  1502. const entity = {[DEF_PK]: 1};
  1503. const promise = R.includePolymorphicByRelationName(
  1504. [entity],
  1505. 'source',
  1506. 'target',
  1507. 'child',
  1508. 'parent',
  1509. );
  1510. await expect(promise).to.be.rejectedWith(
  1511. 'The relation "child" of the model "source" is a polymorphic "hasOne" relation, ' +
  1512. 'so it requires the target relation "parent" to be a polymorphic "belongsTo", ' +
  1513. 'but "referencesMany" type given.',
  1514. );
  1515. });
  1516. it('throws an error if the target relation is not polymorphic', async function () {
  1517. const S = new RepositoriesSchema();
  1518. S.defineModel({name: 'source'});
  1519. S.defineModel({
  1520. name: 'target',
  1521. relations: {
  1522. parent: {
  1523. type: RelationType.BELONGS_TO,
  1524. model: 'source',
  1525. },
  1526. },
  1527. });
  1528. const R = S.getService(HasOneResolver);
  1529. const entity = {[DEF_PK]: 1};
  1530. const promise = R.includePolymorphicByRelationName(
  1531. [entity],
  1532. 'source',
  1533. 'target',
  1534. 'child',
  1535. 'parent',
  1536. );
  1537. await expect(promise).to.be.rejectedWith(
  1538. 'The relation "child" of the model "source" is a polymorphic ' +
  1539. '"hasOne" relation, so it requires the target relation "parent" ' +
  1540. 'to be a polymorphic too.',
  1541. );
  1542. });
  1543. it('throws an error if the given target model does not have a datasource', async function () {
  1544. const S = new RepositoriesSchema();
  1545. S.defineModel({name: 'source'});
  1546. S.defineModel({
  1547. name: 'target',
  1548. relations: {
  1549. parent: {
  1550. type: RelationType.BELONGS_TO,
  1551. polymorphic: true,
  1552. },
  1553. },
  1554. });
  1555. const R = S.getService(HasOneResolver);
  1556. const entity = {[DEF_PK]: 1};
  1557. const promise = R.includePolymorphicByRelationName(
  1558. [entity],
  1559. 'source',
  1560. 'target',
  1561. 'child',
  1562. 'parent',
  1563. );
  1564. await expect(promise).to.be.rejectedWith(
  1565. 'The model "target" does not have a specified datasource.',
  1566. );
  1567. });
  1568. it('does not throw an error if a relation target is not found', async function () {
  1569. const S = new RepositoriesSchema();
  1570. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1571. S.defineModel({name: 'source', datasource: 'datasource'});
  1572. S.defineModel({
  1573. name: 'target',
  1574. datasource: 'datasource',
  1575. relations: {
  1576. parent: {
  1577. type: RelationType.BELONGS_TO,
  1578. polymorphic: true,
  1579. },
  1580. },
  1581. });
  1582. const sourceRel = S.getRepository('source');
  1583. const source = await sourceRel.create({});
  1584. expect(source).to.be.eql({
  1585. [DEF_PK]: source[DEF_PK],
  1586. });
  1587. const R = S.getService(HasOneResolver);
  1588. await R.includePolymorphicByRelationName(
  1589. [source],
  1590. 'source',
  1591. 'target',
  1592. 'child',
  1593. 'parent',
  1594. );
  1595. expect(source).to.be.eql({
  1596. [DEF_PK]: source[DEF_PK],
  1597. });
  1598. });
  1599. it('does not include an entity with a not matched discriminator value', async function () {
  1600. const S = new RepositoriesSchema();
  1601. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1602. S.defineModel({name: 'source', datasource: 'datasource'});
  1603. S.defineModel({
  1604. name: 'target',
  1605. datasource: 'datasource',
  1606. relations: {
  1607. parent: {
  1608. type: RelationType.BELONGS_TO,
  1609. polymorphic: true,
  1610. },
  1611. },
  1612. });
  1613. const sourceRel = S.getRepository('source');
  1614. const targetRel = S.getRepository('target');
  1615. const source = await sourceRel.create({});
  1616. expect(source).to.be.eql({
  1617. [DEF_PK]: source[DEF_PK],
  1618. });
  1619. const target = await targetRel.create({
  1620. parentId: source[DEF_PK],
  1621. parentType: 'unknown',
  1622. });
  1623. expect(target).to.be.eql({
  1624. [DEF_PK]: target[DEF_PK],
  1625. parentId: source[DEF_PK],
  1626. parentType: 'unknown',
  1627. });
  1628. const R = S.getService(HasOneResolver);
  1629. await R.includePolymorphicByRelationName(
  1630. [source],
  1631. 'source',
  1632. 'target',
  1633. 'child',
  1634. 'parent',
  1635. );
  1636. expect(source).to.be.eql({
  1637. [DEF_PK]: source[DEF_PK],
  1638. });
  1639. });
  1640. it('includes if a primary key is not defined in the source model', async function () {
  1641. const S = new RepositoriesSchema();
  1642. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1643. S.defineModel({name: 'source', datasource: 'datasource'});
  1644. S.defineModel({
  1645. name: 'target',
  1646. datasource: 'datasource',
  1647. relations: {
  1648. parent: {
  1649. type: RelationType.BELONGS_TO,
  1650. polymorphic: true,
  1651. },
  1652. },
  1653. });
  1654. const sourceRep = S.getRepository('source');
  1655. const targetRep = S.getRepository('target');
  1656. const source = await sourceRep.create({});
  1657. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  1658. const target = await targetRep.create({
  1659. parentId: source[DEF_PK],
  1660. parentType: 'source',
  1661. });
  1662. expect(target).to.be.eql({
  1663. [DEF_PK]: target[DEF_PK],
  1664. parentId: source[DEF_PK],
  1665. parentType: target.parentType,
  1666. });
  1667. const R = S.getService(HasOneResolver);
  1668. await R.includePolymorphicByRelationName(
  1669. [source],
  1670. 'source',
  1671. 'target',
  1672. 'child',
  1673. 'parent',
  1674. );
  1675. expect(source).to.be.eql({
  1676. [DEF_PK]: source[DEF_PK],
  1677. child: {
  1678. id: target[DEF_PK],
  1679. parentId: source[DEF_PK],
  1680. parentType: target.parentType,
  1681. },
  1682. });
  1683. });
  1684. it('includes if the source model has a custom primary key', async function () {
  1685. const S = new RepositoriesSchema();
  1686. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1687. S.defineModel({
  1688. name: 'source',
  1689. datasource: 'datasource',
  1690. properties: {
  1691. myId: {
  1692. type: DataType.NUMBER,
  1693. primaryKey: true,
  1694. },
  1695. },
  1696. });
  1697. S.defineModel({
  1698. name: 'target',
  1699. datasource: 'datasource',
  1700. relations: {
  1701. parent: {
  1702. type: RelationType.BELONGS_TO,
  1703. polymorphic: true,
  1704. },
  1705. },
  1706. });
  1707. const sourceRep = S.getRepository('source');
  1708. const targetRep = S.getRepository('target');
  1709. const source = await sourceRep.create({});
  1710. expect(source).to.be.eql({myId: source.myId});
  1711. const target = await targetRep.create({
  1712. parentId: source.myId,
  1713. parentType: 'source',
  1714. });
  1715. expect(target).to.be.eql({
  1716. [DEF_PK]: target[DEF_PK],
  1717. parentId: source.myId,
  1718. parentType: target.parentType,
  1719. });
  1720. const R = S.getService(HasOneResolver);
  1721. await R.includePolymorphicByRelationName(
  1722. [source],
  1723. 'source',
  1724. 'target',
  1725. 'child',
  1726. 'parent',
  1727. );
  1728. expect(source).to.be.eql({
  1729. myId: source.myId,
  1730. child: {
  1731. [DEF_PK]: target[DEF_PK],
  1732. parentId: source.myId,
  1733. parentType: target.parentType,
  1734. },
  1735. });
  1736. });
  1737. it('includes if the target model has a custom primary key', async function () {
  1738. const S = new RepositoriesSchema();
  1739. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1740. S.defineModel({name: 'source', datasource: 'datasource'});
  1741. S.defineModel({
  1742. name: 'target',
  1743. datasource: 'datasource',
  1744. properties: {
  1745. myId: {
  1746. type: DataType.NUMBER,
  1747. primaryKey: true,
  1748. },
  1749. },
  1750. relations: {
  1751. parent: {
  1752. type: RelationType.BELONGS_TO,
  1753. polymorphic: true,
  1754. },
  1755. },
  1756. });
  1757. const sourceRep = S.getRepository('source');
  1758. const targetRep = S.getRepository('target');
  1759. const source = await sourceRep.create({});
  1760. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  1761. const target = await targetRep.create({
  1762. parentId: source[DEF_PK],
  1763. parentType: 'source',
  1764. });
  1765. expect(target).to.be.eql({
  1766. myId: target.myId,
  1767. parentId: source[DEF_PK],
  1768. parentType: target.parentType,
  1769. });
  1770. const R = S.getService(HasOneResolver);
  1771. await R.includePolymorphicByRelationName(
  1772. [source],
  1773. 'source',
  1774. 'target',
  1775. 'child',
  1776. 'parent',
  1777. );
  1778. expect(source).to.be.eql({
  1779. [DEF_PK]: source[DEF_PK],
  1780. child: {
  1781. myId: target.myId,
  1782. parentId: source[DEF_PK],
  1783. parentType: target.parentType,
  1784. },
  1785. });
  1786. });
  1787. it('includes if the target model has a custom "foreignKey"', async function () {
  1788. const S = new RepositoriesSchema();
  1789. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1790. S.defineModel({name: 'source', datasource: 'datasource'});
  1791. S.defineModel({
  1792. name: 'target',
  1793. datasource: 'datasource',
  1794. properties: {
  1795. myId: {
  1796. type: DataType.NUMBER,
  1797. primaryKey: true,
  1798. },
  1799. },
  1800. relations: {
  1801. parent: {
  1802. type: RelationType.BELONGS_TO,
  1803. polymorphic: true,
  1804. foreignKey: 'relationId',
  1805. },
  1806. },
  1807. });
  1808. const sourceRep = S.getRepository('source');
  1809. const targetRep = S.getRepository('target');
  1810. const source = await sourceRep.create({});
  1811. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  1812. const target = await targetRep.create({
  1813. relationId: source[DEF_PK],
  1814. parentType: 'source',
  1815. });
  1816. expect(target).to.be.eql({
  1817. myId: target.myId,
  1818. relationId: source[DEF_PK],
  1819. parentType: target.parentType,
  1820. });
  1821. const R = S.getService(HasOneResolver);
  1822. await R.includePolymorphicByRelationName(
  1823. [source],
  1824. 'source',
  1825. 'target',
  1826. 'child',
  1827. 'parent',
  1828. );
  1829. expect(source).to.be.eql({
  1830. [DEF_PK]: source[DEF_PK],
  1831. child: {
  1832. myId: target.myId,
  1833. relationId: source[DEF_PK],
  1834. parentType: target.parentType,
  1835. },
  1836. });
  1837. });
  1838. it('includes if the target model has a custom "discriminator"', async function () {
  1839. const S = new RepositoriesSchema();
  1840. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1841. S.defineModel({name: 'source', datasource: 'datasource'});
  1842. S.defineModel({
  1843. name: 'target',
  1844. datasource: 'datasource',
  1845. properties: {
  1846. myId: {
  1847. type: DataType.NUMBER,
  1848. primaryKey: true,
  1849. },
  1850. },
  1851. relations: {
  1852. parent: {
  1853. type: RelationType.BELONGS_TO,
  1854. polymorphic: true,
  1855. discriminator: 'relationType',
  1856. },
  1857. },
  1858. });
  1859. const sourceRep = S.getRepository('source');
  1860. const targetRep = S.getRepository('target');
  1861. const source = await sourceRep.create({});
  1862. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  1863. const target = await targetRep.create({
  1864. parentId: source[DEF_PK],
  1865. relationType: 'source',
  1866. });
  1867. expect(target).to.be.eql({
  1868. myId: target.myId,
  1869. parentId: source[DEF_PK],
  1870. relationType: target.relationType,
  1871. });
  1872. const R = S.getService(HasOneResolver);
  1873. await R.includePolymorphicByRelationName(
  1874. [source],
  1875. 'source',
  1876. 'target',
  1877. 'child',
  1878. 'parent',
  1879. );
  1880. expect(source).to.be.eql({
  1881. [DEF_PK]: source[DEF_PK],
  1882. child: {
  1883. myId: target.myId,
  1884. parentId: source[DEF_PK],
  1885. relationType: target.relationType,
  1886. },
  1887. });
  1888. });
  1889. it('uses a where clause of the given scope to filter the relation target', async function () {
  1890. const S = new RepositoriesSchema();
  1891. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1892. S.defineModel({name: 'source', datasource: 'datasource'});
  1893. S.defineModel({
  1894. name: 'target',
  1895. datasource: 'datasource',
  1896. relations: {
  1897. parent: {
  1898. type: RelationType.BELONGS_TO,
  1899. polymorphic: true,
  1900. },
  1901. },
  1902. });
  1903. const sourceRep = S.getRepository('source');
  1904. const targetRep = S.getRepository('target');
  1905. const source = await sourceRep.create({});
  1906. expect(source).to.be.eql({[DEF_PK]: source[DEF_PK]});
  1907. const target1 = await targetRep.create({
  1908. featured: false,
  1909. parentId: source[DEF_PK],
  1910. parentType: 'source',
  1911. });
  1912. expect(target1).to.be.eql({
  1913. [DEF_PK]: target1[DEF_PK],
  1914. featured: false,
  1915. parentId: source[DEF_PK],
  1916. parentType: target1.parentType,
  1917. });
  1918. const target2 = await targetRep.create({
  1919. featured: true,
  1920. parentId: source[DEF_PK],
  1921. parentType: 'source',
  1922. });
  1923. expect(target2).to.be.eql({
  1924. [DEF_PK]: target2[DEF_PK],
  1925. featured: true,
  1926. parentId: source[DEF_PK],
  1927. parentType: target2.parentType,
  1928. });
  1929. const R = S.getService(HasOneResolver);
  1930. await R.includePolymorphicByRelationName(
  1931. [source],
  1932. 'source',
  1933. 'target',
  1934. 'child',
  1935. 'parent',
  1936. {where: {featured: false}},
  1937. );
  1938. expect(source).to.be.eql({
  1939. [DEF_PK]: source[DEF_PK],
  1940. child: {
  1941. [DEF_PK]: target1[DEF_PK],
  1942. featured: false,
  1943. parentId: source[DEF_PK],
  1944. parentType: target1.parentType,
  1945. },
  1946. });
  1947. await R.includePolymorphicByRelationName(
  1948. [source],
  1949. 'source',
  1950. 'target',
  1951. 'child',
  1952. 'parent',
  1953. {where: {featured: true}},
  1954. );
  1955. expect(source).to.be.eql({
  1956. [DEF_PK]: source[DEF_PK],
  1957. child: {
  1958. [DEF_PK]: target2[DEF_PK],
  1959. featured: true,
  1960. parentId: source[DEF_PK],
  1961. parentType: target2.parentType,
  1962. },
  1963. });
  1964. });
  1965. it('uses a fields clause of the given scope to filter the relation target', async function () {
  1966. const S = new RepositoriesSchema();
  1967. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  1968. S.defineModel({name: 'source', datasource: 'datasource'});
  1969. S.defineModel({
  1970. name: 'target',
  1971. datasource: 'datasource',
  1972. relations: {
  1973. parent: {
  1974. type: RelationType.BELONGS_TO,
  1975. polymorphic: true,
  1976. },
  1977. },
  1978. });
  1979. const sourceRep = S.getRepository('source');
  1980. const targetRep = S.getRepository('target');
  1981. const source = await sourceRep.create({});
  1982. expect(source).to.be.eql({
  1983. [DEF_PK]: source[DEF_PK],
  1984. });
  1985. const target = await targetRep.create({
  1986. foo: 'fooVal',
  1987. bar: 'barVal',
  1988. parentId: source[DEF_PK],
  1989. parentType: 'source',
  1990. });
  1991. expect(target).to.be.eql({
  1992. [DEF_PK]: target[DEF_PK],
  1993. foo: target.foo,
  1994. bar: target.bar,
  1995. parentId: source[DEF_PK],
  1996. parentType: target.parentType,
  1997. });
  1998. const R = S.getService(HasOneResolver);
  1999. await R.includePolymorphicByRelationName(
  2000. [source],
  2001. 'source',
  2002. 'target',
  2003. 'child',
  2004. 'parent',
  2005. {fields: [DEF_PK, 'bar']},
  2006. );
  2007. expect(source).to.be.eql({
  2008. [DEF_PK]: source[DEF_PK],
  2009. child: {
  2010. [DEF_PK]: target[DEF_PK],
  2011. bar: target.bar,
  2012. },
  2013. });
  2014. });
  2015. it('uses an include clause of the given scope to resolve target relations', async function () {
  2016. const S = new RepositoriesSchema();
  2017. S.defineDatasource({
  2018. name: 'datasource',
  2019. adapter: 'memory',
  2020. });
  2021. S.defineModel({
  2022. name: 'modelA',
  2023. datasource: 'datasource',
  2024. properties: {
  2025. id: {
  2026. type: DataType.NUMBER,
  2027. primaryKey: true,
  2028. },
  2029. source: {
  2030. type: DataType.STRING,
  2031. default: 'modelA',
  2032. },
  2033. },
  2034. relations: {
  2035. child: {
  2036. type: RelationType.HAS_ONE,
  2037. model: 'modelB',
  2038. polymorphic: 'parent',
  2039. },
  2040. },
  2041. });
  2042. S.defineModel({
  2043. name: 'modelB',
  2044. datasource: 'datasource',
  2045. properties: {
  2046. id: {
  2047. type: DataType.NUMBER,
  2048. primaryKey: true,
  2049. },
  2050. source: {
  2051. type: DataType.STRING,
  2052. default: 'modelB',
  2053. },
  2054. },
  2055. relations: {
  2056. parent: {
  2057. type: RelationType.BELONGS_TO,
  2058. polymorphic: true,
  2059. },
  2060. child: {
  2061. type: RelationType.HAS_ONE,
  2062. model: 'modelC',
  2063. polymorphic: 'parent',
  2064. },
  2065. },
  2066. });
  2067. S.defineModel({
  2068. name: 'modelC',
  2069. datasource: 'datasource',
  2070. properties: {
  2071. id: {
  2072. type: DataType.NUMBER,
  2073. primaryKey: true,
  2074. },
  2075. source: {
  2076. type: DataType.STRING,
  2077. default: 'modelC',
  2078. },
  2079. },
  2080. relations: {
  2081. parent: {
  2082. type: RelationType.BELONGS_TO,
  2083. polymorphic: true,
  2084. },
  2085. },
  2086. });
  2087. const aRep = S.getRepository('modelA');
  2088. const bRep = S.getRepository('modelB');
  2089. const cRep = S.getRepository('modelC');
  2090. const a = await aRep.create({});
  2091. const b = await bRep.create({parentId: a.id, parentType: 'modelA'});
  2092. const c = await cRep.create({parentId: b.id, parentType: 'modelB'});
  2093. expect(a).to.be.eql({
  2094. id: a.id,
  2095. source: 'modelA',
  2096. });
  2097. expect(b).to.be.eql({
  2098. id: b.id,
  2099. source: 'modelB',
  2100. parentId: a.id,
  2101. parentType: 'modelA',
  2102. });
  2103. expect(c).to.be.eql({
  2104. id: c.id,
  2105. source: 'modelC',
  2106. parentId: b.id,
  2107. parentType: 'modelB',
  2108. });
  2109. const R = S.getService(HasOneResolver);
  2110. await R.includePolymorphicByRelationName(
  2111. [a],
  2112. 'modelA',
  2113. 'modelB',
  2114. 'child',
  2115. 'parent',
  2116. {include: 'child'},
  2117. );
  2118. expect(a).to.be.eql({
  2119. id: a.id,
  2120. source: 'modelA',
  2121. child: {
  2122. id: b.id,
  2123. source: 'modelB',
  2124. parentId: a.id,
  2125. parentType: 'modelA',
  2126. child: {
  2127. id: c.id,
  2128. source: 'modelC',
  2129. parentId: b.id,
  2130. parentType: 'modelB',
  2131. },
  2132. },
  2133. });
  2134. });
  2135. it('does not break the "and" operator of the given "where" clause', async function () {
  2136. const S = new RepositoriesSchema();
  2137. S.defineDatasource({name: 'datasource', adapter: 'memory'});
  2138. S.defineModel({name: 'source', datasource: 'datasource'});
  2139. S.defineModel({
  2140. name: 'target',
  2141. datasource: 'datasource',
  2142. relations: {
  2143. parent: {
  2144. type: RelationType.BELONGS_TO,
  2145. polymorphic: true,
  2146. },
  2147. },
  2148. });
  2149. const sourceRep = S.getRepository('source');
  2150. const targetRep = S.getRepository('target');
  2151. const source = await sourceRep.create({});
  2152. expect(source).to.be.eql({
  2153. [DEF_PK]: source[DEF_PK],
  2154. });
  2155. const target1 = await targetRep.create({
  2156. featured: false,
  2157. parentId: source[DEF_PK],
  2158. parentType: 'source',
  2159. });
  2160. expect(target1).to.be.eql({
  2161. [DEF_PK]: target1[DEF_PK],
  2162. featured: false,
  2163. parentId: source[DEF_PK],
  2164. parentType: target1.parentType,
  2165. });
  2166. const target2 = await targetRep.create({
  2167. featured: true,
  2168. parentId: source[DEF_PK],
  2169. parentType: 'source',
  2170. });
  2171. expect(target2).to.be.eql({
  2172. [DEF_PK]: target2[DEF_PK],
  2173. featured: true,
  2174. parentId: source[DEF_PK],
  2175. parentType: target2.parentType,
  2176. });
  2177. const R = S.getService(HasOneResolver);
  2178. await R.includePolymorphicByRelationName(
  2179. [source],
  2180. 'source',
  2181. 'target',
  2182. 'child',
  2183. 'parent',
  2184. {where: {and: [{featured: false}]}},
  2185. );
  2186. expect(source).to.be.eql({
  2187. [DEF_PK]: source[DEF_PK],
  2188. child: {
  2189. [DEF_PK]: target1[DEF_PK],
  2190. featured: false,
  2191. parentId: source[DEF_PK],
  2192. parentType: target1.parentType,
  2193. },
  2194. });
  2195. delete source.child;
  2196. await R.includePolymorphicByRelationName(
  2197. [source],
  2198. 'source',
  2199. 'target',
  2200. 'child',
  2201. 'parent',
  2202. {where: {and: [{featured: true}]}},
  2203. );
  2204. expect(source).to.be.eql({
  2205. [DEF_PK]: source[DEF_PK],
  2206. child: {
  2207. [DEF_PK]: target2[DEF_PK],
  2208. featured: true,
  2209. parentId: source[DEF_PK],
  2210. parentType: target2.parentType,
  2211. },
  2212. });
  2213. });
  2214. });
  2215. });