ojob.yaml

# oJob common jobs
# Copyright 2023 Nuno Aguiar

jobs:
# OJOB PASS
# ----------------
- name : ojob pass
  typeArgs:
    noLog: true 
    shortcut:
      name  : pass
      keyArg: __args
      args  :
        debug       : __debug
        templateArgs: __templateArgs
  help :
    text   : Placeholder/pass job to allow for arguments injection
    expects:
    - name: __args
      desc: The args to inject
    - name: __debug
      desc: Boolean to indicate that args to be inject should be printed before
    - name: __templateArgs
      desc: Boolean, true by default, to indicate to apply template to each string in args (use only if typeArgs.noTemplateArgs = false OR job.templateArgs = true)
  check: 
    in:
      __args        : isMap.default({})
      __debug       : toBoolean.isBoolean.default(false)
      __templateArgs: toBoolean.isBoolean.default(true)
  exec : |
    var ar = clone(args.__args)
    // Process templateArgs
    if (args.__templateArgs) {
      traverse(ar, (aK, aV, aP, aO) => {
        if (isNull(aV)) aO[aK] = __
        if (isString(aV) && aV.indexOf("{{") >= 0) {
          aO[aK] = templify(aV, args)
        }
      })
    } else {
      // Process nulls
      traverse(ar, (aK, aV, aP, aO) => {
        if (isNull(aV)) aO[aK] = __
      })
    }

    if (args.__debug) cprint( ow.format.withSideLine(printTreeOrS(ar, __, { bgcolor: "BG(235)" }), __, "FG(240)", "BG(235)", ow.format.withSideLineThemes().openBottomCurvedRect) )

    delete args.__argsp
    delete args.__debug
    delete args.__templateArgs
    args = merge(args, ar)

# OJOB DEBUG
# ----------------
- name : ojob debug
  typeArgs:
    noLog   : true
    shortcut:
      name  : jobdebug
      keyArg: job
      args  :
        lineColor  : lineColor
        textColor  : textColor
        theme      : theme
        emoticons  : emoticons
        signs      : signs
        includeTime: includeTime
  help :
    text: Outputs the current args and res values to help debug an ojob flow.
  exec : |
    ow.loadFormat()
    print("")
    cprint( ow.format.withSideLine("ARGS:", __, "FG(240)", "BG(240),BOLD", ow.format.withSideLineThemes().openBottomCurvedRect) )
    cprint( ow.format.withSideLine(colorify(args, {bgcolor:"BG(235)"}), __, "FG(240)", "BG(235)", ow.format.withSideLineThemes().openTopCurvedRect) )
    cprint( ow.format.withSideLine("RES:", __, "FG(240),BOLD", "BG(240),BOLD", ow.format.withSideLineThemes().openBottomCurvedRect) )
    cprint( ow.format.withSideLine(colorify($get("res"), {bgcolor:"BG(235)"}), __, "FG(240)", "BG(235)", ow.format.withSideLineThemes().openTopCurvedRect) )

