(
parseLiveQueryServer,
clientId,
requestId,
parseWebSocket,
query,
customQueryHashValue
)
| 1852 | } |
| 1853 | |
| 1854 | async function addMockSubscription( |
| 1855 | parseLiveQueryServer, |
| 1856 | clientId, |
| 1857 | requestId, |
| 1858 | parseWebSocket, |
| 1859 | query, |
| 1860 | customQueryHashValue |
| 1861 | ) { |
| 1862 | // If parseWebSocket is null, we use the default one |
| 1863 | if (!parseWebSocket) { |
| 1864 | const EventEmitter = require('events'); |
| 1865 | parseWebSocket = new EventEmitter(); |
| 1866 | } |
| 1867 | parseWebSocket.clientId = clientId; |
| 1868 | // If query is null, we use the default one |
| 1869 | if (!query) { |
| 1870 | query = { |
| 1871 | className: testClassName, |
| 1872 | where: { |
| 1873 | key: 'value', |
| 1874 | }, |
| 1875 | keys: ['test'], |
| 1876 | }; |
| 1877 | } |
| 1878 | const request = { |
| 1879 | query: query, |
| 1880 | requestId: requestId, |
| 1881 | sessionToken: 'sessionToken', |
| 1882 | }; |
| 1883 | await parseLiveQueryServer._handleSubscribe(parseWebSocket, request); |
| 1884 | |
| 1885 | // Make mock subscription |
| 1886 | const subscription = parseLiveQueryServer.subscriptions |
| 1887 | .get(query.className) |
| 1888 | .get(customQueryHashValue || queryHashValue); |
| 1889 | subscription.hasSubscribingClient = function () { |
| 1890 | return false; |
| 1891 | }; |
| 1892 | subscription.className = query.className; |
| 1893 | subscription.hash = customQueryHashValue || queryHashValue; |
| 1894 | if (subscription.clientRequestIds && subscription.clientRequestIds.has(clientId)) { |
| 1895 | subscription.clientRequestIds.get(clientId).push(requestId); |
| 1896 | } else { |
| 1897 | subscription.clientRequestIds = new Map([[clientId, [requestId]]]); |
| 1898 | } |
| 1899 | subscription.query = query.where; |
| 1900 | return subscription; |
| 1901 | } |
| 1902 | |
| 1903 | // Helper functiosn to generate request message |
| 1904 | function generateMockMessage(hasOriginalParseObject) { |
no test coverage detected