feat: added bitbucket issue integration (#507)

* added bitbucket issue integration * Update task.yml * Update task.ts * Update collection.ts * resolved conflict in integrations.tsx
revertinc · Mar 25, 2024 · ee2ec67 · ee2ec67
1 parent e97e269
commit ee2ec67
Show file tree

Hide file tree

Showing 22 changed files with 691 additions and 5 deletions.
diff --git a/fern/definition/ticket/comment.yml b/fern/definition/ticket/comment.yml
@@ -75,6 +75,8 @@ service:
             request:
                 name: CreateCommentRequest
                 body: CreateOrUpdateCommentRequest
+                query-parameters:
+                    fields: optional<string>
             response: CreateOrUpdateCommentResponse
             errors:
                 - errors.UnAuthorizedError
@@ -89,6 +91,8 @@ service:
             request:
                 name: UpdateCommentRequest
                 body: CreateOrUpdateCommentRequest
+                query-parameters:
+                    fields: optional<string>
             response: CreateOrUpdateCommentResponse
             errors:
                 - errors.UnAuthorizedError

diff --git a/fern/definition/ticket/task.yml b/fern/definition/ticket/task.yml
@@ -74,6 +74,8 @@ service:
             request:
                 name: CreateTaskRequest
                 body: CreateOrUpdateTaskRequest
+                 query-parameters:
+                    fields: optional<string>
             response: CreateOrUpdateTaskResponse
             errors:
                 - errors.UnAuthorizedError
@@ -88,6 +90,8 @@ service:
             request:
                 name: UpdateTaskRequest
                 body: CreateOrUpdateTaskRequest
+                 query-parameters:
+                    fields: optional<string>
             response: CreateOrUpdateTaskResponse
             errors:
                 - errors.UnAuthorizedError

diff --git a/packages/backend/config.ts b/packages/backend/config.ts
@@ -48,6 +48,8 @@ const config = {
     MS_DYNAMICS_SALES_CLIENT_ID: process.env.MS_DYNAMICS_SALES_CLIENT_ID!,
     MS_DYNAMICS_SALES_CLIENT_SECRET: process.env.MS_DYNAMICS_SALES_CLIENT_SECRET!,
     MS_DYNAMICS_SALES_ORG_URL: process.env.MS_DYNAMICS_SALES_ORG_URL!,
+    BITBUCKET_CLIENT_ID: process.env.BITBUCKET_CLIENT_ID!,
+    BITBUCKET_CLIENT_SECRET: process.env.BITBUCKET_CLIENT_SECRET!,
 };
 
 export default config;
diff --git a/packages/backend/constants/common.ts b/packages/backend/constants/common.ts
@@ -3,7 +3,7 @@ import { Request, Response } from 'express';
 
 export type CRM_TP_ID = 'zohocrm' | 'sfdc' | 'pipedrive' | 'hubspot' | 'closecrm' | 'ms_dynamics_365_sales';
 export type CHAT_TP_ID = 'slack' | 'discord';
-export type TICKET_TP_ID = 'linear' | 'clickup' | 'asana' | 'jira' | 'trello';
+export type TICKET_TP_ID = 'linear' | 'clickup' | 'asana' | 'jira' | 'trello' | 'bitbucket';
 
 export const DEFAULT_SCOPE = {
     [TP_ID.hubspot]: [
@@ -48,6 +48,7 @@ export const DEFAULT_SCOPE = {
     [TP_ID.trello]: ['read', 'write'],
     [TP_ID.jira]: ['read:jira-work', 'read:jira-user', 'write:jira-work', 'offline_access'],
     [TP_ID.ms_dynamics_365_sales]: ['offline_access', 'User.Read'],
+    [TP_ID.bitbucket]: ['issue', 'issue:write', 'repository', 'account'],
 };
 
 export const mapIntegrationIdToIntegrationName = {
@@ -64,6 +65,7 @@ export const mapIntegrationIdToIntegrationName = {
     [TP_ID.trello]: 'Trello',
     [TP_ID.jira]: 'Jira',
     [TP_ID.ms_dynamics_365_sales]: 'Microsoft Dynamics 365 Sales',
+    [TP_ID.bitbucket]: 'Bitbucket',
 };
 
 export const rootSchemaMappingId = 'revertRootSchemaMapping';

diff --git a/packages/backend/helpers/crm/transform/disunify.ts b/packages/backend/helpers/crm/transform/disunify.ts
@@ -243,5 +243,29 @@ export async function disunifyTicketObject<T extends Record<string, any>>({
 
             return processedObj;
         }
+        case TP_ID.bitbucket: {
+            if (objType === 'ticketTask') {
+                let priorityId = undefined;
+                if (obj.priority === 'urgent') priorityId = 'blocker';
+                else if (obj.priority === 'high') priorityId = 'critical';
+                else if (obj.priority === 'medium') priorityId = 'major';
+                else if (obj.priority === 'low') priorityId = 'minor';
+                else if (obj.priority === 'lowest') priorityId = 'trivial';
+
+                return {
+                    ...transformedObj,
+                    assignee:
+                        obj.assignees && Array.isArray(obj.assignees) && obj.assignees.length > 0
+                            ? {
+                                  account_id: obj.assignees[0],
+                              }
+                            : undefined,
+                    priority: priorityId ? priorityId : undefined,
+
+                    kind: obj.issueTypeId ? obj.issueTypeId : undefined,
+                };
+            }
+            return processedObj;
+        }
     }
 }
diff --git a/packages/backend/helpers/crm/transform/preprocess.ts b/packages/backend/helpers/crm/transform/preprocess.ts
@@ -249,6 +249,43 @@ export const preprocessUnifyObject = <T extends Record<string, any>>({
                 return { ...obj, assignee: obj.assignee ? [obj.assignee.accountId] : undefined };
             },
         },
+        [TP_ID.bitbucket]: {
+            [TicketStandardObjects.ticketTask]: (obj: T) => {
+                let priority: any;
+                let status: any;
+                if (obj.priority) {
+                    if (obj.priority && obj.priority === 'blocker') priority = 'urgent';
+                    else if (obj.priority && obj.priority === 'critical') priority = 'high';
+                    else if (obj.priority && obj.priority === 'major') priority = 'medium';
+                    else if (obj.priority && obj.priority === 'minor') priority = 'low';
+                    else priority = 'trivial';
+                }
+
+                if (obj.state) {
+                    if (String(obj.state).toLowerCase() === 'new' || String(obj.state).toLowerCase() === 'open')
+                        status = 'open';
+                    else if (
+                        String(obj.state).toLowerCase() === 'wontfix' ||
+                        String(obj.state).toLowerCase() === 'closed' ||
+                        String(obj.state).toLowerCase() === 'invalid' ||
+                        String(obj.state).toLowerCase() === 'onhold' ||
+                        String(obj.state).toLowerCase() === 'duplicate' ||
+                        String(obj.state).toLowerCase() === 'resolved'
+                    )
+                        status = 'closed';
+                    else {
+                        status = String(obj.state);
+                    }
+                }
+
+                return {
+                    ...obj,
+                    assignee: obj.assignee ? [obj.assignee.account_id] : undefined,
+                    state: status,
+                    priority,
+                };
+            },
+        },
     };
     const transformFn = (preprocessMap[tpId] || {})[objType];
     return transformFn ? transformFn(obj) : obj;
@@ -389,6 +426,7 @@ export const postprocessDisUnifyTicketObject = <T extends Record<string, any>>({
         [TP_ID.jira]: {},
         [TP_ID.trello]: {},
         [TP_ID.asana]: {},
+        [TP_ID.bitbucket]: {},
     };
     const transformFn = (preprocessMap[tpId] || {})[objType];
     return transformFn ? transformFn(obj) : obj;

diff --git a/packages/backend/prisma/fields.ts b/packages/backend/prisma/fields.ts
@@ -930,6 +930,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'id',
                 [TP_ID.jira]: 'id',
                 [TP_ID.trello]: 'id',
+                [TP_ID.bitbucket]: 'id',
             },
             target_field_name: 'id',
         },
@@ -939,6 +940,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'id',
                 [TP_ID.jira]: 'id',
                 [TP_ID.trello]: 'id',
+                [TP_ID.bitbucket]: 'id',
             },
             target_field_name: 'remoteId',
         },
