package com.armedia.acm.plugins.ecm.service.sync.impl;

/*-
 * #%L
 * ACM Service: Enterprise Content Management
 * %%
 * Copyright (C) 2014 - 2018 ArkCase LLC
 * %%
 * This file is part of the ArkCase software. 
 * 
 * If the software was purchased under a paid ArkCase license, the terms of 
 * the paid license agreement will prevail.  Otherwise, the software is 
 * provided under the following open source license terms:
 * 
 * ArkCase is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *  
 * ArkCase is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public License
 * along with ArkCase. If not, see <http://www.gnu.org/licenses/>.
 * #L%
 */

import static org.easymock.EasyMock.capture;
import static org.easymock.EasyMock.expect;
import static org.easymock.EasyMock.replay;
import static org.easymock.EasyMock.verify;
import static org.junit.Assert.assertEquals;

import com.armedia.acm.plugins.ecm.model.sync.EcmEvent;
import com.armedia.acm.plugins.ecm.service.sync.EcmAuditResponseReader;

import org.apache.commons.io.FileUtils;
import org.easymock.Capture;
import org.easymock.EasyMock;
import org.json.JSONObject;
import org.junit.Before;
import org.junit.Test;
import org.quartz.JobDataMap;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;

import java.util.HashMap;
import java.util.Map;
import java.util.Random;

/**
 * Created by dmiller on 5/15/17.
 */
public class AlfrescoSyncServiceTest
{
    private AlfrescoSyncService unit;

    private AlfrescoAuditApplicationRestClient auditApplicationRestClient = EasyMock.createMock(AlfrescoAuditApplicationRestClient.class);

    private ApplicationEventPublisher applicationEventPublisher = EasyMock.createMock(ApplicationEventPublisher.class);

    private EcmAuditResponseReader firstEcmAuditResponseReader = new AlfrescoNodeServiceCreateNodeAuditResponseReader();
    private EcmAuditResponseReader secondEcmAuditResponseReader = new AlfrescoFileFolderServiceCreateAuditResponseReader();

    private JSONObject firstAuditResponse;
    private JSONObject secondAuditResponse;

    private JSONObject emptyAuditResponse;

    @Before
    public void setUp() throws Exception
    {
        unit = new AlfrescoSyncService();

        unit.setAuditApplicationRestClient(auditApplicationRestClient);
        unit.setApplicationEventPublisher(applicationEventPublisher);

        Map<String, EcmAuditResponseReader> applications = new HashMap<>();
        applications.put("applicationOne", firstEcmAuditResponseReader);
        applications.put("applicationTwo", secondEcmAuditResponseReader);
        unit.setAuditApplications(applications);

        final Resource firstAuditResponseResource = new ClassPathResource("json/SampleAlfrescoNodeServiceCreateNodeAuditResponse.json");
        String firstAuditResponseString = FileUtils.readFileToString(firstAuditResponseResource.getFile());
        firstAuditResponse = new JSONObject(firstAuditResponseString);

        final Resource secondAuditResponseResource = new ClassPathResource("json/SampleAlfrescoFileFolderServiceCreateAuditResponse.json");
        String secondAuditResponseString = FileUtils.readFileToString(secondAuditResponseResource.getFile());
        secondAuditResponse = new JSONObject(secondAuditResponseString);

        final Resource emptyAuditResponseResource = new ClassPathResource("json/SampleAlfrescoEmptyAuditResponse.json");
        String emptyAuditResponseString = FileUtils.readFileToString(emptyAuditResponseResource.getFile());
        emptyAuditResponse = new JSONObject(emptyAuditResponseString);
    }

    @Test
    public void queryAlfrescoAuditApplications() throws Exception
    {

        // generate random audit id from 10 to 10,000
        Long firstAppAuditId = Integer.valueOf(new Random().nextInt(10000 - 10) + 10).longValue();
        Long secondAppAuditId = Integer.valueOf(new Random().nextInt(10000 - 10) + 10).longValue();

        Map<String, Long> lastAuditIdsPerApp = new HashMap<>();
        lastAuditIdsPerApp.put("applicationOne.lastAuditId", firstAppAuditId);
        lastAuditIdsPerApp.put("applicationTwo.lastAuditId", secondAppAuditId);

        // we want to start from the next audit record... so we don't retrieve the last one we got before
        expect(auditApplicationRestClient.service("applicationOne", firstAppAuditId + 1))
                .andReturn(firstAuditResponse);
        expect(auditApplicationRestClient.service("applicationTwo", secondAppAuditId + 1))
                .andReturn(secondAuditResponse);

        // 3 events from the first audit app, and 2 events from the second. The events should be published
        // by order of the audit id in each event: 42, 52, 55, 57, 91
        Capture<EcmEvent> first = Capture.newInstance();
        Capture<EcmEvent> second = Capture.newInstance();
        Capture<EcmEvent> third = Capture.newInstance();
        Capture<EcmEvent> fourth = Capture.newInstance();
        Capture<EcmEvent> fifth = Capture.newInstance();
        applicationEventPublisher.publishEvent(capture(first));
        applicationEventPublisher.publishEvent(capture(second));
        applicationEventPublisher.publishEvent(capture(third));
        applicationEventPublisher.publishEvent(capture(fourth));
        applicationEventPublisher.publishEvent(capture(fifth));

        replay(auditApplicationRestClient, applicationEventPublisher);

        JobDataMap jobDataMap = new JobDataMap(lastAuditIdsPerApp);
        unit.queryAlfrescoAuditApplications(jobDataMap);

        verify(auditApplicationRestClient, applicationEventPublisher);

        assertEquals(42, first.getValue().getAuditId());
        assertEquals(52, second.getValue().getAuditId());
        assertEquals(55, third.getValue().getAuditId());
        assertEquals(57, fourth.getValue().getAuditId());
        assertEquals(91, fifth.getValue().getAuditId());
        // the last audit ID in the first audit response is 61
        assertEquals("61", jobDataMap.get("applicationOne.lastAuditId"));
        // the last audit ID in the second audit response is 91
        assertEquals("91", jobDataMap.get("applicationTwo.lastAuditId"));

    }

}