gvSIG projects pool

package org.gvsig.vcsgis.lib.impl.server;

import java.io.ByteArrayInputStream;

import java.io.File;

import java.io.InputStream;

import java.net.URL;

import java.sql.Timestamp;

import java.util.Map;

import junit.framework.TestCase;

import static junit.framework.TestCase.assertEquals;

import org.apache.commons.io.FileUtils;

import org.apache.commons.io.IOUtils;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.feature.EditableFeature;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorerParameters;

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.gvsig.vcsgis.lib.SequentialCodeGenerator;

import org.gvsig.vcsgis.lib.VCSGisLocator;

import org.gvsig.vcsgis.lib.VCSGisManager;

import static org.gvsig.vcsgis.lib.VCSGisManager.ERR_OK;

import org.gvsig.vcsgis.lib.impl.TestUtils;

import org.gvsig.vcsgis.lib.workspace.VCSGisWorkspace;

import org.gvsig.vcsgis.lib.repository.VCSGisRepository;

import org.gvsig.vcsgis.lib.repository.remoteclient.requests.RowCreateRequestClient;

import org.gvsig.vcsgis.lib.repository.remoteclient.requests.RowDeleteRequestClient;

import org.gvsig.vcsgis.lib.repository.remoteclient.requests.RowUpdateRequestClient;

import org.gvsig.vcsgis.lib.server.VCSGisServerController;

import org.gvsig.vcsgis.lib.server.VCSGisServerHandler;

