Workflow Example 2

Create Workflow Definition

Let create a workflow that monitors specified folders and when a video file appears in some of them transcodes it with selected transcoding template.

LAPIS fires events related to object life-cycle and workflow will monitor two of them: objectCreated (fired when new object appears in the system) and objectUpdated (fired when existing object is modified). When object is created the workflow will check if it is linked to one of the monitored folders, similarly when an existing object is modified workflow will check if it is linked to some of the monitored folders,

Let assume we have some folders:

For this example we will monitor "Folder 1" and "Folder 2". We will need their IDs which we can get by displaying the ID column:

We will also use a Transcoding Template holding the transcoding parameters, so get its ID, too:

Now let's create a new workflow definition as shown:

Set general properties Name, ID and Executable:
Important is also to add the following "Extension Property", so that workflow history is not flooded with all instances that are created for all create and update events:
Set the properties for Object Created start event:
Set the properties for Object Updated start event:
Set the following properties to object created Yes flow:

The script is:
```
def folders = [
  '679d0faa3063823d2ba9a45c@1', // ID of "Folder 1"
  '679d0fb73063823d2ba9a45e@1', // ID of "Folder 2"
]

def containers = (object.get('containers') ?: []).collect { it.id.toString() }

def addedToAnyFolder = folders.intersect(containers)

(object.unwrap().isInstanceOf('Video')) && !['draft', 'newObjectDraft'].contains(object.get('lifeCycleStatus')) && object.get('containers') != null && addedToAnyFolder
```
Replace/add IDs of the folders you want to be monitored in folders variable.

The object variable is defined for the workflow instances that start with objectCreated and/or objectUpdated signal events. with object.get() you can get any property from the object, so similarly you may check for other object's properties and act as needed. In this example containers property holds IDs of folders (and/or other containers) to which this object is linked.

The last script statement must evaluate to Boolean which sets the outcome for condition check. In this example it checks if the newly created object is of type 'Video', if it is not in the process of creation (autosaves during entering data for the new object will have such state), and finally the needed condition (object is linked to one of the monitored folders in this example).

Set the following properties to object updated Yes flow:

The script is:

def folders = [
  '679d0faa3063823d2ba9a45c@1', // ID of "Folder 1"
  '679d0fb73063823d2ba9a45e@1', // ID of "Folder 2"
]

def originalContainers = (originalObject.get('containers') ?: []).collect { it.id.toString() }
def containers = (object.get('containers') ?: []).collect { it.id.toString() }

def intersectOriginal = folders.intersect(originalContainers) ?: []
def intersectNew = folders.intersect(containers) ?: []

def addedToAnyFolder = intersectOriginal.size() == 0 && intersectNew.size() > 0

execution.hasVariable('originalObject') && (object.unwrap().isInstanceOf('Video')) && !['draft', 'newObjectDraft'].contains(object.get('lifeCycleStatus')) && addedToAnyFolder

Match folders variable to the previous script. (Note that there is way to set this variable ones in the workflow and use it on other places, but for simplicity we have put it in both scripts) .

Set the following properties to the scripting task:

The script is:

def operationId = Context.operationHelpers.getOperationByName('TranscodeOperation', godUser).id
def templateId = '679d218d3063823d2ba9a46d@1' // ID of the transcoding template
Context.operations.executeOperationById(operationId, [object.id].toImmutableList(), helpers.getSubject(subject), [  templateId: helpers.relationFromString(templateId),
].toImmutableMap(), null)

Change the templateId with your own.

You can download the BPMN of the above example from here.

Test the new workflow

Upload a file to one of the monitored folders:
The transcoding should start after upload is finished:
You can also drag-drop an existing video in one of the monitored folders and the workflow should start the transcoding for it.