import tensorflow as tf
from tensorflow.keras.layers import (Add, Conv2D, Input, Concatenate, 
                                     TimeDistributed)
from tensorflow.keras.models import Model

from .blocks import (RecurrentConvBlock, ResidualBlock, ConvBlock, 
                     DenseBlock, TransitionBlock, LocalizedConvBlock,
                     get_dropout_layer)
from ..utils import checkarg_backbone, checkarg_dropout_variant


def recnet_pin(
    backbone_block,
    n_channels, 
    n_aux_channels,
    hr_size,
    time_window,
    # ----- below are parameters that shall be tweaked by the user -----
    n_channels_out=1, 
    n_filters=8, 
    n_blocks=6,  
    normalization=None,
    dropout_rate=0,
    dropout_variant=None,
    attention=False,
    activation='relu',
    output_activation=None,
    localcon_layer=False):
    """
    Recurrent deep neural network with different backbone architectures 
    (according to the ``backbone_block``) and pre-upsampling via interpolation
    (the samples are expected to be interpolated to the HR grid). This model is 
    capable of exploiting spatio-temporal samples.

    The interpolation method depends on the ``interpolation`` argument used in
    the training procedure (which is passed to the DataGenerator).

    Parameters
    ----------
    backbone_block : str
        Backbone type. One of dl4ds.BACKBONE_BLOCKS. WARNING: this parameter is
        not supposed to be set by the user. It's set internallly through
        dl4ds.Trainers. 
    n_channels : int
        Number of channels/variables in each sample. WARNING: this parameter is
        not supposed to be set by the user. It's set internallly through
        dl4ds.Trainers. 
    n_aux_channels : int
        Number of auxiliary channels. WARNING: this parameter is not supposed to 
        be set by the user. It's set internallly through dl4ds.Trainers. 
    hr_size : tuple
        Height and width of the HR grid. WARNING: this parameter is not supposed 
        to be set by the user. It's set internallly through dl4ds.Trainers.
    time_window : int
        Temporal window or number of time steps in each sample. WARNING: this 
        parameter is not supposed to be set by the user. It's set internallly 
        through dl4ds.Trainers.
    n_filters : int, optional
        Number of convolutional filters in RecurrentConvBlock. `n_filters` sets 
        the number of output filters in the convolution inside the ConvLSTM unit. 
    n_blocks : int, optional
        Number of recurrent convolutional blocks (RecurrentConvBlock). 
        Sets the depth of the network. 
    normalization : str or None, optional
        Normalization method in the residual or dense block. Can be either 'bn'
        for BatchNormalization or 'ln' for LayerNormalization. If None, then no
        normalization is performed (eg., for the 'resnet' backbone this results 
        in the EDSR-style residual block).
    dropout_rate : float, optional
        Float between 0 and 1. Fraction of the input units to drop. If 0 then no
        dropout is applied. 
    dropout_variant : str or None, optional
        Type of dropout. Defined in dl4ds.DROPOUT_VARIANTS variable. 
    attention : bool, optional
        If True, dl4ds.ChannelAttention2D is used in convolutional blocks. 
    activation : str, optional
        Activation function to use, as supported by tf.keras. E.g., 'relu' or 
        'gelu'.
    output_activation : str, optional
        Activation function to use in the last ConvBlock. Useful to constraint 
        the values distribution of the output grid.
    localcon_layer : bool, optional
        If True, the LocalizedConvBlock is activated in the output module. 
    """
    backbone_block = checkarg_backbone(backbone_block)
    dropout_variant = checkarg_dropout_variant(dropout_variant)

    auxvar_array_is_given = True if n_aux_channels > 0 else False
    h_hr, w_hr = hr_size
    if not localcon_layer: 
        x_in = Input(shape=(None, None, None, n_channels))
    else:
        x_in = Input(shape=(None, h_hr, w_hr, n_channels))
   
    init_n_filters = n_filters

    x = b = RecurrentConvBlock(n_filters, activation=activation, 
                               normalization=normalization)(x_in)

    for i in range(n_blocks):
        b = RecurrentConvBlock(n_filters, activation=activation, 
            normalization=normalization, dropout_rate=dropout_rate,
            dropout_variant=dropout_variant, name_suffix=str(i + 2))(b)

    b = get_dropout_layer(dropout_rate, dropout_variant, dim=3)(b)

    if backbone_block == 'convnet':
        x = b
    elif backbone_block == 'resnet':
        x = Add()([x, b])
    elif backbone_block == 'densenet':
        x = Concatenate()([x, b])

    #---------------------------------------------------------------------------
    # HR aux channels are processed
    if auxvar_array_is_given:
        s_in = Input(shape=(None, None, n_aux_channels))
        s = ConvBlock(n_filters, activation=activation, dropout_rate=0, 
                      normalization=None, attention=attention)(s_in)
        s = tf.expand_dims(s, 1)
        s = tf.repeat(s, time_window, axis=1)
        x = Concatenate()([x, s])

    #---------------------------------------------------------------------------
    # Localized convolutional layer
    if localcon_layer:
        lcb = LocalizedConvBlock(filters=2, use_bias=True)
        lws = TimeDistributed(lcb, name='localized_conv_block')(x)
        x = Concatenate()([x, lws])

    #---------------------------------------------------------------------------
    # Last conv layers
    x = TransitionBlock(init_n_filters, name='TransitionLast')(x)
    x = ConvBlock(init_n_filters, activation=None, dropout_rate=dropout_rate, 
        normalization=normalization, attention=True)(x)  

    x = ConvBlock(n_channels_out, activation=output_activation, dropout_rate=0, 
        normalization=normalization, attention=False)(x) 
    
    model_name = 'rec' + backbone_block + '_pin' 
    if auxvar_array_is_given:
        return Model(inputs=[x_in, s_in], outputs=x, name=model_name)
    else:
        return Model(inputs=[x_in], outputs=x, name=model_name)

