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
|
/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
#include "base/atomic-file.hpp"
#include "base/scriptglobal.hpp"
#include "base/singleton.hpp"
#include "base/logger.hpp"
#include "base/stdiostream.hpp"
#include "base/netstring.hpp"
#include "base/json.hpp"
#include "base/convert.hpp"
#include "base/objectlock.hpp"
#include "base/exception.hpp"
#include "base/namespace.hpp"
#include "base/utility.hpp"
#include <fstream>
using namespace icinga;
Namespace::Ptr ScriptGlobal::m_Globals = new Namespace();
Value ScriptGlobal::Get(const String& name, const Value *defaultValue)
{
Value result;
if (!m_Globals->Get(name, &result)) {
if (defaultValue)
return *defaultValue;
BOOST_THROW_EXCEPTION(std::invalid_argument("Tried to access undefined script variable '" + name + "'"));
}
return result;
}
void ScriptGlobal::Set(const String& name, const Value& value)
{
std::vector<String> tokens = name.Split(".");
if (tokens.empty())
BOOST_THROW_EXCEPTION(std::invalid_argument("Name must not be empty"));
{
ObjectLock olock(m_Globals);
Namespace::Ptr parent = m_Globals;
for (std::vector<String>::size_type i = 0; i < tokens.size(); i++) {
const String& token = tokens[i];
if (i + 1 != tokens.size()) {
Value vparent;
if (!parent->Get(token, &vparent)) {
Namespace::Ptr dict = new Namespace();
parent->Set(token, dict);
parent = dict;
} else {
parent = vparent;
}
}
}
parent->Set(tokens[tokens.size() - 1], value);
}
}
void ScriptGlobal::SetConst(const String& name, const Value& value)
{
GetGlobals()->Set(name, value, true);
}
bool ScriptGlobal::Exists(const String& name)
{
return m_Globals->Contains(name);
}
Namespace::Ptr ScriptGlobal::GetGlobals()
{
return m_Globals;
}
void ScriptGlobal::WriteToFile(const String& filename)
{
Log(LogInformation, "ScriptGlobal")
<< "Dumping variables to file '" << filename << "'";
AtomicFile fp (filename, 0600);
StdioStream::Ptr sfp = new StdioStream(&fp, false);
ObjectLock olock(m_Globals);
for (const Namespace::Pair& kv : m_Globals) {
Value value = kv.second.Val;
if (value.IsObject())
value = Convert::ToString(value);
Dictionary::Ptr persistentVariable = new Dictionary({
{ "name", kv.first },
{ "value", value }
});
String json = JsonEncode(persistentVariable);
NetString::WriteStringToStream(sfp, json);
}
sfp->Close();
fp.Commit();
}
|
