GetConfigurationWebhookActivityStatus impl

Author: filiptronicek

components/server/src/api/configuration-service-api.ts

@@ -15,6 +15,8 @@ import {
     DeleteConfigurationRequest,
     DeleteConfigurationResponse,
     GetConfigurationRequest,
+    GetConfigurationWebhookActivityStatusRequest,
+    GetConfigurationWebhookActivityStatusResponse,
     ListConfigurationsRequest,
     ListConfigurationsResponse,
     PrebuildSettings,
@@ -30,6 +32,8 @@ import { SortOrder } from "@gitpod/public-api/lib/gitpod/v1/sorting_pb";
 import { Project } from "@gitpod/gitpod-protocol";
 import { DeepPartial } from "@gitpod/gitpod-protocol/lib/util/deep-partial";
 import { ContextService } from "../workspace/context-service";
+import { PrebuildManager } from "../prebuilds/prebuild-manager";
+import { Timestamp } from "@bufbuild/protobuf";
 
 function buildUpdateObject<T extends Record<string, any>>(obj: T): Partial<T> {
     const update: Partial<T> = {};
@@ -58,6 +62,8 @@ export class ConfigurationServiceAPI implements ServiceImpl<typeof Configuration
         private readonly userService: UserService,
         @inject(ContextService)
         private readonly contextService: ContextService,
+        @inject(PrebuildManager)
+        private readonly prebuildManager: PrebuildManager,
     ) {}
 
     async createConfiguration(
@@ -238,4 +244,27 @@ export class ConfigurationServiceAPI implements ServiceImpl<typeof Configuration
 
         return new DeleteConfigurationResponse();
     }
+
+    async getConfigurationWebhookActivityStatus(req: GetConfigurationWebhookActivityStatusRequest, _: HandlerContext) {
+        if (!req.configurationId) {
+            throw new ApplicationError(ErrorCodes.BAD_REQUEST, "configuration_id is required");
+        }
+
+        const configuration = await this.projectService.getProject(ctxUserId(), req.configurationId);
+        if (!configuration) {
+            throw new ApplicationError(ErrorCodes.NOT_FOUND, "configuration not found");
+        }
+        const user = await this.userService.findUserById(ctxUserId(), ctxUserId());
+        const event = await this.prebuildManager.getRecentWebhookEvent({}, user, configuration);
+
+        const resp = new GetConfigurationWebhookActivityStatusResponse({
+            isWebhookActive: event !== undefined,
+            latestWebhookEvent: {
+                commit: event?.commit,
+                creationTime: event?.creationTime ? Timestamp.fromDate(new Date(event.creationTime)) : undefined,
+            },
+        });
+
+        return resp;
+    }
 }

components/server/src/prebuilds/prebuild-manager.ts

@@ -4,7 +4,7 @@
  * See License.AGPL.txt in the project root for license information.
  */
 
-import { DBWithTracing, TracedWorkspaceDB, WorkspaceDB } from "@gitpod/gitpod-db/lib";
+import { DBWithTracing, TracedWorkspaceDB, WebhookEventDB, WorkspaceDB } from "@gitpod/gitpod-db/lib";
 import {
     CommitContext,
     CommitInfo,
@@ -16,6 +16,7 @@ import {
     StartPrebuildResult,
     TaskConfig,
     User,
+    WebhookEvent,
     Workspace,
     WorkspaceConfig,
     WorkspaceInstance,
@@ -75,6 +76,7 @@ export class PrebuildManager {
         @inject(ContextParser) private contextParser: ContextParser,
         @inject(IAnalyticsWriter) private readonly analytics: IAnalyticsWriter,
         @inject(RedisSubscriber) private readonly subscriber: RedisSubscriber,
+        @inject(WebhookEventDB) private readonly webhookEventDb: WebhookEventDB,
     ) {}
 
     private async findNonFailedPrebuiltWorkspace(ctx: TraceContext, projectId: string, commitSHA: string) {
@@ -115,6 +117,42 @@ export class PrebuildManager {
         }, opts);
     }
 
+    /**
+     * getRecentWebhookEvent checks if the webhook integration is active for the given user and project by querying the webhook event database and seeing if for any of the latest n commits a webhook event exists.
+     */
+    public async getRecentWebhookEvent(
+        ctx: TraceContext,
+        user: User,
+        project: Project,
+    ): Promise<WebhookEvent | undefined> {
+        const context = (await this.contextParser.handle(ctx, user, project.cloneUrl)) as CommitContext;
+        const maxDepth = 15;
+
+        const events = await this.webhookEventDb.findByCloneUrl(project.cloneUrl, maxDepth);
+        if (events.length === 0) {
+            // return undefined;
+        }
+
+        const hostContext = this.hostContextProvider.get(context.repository.host);
+        const repoProvider = hostContext?.services?.repositoryProvider;
+        if (!repoProvider) {
+            throw new ApplicationError(ErrorCodes.INTERNAL_SERVER_ERROR, `repository provider not found`);
+        }
+        const history = await repoProvider.getCommitHistory(
+            user,
+            context.repository.owner,
+            context.repository.name,
+            context.revision,
+            maxDepth,
+        );
+        if (!history) {
+            throw new ApplicationError(ErrorCodes.NOT_FOUND, `commit history not found`);
+        }
+        const matchingEvent = events.find((event) => history.find((commit) => commit === event.commit));
+
+        return matchingEvent;
+    }
+
     public async *getAndWatchPrebuildStatus(
         userId: string,
         filter: {