import Capacitor
import Foundation
import ActivityKit

@available(iOS 16.2, *)
@objc(LiveActivityPlugin)
public class LiveActivityPlugin: CAPPlugin, CAPBridgedPlugin {
    public let identifier = "LiveActivityPlugin"
    public let jsName = "LiveActivity"

    public let pluginMethods: [CAPPluginMethod] = [
        CAPPluginMethod(name: "startActivity", returnType: CAPPluginReturnPromise),
        CAPPluginMethod(name: "updateActivity", returnType: CAPPluginReturnPromise),
        CAPPluginMethod(name: "endActivity", returnType: CAPPluginReturnPromise),
        CAPPluginMethod(name: "isAvailable", returnType: CAPPluginReturnPromise),
        CAPPluginMethod(name: "isRunning", returnType: CAPPluginReturnPromise),
        CAPPluginMethod(name: "getCurrentActivity", returnType: CAPPluginReturnPromise),
	CAPPluginMethod(name: "startObservingPushToStartToken", returnType: CAPPluginReturnPromise),
    ]

    private let implementation = LiveActivity()

    @objc func startActivity(_ call: CAPPluginCall) {
        guard let id = call.getString("id"),
            let attributes = call.getObject("attributes") as? [String: String],
            let contentState = call.getObject("contentState") as? [String: String]
        else {
            call.reject("Missing required parameters")
            return
        }

        Task {
            do {
                try await implementation.start(
                    id: id, attributes: attributes, content: contentState)
                call.resolve()
            } catch {
                call.reject("Failed to start activity: \(error.localizedDescription)")
            }
        }
    }

	@objc func startObservingPushToStartToken(_ call: CAPPluginCall) {
	    Task {
            if #available(iOS 17.2, *) {
                for await data in Activity<GenericAttributes>.pushToStartTokenUpdates {
                    let token = data.map { String(format: "%02x", $0) }.joined()
                    self.notifyListeners("pushToStartToken", data: ["token": token])
                }
            } else {
                // Fallback on earlier versions
            }
	    }
	    call.resolve()
	}

    @objc func updateActivity(_ call: CAPPluginCall) {
        guard let id = call.getString("id"),
            let contentState = call.getObject("contentState") as? [String: String]
        else {
            call.reject("Missing required parameters")
            return
        }

        Task {
            await implementation.update(id: id, content: contentState)
            call.resolve()
        }
    }

    @objc func endActivity(_ call: CAPPluginCall) {
        guard let id = call.getString("id"),
            let contentState = call.getObject("contentState") as? [String: String]
        else {
            call.reject("Missing required parameters")
            return
        }

        let dismissalDate = call.getDouble("dismissalDate").map(NSNumber.init(value:))
        Task {
            await implementation.end(id: id, content: contentState, dismissalDate: dismissalDate)
            call.resolve()
        }
    }

    @objc func isAvailable(_ call: CAPPluginCall) {
        let available = implementation.isAvailable()
        call.resolve(["value": available])
    }

    @objc func isRunning(_ call: CAPPluginCall) {
        guard let id = call.getString("id") else {
            call.reject("Missing activity id")
            return
        }
        let running = implementation.isRunning(id: id)
        call.resolve(["value": running])
    }

    @objc func getCurrentActivity(_ call: CAPPluginCall) {
        let id = call.getString("id")

        let result = implementation.getCurrent(id: id)

        if let result = result {
            call.resolve(result)
        } else {
            call.resolve([:])  // oder call.reject("No active activity found") falls erwünscht
        }
    }
}