src-electron/db/query-package-notification.js

'use strict'
/**
 *
 *    Copyright (c) 2020 Silicon Labs
 *
 *    Licensed under the Apache License, Version 2.0 (the "License");
 *    you may not use this file except in compliance with the License.
 *    You may obtain a copy of the License at
 *
 *        http://www.apache.org/licenses/LICENSE-2.0
 *
 *    Unless required by applicable law or agreed to in writing, software
 *    distributed under the License is distributed on an "AS IS" BASIS,
 *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *    See the License for the specific language governing permissions and
 *    limitations under the License.
 */

/**
 * This module provides package notification related queries.
 *
 * @module DB API: session related queries.
 */

const dbApi = require('./db-api.js')
const dbMapping = require('./db-mapping.js')

/**
 * Sets a notification in the PACKAGE_NOTICE table
 *
 * @export
 * @param {*} db
 * @param {*} type
 * @param {*} status
 * @param {*} packageId
 * @param {*} severity
 */
async function setNotification(db, type, status, packageId, severity = 2) {
  return dbApi.dbUpdate(
    db,
    'INSERT INTO PACKAGE_NOTICE ( PACKAGE_REF, NOTICE_TYPE, NOTICE_MESSAGE, NOTICE_SEVERITY) VALUES ( ?, ?, ?, ? )',
    [packageId, type, status, severity]
  )
}

/**
 * Deletes a notification from the PACKAGE_NOTICE table
 *
 * @export
 * @param {*} db
 * @param {*} sessionId
 * @param {*} type
 * @param {*} message
 */
async function deleteNotification(db, id) {
  return dbApi.dbUpdate(
    db,
    'DELETE FROM PACKAGE_NOTICE WHERE ( NOTICE_ID ) = ( ? )',
    [id]
  )
}
/**
 * Retrieves notifications from the PACKAGE_NOTICE table related to a sessionId
 *
 * @export
 * @param {*} db
 */
async function getNotificationBySessionId(db, sessionId) {
  let rows = []
  rows = await dbApi.dbAll(
    db,
    'SELECT * FROM PACKAGE_NOTICE WHERE PACKAGE_REF IN' +
      `(  SELECT
            SESSION_PACKAGE.PACKAGE_REF
          FROM
            SESSION_PACKAGE
          INNER JOIN
            SESSION_PARTITION
          ON
            SESSION_PACKAGE.SESSION_PARTITION_REF= SESSION_PARTITION.SESSION_PARTITION_ID
          WHERE
            SESSION_PARTITION.SESSION_REF = ( ? ) )`,
    [sessionId]
  )
  return rows.map(dbMapping.map.packageNotification)
}
/**
 * Retrieves all package notifications in the database
 *
 * @export
 * @param {*} db
 */
async function getAllNotification(db) {
  let rows = []
  rows = await dbApi.dbAll(db, 'SELECT * FROM PACKAGE_NOTICE')
  return rows.map(dbMapping.map.packageNotification)
}
/**
 * Retrieves package notifications of a specific package given its packageId
 *
 * @export
 * @param {*} db
 * @param {*} packageId
 */
async function getNotificationByPackageId(db, packageId) {
  let rows = []
  rows = await dbApi.dbAll(
    db,
    'SELECT * FROM PACKAGE_NOTICE WHERE PACKAGE_REF = ( ? )',
    [packageId]
  )
  return rows.map(dbMapping.map.packageNotification)
}

// exports
exports.setNotification = setNotification
exports.deleteNotification = deleteNotification
exports.getNotificationByPackageId = getNotificationByPackageId
exports.getNotificationBySessionId = getNotificationBySessionId
exports.getAllNotification = getAllNotification
//# sourceMappingURL=query-package-notification.js.map