import org.gvsig.vcsgis.lib.server.handlers.RowCreateHandler;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class TestS04Row extends TestCase {

    private static final Logger LOGGER = LoggerFactory.getLogger(TestS04Row.class);

    public TestS04Row(String testName) {

        super(testName);

    }

    @Override

    protected void setUp() throws Exception {

        super.setUp();

        new DefaultLibrariesInitializer().fullInitialize();

    }

    @Override

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    // TODO add test methods here. The name must begin with 'test'. For example:

    // public void testHello() {}

    public void testRowXXXHandler() throws Exception {

        final String testid = "RowXXXHandler";

        final URL serverUrl = new URL("http://localhost:9810/");

        VCSGisManager manager = VCSGisLocator.getVCSGisManager();

        manager.setCodeGenerator(new SequentialCodeGenerator());

        JDBCServerExplorerParameters explorerParams = TestUtils.getServerExplorerParameters("srv-"+testid);

        File ws1file = TestUtils.getFile(FileUtils.getFile("test-dbs","ws1-"+testid)); 

        File ws2file = TestUtils.getFile(FileUtils.getFile("test-dbs","ws2-"+testid)); 

        Map<String, String> expected = TestUtils.getExpecteds("S04Row.txt");

        // ---------------------------------------------------------

        // Creamos el server y obtenemos el repositorio del server

        int r = manager.initRepository(explorerParams, null);

        assertEquals("srv-init status", 0, r);

        VCSGisRepository repolocal = manager.openRepository(explorerParams);

        TestUtils.h2sql_repository(repolocal);

        // ---------------------------------------------------------

        // Creamos un workspace y preparamos los datos en el para hacer un commit

        r = manager.initWorkspace(ws1file, repolocal, "Test checkout ws1", null);

        assertEquals("ws1-init status", 0, r);

        VCSGisWorkspace ws1 = manager.openWorkspace(ws1file);

        TestUtils.h2sql_workspace(ws1);

        FeatureStore sourceStore = TestUtils.openSourceStore2();

        r = ws1.add("test", sourceStore, "text");

        assertEquals("ws1-add status", 0, r);      

        r = ws1.commit(Timestamp.valueOf("2020-02-17 10:11:12.123"), testid, null);

        assertEquals("ws1.commit status", ERR_OK, r);

        DisposeUtils.disposeQuietly(sourceStore);

        FeatureStore store = ws1.getFeatureStore("test");

        VCSGisRepository reporemote = manager.openRepository(serverUrl);

        VCSGisServerController serverController = manager.createServerController(repolocal);

        VCSGisServerHandler serverHandler;

        InputStream is;

        InputStream os;

        String entityCode = "00000000000003abcdef0123456789";

        String relatedFeatureCode = "00000000000023abcdef0123456789";

        String localRevisionCodeForRowCreate = "00000000000015abcdef0123456789";

        String localRevisionCodeForRowUpdate = "00000000000025abcdef0123456789";

        String localRevisionCodeForRowDelete = "00000000000030abcdef0123456789";

        String localRevisionCodeAfterRowDelete = "00000000000035abcdef0123456789";

        assertEquals("initial EntityRevisionCode", 

                localRevisionCodeForRowCreate, 

                ws1.getWorkspaceEntityByName("test").getRepositoryRevisionCode()

        );

        // RowCreate test

        RowCreateRequestClient createRequest = (RowCreateRequestClient) reporemote.createRowCreateRequest(

                "test", 

                localRevisionCodeForRowCreate

        );

        EditableFeature f = store.createNewFeature();

        f.set("id",4);

        f.set("text","DDD");

        String createdata = f.toJson().toString();

        createRequest.setData(createdata);

        createRequest.setEfectiveDate(Timestamp.valueOf("2020-02-18 10:11:12.123"));

        createRequest.setComment("test row create (4,ddd)");

        String req_s = StringUtils.join(IOUtils.readLines(createRequest.getRequestAsInputStream()),"\n").trim();

        assertEquals("Row create LastErrorCode", ERR_OK, createRequest.getLastErrorCode());

        assertEquals("Row create request", expected.get("RowCreateRequest").trim(), req_s);

        serverHandler = (RowCreateHandler) serverController.createRowCreateHandler();

        is = new ByteArrayInputStream(req_s.getBytes());

        os = serverHandler.handle(is);

        String resp_s = StringUtils.join(IOUtils.readLines(os),"\n").trim();

        assertEquals("Row create response", expected.get("RowCreateResponse").trim(), resp_s);

        createRequest.consumeResponse(new ByteArrayInputStream(resp_s.getBytes()));

        assertEquals("Row create RelatedFeatureCode", relatedFeatureCode, createRequest.getRelatedFeatureCode());

        assertEquals("Row create EntityCode", entityCode, createRequest.getEntityCode());

        assertEquals("Row create EntityRevisionCode", localRevisionCodeForRowUpdate, createRequest.getEntityRevisionCode());

        // RowUpdate test

        RowUpdateRequestClient updateRequest = (RowUpdateRequestClient) reporemote.createRowUpdateRequest(

                "test",

                localRevisionCodeForRowUpdate

        );

        f.set("text", "DD2");

        f.set("VCSGISCODE", relatedFeatureCode);

        String updatedata = f.toJson().toString();

        updateRequest.setData(updatedata);

        createRequest.setEfectiveDate((Timestamp)null);

        updateRequest.setComment("test row update (4,dd2)");

        req_s = StringUtils.join(IOUtils.readLines(updateRequest.getRequestAsInputStream()),"\n").trim();

        assertEquals("Row update LastErrorCode", ERR_OK, updateRequest.getLastErrorCode());

        assertEquals("Row update request", expected.get("RowUpdateRequest").trim(), req_s);

        serverHandler = serverController.createRowUpdateHandler();

        is = new ByteArrayInputStream(req_s.getBytes());

        os = serverHandler.handle(is);

        resp_s = StringUtils.join(IOUtils.readLines(os),"\n").trim();

        assertEquals("Row update request", expected.get("RowUpdateResponse").trim(), resp_s);

        updateRequest.consumeResponse(new ByteArrayInputStream(resp_s.getBytes()));

        assertEquals("Row update EntityCode", entityCode, updateRequest.getEntityCode());

        assertEquals("Row update EntityRevisionCode", localRevisionCodeForRowDelete, updateRequest.getEntityRevisionCode());

        // RowDelete test

        RowDeleteRequestClient deleteRequest = (RowDeleteRequestClient) reporemote.createRowDeleteRequest(

                "test", 

                localRevisionCodeForRowDelete

        );

        deleteRequest.setRelatedFeatureCode(createRequest.getRelatedFeatureCode());

        deleteRequest.setComment("test row delete (4,dd2)");

        deleteRequest.setEfectiveDate(Timestamp.valueOf("2020-02-19 10:11:12.123"));

        req_s = StringUtils.join(IOUtils.readLines(deleteRequest.getRequestAsInputStream()),"\n").trim();

        assertEquals("Row delete request", expected.get("RowDeleteRequest").trim(), req_s);

        serverHandler = serverController.createRowDeleteHandler();

        is = new ByteArrayInputStream(req_s.getBytes());

        os = serverHandler.handle(is);

        resp_s = StringUtils.join(IOUtils.readLines(os),"\n").trim();

        assertEquals("Row delete request", expected.get("RowDeleteResponse").trim(), resp_s);

        deleteRequest.consumeResponse(new ByteArrayInputStream(resp_s.getBytes()));

        assertEquals("Row delete EntityCode", entityCode, deleteRequest.getEntityCode());

        assertEquals("Row delete EntityRevisionCode", localRevisionCodeAfterRowDelete, deleteRequest.getEntityRevisionCode());

        repolocal.dispose();

    }

}