Package org.linkedopenactors.rdfpub.store.rdf4j

Class ActivityPubStoreDefault

java.lang.Object

org.linkedopenactors.rdfpub.store.rdf4j.ActivityPubStoreDefault

All Implemented Interfaces:

ActivityPubStore

public class ActivityPubStoreDefault
extends Object
implements ActivityPubStore

Constructor Summary

Constructors

Constructor	Description
ActivityPubStoreDefault(org.apache.commons.rdf.api.RDF rdf, org.apache.commons.rdf.api.IRI storeOwnerSubject, Store store, ActivityPubObjectFactory activityPubObjectFactory, Vocabularies vocabularies)

Method Summary

Modifier and Type	Method	Description
void	add(Set<org.apache.commons.rdf.api.Triple> newTriples, String logMsg)
void	add(ActivityPubObject ao1, String logMsg)
void	addCollectionItem(CollectionInfo collectionInfo, org.apache.commons.rdf.api.IRI item, String logMsg)
org.apache.commons.rdf.api.Graph	dump(org.apache.commons.rdf.api.IRI graphName)
Optional<ActivityPubObject>	find(org.apache.commons.rdf.api.IRI subject)
Optional<ActivityPubObject>	find(org.apache.commons.rdf.api.IRI subject, int deep)	Searches for the ActivityPubObject with the passed subject.
Optional<ActivityPubObject>	find(org.apache.commons.rdf.api.IRI subject, org.apache.commons.rdf.api.IRI predicate, org.apache.commons.rdf.api.RDFTerm object)	Searches for the ActivityPubObject that matches the passed triple.
Set<ActivityPubObject>	find(org.apache.commons.rdf.api.IRI predicate, org.apache.commons.rdf.api.RDFTerm object)	Finds all subjects that match the passed predicate/object.
Set<ActivityPubObject>	findAll(Set<org.apache.commons.rdf.api.IRI> subjectsParam)	Find object with the passed subjects in the actors store.
Set<ActivityPubObject>	findAll(Set<org.apache.commons.rdf.api.IRI> subjectsParam, int deep)	Find object with the passed subjects in the actors store and resolve dependencies up to the passed depth.
Set<PersistableRdfPubCollection>	findCollection(org.apache.commons.rdf.api.IRI member)	Searches for Collections, where the passed member is a member of.
Optional<ActivityPubObject>	findLatestRevision(org.apache.commons.rdf.api.IRI pointerSubject)
Optional<ActivityPubObject>	findWholeGraph(org.apache.commons.rdf.api.IRI subject)	ATTENTION!! This reads the whole grap of the actor !
OrderedCollectionPage	getCollection(Collection<org.apache.commons.rdf.api.IRI> irisToResolve, org.apache.commons.rdf.api.IRI namedGraphToUse, Integer pageSize, Integer startIndex, Integer deep)
List<org.apache.commons.rdf.api.IRI>	getCollection(CollectionInfo collectionInfo)
Set<org.apache.commons.rdf.api.BlankNodeOrIRI>	getGraphNames()
org.apache.commons.rdf.api.IRI	getOwner()
void	update(ActivityPubObject ao1, String logMsg)

Methods inherited from class java.lang.Object

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

Constructor Details

ActivityPubStoreDefault

public ActivityPubStoreDefault(org.apache.commons.rdf.api.RDF rdf,
 org.apache.commons.rdf.api.IRI storeOwnerSubject,
 Store store,
 ActivityPubObjectFactory activityPubObjectFactory,
 Vocabularies vocabularies)

Method Details

add

public void add(ActivityPubObject ao1,
 String logMsg)

Specified by:

add in interface ActivityPubStore

add

public void add(Set<org.apache.commons.rdf.api.Triple> newTriples,
 String logMsg)

Specified by:

add in interface ActivityPubStore

update

public void update(ActivityPubObject ao1,
 String logMsg)

Specified by:

update in interface ActivityPubStore

addCollectionItem

public void addCollectionItem(CollectionInfo collectionInfo,
 org.apache.commons.rdf.api.IRI item,
 String logMsg)

Specified by:

addCollectionItem in interface ActivityPubStore

