124 lines
3.3 KiB
JavaScript
124 lines
3.3 KiB
JavaScript
const { ApolloServer } = require('@apollo/server');
|
|
const { startServerAndCreateNextHandler } = require('@as-integrations/next');
|
|
const { Pool } = require('pg');
|
|
|
|
// 1. Inisialisasi Pool PostgreSQL untuk Serverless
|
|
const pool = new Pool({
|
|
connectionString: process.env.DATABASE_URL,
|
|
ssl: {
|
|
rejectUnauthorized: false,
|
|
},
|
|
max: 1, // Batasi 1 koneksi per instance serverless
|
|
});
|
|
|
|
// 2. Definisi Schema GraphQL (typeDefs)
|
|
const typeDefs = `#graphql
|
|
type Category {
|
|
id: ID!
|
|
name: String!
|
|
description: String
|
|
products: [Product!]!
|
|
}
|
|
|
|
type Product {
|
|
id: ID!
|
|
title: String!
|
|
price: Float!
|
|
category_id: Int
|
|
created_by: ID
|
|
category: Category
|
|
}
|
|
|
|
type Query {
|
|
categories: [Category!]!
|
|
category(id: ID!): Category
|
|
products: [Product!]!
|
|
product(id: ID!): Product
|
|
}
|
|
`;
|
|
|
|
// 3. Definisi Resolver (Query + Nested Resolvers)
|
|
const resolvers = {
|
|
Query: {
|
|
categories: async () => {
|
|
const result = await pool.query('SELECT * FROM categories ORDER BY id ASC');
|
|
return result.rows;
|
|
},
|
|
category: async (_, { id }) => {
|
|
const result = await pool.query('SELECT * FROM categories WHERE id = $1', [id]);
|
|
return result.rows[0] || null;
|
|
},
|
|
products: async () => {
|
|
const result = await pool.query(
|
|
'SELECT id, title, price::float, category_id, created_by FROM products ORDER BY id ASC'
|
|
);
|
|
return result.rows;
|
|
},
|
|
product: async (_, { id }) => {
|
|
const result = await pool.query(
|
|
'SELECT id, title, price::float, category_id, created_by FROM products WHERE id = $1',
|
|
[id]
|
|
);
|
|
return result.rows[0] || null;
|
|
},
|
|
},
|
|
|
|
// Resolver Relasi Category -> Products (One-to-Many)
|
|
Category: {
|
|
products: async (parent) => {
|
|
const result = await pool.query(
|
|
'SELECT id, title, price::float, category_id, created_by FROM products WHERE category_id = $1 ORDER BY id ASC',
|
|
[parent.id]
|
|
);
|
|
return result.rows;
|
|
},
|
|
},
|
|
|
|
// Resolver Relasi Product -> Category (Many-to-One)
|
|
Product: {
|
|
category: async (parent) => {
|
|
if (!parent.category_id) return null;
|
|
const result = await pool.query('SELECT * FROM categories WHERE id = $1', [parent.category_id]);
|
|
return result.rows[0] || null;
|
|
},
|
|
},
|
|
};
|
|
|
|
// 4. Inisialisasi Apollo Server
|
|
const server = new ApolloServer({
|
|
typeDefs,
|
|
resolvers,
|
|
introspection: true,
|
|
csrfPrevention: false, // Mematikan proteksi CSRF agar request dari browser Sandbox tidak dicegat
|
|
});
|
|
|
|
const apolloHandler = startServerAndCreateNextHandler(server);
|
|
|
|
// 5. Handler CORS untuk Apollo Studio dan Embedded Sandbox
|
|
module.exports = async function handler(req, res) {
|
|
const allowedOrigins = new Set([
|
|
'https://studio.apollographql.com',
|
|
'https://embeddable-sandbox.cdn.apollographql.com',
|
|
]);
|
|
const origin = req.headers.origin;
|
|
|
|
if (allowedOrigins.has(origin)) {
|
|
res.setHeader('Access-Control-Allow-Origin', origin);
|
|
res.setHeader('Vary', 'Origin');
|
|
}
|
|
|
|
res.setHeader('Access-Control-Allow-Methods', 'GET,POST,OPTIONS');
|
|
res.setHeader(
|
|
'Access-Control-Allow-Headers',
|
|
'Content-Type, Authorization, apollo-require-preflight, x-apollo-operation-name'
|
|
);
|
|
|
|
// Respons langsung untuk preflight OPTIONS request
|
|
if (req.method === 'OPTIONS') {
|
|
res.status(200).end();
|
|
return;
|
|
}
|
|
|
|
return apolloHandler(req, res);
|
|
};
|