Using upserts for initial data

.eslintrc

@@ -1,31 +1,29 @@
 {
-  "extends": [
-    "plugin:@sap/cds/recommended",
-    "eslint:recommended"
-  ],
-  "env": {
-    "browser": true,
-    "es2022": true,
-    "node": true,
-    "jest": true,
-    "mocha": true
-  },
-  "globals": {
-    "SELECT": true,
-    "INSERT": true,
-    "UPSERT": true,
-    "UPDATE": true,
-    "DELETE": true,
-    "CREATE": true,
-    "DROP": true,
-    "CDL": true,
-    "CQL": true,
-    "cds": true
-  },
-  "rules": {
-    "no-console": "off",
-    "require-atomic-updates": "off",
+    "extends": [
+        "eslint:recommended",
+        "plugin:@sap/cds/recommended"
+    ],
+    "env": {
+        "browser": true,
+        "es2022": true,
+        "node": true,
+        "jest": true,
+        "mocha": true
+    },
+    "globals": {
+        "SELECT": true,
+        "INSERT": true,
+        "UPSERT": true,
+        "UPDATE": true,
+        "DELETE": true,
+        "CREATE": true,
+        "DROP": true,
+        "cds": true
+    },
+    "rules": {
+        "no-console": "off",
+        "require-atomic-updates": "off",
         "require-await":"warn",
         "no-unused-vars": ["warn", { "argsIgnorePattern": "_" }]
-  }
+    }
 }

.registry/.gitignore

@@ -0,0 +1 @@
+*.tgz

.registry/server.js

@@ -0,0 +1,81 @@
+const { exec } = require ('child_process')
+const isWin = process.platform === 'win32'
+const express = require ('express')
+const fs = require ('fs')
+const app = express()
+
+const { PORT=4444 } = process.env
+const [,,port=PORT,scope='@capire'] = process.argv
+const cwd = __dirname
+
+// clean up on start (exit handler might not complete on Windows)
+exec(isWin ? 'del *.tgz' : 'rm *.tgz', {cwd})
+
+
+app.use('/-/:tarball', (req,res,next) => {
+  console.debug ('GET', req.params)
+  try {
+    const { tarball } = req.params
+    const pkgFull = tarball.substring(0, tarball.lastIndexOf('-'))
+    const [, pkg ] = /^\w+-(.+)/.exec(pkgFull)
+    fs.lstat(tarball,(err => {
+      if (err) console.debug (`npm pack ../${pkg}`)
+      if (err) exec(`npm pack ../${pkg}`,{cwd},next)
+      else next()
+    }))
+  } catch (e) {
+    console.error(e)
+    res.sendStatus(500)
+  }
+})
+
+app.use('/-', express.static(__dirname))
+
+app.get('/*', (req,res)=>{
+  const urlRegex = /^\/(@[\w-]+)\/(.+)/
+  const url = decodeURIComponent(req.url)
+  console.debug ('GET',url)
+  try {
+    if (!urlRegex.test(url))  return res.sendStatus(404)
+    const [, scpe, pkg ] = urlRegex.exec(url)
+    const package = require (`${scpe}/${pkg}/package.json`)
+    const tarball = `${scpe.slice(1)}-${pkg}-${package.version}.tgz`
+    // https://github.com/npm/registry/blob/master/docs/responses/package-metadata.md
+    res.json({
+      "name": package.name,
+      "dist-tags": {
+        "latest": package.version
+      },
+      "versions": {
+        [package.version]: {
+          "name": package.name,
+          "version": package.version,
+          "dist": {
+            "tarball": `${server.url}/-/${tarball}`
+          },
+        }
+      },
+    })
+  } catch (e) {
+    if (e.code === 'MODULE_NOT_FOUND')  return res.sendStatus(404)
+    console.error(e);  throw e
+  }
+})
+
+const server = app.listen(port, ()=>{
+  const url = server.url = `http://localhost:${server.address().port}`
+  console.log (`npm set ${scope}:registry=${url}`)
+  exec(`npm set ${scope}:registry=${url}`)
+  console.log (`${scope} registry listening on ${url}`)
+})
+
+
+const _exit = ()=>{
+  server.close()
+  exec(`npm conf rm "${scope}:registry"`, ()=> { process.exit() })
+}
+
+process.on ('SIGTERM',_exit)
+process.on ('SIGHUP',_exit)
+process.on ('SIGINT',_exit)
+process.on ('SIGUSR2',_exit)

.vscode/launch.json

@@ -13,7 +13,7 @@
         "<node_internals>/**",
         "**/node_modules/**",
         "**/cds/lib/lazy.js",
-        "**/cds/lib/req/cds-context.js",
+        "**/cds/lib/req/cls.js",
         "**/odata-v4/okra/**"
       ]
     },
@@ -26,24 +26,10 @@
         "<node_internals>/**",
         "**/node_modules/**",
         "**/cds/lib/lazy.js",
-        "**/cds/lib/req/cds-context.js",
+        "**/cds/lib/req/cls.js",
         "**/odata-v4/okra/**"
       ]
-    },
-    {
-      "name": "Debug Mocha Tests",
-      "type": "node",
-      "request": "attach",
-      "port": 9229,
-      "continueOnAttach": true,
-      "skipFiles": [
-        "<node_internals>/**",
-        "**/node_modules/**",
-        "**/cds/lib/lazy.js",
-        "**/cds/lib/req/cds-context.js",
-        "**/odata-v4/okra/**",
-      ]
-    },
+    }
   ],
   "inputs": [
     {

.vscode/settings.json

@@ -10,11 +10,10 @@
       "<node_internals>/**",
       "**/node_modules/**",
       "**/cds/lib/lazy.js",
-      "**/cds/lib/req/cds-context.js",
+      "**/cds/lib/req/cls.js",
       "**/odata-v4/okra/**"
     ]
   },
-  "mochaExplorer.debuggerConfig": "Debug Mocha Tests",
   "mochaExplorer.parallel": true,
   "eslint.validate": [
     "cds",
@@ -24,4 +23,4 @@
     "tsv",
     "tab"
   ]
-}
+}

bookshop/app/index.cds

@@ -1,2 +0,0 @@
-// Incorporate pre-build extensions from...
-using from '../../common';

bookshop/db/data/_sap.capire.bookshop-Authors.csv

@@ -1,5 +0,0 @@
-ID;name;dateOfBirth;placeOfBirth;dateOfDeath;placeOfDeath
-101;Emily Brontë;1818-07-30;Thornton, Yorkshire;1848-12-19;Haworth, Yorkshire
-107;Charlotte Brontë;1818-04-21;Thornton, Yorkshire;1855-03-31;Haworth, Yorkshire
-150;Edgar Allen Poe;1809-01-19;Boston, Massachusetts;1849-10-07;Baltimore, Maryland
-170;Richard Carpenter;1929-08-14;King’s Lynn, Norfolk;2012-02-26;Hertfordshire, England

bookshop/db/data/_sap.capire.bookshop-Books_texts.csv

