Package org.opencastproject.assetmanager.impl

Class AssetManagerImpl

java.lang.Object

org.opencastproject.elasticsearch.index.rebuild.AbstractIndexProducer

org.opencastproject.assetmanager.impl.AssetManagerImpl

All Implemented Interfaces:

org.opencastproject.assetmanager.api.AssetManager, org.opencastproject.elasticsearch.index.rebuild.IndexProducer

public class AssetManagerImpl
extends org.opencastproject.elasticsearch.index.rebuild.AbstractIndexProducer
implements org.opencastproject.assetmanager.api.AssetManager

The Asset Manager implementation.

Field Summary

Fields

Modifier and Type	Field	Description
static final Set<org.opencastproject.mediapackage.MediaPackageElement.Type>	MOVABLE_TYPES
static final String	READ_ACTION
static final String	SECURITY_NAMESPACE
static final String	WRITE_ACTION

Fields inherited from interface org.opencastproject.assetmanager.api.AssetManager

DEFAULT_OWNER

Constructor Summary

Constructors

Constructor	Description
AssetManagerImpl()

Method Summary

Modifier and Type	Method	Description
void	activate(org.osgi.service.component.ComponentContext cc)	OSGi callback.
void	addCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)
void	addRemoteAssetStore(org.opencastproject.assetmanager.api.storage.RemoteAssetStore assetStore)
long	countAssets()
long	countEvents(String organization)
long	countProperties()
long	countSnapshots(String organization)
int	deleteAllButLatestSnapshot(String mpId)
int	deleteProperties(String mediaPackageId)
int	deleteProperties(String mediaPackageId, String namespace)
int	deletePropertiesWithCurrentUser(String mediaPackageId, String namespace)
int	deleteSnapshots(String mpId)
Optional<org.opencastproject.assetmanager.api.Asset>	getAsset(org.opencastproject.assetmanager.api.Version version, String mpId, String mpElementId)
Optional<org.opencastproject.assetmanager.api.storage.AssetStore>	getAssetStore(String storeId)
Database	getDatabase()
static Optional<String>	getFileNameFromUrn(org.opencastproject.mediapackage.MediaPackageElement mpe)	Extract the file name from a media package elements URN.
HttpAssetProvider	getHttpAssetProvider()
Optional<org.opencastproject.assetmanager.api.Snapshot>	getLatestSnapshot(String mediaPackageId)
List<org.opencastproject.assetmanager.api.Snapshot>	getLatestSnapshots(Collection mediaPackageIds)
List<org.opencastproject.assetmanager.api.Snapshot>	getLatestSnapshotsBySeriesId(String seriesId)
org.opencastproject.assetmanager.api.storage.AssetStore	getLocalAssetStore()
Optional<org.opencastproject.mediapackage.MediaPackage>	getMediaPackage(String mediaPackageId)	AssetManager implementation
List<org.opencastproject.assetmanager.api.storage.AssetStore>	getRemoteAssetStores()
org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.Service	getService()	AbstractIndexProducer Implementation
Optional<org.opencastproject.assetmanager.api.Snapshot>	getSnapshotByMpIdOrgIdAndVersion(String mpId, String orgId, org.opencastproject.assetmanager.api.Version version)
List<org.opencastproject.assetmanager.api.Snapshot>	getSnapshotsByDateOrderedById(Date start, Date end)
List<org.opencastproject.assetmanager.api.Snapshot>	getSnapshotsById(String mpId)
List<org.opencastproject.assetmanager.api.Snapshot>	getSnapshotsByIdAndDate(String mpId, Date start, Date end)
List<org.opencastproject.assetmanager.api.Snapshot>	getSnapshotsByIdAndDateOrderedByVersion(String mpId, Date start, Date end, boolean asc)
List<org.opencastproject.assetmanager.api.Snapshot>	getSnapshotsByIdAndVersion(String mpId, org.opencastproject.assetmanager.api.Version version)
List<org.opencastproject.assetmanager.api.Snapshot>	getSnapshotsByIdOrderedByVersion(String mpId, boolean asc)
Optional<String>	getSnapshotStorageLocation(org.opencastproject.assetmanager.api.Snapshot snap)
Optional<String>	getSnapshotStorageLocation(org.opencastproject.assetmanager.api.Version version, String mpId)
org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.DataType[]	getSupportedDataTypes()
void	moveSnapshotsByDate(Date start, Date end, String targetStore)
void	moveSnapshotsById(String mpId, String targetStore)
void	moveSnapshotsByIdAndDate(String mpId, Date start, Date end, String targetStore)
void	moveSnapshotsByIdAndVersion(String mpId, org.opencastproject.assetmanager.api.Version version, String targetStore)
void	moveSnapshotToStore(org.opencastproject.assetmanager.api.Version version, String mpId, String storeId)
void	removeCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)
void	removeRemoteAssetStore(org.opencastproject.assetmanager.api.storage.RemoteAssetStore store)
void	repopulate(org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.DataType dataType)
static org.opencastproject.assetmanager.api.Snapshot	rewriteUris(org.opencastproject.assetmanager.api.Snapshot snapshot, Function<org.opencastproject.mediapackage.MediaPackageElement,URI> uriCreator)	Rewrite URIs of all asset elements of a snapshot's media package.
List<org.opencastproject.assetmanager.api.Property>	selectProperties(String mediaPackageId, String namespace)
void	setAclServiceFactory(org.opencastproject.authorization.xacml.manager.api.AclServiceFactory aclServiceFactory)
void	setAssetStore(org.opencastproject.assetmanager.api.storage.AssetStore assetStore)
void	setAuthorizationService(org.opencastproject.security.api.AuthorizationService authorizationService)
void	setAvailability(org.opencastproject.assetmanager.api.Version version, String mpId, org.opencastproject.assetmanager.api.Availability availability)	Used for testing
void	setDatabase(Database database)
void	setDBSessionFactory(org.opencastproject.db.DBSessionFactory dbSessionFactory)
void	setEntityManagerFactory(javax.persistence.EntityManagerFactory emf)	OSGi dependencies
void	setHttpAssetProvider(HttpAssetProvider httpAssetProvider)
void	setIndex(org.opencastproject.elasticsearch.index.ElasticsearchIndex index)
void	setOrgDir(org.opencastproject.security.api.OrganizationDirectoryService orgDir)
boolean	setProperty(org.opencastproject.assetmanager.api.Property property)	Properties
void	setSecurityService(org.opencastproject.security.api.SecurityService securityService)
void	setWorkspace(org.opencastproject.workspace.api.Workspace workspace)
boolean	snapshotExists(String mediaPackageId)	Snapshots
boolean	snapshotExists(String mediaPackageId, String organization)
org.opencastproject.assetmanager.api.Snapshot	takeSnapshot(String owner, org.opencastproject.mediapackage.MediaPackage mp)
org.opencastproject.assetmanager.api.Snapshot	takeSnapshot(org.opencastproject.mediapackage.MediaPackage mp)
Optional<org.opencastproject.assetmanager.api.Version>	toVersion(String version)	Misc.
void	triggerIndexUpdate(String mediaPackageId)

