File size: 7,951 Bytes
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
 
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
 
 
 
 
 
 
 
 
 
 
 
b2c8885
2bf7a2b
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
b2c8885
2bf7a2b
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
b2c8885
2bf7a2b
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
 
b2c8885
2bf7a2b
 
b2c8885
2bf7a2b
 
 
 
 
 
 
 
 
997f2d0
2bf7a2b
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
 
 
 
b2c8885
2bf7a2b
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
 
 
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
 
b2c8885
2bf7a2b
 
 
 
b2c8885
2bf7a2b
 
 
 
b2c8885
2bf7a2b
 
 
b2c8885
6d43d9c
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
2bf7a2b
 
 
 
 
997f2d0
2bf7a2b
 
b2c8885
2bf7a2b
 
 
b2c8885
2bf7a2b
 
 
 
b2c8885
2bf7a2b
 
 
 
 
 
 
 
 
 
 
 
 
 
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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
const express = require('express');
const router = express.Router();
const { KEY_TYPE_ADMIN, KEY_TYPE_SERVER, KEY_TYPE_REGULAR } = require('../database');
const { requireRegularKeyForOwnServerKeys, requireRegularOrAdminKey } = require('../auth');

function createKeysRouter(db, requireAdminKey) {
    router.post('/', requireAdminKey, async (req, res) => {
        try {
            const { name, description = '', key_type = KEY_TYPE_REGULAR, server_id = null } = req.body;

            if (!name) {
                return res.status(400).json({ detail: 'Name is required' });
            }

            if (key_type === KEY_TYPE_REGULAR) {
                // 创建Regular Key并自动生成关联的Server Key
                const result = await db.createRegularKeyWithServerKey(name, description, server_id);

                res.status(201).json({
                    regularKey: {
                        ...db.getApiKeyDetailsById(result.regularKey.id),
                        key: result.regularKey.rawKey
                    },
                    serverKey: {
                        ...db.getApiKeyDetailsById(result.serverKey.id),
                        key: result.serverKey.rawKey
                    }
                });
            } else {
                // 创建单个Admin或Server Key
                const result = await db.createApiKey(name, description, key_type, server_id);
                const details = db.getApiKeyDetailsById(result.keyId);

                res.status(201).json({
                    ...details,
                    key: result.rawKey
                });
            }
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    router.get('/', requireAdminKey, (req, res) => {
        try {
            const keys = db.getAllApiKeysInfo();
            res.json(keys);
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    // Regular Key获取自己的Server Key列表
    router.get('/server-keys', requireRegularOrAdminKey, (req, res) => {
        try {
            if (req.apiKey.keyType === KEY_TYPE_ADMIN) {
                // Admin获取所有Server Key
                const allKeys = db.getAllApiKeysInfo();
                const serverKeys = allKeys.filter(key => key.keyType === KEY_TYPE_SERVER);
                res.json(serverKeys);
            } else if (req.apiKey.keyType === KEY_TYPE_REGULAR) {
                // Regular Key获取自己关联的Server Key
                const serverKeys = db.getServerKeysByRegularKeyId(req.apiKey.id);
                res.json(serverKeys);
            }
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    // Regular Key为自己创建新的Server Key
    // 只有Admin Key可以为Regular Key创建Server Key
    router.post('/server-keys', requireAdminKey, async (req, res) => {
        try {
            const { name, description = '', server_id = null, regular_key_id } = req.body;

            if (!name) {
                return res.status(400).json({ detail: 'Name is required' });
            }

            if (!regular_key_id) {
                return res.status(400).json({ detail: 'regular_key_id is required' });
            }

            const regularKeyInfo = db.getApiKeyDetailsById(regular_key_id);
            if (!regularKeyInfo || regularKeyInfo.keyType !== KEY_TYPE_REGULAR) {
                return res.status(404).json({ detail: 'Invalid Regular Key ID' });
            }

            const result = await db.createApiKey(name, description, KEY_TYPE_SERVER, server_id, regular_key_id);
            const details = db.getApiKeyDetailsById(result.keyId);

            res.status(201).json({
                ...details,
                key: result.rawKey
            });
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    router.get('/:key_id', requireAdminKey, (req, res) => {
        try {
            const details = db.getApiKeyDetailsById(req.params.key_id);

            if (!details) {
                return res.status(404).json({ detail: 'API Key not found' });
            }

            res.json(details);
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    router.patch('/:key_id/activate', requireRegularKeyForOwnServerKeys(db), (req, res) => {
        try {
            const keyId = req.params.key_id;

            if (!db.getApiKeyDetailsById(keyId)) {
                return res.status(404).json({ detail: 'Key not found' });
            }

            if (db.toggleApiKeyActivation(keyId, true)) {
                return res.json({ message: `Key '${keyId}' activated.` });
            }

            res.status(500).json({ detail: 'Failed to activate key.' });
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    router.patch('/:key_id/deactivate', requireRegularKeyForOwnServerKeys(db), (req, res) => {
        try {
            const keyId = req.params.key_id;
            const keyInfo = db.getApiKeyDetailsById(keyId);

            if (!keyInfo) {
                return res.status(404).json({ detail: 'Key not found' });
            }

            // 不能删除自己
            if (keyId === req.apiKey.id) {
                return res.status(400).json({ detail: 'Cannot deactivate your own key.' });
            }

            // 管理员不能删除最后一个Admin Key
            if (req.apiKey.keyType === KEY_TYPE_ADMIN && keyInfo.keyType === KEY_TYPE_ADMIN) {
                const allKeys = db.getAllApiKeysInfo();
                const activeAdmin = allKeys.filter(k => k.keyType === KEY_TYPE_ADMIN && k.isActive && k.id !== keyId);

                if (activeAdmin.length === 0) {
                    return res.status(400).json({ detail: 'Cannot deactivate last active Admin Key.' });
                }
            }

            if (db.toggleApiKeyActivation(keyId, false)) {
                return res.json({ message: `Key '${keyId}' deactivated.` });
            }

            res.status(500).json({ detail: 'Database error during deactivation.' });
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    // 刷新 API Key
    router.post('/:key_id/refresh', requireRegularKeyForOwnServerKeys(db), async (req, res) => {
        try {
            const keyId = req.params.key_id;
            
            // 不能刷新自己 (防止立即失去访问权限)
            if (keyId === req.apiKey.id) {
                return res.status(400).json({ detail: 'Cannot refresh your own key.' });
            }

            const result = await db.refreshApiKey(keyId);
            res.json({
                ...db.getApiKeyDetailsById(result.keyId),
                key: result.rawKey,
                message: 'Key refreshed successfully.'
            });
        } catch (error) {
            res.status(500).json({ detail: error.message });
        }
    });

    router.delete('/:key_id', requireAdminKey, (req, res) => {
        try {
            const keyId = req.params.key_id;

            if (!db.getApiKeyDetailsById(keyId)) {
                return res.status(404).json({ detail: 'Key not found' });
            }

            // 不能删除自己
            if (keyId === req.apiKey.id) {
                return res.status(400).json({ detail: 'Cannot delete your own key.' });
            }

            db.deleteApiKeyById(keyId);
            res.status(204).send();
        } catch (error) {
            if (error.message.includes('last Admin Key')) {
                return res.status(400).json({ detail: error.message });
            }
            res.status(500).json({ detail: error.message });
        }
    });

    return router;
}

module.exports = createKeysRouter;