beam: integrate model attachments with Beam viewer

plane-src/apps/api/plane/app/views/issue/attachment.py

@@ -109,6 +109,12 @@ class IssueAttachmentV2Endpoint(BaseAPIView):
         name = request.data.get("name")
         type = request.data.get("type", False)
         size = int(request.data.get("size", settings.FILE_SIZE_LIMIT))
+        beam_viewer = request.data.get("beamViewer")
+        is_beam_viewer_reference = (
+            isinstance(beam_viewer, dict)
+            and beam_viewer.get("src")
+            and beam_viewer.get("downloadUrl")
+        )
 
         if not type or type not in settings.ATTACHMENT_MIME_TYPES:
             return Response(
@@ -120,6 +126,45 @@ class IssueAttachmentV2Endpoint(BaseAPIView):
         workspace = Workspace.objects.get(slug=slug)
         project = Project.objects.get(id=project_id, workspace=workspace)
 
+        if is_beam_viewer_reference:
+            asset = FileAsset.objects.create(
+                attributes={
+                    "name": name,
+                    "type": type,
+                    "size": size,
+                    "beamViewer": beam_viewer,
+                },
+                asset=f"{workspace.id}/beam-viewer/{uuid.uuid4().hex}-{name}",
+                size=0,
+                workspace_id=workspace.id,
+                created_by=request.user,
+                issue_id=issue_id,
+                project_id=project_id,
+                entity_type=FileAsset.EntityTypeContext.ISSUE_ATTACHMENT,
+                is_uploaded=True,
+                external_source="beam-viewer",
+            )
+            serializer = IssueAttachmentSerializer(asset)
+            issue_activity.delay(
+                type="attachment.activity.created",
+                requested_data=None,
+                actor_id=str(self.request.user.id),
+                issue_id=str(self.kwargs.get("issue_id", None)),
+                project_id=str(self.kwargs.get("project_id", None)),
+                current_instance=json.dumps(serializer.data, cls=DjangoJSONEncoder),
+                epoch=int(timezone.now().timestamp()),
+                notification=True,
+                origin=base_host(request=request, is_app=True),
+            )
+            return Response(
+                {
+                    "asset_id": str(asset.id),
+                    "attachment": serializer.data,
+                    "asset_url": asset.asset_url,
+                },
+                status=status.HTTP_200_OK,
+            )
+
         # asset key
         asset_key = f"{workspace.id}/{uuid.uuid4().hex}-{name}"