restconf/restconf-nb/src/test/java/org/opendaylight/restconf/nb/rfc8040/rests/services/impl/Netconf799Test.java

   1 /*
   2  * Copyright (c) 2021 PANTHEON.tech s.r.o. All Rights Reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.restconf.nb.rfc8040.rests.services.impl;
   9
  10 import static org.hamcrest.CoreMatchers.instanceOf;
  11 import static org.hamcrest.MatcherAssert.assertThat;
  12 import static org.junit.Assert.assertEquals;
  13 import static org.junit.Assert.assertNull;
  14 import static org.mockito.ArgumentMatchers.any;
  15 import static org.mockito.ArgumentMatchers.eq;
  16 import static org.mockito.Mockito.doReturn;
  17 import static org.mockito.Mockito.mock;
  18
  19 import com.google.common.util.concurrent.Futures;
  20 import java.io.FileNotFoundException;
  21 import org.junit.Test;
  22 import org.junit.runner.RunWith;
  23 import org.mockito.junit.MockitoJUnitRunner;
  24 import org.opendaylight.mdsal.dom.api.DOMActionService;
  25 import org.opendaylight.mdsal.dom.api.DOMDataBroker;
  26 import org.opendaylight.mdsal.dom.api.DOMMountPointService;
  27 import org.opendaylight.mdsal.dom.api.DOMSchemaService;
  28 import org.opendaylight.mdsal.dom.spi.SimpleDOMActionResult;
  29 import org.opendaylight.restconf.common.context.InstanceIdentifierContext;
  30 import org.opendaylight.restconf.nb.rfc8040.TestRestconfUtils;
  31 import org.opendaylight.restconf.nb.rfc8040.handlers.SchemaContextHandler;
  32 import org.opendaylight.restconf.nb.rfc8040.legacy.NormalizedNodePayload;
  33 import org.opendaylight.restconf.nb.rfc8040.rests.services.api.RestconfStreamsSubscriptionService;
  34 import org.opendaylight.restconf.nb.rfc8040.streams.Configuration;
  35 import org.opendaylight.yangtools.yang.common.QName;
  36 import org.opendaylight.yangtools.yang.common.Uint32;
  37 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
  38 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
  39 import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
  40 import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes;
  41 import org.opendaylight.yangtools.yang.data.util.DataSchemaContextTree;
  42 import org.opendaylight.yangtools.yang.model.api.ActionNodeContainer;
  43 import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext;
  44 import org.opendaylight.yangtools.yang.model.api.stmt.SchemaNodeIdentifier.Absolute;
  45 import org.opendaylight.yangtools.yang.test.util.YangParserTestUtils;
  46
  47 @RunWith(MockitoJUnitRunner.StrictStubs.class)
  48 public class Netconf799Test {
  49     private static final QName CONT_QNAME = QName.create("instance:identifier:module", "2014-01-17", "cont");
  50     private static final QName CONT1_QNAME = QName.create(CONT_QNAME, "cont1");
  51     private static final QName RESET_QNAME = QName.create(CONT_QNAME, "reset");
  52
  53     private static final QName DELAY_QNAME = QName.create(CONT_QNAME, "delay");
  54     private static final QName INPUT_QNAME = QName.create(CONT_QNAME, "input");
  55     private static final QName OUTPUT_QNAME = QName.create(CONT_QNAME, "output");
  56     private static final YangInstanceIdentifier ACTION_YII = YangInstanceIdentifier.of(CONT_QNAME).node(CONT1_QNAME);
  57
  58     @Test
  59     public void testInvokeAction() throws FileNotFoundException {
  60         final EffectiveModelContext contextRef = YangParserTestUtils.parseYangFiles(
  61             TestRestconfUtils.loadFiles("/instanceidentifier/yang"));
  62
  63         final DOMDataBroker mockDataBroker = mock(DOMDataBroker.class);
  64         final SchemaContextHandler schemaContextHandler = new SchemaContextHandler(mockDataBroker,
  65             mock(DOMSchemaService.class));
  66         schemaContextHandler.onModelContextUpdated(contextRef);
  67
  68         final DOMActionService actionService = mock(DOMActionService.class);
  69         doReturn(Futures.immediateFuture(new SimpleDOMActionResult(
  70             Builders.containerBuilder().withNodeIdentifier(NodeIdentifier.create(OUTPUT_QNAME)).build())))
  71             .when(actionService).invokeAction(eq(Absolute.of(CONT_QNAME, CONT1_QNAME, RESET_QNAME)), any(), any());
  72
  73         final RestconfDataServiceImpl dataService = new RestconfDataServiceImpl(schemaContextHandler, mockDataBroker,
  74             mock(DOMMountPointService.class), mock(RestconfStreamsSubscriptionService.class),
  75             actionService, mock(Configuration.class));
  76
  77         final var nodeAndStack = DataSchemaContextTree.from(contextRef).enterPath(ACTION_YII).orElseThrow();
  78         final var node = nodeAndStack.node().getDataSchemaNode();
  79         assertThat(node, instanceOf(ActionNodeContainer.class));
  80         final var actionNode = ((ActionNodeContainer) node).findAction(RESET_QNAME).orElseThrow();
  81         final var stack = nodeAndStack.stack();
  82         stack.enterSchemaTree(RESET_QNAME);
  83
  84         final var response = dataService.invokeAction(NormalizedNodePayload.of(
  85             InstanceIdentifierContext.ofPath(stack, actionNode, ACTION_YII, null),
  86             Builders.containerBuilder()
  87                 .withNodeIdentifier(NodeIdentifier.create(INPUT_QNAME))
  88                 .withChild(ImmutableNodes.leafNode(DELAY_QNAME, Uint32.TEN))
  89                 .build()));
  90
  91         assertEquals(204, response.getStatus());
  92         assertNull(response.getEntity());
  93     }
  94 }