Workflow Builder
for Developers

Manage customer and data processes across your applications.

Read the Docs Sign-Up

Deliver Production-Ready Workflows in days

Build better software
with less technical resources

Why Zenaton

Customer Processes

Build an event-driven Customer Journey

Build personalized communications for each customer process based on data and behaviour. Wait for events and trigger communications or actions at the right time applying business rules for every path.

Data Processes & Custom Integrations

Integrate cloud services with your applications

Build workflows orchestrating data and events between internal applications and third party APIs. Write custom logic to wait for events, trigger actions and update data across tools in real time.

Workflows as Code

Create an infinite amount of possibilities. Combine Zenaton functions
with javascript to write custom logic and manipulate data.
Include loops, wait function, parallel and asynchronous executions.

More workflows

Real Time Alerts

A workflow that calculates the ETA for a delivery service and sends updates to the customer based on different conditions.

A workflow instance is launched when a shipment leaves the warehouse and triggers a task to calculate the ETA and time to arrival (duration) based on real time tracking data.

Depending on the remaining duration, we either wait, realculate or send an email or text message to the customer with the estimated ETA using the Zenaton Twilio API connector.

View full example

const BEFORE = 3600;
const PRECISION = 120;
const UPDATE = 1200;

module.exports.handle = function*(tripId, user) {
  let duration;
  let eta;
  let eta2;

  // Calculate the initial duration in seconds and estimated time of arrival (ETA)
  [duration, eta] = yield this.run.task("CalculateTimeToArrivalTask", tripId);

  // As long as the remaining duration is more than 1 hour and 2 minutes
  while (duration > BEFORE + PRECISION) {
    // Wait for half of the time of duration minus one hour
    yield this.wait.for((duration - BEFORE) / 2);

    // Re-calculate both the duration and the ETA.
    [duration, eta] = yield this.run.task("CalculateTimeToArrivalTask", tripId);
  }

  // Send a notification to the customer with updated ETA
  yield this.run.task("InformUserOfEtaTask", user, eta);

  // While it remains more than 20 minutes
  while (duration > PRECISION) {

    // Wait for 20 minutes
    yield this.wait.for(UPDATE);

    // Re-calculate both the duration and the ETA
    [duration, eta2] = yield this.run.task("CalculateTimeToArrivalTask", tripId);

    // If the new ETA has changed more than 20 minutes
    const diff = Math.abs(eta2 - eta)
    if (diff >= UPDATE) {
      eta = eta2;
      // Send an SMS notification to the customer with the new ETA
      yield this.run.task('sendSms', user.phone, diff);
    }
  }
};

Moderation Workflow

A workflow that manages the article moderation process for a public blog.

When a user posts an article, a workflow instance is launched that notifies the moderator and waits for the moderator to approve or reject the article - at which point it will notify the user.

The moderator is sent 3 reminders spaced 24 hours apart if they have not responded yet.

module.exports = {
  *handle(article, user) {
    let count = 0;
    this.article = article
    this.user = user

    // An article is sent to a moderator
    yield this.run.task("SendArticleToModerator", article);
    
    do {
      // Wait for the moderator response for up to 24h
      yield this.wait.for(24*60*60);
      
      // if the moderator does not respond within 24h
      yield this.run.task("SendReminderToModerator", article, count);

      count++;
    } while(count < 3);
    
    // if the moderator has not responded yet
    this.run.task("SendRejectionNotification", article, user);
  },
  *onEvent(name, data) {
    if (name === "ModerationEvent") {
      if (data && data.accepted) {
        this.run.task("SendAcceptanceNotification", this.article, this.user);
      } else {
        this.run.task("SendRejectionNotification", this.article, this.user);
      }
      this.terminate();
    }
  }
};

Scrape & Analyze Data

A simple ETL workflow calls the Tripadvisor API to scrape reviews for a particular restaurant for the current month and then runs a sentiment analysis on each review to determine the positive or negative aspects.
Then the results are saved to a google sheet.

This workflow could be scheduled to run on a recurring basis.

View full example

const spreadsheetId = "";

