feat: Added Enhancements in Bubble io import

Author: Mayur

apps/api/src/app/shared/constants.ts

@@ -42,6 +42,9 @@ export const APIMessages = {
   ONBOARD_TEMPLATE_SHEET_NOT_FOUND: 'No sheets found in the workbook',
   ONBOARD_TEMPLATE_FILE_EMPTY: 'File is empty or invalid',
   ONBOARD_TEMPLATE_FILE_EMPTY_RECORDS: 'The file contains empty records',
+
+  INVALID_API_RESPONSE_STRUCTURE: `Invalid API response structure. Please recheck the URL and ensure the API is correctly configured to return data.`,
+  DATATYPE_EMPTY: `The datatype appears to be empty. Please add at least one entry and verify the URL points to the correct data source.`,
 };
 
 export const CONSTANTS = {

apps/api/src/app/shared/services/bubble-io.service.ts

@@ -3,6 +3,7 @@ import { Injectable } from '@nestjs/common';
 import { BubbleBaseService } from '@impler/services';
 import { BubbleDestinationEntity } from '@impler/dal';
 import { ColumnTypesEnum, DEFAULT_KEYS_OBJ, IColumn } from '@impler/shared';
+import { APIMessages } from '@shared/constants';
 
 interface IThingsResponse {
   response: {
@@ -17,13 +18,19 @@ interface IThingsResponse {
 export class BubbleIoService extends BubbleBaseService {
   async getDatatypeData(data: Omit<BubbleDestinationEntity, '_id' | '_templateId'>) {
     try {
-      const response = await axios.get<IThingsResponse>(data.bubbleAppUrl, {
+      const response = await axios.get<IThingsResponse>(this.createBubbleIoUrl(data.bubbleAppUrl), {
         headers: {
           Authorization: `Bearer ${data.apiPrivateKey}`,
         },
       });
-      if (!response.data.response.results.length)
-        throw new Error('Datatype is empty. Please add at least one entry to the datatype');
+
+      if (!Array.isArray(response.data.response.results)) {
+        throw new Error(APIMessages.INVALID_API_RESPONSE_STRUCTURE);
+      }
+
+      if (response.data.response.results.length === 0) {
+        throw new Error(APIMessages.DATATYPE_EMPTY);
+      }
 
       return response.data.response.results;
     } catch (error: unknown) {

apps/queue-manager/src/consumers/send-bubble-data.consumer.ts

@@ -142,7 +142,23 @@ export class SendBubbleDataConsumer extends BaseConsumer {
     const templateData = await this.templateRepository.findById(uploadata._templateId, 'name');
 
     const bubbleDestination = await this.bubbleDestinationRepository.findOne({ _templateId: uploadata._templateId });
-    const bubbleUrl = bubbleDestination.bubbleAppUrl;
+    let bubbleUrl = bubbleDestination?.bubbleAppUrl;
+
+    if (
+      !bubbleUrl &&
+      'baseUrl' in bubbleDestination &&
+      'datatype' in bubbleDestination &&
+      bubbleDestination.baseUrl &&
+      bubbleDestination.datatype
+    ) {
+      const baseUrl = bubbleDestination.baseUrl as string;
+      bubbleUrl = `${baseUrl}/api/1.1/obj/${bubbleDestination.datatype}`;
+    }
+
+    // If still no URL, return null as we can't proceed without a valid URL
+    if (!bubbleUrl) {
+      return null;
+    }
 
     const defaultValueObj = {};
     const customSchema = JSON.parse(uploadata.customSchema) as ITemplateSchemaItem;

apps/web/components/imports/destination/Destination.tsx

@@ -147,7 +147,13 @@ export function Destination({ template }: DestinationProps) {
             <Input
               required
               label="Bubble App URL"
-              placeholder="Bubble App URL"
+              placeholder="https://acme.in/api/1.1/obj/customers"
+              description={
+                <>
+                  <div>Example with default domain: https://your-app.bubbleapps.io/api/1.1/obj/your-datatype</div>
+                  <div>Example with custom domain: https://yourapp.com/api/1.1/obj/your-datatype</div>
+                </>
+              }
               {...register('bubbleIo.bubbleAppUrl')}
               error={errors?.bubbleIo?.bubbleAppUrl?.message}
             />

apps/widget/src/hooks/Phase3/usePhase3.tsx

@@ -196,7 +196,7 @@ export function usePhase3({ onNext }: IUsePhase3Props) {
         setTotalPages(reviewDataResponse.totalPages);
       },
       onError(error: IErrorObject) {
-        notifier.showError({ message: 'Hellow World', title: error.error });
+        notifier.showError({ message: error.message, title: error.error });
       },
     }
   );