/* * Famedly Matrix SDK * Copyright (C) 2019, 2020, 2021 Famedly GmbH * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ import 'dart:convert'; import 'package:olm/olm.dart' as olm; import '../../matrix.dart'; class OutboundGroupSession { /// The devices is a map from user id to device id to if the device is blocked. /// This way we can easily know if a new user is added, leaves, a new devices is added, and, /// very importantly, if we block a device. These are all important for determining if/when /// an outbound session needs to be rotated. Map> devices = {}; // Default to a date, that would get this session rotated in any case to make handling easier DateTime creationTime = DateTime.fromMillisecondsSinceEpoch(0); olm.OutboundGroupSession? outboundGroupSession; int? get sentMessages => outboundGroupSession?.message_index(); bool get isValid => outboundGroupSession != null; final String key; OutboundGroupSession( {required this.devices, required this.creationTime, required this.outboundGroupSession, required this.key}); OutboundGroupSession.fromJson(Map dbEntry, String key) : key = key { try { for (final entry in json.decode(dbEntry['device_ids']).entries) { devices[entry.key] = Map.from(entry.value); } } catch (e) { // devices is bad (old data), so just not use this session Logs().i( '[OutboundGroupSession] Session in database is old, not using it. ' + e.toString()); return; } outboundGroupSession = olm.OutboundGroupSession(); try { outboundGroupSession!.unpickle(key, dbEntry['pickle']); creationTime = DateTime.fromMillisecondsSinceEpoch(dbEntry['creation_time']); } catch (e, s) { dispose(); Logs().e('[LibOlm] Unable to unpickle outboundGroupSession', e, s); } } void dispose() { outboundGroupSession?.free(); outboundGroupSession = null; } }