# --------------------
- name: ojob job debug
  typeArgs:
    noLog: true
    shortcut:
      name  : jobsdebug
      keyArg: jobs
      args  :
        lineColor  : lineColor
        textColor  : textColor
        theme      : theme
        emoticons  : emoticons
        signs      : signs
        includeTime: includeTime
  help: 
    text   : | 
      Provides an alternative to print based debug.

      Example:
        # ----------------
        - name: Sample job
          exec: |
            //@ Declaring array
            var ar = [ 0, 1, 2, 3, 4, 5 ]

            //@ Start cycle
            var ii = 0;
            while(ii < ar.length) {
              print("II = " + ii)
              ii++
              //# ii == 3
            }
            //@ End cycle
            //? ii

            //?s args
            //?y args
    expects:
    - name: job
      desc: The job to change to include debug
    - name: jobs
      desc: The jobs array to change to include debug
    - name: lineColor
      desc: The line color around the debug info
    - name: textColor
      desc: The text color around the debug info
    - name: theme
      desc: The withSideLineThemes theme to use
    - name: emoticons
      desc: If emoticons should be used or not
    - name: signs
      desc: "A custom map of emoticons (keys: checkpoint, assert and print)"
    - name: includeTime
      desc: A boolean value to indicate if a time indication should be included
  check:
    in:
      job        : isString.default(__)
      jobs       : isArray.default([])
      lineColor  : isString.default("FG(220)")
      textColor  : isString.default("BG(230),BLACK")
      lineError  : isString.default("FG(220)")
      textError  : isString.default("BG(196),FG(255),BOLD")
      theme      : isString.default("doubleLineBothSides")
      emoticons  : toBoolean.isBoolean.default(true)
      signs      : isMap.default(__)
      includeTime: toBoolean.isBoolean.default(false)
  exec: |
    var OAF_DEBUG_ARGS
    if (isMap(OAF_DEBUG_ARGS)) args = merge(OAF_DEBUG_ARGS, args)
    
    args.signs     = _$(args.signs, "signs").isMap().default({
      checkpoint: 0x1F37A,
      assert    : 0x1F44D,
      print     : 0x1F50E,
      error     : 0x1F621,
      time      : "🕒"
    })
 
    if (isDef(args.job) && args.jobs.length == 0) args.jobs.push(args.job)

    if (isUnDef(getEnv("OJOB_DEBUG")) || toBoolean(getEnv("OJOB_DEBUG"))) {
      ow.loadFormat()
      var ch = ow.oJob.getJobsCh()

      if (args.jobs.length == 0) args.jobs = ch.getKeys().filter(j => j.name != "ojob job debug").map(j => j.name)

      var owd = false
      if (isDef(ow.loadDebug)) {
        ow.loadDebug()
        ow.debug.register()
        owd = true
      }

      args.jobs.forEach(jj => {
        var job = ch.get({ name: jj })
        
        if (owd) {
          if (isUnDef(job.lang) || (isDef(job.lang) && (job.lang == "oaf" || job.lang == "js") ) ) {
            job.exec = ow.debug.debug(job.exec, args, true)
          }
        } else {
          var _m = (s, c) => {
            var _s = ";try{"
            if (isDef(c)) _s += "if(" + c + ") {"
            var _t = (args.includeTime ? "(new Date()).toISOString() +\" | \" + " : "")
            _s += "cprint(ow.format.withSideLine(" + _t + s + ", __, \"" + args.lineColor + "\", \"" + args.textColor + "\", ow.format.withSideLineThemes()." + args.theme + ")) "
            if (isDef(c)) _s += "}"
            _s += "}catch(__e_debug){cprint(ow.format.withSideLine(" + _t + "' " + sign.error + " ' + String(__e_debug), __, \"" + args.lineError + "\", \"" + args.textError + "\", ow.format.withSideLineThemes()." + args.theme + "))};"
            return _s
          }

          var sign
          if (args.emoticons) {
            sign = args.signs
            if (isNumber(sign.checkpoint)) sign.checkpoint = ow.format.string.unicode(sign.checkpoint)
            if (isNumber(sign.assert)) sign.assert = ow.format.string.unicode(sign.assert)
            if (isNumber(sign.print)) sign.print = ow.format.string.unicode(sign.print)
            if (isNumber(sign.error)) sign.error = ow.format.string.unicode(sign.error)
          }
          sign.checkpoint = _$(sign.checkpoint).default("@")
          sign.assert     = _$(sign.assert).default("#")
          sign.print      = _$(sign.print).default("?")
          sign.error      = _$(sign.error).default("!")

          job.exec = job.exec.split("\n").map(line => {
            var l

            // checkpoint equivalent
            l = line.trim().match(/\/\/\@ (.+)$/)
            if (isArray(l)) {
              var s = l[1]
              line = line.replace(/\/\/\@ (.+)$/, _m("\" " + sign.checkpoint + " " + s.replace(/\"/g, "\\\"") + "\""))
            }

            // assert equivalent
            l = line.trim().match(/\/\/\# (.+)$/)
            if (isArray(l)) {
              var s = l[1]
              line = line.replace(/\/\/\# (.+)$/, _m("\" " + sign.assert + " " + s + "\"", s))
            }

            // print equivalent
            l = line.trim().match(/\/\/\? (.+)$/)
            if (isArray(l)) {
              var s = l[1]
              line = line.replace(/\/\/\? (.+)$/, _m("\" "+ sign.print + " " + s + " = \" + stringify(" + s + ") + \"\""))
            }

            // slon print equivalent
            l = line.trim().match(/\/\/\?s (.+)$/)
            if (isArray(l)) {
              var s = l[1]
              line = line.replace(/\/\/\?s (.+)$/, _m("\" " + sign.print + " " + s + " = \" + af.toSLON(" + s + ") + \"\""))
            }

            // yaml print equivalent
            l = line.trim().match(/\/\/\?y (.+)$/)
            if (isArray(l)) {
              var s = l[1]
              line = line.replace(/\/\/\?y (.+)$/, _m("\" " + sign.print + " " + s + " = \" + af.toYAML(" + s + ") + \"\""))
            }

            return line
          }).join("\n")
        }
        
        ch.set({ name: jj }, job)
      })
    }

# OJOB GET PM
# ------------------
- name : ojob get pm
  args :
    __key: args
  check:
    in:
      __key: isString.default("res")
  exec : |
    var out = __pm

    if (isDef(__pm._map))  out = __pm._map
    if (isDef(__pm._list)) out = __pm._list

    if (args.__key == "args") {
      args = merge(args, out)
    } else {
      $set(args.__key, out)
    }


    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB GET
# ---------------
- name : ojob get
  typeArgs:
    shortcut:
      name  : get
      keyArg: __key
      args  :
        path: __path
  help : 
    text   : Retrieves a specific map key (or path) using $get
    expects:
    - name: __key
      desc: Map key to retrieve (key is also checked for compatibility)
    - name: __path
      desc: The path to consider from the __key
  check:
    in:
      __key : isString.default("res")
      __path: isString.default("@")
  exec : |
    if (isUnDef(args.__key) && isDef(args.key)) args.__key = args.key
  
    var res = args.__key == "args" ? $path(args, args.__path) : $path($get(args.__key), args.__path)
    if (isArray(res)) res = { _list: res }
    args = merge(args, res)

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB SET
# ---------------
- name : ojob set
  typeArgs:
    shortcut:
      name  : set
      keyArg: __key
      args  :
        path        : __path
        data        : __data
        templateArgs: __templateArgs
        debug       : __debug
  help : 
    text   : Sets a "key" with the current value on a "path", or provided data, using $set
    expects:
    - name: __key
      desc: Map key
    - name: __path
      desc: A key or path to a value from the current args
    - name: __data
      desc: If defined, will set the provided data (with templateArgs or not)
    - name: __templateArgs
      desc: If defined, will apply template to each entry in __data
    - name: __debug
      desc: If defined, will print the current args
  check:
    in:
      __key         : isString.default("res")
      __path        : isString.default(__)
      __data        : isMap.default(__)
      __templateArgs: toBoolean.isBoolean.default(true)
      __debug       : toBoolean.isBoolean.default(false)
  exec : |
    var r
    if (isDef(args.__path)) {
      r = $path(args, args.__path)
    } else if (isDef(args.__data)) {
      r = args.__data
      if (args.__templateArgs) {
        traverse(r, (aK, aV, aP, aO) => {
          if (isNull(aV)) aO[aK] = __
          if (isString(aV) && aV.indexOf("{{") >= 0) {
            aO[aK] = templify(aV, args)
          }
        })
      }
    } else {
      r = args
    }

    delete r.__key
    delete r.__path
    delete r.__data
    delete r.__debug
    delete r.__templateArgs
    if (args.__debug) cprint( ow.format.withSideLine(printTreeOrS(r, __, { bgcolor: "BG(235)" }), __, "FG(240)", "BG(235)", ow.format.withSideLineThemes().openBottomCurvedRect) )

    if (isDef(r) && args.__key != "args") $set(args.__key, r)

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB UNSET
# -----------------
- name : ojob unset
  typeArgs:
    shortcut:
      name  : unset
      keyArg: __key
  help :
    text   : Unsets a "key" using $unset
    expects:
    - name: __key
      desc: Map key
    check  :
      in:
        __key: isString.default("res")
  exec : |
    $unset(args.__key)

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB FILE GET
# --------------------
- name : ojob file get
  typeArgs:
    noLog   : true
    shortcut:
      name  : fileget
      keyArg: __file
      args  :
        path : __path
        cache: __cache
        ttl  : __ttl
        out  : __out
        key  : __key
  help :
    text   : "Retrieves a specific map key (or path) from an YAML or JSON file provided."
    expects:
    - name    : __file
      desc    : The file path to an YAML or JSON file
      required: true
    - name: __path
      desc: Path of the file contents
    - name: __cache
      desc: "Boolean value that if false it won't cache the file contents (default: true)"
    - name: __ttl
      desc: If cache is enabled lets you define a numeric ttl
    - name: __out
      desc: The path on args to set the map key/path contents
    - name: __key
      desc: If __out is not defined will set the content into the provided key
  check:
    in:
      __file : isString 
      __path : isString.default("@")
      __cache: toBoolean.isBoolean.default(true)
      __ttl  : isNumber.default(__)
      __out  : isString.default(__)
      __key  : isString.default("res")
  exec : |
    var res;
    if (args.__cache) {
      var c = $cache("__ojob_file_get");
      if (isDef(args.__ttl)) c= c.ttl(args.__ttl);
      c = c.fn(aK => {
        if (isDef(aK.file)) {
          if (aK.file.endsWith(".json")) {
            return io.readFileJSON(aK.file);
          } else {
            if (/\.ya?ml$/.test(aK.file)) {
              return io.readFileYAML(aK.file);
            } else {
              return { error: "Not an yaml, yml or json file."};
            }
          }
        } else {
          return {}
        }
      })
      .create();

      res = c.get({ file: args.__file });
    } else {
      if (args.__file.endsWith(".json")) {
        res = io.readFileJSON(args.__file);
      } else {
        if (/\.ya?ml$/.test(args.__file)) {
          res = io.readFileYAML(args.__file);
        } else {
          res = { error: "Not an yaml, yml or json file."};
        }
      }
    }

    res = $path(res, args.__path)
    if (isDef(args.__out)) {
      $$(args).set(args.__out, res)
    } else {
      if (isDef(args.__key)) {
        $set(args.__key, res)
      } else {
        Object.keys(res).forEach(r => $$(args).set(r, res[r]))
      }
    }

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB TEMPLATE
# --------------------
- name : ojob template
  typeArgs:
    shortcut:
      name  : template
      keyArg: template
      args  :
        templateFile: templateFile
        data        : data
        dataFile    : dataFile
        outputFile  : outputFile
        key         : __key
        tpath       : __tpath
        dpath       : __dpath
        outPath     : __outPath
        out         : __out
  help :
    text: Applies the OpenAF template over the provided data producing an output.
    expects:
    - name: __key
      desc: The key that holds template and/or data (default to 'res'). If 'args' it will use the current arguments.
    - name: __tpath
      desc: The path in __key where a string with the template can be found.
    - name: __dpath
      desc: The path in __key where a map/array data to use can be found.
    - name: __out
      desc: The output will be stored into the provided key (defaults to 'res')
    - name: __outPath
      desc: If defined the $set path where __out will be set in the provided key.
    - name: template
      desc: If defined, will be used as template
    - name: templateFile
      desc: If defined, it will use the provided template file.
    - name: data
      desc: If defined, will be used as data
    - name: dataFile
      desc: If defined, it will use the provided data file (either yaml or json).
    - name: outputFile
      desc: If defined, the output will be written to the provided file path.
    returns:
    - name: output
      desc: If no outputFile is provided this will hold the output of applying the template with the provided data
  check:
    in:
      __key       : isString.default("res")
      __tpath     : isString.default("@")
      __dpath     : isString.default("@")
      __out       : isString.default("res")
      __outPath   : isString.default("")
      templateFile: isString.default(__)
      dataFile    : isString.default(__)
      outputFile  : isString.default(__)
  exec : |
    ow.loadTemplate()

    ow.template.addConditionalHelpers()
    ow.template.addFormatHelpers()
    ow.template.addOpenAFHelpers()

    var data, template

    if (isDef(args.data)) {
      data = args.data
    } else {
      data = args.__key == "args" ? $path(args, args.__dpath) : $path($get(args.__key), args.__dpath)
    }

    if (isDef(args.dataFile)) {
      if (args.dataFile.match(/\.ya?ml$/i)) {
        data = io.readFileYAML(args.dataFile)
      } else {
        data = io.readFileJSON(args.dataFile)
      }
    }

    if (isDef(args.template)) {
      template = args.template
    } else {
      template = args.__key == "args" ? $path(args, args.__tpath) : $path($get(args.__key), args.__tpath)
    }

    if (isDef(args.templateFile)) {
      template = io.readFileString(args.templateFile)
    }

    if (isDef(args.logJob)) $job(args.logJob, args)
    var _r = templify(template, data)
    
    if (isDef(args.outputFile)) {
      io.writeFileString(args.outputFile, _r)
    } else {
      if (args.__out == "args") {
        if (isDef(args.__outPath) && args.__outPath.length > 0) $$(args).set(args.__outPath, _r); else args.output = _r
      } else {
        var __r = {}
        if (isDef(args.__outPath) && args.__outPath.length > 0) $$(__r).set(args.__outPath, _r); __r.output = _r
        $set(args.__out, __r)
      }
    }

# ---------------------------
- name : ojob template folder
  typeArgs:
    shortcut:
      name  : templateFolder
      keyArg: templateFolder
      args  :
        templatePath: __templatePath
        data        : data
        dataFile    : dataFile
        outputFolder: outputFolder
        key         : __key
        dpath       : __dpath
        logJob      : logJob
        metaTemplate: metaTemplate
  help :
    text: >
      Given a templateFolder it will execute 'ojob template' for each (recursively), with the provided data, to output to outputFolder.
      Optionally metaTemplate can be use where each json/yaml file in templateFolder all or part of the arguments for 'ojob template'.
    expects:
    - name: templateFolder
      desc: The original folder where the templates are located.
      required: true
    - name: __templatePath
      desc: If defined, will apply a $path string over the recursive list of files in templateFolder.
    - name: outputFolder
      desc: The path where the output should be stored.
      required: true
    - name: data
      desc: If defined, will be used as data
    - name: dataFile
      desc: If defined, it will use the provided data file (either yaml or json).
    - name: __key
      desc: The key that holds template and/or data (default to 'res'). If 'args' it will use the current arguments.
    - name: __dpath
      desc: The path in __key where a map/array data to use can be found.
    - name: logJob
      desc: A ojob job to log the 'ojob template' activity (receives the same arguments as 'ojob template')
    - name: metaTemplate
      desc: Boolean that if 'true' will interpret any json/yaml file, in the templateFolder, as a map/array of arguments to use when calling 'ojob template' overriden the defaults.
  check:
    in:
      templateFolder: isString
      __templatePath: isString.default("@")
      outputFolder  : isString
      dataFile      : isString.default(__)
      __key         : isString.default("res")
      __dpath       : isString.default("@")
      logJob        : isString.default(__)
      metaTemplate  : toBoolean.isBoolean.default(false)
  exec : |
    var data
    if (isDef(args.data)) {
      data = args.data
    } else {
      data = args.__key == "args" ? $path(args, args.__dpath) : $path($get(args.__key), args.__dpath)
    }
    if (isDef(args.dataFile)) {
      if (args.dataFile.match(/\.ya?ml$/i)) {
        data = io.readFileYAML(args.dataFile)
      } else {
        data = io.readFileJSON(args.dataFile)
      }
    }

    var lst = []
    $path(listFilesRecursive(args.templateFolder), args.__templatePath).forEach(f => {
      var _d = {
        templateFile : f.filepath,
        outputFile   : f.filepath.replace(new RegExp("^" + args.templateFolder), args.outputFolder),
        data         : data,
        logJob       : args.logJob
      }
      if (args.metaTemplate && f.filename.match(/\.(ya?ml|json)$/i)) {
        var _t
        if (f.filename.match(/\.ya?ml$/i)) {
          _t = io.readFileYAML(f.filepath)
        } else {
          _t = io.readFileJSON(f.filepath)
        }
        delete _d.templateFile

        if (isMap(_t)) {
          if (isDef(_t.outputFile) && !_t.outputFile.startsWith("/")) _t.outputFile = args.outputFolder + "/" + _t.outputFile
          lst.push(merge(_d, _t))
        }
        if (isArray(_t)) {
          lst = lst.concat(_t.map(_r => {
            if (isDef(_r.outputFile) && !_r.outputFile.startsWith("/")) _r.outputFile = args.outputFolder + "/" + _r.outputFile
            return merge(_d, _r)
          }))
        }
      } else {
        lst.push(_d)
      }
    })

    io.mkdir(args.outputFolder)
    $job("ojob template", lst)

# ------------------------
- name : ojob find/replace
  typeArgs:
    noLog   : true
    shortcut:
      name  : findReplace
      keyArg: __key
      args  :
        path       : __path
        inputKey   : inputKey
        inputPath  : inputPath
        inputFile  : inputFile
        outputFile : outputFile
        useRegExp  : useRegExp
        flagsRegExp: flagsRegExp
        logJob     : logJob
  help :
    text   : Performs an in-memory find/replace on a provided string or file and outputs to args.output or, optionally, to a file.
    expects:
    - name: __key
      desc: The key that holds template and/or data (default to 'res'). If 'args' it will use the current arguments.
    - name: __path
      desc: The path in __key where a map of replacements ([text/regexp]:[replace text]) can be found.
    - name: inputKey
      desc: If defined, indicates the key that holds the string of data to replace.
    - name: inputPath
      desc: If defined with inputKey, indicates the path to use to select the string of data to replace.
    - name: inputFile
      desc: If defined the contents to be replaced will be read from the inputFile.
    - name: outputFile
      desc: If defined will output of the content replacement to the defined file.
    - name: useRegExp
      desc: Boolean value to determine if the map of replacements will be interpreted as a regexp or text.
    - name: flagsRegExp
      desc: If useRegExp=true the JavaScript reg exp flags to use (defaults to 'g')
    - name: logJob
      desc: Optionally provide a logging job with the current args and __op with 'read' or 'write'
    returns:
    - name: output
      desc: If outputFile is not defined the output will contain the content replacement 
  check: 
    in:
      __key      : default("res")
      __path     : isString.default("@")
      inputKey   : isString.default(__)
      inputPath  : isString.default(__)
      inputFile  : isString.default(__)
      outputFile : isString.default(__)
      useRegExp  : toBoolean.isBoolean.default(false)
      flagsRegExp: isString.default("g")
      logJob     : default(__)
  exec : |
    var data
    if (isMap(args.__key)) {
      data = args.__key
    } else {
      data = $path(args.__key == "args" ? args : $get(args.__key), args.__path)
    }
    _$(data, "__key data").isMap().$_()

    if (isUnDef(args.inputKey) && isUnDef(args.inputFile)) throw "Need args inputKey or inputFile"

    var escapeRegExp = aString => aString.replace(/[.*+?^${}()|[\]\\]/g, '\\$&')

    args.__op = "read"
    if (isDef(args.logJob)) $job(args.logJob, args)

    var content
    if (isDef(args.inputKey)) {
      content = $path(args.inputKey == "args" ? args : $get(args.inputKey), args.inputPath)
    } else {
      content = io.readFileString(args.inputFile)
    }

    Object.keys(data).forEach(k => {
      content = content.replace(new RegExp(args.useRegExp ? k : escapeRegExp(k), (args.useRegExp ? args.flagsRegExp : "g")), data[k])
    })

    args.__op = "write"
    if (isDef(args.logJob)) $job(args.logJob, args)
    if (isDef(args.outputFile)) {
      io.writeFileString(args.outputFile, content)
    } else {
      args.output = content
    }

# OJOB CHANNEL
# ------------
- name : ojob channel
  typeArgs:
    shortcut:
      name  : ch
      keyArg: __name
      args  :
        op   : __op
        key  : __key
        kpath: __kpath
        k    : key
        ks   : keys
        v    : value
        vs   : values
        vpath: __vpath
        extra: extra
  help:
    text: Provides a set of operations over an OpenAF channel
    expects:
    - name: __name
      desc: The name of the OpenAF channel to use
      required: true
    - name: __op
      desc: The operation to perform (e.g. setall, set, get, unset, unsetall, getkeys, getall and size)
      required: true
    - name: __key
      desc: The key from where to retrieve the operation arguments (args to retrive from arguments)
    - name: __kpath
      desc: If defined, the path over the values retrieved from __key where the key or keys of the operation are defined
    - name: key
      desc: If defined, the key to use with the operations set, get and unset
    - name: keys
      desc: If defined, the set of fields to use with the operations setall and unsetall
    - name: value
      desc: If defined, the value to use with the operations set, get and unset
    - name: values
      desc: If defined, an array of values to use with the operations setall and unsetall
    - name: __vpath
      desc: If defined, the path over the values retrieved from __key where the value or values of the operation are defined
    - name: extra
      desc: If defined, will provide an extra argument (usually a map), depending on channel type, for the getall and getkeys operations.
    returns:
    - name: _list
      desc: If __key == 'args' will return the results of getall and getkeys
    - name: _map
      desc: If __key == 'args' will return the results of get
    - name: size
      desc: If __key == 'args' will return the size of the channel
  check:
    in:
      __name  : isString
      __op    : isString
      key     : default(__)
      keys    : default(__)
      value   : default(__)
      values  : default(__)
      __kpath : isString.default(__)
      __vpath : isString.default(__)
      extra   : default(__)
      __key   : default("res")
  exec : |
    var getKV = () => {
      var r = { k: __, v: __ }

      if (isDef(args.key)) r.k = args.key
      if (isDef(args.keys)) r.k = args.keys
      if (isDef(args.value)) r.v = args.value
      if (isDef(args.values)) r.v = args.values
      if (args.__key == "args") {
        if (isDef(args.__kpath)) r.k = $path(args, args.__kpath)
        if (isDef(args.__vpath)) r.v = $path(args, args.__vpath)   
      } else {
        if (isDef(args.__kpath)) r.k = $path($get(args.__key), args.__kpath)
        if (isDef(args.__vpath)) r.v = $path($get(args.__key), args.__vpath) 
      }
      return r 
    }
    switch (args.__op.toLowerCase()) {
    case "getall":
      var _res = $ch(args.__name).getAll(args.extra)
      if (isUnDef(_res)) _res = []
      if (args.__key != "args") $set(args.__key, _res); else args._list = _res
      break
    case "setall":
      var _r = getKV()
      $ch(args.__name).setAll(_r.k, _r.v)
      break
    case "set":
      var _r = getKV()
      $ch(args.__name).set(_r.k, _r.v)
      break
    case "get":
      var _r = getKV()
      var _res = $ch(args.__name).get(_r.k)
      if (isUnDef(_res)) _res = {}
      if (args.__key != "args") $set(args.__key, _res); else args._map = _res
      break
    case "unset":
      var _r = getKV()
      $ch(args.__name).unset(_r.k)
      break
    case "unsetall":
      var _r = getKV()
      $ch(args.__name).unsetAll(_r.k, _r.v)
      break
    case "getkeys":
      var _res = $ch(args.__name).getKeys(args.extra)
      if (isUnDef(_res)) _res = []
      if (args.__key != "args") $set(args.__key, _res); else args._list = _res
      break
    case "size":
      var _res = $ch(args.__name).size()
      if (isUnDef(_res)) _res = -1
      if (args.__key != "args") $set(args.__key, _res); else args.size = _res
    }

# -----------------
- name : ojob print
  typeArgs:
    noLog   : true
    shortcut:
      name  : print
      keyArg: msg
      args  :
        key  : __key
        path : __path
        level: level
  help :
    text: Prints a message line given an OpenAF template
    expects:
    - name: __key
      desc: Map key to retrieve ('args' for arguments)
    - name: __path
      desc: The path to consider from the __key
    - name: msg
      desc: The message template to use
      required: true
    - name: level
      desc: The level of the message (info (default) or error)
  check:
    in:
      __key  : isString.default("res")
      __path : isString.default("@")
      msg    : isString
      level  : isString.oneOf(["info","error"]).default("info")
  exec : |
    var data = args.__key == "args" ? $path(args, args.__path) : $path($get(args.__key), args.__path)

    switch(args.level) {
    case "error": tprintErr(args.msg, data); break
    case "info" : tprint(args.msg, data)   ; break
    }

# -----------------------
- name    : ojob print md
  typeArgs:
    noLog: true
    shortcut:
      name  : printmd
      keyArg: __text
      args  :
        outputMD: __outputMD
  help    :
    text   : Parses an input text as simple ascii markdown
    expects:
    - name: __text
      desc: The text template to parse.
    - name: __outputMD
      desc: A boolean flag that if true will no parse the input text
  check   :
    in:
      __text    : isString
      __outputMD: toBoolean.isBoolean.default(false)
  exec    : |
    var cargs = clone(args)
    delete cargs.__text
    if (args.__outputMD)
      printnl($t(args.__text, cargs))
    else
      printnl(ow.format.withMD($t(args.__text, cargs)))

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# ---------------
- name : ojob log
  typeArgs:
    noLog: true
    shortcut:
      name  : log
      keyArg: msg
      args  :
        key    : __key
        path   : __path
        level  : level
        options: options
  help :
    text: Logs a message line given an OpenAF template
    expects:
    - name: __key
      desc: Map key to retrieve ('args' for arguments)
    - name: __path
      desc: The path to consider from the __key
    - name: msg
      desc: The message template to use
      required: true
    - name: level
      desc: The level of the message (info (default), warn or error)
    - name: options
      desc: Extra options to provide to the tlog* functions. See more in the help of tlog, tlogErr and tlogWarn.
  check:
    in:
      __key  : isString.default("res")
      __path : isString.default("@")
      msg    : isString
      level  : isString.oneOf(["info","warn","error"]).default("info")
      options: isMap.default({})
  exec : |
    var data = args.__key == "args" ? $path(args, args.__path) : $path($get(args.__key), args.__path)

    switch(args.level) {
    case "warn" : tlogWarn(args.msg, data, args.options); break
    case "error": tlogErr(args.msg, data, args.options) ; break
    case "info" : tlog(args.msg, data, args.options)    ; break
    }

# OJOB FUNCTION
# --------------------
- name : ojob function
  typeArgs:
    noLog   : true
    shortcut:
      name  : fn
      keyArg: __fn
      args  :
        key   : __key
        path  : __path
        fnPath: __fnPath
  help :
    text : |
      Executes the provided function mapping any args to the function arguments using the odoc help available for the provided function.
      Note: accessing odoc might be slow on a first execution.
    expects:
    - name: __key
      desc: The key string to retrieve previous results (defaults to 'res')
      required: true
    - name: __fn
      desc: The function to execute
    - name: __path
      desc: If defined the args path for the function arguments to consider
    - name: __fnPath
      desc: If defined the args path where to set the function result
  check:
    in:
      __fn : isString
      __key: isString.default("res")
  exec: |
    if (args.__fn.indexOf(".") < 0) args.__fn = "global." + args.__fn
    var res = $fnM(args.__fn, (isDef(args.__path) ? $path(args, args.__path) : args))
    if (isDef(args.__fnPath)) && isString(args.__fnPath)) res = $$({}).set(args.__fnPath, res)
    if (isDef(args.__key)) && isString(args.__key)) $set(args.__key, res); else args = merge(args, res)

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB OUTPUT
# -----------------
- name: ojob output
  typeArgs:
    noLog   : true
    shortcut:
      name  : output
      keyArg: __key
      args  :
        path    : __path
        format  : __format
        title   : __title
        internal: __internal
        query   : __query
        csv     : __csv
        function: __function
  help: 
    text   : Prints the current arguments to the console.
    expects:
    - name: __key
      desc: The key string to retrieve previous results (defaults to 'res'). If "args" will retrieve from current args.
    - name: __path
      desc: A path string to a map/array over the results set on key. 
    - name: __format
      desc: The output format (e.g. see ow.oJob.output help)
    - name: __title
      desc: Encapsulates the output map/array with a title key.
    - name: __internal
      desc: Boolean value that if true it will display the internal oJob entries on the arguments (default false)
    - name: __function
      desc: One of the OpenAF's print or log functions available 
  exec: |
    if (isUnDef(args.__key) && isDef(args.key)) args.__key = args.key
    if (isUnDef(args.__path) && isDef(args.path)) args.__path = args.path
    if (isUnDef(args.__format) && isDef(args.format)) args.__format = args.format
    if (isUnDef(args.__title) && isDef(args.title)) args.__title = args.title
    if (isUnDef(args.__internal) && isDef(args.internal)) args.__internal = args.internal
    if (isString(args.__function)) {
      if (args.__function.indexOf("print") >= 0 || args.__function.indexOf("log") >= 0) {
        if (!(af.fromJavaArray(af.getScopeIds()).map(r => String(r)).indexOf(args.__function) >= 0)) {
          throw "__function '" + args.__function + "' not found."
        }
        args.__function = global[args.__function]
      } else {
        throw "__function needs to be a 'print' or 'log' function"
      }
    } else {
      args.__function = __
    }

    args.__key = _$(args.__key, "key").isString().default("res");
    if (args.__key == "") args.__key = "res"
    var res    = args.__key == "args" ? args : $get(args.__key)
    if (isUnDef(res)) res = args;
    if (isDef(res) && !isNull(res) && !toBoolean(args.__internal)) {
       delete res.objId;
       delete res.execid;
       delete res.id;
    }

    if (isDef(args.format)) { args.__format = args.format; delete args.format; }
    if (isDef(args.__path)) { res = $path(res, args.__path); delete args.__path; }
    if (isMap(res) && isDef(res._list)) res = res._list;
    if (isMap(res) && isDef(res._map))  res = res._map;

    if (isDef(args.__title)) {
      var r = {}; r[args.__title] = res;
      ow.oJob.output(r, args, args.__function)
    } else {
      ow.oJob.output(res, args, args.__function)
    }

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB FINAL REPORT
# -------------------------------
- name        : ojob final report
  to          : ojob report
  type        : shutdown
  help        : 
    text: Outputs a jobs report (e.g. job name, status, number of executions, total time, avg time and last execution) upon ojob termination
    expects:
    - name: __format
      desc: Can be json, yaml, table (default) or any other ow.oJob.output format

