Update router/api.js

router/api.js

@@ -1 +1,97 @@
-aaaa
+import express from 'express';
+import axios from 'axios';
+import crypto from 'crypto';
+import FormData from 'form-data'; // Import modul form-data untuk menghandle multipart
+import Groq from 'groq-sdk';
+
+const APIrouter = express.Router();
+
+const ISauthenticate = async (req, res, next) => {
+  try {
+    // Contoh sederhana: menggunakan menit UTC sebagai secret
+    const secretResponse = new Date().getUTCMinutes().toString();
+    const generatedApiKey = generateApiKey(secretResponse);
+    console.log(generatedApiKey);
+    console.log(req.headers);
+    const authHeader = req.headers['authorization'];
+    if (!authHeader || authHeader !== `Bearer ${generatedApiKey}`) {
+      return res.status(403).json({ success: false, message: 'Unauthorized' });
+    }
+    next();
+  } catch (error) {
+    console.error('Authentication error:', error);
+    return res.status(500).json({ success: false, message: 'Internal Server Error' });
+  }
+};
+
+// Inisialisasi Groq SDK
+const client = new Groq({
+  apiKey: process.env.GROQ_API_KEY || "",
+  dangerouslyAllowBrowser: true,
+});
+
+APIrouter.get('/', (req, res) => {
+  res.send('Hello World');
+});
+
+APIrouter.post('/gpt/completions', ISauthenticate, async (req, res) => {
+  console.log(req.body);
+  const { messages, model, temperature, max_completion_tokens, top_p, stream, stop } = req.body;
+  try {
+
+    // Atur header untuk streaming
+    res.setHeader('Content-Type', 'text/event-stream');
+    res.setHeader('Cache-Control', 'no-cache');
+    res.setHeader('Connection', 'keep-alive');
+    
+    const chatStream = await client.chat.completions.create({
+      messages,
+      model,
+      temperature,
+      max_completion_tokens,
+      top_p,
+      stream,
+      stop,
+    });
+    
+    // Atau jika perlu mengatur secara manual:
+    chatStream.on('data', chunk => {
+      res.write(`data: ${chunk}\n\n`);
+    });
+    chatStream.on('end', () => {
+      res.write('data: [DONE]\n\n');
+      res.end();
+    });
+    chatStream.on('error', err => {
+      console.error('Stream error:', err);
+      res.end();
+    });
+  } catch (error) {
+    console.error('GPT completion error:', error);
+    res.status(500).json({ message: 'Internal Server Error' });
+  }
+});
+
+APIrouter.get('/gpt/modellist', ISauthenticate, async (req, res) => {
+  try {
+     const models = await client.models.list();
+     res.json(models);
+  } catch (error) {
+    console.error('GPT completion error:', error);
+    res.status(500).json({ message: 'Internal Server Error' });
+  }
+});
+
+export default APIrouter;
+
+function generateApiKey(secret) {
+  // Ambil menit saat ini sebagai nilai integer
+  const currentMinute = Math.floor(Date.now() / 60000).toString();
+  
+  // Buat HMAC menggunakan algoritma SHA256 dan secret key
+  const hmac = crypto.createHmac('sha256', secret);
+  hmac.update(currentMinute);
+  
+  // Kembalikan hash dalam format hexadecimal
+  return hmac.digest('hex');
+}