@@ -948,6 +950,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'name',
                 [TP_ID.jira]: 'summary',
                 [TP_ID.trello]: 'name',
+                [TP_ID.bitbucket]: 'title',
             },
             target_field_name: 'name',
         },
@@ -957,6 +960,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'assignees',
                 [TP_ID.jira]: 'assignee',
                 [TP_ID.trello]: 'idMembers',
+                [TP_ID.bitbucket]: 'assignee',
             },
             target_field_name: 'assignees',
         },
@@ -966,6 +970,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'description',
                 [TP_ID.jira]: 'description',
                 [TP_ID.trello]: 'desc',
+                [TP_ID.bitbucket]: 'content.raw',
             },
             target_field_name: 'description',
         },
@@ -975,6 +980,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'status',
                 [TP_ID.jira]: 'status.name',
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: 'state',
             },
             target_field_name: 'status',
         },
@@ -984,6 +990,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'priority',
                 [TP_ID.jira]: 'priority.name',
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: 'priority',
             },
             target_field_name: 'priority',
         },
@@ -993,6 +1000,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'creator.id',
                 [TP_ID.jira]: 'creator.accountId',
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: 'reporter.account_id',
             },
             target_field_name: 'creatorId',
         },
@@ -1002,6 +1010,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'date_created',
                 [TP_ID.jira]: 'created',
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: 'created_on',
             },
             target_field_name: 'createdTimeStamp',
         },
@@ -1011,6 +1020,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'date_updated',
                 [TP_ID.jira]: 'updated',
                 [TP_ID.trello]: 'dateLastActivity',
+                [TP_ID.bitbucket]: 'updated_on',
             },
             target_field_name: 'updatedTimeStamp',
         },
