feat: add bitbucket cloud support

Signed-off-by: Adam Setch <[email protected]>

Author: setchy

src/utils/api/client.ts

@@ -24,7 +24,7 @@ import type {
 } from '../../typesGitHub';
 import { QUERY_SEARCH_DISCUSSIONS } from './graphql/discussions';
 import { formatAsGitHubSearchSyntax } from './graphql/utils';
-import { apiRequestAuth } from './request';
+import { apiRequestAuth, apiRequestBitbucket } from './request';
 import { getGitHubAPIBaseUrl, getGitHubGraphQLUrl } from './utils';
 
 /**
@@ -69,6 +69,24 @@ export function listNotificationsForAuthenticatedUser(
   return apiRequestAuth(url.toString() as Link, 'GET', account.token);
 }
 
+/**
+ * List all notifications for the current user, sorted by most recently updated.
+ *
+ * Endpoint documentation: https://docs.github.com/en/rest/activity/notifications#list-notifications-for-the-authenticated-user
+ */
+export function listBitbucketWork(
+  account: Account,
+): AxiosPromise<Notification[]> {
+  const url = `${account.hostname}/overview-view-state?fields=pullRequestFilters.*,pullRequests.authored.links.html,-pullRequests.authored.extra.*`;
+
+  return apiRequestBitbucket(
+    url.toString() as Link,
+    'GET',
+    account.user.login,
+    account.token,
+  );
+}
+
 /**
  * Marks a thread as "read." Marking a thread as "read" is equivalent to
  * clicking a notification in your notification inbox on GitHub.

src/utils/api/request.ts

@@ -24,3 +24,17 @@ export function apiRequestAuth(
   axios.defaults.headers.common['Content-Type'] = 'application/json';
   return axios({ method, url, data });
 }
+
+export function apiRequestBitbucket(
+  url: Link,
+  method: Method,
+  username: string,
+  token: Token,
+  data = {},
+): AxiosPromise | null {
+  axios.defaults.headers.common.Accept = 'application/json';
+  axios.defaults.headers.common.Authorization = `Basic ${btoa(`${username}:${token}`)}`;
+  axios.defaults.headers.common['Cache-Control'] = 'no-cache';
+  axios.defaults.headers.common['Content-Type'] = 'application/json';
+  return axios({ method, url, data });
+}

src/utils/notifications.ts

@@ -5,7 +5,10 @@ import type {
   SettingsState,
 } from '../types';
 import { Notification } from '../typesGitHub';
-import { listNotificationsForAuthenticatedUser } from './api/client';
+import {
+  listBitbucketWork,
+  listNotificationsForAuthenticatedUser,
+} from './api/client';
 import { determineFailureType } from './api/errors';
 import { getAccountUUID } from './auth/utils';
 import { hideWindow, showWindow, updateTrayIcon } from './comms';
@@ -116,7 +119,7 @@ function getNotifications(state: GitifyState) {
       account,
       notifications:
         account.platform === 'Bitbucket Cloud'
-          ? null
+          ? listBitbucketWork(account)
           : listNotificationsForAuthenticatedUser(account, state.settings),
     };
   });
@@ -132,22 +135,28 @@ export async function getAllNotifications(
       .filter((response) => !!response)
       .map(async (accountNotifications) => {
         try {
-          let notifications = (
-            await accountNotifications.notifications
-          ).data.map((notification: Notification) => ({
-            ...notification,
-            account: accountNotifications.account,
-          }));
-
-          notifications = await enrichNotifications(notifications, state);
-
-          notifications = filterNotifications(notifications, state.settings);
-
-          return {
-            account: accountNotifications.account,
-            notifications: notifications,
-            error: null,
-          };
+          if (accountNotifications.account.platform === 'Bitbucket Cloud') {
+            console.log(
+              JSON.stringify(await accountNotifications.notifications),
+            );
+          } else {
+            let notifications = (
+              await accountNotifications.notifications
+            ).data.map((notification: Notification) => ({
+              ...notification,
+              account: accountNotifications.account,
+            }));
+
+            notifications = await enrichNotifications(notifications, state);
+
+            notifications = filterNotifications(notifications, state.settings);
+
+            return {
+              account: accountNotifications.account,
+              notifications: notifications,
+              error: null,
+            };
+          }
         } catch (error) {
           log.error(
             'Error occurred while fetching account notifications',