@@ -1,5 +0,0 @@
-ID;locale;title;descr
-201;de;Sturmhöhe;Sturmhöhe (Originaltitel: Wuthering Heights) ist der einzige Roman der englischen Schriftstellerin Emily Brontë (1818–1848). Der 1847 unter dem Pseudonym Ellis Bell veröffentlichte Roman wurde vom viktorianischen Publikum weitgehend abgelehnt, heute gilt er als ein Klassiker der britischen Romanliteratur des 19. Jahrhunderts.
-201;fr;Les Hauts de Hurlevent;Les Hauts de Hurlevent (titre original : Wuthering Heights), parfois orthographié Les Hauts de Hurle-Vent, est l'unique roman d'Emily Brontë, publié pour la première fois en 1847 sous le pseudonyme d’Ellis Bell. Loin d'être un récit moralisateur, Emily Brontë achève néanmoins le roman dans une atmosphère sereine, suggérant le triomphe de la paix et du Bien sur la vengeance et le Mal.
-207;de;Jane Eyre;Jane Eyre. Eine Autobiographie (Originaltitel: Jane Eyre. An Autobiography), erstmals erschienen im Jahr 1847 unter dem Pseudonym Currer Bell, ist der erste veröffentlichte Roman der britischen Autorin Charlotte Brontë und ein Klassiker der viktorianischen Romanliteratur des 19. Jahrhunderts. Der Roman erzählt in Form einer Ich-Erzählung die Lebensgeschichte von Jane Eyre (ausgesprochen /ˌdʒeɪn ˈɛə/), die nach einer schweren Kindheit eine Stelle als Gouvernante annimmt und sich in ihren Arbeitgeber verliebt, jedoch immer wieder um ihre Freiheit und Selbstbestimmung kämpfen muss. Als klein, dünn, blass, stets schlicht dunkel gekleidet und mit strengem Mittelscheitel beschrieben, gilt die Heldin des Romans Jane Eyre nicht zuletzt aufgrund der Kino- und Fernsehversionen der melodramatischen Romanvorlage als die bekannteste englische Gouvernante der Literaturgeschichte
-252;de;Eleonora;“Eleonora” ist eine Erzählung von Edgar Allan Poe. Sie wurde 1841 erstveröffentlicht. In ihr geht es um das Paradox der Treue in der Treulosigkeit.

bookshop/db/data/_sap.capire.bookshop-Genres.csv

@@ -1,16 +0,0 @@
-ID;parent_ID;name
-10;;Fiction
-11;10;Drama
-12;10;Poetry
-13;10;Fantasy
-14;10;Science Fiction
-15;10;Romance
-16;10;Mystery
-17;10;Thriller
-18;10;Dystopia
-19;10;Fairy Tale
-20;;Non-Fiction
-21;20;Biography
-22;21;Autobiography
-23;20;Essay
-24;20;Speech

bookshop/db/init.js

@@ -4,21 +4,15 @@
  * currencies, if not obtained through @capire/common.
  */
 
-module.exports = async (tx)=>{
+module.exports = async ()=>{
 
-  const has_common = tx.model.definitions['sap.common.Currencies']?.elements.numcode
-  if (has_common) return
-
-  const already_filled = await tx.exists('sap.common.Currencies',{code:'EUR'})
-  if (already_filled) return
-
-  await tx.run (INSERT.into ('sap.common.Currencies') .columns (
-    [ 'code', 'symbol', 'name' ]
+  await UPSERT.into ('sap.common.Currencies') .columns (
+    'code','symbol','name'
   ) .rows (
-    [ 'EUR', '€', 'Euro' ],
-    [ 'USD', '$', 'US Dollar' ],
-    [ 'GBP', '£', 'British Pound' ],
-    [ 'ILS', '₪', 'Shekel' ],
-    [ 'JPY', '¥', 'Yen' ],
-  ))
+    [ 'EUR','€','Euro' ],
+    [ 'USD','$','US Dollar' ],
+    [ 'GBP','£','British Pound' ],
+    [ 'ILS','₪','Shekel' ],
+    [ 'JPY','¥','Yen' ],
+  )
 }

bookshop/srv/cat-service.cds

@@ -10,12 +10,7 @@ service CatalogService @(path:'/browse') {
     author.name as author
   } excluding { createdBy, modifiedBy };
 
-<<<<<<< HEAD
-  @requires_: 'authenticated-user'
-  action submitOrder (book : Integer, amount: Integer);
-=======
   @requires: 'authenticated-user'
   action submitOrder ( book: Books:ID, quantity: Integer ) returns { stock: Integer };
   event OrderedBook : { book: Books:ID; quantity: Integer; buyer: String };
->>>>>>> 534af7ffee60e086c563dbaa450e86e5fca5cf2b
 }

bookstore/package.json

@@ -26,7 +26,8 @@
         "[production]": { "kind": "enterprise-messaging" }
       },
       "db": {
-        "kind": "sql"
+        "kind": "sql",
+        "schema_evolution": "auto"
       }
     },
     "log": { "service": true }

fiori/package.json

