import { LiveProvider } from "@pankod/refine-core";
import { Client } from "graphql-ws";

import {
    generateUseListSubscription,
    generateUseManySubscription,
    generateUseOneSubscription,
} from "../utilities";

const subscriptions = {
    useList: generateUseListSubscription,
    useOne: generateUseOneSubscription,
    useMany: generateUseManySubscription,
};

export const liveProvider = (client: Client): LiveProvider => {
    return {
        subscribe: ({ callback, params }) => {
            const {
                resource,
                metaData,
                pagination,
                hasPagination,
                sort,
                filters,
                subscriptionType,
                id,
                ids,
            } = params ?? {};

            if (!metaData) {
                throw new Error(
                    "[useSubscription]: `metaData` is required in `params` for graphql subscriptions",
                );
            }

            if (!subscriptionType) {
                throw new Error(
                    "[useSubscription]: `subscriptionType` is required in `params` for graphql subscriptions",
                );
            }

            if (!resource) {
                throw new Error(
                    "[useSubscription]: `resource` is required in `params` for graphql subscriptions",
                );
            }

            const genereteSubscription = subscriptions[subscriptionType];

            const { query, variables, operation } = genereteSubscription({
                ids,
                id,
                resource,
                filters,
                hasPagination,
                metaData,
                pagination,
                sort,
            });

            const onNext = (payload: any) => {
                callback(payload.data[operation]);
            };

            const unsubscribe = client.subscribe(
                {
                    query,
                    variables,
                },
                {
                    next: onNext,
                    error: () => null,
                    complete: () => null,
                },
            );

            return unsubscribe;
        },
        unsubscribe: (unsubscribe) => {
            unsubscribe();
        },
    };
};