Pubsub new tests e2e #35

priyabhatnagar25 · 2024-01-10T04:27:08Z

No description provided.

itsmekumari · 2024-01-10T07:12:16Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+# the License.
+
+@PubSub_Source
+Feature: PubSub Source - Verification of PubSub to PubSub successful data transfer in different formats.


Verification of successful data transfer from DataStream PubSub source to PubSub sink using different file formats.

changed to above

itsmekumari · 2024-01-10T07:14:01Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+    Then Connect plugins: "Pub/Sub" and "Pub/Sub2" to establish connection
+    Then Navigate to the properties page of plugin: "Pub/Sub"
+    Then Override Service account details if set in environment variables
+    Then Enter input plugin property: "referenceName" with value: "BQReferenceName"


Why is this BQReferenceName? Use relevant value as per plugin which is used.

itsmekumari · 2024-01-10T07:20:34Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+    Then Enter PubSub source property topic name
+    Then Validate "Pub/Sub" plugin properties
+    And Close the Plugin Properties page
+    Then Open the PubSub sink properties


Use the latest steps from framework, update the steps with latest framework steps wherever required. Like here use step---- Navigate to the properties page of plugin: "Pub/Sub". Change in all the scenarios.

Changed wherever needed

itsmekumari · 2024-01-10T07:29:17Z

src/e2e-test/java/io/cdap/plugin/pubsub/stepsdesign/PubSubSource.java

