Package org.opencastproject.transcription.googlespeech

Class GoogleSpeechTranscriptionService

java.lang.Object

org.opencastproject.job.api.AbstractJobProducer

org.opencastproject.transcription.googlespeech.GoogleSpeechTranscriptionService

All Implemented Interfaces:

org.opencastproject.job.api.JobProducer, org.opencastproject.transcription.api.TranscriptionService

public class GoogleSpeechTranscriptionService
extends org.opencastproject.job.api.AbstractJobProducer
implements org.opencastproject.transcription.api.TranscriptionService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CLEANUP_RESULTS_DAYS_CONFIG
static final String	COMPLETION_CHECK_BUFFER_CONFIG
static final String	DEFAULT_WF_DEF
static final String	DISPATCH_WORKFLOW_INTERVAL_CONFIG
static final String	ENABLE_PUNCTUATION
static final String	ENABLED_CONFIG	Service configuration options
static final String	ENCODING_EXTENSION
static final String	GOOGLE_CLOUD_BUCKET
static final String	GOOGLE_CLOUD_CLIENT_ID
static final String	GOOGLE_CLOUD_CLIENT_SECRET
static final String	GOOGLE_CLOUD_REFRESH_TOKEN
static final String	GOOGLE_CLOUD_TOKEN_ENDPOINT_URL
static final String	GOOGLE_SPEECH_LANGUAGE
static final String	MAX_PROCESSING_TIME_CONFIG
static final String	NOTIFICATION_EMAIL_CONFIG
static final String	PROFANITY_FILTER
static final String	TRANSCRIPTION_MODEL
static final String	WORKFLOW_CONFIG

Fields inherited from class org.opencastproject.job.api.AbstractJobProducer

ACCEPT_JOB_LOADS_EXCEEDING_PROPERTY, acceptJobLoadsExeedingMaxLoad, DEFAULT_ACCEPT_JOB_LOADS_EXCEEDING, executor, jobType

Constructor Summary

Constructors

Constructor	Description
GoogleSpeechTranscriptionService()

Method Summary

Modifier and Type	Method	Description
void	activate(org.osgi.service.component.ComponentContext cc)
protected void	deleteStorageFile(String mpId, String token)
org.opencastproject.mediapackage.MediaPackageElement	getGeneratedTranscription(String mpId, String jobId, org.opencastproject.mediapackage.MediaPackageElement.Type type)
String	getLanguage()
protected org.opencastproject.security.api.OrganizationDirectoryService	getOrganizationDirectoryService()
protected String	getRefreshAccessToken()
Map<String,Object>	getReturnValues(String mpId, String jobId)
protected org.opencastproject.security.api.SecurityService	getSecurityService()
protected org.opencastproject.serviceregistry.api.ServiceRegistry	getServiceRegistry()
String	getTranscriptionResults(String jobId)	Get transcription result: GET /v1/operations/{name} Method mainly used by the REST endpoint
String	getTranscriptionStatus(String mpId)	Get mediapackage transcription status
protected org.opencastproject.security.api.UserDirectoryService	getUserDirectoryService()
protected org.apache.http.impl.client.CloseableHttpClient	makeHttpClient()
protected String	process(org.opencastproject.job.api.Job job)
protected String	refreshAccessToken(String clientId, String clientSecret, String refreshToken)
void	setAssetManager(org.opencastproject.assetmanager.api.AssetManager service)
void	setDatabase(org.opencastproject.transcription.persistence.TranscriptionDatabase service)
void	setOrganizationDirectoryService(org.opencastproject.security.api.OrganizationDirectoryService organizationDirectoryService)
void	setSecurityService(org.opencastproject.security.api.SecurityService securityService)
void	setServiceRegistry(org.opencastproject.serviceregistry.api.ServiceRegistry serviceRegistry)
void	setSmtpService(org.opencastproject.kernel.mail.SmtpService service)
void	setUserDirectoryService(org.opencastproject.security.api.UserDirectoryService userDirectoryService)
void	setWorkflowService(org.opencastproject.workflow.api.WorkflowService service)
void	setWorkingFileRepository(org.opencastproject.workingfilerepository.api.WorkingFileRepository wfr)
void	setWorkspace(org.opencastproject.workspace.api.Workspace ws)
org.opencastproject.job.api.Job	startTranscription(String mpId, org.opencastproject.mediapackage.Track track)
org.opencastproject.job.api.Job	startTranscription(String mpId, org.opencastproject.mediapackage.Track track, String... args)
void	transcriptionDone(String mpId, Object obj)
void	transcriptionError(String mpId, Object obj)
protected String	uploadAudioFileToGoogleStorage(String mpId, org.opencastproject.mediapackage.Track track)

