from typing import Optional, Tuple

import chex
import jax
import jax.numpy as jnp
from flax import struct
from jax import lax

from gymnax.environments import environment, spaces


@struct.dataclass
class EnvState:
    last_action: int
    last_reward: int
    exp_reward_best: float
    reward_probs: chex.Array
    time: float


@struct.dataclass
class EnvParams:
    reward_prob: float = 0.1
    normalize_time: bool = True
    max_steps_in_episode: float = 100.0
    min_lim: float = -1.0
    max_lim: float = 1.0
    t_max: int = 100


class BernoulliBandit(environment.Environment):
    """
    JAX version of a Bernoulli bandit environment as in Wang et al. 2017
    """

    def __init__(self):
        super().__init__()

    @property
    def default_params(self) -> EnvParams:
        # Default environment parameters
        return EnvParams()

    def step_env(
        self, key: chex.PRNGKey, state: EnvState, action: int, params: EnvParams
    ) -> Tuple[chex.Array, EnvState, float, bool, dict]:
        """Sample bernoulli reward, increase counter, construct input."""
        reward = jax.random.bernoulli(key, state.reward_probs[action]).astype(
            jnp.int32
        )
        state = EnvState(
            action,
            reward,
            state.exp_reward_best,
            state.reward_probs,
            state.time + 1,
        )
        done = self.is_terminal(state, params)
        return (
            lax.stop_gradient(self.get_obs(state, params)),
            lax.stop_gradient(state),
            reward,
            done,
            {"discount": self.discount(state, params)},
        )

    def reset_env(
        self, key: chex.PRNGKey, params: EnvParams
    ) -> Tuple[chex.Array, EnvState]:
        """Reset environment state by sampling initial position."""
        # Sample reward function + construct state as concat with timestamp
        p1 = jax.random.choice(
            key,
            jnp.array([params.reward_prob, 1 - params.reward_prob]),
            shape=(1,),
        ).squeeze()

        state = EnvState(
            0,
            0,
            jax.lax.select(p1 > 0.5, p1, 1 - p1),
            jnp.array([p1, 1 - p1]),
            0.0,
        )
        return self.get_obs(state, params), state

    def get_obs(self, state: EnvState, params: EnvParams) -> chex.Array:
        """Concatenate reward, one-hot action and time stamp."""
        action_one_hot = jax.nn.one_hot(state.last_action, 2).squeeze()
        time_rep = jax.lax.select(
            params.normalize_time,
            time_normalization(
                state.time, params.min_lim, params.max_lim, params.t_max
            ),
            state.time,
        )
        return jnp.hstack([state.last_reward, action_one_hot, time_rep])

    def is_terminal(self, state: EnvState, params: EnvParams) -> bool:
        """Check whether state is terminal."""
        # Check number of steps in episode termination condition
        done = state.time >= params.max_steps_in_episode
        return done

    @property
    def name(self) -> str:
        """Environment name."""
        return "BernoulliBandit-misc"

    @property
    def num_actions(self) -> int:
        """Number of actions possible in environment."""
        return 2

    def action_space(
        self, params: Optional[EnvParams] = None
    ) -> spaces.Discrete:
        """Action space of the environment."""
        return spaces.Discrete(self.num_actions)

    def observation_space(self, params: EnvParams) -> spaces.Box:
        """Observation space of the environment."""
        low = jnp.array(
            [
                0,
                0,
                0,
                jax.lax.select(params.normalize_time, params.min_lim, 0.0),
            ],
            dtype=jnp.float32,
        )
        high = jnp.array(
            [
                self.num_actions,
                1,
                1,
                jax.lax.select(
                    params.normalize_time,
                    params.max_lim,
                    params.max_steps_in_episode,
                ),
            ],
            dtype=jnp.float32,
        )
        return spaces.Box(low, high, (4,), jnp.float32)

    def state_space(self, params: EnvParams) -> spaces.Dict:
        """State space of the environment."""
        return spaces.Dict(
            {
                "last_action": spaces.Discrete(self.num_actions),
                "last_reward": spaces.Discrete(2),
                "exp_reward_best": spaces.Box(0, 1, (2,), jnp.float32),
                "reward_probs": spaces.Box(0, 1, (2,), jnp.float32),
                "time": spaces.Discrete(params.max_steps_in_episode),
            }
        )


def time_normalization(
    t: int, min_lim: float = -1.0, max_lim: float = 1.0, t_max: int = 100
) -> float:
    """Normalize time integer into range given max time."""
    return (max_lim - min_lim) * t / t_max + min_lim
