2 Commits

Author SHA1 Message Date
Kar
3421a198f3 curl sample 2025-08-14 22:09:10 +05:30
Kar
75656c8f17 Update src/routes/api/aiFollowupQuestion.js 2025-04-28 16:46:41 +00:00
6 changed files with 173 additions and 746 deletions

612
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -48,19 +48,18 @@
], ],
"dependencies": { "dependencies": {
"aws-sdk": "^2.1669.0", "aws-sdk": "^2.1669.0",
"axios": "^1.8.2", "axios": "^1.7.7",
"bcryptjs": "^2.4.3", "bcryptjs": "^2.4.3",
"body-parser": "^1.20.2", "body-parser": "^1.20.2",
"compression": "^1.7.4", "compression": "^1.7.4",
"cors": "^2.8.5", "cors": "^2.8.5",
"cross-env": "^7.0.0", "cross-env": "^7.0.0",
"dotenv": "^10.0.0", "dotenv": "^10.0.0",
"express": "^4.21.2", "express": "^4.17.1",
"express-mongo-sanitize": "^2.0.0", "express-mongo-sanitize": "^2.0.0",
"express-rate-limit": "^5.0.0", "express-rate-limit": "^5.0.0",
"form-data": "^4.0.2", "form-data": "^4.0.1",
"formdata-node": "^6.0.3", "formdata-node": "^6.0.3",
"fs": "^0.0.1-security",
"helmet": "^4.1.0", "helmet": "^4.1.0",
"http-status": "^1.4.0", "http-status": "^1.4.0",
"install": "^0.13.0", "install": "^0.13.0",
@@ -76,9 +75,7 @@
"npm": "^11.0.0", "npm": "^11.0.0",
"passport": "^0.4.0", "passport": "^0.4.0",
"passport-jwt": "^4.0.0", "passport-jwt": "^4.0.0",
"path": "^0.12.7",
"pm2": "^5.1.0", "pm2": "^5.1.0",
"puppeteer": "^24.4.0",
"swagger-jsdoc": "^6.0.8", "swagger-jsdoc": "^6.0.8",
"swagger-ui-express": "^4.1.6", "swagger-ui-express": "^4.1.6",
"validator": "^13.0.0", "validator": "^13.0.0",

View File

@@ -1,4 +1,29 @@
const aiFollowupQuestion = async (req, res) => { const aiFollowupQuestion = async (req, res) => {
// curl -X POST http://localhost:3000/your-endpoint-path \
// -H "Content-Type: application/json" \
// -d '{
// "prompt": "Why is the sky blue?",
// "sessionId": "",
// "model": "gpt-3.5-turbo-16k",
// "max_tokens": 200
// }'
// curl -X POST http://localhost:5174/api/aiFollowupQuestion \
// -H "Content-Type: application/json" \
// -d '{
// "prompt": "Why is the sky blue?",
// "sessionId": "",
// "model": "gpt-3.5-turbo-16k",
// "sessionId" : "8c641aca-582d-4ea7-8e56-4f94318efe74",
// "max_tokens": 200
// }'
// {
// "success": true,
// "data": "The sky looks blue because of how sunlight scatters in the air. Great question! Ask me more!",
// "total_tokens": 45,
// "sessionId": "2a3b3cc4-xxxx-xxxx-xxxx-xxxxxxxxxxxx"
// }
const { MongoClient } = require('mongodb'); const { MongoClient } = require('mongodb');
// const fetch = require('node-fetch'); // const fetch = require('node-fetch');
@@ -11,11 +36,11 @@ const aiFollowupQuestion = async (req, res) => {
const database = client.db(dbName); const database = client.db(dbName);
const conversationsCollection = database.collection('conversations'); const conversationsCollection = database.collection('conversations');
async function fetchOpenAICompletion(prompt, messages, model = "gpt-3.5-turbo-16k", max_tokens = 200) { async function fetchOpenAICompletion(prompt, messages, model = 'gpt-3.5-turbo-16k', max_tokens = 200) {
const response = await fetch('https://api.openai.com/v1/chat/completions', { const response = await fetch('https://api.openai.com/v1/chat/completions', {
method: 'POST', method: 'POST',
headers: { headers: {
'Authorization': `Bearer ${process.env.OPENAI_KEY}`, Authorization: `Bearer ${process.env.OPENAI_KEY}`,
'Content-Type': 'application/json', 'Content-Type': 'application/json',
}, },
body: JSON.stringify({ body: JSON.stringify({
@@ -35,9 +60,8 @@ const aiFollowupQuestion = async (req, res) => {
return data; return data;
} }
try { try {
const { prompt, sessionId, model = "gpt-3.5-turbo-16k", max_tokens = 200 } = req.body; const { prompt, sessionId, model = 'gpt-3.5-turbo-16k', max_tokens = 200 } = req.body;
if (!conversationsCollection) { if (!conversationsCollection) {
return res.status(500).json({ return res.status(500).json({
success: false, success: false,
@@ -52,7 +76,11 @@ const aiFollowupQuestion = async (req, res) => {
conversation = { conversation = {
sessionId: newSessionId, sessionId: newSessionId,
conversationHistory: [ conversationHistory: [
{ role: 'system', content: 'answer within 10 words' }, {
role: 'system',
content:
'Reply to the questions asked by a kindergarten child, Sound excited to answer and encourage the child to ask more questions in 30 words',
},
{ role: 'user', content: prompt }, { role: 'user', content: prompt },
], ],
}; };
@@ -90,8 +118,6 @@ const aiFollowupQuestion = async (req, res) => {
error: 'Something went wrong. Please try again later.', error: 'Something went wrong. Please try again later.',
}); });
} }
};
module.exports = aiFollowupQuestion;
}
module.exports = aiFollowupQuestion;

View File

@@ -3,6 +3,15 @@ const AWS = require('aws-sdk');
const FormData = require('form-data'); const FormData = require('form-data');
const aiTextToSpeech = async (req, res) => { const aiTextToSpeech = async (req, res) => {
// curl -X POST http://localhost:5174/api/aiTextToSpeech \
// -H "Content-Type: application/json" \
// -d '{
// "text": "Hello, this is a sample speech.",
// "voiceId": "Ava"
// }'
// {"message":"Speech generated and saved successfully","fileUrls":["https://polly-bs.s3.ap-south-1.amazonaws.com/file_MpNpWluxR7R70BA-dzju_U3C94bPmC-n-speech.mp3?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=AKIAQ35B6OYR6T5MGH7Q%2F20250814%2Fap-south-1%2Fs3%2Faws4_request&X-Amz-Date=20250814T163252Z&X-Amz-Expires=86400&X-Amz-Signature=12dd2feaf73564d6c843b0dc975fdedb35c430d316f4f09fcdf41e247d1ea63c&X-Amz-SignedHeaders=host","https://polly-bs.s3.ap-south-1.amazonaws.com/file_SXmwHWwlcSBlI9LNoZ1PcLEdMD7D1PWO-text.txt?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=AKIAQ35B6OYR6T5MGH7Q%2F20250814%2Fap-south-1%2Fs3%2Faws4_request&X-Amz-Date=20250814T163252Z&X-Amz-Expires=86400&X-Amz-Signature=d96eb4fe7cabfab93ce0ffe8fc74a8e722a2064d904652d47ad361f2f3667ec7&X-Amz-SignedHeaders=host"],"fileKeys":{"file1":"file_MpNpWluxR7R70BA-dzju_U3C94bPmC-n-speech.mp3","file2":"file_SXmwHWwlcSBlI9LNoZ1PcLEdMD7D1PWO-text.txt"}}
AWS.config.update({ AWS.config.update({
region: 'ap-south-1', region: 'ap-south-1',
accessKeyId: process.env.AWS_polly2_ACCESS_KEY_ID, accessKeyId: process.env.AWS_polly2_ACCESS_KEY_ID,
@@ -11,12 +20,12 @@ const aiTextToSpeech = async (req, res) => {
const polly = new AWS.Polly(); const polly = new AWS.Polly();
const voiceIdMap = { const voiceIdMap = {
"Ava": "Ivy", Ava: 'Ivy',
"Monstero": "Justin", Monstero: 'Justin',
"Dax": "Kevin", Dax: 'Kevin',
"Kai": "Danielle", Kai: 'Danielle',
"Arlo": "Ruth", Arlo: 'Ruth',
"Yara": "Salli" Yara: 'Salli',
}; };
const { text, voiceId: frontendVoiceId } = req.body; const { text, voiceId: frontendVoiceId } = req.body;
@@ -41,7 +50,9 @@ const aiTextToSpeech = async (req, res) => {
function generateTimestampWithRandomDigits() { function generateTimestampWithRandomDigits() {
const now = new Date(); const now = new Date();
const formattedDate = now.toISOString().replace('T', '_').replace(/\..+/, '').replace(/:/g, '-'); const formattedDate = now.toISOString().replace('T', '_').replace(/\..+/, '').replace(/:/g, '-');
const randomDigits = Math.floor(Math.random() * 10000).toString().padStart(4, '0'); const randomDigits = Math.floor(Math.random() * 10000)
.toString()
.padStart(4, '0');
return `${formattedDate}_${randomDigits}`; return `${formattedDate}_${randomDigits}`;
} }
@@ -59,23 +70,18 @@ const aiTextToSpeech = async (req, res) => {
// formData.append('folder', folderName); // Send folder name // formData.append('folder', folderName); // Send folder name
formData.append('bucket', 'polly-bs'); // Adjust bucket formData.append('bucket', 'polly-bs'); // Adjust bucket
const response = await axios.post( const response = await axios.post('https://preschool-curriculum.in/api/one/v1/file/upload', formData, {
'https://preschool-curriculum.in/api/one/v1/file/upload',
formData,
{
headers: { headers: {
// 'Authorization': `Bearer ${process.env.BEARER_TOKEN}`, // 'Authorization': `Bearer ${process.env.BEARER_TOKEN}`,
...formData.getHeaders() // Ensure FormData headers are included ...formData.getHeaders(), // Ensure FormData headers are included
} },
} });
);
res.json({ res.json({
message: 'Speech generated and saved successfully', message: 'Speech generated and saved successfully',
fileUrls: response.data.urls, fileUrls: response.data.urls,
fileKeys: response.data.data fileKeys: response.data.data,
}); });
} catch (error) { } catch (error) {
console.error('Error generating speech or uploading files:', error); console.error('Error generating speech or uploading files:', error);
res.status(500).json({ error: 'Error generating speech or uploading files' }); res.status(500).json({ error: 'Error generating speech or uploading files' });

View File

@@ -1,99 +0,0 @@
const { execSync } = require("child_process");
const fs = require("fs");
const path = require("path");
const axios = require("axios");
const gameIds = [
'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', '114'
];
const SCREENSHOT_FOLDER = path.join(__dirname, "game-screen/drawing");
if (!fs.existsSync(SCREENSHOT_FOLDER)) {
fs.mkdirSync(SCREENSHOT_FOLDER, { recursive: true });
}
const DIRECTUS_API_URL = "https://game-du.teachertrainingkolkata.in/files";
async function takeSnap(req, res) {
for (const id of gameIds) {
try {
const url = `https://interaktogames.beanstalkedu.com/tick/v1?id=${id}`;
console.log(`📸 Taking screenshot for Game ID: ${id}`);
const command = `url2jpg ${url}`;
execSync(command, { stdio: "inherit", shell: true });
const files = fs.readdirSync(process.cwd()).filter(f => f.endsWith(".jpg"));
if (files.length === 0) throw new Error("No screenshot found!");
const latestFile = files.reduce((a, b) =>
fs.statSync(b).mtimeMs > fs.statSync(a).mtimeMs ? b : a
);
const newPath = path.join(SCREENSHOT_FOLDER, `${id}.jpg`);
fs.renameSync(latestFile, newPath);
console.log(`✅ Screenshot saved: ${newPath}`);
const fileId = await uploadToDirectus(newPath);
if (fileId) {
console.log(`📤 Uploaded to Directus. File ID: ${fileId}`);
await updateThumbnail(id, fileId);
}
} catch (error) {
console.error(`❌ Error processing Game ID ${id}:`, error.message);
}
}
res.json({ message: "All screenshots processed successfully!" });
}
async function uploadToDirectus(filePath) {
try {
const fileData = fs.createReadStream(filePath);
const response = await axios.post(
DIRECTUS_API_URL,
{ file: fileData },
{
headers: { "Content-Type": "multipart/form-data" },
}
);
return response.data.data.id;
} catch (error) {
console.error("❌ Failed to upload screenshot to Directus:", error.message);
return null;
}
}
async function updateThumbnail(gameId, fileId) {
const UPDATE_THUMBNAIL_URL = "https://game-du.teachertrainingkolkata.in/items/game_tick_variant1/";
try {
const response = await axios.patch(
`${UPDATE_THUMBNAIL_URL}${gameId}`,
{ thumbnail: fileId }, // ✅ No need for "data" wrapper in REST API
{ headers: { "Content-Type": "application/json" } }
);
console.log(`✅ Thumbnail updated for Game ID ${gameId}:`, response.data);
} catch (error) {
console.error(`❌ Failed to update thumbnail for Game ID ${gameId}`);
if (error.response) {
console.error("Response Data:", error.response.data);
console.error("Status Code:", error.response.status);
} else {
console.error("Error Message:", error.message);
}
}
}
module.exports = takeSnap;

View File

@@ -35,7 +35,6 @@ const getGameInfo = require("../api/getGameInfo");
const saveGalleryImage = require("../api/saveGalleryImage"); const saveGalleryImage = require("../api/saveGalleryImage");
const getGalleryImage = require("../api/getGalleryImage"); const getGalleryImage = require("../api/getGalleryImage");
const getGameData = require("../api/getGameData"); const getGameData = require("../api/getGameData");
const takeSnap = require("../api/takeSnap");
// const aiTest = require("../api/aiTest"); // const aiTest = require("../api/aiTest");
@@ -215,10 +214,6 @@ router.get("/ping", (req, res) => {
getGameData(req, res); getGameData(req, res);
}); });
router.get("/takeSnap", (req, res) => {
takeSnap(req, res);
});
// Get Drawing Game Gallery Image // Get Drawing Game Gallery Image
// router.post("/aiTest", (req, res) => { // router.post("/aiTest", (req, res) => {
// aiTest(req, res); // aiTest(req, res);