Methods inherited from class org.opencastproject.job.api.AbstractJobProducer

acceptJob, countJobs, finallyUpdateJob, getJobType, incident, isReadyToAccept, isReadyToAcceptJobs

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_WF_DEF

public static final String DEFAULT_WF_DEF

See Also:

• Constant Field Values

ENABLED_CONFIG

public static final String ENABLED_CONFIG

Service configuration options

See Also:

• Constant Field Values

GOOGLE_SPEECH_LANGUAGE

public static final String GOOGLE_SPEECH_LANGUAGE

See Also:

• Constant Field Values

PROFANITY_FILTER

public static final String PROFANITY_FILTER

See Also:

• Constant Field Values

ENABLE_PUNCTUATION

public static final String ENABLE_PUNCTUATION

See Also:

• Constant Field Values

TRANSCRIPTION_MODEL

public static final String TRANSCRIPTION_MODEL

See Also:

• Constant Field Values

WORKFLOW_CONFIG

public static final String WORKFLOW_CONFIG

See Also:

• Constant Field Values

DISPATCH_WORKFLOW_INTERVAL_CONFIG

public static final String DISPATCH_WORKFLOW_INTERVAL_CONFIG

See Also:

• Constant Field Values

COMPLETION_CHECK_BUFFER_CONFIG

public static final String COMPLETION_CHECK_BUFFER_CONFIG

See Also:

• Constant Field Values

MAX_PROCESSING_TIME_CONFIG

public static final String MAX_PROCESSING_TIME_CONFIG

See Also:

• Constant Field Values

NOTIFICATION_EMAIL_CONFIG

public static final String NOTIFICATION_EMAIL_CONFIG

See Also:

• Constant Field Values

CLEANUP_RESULTS_DAYS_CONFIG

public static final String CLEANUP_RESULTS_DAYS_CONFIG

See Also:

• Constant Field Values

GOOGLE_CLOUD_CLIENT_ID

public static final String GOOGLE_CLOUD_CLIENT_ID

See Also:

• Constant Field Values

GOOGLE_CLOUD_CLIENT_SECRET

public static final String GOOGLE_CLOUD_CLIENT_SECRET

See Also:

• Constant Field Values

GOOGLE_CLOUD_REFRESH_TOKEN

public static final String GOOGLE_CLOUD_REFRESH_TOKEN

See Also:

• Constant Field Values

GOOGLE_CLOUD_BUCKET

public static final String GOOGLE_CLOUD_BUCKET

See Also:

• Constant Field Values

GOOGLE_CLOUD_TOKEN_ENDPOINT_URL

public static final String GOOGLE_CLOUD_TOKEN_ENDPOINT_URL

See Also:

• Constant Field Values

ENCODING_EXTENSION

public static final String ENCODING_EXTENSION

See Also:

• Constant Field Values

Constructor Details

GoogleSpeechTranscriptionService

public GoogleSpeechTranscriptionService()

Method Details

activate

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

Overrides:

activate in class org.opencastproject.job.api.AbstractJobProducer

startTranscription

public org.opencastproject.job.api.Job startTranscription(String mpId,
 org.opencastproject.mediapackage.Track track,
 String... args)
                                                   throws org.opencastproject.transcription.api.TranscriptionServiceException

Specified by:

startTranscription in interface org.opencastproject.transcription.api.TranscriptionService

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

startTranscription

public org.opencastproject.job.api.Job startTranscription(String mpId,
 org.opencastproject.mediapackage.Track track)
                                                   throws org.opencastproject.transcription.api.TranscriptionServiceException

Specified by:

startTranscription in interface org.opencastproject.transcription.api.TranscriptionService

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

transcriptionDone

public void transcriptionDone(String mpId,
 Object obj)
                       throws org.opencastproject.transcription.api.TranscriptionServiceException

Specified by:

transcriptionDone in interface org.opencastproject.transcription.api.TranscriptionService

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

getLanguage

public String getLanguage()

Specified by:

getLanguage in interface org.opencastproject.transcription.api.TranscriptionService

getReturnValues