module.exports.handle = function*(restaurantName, tripAdvisorUrl) {
  // Scrape the tripAdvisorUrl to get the reviews of the month.
  const reviews = yield this.run.task("ScrapeReviewsOfTheMonth",
    tripAdvisorUrl,
    this.date()
  );

  // Run SentimentAnalysis tasks in parallel for each review.
  tasks = reviews.map((review) => ["SentimentAnalysis", review]);
  const postiveAndNegativeAspects = yield this.run.task(...tasks)

  // Save results or data to a GoogleSheet
  yield this.run.task("sendDataToGoogleSheet", restaurantName, currentMonth, postiveAndNegativeAspects);
};

Document Validation & Reminders

A workflow that manages the process of sending/validating ID documents via a third party service and reminding a user to upload missing documents.

A workflow instance is launched when a user opens an account and waits for all of the necessary documents to be uploaded. When they are uploaded it sends them to the third party service for verification and triggers actions based on the response.

If the user has not uploaded all of the right documents, it sends up to 3 reminder emails to the user spaced 3 days apart via the sendgrid API connector.

View full example

module.exports = {
  *handle(request) {
    this.counter = request.documents.length;

    // While some documents are missing
    let remainingReminders = 3;
    while (remainingReminders > 0) {
      // Wait for 3 days
      yield this.wait.for(3 * 24 * 3600);

      // Send an email reminder to the user
      yield this.run.task('sendEmailReminder', request, remainingReminders);
      
      remainingReminders--;
    }

    // Notify the user that the process failed
    this.run.task('sendEmailProcessFailed', request, remainingReminders);
  },
  *onEvent(name, data) {
    if (name ==="ProofReceivedEvent") {
      this.counter--;
      if (this.counter === 0) {
        // Notify the user that the process is completed
        this.run.task('sendEmailProcessComplete', request);
        // terminate this workflow
        this.terminate();
      }
    }
  }
};

Trigger Emails based on Weather

A workflow that checks OpenWeatherAPI each day and sends emails with customized content based on the weather.

If the temperature is cold for 3 days in a row during our specified time period, customers receive a promotional email to visit somewhere warm via the Mailchimp API connector.

At the end of the time period, if the temperature has not dropped below the limit for 3 days in a row, a different promotional email is sent.

module.exports.handle = function*(period, threshold, minColdDays, city) {
  let nbColdDays = 0;
  do {
    // get the current temperature of the city
    const temperature = yield this.run.task('getTemperature', city);
    // if the current temperature is under the threshold
    if (temperature < threshold) {
      // increment the number of cold days
      nbColdDays++;
    } else {
      // if the current temperature is higher than the threshold
      // reset the counter of cold days
      nbColdDays = 0;
    }
    // wait one day
    yield this.wait.for(24 * 3600);
    period--;
  } while (nbColdDays < minColdDays && period > 0);

  // if there were enought cold days in a row
  if (nbColdDays === minColdDays) {
    // send a campaign about sunny destinations
    yield this.run.task('sendMailchimpCampaign', `${city}_get_some_sun`);
  } else {
    // if there were not so much cold days, send the default campaign
    yield this.run.task('sendMailchimpCampaign', `${city}_default`);
  }
};

Real Time Alerts

A workflow that calculates the ETA for a delivery service and sends updates to the customer based on different conditions.

A workflow instance is launched when a shipment leaves the warehouse and triggers a task to calculate the ETA and time to arrival (duration) based on real time tracking data.

Depending on the remaining duration, we either wait, realculate or send an email or text message to the customer with the estimated ETA using the Zenaton Twilio API connector.

View full example

const BEFORE = 3600;
const PRECISION = 120;
const UPDATE = 1200;

