Merge branch 'master' into feature/partial-update

This commit is contained in:
Salvatore Giordano
2021-02-19 16:10:54 +01:00
committed by GitHub
3 changed files with 127 additions and 82 deletions
@@ -154,7 +154,7 @@ class _MessageSearchListViewState extends State<MessageSearchListView> {
}, },
); );
}, },
errorBuilder: widget.emptyBuilder ?? errorBuilder: widget.errorBuilder ??
(BuildContext context, dynamic error) { (BuildContext context, dynamic error) {
if (error is Error) { if (error is Error) {
print((error).stackTrace); print((error).stackTrace);
@@ -67,6 +67,8 @@ class StreamExample extends StatelessWidget {
/// [ChannelListCore] is a `builder` with callbacks for constructing UIs based /// [ChannelListCore] is a `builder` with callbacks for constructing UIs based
/// on different scenarios. /// on different scenarios.
class HomeScreen extends StatelessWidget { class HomeScreen extends StatelessWidget {
final channelListController = ChannelListController();
@override @override
Widget build(BuildContext context) { Widget build(BuildContext context) {
return Scaffold( return Scaffold(
@@ -75,6 +77,15 @@ class HomeScreen extends StatelessWidget {
), ),
body: ChannelsBloc( body: ChannelsBloc(
child: ChannelListCore( child: ChannelListCore(
channelListController: channelListController,
filter: {
'type': 'messaging',
'members': {
r'$in': [
StreamChatCore.of(context).user.id,
]
}
},
emptyBuilder: (BuildContext context) { emptyBuilder: (BuildContext context) {
return Center( return Center(
child: Text('Looks like you are not in any channels'), child: Text('Looks like you are not in any channels'),
@@ -99,31 +110,46 @@ class HomeScreen extends StatelessWidget {
BuildContext context, BuildContext context,
List<Channel> channels, List<Channel> channels,
) => ) =>
ListView.builder( LazyLoadScrollView(
itemCount: channels.length, onEndOfPage: () async {
itemBuilder: (BuildContext context, int index) { channelListController.paginateData();
final _item = channels[index];
return ListTile(
title: Text(_item.name),
subtitle: Text(_item.state.lastMessage.text),
onTap: () {
/// Display a list of messages when the user taps on an item.
/// We can use [StreamChannel] to wrap our [MessageScreen] screen
/// with the selected channel.
///
/// This allows us to use a built-in inherited widget for accessing
/// our `channel` later on.
Navigator.of(context).push(
MaterialPageRoute(
builder: (context) => StreamChannel(
channel: _item,
child: MessageScreen(),
),
),
);
},
);
}, },
child: ListView.builder(
itemCount: channels.length,
itemBuilder: (BuildContext context, int index) {
final _item = channels[index];
return ListTile(
title: Text(_item.name),
subtitle: StreamBuilder<Message>(
stream: _item.state.lastMessageStream,
initialData: _item.state.lastMessage,
builder: (context, snapshot) {
if (snapshot.hasData) {
return Text(snapshot.data.text);
}
return SizedBox();
},
),
onTap: () {
/// Display a list of messages when the user taps on an item.
/// We can use [StreamChannel] to wrap our [MessageScreen] screen
/// with the selected channel.
///
/// This allows us to use a built-in inherited widget for accessing
/// our `channel` later on.
Navigator.of(context).push(
MaterialPageRoute(
builder: (context) => StreamChannel(
channel: _item,
child: MessageScreen(),
),
),
);
},
);
},
),
), ),
), ),
), ),
@@ -145,6 +171,7 @@ class MessageScreen extends StatefulWidget {
class _MessageScreenState extends State<MessageScreen> { class _MessageScreenState extends State<MessageScreen> {
TextEditingController _controller; TextEditingController _controller;
ScrollController _scrollController; ScrollController _scrollController;
final messageListController = MessageListController();
@override @override
void initState() { void initState() {
@@ -175,68 +202,83 @@ class _MessageScreenState extends State<MessageScreen> {
final channel = StreamChannel.of(context).channel; final channel = StreamChannel.of(context).channel;
return Scaffold( return Scaffold(
appBar: AppBar( appBar: AppBar(
title: Text(channel.name), title: StreamBuilder<List<User>>(
initialData: channel.state.typingEvents,
stream: channel.state.typingEventsStream,
builder: (context, snapshot) {
if (snapshot.hasData && snapshot.data.isNotEmpty) {
return Text('${snapshot.data.first.name} is typing...');
}
return SizedBox();
},
),
), ),
body: SafeArea( body: SafeArea(
child: Column( child: Column(
children: [ children: [
Expanded( Expanded(
child: MessageListCore( child: LazyLoadScrollView(
emptyBuilder: (BuildContext context) { onEndOfPage: () async {
return Center( messageListController.paginateData();
child: Text('Nothing here yet'),
);
},
loadingBuilder: (BuildContext context) {
return Center(
child: SizedBox(
height: 100.0,
width: 100.0,
child: CircularProgressIndicator(),
),
);
},
messageListBuilder: (
BuildContext context,
List<Message> messages,
) {
return ListView.builder(
controller: _scrollController,
itemCount: messages.length,
reverse: true,
itemBuilder: (BuildContext context, int index) {
final item = messages[index];
final client = StreamChatCore.of(context).client;
if (item.user.id == client.uid) {
return Align(
alignment: Alignment.centerRight,
child: Padding(
padding: const EdgeInsets.all(8.0),
child: Text(item.text),
),
);
} else {
return Align(
alignment: Alignment.centerLeft,
child: Padding(
padding: const EdgeInsets.all(8.0),
child: Text(item.text),
),
);
}
},
);
},
errorWidgetBuilder: (BuildContext context, error) {
print(error?.toString());
return Center(
child: SizedBox(
height: 100.0,
width: 100.0,
child: Text('Oh no, an error occured. Please see logs.'),
),
);
}, },
child: MessageListCore(
emptyBuilder: (BuildContext context) {
return Center(
child: Text('Nothing here yet'),
);
},
loadingBuilder: (BuildContext context) {
return Center(
child: SizedBox(
height: 100.0,
width: 100.0,
child: CircularProgressIndicator(),
),
);
},
messageListBuilder: (
BuildContext context,
List<Message> messages,
) {
return ListView.builder(
controller: _scrollController,
itemCount: messages.length,
reverse: true,
itemBuilder: (BuildContext context, int index) {
final item = messages[index];
final client = StreamChatCore.of(context).client;
if (item.user.id == client.uid) {
return Align(
alignment: Alignment.centerRight,
child: Padding(
padding: const EdgeInsets.all(8.0),
child: Text(item.text),
),
);
} else {
return Align(
alignment: Alignment.centerLeft,
child: Padding(
padding: const EdgeInsets.all(8.0),
child: Text(item.text),
),
);
}
},
);
},
errorWidgetBuilder: (BuildContext context, error) {
print(error?.toString());
return Center(
child: SizedBox(
height: 100.0,
width: 100.0,
child:
Text('Oh no, an error occured. Please see logs.'),
),
);
},
),
), ),
), ),
Padding( Padding(
@@ -64,7 +64,10 @@ class ChannelListCore extends StatefulWidget {
this.filter, this.filter,
this.options, this.options,
this.sort, this.sort,
this.pagination, this.pagination = const PaginationParams(
offset: 0,
limit: 25,
),
this.channelListController, this.channelListController,
}) : assert(errorBuilder != null), }) : assert(errorBuilder != null),
assert(emptyBuilder != null), assert(emptyBuilder != null),