fix(no-ignored-replay-buffer): check if bufferSize is set in config o…

…ption for shareReplay

Fixes cartant#100

source/rules/no-ignored-replay-buffer.ts

@@ -3,7 +3,10 @@
  * can be found in the LICENSE file at https://github.com/cartant/eslint-plugin-rxjs
  */
 
-import { TSESTree as es } from "@typescript-eslint/experimental-utils";
+import {
+  AST_NODE_TYPES,
+  TSESTree as es,
+} from "@typescript-eslint/experimental-utils";
 import { getParent } from "eslint-etc";
 import { ruleCreator } from "../utils";
 
@@ -56,6 +59,24 @@ const rule = ruleCreator({
       ) => {
         const callExpression = getParent(node) as es.CallExpression;
         checkNode(node, callExpression);
+
+        const shareReplayConfig = callExpression.arguments[0];
+
+        if (shareReplayConfig?.type === AST_NODE_TYPES.ObjectExpression) {
+          const bufferSizeProp = shareReplayConfig.properties.find(
+            (p) =>
+              p.type === AST_NODE_TYPES.Property &&
+              p.key.type === AST_NODE_TYPES.Identifier &&
+              p.key.name === "bufferSize"
+          );
+
+          if (!bufferSizeProp) {
+            context.report({
+              messageId: "forbidden",
+              node,
+            });
+          }
+        }
       },
     };
   },

tests/rules/no-ignored-replay-buffer.ts

@@ -127,6 +127,16 @@ ruleTester({ types: false }).run("no-ignored-replay-buffer", rule, {
                                  ~~~~~~~~~~~ [forbidden]
       `
     ),
+    fromFixture(
+      stripIndent`
+        // namespace shareReplay ignored
+        import * as Rx from "rxjs";
+        import { shareReplay } from "rxjs/operators";
+
+        const a = Rx.of(42).pipe(shareReplay({ refCount: 1 }));
+                                 ~~~~~~~~~~~ [forbidden]
+      `
+    ),
     fromFixture(
       stripIndent`
         // namespace class ignored