module.exports.handle = function*(tripId, user) {
  let duration;
  let eta;
  let eta2;

  // Calculate the initial duration in seconds and estimated time of arrival (ETA)
  [duration, eta] = yield this.run.task("CalculateTimeToArrivalTask", tripId);

  // As long as the remaining duration is more than 1 hour and 2 minutes
  while (duration > BEFORE + PRECISION) {
    // Wait for half of the time of duration minus one hour
    yield this.wait.for((duration - BEFORE) / 2);

    // Re-calculate both the duration and the ETA.
    [duration, eta] = yield this.run.task("CalculateTimeToArrivalTask", tripId);
  }

  // Send a notification to the customer with updated ETA
  yield this.run.task("InformUserOfEtaTask", user, eta);

  // While it remains more than 20 minutes
  while (duration > PRECISION) {

    // Wait for 20 minutes
    yield this.wait.for(UPDATE);

    // Re-calculate both the duration and the ETA
    [duration, eta2] = yield this.run.task("CalculateTimeToArrivalTask", tripId);

    // If the new ETA has changed more than 20 minutes
    const diff = Math.abs(eta2 - eta)
    if (diff >= UPDATE) {
      eta = eta2;
      // Send an SMS notification to the customer with the new ETA
      yield this.run.task('sendSms', user.phone, diff);
    }
  }
};

Moderation Workflow

A workflow that manages the article moderation process for a public blog.

When a user posts an article, a workflow instance is launched that notifies the moderator and waits for the moderator to approve or reject the article - at which point it will notify the user.

The moderator is sent 3 reminders spaced 24 hours apart if they have not responded yet.

module.exports = {
  *handle(article, user) {
    let count = 0;
    this.article = article
    this.user = user

    // An article is sent to a moderator
    yield this.run.task("SendArticleToModerator", article);
    
    do {
      // Wait for the moderator response for up to 24h
      yield this.wait.for(24*60*60);
      
      // if the moderator does not respond within 24h
      yield this.run.task("SendReminderToModerator", article, count);

      count++;
    } while(count < 3);
    
    // if the moderator has not responded yet
    this.run.task("SendRejectionNotification", article, user);
  },
  *onEvent(name, data) {
    if (name === "ModerationEvent") {
      if (data && data.accepted) {
        this.run.task("SendAcceptanceNotification", this.article, this.user);
      } else {
        this.run.task("SendRejectionNotification", this.article, this.user);
      }
      this.terminate();
    }
  }
};

Scrape & Analyze Data

This workflow could be scheduled to run on a recurring basis.

View full example

const spreadsheetId = "";

module.exports.handle = function*(restaurantName, tripAdvisorUrl) {
  // Scrape the tripAdvisorUrl to get the reviews of the month.
  const reviews = yield this.run.task("ScrapeReviewsOfTheMonth",
    tripAdvisorUrl,
    this.date()
  );

  // Run SentimentAnalysis tasks in parallel for each review.
  tasks = reviews.map((review) => ["SentimentAnalysis", review]);
  const postiveAndNegativeAspects = yield this.run.task(...tasks)

  // Save results or data to a GoogleSheet
  yield this.run.task("sendDataToGoogleSheet", restaurantName, currentMonth, postiveAndNegativeAspects);
};

Document Validation & Reminders

A workflow that manages the process of sending/validating ID documents via a third party service and reminding a user to upload missing documents.

If the user has not uploaded all of the right documents, it sends up to 3 reminder emails to the user spaced 3 days apart via the sendgrid API connector.

View full example

module.exports = {
  *handle(request) {
    this.counter = request.documents.length;

    // While some documents are missing
    let remainingReminders = 3;
    while (remainingReminders > 0) {
      // Wait for 3 days
      yield this.wait.for(3 * 24 * 3600);

      // Send an email reminder to the user
      yield this.run.task('sendEmailReminder', request, remainingReminders);
      
      remainingReminders--;
    }

    // Notify the user that the process failed
    this.run.task('sendEmailProcessFailed', request, remainingReminders);
  },
  *onEvent(name, data) {
    if (name ==="ProofReceivedEvent") {
      this.counter--;
      if (this.counter === 0) {
        // Notify the user that the process is completed
        this.run.task('sendEmailProcessComplete', request);
        // terminate this workflow
        this.terminate();
      }
    }
  }
};

Trigger Emails based on Weather

A workflow that checks OpenWeatherAPI each day and sends emails with customized content based on the weather.

If the temperature is cold for 3 days in a row during our specified time period, customers receive a promotional email to visit somewhere warm via the Mailchimp API connector.

