cps-ncmp-rest/src/test/groovy/org/onap/cps/ncmp/rest/executor/CpsNcmpTaskExecutorSpec.groovy

   1 /*
   2  *  ============LICENSE_START=======================================================
   3  *  Copyright (C) 2023 Nordix Foundation
   4  *  ================================================================================
   5  *  Licensed under the Apache License, Version 2.0 (the "License");
   6  *  you may not use this file except in compliance with the License.
   7  *  You may obtain a copy of the License at
   8  *
   9  *        http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *  Unless required by applicable law or agreed to in writing, software
  12  *  distributed under the License is distributed on an "AS IS" BASIS,
  13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *  See the License for the specific language governing permissions and
  15  *  limitations under the License.
  16  *
  17  *  SPDX-License-Identifier: Apache-2.0
  18  *  ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.cps.ncmp.rest.executor
  22
  23 import ch.qos.logback.classic.Level
  24 import ch.qos.logback.classic.Logger
  25 import ch.qos.logback.classic.spi.ILoggingEvent
  26 import ch.qos.logback.core.read.ListAppender
  27 import org.junit.jupiter.api.AfterEach
  28 import org.junit.jupiter.api.BeforeEach
  29 import org.slf4j.LoggerFactory
  30 import spock.lang.Specification
  31
  32 class CpsNcmpTaskExecutorSpec extends Specification {
  33
  34     def objectUnderTest = new CpsNcmpTaskExecutor()
  35     def logger = Spy(ListAppender<ILoggingEvent>)
  36     def enoughTime = 100
  37
  38     @BeforeEach
  39     void setup() {
  40         ((Logger) LoggerFactory.getLogger(CpsNcmpTaskExecutor.class)).addAppender(logger);
  41         logger.start();
  42     }
  43
  44     @AfterEach
  45     void teardown() {
  46         ((Logger) LoggerFactory.getLogger(CpsNcmpTaskExecutor.class)).detachAndStopAllAppenders();
  47     }
  48
  49     def 'Execute successful task.'() {
  50         when: 'task is executed'
  51             objectUnderTest.executeTask(taskSupplier(), enoughTime)
  52         and: 'wait a little for async execution completion'
  53             Thread.sleep(10)
  54         then: 'an event is logged with level INFO'
  55             def loggingEvent = getLoggingEvent()
  56             assert loggingEvent.level == Level.INFO
  57         and: 'the log indicates the task completed successfully'
  58             assert loggingEvent.formattedMessage == 'Async task completed successfully.'
  59     }
  60
  61     def 'Execute failing task.'() {
  62         when: 'task is executed'
  63             objectUnderTest.executeTask(taskSupplierForFailingTask(), enoughTime)
  64         and: 'wait a little for async execution completion'
  65             Thread.sleep(10)
  66         then: 'an event is logged with level ERROR'
  67             def loggingEvent = getLoggingEvent()
  68             assert loggingEvent.level == Level.ERROR
  69         and: 'the original error message is logged'
  70             assert loggingEvent.formattedMessage.contains('original exception message')
  71     }
  72
  73     def taskSupplier() {
  74         return () -> 'hello world'
  75     }
  76
  77     def taskSupplierForFailingTask() {
  78         return () -> { throw new RuntimeException('original exception message') }
  79     }
  80
  81     def getLoggingEvent() {
  82         return logger.list[0]
  83     }
  84
  85 }