Author: kwright
Date: Wed Mar 26 17:59:45 2014
New Revision: 1581968
URL: http://svn.apache.org/r1581968
Log:
Add testing repository connector
Added:
manifoldcf/branches/CONNECTORS-912/framework/pull-agent/src/test/java/org/apache/manifoldcf/crawler/tests/TestingRepositoryConnector.java
(with props)
Added:
manifoldcf/branches/CONNECTORS-912/framework/pull-agent/src/test/java/org/apache/manifoldcf/crawler/tests/TestingRepositoryConnector.java
URL:
http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-912/framework/pull-agent/src/test/java/org/apache/manifoldcf/crawler/tests/TestingRepositoryConnector.java?rev=1581968&view=auto
==============================================================================
---
manifoldcf/branches/CONNECTORS-912/framework/pull-agent/src/test/java/org/apache/manifoldcf/crawler/tests/TestingRepositoryConnector.java
(added)
+++
manifoldcf/branches/CONNECTORS-912/framework/pull-agent/src/test/java/org/apache/manifoldcf/crawler/tests/TestingRepositoryConnector.java
Wed Mar 26 17:59:45 2014
@@ -0,0 +1,84 @@
+/* $Id$ */
+
+/**
+* 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.manifoldcf.crawler.tests;
+
+import org.apache.manifoldcf.core.interfaces.*;
+import org.apache.manifoldcf.agents.interfaces.*;
+import org.apache.manifoldcf.crawler.interfaces.*;
+import org.apache.manifoldcf.crawler.system.ManifoldCF;
+
+import java.io.*;
+import java.util.*;
+import java.nio.charset.Charset;
+
+/** Connector class to be used by general integration tests that need
documents */
+public class TestingRepositoryConnector extends
org.apache.manifoldcf.crawler.connectors.BaseRepositoryConnector
+{
+ protected final static String[] documents = new
String[]{"test1.txt","test2.txt","test3.txt"};
+
+ private final static Charset UTF_8 = Charset.forName("UTF-8");
+
+ public TestingRepositoryConnector()
+ {
+ }
+
+ @Override
+ public void addSeedDocuments(ISeedingActivity activities,
DocumentSpecification spec,
+ long startTime, long endTime, int jobMode)
+ throws ManifoldCFException, ServiceInterruption
+ {
+ for (String doc : documents)
+ {
+ activities.addSeedDocument(doc,null);
+ }
+ }
+
+ @Override
+ public String[] getDocumentVersions(String[] documentIdentifiers, String[]
oldVersions, IVersionActivity activities,
+ DocumentSpecification spec, int jobMode, boolean usesDefaultAuthority)
+ throws ManifoldCFException, ServiceInterruption
+ {
+ String[] rval = new String[documentIdentifiers.length];
+ for (int i = 0; i < rval.length; i++)
+ {
+ rval[i] = "";
+ }
+ return rval;
+ }
+
+ @Override
+ public void processDocuments(String[] documentIdentifiers, String[]
versions, IProcessActivity activities,
+ DocumentSpecification spec, boolean[] scanOnly, int jobMode)
+ throws ManifoldCFException, ServiceInterruption
+ {
+ for (int i = 0; i < documentIdentifiers.length; i++)
+ {
+ String documentIdentifier = documentIdentifiers[i];
+ String version = versions[i];
+ if (!scanOnly[i])
+ {
+ RepositoryDocument rd = new RepositoryDocument();
+ byte[] bytes = documentIdentifier.getBytes(UTF_8);
+ rd.setBinary(new ByteArrayInputStream(bytes),bytes.length);
+
activities.ingestDocument(documentIdentifier,version,"http://"+documentIdentifier,rd);
+ }
+ }
+ }
+
+}
Propchange:
manifoldcf/branches/CONNECTORS-912/framework/pull-agent/src/test/java/org/apache/manifoldcf/crawler/tests/TestingRepositoryConnector.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
manifoldcf/branches/CONNECTORS-912/framework/pull-agent/src/test/java/org/apache/manifoldcf/crawler/tests/TestingRepositoryConnector.java
------------------------------------------------------------------------------
svn:keywords = Id
