You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@marmotta.apache.org by ja...@apache.org on 2013/02/21 16:30:44 UTC
[52/55] MARMOTTA-106: renamed sesame-rio modules
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/21a28cf8/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParser.java
----------------------------------------------------------------------
diff --git a/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParser.java b/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParser.java
deleted file mode 100644
index 0797b43..0000000
--- a/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParser.java
+++ /dev/null
@@ -1,500 +0,0 @@
-/**
- * Copyright (C) 2013 Salzburg Research.
- *
- * 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 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 at.newmedialab.sesame.rio.ical;
-
-import com.google.common.base.Preconditions;
-import net.fortuna.ical4j.data.CalendarBuilder;
-import net.fortuna.ical4j.data.ParserException;
-import net.fortuna.ical4j.model.Calendar;
-import net.fortuna.ical4j.model.Property;
-import net.fortuna.ical4j.model.component.*;
-import net.fortuna.ical4j.model.property.*;
-import org.openrdf.model.Literal;
-import org.openrdf.model.Resource;
-import org.openrdf.model.URI;
-import org.openrdf.model.ValueFactory;
-import org.openrdf.model.impl.ValueFactoryImpl;
-import org.openrdf.rio.RDFFormat;
-import org.openrdf.rio.RDFHandlerException;
-import org.openrdf.rio.RDFParseException;
-import org.openrdf.rio.helpers.RDFParserBase;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import javax.xml.datatype.DatatypeConfigurationException;
-import javax.xml.datatype.DatatypeFactory;
-import javax.xml.datatype.XMLGregorianCalendar;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.Reader;
-import java.io.UnsupportedEncodingException;
-import java.net.URLDecoder;
-import java.text.SimpleDateFormat;
-import java.util.*;
-
-/**
- * A parser for parsing iCalendar (http://de.wikipedia.org/wiki/ICalendar) files into RDF format. Represents
- * data using the iCal vocabulary (http://www.w3.org/2002/12/cal/icaltzd,
- * http://www.w3.org/wiki/RdfCalendarDocumentation)
- * <p/>
- * Author: Sebastian Schaffert
- */
-public class ICalParser extends RDFParserBase {
- private static Logger log = LoggerFactory.getLogger(ICalParser.class);
-
- private final static SimpleDateFormat DF_DIGITS = new SimpleDateFormat("yyyyMMdd-hhmmss");
-
- public final static String NS_ICAL = "http://www.w3.org/2002/12/cal/icaltzd#";
- public static final String NS_RDF = "http://www.w3.org/1999/02/22-rdf-syntax-ns#";
- public static final String NS_GEO = "http://www.w3.org/2003/01/geo/wgs84_pos#";
-
-
- private ValueFactory valueFactory;
-
- /**
- * Creates a new RDFParserBase that will use a {@link org.openrdf.model.impl.ValueFactoryImpl} to
- * create RDF model objects.
- */
- public ICalParser() {
- this(new ValueFactoryImpl());
- }
-
- /**
- * Creates a new RDFParserBase that will use the supplied ValueFactory to
- * create RDF model objects.
- *
- * @param valueFactory A ValueFactory.
- */
- public ICalParser(ValueFactory valueFactory) {
- super(valueFactory);
- this.valueFactory = valueFactory;
- }
-
-
- @Override
- public void setValueFactory(ValueFactory valueFactory) {
- super.setValueFactory(valueFactory);
- this.valueFactory = valueFactory;
- }
-
- /**
- * Gets the RDF format that this parser can parse.
- */
- @Override
- public RDFFormat getRDFFormat() {
- return ICalFormat.FORMAT;
- }
-
- /**
- * Parses the data from the supplied InputStream, using the supplied baseURI
- * to resolve any relative URI references.
- *
- * @param in The InputStream from which to read the data.
- * @param baseURI The URI associated with the data in the InputStream.
- * @throws java.io.IOException If an I/O error occurred while data was read from the InputStream.
- * @throws org.openrdf.rio.RDFParseException
- * If the parser has found an unrecoverable parse error.
- * @throws org.openrdf.rio.RDFHandlerException
- * If the configured statement handler has encountered an
- * unrecoverable error.
- */
- @Override
- public void parse(InputStream in, String baseURI) throws IOException, RDFParseException, RDFHandlerException {
- Preconditions.checkNotNull(baseURI);
-
- setBaseURI(baseURI);
- try {
- parseCalendar(new CalendarBuilder().build(in));
- } catch (ParserException e) {
- throw new RDFParseException(e);
- }
- }
-
- /**
- * Parses the data from the supplied Reader, using the supplied baseURI to
- * resolve any relative URI references.
- *
- * @param reader The Reader from which to read the data.
- * @param baseURI The URI associated with the data in the InputStream.
- * @throws java.io.IOException If an I/O error occurred while data was read from the InputStream.
- * @throws org.openrdf.rio.RDFParseException
- * If the parser has found an unrecoverable parse error.
- * @throws org.openrdf.rio.RDFHandlerException
- * If the configured statement handler has encountered an
- * unrecoverable error.
- */
- @Override
- public void parse(Reader reader, String baseURI) throws IOException, RDFParseException, RDFHandlerException {
- Preconditions.checkNotNull(baseURI);
-
- setBaseURI(baseURI);
- try {
- parseCalendar(new CalendarBuilder().build(reader));
- } catch (ParserException e) {
- throw new RDFParseException(e);
- }
- }
-
-
- private void parseCalendar(Calendar calendar) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
- for(Object component : calendar.getComponents()) {
- if(component instanceof VEvent) {
- parseEvent((VEvent) component);
- } else if(component instanceof VJournal) {
- parseJournal((VJournal) component);
- } else if(component instanceof VAlarm) {
- parseAlarm((VAlarm) component);
- } else if(component instanceof VFreeBusy) {
- parseFreeBusy((VFreeBusy) component);
- } else if(component instanceof VToDo) {
- parseToDo((VToDo) component);
- }
- }
- }
-
- private void parseEvent(VEvent event) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
- log.debug("parsing event: {}", event.getUid());
- Resource r_event;
-
- String uriBase = "";
- if(event.getUid() != null) {
- uriBase = event.getUid().getValue();
- } else {
- uriBase = UUID.randomUUID().toString();
- }
- if(event.getRecurrenceId() != null) {
- uriBase += "-" + DF_DIGITS.format(event.getRecurrenceId().getDate());
- }
- if(event.getSequence() != null) {
- uriBase += "-"+event.getSequence().getSequenceNo();
- }
- r_event = resolveURI(uriBase);
-
-
- Resource t_vevent = createURI(NS_ICAL + "Vevent");
- URI p_type = createURI(NS_RDF + "type");
- rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
-
- parseCalendarComponent(event,r_event);
- }
-
- private void parseJournal(VJournal journal) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
- log.debug("parsing journal: {}", journal.getUid());
- Resource r_event;
- String uriBase = "";
- if(journal.getUid() != null) {
- uriBase = journal.getUid().getValue();
- } else {
- uriBase = UUID.randomUUID().toString();
- }
- if(journal.getRecurrenceId() != null) {
- uriBase += "-" + DF_DIGITS.format(journal.getRecurrenceId().getDate());
- }
- if(journal.getSequence() != null) {
- uriBase += "-"+journal.getSequence().getSequenceNo();
- }
- r_event = resolveURI(uriBase);
-
- Resource t_vevent = createURI(NS_ICAL + "Vjournal");
- URI p_type = createURI(NS_RDF + "type");
- rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
-
- parseCalendarComponent(journal,r_event);
- }
-
- private void parseAlarm(VAlarm alarm) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
- log.debug("parsing alarm");
- Resource r_event = resolveURI(UUID.randomUUID().toString());
-
-
- Resource t_vevent = createURI(NS_ICAL + "Valarm");
- URI p_type = createURI(NS_RDF + "type");
- rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
-
- parseCalendarComponent(alarm,r_event);
- }
-
- private void parseFreeBusy(VFreeBusy freeBusy) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
- log.debug("parsing free/busy: {}", freeBusy.getUid());
- Resource r_event;
- if(freeBusy.getUid() != null) {
- r_event = resolveURI(freeBusy.getUid().getValue());
- } else {
- r_event = resolveURI(UUID.randomUUID().toString());
- }
-
- Resource t_vevent = createURI(NS_ICAL + "Vfreebusy");
- URI p_type = createURI(NS_RDF + "type");
- rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
-
- parseCalendarComponent(freeBusy,r_event);
- }
-
- private void parseToDo(VToDo toDo) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
- log.debug("parsing todo: {}", toDo.getUid());
- Resource r_event;
- if(toDo.getUid() != null) {
- r_event = resolveURI(toDo.getUid().getValue());
- } else {
- r_event = resolveURI(UUID.randomUUID().toString());
- }
-
- Resource t_vevent = createURI(NS_ICAL + "Vtodo");
- URI p_type = createURI(NS_RDF + "type");
- rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
-
- parseCalendarComponent(toDo,r_event);
- }
-
- @SuppressWarnings("unchecked")
- private void parseCalendarComponent(CalendarComponent component, Resource resource) throws RDFHandlerException, RDFParseException, UnsupportedEncodingException {
- if(component.getProperty(Property.ATTACH) != null) {
- Attach attach = (Attach)component.getProperty(Property.ATTACH);
- if(attach.getUri() != null) {
- URI r_attach = createURI(URLDecoder.decode(attach.getUri().toString(),"UTF-8"));
- URI p_attach = createURI(NS_ICAL + "attach");
- rdfHandler.handleStatement(createStatement(resource,p_attach,r_attach));
- } else {
- log.warn("calendar entry: binary attachments not supported!");
- }
- }
-
-
- if(component.getProperty(Property.CATEGORIES) != null) {
- Categories categories = (Categories)component.getProperty(Property.CATEGORIES);
- URI p_categories = createURI(NS_ICAL + "categories");
- for(Iterator<String> it = categories.getCategories().iterator(); it.hasNext(); ) {
- String value = it.next();
- Literal v_categories = createLiteral(value,null,null);
- rdfHandler.handleStatement(createStatement(resource,p_categories,v_categories));
- }
- }
-
-
- createStringProperty(component,resource,Property.CLASS, NS_ICAL + "class");
- createStringProperty(component,resource,Property.COMMENT, NS_ICAL + "comment");
- createStringProperty(component,resource,Property.DESCRIPTION, NS_ICAL + "description");
-
- if(component.getProperty(Property.GEO) != null) {
- Geo geo = (Geo)component.getProperty(Property.GEO);
- URI p_geo = createURI(NS_ICAL + "geo");
- createLocation(resource, p_geo, geo);
- }
-
- createStringProperty(component,resource,Property.LOCATION, NS_ICAL + "location");
- createIntProperty(component,resource,Property.PERCENT_COMPLETE, NS_ICAL + "percentComplete");
- createIntProperty(component,resource,Property.PRIORITY, NS_ICAL + "priority");
-
- if(component.getProperty(Property.RESOURCES) != null) {
- Resources resources = (Resources)component.getProperty(Property.RESOURCES);
- URI p_resources = createURI(NS_ICAL + "resources");
- for(Iterator<String> it = resources.getResources().iterator(); it.hasNext(); ) {
- String value = it.next();
- Literal v_resources = createLiteral(value,null,null);
- rdfHandler.handleStatement(createStatement(resource,p_resources,v_resources));
- }
- }
-
- createStringProperty(component,resource,Property.STATUS, NS_ICAL + "status");
- createStringProperty(component,resource,Property.SUMMARY, NS_ICAL + "summary");
-
- createDateProperty((DateProperty)component.getProperty(Property.COMPLETED), resource, NS_ICAL + "completed");
- createDateProperty((DateProperty)component.getProperty(Property.DUE), resource, NS_ICAL + "due");
-
- createDateProperty((DateProperty)component.getProperty(Property.DTEND), resource, NS_ICAL + "dtend");
- createDateProperty((DateProperty)component.getProperty(Property.DTSTART), resource, NS_ICAL + "dtstart");
-
-
- if(component.getProperty(Property.DURATION) != null) {
- Duration duration = (Duration)component.getProperty(Property.DURATION);
- URI p_duration = createURI(NS_ICAL + "duration");
- try {
- javax.xml.datatype.Duration dur = DatatypeFactory.newInstance().newDuration(duration.getDuration().getTime(new Date(0)).getTime());
- Literal v_duration = createLiteral(dur.toString(),null, createURI(dur.getXMLSchemaType().toString()));
- rdfHandler.handleStatement(createStatement(resource,p_duration,v_duration));
- } catch (DatatypeConfigurationException e) {
- log.warn("calendar entry: error while parsing duration");
- }
-
- }
-
- createStringProperty(component,resource,Property.TRANSP, NS_ICAL + "transp");
-
- URI p_attendee = createURI(NS_ICAL + "attendee");
- for(Iterator<Property> it = component.getProperties(Property.ATTENDEE).iterator(); it.hasNext(); ) {
- Attendee attendee = (Attendee) it.next();
- if(attendee.getCalAddress() != null) {
- URI v_attendee = createURI(attendee.getCalAddress().toString());
- rdfHandler.handleStatement(createStatement(resource,p_attendee,v_attendee));
- } else {
- log.warn("attendee without calendar address: {}",attendee);
- }
- }
-
- createStringProperty(component,resource,Property.CONTACT, NS_ICAL + "contact");
-
- if(component.getProperty(Property.ORGANIZER) != null) {
- Organizer organizer = (Organizer) component.getProperty(Property.ORGANIZER);
- URI p_organizer = createURI(NS_ICAL + "organizer");
- if(organizer.getCalAddress() != null) {
- URI v_organizer = createURI(organizer.getCalAddress().toString());
- rdfHandler.handleStatement(createStatement(resource,p_organizer,v_organizer));
- }
- }
-
- createStringProperty(component,resource,Property.RELATED_TO, NS_ICAL + "relatedTo");
- createUrlProperty(component,resource,Property.URL, NS_ICAL + "url");
- createStringProperty(component,resource,Property.UID, NS_ICAL + "uid");
-
- for(Iterator<Property> it = component.getProperties(Property.EXDATE).iterator(); it.hasNext(); ) {
- createDateProperty(it.next(),resource, NS_ICAL + "exdate");
- }
- for(Iterator<Property> it = component.getProperties(Property.EXRULE).iterator(); it.hasNext(); ) {
- createStringProperty(it.next(),resource, NS_ICAL + "exrule");
- }
- for(Iterator<Property> it = component.getProperties(Property.RDATE).iterator(); it.hasNext(); ) {
- createDateProperty((DateProperty)it.next(),resource, NS_ICAL + "rdate");
- }
- for(Iterator<Property> it = component.getProperties(Property.RRULE).iterator(); it.hasNext(); ) {
- createStringProperty(it.next(),resource, NS_ICAL + "rrule");
- }
-
- if(component.getProperty(Property.TRIGGER) != null) {
- Trigger duration = (Trigger)component.getProperty(Property.TRIGGER);
- URI p_duration = createURI(NS_ICAL + "trigger");
- try {
- javax.xml.datatype.Duration dur = DatatypeFactory.newInstance().newDuration(duration.getDuration().getTime(new Date(0)).getTime());
- Literal v_duration = createLiteral(dur.toString(),null, createURI(dur.getXMLSchemaType().toString()));
- rdfHandler.handleStatement(createStatement(resource,p_duration,v_duration));
- } catch (DatatypeConfigurationException e) {
- log.warn("calendar entry: error while parsing duration");
- }
-
- }
-
- createDateProperty((DateProperty) component.getProperty(Property.CREATED), resource, NS_ICAL + "created");
- createDateProperty((DateProperty) component.getProperty(Property.DTSTAMP), resource, NS_ICAL + "dtstamp");
- createDateProperty((DateProperty) component.getProperty(Property.LAST_MODIFIED), resource, NS_ICAL + "lastModified");
-
- createDateProperty((DateProperty) component.getProperty(Property.RECURRENCE_ID), resource, NS_ICAL + "recurrenceId");
- createIntProperty(component,resource,Property.SEQUENCE, NS_ICAL + "sequence");
-
- createStringProperty(component,resource,Property.REQUEST_STATUS,NS_ICAL+"requestStatus");
-
- createStringProperty(component,resource,Property.ACTION,NS_ICAL+"action");
- createStringProperty(component,resource,Property.REPEAT,NS_ICAL+"repeat");
-
- }
-
-
- private void createLocation(Resource uri, URI prop, Geo geo) throws RDFHandlerException, RDFParseException {
- Resource r_location = createBNode();
- Resource t_adr = createURI(NS_GEO + "Point");
- URI p_type = createURI(NS_RDF + "type");
- rdfHandler.handleStatement(createStatement(r_location,p_type,t_adr));
-
- URI p_latitute = createURI(NS_GEO+"latitude");
- URI p_longitude = createURI(NS_GEO+"longitude");
- URI t_decimal = createURI("http://www.w3.org/2001/XMLSchema#double");
-
- if(geo.getLatitude() != null) {
- Literal v_latitude = createLiteral(geo.getLatitude().toPlainString(),null,t_decimal);
- rdfHandler.handleStatement(createStatement(r_location,p_latitute,v_latitude));
- }
-
- if(geo.getLongitude() != null) {
- Literal v_longitude = createLiteral(geo.getLongitude().toPlainString(), null, t_decimal);
- rdfHandler.handleStatement(createStatement(r_location,p_longitude,v_longitude));
- }
-
-
- rdfHandler.handleStatement(createStatement(uri,prop,r_location));
- }
-
- private void createStringProperty(CalendarComponent event, Resource r_event, String icalProperty, String rdfProperty) throws RDFParseException, RDFHandlerException {
- if(event.getProperty(icalProperty) != null) {
- Property description = event.getProperty(icalProperty);
- URI p_description = createURI(rdfProperty);
- Literal v_description = createLiteral(description.getValue(), null, null);
- rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
- }
- }
-
- private void createStringProperty(Property property, Resource r_event, String rdfProperty) throws RDFParseException, RDFHandlerException {
- if(property != null) {
- URI p_description = createURI(rdfProperty);
- Literal v_description = createLiteral(property.getValue(), null, null);
- rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
- }
- }
-
- private void createIntProperty(CalendarComponent event, Resource r_event, String icalProperty, String rdfProperty) throws RDFParseException, RDFHandlerException {
- if(event.getProperty(icalProperty) != null) {
- Property description = event.getProperty(icalProperty);
- URI p_description = createURI(rdfProperty);
- Literal v_description = createLiteral(description.getValue(), null, createURI("http://www.w3.org/2001/XMLSchema#int"));
- rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
- }
- }
-
- private void createDateProperty(Property property, Resource r_event, String rdfProperty) throws RDFParseException, RDFHandlerException {
- if(property != null) {
- if(property instanceof DateProperty) {
- DateProperty dateProperty = (DateProperty)property;
- URI p_dateprop = createURI(rdfProperty);
- Literal v_dateprop = valueFactory.createLiteral(getXMLCalendar(dateProperty.getDate(),dateProperty.getTimeZone()));
- rdfHandler.handleStatement(createStatement(r_event,p_dateprop,v_dateprop));
- } else if(property instanceof DateListProperty) {
- DateListProperty dateProperty = (DateListProperty)property;
- URI p_dateprop = createURI(rdfProperty);
- for(@SuppressWarnings("unchecked") Iterator<Date> it = dateProperty.getDates().iterator(); it.hasNext(); ) {
- Literal v_dateprop = valueFactory.createLiteral(getXMLCalendar(it.next(),dateProperty.getTimeZone()));
- rdfHandler.handleStatement(createStatement(r_event,p_dateprop,v_dateprop));
- }
- }
- }
- }
-
-
- private void createUrlProperty(CalendarComponent event, Resource r_event, String icalProperty, String rdfProperty) throws RDFParseException, RDFHandlerException {
- if(event.getProperty(icalProperty) != null) {
- Property description = event.getProperty(icalProperty);
- URI p_description = createURI(rdfProperty);
- URI v_description = createURI(description.getValue());
- rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
- }
- }
-
-
- public static Date getDate(XMLGregorianCalendar calendar) {
- return calendar.toGregorianCalendar().getTime();
- }
-
-
- public static XMLGregorianCalendar getXMLCalendar(Date date, TimeZone timezone) {
- GregorianCalendar c = new GregorianCalendar();
- c.setTime(date);
- if(timezone != null)
- c.setTimeZone(timezone);
- try {
- return DatatypeFactory.newInstance().newXMLGregorianCalendar(c);
- } catch (DatatypeConfigurationException e) {
- return null;
- }
- }
-
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/21a28cf8/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParserFactory.java
----------------------------------------------------------------------
diff --git a/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParserFactory.java b/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParserFactory.java
deleted file mode 100644
index f643d74..0000000
--- a/commons/sesame-tools-rio-ical/src/main/java/at/newmedialab/sesame/rio/ical/ICalParserFactory.java
+++ /dev/null
@@ -1,44 +0,0 @@
-/**
- * Copyright (C) 2013 Salzburg Research.
- *
- * 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 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 at.newmedialab.sesame.rio.ical;
-
-import org.openrdf.rio.RDFFormat;
-import org.openrdf.rio.RDFParser;
-import org.openrdf.rio.RDFParserFactory;
-
-/**
- * Add file description here!
- * <p/>
- * Author: Sebastian Schaffert
- */
-public class ICalParserFactory implements RDFParserFactory {
- /**
- * Returns the RDF format for this factory.
- */
- @Override
- public RDFFormat getRDFFormat() {
- return ICalFormat.FORMAT;
- }
-
- /**
- * Returns a RDFParser instance.
- */
- @Override
- public RDFParser getParser() {
- return new ICalParser();
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/21a28cf8/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParser.java
----------------------------------------------------------------------
diff --git a/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParser.java b/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParser.java
new file mode 100644
index 0000000..8e19b68
--- /dev/null
+++ b/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParser.java
@@ -0,0 +1,502 @@
+/**
+ * Copyright (C) 2013 Salzburg Research.
+ *
+ * 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 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.marmotta.commons.sesame.rio.ical;
+
+import com.google.common.base.Preconditions;
+import net.fortuna.ical4j.data.CalendarBuilder;
+import net.fortuna.ical4j.data.ParserException;
+import net.fortuna.ical4j.model.Calendar;
+import net.fortuna.ical4j.model.Property;
+import net.fortuna.ical4j.model.component.*;
+import net.fortuna.ical4j.model.property.*;
+
+import org.apache.marmotta.commons.sesame.rio.ical.ICalFormat;
+import org.openrdf.model.Literal;
+import org.openrdf.model.Resource;
+import org.openrdf.model.URI;
+import org.openrdf.model.ValueFactory;
+import org.openrdf.model.impl.ValueFactoryImpl;
+import org.openrdf.rio.RDFFormat;
+import org.openrdf.rio.RDFHandlerException;
+import org.openrdf.rio.RDFParseException;
+import org.openrdf.rio.helpers.RDFParserBase;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.xml.datatype.DatatypeConfigurationException;
+import javax.xml.datatype.DatatypeFactory;
+import javax.xml.datatype.XMLGregorianCalendar;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.Reader;
+import java.io.UnsupportedEncodingException;
+import java.net.URLDecoder;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * A parser for parsing iCalendar (http://de.wikipedia.org/wiki/ICalendar) files into RDF format. Represents
+ * data using the iCal vocabulary (http://www.w3.org/2002/12/cal/icaltzd,
+ * http://www.w3.org/wiki/RdfCalendarDocumentation)
+ * <p/>
+ * Author: Sebastian Schaffert
+ */
+public class ICalParser extends RDFParserBase {
+ private static Logger log = LoggerFactory.getLogger(ICalParser.class);
+
+ private final static SimpleDateFormat DF_DIGITS = new SimpleDateFormat("yyyyMMdd-hhmmss");
+
+ public final static String NS_ICAL = "http://www.w3.org/2002/12/cal/icaltzd#";
+ public static final String NS_RDF = "http://www.w3.org/1999/02/22-rdf-syntax-ns#";
+ public static final String NS_GEO = "http://www.w3.org/2003/01/geo/wgs84_pos#";
+
+
+ private ValueFactory valueFactory;
+
+ /**
+ * Creates a new RDFParserBase that will use a {@link org.openrdf.model.impl.ValueFactoryImpl} to
+ * create RDF model objects.
+ */
+ public ICalParser() {
+ this(new ValueFactoryImpl());
+ }
+
+ /**
+ * Creates a new RDFParserBase that will use the supplied ValueFactory to
+ * create RDF model objects.
+ *
+ * @param valueFactory A ValueFactory.
+ */
+ public ICalParser(ValueFactory valueFactory) {
+ super(valueFactory);
+ this.valueFactory = valueFactory;
+ }
+
+
+ @Override
+ public void setValueFactory(ValueFactory valueFactory) {
+ super.setValueFactory(valueFactory);
+ this.valueFactory = valueFactory;
+ }
+
+ /**
+ * Gets the RDF format that this parser can parse.
+ */
+ @Override
+ public RDFFormat getRDFFormat() {
+ return ICalFormat.FORMAT;
+ }
+
+ /**
+ * Parses the data from the supplied InputStream, using the supplied baseURI
+ * to resolve any relative URI references.
+ *
+ * @param in The InputStream from which to read the data.
+ * @param baseURI The URI associated with the data in the InputStream.
+ * @throws java.io.IOException If an I/O error occurred while data was read from the InputStream.
+ * @throws org.openrdf.rio.RDFParseException
+ * If the parser has found an unrecoverable parse error.
+ * @throws org.openrdf.rio.RDFHandlerException
+ * If the configured statement handler has encountered an
+ * unrecoverable error.
+ */
+ @Override
+ public void parse(InputStream in, String baseURI) throws IOException, RDFParseException, RDFHandlerException {
+ Preconditions.checkNotNull(baseURI);
+
+ setBaseURI(baseURI);
+ try {
+ parseCalendar(new CalendarBuilder().build(in));
+ } catch (ParserException e) {
+ throw new RDFParseException(e);
+ }
+ }
+
+ /**
+ * Parses the data from the supplied Reader, using the supplied baseURI to
+ * resolve any relative URI references.
+ *
+ * @param reader The Reader from which to read the data.
+ * @param baseURI The URI associated with the data in the InputStream.
+ * @throws java.io.IOException If an I/O error occurred while data was read from the InputStream.
+ * @throws org.openrdf.rio.RDFParseException
+ * If the parser has found an unrecoverable parse error.
+ * @throws org.openrdf.rio.RDFHandlerException
+ * If the configured statement handler has encountered an
+ * unrecoverable error.
+ */
+ @Override
+ public void parse(Reader reader, String baseURI) throws IOException, RDFParseException, RDFHandlerException {
+ Preconditions.checkNotNull(baseURI);
+
+ setBaseURI(baseURI);
+ try {
+ parseCalendar(new CalendarBuilder().build(reader));
+ } catch (ParserException e) {
+ throw new RDFParseException(e);
+ }
+ }
+
+
+ private void parseCalendar(Calendar calendar) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
+ for(Object component : calendar.getComponents()) {
+ if(component instanceof VEvent) {
+ parseEvent((VEvent) component);
+ } else if(component instanceof VJournal) {
+ parseJournal((VJournal) component);
+ } else if(component instanceof VAlarm) {
+ parseAlarm((VAlarm) component);
+ } else if(component instanceof VFreeBusy) {
+ parseFreeBusy((VFreeBusy) component);
+ } else if(component instanceof VToDo) {
+ parseToDo((VToDo) component);
+ }
+ }
+ }
+
+ private void parseEvent(VEvent event) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
+ log.debug("parsing event: {}", event.getUid());
+ Resource r_event;
+
+ String uriBase = "";
+ if(event.getUid() != null) {
+ uriBase = event.getUid().getValue();
+ } else {
+ uriBase = UUID.randomUUID().toString();
+ }
+ if(event.getRecurrenceId() != null) {
+ uriBase += "-" + DF_DIGITS.format(event.getRecurrenceId().getDate());
+ }
+ if(event.getSequence() != null) {
+ uriBase += "-"+event.getSequence().getSequenceNo();
+ }
+ r_event = resolveURI(uriBase);
+
+
+ Resource t_vevent = createURI(NS_ICAL + "Vevent");
+ URI p_type = createURI(NS_RDF + "type");
+ rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
+
+ parseCalendarComponent(event,r_event);
+ }
+
+ private void parseJournal(VJournal journal) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
+ log.debug("parsing journal: {}", journal.getUid());
+ Resource r_event;
+ String uriBase = "";
+ if(journal.getUid() != null) {
+ uriBase = journal.getUid().getValue();
+ } else {
+ uriBase = UUID.randomUUID().toString();
+ }
+ if(journal.getRecurrenceId() != null) {
+ uriBase += "-" + DF_DIGITS.format(journal.getRecurrenceId().getDate());
+ }
+ if(journal.getSequence() != null) {
+ uriBase += "-"+journal.getSequence().getSequenceNo();
+ }
+ r_event = resolveURI(uriBase);
+
+ Resource t_vevent = createURI(NS_ICAL + "Vjournal");
+ URI p_type = createURI(NS_RDF + "type");
+ rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
+
+ parseCalendarComponent(journal,r_event);
+ }
+
+ private void parseAlarm(VAlarm alarm) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
+ log.debug("parsing alarm");
+ Resource r_event = resolveURI(UUID.randomUUID().toString());
+
+
+ Resource t_vevent = createURI(NS_ICAL + "Valarm");
+ URI p_type = createURI(NS_RDF + "type");
+ rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
+
+ parseCalendarComponent(alarm,r_event);
+ }
+
+ private void parseFreeBusy(VFreeBusy freeBusy) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
+ log.debug("parsing free/busy: {}", freeBusy.getUid());
+ Resource r_event;
+ if(freeBusy.getUid() != null) {
+ r_event = resolveURI(freeBusy.getUid().getValue());
+ } else {
+ r_event = resolveURI(UUID.randomUUID().toString());
+ }
+
+ Resource t_vevent = createURI(NS_ICAL + "Vfreebusy");
+ URI p_type = createURI(NS_RDF + "type");
+ rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
+
+ parseCalendarComponent(freeBusy,r_event);
+ }
+
+ private void parseToDo(VToDo toDo) throws RDFParseException, RDFHandlerException, UnsupportedEncodingException {
+ log.debug("parsing todo: {}", toDo.getUid());
+ Resource r_event;
+ if(toDo.getUid() != null) {
+ r_event = resolveURI(toDo.getUid().getValue());
+ } else {
+ r_event = resolveURI(UUID.randomUUID().toString());
+ }
+
+ Resource t_vevent = createURI(NS_ICAL + "Vtodo");
+ URI p_type = createURI(NS_RDF + "type");
+ rdfHandler.handleStatement(createStatement(r_event,p_type,t_vevent));
+
+ parseCalendarComponent(toDo,r_event);
+ }
+
+ @SuppressWarnings("unchecked")
+ private void parseCalendarComponent(CalendarComponent component, Resource resource) throws RDFHandlerException, RDFParseException, UnsupportedEncodingException {
+ if(component.getProperty(Property.ATTACH) != null) {
+ Attach attach = (Attach)component.getProperty(Property.ATTACH);
+ if(attach.getUri() != null) {
+ URI r_attach = createURI(URLDecoder.decode(attach.getUri().toString(),"UTF-8"));
+ URI p_attach = createURI(NS_ICAL + "attach");
+ rdfHandler.handleStatement(createStatement(resource,p_attach,r_attach));
+ } else {
+ log.warn("calendar entry: binary attachments not supported!");
+ }
+ }
+
+
+ if(component.getProperty(Property.CATEGORIES) != null) {
+ Categories categories = (Categories)component.getProperty(Property.CATEGORIES);
+ URI p_categories = createURI(NS_ICAL + "categories");
+ for(Iterator<String> it = categories.getCategories().iterator(); it.hasNext(); ) {
+ String value = it.next();
+ Literal v_categories = createLiteral(value,null,null);
+ rdfHandler.handleStatement(createStatement(resource,p_categories,v_categories));
+ }
+ }
+
+
+ createStringProperty(component,resource,Property.CLASS, NS_ICAL + "class");
+ createStringProperty(component,resource,Property.COMMENT, NS_ICAL + "comment");
+ createStringProperty(component,resource,Property.DESCRIPTION, NS_ICAL + "description");
+
+ if(component.getProperty(Property.GEO) != null) {
+ Geo geo = (Geo)component.getProperty(Property.GEO);
+ URI p_geo = createURI(NS_ICAL + "geo");
+ createLocation(resource, p_geo, geo);
+ }
+
+ createStringProperty(component,resource,Property.LOCATION, NS_ICAL + "location");
+ createIntProperty(component,resource,Property.PERCENT_COMPLETE, NS_ICAL + "percentComplete");
+ createIntProperty(component,resource,Property.PRIORITY, NS_ICAL + "priority");
+
+ if(component.getProperty(Property.RESOURCES) != null) {
+ Resources resources = (Resources)component.getProperty(Property.RESOURCES);
+ URI p_resources = createURI(NS_ICAL + "resources");
+ for(Iterator<String> it = resources.getResources().iterator(); it.hasNext(); ) {
+ String value = it.next();
+ Literal v_resources = createLiteral(value,null,null);
+ rdfHandler.handleStatement(createStatement(resource,p_resources,v_resources));
+ }
+ }
+
+ createStringProperty(component,resource,Property.STATUS, NS_ICAL + "status");
+ createStringProperty(component,resource,Property.SUMMARY, NS_ICAL + "summary");
+
+ createDateProperty((DateProperty)component.getProperty(Property.COMPLETED), resource, NS_ICAL + "completed");
+ createDateProperty((DateProperty)component.getProperty(Property.DUE), resource, NS_ICAL + "due");
+
+ createDateProperty((DateProperty)component.getProperty(Property.DTEND), resource, NS_ICAL + "dtend");
+ createDateProperty((DateProperty)component.getProperty(Property.DTSTART), resource, NS_ICAL + "dtstart");
+
+
+ if(component.getProperty(Property.DURATION) != null) {
+ Duration duration = (Duration)component.getProperty(Property.DURATION);
+ URI p_duration = createURI(NS_ICAL + "duration");
+ try {
+ javax.xml.datatype.Duration dur = DatatypeFactory.newInstance().newDuration(duration.getDuration().getTime(new Date(0)).getTime());
+ Literal v_duration = createLiteral(dur.toString(),null, createURI(dur.getXMLSchemaType().toString()));
+ rdfHandler.handleStatement(createStatement(resource,p_duration,v_duration));
+ } catch (DatatypeConfigurationException e) {
+ log.warn("calendar entry: error while parsing duration");
+ }
+
+ }
+
+ createStringProperty(component,resource,Property.TRANSP, NS_ICAL + "transp");
+
+ URI p_attendee = createURI(NS_ICAL + "attendee");
+ for(Iterator<Property> it = component.getProperties(Property.ATTENDEE).iterator(); it.hasNext(); ) {
+ Attendee attendee = (Attendee) it.next();
+ if(attendee.getCalAddress() != null) {
+ URI v_attendee = createURI(attendee.getCalAddress().toString());
+ rdfHandler.handleStatement(createStatement(resource,p_attendee,v_attendee));
+ } else {
+ log.warn("attendee without calendar address: {}",attendee);
+ }
+ }
+
+ createStringProperty(component,resource,Property.CONTACT, NS_ICAL + "contact");
+
+ if(component.getProperty(Property.ORGANIZER) != null) {
+ Organizer organizer = (Organizer) component.getProperty(Property.ORGANIZER);
+ URI p_organizer = createURI(NS_ICAL + "organizer");
+ if(organizer.getCalAddress() != null) {
+ URI v_organizer = createURI(organizer.getCalAddress().toString());
+ rdfHandler.handleStatement(createStatement(resource,p_organizer,v_organizer));
+ }
+ }
+
+ createStringProperty(component,resource,Property.RELATED_TO, NS_ICAL + "relatedTo");
+ createUrlProperty(component,resource,Property.URL, NS_ICAL + "url");
+ createStringProperty(component,resource,Property.UID, NS_ICAL + "uid");
+
+ for(Iterator<Property> it = component.getProperties(Property.EXDATE).iterator(); it.hasNext(); ) {
+ createDateProperty(it.next(),resource, NS_ICAL + "exdate");
+ }
+ for(Iterator<Property> it = component.getProperties(Property.EXRULE).iterator(); it.hasNext(); ) {
+ createStringProperty(it.next(),resource, NS_ICAL + "exrule");
+ }
+ for(Iterator<Property> it = component.getProperties(Property.RDATE).iterator(); it.hasNext(); ) {
+ createDateProperty((DateProperty)it.next(),resource, NS_ICAL + "rdate");
+ }
+ for(Iterator<Property> it = component.getProperties(Property.RRULE).iterator(); it.hasNext(); ) {
+ createStringProperty(it.next(),resource, NS_ICAL + "rrule");
+ }
+
+ if(component.getProperty(Property.TRIGGER) != null) {
+ Trigger duration = (Trigger)component.getProperty(Property.TRIGGER);
+ URI p_duration = createURI(NS_ICAL + "trigger");
+ try {
+ javax.xml.datatype.Duration dur = DatatypeFactory.newInstance().newDuration(duration.getDuration().getTime(new Date(0)).getTime());
+ Literal v_duration = createLiteral(dur.toString(),null, createURI(dur.getXMLSchemaType().toString()));
+ rdfHandler.handleStatement(createStatement(resource,p_duration,v_duration));
+ } catch (DatatypeConfigurationException e) {
+ log.warn("calendar entry: error while parsing duration");
+ }
+
+ }
+
+ createDateProperty((DateProperty) component.getProperty(Property.CREATED), resource, NS_ICAL + "created");
+ createDateProperty((DateProperty) component.getProperty(Property.DTSTAMP), resource, NS_ICAL + "dtstamp");
+ createDateProperty((DateProperty) component.getProperty(Property.LAST_MODIFIED), resource, NS_ICAL + "lastModified");
+
+ createDateProperty((DateProperty) component.getProperty(Property.RECURRENCE_ID), resource, NS_ICAL + "recurrenceId");
+ createIntProperty(component,resource,Property.SEQUENCE, NS_ICAL + "sequence");
+
+ createStringProperty(component,resource,Property.REQUEST_STATUS,NS_ICAL+"requestStatus");
+
+ createStringProperty(component,resource,Property.ACTION,NS_ICAL+"action");
+ createStringProperty(component,resource,Property.REPEAT,NS_ICAL+"repeat");
+
+ }
+
+
+ private void createLocation(Resource uri, URI prop, Geo geo) throws RDFHandlerException, RDFParseException {
+ Resource r_location = createBNode();
+ Resource t_adr = createURI(NS_GEO + "Point");
+ URI p_type = createURI(NS_RDF + "type");
+ rdfHandler.handleStatement(createStatement(r_location,p_type,t_adr));
+
+ URI p_latitute = createURI(NS_GEO+"latitude");
+ URI p_longitude = createURI(NS_GEO+"longitude");
+ URI t_decimal = createURI("http://www.w3.org/2001/XMLSchema#double");
+
+ if(geo.getLatitude() != null) {
+ Literal v_latitude = createLiteral(geo.getLatitude().toPlainString(),null,t_decimal);
+ rdfHandler.handleStatement(createStatement(r_location,p_latitute,v_latitude));
+ }
+
+ if(geo.getLongitude() != null) {
+ Literal v_longitude = createLiteral(geo.getLongitude().toPlainString(), null, t_decimal);
+ rdfHandler.handleStatement(createStatement(r_location,p_longitude,v_longitude));
+ }
+
+
+ rdfHandler.handleStatement(createStatement(uri,prop,r_location));
+ }
+
+ private void createStringProperty(CalendarComponent event, Resource r_event, String icalProperty, String rdfProperty) throws RDFParseException, RDFHandlerException {
+ if(event.getProperty(icalProperty) != null) {
+ Property description = event.getProperty(icalProperty);
+ URI p_description = createURI(rdfProperty);
+ Literal v_description = createLiteral(description.getValue(), null, null);
+ rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
+ }
+ }
+
+ private void createStringProperty(Property property, Resource r_event, String rdfProperty) throws RDFParseException, RDFHandlerException {
+ if(property != null) {
+ URI p_description = createURI(rdfProperty);
+ Literal v_description = createLiteral(property.getValue(), null, null);
+ rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
+ }
+ }
+
+ private void createIntProperty(CalendarComponent event, Resource r_event, String icalProperty, String rdfProperty) throws RDFParseException, RDFHandlerException {
+ if(event.getProperty(icalProperty) != null) {
+ Property description = event.getProperty(icalProperty);
+ URI p_description = createURI(rdfProperty);
+ Literal v_description = createLiteral(description.getValue(), null, createURI("http://www.w3.org/2001/XMLSchema#int"));
+ rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
+ }
+ }
+
+ private void createDateProperty(Property property, Resource r_event, String rdfProperty) throws RDFParseException, RDFHandlerException {
+ if(property != null) {
+ if(property instanceof DateProperty) {
+ DateProperty dateProperty = (DateProperty)property;
+ URI p_dateprop = createURI(rdfProperty);
+ Literal v_dateprop = valueFactory.createLiteral(getXMLCalendar(dateProperty.getDate(),dateProperty.getTimeZone()));
+ rdfHandler.handleStatement(createStatement(r_event,p_dateprop,v_dateprop));
+ } else if(property instanceof DateListProperty) {
+ DateListProperty dateProperty = (DateListProperty)property;
+ URI p_dateprop = createURI(rdfProperty);
+ for(@SuppressWarnings("unchecked") Iterator<Date> it = dateProperty.getDates().iterator(); it.hasNext(); ) {
+ Literal v_dateprop = valueFactory.createLiteral(getXMLCalendar(it.next(),dateProperty.getTimeZone()));
+ rdfHandler.handleStatement(createStatement(r_event,p_dateprop,v_dateprop));
+ }
+ }
+ }
+ }
+
+
+ private void createUrlProperty(CalendarComponent event, Resource r_event, String icalProperty, String rdfProperty) throws RDFParseException, RDFHandlerException {
+ if(event.getProperty(icalProperty) != null) {
+ Property description = event.getProperty(icalProperty);
+ URI p_description = createURI(rdfProperty);
+ URI v_description = createURI(description.getValue());
+ rdfHandler.handleStatement(createStatement(r_event,p_description,v_description));
+ }
+ }
+
+
+ public static Date getDate(XMLGregorianCalendar calendar) {
+ return calendar.toGregorianCalendar().getTime();
+ }
+
+
+ public static XMLGregorianCalendar getXMLCalendar(Date date, TimeZone timezone) {
+ GregorianCalendar c = new GregorianCalendar();
+ c.setTime(date);
+ if(timezone != null)
+ c.setTimeZone(timezone);
+ try {
+ return DatatypeFactory.newInstance().newXMLGregorianCalendar(c);
+ } catch (DatatypeConfigurationException e) {
+ return null;
+ }
+ }
+
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/21a28cf8/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParserFactory.java
----------------------------------------------------------------------
diff --git a/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParserFactory.java b/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParserFactory.java
new file mode 100644
index 0000000..cbc14c4
--- /dev/null
+++ b/commons/sesame-tools-rio-ical/src/main/java/org/apache/marmotta/commons/sesame/rio/ical/ICalParserFactory.java
@@ -0,0 +1,45 @@
+/**
+ * Copyright (C) 2013 Salzburg Research.
+ *
+ * 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 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.marmotta.commons.sesame.rio.ical;
+
+import org.apache.marmotta.commons.sesame.rio.ical.ICalFormat;
+import org.openrdf.rio.RDFFormat;
+import org.openrdf.rio.RDFParser;
+import org.openrdf.rio.RDFParserFactory;
+
+/**
+ * Add file description here!
+ * <p/>
+ * Author: Sebastian Schaffert
+ */
+public class ICalParserFactory implements RDFParserFactory {
+ /**
+ * Returns the RDF format for this factory.
+ */
+ @Override
+ public RDFFormat getRDFFormat() {
+ return ICalFormat.FORMAT;
+ }
+
+ /**
+ * Returns a RDFParser instance.
+ */
+ @Override
+ public RDFParser getParser() {
+ return new ICalParser();
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/21a28cf8/commons/sesame-tools-rio-ical/src/main/resources/META-INF/services/org.openrdf.rio.RDFParserFactory
----------------------------------------------------------------------
diff --git a/commons/sesame-tools-rio-ical/src/main/resources/META-INF/services/org.openrdf.rio.RDFParserFactory b/commons/sesame-tools-rio-ical/src/main/resources/META-INF/services/org.openrdf.rio.RDFParserFactory
index 283ea04..2149311 100644
--- a/commons/sesame-tools-rio-ical/src/main/resources/META-INF/services/org.openrdf.rio.RDFParserFactory
+++ b/commons/sesame-tools-rio-ical/src/main/resources/META-INF/services/org.openrdf.rio.RDFParserFactory
@@ -1 +1 @@
-at.newmedialab.sesame.rio.ical.ICalParserFactory
\ No newline at end of file
+org.apache.marmotta.commons.sesame.rio.ical.ICalParserFactory
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/21a28cf8/commons/sesame-tools-rio-ical/src/test/java/TestICalParser.java
----------------------------------------------------------------------
diff --git a/commons/sesame-tools-rio-ical/src/test/java/TestICalParser.java b/commons/sesame-tools-rio-ical/src/test/java/TestICalParser.java
deleted file mode 100644
index b65b0da..0000000
--- a/commons/sesame-tools-rio-ical/src/test/java/TestICalParser.java
+++ /dev/null
@@ -1,99 +0,0 @@
-/*
- * Copyright (c) 2012 Salzburg Research.
- *
- * 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 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.
- */
-
-import static java.util.Arrays.asList;
-import static org.hamcrest.CoreMatchers.everyItem;
-import static org.hamcrest.CoreMatchers.notNullValue;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-import static org.junit.Assume.assumeThat;
-
-import at.newmedialab.sesame.rio.ical.ICalFormat;
-import org.apache.commons.io.IOUtils;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.openrdf.query.BooleanQuery;
-import org.openrdf.query.QueryLanguage;
-import org.openrdf.repository.Repository;
-import org.openrdf.repository.RepositoryConnection;
-import org.openrdf.repository.sail.SailRepository;
-import org.openrdf.sail.memory.MemoryStore;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.InputStream;
-import java.util.ArrayList;
-import java.util.Collection;
-
-/**
- * Add file description here!
- * <p/>
- * Author: Sebastian Schaffert
- */
-@RunWith(Parameterized.class)
-public class TestICalParser {
-
- private static Logger log = LoggerFactory.getLogger(TestICalParser.class);
-
- private String fileName;
-
- public TestICalParser(String fileName) {
- this.fileName = fileName;
- }
-
- @Parameterized.Parameters(name = "{0}")
- public static Collection<Object[]> data() {
- ArrayList<Object[]> list = new ArrayList<Object[]>();
- list.add(new Object[] { "kmt" });
- list.add(new Object[] { "vacation" });
- return list;
- }
-
-
-
- @Test
- public void runTest() throws Exception {
- log.info("running test {} ...", fileName);
-
- InputStream ical = this.getClass().getResourceAsStream("testfiles/"+fileName+".ics");
- InputStream sparql = this.getClass().getResourceAsStream("testfiles/"+fileName+".sparql");
- assumeThat("Could not load testfiles", asList(ical, sparql), everyItem(notNullValue(InputStream.class)));
-
- Repository repository = new SailRepository(new MemoryStore());
- repository.initialize();
-
- RepositoryConnection connection = repository.getConnection();
- try {
- connection.add(ical,"http://localhost/ical/", ICalFormat.FORMAT);
- connection.commit();
- } catch(Exception ex) {
- ex.printStackTrace();
- fail("parsing " + fileName + " failed!");
- }
- assertTrue(connection.size() > 0);
-
- int count = connection.getStatements(null, null, null, false).asList().size();
- assertTrue(count > 0);
-
- BooleanQuery sparqlQuery = (BooleanQuery)connection.prepareQuery(QueryLanguage.SPARQL, IOUtils.toString(sparql));
- assertTrue("SPARQL query evaluation for "+fileName+" failed",sparqlQuery.evaluate());
-
- connection.close();
- repository.shutDown();
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/21a28cf8/commons/sesame-tools-rio-ical/src/test/java/org/apache/marmotta/commons/sesame/rio/ical/TestICalParser.java
----------------------------------------------------------------------
diff --git a/commons/sesame-tools-rio-ical/src/test/java/org/apache/marmotta/commons/sesame/rio/ical/TestICalParser.java b/commons/sesame-tools-rio-ical/src/test/java/org/apache/marmotta/commons/sesame/rio/ical/TestICalParser.java
new file mode 100644
index 0000000..ee6bdd8
--- /dev/null
+++ b/commons/sesame-tools-rio-ical/src/test/java/org/apache/marmotta/commons/sesame/rio/ical/TestICalParser.java
@@ -0,0 +1,100 @@
+package org.apache.marmotta.commons.sesame.rio.ical;
+/*
+ * Copyright (c) 2012 Salzburg Research.
+ *
+ * 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 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.
+ */
+
+import static java.util.Arrays.asList;
+import static org.hamcrest.CoreMatchers.everyItem;
+import static org.hamcrest.CoreMatchers.notNullValue;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+import static org.junit.Assume.assumeThat;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.marmotta.commons.sesame.rio.ical.ICalFormat;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+import org.openrdf.query.BooleanQuery;
+import org.openrdf.query.QueryLanguage;
+import org.openrdf.repository.Repository;
+import org.openrdf.repository.RepositoryConnection;
+import org.openrdf.repository.sail.SailRepository;
+import org.openrdf.sail.memory.MemoryStore;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.Collection;
+
+/**
+ * Add file description here!
+ * <p/>
+ * Author: Sebastian Schaffert
+ */
+@RunWith(Parameterized.class)
+public class TestICalParser {
+
+ private static Logger log = LoggerFactory.getLogger(TestICalParser.class);
+
+ private String fileName;
+
+ public TestICalParser(String fileName) {
+ this.fileName = fileName;
+ }
+
+ @Parameterized.Parameters(name = "{0}")
+ public static Collection<Object[]> data() {
+ ArrayList<Object[]> list = new ArrayList<Object[]>();
+ list.add(new Object[] { "kmt" });
+ list.add(new Object[] { "vacation" });
+ return list;
+ }
+
+
+
+ @Test
+ public void runTest() throws Exception {
+ log.info("running test {} ...", fileName);
+
+ InputStream ical = this.getClass().getResourceAsStream(fileName+".ics");
+ InputStream sparql = this.getClass().getResourceAsStream(fileName+".sparql");
+ assumeThat("Could not load testfiles", asList(ical, sparql), everyItem(notNullValue(InputStream.class)));
+
+ Repository repository = new SailRepository(new MemoryStore());
+ repository.initialize();
+
+ RepositoryConnection connection = repository.getConnection();
+ try {
+ connection.add(ical,"http://localhost/ical/", ICalFormat.FORMAT);
+ connection.commit();
+ } catch(Exception ex) {
+ ex.printStackTrace();
+ fail("parsing " + fileName + " failed!");
+ }
+ assertTrue(connection.size() > 0);
+
+ int count = connection.getStatements(null, null, null, false).asList().size();
+ assertTrue(count > 0);
+
+ BooleanQuery sparqlQuery = (BooleanQuery)connection.prepareQuery(QueryLanguage.SPARQL, IOUtils.toString(sparql));
+ assertTrue("SPARQL query evaluation for "+fileName+" failed",sparqlQuery.evaluate());
+
+ connection.close();
+ repository.shutDown();
+ }
+
+}