from redpitaya.overlay.mercury import mercury as overlay
fpga = overlay()

osc = [fpga.osc(ch, 1.0) for ch in range(2)]

fpga.osc(index: int, input_range: float)
# index: チャンネル番号；0か1を指定できる
# input_range: 入力レンジの設定；lo or hi を切り替える

for ch in osc:
    # data rate decimation 
    ch.decimation = 1

    # trigger timing [sample periods]
    N = ch.buffer_size
    ch.trigger_pre  = 0
    ch.trigger_post = N
    
    # osc[0] is controlling both channels
    ch.sync_src = fpga.sync_src["osc0"]

# trigger level [V], edge ['neg', 'pos']
# hysteresis is used to avoid triggering on wrong edge with noisy signals

# trigger on 0.5V but do not trigger again
# unless signal first falls below 0.45V
osc[0].level = [0.45, 0.5]
osc[0].edge  = 'pos'

# trigger on -0.2V but do not trigger again
# unless signal first rises above -0.15V
osc[1].level = [-0.2, -0.15]
osc[1].edge  = 'neg'

for ch in osc:
    ch.trig_src = fpga.trig_src["osc1"]

# reset and start
osc[0].reset()
osc[0].start()
# wait for data
while (osc[0].status_run()): pass
print ("triggered")

import matplotlib.pyplot as plt

# show only the part of the buffer requested by pre/post trigger timing
for ch in osc:
    data = ch.data(N)
    plt.plot(data)
    plt.show()

_data1: np.array = osc[0].data
_data2: np.array = osc[1].data

ch1 = pd.DataFrame(_data1, columns=["x", "ch1"])
ch2 = pd.DataFrame(_data2, columns=["x", "ch2"])

merged = pd.merge(ch1, ch2, on="x")
merged["datetime"] = 測定日時

merged.to_csv(ファイル名, index=False)
merged.to_json(ファイル名, orient="records")

/**
 * Type representing Input/Output channels.
 */
typedef enum {
    RP_CH_1 = 0,    //!< Channel A
    RP_CH_2 = 1,    //!< Channel B
    RP_CH_3 = 2,    //!< Channel C
    RP_CH_4 = 3     //!< Channel D
} rp_channel_t;

/**
 * Type representing Input/Output channels in trigger.
 */
typedef enum {
    RP_T_CH_1 = 0,    //!< Channel A
    RP_T_CH_2 = 1,    //!< Channel B
    RP_T_CH_3 = 2,    //!< Channel C
    RP_T_CH_4 = 3,    //!< Channel D
    RP_T_CH_EXT = 4
} rp_channel_trigger_t;

/**
 * Type representing decimation used at acquiring signal.
 */
typedef enum {
    RP_DEC_1     = 1,       //!< Decimation 1
    RP_DEC_2     = 2,       //!< Decimation 2
    RP_DEC_4     = 4,       //!< Decimation 4
    RP_DEC_8     = 8,       //!< Decimation 8
    RP_DEC_16    = 16,      //!< Decimation 16
    RP_DEC_32    = 32,      //!< Decimation 32
    RP_DEC_64    = 64,      //!< Decimation 64
    RP_DEC_128   = 128,     //!< Decimation 128
    RP_DEC_256   = 256,     //!< Decimation 256
    RP_DEC_512   = 512,     //!< Decimation 512
    RP_DEC_1024  = 1024,    //!< Decimation 1024
    RP_DEC_2048  = 2048,    //!< Decimation 2048
    RP_DEC_4096  = 4096,    //!< Decimation 4096
    RP_DEC_8192  = 8192,    //!< Decimation 8192
    RP_DEC_16384 = 16384,   //!< Decimation 16384
    RP_DEC_32768 = 32768,   //!< Decimation 32768
    RP_DEC_65536 = 65536    //!< Decimation 65536
} rp_acq_decimation_t;

/**
 * Type representing different trigger sources used at acquiring signal.
 */
typedef enum {
    RP_TRIG_SRC_DISABLED = 0, //!< Trigger is disabled
    RP_TRIG_SRC_NOW      = 1, //!< Trigger triggered now (immediately)
    RP_TRIG_SRC_CHA_PE   = 2, //!< Trigger set to Channel A threshold positive edge
    RP_TRIG_SRC_CHA_NE   = 3, //!< Trigger set to Channel A threshold negative edge
    RP_TRIG_SRC_CHB_PE   = 4, //!< Trigger set to Channel B threshold positive edge
    RP_TRIG_SRC_CHB_NE   = 5, //!< Trigger set to Channel B threshold negative edge
    RP_TRIG_SRC_EXT_PE   = 6, //!< Trigger set to external trigger positive edge (DIO0_P pin)
    RP_TRIG_SRC_EXT_NE   = 7, //!< Trigger set to external trigger negative edge (DIO0_P pin)
    RP_TRIG_SRC_AWG_PE   = 8, //!< Trigger set to arbitrary wave generator application positive edge
    RP_TRIG_SRC_AWG_NE   = 9, //!< Trigger set to arbitrary wave generator application negative edge
    RP_TRIG_SRC_CHC_PE   = 10,//!< Trigger set to Channel C threshold positive edge
    RP_TRIG_SRC_CHC_NE   = 11,//!< Trigger set to Channel C threshold negative edge
    RP_TRIG_SRC_CHD_PE   = 12,//!< Trigger set to Channel D threshold positive edge
    RP_TRIG_SRC_CHD_NE   = 13 //!< Trigger set to Channel D threshold negative edge
} rp_acq_trig_src_t;

/**
 * Type representing different trigger states.
 */
typedef enum {
    RP_TRIG_STATE_TRIGGERED, //!< Trigger is triggered/disabled
    RP_TRIG_STATE_WAITING,   //!< Trigger is set up and waiting (to be triggered)
} rp_acq_trig_state_t;