restconf/restconf-nb-rfc8040/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.junit.Assert.assertEquals;
  11 import static org.junit.Assert.assertNull;
  12 import static org.mockito.ArgumentMatchers.any;
  13 import static org.mockito.ArgumentMatchers.eq;
  14 import static org.mockito.Mockito.doReturn;
  15 import static org.mockito.Mockito.mock;
  16
  17 import com.google.common.util.concurrent.Futures;
  18 import java.io.FileNotFoundException;
  19 import java.util.Optional;
  20 import org.junit.Test;
  21 import org.junit.runner.RunWith;
  22 import org.mockito.junit.MockitoJUnitRunner;
  23 import org.opendaylight.mdsal.dom.api.DOMActionService;
  24 import org.opendaylight.mdsal.dom.api.DOMDataBroker;
  25 import org.opendaylight.mdsal.dom.api.DOMMountPointService;
  26 import org.opendaylight.mdsal.dom.api.DOMSchemaService;
  27 import org.opendaylight.mdsal.dom.spi.SimpleDOMActionResult;
  28 import org.opendaylight.restconf.common.context.InstanceIdentifierContext;
  29 import org.opendaylight.restconf.nb.rfc8040.TestRestconfUtils;
  30 import org.opendaylight.restconf.nb.rfc8040.handlers.SchemaContextHandler;
  31 import org.opendaylight.restconf.nb.rfc8040.legacy.NormalizedNodePayload;
  32 import org.opendaylight.restconf.nb.rfc8040.rests.services.api.RestconfStreamsSubscriptionService;
  33 import org.opendaylight.restconf.nb.rfc8040.streams.Configuration;
  34 import org.opendaylight.yangtools.yang.common.QName;
  35 import org.opendaylight.yangtools.yang.common.Uint32;
  36 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
  37 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
  38 import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
  39 import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes;
  40 import org.opendaylight.yangtools.yang.data.util.DataSchemaContextNode;
  41 import org.opendaylight.yangtools.yang.data.util.DataSchemaContextTree;
  42 import org.opendaylight.yangtools.yang.model.api.ActionDefinition;
  43 import org.opendaylight.yangtools.yang.model.api.ActionNodeContainer;
  44 import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext;
  45 import org.opendaylight.yangtools.yang.model.api.stmt.SchemaNodeIdentifier.Absolute;
  46 import org.opendaylight.yangtools.yang.test.util.YangParserTestUtils;
  47
  48 @RunWith(MockitoJUnitRunner.StrictStubs.class)
  49 public class Netconf799Test {
  50     private static final QName CONT_QNAME = QName.create("instance:identifier:module", "2014-01-17", "cont");
  51     private static final QName CONT1_QNAME = QName.create(CONT_QNAME, "cont1");
  52     private static final QName RESET_QNAME = QName.create(CONT_QNAME, "reset");
  53
  54     private static final QName DELAY_QNAME = QName.create(CONT_QNAME, "delay");
  55     private static final QName INPUT_QNAME = QName.create(CONT_QNAME, "input");
  56     private static final QName OUTPUT_QNAME = QName.create(CONT_QNAME, "output");
  57     private static final YangInstanceIdentifier ACTION_YII = YangInstanceIdentifier.of(CONT_QNAME).node(CONT1_QNAME);
  58
  59     @Test
  60     public void testInvokeAction() throws FileNotFoundException {
  61         final EffectiveModelContext contextRef = YangParserTestUtils.parseYangFiles(
  62             TestRestconfUtils.loadFiles("/instanceidentifier/yang"));
  63
  64         final DOMDataBroker mockDataBroker = mock(DOMDataBroker.class);
  65         final SchemaContextHandler schemaContextHandler = new SchemaContextHandler(mockDataBroker,
  66             mock(DOMSchemaService.class));
  67         schemaContextHandler.onModelContextUpdated(contextRef);
  68
  69         final DOMActionService actionService = mock(DOMActionService.class);
  70         doReturn(Futures.immediateFuture(new SimpleDOMActionResult(
  71             Builders.containerBuilder().withNodeIdentifier(NodeIdentifier.create(OUTPUT_QNAME)).build())))
  72             .when(actionService).invokeAction(eq(Absolute.of(CONT_QNAME, CONT1_QNAME, RESET_QNAME)), any(), any());
  73
  74         final RestconfDataServiceImpl dataService = new RestconfDataServiceImpl(schemaContextHandler, mockDataBroker,
  75             mock(DOMMountPointService.class), mock(RestconfStreamsSubscriptionService.class),
  76             actionService, mock(Configuration.class));
  77
  78         final var schemaNode = loadAction(contextRef, RESET_QNAME, ACTION_YII).orElseThrow();
  79         final var response = dataService.invokeAction(NormalizedNodePayload.of(
  80             new InstanceIdentifierContext<>(ACTION_YII, schemaNode, null, contextRef),
  81             Builders.containerBuilder()
  82                 .withNodeIdentifier(NodeIdentifier.create(INPUT_QNAME))
  83                 .withChild(ImmutableNodes.leafNode(DELAY_QNAME, Uint32.TEN))
  84                 .build()));
  85
  86         assertEquals(204, response.getStatus());
  87         assertNull(response.getEntity());
  88     }
  89
  90     private static Optional<ActionDefinition> loadAction(final EffectiveModelContext modelContext,
  91             final QName actionQName, final YangInstanceIdentifier actionYII) {
  92         return DataSchemaContextTree.from(modelContext)
  93             .findChild(actionYII)
  94             .map(DataSchemaContextNode::getDataSchemaNode)
  95             .flatMap(node -> node instanceof ActionNodeContainer ? ((ActionNodeContainer) node).findAction(actionQName)
  96                 : Optional.empty());
  97     }
  98 }