reuse.js

"use strict";

// ----------------------------------------------------------------------------
// Constants

const color = {
  grey: 0, 
  red: 1,
  yellow: 2,
  green: 3
};

const authorReadingStatusCode = {
  inPreparation: 0,
  published: 1,
  booked: 2,
  completed: 3, // not used
  blocked: 4,
  cancelled: 5 // not used
};

const participantStatusCode = {
  inProcess: 1,
  confirmed: 2,
  cancelled: 3
};

// ----------------------------------------------------------------------------
// Reuse functions

// Reuse function to check the formating of an e-mail address
function validateEmail(email) {
  const regexEmail = /^\w+([\\.-]?\w+)*@\w+([\\.-]?\w+)*(\.\w{2,3})+$/;
  if (email.match(regexEmail)) {
    return true;
  } else {
    return false;
  }
}

// Reuse function to check the formating of an phone number
function validatePhone(phone) {
  const regexPhone = /^\+(?:[0-9] ?){6,14}[0-9]$/;
  if (phone.match(regexPhone)) {
    return true;
  } else {
    return false;
  }
}

// Emit event message to event mesh
async function emitAuthorReadingEvent(req, id, eventMeshTopic) {

  // Return updated reading event data
  const authorReadings = await SELECT.from("sap.samples.authorreadings.AuthorReadings").where({ ID: id });
  const authorReading = authorReadings[0];
  
  try {
    const msg = await cds.connect.to("outbound_messaging");
    await msg.emit( eventMeshTopic, { authorReading, tenant:req.user.tenant } );
    console.log( "====== Inside reuse function to emit Author Reading event messages ======" );
    console.log( `Event message emitted for topic ${eventMeshTopic} and author reading ${authorReading.identifier} and Tenant ID:${req.user.tenant} ` );

    req.info(200, 'EMIT_MESSAGE_SUCCESS', [authorReading.identifier, eventMeshTopic]);

    const text = `Event notification for topic ${eventMeshTopic} emitted successully.`;
    let eventMessages;
    if (authorReading.eventMeshMessage) {
        eventMessages = authorReading.eventMeshMessage + "\n" + text;
    } else {
        eventMessages = text;
    };
    console.log( "Event message log: ", eventMessages);

    let authorReadingUpdate = await UPDATE("sap.samples.authorreadings.AuthorReadings")
      .set({ eventMeshMessage: eventMessages })
      .where({ ID: id });
    if (authorReadingUpdate) { console.log( "Event message log update successfull") }
  } catch (error) {
    req.error(error);
  }
}

// Publish constants and functions
module.exports = {
  color,
  authorReadingStatusCode,
  participantStatusCode,
  validateEmail,
  validatePhone,
  emitAuthorReadingEvent
};