v3.3.7, upgrade deprecated fastify plugins

update packages for v3.3.7
make the indexer behavior clearer when using rewrite: true
2022-11-09 13:01:22 -03:00 · 2022-11-09 12:55:59 -03:00 · 2022-11-09 12:48:14 -03:00 · 2022-11-09 12:00:12 -03:00 · 2022-11-09 11:54:27 -03:00 · 2022-11-03 17:22:04 -03:00
22 changed files with 1074 additions and 870 deletions
@@ -2,6 +2,214 @@ import {createHash} from "crypto";
 import * as _ from "lodash";
 import {FastifyInstance, FastifyReply, FastifyRequest, FastifySchema, HTTPMethods} from "fastify";
 import got from "got";
+import {checkFilter, hLog} from "../../helpers/common_functions";
+
+const deltaQueryFields = ['code', 'table', 'scope', 'payer'];
+
+export async function streamPastDeltas(fastify: FastifyInstance, socket, data) {
+    const search_body = {
+        query: {bool: {must: []}},
+        sort: {block_num: 'asc'},
+    };
+    await addBlockRangeOpts(data, search_body, fastify);
+    deltaQueryFields.forEach(f => {
+        addTermMatch(data, search_body, f);
+    });
+    const responseQueue = [];
+    let counter = 0;
+    const init_response = await fastify.elastic.search({
+        index: fastify.manager.chain + '-delta-*',
+        scroll: '30s',
+        size: 20,
+        body: search_body,
+    });
+    responseQueue.push(init_response);
+    while (responseQueue.length) {
+        const {body} = responseQueue.shift();
+        counter += body['hits']['hits'].length;
+        if (socket.connected) {
+            socket.emit('message', {
+                type: 'delta_trace',
+                mode: 'history',
+                messages: body['hits']['hits'].map(doc => doc._source),
+            });
+        } else {
+            hLog('LOST CLIENT');
+            break;
+        }
+        if (body['hits'].total.value === counter) {
+            hLog(`${counter} past deltas streamed to ${socket.id}`);
+            break;
+        }
+
+        const next_response = await fastify.elastic.scroll({
+            body: {
+                scroll_id: body['_scroll_id'],
+                scroll: '30s'
+            }
+        });
+        responseQueue.push(next_response);
+    }
+}
+
+export async function streamPastActions(fastify: FastifyInstance, socket, data) {
+    const search_body = {
+        query: {bool: {must: []}},
+        sort: {global_sequence: 'asc'},
+    };
+
+    await addBlockRangeOpts(data, search_body, fastify);
+
+    if (data.account !== '') {
+        search_body.query.bool.must.push({
+            bool: {
+                should: [
+                    {term: {'notified': data.account}},
+                    {term: {'act.authorization.actor': data.account}},
+                ],
+            },
+        });
+    }
+
+    if (data.contract !== '*' && data.contract !== '') {
+        search_body.query.bool.must.push({'term': {'act.account': data.contract}});
+    }
+
+    if (data.action !== '*' && data.action !== '') {
+        search_body.query.bool.must.push({'term': {'act.name': data.action}});
+    }
+
+    const onDemandFilters = [];
+    if (data.filters.length > 0) {
+        data.filters.forEach(f => {
+            if (f.field && f.value) {
+                if (f.field.startsWith('@') && !f.field.startsWith('act.data')) {
+                    const _q = {};
+                    _q[f.field] = f.value;
+                    search_body.query.bool.must.push({'term': _q});
+                } else {
+                    onDemandFilters.push(f);
+                }
+            }
+        });
+    }
+
+    const responseQueue = [];
+    let counter = 0;
+
+    const init_response = await fastify.elastic.search({
+        index: fastify.manager.chain + '-action-*',
+        scroll: '30s',
+        size: 20,
+        body: search_body,
+    });
+    responseQueue.push(init_response);
+    while (responseQueue.length) {
+        const {body} = responseQueue.shift();
+        const enqueuedMessages = [];
+        counter += body['hits']['hits'].length;
+        for (const doc of body['hits']['hits']) {
+            let allow = false;
+            if (onDemandFilters.length > 0) {
+                allow = onDemandFilters.every(filter => {
+                    return checkFilter(filter, doc._source);
+                });
+            } else {
+                allow = true;
+            }
+            if (allow) {
+                enqueuedMessages.push(doc._source);
+            }
+        }
+        if (socket.connected) {
+            socket.emit('message', {type: 'action_trace', mode: 'history', messages: enqueuedMessages});
+        } else {
+            hLog('LOST CLIENT');
+            break;
+        }
+        if (body['hits'].total.value === counter) {
+            hLog(`${counter} past actions streamed to ${socket.id}`);
+            break;
+        }
+        if (init_response.body.hits.total.value < 1000) {
+            const next_response = await fastify.elastic.scroll({
+                body: {scroll_id: body['_scroll_id'], scroll: '30s'}
+            });
+            responseQueue.push(next_response);
+        } else {
+            hLog('Request too large!');
+            socket.emit('message', {type: 'action_trace', mode: 'history', messages: []});
+        }
+    }
+}
+
+export function addTermMatch(data, search_body, field) {
+    if (data[field] !== '*' && data[field] !== '') {
+        const termQuery = {};
+        termQuery[field] = data[field];
+        search_body.query.bool.must.push({'term': termQuery});
+    }
+}
+
+export async function addBlockRangeOpts(data, search_body, fastify: FastifyInstance) {
+
+    let timeRange;
+    let blockRange;
+    let head;
+
+    if (typeof data['start_from'] === 'string' && data['start_from'] !== '') {
+        if (!timeRange) {
+            timeRange = {"@timestamp": {}};
+        }
+        timeRange["@timestamp"]['gte'] = data['start_from'];
+    }
+
+    if (typeof data['read_until'] === 'string' && data['read_until'] !== '') {
+        if (!timeRange) {
+            timeRange = {"@timestamp": {}};
+        }
+        timeRange["@timestamp"]['lte'] = data['read_until'];
+    }
+
+    if (typeof data['start_from'] === 'number' && data['start_from'] !== 0) {
+        if (!blockRange) {
+            blockRange = {"block_num": {}};
+        }
+        if (data['start_from'] < 0) {
+            if (!head) {
+                head = (await fastify.eosjs.rpc.get_info()).head_block_num;
+            }
+            blockRange["block_num"]['gte'] = head + data['start_from'];
+        } else {
+            blockRange["block_num"]['gte'] = data['start_from'];
+        }
+    }
+
+    if (typeof data['read_until'] === 'number' && data['read_until'] !== 0) {
+        if (!blockRange) {
+            blockRange = {"block_num": {}};
+        }
+        if (data['read_until'] < 0) {
+            if (!head) {
+                head = (await fastify.eosjs.rpc.get_info()).head_block_num;
+            }
+            blockRange["block_num"]['lte'] = head + data['read_until'];
+        } else {
+            blockRange["block_num"]['lte'] = data['read_until'];
+        }
+    }
+
+    if (timeRange) {
+        search_body.query.bool.must.push({
+            range: timeRange,
+        });
+    }
+    if (blockRange) {
+        search_body.query.bool.must.push({
+            range: blockRange,
+        });
+    }
+}

 export function extendResponseSchema(responseProps: any) {
    const props = {
@@ -4,10 +4,10 @@ import {IncomingMessage, Server, ServerResponse} from "http";
 // fastify plugins
 import * as fastifyElasticsearch from 'fastify-elasticsearch';
 import fastifySwagger from '@fastify/swagger';
-import fastifyCors from 'fastify-cors';
-import formBodyPlugin from 'fastify-formbody';
-import fastifyRedis from 'fastify-redis';
-import fastifyRateLimit from 'fastify-rate-limit';
+import fastifyCors from '@fastify/cors';
+import formBodyPlugin from '@fastify/formbody';
+import fastifyRedis from '@fastify/redis';
+import fastifyRateLimit from '@fastify/rate-limit';

 // custom plugins
 import fastify_eosjs from "./plugins/fastify-eosjs";
@@ -2,7 +2,7 @@ import {join} from "path";
 import {FastifyError, FastifyInstance, FastifyReply, FastifyRequest} from "fastify";
 import {createReadStream} from "fs";
 import {addSharedSchemas, handleChainApiRedirect} from "./helpers/functions";
-import autoLoad from 'fastify-autoload';
+import autoLoad from '@fastify/autoload';
 import got from "got";

 function addRedirect(server: FastifyInstance, url: string, redirectTo: string) {
@@ -37,7 +37,7 @@ export default function (fastify: FastifyInstance, opts: any, next) {
                "type": "string"
            }
        },
-        ["code", "table", "scope"]
+        ["code", "table"]
    );
    next();
 }
@@ -1,6 +1,148 @@
 import {FastifyInstance, FastifyReply, FastifyRequest} from "fastify";
 import {mergeActionMeta, timedQuery} from "../../../helpers/functions";
-import flatstr from 'flatstr';
+import {Serialize} from "eosjs";
+import {hLog} from "../../../../helpers/common_functions";
+import * as AbiEOS from "@eosrio/node-abieos";
+import {ApiResponse} from "@elastic/elasticsearch";
+import {TextDecoder, TextEncoder} from "util";
+import {JsonRpc} from "eosjs/dist";
+
+const abi_remapping = {
+    "_Bool": "bool"
+};
+
+const txEnc = new TextEncoder();
+const txDec = new TextDecoder();
+
+async function fetchAbiHexAtBlockElastic(client, chain, contract_name, last_block, get_json) {
+    try {
+        const _includes = ["actions", "tables", "block"];
+        if (get_json) {
+            _includes.push("abi");
+        } else {
+            _includes.push("abi_hex");
+        }
+        const query = {
+            bool: {
+                must: [
+                    {term: {account: contract_name}},
+                    {range: {block: {lte: last_block}}}
+                ]
+            }
+        };
+        const queryResult: ApiResponse = await client.search({
+            index: `${chain}-abi-*`,
+            body: {
+                size: 1, query,
+                sort: [{block: {order: "desc"}}],
+                _source: {includes: _includes}
+            }
+        });
+        const results = queryResult.body.hits.hits;
+        if (results.length > 0) {
+            const nextRefResponse: ApiResponse = await client.search({
+                index: `${chain}-abi-*`,
+                body: {
+                    size: 1,
+                    query: {
+                        bool: {
+                            must: [
+                                {term: {account: contract_name}},
+                                {range: {block: {gte: last_block}}}
+                            ]
+                        }
+                    },
+                    sort: [{block: {order: "asc"}}],
+                    _source: {includes: ["block"]}
+                }
+            });
+            const nextRef = nextRefResponse.body.hits.hits;
+            if (nextRef.length > 0) {
+                return {
+                    valid_until: nextRef[0]._source.block,
+                    ...results[0]._source
+                };
+            }
+            return results[0]._source;
+        } else {
+            return null;
+        }
+    } catch (e) {
+        hLog(e);
+        return null;
+    }
+}
+
+async function getAbiFromHeadBlock(rpc: JsonRpc, code) {
+    let _abi;
+    try {
+        _abi = (await rpc.get_abi(code)).abi;
+    } catch (e) {
+        hLog(e);
+    }
+    return {abi: _abi, valid_until: null, valid_from: null};
+}
+
+async function getContractAtBlock(esClient, rpc, chain, accountName: string, block_num: number, check_action?: string) {
+    let savedAbi, abi;
+    savedAbi = await fetchAbiHexAtBlockElastic(esClient, chain, accountName, block_num, true);
+    if (savedAbi === null || (savedAbi.actions && !savedAbi.actions.includes(check_action))) {
+        savedAbi = await getAbiFromHeadBlock(rpc, accountName);
+        if (!savedAbi) return [null, null];
+        abi = savedAbi.abi;
+    } else {
+        try {
+            abi = JSON.parse(savedAbi.abi);
+        } catch (e) {
+            hLog(e);
+            return [null, null];
+        }
+    }
+    if (!abi) return [null, null];
+    const initialTypes = Serialize.createInitialTypes();
+    let types;
+    try {
+        types = Serialize.getTypesFromAbi(initialTypes, abi);
+    } catch (e) {
+        let remapped = false;
+        for (const struct of abi.structs) {
+            for (const field of struct.fields) {
+                if (abi_remapping[field.type]) {
+                    field.type = abi_remapping[field.type];
+                    remapped = true;
+                }
+            }
+        }
+        if (remapped) {
+            try {
+                types = Serialize.getTypesFromAbi(initialTypes, abi);
+            } catch (e) {
+                hLog('failed after remapping abi');
+                hLog(accountName, block_num, check_action);
+                hLog(e);
+            }
+        } else {
+            hLog(accountName, block_num);
+            hLog(e);
+        }
+    }
+    const actions = new Map();
+    for (const {name, type} of abi.actions) {
+        actions.set(name, Serialize.getType(types, type));
+    }
+    const result = {types, actions, tables: abi.tables};
+    if (check_action) {
+        if (actions.has(check_action)) {
+            try {
+                AbiEOS['load_abi'](accountName, JSON.stringify(abi));
+            } catch (e) {
+                hLog(e);
+            }
+        }
+    }
+    return [result, abi];
+}
+

 const terms = ["notified", "act.authorization.actor"];
 const extendedActions = new Set(["transfer", "newaccount", "updateauth"]);
@@ -154,11 +296,13 @@ async function getActions(fastify: FastifyInstance, request: FastifyRequest) {
            }
            actions = actions.slice(index);
        }
