run_cue_induction.py

#!/usr/bin/env python
# coding: utf-8

# In[15]:


import numpy as np
from pprint import pprint
import sys, os
import pickle as pkl
from collections import defaultdict
import argparse


from neuron import h
from neuron.units import ms, mV
h.nrnmpi_init()


import time


def get_cell_population_spikes(c,pop_id):
    spike_times_dict = c.get_cell_spikes(pop_id)
    return spike_times_dict

def get_ext_population_spikes(c,pop_id):
    spike_vec_dict = defaultdict(list)
    spike_times_vec = c.external_spike_time_recs[pop_id]
    spike_gids_vec  = c.external_spike_gid_recs[pop_id]
    for spike_t, spike_gid in zip(spike_times_vec, spike_gids_vec):
        spike_gid = int(spike_gid)
        spike_vec_dict[spike_gid].append(spike_t)
    return spike_vec_dict


def get_population_voltages(c,pop_id):
    v_vec_dict = {}
    for cid, cell in c.neurons[pop_id].items():
        v_vec = h.Vector()
        try:
            v_vec.record(cell.axon(0.5)._ref_v)
        except:
            v_vec.record(cell.soma(0.5)._ref_v)
        gid = c.ctype_offsets[pop_id] + cid
        v_vec_dict[gid] = v_vec
    return v_vec_dict

def pull_spike_times(population2info_dict):
    spike_times = {}
    gids = np.sort(list(population2info_dict.keys()))
    for gid in gids:
        gid_info = population2info_dict[gid]
        if 'spike times' in gid_info:
            spike_times[gid] = gid_info['spike times']
    return spike_times


