summaryrefslogtreecommitdiff
path: root/src/settings.h
blob: b95fbd1845ef4f5eae88ba24f4160b587882134f (plain)
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
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479

	objectrefGetOrCreate(L, player);   // player
	lua_pushstring(L,type.c_str()); // event type
	try {
		runCallbacks(2, RUN_CALLBACKS_MODE_FIRST);
	} catch (LuaError &e) {
		getServer()->setAsyncFatalError(
				std::string("player_event: ") + e.what() + "\n"
				+ script_get_backtrace(L) );
	}
}

void ScriptApiEnv::initializeEnvironment(ServerEnvironment *env)
{
	SCRIPTAPI_PRECHECKHEADER
	verbosestream << "scriptapi_add_environment" << std::endl;
	setEnv(env);

	/*
		Add {Loading,Active}BlockModifiers to environment
	*/

	// Get core.registered_abms
	lua_getglobal(L, "core");
	lua_getfield(L, -1, "registered_abms");
	int registered_abms = lua_gettop(L);

	if (!lua_istable(L, registered_abms)) {
		lua_pop(L, 1);
		throw LuaError("core.registered_abms was not a lua table, as expected.");
	}
	lua_pushnil(L);
	while (lua_next(L, registered_abms)) {
		// key at index -2 and value at index -1
		int id = lua_tonumber(L, -2);
		int current_abm = lua_gettop(L);

		std::set<std::string> trigger_contents;
		lua_getfield(L, current_abm, "nodenames");
		if (lua_istable(L, -1)) {
			int table = lua_gettop(L);
			lua_pushnil(L);
			while (lua_next(L, table)) {
				// key at index -2 and value at index -1
				luaL_checktype(L, -1, LUA_TSTRING);
				trigger_contents.insert(lua_tostring(L, -1));
				// removes value, keeps key for next iteration
				lua_pop(L, 1);
			}
		} else if (lua_isstring(L, -1)) {
			trigger_contents.insert(lua_tostring(L, -1));
		}
		lua_pop/*
Minetest-c55
Copyright
		std::set<std::string> required_neighbors;
		lua_getfield(L, current_abm, "neighbors");
		if (lua_istable(L, -1)) {
			int table = lua_gettop(L);
			lua_pushnil(L);
			while (lua_next(L, table)) {
				// key at index -2 and value at index -1
				luaL_checktype(L, -1, LUA_TSTRING);
				required_neighbors.insert(lua_tostring(L, -1));
				// removes value, keeps key for next iteration
				lua_pop(L, 1);
			}
		} else if (lua_isstring(L, -1)) {
			required_neighbors.insert(lua_tostring(L, -1));
		}
		lua_pop(L, 1);

		float trigger_interval = 10.0;
		getfloatfield(L, current_abm, "interval", trigger_interval);

		int trigger_chance = 50;
		getintfield(L, current_abm, "chance", trigger_chance);

		bool simple_catch_up = true;
		getboolfield(L, current_abm, "catch_up", simple_catch_up);

		LuaABM *abm = new LuaABM(L, id, trigger_contents, required_neighbors,
			trigger_interval, trigger_chance, simple_catch_up);

		env->addActiveBlockModifier(abm);

		// removes value, keeps key for next iteration
		lua_pop(L, 1);
	}
	lua_pop(L, 1);

	// Get core.registered_lbms
	lua_getglobal(L, "core");
	lua_getfield(L, -1, "registered_lbms");
	int registered_lbms = lua_gettop(L);

	if (!lua_istable(L, registered_lbms)) {
		lua_pop(L, 1);
		throw LuaError("core.registered_lbms was not a lua table, as expected.");
	}

	lua_pushnil(L);
	while (lua_next(L, registered_lbms)) {
		// key at index -2 and value at index -1
		int id = lua_tonumber(L, -2);
		int current_lbm = lua_gettop(L);

		std::set<std::string> trigger_contents;
		lua_getfield(L, current_lbm, "nodenames");
		if (lua_istable(L, -1)) {
			int table = lua_gettop(L);
			lua_pushnil(L);
			while (lua_next(L, table)) {
				// key at index -2 and value at index -1
				luaL_checktype(L, -1, LUA_TSTRING);
				trigger_contents.insert(lua_tostring(L, -1));
				// removes value, keeps key for next iteration
				lua_pop(L, 1);
			}
		} else if (lua_isstring(L, -1)) {
			trigger_contents.insert(lua_tostring(L, -1));
		}
		lua_pop(L, 1);

		std::string name;
		getstringfield(L, current_lbm, "name", name);

		bool run_at_every_load = getboolfield_default(L, current_lbm,
			"run_at_every_load", false);

		LuaLBM *lbm = new LuaLBM(L, id, trigger_contents, name,
			run_at_every_load);

		env->addLoadingBlockModifierDef(lbm);

		// removes value, keeps key for next iteration
		lua_pop(L, 1);
	}
	lua_pop(L, 1);
}

void ScriptApiEnv::on_emerge_area_completion(
	v3s16 blockpos, int action, ScriptCallbackState *state)
{
	Server *server = getServer();

	// This function should be executed with envlock held.
	// The caller (LuaEmergeAreaCallback in src/script/lua_api/l_env.cpp)
	// should have obtained the lock.
	// Note that the order of these locks is important!  Envlock must *ALWAYS*
	// be acquired before attempting to acquire scriptlock, or else ServerThread
	// will try to acquire scriptlock after it already owns envlock, thus
	// deadlocking EmergeThread and ServerThread

	SCRIPTAPI_PRECHECKHEADER

	int error_handler = PUSH_ERROR_HANDLER(L);

	lua_rawgeti(L, LUA_REGISTRYINDEX, state->callback_ref);
	luaL_checktype(L, -1, LUA_TFUNCTION);

	push_v3s16(L, blockpos);
	lua_pushinteger(L, action);
	lua_pushinteger(L, state->refcount);
	lua_rawgeti(L, LUA_REGISTRYINDEX, state->args_ref);

	setOriginDirect(state->origin.c_str());

	try {
		PCALL_RES(lua_pcall(L, 4, 0, error_handler));
	} catch (LuaError &e) {
		server->setAsyncFatalError(
				std::string("on_emerge_area_completion: ") + e.what() + "\n"
				+ script_get_backtrace(L));
	}

	lua_pop(L, 1); // Pop error handler

	if (state->refcount == 0) {
		luaL_unref(L, LUA_REGISTRYINDEX, state->callback_ref);
		luaL_unref(L, LUA_REGISTRYINDEX, state->args_ref);
	}
}
an> if(trimmedline.size() == 0 || trimmedline[0] == '#') { dst.push_back(line+line_end); return true; } Strfnd sf(trim(line)); std::string name = sf.next("="); name = trim(name); if(name == "") { dst.push_back(line+line_end); return true; } std::string value = sf.next("\n"); value = trim(value); if(m_settings.find(name)) { std::string newvalue = m_settings[name]; if(newvalue != value) { infostream<<"Changing value of \""<<name<<"\" = \"" <<value<<"\" -> \""<<newvalue<<"\"" <<std::endl; value_changed = true; } dst.push_back(name + " = " + newvalue + line_end); updated[name] = true; } return true; } /* Updates configuration file Returns true on success */ bool updateConfigFile(const char *filename) { infostream<<"Updating configuration file: \"" <<filename<<"\""<<std::endl; core::list<std::string> objects; core::map<std::string, bool> updated; bool something_actually_changed = false; // Read and modify stuff { std::ifstream is(filename); if(is.good() == false) { infostream<<"updateConfigFile():" " Error opening configuration file" " for reading: \"" <<filename<<"\""<<std::endl; } else { while(getUpdatedConfigObject(is, objects, updated, something_actually_changed)); } } JMutexAutoLock lock(m_mutex); // If something not yet determined to have been changed, check if // any new stuff was added if(!something_actually_changed){ for(core::map<std::string, std::string>::Iterator i = m_settings.getIterator(); i.atEnd() == false; i++) { if(updated.find(i.getNode()->getKey())) continue; something_actually_changed = true; break; } } // If nothing was actually changed, skip writing the file if(!something_actually_changed){ infostream<<"Skipping writing of "<<filename <<" because content wouldn't be modified"<<std::endl; return true; } // Write stuff back { std::ofstream os(filename); if(os.good() == false) { errorstream<<"Error opening configuration file" " for writing: \"" <<filename<<"\""<<std::endl; return false; } /* Write updated stuff */ for(core::list<std::string>::Iterator i = objects.begin(); i != objects.end(); i++) { os<<(*i); } /* Write stuff that was not already in the file */ for(core::map<std::string, std::string>::Iterator i = m_settings.getIterator(); i.atEnd() == false; i++) { if(updated.find(i.getNode()->getKey())) continue; std::string name = i.getNode()->getKey(); std::string value = i.getNode()->getValue(); infostream<<"Adding \""<<name<<"\" = \""<<value<<"\"" <<std::endl; os<<name<<" = "<<value<<"\n"; } } return true; } /* NOTE: Types of allowed_options are ignored returns true on success */ bool parseCommandLine(int argc, char *argv[], core::map<std::string, ValueSpec> &allowed_options) { int nonopt_index = 0; int i=1; for(;;) { if(i >= argc) break; std::string argname = argv[i]; if(argname.substr(0, 2) != "--") { // If option doesn't start with -, read it in as nonoptX if(argname[0] != '-'){ std::string name = "nonopt"; name += itos(nonopt_index); set(name, argname); nonopt_index++; i++; continue; } errorstream<<"Invalid command-line parameter \"" <<argname<<"\": --<option> expected."<<std::endl; return false; } i++; std::string name = argname.substr(2); core::map<std::string, ValueSpec>::Node *n; n = allowed_options.find(name); if(n == NULL) { errorstream<<"Unknown command-line parameter \"" <<argname<<"\""<<std::endl; return false; } ValueType type = n->getValue().type; std::string value = ""; if(type == VALUETYPE_FLAG) { value = "true"; } else { if(i >= argc) { errorstream<<"Invalid command-line parameter \"" <<name<<"\": missing value"<<std::endl; return false; } value = argv[i]; i++; } infostream<<"Valid command-line parameter: \"" <<name<<"\" = \""<<value<<"\"" <<std::endl; set(name, value); } return true; } void set(std::string name, std::string value) { JMutexAutoLock lock(m_mutex); m_settings[name] = value; } void set(std::string name, const char *value) { JMutexAutoLock lock(m_mutex); m_settings[name] = value; } void setDefault(std::string name, std::string value) { JMutexAutoLock lock(m_mutex); m_defaults[name] = value; } bool exists(std::string name) { JMutexAutoLock lock(m_mutex); return (m_settings.find(name) || m_defaults.find(name)); } std::string get(std::string name) { JMutexAutoLock lock(m_mutex); core::map<std::string, std::string>::Node *n; n = m_settings.find(name); if(n == NULL) { n = m_defaults.find(name); if(n == NULL) { throw SettingNotFoundException("Setting not found"); } } return n->getValue(); } bool getBool(std::string name) { return is_yes(get(name)); } bool getFlag(std::string name) { try { return getBool(name); } catch(SettingNotFoundException &e) { return false; } } // Asks if empty bool getBoolAsk(std::string name, std::string question, bool def) { // If it is in settings if(exists(name)) return getBool(name); std::string s; char templine[10]; std::cout<<question<<" [y/N]: "; std::cin.getline(templine, 10); s = templine; if(s == "") return def; return is_yes(s); } float getFloat(std::string name) { return stof(get(name)); } u16 getU16(std::string name) { return stoi(get(name), 0, 65535); } u16 getU16Ask(std::string name, std::string question, u16 def) { // If it is in settings if(exists(name)) return getU16(name); std::string s; char templine[10]; std::cout<<question<<" ["<<def<<"]: "; std::cin.getline(templine, 10); s = templine; if(s == "") return def; return stoi(s, 0, 65535); } s16 getS16(std::string name) { return stoi(get(name), -32768, 32767); } s32 getS32(std::string name) { return stoi(get(name)); } v3f getV3F(std::string name) { v3f value; Strfnd f(get(name)); f.next("("); value.X = stof(f.next(",")); value.Y = stof(f.next(",")); value.Z = stof(f.next(")")); return value; } v2f getV2F(std::string name) { v2f value; Strfnd f(get(name)); f.next("("); value.X = stof(f.next(",")); value.Y = stof(f.next(")")); return value; } u64 getU64(std::string name) { u64 value = 0; std::string s = get(name); std::istringstream ss(s); ss>>value; return value; } void setBool(std::string name, bool value) { if(value) set(name, "true"); else set(name, "false"); } void setS32(std::string name, s32 value) { set(name, itos(value)); } void setFloat(std::string name, float value) { set(name, ftos(value)); } void setV3F(std::string name, v3f value) { std::ostringstream os; os<<"("<<value.X<<","<<value.Y<<","<<value.Z<<")"; set(name, os.str()); } void setV2F(std::string name, v2f value) { std::ostringstream os; os<<"("<<value.X<<","<<value.Y<<")"; set(name, os.str()); } void setU64(std::string name, u64 value) { std::ostringstream os; os<<value; set(name, os.str()); } void clear() { JMutexAutoLock lock(m_mutex); m_settings.clear(); m_defaults.clear(); } void updateValue(Settings &other, const std::string &name) { JMutexAutoLock lock(m_mutex); if(&other == this) return; try{ std::string val = other.get(name); m_settings[name] = val; } catch(SettingNotFoundException &e){ } return; } void update(Settings &other) { JMutexAutoLock lock(m_mutex); JMutexAutoLock lock2(other.m_mutex); if(&other == this) return; for(core::map<std::string, std::string>::Iterator i = other.m_settings.getIterator(); i.atEnd() == false; i++) { m_settings[i.getNode()->getKey()] = i.getNode()->getValue(); } for(core::map<std::string, std::string>::Iterator i = other.m_defaults.getIterator(); i.atEnd() == false; i++) { m_defaults[i.getNode()->getKey()] = i.getNode()->getValue(); } return; } Settings & operator+=(Settings &other) { JMutexAutoLock lock(m_mutex); JMutexAutoLock lock2(other.m_mutex); if(&other == this) return *this; for(core::map<std::string, std::string>::Iterator i = other.m_settings.getIterator(); i.atEnd() == false; i++) { m_settings.insert(i.getNode()->getKey(), i.getNode()->getValue()); } for(core::map<std::string, std::string>::Iterator i = other.m_defaults.getIterator(); i.atEnd() == false; i++) { m_defaults.insert(i.getNode()->getKey(), i.getNode()->getValue()); } return *this; } Settings & operator=(Settings &other) { JMutexAutoLock lock(m_mutex); JMutexAutoLock lock2(other.m_mutex); if(&other == this) return *this; clear(); (*this) += other; return *this; } private: core::map<std::string, std::string> m_settings; core::map<std::string, std::string> m_defaults; // All methods that access m_settings/m_defaults directly should lock this. JMutex m_mutex; }; #endif