tensorflow.keras.layers.Concatenate tensorflow.keras.models.Model tensorflow.keras.layers.TimeDistributed tensorflow.expand_dims tensorflow.repeat tensorflow.keras.layers.Add tensorflow.keras.layers.Input
[(91, 'tensorflow.keras.layers.Input', 'Input', ([], {'shape': '(None, None, None, n_channels)'}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n'), (93, 'tensorflow.keras.layers.Input', 'Input', ([], {'shape': '(None, h_hr, w_hr, n_channels)'}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n'), (117, 'tensorflow.keras.layers.Input', 'Input', ([], {'shape': '(None, None, n_aux_channels)'}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n'), (120, 'tensorflow.expand_dims', 'tf.expand_dims', (['s', '(1)'], {}), True, 'import tensorflow as tf\n'), (121, 'tensorflow.repeat', 'tf.repeat', (['s', 'time_window'], {'axis': '(1)'}), True, 'import tensorflow as tf\n'), (142, 'tensorflow.keras.models.Model', 'Model', ([], {'inputs': '[x_in, s_in]', 'outputs': 'x', 'name': 'model_name'}), False, 'from tensorflow.keras.models import Model\n'), (144, 'tensorflow.keras.models.Model', 'Model', ([], {'inputs': '[x_in]', 'outputs': 'x', 'name': 'model_name'}), False, 'from tensorflow.keras.models import Model\n'), (122, 'tensorflow.keras.layers.Concatenate', 'Concatenate', ([], {}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n'), (128, 'tensorflow.keras.layers.TimeDistributed', 'TimeDistributed', (['lcb'], {'name': '"""localized_conv_block"""'}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n'), (129, 'tensorflow.keras.layers.Concatenate', 'Concatenate', ([], {}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n'), (110, 'tensorflow.keras.layers.Add', 'Add', ([], {}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n'), (112, 'tensorflow.keras.layers.Concatenate', 'Concatenate', ([], {}), False, 'from tensorflow.keras.layers import Add, Conv2D, Input, Concatenate, TimeDistributed\n')]