tika-parsers/tika-parsers-standard/tika-parsers-standard-modules/tika-parser-pkg-module/src/test/java/org/apache/tika/parser/pkg/AbstractPkgTest.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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 at
 *
 *     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 org.apache.tika.parser.pkg;

import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;

import org.junit.Before;
import org.xml.sax.ContentHandler;
import org.xml.sax.SAXException;

import org.apache.tika.TikaTest;
import org.apache.tika.exception.TikaException;
import org.apache.tika.metadata.Metadata;
import org.apache.tika.metadata.TikaCoreProperties;
import org.apache.tika.mime.MediaType;
import org.apache.tika.parser.AbstractParser;
import org.apache.tika.parser.ParseContext;
import org.apache.tika.parser.Parser;

/**
 * Parent class for all Package based Test cases
 */
public abstract class AbstractPkgTest extends TikaTest {
    protected ParseContext trackingContext;
    protected ParseContext recursingContext;

    protected EmbeddedTrackingParser tracker;

    @Before
    public void setUp() throws Exception {
        tracker = new EmbeddedTrackingParser();
        trackingContext = new ParseContext();
        trackingContext.set(Parser.class, tracker);

        recursingContext = new ParseContext();
        recursingContext.set(Parser.class, AUTO_DETECT_PARSER);
    }


    @SuppressWarnings("serial")
    protected static class EmbeddedTrackingParser extends AbstractParser {
        protected List<String> filenames = new ArrayList<>();
        protected List<String> mediatypes = new ArrayList<>();
        protected List<String> createdAts = new ArrayList<>();
        protected List<String> modifiedAts = new ArrayList<>();
        protected byte[] lastSeenStart;

        public void reset() {
            filenames.clear();
            mediatypes.clear();
            createdAts.clear();
            modifiedAts.clear();
        }

        public Set<MediaType> getSupportedTypes(ParseContext context) {
            // Cheat!
            return AUTO_DETECT_PARSER.getSupportedTypes(context);
        }

        public void parse(InputStream stream, ContentHandler handler, Metadata metadata,
                          ParseContext context) throws IOException, SAXException, TikaException {
            filenames.add(metadata.get(TikaCoreProperties.RESOURCE_NAME_KEY));
            mediatypes.add(metadata.get(Metadata.CONTENT_TYPE));
            createdAts.add(metadata.get(TikaCoreProperties.CREATED));
            modifiedAts.add(metadata.get(TikaCoreProperties.MODIFIED));

            lastSeenStart = new byte[32];
            stream.read(lastSeenStart);
        }

    }
}