RHTAP-2547 Add import test

RHTAP-2547 Add import test

Author: jkopriva

README.md

@@ -335,6 +335,8 @@ TESTPLAN_PATH=./custom-testplan.json TESTPLAN_NAME=backend-tests npm test
 
 # Force UI test execution
 ENABLE_UI_TESTS=true npm test
+# Run import template tests (supports all Git providers)
+npm run test:import
 
 # View test report
 npm run test:report
@@ -387,6 +389,10 @@ TESTPLAN_NAME=github-tests npm test
 # Run UI tests
 npm run test:ui
 
+# Run import template tests (supports all Git providers)
+npm run test:import
+
+
 # View test report
 npm run test:report
 

package.json

@@ -12,6 +12,7 @@
         "generate-config": "npx ts-node scripts/generateProjectConfig.ts",
         "test": "npm run generate-config && playwright test",
         "test:e2e": "TESTPLAN_NAME=backend-tests npm run generate-config &&  playwright test",
+        "test:import": "TESTPLAN_NAME=import-tests npm run generate-config &&  playwright test",
         "test:ui": "TESTPLAN_NAME=ui-tests playwright test",
         "test:ui-interactive": "TESTPLAN_NAME=ui-tests playwright test --ui",
         "test:all": "TESTPLAN_NAME=backend-tests npm run generate-config &&  playwright test && TESTPLAN_NAME=ui-tests playwright test",

playwright.config.ts

