Feature/add bitbucket implementation

client/src/components/pipelines/new.vue

@@ -36,7 +36,7 @@
             <v-tab href="#gitlab" :disabled="this.repositoriesList.gitlab == false">Gitlab <v-icon>mdi-gitlab</v-icon></v-tab>
             <v-tab href="#onedev" disabled>oneDev <v-icon class="onedev"></v-icon></v-tab>
             <v-tab href="#gogs" :disabled="this.repositoriesList.gogs == false">Gogs <v-icon class="gogs"></v-icon></v-tab>
-            <v-tab href="#bitbucket" disabled>Bitbucket <v-icon>mdi-bitbucket</v-icon></v-tab>
+            <v-tab href="#bitbucket" :disabled="this.repositoriesList.bitbucket == false">Bitbucket <v-icon>mdi-bitbucket</v-icon></v-tab>
         </v-tabs>
         </v-col>
       </v-row>
@@ -311,24 +311,20 @@ export default {
             break;
           case 'gitlab':
             this.connectRepository('gitlab')
-            return;
-            /*
-            this.repositoriesList.gitea = false;
             this.repositoriesList.github = false;
+            this.repositoriesList.gitea = false;
+            this.repositoriesList.gogs = false;
             this.repositoriesList.bitbucket = false;
             this.repositoriesList.docker = false;
-            break;
-            */
-          case 'bitbucket':
-            this.connectBitbucket();
             return;
-            /*
+          case 'bitbucket':
+            this.connectRepository('bitbucket')
+            this.repositoriesList.github = false;
             this.repositoriesList.gitea = false;
             this.repositoriesList.gitlab = false;
-            this.repositoriesList.github = false;
+            this.repositoriesList.gogs = false;
             this.repositoriesList.docker = false;
-            break;
-            */
+            return;
           default:
             break;
         }

package.json

@@ -19,6 +19,7 @@
     "@octokit/core": "^3.6.0",
     "@octokit/webhooks": "^9.26.0",
     "axios": "^0.27.2",
+    "bitbucket": "^2.9.0",
     "connect-history-api-fallback": "^1.6.0",
     "cors": "^2.8.5",
     "cross-fetch": "^3.1.5",

src/git/bitbucket.ts