Methods inherited from class org.opencastproject.elasticsearch.index.rebuild.AbstractIndexProducer

logIndexRebuildBegin, logIndexRebuildBegin, logIndexRebuildError, logIndexRebuildError, logIndexRebuildError, logIndexRebuildProgress, logIndexRebuildProgress, logIndexRebuildProgress, logIndexRebuildProgress, logSkippingElement, logSkippingElement

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opencastproject.elasticsearch.index.rebuild.IndexProducer

dataTypeSupported

Field Details

WRITE_ACTION

public static final String WRITE_ACTION

See Also:

• Constant Field Values

READ_ACTION

public static final String READ_ACTION

See Also:

• Constant Field Values

SECURITY_NAMESPACE

public static final String SECURITY_NAMESPACE

See Also:

• Constant Field Values

MOVABLE_TYPES

public static final Set<org.opencastproject.mediapackage.MediaPackageElement.Type> MOVABLE_TYPES

Constructor Details

AssetManagerImpl

public AssetManagerImpl()

Method Details

activate

public void activate(org.osgi.service.component.ComponentContext cc)

OSGi callback.

setEntityManagerFactory

public void setEntityManagerFactory(javax.persistence.EntityManagerFactory emf)

OSGi dependencies

setDBSessionFactory

public void setDBSessionFactory(org.opencastproject.db.DBSessionFactory dbSessionFactory)