def main():
    parser = argparse.ArgumentParser(
        description="Run CA3 cue cell offline phase."
    )


    parser.add_argument(
        "--circuit-config",
        required=True,
        type=str,
        help="Name of circuit configuration file. ",
    )

    parser.add_argument(
        "--arena-config",
        required=True,
        type=str,
        help="Name of arena configuration file. ",
    )

    parser.add_argument(
        "--model-home",
        required=True,
        type=str,
        help="Path to model home directory. ",
    )

    parser.add_argument(
        "--saved-weights-path",
        required=True,
        type=str,
        help="Path to saved weights file. ",
    )

    parser.add_argument(
        "-c", "--config-id",
        required=True,
        type=str,
        help="Configuration identifier. ",
    )

    model_home = args.model_home
    sys.path.append(os.path.join(model_home, 'utils'))
    sys.path.append(os.path.join(model_home, 'cells'))

    circuit_config_file = args.circuit_config
    arena_config_file = args.arena_config
    config_id = args.config_id
    saved_weights_path = args.saved_weights_path
    
    from SetupConnections import WiringDiagram, Arena
    from NeuronCircuit import Circuit, save_v_vecs, save_netcon_data, save_spike_vecs, restore_netcons
    from simtime import SimTimeEvent

    print('constructing model..')
    sys.stdout.flush()

    delay = 500.
    dt = 0.1
    
    
    params_path = os.path.join(model_home, 'params')
    arena_config_path = os.path.join(params_path, arena_config_file)
    circuit_config_path = os.path.join(params_path, circuit_config_file)

    ar = Arena(os.path.join(params_path, arena_config_path))
    ar.generate_population_firing_rates()
    

    arena_size = ar.params['Arena']['arena size']
    bin_size   = ar.params['Arena']['bin size']
    mouse_speed = ar.params['Arena']['mouse speed']
    nlaps       = ar.params['Arena']['lap information']['nlaps']
    
    time_for_single_lap = arena_size / mouse_speed * 1000.

    place_information = {'place ids': [0], 'place fracs': [0.80]}
    
    diagram = WiringDiagram(circuit_config_path, place_information)

    place_ids = diagram.place_information[0]['place']
    cue_ids = diagram.place_information[0]['not place']

    internal_kwargs = {}
    internal_kwargs['place information'] = diagram.place_information
    internal_kwargs['cue information'] = diagram.place_information
    
    diagram.generate_internal_connectivity(**internal_kwargs)
    
    external_kwargs = {}
    external_kwargs['place information'] = diagram.place_information
    external_kwargs['external place ids'] = [100, 101, 102]
    external_kwargs['cue information'] = diagram.place_information
    external_kwargs['external cue ids'] = [100, 101, 102]
    
    diagram.generate_external_connectivity(ar.cell_information, **external_kwargs)
    diagram.generate_septal_connectivity()
    
    
    print('generating spike times..')
    sys.stdout.flush()
    ar.generate_spike_times('MF', dt=dt, delay=delay)
    ar.generate_spike_times('MEC', dt=dt, delay=delay)
    ar.generate_spike_times('LEC', dt=dt, delay=delay, cued=False)
    ar.generate_spike_times('Background', dt=dt, delay=delay)
    print('generated spike times..')
    sys.stdout.flush()


    mf_spike_times  = pull_spike_times(ar.cell_information['MF']['cell info'])
    mec_spike_times = pull_spike_times(ar.cell_information['MEC']['cell info'])
    lec_spike_times = pull_spike_times(ar.cell_information['LEC']['cell info'])
    bk_spike_times  = pull_spike_times(ar.cell_information['Background']['cell info'])

    
    print('constructing circuit..')
    sys.stdout.flush()
    
    circuit = Circuit(params_prefix=params_path, 
                      params_filename='circuitparams_ripple.yaml',
                      arena_params_filename='arenaparams_ripple_inh_stdp.yaml', 
                      internal_pop2id=diagram.pop2id, 
                      external_pop2id=diagram.external_pop2id, 
                      external_spike_times = {100: mf_spike_times,
                                              101: mec_spike_times,
                                              102: lec_spike_times,
                                              103: bk_spike_times})
    print('building cells..')
    sys.stdout.flush()
    circuit.build_cells()

    #circuit.build_internal_netcons(diagram.internal_adj_matrices, diagram.internal_ws)
    #circuit.build_external_netcons(100, diagram.external_adj_matrices[100], diagram.external_ws[100])
    #circuit.build_external_netcons(101, diagram.external_adj_matrices[101], diagram.external_ws[101])
    #circuit.build_external_netcons(102, diagram.external_adj_matrices[102], diagram.external_ws[102])
    #circuit.build_external_netcons(103, diagram.external_adj_matrices[103], diagram.external_ws[103])
    #circuit.record_lfp([0,1])
    #circuit.build_septal_netcons(diagram.septal_adj_matrices)
    
    pc = circuit.pc
    
    restore_netcons(pc, circuit, saved_weights_path)

    
    
    
    exc_v_vecs     = get_population_voltages(circuit, 0)
    pvbc_v_vecs    = get_population_voltages(circuit, 1)
    # aac_v_vecs   = get_population_voltages(2)
    # bis_v_vecs   = get_population_voltages(3)
    # olm_v_vecs   = get_population_voltages(4)
    # isccr_v_vecs = get_population_voltages(5)
    # iscck_v_vecs = get_population_voltages(6)
    
    
    t_vec = h.Vector()  # Time stamp vector
    t_vec.record(h._ref_t)
    
    tic = time.time()
    
    h.dt = 0.025
    h.celsius = 37.
    h.tstop =  time_for_single_lap * nlaps + 500

    if pc.id() == 0:
        print(f'starting simulation for {nlaps} lap(s) until {h.tstop} ms..')
        sys.stdout.flush()
    
    simtime = SimTimeEvent(pc, h.tstop, 8.0, 10, 0)
        
    pc.set_maxstep(10 * ms)
    
    t = h.Vector().record(h._ref_t)
    h.finitialize(-65 * mV)
    pc.psolve(h.tstop * ms)
    
    elapsed = time.time() - tic
    pc.barrier()
    
    if pc.id() == 0:
        print('simulation took %0.3f seconds' % elapsed)

    ext_spikes_MF   = get_ext_population_spikes(circuit, 100)
    ext_spikes_MEC  = get_ext_population_spikes(circuit, 101)
    ext_spikes_LEC  = get_ext_population_spikes(circuit, 102)
    ext_spikes_Bk   = get_ext_population_spikes(circuit, 103)
    
    save_spike_vecs(pc, f"data/ext_spikes_1011-ripple-nlaps-{nlaps}",
                    ext_spikes_MF,
                    ext_spikes_MEC,
                    ext_spikes_LEC,
                    ext_spikes_Bk)
    
    cell_spikes_PC    = get_cell_population_spikes(circuit,0)
    cell_spikes_PVBC  = get_cell_population_spikes(circuit,1)
    
    save_spike_vecs(pc, f"data/cell_spikes_1011-ripple-nlaps-{nlaps}",
                    cell_spikes_PC,
                    cell_spikes_PVBC)
                

    all_v_vecs = exc_v_vecs
    all_v_vecs.update(pvbc_v_vecs)

    save_v_vecs(pc, f"data/v_vecs_1011-ripple-nlaps-{nlaps}", all_v_vecs)

    pc.runworker()
    pc.done()
    h.quit()