public class org.apache.wiki.search.kendra.KendraSearchProvider extends java.lang.Object implements org.apache.wiki.search.SearchProvider
{
private static final org.apache.logging.log4j.Logger LOG;
private org.apache.wiki.api.core.Engine engine;
private java.util.Properties properties;
private java.util.Map contentTypes;
private com.amazonaws.services.kendra.AWSkendra kendra;
private java.lang.String indexName;
private java.lang.String indexId;
private java.lang.String dataSourceName;
private java.lang.String dataSourceId;
private final java.util.List updates;
private static final java.lang.String PROP_KENDRA_INDEX_NAME;
private static final java.lang.String PROP_KENDRA_DATA_SOURCE_NAME;
private static final java.lang.String PROP_KENDRA_INDEXDELAY;
private static final java.lang.String PROP_KENDRA_INITIALDELAY;
public void <init>()
{
java.util.List v;
java.util.ArrayList v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List synchronizedList(java.util.List)>(v);
v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.List updates> = v;
return;
}
public void initialize(org.apache.wiki.api.core.Engine, java.util.Properties) throws org.apache.wiki.api.exceptions.NoRequiredPropertyException, java.io.IOException
{
java.util.Properties v, v, v, v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.AWSkendra v;
org.apache.wiki.api.core.Engine v;
org.apache.wiki.search.kendra.KendraSearchProvider$KendraUpdater v;
java.util.Map v;
int v, v;
java.lang.String v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: org.apache.wiki.api.core.Engine;
v := @parameter: java.util.Properties;
v.<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.wiki.api.core.Engine engine> = v;
v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Properties properties> = v;
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Map getContentTypes()>();
v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Map contentTypes> = v;
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra buildClient()>();
virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void setKendra(com.amazonaws.services.kendra.AWSkendra)>(v);
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Properties properties>;
v = staticinvoke <org.apache.wiki.util.TextUtil: java.lang.String getRequiredProperty(java.util.Properties,java.lang.String)>(v, "jspwiki.kendra.indexName");
v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexName> = v;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Properties properties>;
v = staticinvoke <org.apache.wiki.util.TextUtil: java.lang.String getRequiredProperty(java.util.Properties,java.lang.String)>(v, "jspwiki.kendra.dataSourceName");
v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceName> = v;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Properties properties>;
v = staticinvoke <org.apache.wiki.util.TextUtil: int getIntegerProperty(java.util.Properties,java.lang.String,int)>(v, "jspwiki.kendra.initialdelay", 10);
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Properties properties>;
v = staticinvoke <org.apache.wiki.util.TextUtil: int getIntegerProperty(java.util.Properties,java.lang.String,int)>(v, "jspwiki.kendra.indexdelay", 5);
if v < 0 goto label;
v = new org.apache.wiki.search.kendra.KendraSearchProvider$KendraUpdater;
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider$KendraUpdater: void <init>(org.apache.wiki.api.core.Engine,org.apache.wiki.search.kendra.KendraSearchProvider,int,int)>(v, v, v, v);
virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider$KendraUpdater: void start()>();
label:
return;
}
private java.util.Map getContentTypes()
{
java.lang.Throwable v;
java.lang.Object[] v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.io.IOException v;
java.io.InputStreamReader v;
com.google.gson.GsonBuilder v;
org.apache.wiki.search.kendra.KendraSearchProvider$1 v;
org.apache.logging.log4j.Logger v;
java.lang.reflect.Type v;
com.google.gson.Gson v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v, v;
java.io.InputStream v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = new com.google.gson.GsonBuilder;
specialinvoke v.<com.google.gson.GsonBuilder: void <init>()>();
v = virtualinvoke v.<com.google.gson.GsonBuilder: com.google.gson.Gson create()>();
label:
v = class "Lorg/apache/wiki/search/kendra/KendraSearchProvider;";
v = virtualinvoke v.<java.lang.Class: java.io.InputStream getResourceAsStream(java.lang.String)>("content_types.json");
label:
if v == null goto label;
v = new org.apache.wiki.search.kendra.KendraSearchProvider$1;
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider$1: void <init>(org.apache.wiki.search.kendra.KendraSearchProvider)>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider$1: java.lang.reflect.Type getType()>();
v = new java.io.InputStreamReader;
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream)>(v);
v = virtualinvoke v.<com.google.gson.Gson: java.lang.Object fromJson(java.io.Reader,java.lang.reflect.Type)>(v, v);
label:
virtualinvoke v.<java.io.InputStream: void close()>();
label:
return v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to load default propertyfile \'content_types.json\': %s", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
label:
return null;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
public java.lang.String getProviderInfo()
{
org.apache.wiki.search.kendra.KendraSearchProvider v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
return "KendraSearchProvider";
}
public void pageRemoved(org.apache.wiki.api.core.Page)
{
java.lang.Object[] v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.lang.String[] v;
int v;
java.lang.String v, v, v, v;
com.amazonaws.services.kendra.model.BatchDeleteDocumentResult v;
com.amazonaws.services.kendra.AWSkendra v;
org.apache.wiki.api.core.Page v;
java.util.List v;
com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest v, v, v;
org.apache.logging.log4j.Logger v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: org.apache.wiki.api.core.Page;
v = interfaceinvoke v.<org.apache.wiki.api.core.Page: java.lang.String getName()>();
v = new com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest: void <init>()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest: com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest withIndexId(java.lang.String)>(v);
v = newarray (java.lang.String)[1];
v[0] = v;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest: com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest withDocumentIdList(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.BatchDeleteDocumentResult batchDeleteDocument(com.amazonaws.services.kendra.model.BatchDeleteDocumentRequest)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchDeleteDocumentResult: java.util.List getFailedDocuments()>();
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Page \'%s\' was removed from index", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void debug(java.lang.String)>(v);
goto label;
label:
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to remove Page \'%s\' from index", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
label:
return;
}
public void reindexPage(org.apache.wiki.api.core.Page)
{
java.util.List v;
java.lang.Object[] v;
org.apache.logging.log4j.Logger v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.lang.String v, v;
org.apache.wiki.api.core.Page v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: org.apache.wiki.api.core.Page;
if v == null goto label;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.List updates>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<org.apache.wiki.api.core.Page: java.lang.String getName()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Scheduling page \'%s\' for indexing ...", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void debug(java.lang.String)>(v);
label:
return;
}
public java.util.Collection findPages(java.lang.String, org.apache.wiki.api.core.Context) throws org.apache.wiki.api.exceptions.ProviderException, java.io.IOException
{
org.apache.wiki.api.spi.ContentsDSL v;
org.apache.wiki.search.kendra.KendraSearchProvider$SearchResultImpl v;
int[] v;
org.apache.wiki.api.core.Session v;
com.amazonaws.services.kendra.model.ScoreAttributes v;
boolean v, v;
org.apache.wiki.api.core.Context v;
com.amazonaws.services.kendra.AWSkendra v;
org.apache.wiki.auth.permissions.PagePermission v;
java.util.List v;
org.apache.logging.log4j.Logger v, v, v, v;
java.lang.Throwable v;
java.lang.Object[] v, v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.lang.String[] v;
java.util.ArrayList v, v;
int v, v, v, v, v;
com.amazonaws.services.kendra.model.QueryRequest v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.wiki.api.core.Page v, v;
com.amazonaws.services.kendra.model.QueryResultType v;
org.apache.wiki.api.core.Engine v, v, v;
java.lang.Object v, v, v;
com.amazonaws.services.kendra.model.TextWithHighlights v;
com.amazonaws.services.kendra.model.QueryResult v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: java.lang.String;
v := @parameter: org.apache.wiki.api.core.Context;
v = new com.amazonaws.services.kendra.model.QueryRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.QueryRequest: void <init>()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryRequest: com.amazonaws.services.kendra.model.QueryRequest withIndexId(java.lang.String)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryRequest: com.amazonaws.services.kendra.model.QueryRequest withQueryText(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.QueryResult query(com.amazonaws.services.kendra.model.QueryRequest)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryResult: java.util.List getResultItems()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>("ThrottlingException. Skipping...");
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
return v;
label:
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.List: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.wiki.api.core.Engine engine>;
v = interfaceinvoke v.<org.apache.wiki.api.core.Engine: java.lang.Object getManager(java.lang.Class)>(class "Lorg/apache/wiki/auth/AuthorizationManager;");
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.wiki.search.kendra.KendraSearchProvider$2: int[] $SwitchMap$com$amazonaws$services$kendra$model$QueryResultType>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryResultItem: java.lang.String getType()>();
v = staticinvoke <com.amazonaws.services.kendra.model.QueryResultType: com.amazonaws.services.kendra.model.QueryResultType fromValue(java.lang.String)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryResultType: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryResultItem: java.lang.String getDocumentId()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryResultItem: com.amazonaws.services.kendra.model.TextWithHighlights getDocumentExcerpt()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.TextWithHighlights: java.lang.String getText()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryResultItem: com.amazonaws.services.kendra.model.ScoreAttributes getScoreAttributes()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ScoreAttributes: java.lang.String getScoreConfidence()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.wiki.api.core.Engine engine>;
v = interfaceinvoke v.<org.apache.wiki.api.core.Engine: java.lang.Object getManager(java.lang.Class)>(class "Lorg/apache/wiki/pages/PageManager;");
v = (int) -1;
v = interfaceinvoke v.<org.apache.wiki.pages.PageManager: org.apache.wiki.api.core.Page getPage(java.lang.String,int)>(v, v);
if v == null goto label;
v = new org.apache.wiki.auth.permissions.PagePermission;
specialinvoke v.<org.apache.wiki.auth.permissions.PagePermission: void <init>(org.apache.wiki.api.core.Page,java.lang.String)>(v, "view");
v = interfaceinvoke v.<org.apache.wiki.api.core.Context: org.apache.wiki.api.core.Session getWikiSession()>();
v = interfaceinvoke v.<org.apache.wiki.auth.AuthorizationManager: boolean checkPermission(org.apache.wiki.api.core.Session,java.security.Permission)>(v, v);
if v == 0 goto label;
v = new org.apache.wiki.search.kendra.KendraSearchProvider$SearchResultImpl;
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: int confidence2score(java.lang.String)>(v);
v = newarray (java.lang.String)[1];
v[0] = v;
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider$SearchResultImpl: void <init>(org.apache.wiki.api.core.Page,int,java.lang.String[])>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Page \'%s\' is not accessible", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
goto label;
label:
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Kendra found a result page \'%s\' that could not be loaded, removing from index", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
v = staticinvoke <org.apache.wiki.api.spi.Wiki: org.apache.wiki.api.spi.ContentsDSL contents()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.wiki.api.core.Engine engine>;
v = virtualinvoke v.<org.apache.wiki.api.spi.ContentsDSL: org.apache.wiki.api.core.Page page(org.apache.wiki.api.core.Engine,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void pageRemoved(org.apache.wiki.api.core.Page)>(v);
goto label;
label:
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<com.amazonaws.services.kendra.model.QueryResultItem: java.lang.String getType()>();
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unknown query result type: %s", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
goto label;
label:
return v;
catch com.amazonaws.services.kendra.model.ThrottlingException from label to label with label;
}
public void initializeIndexAndDataSource()
{
java.lang.Object[] v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.IllegalArgumentException v, v;
org.apache.logging.log4j.Logger v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexName>;
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String getIndexId(java.lang.String)>(v);
v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId> = v;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId>;
if v != null goto label;
v = newarray (java.lang.Object)[1];
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexName>;
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Index \'%s\' does not exist", v);
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId>;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceName>;
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String getDatasourceId(java.lang.String,java.lang.String)>(v, v);
v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceId> = v;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceId>;
if v != null goto label;
v = newarray (java.lang.Object)[2];
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceName>;
v[0] = v;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexName>;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Datasource \'%s\' does not exist in index %s", v);
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private java.lang.String getIndexId(java.lang.String)
{
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.model.ListIndicesRequest v, v, v;
java.lang.String v, v, v, v, v;
boolean v, v, v;
com.amazonaws.services.kendra.model.ListIndicesResult v;
java.util.Iterator v;
com.amazonaws.services.kendra.AWSkendra v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: java.lang.String;
v = new com.amazonaws.services.kendra.model.ListIndicesRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.ListIndicesRequest: void <init>()>();
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.ListIndicesResult listIndices(com.amazonaws.services.kendra.model.ListIndicesRequest)>(v);
v = "";
label:
if v == null goto label;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListIndicesResult: java.util.List getIndexConfigurationSummaryItems()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
label:
return null;
label:
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.IndexConfigurationSummary: java.lang.String getName()>();
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean equals(java.lang.CharSequence,java.lang.CharSequence)>(v, v);
if v == 0 goto label;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.IndexConfigurationSummary: java.lang.String getId()>();
return v;
label:
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListIndicesResult: java.lang.String getNextToken()>();
v = new com.amazonaws.services.kendra.model.ListIndicesRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.ListIndicesRequest: void <init>()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListIndicesResult: java.lang.String getNextToken()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListIndicesRequest: com.amazonaws.services.kendra.model.ListIndicesRequest withNextToken(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.ListIndicesResult listIndices(com.amazonaws.services.kendra.model.ListIndicesRequest)>(v);
goto label;
label:
return null;
}
private java.lang.String getDatasourceId(java.lang.String, java.lang.String)
{
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.model.ListDataSourcesRequest v, v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v;
java.util.Iterator v;
com.amazonaws.services.kendra.AWSkendra v, v;
com.amazonaws.services.kendra.model.ListDataSourcesResult v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new com.amazonaws.services.kendra.model.ListDataSourcesRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.ListDataSourcesRequest: void <init>()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListDataSourcesRequest: com.amazonaws.services.kendra.model.ListDataSourcesRequest withIndexId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.ListDataSourcesResult listDataSources(com.amazonaws.services.kendra.model.ListDataSourcesRequest)>(v);
v = "";
label:
if v == null goto label;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListDataSourcesResult: java.util.List getSummaryItems()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
label:
return null;
label:
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.DataSourceSummary: java.lang.String getName()>();
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean equals(java.lang.CharSequence,java.lang.CharSequence)>(v, v);
if v == 0 goto label;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.DataSourceSummary: java.lang.String getId()>();
return v;
label:
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListDataSourcesResult: java.lang.String getNextToken()>();
v = new com.amazonaws.services.kendra.model.ListDataSourcesRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.ListDataSourcesRequest: void <init>()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListDataSourcesResult: java.lang.String getNextToken()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ListDataSourcesRequest: com.amazonaws.services.kendra.model.ListDataSourcesRequest withNextToken(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.ListDataSourcesResult listDataSources(com.amazonaws.services.kendra.model.ListDataSourcesRequest)>(v);
goto label;
label:
return null;
}
private int confidence2score(java.lang.String)
{
com.amazonaws.services.kendra.model.ScoreConfidence v;
int[] v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
int v, v;
java.lang.String v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: java.lang.String;
v = <org.apache.wiki.search.kendra.KendraSearchProvider$2: int[] $SwitchMap$com$amazonaws$services$kendra$model$ScoreConfidence>;
v = staticinvoke <com.amazonaws.services.kendra.model.ScoreConfidence: com.amazonaws.services.kendra.model.ScoreConfidence fromValue(java.lang.String)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ScoreConfidence: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
return 100;
label:
return 75;
label:
return 50;
label:
return 25;
label:
return 0;
}
private void doFullReindex() throws java.io.IOException
{
java.lang.Throwable v, v;
java.lang.Object[] v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.lang.Integer v;
int v;
java.lang.String v, v, v;
boolean v, v;
java.util.Iterator v;
java.util.Collection v;
java.io.IOException v;
org.apache.logging.log4j.Logger v, v;
org.apache.wiki.api.core.Engine v;
java.lang.Object v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
label:
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.wiki.api.core.Engine engine>;
v = interfaceinvoke v.<org.apache.wiki.api.core.Engine: java.lang.Object getManager(java.lang.Class)>(class "Lorg/apache/wiki/pages/PageManager;");
v = interfaceinvoke v.<org.apache.wiki.pages.PageManager: java.util.Collection getAllPages()>();
v = interfaceinvoke v.<java.util.Collection: boolean isEmpty()>();
if v == 0 goto label;
label:
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void stopExecution()>();
return;
label:
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<java.util.Collection: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Indexing all %d pages. Please wait ...", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void debug(java.lang.String)>(v);
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String startExecution()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void indexOnePage(org.apache.wiki.api.core.Page,java.lang.String)>(v, v);
goto label;
label:
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void stopExecution()>();
goto label;
label:
v := @caughtexception;
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = virtualinvoke v.<org.apache.wiki.api.exceptions.ProviderException: java.lang.String getMessage()>();
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void stopExecution()>();
throw v;
label:
return;
catch org.apache.wiki.api.exceptions.ProviderException from label to label with label;
catch org.apache.wiki.api.exceptions.ProviderException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private void doPartialReindex()
{
java.lang.Throwable v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.util.List v, v, v, v;
org.apache.logging.log4j.Logger v;
int v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.List updates>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
return;
label:
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
interfaceinvoke v.<org.apache.logging.log4j.Logger: void debug(java.lang.String)>("Indexing updated pages. Please wait ...");
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String startExecution()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.List updates>;
entermonitor v;
label:
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.List updates>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.List updates>;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void indexOnePage(org.apache.wiki.api.core.Page,java.lang.String)>(v, v);
goto label;
label:
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void stopExecution()>();
goto label;
label:
v := @caughtexception;
specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: void stopExecution()>();
throw v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private java.lang.String startExecution()
{
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.AWSkendra v;
com.amazonaws.services.kendra.model.StartDataSourceSyncJobResult v;
com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest v, v, v;
java.lang.String v, v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = new com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest: void <init>()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest: com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest withIndexId(java.lang.String)>(v);
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceId>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest: com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest withId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.StartDataSourceSyncJobResult startDataSourceSyncJob(com.amazonaws.services.kendra.model.StartDataSourceSyncJobRequest)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.StartDataSourceSyncJobResult: java.lang.String getExecutionId()>();
return v;
}
private void stopExecution()
{
com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest v, v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.AWSkendra v;
java.lang.String v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = new com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest: void <init>()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest: com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest withIndexId(java.lang.String)>(v);
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceId>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest: com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest withId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.StopDataSourceSyncJobResult stopDataSourceSyncJob(com.amazonaws.services.kendra.model.StopDataSourceSyncJobRequest)>(v);
return;
}
private void indexOnePage(org.apache.wiki.api.core.Page, java.lang.String)
{
boolean v;
com.amazonaws.services.kendra.model.BatchPutDocumentResult v;
com.amazonaws.services.kendra.AWSkendra v;
java.util.List v, v;
org.apache.logging.log4j.Logger v, v, v;
com.amazonaws.services.kendra.model.Document[] v;
com.amazonaws.services.kendra.model.BatchPutDocumentRequest v, v, v;
java.lang.Object[] v, v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.model.Document v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
java.util.Iterator v;
java.io.IOException v;
org.apache.wiki.api.core.Page v;
java.lang.Object v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: org.apache.wiki.api.core.Page;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<org.apache.wiki.api.core.Page: java.lang.String getName()>();
label:
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.model.Document newDocument(org.apache.wiki.api.core.Page,java.lang.String)>(v, v);
v = new com.amazonaws.services.kendra.model.BatchPutDocumentRequest;
specialinvoke v.<com.amazonaws.services.kendra.model.BatchPutDocumentRequest: void <init>()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexId>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchPutDocumentRequest: com.amazonaws.services.kendra.model.BatchPutDocumentRequest withIndexId(java.lang.String)>(v);
v = newarray (com.amazonaws.services.kendra.model.Document)[1];
v[0] = v;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchPutDocumentRequest: com.amazonaws.services.kendra.model.BatchPutDocumentRequest withDocuments(com.amazonaws.services.kendra.model.Document[])>(v);
v = virtualinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra getKendra()>();
v = interfaceinvoke v.<com.amazonaws.services.kendra.AWSkendra: com.amazonaws.services.kendra.model.BatchPutDocumentResult batchPutDocument(com.amazonaws.services.kendra.model.BatchPutDocumentRequest)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchPutDocumentResult: java.util.List getFailedDocuments()>();
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[2];
v = interfaceinvoke v.<org.apache.wiki.api.core.Page: java.lang.String getName()>();
v[0] = v;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.Document: java.lang.String getContentType()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Successfully indexed Page \'%s\' as %s", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void info(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchPutDocumentResult: java.util.List getFailedDocuments()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchPutDocumentResponseFailedDocument: java.lang.String getId()>();
v[0] = v;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.BatchPutDocumentResponseFailedDocument: java.lang.String getErrorMessage()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to index Page \'%s\': %s", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
goto label;
label:
v := @caughtexception;
v = <org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG>;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to index Page \'%s\': %s", v);
interfaceinvoke v.<org.apache.logging.log4j.Logger: void error(java.lang.String)>(v);
label:
return;
catch java.io.IOException from label to label with label;
}
private com.amazonaws.services.kendra.model.Document newDocument(org.apache.wiki.api.core.Page, java.lang.String) throws java.io.IOException
{
java.lang.Throwable v, v;
byte[] v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.model.Document v, v, v, v, v, v;
com.amazonaws.services.kendra.model.ContentType v;
java.nio.ByteBuffer v;
java.util.ArrayList v;
java.nio.charset.Charset v;
java.lang.String v, v, v, v, v, v;
boolean v;
com.amazonaws.services.kendra.model.DocumentAttribute v, v;
java.io.IOException v;
org.apache.wiki.api.core.Page v;
org.apache.wiki.api.core.Engine v, v;
java.lang.Object v, v;
java.io.InputStream v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: org.apache.wiki.api.core.Page;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<org.apache.wiki.api.core.Page: java.lang.String getName()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceId>;
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.model.DocumentAttribute newAttribute(java.lang.String,java.lang.String)>("_data_source_id", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.model.DocumentAttribute newAttribute(java.lang.String,java.lang.String)>("_data_source_sync_job_execution_id", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.wiki.util.TextUtil: java.lang.String beautifyString(java.lang.String)>(v);
v = <com.amazonaws.services.kendra.model.ContentType: com.amazonaws.services.kendra.model.ContentType PLAIN_TEXT>;
v = v instanceof org.apache.wiki.api.core.Attachment;
if v == 0 goto label;
v = null;
label:
v = interfaceinvoke v.<org.apache.wiki.api.core.Attachment: java.lang.String getFileName()>();
v = specialinvoke v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.model.ContentType getContentType(java.lang.String)>(v);
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.wiki.api.core.Engine engine>;
v = interfaceinvoke v.<org.apache.wiki.api.core.Engine: java.lang.Object getManager(java.lang.Class)>(class "Lorg/apache/wiki/attachment/AttachmentManager;");
v = interfaceinvoke v.<org.apache.wiki.attachment.AttachmentManager: java.io.InputStream getAttachmentStream(org.apache.wiki.api.core.Attachment)>(v);
v = staticinvoke <com.amazonaws.util.IOUtils: byte[] toByteArray(java.io.InputStream)>(v);
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
label:
staticinvoke <com.amazonaws.util.IOUtils: void closeQuietly(java.io.Closeable,org.apache.commons.logging.Log)>(v, null);
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
staticinvoke <com.amazonaws.util.IOUtils: void closeQuietly(java.io.Closeable,org.apache.commons.logging.Log)>(v, null);
throw v;
label:
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.wiki.api.core.Engine engine>;
v = interfaceinvoke v.<org.apache.wiki.api.core.Engine: java.lang.Object getManager(java.lang.Class)>(class "Lorg/apache/wiki/pages/PageManager;");
v = interfaceinvoke v.<org.apache.wiki.pages.PageManager: java.lang.String getPureText(org.apache.wiki.api.core.Page)>(v);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
label:
v = new com.amazonaws.services.kendra.model.Document;
specialinvoke v.<com.amazonaws.services.kendra.model.Document: void <init>()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.Document: com.amazonaws.services.kendra.model.Document withId(java.lang.String)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.Document: com.amazonaws.services.kendra.model.Document withTitle(java.lang.String)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.Document: com.amazonaws.services.kendra.model.Document withAttributes(java.util.Collection)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.Document: com.amazonaws.services.kendra.model.Document withBlob(java.nio.ByteBuffer)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.Document: com.amazonaws.services.kendra.model.Document withContentType(com.amazonaws.services.kendra.model.ContentType)>(v);
return v;
catch org.apache.wiki.api.exceptions.ProviderException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private com.amazonaws.services.kendra.model.DocumentAttribute newAttribute(java.lang.String, java.lang.String)
{
com.amazonaws.services.kendra.model.DocumentAttribute v, v, v;
com.amazonaws.services.kendra.model.DocumentAttributeValue v, v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
java.lang.String v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new com.amazonaws.services.kendra.model.DocumentAttribute;
specialinvoke v.<com.amazonaws.services.kendra.model.DocumentAttribute: void <init>()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.DocumentAttribute: com.amazonaws.services.kendra.model.DocumentAttribute withKey(java.lang.String)>(v);
v = new com.amazonaws.services.kendra.model.DocumentAttributeValue;
specialinvoke v.<com.amazonaws.services.kendra.model.DocumentAttributeValue: void <init>()>();
v = virtualinvoke v.<com.amazonaws.services.kendra.model.DocumentAttributeValue: com.amazonaws.services.kendra.model.DocumentAttributeValue withStringValue(java.lang.String)>(v);
v = virtualinvoke v.<com.amazonaws.services.kendra.model.DocumentAttribute: com.amazonaws.services.kendra.model.DocumentAttribute withValue(com.amazonaws.services.kendra.model.DocumentAttributeValue)>(v);
return v;
}
private com.amazonaws.services.kendra.model.ContentType getContentType(java.lang.String)
{
org.apache.wiki.search.kendra.KendraSearchProvider v;
com.amazonaws.services.kendra.model.ContentType v, v;
java.util.Map v;
java.lang.Object v, v;
java.lang.String v, v, v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.commons.io.FilenameUtils: java.lang.String getExtension(java.lang.String)>(v);
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.util.Map contentTypes>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("ContentTypes");
v = <com.amazonaws.services.kendra.model.ContentType: com.amazonaws.services.kendra.model.ContentType PLAIN_TEXT>;
v = virtualinvoke v.<com.amazonaws.services.kendra.model.ContentType: java.lang.String name()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object getOrDefault(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <com.amazonaws.services.kendra.model.ContentType: com.amazonaws.services.kendra.model.ContentType fromValue(java.lang.String)>(v);
return v;
}
public com.amazonaws.services.kendra.AWSkendra getKendra()
{
com.amazonaws.services.kendra.AWSkendra v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra kendra>;
return v;
}
public void setKendra(com.amazonaws.services.kendra.AWSkendra)
{
com.amazonaws.services.kendra.AWSkendra v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v := @parameter: com.amazonaws.services.kendra.AWSkendra;
v.<org.apache.wiki.search.kendra.KendraSearchProvider: com.amazonaws.services.kendra.AWSkendra kendra> = v;
return;
}
protected com.amazonaws.services.kendra.AWSkendra buildClient()
{
com.amazonaws.services.kendra.AWSkendra v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = staticinvoke <com.amazonaws.services.kendra.AWSkendraClientBuilder: com.amazonaws.services.kendra.AWSkendra defaultClient()>();
return v;
}
public java.lang.String getIndexName()
{
java.lang.String v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String indexName>;
return v;
}
public java.lang.String getDataSourceName()
{
java.lang.String v;
org.apache.wiki.search.kendra.KendraSearchProvider v;
v := @this: org.apache.wiki.search.kendra.KendraSearchProvider;
v = v.<org.apache.wiki.search.kendra.KendraSearchProvider: java.lang.String dataSourceName>;
return v;
}
static void <clinit>()
{
org.apache.logging.log4j.Logger v;
v = staticinvoke <org.apache.logging.log4j.LogManager: org.apache.logging.log4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/wiki/search/kendra/KendraSearchProvider;");
<org.apache.wiki.search.kendra.KendraSearchProvider: org.apache.logging.log4j.Logger LOG> = v;
return;
}
}