Merge pull request #34 from diggerhq/feat/trigger-apply-button

Trigger apply button

Author: ZIJ

src/app/(dynamic-pages)/(authenticated-pages)/(application-pages)/project/[projectSlug]/(specific-project-pages)/TriggerApplyButton.tsx

@@ -0,0 +1,36 @@
+'use client'
+
+import { Button } from "@/components/Button";
+import { triggerApplyAction } from "@/data/user/projects";
+import { useSAToastMutation } from "@/hooks/useSAToastMutation";
+
+export function TriggerApplyButton({ projectId }: { projectId: string }) {
+
+    const triggerApplyMutation = useSAToastMutation(
+        async () => {
+            const result = await triggerApplyAction({
+                projectId: projectId,
+            });
+            return result;
+        },
+        {
+            loadingMessage: "Triggering apply...",
+            successMessage: "Apply run scheduled successfully!",
+            errorMessage: "Failed to schedule Apply run",
+        }
+    );
+
+    const onClick = async () => {
+        try {
+            await triggerApplyMutation.mutateAsync();
+        } catch (error) {
+            console.error("Error updating project settings:", error);
+        }
+    };
+
+    return (
+        <Button variant="default" onClick={onClick} size="sm">
+            Trigger Apply
+        </Button>
+    )
+}

src/app/(dynamic-pages)/(authenticated-pages)/(application-pages)/project/[projectSlug]/(specific-project-pages)/layout.tsx

@@ -6,14 +6,15 @@ import { projectSlugParamSchema } from "@/utils/zod-schemas/params";
 import { AlertCircleIcon, ExternalLink, GitBranch } from "lucide-react";
 import Link from "next/link";
 import { Suspense } from "react";
+import { TriggerApplyButton } from "./TriggerApplyButton";
 
 
 async function ProjectPageHeading({ projectId, branch }: { projectId: string, branch: string | null }) {
   const projectTitle = await getProjectTitleById(projectId);
   return (
     <PageHeading
       title={projectTitle}
-      subTitle={<p className="flex items-center"><GitBranch /> {branch || 'main'}</p>}
+      subTitle={<span className="flex items-center"><GitBranch /> {branch || 'main'}</span>}
     />
   );
 }
@@ -25,8 +26,6 @@ export default async function ProjectPagesLayout({ params, children }: { params:
   const projectId = (await getSlimProjectBySlug(projectSlug)).id;
   const project = await getProjectById(projectId);
 
-
-
   const tabs = [
     {
       label: 'Runs',
@@ -60,8 +59,13 @@ export default async function ProjectPagesLayout({ params, children }: { params:
       )}
 
       <Suspense>
-        <ProjectPageHeading projectId={project.id} branch={project.branch} />
+        <div className="flex justify-between items-center space-y-4 max-w-5xl">
+          <ProjectPageHeading projectId={project.id} branch={project.branch} />
+          <TriggerApplyButton projectId={project.id} />
+        </div>
       </Suspense>
+
+
       <Suspense>
         <TabsNavigationV2 tabs={tabs} />
       </Suspense>

src/data/user/projects.tsx

@@ -956,4 +956,35 @@ export async function deleteProject(projectId: string): Promise<SAPayload<unknow
   }
 
   return { status: 'success', data };
+}
+
+export async function triggerApplyAction({ projectId }: { projectId: string }): Promise<SAPayload<unknown>> {
+  const triggerApplyUrl = process.env.DIGGER_TRIGGER_APPLY_URL;
+  const webhookSecret = process.env.DIGGER_WEBHOOK_SECRET;
+  if (!triggerApplyUrl) {
+    throw new Error('DIGGER_TRIGGER_APPLY_URL env variable is not set');
+  }
+  if (!webhookSecret) {
+    throw new Error('DIGGER_WEBHOOK_SECRET env variable is not set');
+  }
+
+  const user = await serverGetLoggedInUser();
+  const payload = {
+    user_id: user.id,
+    project_id: projectId,
+  }
+  const response = await fetch(
+    triggerApplyUrl,
+    {
+      method: 'POST',
+      body: JSON.stringify(payload),
+      headers: {
+        Authorization: `Bearer ${webhookSecret}`,
+      },
+    },
+  );
+  if (!response.ok) {
+    throw new Error(`Digger api responded with status: ${response.status}`);
+  }
+  return { status: 'success', data: {} };
 }