@@ -1020,6 +1030,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'due_date',
                 [TP_ID.jira]: 'duedate',
                 [TP_ID.trello]: 'due',
+                [TP_ID.bitbucket]: undefined,
             },
             target_field_name: 'dueDate',
         },
@@ -1029,6 +1040,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'date_done',
                 [TP_ID.jira]: undefined,
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: undefined,
             },
             target_field_name: 'completedDate',
         },
@@ -1038,6 +1050,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'parent',
                 [TP_ID.jira]: 'parent.id',
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: undefined,
             },
             target_field_name: 'parentId',
         },
@@ -1050,6 +1063,7 @@ export const ticketingFields = {
         {
             source_field_name: {
                 [TP_ID.jira]: 'issuetype.id',
+                [TP_ID.bitbucket]: 'kind',
             },
             target_field_name: 'issueTypeId',
         },
@@ -1061,6 +1075,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'id',
                 [TP_ID.jira]: 'accountId',
                 [TP_ID.trello]: 'id',
+                [TP_ID.bitbucket]: 'account_id',
             },
             target_field_name: 'id',
         },
@@ -1070,6 +1085,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'id',
                 [TP_ID.jira]: 'accountId',
                 [TP_ID.trello]: 'id',
+                [TP_ID.bitbucket]: 'account_id',
             },
             target_field_name: 'remoteId',
         },
@@ -1079,6 +1095,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'email',
                 [TP_ID.jira]: 'emailAddress',
                 [TP_ID.trello]: 'email',
+                [TP_ID.bitbucket]: undefined,
             },
             target_field_name: 'email',
         },
@@ -1088,6 +1105,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'username',
                 [TP_ID.jira]: 'displayName',
                 [TP_ID.trello]: 'fullName',
+                [TP_ID.bitbucket]: 'display_name',
             },
             target_field_name: 'name',
         },
@@ -1097,6 +1115,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: undefined,
                 [TP_ID.jira]: 'active',
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: 'account_status',
             },
             target_field_name: 'isActive',
         },
@@ -1106,6 +1125,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'profilePicture',
                 [TP_ID.jira]: 'avatarUrls."48x48"',
                 [TP_ID.trello]: 'avatarUrl',
+                [TP_ID.bitbucket]: 'links.avatar',
             },
             target_field_name: 'avatar',
         },
@@ -1115,6 +1135,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: undefined,
                 [TP_ID.jira]: undefined,
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: 'created_on',
             },
             target_field_name: 'createdTimeStamp',
         },
@@ -1124,6 +1145,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: undefined,
                 [TP_ID.jira]: undefined,
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: undefined,
             },
             target_field_name: 'updatedTimeStamp',
         },
@@ -1133,6 +1155,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: undefined,
                 [TP_ID.jira]: undefined,
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: 'is_staff',
             },
             target_field_name: 'isAdmin',
         },
@@ -1144,6 +1167,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'id',
                 [TP_ID.jira]: 'id',
                 [TP_ID.trello]: 'id',
+                [TP_ID.bitbucket]: 'id',
             },
             target_field_name: 'id',
         },
@@ -1153,6 +1177,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'id',
                 [TP_ID.jira]: 'id',
                 [TP_ID.trello]: 'id',
+                [TP_ID.bitbucket]: 'id',
             },
             target_field_name: 'remoteId',
         },
@@ -1162,6 +1187,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'comment_text',
                 [TP_ID.jira]: 'body',
                 [TP_ID.trello]: 'data.text',
+                [TP_ID.bitbucket]: 'content.raw',
             },
             target_field_name: 'body',
         },
@@ -1171,6 +1197,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'user.id',
                 [TP_ID.jira]: 'author.accountId',
                 [TP_ID.trello]: 'idMemberCreator',
+                [TP_ID.bitbucket]: 'user.account_id',
             },
             target_field_name: 'createdBy',
         },
@@ -1180,6 +1207,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: 'date',
                 [TP_ID.jira]: 'created',
                 [TP_ID.trello]: 'date',
+                [TP_ID.bitbucket]: 'created_on',
             },
             target_field_name: 'createdTimestamp',
         },
@@ -1189,6 +1217,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: undefined,
                 [TP_ID.jira]: 'updated',
                 [TP_ID.trello]: 'data.dateLastEdited',
+                [TP_ID.bitbucket]: 'updated_on',
             },
             target_field_name: 'updatedTimeStamp',
         },
@@ -1198,6 +1227,7 @@ export const ticketingFields = {
                 [TP_ID.clickup]: undefined,
                 [TP_ID.jira]: undefined,
                 [TP_ID.trello]: undefined,
+                [TP_ID.bitbucket]: undefined,
             },
             target_field_name: 'parentId',
         },

diff --git a/packages/backend/prisma/migrations/20240305191556_bitbucket/migration.sql b/packages/backend/prisma/migrations/20240305191556_bitbucket/migration.sql
@@ -0,0 +1,2 @@
+-- AlterEnum
+ALTER TYPE "TP_ID" ADD VALUE 'bitbucket';