setSecurityService

public void setSecurityService(org.opencastproject.security.api.SecurityService securityService)

setAuthorizationService

public void setAuthorizationService(org.opencastproject.security.api.AuthorizationService authorizationService)

setOrgDir

public void setOrgDir(org.opencastproject.security.api.OrganizationDirectoryService orgDir)

setWorkspace

public void setWorkspace(org.opencastproject.workspace.api.Workspace workspace)

setAssetStore

public void setAssetStore(org.opencastproject.assetmanager.api.storage.AssetStore assetStore)

addRemoteAssetStore

public void addRemoteAssetStore(org.opencastproject.assetmanager.api.storage.RemoteAssetStore assetStore)

removeRemoteAssetStore

public void removeRemoteAssetStore(org.opencastproject.assetmanager.api.storage.RemoteAssetStore store)

setHttpAssetProvider

public void setHttpAssetProvider(HttpAssetProvider httpAssetProvider)

setAclServiceFactory

public void setAclServiceFactory(org.opencastproject.authorization.xacml.manager.api.AclServiceFactory aclServiceFactory)

setIndex

public void setIndex(org.opencastproject.elasticsearch.index.ElasticsearchIndex index)

addCatalogUIAdapter

public void addCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)

removeCatalogUIAdapter

public void removeCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)

getMediaPackage

public Optional<org.opencastproject.mediapackage.MediaPackage> getMediaPackage(String mediaPackageId)

AssetManager implementation

Specified by:

getMediaPackage in interface org.opencastproject.assetmanager.api.AssetManager

getLatestSnapshots

public List<org.opencastproject.assetmanager.api.Snapshot> getLatestSnapshots(Collection mediaPackageIds)

Specified by:

getLatestSnapshots in interface org.opencastproject.assetmanager.api.AssetManager

getLatestSnapshot

public Optional<org.opencastproject.assetmanager.api.Snapshot> getLatestSnapshot(String mediaPackageId)

Specified by:

getLatestSnapshot in interface org.opencastproject.assetmanager.api.AssetManager

getAsset

public Optional<org.opencastproject.assetmanager.api.Asset> getAsset(org.opencastproject.assetmanager.api.Version version,
 String mpId,
 String mpElementId)

Specified by:

getAsset in interface org.opencastproject.assetmanager.api.AssetManager

getAssetStore

public Optional<org.opencastproject.assetmanager.api.storage.AssetStore> getAssetStore(String storeId)

Specified by:

getAssetStore in interface org.opencastproject.assetmanager.api.AssetManager

getLocalAssetStore

public org.opencastproject.assetmanager.api.storage.AssetStore getLocalAssetStore()

Specified by:

getLocalAssetStore in interface org.opencastproject.assetmanager.api.AssetManager

getRemoteAssetStores

public List<org.opencastproject.assetmanager.api.storage.AssetStore> getRemoteAssetStores()

Specified by:

getRemoteAssetStores in interface org.opencastproject.assetmanager.api.AssetManager

snapshotExists

public boolean snapshotExists(String mediaPackageId)

Snapshots

Specified by:

snapshotExists in interface org.opencastproject.assetmanager.api.AssetManager

snapshotExists

public boolean snapshotExists(String mediaPackageId,
 String organization)

Specified by:

snapshotExists in interface org.opencastproject.assetmanager.api.AssetManager

takeSnapshot

public org.opencastproject.assetmanager.api.Snapshot takeSnapshot(org.opencastproject.mediapackage.MediaPackage mp)

Specified by:

takeSnapshot in interface org.opencastproject.assetmanager.api.AssetManager

takeSnapshot

public org.opencastproject.assetmanager.api.Snapshot takeSnapshot(String owner,
 org.opencastproject.mediapackage.MediaPackage mp)

Specified by:

takeSnapshot in interface org.opencastproject.assetmanager.api.AssetManager

triggerIndexUpdate

public void triggerIndexUpdate(String mediaPackageId)
                        throws org.opencastproject.util.NotFoundException,
org.opencastproject.security.api.UnauthorizedException

Specified by:

triggerIndexUpdate in interface org.opencastproject.assetmanager.api.AssetManager

