feat(chat): usable 1:1 chat — bottom-anchored, Drift-backed, dated
- Anchor the message list to the bottom (`reverse: true`) so new messages stay in view instead of landing below the fold. - Move chat history from the OS keystore (O(n²) JSON blob, silent 200-msg cap) to a separate encrypted Drift/SQLCipher DB (`ChatDatabase`): indexed append, uncapped history, dedup as a unique-key invariant. It's an ephemeral per-device cache, isolated from the inventory schema, its migrations, and its sync. No data migration (pre-release). - Add day separators (Today/Yesterday/locale date) and a per-bubble time, all via ICU (12/24h per locale; Localizations locale maps Asturian → Spanish for intl date symbols). - Add peer avatars (deterministic colour from the pubkey + name initial), surface send failures that were previously silent, and make bubble text selectable (addresses, links). - New i18n keys in en/es/pt/ast; tests for grouping, formatting, avatars, scroll anchoring, storage and send errors. Docs: docs/design/chat-storage.md + open-decisions.md.
This commit is contained in:
parent
171daabce3
commit
6cff0d0b11
27 changed files with 1793 additions and 264 deletions
|
|
@ -26,6 +26,19 @@ class FakeMessageTransport implements MessageTransport {
|
|||
Future<void> close() async => _inbox.close();
|
||||
}
|
||||
|
||||
/// A transport whose [send] always fails (e.g. no relay reachable).
|
||||
class _FailingSendTransport implements MessageTransport {
|
||||
@override
|
||||
Future<void> send({required String toPubkey, required String text}) async =>
|
||||
throw StateError('no relay');
|
||||
|
||||
@override
|
||||
Stream<PrivateMessage> inbox() => const Stream.empty();
|
||||
|
||||
@override
|
||||
Future<void> close() async {}
|
||||
}
|
||||
|
||||
void main() {
|
||||
const peer = 'aa';
|
||||
const me = 'bb';
|
||||
|
|
@ -35,8 +48,8 @@ void main() {
|
|||
|
||||
test('receives messages from the peer only', () async {
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit =
|
||||
MessagesCubit(transport, peerPubkey: peer, selfPubkey: me)..start();
|
||||
final cubit = MessagesCubit(transport, peerPubkey: peer, selfPubkey: me)
|
||||
..start();
|
||||
|
||||
transport.receive(msg(peer, 'hola'));
|
||||
transport.receive(msg('cc', 'not for this chat')); // other conversation
|
||||
|
|
@ -62,8 +75,8 @@ void main() {
|
|||
|
||||
test('a full exchange keeps order and sides', () async {
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit =
|
||||
MessagesCubit(transport, peerPubkey: peer, selfPubkey: me)..start();
|
||||
final cubit = MessagesCubit(transport, peerPubkey: peer, selfPubkey: me)
|
||||
..start();
|
||||
|
||||
await cubit.send('hi');
|
||||
transport.receive(msg(peer, 'hello'));
|
||||
|
|
@ -74,6 +87,19 @@ void main() {
|
|||
await cubit.close();
|
||||
});
|
||||
|
||||
test(
|
||||
'a failed send surfaces an error and drops the optimistic message',
|
||||
() async {
|
||||
final transport = _FailingSendTransport();
|
||||
final cubit = MessagesCubit(transport, peerPubkey: peer, selfPubkey: me);
|
||||
await cubit.send('hi');
|
||||
expect(cubit.state.error, isNotNull);
|
||||
expect(cubit.state.sending, isFalse);
|
||||
expect(cubit.state.messages, isEmpty);
|
||||
await cubit.close();
|
||||
},
|
||||
);
|
||||
|
||||
test('empty/whitespace text is not sent', () async {
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit = MessagesCubit(transport, peerPubkey: peer, selfPubkey: me);
|
||||
|
|
@ -83,57 +109,88 @@ void main() {
|
|||
await cubit.close();
|
||||
});
|
||||
|
||||
test('loads saved history on start and persists across a new cubit',
|
||||
() async {
|
||||
final store = MessageStore(InMemorySecretStore());
|
||||
await store.append(
|
||||
peer, msg(peer, 'earlier')); // a message from a previous session
|
||||
test(
|
||||
'loads saved history on start and persists across a new cubit',
|
||||
() async {
|
||||
// History is ordered by each message's own timestamp, so use realistic
|
||||
// monotonic times: 'earlier' predates the sent 'hi' (stamped now() by the
|
||||
// cubit), and 'reply' comes after it.
|
||||
PrivateMessage at(String from, String text, DateTime when) =>
|
||||
PrivateMessage(fromPubkey: from, text: text, at: when);
|
||||
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit = MessagesCubit(transport,
|
||||
peerPubkey: peer, selfPubkey: me, store: store);
|
||||
await cubit.start();
|
||||
expect(cubit.state.messages.map((m) => m.text), ['earlier']);
|
||||
final store = MessageStore(newTestChatDatabase());
|
||||
await store.append(
|
||||
peer,
|
||||
at(peer, 'earlier', DateTime(2020)),
|
||||
); // from a previous session
|
||||
|
||||
await cubit.send('hi'); // persisted
|
||||
transport.receive(msg(peer, 'reply')); // persisted
|
||||
await pumpEventQueue();
|
||||
expect(cubit.state.messages.map((m) => m.text), ['earlier', 'hi', 'reply']);
|
||||
await cubit.close();
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit = MessagesCubit(
|
||||
transport,
|
||||
peerPubkey: peer,
|
||||
selfPubkey: me,
|
||||
store: store,
|
||||
);
|
||||
await cubit.start();
|
||||
expect(cubit.state.messages.map((m) => m.text), ['earlier']);
|
||||
|
||||
// A fresh cubit (even offline) sees the saved conversation.
|
||||
final reopened =
|
||||
MessagesCubit(null, peerPubkey: peer, selfPubkey: me, store: store);
|
||||
await reopened.start();
|
||||
expect(reopened.state.messages.map((m) => m.text),
|
||||
['earlier', 'hi', 'reply']);
|
||||
await reopened.close();
|
||||
});
|
||||
await cubit.send('hi'); // persisted, stamped now()
|
||||
transport.receive(at(peer, 'reply', DateTime(2100))); // persisted, later
|
||||
await pumpEventQueue();
|
||||
expect(cubit.state.messages.map((m) => m.text), [
|
||||
'earlier',
|
||||
'hi',
|
||||
'reply',
|
||||
]);
|
||||
await cubit.close();
|
||||
|
||||
test('a re-delivered wrap is shown once (relay resends stored events)',
|
||||
() async {
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit =
|
||||
MessagesCubit(transport, peerPubkey: peer, selfPubkey: me)..start();
|
||||
// A fresh cubit (even offline) sees the saved conversation.
|
||||
final reopened = MessagesCubit(
|
||||
null,
|
||||
peerPubkey: peer,
|
||||
selfPubkey: me,
|
||||
store: store,
|
||||
);
|
||||
await reopened.start();
|
||||
expect(reopened.state.messages.map((m) => m.text), [
|
||||
'earlier',
|
||||
'hi',
|
||||
'reply',
|
||||
]);
|
||||
await reopened.close();
|
||||
},
|
||||
);
|
||||
|
||||
final same = msg(peer, 'hola'); // identical sender+timestamp+text
|
||||
transport.receive(same);
|
||||
transport.receive(same); // relay re-delivery on the same subscription
|
||||
await pumpEventQueue();
|
||||
test(
|
||||
'a re-delivered wrap is shown once (relay resends stored events)',
|
||||
() async {
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit = MessagesCubit(transport, peerPubkey: peer, selfPubkey: me)
|
||||
..start();
|
||||
|
||||
expect(cubit.state.messages, hasLength(1));
|
||||
await cubit.close();
|
||||
});
|
||||
final same = msg(peer, 'hola'); // identical sender+timestamp+text
|
||||
transport.receive(same);
|
||||
transport.receive(same); // relay re-delivery on the same subscription
|
||||
await pumpEventQueue();
|
||||
|
||||
expect(cubit.state.messages, hasLength(1));
|
||||
await cubit.close();
|
||||
},
|
||||
);
|
||||
|
||||
test('history already surfaced live is not shown twice', () async {
|
||||
// The stored message is ALSO handed back by the live subscription on open.
|
||||
final store = MessageStore(InMemorySecretStore());
|
||||
final store = MessageStore(newTestChatDatabase());
|
||||
final m = msg(peer, 'hola');
|
||||
await store.append(peer, m);
|
||||
|
||||
final transport = FakeMessageTransport();
|
||||
final cubit = MessagesCubit(transport,
|
||||
peerPubkey: peer, selfPubkey: me, store: store);
|
||||
final cubit = MessagesCubit(
|
||||
transport,
|
||||
peerPubkey: peer,
|
||||
selfPubkey: me,
|
||||
store: store,
|
||||
);
|
||||
unawaited(cubit.start());
|
||||
transport.receive(m); // live redelivery races the history load
|
||||
await pumpEventQueue();
|
||||
|
|
@ -143,7 +200,8 @@ void main() {
|
|||
});
|
||||
|
||||
test('offline (no transport) never throws', () async {
|
||||
final cubit = MessagesCubit(null, peerPubkey: peer, selfPubkey: me)..start();
|
||||
final cubit = MessagesCubit(null, peerPubkey: peer, selfPubkey: me)
|
||||
..start();
|
||||
expect(cubit.isOnline, isFalse);
|
||||
await cubit.send('hi');
|
||||
expect(cubit.state.messages, isEmpty);
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue