import { isObservable } from "rxjs";
import { pluck } from "rxjs/operators";
import VueRx from "vue-rx";

const defaultNext = (label) => (result) => {
    if (label) {
        console.log(`[${label}] next`, result);
    }
};

const defaultErr = (label) => (err) => {
    if (label) {
        console.warn(`[${label}] error`, err);
    }
};

const defaultComplete = (label) => () => {
    if (label) {
        console.log(`[${label}] complete`);
    }
};

export const vueRxShortcuts = {
    methods: {
        /**
         * Watch any property, adds debugging tag and assumes you want newValue,
         * this is usually what we want and shorter than typing it every time
         *
         * @param {string} propName Member to watch
         * @param {boolean} immediate Check right now?
         * @returns Observable of new value
         */
        watch$(propName, immediate = true) {
            const opts = { immediate };
            // prettier-ignore
            return this.$watchAsObservable(propName, opts).pipe(
                pluck("newValue")
            );
        },

        /**
         * Generic subscriber to an observable. Subscribes using provided
         * handler or default and disposes of subscription when component is destroyed.
         *
         * @param   {Observable}  obs$  Observable to subscribe to
         * @param   {Object | Function}  cfg   Configuration or next handler
         *
         * @return  {Subscription}
         */
        listenTo(obs$, cfg = {}) {
            const config = cfg instanceof Function ? { next: cfg } : cfg;
            const {
                label = null,
                next = defaultNext(label),
                error = defaultErr(label),
                complete = defaultComplete(label),
            } = config;

            if (!isObservable(obs$)) {
                console.warn("Object provided to listenTo was not an observable");
                return;
            }

            this.$subscribeTo(obs$, next, error, complete);
        },
    },
};

export const vueRxShortcutPlugin = {
    install(Vue) {
        Vue.use(VueRx);
        Vue.mixin(vueRxShortcuts);
    },
};