source/api/actions/calendar_add.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_add(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<
@@ -64,8 +64,7 @@ namespace _zeitbild.api
 					else {
 						// TODO move logic to calendar service
 						let resource_object : _zeitbild.type_resource_object;
-						switch (stuff.input.resource.kind)
+						switch (stuff.input.resource.kind) {
-						{
 							case "local": {
 								resource_object = {
 									"kind": "local",

source/api/actions/calendar_change.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_change(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/calendar_event_add.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_event_add(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/calendar_event_change.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_event_change(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/calendar_event_get.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_event_get(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/calendar_event_remove.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_event_remove(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/calendar_get.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_get(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/calendar_list.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_list(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/calendar_remove.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_calendar_remove(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/events.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_events(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/meta_ping.ts

@@ -5,10 +5,10 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_meta_ping(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
-		lib_plankton.rest_http.register<
+		lib_plankton.rest.register<
 			null,
 			string
 		>
@@ -17,7 +17,7 @@ namespace _zeitbild.api
 			lib_plankton.http.enum_method.get,
 			_zeitbild.conf.get().server.path_base + "/meta/ping",
 			{
-				"description": () => "sendet ein 'pong' zurück; gedacht um die Erreichbarkeit des Backends zu prüfen",
+				"description": "sendet ein 'pong' zurück; gedacht um die Erreichbarkeit des Backends zu prüfen",
 				"input_schema": () => ({
 					"nullable": true,
 				}),
@@ -25,10 +25,8 @@ namespace _zeitbild.api
 					"nullable": false,
 					"type": "string",
 				}),
-				"response_body_encode": () => (body) => Promise.resolve<string>(body),
+				"restriction": restriction_none,
-				"response_body_mimetype": () => "text/plain",
+				"execution": () => {
-				"restriction": () => restriction_none,
-				"execution": () => () => {
 					return Promise.resolve({
 						"status_code": 200,
 						"data": "pong",

source/api/actions/meta_spec.ts

@@ -5,10 +5,10 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_meta_spec(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
-		lib_plankton.rest_http.register<
+		lib_plankton.rest.register<
 			null,
 			any
 		>
@@ -17,17 +17,17 @@ namespace _zeitbild.api
 			lib_plankton.http.enum_method.get,
 			_zeitbild.conf.get().server.path_base + "/meta/spec",
 			{
-				"description": () => "gibt die API-Spezifikation im OpenAPI-Format aus",
+				"description": "gibt die API-Spezifikation im OpenAPI-Format aus",
 				"input_schema": () => ({
 					"nullable": true,
 				}),
 				"output_schema": () => ({
 				}),
-				"restriction": () => restriction_none,
+				"restriction": restriction_none,
-				"execution": () => () => {
+				"execution": () => {
 					return Promise.resolve({
 						"status_code": 200,
-						"data": lib_plankton.rest_http.to_oas(rest_subject),
+						"data": lib_plankton.rest.to_oas(rest_subject),
 					});
 				},
 			}

source/api/actions/session_begin.ts

@@ -5,10 +5,10 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_session_begin(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
-		lib_plankton.rest_http.register<
+		lib_plankton.rest.register<
 			{
 				name : string;
 				password : string;
@@ -23,7 +23,7 @@ namespace _zeitbild.api
 			lib_plankton.http.enum_method.post,
 			"/session/begin",
 			{
-				"description": () => "führt die Anmeldung am System aus um geschützte Aktionen nutzen zu können",
+				"description": "führt die Anmeldung am System aus um geschützte Aktionen nutzen zu können",
 				"input_schema": () => ({
 					"type": "object",
 					"properties": {
@@ -44,8 +44,8 @@ namespace _zeitbild.api
 					"type": "string",
 					"description": "der Sitzungs-Schlüssel, der als Header 'X-Session-Key' gesetzt werden muss um Erlaubnis zur Ausführung geschützter Aktionen zu erhalten",
 				}),
-				"restriction": () => restriction_none,
+				"restriction": restriction_none,
-				"execution": () => async ({"input": input}) => {
+				"execution": async ({"input": input}) => {
 					if (input === null) {
 						return Promise.reject(new Error("impossible"));
 					}

source/api/actions/session_end.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_session_end(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<null, null>(

source/api/actions/session_oidc.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_session_oidc(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/api/actions/session_prepare.ts

@@ -5,10 +5,10 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_session_prepare(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
-		lib_plankton.rest_http.register<
+		lib_plankton.rest.register<
 			any,
 			{
 				kind : string;
@@ -19,15 +19,15 @@ namespace _zeitbild.api
 			lib_plankton.http.enum_method.post,
 			"/session/prepare",
 			{
-				"description": () => "gibt die nötigen Werkzeuge für eine Anmeldung aus",
+				"description": "gibt die nötigen Werkzeuge für eine Anmeldung aus",
 				"input_schema": () => ({
 					"nullable": true,
 				}),
 				"output_schema": () => ({
 					"nullable": false
 				}),
-				"restriction": () => restriction_none,
+				"restriction": restriction_none,
-				"execution": () => async (stuff) => {
+				"execution": async (stuff) => {
 					const preparation = await _zeitbild.auth.prepare(stuff.input);
 					return Promise.resolve({
 						"status_code": 200,

source/api/actions/users.ts

@@ -5,7 +5,7 @@ namespace _zeitbild.api
 	/**
 	 */
 	export function register_users(
-		rest_subject : lib_plankton.rest_http.type_rest
+		rest_subject : lib_plankton.rest.type_rest
 	) : void
 	{
 		register<

source/base.ts

@@ -3,16 +3,6 @@ namespace _zeitbild
 	
 	/**
 	 */
-	export var cache_regular : lib_plankton.cache.type_subject<any>;
+	export var cache : lib_plankton.cache.type_cache<any>;
-	
-	
-	/**
-	 */
-	export var cache_external_resources : lib_plankton.cache.type_subject<any>;
-	
-	
-	/**
-	 */
-	export var cache_templates : lib_plankton.cache.type_subject<string>;
 	
 }

source/conf.ts

@@ -41,17 +41,7 @@ namespace _zeitbild.conf
 												"error"
 											],
 											"default": "info"
-										},
+										}
-										"format": {
-											"nullable": false,
-											"type": "string",
-											"enum": [
-												"human_readable",
-												"jsonl",
-												"jsonl_structured",
-											],
-											"default": "human_readable",
-										},
 									},
 									"required": [
 									]

source/helpers.ts

@@ -60,29 +60,37 @@ namespace _zeitbild.helpers
 	
 	/**
 	 */
+	var _template_cache : Record<string, string> = {};
+	
+	
+	/**
+	 * @todo caching
+	 */
 	export async function template_coin(
 		name : string,
 		data : Record<string, string>
 	) : Promise<string>
 	{
-		const content : string = await lib_plankton.cache.get<string>(
+		let content : string;
-			_zeitbild.cache_templates,
+		if (! (name in _template_cache)) {
-			name,
+			content = (
-			null,
+				(
-			() => (
+					await lib_plankton.file.read(
-				lib_plankton.file.read(
+						lib_plankton.string.coin(
-					lib_plankton.string.coin(
+							"templates/{{name}}.html.tpl",
-						"templates/{{name}}.html.tpl",
+							{
-						{
+								"name": name,
-							"name": name,
+							}
-						}
+						)
 					)
 				)
-				.then(
+				.toString()
-					x => Promise.resolve<string>(x.toString())
+			);
-				)
+			_template_cache[name] = content;
-			)
+		}
-		);
+		else {
+			content = _template_cache[name];
+		}
 		return Promise.resolve<string>(
 			lib_plankton.string.coin(
 				content,

source/main.ts

@@ -68,8 +68,7 @@ async function data_init(
 		"user": {},
 		"calendar": {},
 	};
-	for await (const user_raw of data.users)
+	for await (const user_raw of data.users) {
-	{
 		const user_object : _zeitbild.type_user_object = {
 			"name": user_raw.name,
 			"email_address": user_raw.email_address,
@@ -83,14 +82,11 @@ async function data_init(
 		);
 		track.user[user_raw.id] = user_id;
 	}
-	for await (const calendar_raw of data.calendars)
+	for await (const calendar_raw of data.calendars) {
-	{
 		let resource_object : _zeitbild.type_resource_object;
 		let resource_id : _zeitbild.type_resource_id;
-		switch (calendar_raw.resource.kind)
+		switch (calendar_raw.resource.kind) {
-		{
+			case "local": {
-			case "local":
-			{
 				resource_object = {
 					"kind": "local",
 					"data": {
@@ -108,8 +104,7 @@ async function data_init(
 				);
 				break;
 			}
-			case "caldav":
+			case "caldav": {
-			{
 				resource_object = {
 					"kind": "caldav",
 					"data": {
@@ -124,8 +119,7 @@ async function data_init(
 				break;
 			}
 		}
-		const calendar_object : _zeitbild.type_calendar_object =
+		const calendar_object : _zeitbild.type_calendar_object = {
-		{
 			"name": calendar_raw.name,
 			"access": {
 				"public": (calendar_raw.access.public ?? false),
@@ -165,17 +159,11 @@ async function main(
 ) : Promise<void>
 {
 	// init1
-	/*
+	lib_plankton.log.conf_push(
-	lib_plankton.log.set_main_logger(
 		[
-			{
+			lib_plankton.log.channel_make({"kind": "stdout", "data": {"threshold": "info"}}),
-				"kind": "std",
-				"data": {
-				}
-			}
 		]
 	);
-	 */
 	
 	// args
 	const arg_handler : lib_plankton.args.class_handler = new lib_plankton.args.class_handler({
@@ -258,79 +246,30 @@ async function main(
 			"name": "help",
 		}),
 	});
-	const args : Record<string, any> = arg_handler.read(
+	const args : Record<string, any> = arg_handler.read(lib_plankton.args.enum_environment.cli, args_raw.join(" "));	
-		lib_plankton.args.enum_environment.cli,
-		args_raw.join(" ")
-	);
 	
 	// init2
 	await _zeitbild.conf.init(
 		args["conf_path"]
 	);
-	lib_plankton.log.set_main_logger(
+	lib_plankton.log.conf_push(
 		_zeitbild.conf.get().log.map(
-			(log_output : any) => {
+			(log_output : any) => lib_plankton.log.channel_make(
-				switch (log_output.kind) {
+				{
-					case "stdout": {
+					"kind": log_output.kind,
-						return {
+					"data": log_output.data
-							"kind": "minlevel",
-							"data": {
-								"core": {
-									"kind": "std",
-									"data": {
-										"target": "stdout",
-										"format": lib_plankton.call.distinguish(
-											{
-												"kind": log_output.data.format,
-												"data": null,
-											},
-											{
-												"jsonl": () => ({
-													"kind": "jsonl",
-													"data": {
-														"structured": false,
-													}
-												}),
-												"jsonl_structured": () => ({
-													"kind": "jsonl",
-													"data": {
-														"structured": true,
-													}
-												}),
-												"human_readable": () => ({
-													"kind": "human_readable",
-													"data": {
-													}
-												}),
-											}
-										),
-									}
-								},
-								"threshold": log_output.data.threshold,
-							}
-						};
-						break;
-					}
-					default: {
-						throw (new Error("unhandled"));
-						break;
-					}
 				}
+			)
+		)
+	);
+	_zeitbild.cache = lib_plankton.cache.chest.implementation<any>(
+		lib_plankton.cache.chest.make<any>(
+			{
+				"chest": lib_plankton.storage.memory.implementation_chest<any>({}),
 			}
 		)
 	);
-	{
+	await _zeitbild.cache.init();
-		_zeitbild.cache_regular = lib_plankton.cache.make<any>();
-		await lib_plankton.cache.init(_zeitbild.cache_regular);
-	}
-	{
-		_zeitbild.cache_external_resources = lib_plankton.cache.make<any>();
-		await lib_plankton.cache.init(_zeitbild.cache_external_resources);
-	}
-	{
-		_zeitbild.cache_templates = lib_plankton.cache.make<any>();
-		await lib_plankton.cache.init(_zeitbild.cache_templates);
-	}
 	
 	// exec
 	if (args["help"]) {
@@ -382,7 +321,7 @@ async function main(
 				break;
 			}
 			case "api-doc": {
-				lib_plankton.log.set_main_logger([]);
+				lib_plankton.log.conf_push([]);
 				const rest_subject : lib_plankton.rest.type_rest = _zeitbild.api.make();
 				lib_plankton.log.conf_pop();
 				process.stdout.write(
@@ -450,7 +389,6 @@ async function main(
 								"checklevel_restriction": lib_plankton.api.enum_checklevel.hard,
 								// "checklevel_input": lib_plankton.api.enum_checklevel.soft,
 								// "checklevel_output": lib_plankton.api.enum_checklevel.soft,
-								"set_content_length": false,
 							}
 						);
 						const output : string = lib_plankton.http.encode_response(http_response);

source/repositories/calendar.ts

@@ -251,7 +251,7 @@ namespace _zeitbild.repository.calendar
 				{"level": access_attributed_row["level"]}
 			);
 		}
-		await lib_plankton.cache.clear(_zeitbild.cache_regular);
+		await _zeitbild.cache.clear();
 		return Promise.resolve<_zeitbild.type_calendar_id>(calendar_id);
 	}
 	
@@ -313,7 +313,7 @@ namespace _zeitbild.repository.calendar
 				);
 			}
 		}
-		await lib_plankton.cache.clear(_zeitbild.cache_regular);
+		await _zeitbild.cache.clear();
 		return Promise.resolve<void>(undefined);
 	}
 	
@@ -325,7 +325,7 @@ namespace _zeitbild.repository.calendar
 		calendar_id : _zeitbild.type_calendar_id
 	) : Promise<void>
 	{
-		await lib_plankton.cache.clear(_zeitbild.cache_regular);
+		await _zeitbild.cache.clear();
 		const core_store = get_core_store();
 		const access_attributed_chest = get_access_attributed_chest();
 		// attributed access
@@ -375,12 +375,11 @@ namespace _zeitbild.repository.calendar
 	>
 	{
 		return lib_plankton.cache.get_complex<any, Array<type_overview_entry>>(
-			_zeitbild.cache_regular,
+			_zeitbild.cache,
 			"calendar_overview",
 			{
 				"user_id": user_id,
 			},
-			null,
 			() => (
 				lib_plankton.file.read("sql/calendar_overview.sql")
 				.then(

source/repositories/resource.ts

@@ -401,7 +401,7 @@ namespace _zeitbild.repository.resource
 						"sub_id": local_resource_id,
 					}
 				);
-				await lib_plankton.cache.clear(_zeitbild.cache_regular);
+				await _zeitbild.cache.clear();
 				return Promise.resolve<_zeitbild.type_resource_id>(resource_id);
 				break;
 			}
@@ -419,7 +419,7 @@ namespace _zeitbild.repository.resource
 						"sub_id": caldav_resource_id,
 					}
 				);
-				await lib_plankton.cache.clear(_zeitbild.cache_regular);
+				await _zeitbild.cache.clear();
 				return Promise.resolve<_zeitbild.type_resource_id>(resource_id);
 				break;
 			}
@@ -499,7 +499,7 @@ namespace _zeitbild.repository.resource
 							"read_only": resource_object.data.read_only,
 						}
 					);
-					await lib_plankton.cache.clear(_zeitbild.cache_regular);
+					await _zeitbild.cache.clear();
 					break;
 				}
 				default: {
@@ -561,7 +561,7 @@ namespace _zeitbild.repository.resource
 					}
 				)
 			);
-			await lib_plankton.cache.clear(_zeitbild.cache_regular);
+			await _zeitbild.cache.clear();
 			return Promise.resolve(local_resource_event_id);
 		}
 	}
@@ -589,7 +589,7 @@ namespace _zeitbild.repository.resource
 					}
 				)
 			);
-			await lib_plankton.cache.clear(_zeitbild.cache_regular);
+			await _zeitbild.cache.clear();
 			return Promise.resolve<void>(undefined);
 		}
 	}
@@ -602,7 +602,7 @@ namespace _zeitbild.repository.resource
 		local_resource_event_id : _zeitbild.type_local_resource_event_id
 	) : Promise<void>
 	{
-		await lib_plankton.cache.clear(_zeitbild.cache_regular);
+		await _zeitbild.cache.clear();
 		const dataset_core : Record<string, any> = await get_resource_core_store().read(resource_id);
 		if (! (dataset_core.kind === "local")) {
 			throw (new Error("not a local resource"));