Nachrichten eingebaut
This commit is contained in:
1 parent
f72ca72576
commit
94998bdb6d
2 files changed
+7
-3
No files matched your search
@@ -1,3 +1,5 @@
|
|||||||
|
import 'dart:convert';
|
||||||
|
|
||||||
import 'package:flutter/material.dart';
|
import 'package:flutter/material.dart';
|
||||||
import 'package:flutter_chat_ui/flutter_chat_ui.dart';
|
import 'package:flutter_chat_ui/flutter_chat_ui.dart';
|
||||||
import 'package:flutter_chat_types/flutter_chat_types.dart' as types;
|
import 'package:flutter_chat_types/flutter_chat_types.dart' as types;
|
||||||
@@ -105,7 +107,9 @@ class _MessagesPageState extends State<MessagesPage> {
|
|||||||
MyApp.isarInstance.messages.putSync(message);
|
MyApp.isarInstance.messages.putSync(message);
|
||||||
});
|
});
|
||||||
|
|
||||||
MqttCore.instance.publishPayloadMessage('mssg', message.toJson());
|
var json = jsonEncode(message.toJson());
|
||||||
|
|
||||||
|
MqttCore.instance.publishText('/appserver/to_server/100/1/104400/set_location', jsonEncode(message.toJson()));
|
||||||
|
|
||||||
_messages.insert(0, types.TextMessage(
|
_messages.insert(0, types.TextMessage(
|
||||||
author: _user,
|
author: _user,
|
||||||
|
|||||||
@@ -198,7 +198,7 @@ class MqttCore {
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
case "mssg":
|
case "mssg":
|
||||||
//_messageMessageReceived(payloadData);
|
_messageMessageReceived(payload);
|
||||||
break;
|
break;
|
||||||
|
|
||||||
default:
|
default:
|
||||||
@@ -297,7 +297,7 @@ class MqttCore {
|
|||||||
_sendSyncMessage();
|
_sendSyncMessage();
|
||||||
}
|
}
|
||||||
|
|
||||||
void _messageMessageReceived(Map<String, dynamic> payloadData) async {
|
void _messageMessageReceived(payloadData) async {
|
||||||
var newMessage = await Message.mergeFromJson(payloadData);
|
var newMessage = await Message.mergeFromJson(payloadData);
|
||||||
|
|
||||||
await MyApp.isarInstance.writeTxn(() async {
|
await MyApp.isarInstance.writeTxn(() async {
|
||||||
|
|||||||
Reference in new issue
Block a user