updating Wizard route

client/src/api/schema/schema.ts

@@ -21,6 +21,13 @@ export interface paths {
         patch?: never;
         trace?: never;
     };
+    "/api/chat": {
+        /**
+         * Query
+         * @description We're off to ask the wizard
+        */
+        post: operations["query_api_chat_post"];
+};
     "/api/configuration": {
         parameters: {
             query?: never;

client/src/components/DatasetInformation/DatasetError.vue

@@ -16,6 +16,7 @@ import { errorMessageAsString } from "@/utils/simple-error";
 
 import DatasetErrorDetails from "@/components/DatasetInformation/DatasetErrorDetails.vue";
 import FormElement from "@/components/Form/FormElement.vue";
+import GalaxyWizard from "@/components/GalaxyWizard.vue";
 
 library.add(faBug);
 
@@ -187,7 +188,11 @@ onMounted(async () => {
                     </a>
                 </b>
             </p>
-
+            <!-- Galaxy Wizard Component Integration -->
+            <h4 class="mb-3 h-md">What might have happened?</h4>
+            <b-card>
+                <GalaxyWizard view="error" :query="jobDetails.tool_stderr" context="tool_error" />
+            </b-card>
             <h4 class="mb-3 h-md">Issue Report</h4>
 
             <BAlert v-for="(resultMessage, index) in resultMessages" :key="index" :variant="resultMessage[1]" show>

client/src/components/GalaxyWizard.vue

@@ -0,0 +1,83 @@
+<script setup lang="ts">
+import axios from "axios";
+import { ref } from "vue";
+import Heading from "./Common/Heading.vue";
+import LoadingSpan from "./LoadingSpan.vue";
+const props = defineProps({
+    view: {
+        type: String,
+        default: "wizard",
+    },
+    query: {
+        type: String,
+        default: "",
+    },
+    context: {
+        type: String,
+        default: "",
+    },
+});
+const query = ref(props.query);
+const queryResponse = ref("");
+const busy = ref(false);
+// on submit, query the server and put response in display box
+function submitQuery() {
+    busy.value = true;
+    queryResponse.value = "";
+    const context = props.context || "username";
+    axios
+        .post("/api/chat", {
+            query: query.value,
+            context: context,
+        })
+        .then(function (response) {
+            console.log(response);
+            queryResponse.value = response.data;
+        })
+        .catch(function (error) {
+            console.error(error);
+        })
+        .finally(() => {
+            busy.value = false;
+        });
+}
+</script>
+<template>
+    <div>
+        <!-- input text, full width top of page -->
+        <Heading v-if="props.view == 'wizard'" inline h2>Ask the wizard</Heading>
+        <div :class="props.view == 'wizard' && 'mt-2'">
+            <b-input
+                v-if="props.query == ''"
+                id="wizardinput"
+                v-model="query"
+                style="width: 100%"
+                placeholder="What's the difference in fasta and fastq files?"
+                @keyup.enter="submitQuery" />
+            <b-button
+                v-else-if="!queryResponse"
+                variant="info"
+                :disabled="busy"
+                @click="submitQuery">
+                <span v-if="!busy">
+                    Let our Help Wizard Figure it out!
+                </span>
+                <LoadingSpan v-else message="Thinking..." />
+            </b-button>
+        </div>
+        <!-- spinner when busy -->
+        <div :class="props.view == 'wizard' && 'mt-4'">
+            <div v-if="busy">
+                <b-skeleton animation="wave" width="85%"></b-skeleton>
+                <b-skeleton animation="wave" width="55%"></b-skeleton>
+                <b-skeleton animation="wave" width="70%"></b-skeleton>
+            </div>
+            <div v-else class="chatResponse">{{ queryResponse }}</div>
+        </div>
+    </div>
+</template>
+<style lang="scss" scoped>
+.chatResponse {
+    white-space: pre-wrap;
+}
+</style>

client/src/entry/analysis/router.js

@@ -7,6 +7,7 @@ import DatasetAttributes from "components/DatasetInformation/DatasetAttributes";
 import DatasetDetails from "components/DatasetInformation/DatasetDetails";
 import DatasetError from "components/DatasetInformation/DatasetError";
 import FormGeneric from "components/Form/FormGeneric";
+import GalaxyWizard from "components/GalaxyWizard.vue";
 import HelpTerm from "components/Help/HelpTerm";
 import HistoryExportTasks from "components/History/Export/HistoryExport";
 import HistoryPublished from "components/History/HistoryPublished";
@@ -614,6 +615,10 @@ export function getRouter(Galaxy) {
                             activeList: "published",
                         },
                     },
+                    {
+                        path: "wizard",
+                        component: GalaxyWizard,
+                    },
                     {
                         path: "workflows/create",
                         component: WorkflowCreate,

doc/source/admin/galaxy_options.rst

@@ -5364,6 +5364,15 @@
 :Default: ``-1``
 :Type: int
 
+~~~~~~~~~~~~~~~~~~
+``openai_api_key``
+~~~~~~~~~~~~~~~~~~
+
+:Description:
+    API key for OpenAI (https://openai.com/) to enable the wizard (or
+    more?)
+:Default: ``None``
+:Type: str
 
 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 ``enable_tool_recommendations``

lib/galaxy/config/sample/galaxy.yml.sample

@@ -2881,6 +2881,9 @@ galaxy:
   # as threshold (above threshold: regular select fields will be used)
   #select_type_workflow_threshold: -1
 
+  # API key for OpenAI (https://openai.com/) to enable the wizard
+  #openai_api_key: null
+
   # Allow the display of tool recommendations in workflow editor and
   # after tool execution. If it is enabled and set to true, please
   # enable 'tool_recommendation_model_path' as well

lib/galaxy/config/schemas/config_schema.yml

@@ -3923,6 +3923,12 @@ mapping:
           use -1 (default) in order to always use the regular select fields,
           use any other positive number as threshold (above threshold: regular select fields will be used)
 
+      openai_api_key:
+        type: str
+        required: false
+        desc: |
+          OpenAI API key to enable the wizard.    
+
       enable_tool_recommendations:
         type: bool
         default: false

lib/galaxy/dependencies/__init__.py

@@ -289,6 +289,9 @@ def check_influxdb(self):
 
     def check_tensorflow(self):
         return asbool(self.config["enable_tool_recommendations"])
+
+    def check_openai(self):
+        return self.config.get("openai_api_key", None) is not None
 
     def check_weasyprint(self):
         # See notes in ./conditional-requirements.txt for more information.

lib/galaxy/dependencies/conditional-requirements.txt

@@ -14,6 +14,7 @@ python-pam
 galaxycloudrunner
 pkce
 total-perspective-vortex>=2.3.2,<3
+openai
 
 # For file sources plugins
 fs.webdavfs>=0.4.2  # type: webdav

lib/galaxy/schema/schema.py

@@ -3708,6 +3708,17 @@ class MaterializeDatasetInstanceAPIRequest(MaterializeDatasetOptions):
 class MaterializeDatasetInstanceRequest(MaterializeDatasetInstanceAPIRequest):
     history_id: DecodedDatabaseIdField
 
+class ChatPayload(Model):
+    query: str = Field(
+        ...,
+        title="Query",
+        description="The query to be sent to the chatbot.",
+    )
+    context: Optional[str] = Field(
+        default=""
+        title="Context",
+        description="The context for the chatbot.",
+    )
 
 class CreatePagePayload(PageSummaryBase):
     content_format: PageContentFormat = ContentFormatField

lib/galaxy/webapps/galaxy/api/chat.py

@@ -0,0 +1,73 @@
+"""
+API Controller providing Chat functionality
+"""
+import logging
+
+try:
+    import openai
+except ImportError:
+    openai = None
+
+from galaxy.config import GalaxyAppConfiguration
+from galaxy.managers.context import ProvidesUserContext
+from galaxy.webapps.galaxy.api import (
+    depends,
+    DependsOnTrans,
+)
+from galaxy.exceptions import ConfigurationError
+from galaxy.schema.schema import ChatPayload
+from . import (
+    depends,
+    Router,
+)
+
+log = logging.getLogger(__name__)
+
+router = Router(tags=["chat"])
+
+PROMPT = """
+You are a highly intelligent question answering agent, expert on the Galaxy analysis platform and in the fields of computer science, bioinformatics, and genomics.
+You will try to answer questions about Galaxy, and if you don't know the answer, you will ask the user to rephrase the question.
+"""
+
+
+@router.cbv
+class ChatAPI:
+    config: GalaxyAppConfiguration = depends(GalaxyAppConfiguration)
+
+    @router.post("/api/chat")
+    def query(self, query: ChatPayload, trans: ProvidesUserContext = DependsOnTrans) -> str:
+        """We're off to ask the wizard"""
+
+        if openai is None or self.config.openai_api_key is None:
+            raise ConfigurationError("OpenAI is not configured for this instance.")
+        else:
+            openai.api_key = self.config.openai_api_key
+
+        messages=[
+            {"role": "system", "content": PROMPT},
+            {"role": "user", "content": query.query},
+        ]
+
+        if query.context == "username":
+            user = trans.user
+            if user is not None:
+                log.debug(f"CHATGPTuser: {user.username}")
+                msg = f"You will address the user as {user.username}"
+            else:
+                msg = f"You will address the user as Anonymous User"
+            messages.append({"role": "system", "content": msg})
+        elif query.context == "tool_error":
+            msg = "The user will provide you a Galaxy tool error, and you will try to debug and explain what happened"
+            messages.append({"role": "system", "content": msg})
+
+        log.debug(f"CHATGPTmessages: {messages}")
+
+        response = openai.ChatCompletion.create(
+            model="gpt-3.5-turbo",
+            messages=messages,
+            temperature=0,
+        )
+
+        answer = response["choices"][0]["message"]["content"]
+        return answer

lib/galaxy/webapps/galaxy/buildapp.py

@@ -284,6 +284,7 @@ def app_pair(global_conf, load_app_kwds=None, wsgi_preflight=True, **kwargs):
     webapp.add_client_route("/collection/{collection_id}/edit")
     webapp.add_client_route("/jobs/submission/success")
     webapp.add_client_route("/jobs/{job_id}/view")
+    webapp.add_client_route("/wizard")
     webapp.add_client_route("/workflows/list")
     webapp.add_client_route("/workflows/list_published")
     webapp.add_client_route("/workflows/list_shared_with_me")