106 lines
2.8 KiB
Dart
106 lines
2.8 KiB
Dart
import 'dart:convert';
|
|
|
|
import 'package:stream_chatter/data/stream_api_repository.dart';
|
|
import 'package:stream_chatter/domain/models/chat_user.dart';
|
|
import 'package:stream_chat_flutter/stream_chat_flutter.dart';
|
|
import 'package:http/http.dart' as http;
|
|
|
|
class StreamApiImpl extends StreamApiRepository {
|
|
StreamApiImpl(this._client);
|
|
|
|
final StreamChatClient _client;
|
|
|
|
@override
|
|
Future<ChatUser> connectUser(ChatUser user, String token) async {
|
|
Map<String, dynamic> extraData = {};
|
|
if (user.image != null) {
|
|
extraData['image'] = user.image;
|
|
}
|
|
if (user.name != null) {
|
|
extraData['name'] = user.name;
|
|
}
|
|
await _client.disconnectUser();
|
|
await _client.connectUser(
|
|
User(id: user.id!, extraData: extraData as Map<String, Object>),
|
|
token,
|
|
);
|
|
return user;
|
|
}
|
|
|
|
@override
|
|
Future<List<ChatUser>> getChatUsers() async {
|
|
final result = await _client.queryUsers();
|
|
final chatUsers = result.users
|
|
.where((element) => element.id != _client.state.currentUser!.id)
|
|
.map(
|
|
(e) => ChatUser(
|
|
id: e.id,
|
|
name: e.name,
|
|
image: e.extraData['image'] as String?,
|
|
),
|
|
)
|
|
.toList();
|
|
return chatUsers;
|
|
}
|
|
|
|
@override
|
|
Future<String> getToken(String userId) async {
|
|
//TODO: use your own implementation in Production
|
|
final response = await http.post(
|
|
Uri.parse('your_backend_url'),
|
|
body: jsonEncode(<String, String>{'id': userId}),
|
|
headers: <String, String>{
|
|
'Content-Type': 'application/json; charset=UTF-8',
|
|
},
|
|
);
|
|
final token = jsonDecode(response.body)['token'];
|
|
|
|
//In Development mode you can just use :
|
|
// _client.devToken(userId);
|
|
|
|
return token;
|
|
}
|
|
|
|
@override
|
|
Future<Channel> createGroupChat(
|
|
String id, String? name, List<String?>? members,
|
|
{String? image}) async {
|
|
final channel = _client.channel('messaging', id: id, extraData: {
|
|
'name': name!,
|
|
'image': image!,
|
|
'members': [_client.state.currentUser!.id, ...members!],
|
|
});
|
|
await channel.watch();
|
|
return channel;
|
|
}
|
|
|
|
@override
|
|
Future<Channel> createSimpleChat(String? friendId) async {
|
|
final channel = _client.channel('messaging',
|
|
id: '${_client.state.currentUser!.id.hashCode}${friendId.hashCode}',
|
|
extraData: {
|
|
'members': [
|
|
friendId,
|
|
_client.state.currentUser!.id,
|
|
],
|
|
});
|
|
await channel.watch();
|
|
return channel;
|
|
}
|
|
|
|
@override
|
|
Future<void> logout() async {
|
|
return _client.disconnectUser();
|
|
}
|
|
|
|
@override
|
|
Future<bool> connectIfExist(String userId) async {
|
|
final token = await getToken(userId);
|
|
await _client.connectUser(
|
|
User(id: userId),
|
|
token,
|
|
);
|
|
return _client.state.currentUser!.name != userId;
|
|
}
|
|
}
|