moxxmpp/example/lib/main.dart

import 'package:flutter/material.dart';
import 'package:logging/logging.dart';
import 'package:moxdns/moxdns.dart';
import 'package:moxxmpp/moxxmpp.dart';
import 'package:moxxmpp_socket_tcp/moxxmpp_socket_tcp.dart';

class ExampleTcpSocketWrapper extends TCPSocketWrapper {
  ExampleTcpSocketWrapper() : super(false);

  @override
  Future<List<MoxSrvRecord>> srvQuery(String domain, bool dnssec) async {
    final records = await MoxdnsPlugin.srvQuery(domain, false);
    return records
      .map((record) => MoxSrvRecord(
        record.priority,
        record.weight,
        record.target,
        record.port,
      ),)
      .toList();
  }
}

void main() {
  Logger.root.level = Level.ALL;
  Logger.root.onRecord.listen((record) {
    print('${record.level.name}: ${record.time}: ${record.message}');
  });

  runApp(const MyApp());
}

class MyApp extends StatelessWidget {
  const MyApp({super.key});

  // This widget is the root of your application.
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Moxxmpp Demo',
      theme: ThemeData(primarySwatch: Colors.blue),
      home: const MyHomePage(title: 'Moxxmpp Demo Home Page'),
    );
  }
}

class MyHomePage extends StatefulWidget {
  const MyHomePage({super.key, required this.title});

  final String title;

  @override
  State<MyHomePage> createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  final XmppConnection connection = XmppConnection(
    RandomBackoffReconnectionPolicy(1, 60),
    AlwaysConnectedConnectivityManager(),
    //ExampleTcpSocketWrapper(), // this causes the app to crash
    TCPSocketWrapper(true), // Note: you probably want this to be false in a real app
  );
  TextEditingController jidController = TextEditingController();
  TextEditingController passwordController = TextEditingController();
  bool connected = false;
  bool loading = false;

  _MyHomePageState() : super() {
    connection
      ..registerManagers([
        StreamManagementManager(),
        DiscoManager([]),
        RosterManager(TestingRosterStateManager("", [])),
        PingManager(),
        MessageManager(),
        PresenceManager(),
      ])
      ..registerFeatureNegotiators([
        ResourceBindingNegotiator(),
        StartTlsNegotiator(),
        StreamManagementNegotiator(),
        CSINegotiator(),
        RosterFeatureNegotiator(),
        SaslPlainNegotiator(),
        SaslScramNegotiator(10, '', '', ScramHashType.sha512),
        SaslScramNegotiator(9, '', '', ScramHashType.sha256),
        SaslScramNegotiator(8, '', '', ScramHashType.sha1),
      ]);
  }

  Future<void> _buttonPressed() async {
    if (connected) {
      await connection.disconnect();
      setState(() {connected = false;});
      return;
    }
    setState(() {loading = true;});
    connection.setConnectionSettings(
      ConnectionSettings(
        jid: JID.fromString(jidController.text),
        password: passwordController.text,
        useDirectTLS: true,
        allowPlainAuth: true,
          // otherwise, connecting to some servers will
          // cause an app to hang
      ),
    );
    final result = await connection.connectAwaitable();
    setState(() {connected = result.success; loading = false;});
    if (result.error != null) {
      print(result.error);
      if (context.mounted) {
        showDialog(context: context, builder: (_) => AlertDialog(
          title: const Text('Error'),
          content: Text(result.error.toString()),
        ));
      }
    }
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text(widget.title),
        backgroundColor: connected ? Colors.green : Colors.deepPurple[800],
        foregroundColor: connected ? Colors.black : Colors.white,
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            TextField(
              enabled: !loading,
              controller: jidController,
              decoration: InputDecoration(
                labelText: 'JID',
              ),
            ),
            TextField(
              enabled: !loading,
              controller: passwordController,
              decoration: InputDecoration(
                labelText: 'Password',
              ),
              obscureText: true,
            ),
          ],
        ),
      ),
      floatingActionButton: FloatingActionButton.extended(
        onPressed: _buttonPressed,
        label: Text(connected ? 'Disconnect' : 'Connect'),
        backgroundColor: Colors.blue,
        foregroundColor: Colors.white,
        tooltip: 'Connect',
        icon: const Icon(Icons.power),
      ),
    );
  }
}