diff --git a/src/utils/child_process.js b/src/utils/child_process.js new file mode 100644 index 0000000..7fdcac5 --- /dev/null +++ b/src/utils/child_process.js @@ -0,0 +1,14 @@ +import axios from 'axios'; + +process.stdin.setEncoding('utf8'); + +process.stdin.on('data', async (data) => { + const requestData = JSON.parse(data); + + try { + const response = await axios(requestData); + console.log(response.data); + } catch (error) { + console.error('Error sending data:', error); + } +}); diff --git a/src/utils/sendDataSAbackend.ts b/src/utils/sendDataSAbackend.ts index e22113e..8a0cba7 100644 --- a/src/utils/sendDataSAbackend.ts +++ b/src/utils/sendDataSAbackend.ts @@ -1,14 +1,27 @@ -import axios from 'axios' -import { messageDataType } from '../types' +import { spawn } from 'child_process'; +import axios from 'axios'; +import { messageDataType } from '../types'; - -export const sendDataSAbackend = async (messageData : messageDataType) => { - const apiUrl = `` +export const sendDataSAbackend = async (messageData: messageDataType) => { + const apiUrl = 'YOUR_BACKEND_ENDPOINT_URL'; const body = { - method : 'post', - url : apiUrl, - data : messageData, - headers : '' - } -} \ No newline at end of file + method: 'post', + url: apiUrl, + data: messageData, + headers: { 'Content-Type': 'application/json' } // Assuming JSON data + }; + + const child = spawn('node', ['child_process.js'], { stdio: 'inherit' }); // Spawning child process + + child.on('exit', (code) => { + console.log(`Child process exited with code ${code}`); + }); + + child.on('error', (err) => { + console.error('Failed to start subprocess.', err); + }); + + child?.stdin?.write(JSON.stringify(body)); // Sending data to child process + child?.stdin?.end(); +}; diff --git a/src/wa.ts b/src/wa.ts index 9b68795..dd0bcdb 100644 --- a/src/wa.ts +++ b/src/wa.ts @@ -1,4 +1,4 @@ -import makeWASocket, { ConnectionState, DisconnectReason, SocketConfig, fetchLatestBaileysVersion, makeCacheableSignalKeyStore, downloadMediaMessage } from "@whiskeysockets/baileys"; +import makeWASocket, { ConnectionState, DisconnectReason, SocketConfig, fetchLatestBaileysVersion, makeCacheableSignalKeyStore, downloadMediaMessage, mediaMessageSHA256B64 } from "@whiskeysockets/baileys"; import { Boom } from '@hapi/boom'; import { Response } from "express"; import { logger, prisma } from "./shared"; @@ -224,6 +224,7 @@ export async function createSession(options:createSessionOptions) { messageData.caption = msg?.message?.imageMessage?.caption; messageData.timestamp = (msg.messageTimestamp)?.toString()!; sendDataSAbackend(messageData); + console.log(messageData); // @ts-ignore // await writeFile('./demo.jpeg', Buffer.from(buffer, 'binary').toString('base64')).then(()=>{console.log("image-generated")}); } @@ -231,6 +232,7 @@ export async function createSession(options:createSessionOptions) { messageData.phoneNumber = msg.key.remoteJid!.slice(2,12); messageData.message = msg.message?.conversation; messageData.timestamp = (msg.messageTimestamp)?.toString()!; + console.log(messageData); sendDataSAbackend(messageData); } }