123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260
import { id } from "../tools/typeSafety/id.ts";import { assert } from "../tools/typeSafety/assert.ts";import { typeGuard } from "../tools/typeSafety/typeGuard.ts";import { mergeImpl } from "./Evt.merge.ts";import { importProxy } from "./importProxy.ts";
import * as _1 from "./types/EventTargetLike.ts";
namespace dom {
    export type HTMLElementEventMap = import("./types/lib.dom.ts").HTMLElementEventMap;    export type WindowEventMap = import("./types/lib.dom.ts").WindowEventMap;    export type DocumentEventMap = import("./types/lib.dom.ts").DocumentEventMap;
}
type Evt<T>= import("./types/interfaces/Evt.ts").Evt<T>;type EvtLike<T> = import("./types/helper/UnpackEvt.ts").EvtLike<T>;
type OneOrMany<T> = T | ArrayLike<T>;type CtxLike<Result> = import("./types/interfaces/index.ts").CtxLike<Result> & {      evtDoneOrAborted: EvtLike<unknown> & { postCount: number; attachOnce(callback: ()=> void): void; };};
function fromImpl<T>(    ctx: CtxLike<any> | undefined,    target: OneOrMany<_1.EventTargetLike<T>> | PromiseLike<T>,    eventName?: string,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<T> {
    const matchEventTargetLike =        (target_: typeof target): target_ is _1.EventTargetLike<T> =>            _1.z_2.canBe(target_);
    if (!matchEventTargetLike(target)) {
        if ("then" in target) {
            const evt = new importProxy.Evt<T>();
            const isCtxDone = (() => {
                const getEvtDonePostCount = () => ctx?.evtDoneOrAborted.postCount;
                const n = getEvtDonePostCount();
                return () => n !== getEvtDonePostCount();
            })();
            target.then(data => {
                if (isCtxDone()) {                    return;                }
                evt.post(data);
            });
            return evt;
        }
        return mergeImpl<Evt<T>>(            ctx,            Array.from(target).map(                target => fromImpl<T>(ctx, target, eventName, options)            )        );
    }
    type ProxyMethod<T> = (        listener: (data: T) => void,        eventName: string,        options?: _1.EventTargetLike.HasEventTargetAddRemove.Options    ) => void;
    let proxy: {        on: ProxyMethod<T>;        off: ProxyMethod<T>;    };
    if (_1.z_2.NodeStyleEventEmitter_match(target)) {        proxy = {            "on": (listener, eventName) => target.addListener(eventName, listener),            "off": (listener, eventName) => target.removeListener(eventName, listener)        };    } else if (_1.z_2.JQueryStyleEventEmitter_match(target)) {        proxy = {            "on": (listener, eventName) => target.on(eventName, listener),            "off": (listener, eventName) => target.off(eventName, listener)        };    } else if (_1.z_2.HasEventTargetAddRemove_match(target)) {        proxy = {            "on": (listener, eventName, options) => target.addEventListener(eventName, listener, options),            "off": (listener, eventName, options) => target.removeEventListener(eventName, listener, options)        };    } else if (_1.z_2.RxJSSubject_match(target)) {
        let subscription: _1.EventTargetLike.RxJSSubject.Subscription;
        proxy = {            "on": listener => subscription = target.subscribe(data => listener(data)),            "off": () => subscription.unsubscribe()        };
    } else {
        id<never>(target);        assert(false);
    }
    const evt = new importProxy.Evt<T>();
    const listener = (data: T) => evt.post(data);
    ctx?.evtDoneOrAborted.attachOnce(        () => proxy.off(            listener,            eventName!,            options        )    );
    proxy.on(listener, eventName!, options);
    return evt;
}

/** https://docs.evt.land/api/evt/from */export function from<K extends keyof dom.HTMLElementEventMap>(    ctx: CtxLike<any>,    target: _1.EventTargetLike.HTMLElement,    eventName: K,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<dom.HTMLElementEventMap[K]>;
export function from<K extends keyof dom.WindowEventMap>(    ctx: CtxLike<any>,    target: _1.EventTargetLike.Window,    eventName: K,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<dom.WindowEventMap[K]>;
export function from<K extends keyof dom.DocumentEventMap>(    ctx: CtxLike<any>,    target: _1.EventTargetLike.Document,    eventName: K,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<dom.DocumentEventMap[K]>;
export function from<T>(    ctx: CtxLike<any>,    target: OneOrMany<        _1.EventTargetLike.NodeStyleEventEmitter |        _1.EventTargetLike.JQueryStyleEventEmitter    >,    eventName: string): Evt<T>;export function from<T>(    ctx: CtxLike<any>,    target: OneOrMany<        _1.EventTargetLike.HasEventTargetAddRemove<T>    >,    eventName: string,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<T>;export function from<T>(    ctx: CtxLike<any>,    target: OneOrMany<_1.EventTargetLike.RxJSSubject<T>>): Evt<T>;
export function from<T>(    ctx: CtxLike<any>,    target: PromiseLike<T>): Evt<T>;

export function from<K extends keyof dom.HTMLElementEventMap>(    target: _1.EventTargetLike.HTMLElement,    eventName: K,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<dom.HTMLElementEventMap[K]>;export function from<K extends keyof dom.WindowEventMap>(    target: _1.EventTargetLike.Window,    eventName: K,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<dom.WindowEventMap[K]>;export function from<K extends keyof dom.DocumentEventMap>(    target: _1.EventTargetLike.Document,    eventName: K,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<dom.DocumentEventMap[K]>;export function from<T>(    target: OneOrMany<        _1.EventTargetLike.NodeStyleEventEmitter |        _1.EventTargetLike.JQueryStyleEventEmitter    >,    eventName: string): Evt<T>;export function from<T>(    target: OneOrMany<        _1.EventTargetLike.HasEventTargetAddRemove<T>    >,    eventName: string,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<T>;export function from<T>(    target: OneOrMany<_1.EventTargetLike.RxJSSubject<T>>): Evt<T>;export function from<T>(    target: PromiseLike<T>): Evt<T>;
export function from<T>(    ctxOrTarget: CtxLike<any> | OneOrMany<_1.EventTargetLike<T>> | PromiseLike<T>,    targetOrEventName?: OneOrMany<_1.EventTargetLike<T>> | string | PromiseLike<T>,    eventNameOrOptions?: string | _1.EventTargetLike.HasEventTargetAddRemove.Options,    options?: _1.EventTargetLike.HasEventTargetAddRemove.Options): Evt<T> {
    if ("evtDoneOrAborted" in ctxOrTarget) {
        assert(            typeGuard<OneOrMany<_1.EventTargetLike<T>> | PromiseLike<T>>(targetOrEventName) &&            typeGuard<string | undefined>(eventNameOrOptions) &&            typeGuard<_1.EventTargetLike.HasEventTargetAddRemove.Options | undefined>(options)        );
        return fromImpl(            ctxOrTarget,            targetOrEventName,            eventNameOrOptions,            options        );
    } else {
        assert(            typeGuard<string | undefined>(targetOrEventName) &&            typeGuard<_1.EventTargetLike.HasEventTargetAddRemove.Options | undefined>(eventNameOrOptions)        );
        return fromImpl(            undefined,            ctxOrTarget,            targetOrEventName,            eventNameOrOptions        );
    }
}