# OJOB FINAL DEPS REPORT
# ------------------------------------
- name        : ojob final deps report
  to          : ojob deps report
  type        : shutdown
  help        :
    text: Outputs a tree list for each defined job (excluding "ojob *") and a comma delimited list of dependencies with a status flag

# OJOB DEPS REPORT
# ------------------------------
- name        : ojob deps report
  help        :
    text: Outputs a tree list for each defined job (excluding "ojob *") and a comma delimited list of dependencies with a status flag
  exec        : |
    var runs = {}
    $from( $ch("oJob::log").getAll() )
    .notStarts("name", "ojob ")
    .select(r => {
      runs[r.name] = (r.start ? (r.success ? ansiColor("GREEN", "\u2713") : (r.deps ? (r.error ? ansiColor("RED", "\u2715") : ansiColor("BLUE", "\u25B7") ) : ansiColor("RED", "\u2715") )) : ansiColor("YELLOW", "\u23F8"))
    })

    var out = {}
    $from($ch("oJob::jobs").getAll()).notStarts("name", "ojob ").select(r => {
      out[r.name] = r.deps.map(s => runs[s]+" "+s).join(", ")
    })
    ow.oJob.output(out, { __format: "tree" } )

# OJOB REPORT
# -------------------------
- name        : ojob report
  help        : 
    text: Outputs a jobs report (e.g. job name, status, number of executions, total time, avg time and last execution)
    expects:
    - name: __format
      desc: Can be json, yaml, table (default) or any other ow.oJob.output format
  exec        : |
    ow.loadFormat(); print("\n");

    var logs = $ch("oJob::log").getAll();
    var report = $from(logs)
                 .notEquals("name", "ojob report")
                 .notEquals("name", "ojob final report")
                 .select(r => ({
          "Job name"  : r.name,
          "Status"    : (r.start ? (r.success ? "OK" : (r.deps ? (r.error ? "NOT OK!" : "executing") : "failed deps")) : "not started"),
          "# execs"   : r.count,
          "Total time": ow.format.elapsedTime4ms(r.totalTime, { abrev: true }),
          "Avg time"  : ow.format.elapsedTime4ms(r.avgTime, { abrev: true }),
          "Last exec" : (r.log.length > 0 ? ow.format.timeago($from(r.log).sort("-endTime").at(0).endTime) : "n/a")
      }));

    report.push({
      "Job name"  : "TOTAL:",
      "Status"    : "",
      "# execs"   : "",
      "Total time": ow.format.elapsedTime4ms((now() - $from(logs).sort("createDate").at(0).createDate)),
      "Avg time"  : "",
      "Last exec" : ""
    });

    args.__format = _$(args.__format).default("table");
    ow.oJob.output(report, args);

