Taskman

A simple and lightweight async/sync scheduling library for running tasks at certain times.

Supports

• Running on an interval e.g. every 5 minutes, every 2.5 seconds
• Running on a set date
• Run after an amount of time e.g. run after 10 hours
• Run on cron format e.g. 10 4 * * * (Run on the 10th minute of the 4th hour everyday)

Go to the docs here for more information and examples

Installation

Either run nimble install taskman or add requires "taskman" to your .nimble file

Examples

Every day get the IP address of the computer

import std/[httpclient, json]

let tasks = newAsyncScheduler()

var ip = ""

tasks.every(1.days) do () {.async.}:
  let client = newAsyncHttpClient()
  defer: client.close()
  ip = client
    .getContent("https://httpbin.org/ip")
    .parseJson()["origin"]
    .getStr()

waitFor tasks.start()

When the client first connects they get added to a queue and after 5 mins they are allowed to see the actual page

import src/taskman
import std/asynchttpserver
import std/sets

let tasks = newAsyncScheduler()


var allowed: HashSet[string]

proc cb(req: Request) {.async, gcsafe.} =
  if req.hostname notin allowed:
    # Add the client to the wait list
    tasks.wait(5.minutes) do () {.async.}:
      # Once the wait is over, allow them in
      allowed.incl req.hostname
    await req.respond(Http200, "You can join in 5 minutes")
  else:
    await req.respond(Http200, "Hello again!")

# This is NOT how you should be using asyncHttpServer
# This is just a basic example
var server = newAsyncHttpServer()
server.listen 8080.Port
echo "Running on port 8080"
while true:
  waitFor server.acceptRequest(cb)