package org.rcsb.cif;

import org.junit.jupiter.api.Test;
import org.rcsb.cif.model.Block;
import org.rcsb.cif.model.Category;
import org.rcsb.cif.model.CifFile;
import org.rcsb.cif.model.Column;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.stream.IntStream;

import static org.junit.jupiter.api.Assertions.fail;

/**
 * CIF specification states that case does not matter. This test defines the behavior of the implementation: case should
 * not matter during category/column retrieval but it should be honored during file writing.
 */
class CaseSensitivityTest {
    @Test
    void shouldIgnoreReadCaseForBinaryFiles() throws IOException {
        InputStream inputStream = TestHelper.getInputStream("bcif/1acj.bcif");
        CifFile cifFile = CifIO.readFromInputStream(inputStream);

        assertRetrievalBehavior(cifFile);
    }

    @Test
    void shouldIgnoreReadCaseForTextFiles() throws IOException {
        InputStream inputStream = TestHelper.getInputStream("bcif/1acj.bcif");
        CifFile cifFile = CifIO.readFromInputStream(inputStream);

        assertRetrievalBehavior(cifFile);
    }

    private void assertRetrievalBehavior(CifFile cifFile) {
        Block firstBlock = cifFile.getBlocks().get(0);

        Category originalAtomSite = firstBlock.getCategory("atom_site");
        Category atom_site = firstBlock.getCategory("atom_site");
        assertCategoryEquals("good luck if these do not match", originalAtomSite, atom_site);
        Category atom_Site = firstBlock.getCategory("atom_Site");
        assertCategoryEquals("case insensitivity not honored for categories", originalAtomSite, atom_Site);
        Category ATOM_SITE = firstBlock.getCategory("ATOM_SITE");
        assertCategoryEquals("case insensitivity not honored for categories", originalAtomSite, ATOM_SITE);

        Column<?> originalCartnX = originalAtomSite.getColumn("Cartn_x");
        Column<?> Cartn_x = atom_site.getColumn("Cartn_x");
        assertColumnEquals("good luck if these do not match", originalCartnX, Cartn_x);
        Column<?> cartn_x = atom_Site.getColumn("cartn_x");
        assertColumnEquals("case insensitivity not honored for columns", originalCartnX, cartn_x);
        Column<?> CARTN_X = ATOM_SITE.getColumn("CARTN_X");
        assertColumnEquals("case insensitivity not honored for columns", originalCartnX, CARTN_X);
    }

    private void assertColumnEquals(String msg, Column<?> expected, Column<?> actual) {
        if (expected == actual) {
            return;
        }

        if (expected.equals(actual)) {
            return;
        }

        if (!expected.getColumnName().equalsIgnoreCase(actual.getColumnName())) {
            fail("column names mismatch " + expected.getColumnName() + " vs " + actual.getColumnName());
        }

        if (expected.getRowCount() != actual.getRowCount()) {
            fail("row counts mismatch " + expected.getRowCount() + " vs " + actual.getRowCount() + " for column " + expected.getColumnName());
        }

        if(!IntStream.range(0, expected.getRowCount())
                        .allMatch(i -> expected.getStringData(i).equals(actual.getStringData(i)))) {
            fail("column content mismatch for column " + expected.getColumnName());
        }

        fail(msg);
    }

    private void assertCategoryEquals(String msg, Category expected, Category actual) {
        if (expected == actual) {
            return;
        }

        if (expected.equals(actual)) {
            return;
        }

        if (expected.getCategoryName().equalsIgnoreCase(actual.getCategoryName()) &&
                expected.getRowCount() == actual.getRowCount()) {
            return;
        }

        fail(msg);
    }

    @Test
    void shouldPropagateCaseForBinaryFiles() throws IOException {
        CifFile cifFile = CifBuilder.enterFile()
                .enterBlock("TEST")
                .enterCategory("ATOM_SITE")
                .enterFloatColumn("cartn_x")
                .add(1, 2, 3, 4)
                .leaveColumn()
                .leaveCategory()
                .leaveBlock()
                .leaveFile();

        byte[] bytes = CifIO.writeBinary(cifFile);
        InputStream inputStream = new ByteArrayInputStream(bytes);

        CifFile readCifFile = CifIO.readFromInputStream(inputStream);
        assertRetrievalBehavior(readCifFile);
    }

    @Test
    void shouldPropagateCaseForTextFiles() throws IOException {
        CifFile cifFile = CifBuilder.enterFile()
                .enterBlock("TEST")
                .enterCategory("ATOM_SITE")
                .enterFloatColumn("cartn_x")
                .add(1, 2, 3, 4)
                .leaveColumn()
                .leaveCategory()
                .leaveBlock()
                .leaveFile();

        byte[] bytes = CifIO.writeText(cifFile);
        InputStream inputStream = new ByteArrayInputStream(bytes);

        CifFile readCifFile = CifIO.readFromInputStream(inputStream);
        assertRetrievalBehavior(readCifFile);
    }

    @Test
    void shouldReadTamperedFileCaseInsensitively() throws IOException {
        InputStream inputStream = TestHelper.getInputStream("cif/1acj-cases.cif");
        CifFile cifFile = CifIO.readFromInputStream(inputStream);

        assertRetrievalBehavior(cifFile);
    }
}