Address lookup to mocked S/4HANA system

What's working:
- Address information on OP
- Reading of S/4HANA Addresses
- Translations

packages/bookshop/srv/admin-service.cds

@@ -4,6 +4,7 @@ service AdminService @(_requires:'authenticated-user') {
   entity Books as projection on my.Books;
   entity Authors as projection on my.Authors;
   entity Orders as select from my.Orders;
+  entity Addresses as projection on my.ShippingAddresses;
 }
 
 // Enable Fiori Draft for Orders

packages/bookshop/srv/admin-service.js

@@ -0,0 +1,67 @@
+const cds = require('@sap/cds')
+const { Books, ShippingAddresses } = cds.entities
+
+const bupaSrv = cds.connect.to('API_BUSINESS_PARTNER')
+
+/** Service implementation for CatalogService */
+module.exports = cds.service.impl(function () {
+  this.before('CREATE', 'Orders', _reduceStock)
+  // this.before('CREATE', 'Orders', _fillAddress)
+  this.before('PATCH', 'Orders', _fillAddress)
+
+  this.on('READ', 'Addresses', _readAddresses)
+})
+
+function _readAddresses (req) {
+  // TODO: Delegate to external service
+}
+
+/** Fill Address data from external service */
+async function _fillAddress (req) {
+  console.log('retrieving addresses')
+  if (req.data.shippingAddress_AddressID) {
+    const tx = bupaSrv.transaction(req)
+    const response = await tx.run(
+      SELECT.from('API_BUSINESS_PARTNER.A_BusinessPartnerAddress')
+        .columns('AddressID', 'CityName', 'StreetName', 'HouseNumber')
+        .where({ AddressID: req.data.shippingAddress_AddressID })
+    )
+    if (response && response.length > 0) {
+      console.log('filling addresses')
+      const tx2 = cds.transaction(req)
+      try {
+        await tx2.run(
+          INSERT.into('sap.capire.bookshop.ShippingAddresses').entries(response)
+        )
+      } catch (e) {
+        // already in there
+      }
+    } else {
+      req.error('Shipping address not found.')
+    }
+  }
+}
+
+/** Reduce stock of ordered books if available stock suffices */
+async function _reduceStock (req) {
+  const { Items: OrderItems } = req.data
+  if (OrderItems && OrderItems.length > 0) {
+    const all = await cds.transaction(req).run(() =>
+      OrderItems.map(order =>
+        UPDATE(Books)
+          .set('stock -=', order.amount)
+          .where('ID =', order.book_ID)
+          .and('stock >=', order.amount)
+      )
+    )
+    all.forEach((affectedRows, i) => {
+      if (affectedRows === 0)
+        req.error(
+          409,
+          `${OrderItems[i].amount} exceeds stock for book #${
+            OrderItems[i].book_ID
+          }`
+        )
+    })
+  }
+}

packages/bookshop/srv/cat-service.cds

@@ -1,5 +1,6 @@
 using { sap.capire.bookshop as my } from '../db/schema';
 
+
 @path:'/browse'
 service CatalogService {
 
@@ -9,5 +10,6 @@ service CatalogService {
 
   @requires_: 'authenticated-user'
   @insertonly entity Orders as projection on my.Orders;
+  entity Addresses as projection on my.ShippingAddresses;
 
 }

packages/bookshop/srv/cat-service.js

@@ -1,5 +1,7 @@
 const cds = require('@sap/cds')
-const { Books } = cds.entities
+const { Books, ShippingAddresses } = cds.entities
+
+const bupaSrv = cds.connect.to('API_BUSINESS_PARTNER')
 
 /** Service implementation for CatalogService */
 module.exports = cds.service.impl(function () {
@@ -9,32 +11,64 @@ module.exports = cds.service.impl(function () {
     each => each.stock > 111 && _addDiscount2(each, 11)
   )
   this.before('CREATE', 'Orders', _reduceStock)
+  this.before('CREATE', 'Orders', _fillAddress)
+
+  this.on('READ', 'Addresses', _readAddresses)
+
+  // this.after('READ', 'Orders', (data, req) => {
+  //   if (req.query.SELECT.columns.includes('shippingAddress')) {
+  //     data.shippingAddress = _readAddresses()
+  //   }
+  // })
 })
 
+function _readAddresses (req) {
+  // TODO: Delegate to external service
+  return [
+    { AddressID: 'add1', CityName: 'Walldorf', StreetName: 'ExampleStreet' },
+    { AddressID: 'add2', CityName: 'Schwetzingen', StreetName: 'BestStreet' }
+  ]
+}
+
 /** Add some discount for overstocked books */
-function _addDiscount2(each, discount) {
+function _addDiscount2 (each, discount) {
   each.title += ` -- ${discount}% discount!`
 }
 
-/** Reduce stock of ordered books if available stock suffices */
-async function _reduceStock(req) {
-  const { Items: OrderItems } = req.data
-  const all = await cds
-    .transaction(req)
-    .run(() =>
-      OrderItems.map(order =>
-        UPDATE(Books)
-          .set('stock -=', order.amount)
-          .where('ID =', order.book_ID)
-          .and('stock >=', order.amount)
-      )
+async function _fillAddress (req) {
+  console.log('filling addresses')
+  if (req.data.shippingAdress_AddressID) {
+    const tx = bupaSrv.transaction(req)
+    const result = tx.run(
+      SELECT.one(['AdressID, CityName, StreetName, HouseNumber'])
+        .from('A_BusinessPartnerAddress')
+        .where({ AddressID: req.data.shippingAdress_AddressID })
     )
+    if (result) {
+      const tx2 = cds.transaction(req)
+      console.log('filling addresses for real')
+      tx2.run(INSERT.into(ShippingAddresses).entries([result]))
+    }
+  }
+}
+
+/** Reduce stock of ordered books if available stock suffices */
+async function _reduceStock (req) {
+  const { Items: OrderItems } = req.data
+  const all = await cds.transaction(req).run(() =>
+    OrderItems.map(order =>
+      UPDATE(Books)
+        .set('stock -=', order.amount)
+        .where('ID =', order.book_ID)
+        .and('stock >=', order.amount)
+    )
+  )
   all.forEach((affectedRows, i) => {
     if (affectedRows === 0)
       req.error(
         409,
         `${OrderItems[i].amount} exceeds stock for book #${
-        OrderItems[i].book_ID
+          OrderItems[i].book_ID
         }`
       )
   })

packages/bookshop/srv/init.js

@@ -0,0 +1,37 @@
+module.exports = db => {
+  const { A_BusinessPartnerAddress: Addresses } = db.entities(
+    'API_BUSINESS_PARTNER'
+  )
+
+  DELETE.from(Addresses)
+  INSERT.into(Addresses).entries(
+    {
+      BusinessPartner: 'anonymous',
+      AddressID: '28238',
+      CityName: 'Walldorf',
+      StreetName: 'Dietmar-Hopp-Allee',
+      HouseNumber: '123'
+    },
+    {
+      BusinessPartner: '1003765',
+      AddressID: '28241',
+      CityName: 'Palo Alto',
+      StreetName: 'Hillview Avenue',
+      HouseNumber: '26'
+    },
+    {
+      BusinessPartner: '1003766',
+      AddressID: '28244',
+      CityName: 'Hallbergmoos',
+      StreetName: 'Zeppelinstraße',
+      HouseNumber: '93'
+    },
+    {
+      BusinessPartner: '1003767',
+      AddressID: '28247',
+      CityName: 'Potsdam',
+      StreetName: 'Konrad-Zuse-Ring',
+      HouseNumber: '29'
+    }
+  )
+}