File size: 2,788 Bytes
c517271
7626743
 
 
 
 
 
 
 
 
 
 
 
 
 
c517271
 
d6474bb
 
 
 
 
 
 
c517271
 
 
 
d6474bb
c517271
 
 
 
cb0dedb
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
7626743
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
cf6dabc
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
7626743
 
 
1945d73
 
 
7626743
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
const fs = require("fs").promises;
const express = require("express");
const axios = require("axios");
const bodyParser = require("body-parser");
const path = require("path");

const app = express();

app.use(express.static(path.join(__dirname, ".")));
app.use(bodyParser.json());

app.get("/", (req, res) => {
    res.sendFile(path.join(__dirname + "/index.html"));
});

app.get("/endpoints", async (req, res) => {
    try {
        let endpoints_configs_path = path.join(
            __dirname,
            "configs",
            "endpoints.json"
        );
        const data = await fs.readFile(endpoints_configs_path, "utf-8");
        const local_points = JSON.parse(data);
        res.json(local_points);
    } catch (error) {
        console.error(error);
        res.status(500).json({
            error: "Failed to get local endpoints: Maybe configs/endpoints.json not existed?",
        });
    }
});

app.get("/agents", async (req, res) => {
    try {
        let agents_configs_path = path.join(
            __dirname,
            "configs",
            "agents.json"
        );
        const data = await fs.readFile(agents_configs_path, "utf-8");
        const local_agents = JSON.parse(data);
        res.json(local_agents);
    } catch (error) {
        console.error(error);
        res.status(500).json({
            error: "Failed to get local agents: Maybe configs/agents.json not existed?",
        });
    }
});

app.post("/chat/completions", async (req, res) => {
    try {
        const {
            openai_endpoint,
            openai_request_method,
            openai_request_headers,
            openai_request_body,
        } = req.body;

        const response = await axios({
            method: openai_request_method,
            url: openai_endpoint + "/chat/completions",
            data: openai_request_body,
            headers: openai_request_headers,
            responseType: "stream",
        });
        response.data.pipe(res);
    } catch (error) {
        console.error(error);
        res.status(500).json({ error: "Failed to request OpenAI Endpoint" });
    }
});

app.post("/models", async (req, res) => {
    try {
        const {
            openai_endpoint,
            openai_request_method,
            openai_request_headers,
        } = req.body;

        const response = await axios({
            method: openai_request_method,
            url: openai_endpoint + "/models",
            headers: openai_request_headers,
        });
        res.json(response.data);
    } catch (error) {
        console.error(error);
        res.status(500).json({ error: "Failed to request OpenAI Endpoint" });
    }
});

const port = 23456;
app.listen(port, "0.0.0.0", () => {
    console.log(`Server is running on http://0.0.0.0:${port}`);
});