getCollection

public List<org.apache.commons.rdf.api.IRI> getCollection(CollectionInfo collectionInfo)

Specified by:

getCollection in interface ActivityPubStore

getCollection

public OrderedCollectionPage getCollection(Collection<org.apache.commons.rdf.api.IRI> irisToResolve,
 org.apache.commons.rdf.api.IRI namedGraphToUse,
 Integer pageSize,
 Integer startIndex,
 Integer deep)

Specified by:

getCollection in interface ActivityPubStore

findCollection

public Set<PersistableRdfPubCollection> findCollection(org.apache.commons.rdf.api.IRI member)

Description copied from interface: ActivityPubStore

Searches for Collections, where the passed member is a member of.

Specified by:

findCollection in interface ActivityPubStore

Parameters:

member -

Returns:

List of Collections, where the passed member is a member of.

find

public Optional<ActivityPubObject> find(org.apache.commons.rdf.api.IRI subject)

Specified by:

find in interface ActivityPubStore

find

public Optional<ActivityPubObject> find(org.apache.commons.rdf.api.IRI subject,
 int deep)

Description copied from interface: ActivityPubStore

Searches for the ActivityPubObject with the passed subject.

Specified by:

find in interface ActivityPubStore

Parameters:

subject -

deep - up to which hierarchy level should object references be resolved ?

Returns:

found ActivityPubObject.

find

public Optional<ActivityPubObject> find(org.apache.commons.rdf.api.IRI subject,
 org.apache.commons.rdf.api.IRI predicate,
 org.apache.commons.rdf.api.RDFTerm object)

Description copied from interface: ActivityPubStore

Searches for the ActivityPubObject that matches the passed triple.

Specified by:

find in interface ActivityPubStore

Parameters:

subject -

predicate -

object -

Returns:

found ActivityPubObject.

find

public Set<ActivityPubObject> find(org.apache.commons.rdf.api.IRI predicate,
 org.apache.commons.rdf.api.RDFTerm object)

Description copied from interface: ActivityPubStore

Finds all subjects that match the passed predicate/object.

Specified by:

find in interface ActivityPubStore

Parameters:

predicate -

object -

Returns:

Set of ActivityPubObjects that contains the predicate/object. NOTE the ActivityPubObjects have only one predicate!

findAll

public Set<ActivityPubObject> findAll(Set<org.apache.commons.rdf.api.IRI> subjectsParam)

Description copied from interface: ActivityPubStore

Find object with the passed subjects in the actors store.

Specified by:

findAll in interface ActivityPubStore

Parameters:

subjectsParam - Subjects to search for.

Returns:

Found ActivityPubObjects

findAll

public Set<ActivityPubObject> findAll(Set<org.apache.commons.rdf.api.IRI> subjectsParam,
 int deep)

Description copied from interface: ActivityPubStore

Find object with the passed subjects in the actors store and resolve dependencies up to the passed depth.

Specified by:

findAll in interface ActivityPubStore

Parameters:

subjectsParam - Subjects to search for.

deep - up to which hierarchy level should object references be resolved ?

Returns:

Found ActivityPubObjects

findLatestRevision

public Optional<ActivityPubObject> findLatestRevision(org.apache.commons.rdf.api.IRI pointerSubject)

Specified by:

findLatestRevision in interface ActivityPubStore

findWholeGraph

public Optional<ActivityPubObject> findWholeGraph(org.apache.commons.rdf.api.IRI subject)

Description copied from interface: ActivityPubStore

ATTENTION!! This reads the whole grap of the actor !

Specified by:

findWholeGraph in interface ActivityPubStore

Parameters:

subject -

Returns:

getOwner

public org.apache.commons.rdf.api.IRI getOwner()

Specified by:

getOwner in interface ActivityPubStore

dump

public org.apache.commons.rdf.api.Graph dump(org.apache.commons.rdf.api.IRI graphName)

Specified by:

dump in interface ActivityPubStore

getGraphNames

public Set<org.apache.commons.rdf.api.BlankNodeOrIRI> getGraphNames()

Specified by:

getGraphNames in interface ActivityPubStore

Returns:

Set of all known graphNames.