MCPcopy
hub / github.com/parse-community/parse-server / addMockSubscription

Function addMockSubscription

spec/ParseLiveQueryServer.spec.js:1854–1901  ·  view source on GitHub ↗
(
    parseLiveQueryServer,
    clientId,
    requestId,
    parseWebSocket,
    query,
    customQueryHashValue
  )

Source from the content-addressed store, hash-verified

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) {

Callers 1

Calls 2

_handleSubscribeMethod · 0.80
getMethod · 0.45

Tested by

no test coverage detected