@@ -0,0 +1,288 @@
+import debug from 'debug';
+import * as crypto from "crypto"
+import { IWebhook, IRepository, IWebhookR, IDeploykeyR} from './types';
+import { Repo } from './repo';
+debug('app:kubero:bitbucket:api')
+
+//const { Octokit } = require("@octokit/core");
+import { Bitbucket, APIClient } from "bitbucket"
+import { RequestError } from '@octokit/types';
+
+export class BitbucketApi extends Repo {
+    private bitbucket: APIClient;
+
+    constructor(username: string, appPassword: string) {
+        super("bitbucket");
+        const clientOptions = {
+            auth: {
+                username: username,
+                password: appPassword
+            },
+        }
+
+         this.bitbucket = new Bitbucket(clientOptions)
+    }
+
+    protected async getRepository(gitrepo: string): Promise<IRepository> {
+        let ret: IRepository = {
+            status: 500,
+            statusText: 'error',
+            data: {
+                owner: 'unknown',
+                name: 'unknown',
+                admin: false,
+                push: false,
+            }
+        }
+
+        // TODO : Improve matching here
+        let owner = gitrepo.match(/^git@bitbucket.org:(.*)\/.*$/)?.[1] as string;
+        let repo = gitrepo.match(/^git@bitbucket.org:.*\/(.*).git$/)?.[1] as string;
+
+        console.log(owner, repo);
+        try {
+            // https://bitbucketjs.netlify.app/#api-repositories-repositories_get
+            let res = await this.bitbucket.repositories.get({
+                repo_slug: repo,
+                workspace: owner
+            })
+            console.log(res.data);
+
+            ret = {
+                status: res.status,
+                statusText: 'found',
+                data: {
+                    id: res.data.uuid,
+                    node_id: res.data.full_name as string,
+                    name: res.data.slug as string,
+                    description: res.data.description,
+                    owner: res.data.owner?.nickname as string,
+                    private : res.data.is_private,
+                    ssh_url: res.data.links?.clone?.find((c: any) => c.name === 'ssh')?.href as string,
+                    clone_url: res.data.links?.clone?.find((c: any) => c.name === 'https')?.href as string,
+                    language: res.data.language,
+                    homepage: res.data.website as string,
+                    admin: true, // assumed since we ar loading only owned repos
+                    push: true, // assumed since we ar loading only owned repos
+                    //visibility: res.data.visibility,
+                    default_branch: res.data.mainbranch?.name as string,
+                }
+            }
+
+        } catch (e) {
+            let res = e as RequestError;
+            debug.log("Repository not found: "+ gitrepo);
+            ret = {
+                status: res.status,
+                statusText: 'not found',
+                data: {
+                    owner: owner,
+                    name: repo,
+                    admin: false,
+                    push: false,
+                }
+            }
+        }
+        return ret;
+    }
+
+    public async getRepositories() {
+        let res = await this.bitbucket.request('GET /user/repos', {})
+        return res.data;
+    }
+
+    protected async addWebhook(owner: string, repo: string, url: string, secret: string): Promise<IWebhookR> {
+
+        let ret: IWebhookR = {
+            status: 500,
+            statusText: 'error',
+            data: {
+                id: 0,
+                active: false,
+                created_at: '2020-01-01T00:00:00Z',
+                url: '',
+                insecure: true,
+                events: [],
+            }
+        }
+
+
+        let webhooksList = await this.bitbucket.repositories.listWebhooks({
+            repo_slug: repo,
+            workspace: owner
+        })
+
+        let webhook = webhooksList.data.values?.find((w: any) => w.url === url);
+        if (webhook == undefined) {
+            try {
+                let res = await this.bitbucket.repositories.createWebhook({
+                    repo_slug: repo,
+                    workspace: owner,
+                    _body: {
+                        description: "Kubero webhook",
+                        url: url,
+                        active: true,
+                        //skip_cert_verification: false,
+                        events: ["pullrequest:created", "repo:push"]
+                    }
+                })
+                ret = {
+                    status: 201,
+                    statusText: 'created',
+                    data: {
+                        id: res.data.uuid as string,
+                        active: res.data.active as boolean,
+                        created_at: res.data.created_at as string,
+                        url: res.data.url as string,
+                        insecure: !res.data.skip_cert_verification as boolean,
+                        events: res.data.events as string[],
+                    }
+                }
+            } catch (e) {
+                console.log(e)
+            }
+        } else {
+            console.log("Webhook already exists")
+            console.log(webhook)
+
+            ret = {
+                status: 422,
+                statusText: 'created',
+                data: {
+                    id: webhook.uuid as string,
+                    active: webhook.active as boolean,
+                    created_at: webhook.created_at as string,
+                    url: webhook.url as string,
+                    insecure: !webhook.skip_cert_verification as boolean,
+                    events: webhook.events as string[],
+                }
+            }
+
+        }
+
+        return ret;
+    }
+
+    protected async addDeployKey(owner: string, repo: string): Promise<IDeploykeyR> {
+
+        const keyPair = this.createDeployKeyPair();
+
+        let ret: IDeploykeyR = {
+            status: 500,
+            statusText: 'error',
+            data: {
+                id: 0,
+                title: "bot@kubero",
+                verified: false,
+                created_at: '2020-01-01T00:00:00Z',
+                url: '',
+                read_only: true,
+                pub: keyPair.pubKeyBase64,
+                priv: keyPair.privKeyBase64
+            }
+        }
+
+        try {
+            // https://bitbucketjs.netlify.app/#api-repositories-repositories_createDeployKey
+            let res = await this.bitbucket.repositories.createDeployKey({
+                label: "bot@kubero",
+                key: keyPair.pubKey,
+                repo_slug: repo,
+                workspace: owner
+            });
+
+            console.log(res);
+
+
+            ret = {
+                status: res.status,
+                statusText: 'created',
+                data: {
+                    id: res.data.id as number,
+                    title: res.data.label as string,
+                    verified: true,
+                    created_at: res.data.created_on as string,
+                    url: '',
+                    read_only: false,
+                    pub: keyPair.pubKeyBase64,
+                    priv: keyPair.privKeyBase64
+                }
+            }
+        } catch (e) {
+            let res = e as RequestError;
+            debug.log("Error adding deploy key: "+ res);
+        }
+
+        return ret
+    }
+
+    public getWebhook(event: string, delivery: string, body: any): IWebhook | boolean {
+
+        // use github and gitea naming for the event
+        let github_event = event;
+        if (event === 'repo:push') {
+            github_event = 'push';
+        } else if (event === 'pullrequest:created') {
+            github_event = 'pull_request';
+        } else {
+            debug.log('ERROR: untranslated Bitbucket event: '+event);
+            return false;
+        }
+
+        let branch: string = 'main';
+        let ssh_url: string = '';
+        let action;
+        if (body.ref != undefined) {
+            let ref = body.ref
+            let refs = ref.split('/')
+            branch = refs[refs.length - 1]
+            ssh_url = body.repository.ssh_url
+        } else if (body.pull_request != undefined) {
+            action = body.action,
+            branch = body.pull_request.head.ref
+            ssh_url = body.pull_request.head.repo.ssh_url
+        } else {
+            ssh_url = body.repository.ssh_url
+        }
+
+        try {
+            let webhook: IWebhook = {
+                repoprovider: 'bitbucket',
+                action: action,
+                event: github_event,
+                delivery: delivery,
+                body: body,
+                branch: branch,
+                verified: true, // bitbucket does not support verification with signatures :(
+                repo: {
+                    ssh_url: ssh_url,
+                }
+            }
+
+            return webhook;
+        } catch (error) {
+            debug.log(error)
+            return false;
+        }
+    }
+
+    public async listRepos(): Promise<string[]> {
+        let ret: string[] = [];
+        try {
+            // https://bitbucketjs.netlify.app/#api-repositories-repositories_listGlobal
+            const repos = await this.bitbucket.repositories.listGlobal({ role: 'member' })
+
+            if (repos.data.values != undefined) {
+                for (let repo of repos.data.values) {
+                    if (repo.links != undefined && repo.links.clone != undefined) {
+                        ret.push(repo.links.clone[1].href as string);
+                    }
+                }
+            }
+
+        } catch (error) {
+            debug.log(error)
+        }
+        return ret;
+    }
+}

src/git/types.ts

@@ -15,7 +15,7 @@ export interface IRepository {
     status: number,
     statusText: 'error' | 'not found' | 'found',
     data: {
-        id?: number,
+        id?: number | string, // bitbucket uses UUID's
         node_id?: string,
         name: string,
         description?: string,
@@ -36,7 +36,7 @@ export interface IWebhookR {
     status: number,
     statusText: 'error' | 'created' | 'not found' | 'found',
     data: {
-        id?: number,
+        id?: number | string, // bitbucket uses UUID's
         active: boolean,
         created_at: string,
         url: string,