OpenPLC_v3/utils/dnp3_src/cpp/examples/tls/outstation/main.cpp

/*
 * Licensed to Green Energy Corp (www.greenenergycorp.com) under one or
 * more contributor license agreements. See the NOTICE file distributed
 * with this work for additional information regarding copyright ownership.
 * Green Energy Corp licenses this file to you under the Apache License,
 * Version 2.0 (the "License"); you may not use this file except in
 * compliance with the License.  You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * This project was forked on 01/01/2013 by Automatak, LLC and modifications
 * may have been made to this file. Automatak, LLC licenses these modifications
 * to you under the terms of the License.
 */
#include <asiodnp3/DNP3Manager.h>
#include <asiodnp3/PrintingSOEHandler.h>
#include <asiodnp3/PrintingChannelListener.h>
#include <asiodnp3/ConsoleLogger.h>
#include <asiodnp3/UpdateBuilder.h>

#include <asiopal/UTCTimeSource.h>
#include <opendnp3/outstation/SimpleCommandHandler.h>

#include <opendnp3/outstation/Database.h>

#include <opendnp3/LogLevels.h>

#include <string>
#include <thread>
#include <iostream>

using namespace std;
using namespace opendnp3;
using namespace openpal;
using namespace asiopal;
using namespace asiodnp3;

void ConfigureDatabase(DatabaseConfig& config)
{
	// example of configuring analog index 0 for Class2 with floating point variations by default
	config.analog[0].clazz = PointClass::Class2;
	config.analog[0].svariation = StaticAnalogVariation::Group30Var5;
	config.analog[0].evariation = EventAnalogVariation::Group32Var7;
}

struct State
{
	uint32_t count = 0;
	double value = 0;
	bool binary = false;
	DoubleBit dbit = DoubleBit::DETERMINED_OFF;
};

void AddUpdates(UpdateBuilder& builder, State& state, const std::string& arguments);

int main(int argc, char* argv[])
{
	if (argc != 4)
	{
		std::cout << "usage: master-gprs-tls-demo <ca certificate> <certificate chain> <private key>" << std::endl;
		return -1;
	}

	std::string caCertificate(argv[1]);
	std::string certificateChain(argv[2]);
	std::string privateKey(argv[3]);

	std::cout << "Using CA certificate: " << caCertificate << std::endl;
	std::cout << "Using certificate chain: " << certificateChain << std::endl;
	std::cout << "Using private key file: " << privateKey << std::endl;

	// Specify what log levels to use. NORMAL is warning and above
	// You can add all the comms logging by uncommenting below.
	const uint32_t FILTERS = levels::NORMAL; // | levels::ALL_COMMS;

	// This is the main point of interaction with the stack
	// Allocate a single thread to the pool since this is a single outstation
	DNP3Manager manager(1, ConsoleLogger::Create());

	std::error_code ec;

	// Create a TCP server (listener)
	auto channel = manager.AddTLSClient(
	                   "server",
	                   FILTERS,
	                   ChannelRetry::Default(),
	                   "127.0.0.1",
	                   "0.0.0.0",
	                   20001,
	                   TLSConfig(
	                       caCertificate,
	                       certificateChain,
	                       privateKey,
	                       2
	                   ),
	                   PrintingChannelListener::Create(),
	                   ec
	               );

	if (ec)
	{
		std::cout << "Unable to create tls server: " << ec.message() << std::endl;
		return ec.value();
	}

	// The main object for a outstation. The defaults are useable,
	// but understanding the options are important.
	OutstationStackConfig stackConfig(DatabaseSizes::AllTypes(10));

	// specify the maximum size of the event buffers
	stackConfig.outstation.eventBufferConfig = EventBufferConfig::AllTypes(10);

	// you can override an default outstation parameters here
	// in this example, we've enabled the oustation to use unsolicted reporting
	// if the master enables it
	stackConfig.outstation.params.allowUnsolicited = true;

	// You can override the default link layer settings here
	// in this example we've changed the default link layer addressing
	stackConfig.link.LocalAddr = 10;
	stackConfig.link.RemoteAddr = 1;

	// You can optionally change the default reporting variations or class assignment prior to enabling the outstation
	ConfigureDatabase(stackConfig.dbConfig);

	// Create a new outstation with a log level, command handler, and
	// config info this	returns a thread-safe interface used for
	// updating the outstation's database.
	auto outstation = channel->AddOutstation("outstation", SuccessCommandHandler::Create(), DefaultOutstationApplication::Create(), stackConfig);

	// Enable the outstation and start communications
	outstation->Enable();

	// variables used in example loop
	string input;
	State state;

	while (true)
	{
		std::cout << "Enter one or more measurement changes then press <enter>" << std::endl;
		std::cout << "c = counter, b = binary, d = doublebit, a = analog, 'quit' = exit" << std::endl;
		std::cin >> input;

		if (input == "quit") return 0;
		else
		{
			UpdateBuilder builder;
			AddUpdates(builder, state, input);
			outstation->Apply(builder.Build());
		}
	}

	return 0;
}

void AddUpdates(UpdateBuilder& builder, State& state, const std::string& arguments)
{
	for (const char& c : arguments)
	{
		switch (c)
		{
		case('c'):
			{
				builder.Update(Counter(state.count), 0);
				++state.count;
				break;
			}
		case('a'):
			{
				builder.Update(Analog(state.value), 0);
				state.value += 1;
				break;
			}
		case('b'):
			{
				builder.Update(Binary(state.binary), 0);
				state.binary = !state.binary;
				break;
			}
		case('d'):
			{
				builder.Update(DoubleBitBinary(state.dbit), 0);
				state.dbit = (state.dbit == DoubleBit::DETERMINED_OFF) ? DoubleBit::DETERMINED_ON : DoubleBit::DETERMINED_OFF;
				break;
			}
		default:
			break;
		}
	}
}