# OJOB SWITCH
# ------------------
- name: ojob options
  typeArgs:
    noLog: true
    shortcut:
      name  : optionOn
      keyArg: __optionOn
      args  :
        lowerCase: __lowerCase
        upperCase: __upperCase
        todos    : __todos
        default  : __default
        async    : __async
  help: 
    text: |
      Adds new "todo" entries depending on the value of a provided args variable.

      Example:

        __optionOn : mode
        __lowerCase: true
        __todos    :
          mode1:
          - Job 1
          - Job 2
          mode2:
          - Job 2
          - Job 3
        __default:
        - Job 2
    expects:
    - name: __optionOn
      desc: The variable in args that will define which set of "todo"s will be added (trimmed)
      required: true
    - name: __lowerCase
      desc: Boolean value to determine if should compare the optionOn in lower case (defaults to false)
    - name: __upperCase
      desc: Boolean value to determine if should compare the optionOn in upper case (defaults to false)
    - name: __todos
      desc: Map where each option value should have a list/array of "todo"s
      required: true
    - name: __default
      desc: Default array of "todo"s
    - name: __async
      desc: Boolean value that if true, run the todos in async mode
  check:
    in:
      __optionOn : isString
      __todos    : isMap
      __lowerCase: toBoolean.isBoolean.default(false)
      __upperCase: toBoolean.isBoolean.default(false)
      __default  : default([])
      __async    : toBoolean.isBoolean.default(false) 
  exec: |
    if (isUnDef(args.__optionOn) && isDef(args.optionOn)) args.__optionOn = args.optionOn
    if (isUnDef(args.__todos) && isDef(args.todos)) args.__todos = args.todos
    if (isUnDef(args.__lowerCase) && isDef(args.lowerCase)) args.__lowerCase = args.lowerCase
    if (isUnDef(args.__upperCase) && isDef(args.upperCase)) args.__upperCase = args.upperCase
    if (isUnDef(args.__default) && isDef(args.default)) args.__default = args.default

    if (isString(args.__default)) args.__default = [ args.__default ]

    var todoValue = String(args[args.__optionOn]).trim();
    if (args.__lowerCase) todoValue = todoValue.toLowerCase()
    if (args.__upperCase) todoValue = todoValue.toUpperCase()

    var res = {}, iargs = clone(args)
    delete iargs.__default
    delete iargs.__lowerCase
    delete iargs.__upperCase
    delete iargs.__todos
    delete iargs.__optionOn
    delete iargs.__async

    if (isDef(args.__todos[todoValue]) && isString(args.__todos[todoValue])) args.__todos[todoValue] = [ args.__todos[todoValue] ]
    var _l
    if (isDef(args.__todos[todoValue]) && isArray(args.__todos[todoValue])) {
      _l = { todo: args.__todos[todoValue] }
    } else {
      _l = { todo: args.__default }
    }

    // Prepare data
    _l.todo.forEach(job => {
      if (isString(job.args)) job.args = ow.oJob.__processArgs(job.args)
      if (isMap(job))
        job.args = merge(job.args, iargs)
      else
        job.args = iargs
    })

    if (args.__async) {
      $job("ojob parallel", merge(iargs, _l))
    } else {
      $job("ojob todo", merge(iargs, _l))
    }
    
