/*
 * Copyright 2009-2010 by The Regents of the University of California
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * you may obtain a copy of the License from
 * 
 *     http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package edu.uci.ics.asterix.transaction.management.test;

import java.io.IOException;
import java.util.Properties;

import edu.uci.ics.asterix.transaction.management.exception.ACIDException;
import edu.uci.ics.asterix.transaction.management.service.logging.IBuffer;
import edu.uci.ics.asterix.transaction.management.service.logging.ILogCursor;
import edu.uci.ics.asterix.transaction.management.service.logging.ILogFilter;
import edu.uci.ics.asterix.transaction.management.service.logging.ILogManager;
import edu.uci.ics.asterix.transaction.management.service.logging.ILogRecordHelper;
import edu.uci.ics.asterix.transaction.management.service.logging.LogManager;
import edu.uci.ics.asterix.transaction.management.service.logging.LogManagerProperties;
import edu.uci.ics.asterix.transaction.management.service.logging.LogUtil;
import edu.uci.ics.asterix.transaction.management.service.logging.LogicalLogLocator;
import edu.uci.ics.asterix.transaction.management.service.logging.PhysicalLogLocator;
import edu.uci.ics.asterix.transaction.management.service.transaction.TransactionSubsystem;

public class LogRecordReader {

    ILogManager logManager;

    public LogRecordReader(TransactionSubsystem factory) throws ACIDException {
        logManager = factory.getLogManager();
    }

    public LogRecordReader(ILogManager logManager) {
        this.logManager = logManager;
    }

    public void readLogs(long startingLsn) throws IOException, ACIDException {
        ILogRecordHelper parser = logManager.getLogRecordHelper();
        PhysicalLogLocator lsn = new PhysicalLogLocator(startingLsn, logManager);
        ILogCursor logCursor = logManager.readLog(lsn, new ILogFilter() {
            @Override
            public boolean accept(IBuffer buffer, long startOffset, int length) {
                return true;
            }
        });
        LogicalLogLocator currentLogLocator = LogUtil.getDummyLogicalLogLocator(logManager);
        int logCount = 0;
        while (true) {
            boolean logValidity = logCursor.next(currentLogLocator);
            if (logValidity) {
                System.out.println(++logCount + parser.getLogRecordForDisplay(currentLogLocator));
            } else {
                break;
            }
        }
    }

    public void readLogRecord(long lsnValue) throws IOException, ACIDException {
        LogicalLogLocator memLSN = null;
        logManager.readLog(lsnValue, memLSN);
        System.out.println(logManager.getLogRecordHelper().getLogRecordForDisplay(memLSN));
    }

    /**
     * @param args
     */
    public static void main(String[] args) throws ACIDException, Exception {
        LogManager logManager = new LogManager(null, "nc1");
        LogRecordReader logReader = new LogRecordReader(logManager);
        logReader.readLogs(0);
    }

}