@@ -33,6 +42,32 @@ public void sourceIsPubSub() {

  @Then("Open the PubSub source properties")
  public void openThePubSubSourceProperties() {
-    openSourcePluginProperties("GooglePublisher");
+    openSourcePluginProperties("pubsub");


This change is not required if latest framework steps are used. Please check and revert.

Reverted the change

itsmekumari · 2024-01-10T09:45:50Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+    try {
+      publisher = Publisher.newBuilder(topicName).build();
+
+//      List<String> messages = Arrays.asList("first message", "second message");


Remove commented code, if not required.

itsmekumari · 2024-01-10T10:21:17Z

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

@@ -1141,7 +1179,7 @@ public static void createSinkBQDedupeTable() throws IOException, InterruptedExce

  @Before(value = "@BQ_INSERT_INT_SOURCE_TEST")
  public static void createSourceBQTable() throws IOException, InterruptedException {
-    bqSourceTable = "E2E_TARGET_" + UUID.randomUUID().toString().replaceAll("-", "_");
+    bqSourceTable = "E2E_SOURCE_" + UUID.randomUUID().toString().replaceAll("-", "_");


Why are we changing BQ related in Pubsub

rahuldash171 · 2024-01-10T12:43:46Z

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

@@ -1141,7 +1179,7 @@ public static void createSinkBQDedupeTable() throws IOException, InterruptedExce

  @Before(value = "@BQ_INSERT_INT_SOURCE_TEST")
  public static void createSourceBQTable() throws IOException, InterruptedException {
-    bqSourceTable = "E2E_TARGET_" + UUID.randomUUID().toString().replaceAll("-", "_");
+    bqSourceTable = "E2E_SOURCE_" + UUID.randomUUID().toString().replaceAll("-", "_");


What is this change regarding ?

rahuldash171 · 2024-01-10T12:46:07Z

src/e2e-test/java/io/cdap/plugin/pubsub/stepsdesign/PubSubSink.java

+  @Then("Subscribe to the messages")
+  public void subscribeToTheMessages() throws InterruptedException {
+    TimeUnit time = TimeUnit.SECONDS;
+    time.sleep(60);


it will hault the code execution , can we use implicit wait ?

We have to use it, otherwise steps run very fast and they fail

rahuldash171 · 2024-01-10T12:54:55Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+      // Allow the subscriber to run for 30s unless an unrecoverable error occurs.
+      subscriber.awaitTerminated(200, TimeUnit.SECONDS);
+    } catch (TimeoutException timeoutException) {
+      // Shut down the subscriber after 30s. Stop receiving messages.


are these commented lines needed in this file ?

yes , its some description about the code

Also I do not see any runner file for these tests , how are we executing them ? is runner file not needed ?

rahuldash171 · 2024-01-10T12:58:59Z

src/e2e-test/java/io/cdap/plugin/pubsub/stepsdesign/PubSubSource.java

+  @Then("Publish the messages")
+  public void publishTheMessage() throws IOException, InterruptedException {
+    TimeUnit time = TimeUnit.SECONDS;
+    time.sleep(120);


time.sleep will hault the program ,

itsmekumari · 2024-01-10T16:17:13Z

src/e2e-test/java/io/cdap/plugin/pubsub/stepsdesign/PubSubSource.java

+
+  @Then("Enter PubSub source property topic name")
+  public void enterPubSubSourcePropertyTopicName() {
+    PubSubActions.enterPubSubTopic(TestSetupHooks.pubSubSourceTopic); }


Add one line space.

itsmekumari · 2024-01-10T16:19:32Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+    Then Wait for pipeline to be in status: "Running" with a timeout of 240 seconds
+    Then Publish the messages
+    Then Subscribe to the messages
+    Then Validate OUT record count is equal to IN record count


Can add validation step to validate the message content. Common step to be added for all the scenarios.

No we cannot add and validation step to check the message content, this is asynchronous transfer and it will not always send messages properly as already discussed with rahul

itsmekumari · 2024-01-10T16:27:43Z

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

+    pubSubSourceSubscription = "cdf-e2e-test-" + UUID.randomUUID();
+    PubSubClient.createSubscription(pubSubSourceSubscription , pubSubSourceTopic);
+    BeforeActions.scenario.write("Source PubSub subscription " + pubSubSourceSubscription);
+  }


Add a one line space.

itsmekumari · 2024-01-10T16:29:29Z

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

+    PubSubClient.createSubscription(pubSubSourceSubscription , pubSubSourceTopic);
+    BeforeActions.scenario.write("Source PubSub subscription " + pubSubSourceSubscription);
+  }
+  @After(order = 1, value = "@PUBSUB_SOURCE_TESTt")


Cross check the Hook name used on scenarios, remove extra 't' letter in hooks if not present.

removed , used only to run scenarios

itsmekumari · 2024-01-10T16:30:16Z

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

+                                                pubSubSourceTopic, dataMessagesList);
+  }
+
+


remove extra line.

itsmekumari · 2024-01-10T16:34:24Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+       subscriptionName = ProjectSubscriptionName.of
+         (PluginPropertyUtils.pluginProp(ConstantsUtil.PROJECT_ID), subscriptionId);
+      subscriptionAdminClient.createSubscription(subscriptionName, topicName, PushConfig.getDefaultInstance(), 60);
+      System.out.println("Subscription created: " + subscriptionName.toString());


Remove system.out.println line. Use logger

used logger

itsmekumari · 2024-01-10T16:35:14Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+      System.out.println("Subscription created: " + subscriptionName.toString());
+    } catch (AlreadyExistsException e) {
+      assert subscriptionName != null;
+      System.out.println("Subscription already exists: " + subscriptionName.toString());


Remove system.out.println line. Use logger

used logger

itsmekumari · 2024-01-10T16:39:08Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+                if (throwable instanceof ApiException) {
+                  ApiException apiException = ((ApiException) throwable);
+                   // details on the API exception
+                   System.out.println(apiException.getStatusCode().getCode());


Remove and use logger. Cross check and remove wherever present.

removed from everywhere

itsmekumari · 2024-01-10T16:43:29Z

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

+    BeforeActions.scenario.write("Source PubSub topic " + pubSubSourceTopic);
+  }
+
+  @Before(order = 1, value = "@PUBSUB_SUBSCRIPTION_TEST")


Add the After hook for the Subscription as well.

itsmekumari · 2024-01-10T16:50:25Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+@PubSub_Source
+Feature: PubSub Source - Verification of PubSub to PubSub successful data transfer in different formats.
+
+  @PUBSUB_SOURCE_TEST @PUBSUB_SINK_TEST @PUBSUB_SUBSCRIPTION_TEST @PUBSUB_MESSAGE_TEST


Where is @PUBSUB_MESSAGE_TEST hook details in TestSetupHooks file?

Removed the hook,

itsmekumari · 2024-01-10T16:54:03Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+# License for the specific language governing permissions and limitations under
+# the License.
+
+@PubSub_Source


Where is the TestRunner file changes for PubSub Source feature? Please add the TestRunner File for PubSub Source tests having PubSub_Source tag.

which runner file? pubsub is already added in the runner file

In existing, It has only the runner file for sink, add runner file for source as well to execute the tests, as because you are using @PubSub_Source tag. Without this how the tests are running? Please add the runner file for source.

Changed the tag name , added in runner file aswell

itsmekumari · 2024-01-10T17:02:27Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+# License for the specific language governing permissions and limitations under
+# the License.
+
+@PubSub_Source


Also, Add the Relevant Folder name like 'PubSubDataStream'

Changed to above

rahuldash171 · 2024-01-11T07:04:15Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+    MessageReceiver receiver =
+        (PubsubMessage message, AckReplyConsumer consumer) -> {
+          // Handle incoming message, then ack the received message.
+          System.out.println("Id: " + message.getMessageId());


use logger for println and printf

Changed to logger

itsmekumari · 2024-01-11T07:04:50Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+      subscriber = Subscriber.newBuilder(subscriptionName, receiver).build();
+      // Start the subscriber.
+      subscriber.startAsync().awaitRunning();
+      System.out.printf("Listening for messages on %s:\n", subscriptionName.toString());


Don't use Sysout printf in code. Use logger

bharatgulati · 2024-01-11T07:39:47Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+    Then Save the pipeline
+    Then Deploy the pipeline
+    Then Run the Pipeline in Runtime
+    Then Wait for pipeline to be in status: "Running" with a timeout of 240 seconds


Do we really need the timeout of 240 seconds for runtime pipelines?

Yes we do after the pipeline runs for this much time only then we are sending the messages

bharatgulati · 2024-01-11T07:41:13Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+      Then Navigate to the properties page of plugin: "Pub/Sub"
+      Then Override Service account details if set in environment variables
+      Then Enter input plugin property: "referenceName" with value: "BQReferenceName"
+      Then Click on the Macro button of Property: "topic" and set the value to: "PubSubSourceTopic"


can we rename it to pubSubSourceTopic, pubSubSourceSubscription?

Changed the name

bharatgulati · 2024-01-11T07:44:57Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+      Then Verify the pipeline status is "Stopped"
+
+  @PUBSUB_SOURCE_TEST @PUBSUB_SINK_TEST @PUBSUB_SUBSCRIPTION_TEST @PUBSUB_MESSAGE_TEST
+  Scenario: Validate successful transfer of records from PubSub(source) to PubSub(sink)  having formats TEXT at both source and sink.


Validate the successful transfer of records from a pubSub source to a pubSub sink with format Text at both source and sink.

Changed to above

bharatgulati · 2024-01-11T07:46:30Z

src/e2e-test/features/pubsub/pubsubadditionalfeature/PubSubToPubSub.feature

+    Then Verify the pipeline status is "Stopped"
+
+  @PUBSUB_SOURCE_TEST @PUBSUB_SINK_TEST @PUBSUB_SUBSCRIPTION_TEST @PUBSUB_MESSAGE_TEST
+  Scenario: Validate successful transfer of records from PubSub(source) to PubSub(sink)  having formats TEXT at source and JSON at sink.


Validate the successful transfer of records from a pubSub source to a pubSub sink with format Text at source and Json at sink.

Changed to above

bharatgulati · 2024-01-11T07:55:56Z

src/e2e-test/resources/pluginParameters.properties

+pubSubSourceSubscription=dummy
+pubSubSourceTopic=dummy
+firstMessage=hellomessage
+secondMessage=himessage


bharatgulati · 2024-01-11T07:56:04Z

src/e2e-test/resources/pluginParameters.properties

@@ -243,6 +243,10 @@ pubSubErrorThreshold=0
 pubSubStringValue=one
 pubSubNegativeValue=-100
 pubsubDelimiter=@
+pubSubSourceSubscription=dummy
+pubSubSourceTopic=dummy
+firstMessage=hellomessage


helloMessage

bharatgulati · 2024-01-11T08:05:29Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

@@ -36,6 +56,22 @@ public static Topic createTopic(String topicId) throws IOException {
    }
  }

+  // Create the subscription


Add the relevant comment under this
/**
Describe the function.
*/

bharatgulati · 2024-01-11T08:09:23Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+      TopicName topicName = TopicName.of(PluginPropertyUtils.pluginProp(ConstantsUtil.PROJECT_ID), topicId);
+       subscriptionName = ProjectSubscriptionName.of
+         (PluginPropertyUtils.pluginProp(ConstantsUtil.PROJECT_ID), subscriptionId);
+      subscriptionAdminClient.createSubscription(subscriptionName, topicName, PushConfig.getDefaultInstance(), 60);


Why do we need 60 int value?

its for deadline acknowlodgement

bharatgulati · 2024-01-11T08:11:12Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+         (PluginPropertyUtils.pluginProp(ConstantsUtil.PROJECT_ID), subscriptionId);
+      subscriptionAdminClient.createSubscription(subscriptionName, topicName, PushConfig.getDefaultInstance(), 60);
+      System.out.println("Subscription created: " + subscriptionName.toString());
+    } catch (AlreadyExistsException e) {


Can you try with StatusRuntimeException

it works with this only for messaging

bharatgulati · 2024-01-11T08:16:23Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+      subscriptionAdminClient.createSubscription(subscriptionName, topicName, PushConfig.getDefaultInstance(), 60);
+      System.out.println("Subscription created: " + subscriptionName.toString());
+    } catch (AlreadyExistsException e) {
+      assert subscriptionName != null;


Add
if ("ALREADY_EXISTS".equals(e.getStatus().getCode().name())) {
use logger and print this("Subscription already exists: {}", subscriptionName.toString());
} else {
use logger and print ("Error creating subscription", e)
}

added the above code

bharatgulati · 2024-01-11T08:21:45Z

src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java

+      pubSubSourceTopic = StringUtils.EMPTY;
+    } catch (Exception e) {
+      if (e.getMessage().contains("Invalid resource name given") || e.getMessage().contains("Resource not found")) {
+


Complete the catch block

catch (Exception e) { if (e.getMessage().contains("Invalid resource name given") || e.getMessage().contains("Resource not found")) { BeforeActions.scenario.write("Source PubSub topic " + pubSubSourceTopic + " does not exist."); } else { Assert.fail(e.getMessage()); } }

completed the catch block

bharatgulati · 2024-01-11T08:24:56Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+
+  public static void publishWithErrorHandlerExample(String projectId, String topicId, List<String> dataMessages)
+      throws IOException, InterruptedException {
+    TopicName topicName = TopicName.of(PluginPropertyUtils.pluginProp(ConstantsUtil.PROJECT_ID), topicId);


Can we use the projectId Variable from the parameter?

this code was already used before and its taking project id from plugin properties inly

bharatgulati · 2024-01-15T09:13:29Z

src/test/java/io/cdap/plugin/gcp/bigquery/BigQueryRecordToJsonTest.java

@@ -422,6 +422,58 @@ public void testJsonStringWithEmptyArray() throws IOException {
    }
  }

+  @Test
+  public void testJsonStringWithStringArray() throws IOException {


why we have added unit tests?

bharatgulati · 2024-01-16T05:13:59Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+                ApiException apiException = ((ApiException) throwable);
+                /**
+                 * details on the API exception.
+                 */


Fix indentation and line spacing

bharatgulati · 2024-01-16T05:14:58Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+
+  public static void subscribeAsyncExample(String projectId, String subscriptionId) {
+    ProjectSubscriptionName subscriptionName = ProjectSubscriptionName.of(PluginPropertyUtils.pluginProp
+      (ConstantsUtil.PROJECT_ID), subscriptionId);


use projectId from the function parameter

bharatgulati · 2024-01-16T05:16:04Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+      subscriber.awaitTerminated(200, TimeUnit.SECONDS);
+    } catch (TimeoutException timeoutException) {
+      /**
+       * Shut down the subscriber after 30s. Stop receiving messages.


add logger to print the timeout exception in the catch block

added the logger

bharatgulati · 2024-01-16T05:16:26Z

src/test/java/io/cdap/plugin/gcp/bigquery/BigQueryRecordToJsonTest.java

+      writer.beginObject();
+      for (Schema.Field recordField : Objects.requireNonNull(record.getSchema().getFields())) {
+        if (recordSchema.getField(recordField.getName()) != null) {
+          BigQueryRecordToJson.write(writer, recordField.getName(), record.get(recordField.getName()),


Revert this file.

bharatgulati · 2024-01-16T05:17:47Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java


 /**
 * Represents PubSub client.
 */
 public class PubSubClient {

+  private static final Logger logger = LoggerFactory.getLogger(SeleniumDriver.class);


Why there is SeleniumDriver.class in the Logger var?

Changed to pubsub client class

bharatgulati · 2024-01-16T05:18:58Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

@@ -56,4 +101,92 @@ public static String getTopicCmekKey(String topicId) throws IOException {
    return getTopic(topicId).getKmsKeyName();
  }

+
+  public static void publishWithErrorHandlerExample(String projectId, String topicId, List<String> dataMessages)


change the function name to something more relatable, try removing example from the method name

publishMessagesWithPubSub

bharatgulati · 2024-01-16T05:24:48Z

src/e2e-test/java/io/cdap/plugin/utils/PubSubClient.java

+  public static void publishWithErrorHandlerExample(String projectId, String topicId, List<String> dataMessages)
+    throws IOException, InterruptedException {
+    TopicName topicName = TopicName.of(projectId, topicId);
+    Publisher publisher = null;


Instead of creating a new Publisher instance for each message, can you reuse the same Publisher instance for all messages. Creating a Publisher is an expensive operation, and reusing it can significantly improve performance.

Or do we have the After hook for the publisher where it delete it every time?

As Discussed we already have the after hooks for deletion of topics and subscription

Added BQ Retry

priyabhatnagar25 requested review from bharatgulati and itsmekumari January 10, 2024 04:34

itsmekumari reviewed Jan 10, 2024

View reviewed changes

rahuldash171 reviewed Jan 10, 2024

View reviewed changes

itsmekumari reviewed Jan 10, 2024

View reviewed changes

rahuldash171 reviewed Jan 11, 2024

View reviewed changes

itsmekumari reviewed Jan 11, 2024

View reviewed changes

bharatgulati reviewed Jan 11, 2024

View reviewed changes

bharatgulati reviewed Jan 15, 2024

View reviewed changes

bharatgulati reviewed Jan 16, 2024

View reviewed changes

priyabhatnagar25 and others added 8 commits January 16, 2024 15:41

bq additional scenarios

9108fee

pubsub cases

678d82a

Added BQ Execute Action job label support

53549c2

Added BQ Execute Retry

9148b65

Added BQ Retry

pubsub to pubsub e2e scenarios

db990e6

Added BQ Execute Action job label support

c8ffc86

Added BQ Execute Retry

3eea7c5

Added BQ Retry

change file

f5807a5

priyabhatnagar25 force-pushed the pubsub_new_tests_e2e branch from 3b4478e to f5807a5 Compare January 16, 2024 10:50

NavdeepCS force-pushed the develop branch 4 times, most recently from fc2efdf to 5f4f137 Compare March 1, 2024 06:20

vikasrathee-cs force-pushed the develop branch from 5f4f137 to 008f3a8 Compare March 1, 2024 06:27

Pubsub new tests e2e #35

Are you sure you want to change the base?

Pubsub new tests e2e #35

Conversation

priyabhatnagar25 commented Jan 10, 2024

itsmekumari Jan 10, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

itsmekumari Jan 10, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

itsmekumari Jan 10, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

itsmekumari Jan 10, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

itsmekumari Jan 10, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

itsmekumari Jan 11, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

bharatgulati Jan 11, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

bharatgulati Jan 11, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

itsmekumari Jan 10, 2024 •

edited

Loading

itsmekumari Jan 10, 2024 •

edited

Loading

itsmekumari Jan 10, 2024 •

edited

Loading

itsmekumari Jan 10, 2024 •

edited

Loading

itsmekumari Jan 10, 2024 •

edited

Loading

itsmekumari Jan 11, 2024 •

edited

Loading

bharatgulati Jan 11, 2024 •

edited

Loading

bharatgulati Jan 11, 2024 •

edited

Loading