Method askAi

server/controllers/DataRequestController.js:246–288

(id, question, conversationHistory, currentQuery)

  }

  askAi(id, question, conversationHistory, currentQuery) {
    return this.findById(id)
      .then(async (dataRequest) => {
        const connection = await db.Connection.findByPk(dataRequest.Connection.id);
        const source = findSourceForConnection(connection);
        let schema = connection?.schema;
        if (!schema) {
          if (source?.backend?.ai?.getSchema) {
            assertSourceServerEnabled(source);
            schema = await source.backend.ai.getSchema({ connection, dataRequest });
          } else if (source?.backend?.getSchema) {
            assertSourceServerEnabled(source);
            schema = await source.backend.getSchema({ connection, dataRequest });
          }
        }

        if (!schema) {
          return Promise.reject(new Error("No schema found. Please test your connection first."));
        }

        let aiResponse;
        if (source?.backend?.ai?.generateQuery) {
          assertSourceServerEnabled(source);
          aiResponse = await source.backend.ai.generateQuery({
            schema,
            question,
            conversationHistory,
            currentQuery,
            connection,
            dataRequest,
          });
        } else {
          aiResponse = await generateSqlQuery(
            schema, question, conversationHistory, currentQuery
          );
        }

        return aiResponse;
      })
      .catch((error) => {
        return Promise.reject(error);
      });
  }

  createVariableBinding(id, data) {
    const newVar = {