import { apiFetch } from '../api'
import { setEntities } from '../actions/entities'
import { startRequest, finishRequest } from '../actions/requests'
import { AppThunkAction, Entity, RequestKey, EntityType } from '../types'
import { normalize } from '../utils/normalization'

export const fetchUser = (id: string): AppThunkAction => {
    return async dispatch => {
        dispatch(startRequest(RequestKey.FetchUser))

        try {
            const user = await apiFetch<Entity>({
                path: `/v1/user/${id}`
            })

            const users = normalize([user], EntityType.User)

            dispatch(setEntities(users.entities))
            dispatch(finishRequest(RequestKey.FetchUser, true))
        } catch (err) {
            dispatch(finishRequest(RequestKey.FetchUser, false))
            throw err
        }
    }
}

export const subscribe = (id: string): AppThunkAction => {
    return async dispatch => {
        dispatch(startRequest(RequestKey.Subscribe))

        try {
            await apiFetch<Entity>({
                path: `/v1/user/${id}/subscribe`,
                method: 'post',
            })

            dispatch(finishRequest(RequestKey.Subscribe, true))
        } catch (err) {
            dispatch(finishRequest(RequestKey.Subscribe, false))
            throw err
        }
    }
}

export const unsubscribe = (id: string): AppThunkAction => {
    return async dispatch => {
        dispatch(startRequest(RequestKey.Unsubscribe))

        try {
            await apiFetch<Entity>({
                path: `/v1/user/${id}/unsubscribe`,
                method: 'post',
            })

            dispatch(finishRequest(RequestKey.Unsubscribe, true))
        } catch (err) {
            dispatch(finishRequest(RequestKey.Unsubscribe, false))
            throw err
        }
    }
}