@@ -15,7 +15,6 @@ declare module '@playwright/test' {
 // Configuration constants
 const DEFAULT_TIMEOUT = 2100000; // 35 minutes
 
-// Environment variable flags to control which tests run
 const DEFAULT_WORKERS = 6;
 const DEFAULT_UI_TIMEOUT = 60000;
 
@@ -83,6 +82,7 @@ try {
 
   let e2eProjects: any[] = [];
   let uiProjects: any[] = [];
+  let importProjects: any[] = [];
   let authProjects: any[] = [];
 
   // Create E2E projects (always created for backend tests)
@@ -187,7 +187,8 @@ try {
   allProjects = [
     ...authProjects,
     ...e2eProjects,
-    ...uiProjects
+    ...uiProjects,
+    ...importProjects
   ];
 
 } catch (error) {

src/api/bitbucket/services/bitbucket-repository.service.ts

@@ -1,5 +1,7 @@
+import retry from 'async-retry';
+import { defaultLogger } from '../../../log/logger';
 import { BitbucketHttpClient } from '../http/bitbucket-http.client';
-import { BitbucketRepository, BitbucketBranch, BitbucketCommit, BitbucketPaginatedResponse } from '../types/bitbucket.types';
+import { BitbucketRepository, BitbucketBranch, BitbucketCommit, BitbucketPaginatedResponse, BitbucketDirectoryEntry } from '../types/bitbucket.types';
 
 export class BitbucketRepositoryService {
   constructor(private readonly httpClient: BitbucketHttpClient) {}
@@ -47,4 +49,122 @@ export class BitbucketRepositoryService {
   public async getFileContent(workspace: string, repoSlug: string, filePath: string, ref: string = 'main'): Promise<string> {
     return this.httpClient.get<string>(`/repositories/${workspace}/${repoSlug}/src/${ref}/${filePath}`);
   }
+
+  public async getDirectoryContent(workspace: string, repoSlug: string, path: string, ref: string = 'main'): Promise<BitbucketDirectoryEntry[]> {
+    // Input validation
+    if (!workspace || workspace.trim() === '') {
+      throw new Error('Workspace is required and cannot be empty');
+    }
+    if (!repoSlug || repoSlug.trim() === '') {
+      throw new Error('Repository slug is required and cannot be empty');
+    }
+    if (!ref || ref.trim() === '') {
+      throw new Error('Reference is required and cannot be empty');
+    }
+
+    const trimmedWorkspace = workspace.trim();
+    const trimmedRepoSlug = repoSlug.trim();
+    const trimmedPath = path.trim();
+    const trimmedRef = ref.trim();
+
+    try {
+      const response = await retry(
+        async () => {
+          return await this.httpClient.get<BitbucketPaginatedResponse<BitbucketDirectoryEntry>>(
+            `/repositories/${trimmedWorkspace}/${trimmedRepoSlug}/src/${trimmedRef}/${trimmedPath}`
+          );
+        },
+        {
+          retries: 3,
+          minTimeout: 1000,
+          maxTimeout: 5000,
+          factor: 2,
+          onRetry: (error: Error, attempt: number) => {
+            defaultLogger.warn({
+              operation: 'getDirectoryContent',
+              workspace: trimmedWorkspace,
+              repoSlug: trimmedRepoSlug,
+              path: trimmedPath,
+              ref: trimmedRef,
+              attempt,
+              error: error.message
+            }, `Retrying directory content retrieval (attempt ${attempt}/3)`);
+          }
+        }
+      );
+
+      // Defensive validation of response
+      if (!response || !Array.isArray(response.values)) {
+        defaultLogger.warn({
+          operation: 'getDirectoryContent',
+          workspace: trimmedWorkspace,
+          repoSlug: trimmedRepoSlug,
+          path: trimmedPath,
+          ref: trimmedRef,
+          responseType: typeof response,
+          hasValues: !!response?.values
+        }, `Invalid response structure for directory content, returning empty array`);
+        return [];
+      }
+
+      defaultLogger.info({
+        operation: 'getDirectoryContent',
+        workspace: trimmedWorkspace,
+        repoSlug: trimmedRepoSlug,
+        path: trimmedPath,
+        ref: trimmedRef,
+        itemCount: response.values.length
+      }, `Successfully retrieved directory content for ${trimmedWorkspace}/${trimmedRepoSlug}/${trimmedPath}`);
+
+      return response.values;
+    } catch (error: any) {
+      // Handle 404 errors gracefully for idempotent operations
+      if (error.response?.status === 404 || error.status === 404 || error.message?.includes('404')) {
+        defaultLogger.info({
+          operation: 'getDirectoryContent',
+          workspace: trimmedWorkspace,
+          repoSlug: trimmedRepoSlug,
+          path: trimmedPath,
+          ref: trimmedRef,
+          status: 'not_found'
+        }, `Directory content not found for ${trimmedWorkspace}/${trimmedRepoSlug}/${trimmedPath} (404 Not Found)`);
+        return [];
+      }
+
+      defaultLogger.error({
+        operation: 'getDirectoryContent',
+        workspace: trimmedWorkspace,
+        repoSlug: trimmedRepoSlug,
+        path: trimmedPath,
+        ref: trimmedRef,
+        error: error.message,
+        status: error.response?.status || error.status
+      }, `Failed to get directory content for ${trimmedWorkspace}/${trimmedRepoSlug}/${trimmedPath}`);
+      throw error;
+    }
+  }
+
+  public async deleteFile(workspace: string, repoSlug: string, filePath: string, branch: string = 'main', commitMessage: string = 'Delete file'): Promise<void> {
+    try {
+      // Bitbucket API requires a commit with file deletion
+      const commitData = {
+        message: commitMessage,
+        branch: branch,
+        files: {
+          [filePath]: null // null value indicates file deletion
+        }
+      };
+      
+      await this.httpClient.post(`/repositories/${workspace}/${repoSlug}/src`, commitData, {
+        headers: {
+          'Content-Type': 'application/x-www-form-urlencoded',
+        },
+      });
+      
+      console.log(`Successfully deleted file ${filePath} from ${workspace}/${repoSlug}`);
+    } catch (error) {
+      console.error(`Failed to delete file ${filePath} from ${workspace}/${repoSlug}:`, error);
+      throw error;
+    }
+  }
 }

src/api/bitbucket/types/bitbucket.types.ts

@@ -85,6 +85,15 @@ export interface BitbucketWebhook {
   events: string[];
 }
 
+export interface BitbucketDirectoryEntry {
+  path: string;
+  type: 'commit_file' | 'commit_directory';
+  size?: number;
+  commit?: {
+    hash: string;
+  };
+}
+
 export interface BitbucketPaginatedResponse<T> {
   values: T[];
   page?: number;