At the end of the time period, if the temperature has not dropped below the limit for 3 days in a row, a different promotional email is sent.

module.exports.handle = function*(period, threshold, minColdDays, city) {
  let nbColdDays = 0;
  do {
    // get the current temperature of the city
    const temperature = yield this.run.task('getTemperature', city);
    // if the current temperature is under the threshold
    if (temperature < threshold) {
      // increment the number of cold days
      nbColdDays++;
    } else {
      // if the current temperature is higher than the threshold
      // reset the counter of cold days
      nbColdDays = 0;
    }
    // wait one day
    yield this.wait.for(24 * 3600);
    period--;
  } while (nbColdDays < minColdDays && period > 0);

  // if there were enought cold days in a row
  if (nbColdDays === minColdDays) {
    // send a campaign about sunny destinations
    yield this.run.task('sendMailchimpCampaign', `${city}_get_some_sun`);
  } else {
    // if there were not so much cold days, send the default campaign
    yield this.run.task('sendMailchimpCampaign', `${city}_default`);
  }
};

Real Time Alerts

A workflow that calculates the ETA for a delivery service and sends updates to the customer based on different conditions.

A workflow instance is launched when a shipment leaves the warehouse and triggers a task to calculate the ETA and time to arrival (duration) based on real time tracking data.

Depending on the remaining duration, we either wait, realculate or send an email or text message to the customer with the estimated ETA using the Zenaton Twilio API connector.

View full example

const BEFORE = 3600;
const PRECISION = 120;
const UPDATE = 1200;

module.exports.handle = function*(tripId, user) {
  let duration;
  let eta;
  let eta2;

  // Calculate the initial duration in seconds and estimated time of arrival (ETA)
  [duration, eta] = yield this.run.task("CalculateTimeToArrivalTask", tripId);

  // As long as the remaining duration is more than 1 hour and 2 minutes
  while (duration > BEFORE + PRECISION) {
    // Wait for half of the time of duration minus one hour
    yield this.wait.for((duration - BEFORE) / 2);

    // Re-calculate both the duration and the ETA.
    [duration, eta] = yield this.run.task("CalculateTimeToArrivalTask", tripId);
  }

  // Send a notification to the customer with updated ETA
  yield this.run.task("InformUserOfEtaTask", user, eta);

  // While it remains more than 20 minutes
  while (duration > PRECISION) {

    // Wait for 20 minutes
    yield this.wait.for(UPDATE);

    // Re-calculate both the duration and the ETA
    [duration, eta2] = yield this.run.task("CalculateTimeToArrivalTask", tripId);

    // If the new ETA has changed more than 20 minutes
    const diff = Math.abs(eta2 - eta)
    if (diff >= UPDATE) {
      eta = eta2;
      // Send an SMS notification to the customer with the new ETA
      yield this.run.task('sendSms', user.phone, diff);
    }
  }
};

000's of Developer Hours Saved

Zenaton is for ambitious and agile developers that build software and care about flexibility, adaptability and reliability.

Read what our customers are saying

"It improved our user's confidence by sending communications and reaching out at key moments in their journey."

Case Study André, CTO at Tradee

"with Zenaton I need only 1 engineer to handle both the business logic and the scalability/reliability... at Box, we needed two teams of about 12 people to deal with this!"

Florian Jourda, CTO at Wave

"Zenaton allows us to focus on the functionalities that need to be developed. We no longer think about the infrastructure behind the business."

Case Study Olivier, CTO at Mobile Club

Simplified Infrastructure Sophisticated Logic

The Business logic is written into your code and executed through Zenaton workflow engine that manages the queuing, storing of database states and then executes tasks on your servers.

Product

Extend your Applications

Dispatch workflows and send events in real time from any web application. Trigger actions in internal apps or SAAS tools based on user behaviour, data updates or custom conditions.

Custom Integrations with APIs

Connect to any SaaS app within a workflow with automatic retries and monitoring. Automate the flow of data and events across cloud platforms.

Control Timing

Manage the timing of actions within workflows using Zenaton wait functions. Wait for an event or trigger an action if the event does not happen within a specified time frame.