from bluesky import Msg
from bluesky.callbacks.olog import logbook_cb_factory

text = []


def f(**kwargs):
    text.append(kwargs['text'])


def test_default_template(RE):
    text.clear()
    RE.subscribe(logbook_cb_factory(f), 'start')
    RE([Msg('open_run', plan_args={}), Msg('close_run')])
    assert len(text[0]) > 0


def test_trivial_template(RE):
    text.clear()
    RE.subscribe(logbook_cb_factory(f, desc_template='hello'), 'start')
    RE([Msg('open_run', plan_args={}), Msg('close_run')])
    assert text[0] == 'hello'

    # smoke test the long_template
    RE.subscribe(logbook_cb_factory(f, long_template='hello'), 'start')
    RE([Msg('open_run', plan_args={}), Msg('close_run')])


def test_template_dispatch(RE):
    disp = {'a': 'A', 'b': 'B'}
    text.clear()
    RE.subscribe(logbook_cb_factory(f, desc_dispatch=disp), 'start')
    RE([Msg('open_run', plan_name='a', plan_args={}),
        Msg('close_run')])
    RE([Msg('open_run', plan_name='b', plan_args={}),
        Msg('close_run')])
    assert text[0] == 'A'
    assert text[1] == 'B'

    # smoke test the long_dispatch
    RE.subscribe(logbook_cb_factory(f, long_dispatch=disp), 'start')
    RE([Msg('open_run', plan_name='a', plan_args={}),
        Msg('close_run')])
    RE([Msg('open_run', plan_name='b', plan_args={}),
        Msg('close_run')])

from bluesky import Msg
from bluesky.callbacks.olog import logbook_cb_factory

text = []


def f(**kwargs):
    text.append(kwargs['text'])


def test_default_template(RE):
    text.clear()
    RE.subscribe(logbook_cb_factory(f), 'start')
    RE([Msg('open_run', plan_args={}), Msg('close_run')])
    assert len(text[0]) > 0


def test_trivial_template(RE):
    text.clear()
    RE.subscribe(logbook_cb_factory(f, desc_template='hello'), 'start')
    RE([Msg('open_run', plan_args={}), Msg('close_run')])
    assert text[0] == 'hello'

    # smoke test the long_template
    RE.subscribe(logbook_cb_factory(f, long_template='hello'), 'start')
    RE([Msg('open_run', plan_args={}), Msg('close_run')])


def test_template_dispatch(RE):
    disp = {'a': 'A', 'b': 'B'}
    text.clear()
    RE.subscribe(logbook_cb_factory(f, desc_dispatch=disp), 'start')
    RE([Msg('open_run', plan_name='a', plan_args={}),
        Msg('close_run')])
    RE([Msg('open_run', plan_name='b', plan_args={}),
        Msg('close_run')])
    assert text[0] == 'A'
    assert text[1] == 'B'

    # smoke test the long_dispatch
    RE.subscribe(logbook_cb_factory(f, long_dispatch=disp), 'start')
    RE([Msg('open_run', plan_name='a', plan_args={}),
        Msg('close_run')])
    RE([Msg('open_run', plan_name='b', plan_args={}),
        Msg('close_run')])

# smoke test the long_template # smoke test the long_dispatch