public Map<String,Object> getReturnValues(String mpId,
 String jobId)
                                   throws org.opencastproject.transcription.api.TranscriptionServiceException

Specified by:

getReturnValues in interface org.opencastproject.transcription.api.TranscriptionService

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

transcriptionError

public void transcriptionError(String mpId,
 Object obj)
                        throws org.opencastproject.transcription.api.TranscriptionServiceException

Specified by:

transcriptionError in interface org.opencastproject.transcription.api.TranscriptionService

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

process

protected String process(org.opencastproject.job.api.Job job)
                  throws Exception

Specified by:

process in class org.opencastproject.job.api.AbstractJobProducer

Throws:

Exception

getTranscriptionResults

public String getTranscriptionResults(String jobId)
                               throws org.opencastproject.transcription.api.TranscriptionServiceException,
IOException

Get transcription result: GET /v1/operations/{name} Method mainly used by the REST endpoint

Parameters:

jobId -

Returns:

job details

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

IOException

getGeneratedTranscription

public org.opencastproject.mediapackage.MediaPackageElement getGeneratedTranscription(String mpId,
 String jobId,
 org.opencastproject.mediapackage.MediaPackageElement.Type type)
                                                                               throws org.opencastproject.transcription.api.TranscriptionServiceException

Specified by:

getGeneratedTranscription in interface org.opencastproject.transcription.api.TranscriptionService

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

getTranscriptionStatus

public String getTranscriptionStatus(String mpId)
                              throws org.opencastproject.transcription.api.TranscriptionServiceException

Get mediapackage transcription status

Parameters:

mpId - , mediapackage id

Returns:

transcription status

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

makeHttpClient

protected org.apache.http.impl.client.CloseableHttpClient makeHttpClient()
                                                                  throws IOException

Throws:

IOException

refreshAccessToken

protected String refreshAccessToken(String clientId,
 String clientSecret,
 String refreshToken)
                             throws org.opencastproject.transcription.api.TranscriptionServiceException,
IOException

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

IOException

getRefreshAccessToken

protected String getRefreshAccessToken()
                                throws org.opencastproject.transcription.api.TranscriptionServiceException,
IOException

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

IOException

uploadAudioFileToGoogleStorage

protected String uploadAudioFileToGoogleStorage(String mpId,
 org.opencastproject.mediapackage.Track track)
                                         throws org.opencastproject.transcription.api.TranscriptionServiceException,
IOException

Throws:

org.opencastproject.transcription.api.TranscriptionServiceException

IOException

deleteStorageFile

protected void deleteStorageFile(String mpId,
 String token)
                          throws IOException

Throws:

IOException

setServiceRegistry

public void setServiceRegistry(org.opencastproject.serviceregistry.api.ServiceRegistry serviceRegistry)

setSecurityService

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

setUserDirectoryService

public void setUserDirectoryService(org.opencastproject.security.api.UserDirectoryService userDirectoryService)

setOrganizationDirectoryService

public void setOrganizationDirectoryService(org.opencastproject.security.api.OrganizationDirectoryService organizationDirectoryService)

setSmtpService

public void setSmtpService(org.opencastproject.kernel.mail.SmtpService service)

setWorkspace

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

setWorkingFileRepository

public void setWorkingFileRepository(org.opencastproject.workingfilerepository.api.WorkingFileRepository wfr)

setDatabase

public void setDatabase(org.opencastproject.transcription.persistence.TranscriptionDatabase service)

setAssetManager

public void setAssetManager(org.opencastproject.assetmanager.api.AssetManager service)

setWorkflowService

public void setWorkflowService(org.opencastproject.workflow.api.WorkflowService service)

getServiceRegistry

protected org.opencastproject.serviceregistry.api.ServiceRegistry getServiceRegistry()

Specified by:

getServiceRegistry in class org.opencastproject.job.api.AbstractJobProducer

getSecurityService

protected org.opencastproject.security.api.SecurityService getSecurityService()

Specified by:

getSecurityService in class org.opencastproject.job.api.AbstractJobProducer

getUserDirectoryService

protected org.opencastproject.security.api.UserDirectoryService getUserDirectoryService()

Specified by:

getUserDirectoryService in class org.opencastproject.job.api.AbstractJobProducer

getOrganizationDirectoryService

protected org.opencastproject.security.api.OrganizationDirectoryService getOrganizationDirectoryService()

Specified by:

getOrganizationDirectoryService in class org.opencastproject.job.api.AbstractJobProducer