28594_usage_tracking

@@ -5,6 +5,7 @@ const cors = require('cors')
 require('dotenv').config()
 require('dotenv').config()
 const rateLimit = require('express-rate-limit')
 const rateLimit = require('express-rate-limit')
 const anchorme = require("anchorme").default;
 const anchorme = require("anchorme").default;
+const axios = require('axios');
 const tiktoken = require('@dqbd/tiktoken');
 const tiktoken = require('@dqbd/tiktoken');
 const tiktokenModels = [
 const tiktokenModels = [
   'text-davinci-003',
   'text-davinci-003',
@@ -105,6 +106,23 @@ app.post('/api', async (req, res) => {
 			temperature,
 			temperature,
 		  });
 		  });
 		let input = response.data.choices[0].text;
 		let input = response.data.choices[0].text;
+		let usage = {};
+		let enc = null;
+		try {
+			enc = encoding_for_model(tiktokenModels.includes(currentModel) ? currentModel : 'gpt-3.5-turbo');
+			usage.prompt_tokens = (enc.encode(query_prompt)).length;
+			usage.completion_tokens = (enc.encode(input)).length;
+			usage.total_tokens = usage.prompt_tokens + usage.completion_tokens;
+		} catch (e) {
+			console.log('Error encoding prompt text', e);
+		}
+
+		// TOKEN USAGE
+    axios.post(`${process.env.API_URL}e/set-chat-usage`,
+      { app: 'chatbot', prompt_token: usage.prompt_tokens, total_token: usage.total_tokens },
+      { headers: { 'content-type': 'application/x-www-form-urlencoded' }
+    });
+
 		res.json({
 		res.json({
 			message: anchorme({
 			message: anchorme({
 				input,
 				input,
@@ -133,6 +151,8 @@ async function runGPTTurbo(req, res) {
 	// "gpt-3.5-turbo"
 	// "gpt-3.5-turbo"
 	const { message, currentModel, temperature } = req.body;
 	const { message, currentModel, temperature } = req.body;
 	var input = '';
 	var input = '';
+	const message_history = JSON.parse(message);
+	const query_prompt = message_history.length ? message_history[message_history.length - 1].content : "";
 	try {
 	try {
 		const response = await openai.createChatCompletion({
 		const response = await openai.createChatCompletion({
 			model: `${currentModel}`,
 			model: `${currentModel}`,
@@ -149,6 +169,24 @@ async function runGPTTurbo(req, res) {
 			console.log(e.response);
 			console.log(e.response);
 		}
 		}
 	} finally {
 	} finally {
+
+		let usage = {};
+		let enc = null;
+		try {
+			enc = encoding_for_model(tiktokenModels.includes(currentModel) ? currentModel : 'gpt-3.5-turbo');
+			usage.prompt_tokens = (enc.encode(query_prompt)).length;
+			usage.completion_tokens = (enc.encode(input)).length;
+			usage.total_tokens = usage.prompt_tokens + usage.completion_tokens;
+		} catch (e) {
+			console.log('Error encoding prompt text', e);
+		}
+
+		// TOKEN USAGE
+    axios.post(`${process.env.API_URL}e/set-chat-usage`,
+      { app: 'chatbot', prompt_token: usage.prompt_tokens, total_token: usage.total_tokens },
+      { headers: { 'content-type': 'application/x-www-form-urlencoded' }
+    });
+
 		res.json({
 		res.json({
 			prompt: JSON.parse(message),
 			prompt: JSON.parse(message),
 			message: anchorme({
 			message: anchorme({

@@ -11,6 +11,7 @@
   "dependencies": {
   "dependencies": {
     "@dqbd/tiktoken": "^1.0.7",
     "@dqbd/tiktoken": "^1.0.7",
     "anchorme": "^2.1.2",
     "anchorme": "^2.1.2",
+    "axios": "^1.5.1",
     "body-parser": "^1.20.1",
     "body-parser": "^1.20.1",
     "cors": "^2.8.5",
     "cors": "^2.8.5",
     "dotenv": "^16.0.3",
     "dotenv": "^16.0.3",