timetracker
  1. 1
  2. 2
  3. 3
  4. 4
  5. 5
  6. 6
  7. 7
  8. 8
  9. 9
  10. 10
  11. 11
  12. 12
  13. 13
  14. 14
  15. 15
  16. 16
  17. 17
  18. 18
  19. 19
  20. 20
  21. 21
  22. 22
  23. 23
  24. 24
  25. 25
  26. 26
  27. 27
  28. 28
  29. 29
  30. 30
  31. 31
  32. 32
  33. 33
  34. 34
  35. 35
  36. 36
  37. 37
  38. 38
  39. 39
  40. 40
  41. 41
  42. 42
  43. 43
  44. 44
  45. 45
  46. 46
  47. 47
  48. 48
  49. 49
  50. 50
  51. 51
  52. 52
  53. 53
  54. 54
  55. 55
  56. 56
  57. 57
  58. 58
  59. 59
  60. 60
  61. 61
  62. 62
  63. 63
// Copyright 2025 Shota FUJI
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at https://mozilla.org/MPL/2.0/.
//
// SPDX-License-Identifier: MPL-2.0

using GLib;

namespace TimeTracker.Storage {
	private class LocalEnvelope : Object {
		public string? parent { get; set; default = null; }
		public string id { get; construct; }
		public Event.EventType event_type { get; construct; }
		public string event_data { get; construct; }

		public LocalEnvelope(Event.Event event) throws Error {
			var node = Json.gobject_serialize(event);

			var generator = new Json.Generator();
			generator.set_root(node);

			Object(
				id: event.event_id,
				event_data: generator.to_data(null),
				event_type: Event.EventType.from_event(event)
			);
		}

		public static LocalEnvelope new_from_stream(InputStream stream) throws Error {
			var parser = new Json.Parser();
			parser.load_from_stream(stream);
			var node = parser.get_root();

			var envelope = Json.gobject_deserialize(typeof(LocalEnvelope), node) as LocalEnvelope;
			assert(envelope != null);

			return envelope;
		}

		public Event.Event parse_event() throws Error {
			var type = event_type.to_type();

			var parser = new Json.Parser();
			parser.load_from_data(event_data);
			var node = parser.get_root();

			var event = Json.gobject_deserialize(type, node) as Event.Event;
			assert(event != null);

			return event;
		}

		public void write_stream(OutputStream stream) throws Error {
			var node = Json.gobject_serialize(this);

			var generator = new Json.Generator();
			generator.set_root(node);
			generator.to_stream(stream);
		}
	}
}