Skip to content

Introduction

In this example, we will create two workflows; one will send and email and generate a cloud event, and the other will trigger upon receiving the cloud event, check the contents of an email, use AI to discern the 'intent' of the message, and respond if the intent is deemed to be negative.

Send an Email and Trigger an Event

id: send-email-trigger-event
functions:
- id: smtp
  image: direktiv/smtp:v1
  type: reusable
description: This workflow sends an email and triggers an event.
states:
  # continued in next code block

Send Email

This state uses the direktiv/smtp:v1 container to send an email.

- id: sendemail
  type: action
  action:
    function: smtp
    secrets: ["EMAIL_ADDRESS", "EMAIL_PASSWORD"]
    input:
      to: jq(.secrets.EMAIL_ADDRESS)
      subject: "Your Review"
      message: "You are very bad at doing work."
      from: jq(.secrets.EMAIL_ADDRESS)
      password: jq(.secrets.EMAIL_PASSWORD))"
      server: smtp.gmail.com
      port: 587
  transition: sendcloudevent

Trigger Event

This generateEvent state sends a cloud event to a namespace.

- id: sendcloudevent
  type: generateEvent
  event:
    source: direktiv
    type: smtp

Workflow Send Email

id: send-email-trigger-event
functions:
- id: smtp
  image: direktiv/smtp:v1
  type: reusable
description: This workflow sends an email and triggers an event.
states:
- id: sendemail
  type: action
  action:
    secrets: ["EMAIL_ADDRESS", "EMAIL_PASSWORD"]
    function: smtp
    input:
      to: jq(.secrets.EMAIL_ADDRESS)
      subject: "Your Review"
      message: "You are very bad at doing work."
      from: jq(.secrets.EMAIL_ADDRESS)
      password: jq(.secrets.EMAIL_PASSWORD)
      server: smtp.gmail.com
      port: 587
  transition: sendcloudevent
- id: sendcloudevent
  type: generateEvent
  event:
    source: direktiv
    type: smtp

Read the Email and Check its Intent

id: listen-for-email
description: This workflow reads an email when a cloud event is received.
functions:
- id: imap
  image: direktiv/imap:v1
  type: reusable
- id: smtp
  image: direktiv/smtp:v1
  type: reusable
- id: sentiment
  image: direktiv/google-sentiment-check:v1
  type: reusable
start:
  type: event
  state: read-email
  event:
    type: smtp
states:
  # continued in next code block

NOTE: This workflow will be triggered when the 'direktiv' namespace receives a cloud event of type smtp.

Read Email

This state takes the first message from the email 'INBOX', reads & outputs the contents of the message, and transitions to the sentiment-check state.

- id: read-email
  type: action
  action:
    secrets: ["EMAIL_ADDRESS", "EMAIL_PASSWORD"]
    function: imap
    input:
      email: jq(.secrets.EMAIL_ADDRESS)
      password: jq(.secrets.EMAIL_PASSWORD)
      imap-address: "imap.gmail.com:993"
  transition: sentiment-check

Check Intent

- id: sentiment-check
  type: action
  action:
    function: sentiment
    secrets: ["SERVICE_ACCOUNT_KEY"]
    input:
      message: jq(.return.msg)
      serviceAccountKey: jq(.secrets.SERVICE_ACCOUNT_KEY)
  transition: check-feeling

Check Intent

If the message 'intent' is determined to be negative, send an automated response to the sender.

- id: check-feeling
  type: switch
  conditions:
  - condition: jq(.return.feeling == "Negative")
    transition: send-response

Reply to Email

This state uses the direktiv/smtp:v2 isolate to send an email to the sender of the negative email.

- id: send-response
  type: action
  action:
    secrets: ["EMAIL_ADDRESS","EMAIL_PASSWORD"]
    function: smtp
    input:
      to: jq(.secrets.EMAIL_ADDRESS)
      subject: "I dont appreciate your message"
      message: ""
      from: jq(.secrets.EMAIL_ADDRESS)
      password: jq(.secrets.EMAIL_PASSWORD)
      server: smtp.gmail.com
      port: 587

Workflow Listen For Email

id: listen-for-email
description: This workflow reads an email when a cloud event is received.
functions:
- id: imap
  image: direktiv/imap:v1
  type: reusable
- id: smtp
  image: direktiv/smtp:v1
  type: reusable
- id: sentiment
  image: direktiv/google-sentiment-check:v1
  type: reusable
start:
  type: event
  state: read-email
  event:
    type: smtp
states:
- id: read-email
  type: action
  action:
    secrets: ["EMAIL_ADDRESS", "EMAIL_PASSWORD"]
    function: imap
    input:
      email: jq(.secrets.EMAIL_ADDRESS)
      password: jq(.secrets.EMAIL_PASSWORD)
      imap-address: "imap.gmail.com:993"
  transition: sentiment-check
- id: sentiment-check
  type: action
  action:
    function: sentiment
    secrets: ["SERVICE_ACCOUNT_KEY"]
    input:
      message: jq(.return.msg)
      serviceAccountKey: jq(.secrets.SERVICE_ACCOUNT_KEY)
  transition: check-feeling
- id: check-feeling
  type: switch
  conditions:
  - condition: jq(.return.feeling == "Negative")
    transition: send-response
- id: send-response
  type: action
  action:
    secrets: ["EMAIL_ADDRESS","EMAIL_PASSWORD"]
    function: smtp
    input:
      to: jq(.secrets.EMAIL_ADDRESS)
      subject: "I dont appreciate your message"
      message: ""
      from: jq(.secrets.EMAIL_ADDRESS)
      password: jq(.secrets.EMAIL_PASSWORD)
      server: smtp.gmail.com
      port: 587

Although this particular example is quite simple, the logic used could be modified for something far more 'in-depth'. For example, it could be extended to run an 'IMAP' listener that generates a cloud event, triggering the 'intent' checker on Direktiv. Depending on the determined intent of each email received, actions such as email deletion could be performed.

Back to top