Spaces:
Sleeping
Sleeping
Update app.js
Browse files
app.js
CHANGED
@@ -3,10 +3,8 @@ const { Client } = require('pg');
|
|
3 |
const app = express();
|
4 |
const port = 7860;
|
5 |
|
6 |
-
// Middleware to parse JSON bodies
|
7 |
app.use(express.json());
|
8 |
|
9 |
-
// Database connection configuration
|
10 |
const client = new Client({
|
11 |
host: 'db',
|
12 |
user: 'user',
|
@@ -15,10 +13,19 @@ const client = new Client({
|
|
15 |
port: 5432,
|
16 |
});
|
17 |
|
18 |
-
|
19 |
-
client.connect(
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
20 |
|
21 |
-
// Route to handle cases
|
22 |
app.post('/case', (req, res) => {
|
23 |
const { caseId, description } = req.body;
|
24 |
client.query('INSERT INTO cases (caseId, description) VALUES ($1, $2)', [caseId, description], (err, result) => {
|
@@ -41,7 +48,6 @@ app.get('/case/:caseId', (req, res) => {
|
|
41 |
});
|
42 |
});
|
43 |
|
44 |
-
// Route to handle questionnaires
|
45 |
app.post('/questionnaire', (req, res) => {
|
46 |
const { questionnaireId, responses } = req.body;
|
47 |
client.query('INSERT INTO questionnaires (questionnaireId, responses) VALUES ($1, $2)', [questionnaireId, responses], (err, result) => {
|
@@ -64,7 +70,6 @@ app.get('/questionnaire/:questionnaireId', (req, res) => {
|
|
64 |
});
|
65 |
});
|
66 |
|
67 |
-
// Route to handle jury details
|
68 |
app.post('/jury', (req, res) => {
|
69 |
const { juryId, details } = req.body;
|
70 |
client.query('INSERT INTO jury (juryId, details) VALUES ($1, $2)', [juryId, details], (err, result) => {
|
@@ -87,7 +92,6 @@ app.get('/jury/:juryId', (req, res) => {
|
|
87 |
});
|
88 |
});
|
89 |
|
90 |
-
// Start the server
|
91 |
app.listen(port, () => {
|
92 |
console.log(`App running on port ${port}`);
|
93 |
});
|
|
|
3 |
const app = express();
|
4 |
const port = 7860;
|
5 |
|
|
|
6 |
app.use(express.json());
|
7 |
|
|
|
8 |
const client = new Client({
|
9 |
host: 'db',
|
10 |
user: 'user',
|
|
|
13 |
port: 5432,
|
14 |
});
|
15 |
|
16 |
+
const connectWithRetry = () => {
|
17 |
+
client.connect(err => {
|
18 |
+
if (err) {
|
19 |
+
console.error('Failed to connect to database:', err);
|
20 |
+
setTimeout(connectWithRetry, 5000); // wait 5 seconds then retry connection
|
21 |
+
} else {
|
22 |
+
console.log('Connected to database');
|
23 |
+
}
|
24 |
+
});
|
25 |
+
};
|
26 |
+
|
27 |
+
connectWithRetry();
|
28 |
|
|
|
29 |
app.post('/case', (req, res) => {
|
30 |
const { caseId, description } = req.body;
|
31 |
client.query('INSERT INTO cases (caseId, description) VALUES ($1, $2)', [caseId, description], (err, result) => {
|
|
|
48 |
});
|
49 |
});
|
50 |
|
|
|
51 |
app.post('/questionnaire', (req, res) => {
|
52 |
const { questionnaireId, responses } = req.body;
|
53 |
client.query('INSERT INTO questionnaires (questionnaireId, responses) VALUES ($1, $2)', [questionnaireId, responses], (err, result) => {
|
|
|
70 |
});
|
71 |
});
|
72 |
|
|
|
73 |
app.post('/jury', (req, res) => {
|
74 |
const { juryId, details } = req.body;
|
75 |
client.query('INSERT INTO jury (juryId, details) VALUES ($1, $2)', [juryId, details], (err, result) => {
|
|
|
92 |
});
|
93 |
});
|
94 |
|
|
|
95 |
app.listen(port, () => {
|
96 |
console.log(`App running on port ${port}`);
|
97 |
});
|