fledge-south-dht/plugin.cpp at develop · fledge-iot/fledge-south-dht · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
/*
 * Fledge south plugin.
 *
 * Copyright (c) 2018 OSisoft, LLC
 *
 * Released under the Apache 2.0 Licence
 *
 * Author: Amandeep Singh Arora
 */
#include <dht11.h>
#include <plugin_api.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <string>
#include <logger.h>
#include <plugin_exception.h>
#include <config_category.h>
#include <rapidjson/document.h>
#include <version.h>

using namespace std;
#define PLUGIN_NAME "dht11_V2"

/**
 * Default configuration
 */
static const char *default_config = QUOTE({
		"plugin" : {
			"description" : "DHT11 C south plugin",
			"type" : "string",
			"default" : PLUGIN_NAME,
			"readonly": "true"
			},
                "asset" : {
	       		"description" : "Asset name",
                        "type" : "string",
			"default" : "dht11",
			"order": "1",
                        "displayName": "Asset Name",
			"mandatory" : "true"
			},
                "pin" : {
			"description" : "Rpi pin to which DHT11 is attached",
			"type" : "integer",
			"default" : "7",
                        "displayName": "Rpi Pin"
		       	}
                });


/**
 * The DHT11 plugin interface
 */
extern "C" {

/**
 * The plugin information structure
 */
static PLUGIN_INFORMATION info = {
	PLUGIN_NAME,              // Name
	VERSION,                  // Version
	0,    		          // Flags
	PLUGIN_TYPE_SOUTH,        // Type
	"1.0.0",                  // Interface version
	default_config            // Default configuration
};

/**
 * Return the information about this plugin
 */
PLUGIN_INFORMATION *plugin_info()
{
	return &info;
}

/**
 * Initialise the plugin, called to get the plugin handle
 */
PLUGIN_HANDLE plugin_init(ConfigCategory *config)
{
	unsigned int pin;

	if (config->itemExists("pin"))
        {
                pin = stoul(config->getValue("pin"), nullptr, 0);
        }

	DHT11 *dht11= new DHT11(pin);

	if (config->itemExists("asset"))
                dht11->setAssetName(config->getValue("asset"));
        else
                dht11->setAssetName("dht11");

	Logger::getLogger()->info("m_assetName set to %s", dht11->getAssetName());

	return (PLUGIN_HANDLE)dht11;
}

/**
 * Poll for a plugin reading
 */
Reading plugin_poll(PLUGIN_HANDLE handle)
{
	DHT11 *dht11 = static_cast<DHT11*>(handle);
	return dht11->takeReading();
}

/**
 * Reconfigure the plugin
 */
void plugin_reconfigure(PLUGIN_HANDLE *handle, string& newConfig)
{
	ConfigCategory conf("dht", newConfig);
	DHT11 *dht11 = static_cast<DHT11*>(*handle);

	if (conf.itemExists("asset"))
                dht11->setAssetName(conf.getValue("asset"));
	if (conf.itemExists("pin"))
        {
                unsigned int pin = stoul(conf.getValue("pin"), nullptr, 0);
		dht11->setPin(pin);
        }
}

/**
 * Shutdown the plugin
 */
void plugin_shutdown(PLUGIN_HANDLE handle)
{
	DHT11 *dht11 = static_cast<DHT11*>(handle);
	delete dht11;
}
};