mirror of https://github.com/dapr/quickstarts.git
49 lines
1.3 KiB
JavaScript
49 lines
1.3 KiB
JavaScript
// ------------------------------------------------------------
|
|
// Copyright (c) Microsoft Corporation.
|
|
// Licensed under the MIT License.
|
|
// ------------------------------------------------------------
|
|
|
|
const express = require('express');
|
|
const bodyParser = require('body-parser');
|
|
require('isomorphic-fetch');
|
|
|
|
const app = express();
|
|
app.use(bodyParser.json());
|
|
|
|
const daprPort = process.env.DAPR_HTTP_PORT || 3500;
|
|
const daprUrl = `http://localhost:${daprPort}/v1.0`;
|
|
const port = 3000;
|
|
|
|
app.get('/order', (_req, res) => {
|
|
fetch(`${daprUrl}/state/order`)
|
|
.then((response) => {
|
|
return response.json();
|
|
}).then((order) => {
|
|
res.send(order);
|
|
});
|
|
});
|
|
|
|
app.post('/neworder', (req, res) => {
|
|
const data = req.body.data;
|
|
const orderId = data.orderId;
|
|
console.log("Got a new order! Order ID: " + orderId);
|
|
|
|
const state = [{
|
|
key: "order",
|
|
value: data
|
|
}];
|
|
|
|
fetch(`${daprUrl}/state`, {
|
|
method: "POST",
|
|
body: JSON.stringify(state),
|
|
headers: {
|
|
"Content-Type": "application/json"
|
|
}
|
|
}).then((response) => {
|
|
console.log((response.ok) ? "Successfully persisted state" : "Failed to persist state");
|
|
});
|
|
|
|
res.status(200).send();
|
|
});
|
|
|
|
app.listen(port, () => console.log(`Node App listening on port ${port}!`)); |