const express = require('express');
const line = require('@line/bot-sdk');
const app = express();

const config = {
  channelAccessToken: 'YOUR_CHANNEL_ACCESS_TOKEN',
  channelSecret: 'YOUR_CHANNEL_SECRET'
};

const client = new line.Client(config);

app.post('/webhook', line.middleware(config), (req, res) => {
  Promise
    .all(req.body.events.map(handleEvent))
    .then((result) => res.json(result))
    .catch((err) => {
      console.error(err);
      res.status(500).end();
    });
});

function handleEvent(event) {
  if (event.type !== 'message' || event.message.type !== 'text') {
    return Promise.resolve(null);
  }

  const userMessage = event.message.text;
  let replyMessage = '申し訳ございません。';

  if (userMessage.includes('こんにちは')) {
    replyMessage = 'こんにちは!何かお手伝いできますか?';
  }

  return client.replyMessage(event.replyToken, {
    type: 'text',
    text: replyMessage
  });
}

app.listen(3000);

const OpenAI = require('openai');
const openai = new OpenAI({ 
  apiKey: process.env.OPENAI_API_KEY 
});

async function generateAIResponse(userMessage) {
  const completion = await openai.chat.completions.create({
    model: "gpt-4",
    messages: [
      {
        role: "system",
        content: "親切なカスタマーサポートです"
      },
      {
        role: "user",
        content: userMessage
      }
    ]
  });
  
  return completion.choices[0].message.content;
}

const flexMessage = {
  type: 'flex',
  altText: '商品情報',
  contents: {
    type: 'bubble',
    hero: {
      type: 'image',
      url: 'https://example.com/product.jpg',
      size: 'full'
    },
    body: {
      type: 'box',
      layout: 'vertical',
      contents: [
        {
          type: 'text',
          text: 'プレミアムコーヒー',
          weight: 'bold',
          size: 'xl'
        }
      ]
    }
  }
};

const { Pool } = require('pg');
const pool = new Pool({
  user: 'dbuser',
  host: 'localhost',
  database: 'linebot'
});

async function registerUser(userId, displayName) {
  const query = `
    INSERT INTO users (line_user_id, display_name)
    VALUES ($1, $2)
    ON CONFLICT (line_user_id) 
    DO UPDATE SET display_name = $2
  `;
  await pool.query(query, [userId, displayName]);
}

async function requestPayment(amount) {
  const response = await fetch(
    'https://api-pay.line.me/v2/payments/request',
    {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        amount: amount,
        currency: 'JPY'
      })
    }
  );
  return await response.json();
}

async function broadcastMessage(message) {
  await client.broadcast({
    type: 'text',
    text: message
  });
}