Skip to content

Commit

Permalink
feat: Add utils for testing communication between pods
Browse files Browse the repository at this point in the history
  • Loading branch information
amanvr committed Oct 22, 2023
1 parent 321141e commit 857f3b7
Show file tree
Hide file tree
Showing 5 changed files with 771 additions and 2 deletions.
1 change: 1 addition & 0 deletions assets/docker/Dockerfile.node.tmpl
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,5 @@ FROM gcr.io/distroless/nodejs20-debian11
COPY --from=build-env /app /app
WORKDIR /app
USER nonroot

CMD ["index.js"]
50 changes: 49 additions & 1 deletion example/index.js
Original file line number Diff line number Diff line change
@@ -1 +1,49 @@
console.log("KKA-CLI from NearForm")
const express = require('express');
const bodyParser = require('body-parser');
const axios = require('axios');

const app = express();

app.use(bodyParser.json());

app.get('/', (req, res) => {
res.status(200).send({"message": "Welcome to Initium CLI"});
});

app.post('/', async(req, res) => {
const { mode, to_host, number } = req.body;

console.log('mode: %s - to_host: %s - number: %s', mode, to_host, number);

if (mode === 'sender') {
const generatedNumber = Math.floor(Math.random() * 1000);
console.log('Generated number is %s', generatedNumber);

try {
const resp = await axios.post(to_host, {
"mode": 'receiver',
"to_host": req.headers.host,
"number": generatedNumber
});

res.send(resp.data);
} catch (error) {
console.log(error)
res.status(500).send({error: 'Failed to send data'});
}
} else if (mode === 'receiver') {
const generatedNumber = Math.floor(Math.random() * 1000);
console.log('Generated number is %s', generatedNumber);

const sum = generatedNumber + number;

res.send({"sum": sum})
} else {
res.status(200).send({"message": "Welcome to Initium"});
}
})

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

0 comments on commit 857f3b7

Please sign in to comment.