feat: add labels to projects

raghavyuva · raghavyuva · commit 871021e601f0 · 2025-09-18T20:57:53.000+05:30
diff --git a/api/api/versions.json b/api/api/versions.json
@@ -3,7 +3,7 @@
     {
       "version": "v1",
       "status": "active",
-      "release_date": "2025-08-21T22:58:05.772340699+05:30",
+      "release_date": "2025-09-02T19:27:36.312579047+05:30",
       "end_of_life": "0001-01-01T00:00:00Z",
       "changes": [
         "Initial API version"
diff --git a/api/doc/openapi.json b/api/doc/openapi.json
diff --git a/api/go.mod b/api/go.mod
@@ -18,6 +18,7 @@ require (
 	github.com/moby/term v0.5.2
 	github.com/opencontainers/image-spec v1.1.1
 	github.com/pkg/sftp v1.13.5
+	github.com/raghavyuva/caddygo v0.0.0-20250820132249-3db4bc273996
 	github.com/shirou/gopsutil/v3 v3.24.5
 	github.com/sirupsen/logrus v1.9.3
 	github.com/slack-go/slack v0.16.0
@@ -85,9 +86,6 @@ require (
 	github.com/gabriel-vasile/mimetype v1.4.8 // indirect
 	github.com/go-jose/go-jose/v3 v3.0.4 // indirect
 	github.com/go-jose/go-jose/v4 v4.1.2 // indirect
-	github.com/go-kit/kit v0.13.0 // indirect
-	github.com/go-kit/log v0.2.1 // indirect
-	github.com/go-logfmt/logfmt v0.6.0 // indirect
 	github.com/go-logr/logr v1.4.3 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/go-ole/go-ole v1.2.6 // indirect
@@ -105,7 +103,7 @@ require (
 	github.com/golang/snappy v1.0.0 // indirect
 	github.com/google/cel-go v0.26.0 // indirect
 	github.com/google/go-cmp v0.7.0 // indirect
-	github.com/google/pprof v0.0.0-20250630185457-6e76a2b096b5 // indirect
+	github.com/google/pprof v0.0.0-20241210010833-40e02aabc2ad // indirect
 	github.com/google/s2a-go v0.1.9 // indirect
 	github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect
 	github.com/googleapis/gax-go/v2 v2.15.0 // indirect
@@ -116,14 +114,8 @@ require (
 	github.com/inconshreveable/mousetrap v1.1.0 // indirect
 	github.com/itchyny/gojq v0.12.5 // indirect
 	github.com/itchyny/timefmt-go v0.1.3 // indirect
-	github.com/jackc/chunkreader/v2 v2.0.1 // indirect
-	github.com/jackc/pgconn v1.14.3 // indirect
-	github.com/jackc/pgio v1.0.0 // indirect
 	github.com/jackc/pgpassfile v1.0.0 // indirect
-	github.com/jackc/pgproto3/v2 v2.3.3 // indirect
 	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
-	github.com/jackc/pgtype v1.14.4 // indirect
-	github.com/jackc/pgx/v4 v4.18.3 // indirect
 	github.com/jackc/puddle/v2 v2.2.2 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/josharian/intern v1.0.0 // indirect
@@ -158,7 +150,7 @@ require (
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
 	github.com/oasdiff/yaml v0.0.0-20250309154309-f31be36b4037 // indirect
 	github.com/oasdiff/yaml3 v0.0.0-20250309153720-d2182401db90 // indirect
-	github.com/onsi/ginkgo/v2 v2.24.0 // indirect
+	github.com/onsi/ginkgo/v2 v2.23.3 // indirect
 	github.com/onsi/gomega v1.37.0 // indirect
 	github.com/opencontainers/go-digest v1.0.0 // indirect
 	github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58 // indirect
@@ -173,8 +165,7 @@ require (
 	github.com/prometheus/procfs v0.17.0 // indirect
 	github.com/puzpuzpuz/xsync/v3 v3.5.1 // indirect
 	github.com/quic-go/qpack v0.5.1 // indirect
-	github.com/quic-go/quic-go v0.54.0 // indirect
-	github.com/raghavyuva/caddygo v0.0.0-20250820132249-3db4bc273996 // indirect
+	github.com/quic-go/quic-go v0.50.1 // indirect
 	github.com/rs/xid v1.6.0 // indirect
 	github.com/russross/blackfriday/v2 v2.1.0 // indirect
 	github.com/shoenig/go-m1cpu v0.1.6 // indirect
@@ -211,11 +202,8 @@ require (
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.35.0 // indirect
 	go.opentelemetry.io/otel/metric v1.37.0 // indirect
 	go.opentelemetry.io/otel/trace v1.37.0 // indirect
-	go.step.sm/cli-utils v0.9.0 // indirect
 	go.step.sm/crypto v0.69.0 // indirect
-	go.step.sm/linkedca v0.22.2 // indirect
 	go.uber.org/automaxprocs v1.6.0 // indirect
-	go.uber.org/goleak v1.3.0 // indirect
 	go.uber.org/mock v0.6.0 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
 	go.uber.org/zap v1.27.0 // indirect
diff --git a/api/go.sum b/api/go.sum
diff --git a/api/internal/features/deploy/controller/application_labels.go b/api/internal/features/deploy/controller/application_labels.go
@@ -0,0 +1,77 @@
+package controller
+
+import (
+	"net/http"
+
+	"github.com/go-fuego/fuego"
+	"github.com/google/uuid"
+	"github.com/raghavyuva/nixopus-api/internal/features/logger"
+	"github.com/raghavyuva/nixopus-api/internal/types"
+	"github.com/raghavyuva/nixopus-api/internal/utils"
+)
+
+type UpdateLabelsRequest struct {
+	Labels []string `json:"labels" validate:"required"`
+}
+
+func (c *DeployController) UpdateApplicationLabels(f fuego.ContextWithBody[UpdateLabelsRequest]) (*types.Response, error) {
+	data, err := f.Body()
+	if err != nil {
+		c.logger.Log(logger.Error, "failed to read request body", err.Error())
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusBadRequest,
+		}
+	}
+
+	applicationID := f.QueryParam("id")
+	if applicationID == "" {
+		c.logger.Log(logger.Error, "application id is required", "")
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusBadRequest,
+		}
+	}
+
+	user := utils.GetUser(f.Response(), f.Request())
+	if user == nil {
+		c.logger.Log(logger.Error, "user not found", "")
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusUnauthorized,
+		}
+	}
+
+	organizationID := utils.GetOrganizationID(f.Request())
+	if organizationID == uuid.Nil {
+		c.logger.Log(logger.Error, "organization not found", "")
+		return nil, fuego.HTTPError{
+			Err:    nil,
+			Status: http.StatusUnauthorized,
+		}
+	}
+
+	appID, err := uuid.Parse(applicationID)
+	if err != nil {
+		c.logger.Log(logger.Error, "invalid application id", err.Error())
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusBadRequest,
+		}
+	}
+
+	err = c.service.UpdateApplicationLabels(appID, data.Labels, organizationID)
+	if err != nil {
+		c.logger.Log(logger.Error, err.Error(), "")
+		return nil, fuego.HTTPError{
+			Err:    err,
+			Status: http.StatusInternalServerError,
+		}
+	}
+
+	return &types.Response{
+		Status:  "success",
+		Message: "Labels updated successfully",
+		Data:    data.Labels,
+	}, nil
+}
diff --git a/api/internal/features/deploy/service/application_labels.go b/api/internal/features/deploy/service/application_labels.go
@@ -0,0 +1,9 @@
+package service
+
+import (
+	"github.com/google/uuid"
+)
+
+func (s *DeployService) UpdateApplicationLabels(applicationID uuid.UUID, labels []string, organizationID uuid.UUID) error {
+	return s.storage.UpdateApplicationLabels(applicationID, labels, organizationID)
+}
diff --git a/api/internal/features/deploy/storage/init.go b/api/internal/features/deploy/storage/init.go
@@ -7,6 +7,7 @@ import (
 
 	"github.com/google/uuid"
 	"github.com/uptrace/bun"
+	"github.com/uptrace/bun/dialect/pgdialect"
 
 	"github.com/raghavyuva/nixopus-api/internal/features/deploy/types"
 	shared_types "github.com/raghavyuva/nixopus-api/internal/types"
@@ -41,6 +42,7 @@ type DeployRepository interface {
 	GetDeploymentLogs(deploymentID string, page, pageSize int, level string, startTime, endTime time.Time, searchTerm string) ([]shared_types.ApplicationLogs, int, error)
 	GetApplicationByRepositoryID(repositoryID uint64) (shared_types.Application, error)
 	GetApplicationByRepositoryIDAndBranch(repositoryID uint64, branch string) ([]shared_types.Application, error)
+	UpdateApplicationLabels(applicationID uuid.UUID, labels []string, organizationID uuid.UUID) error
 }
 
 func (s *DeployStorage) IsNameAlreadyTaken(name string) (bool, error) {
@@ -422,3 +424,13 @@ func (s *DeployStorage) GetApplicationByRepositoryIDAndBranch(repositoryID uint6
 
 	return applications, nil
 }
+
+func (s *DeployStorage) UpdateApplicationLabels(applicationID uuid.UUID, labels []string, organizationID uuid.UUID) error {
+	_, err := s.DB.NewUpdate().
+		Model((*shared_types.Application)(nil)).
+		Set("labels = ?", pgdialect.Array(labels)).
+		Set("updated_at = CURRENT_TIMESTAMP").
+		Where("id = ? AND organization_id = ?", applicationID, organizationID).
+		Exec(s.Ctx)
+	return err
+}
diff --git a/api/internal/routes.go b/api/internal/routes.go
@@ -360,6 +360,7 @@ func (router *Router) DeployApplicationRoutes(f *fuego.Server, deployController
 	fuego.Get(f, "/logs/{application_id}", deployController.GetLogs)
 	fuego.Get(f, "/deployments/{deployment_id}/logs", deployController.GetDeploymentLogs)
 	fuego.Get(f, "/deployments", deployController.GetApplicationDeployments)
+	fuego.Put(f, "/labels", deployController.UpdateApplicationLabels)
 }
 
 func (router *Router) FileManagerRoutes(f *fuego.Server, fileManagerController *file_manager.FileManagerController) {
diff --git a/api/internal/types/application.go b/api/internal/types/application.go
@@ -33,6 +33,7 @@ type Application struct {
 	Logs                 []*ApplicationLogs       `json:"logs,omitempty" bun:"rel:has-many,join:id=application_id"`
 	Deployments          []*ApplicationDeployment `json:"deployments,omitempty" bun:"rel:has-many,join:id=application_id"`
 	Organization         *Organization            `json:"organization,omitempty" bun:"rel:belongs-to,join:organization_id=id"`
+	Labels               []string                 `json:"labels,omitempty" bun:"labels,array"`
 }
 
 type ApplicationDeployment struct {
diff --git a/api/migrations/applications/034_add_labels_to_applications_down.sql b/api/migrations/applications/034_add_labels_to_applications_down.sql
@@ -0,0 +1,2 @@
+ALTER TABLE applications DROP COLUMN IF EXISTS labels;
+DROP INDEX IF EXISTS idx_applications_labels;
diff --git a/api/migrations/applications/034_add_labels_to_applications_up.sql b/api/migrations/applications/034_add_labels_to_applications_up.sql
@@ -0,0 +1,2 @@
+ALTER TABLE applications ADD COLUMN IF NOT EXISTS labels TEXT[] DEFAULT '{}';
+CREATE INDEX IF NOT EXISTS idx_applications_labels ON applications USING GIN(labels);
diff --git a/view/app/self-host/application/[id]/page.tsx b/view/app/self-host/application/[id]/page.tsx
@@ -11,7 +11,7 @@ import ApplicationDetailsHeader from '../../components/application-details/heade
 import { useTranslation } from '@/hooks/use-translation';
 import { ResourceGuard } from '@/components/rbac/PermissionGuard';
 import { Skeleton } from '@/components/ui/skeleton';
-import PageLayout from '@/components/layout/page-layout';
+import Labels from '../../components/application-details/labels';
 
 function Page() {
   const { t } = useTranslation();
@@ -36,8 +36,18 @@ function Page() {
       action="read"
       loadingFallback={<Skeleton className="h-96" />}
     >
-      <PageLayout maxWidth="6xl" padding="md" spacing="lg">
+      <div className="container mx-auto py-6 space-y-8 max-w-4xl 2xl:max-w-7xl">
         <ApplicationDetailsHeader application={application} />
+            <Labels
+            applicationId={application?.id || ''}
+            labels={application?.labels || []}
+            onLabelsChange={(labels) => {
+              if (application) {
+                application.labels = labels;
+              }
+            }}
+            isEditable={true}
+          />
         <Tabs defaultValue={defaultTab} className="w-full">
           <TabsList>
             <TabsTrigger value="monitoring">{t('selfHost.application.tabs.monitoring')}</TabsTrigger>
@@ -86,7 +96,7 @@ function Page() {
             <Monitor application={application} />
           </TabsContent>
         </Tabs>
-      </PageLayout>
+      </div>
     </ResourceGuard>
   );
 }
diff --git a/view/app/self-host/components/application-details/header.tsx b/view/app/self-host/components/application-details/header.tsx
@@ -1,6 +1,7 @@
 'use client';
 import React from 'react';
 import { Button } from '@/components/ui/button';
+import { Badge } from '@/components/ui/badge';
 import { ExternalLink, MoreVertical, RotateCcw, TrashIcon } from 'lucide-react';
 import {
   DropdownMenu,
@@ -83,6 +84,19 @@ const ApplicationDetailsHeader = ({ application }: { application?: Application }
                 <ExternalLink className="h-5 w-5" />
               </Button>
             </div>
+            {application?.labels && application.labels.length > 0 && (
+              <div className="flex flex-wrap gap-2 mt-3">
+                {application.labels.map((label, index) => (
+                  <Badge
+                    key={index}
+                    variant="secondary"
+                    className="text-sm px-3 py-1"
+                  >
+                    {label}
+                  </Badge>
+                ))}
+              </div>
+            )}
           </div>
         </div>
         <div className="flex items-center gap-2">
diff --git a/view/app/self-host/components/application-details/labels.tsx b/view/app/self-host/components/application-details/labels.tsx
@@ -0,0 +1,95 @@
+'use client';
+import React, { useEffect, useRef, useState } from 'react';
+import { Input } from '@/components/ui/input';
+import { Plus } from 'lucide-react';
+import { Badge } from '@/components/ui/badge';
+import { useUpdateApplicationLabelsMutation } from '@/redux/services/deploy/applicationsApi';
+
+interface LabelsProps {
+	applicationId: string;
+	labels?: string[];
+	onLabelsChange?: (labels: string[]) => void;
+	isEditable?: boolean;
+}
+
+export default function Labels({ applicationId, labels = [], onLabelsChange, isEditable = true }: LabelsProps) {
+	const [localLabels, setLocalLabels] = useState<string[]>(labels);
+	const [isAdding, setIsAdding] = useState(false);
+	const [newLabel, setNewLabel] = useState('');
+	const inputRef = useRef<HTMLInputElement>(null);
+	const [updateLabels, { isLoading }] = useUpdateApplicationLabelsMutation();
+
+	useEffect(() => {
+		setLocalLabels(labels);
+	}, [labels]);
+
+	useEffect(() => {
+		if (isAdding && inputRef.current) inputRef.current.focus();
+	}, [isAdding]);
+
+	const saveLabels = async (updated: string[]) => {
+		await updateLabels({ id: applicationId, labels: updated }).unwrap();
+		setLocalLabels(updated);
+		onLabelsChange?.(updated);
+	};
+
+	const handleAdd = async () => {
+		const value = newLabel.trim();
+		if (!value) {
+			setIsAdding(false);
+			setNewLabel('');
+			return;
+		}
+		const updated = [...localLabels, value];
+		await saveLabels(updated);
+		setIsAdding(false);
+		setNewLabel('');
+	};
+
+	const handleKeyDown = async (e: React.KeyboardEvent<HTMLInputElement>) => {
+		if (e.key === 'Enter') {
+			await handleAdd();
+		} else if (e.key === 'Escape') {
+			setIsAdding(false);
+			setNewLabel('');
+		}
+	};
+
+	return (
+		<div className="flex flex-wrap gap-2">
+			{isEditable ? (
+				<>
+					{isAdding ? (
+						<Input
+							ref={inputRef}
+							value={newLabel}
+							onChange={(e) => setNewLabel(e.target.value)}
+							onKeyDown={handleKeyDown}
+							onBlur={handleAdd}
+							className="h-6 w-28 text-xs"
+							placeholder="New label"
+							disabled={isLoading}
+						/>
+					) : (
+						<button
+							type="button"
+							onClick={() => setIsAdding(true)}
+							className="inline-flex items-center gap-1 h-5 px-2 rounded-md border text-xs text-muted-foreground hover:bg-secondary"
+						>
+							<Plus size={12} />
+							Add Label
+						</button>
+					)}
+				</>
+			) : (
+				<>
+					{localLabels.map((label, index) => (
+						<Badge key={`${label}-${index}`} variant="secondary" className="text-xs px-2 py-1 h-5">
+							{label}
+						</Badge>
+					))}
+				</>
+			)}
+		</div>
+	);
+}
diff --git a/view/app/self-host/components/application.tsx b/view/app/self-host/components/application.tsx
diff --git a/view/redux/api-conf.ts b/view/redux/api-conf.ts
diff --git a/view/redux/services/deploy/applicationsApi.ts b/view/redux/services/deploy/applicationsApi.ts
diff --git a/view/redux/types/applications.ts b/view/redux/types/applications.ts

Original file line number	Diff line number	Diff line change
`@@ -3,7 +3,7 @@`
`3`	`3`	`{`
`4`	`4`	`"version": "v1",`
`5`	`5`	`"status": "active",`
`6`		`- "release_date": "2025-08-21T22:58:05.772340699+05:30",`
	`6`	`+ "release_date": "2025-09-02T19:27:36.312579047+05:30",`
`7`	`7`	`"end_of_life": "0001-01-01T00:00:00Z",`
`8`	`8`	`"changes": [`
`9`	`9`	`"Initial API version"`
Original file line number	Diff line number	Diff line change
`@@ -360,6 +360,7 @@ func (router Router) DeployApplicationRoutes(f fuego.Server, deployController`
`360`	`360`	`fuego.Get(f, "/logs/{application_id}", deployController.GetLogs)`
`361`	`361`	`fuego.Get(f, "/deployments/{deployment_id}/logs", deployController.GetDeploymentLogs)`
`362`	`362`	`fuego.Get(f, "/deployments", deployController.GetApplicationDeployments)`
	`363`	`+ fuego.Put(f, "/labels", deployController.UpdateApplicationLabels)`
`363`	`364`	`}`
`364`	`365`
`365`	`366`	`func (router Router) FileManagerRoutes(f fuego.Server, fileManagerController *file_manager.FileManagerController) {`
Original file line number	Diff line number	Diff line change
`@@ -33,6 +33,7 @@ type Application struct {`
`33`	`33`	Logs []*ApplicationLogs `json:"logs,omitempty" bun:"rel:has-many,join:id=application_id"`
`34`	`34`	Deployments []*ApplicationDeployment `json:"deployments,omitempty" bun:"rel:has-many,join:id=application_id"`
`35`	`35`	Organization *Organization `json:"organization,omitempty" bun:"rel:belongs-to,join:organization_id=id"`
	`36`	+ Labels []string `json:"labels,omitempty" bun:"labels,array"`
`36`	`37`	`}`
`37`	`38`
`38`	`39`	`type ApplicationDeployment struct {`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+ALTER TABLE applications DROP COLUMN IF EXISTS labels;`
	`2`	`+DROP INDEX IF EXISTS idx_applications_labels;`