import {createApi, fetchBaseQuery} from "@reduxjs/toolkit/query/react";
import type {DeadLetterScrobble, JsonPlayObject} from "../../core/Atomic";
import {createAction, createEntityAdapter, createSlice} from "@reduxjs/toolkit";
import {type ApiEventPayload, clientUpdate} from "../status/ducks";

type DeadResponse = DeadLetterScrobble<JsonPlayObject, string>[];
export const deadApi = createApi({
    reducerPath: 'deadApi',
    baseQuery: fetchBaseQuery({baseUrl: './api/'}),
    tagTypes: ['DeadLetters'],
    endpoints: (builder) => ({
        getDead: builder.query<DeadResponse, { name: string, type: string }>({
            query: (params) => `dead?name=${params.name}&type=${params.type}&sort=seenAt&order=desc`,
            providesTags: ['DeadLetters']
        }),
        processDead: builder.query<DeadResponse, { name: string, type: string }>({
            query: (params) => ({
                url: `dead`,
                method: 'PUT',
                params: {
                    name: params.name,
                    type: params.type
                }
            }),
            providesTags: ['DeadLetters']
        }),
        processDeadSingle: builder.mutation<DeadLetterScrobble<JsonPlayObject, string> | undefined, {
            name: string,
            type: string,
            id: string
        }>({
            query: (params) => ({
                url: `/dead/${params.id}`,
                method: 'PUT',
                params: {
                    name: params.name,
                    type: params.type
                }
            })
        }),
        removeDead: builder.query<DeadResponse, { name: string, type: string }>({
            query: (params) => ({
                url: `dead`,
                method: 'DELETE',
                params: {
                    name: params.name,
                    type: params.type
                }
            }),
            providesTags: ['DeadLetters']
        }),
        removeDeadSingle: builder.mutation<DeadLetterScrobble<JsonPlayObject, string> | undefined, {
            name: string,
            type: string,
            id: string
        }>({
            query: (params) => ({
                url: `/dead/${params.id}`,
                method: 'DELETE',
                params: {
                    name: params.name,
                    type: params.type
                },
                transformResponse: (response, meta, arg) => {
                    if (response === undefined) {
                        return undefined;
                    } else {
                        return response;
                    }
                },
                invalidatesTags: ['DeadLetters']
            }),
        }),
    }),
});

export const deadAdapter = createEntityAdapter<DeadLetterScrobble<JsonPlayObject, string>>({
    selectId: (data) => data.id
});

export const deadSlice = createSlice({
    name: 'deadLetter',
    initialState: deadAdapter.getInitialState(),
    reducers: {
        deadUpdated: deadAdapter.updateOne,
    },
    extraReducers: (builder) => {
        builder.addMatcher(
            (action) => deadApi.endpoints.getDead.matchPending(action),
            (state, action) => {
                state = deadAdapter.getInitialState();
            }
        )
        builder.addMatcher(
            (action) => deadApi.endpoints.getDead.matchFulfilled(action),
            (state, action) => {
                deadAdapter.setAll(state, action.payload);
            }
        )
            // .addMatcher(
            //     (action) => deadApi.endpoints.removeDeadSingle.matchFulfilled(action),
            //     (state, action) => {
            //         deadAdapter.removeOne(state, action.meta.arg.originalArgs.id)
            //     }
            // )
            // .addMatcher(
            //     (action) => deadApi.endpoints.processDeadSingle.matchFulfilled(action),
            //     (state, action) => {
            //         if (action.payload === undefined) {
            //             deadAdapter.removeOne(state, action.meta.arg.originalArgs.id);
            //         } else {
            //             state.entities[action.meta.arg.originalArgs.id] = action.payload;
            //             //deadAdapter.updateOne(state, action.meta.arg.originalArgs.id);
            //         }
            //     }
            // )
            .addMatcher(
                (action) => clearDead.match(action),
                (state, action) => {
                    state = deadAdapter.getInitialState();
                }
            )
            .addMatcher(
                (action) => clientUpdate.match(action) && action.payload.event === 'deadLetter',
                (state, action) => {
                    state.entities[(action.payload as ApiEventPayload).data.dead.id] = (action.payload as ApiEventPayload).data.dead;
                    state.ids.push((action.payload as ApiEventPayload).data.dead.id);
                }
            )
            .addMatcher(
                (action) => clientUpdate.match(action) && action.payload.event === 'removeDeadLetter',
                (state, action) => {
                    delete state.entities[(action.payload as ApiEventPayload).data.dead.id];
                    state.ids = state.ids.filter(x => x !== (action.payload as ApiEventPayload).data.dead.id);
                }
            )
            .addMatcher(
                (action) => clientUpdate.match(action) && action.payload.event === 'updateDeadLetter',
                (state, action) => {
                    state.entities[(action.payload as ApiEventPayload).data.dead.id] = (action.payload as ApiEventPayload).data.dead;
                }
            )
    }
});

export const clearDead = createAction('clearDead');

export const {useGetDeadQuery, useProcessDeadSingleMutation, useRemoveDeadSingleMutation, useLazyProcessDeadQuery, useLazyRemoveDeadQuery} = deadApi;