from itertools import groupby
import os

import h5py
import numpy as np


def get_state_embeddings(data_dict, dirname):
    region_names = data_dict['region_names']
    region_weights = data_dict['region_weights']

    squeezed = region_weights.ndim == 1
    if squeezed:
        region_weights = region_weights[:, np.newaxis]

    n_subsets = region_weights.shape[1]
    state_names = sorted({r[:2] for r in region_names})
    state_lookup = {n: i for i, n in enumerate(state_names)}

    transform = np.zeros(
        (len(state_names), len(region_names), n_subsets))
    for r_i, (r, w) in enumerate(zip(region_names, region_weights)):
        transform[state_lookup[r[:2]], r_i, :] = w

    state_weights = transform.sum(axis=1)
    transform /= state_weights[:, np.newaxis, :]

    ret = {'state_names': state_names, 'state_weights': state_weights}
    for k in ['bandwidth', 'freqs', 'feature_names', 'subset_queries']:
        if k in data_dict:
            ret[k] = data_dict[k]
    for k in data_dict:
        if k.startswith('emb_'):
            v = data_dict[k]
            if squeezed:
                v = v[:, :, np.newaxis]
            ret[k] = np.einsum('grs, rfs -> gfs', transform, v)
            if squeezed:
                ret[k] = ret[k][:, :, 0]
    return ret

import numpy as np


def get_state_embeddings(data_dict, dirname):
    region_names = data_dict['region_names']
    region_weights = data_dict['region_weights']

    squeezed = region_weights.ndim == 1
    if squeezed:
        region_weights = region_weights[:, np.newaxis]

    n_subsets = region_weights.shape[1]
    state_names = sorted({r[:2] for r in region_names})
    state_lookup = {n: i for i, n in enumerate(state_names)}

    transform = np.zeros(
        (len(state_names), len(region_names), n_subsets))
    for r_i, (r, w) in enumerate(zip(region_names, region_weights)):
        transform[state_lookup[r[:2]], r_i, :] = w

    state_weights = transform.sum(axis=1)
    transform /= state_weights[:, np.newaxis, :]

    ret = {'state_names': state_names, 'state_weights': state_weights}
    for k in data_dict:
        if k.startswith('emb_'):
            v = data_dict[k]
            if squeezed:
                v = v[:, :, np.newaxis]
            ret[k] = np.einsum('grs, rfs -> gfs', transform, v)
            if squeezed:
                ret[k] = ret[k][:, :, 0]
        elif k in {'region_names', 'region_weights'}:
            pass
        else:
            ret[k] = data_dict[k]
    return ret

maintain more variables