poe.js

import fs from 'fs/promises';
import { exec } from 'child_process';
import { promisify } from 'util';

const newsContentFile = './poe-query/_input_content.txt';
const newsReportFile = './poe-query/_output.txt';

const execPromise = promisify(exec);
export async function queryNewsToPoe(content) {
  try {
    await fs.writeFile(newsContentFile, content);
    const command = 'cd poe-query && python3 poe.py';
    const { stdout, stderr } = await Promise.race([
      execPromise(command),
    ]);

    // console.log(`stdout: ${stdout}`);
    // console.error(`stderr: ${stderr}`);

    const data = await fs.readFile(newsReportFile, 'utf8');
    return data;
  } catch (err) {
    console.error(err);
  }
}

// const report = await queryNewsToPoe('this is a sample news.');
// if(report){
//   console.log(JSON.parse(report));
// }