Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/var/www/html/mindsDb/   drwxr-xr-x
Free 13.06 GB of 57.97 GB (22.54%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     api.js (4.25 KB)      -rw-r--r--

const axios = require("axios");

const client = axios.create({
    baseURL: "http://161.35.7.206:47334/api",
});
// equests.post(url, json={'query':
//                     'SELECT * FROM example_db.demo_data.home_rentals LIMIT 10;'})
async function createProject() {
    try {
        const res = await client.post("/sql/query", {
                'query':
                    'SELECT * FROM  demo_database.car_info LIMIT 10;'
        });
        console.log(res.data);
        
    } catch (error) {
        console.log(error.message);
        
    }
    // console.log(res.data);
}

// createProject();
async function createDatabase() {
  try {
    const response = await axios.post(
      'http://161.35.7.206:47334/api/databases',
      {
        database: {
          name: "ecommerce",
          engine: "mysql",
          parameters: {
            user: "admin",
            password: "wahid",
            host: "http://139.59.127.108",
            port: "3306",
            database: "ecommerce"
          }
        }
      },
      {
        headers: {
          "Content-Type": "application/json"
        }
      }
    );

    console.log("Response:", response.data);

  } catch (error) {
    console.error("Error:", error.response?.data || error.message);
  }
}
// createDatabase();
async function listDatabases() {
  try {
    const response = await axios.get(
      'http://161.35.7.206:47334/api/databases',
      {
        headers: {
          "Content-Type": "application/json"
        }
      }
    );

    console.log("Databases:", response.data);
  } catch (error) {
    console.error("Error:", error.response?.data || error.message);
  }
}

// listDatabases();
async function listProjects() {
  try {
    const response = await axios.get(
      'http://161.35.7.206:47334/api/projects',
      {
        headers: {
          "Content-Type": "application/json"
        }
      }
    );

    console.log("Projects:", response.data);
  } catch (error) {
    console.error("Error:", error.response?.data || error.message);
  }
}

// listProjects();
async function createAgent() {
  try {
    const response = await axios.post(
      'http://161.35.7.206:47334/api/projects/mindsdb/agents',
      {
        agent: {
          name: "my_agent",
          model: {
            provider: "openai",
            model_name: "gpt-4o",
            api_key: "sk-xxx"
          },
          data: {
            knowledge_bases: ["my_project.my_kb"],
            tables: ["my_data_source.my_table"]
          },
          prompt_template:
            "my_project.my_kb stores documentation of MindsDB, my_data_source.my_table stores documentation of MindsDB"
        }
      },
      {
        headers: {
          "Content-Type": "application/json"
        }
      }
    );

    console.log("Agent created:", response.data);

  } catch (error) {
    console.error("Error:", error.response?.data || error.message);
  }
}

// createAgent();

async function listAgents() {
  try {
    const response = await axios.get(
      'http://161.35.7.206:47334/api/projects/mindsdb/agents',
      {
        headers: {
          "Content-Type": "application/json"
        }
      }
    );

    console.log("Agents:", response.data);
  } catch (error) {
    console.error("Error:", error.response?.data || error.message);
  }
}

// listAgents();

async function streamAgentCompletion() {
  try {
    const response = await axios.post(
      'http://161.35.7.206:47334/api/projects/mindsdb/agents/my_agent/completions/stream',
      {
        messages: [
          {
            question: "can you generate a reporty for last month?",
            answer: ""
          }
        ]
      },
      {
        headers: {
          "Content-Type": "application/json"
        },
        responseType: 'stream'  // important for streaming
      }
    );

    // Stream data chunks in real time
    response.data.on('data', (chunk) => {
      console.log("Chunk:", chunk.toString());
    });

    response.data.on('end', () => {
      console.log("Stream ended.");
    });

  } catch (error) {
    console.error("Error:", error.response?.data || error.message);
  }
}

streamAgentCompletion();