-        actions.forEach((action, index) => {
+
+        for (let i = 0; i < actions.length; i++) {
+            let action = actions[i];
            action = action._source;
            let act: any = {
                "global_action_seq": action.global_sequence,
-                "account_action_seq": index,
+                "account_action_seq": i,
                "block_num": action.block_num,
                "block_time": action['@timestamp'],
                "action_trace": {
@@ -174,7 +318,31 @@ async function getActions(fastify: FastifyInstance, request: FastifyRequest) {
            };
            mergeActionMeta(action);
            act.action_trace.act = action.act;
-            act.action_trace.act.hex_data = Buffer.from(flatstr(JSON.stringify(action.act.data))).toString('hex');
+
+            if (reqBody.hex_data) {
+                try {
+                    const [contract, _] = await getContractAtBlock(
+                        fastify.elastic,
+                        fastify.eosjs.rpc,
+                        fastify.manager.chain,
+                        action.act.account,
+                        action.block_num
+                    );
+                    action.act.hex_data = Serialize.serializeActionData(
+                        contract,
+                        action.act.account,
+                        action.act.name,
+                        action.act.data,
+                        txEnc,
+                        txDec
+                    );
+                } catch (e: any) {
+                    console.log(e);
+                }
+            }
+
+            // TODO: Optionally re-encode using the original ABI, will increase query time
+            // act.action_trace.act.hex_data = Buffer.from(flatstr(JSON.stringify(action.act.data))).toString('hex');
            if (action.act.account_ram_deltas) {
                act.action_trace.account_ram_deltas = action.account_ram_deltas
            }
@@ -184,7 +352,7 @@ async function getActions(fastify: FastifyInstance, request: FastifyRequest) {
            act.action_trace.receiver = receipt.receiver;
            act.account_action_seq = receipt['recv_sequence'];
            response.actions.push(act);
-        });
+        }
    }
    return response;
 }
@@ -136,7 +136,9 @@ async function getTransaction(fastify: FastifyInstance, request: FastifyRequest)
 		for (let action of actions) {
 			action = action._source;
 			mergeActionMeta(action);
-			action.act['hex_data'] = Buffer.from(flatstr(JSON.stringify(action.act.data))).toString('hex');
+
+			// action.act['hex_data'] = Buffer.from(flatstr(JSON.stringify(action.act.data))).toString('hex');
+
 			if (action.parent === 0) {
 				response.trx.trx.actions.push(action.act);
 			}
@@ -1,118 +1,128 @@
 import {FastifyInstance, FastifyReply, FastifyRequest} from "fastify";
 import {getTrackTotalHits, mergeActionMeta, timedQuery} from "../../../helpers/functions";
 import {
-	addSortedBy,
-	applyAccountFilters,
-	applyCodeActionFilters,
-	applyGenericFilters,
-	applyTimeFilter,
-	getSkipLimit,
-	getSortDir
+    addSortedBy,
+    applyAccountFilters,
+    applyCodeActionFilters,
+    applyGenericFilters,
+    applyTimeFilter,
+    getSkipLimit,
+    getSortDir
 } from "./functions";

 async function getActions(fastify: FastifyInstance, request: FastifyRequest) {
-	const query: any = request.query;
-	const maxActions = fastify.manager.config.api.limits.get_actions;
-	const queryStruct = {
-		"bool": {
-			must: [],
-			must_not: [],
-			boost: 1.0
-		}
-	};
+    const query: any = request.query;
+    const maxActions = fastify.manager.config.api.limits.get_actions;
+    const queryStruct = {
+        "bool": {
+            must: [],
+            must_not: [],
+            boost: 1.0
+        }
+    };

-	const {skip, limit} = getSkipLimit(query, maxActions);
-	const sort_direction = getSortDir(query);
-	applyAccountFilters(query, queryStruct);
-	applyGenericFilters(query, queryStruct, fastify.allowedActionQueryParamSet);
-	applyTimeFilter(query, queryStruct);
-	applyCodeActionFilters(query, queryStruct);
-	// allow precise counting of total hits
-	const trackTotalHits = getTrackTotalHits(query);
+    const {skip, limit} = getSkipLimit(query, maxActions);
+    const sort_direction = getSortDir(query);
+    applyAccountFilters(query, queryStruct);
+    applyGenericFilters(query, queryStruct, fastify.allowedActionQueryParamSet);
+    applyTimeFilter(query, queryStruct);
+    applyCodeActionFilters(query, queryStruct);
+    // allow precise counting of total hits
+    const trackTotalHits = getTrackTotalHits(query);

-	// Prepare query body
-	const query_body = {
-		"track_total_hits": trackTotalHits,
-		"query": queryStruct
-	};
+    // Prepare query body
+    const query_body = {
+        "track_total_hits": trackTotalHits,
+        "query": queryStruct
+    };

-	// Include sorting
-	addSortedBy(query, query_body, sort_direction);
+    // Include sorting
+    addSortedBy(query, query_body, sort_direction);

-	// Perform search
+    // Perform search

-	let indexPattern = fastify.manager.chain + '-action-*';
-	if (query.hot_only) {
-		indexPattern = fastify.manager.chain + '-action';
-	}
+    let indexPattern = fastify.manager.chain + '-action-*';
+    if (query.hot_only) {
+        indexPattern = fastify.manager.chain + '-action';
+    }

-	const esResults = await fastify.elastic.search({
-		"index": indexPattern,
-		"from": skip || 0,
-		"size": (limit > maxActions ? maxActions : limit) || 10,
-		"body": query_body
-	});
+    const esResults = await fastify.elastic.search({
+        "index": indexPattern,
+        "from": skip || 0,
+        "size": (limit > maxActions ? maxActions : limit) || 10,
+        "body": query_body
+    });

-	const results = esResults['body']['hits'];
-	const response: any = {
-		cached: false,
-		lib: 0,
-		total: results['total']
-	};
+    const results = esResults['body']['hits'];
+    const response: any = {
+        cached: false,
+        lib: 0,
+        total: results['total']
+    };

-	if (query.hot_only) {
-		response.hot_only = true;
-	}
+    if (query.hot_only) {
+        response.hot_only = true;
+    }

-	if (query.checkLib) {
-		response.lib = (await fastify.eosjs.rpc.get_info()).last_irreversible_block_num;
-	}
+    if (query.checkLib) {
+        response.lib = (await fastify.eosjs.rpc.get_info()).last_irreversible_block_num;
+    }

-	if (query.simple) {
-		response['simple_actions'] = [];
-	} else {
-		response['actions'] = [];
-	}
+    if (query.simple) {
+        response['simple_actions'] = [];
+    } else {
+        response['actions'] = [];
+    }

-	if (results['hits'].length > 0) {
-		const actions = results['hits'];
-		for (let action of actions) {
-			action = action._source;
-			mergeActionMeta(action);
+    if (results['hits'].length > 0) {
+        const actions = results['hits'];
+        for (let action of actions.map(a => a._source)) {

-			if (query.noBinary === true) {
-				for (const key in action['act']['data']) {
-					if (action['act']['data'].hasOwnProperty(key)) {
-						if (typeof action['act']['data'][key] === 'string' && action['act']['data'][key].length > 256) {
-							action['act']['data'][key] = action['act']['data'][key].slice(0, 32) + "...";
-						}
-					}
-				}
-			}
+            try {
+                if (action.act.data) {
+                    if (action.act.data.account && action.act.data.name && action.act.data.authorization) {
+                        action.act.data = action.act.data.data;
+                    }
+                }
+            } catch (e: any) {
+                console.log(e);
+            }

-			if (query.simple) {
-				response.simple_actions.push({
-					block: action['block_num'],
-					irreversible: response.lib !== 0 ? action['block_num'] < response.lib : undefined,
-					timestamp: action['@timestamp'],
-					transaction_id: action['trx_id'],
-					actors: action['act']['authorization'].map(a => `${a.actor}@${a.permission}`).join(","),
-					notified: action['notified'].join(','),
-					contract: action['act']['account'],
-					action: action['act']['name'],
-					data: action['act']['data']
-				});
+            mergeActionMeta(action);

-			} else {
-				response.actions.push(action);
-			}
-		}
-	}
-	return response;
+            if (query.noBinary === true) {
+                for (const key in action['act']['data']) {
+                    if (action['act']['data'].hasOwnProperty(key)) {
+                        if (typeof action['act']['data'][key] === 'string' && action['act']['data'][key].length > 256) {
+                            action['act']['data'][key] = action['act']['data'][key].slice(0, 32) + "...";
+                        }
+                    }
+                }
+            }
+
+            if (query.simple) {
+                response.simple_actions.push({
+                    block: action['block_num'],
+                    irreversible: response.lib !== 0 ? action['block_num'] < response.lib : undefined,
+                    timestamp: action['@timestamp'],
+                    transaction_id: action['trx_id'],
+                    actors: action['act']['authorization'].map(a => `${a.actor}@${a.permission}`).join(","),
+                    notified: action['notified'].join(','),
+                    contract: action['act']['account'],
+                    action: action['act']['name'],
+                    data: action['act']['data']
+                });
+
+            } else {
+                response.actions.push(action);
+            }
+        }
+    }
+    return response;
 }

 export function getActionsHandler(fastify: FastifyInstance, route: string) {
-	return async (request: FastifyRequest, reply: FastifyReply) => {
-		reply.send(await timedQuery(getActions, fastify, request, route));
-	}
+    return async (request: FastifyRequest, reply: FastifyReply) => {
+        reply.send(await timedQuery(getActions, fastify, request, route));
+    }
 }
@@ -3,89 +3,97 @@ import {mergeDeltaMeta, timedQuery} from "../../../helpers/functions";
 import {applyTimeFilter} from "../get_actions/functions";

 async function getDeltas(fastify: FastifyInstance, request: FastifyRequest) {
-	let skip, limit;
-	let sort_direction = 'desc';
-	const mustArray = [];
-	const query: any = request.query;
-	for (const param in query) {
-		if (Object.prototype.hasOwnProperty.call(query, param)) {
-			const value = query[param];
-			switch (param) {
-				case 'limit': {
-					limit = parseInt(value, 10);
-					if (limit < 1) {
-						return 'invalid limit parameter';
-					}
-					break;
-				}
-				case 'skip': {
-					skip = parseInt(value, 10);
-					if (skip < 0) {
-						return 'invalid skip parameter';
-					}
-					break;
-				}
-				case 'sort': {
-					if (value === 'asc' || value === '1') {
-						sort_direction = 'asc';
-					} else if (value === 'desc' || value === '-1') {
-						sort_direction = 'desc'
-					} else {
-						return 'invalid sort direction';
-					}
-					break;
-				}
-				case 'before': {
-					break;
-				}
-				case 'after': {
-					break;
-				}
-				default: {
-					const values = query[param].split(",");
-					if (values.length > 1) {
-						const terms = {};
-						terms[param] = values;
-						mustArray.push({terms: terms});
-					} else {
-						const term = {};
-						term[param] = values[0];
-						mustArray.push({term: term});
-					}
-					break;
-				}
-			}
-		}
-	}
+    let skip, limit;
+    let sort_direction = 'desc';
+    const mustArray = [];
+    const query: any = request.query;
+    for (const param in query) {
+        if (Object.prototype.hasOwnProperty.call(query, param)) {
+            const value = query[param];
+            switch (param) {
+                case 'limit': {
+                    limit = parseInt(value, 10);
+                    if (limit < 1) {
+                        return 'invalid limit parameter';
+                    }
+                    break;
+                }
+                case 'skip': {
+                    skip = parseInt(value, 10);
+                    if (skip < 0) {
+                        return 'invalid skip parameter';
+                    }
+                    break;
+                }
+                case 'sort': {
+                    if (value === 'asc' || value === '1') {
+                        sort_direction = 'asc';
+                    } else if (value === 'desc' || value === '-1') {
+                        sort_direction = 'desc'
+                    } else {
+                        return 'invalid sort direction';
+                    }
+                    break;
+                }
+                case 'before': {
+                    break;
+                }
+                case 'after': {
+                    break;
+                }
+                default: {
+                    if (typeof value === 'string') {
+                        const values = query[param].split(",");
+                        if (values.length > 1) {
+                            const terms = {};
+                            terms[param] = values;
+                            mustArray.push({terms: terms});
+                        } else {
+                            const term = {};
+                            term[param] = values[0];
+                            mustArray.push({term: term});
+                        }
+                    } else {
+                        if (typeof value === 'number') {
+                            const term = {};
+                            term[param] = value;
+                            mustArray.push({term: term});
+                        }
+                    }
+                    break;
+                }
+            }
+        }
+    }

-	const maxDeltas = fastify.manager.config.api.limits.get_deltas ?? 1000;
-	const queryStruct = {bool: {must: mustArray}};
+    const maxDeltas = fastify.manager.config.api.limits.get_deltas ?? 1000;
+    const queryStruct = {bool: {must: mustArray}};

-	applyTimeFilter(query, queryStruct);
+    applyTimeFilter(query, queryStruct);

-	const results = await fastify.elastic.search({
-		"index": fastify.manager.chain + '-delta-*',
-		"from": skip || 0,
-		"size": (limit > maxDeltas ? maxDeltas : limit) || 10,
-		"body": {
-			query: queryStruct,
-			sort: {
-				"block_num": sort_direction
-			}
-		}
-	});
-	const deltas = results['body']['hits']['hits'].map((d) => {
-		return mergeDeltaMeta(d._source);
-	});
-	return {
-		query_time: null,
-		total: results['body']['hits']['total'],
-		deltas
-	};
+    const results = await fastify.elastic.search({
+        "index": fastify.manager.chain + '-delta-*',
+        "from": skip || 0,
+        "size": (limit > maxDeltas ? maxDeltas : limit) || 10,
+        "body": {
+            query: queryStruct,
+            sort: {
+                "block_num": sort_direction
+            }
+        }
+    });
+    const deltas = results['body']['hits']['hits'].map((d) => {
+        return mergeDeltaMeta(d._source);
+    });
+    return {
+        query_time: null,
+        total: results['body']['hits']['total'],
+        deltas
+    };
 }

 export function getDeltasHandler(fastify: FastifyInstance, route: string) {
-	return async (request: FastifyRequest, reply: FastifyReply) => {
-		reply.send(await timedQuery(getDeltas, fastify, request, route));
-	}
+    return async (request: FastifyRequest, reply: FastifyReply) => {
+        reply.send(await timedQuery(getDeltas, fastify, request, route));
+    }
 }
@@ -1,384 +1,201 @@
-import {checkFilter, hLog} from '../helpers/common_functions';
+import {hLog} from '../helpers/common_functions';
 import {Server, Socket} from 'socket.io';
 import {createAdapter} from 'socket.io-redis';
 import {io} from 'socket.io-client';
 import {FastifyInstance} from "fastify";
 import IORedis from "ioredis";
+import {App, TemplatedApp} from 'uWebSockets.js';
+import {streamPastActions, streamPastDeltas} from "./helpers/functions";

 export interface StreamDeltasRequest {
-	code: string;
-	table: string;
-	scope: string;
-	payer: string;
-	start_from: number | string;
-	read_until: number | string;
+    code: string;
+    table: string;
+    scope: string;
+    payer: string;
+    start_from: number | string;
+    read_until: number | string;
 }

 export interface RequestFilter {
-	field: string;
-	value: string;
+    field: string;
+    value: string;
 }

 export interface StreamActionsRequest {
-	contract: string;
-	account: string;
-	action: string;
-	filters: RequestFilter[];
-	start_from: number | string;
-	read_until: number | string;
+    contract: string;
+    account: string;
+    action: string;
+    filters: RequestFilter[];
+    start_from: number | string;
+    read_until: number | string;
 }

-async function addBlockRangeOpts(data, search_body, fastify: FastifyInstance) {
-
-	let timeRange;
-	let blockRange;
-	let head;
-
-	if (typeof data['start_from'] === 'string' && data['start_from'] !== '') {
-		if (!timeRange) {
-			timeRange = {"@timestamp": {}};
-		}
-		timeRange["@timestamp"]['gte'] = data['start_from'];
-	}
-
-	if (typeof data['read_until'] === 'string' && data['read_until'] !== '') {
-		if (!timeRange) {
-			timeRange = {"@timestamp": {}};
-		}
-		timeRange["@timestamp"]['lte'] = data['read_until'];
-	}
-
-	if (typeof data['start_from'] === 'number' && data['start_from'] !== 0) {
-		if (!blockRange) {
-			blockRange = {"block_num": {}};
-		}
-		if (data['start_from'] < 0) {
-			if (!head) {
-				head = (await fastify.eosjs.rpc.get_info()).head_block_num;
-			}
-			blockRange["block_num"]['gte'] = head + data['start_from'];
-		} else {
-			blockRange["block_num"]['gte'] = data['start_from'];
-		}
-	}
-
-	if (typeof data['read_until'] === 'number' && data['read_until'] !== 0) {
-		if (!blockRange) {
-			blockRange = {"block_num": {}};
-		}
-		if (data['read_until'] < 0) {
-			if (!head) {
-				head = (await fastify.eosjs.rpc.get_info()).head_block_num;
-			}
-			blockRange["block_num"]['lte'] = head + data['read_until'];
-		} else {
-			blockRange["block_num"]['lte'] = data['read_until'];
-		}
-	}
-
-	if (timeRange) {
-		search_body.query.bool.must.push({
-			range: timeRange,
-		});
-	}
-	if (blockRange) {
-		search_body.query.bool.must.push({
-			range: blockRange,
-		});
-	}
-}
-
-function addTermMatch(data, search_body, field) {
-	if (data[field] !== '*' && data[field] !== '') {
-		const termQuery = {};
-		termQuery[field] = data[field];
-		search_body.query.bool.must.push({'term': termQuery});
-	}
-}
-
-const deltaQueryFields = ['code', 'table', 'scope', 'payer'];
-
-async function streamPastDeltas(fastify: FastifyInstance, socket, data) {
-	const search_body = {
-		query: {bool: {must: []}},
-		sort: {block_num: 'asc'},
-	};
-	await addBlockRangeOpts(data, search_body, fastify);
-	deltaQueryFields.forEach(f => {
-		addTermMatch(data, search_body, f);
-	});
-	const responseQueue = [];
-	let counter = 0;
-	const init_response = await fastify.elastic.search({
-		index: fastify.manager.chain + '-delta-*',
-		scroll: '30s',
-		size: 20,
-		body: search_body,
-	});
-	responseQueue.push(init_response);
-	while (responseQueue.length) {
-		const {body} = responseQueue.shift();
-		counter += body['hits']['hits'].length;
-		if (socket.connected) {
-			socket.emit('message', {
-				type: 'delta_trace',
-				mode: 'history',
-				messages: body['hits']['hits'].map(doc => doc._source),
-			});
-		} else {
-			hLog('LOST CLIENT');
-			break;
-		}
-		if (body['hits'].total.value === counter) {
-			hLog(`${counter} past deltas streamed to ${socket.id}`);
-			break;
-		}
-
-		const next_response = await fastify.elastic.scroll({
-			body: {
-				scroll_id: body['_scroll_id'],
-				scroll: '30s'
-			}
-		});
-		responseQueue.push(next_response);
-	}
-}
-
-async function streamPastActions(fastify: FastifyInstance, socket, data) {
-	const search_body = {
-		query: {bool: {must: []}},
-		sort: {global_sequence: 'asc'},
-	};
-
-	await addBlockRangeOpts(data, search_body, fastify);
-
-	if (data.account !== '') {
-		search_body.query.bool.must.push({
-			bool: {
-				should: [
-					{term: {'notified': data.account}},
-					{term: {'act.authorization.actor': data.account}},
-				],
-			},
-		});
-	}
-
-	if (data.contract !== '*' && data.contract !== '') {
-		search_body.query.bool.must.push({'term': {'act.account': data.contract}});
-	}
-
-	if (data.action !== '*' && data.action !== '') {
-		search_body.query.bool.must.push({'term': {'act.name': data.action}});
-	}
-
-	const onDemandFilters = [];
-	if (data.filters.length > 0) {
-		data.filters.forEach(f => {
-			if (f.field && f.value) {
-				if (f.field.startsWith('@') && !f.field.startsWith('act.data')) {
-					const _q = {};
-					_q[f.field] = f.value;
-					search_body.query.bool.must.push({'term': _q});
-				} else {
-					onDemandFilters.push(f);
-				}
-			}
-		});
-	}
-
-	const responseQueue = [];
-	let counter = 0;
-
-	const init_response = await fastify.elastic.search({
-		index: fastify.manager.chain + '-action-*',
-		scroll: '30s',
-		size: 20,
-		body: search_body,
-	});
-	responseQueue.push(init_response);
-	while (responseQueue.length) {
-		const {body} = responseQueue.shift();
-		const enqueuedMessages = [];
-		counter += body['hits']['hits'].length;
-		for (const doc of body['hits']['hits']) {
-			let allow = false;
-			if (onDemandFilters.length > 0) {
-				allow = onDemandFilters.every(filter => {
-					return checkFilter(filter, doc._source);
-				});
-			} else {
-				allow = true;
-			}
-			if (allow) {
-				enqueuedMessages.push(doc._source);
-			}
-		}
-		if (socket.connected) {
-			socket.emit('message', {type: 'action_trace', mode: 'history', messages: enqueuedMessages});
-		} else {
-			hLog('LOST CLIENT');
-			break;
-		}
-		if (body['hits'].total.value === counter) {
-			hLog(`${counter} past actions streamed to ${socket.id}`);
-			break;
-		}
-		if (init_response.body.hits.total.value < 1000) {
-			const next_response = await fastify.elastic.scroll({
-				body: {scroll_id: body['_scroll_id'], scroll: '30s'}
-			});
-			responseQueue.push(next_response);
-		} else {
-			hLog('Request too large!');
-			socket.emit('message', {type: 'action_trace', mode: 'history', messages: []});
-		}
-	}
-}

 export class SocketManager {

-	private io: Server;
-	private relay;
-	relay_restored = true;
-	relay_down = false;
-	private readonly url;
-	private readonly server: FastifyInstance;
+    private io: Server;
+    private relay;
+    relay_restored = true;
+    relay_down = false;
+    private readonly url;
+    private readonly server: FastifyInstance;
+    private readonly uwsApp: TemplatedApp;

-	constructor(fastify: FastifyInstance, url, redisOptions) {
-		this.server = fastify;
-		this.url = url;
+    constructor(fastify: FastifyInstance, url, redisOptions) {
+        this.server = fastify;
+        this.url = url;
+        this.uwsApp = App({});

-		this.io = new Server(fastify.server, {
-			allowEIO3: true,
-			transports: ['websocket', 'polling'],
-		});
+        // this.io = new Server(fastify.server, {
+        // 	allowEIO3: true,
+        // 	transports: ['websocket', 'polling'],
+        // });

-		const pubClient = new IORedis(redisOptions);
-		const subClient = pubClient.duplicate();
-		this.io.adapter(createAdapter({pubClient, subClient}));
+        // WS Server for public access
+        this.io = new Server({
+            transports: ['websocket'],
+            path: '/stream'
+        });

-		this.io.on('connection', (socket: Socket) => {
+        this.io.attachApp(this.uwsApp);

-			if (socket.handshake.headers['x-forwarded-for']) {
-				hLog(`[socket] ${socket.id} connected via ${socket.handshake.headers['x-forwarded-for']}`);
-			}
+        const pubClient = new IORedis(redisOptions);
+        const subClient = pubClient.duplicate();
+        this.io.adapter(createAdapter({pubClient, subClient}));

-			socket.emit('message', {
-				event: 'handshake',
-				chain: fastify.manager.chain,
-			});
+        this.io.on('connection', (socket: Socket) => {

-			if (this.relay) {
-				this.relay.emit('event', {
-					type: 'client_count',
-					counter: this.io.sockets.sockets.size,
-				});
-			}
+            if (socket.handshake.headers['x-forwarded-for']) {
+                hLog(`[socket] ${socket.id} connected via ${socket.handshake.headers['x-forwarded-for']}`);
+            }

-			socket.on('delta_stream_request', async (data: StreamDeltasRequest, callback) => {
-				if (typeof callback === 'function' && data) {
-					try {
-						if (data.start_from) {
-							await streamPastDeltas(this.server, socket, data);
-						}
-						this.emitToRelay(data, 'delta_request', socket, callback);
-					} catch (e) {
-						console.log(e);
-					}
-				}
-			});
+            socket.emit('message', {
+                event: 'handshake',
+                chain: fastify.manager.chain,
+            });

-			socket.on('action_stream_request', async (data: StreamActionsRequest, callback) => {
-				if (typeof callback === 'function' && data) {
-					try {
-						if (data.start_from) {
-							await streamPastActions(this.server, socket, data);
-						}
-						this.emitToRelay(data, 'action_request', socket, callback);
-					} catch (e) {
-						console.log(e);
-					}
-				}
-			});
+            if (this.relay) {
+                this.relay.emit('event', {
+                    type: 'client_count',
+                    counter: this.io.sockets.sockets.size,
+                });
+            }

-			socket.on('disconnect', (reason) => {
-				hLog(`[socket] ${socket.id} disconnected - ${reason}`);
-				this.relay.emit('event', {
-					type: 'client_disconnected',
-					id: socket.id,
-					reason,
-				});
-			});
-		});
-		hLog('Websocket manager loaded!');
-	}
+            socket.on('delta_stream_request', async (data: StreamDeltasRequest, callback) => {
+                if (typeof callback === 'function' && data) {
+                    try {
+                        if (data.start_from) {
+                            await streamPastDeltas(this.server, socket, data);
+                        }
+                        this.emitToRelay(data, 'delta_request', socket, callback);
+                    } catch (e) {
+                        console.log(e);
+                    }
+                }
+            });

-	startRelay() {
-		hLog(`starting relay - ${this.url}`);
+            socket.on('action_stream_request', async (data: StreamActionsRequest, callback) => {
+                if (typeof callback === 'function' && data) {
+                    try {
+                        if (data.start_from) {
+                            await streamPastActions(this.server, socket, data);
+                        }
+                        this.emitToRelay(data, 'action_request', socket, callback);
+                    } catch (e) {
+                        console.log(e);
+                    }
+                }
+            });

-		this.relay = io(this.url, {path: '/router'});
+            socket.on('disconnect', (reason) => {
+                hLog(`[socket] ${socket.id} disconnected - ${reason}`);
+                this.relay.emit('event', {
+                    type: 'client_disconnected',
+                    id: socket.id,
+                    reason,
+                });
+            });
+        });

-		this.relay.on('connect', () => {
-			hLog('Relay Connected!');
-			if (this.relay_down) {
-				this.relay_restored = true;
-				this.relay_down = false;
-				this.io.emit('status', 'relay_restored');
-			}
-		});
+        try {
+            this.uwsApp.listen(1234, () => {
+                hLog('Socket.IO via uWS started!');
+            });
+        } catch (e) {
+            hLog(e.message);
+        }

-		this.relay.on('disconnect', () => {
-			hLog('Relay disconnected!');
-			this.io.emit('status', 'relay_down');
-			this.relay_down = true;
-			this.relay_restored = false;
-		});
+        hLog('Websocket manager loaded!');
+    }

-		this.relay.on('delta', (traceData) => {
-			this.emitToClient(traceData, 'delta_trace');
-		});
+    /*
+    WS Relay will connect to the indexer
+     */
+    startRelay() {
+        hLog(`starting relay - ${this.url}`);
+        this.relay = io(this.url, {path: '/router'});

-		this.relay.on('trace', (traceData) => {
-			this.emitToClient(traceData, 'action_trace');
-		});
+        this.relay.on('connect', () => {
+            hLog('Relay Connected!');
+            if (this.relay_down) {
+                this.relay_restored = true;
+                this.relay_down = false;
+                this.io.emit('status', 'relay_restored');
+            }
+        });

-		// Relay LIB info to clients;
-		this.relay.on('lib_update', (data) => {
-			if (this.server.manager.conn.chains[this.server.manager.chain].chain_id === data.chain_id) {
-				this.io.emit('lib_update', data);
-			}
-		});
+        this.relay.on('disconnect', () => {
+            hLog('Relay disconnected!');
+            this.io.emit('status', 'relay_down');
+            this.relay_down = true;
+            this.relay_restored = false;
+        });

-		// Relay LIB info to clients;
-		this.relay.on('fork_event', (data) => {
-			hLog(data);
-			if (this.server.manager.conn.chains[this.server.manager.chain].chain_id === data.chain_id) {
-				this.io.emit('fork_event', data);
-			}
-		});
-	}
+        this.relay.on('delta', (traceData) => {
+            this.emitToClient(traceData, 'delta_trace');
+        });

-	emitToClient(traceData, type) {
-		if (this.io.sockets.sockets.has(traceData.client)) {
-			this.io.sockets.sockets.get(traceData.client).emit('message', {
-				type: type,
-				mode: 'live',
-				message: traceData.message,
-			});
-		}
-	}
+        this.relay.on('trace', (traceData) => {
+            this.emitToClient(traceData, 'action_trace');
+        });

-	emitToRelay(data, type, socket, callback) {
-		if (this.relay.connected) {
-			this.relay.emit('event', {
-				type: type,
-				client_socket: socket.id,
-				request: data,
-			}, (response) => {
-				callback(response);
-			});
-		} else {
-			callback('STREAMING_OFFLINE');
-		}
-	}
+        // Relay LIB info to clients;
+        this.relay.on('lib_update', (data) => {
+            if (this.server.manager.conn.chains[this.server.manager.chain].chain_id === data.chain_id) {
+                this.io.emit('lib_update', data);
+            }
+        });
+
+        // Relay LIB info to clients;
+        this.relay.on('fork_event', (data) => {
+            hLog(data);
+            if (this.server.manager.conn.chains[this.server.manager.chain].chain_id === data.chain_id) {
+                this.io.emit('fork_event', data);
+            }
+        });
+    }
+
+    emitToClient(traceData, type) {
+        if (this.io.sockets.sockets.has(traceData.client)) {
+            this.io.sockets.sockets.get(traceData.client).emit('message', {
+                type: type,
+                mode: 'live',
+                message: traceData.message,
+            });
+        }
+    }
+
+    emitToRelay(data, type, socket, callback) {
+        if (this.relay.connected) {
+            this.relay.emit('event', {
+                type: type,
+                client_socket: socket.id,
+                request: data,
+            }, (response) => {
+                callback(response);
+            });
+        } else {
+            callback('STREAMING_OFFLINE');
+        }
+    }
 }
@@ -702,7 +702,8 @@ export class HyperionMaster {
            }
        } else {
            if (this.conf.indexer.rewrite) {
-                this.starting_block = 0;
+                hLog(`WARNING! "indexer.rewrite: true" If you want to reindex from a specific block, "indexer.start_on" must be greater than zero!`);
+                hLog(`The indexer will start from ${this.starting_block}`);
            }
            // Auto Mode
            if (this.conf.indexer.abi_scan_mode) {
@@ -184,6 +184,12 @@ export abstract class BaseParser {
        }

        if (ds_act) {
+
+            if (ds_act.account && ds_act.name && ds_act.authorization) {
+                console.log(ds_act);
+                action.act.data = ds_act.data;
+            }
+
            // save serialized data
            action.act.data = ds_act;
            try {
@@ -1,48 +1,49 @@
 {
  "name": "hyperion-history",
-  "version": "3.3.6",
+  "version": "3.3.7",
  "lockfileVersion": 2,
  "requires": true,
  "packages": {
    "": {
      "name": "hyperion-history",
-      "version": "3.3.6",
+      "version": "3.3.7",
      "hasInstallScript": true,
      "license": "MIT",
      "dependencies": {
        "@elastic/elasticsearch": "^7.17.0",
        "@eosrio/node-abieos": "^2.1.1",
+        "@fastify/autoload": "4.0.1",
+        "@fastify/cors": "7.0.0",
+        "@fastify/formbody": "^6.0.0",
+        "@fastify/rate-limit": "^6.0.0",
+        "@fastify/redis": "^5.0.0",
        "@fastify/swagger": "6.1.0",
        "@pm2/io": "^5.0.0",
-        "amqplib": "^0.8.0",
+        "amqplib": "^0.10.3",
        "async": "^3.2.4",
        "base-x": "^4.0.0",
        "commander": "^8.3.0",
        "cross-fetch": "^3.1.5",
        "eosjs": "^22.1.0",
        "fast-json-stringify": "^2.7.9",
-        "fastify": "^3.24.0",
-        "fastify-autoload": "^3.9.0",
-        "fastify-cors": "^6.0.2",
+        "fastify": "^3.29.3",
        "fastify-elasticsearch": "^2.0.0",
-        "fastify-formbody": "^5.2.0",
-        "fastify-plugin": "^3.0.0",
-        "fastify-rate-limit": "^5.6.2",
-        "fastify-redis": "^4.3.3",
+        "fastify-plugin": "^3.0.1",
        "flatstr": "^1.0.12",
        "global-agent": "^3.0.0",
        "got": "11.8.5",
-        "ioredis": "^4.28.1",
+        "ioredis": "^4.28.5",
        "lodash": "^4.17.21",
        "moment": "^2.29.4",
        "nodemailer": "^6.7.8",
        "portfinder": "^1.0.32",
-        "socket.io": "^4.5.2",
-        "socket.io-client": "^4.5.2",
+        "socket.io": "4.5.3",
+        "socket.io-client": "4.5.3",
        "socket.io-redis": "^6.1.1",
        "telegraf": "^4.9.1",
        "typescript": "^4.5.2",
-        "ws": "^8.8.1"
+        "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.15.0",
+        "ws": "^8.11.0"
      },
      "devDependencies": {
        "@types/amqplib": "^0.8.2",
@@ -50,18 +51,36 @@
        "@types/global-agent": "^2.1.1",
        "@types/ioredis": "^4.28.1",
        "@types/lodash": "^4.14.177",
-        "@types/node": "^16.11.10",
+        "@types/node": "^18.11.9",
        "@types/nodemailer": "^6.4.4",
-        "@types/ws": "^8.2.0"
+        "@types/ws": "^8.5.3"
      },
      "engines": {
-        "node": "^16"
+        "node": "^18"
      },
      "optionalDependencies": {
-        "bufferutil": "^4.0.5",
+        "bufferutil": "^4.0.7",
        "utf-8-validate": "^5.0.7"
      }
    },
+    "node_modules/@acuminous/bitsyntax": {
+      "version": "0.1.2",
+      "resolved": "https://registry.npmjs.org/@acuminous/bitsyntax/-/bitsyntax-0.1.2.tgz",
+      "integrity": "sha512-29lUK80d1muEQqiUsSo+3A0yP6CdspgC95EnKBMi22Xlwt79i/En4Vr67+cXhU+cZjbti3TgGGC5wy1stIywVQ==",
+      "dependencies": {
+        "buffer-more-ints": "~1.0.0",
+        "debug": "^4.3.4",
+        "safe-buffer": "~5.1.2"
+      },
+      "engines": {
+        "node": ">=0.8"
+      }
+    },
+    "node_modules/@acuminous/bitsyntax/node_modules/safe-buffer": {
+      "version": "5.1.2",
+      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
+      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
+    },
    "node_modules/@elastic/elasticsearch": {
      "version": "7.17.0",
      "resolved": "https://registry.npmjs.org/@elastic/elasticsearch/-/elasticsearch-7.17.0.tgz",
@@ -90,6 +109,70 @@
        "ajv": "^6.12.6"
      }
    },
+    "node_modules/@fastify/autoload": {
+      "version": "4.0.1",
+      "resolved": "https://registry.npmjs.org/@fastify/autoload/-/autoload-4.0.1.tgz",
+      "integrity": "sha512-eiKxDuz83gFID9LN2BVma0sj3gqDqP8sCHbNN4JmLGe2YNzrSQ+11axweIV8eu1tfWu6v8rgTqu/nu59QXhlsw==",
+      "dependencies": {
+        "pkg-up": "^3.1.0",
+        "semver": "^7.3.5"
+      }
+    },
+    "node_modules/@fastify/autoload/node_modules/semver": {
+      "version": "7.3.8",
+      "resolved": "https://registry.npmjs.org/semver/-/semver-7.3.8.tgz",
+      "integrity": "sha512-NB1ctGL5rlHrPJtFDVIVzTyQylMLu9N9VICA6HSFJo8MCGVTMW6gfpicwKmmK/dAjTOrqu5l63JJOpDSrAis3A==",
+      "dependencies": {
+        "lru-cache": "^6.0.0"
+      },
+      "bin": {
+        "semver": "bin/semver.js"
+      },
+      "engines": {
+        "node": ">=10"
+      }
+    },
+    "node_modules/@fastify/cors": {
+      "version": "7.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/cors/-/cors-7.0.0.tgz",
+      "integrity": "sha512-nlo6ScwagBNJacAZD3KX90xjWLIoV0vN9QqoX1wUE9ZeZMdvkVkMZCGlxEtr00NshV0X5wDge4w5rwox7rRzSg==",
+      "dependencies": {
+        "fastify-plugin": "^3.0.0",
+        "vary": "^1.1.2"
+      }
+    },
+    "node_modules/@fastify/error": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/error/-/error-2.0.0.tgz",
+      "integrity": "sha512-wI3fpfDT0t7p8E6dA2eTECzzOd+bZsZCJ2Hcv+Onn2b7ZwK3RwD27uW2QDaMtQhAfWQQP+WNK7nKf0twLsBf9w=="
+    },
+    "node_modules/@fastify/formbody": {
+      "version": "6.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/formbody/-/formbody-6.0.0.tgz",
+      "integrity": "sha512-YzPTXJbB3CzDMqU5K9YGSBt/nc/RDFZSxSWZ4SoqA3T2VRJzCPd7sZFpggdmlBRWhEBlvl0EWW7EX33kfbbFlg==",
+      "dependencies": {
+        "fastify-plugin": "^3.0.0"
+      }
+    },
+    "node_modules/@fastify/rate-limit": {
+      "version": "6.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/rate-limit/-/rate-limit-6.0.0.tgz",
+      "integrity": "sha512-EZ0TI7Mpo5aK/QaooSt3U0cAGSFjrN51vwj6osgBF1KrnLVSmRA7KPYhPimMoL9YFu9GH53aiNU0H1qTLh7s1Q==",
+      "dependencies": {
+        "fastify-plugin": "^3.0.1",
+        "ms": "^2.1.3",
+        "tiny-lru": "^8.0.1"
+      }
+    },
+    "node_modules/@fastify/redis": {
+      "version": "5.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/redis/-/redis-5.0.0.tgz",
+      "integrity": "sha512-uAFbtQ85VZmeG9crm4Qew1QjbrLwzEwgDQCPzsEWIEgkI73OUtCGoDqvbx/LmPvAlace7ZfLBGTcljIwqB7Uyw==",
+      "dependencies": {
+        "fastify-plugin": "^3.0.0",
+        "ioredis": "^4.27.9"
+      }
+    },
    "node_modules/@fastify/static": {
      "version": "5.0.2",
      "resolved": "https://registry.npmjs.org/@fastify/static/-/static-5.0.2.tgz",
@@ -343,9 +426,9 @@
      "dev": true
    },
    "node_modules/@types/node": {
-      "version": "16.11.10",
-      "resolved": "https://registry.npmjs.org/@types/node/-/node-16.11.10.tgz",
-      "integrity": "sha512-3aRnHa1KlOEEhJ6+CvyHKK5vE9BcLGjtUpwvqYLRvYNQKMfabu3BwfJaA/SLW8dxe28LsNDjtHwePTuzn3gmOA=="
+      "version": "18.11.9",
+      "resolved": "https://registry.npmjs.org/@types/node/-/node-18.11.9.tgz",
+      "integrity": "sha512-CRpX21/kGdzjOpFsZSkcrXMGIBWMGNIHXXBVFSH+ggkftxg+XYP20TESbh+zFvFj3EQOl5byk0HTRn1IL6hbqg=="
    },
    "node_modules/@types/nodemailer": {
      "version": "6.4.4",
@@ -365,9 +448,9 @@
      }
    },
    "node_modules/@types/ws": {
-      "version": "8.2.0",
-      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.2.0.tgz",
-      "integrity": "sha512-cyeefcUCgJlEk+hk2h3N+MqKKsPViQgF5boi9TTHSK+PoR9KWBb/C5ccPcDyAqgsbAYHTwulch725DV84+pSpg==",
+      "version": "8.5.3",
+      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.5.3.tgz",
+      "integrity": "sha512-6YOoWjruKj1uLf3INHH7D3qTXwFfEsg1kf3c0uDdSBJwfa/llkwIjrAGV7j7mVgGNbzTQ3HiHKKDXl6bJPD97w==",
      "dev": true,
      "dependencies": {
        "@types/node": "*"
@@ -417,16 +500,14 @@
      }
    },
    "node_modules/amqplib": {
-      "version": "0.8.0",
-      "resolved": "https://registry.npmjs.org/amqplib/-/amqplib-0.8.0.tgz",
-      "integrity": "sha512-icU+a4kkq4Y1PS4NNi+YPDMwdlbFcZ1EZTQT2nigW3fvOb6AOgUQ9+Mk4ue0Zu5cBg/XpDzB40oH10ysrk2dmA==",
+      "version": "0.10.3",
+      "resolved": "https://registry.npmjs.org/amqplib/-/amqplib-0.10.3.tgz",
+      "integrity": "sha512-UHmuSa7n8vVW/a5HGh2nFPqAEr8+cD4dEZ6u9GjP91nHfr1a54RyAKyra7Sb5NH7NBKOUlyQSMXIp0qAixKexw==",
      "dependencies": {
-        "bitsyntax": "~0.1.0",
-        "bluebird": "^3.7.2",
+        "@acuminous/bitsyntax": "^0.1.2",
        "buffer-more-ints": "~1.0.0",
        "readable-stream": "1.x >=1.1.9",
-        "safe-buffer": "~5.2.1",
-        "url-parse": "~1.5.1"
+        "url-parse": "~1.5.10"
      },
      "engines": {
        "node": ">=10"
@@ -504,42 +585,6 @@
        "node": "^4.5.0 || >= 5.9"
      }
    },
-    "node_modules/bitsyntax": {
-      "version": "0.1.0",
-      "resolved": "https://registry.npmjs.org/bitsyntax/-/bitsyntax-0.1.0.tgz",
-      "integrity": "sha512-ikAdCnrloKmFOugAfxWws89/fPc+nw0OOG1IzIE72uSOg/A3cYptKCjSUhDTuj7fhsJtzkzlv7l3b8PzRHLN0Q==",
-      "dependencies": {
-        "buffer-more-ints": "~1.0.0",
-        "debug": "~2.6.9",
-        "safe-buffer": "~5.1.2"
-      },
-      "engines": {
-        "node": ">=0.8"
-      }
-    },
-    "node_modules/bitsyntax/node_modules/debug": {
-      "version": "2.6.9",
-      "resolved": "https://registry.npmjs.org/debug/-/debug-2.6.9.tgz",
-      "integrity": "sha512-bC7ElrdJaJnPbAP+1EotYvqZsb3ecl5wi6Bfi6BJTUcNowp6cvspg0jXznRTKDjm/E7AdgFBVeAPVMNcKGsHMA==",
-      "dependencies": {
-        "ms": "2.0.0"
-      }
-    },
-    "node_modules/bitsyntax/node_modules/ms": {
-      "version": "2.0.0",
-      "resolved": "https://registry.npmjs.org/ms/-/ms-2.0.0.tgz",
-      "integrity": "sha1-VgiurfwAvmwpAd9fmGF4jeDVl8g="
-    },
-    "node_modules/bitsyntax/node_modules/safe-buffer": {
-      "version": "5.1.2",
-      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
-      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
-    },
-    "node_modules/bluebird": {
-      "version": "3.7.2",
-      "resolved": "https://registry.npmjs.org/bluebird/-/bluebird-3.7.2.tgz",
-      "integrity": "sha512-XpNj6GDQzdfW+r2Wnn7xiSAd7TM3jzkxGXBGTtWKuSXv1xUV+azxAm8jdWZN06QTQk+2N2XB9jRDkvbmQmcRtg=="
-    },
    "node_modules/bn.js": {
      "version": "5.2.0",
      "resolved": "https://registry.npmjs.org/bn.js/-/bn.js-5.2.0.tgz",
@@ -589,9 +634,9 @@
      "integrity": "sha512-EMetuGFz5SLsT0QTnXzINh4Ksr+oo4i+UGTXEshiGCQWnsgSs7ZhJ8fzlwQ+OzEMs0MpDAMr1hxnblp5a4vcHg=="
    },
    "node_modules/bufferutil": {
-      "version": "4.0.5",
-      "resolved": "https://registry.npmjs.org/bufferutil/-/bufferutil-4.0.5.tgz",
-      "integrity": "sha512-HTm14iMQKK2FjFLRTM5lAVcyaUzOnqbPtesFIvREgXpJHdQm8bWS+GkQgIkfaBYRHuCnea7w8UVNfwiAQhlr9A==",
+      "version": "4.0.7",
+      "resolved": "https://registry.npmjs.org/bufferutil/-/bufferutil-4.0.7.tgz",
+      "integrity": "sha512-kukuqc39WOHtdxtw4UScxF/WVnMFVSQVKhtx3AjZJzhd0RGZZldcrfSEbVsWWe6KNH253574cq5F+wpv0G9pJw==",
      "hasInstallScript": true,
      "optional": true,
      "dependencies": {
@@ -884,9 +929,9 @@
      }
    },
    "node_modules/engine.io-client": {
-      "version": "6.2.2",
-      "resolved": "https://registry.npmjs.org/engine.io-client/-/engine.io-client-6.2.2.tgz",
-      "integrity": "sha512-8ZQmx0LQGRTYkHuogVZuGSpDqYZtCM/nv8zQ68VZ+JkOpazJ7ICdsSpaO6iXwvaU30oFg5QJOJWj8zWqhbKjkQ==",
+      "version": "6.2.3",
+      "resolved": "https://registry.npmjs.org/engine.io-client/-/engine.io-client-6.2.3.tgz",
+      "integrity": "sha512-aXPtgF1JS3RuuKcpSrBtimSjYvrbhKW9froICH4s0F3XQWLxsKNxqzG39nnvQZQnva4CMvUK63T7shevxRyYHw==",
      "dependencies": {
        "@socket.io/component-emitter": "~3.1.0",
        "debug": "~4.3.1",
@@ -1039,57 +1084,25 @@
      "integrity": "sha512-W+KJc2dmILlPplD/H4K9l9LcAHAfPtP6BY84uVLXQ6Evcz9Lcg33Y2z1IVblT6xdY54PXYVHEv+0Wpq8Io6zkA=="
    },
    "node_modules/fastify": {
-      "version": "3.24.0",
-      "resolved": "https://registry.npmjs.org/fastify/-/fastify-3.24.0.tgz",
-      "integrity": "sha512-fmRyrI25rzLGHDQ1FME02NsbP658mVa0EaSqfYUFwx2UOF+4/GcyNrsdWILSDOEiUbOsRYCD3sRCE9v7mvRLRQ==",
+      "version": "3.29.3",
+      "resolved": "https://registry.npmjs.org/fastify/-/fastify-3.29.3.tgz",
+      "integrity": "sha512-PA5mGkVnAnhysmyAnXMN9gdOlcfIxyGsfj9C7/a3sSfe5mC38euEGRLEB0T7ygbi7TIZ9yIZ/FLiERpwZeWriA==",
      "dependencies": {
        "@fastify/ajv-compiler": "^1.0.0",
+        "@fastify/error": "^2.0.0",
        "abstract-logging": "^2.0.0",
        "avvio": "^7.1.2",
        "fast-json-stringify": "^2.5.2",
-        "fastify-error": "^0.3.0",
-        "fastify-warning": "^0.2.0",
-        "find-my-way": "^4.1.0",
+        "find-my-way": "^4.5.0",
        "flatstr": "^1.0.12",
        "light-my-request": "^4.2.0",
        "pino": "^6.13.0",
+        "process-warning": "^1.0.0",
        "proxy-addr": "^2.0.7",
        "rfdc": "^1.1.4",
        "secure-json-parse": "^2.0.0",
        "semver": "^7.3.2",
-        "tiny-lru": "^7.0.0"
-      }
-    },
-    "node_modules/fastify-autoload": {
-      "version": "3.9.0",
-      "resolved": "https://registry.npmjs.org/fastify-autoload/-/fastify-autoload-3.9.0.tgz",
-      "integrity": "sha512-GNal/ijLiuwCJBmr7oVVQH/cuDQ9ytm/HbDZLbSWSGr3GW8doGp88vChN3SN87o99isL65whgoqwB97E+XoegQ==",
-      "dependencies": {
-        "pkg-up": "^3.1.0",
-        "semver": "^7.3.2"
-      }
-    },
-    "node_modules/fastify-autoload/node_modules/semver": {
-      "version": "7.3.5",
-      "resolved": "https://registry.npmjs.org/semver/-/semver-7.3.5.tgz",
-      "integrity": "sha512-PoeGJYh8HK4BTO/a9Tf6ZG3veo/A7ZVsYrSA6J8ny9nb3B1VrpkuN+z9OE5wfE5p6H4LchYZsegiQgbJD94ZFQ==",
-      "dependencies": {
-        "lru-cache": "^6.0.0"
-      },
-      "bin": {
-        "semver": "bin/semver.js"
-      },
-      "engines": {
-        "node": ">=10"
-      }
-    },
-    "node_modules/fastify-cors": {
-      "version": "6.0.2",
-      "resolved": "https://registry.npmjs.org/fastify-cors/-/fastify-cors-6.0.2.tgz",
-      "integrity": "sha512-sE0AOyzmj5hLLRRVgenjA6G2iOGX35/1S3QGYB9rr9TXelMZB3lFrXy4CzwYVOMiujJeMiLgO4J7eRm8sQSv8Q==",
-      "dependencies": {
-        "fastify-plugin": "^3.0.0",
-        "vary": "^1.1.2"
+        "tiny-lru": "^8.0.1"
      }
    },
    "node_modules/fastify-elasticsearch": {
@@ -1123,42 +1136,10 @@
        "node": ">=10"
      }
    },
-    "node_modules/fastify-error": {
-      "version": "0.3.1",
-      "resolved": "https://registry.npmjs.org/fastify-error/-/fastify-error-0.3.1.tgz",
-      "integrity": "sha512-oCfpcsDndgnDVgiI7bwFKAun2dO+4h84vBlkWsWnz/OUK9Reff5UFoFl241xTiLeHWX/vU9zkDVXqYUxjOwHcQ=="
-    },
-    "node_modules/fastify-formbody": {
-      "version": "5.2.0",
-      "resolved": "https://registry.npmjs.org/fastify-formbody/-/fastify-formbody-5.2.0.tgz",
-      "integrity": "sha512-d8Y5hCL82akPyoFiXh2wYOm3es0pV9jqoPo3pO9OV2cNF0cQx39J5WAVXzCh4MSt9Z2qF4Fy5gHlvlyESwjtvg==",
-      "dependencies": {
-        "fastify-plugin": "^3.0.0"
-      }
-    },
    "node_modules/fastify-plugin": {
-      "version": "3.0.0",
-      "resolved": "https://registry.npmjs.org/fastify-plugin/-/fastify-plugin-3.0.0.tgz",
-      "integrity": "sha512-ZdCvKEEd92DNLps5n0v231Bha8bkz1DjnPP/aEz37rz/q42Z5JVLmgnqR4DYuNn3NXAO3IDCPyRvgvxtJ4Ym4w=="
-    },
-    "node_modules/fastify-rate-limit": {
-      "version": "5.6.2",
-      "resolved": "https://registry.npmjs.org/fastify-rate-limit/-/fastify-rate-limit-5.6.2.tgz",
-      "integrity": "sha512-3CJudTi0Arf16OyUhXlW3lHaSJDZOtchyYgA3BCR1RpfnEm4pvZCwASR+vYfCJiWGhW+bn8uY/7DWvTHo/Je6A==",
-      "dependencies": {
-        "fastify-plugin": "^3.0.0",
-        "ms": "^2.1.1",
-        "tiny-lru": "^7.0.0"
-      }
-    },
-    "node_modules/fastify-redis": {
-      "version": "4.3.3",
-      "resolved": "https://registry.npmjs.org/fastify-redis/-/fastify-redis-4.3.3.tgz",
-      "integrity": "sha512-E9OP1QSL6i/wWIOwRmSlJd7vBmTmOpSqQjvk4+SQTZ5VMBS7ANpZj+nSRm0F8MIDQFLIsTSUE7ozHibDt22R2g==",
-      "dependencies": {
-        "fastify-plugin": "^3.0.0",
-        "ioredis": "^4.27.9"
-      }
+      "version": "3.0.1",
+      "resolved": "https://registry.npmjs.org/fastify-plugin/-/fastify-plugin-3.0.1.tgz",
+      "integrity": "sha512-qKcDXmuZadJqdTm6vlCqioEbyewF60b/0LOFCcYN1B6BIZGlYJumWWOYs70SFYLDAH4YqdE1cxH/RKMG7rFxgA=="
    },
    "node_modules/fastify-warning": {
      "version": "0.2.0",
@@ -1188,9 +1169,9 @@
      }
    },
    "node_modules/find-my-way": {
-      "version": "4.3.3",
-      "resolved": "https://registry.npmjs.org/find-my-way/-/find-my-way-4.3.3.tgz",
-      "integrity": "sha512-5E4bRdaATB1MewjOCBjx4xvD205a4t2ripCnXB+YFhYEJ0NABtrcC7XLXLq0TPoFe/WYGUFqys3Qk3HCOGeNcw==",
+      "version": "4.5.1",
+      "resolved": "https://registry.npmjs.org/find-my-way/-/find-my-way-4.5.1.tgz",
+      "integrity": "sha512-kE0u7sGoUFbMXcOG/xpkmz4sRLCklERnBcg7Ftuu1iAxsfEt2S46RLJ3Sq7vshsEy2wJT2hZxE58XZK27qa8kg==",
      "dependencies": {
        "fast-decode-uri-component": "^1.0.1",
        "fast-deep-equal": "^3.1.3",
@@ -1426,9 +1407,9 @@
      "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ=="
    },
    "node_modules/ioredis": {
-      "version": "4.28.1",
-      "resolved": "https://registry.npmjs.org/ioredis/-/ioredis-4.28.1.tgz",
-      "integrity": "sha512-7gcrUJEcPHWy+eEyq6wIZpXtfHt8crhbc5+z0sqrnHUkwBblXinygfamj+/jx83Qo+2LW3q87Nj2VsuH6BF2BA==",
+      "version": "4.28.5",
+      "resolved": "https://registry.npmjs.org/ioredis/-/ioredis-4.28.5.tgz",
+      "integrity": "sha512-3GYo0GJtLqgNXj4YhrisLaNNvWSNwSS2wS4OELGfGxH8I69+XfNdnmV1AyN+ZqMh0i7eX+SWjrwFKDBDgfBC1A==",
      "dependencies": {
        "cluster-key-slot": "^1.1.0",
        "debug": "^4.3.1",
@@ -1912,7 +1893,7 @@
    "node_modules/path-exists": {
      "version": "3.0.0",
      "resolved": "https://registry.npmjs.org/path-exists/-/path-exists-3.0.0.tgz",
-      "integrity": "sha1-zg6+ql94yxiSXqfYENe1mwEP1RU=",
+      "integrity": "sha512-bpC7GYwiDYQ4wYLe+FA8lhRjhQCMcQGuSgGGqDkg/QerRWw9CmGRT0iSOVRSZJ29NMLZgIzqaljJ63oaL4NIJQ==",
      "engines": {
        "node": ">=4"
      }
@@ -1992,6 +1973,11 @@
        "ms": "^2.1.1"
      }
    },
+    "node_modules/process-warning": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/process-warning/-/process-warning-1.0.0.tgz",
+      "integrity": "sha512-du4wfLyj4yCZq1VupnVSZmRsPJsNuxoDQFdCFHLaYiEbFBD7QE0a+I4D7hOxrVnh78QE/YipFAj9lXHiXocV+Q=="
+    },
    "node_modules/proxy-addr": {
      "version": "2.0.7",
      "resolved": "https://registry.npmjs.org/proxy-addr/-/proxy-addr-2.0.7.tgz",
@@ -2345,9 +2331,9 @@
      "integrity": "sha512-VUJ49FC8U1OxwZLxIbTTrDvLnf/6TDgxZcK8wxR8zs13xpx7xbG60ndBlhNrFi2EMuFRoeDoJO7wthSLq42EjA=="
    },
    "node_modules/socket.io": {
-      "version": "4.5.2",
-      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.5.2.tgz",
-      "integrity": "sha512-6fCnk4ARMPZN448+SQcnn1u8OHUC72puJcNtSgg2xS34Cu7br1gQ09YKkO1PFfDn/wyUE9ZgMAwosJed003+NQ==",
+      "version": "4.5.3",
+      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.5.3.tgz",
+      "integrity": "sha512-zdpnnKU+H6mOp7nYRXH4GNv1ux6HL6+lHL8g7Ds7Lj8CkdK1jJK/dlwsKDculbyOHifcJ0Pr/yeXnZQ5GeFrcg==",
      "dependencies": {
        "accepts": "~1.3.4",
        "base64id": "~2.0.0",
@@ -2366,13 +2352,13 @@
      "integrity": "sha512-W4N+o69rkMEGVuk2D/cvca3uYsvGlMwsySWV447y99gUPghxq42BxqLNMndb+a1mm/5/7NeXVQS7RLa2XyXvYg=="
    },
    "node_modules/socket.io-client": {
-      "version": "4.5.2",
-      "resolved": "https://registry.npmjs.org/socket.io-client/-/socket.io-client-4.5.2.tgz",
-      "integrity": "sha512-naqYfFu7CLDiQ1B7AlLhRXKX3gdeaIMfgigwavDzgJoIUYulc1qHH5+2XflTsXTPY7BlPH5rppJyUjhjrKQKLg==",
+      "version": "4.5.3",
+      "resolved": "https://registry.npmjs.org/socket.io-client/-/socket.io-client-4.5.3.tgz",
+      "integrity": "sha512-I/hqDYpQ6JKwtJOf5ikM+Qz+YujZPMEl6qBLhxiP0nX+TfXKhW4KZZG8lamrD6Y5ngjmYHreESVasVCgi5Kl3A==",
      "dependencies": {
        "@socket.io/component-emitter": "~3.1.0",
        "debug": "~4.3.2",
-        "engine.io-client": "~6.2.1",
+        "engine.io-client": "~6.2.3",
        "socket.io-parser": "~4.2.0"
      },
      "engines": {
@@ -2470,9 +2456,9 @@
      }
    },
    "node_modules/tiny-lru": {
-      "version": "7.0.6",
-      "resolved": "https://registry.npmjs.org/tiny-lru/-/tiny-lru-7.0.6.tgz",
-      "integrity": "sha512-zNYO0Kvgn5rXzWpL0y3RS09sMK67eGaQj9805jlK9G6pSadfriTczzLHFXa/xcW4mIRfmlB9HyQ/+SgL0V1uow==",
+      "version": "8.0.2",
+      "resolved": "https://registry.npmjs.org/tiny-lru/-/tiny-lru-8.0.2.tgz",
+      "integrity": "sha512-ApGvZ6vVvTNdsmt676grvCkUCGwzG9IqXma5Z07xJgiC5L7akUMof5U8G2JTI9Rz/ovtVhJBlY6mNhEvtjzOIg==",
      "engines": {
        "node": ">=6"
      }
@@ -2572,6 +2558,10 @@
        "uuid": "bin/uuid"
      }
    },
+    "node_modules/uWebSockets.js": {
+      "version": "20.10.0",
+      "resolved": "git+ssh://git@github.com/uNetworking/uWebSockets.js.git#806df48c9da86af7b3341f3e443388c7cd15c3de"
+    },
    "node_modules/vary": {
      "version": "1.1.2",
      "resolved": "https://registry.npmjs.org/vary/-/vary-1.1.2.tgz",
@@ -2600,9 +2590,9 @@
      "integrity": "sha1-tSQ9jz7BqjXxNkYFvA0QNuMKtp8="
    },
    "node_modules/ws": {
-      "version": "8.8.1",
-      "resolved": "https://registry.npmjs.org/ws/-/ws-8.8.1.tgz",
-      "integrity": "sha512-bGy2JzvzkPowEJV++hF07hAD6niYSr0JzBNo/J29WsB57A2r7Wlc1UFcTR9IzrPvuNVO4B8LGqF8qcpsVOhJCA==",
+      "version": "8.11.0",
+      "resolved": "https://registry.npmjs.org/ws/-/ws-8.11.0.tgz",
+      "integrity": "sha512-HPG3wQd9sNQoT9xHyNCXoDUa+Xw/VevmY9FoHyQ+g+rrMn4j6FB4np7Z0OhdTgjx6MgQLK7jwSy1YecU1+4Asg==",
      "engines": {
        "node": ">=10.0.0"
      },
@@ -2645,6 +2635,23 @@
    }
  },
  "dependencies": {
+    "@acuminous/bitsyntax": {
+      "version": "0.1.2",
+      "resolved": "https://registry.npmjs.org/@acuminous/bitsyntax/-/bitsyntax-0.1.2.tgz",
+      "integrity": "sha512-29lUK80d1muEQqiUsSo+3A0yP6CdspgC95EnKBMi22Xlwt79i/En4Vr67+cXhU+cZjbti3TgGGC5wy1stIywVQ==",
+      "requires": {
+        "buffer-more-ints": "~1.0.0",
+        "debug": "^4.3.4",
+        "safe-buffer": "~5.1.2"
+      },
+      "dependencies": {
+        "safe-buffer": {
+          "version": "5.1.2",
+          "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
+          "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
+        }
+      }
+    },
    "@elastic/elasticsearch": {
      "version": "7.17.0",
      "resolved": "https://registry.npmjs.org/@elastic/elasticsearch/-/elasticsearch-7.17.0.tgz",
@@ -2669,6 +2676,66 @@
        "ajv": "^6.12.6"
      }
    },
+    "@fastify/autoload": {
+      "version": "4.0.1",
+      "resolved": "https://registry.npmjs.org/@fastify/autoload/-/autoload-4.0.1.tgz",
+      "integrity": "sha512-eiKxDuz83gFID9LN2BVma0sj3gqDqP8sCHbNN4JmLGe2YNzrSQ+11axweIV8eu1tfWu6v8rgTqu/nu59QXhlsw==",
+      "requires": {
+        "pkg-up": "^3.1.0",
+        "semver": "^7.3.5"
+      },
+      "dependencies": {
+        "semver": {
+          "version": "7.3.8",
+          "resolved": "https://registry.npmjs.org/semver/-/semver-7.3.8.tgz",
+          "integrity": "sha512-NB1ctGL5rlHrPJtFDVIVzTyQylMLu9N9VICA6HSFJo8MCGVTMW6gfpicwKmmK/dAjTOrqu5l63JJOpDSrAis3A==",
+          "requires": {
+            "lru-cache": "^6.0.0"
+          }
+        }
+      }
+    },
+    "@fastify/cors": {
+      "version": "7.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/cors/-/cors-7.0.0.tgz",
+      "integrity": "sha512-nlo6ScwagBNJacAZD3KX90xjWLIoV0vN9QqoX1wUE9ZeZMdvkVkMZCGlxEtr00NshV0X5wDge4w5rwox7rRzSg==",
+      "requires": {
+        "fastify-plugin": "^3.0.0",
+        "vary": "^1.1.2"
+      }
+    },
+    "@fastify/error": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/error/-/error-2.0.0.tgz",
+      "integrity": "sha512-wI3fpfDT0t7p8E6dA2eTECzzOd+bZsZCJ2Hcv+Onn2b7ZwK3RwD27uW2QDaMtQhAfWQQP+WNK7nKf0twLsBf9w=="
+    },
+    "@fastify/formbody": {
+      "version": "6.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/formbody/-/formbody-6.0.0.tgz",
+      "integrity": "sha512-YzPTXJbB3CzDMqU5K9YGSBt/nc/RDFZSxSWZ4SoqA3T2VRJzCPd7sZFpggdmlBRWhEBlvl0EWW7EX33kfbbFlg==",
+      "requires": {
+        "fastify-plugin": "^3.0.0"
+      }
+    },
+    "@fastify/rate-limit": {
+      "version": "6.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/rate-limit/-/rate-limit-6.0.0.tgz",
+      "integrity": "sha512-EZ0TI7Mpo5aK/QaooSt3U0cAGSFjrN51vwj6osgBF1KrnLVSmRA7KPYhPimMoL9YFu9GH53aiNU0H1qTLh7s1Q==",
+      "requires": {
+        "fastify-plugin": "^3.0.1",
+        "ms": "^2.1.3",
+        "tiny-lru": "^8.0.1"
+      }
+    },
+    "@fastify/redis": {
+      "version": "5.0.0",
+      "resolved": "https://registry.npmjs.org/@fastify/redis/-/redis-5.0.0.tgz",
+      "integrity": "sha512-uAFbtQ85VZmeG9crm4Qew1QjbrLwzEwgDQCPzsEWIEgkI73OUtCGoDqvbx/LmPvAlace7ZfLBGTcljIwqB7Uyw==",
+      "requires": {
+        "fastify-plugin": "^3.0.0",
+        "ioredis": "^4.27.9"
+      }
+    },
    "@fastify/static": {
      "version": "5.0.2",
      "resolved": "https://registry.npmjs.org/@fastify/static/-/static-5.0.2.tgz",
@@ -2894,9 +2961,9 @@
      "dev": true
    },
    "@types/node": {
-      "version": "16.11.10",
-      "resolved": "https://registry.npmjs.org/@types/node/-/node-16.11.10.tgz",
-      "integrity": "sha512-3aRnHa1KlOEEhJ6+CvyHKK5vE9BcLGjtUpwvqYLRvYNQKMfabu3BwfJaA/SLW8dxe28LsNDjtHwePTuzn3gmOA=="
+      "version": "18.11.9",
+      "resolved": "https://registry.npmjs.org/@types/node/-/node-18.11.9.tgz",
+      "integrity": "sha512-CRpX21/kGdzjOpFsZSkcrXMGIBWMGNIHXXBVFSH+ggkftxg+XYP20TESbh+zFvFj3EQOl5byk0HTRn1IL6hbqg=="
    },
    "@types/nodemailer": {
      "version": "6.4.4",
@@ -2916,9 +2983,9 @@
      }
    },
    "@types/ws": {
-      "version": "8.2.0",
-      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.2.0.tgz",
-      "integrity": "sha512-cyeefcUCgJlEk+hk2h3N+MqKKsPViQgF5boi9TTHSK+PoR9KWBb/C5ccPcDyAqgsbAYHTwulch725DV84+pSpg==",
+      "version": "8.5.3",
+      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.5.3.tgz",
+      "integrity": "sha512-6YOoWjruKj1uLf3INHH7D3qTXwFfEsg1kf3c0uDdSBJwfa/llkwIjrAGV7j7mVgGNbzTQ3HiHKKDXl6bJPD97w==",
      "dev": true,
      "requires": {
        "@types/node": "*"
@@ -2958,16 +3025,14 @@
      }
    },
    "amqplib": {
-      "version": "0.8.0",
-      "resolved": "https://registry.npmjs.org/amqplib/-/amqplib-0.8.0.tgz",
-      "integrity": "sha512-icU+a4kkq4Y1PS4NNi+YPDMwdlbFcZ1EZTQT2nigW3fvOb6AOgUQ9+Mk4ue0Zu5cBg/XpDzB40oH10ysrk2dmA==",
+      "version": "0.10.3",
+      "resolved": "https://registry.npmjs.org/amqplib/-/amqplib-0.10.3.tgz",
+      "integrity": "sha512-UHmuSa7n8vVW/a5HGh2nFPqAEr8+cD4dEZ6u9GjP91nHfr1a54RyAKyra7Sb5NH7NBKOUlyQSMXIp0qAixKexw==",
      "requires": {
-        "bitsyntax": "~0.1.0",
-        "bluebird": "^3.7.2",
+        "@acuminous/bitsyntax": "^0.1.2",
        "buffer-more-ints": "~1.0.0",
        "readable-stream": "1.x >=1.1.9",
-        "safe-buffer": "~5.2.1",
-        "url-parse": "~1.5.1"
+        "url-parse": "~1.5.10"
      }
    },
    "archy": {
@@ -3032,41 +3097,6 @@
      "resolved": "https://registry.npmjs.org/base64id/-/base64id-2.0.0.tgz",
      "integrity": "sha512-lGe34o6EHj9y3Kts9R4ZYs/Gr+6N7MCaMlIFA3F1R2O5/m7K06AxfSeO5530PEERE6/WyEg3lsuyw4GHlPZHog=="
    },
-    "bitsyntax": {
-      "version": "0.1.0",
-      "resolved": "https://registry.npmjs.org/bitsyntax/-/bitsyntax-0.1.0.tgz",
-      "integrity": "sha512-ikAdCnrloKmFOugAfxWws89/fPc+nw0OOG1IzIE72uSOg/A3cYptKCjSUhDTuj7fhsJtzkzlv7l3b8PzRHLN0Q==",
-      "requires": {
-        "buffer-more-ints": "~1.0.0",
-        "debug": "~2.6.9",
-        "safe-buffer": "~5.1.2"
-      },
-      "dependencies": {
-        "debug": {
-          "version": "2.6.9",
-          "resolved": "https://registry.npmjs.org/debug/-/debug-2.6.9.tgz",
-          "integrity": "sha512-bC7ElrdJaJnPbAP+1EotYvqZsb3ecl5wi6Bfi6BJTUcNowp6cvspg0jXznRTKDjm/E7AdgFBVeAPVMNcKGsHMA==",
-          "requires": {
-            "ms": "2.0.0"
-          }
-        },
-        "ms": {
-          "version": "2.0.0",
-          "resolved": "https://registry.npmjs.org/ms/-/ms-2.0.0.tgz",
-          "integrity": "sha1-VgiurfwAvmwpAd9fmGF4jeDVl8g="
-        },
-        "safe-buffer": {
-          "version": "5.1.2",
-          "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
-          "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
-        }
-      }
-    },
-    "bluebird": {
-      "version": "3.7.2",
-      "resolved": "https://registry.npmjs.org/bluebird/-/bluebird-3.7.2.tgz",
-      "integrity": "sha512-XpNj6GDQzdfW+r2Wnn7xiSAd7TM3jzkxGXBGTtWKuSXv1xUV+azxAm8jdWZN06QTQk+2N2XB9jRDkvbmQmcRtg=="
-    },
    "bn.js": {
      "version": "5.2.0",
      "resolved": "https://registry.npmjs.org/bn.js/-/bn.js-5.2.0.tgz",
@@ -3116,9 +3146,9 @@
      "integrity": "sha512-EMetuGFz5SLsT0QTnXzINh4Ksr+oo4i+UGTXEshiGCQWnsgSs7ZhJ8fzlwQ+OzEMs0MpDAMr1hxnblp5a4vcHg=="
    },
    "bufferutil": {
-      "version": "4.0.5",
-      "resolved": "https://registry.npmjs.org/bufferutil/-/bufferutil-4.0.5.tgz",
-      "integrity": "sha512-HTm14iMQKK2FjFLRTM5lAVcyaUzOnqbPtesFIvREgXpJHdQm8bWS+GkQgIkfaBYRHuCnea7w8UVNfwiAQhlr9A==",
+      "version": "4.0.7",
+      "resolved": "https://registry.npmjs.org/bufferutil/-/bufferutil-4.0.7.tgz",
+      "integrity": "sha512-kukuqc39WOHtdxtw4UScxF/WVnMFVSQVKhtx3AjZJzhd0RGZZldcrfSEbVsWWe6KNH253574cq5F+wpv0G9pJw==",
      "optional": true,
      "requires": {
        "node-gyp-build": "^4.3.0"
@@ -3356,9 +3386,9 @@
      }
    },
    "engine.io-client": {
-      "version": "6.2.2",
-      "resolved": "https://registry.npmjs.org/engine.io-client/-/engine.io-client-6.2.2.tgz",
-      "integrity": "sha512-8ZQmx0LQGRTYkHuogVZuGSpDqYZtCM/nv8zQ68VZ+JkOpazJ7ICdsSpaO6iXwvaU30oFg5QJOJWj8zWqhbKjkQ==",
+      "version": "6.2.3",
+      "resolved": "https://registry.npmjs.org/engine.io-client/-/engine.io-client-6.2.3.tgz",
+      "integrity": "sha512-aXPtgF1JS3RuuKcpSrBtimSjYvrbhKW9froICH4s0F3XQWLxsKNxqzG39nnvQZQnva4CMvUK63T7shevxRyYHw==",
      "requires": {
        "@socket.io/component-emitter": "~3.1.0",
        "debug": "~4.3.1",
@@ -3458,25 +3488,25 @@
      "integrity": "sha512-W+KJc2dmILlPplD/H4K9l9LcAHAfPtP6BY84uVLXQ6Evcz9Lcg33Y2z1IVblT6xdY54PXYVHEv+0Wpq8Io6zkA=="
    },
    "fastify": {
-      "version": "3.24.0",
-      "resolved": "https://registry.npmjs.org/fastify/-/fastify-3.24.0.tgz",
-      "integrity": "sha512-fmRyrI25rzLGHDQ1FME02NsbP658mVa0EaSqfYUFwx2UOF+4/GcyNrsdWILSDOEiUbOsRYCD3sRCE9v7mvRLRQ==",
+      "version": "3.29.3",
+      "resolved": "https://registry.npmjs.org/fastify/-/fastify-3.29.3.tgz",
+      "integrity": "sha512-PA5mGkVnAnhysmyAnXMN9gdOlcfIxyGsfj9C7/a3sSfe5mC38euEGRLEB0T7ygbi7TIZ9yIZ/FLiERpwZeWriA==",
      "requires": {
        "@fastify/ajv-compiler": "^1.0.0",
+        "@fastify/error": "^2.0.0",
        "abstract-logging": "^2.0.0",
        "avvio": "^7.1.2",
        "fast-json-stringify": "^2.5.2",
-        "fastify-error": "^0.3.0",
-        "fastify-warning": "^0.2.0",
-        "find-my-way": "^4.1.0",
+        "find-my-way": "^4.5.0",
        "flatstr": "^1.0.12",
        "light-my-request": "^4.2.0",
        "pino": "^6.13.0",
+        "process-warning": "^1.0.0",
        "proxy-addr": "^2.0.7",
        "rfdc": "^1.1.4",
        "secure-json-parse": "^2.0.0",
        "semver": "^7.3.2",
-        "tiny-lru": "^7.0.0"
+        "tiny-lru": "^8.0.1"
      },
      "dependencies": {
        "semver": {
@@ -3489,34 +3519,6 @@
        }
      }
    },
-    "fastify-autoload": {
-      "version": "3.9.0",
-      "resolved": "https://registry.npmjs.org/fastify-autoload/-/fastify-autoload-3.9.0.tgz",
-      "integrity": "sha512-GNal/ijLiuwCJBmr7oVVQH/cuDQ9ytm/HbDZLbSWSGr3GW8doGp88vChN3SN87o99isL65whgoqwB97E+XoegQ==",
-      "requires": {
-        "pkg-up": "^3.1.0",
-        "semver": "^7.3.2"
-      },
-      "dependencies": {
-        "semver": {
-          "version": "7.3.5",
-          "resolved": "https://registry.npmjs.org/semver/-/semver-7.3.5.tgz",
-          "integrity": "sha512-PoeGJYh8HK4BTO/a9Tf6ZG3veo/A7ZVsYrSA6J8ny9nb3B1VrpkuN+z9OE5wfE5p6H4LchYZsegiQgbJD94ZFQ==",
-          "requires": {
-            "lru-cache": "^6.0.0"
-          }
-        }
-      }
-    },
-    "fastify-cors": {
-      "version": "6.0.2",
-      "resolved": "https://registry.npmjs.org/fastify-cors/-/fastify-cors-6.0.2.tgz",
-      "integrity": "sha512-sE0AOyzmj5hLLRRVgenjA6G2iOGX35/1S3QGYB9rr9TXelMZB3lFrXy4CzwYVOMiujJeMiLgO4J7eRm8sQSv8Q==",
-      "requires": {
-        "fastify-plugin": "^3.0.0",
-        "vary": "^1.1.2"
-      }
-    },
    "fastify-elasticsearch": {
      "version": "2.0.0",
      "resolved": "https://registry.npmjs.org/fastify-elasticsearch/-/fastify-elasticsearch-2.0.0.tgz",
@@ -3544,42 +3546,10 @@
        }
      }
    },
