feat: receive realtime event (#6)

* feat: receive realtime event

* chore: typo

Author: SSebo

example/demo.js

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-const featureProbe = require('../dist/featureprobe-server-sdk-node.min');
+const featureProbe = require('../dist/index.js');
 const pino = require('pino');
 
 const user = new featureProbe.FPUser().with('userId', '00001');
@@ -40,29 +40,30 @@ const FEATURE_PROBE_SERVER_URL = 'https://featureprobe.io/server';  // for featu
 const FEATURE_PROBE_SERVER_SDK_KEY = 'server-9b8b98cf444328ff1280a0757b26ec0abdacba76';  // change me
 
 const fpClient = new featureProbe.FeatureProbe({
-    remoteUrl: FEATURE_PROBE_SERVER_URL,
-    serverSdkKey: FEATURE_PROBE_SERVER_SDK_KEY,
-    refreshInterval: 5000,
-    // logTransport: pino(logToFile)  // uncomment this line to try out pino transport, by default a general pino client will be used
+  remoteUrl: FEATURE_PROBE_SERVER_URL,
+  serverSdkKey: FEATURE_PROBE_SERVER_SDK_KEY,
+  refreshInterval: 5000,
+  // logTransport: pino(logToFile)  // uncomment this line to try out pino transport, by default a general pino client will be used
 });
 
 const main = async () => {
-    // wait until the repo has been initialized
-    // await fpClient.start();
-    // add time limit
-    await fpClient.start(1000);
-    console.log('FeatureProbe evaluation boolean type toggle result is:', fpClient.booleanValue('campaign_allow_list', user, false));
-    console.log('FeatureProbe evaluation boolean type toggle detail is:', fpClient.booleanDetail('campaign_allow_list', user, false));
-    console.log();
-    console.log('FeatureProbe evaluation string type toggle result is:', fpClient.stringValue('string_toggle_key', user, 'default'));
-    console.log('FeatureProbe evaluation string type toggle detail is:', fpClient.stringDetail('string_toggle_key', user, 'default'));
-    console.log();
-    console.log('FeatureProbe evaluation number type toggle result is:', fpClient.numberValue('promotion_campaign', user2, 0));
-    console.log('FeatureProbe evaluation number type toggle detail is:', fpClient.numberDetail('promotion_campaign', user2, 0));
-    console.log();
-    console.log('FeatureProbe evaluation json type toggle result is:', fpClient.jsonValue('json_toggle_key', user, {}));
-    console.log('FeatureProbe evaluation json type toggle detail is:', fpClient.jsonDetail('json_toggle_key', user, {}));
-    await fpClient.close();
+  // wait until the repo has been initialized
+  // await fpClient.start();
+  // add time limit
+  await fpClient.start(1000);
+  console.log('FeatureProbe evaluation boolean type toggle result is:', fpClient.booleanValue('campaign_allow_list', user, false));
+  console.log('FeatureProbe evaluation boolean type toggle detail is:', fpClient.booleanDetail('campaign_allow_list', user, false));
+  console.log();
+  console.log('FeatureProbe evaluation string type toggle result is:', fpClient.stringValue('string_toggle_key', user, 'default'));
+  console.log('FeatureProbe evaluation string type toggle detail is:', fpClient.stringDetail('string_toggle_key', user, 'default'));
+  console.log();
+  console.log('FeatureProbe evaluation number type toggle result is:', fpClient.numberValue('promotion_campaign', user2, 0));
+  console.log('FeatureProbe evaluation number type toggle detail is:', fpClient.numberDetail('promotion_campaign', user2, 0));
+  console.log();
+  console.log('FeatureProbe evaluation json type toggle result is:', fpClient.jsonValue('json_toggle_key', user, {}));
+  console.log('FeatureProbe evaluation json type toggle detail is:', fpClient.jsonDetail('json_toggle_key', user, {}));
+
+  await fpClient.close();
 };
 
 main().then(() => console.log('Enjoy using FeatureProbe!'));

package-lock.json

@@ -68,6 +68,7 @@
     "@types/semver": "^7.3.12",
     "isomorphic-fetch": "^3.0.0",
     "pino": "^7.10.0",
+    "socket.io-client": "^4.5.3",
     "ts-node": "^10.9.1"
   }
 }

package.json

@@ -79,9 +79,9 @@ export class EventRecorder {
   }
 
   constructor(serverSdkKey: string,
-              eventsUrl: URL | string,
-              flushInterval: number,
-              logger?: pino.Logger) {
+    eventsUrl: URL | string,
+    flushInterval: number,
+    logger?: pino.Logger) {
     this._serverSdkKey = serverSdkKey;
     this._eventsUrl = new URL(eventsUrl).toString();
     this._closed = false;
@@ -197,7 +197,7 @@ export class EventRecorder {
 // cred: https://stackoverflow.com/questions/47157428/how-to-implement-a-pseudo-blocking-async-queue-in-js-ts
 class AsyncBlockingQueue<T> {
   private _promises: Promise<T>[];
-  private _resolvers: ( (t: T) => void )[];
+  private _resolvers: ((t: T) => void)[];
 
   constructor() {
     this._resolvers = [];