won.protocol.util.linkeddata

Class WonLinkedDataUtils

java.lang.Object

won.protocol.util.linkeddata.WonLinkedDataUtils

public class WonLinkedDataUtils
extends java.lang.Object

Utilitiy functions for common linked data lookups.

Constructor Summary

Constructors

Constructor and Description
WonLinkedDataUtils()

Method Summary

Modifier and Type	Method and Description
static java.util.Optional<java.net.URI>	extractLDPNextPageLinkFromLinkHeaders(java.util.List<java.lang.String> linkHeaders) Extracts the next page link from a list of HTTP 'Link' headers returned by an LDP container.
static java.util.Optional<java.net.URI>	extractLDPPrevPageLinkFromLinkHeaders(java.util.List<java.lang.String> linkHeaders) Extracts the prev page link from a list of HTTP 'Link' headers returned by an LDP container.
static java.util.Optional<WonNodeInfo>	findWonNode(java.net.URI someURI, java.util.Optional<java.net.URI> requesterWebID, LinkedDataSource linkedDataSource)
static java.util.Optional<java.net.URI>	getAtomOfSocket(java.net.URI socketURI, LinkedDataSource linkedDataSource)
static java.net.URI	getAtomURIforConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.util.Set<RdfUtils.Pair<java.net.URI>>	getCompatibleSocketsForAtoms(LinkedDataSource linkedDataSource, java.net.URI firstAtom, java.net.URI secondAtom) Executes WonRdfUtils.SocketUtils#getCompatibleSocketsForAtoms after crawling the required data.
static java.util.Optional<Connection>	getConnectionForConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.util.Optional<Connection>	getConnectionForIncomingMessage(WonMessage wonMessage, LinkedDataSource linkedDataSource)
static java.util.Optional<Connection>	getConnectionForOutgoingMessage(WonMessage wonMessage, LinkedDataSource linkedDataSource)
static org.apache.jena.query.Dataset	getConnectionNetwork(java.net.URI atomURI, LinkedDataSource linkedDataSource) Crawls all connections of the specified atom without messages.
static java.net.URI	getConnectionStateforConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.util.Optional<java.net.URI>	getConnectionURIForIncomingMessage(WonMessage wonMessage, LinkedDataSource linkedDataSource)
static java.util.Optional<java.net.URI>	getConnectionURIForOutgoingMessage(WonMessage wonMessage, LinkedDataSource linkedDataSource)
static java.util.Optional<java.net.URI>	getConnectionURIForSocketAndTargetSocket(java.net.URI socket, java.net.URI targetSocket, LinkedDataSource linkedDataSource)
static org.apache.jena.query.Dataset	getConversationAndAtomsDataset(java.lang.String connectionURI, LinkedDataSource linkedDataSource)
static org.apache.jena.query.Dataset	getConversationAndAtomsDataset(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static org.apache.jena.query.Dataset	getConversationDataset(java.lang.String connectionURI, LinkedDataSource linkedDataSource)
static org.apache.jena.query.Dataset	getConversationDataset(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static org.apache.jena.query.Dataset	getDataForResource(java.net.URI resourceURI, LinkedDataSource linkedDataSource)
static DatasetResponseWithStatusCodeAndHeaders	getDataForResourceWithHeaders(java.net.URI resourceURI, org.springframework.http.HttpHeaders headers, LinkedDataSource linkedDataSource)
static java.util.Optional<java.net.URI>	getDefaultSocket(java.net.URI atomURI, boolean returnAnyIfNoDefaultFound, LinkedDataSource linkedDataSource)
static org.apache.jena.query.Dataset	getFullAtomDataset(java.net.URI atomURI, LinkedDataSource linkedDataSource)
static java.util.Set<RdfUtils.Pair<java.net.URI>>	getIncompatibleSocketsForAtoms(LinkedDataSource linkedDataSource, java.net.URI firstAtom, java.net.URI secondAtom)
static java.net.URI	getMessageContainerURIforAtomURI(java.net.URI atomURI, LinkedDataSource linkedDataSource)
static java.net.URI	getMessageContainerURIforConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.util.Iterator<org.apache.jena.query.Dataset>	getModelForURIs(java.util.Iterator<java.net.URI> uriIterator, LinkedDataSource linkedDataSource)
static java.util.List<java.net.URI>	getNodeAtomUris(java.net.URI nodeURI, LinkedDataSource linkedDataSource)
static java.util.List<java.net.URI>	getNodeAtomUris(java.net.URI nodeURI, java.time.ZonedDateTime modifiedAfter, java.time.ZonedDateTime createdAfter, AtomState atomState, java.net.URI filterBySocketTypeUri, java.net.URI filterByAtomTypeUri, LinkedDataSource linkedDataSource)
static LDPContainerPage<java.util.List<java.net.URI>>	getNodeAtomUrisPage(java.net.URI nodeURI, java.time.ZonedDateTime modifiedAfter, java.time.ZonedDateTime createdAfter, AtomState atomState, java.net.URI filterBySocketTypeUri, java.net.URI filterByAtomTypeUri, java.lang.Integer page, java.lang.Integer pageSize, LinkedDataSource linkedDataSource) Fetch pageSize atoms with specified restrictions, starting at page page.
static LDPContainerPage<java.util.List<java.net.URI>>	getNodeAtomUrisPageAfter(java.net.URI nodeURI, java.time.ZonedDateTime modifiedAfter, java.time.ZonedDateTime createdAfter, AtomState atomState, java.net.URI filterBySocketTypeUri, java.net.URI filterByAtomTypeUri, java.net.URI resumeAfter, int pageSize, LinkedDataSource linkedDataSource) Fetch pageSize atoms with specified restrictions, starting after the specified atom resumeAfter.
static org.apache.jena.graph.Node	getPropertyForURI(java.net.URI resourceURI, org.apache.jena.sparql.path.Path propertyPath, LinkedDataSource linkedDataSource) For the specified URI, the model is fetched and the specified property path is evaluated in that graph, starting at the specified URI.
static java.util.Optional<SocketDefinition>	getSocketDefinition(LinkedDataSource linkedDataSource, java.net.URI socketDefinitionURI)
static java.util.Optional<SocketDefinition>	getSocketDefinitionOfSocket(LinkedDataSource linkedDataSource, java.net.URI socket)
static java.util.Collection<java.net.URI>	getSocketsOfType(java.net.URI atomURI, java.net.URI socketTypeURI, LinkedDataSource linkedDataSource)
static java.net.URI	getSocketURIForConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.net.URI	getTargetAtomURIforConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.net.URI	getTargetConnectionURIforConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.net.URI	getTargetSocketURIForConnectionURI(java.net.URI connectionURI, LinkedDataSource linkedDataSource)
static java.util.Optional<java.net.URI>	getTypeOfSocket(java.net.URI socketURI, LinkedDataSource linkedDataSource)
static java.util.Optional<WonNodeInfo>	getWonNodeInfo(java.net.URI wonNodeUri, LinkedDataSource linkedDataSource)
static org.apache.jena.graph.Node	getWonNodePropertyForAtomOrConnectionURI(java.net.URI resourceURI, org.apache.jena.sparql.path.Path propertyPath, LinkedDataSource linkedDataSource) For the specified atom or connection URI, the model is fetched, the WON node URI found there is also de-referenced, and the specified property path is evaluated in that graph, starting at the WON node URI.
static java.net.URI	getWonNodeURIForAtomOrConnection(java.net.URI resourceURI, org.apache.jena.query.Dataset resourceDataset)
static java.net.URI	getWonNodeURIForAtomOrConnection(java.net.URI resURI, org.apache.jena.rdf.model.Model resourceModel)
static java.net.URI	getWonNodeURIForAtomOrConnectionURI(java.net.URI resourceURI, LinkedDataSource linkedDataSource)
static boolean	isCompatibleSockets(LinkedDataSource linkedDataSource, java.net.URI firstSocket, java.net.URI secondSocket)
static org.apache.jena.query.Dataset	loadDataForAtomWithSocketDefinitions(LinkedDataSource linkedDataSource, java.net.URI atomURI)
static org.apache.jena.query.Dataset	loadDataForSocket(LinkedDataSource linkedDataSource, java.net.URI socket)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WonLinkedDataUtils

public WonLinkedDataUtils()

Method Detail

getConnectionStateforConnectionURI

public static java.net.URI getConnectionStateforConnectionURI(java.net.URI connectionURI,
                                                              LinkedDataSource linkedDataSource)

getConnectionURIForIncomingMessage

public static java.util.Optional<java.net.URI> getConnectionURIForIncomingMessage(WonMessage wonMessage,
                                                                                  LinkedDataSource linkedDataSource)

getConnectionURIForOutgoingMessage

public static java.util.Optional<java.net.URI> getConnectionURIForOutgoingMessage(WonMessage wonMessage,
                                                                                  LinkedDataSource linkedDataSource)

getConnectionForIncomingMessage

public static java.util.Optional<Connection> getConnectionForIncomingMessage(WonMessage wonMessage,
                                                                             LinkedDataSource linkedDataSource)

getConnectionForOutgoingMessage

public static java.util.Optional<Connection> getConnectionForOutgoingMessage(WonMessage wonMessage,
                                                                             LinkedDataSource linkedDataSource)

getConnectionForConnectionURI

public static java.util.Optional<Connection> getConnectionForConnectionURI(java.net.URI connectionURI,
                                                                           LinkedDataSource linkedDataSource)

getAtomURIforConnectionURI

public static java.net.URI getAtomURIforConnectionURI(java.net.URI connectionURI,
                                                      LinkedDataSource linkedDataSource)

getTargetConnectionURIforConnectionURI

public static java.net.URI getTargetConnectionURIforConnectionURI(java.net.URI connectionURI,
                                                                  LinkedDataSource linkedDataSource)

getTargetAtomURIforConnectionURI

public static java.net.URI getTargetAtomURIforConnectionURI(java.net.URI connectionURI,
                                                            LinkedDataSource linkedDataSource)

getMessageContainerURIforConnectionURI

public static java.net.URI getMessageContainerURIforConnectionURI(java.net.URI connectionURI,
                                                                  LinkedDataSource linkedDataSource)

getSocketURIForConnectionURI

public static java.net.URI getSocketURIForConnectionURI(java.net.URI connectionURI,
                                                        LinkedDataSource linkedDataSource)

getTargetSocketURIForConnectionURI

public static java.net.URI getTargetSocketURIForConnectionURI(java.net.URI connectionURI,
                                                              LinkedDataSource linkedDataSource)

getMessageContainerURIforAtomURI

public static java.net.URI getMessageContainerURIforAtomURI(java.net.URI atomURI,
                                                            LinkedDataSource linkedDataSource)

getConversationAndAtomsDataset

public static org.apache.jena.query.Dataset getConversationAndAtomsDataset(java.lang.String connectionURI,
                                                                           LinkedDataSource linkedDataSource)

getNodeAtomUris

public static java.util.List<java.net.URI> getNodeAtomUris(java.net.URI nodeURI,
                                                           LinkedDataSource linkedDataSource)

getNodeAtomUris

public static java.util.List<java.net.URI> getNodeAtomUris(java.net.URI nodeURI,
                                                           java.time.ZonedDateTime modifiedAfter,
                                                           java.time.ZonedDateTime createdAfter,
                                                           AtomState atomState,
                                                           java.net.URI filterBySocketTypeUri,
                                                           java.net.URI filterByAtomTypeUri,
                                                           LinkedDataSource linkedDataSource)

getNodeAtomUrisPage

public static LDPContainerPage<java.util.List<java.net.URI>> getNodeAtomUrisPage(java.net.URI nodeURI,
                                                                                 java.time.ZonedDateTime modifiedAfter,
                                                                                 java.time.ZonedDateTime createdAfter,
                                                                                 AtomState atomState,
                                                                                 java.net.URI filterBySocketTypeUri,
                                                                                 java.net.URI filterByAtomTypeUri,
                                                                                 java.lang.Integer page,
                                                                                 java.lang.Integer pageSize,
                                                                                 LinkedDataSource linkedDataSource)

Fetch pageSize atoms with specified restrictions, starting at page page.

Parameters:

nodeURI -

modifiedAfter -

createdAfter -

atomState -

filterBySocketTypeUri -

filterByAtomTypeUri -

linkedDataSource -

page - the page index, 1-based

pageSize -

Returns:

getNodeAtomUrisPageAfter

public static LDPContainerPage<java.util.List<java.net.URI>> getNodeAtomUrisPageAfter(java.net.URI nodeURI,
                                                                                      java.time.ZonedDateTime modifiedAfter,
                                                                                      java.time.ZonedDateTime createdAfter,
                                                                                      AtomState atomState,
                                                                                      java.net.URI filterBySocketTypeUri,
                                                                                      java.net.URI filterByAtomTypeUri,
                                                                                      java.net.URI resumeAfter,
                                                                                      int pageSize,
                                                                                      LinkedDataSource linkedDataSource)

Fetch pageSize atoms with specified restrictions, starting after the specified atom resumeAfter.

Parameters:

nodeURI -

modifiedAfter -

createdAfter -

atomState -

filterBySocketTypeUri -

filterByAtomTypeUri -

resumeAfter - the next link URI as returned by the container. Must start with the node URI.

pageSize -

linkedDataSource -

Returns:

getFullAtomDataset

public static org.apache.jena.query.Dataset getFullAtomDataset(java.net.URI atomURI,
                                                               LinkedDataSource linkedDataSource)

getConversationAndAtomsDataset

public static org.apache.jena.query.Dataset getConversationAndAtomsDataset(java.net.URI connectionURI,
                                                                           LinkedDataSource linkedDataSource)

findWonNode

public static java.util.Optional<WonNodeInfo> findWonNode(java.net.URI someURI,
                                                          java.util.Optional<java.net.URI> requesterWebID,
                                                          LinkedDataSource linkedDataSource)

getConversationDataset

public static org.apache.jena.query.Dataset getConversationDataset(java.lang.String connectionURI,
                                                                   LinkedDataSource linkedDataSource)

getConversationDataset

public static org.apache.jena.query.Dataset getConversationDataset(java.net.URI connectionURI,
                                                                   LinkedDataSource linkedDataSource)

getDataForResource

public static org.apache.jena.query.Dataset getDataForResource(java.net.URI resourceURI,
                                                               LinkedDataSource linkedDataSource)

getDataForResourceWithHeaders

public static DatasetResponseWithStatusCodeAndHeaders getDataForResourceWithHeaders(java.net.URI resourceURI,
                                                                                    org.springframework.http.HttpHeaders headers,
                                                                                    LinkedDataSource linkedDataSource)

getModelForURIs

public static java.util.Iterator<org.apache.jena.query.Dataset> getModelForURIs(java.util.Iterator<java.net.URI> uriIterator,
                                                                                LinkedDataSource linkedDataSource)

getWonNodeInfo

public static java.util.Optional<WonNodeInfo> getWonNodeInfo(java.net.URI wonNodeUri,
                                                             LinkedDataSource linkedDataSource)

getWonNodeURIForAtomOrConnectionURI

public static java.net.URI getWonNodeURIForAtomOrConnectionURI(java.net.URI resourceURI,
                                                               LinkedDataSource linkedDataSource)

getWonNodeURIForAtomOrConnection

public static java.net.URI getWonNodeURIForAtomOrConnection(java.net.URI resURI,
                                                            org.apache.jena.rdf.model.Model resourceModel)

getWonNodeURIForAtomOrConnection

public static java.net.URI getWonNodeURIForAtomOrConnection(java.net.URI resourceURI,
                                                            org.apache.jena.query.Dataset resourceDataset)

getWonNodePropertyForAtomOrConnectionURI

public static org.apache.jena.graph.Node getWonNodePropertyForAtomOrConnectionURI(java.net.URI resourceURI,
                                                                                  org.apache.jena.sparql.path.Path propertyPath,
                                                                                  LinkedDataSource linkedDataSource)

For the specified atom or connection URI, the model is fetched, the WON node URI found there is also de-referenced, and the specified property path is evaluated in that graph, starting at the WON node URI.

Parameters:

resourceURI -

propertyPath -

linkedDataSource -

Returns:

getPropertyForURI

public static org.apache.jena.graph.Node getPropertyForURI(java.net.URI resourceURI,
                                                           org.apache.jena.sparql.path.Path propertyPath,
                                                           LinkedDataSource linkedDataSource)

For the specified URI, the model is fetched and the specified property path is evaluated in that graph, starting at the specified URI.

Parameters:

resourceURI -

propertyPath -

linkedDataSource -

Returns:

getDefaultSocket

public static java.util.Optional<java.net.URI> getDefaultSocket(java.net.URI atomURI,
                                                                boolean returnAnyIfNoDefaultFound,
                                                                LinkedDataSource linkedDataSource)

getSocketsOfType

public static java.util.Collection<java.net.URI> getSocketsOfType(java.net.URI atomURI,
                                                                  java.net.URI socketTypeURI,
                                                                  LinkedDataSource linkedDataSource)

getCompatibleSocketsForAtoms

public static java.util.Set<RdfUtils.Pair<java.net.URI>> getCompatibleSocketsForAtoms(LinkedDataSource linkedDataSource,
                                                                                      java.net.URI firstAtom,
                                                                                      java.net.URI secondAtom)

Executes WonRdfUtils.SocketUtils#getCompatibleSocketsForAtoms after crawling the required data.

Parameters:

linkedDataSource -

firstAtom -

secondAtom -

Returns:

set of pairs, the first member belonging to the firstAtom, the second to the secondAtom

getIncompatibleSocketsForAtoms

public static java.util.Set<RdfUtils.Pair<java.net.URI>> getIncompatibleSocketsForAtoms(LinkedDataSource linkedDataSource,
                                                                                        java.net.URI firstAtom,
                                                                                        java.net.URI secondAtom)

isCompatibleSockets

public static boolean isCompatibleSockets(LinkedDataSource linkedDataSource,
                                          java.net.URI firstSocket,
                                          java.net.URI secondSocket)

loadDataForAtomWithSocketDefinitions

public static org.apache.jena.query.Dataset loadDataForAtomWithSocketDefinitions(LinkedDataSource linkedDataSource,
                                                                                 java.net.URI atomURI)

loadDataForSocket

public static org.apache.jena.query.Dataset loadDataForSocket(LinkedDataSource linkedDataSource,
                                                              java.net.URI socket)

getSocketDefinitionOfSocket

public static java.util.Optional<SocketDefinition> getSocketDefinitionOfSocket(LinkedDataSource linkedDataSource,
                                                                               java.net.URI socket)

getSocketDefinition

public static java.util.Optional<SocketDefinition> getSocketDefinition(LinkedDataSource linkedDataSource,
                                                                       java.net.URI socketDefinitionURI)

getTypeOfSocket

public static java.util.Optional<java.net.URI> getTypeOfSocket(java.net.URI socketURI,
                                                               LinkedDataSource linkedDataSource)

getAtomOfSocket

public static java.util.Optional<java.net.URI> getAtomOfSocket(java.net.URI socketURI,
                                                               LinkedDataSource linkedDataSource)

getConnectionNetwork

public static org.apache.jena.query.Dataset getConnectionNetwork(java.net.URI atomURI,
                                                                 LinkedDataSource linkedDataSource)

Crawls all connections of the specified atom without messages.

getConnectionURIForSocketAndTargetSocket

public static java.util.Optional<java.net.URI> getConnectionURIForSocketAndTargetSocket(java.net.URI socket,
                                                                                        java.net.URI targetSocket,
                                                                                        LinkedDataSource linkedDataSource)

extractLDPPrevPageLinkFromLinkHeaders

public static java.util.Optional<java.net.URI> extractLDPPrevPageLinkFromLinkHeaders(java.util.List<java.lang.String> linkHeaders)

Extracts the prev page link from a list of HTTP 'Link' headers returned by an LDP container.

Parameters:

linkHeaders -

Returns:

See Also:

https://www.w3.org/TR/ldp-paging/#ldpp-ex-paging-other-links

extractLDPNextPageLinkFromLinkHeaders

public static java.util.Optional<java.net.URI> extractLDPNextPageLinkFromLinkHeaders(java.util.List<java.lang.String> linkHeaders)

Extracts the next page link from a list of HTTP 'Link' headers returned by an LDP container.

Parameters:

linkHeaders -

Returns:

See Also:

https://www.w3.org/TR/ldp-paging/#ldpp-ex-paging-other-links