# OJOB SEC GET
# -------------------
- name : ojob sec get
  typeArgs:
    noLog: true
    shortcut:
      name  : secget
      keyArg: secKey
      args  :
        secRepo    : secRepo
        secBucket  : secBucket
        secPass    : secPass
        secOut     : secOut
        secMainPass: secMainPass
        secFile    : secFile
        secDontAsk : secDontAsk
        secIgnore  : secIgnore
        secEnv     : secEnv
  help : 
    text   : This job will get a SBucket secret and map it to oJob's args
    expects:
    - name: secIn
      desc: The args path where all the remaining sec arguments should be read from (defaults to no path)
    - name: "[secIn].secOut"
      desc: The args path to be mapped with the secret (defaults to secIn)
    - name: "[secIn].secKey"
      desc: The SBucket key
    - name: "[secIn].secRepo"
      desc: The SBucket repository
    - name: "[secIn].secBucket"
      desc: The SBucket name
    - name: "[secIn].secPass"
      desc: The SBucket password
    - name: "[secIn].secMainPass"
      desc: The SBucket repository password
    - name: "[secIn].secFile"
      desc: Optional provide a specific sbucket file
    - name: "[secIn].secDontAsk"
      desc: Determine if passwords should be asked from the user (default=false)
    - name: "[secIn].secEnv"
      desc: If true will set everything to retrieve the secret from an env variable
    - name: "[secIn].secIgnore"
      desc: If true will ignore errors of sec parameters not being provided (default=false)
    returns:
    - name: "[secIn].[secOut]"
      desc: The args path to be mapped with the secret (defaults to secIn)
  check:
    in:
      secIn: isString.default("")
  exec : |
    ow.loadSec()
    var secIn = args.secIn
    if (secIn != "") secIn += ".";

    var secIgnore   = _$($$(args).get(secIn + "secIgnore"), "secIgnore").isBoolean().default(false);
    var secOut      = _$($$(args).get(secIn + "secOut"), "secOut").default(secIn != "" ? secIn.replace(/\.$/, "") : __);
    if (!secIgnore) _$($$(args).get(secIn + "secKey"), "secKey").$_();
    var secDontAsk  = toBoolean( _$($$(args).get(secIn + "secDontAsk"), "secDontAsk").default(false) );
    var secKey      = _$($$(args).get(secIn + "secKey"), "secKey").default(__);
    var secBucket   = _$($$(args).get(secIn + "secBucket"), "secBucket").default(__);
    var secPass     = _$($$(args).get(secIn + "secPass"), "secPass").default(__);
    var secFile     = _$($$(args).get(secIn + "secFile"), "secFile").default(__);
    var secRepo     = _$($$(args).get(secIn + "secRepo"), "secRepo").default(__);
    var secMainPass = _$($$(args).get(secIn + "secMainPass"), "secMainPass").default(__);
    var secEnv      = _$(toBoolean($$(args).get(secIn + "secEnv")), "secEnv").isBoolean().default(false)

    // Set to env variable
    if (secEnv) {
      secRepo = "system"
      secBucket = "envs"
      secDontAsk = true
    }

    if (!secDontAsk && isDef(secKey)) {
       secBucket = askDef(secBucket, "Sec bucket: ");
       if (isDef(secBucket) && isUnDef(secFile)) secPass = askDef(secPass, "Sec bucket '" + secBucket + "' pass: ", true);
       if (isDef(secRepo))                       secMainPass = askDef(secMainPass, "Sec repo '" + secRepo + "' pass: ", true);
    }

    if (isUnDef(secPass) && isDef(args.secPass))         secPass = args.secPass
    if (isUnDef(secMainPass) && isDef(args.secMainPass)) secMainPass = args.secMainPass

    if (isDef(secKey)) {
       var res = $sec(secRepo, secBucket, secPass, secMainPass, secFile).get(secKey);
       if (isUnDef(res)) throw "Couldn't retrieve secKey '" + secKey + "' from bucket '" + secBucket + "'!";
       if (isDef(secOut) && secOut.length > 0) {
         var prev = $$(args).get(secOut);
         $$(args).set(secOut, (isDef(prev) ? merge(prev, res) : res));
       } else {
         Object.keys(res).forEach(r => $$(args).set(r, res[r]));
       }
    } 

# OJOB SPLIT TO ITEMS
# --------------------------
- name : ojob split to items
  help : 
    text: | 
      Splits an args source into an array of maps (_list).

      Example:

        a source string with the value "abc, xyz, 1"
        + separator = ','
        transforms into:

        - item: abc
        - item: xyz
        - item: 1
    expects:
    - name: source
      desc: A object path to the string source to split
    - name: separator
      desc: The separator for the source string (defaults to \n)
  exec: |
    _$(args.source, "source").isString().$_();
    args.separator = _$(args.separator, "separator").isString().default("\n");

    ow.loadObj();
    args._list = String(ow.obj.getPath(args, args.source)).split(args.separator).map(r => {
      return { item: r };
    });

# OJOB QUERY
# -----------------
- name : ojob query
  typeArgs:
    noLog   : true
    shortcut:
      name  : query
      keyArg: __query
      args  :
        type : __type
        from : __from
        to   : __to
        toKey: __toKey
        key  : __key
  help : 
    text: Performs a query (using ow.obj.filter) to the existing args.
    expects:
    - name: __query
      desc: The query map for ow.obj.filter or af.fromNLinq
    - name: __type
      desc: The type of query to perform (e.g. path, sql or nlinq)
    - name: __from
      desc: The path to the args key to perform the query
    - name: __to
      desc: The path to where the results should be stored in args
    - name: __toKey
      desc: If __to not provided defaults to $set on the provided key
    - name: __key
      desc: If __from and/or __to not provided defaults to $get/$set on the provided key
  exec : |
    if (isUnDef(args.__from) && isDef(args.from)) args.__from = args.from
    if (isUnDef(args.__key) && isDef(args.key)) args.__key = args.key
    if (isUnDef(args.__query)) args.__query = {}

    if (isUnDef(args.__key)) args.__key = "res"
    var f = (args.__key == "args" ? args : $get(args.__key) )
    if (isDef(args.__from)) f = $path(f, args.__from)
   
    ow.loadObj()
    switch(args.__type) {
    case "path" : f = $path(f, args.__query); break 
    case "sql"  : f = $sql(f, args.__query); break
    case "nlinq": 
    default     : f = ( isString(args.__query) ? $from(f).query(af.fromNLinq(args.__query)) : $from(f).query(args.__query) )
    }

    if (args.__key == "args" && isUnDef(args.__toKey)) {
      $$(args).set(isDef(args.__to) ? args.__to : args.__from, f)
    } else {
      if (isDef(args.__toKey)) {
        $set(args.__toKey, f)
      } else {
        $set(args.__key, f)
      }
    }

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# OJOB ENV
# --------
- name : ojob set envs
  help : 
    text: Sets job args based on environment variables.
    expects:
    - name: envs
      desc: A map where each key corresponds to an environment variable and the value to the args path where it should be placed
  check:
    in:
      envs: isMap
  exec : |
    Object.keys(args.envs).forEach(key => {
      var p = args.envs[key];
      var v = getEnv(key);
      if (isDef(v) && !isNull(v)) $$(args).set(String(p), String(v));
    });

# OJOB CONTROL
# ------------

