104 lines
2.7 KiB
JavaScript
104 lines
2.7 KiB
JavaScript
/* eslint-disable */
|
|
const express = require('express');
|
|
const cors = require('cors');
|
|
const { MemBlockHeightSwCache } = require('../lib/cjs/cache/impl/MemBlockHeightCache');
|
|
const app = express();
|
|
const port = 3000;
|
|
|
|
app.use(cors());
|
|
app.use(express.json({ limit: "50mb", extended: true }));
|
|
|
|
|
|
const caches = {
|
|
STATE: new MemBlockHeightSwCache(1),
|
|
INTERACTIONS: new MemBlockHeightSwCache(1)
|
|
};
|
|
|
|
// getLast
|
|
app.get('/last/:type/:key', async function (req, res, next) {
|
|
console.log('last:', {
|
|
url: req.url,
|
|
params: req.params
|
|
});
|
|
const { type, key } = req.params;
|
|
|
|
const result = await caches[type].getLast(key);
|
|
|
|
res.send(result);
|
|
});
|
|
|
|
// getLessOrEqual
|
|
app.get('/less-or-equal/:type/:key/:blockHeight', async function (req, res, next) {
|
|
console.log('less-or-equal:', {
|
|
url: req.url,
|
|
params: req.params
|
|
});
|
|
|
|
const { type, key } = req.params;
|
|
const blockHeight = parseInt(req.params.blockHeight);
|
|
|
|
const result = await caches[type].getLessOrEqual(key, blockHeight);
|
|
console.log(result);
|
|
|
|
res.send(result);
|
|
});
|
|
|
|
// contains
|
|
app.get('/contains/:type/:key', async function (req, res, next) {
|
|
console.log('contains:', {
|
|
url: req.url,
|
|
params: req.params
|
|
});
|
|
|
|
const { type, key } = req.params;
|
|
|
|
res.send(await caches[type].contains(key));
|
|
});
|
|
|
|
// get
|
|
app.get('/:type/:key/:blockHeight', async function (req, res, next) {
|
|
console.log('get:', {
|
|
url: req.url,
|
|
params: req.params
|
|
});
|
|
|
|
const { type, key } = req.params;
|
|
const blockHeight = parseInt(req.params.blockHeight);
|
|
|
|
const result = await caches[type].get(key, blockHeight);
|
|
console.log('get', result);
|
|
|
|
res.send(result);
|
|
});
|
|
|
|
// put
|
|
app.put('/:type/:key/:blockHeight', async function (req, res, next) {
|
|
console.log('put:', {
|
|
url: req.url,
|
|
params: req.params,
|
|
body: req.body
|
|
});
|
|
|
|
const { type, key } = req.params;
|
|
const blockHeight = parseInt(req.params.blockHeight);
|
|
|
|
await caches[type].put({ cacheKey: key, blockHeight }, req.body);
|
|
|
|
res.send(null);
|
|
});
|
|
|
|
app.listen(port, async () => {
|
|
console.log(`Cache listening at http://localhost:${port}`);
|
|
|
|
// note: with current cache configuration (new MemBlockHeightSwCache(1))
|
|
// there should be at most one block height cached for given cache key.
|
|
await caches['STATE'].put({ cacheKey: 'txId', blockHeight: 555 }, { foo: "bar555" });
|
|
await caches['STATE'].put({ cacheKey: 'txId', blockHeight: 556 }, { foo: "bar556" });
|
|
await caches['STATE'].put({ cacheKey: 'txId', blockHeight: 557 }, { foo: "bar557" });
|
|
|
|
await caches['INTERACTIONS'].put({ cacheKey: 'txId', blockHeight: 557 }, [{ foo: "bar557" }]);
|
|
await caches['INTERACTIONS'].put({ cacheKey: 'txId', blockHeight: 600 }, [{ bar: "foo600" }]);
|
|
|
|
console.log('Caches filled');
|
|
});
|