WFTK_EXPORT void repos_workflow_start (XML * repository, const char * list, const char * key, XML * wf_defn, const char * wf_id)
{
   XML * obj = repos_get (repository, list, key);

   if (obj) {
      repos_workflow_start_direct (repository, obj, wf_defn, wf_id);
      repos_mod (repository, list, obj, key);
   }
   xml_free (obj);
}
WFTK_EXPORT void repos_workflow_start_direct (XML * repository, XML * obj, XML * wf_defn, const char * wf_id)
{
   XML * adhoc;

   xml_setf (obj, "repository", "list:%s", xml_attrval (obj, "list")); /* tell wftk_process_save what to do */

   /* If wf_defn is supplied, we start ad-hoc workflow. */
   if (wf_defn) {
      adhoc = xml_create ("sequence"); /* TODO: support parallel as well?  workflow-type=, maybe */
      xml_copyinto (adhoc, wf_defn);
      wftk_process_adhoc (repository, obj, adhoc);
      xml_free (adhoc);
   }

   /* If wf_id is supplied, we start a procdef from the default pdrep. */
   if (wf_id && *wf_id) {
      wftk_process_start (repository, obj, NULL, wf_id);
   }
}

WFTK_EXPORT void repos_task_add (XML * repository, const char * list, const char * key, XML * task_defn)
{
   XML * obj = repos_get (repository, list, key);

   if (obj) {
      repos_task_add_direct (repository, obj, task_defn);
      repos_mod (repository, list, obj, key);
   }
   xml_free (obj);
}
WFTK_EXPORT void repos_task_add_direct (XML * repository, XML * obj, XML * task_defn)
{

}

WFTK_EXPORT XML * repos_tasks (XML * repository, XML * tasklist, const char * list, const char * key, const char * user)
{
   XML * obj = repos_get (repository, list, key);
   XML * ret;

   if (obj) {
      ret = repos_tasks_direct (repository, tasklist, obj, user);
      xml_free (obj);
      return (ret);
   }
}
WFTK_EXPORT XML * repos_tasks_direct (XML * repository, XML * tasklist, XML * obj, const char * user)
{
   if (!tasklist) tasklist = xml_create ("list");
   if (user) xml_set   (tasklist, "userid", user);
   else      xml_unset (tasklist, "userid");

   wftk_task_list (repository, tasklist, obj);
   return (tasklist);
}

WFTK_EXPORT XML * repos_task_get (XML * repository, const char * list, const char * key, const char * local_key)
{
   char * list_id;
   char * task_key;
   XML * task;

   list_id = strdup (list);
   xmlobj_fixkey (list_id);
   task_key = xml_string_format ("%s~%s~%s", list_id, key, local_key);

   repos_log (repository, 5, 2, NULL, "repmgr", "repos_task_get: getting task %s", task_key);
   task = repos_get (repository, "_tasks", task_key);

   free (task_key);
   free (list_id);

   return (task);
}
WFTK_EXPORT XML * repos_task_get_direct (XML * repository, XML * obj, const char * local_key)
{
   return (repos_task_get (repository, xml_attrval (obj, "list"), xml_attrval (obj, "key"), local_key)); /* TODO: look for potentials n stuff. */
}

WFTK_EXPORT int repos_workflow_action_taken (XML * repository, XML * list, XML * object, const char * action)
{
   int workflow_started = 0;
   XML * mark;

   /* Workflow specs may be multiple, and may be in either the object or the list definition.  Let's look at the object first, then the list. */
   mark = xml_search (object, "on", "action", action);
   while (mark) {
      workflow_started = 1;
      repos_workflow_start_direct (repository, object, *xml_attrval (mark, "procdef") ? NULL : mark, xml_attrval (mark, "procdef"));
      mark = xml_search_next (object, mark, "on", "action", action);
   }

   /* Now the list. */
   if (!strcmp (action, "add")) {
      if (*xml_attrval (list, "workflow")) { /* Special abbreviation for convenience. */
         workflow_started = 1;
         repos_workflow_start_direct (repository, object, NULL, xml_attrval (list, "workflow"));
      }
   }
   mark = xml_search (list, "on", "action", action); /* TODO: shouldn't this be restricted to top level? */
   while (mark) {
      workflow_started = 1;
      repos_workflow_start_direct (repository, object, *xml_attrval (mark, "procdef") ? NULL : mark, xml_attrval (mark, "procdef"));
      mark = xml_search_next (list, mark, "on", "action", action);
   }

   return workflow_started;
}