mirror of https://github.com/dapr/quickstarts.git
80 lines
2.4 KiB
JavaScript
80 lines
2.4 KiB
JavaScript
//
|
|
// Copyright 2021 The Dapr Authors
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
//
|
|
|
|
const express = require('express');
|
|
const bodyParser = require('body-parser');
|
|
require('isomorphic-fetch');
|
|
|
|
const app = express();
|
|
app.use(bodyParser.json());
|
|
|
|
// These ports are injected automatically into the container.
|
|
const daprPort = process.env.DAPR_HTTP_PORT;
|
|
const daprGRPCPort = process.env.DAPR_GRPC_PORT;
|
|
|
|
const stateStoreName = `statestore`;
|
|
const stateUrl = `http://localhost:${daprPort}/v1.0/state/${stateStoreName}`;
|
|
const port = 3000;
|
|
|
|
app.get('/order', (_req, res) => {
|
|
fetch(`${stateUrl}/order`)
|
|
.then((response) => {
|
|
if (!response.ok) {
|
|
throw "Could not get state.";
|
|
}
|
|
|
|
return response.text();
|
|
}).then((orders) => {
|
|
res.send(orders);
|
|
}).catch((error) => {
|
|
console.log(error);
|
|
res.status(500).send({message: error});
|
|
});
|
|
});
|
|
|
|
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(stateUrl, {
|
|
method: "POST",
|
|
body: JSON.stringify(state),
|
|
headers: {
|
|
"Content-Type": "application/json"
|
|
}
|
|
}).then((response) => {
|
|
if (!response.ok) {
|
|
throw "Failed to persist state.";
|
|
}
|
|
|
|
console.log("Successfully persisted state.");
|
|
res.status(200).send();
|
|
}).catch((error) => {
|
|
console.log(error);
|
|
res.status(500).send({message: error});
|
|
});
|
|
});
|
|
|
|
app.get('/ports', (_req, res) => {
|
|
console.log("DAPR_HTTP_PORT: " + daprPort);
|
|
console.log("DAPR_GRPC_PORT: " + daprGRPCPort);
|
|
res.status(200).send({DAPR_HTTP_PORT: daprPort, DAPR_GRPC_PORT: daprGRPCPort })
|
|
});
|
|
|
|
app.listen(port, () => console.log(`Node App listening on port ${port}!`)); |