package com.mes.milo.runner;

import lombok.extern.slf4j.Slf4j;
import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
import org.eclipse.milo.opcua.sdk.client.nodes.UaNode;
import org.eclipse.milo.opcua.stack.core.Identifiers;
import org.eclipse.milo.opcua.stack.core.UaException;
import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UShort;

import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

/**
 * @author mes
 * @version 0.0.1
 * @since 2020/4/14
 */
@Slf4j
public class BrowseRunner {

    public List<String> run(OpcUaClient opcUaClient) {
        List<String> nodesList = new ArrayList<>();
        try {
            List<? extends UaNode> nodes = opcUaClient.getAddressSpace().browseNodes(Identifiers.ObjectsFolder);

            nodesList.addAll(nodes.stream().filter(item -> !Objects.requireNonNull(item.getBrowseName().getName()).startsWith("_")
                    && Objects.equals(item.getBrowseName().getNamespaceIndex(), UShort.valueOf(2)))
                    .map(item -> item.getBrowseName().getName()).collect(Collectors.toList()));
        } catch (UaException e) {
            log.error("遍历根节点异常：{}", e.getMessage(), e);
        }
        return nodesList;
    }
}