-    "fastify-error": {
-      "version": "0.3.1",
-      "resolved": "https://registry.npmjs.org/fastify-error/-/fastify-error-0.3.1.tgz",
-      "integrity": "sha512-oCfpcsDndgnDVgiI7bwFKAun2dO+4h84vBlkWsWnz/OUK9Reff5UFoFl241xTiLeHWX/vU9zkDVXqYUxjOwHcQ=="
-    },
-    "fastify-formbody": {
-      "version": "5.2.0",
-      "resolved": "https://registry.npmjs.org/fastify-formbody/-/fastify-formbody-5.2.0.tgz",
-      "integrity": "sha512-d8Y5hCL82akPyoFiXh2wYOm3es0pV9jqoPo3pO9OV2cNF0cQx39J5WAVXzCh4MSt9Z2qF4Fy5gHlvlyESwjtvg==",
-      "requires": {
-        "fastify-plugin": "^3.0.0"
-      }
-    },
    "fastify-plugin": {
-      "version": "3.0.0",
-      "resolved": "https://registry.npmjs.org/fastify-plugin/-/fastify-plugin-3.0.0.tgz",
-      "integrity": "sha512-ZdCvKEEd92DNLps5n0v231Bha8bkz1DjnPP/aEz37rz/q42Z5JVLmgnqR4DYuNn3NXAO3IDCPyRvgvxtJ4Ym4w=="
-    },
-    "fastify-rate-limit": {
-      "version": "5.6.2",
-      "resolved": "https://registry.npmjs.org/fastify-rate-limit/-/fastify-rate-limit-5.6.2.tgz",
-      "integrity": "sha512-3CJudTi0Arf16OyUhXlW3lHaSJDZOtchyYgA3BCR1RpfnEm4pvZCwASR+vYfCJiWGhW+bn8uY/7DWvTHo/Je6A==",
-      "requires": {
-        "fastify-plugin": "^3.0.0",
-        "ms": "^2.1.1",
-        "tiny-lru": "^7.0.0"
-      }
-    },
-    "fastify-redis": {
-      "version": "4.3.3",
-      "resolved": "https://registry.npmjs.org/fastify-redis/-/fastify-redis-4.3.3.tgz",
-      "integrity": "sha512-E9OP1QSL6i/wWIOwRmSlJd7vBmTmOpSqQjvk4+SQTZ5VMBS7ANpZj+nSRm0F8MIDQFLIsTSUE7ozHibDt22R2g==",
-      "requires": {
-        "fastify-plugin": "^3.0.0",
-        "ioredis": "^4.27.9"
-      }
+      "version": "3.0.1",
+      "resolved": "https://registry.npmjs.org/fastify-plugin/-/fastify-plugin-3.0.1.tgz",
+      "integrity": "sha512-qKcDXmuZadJqdTm6vlCqioEbyewF60b/0LOFCcYN1B6BIZGlYJumWWOYs70SFYLDAH4YqdE1cxH/RKMG7rFxgA=="
    },
    "fastify-warning": {
      "version": "0.2.0",
@@ -3595,9 +3565,9 @@
      }
    },
    "find-my-way": {
-      "version": "4.3.3",
-      "resolved": "https://registry.npmjs.org/find-my-way/-/find-my-way-4.3.3.tgz",
-      "integrity": "sha512-5E4bRdaATB1MewjOCBjx4xvD205a4t2ripCnXB+YFhYEJ0NABtrcC7XLXLq0TPoFe/WYGUFqys3Qk3HCOGeNcw==",
+      "version": "4.5.1",
+      "resolved": "https://registry.npmjs.org/find-my-way/-/find-my-way-4.5.1.tgz",
+      "integrity": "sha512-kE0u7sGoUFbMXcOG/xpkmz4sRLCklERnBcg7Ftuu1iAxsfEt2S46RLJ3Sq7vshsEy2wJT2hZxE58XZK27qa8kg==",
      "requires": {
        "fast-decode-uri-component": "^1.0.1",
        "fast-deep-equal": "^3.1.3",
@@ -3781,9 +3751,9 @@
      "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ=="
    },
    "ioredis": {
-      "version": "4.28.1",
-      "resolved": "https://registry.npmjs.org/ioredis/-/ioredis-4.28.1.tgz",
-      "integrity": "sha512-7gcrUJEcPHWy+eEyq6wIZpXtfHt8crhbc5+z0sqrnHUkwBblXinygfamj+/jx83Qo+2LW3q87Nj2VsuH6BF2BA==",
+      "version": "4.28.5",
+      "resolved": "https://registry.npmjs.org/ioredis/-/ioredis-4.28.5.tgz",
+      "integrity": "sha512-3GYo0GJtLqgNXj4YhrisLaNNvWSNwSS2wS4OELGfGxH8I69+XfNdnmV1AyN+ZqMh0i7eX+SWjrwFKDBDgfBC1A==",
      "requires": {
        "cluster-key-slot": "^1.1.0",
        "debug": "^4.3.1",
@@ -4143,7 +4113,7 @@
    "path-exists": {
      "version": "3.0.0",
      "resolved": "https://registry.npmjs.org/path-exists/-/path-exists-3.0.0.tgz",
-      "integrity": "sha1-zg6+ql94yxiSXqfYENe1mwEP1RU="
+      "integrity": "sha512-bpC7GYwiDYQ4wYLe+FA8lhRjhQCMcQGuSgGGqDkg/QerRWw9CmGRT0iSOVRSZJ29NMLZgIzqaljJ63oaL4NIJQ=="
    },
    "path-is-absolute": {
      "version": "1.0.1",
@@ -4210,6 +4180,11 @@
        }
      }
    },
+    "process-warning": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/process-warning/-/process-warning-1.0.0.tgz",
+      "integrity": "sha512-du4wfLyj4yCZq1VupnVSZmRsPJsNuxoDQFdCFHLaYiEbFBD7QE0a+I4D7hOxrVnh78QE/YipFAj9lXHiXocV+Q=="
+    },
    "proxy-addr": {
      "version": "2.0.7",
      "resolved": "https://registry.npmjs.org/proxy-addr/-/proxy-addr-2.0.7.tgz",
@@ -4480,9 +4455,9 @@
      "integrity": "sha512-VUJ49FC8U1OxwZLxIbTTrDvLnf/6TDgxZcK8wxR8zs13xpx7xbG60ndBlhNrFi2EMuFRoeDoJO7wthSLq42EjA=="
    },
    "socket.io": {
-      "version": "4.5.2",
-      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.5.2.tgz",
-      "integrity": "sha512-6fCnk4ARMPZN448+SQcnn1u8OHUC72puJcNtSgg2xS34Cu7br1gQ09YKkO1PFfDn/wyUE9ZgMAwosJed003+NQ==",
+      "version": "4.5.3",
+      "resolved": "https://registry.npmjs.org/socket.io/-/socket.io-4.5.3.tgz",
+      "integrity": "sha512-zdpnnKU+H6mOp7nYRXH4GNv1ux6HL6+lHL8g7Ds7Lj8CkdK1jJK/dlwsKDculbyOHifcJ0Pr/yeXnZQ5GeFrcg==",
      "requires": {
        "accepts": "~1.3.4",
        "base64id": "~2.0.0",
@@ -4498,13 +4473,13 @@
      "integrity": "sha512-W4N+o69rkMEGVuk2D/cvca3uYsvGlMwsySWV447y99gUPghxq42BxqLNMndb+a1mm/5/7NeXVQS7RLa2XyXvYg=="
    },
    "socket.io-client": {
-      "version": "4.5.2",
-      "resolved": "https://registry.npmjs.org/socket.io-client/-/socket.io-client-4.5.2.tgz",
-      "integrity": "sha512-naqYfFu7CLDiQ1B7AlLhRXKX3gdeaIMfgigwavDzgJoIUYulc1qHH5+2XflTsXTPY7BlPH5rppJyUjhjrKQKLg==",
+      "version": "4.5.3",
+      "resolved": "https://registry.npmjs.org/socket.io-client/-/socket.io-client-4.5.3.tgz",
+      "integrity": "sha512-I/hqDYpQ6JKwtJOf5ikM+Qz+YujZPMEl6qBLhxiP0nX+TfXKhW4KZZG8lamrD6Y5ngjmYHreESVasVCgi5Kl3A==",
      "requires": {
        "@socket.io/component-emitter": "~3.1.0",
        "debug": "~4.3.2",
-        "engine.io-client": "~6.2.1",
+        "engine.io-client": "~6.2.3",
        "socket.io-parser": "~4.2.0"
      }
    },
@@ -4586,9 +4561,9 @@
      }
    },
    "tiny-lru": {
-      "version": "7.0.6",
-      "resolved": "https://registry.npmjs.org/tiny-lru/-/tiny-lru-7.0.6.tgz",
-      "integrity": "sha512-zNYO0Kvgn5rXzWpL0y3RS09sMK67eGaQj9805jlK9G6pSadfriTczzLHFXa/xcW4mIRfmlB9HyQ/+SgL0V1uow=="
+      "version": "8.0.2",
+      "resolved": "https://registry.npmjs.org/tiny-lru/-/tiny-lru-8.0.2.tgz",
+      "integrity": "sha512-ApGvZ6vVvTNdsmt676grvCkUCGwzG9IqXma5Z07xJgiC5L7akUMof5U8G2JTI9Rz/ovtVhJBlY6mNhEvtjzOIg=="
    },
    "toidentifier": {
      "version": "1.0.1",
@@ -4661,6 +4636,10 @@
      "resolved": "https://registry.npmjs.org/uuid/-/uuid-3.4.0.tgz",
      "integrity": "sha512-HjSDRw6gZE5JMggctHBcjVak08+KEVhSIiDzFnT9S9aegmp85S/bReBVTb4QTFaRNptJ9kuYaNhnbNEOkbKb/A=="
    },