# --------------
- name : ojob if
  typeArgs:
    noLog   : true
    shortcut:
      name  : if
      keyArg: __condition
      args  :
        then : __then
        else : __else
        debug: __debug
  help :
    text: If the provided "condition" is evaluated as true it will execute the "then" jobs otherwise it will execute the "else" jobs
    expects:
    - name: __condition
      desc: "An OpenAF code condition with templating functionality (example: \"{{abc}} == 123\")"
    - name: __then
      desc: One job or a list of jobs to execute if the "condition" is true
    - name: __else
      desc: One job or a list of jobs to execute if the "condition" is false
    - name: __debug
      desc: Boolean to indicate if should log the original condition and the parsed condition for debug proposes
  check:
    in:
      __condition: isString
      __then     : default([])
      __else     : default([])
      __debug    : toBoolean.isBoolean.default(false)
  exec : |
    if (isString(args.__then)) args.__then = [ args.__then ]
    if (isString(args.__else)) args.__else = [ args.__else ]

    var c = String(args.__condition)
    delete args.__condition

    var t = clone(args.__then)
    delete args.__then

    var e = clone(args.__else)
    delete args.__else

    var d = Boolean(args.__debug)
    delete args.__debug

    var expr = templify(c, args).replace(/\n/g, "")
    if (d) log(" DEBUG | " + af.toSLON({ origCondition: " "+c+" ", parsedCondition: " "+expr+" " }))

    var res = af.eval(expr)
    if (d) log(" DEBUG | " + af.toSLON({ origCondition: " "+c+" ", result: res }))

    var fn = j => {
      j = ow.oJob.parseTodo(j)
      /*if (isString(j))               $job(j, args)
      if (isMap(j) && isDef(j.name)) $job(j.name, j.args)*/
      $job(j, args)
    }
    if (res) t.forEach(fn); else e.forEach(fn)

# ------------------
- name : ojob repeat
  typeArgs:
    noLog: true
    shortcut:
      name  : repeat
      keyArg: __time
      args  :
        todo: __jobs
  help : 
    text: Repeats sequentially, for a specific number of "times", the provided list of "jobs" (one or more)
    expects:
    - name: __times
      desc: The number of times to repeat the provided list of jobs
    - name: __jobs
      desc: One job or a list of jobs to execute each time
  check:
    in:
      __times: toNumber.isNumber
  exec : |
    if (!(isString(args.__jobs) || isArray(args.__jobs))) throw "The provided 'jobs' need to be one or a list of jobs."
    if (isUnDef(args.__jobs)) throw "No 'jobs' list was provided."

    if (isString(args.__jobs)) args.__jobs = [ args.__jobs ]
    var njobs = clone(args.__jobs)
    delete args.__jobs

    var ntimes = Number(args.__times)
    delete args.__times

    var iargs = clone(args)
    delete iargs.__jobs
    delete iargs.__time

    for(var n = 0; n < ntimes; n++) {
      $job("ojob todo", merge(iargs, { todo: njobs }))
    }

# ----------------------------
- name : ojob repeat with each
  typeArgs:
    noLog: true
    shortcut:
      name  : each
      keyArg: __path
      args  :
        key : __key
        todo: __jbos
  help : 
    text: Repeats the configured "jobs" (one or more jobs) sequentially for each element of the provided "key" list.
    expects:
    - name: __key
      desc: The key for an existing list or args
    - name: __path
      desc: The path to consider from __key
    - name: __jobs
      desc: One job or a list of jobs to execute each time
  check:
    in:
      __key : isString
      __path: isString.default("@")
  exec : |
    if (!(isString(args.__jobs) || isArray(args.__jobs))) throw "The provided 'jobs' need to be one or a list of jobs."
    if (isUnDef(args.__jobs)) throw "No 'jobs' list was provided."

    var ak = String(args.__key)
    var ap = String(args.__path)
    delete args.__key
    delete args.__path

    if (isString(args.__jobs)) args.__jobs = [ args.__jobs ]
    var njobs = clone(args.__jobs)
    delete args.__jobs

    var arr = ak == "args" ? $path(args, ap) : $path($get(ak), ap)
    if (!isArray(arr)) throw "The key/path '" + ak + "' is not an array/list."
    arr.forEach(elem => {
      njobs.forEach(j => {
        j = ow.oJob.parseTodo(j)
        $job(j, merge(args, elem))
      })
    })

# OJOB JOB
# --------

# -----------------
- name : ojob check
  typeArgs:
    noLog: true
    shortcut:
      name  : check
      keyArg: _checks
      args  :
        actions: _actions
  to   : ojob job

# ---------------
- name : ojob job
  typeArgs:
      noLog: true
  help : 
    text: |
      Provides a way to organize idempotent jobs. One or more "checks" jobs will be called to determine an args._action.
      Initially the args._action is set to "none". If the "checks" jobs determine an action it will call the corresponding
      jobs on "actions" jobs. If "_go=true" is not provided, instead of running, it will only return a plan of actions. 
      For example:

        - name: Write Hello World
          to  : ojob job
          args:
            _checks : Check Hello World
            _actions:
              create   : Create Hello World
              overwrite: Overwrite Hello World
              delete   : Delete Hello World
    expects:
    - name: _checks
      desc: A list of one or more jobs to be called to perform checks to determine an args._action
    - name: _actions
      desc: A map of possible values of args._action whose values are one or more jobs to execute
    - name: _go
      desc: A boolean value (defaults to false) that controls if the _actions jobs are called (when true) or not
  check:
    in:
      _go: toBoolean.isBoolean.default(false)
  exec : |
    if (isString(args._checks))  args._checks  = [ args._checks ]
    if (isString(args._actions)) args._actions = { none: args._actions }
    
    var hideArgs = ar => {
      var nar = clone(ar)
      delete nar._checks
      delete nar._actions
      return nar
    }

    args._action = "none"
    args._checks.forEach(r => {
      if (isString(r)) {
        var res = $job(r, hideArgs(args))
        if (isMap(res) && isString(res._action)) args._action = res._action 
      } else {
        logErr("oJob Job 'checks' must be job names")
      }
    })

    $ch("_ojob_plan").create()
    $ch("_ojob_plan").get({ name: job.name })
    var plan = []

    if (isDef(args._actions[args._action])) {
       // Do the action(s)
       var acts
       if (isArray(args._actions[args._action]))  acts = args._actions[args._action]
       if (isString(args._actions[args._action])) acts = [ args._actions[args._action] ]
       acts.forEach(s => {
         if (args._go) {
           $job(s, hideArgs(args))
         } else {
           plan.push(s)
         }
       })
    }

    $ch("_ojob_plan").set({ name: job.name }, { 
      name: job.name,
      action: args._action,
      "go?": args._go,
      plan: plan
    })

# ----------------------
- name : ojob job report
  help : 
    text: Outputs a job jobs report (e.g. job name, action and plan)
    expects:
    - name: __format
      desc: Can be json, yaml, table (default) or any other ow.oJob.output format
  exec : |
    ow.oJob.output($ch("_ojob_plan").getAll(), { __format: _$(args.__format).default("table") })
    
# ----------------------------
- name : ojob job final report
  type : shutdown
  to   : ojob job report
  help : 
    text: Outputs a job jobs report (e.g. job name, action and plan) upon ojob termination
    expects:
    - name: __format
      desc: Can be json, yaml, table (default) or any other ow.oJob.output format

# OJOB STATE
# --------------------
- name: ojob set state
  typeArgs:
    noLog: true
    shortcut:
      name  : state
      keyArg: __state
  help: 
    text: Changes the current state.
    expects:
    - name: __state
      desc: The state to change to (to execute todo.when)
  exec: |
    if (isUnDef(args.__state) && isDef(args.state)) args.__state = args.state

    _$(args.__state, "state").isString().$_();
    ow.oJob.setState(args.__state);

# --------------------
- name: ojob get state
  help: 
    text: Gets the current state into args.state.
    returns:
    - name: state
      desc: The current state
  exec: |
    args.state = ow.oJob.getState();

# ----------------
- name: ojob state
  typeArgs:
      noLog: true
  help: 
    text: | 
      Changes the current state depending on the value of a provided args variable.

        Example:

          stateOn  : mode
          lowerCase: true
          default  : Help
    expects:
    - name: stateOn
      desc: The variable in args that will define the current global set (to execute todo.when)
    - name: lowerCase
      desc: A boolean value to determine if should compare the stateOn in lower case (defaults to false)
    - name: upperCase
      desc: A boolean value to determine if should compare the stateOn in upper case (defaults to false)
    - name: validStates
      desc: An array of valid states to change to. If not included the default will be choosen (or none).
    - name: default
      desc: Default value of state
  check:
    in:
      stateOn  : isString.default("state")
      lowerCase: toBoolean.isBoolean.default(false)
      upperCase: toBoolean.isBoolean.default(false)
      default  : default(__) 
  exec : |
    args.state     = _$(args[args.stateOn], args.stateOn).default(args.default);
    if (args.lowerCase && isString(args.state)) args.state = args.state.toLowerCase();
    if (args.upperCase && isString(args.state)) args.state = args.state.toUpperCase()
    if (isArray(args.validStates)) {
      if (args.validStates.indexOf(args.state) < 0) {
        if (isDef(args.default)) args.state = args.default; else args.state = __;
      }
    }

    if (isString(args.state) && isDef(ow.oJob.setState)) ow.oJob.setState(args.state);

