from .stoicheia import Axis, Patch, Catalog
import numpy as np

def test_catalog_in_memory():
    cat = Catalog()

def test_catalog_on_disk():
    cat = Catalog("/tmp/foo.db")

def test_create_quilt():
    cat = Catalog()
    cat.create_quilt("sales", ["itm", "lct", "day"])

def test_fetch_empty():
    cat = Catalog()
    try:
        pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])
        assert False, "Should have failed because of missing quilt/axes"
    except ValueError:
        # This is the right thing to do
        pass

    cat.create_quilt("sales", ["itm", "lct", "day"])

    # Empty axis: the result should have zero size
    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])
    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(axes[2], np.array([]))
    assert np.array_equal(content, np.zeros((1,3,0), dtype=np.float32))

    # Empty content: the content should have size but be 0
    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4], day=[700])
    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(axes[2], np.array([700]))
    assert np.all(np.isnan(content))


def test_init_an_axis():
    # Should work fine with a numpy array
    a = Axis("thing", np.array([1,2,3]))
    assert np.array_equal(a.labels(), np.array([1,2,3]))
    assert a.name() == "thing"
    # TODO: Should work fine with a list too
    # a = Axis("thing", [1,2,3])
    # assert np.array_equal(a.labels(), np.array([1,2,3]))

def test_create_patch():
    pat = Patch(
        axes = [
            Axis("itm", np.array([1])),
            Axis("lct", np.array([2,3,4]))
        ],
        content = np.array([[1, 2, 6]], dtype=np.float32)
    )

    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(content, np.array([[1,2,6]]))

def test_commit_patch():
    cat = Catalog()
    cat.create_quilt("sales", ["itm", "lct", "day"])

    # Same as test_commit_patch
    pat = Patch(
        axes = [
            Axis("itm", np.array([1])),
            Axis("lct", np.array([2,3,4])),
            Axis("day", np.array([700]))
        ],
        content = np.array([[[1],[2],[6]]], dtype=np.float32)
    )
    cat.commit(
        "sales",
        parent_tag="latest",
        new_tag="latest",
        message="example commit",
        patches=[
            pat
        ]
    )

    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])

    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(axes[2], np.array([700]))
    assert np.array_equal(content, np.array([[[1],[2],[6]]], dtype=np.float32))


    # Cool, now commit twice.

    # This is shifted +1 on lct
    pat = Patch(
        axes = [
            Axis("itm", np.array([1])),
            Axis("lct", np.array([3,4,5])),
            Axis("day", np.array([700]))
        ],
        content = np.array([[[101],[102],[106]]], dtype=np.float32)
    )
    cat.commit(
        "sales",
        parent_tag="latest",
        new_tag="latest",
        message="example commit",
        patches=[
            pat
        ]
    )

    pat = cat.fetch("sales", "latest", itm=1, lct=None)
    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4,5]))
    assert np.array_equal(axes[2], np.array([700]))
    assert np.array_equal(content, np.array([[[1],[101],[102],[106]]], dtype=np.float32))


    # Test untag, to make sure it doesn't throw an error
    cat.untag("sales", "latest")
    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])

from .stoicheia import Axis, Patch, Catalog
import numpy as np

def test_catalog_in_memory():
    cat = Catalog()

def test_catalog_on_disk():
    cat = Catalog("/tmp/foo.db")

def test_create_quilt():
    cat = Catalog()
    cat.create_quilt("sales", ["itm", "lct", "day"])

def test_fetch_empty():
    cat = Catalog()
    try:
        pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])
        assert False, "Should have failed because of missing quilt/axes"
    except ValueError:
        # This is the right thing to do
        pass

    cat.create_quilt("sales", ["itm", "lct", "day"])

    # Empty axis: the result should have zero size
    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])
    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(axes[2], np.array([]))
    assert np.array_equal(content, np.zeros((1,3,0), dtype=np.float32))

    # Empty content: the content should have size but be 0
    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4], day=[700])
    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(axes[2], np.array([700]))
    assert np.all(np.isnan(content))


def test_init_an_axis():
    # Should work fine with a numpy array
    a = Axis("thing", np.array([1,2,3]))
    assert np.array_equal(a.labels(), np.array([1,2,3]))
    assert a.name() == "thing"
    # TODO: Should work fine with a list too
    # a = Axis("thing", [1,2,3])
    # assert np.array_equal(a.labels(), np.array([1,2,3]))

def test_create_patch():
    pat = Patch(
        axes = [
            Axis("itm", np.array([1])),
            Axis("lct", np.array([2,3,4]))
        ],
        content = np.array([[1, 2, 6]], dtype=np.float32)
    )

    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(content, np.array([[1,2,6]]))

def test_commit_patch():
    cat = Catalog()
    cat.create_quilt("sales", ["itm", "lct", "day"])

    # Same as test_commit_patch
    pat = Patch(
        axes = [
            Axis("itm", np.array([1])),
            Axis("lct", np.array([2,3,4])),
            Axis("day", np.array([700]))
        ],
        content = np.array([[[1],[2],[6]]], dtype=np.float32)
    )
    cat.commit(
        "sales",
        parent_tag="latest",
        new_tag="latest",
        message="example commit",
        patches=[
            pat
        ]
    )

    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])

    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4]))
    assert np.array_equal(axes[2], np.array([700]))
    assert np.array_equal(content, np.array([[[1],[2],[6]]], dtype=np.float32))


    # Cool, now commit twice.

    # This is shifted +1 on lct
    pat = Patch(
        axes = [
            Axis("itm", np.array([1])),
            Axis("lct", np.array([3,4,5])),
            Axis("day", np.array([700]))
        ],
        content = np.array([[[101],[102],[106]]], dtype=np.float32)
    )
    cat.commit(
        "sales",
        parent_tag="latest",
        new_tag="latest",
        message="example commit",
        patches=[
            pat
        ]
    )

    pat = cat.fetch("sales", "latest", itm=1, lct=None)
    axes, content = pat.export()
    assert np.array_equal(axes[0], np.array([1]))
    assert np.array_equal(axes[1], np.array([2,3,4,5]))
    assert np.array_equal(axes[2], np.array([700]))
    assert np.array_equal(content, np.array([[[1],[101],[102],[106]]], dtype=np.float32))


    # Test untag, to make sure it doesn't throw an error
    cat.untag("sales", "latest")
    pat = cat.fetch("sales", "latest", itm=1, lct=[2,3,4])

# This is the right thing to do # Empty axis: the result should have zero size # Empty content: the content should have size but be 0 # Should work fine with a numpy array # TODO: Should work fine with a list too # a = Axis("thing", [1,2,3]) # assert np.array_equal(a.labels(), np.array([1,2,3])) # Same as test_commit_patch # Cool, now commit twice. # This is shifted +1 on lct # Test untag, to make sure it doesn't throw an error