const express = require('express');
const axios = require('axios');

const app = express();

// Body parser middleware
app.use(express.json());
app.use(express.text()); // เพิ่ม middleware สำหรับ text/plain

// ใส่ Token ที่คุณได้รับจาก Line Notify ที่นี่
const LINE_NOTIFY_TOKEN = 'xxxxxxxxxxxxxx';

app.post('/linenotify', async (req, res) => {
  console.log(req.body)
  let text;

  // ตรวจสอบ Content-Type และปรับค่าตามนั้น
  if (req.is('json')) {
    text = req.body.text;
  } else if (req.is('text')) {
    text = req.body;
  } else {
    return res.status(400).json({ error: 'Content-Type ไม่ถูกต้อง' });
  }

  console.log(text);

  if (!text) {
    return res.status(400).json({ error: 'ข้อความไม่ถูกต้อง' });
  }

  try {
    const response = await axios.post(
      'https://notify-api.line.me/api/notify',
      `message=${text}`,
      {
        headers: {
          'Content-Type': 'application/x-www-form-urlencoded',
          'Authorization': `Bearer ${LINE_NOTIFY_TOKEN}`,
        },
      }
    );

    if (response.status === 200) {
      console.log('ส่งข้อความ Line Notify เรียบร้อยแล้ว');
      return res.status(200).json({ message: 'ส่งข้อความ Line Notify เรียบร้อยแล้ว' });
    } else {
      console.error('เกิดข้อผิดพลาดในการส่งข้อความ Line Notify');
      return res.status(500).json({ error: 'เกิดข้อผิดพลาดในการส่งข้อความ Line Notify' });
    }
  } catch (error) {
    console.error('เกิดข้อผิดพลาดในการส่งข้อความ Line Notify:', error.message);
    return res.status(500).json({ error: 'เกิดข้อผิดพลาดในการส่งข้อความ Line Notify' });
  }
});

const PORT = process.env.PORT || 3000;

app.listen(PORT, () => {
  console.log(`Server is running on port ${PORT}`);
});