Hi,
I managed to post content to SOLR from Alfresco using command cURL.
http://curl.haxx.se/
Once content is approved under workflow, i am forming an XML using DOM parser & posting this well formed XML using cURL command.
Here is source for the same:
KMReviewProcessAction.java from where I am posting XML to SOLR.
XmlFormationBean.java forming XML.
This seems to be kind of workaround but at the same time i am looking for other better alternatives, if any.
I managed to post content to SOLR from Alfresco using command cURL.
http://curl.haxx.se/
Once content is approved under workflow, i am forming an XML using DOM parser & posting this well formed XML using cURL command.
Here is source for the same:
KMReviewProcessAction.java from where I am posting XML to SOLR.
/**
* Method to form XML to post to SOLR.
* @param nodeRef
*/
@SuppressWarnings("unchecked")
public void formSolrXml(NodeRef nodeRef){
logger.debug("Inside formSolrXml with noderef "+nodeRef);
Node contentNode = new Node(nodeRef);
String repoPath = Utils.generateURL(FacesContext.getCurrentInstance(), contentNode, URLMode.WEBDAV);
//logger.debug("repoPath "+repoPath);
String webdavUrl = alfServerIp+repoPath;
logger.debug("webdavUrl in formSolrXml() : "+webdavUrl);
String noderef = nodeRef.toString();
String[] tempNodeRef = noderef.split("SpacesStore/");
String contentUuid = tempNodeRef[1];
String curlPreSyntax = "curl ";
String curlPostSyntax = "/solr/update -F commit=true -F stream.file=@";
//Create an XML using XMLFormationBean & pass it to SOLR.
XmlFormationBean xmlFormationBean = new XmlFormationBean();
QName statusQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentStatus");
QName ownerQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}originalOwner");
QName ratingQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentRating");
QName nameQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}name");
QName coAuthorQname = QName.createQName("{{http://www.xxxx.com/model/km/content/1.0}coauthor");
QName titleQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}title");
QName descriptionQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}description");
QName authorQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}author");
String cName = nodeService.getProperty(nodeRef, nameQname).toString();
logger.debug("Content Name in formSolrXml : "+cName);
String cStatus = nodeService.getProperty(nodeRef, statusQname).toString();
logger.debug("Content Status in formSolrXml : "+cStatus);
String cOwner = nodeService.getProperty(nodeRef, ownerQname).toString();
logger.debug("Content Owner in formSolrXml : "+cOwner);
String cRating = nodeService.getProperty(nodeRef, ratingQname).toString();
logger.debug("Content Rating in formSolrXml : "+cRating);
String cCoAuthor = ".";
try{
cCoAuthor = nodeService.getProperty(nodeRef, coAuthorQname).toString();
}catch (NullPointerException e) {
cCoAuthor = ".";
}
logger.debug("Content CoAuthor in formSolrXml : "+cCoAuthor);
String cTitle = nodeService.getProperty(nodeRef, titleQname).toString();
logger.debug("Content Title in formSolrXml : "+cTitle);
String cDesc = ".";
try{
cDesc = nodeService.getProperty(nodeRef, descriptionQname).toString();
}catch (NullPointerException e) {
cDesc = ".";
}
logger.debug("Content Description in formSolrXml : "+cDesc);
String cAuthor = ".";
try{
cAuthor = nodeService.getProperty(nodeRef, authorQname).toString();
}catch (NullPointerException e) {
cAuthor = ".";
}
logger.debug("Content Author in formSolrXml : "+cAuthor);
String cType = getContentMimeType(nodeRef);
logger.debug("Content Type in formSolrXml : "+cType);
try{
Collection<NodeRef> categories = (Collection<NodeRef>)nodeService.getProperty(nodeRef, ContentModel.PROP_CATEGORIES);
Iterator itr11 = categories.iterator();
while(itr11.hasNext()){
NodeRef catNodeRef = (NodeRef) itr11.next();
String category = Repository.getNameForNode(nodeService, catNodeRef);
logger.debug("category name in formSolrXml : "+category);
categoryList.add(category);
}
}catch (NullPointerException e) {
logger.error("Error while retrieving categories in formSolrXml : "+e.getMessage());
}
//InputStream iStream = (InputStream) contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
contentService = services.getContentService();
ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
if (reader != null && reader.exists())
{
// get the transformer
ContentTransformer transformer = contentService.getTransformer(reader.getMimetype(), MimetypeMap.MIMETYPE_TEXT_PLAIN);
// is this transformer good enough?
if (transformer != null)
{
// We have a transformer that is fast enough
ContentWriter writer = contentService.getTempWriter();
writer.setMimetype(MimetypeMap.MIMETYPE_TEXT_PLAIN);
try
{
transformer.transform(reader, writer);
// point the reader to the new-written content
reader = writer.getReader();
// Check that the reader is a view onto something concrete
if (!reader.exists())
{
throw new ContentIOException("The transformation did not write any content, yet: \n"
+ " transformer: " + transformer + "\n" + " temp writer: " + writer);
}else {
content = reader.getContentString();
}
}
catch (ContentIOException e)
{
}
}
}
logger.debug("Content as a string for SOLR indexing !! : "+content);
//Forming XML.
String finalFileName = xmlFormationBean.formXmlFromContent(contentUuid,content, cType, cAuthor, cCoAuthor, cTitle, cOwner, categoryList, cDesc, cStatus, cRating, cName, solrFileLoc,webdavUrl);
logger.debug("finalFileName in KMReviewProcessAction : "+finalFileName);
//Deploying to SOLR.Check for content type.
String curlCommand = curlPreSyntax + solrServIp + curlPostSyntax;
if(cType.equalsIgnoreCase("application/pdf")){ //PDF
curlCommand += finalFileName;
logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
}else if(cType.equalsIgnoreCase("application/msword")){ // Word
curlCommand += finalFileName;
logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
}else if(cType.equalsIgnoreCase("application/vnd.excel")){ //Excel
curlCommand += finalFileName;
logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
}else if(cType.equalsIgnoreCase("application/vnd.powerpoint")){ // Powerpoint
curlCommand += finalFileName;
logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
}else if(cType.equalsIgnoreCase("text/plain")){ //Text
curlCommand += finalFileName;
logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
}else if(cType.equalsIgnoreCase("text/html")){ //HTML
curlCommand += finalFileName;
logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
}else if(cType.equalsIgnoreCase("text/xml")){ //XML
curlCommand += finalFileName;
logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
}
Runtime systemShell = Runtime.getRuntime();
try {
//Process output = systemShell.exec(curlCommand);
//int outputCode = output.exitValue();
systemShell.exec(curlCommand);
logger.debug("Curl command called correctly for : "+cName);
} catch (IOException e) {
logger.debug("Document named "+cName +" could not indexed");
e.printStackTrace();
}
}
XmlFormationBean.java forming XML.
public class XmlFormationBean {
private static final Log logger = LogFactory.getLog(XmlFormationBean.class);
private String add = "add";
private String doc = "doc";
private String field = "field";
private String fieldName = "name";
private String id = "id";
private String text = "text";
private String type = "content_type";
private String author = "author";
private String coAuthor = "coAuthor";
private String title = "title";
private String owner = "owner";
private String description = "description";
private String url = "link";
private String category = "category";
private String rating = "rating";
private String lastModified = "last_modified";
private String cdataStartTag = "<![CDATA[";
private String cdataEndTag = "]]>";
private String tilde = "~";
private String cap = "^";
// private String keywords = "keywords";
/**
* Method forming XML with passed parameters.
* It returns the full file path of XML to be posted to SOLR using cURL.
* Text content is tagged in <![CDATA[]]> tag for XML transformation.
*
* @param contentUuid
* @param passedContent
* @param contentType
* @param contentAuthor
* @param contentCoAuthor
* @param contentTitle
* @param contentOwner
* @param contentCategories
* @param contentDescription
* @param contentUrl
* @param contentStatus
* @param contentRating
* @param contentName
* @return fileNameToReturn.
*/
public String formXmlFromContent(String contentUuid, String passedContent,
String contentType, String contentAuthor, String contentCoAuthor,
String contentTitle, String contentOwner,
List<String> contentCategories, String contentDescription,
String contentStatus, String contentRating,
String contentName, String solrFileLoc, String webdavUrl) {
String nameOfContent = contentName;
String xmlExt = ".xml";
String forwardSlash = "/";
logger.debug("Inside formXmlFromContent() with nameOfContent : "
+ nameOfContent);
String fileNameToReturn = null;
String cleanContent = passedContent.replaceAll("\\P{ASCII}+", "");
try {
DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory
.newInstance();
DocumentBuilder docBuilder = docBuilderFactory.newDocumentBuilder();
Document document = docBuilder.newDocument();
Element rootElement = document.createElement(add);
Element docElement = document.createElement(doc);
Element idField = document.createElement(field);
idField.setAttribute(fieldName, id);
idField.appendChild(document.createTextNode(contentUuid));
docElement.appendChild(idField);
Element titleField = document.createElement(field);
titleField.setAttribute(fieldName, title);
titleField.appendChild(document.createTextNode(contentTitle));
docElement.appendChild(titleField);
Element descriptionField = document.createElement(field);
descriptionField.setAttribute(fieldName, description);
descriptionField.appendChild(document
.createTextNode(contentDescription));
docElement.appendChild(descriptionField);
Element authorField = document.createElement(field);
authorField.setAttribute(fieldName, author);
authorField.appendChild(document.createTextNode(contentAuthor));
docElement.appendChild(authorField);
Iterator<String> catItr = contentCategories.iterator();
while (catItr.hasNext()) {
String contentCategory = catItr.next();
logger.debug("contentCategory " + contentCategory);
Element categoryField = document.createElement(field);
categoryField.setAttribute(fieldName, category);
categoryField.appendChild(document
.createTextNode(contentCategory));
docElement.appendChild(categoryField);
}
Element typeField = document.createElement(field);
typeField.setAttribute(fieldName, type);
typeField.appendChild(document.createTextNode(getMimetypeForSolrSearch(contentType)));
docElement.appendChild(typeField);
Element coAuthorField = document.createElement(field);
coAuthorField.setAttribute(fieldName, coAuthor);
coAuthorField.appendChild(document.createTextNode(contentCoAuthor));
docElement.appendChild(coAuthorField);
Element contentField = document.createElement(field);
contentField.setAttribute(fieldName, text);
//CDATASection contentCdata = document.createCDATASection(passedContent);
//contentCdata.deleteData(contentCdata.get, count)
contentField.appendChild(document.createCDATASection(cleanContent));
docElement.appendChild(contentField);
//logger.debug("Content text : "+contentField.getTextContent());
Element lastModifiedField = document.createElement(field);
lastModifiedField.setAttribute(fieldName, lastModified);
lastModifiedField.appendChild(document
.createTextNode(getLastModifiedDate()));
docElement.appendChild(lastModifiedField);
/*
* Commented out for future. String docKeywords = " "; Element
* keywordsField = document.createElement(field);
* keywordsField.setAttribute(fieldName, keywords);
* keywordsField.appendChild(document.createTextNode(docKeywords));
* docElement.appendChild(keywordsField);
*/
Element ownerField = document.createElement(field);
ownerField.setAttribute(fieldName, owner);
ownerField.appendChild(document.createTextNode(contentOwner));
docElement.appendChild(ownerField);
Element ratingField = document.createElement(field);
ratingField.setAttribute(fieldName, rating);
ratingField.appendChild(document.createTextNode(contentRating));
docElement.appendChild(ratingField);
Element urlField = document.createElement(field);
urlField.setAttribute(fieldName, url);
urlField.appendChild(document.createTextNode(webdavUrl));
docElement.appendChild(urlField);
rootElement.appendChild(docElement);
document.appendChild(rootElement);
//Element contentText = document.getElementById("text");
//String tempContent = contentText.getTextContent();
//String cdataContent = cdataStartTag + tempContent +cdataEndTag;
//contentText.setTextContent(cdataContent);
DOMSource source = new DOMSource(document);
fileNameToReturn = solrFileLoc + forwardSlash + contentUuid + xmlExt;
File file = new File(fileNameToReturn);
Result result = new StreamResult(file);
Transformer xformer = TransformerFactory.newInstance()
.newTransformer();
xformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes");
xformer.setOutputProperty(OutputKeys.ENCODING, "UTF-16");
// xformer.setOutputProperty(OutputKeys.STANDALONE, "yes");
xformer.transform(source, result);
} catch (Exception e) {
logger.error("Error while forming XML in formXmlFromContent() : "
+ e.getMessage());
e.printStackTrace();
}
logger.debug("fileNameToReturn in formXmlFromContent() : " + fileNameToReturn);
return fileNameToReturn;
}
/**
* Method to get Last Modified date as per SOLR specified format i.e "yyyy-MM-dd'T'HH:mm:ss'Z'".
* @return formattedDate.
*/
public String getLastModifiedDate() {
// logger.debug("Inside getLastModifiedDate()");
Calendar lastModDate = Calendar.getInstance();
lastModDate.setTime(new Date());
SimpleDateFormat format = new SimpleDateFormat(
"yyyy-MM-dd'T'HH:mm:ss'Z'");
String formattedDate = format.format(lastModDate.getTime());
logger.debug("formattedDate in getLastModifiedDate() : "
+ formattedDate);
return formattedDate;
}
/**
* Method to get simplified Mimetype for a content to be indexed with SOLR.
* @param contentType
* @return simplified Mimetype.
*/
public String getMimetypeForSolrSearch(String contentType){
String result = null;
if(contentType.equalsIgnoreCase("application/pdf")){
result = "pdf";
}else if(contentType.equalsIgnoreCase("application/msword")){
result = "word";
}else if(contentType.equalsIgnoreCase("application/vnd.excel")){
result = "excel";
}else if(contentType.equalsIgnoreCase("application/vnd.powerpoint")){
result = "powerpoint";
}else if(contentType.equalsIgnoreCase("text/plain")){
result = "text";
}else if(contentType.equalsIgnoreCase("text/html")){
result = "html";
}else if(contentType.equalsIgnoreCase("text/xml")){
result = "xml";
}
logger.debug("Mimetype in getMimetpyeForSolr() " +result);
return result;
}
}
This seems to be kind of workaround but at the same time i am looking for other better alternatives, if any.
Hi Jan,
Thanks for you reply.
I got good amount of help from SOLRJ.Below is my utility for posting XML file to SOLR.
SolrPostContentUtility.java :
KMSolrSearchActionHandler.java invoking utility :
Thanks for you reply.
I got good amount of help from SOLRJ.Below is my utility for posting XML file to SOLR.
SolrPostContentUtility.java :
package com.xxxx.alfresco.km.bpm;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.StringReader;
import java.io.StringWriter;
import java.io.UnsupportedEncodingException;
import java.io.Writer;
import java.net.HttpURLConnection;
import java.net.ProtocolException;
import java.net.URL;
import org.apache.log4j.Logger;
import com.xxxx.alfresco.km.property.KmPropertyReader;
/**
* Utility class for posting XML file to SOLR server.
* For a given well-formed XML, it posts the data of file to
* SOLR server & get response back.
*/
public class SolrPostContentUtility {
private static Logger logger = Logger.getLogger(SolrPostContentUtility.class);
public static final String POST_ENCODING = "UTF-8";
private static final String SOLR_OK_RESPONSE_EXCERPT = "<int name=\"status\">0</int>";
private String solrServIp = null;
private URL solrUrl = null;
/**
* Constructs an instance for posting data to the specified SOLR URL.
*/
public SolrPostContentUtility() {
try{
KmPropertyReader kmPropertyReader = new KmPropertyReader();
solrServIp = kmPropertyReader.getProperty("solr.server.ip");
logger.debug("solrServIp in SolrPostContentUtility : "+solrServIp);
URL passedSolrUrl = new URL(solrServIp);
solrUrl = passedSolrUrl;
}catch (Exception e) {
logger.error("Error while reading property in SolrPostContentUtility : "+e.getMessage());
}
}
/**
* Method posting XML to SOLR & returning number of content posted successfully.
* @param fullyQldFileName
*/
public int postXmlToSolr(String fullyQldFileName){
int result = 0;//0 for normal & 1 for error.
logger.debug("Entering postXmlToSolr() with file name : "+fullyQldFileName);
try {
result = postFileToSolr(fullyQldFileName);
//Checking for response
if(result == 0){
logger.debug("Committing Solr index changes after successful posting of data.");
final StringWriter sw = new StringWriter();
commit(sw);
warnIfNotExpectedResponse(sw.toString(),SOLR_OK_RESPONSE_EXCERPT);
}else if(result == 1){
logger.error("Could not commit Solr index changes due to error.");
}
} catch(IOException ioe) {
logger.error("Unexpected IOException in postXmlToSolr() : " + ioe);
}
logger.debug("result in postXmlToSolr() : "+result);
return result;
}
/**
* Method to post XML file to SOLR.
* It takes file name & passes it with StringWriter object to postFile().
* @param fileName
* @return
* @throws IOException
*/
public int postFileToSolr(String fileName) throws IOException {
logger.debug("Entering postFileToSolr() with file name : "+fileName);
int result = 0;//0 for normal & 1 for error.
File srcFile = new File(fileName);
final StringWriter sw = new StringWriter();
if (srcFile.canRead()) {
//logger.debug("File name to be posted to SOLR server in postFileToSolr() : " + srcFile.getName());
result = postFile(srcFile, sw);
warnIfNotExpectedResponse(sw.toString(),SOLR_OK_RESPONSE_EXCERPT);
} else {
logger.error("Cannot read input file in postFileToSolr() : " + srcFile);
}
logger.debug("result in postFileToSolr() : "+result);
return result;
}
/**
* Opens the file and posts it's contents to the solrUrl,
* writes to response to output.
* XML should be formed using a real parser e.g. DOM & should be well-formed.
* @throws UnsupportedEncodingException
*/
public int postFile(File file, Writer output)
throws FileNotFoundException, UnsupportedEncodingException {
logger.debug("Entering postFile() ");
int result = 0;//0 for normal & 1 for error.
Reader reader = new InputStreamReader(new FileInputStream(file),POST_ENCODING);
try {
result = postDataToSolr(reader, output);
} finally {
try {
if(reader != null) reader.close();
} catch (IOException e) {
throw new PostException("IOException while closing file in postFile()", e);
}
}
logger.debug("result in postFile() : "+result);
return result;
}
/**
* Reads data from the data reader and posts it to solr,
* writes to the response to output
*/
public int postDataToSolr(Reader data, Writer output) {
logger.debug("Entering postDataToSolr() ");
HttpURLConnection urlc = null;
int result = 0; //0 for normal & 1 for error.
try {
urlc = (HttpURLConnection) solrUrl.openConnection();
try {
urlc.setRequestMethod("POST");
} catch (ProtocolException e) {
throw new PostException("Shouldn't happen: HttpURLConnection doesn't support POST??", e);
}
urlc.setDoOutput(true);
urlc.setDoInput(true);
urlc.setUseCaches(false);
urlc.setAllowUserInteraction(false);
urlc.setRequestProperty("Content-type", "text/xml; charset=" + POST_ENCODING);
OutputStream out = urlc.getOutputStream();
try {
Writer writer = new OutputStreamWriter(out, POST_ENCODING);
pipeDataToSolr(data, writer);
writer.close();
} catch (IOException e) {
result = 1;//error.
throw new PostException("IOException while posting data in postDataToSolr() ", e);
} finally {
if(out!=null) out.close();
}
InputStream in = urlc.getInputStream();
try {
Reader reader = new InputStreamReader(in);
pipeDataToSolr(reader, output);
reader.close();
} catch (IOException e) {
result = 1;//error.
throw new PostException("IOException while reading response in postDataToSolr()", e);
} finally {
if(in!=null) in.close();
}
} catch (IOException e) {
result = 1;//error.
try {
logger.error("Solr returned an error in postDataToSolr() : " + urlc.getResponseMessage());
} catch (IOException f) { }
logger.error("Connection error while connecting to SOLR server in postDataToSolr() : " + e);
} finally {
if(urlc != null){
urlc.disconnect();
}
}
logger.debug("result in postDataToSolr() : "+result);
return result;
}
/**
* Pipes everything from the reader to the writer via a buffer
*/
private static void pipeDataToSolr(Reader reader, Writer writer) throws IOException {
logger.debug("Entering pipeDataToSolr() ");
char[] buf = new char[1024];
int read = 0;
while ( (read = reader.read(buf) ) >= 0) {
writer.write(buf, 0, read);
}
writer.flush();
}
/**
* Custom Exception class for utility.
*/
private class PostException extends RuntimeException {
private static final long serialVersionUID = 1L;
PostException(String reason,Throwable cause) {
super(reason + " POST URL = " + solrUrl ,cause);
}
}
/** Check what SOLR replied to a POST, and complain if it's not what we expected.
* Parse the response and check it XMLwise, here we just check it as an unparsed String
*/
static void warnIfNotExpectedResponse(String actual,String expected) {
if(actual.indexOf(expected) < 0) {
logger.error("Unexpected response from Solr: '" + actual + "' does not contain '" + expected + "'");
}
}
/**
* Does a simple commit operation
*/
public void commit(Writer output) throws IOException {
logger.debug("Entering commit()");
postDataToSolr(new StringReader("<commit/>"), output);
}
}
KMSolrSearchActionHandler.java invoking utility :
package com.xxxx.alfresco.km.bpm;
import java.io.File;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import javax.faces.context.FacesContext;
import org.alfresco.model.ContentModel;
import org.alfresco.repo.content.MimetypeMap;
import org.alfresco.repo.content.transform.ContentTransformer;
import org.alfresco.repo.workflow.jbpm.JBPMSpringActionHandler;
import org.alfresco.service.ServiceRegistry;
import org.alfresco.service.cmr.repository.ContentData;
import org.alfresco.service.cmr.repository.ContentIOException;
import org.alfresco.service.cmr.repository.ContentReader;
import org.alfresco.service.cmr.repository.ContentService;
import org.alfresco.service.cmr.repository.ContentWriter;
import org.alfresco.service.cmr.repository.NodeRef;
import org.alfresco.service.cmr.repository.NodeService;
import org.alfresco.service.namespace.QName;
import org.alfresco.web.bean.repository.Node;
import org.alfresco.web.bean.repository.Repository;
import org.alfresco.web.ui.common.Utils;
import org.alfresco.web.ui.common.Utils.URLMode;
import org.apache.log4j.Logger;
import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.exe.ExecutionContext;
import org.springframework.beans.factory.BeanFactory;
import com.xxxx.alfresco.km.property.KmPropertyReader;
/**
* @author Lalit Jangra
* Class to handle SOLR integration with Alfresco.
* Once content is approved & moved back to original upload location,
* it will check for 'cm:contentStatus' property of content.
* If it is set to 'approved', another workflow named 'SolrSearchWF' is triggered.
* This workflow will extract all required metadata properties from content noderef &
* form an XML to be posted to SOLR along with content as text string.
* Finally XML will be posted to SOLR using SOLR Content Post Utility.
*/
public class KMSolrSearchActionHandler extends JBPMSpringActionHandler{
private static final long serialVersionUID = 1L;
private static Logger logger = Logger
.getLogger(KMSolrSearchActionHandler.class);
private String solrServIp = null;
private String solrFileLoc = null;
private String alfServerIp = null;
private NodeService nodeService;
private ServiceRegistry services;
ContentService contentService = null;
List<String> categoryList = null;
private String webdavUrl = null;
//private Collection<NodeRef> categories = null;
/**
* Method to initialize services.
*/
@Override
protected void initialiseHandler(BeanFactory factory) {
services = (ServiceRegistry) factory
.getBean(ServiceRegistry.SERVICE_REGISTRY);
nodeService = services.getNodeService();
contentService = services.getContentService();
}
/**
* Method calling formSolrXml() passing noderef of the content
* forming SOLR search specific XML.
*/
@Override
public void execute(ExecutionContext context) throws Exception {
logger.debug("Inside execute of KMSolrSearchActionHandler");
try{
KmPropertyReader kmPropertyReader = new KmPropertyReader();
solrServIp = kmPropertyReader.getProperty("solr.server.ip");
logger.debug("solrServIp in KMSolrSearchActionHandler : "+solrServIp);
solrFileLoc = kmPropertyReader.getProperty("solr.file.location");
logger.debug("solrFileLoc in KMSolrSearchActionHandler : "+solrFileLoc);
alfServerIp = kmPropertyReader.getProperty("alfresco.server.ip");
logger.debug("alfServerIp in KMSolrSearchActionHandler : "+alfServerIp);
}catch (Exception e) {
logger.error("Error while reading property in KMSolrSearchActionHandler : "+e.getMessage());
}
final ContextInstance contextInstance = context.getContextInstance();
NodeRef nodeRef = (NodeRef) contextInstance.getVariable("nodeRef");
//Forming SOLR XML.
formSolrXml(nodeRef);
}
/**
* Method to form XML to be posted to SOLR.
* Once well-formed XML is formed, it will call postSolrXML method to post
* the same XML to SOLR using Content Post Utility.
* @param nodeRef
*/
@SuppressWarnings("unchecked")
public void formSolrXml(NodeRef nodeRef){
logger.debug("Inside formSolrXml in KMSolrSearchActionHandler : "+nodeRef);
Node contentNode = new Node(nodeRef);
String repoPath = Utils.generateURL(FacesContext.getCurrentInstance(), contentNode, URLMode.WEBDAV);
//logger.debug("repoPath "+repoPath);
webdavUrl = alfServerIp+repoPath;
logger.debug("webdavUrl in formSolrXml() : "+webdavUrl);
String noderef = nodeRef.toString();
String[] tempNodeRef = noderef.split("SpacesStore/");
String contentUuid = tempNodeRef[1];
String category = "";
String content = "";
//Create an XML using XMLFormationBean & pass it to SOLR.
XmlFormationBean xmlFormationBean = new XmlFormationBean();
QName statusQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentStatus");
QName ownerQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}originalOwner");
QName ratingQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentRating");
QName nameQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}name");
QName coAuthorQname = QName.createQName("{{http://www.xxxx.com/model/km/content/1.0}coauthor");
QName titleQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}title");
QName descriptionQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}description");
QName authorQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}author");
// QName kTQName = QName.createQName("{http://www.alfresco.org/model/content/1.0}Knowledge Type");
// QName kPQName = QName.createQName("{http://www.alfresco.org/model/content/1.0}KP Domain");
// QName typeQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}content");
String cName = nodeService.getProperty(nodeRef, nameQname).toString();
logger.debug("Content Name in formSolrXml : "+cName);
String cStatus = nodeService.getProperty(nodeRef, statusQname).toString();
logger.debug("Content Status in formSolrXml : "+cStatus);
String cOwner = nodeService.getProperty(nodeRef, ownerQname).toString();
logger.debug("Content Owner in formSolrXml : "+cOwner);
String cRating = nodeService.getProperty(nodeRef, ratingQname).toString();
logger.debug("Content Rating in formSolrXml : "+cRating);
String cCoAuthor = "";
try{
cCoAuthor = nodeService.getProperty(nodeRef, coAuthorQname).toString();
}catch (NullPointerException e) {
logger.debug("Null CoAuthor in formSolrXml()");
}
logger.debug("Content CoAuthor in formSolrXml : "+cCoAuthor);
String cTitle = "";
try{
cTitle = nodeService.getProperty(nodeRef, titleQname).toString();
}catch (NullPointerException e) {
logger.debug("Null Title in formSolrXml()");
}
logger.debug("Content Title in formSolrXml : "+cTitle);
String cDesc = "";
try{
cDesc = nodeService.getProperty(nodeRef, descriptionQname).toString();
}catch (NullPointerException e) {
logger.debug("Null Description in formSolrXml()");
}
logger.debug("Content Description in formSolrXml : "+cDesc);
String cAuthor = "";
try{
cAuthor = nodeService.getProperty(nodeRef, authorQname).toString();
}catch (NullPointerException e) {
logger.debug("Null Author in formSolrXml()");
}
logger.debug("Content Author in formSolrXml : "+cAuthor);
String cType = getContentMimeType(nodeRef);
logger.debug("Content Mimetype in formSolrXml : "+cType);
try{
Collection<NodeRef> categories = (Collection<NodeRef>)nodeService.getProperty(nodeRef, ContentModel.PROP_CATEGORIES);
logger.debug("categories size : "+categories.size());
Iterator itr11 = categories.iterator();
categoryList = new ArrayList<String>();
while(itr11.hasNext()){
NodeRef catNodeRef = (NodeRef) itr11.next();
category = Repository.getNameForNode(nodeService, catNodeRef);
logger.debug("category name in formSolrXml : "+category);
categoryList.add(category);
logger.debug("categoryList size : "+categoryList.size());
}
}catch (NullPointerException e) {
logger.error("Null categories in formSolrXml() ");
}
//Transforming content to plain text format & extracting text from content as a string.
contentService = services.getContentService();
ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
if (reader != null && reader.exists())
{
// get the transformer
ContentTransformer transformer = contentService.getTransformer(reader.getMimetype(), MimetypeMap.MIMETYPE_TEXT_PLAIN);
if (transformer != null)
{
// We have a transformer that is fast enough
ContentWriter writer = contentService.getTempWriter();
writer.setMimetype(MimetypeMap.MIMETYPE_TEXT_PLAIN);
try
{
transformer.transform(reader, writer);
// point the reader to the new-written content
reader = writer.getReader();
// Check that the reader is a view onto something concrete
if (!reader.exists())
{
logger.error("Error while getting reader in KMSolrSearchActionHandler ");
throw new ContentIOException("The transformation did not write any content, yet: \n"
+ " transformer: " + transformer + "\n" + " temp writer: " + writer);
}else {
content = reader.getContentString();
}
}
catch (ContentIOException e)
{
logger.error("Error in transforming content : "+e.getMessage());
}
}
}
logger.debug("Length of content as a string for SOLR indexing !! : "+content.length());
//Forming well-formed SOLR search XML.
String finalFileName = xmlFormationBean.formXmlFromContent(contentUuid,content, cType, cAuthor, cCoAuthor, cTitle, cOwner, categoryList, cDesc, cStatus, cRating, cName, solrFileLoc,webdavUrl);
logger.debug("finalFileName in formSolrXml : "+finalFileName);
//Posting well-formed XML to SOLR server.
postSolrXML(finalFileName,cName,nodeRef);
}
/**
* Method to post well-formed XML to SOLR using content post utility.
* @param fileName
* @param contentName
*/
public void postSolrXML(String fullFileName,String contentName, NodeRef nodeRef){
logger.debug("Entering postSolrXML() with content to be posted to SOLR : "+contentName +" & fullFileName : "+fullFileName);
//Only if these is a non-null file, then it should be posted to SOLR.
File file = new File(fullFileName);
if(file.length() > 0){
try {
//Calling SolrPostContentUtility.
logger.debug("Posting content to SOLR using utility by passing fully qualified file name,if result is 0, it's OK . if it's 1, its error!");
SolrPostContentUtility utility = new SolrPostContentUtility();
int outCome = utility.postXmlToSolr(fullFileName);
//If outCome is 0, it is OK , if it is 1, it's error!
if(outCome == 0){
//Set km:underWorkflow to indexed for this content.
logger.debug("\n *************** Content named : "+contentName+" : successfully posted to SOLR. *************** \n");
logger.debug("\n *************** nodeRef of content posted successfully : " + nodeRef + " ***************");
logger.debug("\n *************** webdavUrl of content posted successfully : " + webdavUrl + " ***************");
QName underWorkflowQname = QName.createQName("{http://www.xxxx.com/model/km/content/1.0}underWorkflow");
String underWorkflowFlag = nodeService.getProperty(nodeRef, underWorkflowQname).toString();
logger.debug("km:underWorkflow set value in postSolrXML after post : "+underWorkflowFlag);
Map<QName, Serializable> propertyMap = nodeService.getProperties(nodeRef);
propertyMap.put(underWorkflowQname, "indexed");
nodeService.setProperties(nodeRef, propertyMap);
}else if(outCome == 1){
logger.error("\n *************** Content named : "+contentName +" : could NOT be posted successfully to SOLR. *************** \n");
}
} catch (Exception e) {
logger.debug("Error while posting file : "+e.getMessage());
e.printStackTrace();
}
}else{
logger.error("Null XML formed");
}
}
/**
* Method to get MimeType of a content passing it's nodeRef.
* @param nodeRef
* @return MimeType
*/
public String getContentMimeType(NodeRef nodeRef){
QName PROP_QNAME_CONTENT = QName.createQName("http://www.alfresco.org/model/content/1.0", "content");
ContentData contentData = (ContentData) nodeService.getProperty(nodeRef, PROP_QNAME_CONTENT);
String originalMimeType = contentData.getMimetype();
return originalMimeType;
}
}
