@@ -11,10 +11,10 @@ import 'package:sm_websocket/sm_websocket.dart';
1111import 'package:string_to_hex/string_to_hex.dart' ;
1212
1313class ChatController {
14- Future <List <Message >> getMessages ({String sender}) async {
14+ Future <List <Message >> getMessages ({String sender}) async {
1515 CoreUser connectedUser = await UsersRepository .getConnectedUser ();
1616 final response = await post (
17- Uri .http (baseURL,"api/chat/getMessages/" ),
17+ Uri .https (baseURL, "api/chat/getMessages/" ),
1818 headers: < String , String > {
1919 'Content-Type' : 'application/json; charset=UTF-8' ,
2020 },
@@ -23,27 +23,26 @@ class ChatController {
2323 "receiver" : connectedUser.id,
2424 }),
2525 );
26- if (response.statusCode== 200 ){
26+ if (response.statusCode == 200 ) {
2727 var body = json.decode (response.body);
2828 List <Message > messages = [];
2929
30- for (var obj in body){
31- Message message = Message .fromJson (obj,connectedUser.id);
30+ for (var obj in body) {
31+ Message message = Message .fromJson (obj, connectedUser.id);
3232 messages.add (message);
3333 }
3434
3535 return messages;
36- }else {
36+ } else {
3737 throw Exception ('Request API Failed' );
3838 }
39-
4039 }
4140
42- Future <String > addMessageToDataBase ({Message message}) async {
41+ Future <String > addMessageToDataBase ({Message message}) async {
4342 CoreUser connectedUser = await UsersRepository .getConnectedUser ();
4443
4544 final response = await post (
46- Uri .http (baseURL,"api/chat/addMessage/" ),
45+ Uri .https (baseURL, "api/chat/addMessage/" ),
4746 headers: < String , String > {
4847 'Content-Type' : 'application/json; charset=UTF-8' ,
4948 },
@@ -54,19 +53,19 @@ class ChatController {
5453 "message" : message.message,
5554 }),
5655 );
57- if (response.statusCode== 200 ){
56+ if (response.statusCode == 200 ) {
5857 var body = json.decode (response.body);
5958 String message = body["message" ] as String ;
6059
6160 return message;
62- }else {
61+ } else {
6362 throw Exception ('Request API Failed' );
6463 }
6564 }
6665
67- Future <String > generateDiscussionId ({String sender,String receiver}) async {
66+ Future <String > generateDiscussionId ({String sender, String receiver}) async {
6867 final response = await post (
69- Uri .http (baseURL,"api/chat/generateDiscussionId/" ),
68+ Uri .https (baseURL, "api/chat/generateDiscussionId/" ),
7069 headers: < String , String > {
7170 'Content-Type' : 'application/json; charset=UTF-8' ,
7271 },
@@ -76,73 +75,70 @@ class ChatController {
7675 }),
7776 );
7877
79- if (response.statusCode== 200 ){
78+ if (response.statusCode == 200 ) {
8079 var body = json.decode (response.body);
8180 String discussionId = body["discussionId" ] as String ;
8281
8382 return discussionId;
84- }else {
83+ } else {
8584 throw Exception ('Request API Failed' );
8685 }
8786 }
8887
89-
90- void sendMessageToWebSocket ({Message message,WebSocket webSocket}) async {
88+ void sendMessageToWebSocket ({Message message, WebSocket webSocket}) async {
9189 CoreUser connectedUser = await UsersRepository .getConnectedUser ();
9290
93- String discussionId = await this .generateDiscussionId (sender: connectedUser.id,receiver: message.receiver);
94- message.discussionId= discussionId;
91+ String discussionId = await this .generateDiscussionId (
92+ sender: connectedUser.id, receiver: message.receiver);
93+ message.discussionId = discussionId;
9594
9695 webSocket.send (
97- jsonEncode (message.toJson ())
98- ); //parse message to JSON then to String
96+ jsonEncode (message.toJson ())); //parse message to JSON then to String
9997 }
10098
101- Future <List <Conversations >> getConversations () async {
99+ Future <List <Conversations >> getConversations () async {
102100 CoreUser connectedUser = await UsersRepository .getConnectedUser ();
103101
104102 final response = await post (
105- Uri .http (baseURL,"api/chat/getConversations/" ),
103+ Uri .https (baseURL, "api/chat/getConversations/" ),
106104 headers: < String , String > {
107105 'Content-Type' : 'application/json; charset=UTF-8' ,
108106 },
109- body: jsonEncode (< String , String > {
110- "sender" : connectedUser.id
111- }),
107+ body: jsonEncode (< String , String > {"sender" : connectedUser.id}),
112108 );
113- if (response.statusCode== 200 ){
109+ if (response.statusCode == 200 ) {
114110 var body = json.decode (response.body);
115111 List <Conversations > conversations = [];
116112
117-
118113 body.forEach ((key, value) {
119-
120114 List <PopulatedMessage > messages = [];
121- for (var message in value){
122- PopulatedMessage populatedMessage = PopulatedMessage .fromJson (message, connectedUser.id);
115+ for (var message in value) {
116+ PopulatedMessage populatedMessage =
117+ PopulatedMessage .fromJson (message, connectedUser.id);
123118 messages.add (populatedMessage);
124119 }
125- messages.sort ((m1,m2) {
120+ messages.sort ((m1, m2) {
126121 return m1.createdAt.compareTo (m2.createdAt);
127122 });
128- Conversations conversation = Conversations .fromJson (messages, key, connectedUser);
123+ Conversations conversation =
124+ Conversations .fromJson (messages, key, connectedUser);
129125 conversations.add (conversation);
130126 });
131127
132128 return conversations;
133- }else {
129+ } else {
134130 throw Exception ('Request API Failed' );
135131 }
136132 }
137133
138- int getUnseenMessages (List <PopulatedMessage > messages,CoreUser connectedUser){
139- int count= 0 ;
140- for (var message in messages){
141- if (message.seen== "false" && (message.sender.id!= connectedUser.id)){
134+ int getUnseenMessages (
135+ List <PopulatedMessage > messages, CoreUser connectedUser) {
136+ int count = 0 ;
137+ for (var message in messages) {
138+ if (message.seen == "false" && (message.sender.id != connectedUser.id)) {
142139 count++ ;
143140 }
144141 }
145142 return count;
146-
147143 }
148144}
0 commit comments