Merge "BUG 2799: SPI for EventSources"
[controller.git] / opendaylight / netconf / netconf-cli / src / main / java / org / opendaylight / controller / netconf / cli / commands / local / Disconnect.java
1 /*
2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  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.controller.netconf.cli.commands.local;
9
10 import org.opendaylight.controller.netconf.cli.NetconfDeviceConnectionManager;
11 import org.opendaylight.controller.netconf.cli.commands.AbstractCommand;
12 import org.opendaylight.controller.netconf.cli.commands.Command;
13 import org.opendaylight.controller.netconf.cli.commands.input.Input;
14 import org.opendaylight.controller.netconf.cli.commands.input.InputDefinition;
15 import org.opendaylight.controller.netconf.cli.commands.output.Output;
16 import org.opendaylight.controller.netconf.cli.commands.output.OutputDefinition;
17 import org.opendaylight.yangtools.yang.common.QName;
18 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
19 import org.opendaylight.yangtools.yang.data.impl.schema.builder.impl.ImmutableContainerNodeBuilder;
20 import org.opendaylight.yangtools.yang.data.impl.schema.builder.impl.ImmutableLeafNodeBuilder;
21 import org.opendaylight.yangtools.yang.model.api.RpcDefinition;
22
23 /**
24  * Local disconnect command
25  */
26 public class Disconnect extends AbstractCommand {
27
28     private final NetconfDeviceConnectionManager connectionManager;
29
30     public Disconnect(final QName qName, final InputDefinition inputDefinition,
31             final OutputDefinition outputDefinition, final NetconfDeviceConnectionManager connectionManager,
32             final String description) {
33         super(qName, inputDefinition, outputDefinition, description);
34         this.connectionManager = connectionManager;
35     }
36
37     @Override
38     public Output invoke(final Input inputArgs) {
39         connectionManager.disconnect();
40
41         return new Output(
42                 ImmutableContainerNodeBuilder.create()
43                         .withNodeIdentifier(new NodeIdentifier(getCommandId()))
44                         .withChild(ImmutableLeafNodeBuilder.create()
45                                 .withNodeIdentifier(new NodeIdentifier(QName.create(getCommandId(), "status")))
46                                 .withValue("Connection disconnected").build()).build());
47     }
48
49     public static Command create(final RpcDefinition rpcDefinition,
50             final NetconfDeviceConnectionManager commandDispatcher) {
51         return new Disconnect(rpcDefinition.getQName(), getInputDefinition(rpcDefinition),
52                 getOutputDefinition(rpcDefinition), commandDispatcher, rpcDefinition.getDescription());
53     }
54 }