Throws:

org.opencastproject.util.NotFoundException

org.opencastproject.security.api.UnauthorizedException

getSnapshotsById

public List<org.opencastproject.assetmanager.api.Snapshot> getSnapshotsById(String mpId)

Specified by:

getSnapshotsById in interface org.opencastproject.assetmanager.api.AssetManager

getSnapshotsByIdOrderedByVersion

public List<org.opencastproject.assetmanager.api.Snapshot> getSnapshotsByIdOrderedByVersion(String mpId,
 boolean asc)

Specified by:

getSnapshotsByIdOrderedByVersion in interface org.opencastproject.assetmanager.api.AssetManager

getSnapshotsByIdAndVersion

public List<org.opencastproject.assetmanager.api.Snapshot> getSnapshotsByIdAndVersion(String mpId,
 org.opencastproject.assetmanager.api.Version version)

Specified by:

getSnapshotsByIdAndVersion in interface org.opencastproject.assetmanager.api.AssetManager

getSnapshotsByDateOrderedById

public List<org.opencastproject.assetmanager.api.Snapshot> getSnapshotsByDateOrderedById(Date start,
 Date end)

Specified by:

getSnapshotsByDateOrderedById in interface org.opencastproject.assetmanager.api.AssetManager

getSnapshotsByIdAndDate

public List<org.opencastproject.assetmanager.api.Snapshot> getSnapshotsByIdAndDate(String mpId,
 Date start,
 Date end)

Specified by:

getSnapshotsByIdAndDate in interface org.opencastproject.assetmanager.api.AssetManager

getSnapshotsByIdAndDateOrderedByVersion

public List<org.opencastproject.assetmanager.api.Snapshot> getSnapshotsByIdAndDateOrderedByVersion(String mpId,
 Date start,
 Date end,
 boolean asc)

Specified by:

getSnapshotsByIdAndDateOrderedByVersion in interface org.opencastproject.assetmanager.api.AssetManager

getLatestSnapshotsBySeriesId

public List<org.opencastproject.assetmanager.api.Snapshot> getLatestSnapshotsBySeriesId(String seriesId)

Specified by:

getLatestSnapshotsBySeriesId in interface org.opencastproject.assetmanager.api.AssetManager

getSnapshotByMpIdOrgIdAndVersion

public Optional<org.opencastproject.assetmanager.api.Snapshot> getSnapshotByMpIdOrgIdAndVersion(String mpId,
 String orgId,
 org.opencastproject.assetmanager.api.Version version)

Specified by:

getSnapshotByMpIdOrgIdAndVersion in interface org.opencastproject.assetmanager.api.AssetManager

deleteSnapshots

public int deleteSnapshots(String mpId)

Specified by:

deleteSnapshots in interface org.opencastproject.assetmanager.api.AssetManager

deleteAllButLatestSnapshot

public int deleteAllButLatestSnapshot(String mpId)

Specified by:

deleteAllButLatestSnapshot in interface org.opencastproject.assetmanager.api.AssetManager

moveSnapshotsById

public void moveSnapshotsById(String mpId,
 String targetStore)
                       throws org.opencastproject.util.NotFoundException

Specified by:

moveSnapshotsById in interface org.opencastproject.assetmanager.api.AssetManager

Throws:

org.opencastproject.util.NotFoundException

moveSnapshotsByIdAndVersion

public void moveSnapshotsByIdAndVersion(String mpId,
 org.opencastproject.assetmanager.api.Version version,
 String targetStore)
                                 throws org.opencastproject.util.NotFoundException

Specified by:

moveSnapshotsByIdAndVersion in interface org.opencastproject.assetmanager.api.AssetManager

Throws:

org.opencastproject.util.NotFoundException

moveSnapshotsByDate

public void moveSnapshotsByDate(Date start,
 Date end,
 String targetStore)
                         throws org.opencastproject.util.NotFoundException

Specified by:

moveSnapshotsByDate in interface org.opencastproject.assetmanager.api.AssetManager

Throws:

org.opencastproject.util.NotFoundException

moveSnapshotsByIdAndDate

public void moveSnapshotsByIdAndDate(String mpId,
 Date start,
 Date end,
 String targetStore)
                              throws org.opencastproject.util.NotFoundException