# ----------------
- name : ojob todo
  typeArgs:
    noLog   : true
    shortcut:
      name  : todo
      keyArg: todo
      args  :
        isolateArgs : isolateArgs
        isolateJob  : isolateJob
        templateArgs: templateArgs
        shareArgs   : shareArgs
        debug       : __debug
  help: 
    text: "Executes an ojob sub-todo.\nNOTE: doesn't perform any checks for recursive behaviour!"
    expects:
    - name: todo
      desc: A string or array of todo' maps 
    - name: todo[].name
      desc: Name of the job to execute
    - name: todo[].args
      desc: Arguments to merge (if isolateArgs is not true) with the main job arguments
    - name: todo[].isolateArgs
      desc: Boolean to indicate, for a specific todo, that args should be isolated from all others
    - name: todo[].isolateJob
      desc: Boolean to indicate, for a specific todo, that the job should run in a different scope (e.g. deps will not work)
    - name: todo[].templateArgs
      desc: Boolean to indicate, for a specific todo, to apply template to each string of the provided args (use only if typeArgs.noTemplateArgs = false OR job.templateArgs = true)
    - name: isolateArgs
      desc: Boolean, false by default, to indicate that args should be isolated from all others
    - name: isolateJob
      desc: Boolean, false by default, to indicate that the job should run in a different scope (e.g. deps will not work)
    - name: templateArgs
      desc: Boolean, true by default, to indicate to apply template to each string of the provided args (use only if typeArgs.noTemplateArgs = false OR job.templateArgs = true)
    - name: shareArgs
      desc: Boolean, false by default, to indicate that args should be shared between all todo's jobs sequentially.
    - name: __debug
      desc: Boolean to indicate that each job execution parameters should be printed before executing
  check: 
    in:
      isolateArgs : toBoolean.isBoolean.default(false)
      isolateJob  : toBoolean.isBoolean.default(false)
      templateArgs: toBoolean.isBoolean.default(true)
      shareArgs   : toBoolean.isBoolean.default(false)
      __debug     : toBoolean.isBoolean.default(false)
  exec : |
    if (!isString(args.todo) && !isArray(args.todo)) throw "todo needs to be a string or an array"

    if (isString(args.todo)) args.todo = [ args.todo ]
    var ires = clone(args)

    delete ires.todo
    delete ires.isolateArgs
    delete ires.templateArgs
    delete ires.shareArgs
    delete ires.__debug

    args.todo.forEach(j => {
      if (!isMap(j) && !isString(j)) throw "todo entry needs to be a map or a string (" + af.toSLON(j) + ")"
      var ores = $job("ojob run", {
        job         : j,
        id          : ow.oJob.__id,
        isolateArgs : args.isolateArgs,
        isolateJob  : args.isolateJob,
        templateArgs: args.templateArgs,
        __debug     : args.__debug,
        args        : ires
      })
      if (args.shareArgs) ires = merge(ires, ores)
    })

# ---------------
- name : ojob run
  typeArgs:
      noLog: true
  check:
    in:
      job         : default(__)
      id          : isString.default(ow.oJob.__id)
      isolateArgs : toBoolean.isBoolean.default(false)
      isolateJob  : toBoolean.isBoolean.default(false)
      templateArgs: toBoolean.isBoolean.default(true)
      __debug     : toBoolean.isBoolean.default(false)
  help: 
    text: "Executes an ojob but alternatively use 'ojob todo' or $job for most functionality."
    expects:
    - name: job
      desc: Name of the job to execute
    - name: id
      desc: The oJob id to execute (leave undefined to default to the current one)
    - name: args
      desc: The args to consider on execution.
    - name: isolateArgs
      desc: Boolean to indicate that args should be isolated.
    - name: isolateJob
      desc: Boolean to indicate that the job should run in a different scope (e.g. deps will not work)
    - name: templateArgs
      desc: Boolean to indicate to apply template to each string of the provided args (use only if typeArgs.noTemplateArgs = false OR job.templateArgs = true)
    - name: __debug
      desc: Boolean to indicate that each job execution parameters should be printed before executing
  exec : |
    if (!isString(args.job) && !isMap(args.job)) {
      throw "job needs to be either a string or job map"
    }

    if (isString(args.job)) args.job = { name: args.job }

    args.job.templateArgs = _$(args.job.templateArgs, "templateArgs " + args.job.name).isBoolean().default(args.templateArgs)
    args.job.isolateArgs  = _$(args.job.isolateArgs, "isolateArgs " + args.job.name).isBoolean().default(args.isolateArgs)
    args.job.isolateJob   = _$(args.job.isolateJob, "isolateJob " + args.job.name).isBoolean().default(args.isolateJob)

    if (args.job.templateArgs && isDef(args.args)) {
      if (args.job.templateArgs && isDef(args.job.args)) {
        if (isString(args.job.args)) args.job.args = ow.oJob.__processArgs(args.job.args)
        traverse(args.job.args, (aK, aV, aP, aO) => {
          if (isString(aV)) {
            aO[aK] = templify(aV, args)
          }
        })
      }
    }

    args.job = ow.oJob.parseTodo(args.job)
    var _j = {
      name: args.job.name,
      args: args.job.isolateArgs ? args.job.args : merge(args.args, args.job.args),
      id  : args.job.isolateJob ? __ : args.id
    }

    if (args.__debug) cprint( ow.format.withSideLine(printTreeOrS(_j, __, { bgcolor: "BG(235)" }), __, "FG(240)", "BG(235)", ow.format.withSideLineThemes().openBottomCurvedRect) )
    args = merge(args, $job(_j.name, _j.args, _j.id))

# --------------------
- name : ojob run file
  typeArgs:
    noLog: true
    shortcut:
      name  : runfile
      keyArg: __job
      args  :
        args        : __args
        out         : __out
        key         : __key
        inKey       : __inKey
        usePM       : __usePM
        inPM        : __inPM
        templateArgs: __templateArgs
        debug       : __debug
  help :
    text   : Executes an external YAML/JSON ojob file or a remote URL with the provided args.
    expects:
    - name: __job
      desc: The YAML/JSON ojob file or remote URL to run
    - name: __args
      desc: The args to provide to the external ojob file/url
    - name: __out
      desc: The path on args to set the map key/path contents
    - name: __key
      desc: If __out is not defined will set the content into the provided key
    - name: __inKey
      desc: If defined, args will be merged with the content from the provided key
    - name: __usePM
      desc: Output to __pm
    - name: __inPM
      desc: Input from provided key to __pm
    - name: __templateArgs
      desc: Boolean to indicate to apply template to each string of the provided args (use only if typeArgs.noTemplateArgs = false OR job.templateArgs = true)
    - name: __debug
      desc: Boolean to indicate that the job execution parameters should be printed before executing
  check:
    in: 
      __job         : isString
      __args        : isMap.default({})
      __out         : isString.default(__)
      __key         : isString.default("res")
      __inKey       : isString.default(__)
      __usePM       : toBoolean.isBoolean.default(false)
      __inPM        : isString.default(__)
      __templateArgs: toBoolean.isBoolean.default(false)
      __debug       : toBoolean.isBoolean.default(false)
  exec : |
    var id = args.__key == "args" ? "r" + nowNano() : args.__key

    if (args.__templateArgs && isDef(args.__args)) {
      traverse(args.__args, (aK, aV, aP, aO) => {
        if (isString(aV)) {
          aO[aK] = templify(aV, args)
        }
      })
    }

    var inputArgs, _f
    if (args.__usePM) {
      _f = { __format: "pm" }
      args.__key = __
      args.__usePM = __
    } else {
      _f = { __format: "key", __key: id }
    }

    if (isDef(args.__inKey)) {
      var _i = $get(args.__inKey)
      inputArgs = merge((isDef(_i) ? merge(args.__args, _i) : args.__args), _f)
    } else {
      inputArgs  = merge(args.__args, _f)
    }
    if (isDef(args.__inPM)) {
      ow.oJob.output($get(args.__inPM), { __format: "pm" })
    }
    if (args.__debug) cprint( ow.format.withSideLine(printTreeOrS(inputArgs, __, { bgcolor: "BG(235)" }), __, "FG(235)", "BG(235)", ow.format.withSideLineThemes().openBottomCurvedRect) )
    oJobRunFile(args.__job, inputArgs, nowNano(), { shareArgs: false }, true)

    if (args.__key == "args" || args.__key == "res") {
      var _t = $get(id)
      if (isDef(_t)) {
        delete _t.__format
        delete _t.__key

        args = merge(args, _t)
        if (args.__key == "args") {
          $unset(id)
        }
      }
    }

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# --------------------
- name : ojob parallel
  typeArgs:
    noLog: true
    shortcut:
      name  : parallel
      keyArg: todo
  help: 
    text: "Executes an ojob sub-todo in parallel.\nNOTE: doesn't perform any checks for recursive behaviour!"
    expects:
    - name: todo
      desc: A string or array of todo' maps 
    - name: todo[].name
      desc: Name of the job to execute
    - name: todo[].args
      desc: Arguments to merge (if isolateArgs is not true) with the main job arguments
    - name: todo[].isolateArgs
      desc: Boolean to indicate, for a specific todo, that args should be isolated from all others
    - name: todo[].isolateJob
      desc: Boolean to indicate, for a specific todo, that the job should run in a different scope (e.g. deps will not work)
    - name: todo[].templateArgs
      desc: Boolean to indicate, for a specific todo, to apply template to each string of the provided args (use only if typeArgs.noTemplateArgs = false OR job.templateArgs = true)
    - name: isolateArgs
      desc: Boolean, false by default, to indicate that args should be isolated from all others
    - name: isolateJob
      desc: Boolean, false by default, to indicate that the job should run in a different scope (e.g. deps will not work)
    - name: templateArgs
      desc: Boolean, true by default, to indicate to apply template to each string of the provided args (use only if typeArgs.noTemplateArgs = false OR job.templateArgs = true)
    - name: shareArgs
      desc: Boolean, false by default, to indicate that args should be shared between all todo's jobs sequentially.
    - name: __debug
      desc: Boolean to indicate that each job execution parameters should be printed before executing
  check: 
    in:
      isolateArgs : toBoolean.isBoolean.default(false)
      isolateJob  : toBoolean.isBoolean.default(false)
      templateArgs: toBoolean.isBoolean.default(true)
      shareArgs   : toBoolean.isBoolean.default(false)
      __debug     : toBoolean.isBoolean.default(false)
  exec : |
    if (!isString(args.todo) && !isArray(args.todo)) throw "todo needs to be a string or an array"
    if (isString(args.todo)) args.todo = [ args.todo ]
    var ires = clone(args), ar = []
    
    delete ires.todo
    delete ires.isolateArgs
    delete ires.templateArgs
    delete ires.shareArgs
    delete ires.__debug

    args.todo.forEach(j => {
      if (!isMap(j) && !isString(j)) throw "todo entry needs to be a map or a string (" + af.toSLON(j) + ")"
      ar.push($do(() => $job("ojob run", {
        job         : j,
        id          : ow.oJob.__id,
        isolateArgs : args.isolateArgs,
        isolateJob  : args.isolateJob,
        templateArgs: args.templateArgs,
        __debug     : args.__debug,
        args        : ires
      })))
    })
    $doWait($doAll(ar))