+    "uWebSockets.js": {
+      "version": "git+ssh://git@github.com/uNetworking/uWebSockets.js.git#806df48c9da86af7b3341f3e443388c7cd15c3de",
+      "from": "uWebSockets.js@github:uNetworking/uWebSockets.js#v20.15.0"
+    },
    "vary": {
      "version": "1.1.2",
      "resolved": "https://registry.npmjs.org/vary/-/vary-1.1.2.tgz",
@@ -4686,9 +4665,9 @@
      "integrity": "sha1-tSQ9jz7BqjXxNkYFvA0QNuMKtp8="
    },
    "ws": {
-      "version": "8.8.1",
-      "resolved": "https://registry.npmjs.org/ws/-/ws-8.8.1.tgz",
-      "integrity": "sha512-bGy2JzvzkPowEJV++hF07hAD6niYSr0JzBNo/J29WsB57A2r7Wlc1UFcTR9IzrPvuNVO4B8LGqF8qcpsVOhJCA==",
+      "version": "8.11.0",
+      "resolved": "https://registry.npmjs.org/ws/-/ws-8.11.0.tgz",
+      "integrity": "sha512-HPG3wQd9sNQoT9xHyNCXoDUa+Xw/VevmY9FoHyQ+g+rrMn4j6FB4np7Z0OhdTgjx6MgQLK7jwSy1YecU1+4Asg==",
      "requires": {}
    },
    "xmlhttprequest-ssl": {
@@ -1,6 +1,6 @@
 {
  "name": "hyperion-history",
-  "version": "3.3.6",
+  "version": "3.3.7",
  "description": "Scalable Full History API Solution for EOSIO based blockchains",
  "main": "launcher.js",
  "scripts": {
@@ -13,7 +13,7 @@
    "fix-permissions": "node scripts/fix-permissions.js"
  },
  "engines": {
-    "node": "^16"
+    "node": "^18"
  },
  "author": {
    "name": "EOS Rio",
@@ -27,37 +27,38 @@
  "dependencies": {
    "@elastic/elasticsearch": "^7.17.0",
    "@eosrio/node-abieos": "^2.1.1",
+    "@fastify/autoload": "4.0.1",
+    "@fastify/cors": "7.0.0",
+    "@fastify/formbody": "^6.0.0",
+    "@fastify/rate-limit": "^6.0.0",
+    "@fastify/redis": "^5.0.0",
    "@fastify/swagger": "6.1.0",
    "@pm2/io": "^5.0.0",
-    "amqplib": "^0.8.0",
+    "amqplib": "^0.10.3",
    "async": "^3.2.4",
    "base-x": "^4.0.0",
    "commander": "^8.3.0",
    "cross-fetch": "^3.1.5",
    "eosjs": "^22.1.0",
    "fast-json-stringify": "^2.7.9",
-    "fastify": "^3.24.0",
-    "fastify-autoload": "^3.9.0",
-    "fastify-cors": "^6.0.2",
+    "fastify": "^3.29.3",
    "fastify-elasticsearch": "^2.0.0",
-    "fastify-formbody": "^5.2.0",
-    "fastify-plugin": "^3.0.0",
-    "fastify-rate-limit": "^5.6.2",
-    "fastify-redis": "^4.3.3",
+    "fastify-plugin": "^3.0.1",
    "flatstr": "^1.0.12",
    "global-agent": "^3.0.0",
    "got": "11.8.5",
-    "ioredis": "^4.28.1",
+    "ioredis": "^4.28.5",
    "lodash": "^4.17.21",
    "moment": "^2.29.4",
    "nodemailer": "^6.7.8",
    "portfinder": "^1.0.32",
-    "socket.io": "^4.5.2",
-    "socket.io-client": "^4.5.2",
+    "socket.io": "4.5.3",
+    "socket.io-client": "4.5.3",
    "socket.io-redis": "^6.1.1",
    "telegraf": "^4.9.1",
    "typescript": "^4.5.2",
-    "ws": "^8.8.1"
+    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.15.0",
+    "ws": "^8.11.0"
  },
  "devDependencies": {
    "@types/amqplib": "^0.8.2",
@@ -65,12 +66,12 @@
    "@types/global-agent": "^2.1.1",
    "@types/ioredis": "^4.28.1",
    "@types/lodash": "^4.14.177",
-    "@types/node": "^16.11.10",
+    "@types/node": "^18.11.9",
    "@types/nodemailer": "^6.4.4",
-    "@types/ws": "^8.2.0"
+    "@types/ws": "^8.5.3"
  },
  "optionalDependencies": {
-    "bufferutil": "^4.0.5",
+    "bufferutil": "^4.0.7",
    "utf-8-validate": "^5.0.7"
  }
 }
@@ -74,7 +74,7 @@ def query_body(interval):
        "histogram": {
            "field": "block_num",
            "interval": interval,
-            "min_doc_count": 1
+            "min_doc_count": 0
        },
        "aggs": {
            "max_block": {
@@ -99,7 +99,7 @@ def query_body2(gte,lte,interval):
                "histogram": {
                    "field": "block_num",
                    "interval": interval,
-                    "min_doc_count": 1
+                    "min_doc_count": 0
                },
                "aggs": {
                    "max_block": {
@@ -151,6 +151,7 @@ def buckets_missing(bucketlist,count1,count2):
            new.update({'key': key, 'doc_count': doc_count})
            buckets_final.append(new)
        # If not first bucket but has less than count2
+        # Might have to remove to account for indices with 0 count
        elif doc_count < count2 and num != 0:
            new.update({'key': key, 'doc_count': doc_count})
            buckets_final.append(new)
@@ -281,12 +282,12 @@ if __name__ == '__main__':
    print(bcolors.OKYELLOW,f"{'='*100}\nSearching for missing Blocks ",bcolors.ENDC)
    # Search for buckets using histogram interval
    buckets = get_buckets(10000000,query_body)
-    # Get buckets with missing blocks, first count is 9999999 to account for bucket 0-9999999.
-    missing = buckets_missing(buckets,9999999,10000000 )
+    # Get buckets with missing blocks, first count is 9999998 to account for bucket 0-9999999.
+    missing = buckets_missing(buckets,9999998,10000000 )
    # Redefine search and set interval to 1000
    gt_lt_list = CreateGtLT(missing)
    print(bcolors.OKYELLOW,f"{'='*100}\nCompleted Search ",bcolors.ENDC)
    #### For testing purposes use  MagicFuzz(testing)
    MagicFuzz(gt_lt_list)
    ## Once rewrite is completed go back to live reading
-    start_indexer_live()
+    start_indexer_live()
@@ -2,7 +2,7 @@ import {Client} from "@elastic/elasticsearch";
 import {ConnectionManager} from "../../connections/manager.class";
 import {Api, JsonRpc} from "eosjs";
 import {CacheManager} from "../../api/helpers/cacheManager";
-import {FastifyRedis} from "fastify-redis";
+import {FastifyRedis} from "@fastify/redis";

 declare module 'fastify' {
    export interface FastifyInstance {
@@ -1495,7 +1495,7 @@ export default class MainDSWorker extends HyperionWorker {
            proposal_name: data['@approvals']['proposal_name'],
            requested_approvals: data['@approvals']['requested_approvals'],
            provided_approvals: data['@approvals']['provided_approvals'],
-            executed: data.present === false,
+            executed: data.present === false || data.present === 0,
            primary_key: data['primary_key'],
            block_num: data['block_num']
        };
@@ -256,12 +256,12 @@ export default class DSPoolWorker extends HyperionWorker {
        const [_status, actionType] = await self.verifyLocalType(_action.account, _action.name, block_num, "action");
        if (_status) {
            try {
-                return AbiEOS.bin_to_json(_action.account, actionType, Buffer.from(_action.data, 'hex'));
+                return JSON.parse(AbiEOS.bin_to_json(_action.account, actionType, Buffer.from(_action.data, 'hex')));
            } catch (e) {
                debugLog(`(abieos) ${_action.account}::${_action.name} @ ${block_num} >>> ${e.message}`);
            }
        }
-        return await self.deserializeActionAtBlock(_action, block_num);
+        return self.deserializeActionAtBlock(_action, block_num);
    }

    async getAbiFromHeadBlock(code) {
@@ -380,9 +380,9 @@ export default class DSPoolWorker extends HyperionWorker {
                        action.data,
                        this.txEnc,
                        this.txDec
-                    );
+                    ).data;
                } catch (e) {
-                    debugLog(`(eosjs)  ${action.account}::${action.name} @ ${block_num} >>> ${e.message}`);
+                    debugLog(`(eosjs) ${action.account}::${action.name} @ ${block_num} >>> ${e.message}`);
                    return null;
                }
            } else {
@@ -314,6 +314,9 @@ export default class WSRouter extends HyperionWorker {
        }
    }

+    /*
+    WS Routing server, API will connect to it.
+     */
    initRoutingServer() {
        const server = createServer();
        this.io = new Server(server, {
Author	SHA1	Message	Date
Igor Lins e Silva	57ea9717f5	v3.3.7, upgrade deprecated fastify plugins	2022-11-09 13:01:22 -03:00
Igor Lins e Silva	40fa86f6d8	update packages for v3.3.7	2022-11-09 12:55:59 -03:00
Igor Lins e Silva	e21554a239	make the indexer behavior clearer when using rewrite: true	2022-11-09 12:48:14 -03:00
Igor Lins e Silva	160b2ebd32	add logging	2022-11-09 12:00:12 -03:00
Igor Lins e Silva	bb28ac7139	update packages	2022-11-09 11:54:27 -03:00
Igor Lins e Silva	4139cd02c1	fix proposal execution flag	2022-11-03 17:22:04 -03:00
Igor Lins e Silva	c66e71df0e	Update get_actions.ts	2022-10-26 17:19:00 -03:00
Igor Lins e Silva	7f15648b38	patch API queries for nested indexed data	2022-10-26 17:18:15 -03:00
Igor Lins e Silva	04c738fffe	fix nested act data on failed abieos deserialization	2022-10-26 17:08:18 -03:00
Igor Lins e Silva	c6b3afc1d1	Update index.ts	2022-10-26 09:54:26 -03:00
Igor Lins e Silva	91fd57bd83	Update get_deltas.ts	2022-10-26 09:41:40 -03:00
Igor Lins e Silva	2d3a46d0fe	fix get_deltas param parsing	2022-10-26 09:40:05 -03:00
Igor Lins e Silva	d99e1cdd8a	Merge pull request #126 from ankh2054/main Update fix-missing-blocks.py	2022-10-20 12:39:53 -03:00
Igor Lins e Silva	24ad40c889	use uWebsockets.js as Socket.IO engine	2022-10-17 01:20:31 +00:00
Charles Holtzkampf	db9dd56b9a	Update fix-missing-blocks.py	2022-10-04 14:10:59 +01:00
Igor Lins e Silva	f7a18b55ab	Update get_actions.ts	2022-09-22 13:56:58 -03:00
Igor Lins e Silva	91b6da103b	Update get_actions.ts	2022-09-22 13:55:37 -03:00
Igor Lins e Silva	f6aef13f88	Update get_actions.ts	2022-09-22 13:52:28 -03:00
Igor Lins e Silva	61c69d0ab6	Update get_actions.ts	2022-09-22 13:51:23 -03:00
Igor Lins e Silva	061d7a443d	add optional hex_data	2022-09-22 13:46:02 -03:00
Igor Lins e Silva	b7e2ead86d	remove wrong encoding for hex_data	2022-09-22 13:21:39 -03:00