客户端调用Amazon API Gateway的CORS与认证挑战及解决方案

客户端 (Web/Mobile App)
      ↓ (Axios Request)
自定义后端代理服务 (Node.js/Python/Java等)
      ↓ (Server-to-Server Request)
Amazon API Gateway
      ↓ (Response)
自定义后端代理服务
      ↓ (Response)
客户端

npm init -y
npm install express axios cors

const express = require('express');
const axios = require('axios');
const cors = require('cors'); // 用于处理客户端到代理服务的CORS

const app = express();
const port = 3000;

// 配置CORS，允许客户端访问此代理服务
app.use(cors({
    origin: 'http://localhost:8080' // 替换为你的客户端应用的域名和端口
}));
app.use(express.json()); // 用于解析JSON格式的请求体

// 你的Amazon API Gateway的实际URL
const AMAZON_API_GATEWAY_URL = 'https://YOUR_AMAZON_API_GATEWAY_ENDPOINT';
// 如果Amazon API Gateway需要API Key，可以在这里配置
const AMAZON_API_KEY = 'YOUR_AMAZON_API_KEY_IF_NEEDED'; 

// 代理GET请求到Amazon API Gateway
app.get('/api/amazon-resource', async (req, res) => {
    try {
        // 从客户端请求中获取授权头，并转发给Amazon API Gateway
        // 注意：这里假设客户端将Bearer Token发送给你的代理服务
        const clientAuthHeader = req.headers.authorization; 

        const headers = {
            'Accept': 'application/json',
            // 将客户端的授权头转发给Amazon API Gateway
            'Authorization': clientAuthHeader || '' 
        };

        // 如果API Gateway需要API Key，也添加到请求头中
        if (AMAZON_API_KEY) {
            headers['x-api-key'] = AMAZON_API_KEY;
        }

        // 发起服务器到服务器的请求
        const apiGatewayResponse = await axios.get(AMAZON_API_GATEWAY_URL, { headers });

        // 将Amazon API Gateway的响应返回给客户端
        res.status(apiGatewayResponse.status).json(apiGatewayResponse.data);

    } catch (error) {
        console.error('Error proxying request to Amazon API Gateway:', error.message);
        // 检查Axios错误响应
        if (error.response) {
            // 将Amazon API Gateway的错误响应返回给客户端
            res.status(error.response.status).json(error.response.data);
        } else {
            res.status(500).json({ message: 'Internal Server Error', details: error.message });
        }
    }
});

// 你也可以为POST, PUT, DELETE等方法创建类似的代理路由
app.post('/api/amazon-resource', async (req, res) => {
    try {
        const clientAuthHeader = req.headers.authorization;
        const headers = {
            'Accept': 'application/json',
            'Content-Type': 'application/json', // 确保POST请求有Content-Type
            'Authorization': clientAuthHeader || ''
        };
        if (AMAZON_API_KEY) {
            headers['x-api-key'] = AMAZON_API_KEY;
        }

        const apiGatewayResponse = await axios.post(AMAZON_API_GATEWAY_URL, req.body, { headers });
        res.status(apiGatewayResponse.status).json(apiGatewayResponse.data);

    } catch (error) {
        console.error('Error proxying POST request to Amazon API Gateway:', error.message);
        if (error.response) {
            res.status(error.response.status).json(error.response.data);
        } else {
            res.status(500).json({ message: 'Internal Server Error', details: error.message });
        }
    }
});

app.listen(port, () => {
    console.log(`Proxy server listening at http://localhost:${port}`);
});

// 假设你的代理服务运行在 http://localhost:3000
const API_BASE_URL = 'http://localhost:3000'; 
const userToken = 'YOUR_ACTUAL_USER_TOKEN'; // 从你的认证流程中获取

async function fetchDataFromAmazon() {
    try {
        const headers = {
            'Authorization': 'Bearer ' + userToken,
            'Accept': 'application/json'
        };

        // 调用你的后端代理服务
        const response = await axios.get(`${API_BASE_URL}/api/amazon-resource`, { headers });
        console.log('Success from proxy:', response.data);
    } catch (error) {
        console.error('Error calling proxy:', error.response ? error.response.data : error.message);
    }
}

fetchDataFromAmazon();