# ----------------
- name : ojob wait
  typeArgs:
    noLog   : true
    shortcut:
      name  : wait
      keyArg: time
  help : 
    text: "Waits for a specific amount of time"
    expects:
    - name: time
      desc: The amount of time, in ms, to pause execution
  check:
    in:
      time: toNumber.isNumber
  exec : |
    sleep(args.time, true)

# ----------------
- name : ojob exit
  typeArgs:
    noLog: true
    shortcut:
      name  : fail
      keyArg: code
      args  :
        force: force
  help : 
    text: "Ends all processing with an exit code"
    expects:
    - name: code
      desc: The exit code number to use
    - name: force
      desc: A boolean indicating if instead of exit the processing should halt
  check:
    in:
      code : toNumber.isNumber.default(0)
      force: toBoolean.isBoolean.default(false)
  exec : |
    exit(args.code, args.force)

# ----------------------
- name    : ojob convert
  typeArgs:
    noLog   : false
    shortcut:
      name  : convert
      keyArg: __inKey
      args  :
        inPath  : __inPath
        inFormat: __inFormat
        outPath : __outPath
        outKey  : __outKey
  check   :
    in:
      __inPath  : isString.default("")
      __inKey   : isString.default("res")
      __inFormat: isString.oneOf(['yaml','json','xml','ndjson','slon'])
      __outPath : isString.default(__)
      __outKey  : isString.default(__)
  help :
    text   : Converts string content into an internal object (map/array)
    expects:
    - name: __inKey
      desc: Where to find the input contents to convert (if 'args' will default to the current args)
    - name: __inPath
      desc: The path on the input contents for the string to convert
    - name: __inFormat
      desc: The format of the input contents (yaml, json, xml, ndjson, slon)
    - name: __outKey
      desc: Where the converted output object should be placed (if 'args' with default to the current args)
    - name: __outPath
      desc: The path on the output contents to store the converted object
  exec    : |
    var c
    // Check input
    if (args.__inKey != "args") {
      c = String( $$(args).get(args.__inPath) )
    } else {
      c = String( $$($get(args.__inKey)).get(args.__inPath) )
    }

    if (isUnDef(args.__outKey))  args.__outKey = args.__inKey
    if (isUnDef(args.__outPath)) args.__outPath = args.__inPath

    // Converting
    var _r
    switch(args.__inFormat) {
    case "yaml":
      _$(c, "yaml input").isString().$_()
      _r = af.fromYAML(c)
      break
    case "json":
      _r = jsonParse(c, true)
      break
    case "ndjson":
      _r = c.split("\n").map(l => jsonParse(l, true)).filter(l => isDef(l) && !isNull(l))
      break
    case "xml":
      _r = af.fromXML2Obj(_r)
      break
    case "slon":
      _r = af.fromSLON(_r)
      break
    default:
      throw "No inFormat provided."
    }

    // Output
    if (args.__outKey != "args") {
      $$(args).set(args.__outPath, _r)
    } else {
      var _o = $get(args.outKey)
      $$(o).set(args.outPath, _r)
      $set(args.outKey, o)
    }

    // Delete all __ args
    Object.keys(args).filter(k => k.startsWith("__")).forEach(k => delete args[k])

# ---------------------
- name : ojob questions
  typeArgs:
    noLog   : true
    shortcut:
      name  : questions
      keyArg: __questions
  help :
    text: |
      Asks a list of questions and stores the answers into args.
    expects:
    - name: __questions
      desc: A map structure equivalent to OpenAF's askStruct.
  check:
    in:
      __questions: isArray
  exec : |
    askStruct(args.__questions).forEach(r => {
      if (isDef(r.name)) {
        $$(args).set(r.name, r.answer)
      }
    })

# ---------------
- name : ojob ask
  typeArgs:
    noLog   : true
    shortcut:
      name  : ask
      keyArg: __answers
      args  :
        question: __question
        force   : __force
  help : 
    text: |
      Asks for user input and stores the result into args if the args value is not yet defined.
    expects:
    - name: __question
      desc: The question to ask.
    - name: __answers
      desc: "A map of answers to store into args. Each value should on the form of \"type.slonOptionsArray.size\" (e.g. text, encrypt, password, char.['y'|'n'], option.['op1'|'op2'|'op3'].3, moption.['op1'|'op2'|'op3'].3)"
    - name: __force
      desc: Boolean flag to force asking for an args value even if not defined.
  check:
    in:
      __question: isString.default(__)
      __answers : isMap.default({})
      __force   : toBoolean.isBoolean.default(false)
  exec : |
    if (isDef(args.__question)) {
      args.__question = args.__question.replace(/\n/g, "")
      if (!args.__question.endsWith(" ")) args.__question += " "
    }

    traverse(args.__answers, (aK, aV, aP, aO) => {
      if (isString(aV)) {
        if (args.__force || isUnDef($$(args).get(aP + "." + aK)) ) {
          var parts = aV.split(".")
          var options = _$(options, "options").isArray().default([])
          if (isDef(parts[1]) && parts[1].startsWith("[") && parts[1].endsWith("]")) options = af.fromSLON(parts[1])
          if (!isArray(options)) options = [ options ]

          if (isString(parts[0])) {
            if (isUnDef(args.__question)) args.__question = "args" + aP + "." + aK + " value: "
            switch(parts[0].toLowerCase()) {
            case "encrypt" :
            case "password": $$(args).set(aP + "." + aK, askEncrypt(args.__question)); break
            case "char"    : 
              var _o = options.join("")
              $$(args).set(aP + "." + aK, ask1(args.__question), _o)
              break
            case "option"  :
            case "list"    : 
              if (isArray(options)) {
                $$(args).set(aP + "." + aK, options[ askChoose(args.__question, options, (isDef(parts[2]) ? Number(parts[2]) : __) )] ); break
              }
            case "moption" :
              if (isArray(options)) {
                $$(args).set(aP + "." + aK, options[ askChooseMultiple(args.__question, options, (isDef(parts[2]) ? Number(parts[2]) : __) )] ); break
              }
            case "text"    :
            default        : $$(args).set(aP + "." + aK, ask(args.__question))
            }
          }
        }
      }
    })

# ----------------
- name : ojob oafp
  typeArgs:
    noLog   : true
    shortcut:
      name  : oafp
      keyArg: __params
    help  :
      text   : |
        "Executes oafp with the provided params"
      expects:
      - name: __params
        desc: The parameters to provide to oafp
  check:
    in:
      __params: isMap
  exec : |
    loadOAFP()
    oafp(args.__params)

# ---------------
- name : ojob llm
  typeArgs:
    noLog   : true
    shortcut:
      name  : llm
      keyArg: __llmPrompt
      args  :
        context: __llmContext
        inPath : __llmInPath
        inKey  : __llmInKey
        env    : __llmEnv
        options: __llmOptions
        outPath: __llmOutPath
        debug  : __llmDebug
  help :
    text: |
      "Executes a LLM (Local Language Model) prompt using $llm"
    expects:
    - name: __llmContext
      desc: The context of the input data (determined by __llmInPath)
    - name: __llmInPath
      desc: The path to consider from __llmInKey (mandatory for using context)
    - name: __llmInKey
      desc: The key for an existing list or 'args'
    - name: __llmEnv
      desc: "The environment variable to consider for $llm options"
    - name: __llmOptions
      desc: "The options to consider for $llm"
    - name: __llmOutPath
      desc: The path to store the result
    - name: __llmPrompt
      desc: The prompt to send to the LLM model
    - name: __llmDebug
      desc: Boolean to indicate that the job execution parameters should be printed before executing
  check: 
    in:
      __llmContext: isString.default(__)
      __llmInKey  : isString.default("args")
      __llmInPath : isString.default(__)
      __llmEnv    : isString.default("OJOB_MODEL")
      __llmOptions: isMap.default(__)
      __llmOutPath: isString.default(__)
      __llmPrompt : isString
      __llmDebug  : isBoolean.default(false)
  exec : |
    try {
    var _lo = isDef(args.__llmOptions) ? args.__llmOptions : __
    if (isUnDef(_lo) && isDef(args.__llmEnv)) _lo = $sec("system", "envs").get(args.__llmEnv)

    var _l = $llm(_lo)
    if (isDef(args.__llmInPath)) {
      if (isUnDef(args.__llmContext)) { args.__llmContext = "a JSON input data" }
      var _i = args.__llmInKey == "args" ? $$(args).get(args.__llmInPath) : $$($get(args.__llmInKey)).get(args.__llmInPath)
      if (args.__llmDebug) {
        print("DEBUG | Input data:")
        cprint(_i)
      }
      if (isDef(_i)) _l = _l.withContext(_i, args.__llmContext) 
    }

    var _r = _l.promptJSON(args.__llmPrompt)
    if (args.__llmDebug) {
      print("DEBUG | Result data:")
      cprint(_r)
    }
    if (isUnDef(args.__llmOutPath)) 
      $set("res", _r)
    else
      $$(args).set(args.__llmOutPath, _r)
    } catch(e) {
      throw "Error on LLM: " + e
    }