open-TestChatApp-iOS/Chat/Main/XMPPController.swift

//
//  XMPPController.swift
//  Chat (iOS)
//
//  Created by Sergey Tarasov on 12.10.2022.
//

import XMPPFramework
import XMPPFrameworkSwift

final class XMPPController {
	static let shared: XMPPController = XMPPController()

	let xmppStream: XMPPStream
	let xmppReconnect: XMPPReconnect
	let xmppRoster: XMPPRoster
	let xmppRosterStorage: XMPPRosterMemoryStorage

	var xmppAuth: XMPPPlainAuthentication

	private init() {
		self.xmppStream = XMPPStream()

		self.xmppRosterStorage = XMPPRosterMemoryStorage()
		self.xmppRoster = XMPPRoster(rosterStorage: xmppRosterStorage)

		self.xmppReconnect = XMPPReconnect()

		self.xmppReconnect.activate(xmppStream)
		self.xmppRoster.activate(xmppStream)

		self.xmppAuth = XMPPPlainAuthentication()

		self.xmppReconnect.addDelegate(self, delegateQueue: .main)
	}

	func setupStream() {
		self.xmppStream.hostName = "msg.sharix-app.org"
		self.xmppStream.hostPort = 5222
		self.xmppStream.startTLSPolicy = XMPPStreamStartTLSPolicy.allowed
	}

	func login(with login: String, and password: String) {
		self.xmppStream.myJID = XMPPJID(string: login)
		self.xmppAuth = XMPPPlainAuthentication(stream: xmppStream, password: password)
		connect()
	}

	func connect() {
		if self.xmppStream.isDisconnected {
			do {
				try self.xmppStream.authenticate(xmppAuth)
			} catch {

			}
		}
	}
}

extension XMPPController: XMPPReconnectDelegate {
	func xmppReconnect(_ sender: XMPPReconnect, shouldAttemptAutoReconnect connectionFlags: SCNetworkConnectionFlags) -> Bool {
		print("---------- xmppReconnect:shouldAttemptAutoReconnect: ----------")
		return true
	}
}