aequitosh/flutter-vienna-hackathon-25
1
0
Fork 0
mirror of https://github.com/timokz/flutter-vienna-hackathon-25.git synced 2025-11-08 21:24:20 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

yield quote updates

Browse source
This commit is contained in:
tk 2025-08-16 14:43:05 +02:00
parent 6f75132073
commit 75724e4043
1 changed files with 18 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
wien_talks/wien_talks_server/lib/src/quotes/quotes_endpoint.dart
View file

@ -3,6 +3,22 @@ import 'package:wien_talks_server/src/generated/protocol.dart';
import 'package:wien_talks_server/src/quotes/quote_controller.dart'; import 'package:wien_talks_server/src/quotes/quote_controller.dart';
class QuoteEndpoint extends Endpoint { class QuoteEndpoint extends Endpoint {
static const _channelQuoteUpdates = 'quote-updates';
Future<void> updateQuote(Session session, Quote quote) async {
await Quote.db.updateRow(session, quote);
await session.messages.postMessage(_channelQuoteUpdates, quote);
}
Stream<Quote> quoteUpdates(Session session) async* {
var updateStream =
session.messages.createStream<Quote>(_channelQuoteUpdates);
await for (var quote in updateStream) {
yield quote;
}
}
Future<Quote> createQuote(Session session, CreateQuoteRequest req) async { Future<Quote> createQuote(Session session, CreateQuoteRequest req) async {
final authInfo = await session.authenticated; final authInfo = await session.authenticated;
final userId = authInfo?.userId; final userId = authInfo?.userId;
@ -29,6 +45,8 @@ class QuoteEndpoint extends Endpoint {
); );
final inserted = await session.db.insertRow<Quote>(quote); final inserted = await session.db.insertRow<Quote>(quote);
await session.messages.postMessage(_channelQuoteUpdates, quote);
return inserted; return inserted;
} }