Specified by:

moveSnapshotsByIdAndDate in interface org.opencastproject.assetmanager.api.AssetManager

Throws:

org.opencastproject.util.NotFoundException

moveSnapshotToStore

public void moveSnapshotToStore(org.opencastproject.assetmanager.api.Version version,
 String mpId,
 String storeId)
                         throws org.opencastproject.util.NotFoundException

Specified by:

moveSnapshotToStore in interface org.opencastproject.assetmanager.api.AssetManager

Throws:

org.opencastproject.util.NotFoundException

getSnapshotStorageLocation

public Optional<String> getSnapshotStorageLocation(org.opencastproject.assetmanager.api.Version version,
 String mpId)

getSnapshotStorageLocation

public Optional<String> getSnapshotStorageLocation(org.opencastproject.assetmanager.api.Snapshot snap)

setProperty

public boolean setProperty(org.opencastproject.assetmanager.api.Property property)

Properties

Specified by:

setProperty in interface org.opencastproject.assetmanager.api.AssetManager

selectProperties

public List<org.opencastproject.assetmanager.api.Property> selectProperties(String mediaPackageId,
 String namespace)

Specified by:

selectProperties in interface org.opencastproject.assetmanager.api.AssetManager

deleteProperties

public int deleteProperties(String mediaPackageId)

Specified by:

deleteProperties in interface org.opencastproject.assetmanager.api.AssetManager

deleteProperties

public int deleteProperties(String mediaPackageId,
 String namespace)

Specified by:

deleteProperties in interface org.opencastproject.assetmanager.api.AssetManager

deletePropertiesWithCurrentUser

public int deletePropertiesWithCurrentUser(String mediaPackageId,
 String namespace)

Specified by:

deletePropertiesWithCurrentUser in interface org.opencastproject.assetmanager.api.AssetManager

toVersion

public Optional<org.opencastproject.assetmanager.api.Version> toVersion(String version)

Misc.

Specified by:

toVersion in interface org.opencastproject.assetmanager.api.AssetManager

countEvents

public long countEvents(String organization)

Specified by:

countEvents in interface org.opencastproject.assetmanager.api.AssetManager

countSnapshots

public long countSnapshots(String organization)

Specified by:

countSnapshots in interface org.opencastproject.assetmanager.api.AssetManager

countAssets

public long countAssets()

Specified by:

countAssets in interface org.opencastproject.assetmanager.api.AssetManager

countProperties

public long countProperties()

Specified by:

countProperties in interface org.opencastproject.assetmanager.api.AssetManager

getService

public org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.Service getService()

AbstractIndexProducer Implementation

Specified by:

getService in interface org.opencastproject.elasticsearch.index.rebuild.IndexProducer

getSupportedDataTypes

public org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.DataType[] getSupportedDataTypes()

Specified by:

getSupportedDataTypes in interface org.opencastproject.elasticsearch.index.rebuild.IndexProducer

repopulate

public void repopulate(org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.DataType dataType)
                throws org.opencastproject.elasticsearch.index.rebuild.IndexRebuildException

Specified by:

repopulate in interface org.opencastproject.elasticsearch.index.rebuild.IndexProducer

Throws:

org.opencastproject.elasticsearch.index.rebuild.IndexRebuildException

setAvailability

public void setAvailability(org.opencastproject.assetmanager.api.Version version,
 String mpId,
 org.opencastproject.assetmanager.api.Availability availability)

Used for testing

setDatabase

public void setDatabase(Database database)

getDatabase

public Database getDatabase()

getHttpAssetProvider

public HttpAssetProvider getHttpAssetProvider()

getFileNameFromUrn

public static Optional<String> getFileNameFromUrn(org.opencastproject.mediapackage.MediaPackageElement mpe)

Extract the file name from a media package elements URN.

Returns:

the file name or none if it could not be determined

rewriteUris

public static org.opencastproject.assetmanager.api.Snapshot rewriteUris(org.opencastproject.assetmanager.api.Snapshot snapshot,
 Function<org.opencastproject.mediapackage.MediaPackageElement,URI> uriCreator)

Rewrite URIs of all asset elements of a snapshot's media package. This method does not mutate anything.