chore: refactor NodeRef structure in Integrations API (#2972)

We are still using `workflow_*` in the integration object and also in
the integrations page.

Signed-off-by: Lucas Pinheiro <lucas@superplane.com>

Author: lucaspin

api/swagger/superplane.swagger.json

@@ -4399,10 +4399,10 @@
     "IntegrationNodeRef": {
       "type": "object",
       "properties": {
-        "workflowId": {
+        "canvasId": {
           "type": "string"
         },
-        "workflowName": {
+        "canvasName": {
           "type": "string"
         },
         "nodeId": {

pkg/grpc/actions/organizations/create_integration.go

@@ -86,7 +86,7 @@ func CreateIntegration(ctx context.Context, registry *registry.Registry, oidcPro
 		}
 	}
 
-	proto, err := serializeIntegration(registry, newIntegration, []models.WorkflowNodeReference{})
+	proto, err := serializeIntegration(registry, newIntegration, []models.CanvasNodeReference{})
 	if err != nil {
 		return nil, status.Errorf(codes.Internal, "failed to serialize integration: %v", err)
 	}
@@ -96,7 +96,7 @@ func CreateIntegration(ctx context.Context, registry *registry.Registry, oidcPro
 	}, nil
 }
 
-func serializeIntegration(registry *registry.Registry, instance *models.Integration, nodeRefs []models.WorkflowNodeReference) (*pb.Integration, error) {
+func serializeIntegration(registry *registry.Registry, instance *models.Integration, nodeRefs []models.CanvasNodeReference) (*pb.Integration, error) {
 	integration, err := registry.GetIntegration(instance.AppName)
 	if err != nil {
 		return nil, err
@@ -144,10 +144,10 @@ func serializeIntegration(registry *registry.Registry, instance *models.Integrat
 
 	for _, nodeRef := range nodeRefs {
 		proto.Status.UsedIn = append(proto.Status.UsedIn, &pb.Integration_NodeRef{
-			WorkflowId:   nodeRef.WorkflowID.String(),
-			WorkflowName: nodeRef.WorkflowName,
-			NodeId:       nodeRef.NodeID,
-			NodeName:     nodeRef.NodeName,
+			CanvasId:   nodeRef.CanvasID.String(),
+			CanvasName: nodeRef.CanvasName,
+			NodeId:     nodeRef.NodeID,
+			NodeName:   nodeRef.NodeName,
 		})
 	}
 

pkg/grpc/actions/organizations/list_integrations.go

@@ -17,7 +17,7 @@ func ListIntegrations(ctx context.Context, registry *registry.Registry, orgID st
 
 	protos := []*pb.Integration{}
 	for _, integration := range integrations {
-		proto, err := serializeIntegration(registry, &integration, []models.WorkflowNodeReference{})
+		proto, err := serializeIntegration(registry, &integration, []models.CanvasNodeReference{})
 		if err != nil {
 			return nil, err
 		}

pkg/grpc/actions/organizations/update_integration.go

@@ -83,7 +83,7 @@ func UpdateIntegration(ctx context.Context, registry *registry.Registry, oidcPro
 		return nil, status.Error(codes.Internal, "failed to save integration")
 	}
 
-	proto, err := serializeIntegration(registry, instance, []models.WorkflowNodeReference{})
+	proto, err := serializeIntegration(registry, instance, []models.CanvasNodeReference{})
 	if err != nil {
 		log.Errorf("failed to serialize integration %s: %v", instance.ID, err)
 		return nil, status.Error(codes.Internal, "failed to serialize integration")

pkg/models/integration.go

@@ -113,19 +113,19 @@ func ListUnscopedIntegrationWebhooks(tx *gorm.DB, integrationID uuid.UUID) ([]We
 	return webhooks, nil
 }
 
-type WorkflowNodeReference struct {
-	WorkflowID   uuid.UUID
-	WorkflowName string
-	NodeID       string
-	NodeName     string
+type CanvasNodeReference struct {
+	CanvasID   uuid.UUID
+	CanvasName string
+	NodeID     string
+	NodeName   string
 }
 
-func ListIntegrationNodeReferences(integrationID uuid.UUID) ([]WorkflowNodeReference, error) {
-	var nodeReferences []WorkflowNodeReference
+func ListIntegrationNodeReferences(integrationID uuid.UUID) ([]CanvasNodeReference, error) {
+	var nodeReferences []CanvasNodeReference
 	err := database.Conn().
 		Table("workflow_nodes AS wn").
 		Joins("JOIN workflows AS w ON w.id = wn.workflow_id").
-		Select("w.id as workflow_id, w.name as workflow_name, wn.node_id as node_id, wn.name as node_name").
+		Select("w.id as canvas_id, w.name as canvas_name, wn.node_id as node_id, wn.name as node_name").
 		Where("wn.app_installation_id = ?", integrationID).
 		Where("wn.deleted_at IS NULL").
 		Find(&nodeReferences).

pkg/openapi_client/model_integration_node_ref.go

@@ -410,8 +410,8 @@ message Integration {
   }
 
   message NodeRef {
-    string workflow_id = 1;
-    string workflow_name = 2;
+    string canvas_id = 1;
+    string canvas_name = 2;
     string node_id = 3;
     string node_name = 4;
   }

pkg/protos/organizations/organizations.pb.go

@@ -577,8 +577,8 @@ export type GroupsUpdateGroupResponse = {
 };
 
 export type IntegrationNodeRef = {
-  workflowId?: string;
-  workflowName?: string;
+  canvasId?: string;
+  canvasName?: string;
   nodeId?: string;
   nodeName?: string;
 };

protos/organizations.proto

@@ -53,22 +53,22 @@ export function IntegrationDetails({ organizationId }: IntegrationDetailsProps)
   const workflowGroups = useMemo(() => {
     if (!integration?.status?.usedIn) return [];
 
-    const groups = new Map<string, { workflowName: string; nodes: Array<{ nodeId: string; nodeName: string }> }>();
+    const groups = new Map<string, { canvasName: string; nodes: Array<{ nodeId: string; nodeName: string }> }>();
     integration.status.usedIn.forEach((nodeRef) => {
-      const workflowId = nodeRef.workflowId || "";
-      const workflowName = nodeRef.workflowName || workflowId;
+      const canvasId = nodeRef.canvasId || "";
+      const canvasName = nodeRef.canvasName || canvasId;
       const nodeId = nodeRef.nodeId || "";
       const nodeName = nodeRef.nodeName || nodeId;
 
-      if (!groups.has(workflowId)) {
-        groups.set(workflowId, { workflowName, nodes: [] });
+      if (!groups.has(canvasId)) {
+        groups.set(canvasId, { canvasName, nodes: [] });
       }
-      groups.get(workflowId)?.nodes.push({ nodeId, nodeName });
+      groups.get(canvasId)?.nodes.push({ nodeId, nodeName });
     });
 
-    return Array.from(groups.entries()).map(([workflowId, data]) => ({
-      workflowId,
-      workflowName: data.workflowName,
+    return Array.from(groups.entries()).map(([canvasId, data]) => ({
+      canvasId,
+      canvasName: data.canvasName,
       nodes: data.nodes,
     }));
   }, [integration?.status?.usedIn]);
@@ -248,13 +248,13 @@ export function IntegrationDetails({ organizationId }: IntegrationDetailsProps)
                   <div className="space-y-2">
                     {workflowGroups.map((group) => (
                       <button
-                        key={group.workflowId}
-                        onClick={() => window.open(`/${organizationId}/canvases/${group.workflowId}`, "_blank")}
+                        key={group.canvasId}
+                        onClick={() => window.open(`/${organizationId}/canvases/${group.canvasId}`, "_blank")}
                         className="w-full flex items-center gap-2 p-3 bg-gray-50 dark:bg-gray-800/50 rounded-md border border-gray-300 dark:border-gray-700 hover:bg-gray-100 dark:hover:bg-gray-800 transition-colors text-left"
                       >
                         <div className="flex-1">
                           <p className="text-sm font-medium text-gray-800 dark:text-gray-100">
-                            Canvas: {group.workflowName}
+                            Canvas: {group.canvasName}
                           </p>
                           <p className="text-xs text-gray-500 dark:text-gray-400 mt-1">
                             Used in {group.nodes.length} node{group.nodes.length !== 1 ? "s" : ""}:{" "}