@@ -34,7 +34,8 @@
         }
       },
       "db": {
-        "kind": "sql"
+        "kind": "sql",
+        "schema_evolution": "auto"
       },
       "db-ext": {
         "[development]": {

fiori/server.js

@@ -1,8 +1,8 @@
-// install OData v2 adapter
 const cds = require("@sap/cds")
-const proxy = require('@sap/cds-odata-v2-adapter-proxy')
-const opts = global.it ? { target:'auto' } : {}   // for tests, set 'auto' to detect port dynamically
-cds.on('bootstrap', app => app.use(proxy(opts)))  // install proxy
-cds.log('cov2ap','silent') // suppress anoying log outpout, e.g. for `npm run mocha -- --reporter nyan`
 
-module.exports = require('@capire/bookstore/server.js')
+// install OData v2 adapter
+const proxy = require('@sap/cds-odata-v2-adapter-proxy')
+const proxyOpts = global.it ? { target:'auto' } : {} // for tests, set 'auto' to detect port dynamically
+cds.on('bootstrap', app => app.use(proxy(proxyOpts)))
+
+module.exports = require('@capire/bookstore/server.js')

gdpr/.pdm/pdm-config.json

@@ -1,18 +0,0 @@
-{
-  "fullyQualifiedApplicationName": "gdpr-bookshop",
-  "fullyQualifiedModuleName": "gdpr-srv",
-  "applicationTitle": "PDM Bookshop",
-  "applicationTitleKey": "PDM Bookshop",
-  "applicationURL": "https://gdpr-srv.cfapps.sap.hana.ondemand.com/",
-  "endPoints": [
-    {
-      "type": "odatav4",
-      "serviceName": "pdm-service",
-      "serviceTitle": "GDPR",
-      "serviceTitleKey": "GDPR",
-      "serviceURI": "pdm",
-      "hasGdprV4Annotations": true,
-      "cacheControl": "no-cache"
-    }
-  ]
-}

gdpr/.pdm/pdm-instance-config.json

@@ -1,8 +0,0 @@
-{
-  "xs-security": {
-    "xsappname": "gdpr-bookshop",
-    "authorities": ["$ACCEPT_GRANTED_AUTHORITIES"]
-  },
-  "fullyQualifiedApplicationName": "gdpr-bookshop",
-  "appConsentServiceEnabled": true
-}

gdpr/db/AuditLogStore.cds

@@ -1,28 +0,0 @@
-using {
-  managed,
-  cuid,
-  sap.common.CodeList
-} from '@sap/cds/common';
-
-namespace sap.capire.auditLog;
-
-entity AuditLogStore : cuid {
-
-  Action          : String enum {
-    DataAccess;
-    DataModification
-  };
-
-  User            : String;
-  Timestamp       : Timestamp;
-  Tenant          : String;
-  Channel         : String;
-  DataSubjectType : String; // Bussiness Partner
-  DataSubjectRole : String; // Customer // Employee // ...
-  DataSubjectID   : LargeString; // key value pair as JSON
-  ObjectType      : String; // like SalesOrder
-  ObjectKey       : LargeString; // key value pair as JSON
-
-  Blob            : LargeString; // Payload: DataModification or Data Access as BLOB
-
-}

gdpr/db/data-privacy.cds

@@ -1,38 +0,0 @@
-// Proxy for importing schema from bookshop sample
-using {sap.capire.bookshop} from './schema';
-
-// annotations for Data Privacy
-annotate bookshop.Customers with @PersonalData: {
-  DataSubjectRole: 'Customer',
-  EntitySemantics: 'DataSubject'
-} {
-  ID          @PersonalData.FieldSemantics    : 'DataSubjectID';
-  email       @PersonalData.IsPotentiallyPersonal;
-  firstName   @PersonalData.IsPotentiallyPersonal;
-  lastName    @PersonalData.IsPotentiallyPersonal;
-  dateOfBirth @PersonalData.IsPotentiallyPersonal;
-}
-
-annotate bookshop.BillingData with @PersonalData: {
-  DataSubjectRole: 'Customer',
-  EntitySemantics: 'DataSubjectDetails'
-} {
-  customer     @PersonalData.FieldSemantics     : 'DataSubjectID';
-  creditCardNo @PersonalData.IsPotentiallySensitive;
-}
-
-annotate bookshop.Addresses with @PersonalData: {
-  DataSubjectRole: 'Customer',
-  EntitySemantics: 'DataSubjectDetails'
-} {
-  customer @PersonalData.FieldSemantics       : 'DataSubjectID';
-  street   @PersonalData.IsPotentiallyPersonal;
-  town     @PersonalData.IsPotentiallyPersonal;
-  country  @PersonalData.IsPotentiallyPersonal;
-}
-
-annotate bookshop.Orders with @PersonalData.EntitySemantics: 'Other' {
-  ID              @PersonalData.FieldSemantics             : 'ContractRelatedID';
-  customer        @PersonalData.FieldSemantics             : 'DataSubjectID';
-  personalComment @PersonalData.IsPotentiallyPersonal;
-}

gdpr/db/data/sap.capire.bookshop-Books.csv

@@ -1,6 +0,0 @@
-ID;title;descr;author_ID;stock;price;currency_code;genre_ID
-201;Wuthering Heights;"Wuthering Heights, Emily Brontë's only novel, was published in 1847 under the pseudonym ""Ellis Bell"". It was written between October 1845 and June 1846. Wuthering Heights and Anne Brontë's Agnes Grey were accepted by publisher Thomas Newby before the success of their sister Charlotte's novel Jane Eyre. After Emily's death, Charlotte edited the manuscript of Wuthering Heights and arranged for the edited version to be published as a posthumous second edition in 1850.";101;12;11.11;GBP;11
-207;Jane Eyre;"Jane Eyre /ɛər/ (originally published as Jane Eyre: An Autobiography) is a novel by English writer Charlotte Brontë, published under the pen name ""Currer Bell"", on 16 October 1847, by Smith, Elder & Co. of London. The first American edition was published the following year by Harper & Brothers of New York. Primarily a bildungsroman, Jane Eyre follows the experiences of its eponymous heroine, including her growth to adulthood and her love for Mr. Rochester, the brooding master of Thornfield Hall. The novel revolutionised prose fiction in that the focus on Jane's moral and spiritual development is told through an intimate, first-person narrative, where actions and events are coloured by a psychological intensity. The book contains elements of social criticism, with a strong sense of Christian morality at its core and is considered by many to be ahead of its time because of Jane's individualistic character and how the novel approaches the topics of class, sexuality, religion and feminism.";107;11;12.34;GBP;11
-251;The Raven;"""The Raven"" is a narrative poem by American writer Edgar Allan Poe. First published in January 1845, the poem is often noted for its musicality, stylized language, and supernatural atmosphere. It tells of a talking raven's mysterious visit to a distraught lover, tracing the man's slow fall into madness. The lover, often identified as being a student, is lamenting the loss of his love, Lenore. Sitting on a bust of Pallas, the raven seems to further distress the protagonist with its constant repetition of the word ""Nevermore"". The poem makes use of folk, mythological, religious, and classical references.";150;333;13.13;USD;16
-252;Eleonora;"""Eleonora"" is a short story by Edgar Allan Poe, first published in 1842 in Philadelphia in the literary annual The Gift. It is often regarded as somewhat autobiographical and has a relatively ""happy"" ending.";150;555;14;USD;16
-271;Catweazle;Catweazle is a British fantasy television series, starring Geoffrey Bayldon in the title role, and created by Richard Carpenter for London Weekend Television. The first series, produced and directed by Quentin Lawrence, was screened in the UK on ITV in 1970. The second series, directed by David Reid and David Lane, was shown in 1971. Each series had thirteen episodes, most but not all written by Carpenter, who also published two books based on the scripts.;170;22;15;EUR;13

gdpr/db/data/sap.capire.bookshop-CustomerBillingData.csv

@@ -1,3 +0,0 @@
-ID;modifiedAt;createdAt;createdBy;modifiedBy;Customer_ID;creditCardNo
-1e2f2640-6866-4dcf-8f4d-3027aa831cad;2019-04-04;2019-01-31;admin@business.com;admin@business.com;8e2f2640-6866-4dcf-8f4d-3027aa831cad;2222-1111-6666-7777
-24e718c9-ff99-47f1-8ca3-950c850777d4;2019-04-04;2019-01-30;admin@business.com;admin@business.com;74e718c9-ff99-47f1-8ca3-950c850777d4;3333-2222-5555-8888

gdpr/db/data/sap.capire.bookshop-CustomerPostalAddress.csv

@@ -1,3 +0,0 @@
-ID;modifiedAt;createdAt;createdBy;modifiedBy;Customer_ID;street;town;country_code;someOtherField
-1e2f2640-6866-4dcf-8f4d-3027aa831cad;2019-04-04;2019-01-31;admin@business.com;admin@business.com;8e2f2640-6866-4dcf-8f4d-3027aa831cad;Hauptstrasse 11;Berlin;DE;Eine Bemerkung
-24e718c9-ff99-47f1-8ca3-950c850777d4;2019-04-04;2019-01-30;admin@business.com;admin@business.com;74e718c9-ff99-47f1-8ca3-950c850777d4;Main Street 22;London;GB;Some Remark

gdpr/db/data/sap.capire.bookshop-Customers.csv

@@ -1,3 +0,0 @@
-ID;modifiedAt;createdAt;createdBy;modifiedBy;email;firstName;lastName;dateOfBirth
-8e2f2640-6866-4dcf-8f4d-3027aa831cad;2019-04-04;2019-01-31;admin@business.com;admin@business.com;john.doe@test.com;John;Doe;1970-01-01
-74e718c9-ff99-47f1-8ca3-950c850777d4;2019-04-04;2019-01-30;admin@business.com;admin@business.com;jane.doe@sap.com;Jane;Doe;1980-11-11

gdpr/db/data/sap.capire.bookshop-OrderItems.csv

@@ -1,4 +0,0 @@
-ID;amount;parent_ID;book_ID;netAmount
-78040e66-1dcd-4ffb-ab10-fdce32028b79;1;5e2f2640-6866-4dcf-8f4d-3027aa831cad;201;11.11
-84e718c9-ff99-47f1-8ca3-950c850777d4;1;5e2f2640-6866-4dcf-8f4d-3027aa831cad;271;15
-f9641166-e050-4261-bfee-d1e797e6cb7f;2;44e718c9-ff99-47f1-8ca3-950c850777d4;252;28

gdpr/db/data/sap.capire.bookshop-Orders.csv

@@ -1,3 +0,0 @@
-ID;modifiedAt;createdAt;createdBy;modifiedBy;OrderNo;currency_code;Customer_ID
-5e2f2640-6866-4dcf-8f4d-3027aa831cad;2019-04-04;2019-01-31;john.doe@test.com;john.doe@test.com;1;USD;8e2f2640-6866-4dcf-8f4d-3027aa831cad
-44e718c9-ff99-47f1-8ca3-950c850777d4;2019-04-04;2019-01-30;jane.doe@test.com;jane.doe@test.com;2;USD;74e718c9-ff99-47f1-8ca3-950c850777d4

gdpr/db/schema.cds

@@ -1,41 +0,0 @@
-// Proxy for importing schema from bookshop sample
-using {sap.capire.bookshop.Books} from '../../bookshop/db/schema';
-using {sap.capire.orders.Orders} from '../../orders/db/schema';
-using {sap.capire.orders.OrderItems} from '../../orders/db/schema';
-using {
-  Country,
-  managed,
-  cuid
-} from '@sap/cds/common';
-
-namespace sap.capire.bookshop;
-
-extend Orders with {
-  customer        : Association to Customers;
-  personalComment : String;
-}
-
-entity Customers : cuid, managed {
-  email       : String;
-  firstName   : String;
-  lastName    : String;
-  dateOfBirth : Date;
-  billingData : Composition of BillingData
-                  on billingData.customer = $self;
-  addresses   : Composition of Addresses
-                  on addresses.customer = $self;
-}
-
-entity Addresses : cuid, managed {
-  customer       : Association to one Customers;
-  street         : String(128);
-  town           : String(128);
-  country        : Country;
-  someOtherField : String(128);
-};
-
-
-entity BillingData : cuid, managed {
-  customer     : Association to one Customers;
-  creditCardNo : String;
-};

gdpr/db/src/.hdiconfig

@@ -1,136 +0,0 @@
-{
-    "file_suffixes": {
-        "csv": {
-            "plugin_name": "com.sap.hana.di.tabledata.source"
-        },
-        "hdbafllangprocedure": {
-            "plugin_name": "com.sap.hana.di.afllangprocedure"
-        },
-        "hdbanalyticprivilege": {
-            "plugin_name": "com.sap.hana.di.analyticprivilege"
-        },
-        "hdbcalculationview": {
-            "plugin_name": "com.sap.hana.di.calculationview"
-        },
-        "hdbcollection": {
-            "plugin_name": "com.sap.hana.di.collection"
-        },
-        "hdbconstraint": {
-            "plugin_name": "com.sap.hana.di.constraint"
-        },
-        "hdbdropcreatetable": {
-            "plugin_name": "com.sap.hana.di.dropcreatetable"
-        },
-        "hdbflowgraph": {
-            "plugin_name": "com.sap.hana.di.flowgraph"
-        },
-        "hdbfunction": {
-            "plugin_name": "com.sap.hana.di.function"
-        },
-        "hdbgraphworkspace": {
-            "plugin_name": "com.sap.hana.di.graphworkspace"
-        },
-        "hdbhadoopmrjob": {
-            "plugin_name": "com.sap.hana.di.virtualfunctionpackage.hadoop"
-        },
-        "hdbindex": {
-            "plugin_name": "com.sap.hana.di.index"
-        },
-        "hdblibrary": {
-            "plugin_name": "com.sap.hana.di.library"
-        },
-        "hdbmigrationtable": {
-            "plugin_name": "com.sap.hana.di.table.migration"
-        },
-        "hdbprocedure": {
-            "plugin_name": "com.sap.hana.di.procedure"
-        },
-        "hdbprojectionview": {
-            "plugin_name": "com.sap.hana.di.projectionview"
-        },
-        "hdbprojectionviewconfig": {
-            "plugin_name": "com.sap.hana.di.projectionview.config"
-        },
-        "hdbreptask": {
-            "plugin_name": "com.sap.hana.di.reptask"
-        },
-        "hdbresultcache": {
-            "plugin_name": "com.sap.hana.di.resultcache"
-        },
-        "hdbrole": {
-            "plugin_name": "com.sap.hana.di.role"
-        },
-        "hdbroleconfig": {
-            "plugin_name": "com.sap.hana.di.role.config"
-        },
-        "hdbsearchruleset": {
-            "plugin_name": "com.sap.hana.di.searchruleset"
-        },
-        "hdbsequence": {
-            "plugin_name": "com.sap.hana.di.sequence"
-        },
-        "hdbstatistics": {
-            "plugin_name": "com.sap.hana.di.statistics"
-        },
-        "hdbstructuredprivilege": {
-            "plugin_name": "com.sap.hana.di.structuredprivilege"
-        },
-        "hdbsynonym": {
-            "plugin_name": "com.sap.hana.di.synonym"
-        },
-        "hdbsynonymconfig": {
-            "plugin_name": "com.sap.hana.di.synonym.config"
-        },
-        "hdbsystemversioning": {
-            "plugin_name": "com.sap.hana.di.systemversioning"
-        },
-        "hdbtable": {
-            "plugin_name": "com.sap.hana.di.table"
-        },
-        "hdbtabledata": {
-            "plugin_name": "com.sap.hana.di.tabledata"
-        },
-        "hdbtabletype": {
-            "plugin_name": "com.sap.hana.di.tabletype"
-        },
-        "hdbtrigger": {
-            "plugin_name": "com.sap.hana.di.trigger"
-        },
-        "hdbview": {
-            "plugin_name": "com.sap.hana.di.view"
-        },
-        "hdbvirtualfunction": {
-            "plugin_name": "com.sap.hana.di.virtualfunction"
-        },
-        "hdbvirtualfunctionconfig": {
-            "plugin_name": "com.sap.hana.di.virtualfunction.config"
-        },
-        "hdbvirtualpackagehadoop": {
-            "plugin_name": "com.sap.hana.di.virtualpackage.hadoop"
-        },
-        "hdbvirtualpackagesparksql": {
-            "plugin_name": "com.sap.hana.di.virtualpackage.sparksql"
-        },
-        "hdbvirtualprocedure": {
-            "plugin_name": "com.sap.hana.di.virtualprocedure"
-        },
-        "hdbvirtualprocedureconfig": {
-            "plugin_name": "com.sap.hana.di.virtualprocedure.config"
-        },
-        "hdbvirtualtable": {
-            "plugin_name": "com.sap.hana.di.virtualtable"
-        },
-        "hdbvirtualtableconfig": {
-            "plugin_name": "com.sap.hana.di.virtualtable.config"
-        },
-        "properties": {
-            "plugin_name": "com.sap.hana.di.tabledata.properties"
-        },
-        "tags": {
-            "plugin_name": "com.sap.hana.di.tabledata.properties"
-        },
-        "txt": {
-            "plugin_name": "com.sap.hana.di.copyonly"
-        }
-    }
-}

gdpr/index.cds

@@ -1,4 +0,0 @@
-namespace sap.capire.gdpr; //> important for reflection
-using from './db/schema';
-using from './srv/pdm-service';
-using from './srv/log-service';

gdpr/manifest.yml

@@ -1,31 +0,0 @@
-# Generated manifest.yml based on template version 0.1.0
-# appName = gdpr
-# language=nodejs
-# multiTenant=false
----
-applications:
-# -----------------------------------------------------------------------------------
-# Backend Service
-# -----------------------------------------------------------------------------------
-- name: gdpr-srv
-  path: gen/srv
-  memory: 256M
-  buildpack: nodejs_buildpack
-  services:
-  - gdpr-db
-  - uaa
-#  - name: pdm
-#    parameters: ./pdm-config.json 
-
-# -----------------------------------------------------------------------------------
-# HANA Database Content Deployer App
-# -----------------------------------------------------------------------------------
-- name: gdpr-db-deployer
-  path: gen/db
-  no-route: true
-  health-check-type: process
-  memory: 256M
-  instances: 1
-  buildpack: nodejs_buildpack
-  services:
-  - gdpr-db

gdpr/mta.yaml

@@ -1,72 +0,0 @@
-## Generated mta.yaml based on template version 0.4.0
-## appName = gdpr
-## language=nodejs; multitenant=false
-## approuter=
-_schema-version: '3.1'
-ID: capire.gdpr
-version: 1.0.0
-description: "gdpr"
-parameters:
-  enable-parallel-deployments: true
-   
-build-parameters:
-  before-all:
-   - builder: custom
-     commands:
-      - npm install --production
-      - npx -p @sap/cds-dk cds build --production
-
-modules:
- # --------------------- SERVER MODULE ------------------------
- - name: gdpr-srv
- # ------------------------------------------------------------
-   type: nodejs
-   path: gen/srv
-   parameters:
-     buildpack: nodejs_buildpack
-   requires:
-    # Resources extracted from CAP configuration
-    - name: gdpr-db
-    - name: gdpr-uaa
-   provides:
-    - name: srv-api      # required by consumers of CAP services (e.g. approuter)
-      properties:
-        srv-url: ${default-url}
-
- # -------------------- SIDECAR MODULE ------------------------
- - name: gdpr-db-deployer
- # ------------------------------------------------------------
-   type: hdb
-   path: gen/db  
-   parameters:
-     buildpack: nodejs_buildpack
-   requires:
-    # 'hana' and 'xsuaa' resources extracted from CAP configuration
-    - name: gdpr-db
-    - name: gdpr-uaa
-
-
-resources:
- # services extracted from CAP configuration
- # 'service-plan' can be configured via 'cds.requires.<name>.vcap.plan'
-# ------------------------------------------------------------
- - name: gdpr-db
-# ------------------------------------------------------------
-   type: com.sap.xs.hdi-container
-   parameters:
-     service: hana  # or 'hanatrial' on trial landscapes
-     service-plan: hdi-shared
-   properties:
-     hdi-service-name: ${service-name}
-# ------------------------------------------------------------
- - name: gdpr-uaa
-# ------------------------------------------------------------
-   type: org.cloudfoundry.managed-service
-   parameters:
-     service: xsuaa
-     service-plan: application  
-     config:
-       xsappname: gdpr-${space}    #  name + space dependency
-       tenant-mode: dedicated
-
-

gdpr/package.json

@@ -1,33 +0,0 @@
-{
-    "name": "@capire/gdpr",
-    "version": "1.0.0",
-    "dependencies": {
-        "@capire/bookshop": "../bookshop",
-        "@capire/common": "../common",
-        "@capire/orders": "../orders",
-        "@sap/cds": "^5",
-        "@sap/hana-client": "^2.4.177",
-        "@sap/xsenv": "^3.1.0",
-        "@sap/xssec": "^3.1.1",
-        "express": "^4.17.1",
-        "passport": "^0.4.1"
-    },
-    "scripts": {
-        "start": "cds run --in-memory?",
-        "watch": "cds watch"
-    },
-    "cds": {
-        "requires": {
-            "db": {
-                "kind": "sql"
-            },
-            "uaa": {
-                "kind": "xsuaa"
-            },
-            "audit-log": {
-                "impl": "srv/customAuditLog.js"
-            }
-        },
-        "features": {"audit_personal_data": true}
-    }
-}

gdpr/services-manifest.yml

@@ -1,18 +0,0 @@
-# Generated services-manifest.yml based on template version 0.1.0
-# appName = gdpr
----
-create-services:
-# ------------------------------------------------------------
-  - name:   gdpr-db
-    broker: hana  # 'hanatrial' on trial landscapes
-    plan: "hdi-shared"
-  - name:   pdm
-    broker: personal-data-manager-service  
-    plan: standard
-    parameters: ./.pdm/pdm-instance-config.json
-  - name:   uaa
-    broker: xsuaa
-    plan: application
-    parameters: xs-security.json
-     
-

gdpr/srv/customAuditLog.js

@@ -1,70 +0,0 @@
-const cds = require('@sap/cds')
-
-// FIXME: no longer works like this with new audit logging plugin
-module.exports = class MyAuditLogService extends cds.AuditLogService {
-  async init() {
-    // console.log('My Audit Log');
-    // call AuditLogService's init
-    await super.init()
-
-    const db = await cds.connect.to('db')
-    const { AuditLogStore } = db.entities('sap.capire.auditLog')
-
-    // register custom handlers
-    this.on('dataAccessLog', async req => {
-      const logs = []
-
-      const action = 'DataAccess'
-      const user = req.user.id
-      const timestamp = req.timestamp
-      const tenant = req.tenant
-      const channel = req.channel
-
-      req.data.accesses.forEach(dataAccess => {
-        logs.push({
-          Action: action,
-          User: user,
-          Timestamp: timestamp,
-          Tenant: tenant,
-          Channel: channel,
-          DataSubjectType: dataAccess.data_subject.type,
-          DataSubjectRole: dataAccess.data_subject.role,
-          DataSubjectID: JSON.stringify(dataAccess.data_subject.id),
-          ObjectType: dataAccess.object.type,
-          ObjectKey: JSON.stringify(dataAccess.object.id),
-          Blob: JSON.stringify(dataAccess)
-        })
-      })
-
-      await INSERT.into(AuditLogStore).entries(logs)
-    })
-
-    this.on('dataModificationLog', async req => {
-      const mods = []
-
-      const action = 'DataModification'
-      const user = req.user.id
-      const timestamp = req.timestamp
-      const tenant = req.tenant
-      const channel = req.channel
-
-      req.data.modifications.forEach(dataModification => {
-        mods.push({
-          Action: action,
-          User: user,
-          Timestamp: timestamp,
-          Tenant: tenant,
-          Channel: channel,
-          DataSubjectType: dataModification.data_subject.type,
-          DataSubjectRole: dataModification.data_subject.role,
-          DataSubjectID: JSON.stringify(dataModification.data_subject.id),
-          ObjectType: dataModification.object.type,
-          ObjectKey: JSON.stringify(dataModification.object.id),
-          Blob: JSON.stringify(dataModification)
-        })
-      })
-
-      await INSERT.into(AuditLogStore).entries(mods)
-    })
-  }
-}

gdpr/srv/log-service.cds

@@ -1,13 +0,0 @@
-using {sap.capire.bookshop as db} from '../db/data-privacy';
-using {sap.capire.orders as dbo} from '../db/data-privacy';
-using {sap.capire.auditLog as log} from '../db/AuditLogStore.cds';
-
-//@requires: 'PersonalDataManagerUser' // security check
-service LogService {
-
-  entity Customers     as projection on db.Customers;
-  entity Addresses     as projection on db.Addresses;
-  entity Orders        as projection on dbo.Orders;
-  entity AuditLogStore as projection on log.AuditLogStore;
-
-};

gdpr/srv/pdm-service.cds

@@ -1,43 +0,0 @@
-using {sap.capire.bookshop as db} from '../db/data-privacy';
-using {sap.capire.bookshop.Books} from '../db/data-privacy';
-using {sap.capire.orders.Orders} from '../db/data-privacy';
-using {sap.capire.orders.OrderItems} from '../db/data-privacy';
-
-//@requires: 'PersonalDataManagerUser' // security check
-service PDMService {
-
-  // Data Privacy annotations on 'Customers', 'Addresses', and 'BillingData' are derived from original entity definitions
-  entity Customers     as projection on db.Customers;
-  entity Addresses     as projection on db.Addresses;
-  entity BillingData   as projection on db.BillingData;
-
-  //   create view on Orders and Items as flat projection
-  entity OrderItemView as
-    select from Orders {
-          ID,
-      key Items.ID        as item_ID,
-          OrderNo,
-          customer.ID     as customer_ID,
-          customer.email  as customer_email,
-          Items.book.ID   as item_Book_ID,
-          Items.amount    as item_Amount,
-          Items.netAmount as item_NetAmount
-    };
-
-  //  annotate new view
-  annotate PDMService.OrderItemView with @(PersonalData.EntitySemantics: 'Other') {
-    item_ID        @PersonalData.FieldSemantics: 'ContractRelatedID';
-    customer_ID    @PersonalData.FieldSemantics: 'DataSubjectID';
-    customer_email @PersonalData.IsPotentiallyPersonal;
-  };
-
-  // annotations for Personal Data Manager - Search Fields
-  annotate Customers with @(Communication.Contact: {
-    n   : {
-      surname: lastName,
-      given  : firstName
-    },
-    bday: dateOfBirth
-  });
-
-};

gdpr/test.http

@@ -1,25 +0,0 @@
-###
-
-get http://localhost:4004/log/AuditLogStore
-
-###
-
-get http://localhost:4004/log/Customers
-
-###
-
-post http://localhost:4004/log/Customers
-Content-Type: application/json
-
-{
-            "ID": "22e718c9-ff99-47f1-8ca3-950c850777d4",
-            "createdAt": "2019-01-30T00:00:00.000Z",
-            "createdBy": "admin@business.com",
-            "modifiedAt": "2019-04-04T00:00:00.000Z",
-            "modifiedBy": "admin@business.com",
-            "email": "johanna.doe@company.org",
-            "firstName": "Queen Johanna",
-            "lastName": "Doe",
-            "creditCardNo": "1313-7171-5656-7878",
-            "dateOfBirth": "2001-11-11"
-}

gdpr/xs-security.json

@@ -1,13 +0,0 @@
-{
-    "xsappname": "gdpr-bookshop",
-    "tenant-mode": "shared",
-    "scopes": [
-        {
-            "name": "$XSAPPNAME.PersonalDataManagerUser",
-            "description": "Authority for Personal Data Manager",
-            "grant-as-authority-to-apps": [
-                "$XSSERVICENAME(pdm)"
-            ]
-        }
-    ]
-}

orders/db/schema.cds

@@ -1,20 +1,17 @@
-using { sap.capire.bookshop.Books }       from '../../bookshop/db/schema';
-using { User, Currency, managed, cuid }   from '../../common';
+using { Currency, User, managed, cuid } from '@sap/cds/common';
 namespace sap.capire.orders;
 
 entity Orders : cuid, managed {
   OrderNo  : String(22) @title:'Order Number'; //> readable key
-  Items    : Composition of many OrderItems;
-  buyer    : User;
-  currency : Currency;
-}
-
-entity OrderItems : cuid, managed {
-    book      : Association to Products;
+  Items    : Composition of many {
+    key ID    : UUID;
+    product   : Association to Products;
     quantity  : Integer;
     title     : String; //> intentionally replicated as snapshot from product.title
-    amount    : Double; //> materialized calculated field
-    netAmount : Double; 
+    price     : Double; //> materialized calculated field
+  };
+  buyer    : User;
+  currency : Currency;
 }
 
 /** This is a stand-in for arbitrary ordered Products */
@@ -24,4 +21,4 @@ entity Products @(cds.persistence.skip:'always') {
 
 
 // this is to ensure we have filled-in currencies
-// using from '@capire/common';
+using from '@capire/common';

package.json

@@ -5,12 +5,6 @@
   "repository": "https://github.com/sap-samples/cloud-cap-samples.git",
   "author": "daniel.hutzel@sap.com",
   "dependencies": {
-    "@capire/bookshop": "./bookshop",
-    "@capire/common": "./common",
-    "@capire/fiori": "./fiori",
-    "@capire/media": "./media",
-    "@capire/orders": "./orders",
-    "@capire/reviews": "./reviews",
     "@sap/cds": ">=5.5.3"
   },
   "workspaces": [
@@ -26,7 +20,6 @@
     "./reviews"
   ],
   "devDependencies": {
-    "@sap/eslint-plugin-cds": "^2.6.1",
     "axios": "^1",
     "chai": "^4.3.4",
     "chai-as-promised": "^7.1.1",
@@ -36,12 +29,13 @@
   },
   "scripts": {
     "cleanup": "rm -rf node_modules && rm -rf */node_modules && rm -rf */*/node_modules",
+    "registry": "node .registry/server.js",
     "bookshop": "cds watch bookshop",
     "fiori": "cds watch fiori",
     "hello": "cds watch hello",
     "media": "cds watch media",
-    "mocha": "CDS_TEST_SILENT=y npx mocha",
-    "jest": "npx jest --silent",
+    "mocha": "npx mocha || echo",
+    "jest": "npx jest",
     "start": "cds watch fiori",
     "test": "npm run jest -- --silent",
     "test:hello": "cd hello && npm test"
@@ -54,8 +48,7 @@
   },
   "mocha": {
     "recursive": true,
-    "parallel": true,
-    "timeout": 6666
+    "parallel": true
   },
   "license": "SAP SAMPLE CODE LICENSE",
   "private": true

reviews/db/data/sap.capire.reviews-Reviews.csv

@@ -1,5 +1,5 @@
-subject;rating;reviewer;title;text
-201;5;bob;Intriguing;Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet.
-201;4;bob;Fascinating;Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Id diam maecenas ultricies mi eget mauris pharetra et. Risus at ultrices mi tempus imperdiet nulla malesuada pellentesque. Pulvinar mattis nunc sed blandit libero. Facilisis magna etiam tempor orci eu. Nec sagittis aliquam malesuada bibendum arcu. Eu consequat ac felis donec. Ultricies tristique nulla aliquet enim tortor at auctor urna nunc. Tortor posuere ac ut consequat semper viverra nam libero. Amet nisl suscipit adipiscing bibendum est ultricies integer quis auctor. Scelerisque purus semper eget duis at tellus. Elementum tempus egestas sed sed risus pretium. Arcu dictum varius duis at. Amet luctus venenatis lectus magna fringilla urna. Eget velit aliquet sagittis id consectetur purus ut faucibus. Vitae auctor eu augue ut lectus. Fermentum iaculis eu non diam phasellus vestibulum.
-207;2;bob;What is this?;Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Libero justo laoreet sit amet cursus sit amet dictum. Nunc faucibus a pellentesque sit. Dis parturient montes nascetur ridiculus mus mauris vitae ultricies. Enim nunc faucibus a pellentesque. Commodo quis imperdiet massa tincidunt nunc pulvinar sapien. Cras ornare arcu dui vivamus. Facilisi etiam dignissim diam quis enim lobortis. Et molestie ac feugiat sed. Urna neque viverra justo nec ultrices dui. Ullamcorper a lacus vestibulum sed arcu non. Volutpat ac tincidunt vitae semper quis. Dignissim sodales ut eu sem. Feugiat in fermentum posuere urna nec. At augue eget arcu dictum varius.
-251;3;bob;It's dark...;Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Suscipit tellus mauris a diam. Velit aliquet sagittis id consectetur purus ut. Viverra adipiscing at in tellus integer. Vitae elementum curabitur vitae nunc. Mattis ullamcorper velit sed ullamcorper morbi. Diam quis enim lobortis scelerisque. Auctor neque vitae tempus quam pellentesque nec nam aliquam. Semper auctor neque vitae tempus. Quis eleifend quam adipiscing vitae proin. Neque convallis a cras semper auctor neque vitae. Imperdiet massa tincidunt nunc pulvinar sapien et ligula. Sit amet consectetur adipiscing elit ut aliquam purus. Pretium quam vulputate dignissim suspendisse.
+ID;subject;rating;reviewer;title;text
+1223a37c-9dca-4c4c-a629-9dd93b947864;201;5;bob;Intriguing;Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet.
+ae275d4f-1fb5-491b-ba6e-79b339e1edef;201;4;bob;Fascinating;Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Id diam maecenas ultricies mi eget mauris pharetra et. Risus at ultrices mi tempus imperdiet nulla malesuada pellentesque. Pulvinar mattis nunc sed blandit libero. Facilisis magna etiam tempor orci eu. Nec sagittis aliquam malesuada bibendum arcu. Eu consequat ac felis donec. Ultricies tristique nulla aliquet enim tortor at auctor urna nunc. Tortor posuere ac ut consequat semper viverra nam libero. Amet nisl suscipit adipiscing bibendum est ultricies integer quis auctor. Scelerisque purus semper eget duis at tellus. Elementum tempus egestas sed sed risus pretium. Arcu dictum varius duis at. Amet luctus venenatis lectus magna fringilla urna. Eget velit aliquet sagittis id consectetur purus ut faucibus. Vitae auctor eu augue ut lectus. Fermentum iaculis eu non diam phasellus vestibulum.
+3fffe4b7-d34f-4fd3-9aab-f609f41539cc;207;2;bob;What is this?;Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Libero justo laoreet sit amet cursus sit amet dictum. Nunc faucibus a pellentesque sit. Dis parturient montes nascetur ridiculus mus mauris vitae ultricies. Enim nunc faucibus a pellentesque. Commodo quis imperdiet massa tincidunt nunc pulvinar sapien. Cras ornare arcu dui vivamus. Facilisi etiam dignissim diam quis enim lobortis. Et molestie ac feugiat sed. Urna neque viverra justo nec ultrices dui. Ullamcorper a lacus vestibulum sed arcu non. Volutpat ac tincidunt vitae semper quis. Dignissim sodales ut eu sem. Feugiat in fermentum posuere urna nec. At augue eget arcu dictum varius.
+71c037b3-767d-4f5d-9e90-90b894a2043a;251;3;bob;It's dark...;Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Suscipit tellus mauris a diam. Velit aliquet sagittis id consectetur purus ut. Viverra adipiscing at in tellus integer. Vitae elementum curabitur vitae nunc. Mattis ullamcorper velit sed ullamcorper morbi. Diam quis enim lobortis scelerisque. Auctor neque vitae tempus quam pellentesque nec nam aliquam. Semper auctor neque vitae tempus. Quis eleifend quam adipiscing vitae proin. Neque convallis a cras semper auctor neque vitae. Imperdiet massa tincidunt nunc pulvinar sapien et ligula. Sit amet consectetur adipiscing elit ut aliquam purus. Pretium quam vulputate dignissim suspendisse.

samples.md

@@ -1,7 +1,7 @@
 # Overview of Samples
 
 The following list gives an overview of the samples provided in subdirectories.
-Each sub directory essentially is an individual npm package arranged in an [all-in-one monorepo](#all-in-one-monorepo) umbrella setup.
+Each sub directory essentially is an individual npm package arranged in an [all-in-one monorepo](all-in-one-monorepo) umbrella setup.
 
 
 ## [@capire/hello-world](hello)

test/custom-handlers.test.js

@@ -3,9 +3,8 @@ const cds = require('@sap/cds/lib')
 describe('cap/samples - Custom Handlers', () => {
 
   const { GET, POST, expect } = cds.test(__dirname+'/../bookshop')
-  beforeAll(()=>{
-    cds.User.default = cds.User.Privileged // hard core monkey patch
-  })
+  if (cds.User.default) cds.User.default = cds.User.Privileged // hard core monkey patch
+  else cds.User = cds.User.Privileged // hard core monkey patch for older cds releases
 
   it('should reject out-of-stock orders', async () => {
     await POST `/browse/submitOrder ${{ book: 201, quantity: 5 }}`

test/fiori.test.js

@@ -1,12 +1,10 @@
 const cds = require('@sap/cds/lib')
 
-describe('cap/samples - Fiori APIs - v2', function() {
+describe('cap/samples - Fiori APIs - v2', () => {
 
   const { GET, expect, axios } = cds.test ('@capire/fiori', '--with-mocks')
   axios.defaults.auth = { username: 'alice', password: 'admin' }
 
-  // if (this.timeout) this.timeout(1e6)
-
   it('serves $metadata documents in v2', async () => {
     const { headers, data } = await GET `/v2/browse/$metadata`
     expect(headers).to.contain({

test/hierarchical-data.test.js

@@ -16,21 +16,21 @@ describe('cap/samples - Hierarchical Data', ()=>{
 	before ('bootstrap sqlite in-memory db...', async()=>{
 		await cds.deploy (model) .to ('sqlite::memory:')
 		expect (cds.db) .to.exist
-		expect (cds.db.model) .to.exist
+    expect (cds.db.model) .to.exist
 	})
 
 	it ('supports deeply nested inserts', ()=> INSERT.into (Cats,
-		{ ID:100, name:'Some Cats...', children:[
-			{ ID:101, name:'Cat', children:[
-				{ ID:102, name:'Kitty', children:[
-					{ ID:103, name:'Kitty Cat', children:[
-						{ ID:104, name:'Aristocat' } ]},
-					{ ID:105, name:'Kitty Bat' } ]},
-				{ ID:106, name:'Catwoman', children:[
-					{ ID:107, name:'Catalina' } ]} ]},
-			{ ID:108, name:'Catweazle' }
-		]}
-	))
+    { ID:100, name:'Some Cats...', children:[
+      { ID:101, name:'Cat', children:[
+        { ID:102, name:'Kitty', children:[
+          { ID:103, name:'Kitty Cat', children:[
+            { ID:104, name:'Aristocat' } ]},
+          { ID:105, name:'Kitty Bat' } ]},
+        { ID:106, name:'Catwoman', children:[
+          { ID:107, name:'Catalina' } ]} ]},
+      { ID:108, name:'Catweazle' }
+    ]}
+  ))
 
 	it ('supports nested reads', async()=>{
 		if (require('semver').gte(cds.version, '5.9.0')) {
@@ -101,12 +101,12 @@ describe('cap/samples - Hierarchical Data', ()=>{
 	})
 
 	it ('supports cascaded deletes', async()=>{
-		const affectedRows = await DELETE.from (Cats) .where ({ID:[102,106]})
-		expect (affectedRows) .to.be.greaterThan (0)
+    const affectedRows = await DELETE.from (Cats) .where ({ID:[102,106]})
+    expect (affectedRows) .to.be.greaterThan (0)
 		const expected = [
-			{ ID:100, name:'Some Cats...' },
-			{ ID:101, name:'Cat' },
-			{ ID:108, name:'Catweazle' }
+      { ID:100, name:'Some Cats...' },
+      { ID:101, name:'Cat' },
+      { ID:108, name:'Catweazle' }
 		]
 		expect ( await SELECT`ID,name`.from(Cats) ).to.eql (expected)
 	})

test/localized-data/package.json

@@ -0,0 +1,10 @@
+{
+  "cds": {
+    "requires": {
+      "db": {
+        "kind": "sql",
+        "schema_evolution": "auto"
+      }
+    }
+  }
+}

test/localized-data/services.test.js

@@ -1,12 +1,8 @@
-const cds = require('@sap/cds/lib')
-
 describe('cap/samples - Localized Data', () => {
 
-  const { GET, expect } = cds.test (__dirname)
-  beforeAll(()=>{
-    cds.User.default = cds.User.Privileged // hard core monkey patch
-  })
-
+  const { GET, expect, cds } = require('@sap/cds/lib').test (__dirname)
+  if (cds.User.default) cds.User.default = cds.User.Privileged // hard core monkey patch
+  else cds.User = cds.User.Privileged // hard core monkey patch for older cds releases
 
   it('serves localized $metadata documents', async () => {
     const { data } = await GET(`/browse/$metadata?sap-language=de`, { headers: { 'accept-language': 'de' }})

test/messaging.test.js

@@ -1,13 +1,16 @@
 const cds = require('@sap/cds/lib')
+const {resolve} = require('path')
 
 describe('cap/samples - Messaging', ()=>{
 
-    const { expect } = cds.test.in(__dirname,'..')
+    const { expect } = cds.test
     const _model = '@capire/reviews'
     const Reviews = 'sap.capire.reviews.Reviews'
-    beforeAll(()=>{
-        cds.User.default = cds.User.Privileged // hard core monkey patch
-    })
+    if (cds.User.default) cds.User.default = cds.User.Privileged // hard core monkey patch
+    else cds.User = cds.User.Privileged // hard core monkey patch for older cds releases
+
+    beforeAll(() => { cds.root = resolve(__dirname, '..') })
+    afterAll(() => { cds.root = process.cwd() })
 
     it ('should bootstrap sqlite in-memory db', async()=>{
         const db = await cds.deploy (_model) .to ('sqlite::memory:')
@@ -32,7 +35,6 @@ describe('cap/samples - Messaging', ()=>{
 
     it ('should add review', async ()=>{
         const review = { subject: "201", title: "Captivating", rating: ++N }
-        cds._debug = 1
         const response = await srv.create ('Reviews') .entries (review)
         expect (response) .to.containSubset (review)
     })

test/odata.test.js

@@ -4,6 +4,47 @@ describe('cap/samples - Bookshop APIs', () => {
   const { GET, expect, axios } = cds.test ('@capire/bookshop')
   axios.defaults.auth = { username: 'alice', password: 'admin' }
 
+  // Genres
+  const Drama = {
+    "name": "Drama",
+    "descr": null,
+    "ID": 11,
+    "parent_ID": 10
+  }
+  const Mystery = {
+    "name": "Mystery",
+    "descr": null,
+    "ID": 16,
+    "parent_ID": 10
+  }
+  const Romance = {
+    "name": "Romance",
+    "descr": null,
+    "ID": 15,
+    "parent_ID": 10
+  }
+
+  // Currencies
+  const GBP = {
+    "name": "British Pound",
+    "descr": null,
+    "code": "GBP",
+    "symbol": "£"
+  }
+  const USD = {
+    "name": "US Dollar",
+    "descr": null,
+    "code": "USD",
+    "symbol": "$"
+  }
+  const JPY = {
+    "name": "Yen",
+    "descr": null,
+    "code": "JPY",
+    "symbol": "¥"
+  }
+
+
   it('serves $metadata documents in v4', async () => {
     const { headers, status, data } = await GET `/browse/$metadata`
     expect(status).to.equal(200)
@@ -16,9 +57,6 @@ describe('cap/samples - Bookshop APIs', () => {
   })
 
   it('serves ListOfBooks?$expand=genre,currency', async () => {
-    const Mystery = { ID: 16, name: 'Mystery', descr: null, parent_ID: 10 }
-    const Romance = { ID: 15, name: 'Romance', descr: null, parent_ID: 10 }
-    const USD = { code: 'USD', name: 'US Dollar', descr: null, symbol: '$' }
     const { data } = await GET `/browse/ListOfBooks ${{
       params: { $search: 'Po', $select: `title,author`, $expand:`genre,currency` },
     }}`
@@ -88,10 +126,14 @@ describe('cap/samples - Bookshop APIs', () => {
   })
 
   it('serves user info', async () => {
-    const { data: alice } = await GET `/user/me`
-    expect(alice).to.containSubset({ id: 'alice', locale:'en' })
-    const { data: joe } = await GET (`/user/me`, {auth: { username: 'joe' }})
-    expect(joe).to.containSubset({ id: 'joe', locale:'en' })
+    {
+      const { data } = await GET (`/user/me`)
+      expect(data).to.containSubset({ id: 'alice', locale:'en' })
+    }
+    {
+      const { data } = await GET (`/user/me`, {auth: { username: 'joe' }})
+      expect(data).to.containSubset({ id: 'joe', locale:'en' })
+    }
   })
 
 })

test/registry.test.js

@@ -0,0 +1,57 @@
+
+const cds = require('@sap/cds/lib')
+const { fork } = require('child_process')
+const { resolve } = require('path')
+const verbose = process.env.CDS_TEST_VERBOSE
+
+describe('cap/samples - Local NPM registry', () => {
+
+  const { expect } = cds.test
+  // ||true
+
+  let registry
+  let axios
+  const cwd = resolve(__dirname, '..')
+
+  before(async ()=> {
+    const env = Object.assign(process.env, {PORT:'0'})
+    const res = await exec (resolve(cwd, '.registry/server.js'), {cwd, stdio: 'pipe', env})
+    registry = res.cp
+    axios = require('axios').create ({ baseURL: res.url, validateStatus: (status)=>status<500 })
+  })
+
+  after(done => { registry.once('exit',done); registry.kill() })
+
+  for (const mod of ['bookshop', 'data-viewer', 'fiori','orders','reviews']) {
+    it(`should serve ${mod}`, async () => {
+      const resp = await axios.get(`/@capire/${mod}`)
+      expect(resp.data).to.containSubset({name: `@capire/${mod}`, versions:{}})
+      const versions = Object.values(resp.data.versions)
+      await axios.get(versions[0].dist.tarball)
+    })
+  }
+  it(`should return 404 for unknown packages`, async () => {
+    let resp = await axios.get(`/@capire/foo`)
+    expect(resp.status).to.equal(404)
+    resp = await axios.get(`/foo`)
+    expect(resp.status).to.equal(404)
+  })
+
+})
+
+function exec (script, opts) {
+  return new Promise((resolve, reject)=> {
+    const cp = fork (script, [], opts)
+      .on('error', err => reject(new Error(err)))
+    cp.stdout.on('data', chunk => {
+      if (verbose) console.log(chunk.toString())
+      if (chunk.toString().match(/listening.*(http:.*:\d+)/i)) {
+         resolve({cp, url:RegExp.$1})
+      }
+    })
+    cp.stderr.on('data', chunk => {
+      if (verbose)  console.error(chunk.toString())
+    })
+  })
+
+}