add heroku magic

Author: mms-gianni

server-refactored-v3/src/apps/apps.service.ts

@@ -391,6 +391,122 @@ export class AppsService {
     }
   }
 
+  public async getAllAppsList(contextName: string) {
+    this.logger.debug('getAppsList');
+    this.kubectl.setCurrentContext(contextName);
+    const apps = await this.kubectl.getAllAppsList(contextName);
+    const appslist = [] as IApp[];
+    for (const app of apps.items) {
+      appslist.push(app.spec);
+    }
+    return appslist;
+  }
+
+  
+  public async getAppsByRepoAndBranch(repository: string, branch: string) {
+    this.logger.debug('getAppsByBranch: ' + branch);
+
+    const appslist = await this.getAllAppsList(
+      process.env.KUBERO_CONTEXT || 'default',
+    );
+    const apps: IApp[] = [];
+    for (const app of appslist) {
+      if (app.branch === branch && repository === app.gitrepo?.ssh_url) {
+        apps.push(app);
+      }
+    }
+    return apps;
+  }
+  
+
+  // delete a pr app in all pipelines that have review apps enabled and the same ssh_url
+  public async deletePRApp(branch: string, title: string, ssh_url: string) {
+    this.logger.debug('destroyPRApp');
+    const websaveTitle = title.toLowerCase().replace(/[^a-z0-9-]/g, '-'); //TODO improve websave title
+
+
+    const appslist = await this.getAllAppsList(
+      process.env.KUBERO_CONTEXT || 'default',
+    );
+
+    for (const app of appslist) {
+      if (
+        app.phase === 'review' &&
+        app.gitrepo &&
+        app.gitrepo.ssh_url === ssh_url &&
+        app.branch === branch
+      ) {
+        const user = {
+          username: 'unknown',
+        } as IUser;
+
+        this.deleteApp(app.pipeline, app.phase, websaveTitle, user);
+      }
+    }
+  }
+
+  public async rebuildApp(app: IApp) {
+    this.logger.debug(
+      'rebuild App: ' +
+        app.name +
+        ' in ' +
+        app.pipeline +
+        ' phase: ' +
+        app.phase,
+    );
+
+    const contextName = await this.pipelinesService.getContext(
+      app.pipeline,
+      app.phase,
+    );
+
+    if (contextName) {
+      if (
+        app.deploymentstrategy == 'docker' ||
+        app.buildstrategy == undefined ||
+        app.buildstrategy == 'plain'
+      ) {
+        this.kubectl.restartApp(
+          app.pipeline,
+          app.phase,
+          app.name,
+          'web',
+          contextName,
+        );
+        this.kubectl.restartApp(
+          app.pipeline,
+          app.phase,
+          app.name,
+          'worker',
+          contextName,
+        );
+      } else {
+        // rebuild for buildstrategy git/dockerfile or git/nixpacks
+        this.triggerImageBuild(app.pipeline, app.phase, app.name);
+      }
+
+      const m = {
+        name: 'restartApp',
+        user: '',
+        resource: 'app',
+        action: 'restart',
+        severity: 'normal',
+        message:
+          'Rebuild app: ' +
+          app.name +
+          ' in ' +
+          app.pipeline +
+          ' phase: ' +
+          app.phase,
+        pipelineName: app.pipeline,
+        phaseName: app.phase,
+        appName: app.name,
+        data: {},
+      } as INotification;
+      this.NotificationsService.send(m);
+    }
+  }
+
   public async getTemplate(
     pipelineName: string,
     phaseName: string,

server-refactored-v3/src/auth/auth.service.ts

@@ -41,7 +41,7 @@ export class AuthService {
         .update(pass)
         .digest('hex');
       const passwordMatch = await bcrypt.compare(pass, user.password);
-      //if (passwordMatch) { 
+      //if (passwordMatch) {
       if (user.password === password || passwordMatch) {
         const { password, ...result } = user;
         return result;

server-refactored-v3/src/deployments/templates/buildpacks.yaml.ts

@@ -137,4 +137,4 @@ spec:
 #        secret:
 #          defaultMode: 0384
 #          secretName: kubero-pull-secret
-`
+`;

server-refactored-v3/src/deployments/templates/dockerfile.yaml.ts

@@ -122,4 +122,4 @@ spec:
         secret:
           defaultMode: 384
           secretName: kubero-pull-secret
-`;
+`;

server-refactored-v3/src/deployments/templates/nixpacks.yaml.ts

@@ -138,4 +138,4 @@ spec:
         secret:
           defaultMode: 384
           secretName: kubero-pull-secret
-`;
+`;

server-refactored-v3/src/kubernetes/kubernetes.service.ts

@@ -429,6 +429,28 @@ export class KubernetesService {
     return appslist;
   }
 
+  public async getAllAppsList(
+    context: string,
+  ): Promise<IKubectlAppList> {
+    this.kc.setCurrentContext(context);
+    try {
+      const appslist = await this.customObjectsApi.listClusterCustomObject(
+        'application.kubero.dev',
+        'v1alpha1',
+        'kuberoapps',
+
+      );
+      return appslist.body as IKubectlAppList;
+    } catch (error) {
+      //this.logger.debug(error);
+      this.logger.debug('getAppsList: error getting apps');
+    }
+    const appslist = {} as IKubectlAppList;
+    appslist.items = [];
+    return appslist;
+  }
+
+
   public async restartApp(
     pipelineName: string,
     phaseName: string,
@@ -1454,13 +1476,13 @@ export class KubernetesService {
     let job = '';
     switch (jobname) {
       case 'buildpacks':
-        job = buildpacksTemplate
+        job = buildpacksTemplate;
         break;
       case 'dockerfile':
-        job = dockerfileTemplate
+        job = dockerfileTemplate;
         break;
       case 'nixpacks':
-        job = nixpacksTemplate
+        job = nixpacksTemplate;
         break;
       default:
         break;

server-refactored-v3/src/repo/repo.controller.ts

@@ -1,4 +1,12 @@
-import { Body, Controller, Get, Param, Post, UseGuards } from '@nestjs/common';
+import {
+  Body,
+  Controller,
+  Get,
+  Param,
+  Post,
+  Req,
+  UseGuards,
+} from '@nestjs/common';
 import { RepoService } from './repo.service';
 import {
   ApiBearerAuth,
@@ -182,7 +190,13 @@ export class RepoController {
     required: true,
     enum: ['github', 'gitlab', 'bigbucket', 'gitea', 'gogs'],
   })
-  async repositoryWebhook(@Body() body: any) {
-    return 'Not implemented';
+  async repositoryWebhook(
+    @Param('provider') provider: string,
+    @Body() body: any,
+    @Req() req: Request,
+  ) {
+    const ret: string = 'ok';
+    this.repoService.handleWebhook(provider, req.headers, body);
+    return ret;
   }
 }

server-refactored-v3/src/repo/repo.interface.ts

@@ -5,3 +5,15 @@ export interface IDeployKeyPair {
   privKey: string;
   privKeyBase64: string;
 }
+export interface IWebhook {
+  repoprovider: 'gitea' | 'gitlab' | 'github' | 'bitbucket' | 'gogs' | 'onedev';
+  action: 'opened' | 'reopened' | 'closed' | undefined;
+  event: string;
+  delivery: string;
+  body: any;
+  branch: string;
+  verified: boolean;
+  repo: {
+    ssh_url: string;
+  };
+}

server-refactored-v3/src/repo/repo.module.ts

@@ -1,9 +1,10 @@
 import { Module } from '@nestjs/common';
 import { RepoController } from './repo.controller';
 import { RepoService } from './repo.service';
+import { AppsService } from 'src/apps/apps.service';
 
 @Module({
   controllers: [RepoController],
-  providers: [RepoService],
+  providers: [RepoService, AppsService],
 })
 export class RepoModule {}