File size: 2,216 Bytes
88c4c60 | 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 | import { v4 as uuidv4 } from "uuid";
import { getAdapter } from "../driver.js";
function rowToKey(row) {
if (!row) return null;
return {
id: row.id,
key: row.key,
name: row.name,
machineId: row.machineId,
isActive: row.isActive === 1 || row.isActive === true,
createdAt: row.createdAt,
};
}
export async function getApiKeys() {
const db = await getAdapter();
const rows = db.all(`SELECT * FROM apiKeys ORDER BY createdAt ASC`);
return rows.map(rowToKey);
}
export async function getApiKeyById(id) {
const db = await getAdapter();
const row = db.get(`SELECT * FROM apiKeys WHERE id = ?`, [id]);
return rowToKey(row);
}
export async function createApiKey(name, machineId) {
if (!machineId) throw new Error("machineId is required");
const db = await getAdapter();
const { generateApiKeyWithMachine } = await import("@/shared/utils/apiKey");
const result = generateApiKeyWithMachine(machineId);
const apiKey = {
id: uuidv4(),
name,
key: result.key,
machineId,
isActive: true,
createdAt: new Date().toISOString(),
};
db.run(
`INSERT INTO apiKeys(id, key, name, machineId, isActive, createdAt) VALUES(?, ?, ?, ?, ?, ?)`,
[apiKey.id, apiKey.key, apiKey.name, apiKey.machineId, 1, apiKey.createdAt]
);
return apiKey;
}
export async function updateApiKey(id, data) {
const db = await getAdapter();
let result = null;
db.transaction(() => {
const row = db.get(`SELECT * FROM apiKeys WHERE id = ?`, [id]);
if (!row) return;
const merged = { ...rowToKey(row), ...data };
db.run(
`UPDATE apiKeys SET key = ?, name = ?, machineId = ?, isActive = ? WHERE id = ?`,
[merged.key, merged.name, merged.machineId, merged.isActive ? 1 : 0, id]
);
result = merged;
});
return result;
}
export async function deleteApiKey(id) {
const db = await getAdapter();
const res = db.run(`DELETE FROM apiKeys WHERE id = ?`, [id]);
return (res?.changes ?? 0) > 0;
}
export async function validateApiKey(key) {
const db = await getAdapter();
const row = db.get(`SELECT isActive FROM apiKeys WHERE key = ?`, [key]);
if (!row) return false;
return row.isActive === 1 || row.isActive === true;
}
|