(data)
| 21 | } |
| 22 | |
| 23 | async function Middleware(data) { |
| 24 | const randomId = Math.floor(Math.random() * 100000); |
| 25 | const queryId = `${performance.now()}-${randomId}`; |
| 26 | queue[queryId] = { resourceName: data.resourceName, type: data.type, dbId: data.dbId, query: data.query, values: data.values, callback: data.callback, cache: data.cache, canfollow: false }; |
| 27 | for(let i = 0; i < interceptorSuscribers.length; i++) { |
| 28 | TriggerClientEvent("icmysql:client:getQueryData", interceptorSuscribers[i], queryId, data); |
| 29 | } |
| 30 | |
| 31 | while(queue[queryId].canfollow === false && global.interceptor) { |
| 32 | await new Promise((resolve) => setTimeout(resolve, 1000)); |
| 33 | } |
| 34 | if(queue[queryId].canfollow === -1) return null; |
| 35 | const result = queue[queryId]; |
| 36 | delete queue[queryId]; |
| 37 | return result; |
| 38 | } |
| 39 | |
| 40 | function SendEventToSuscribers(eventName, ...args) { |
| 41 | for(let i = 0; i < interceptorSuscribers.length; i++) { |
nothing calls this directly
no outgoing calls
no test coverage detected