Add preview in details page

core/amber/src/main/resources/application.conf

@@ -90,4 +90,4 @@ fault-tolerance {
 region-plan-generator {
     enable-cost-based-region-plan-generator = false
     use-global-search = false
-}
+}

core/amber/src/main/scala/edu/uci/ics/texera/web/resource/dashboard/hub/test/TestHubResource.scala

@@ -0,0 +1,58 @@
+package edu.uci.ics.texera.web.resource.dashboard.hub.test
+
+import edu.uci.ics.texera.web.SqlServer
+import edu.uci.ics.texera.web.auth.SessionUser
+import org.jooq.types.UInteger
+
+import java.util
+
+import edu.uci.ics.texera.web.resource.dashboard.hub.test.TestHubResource.Workflow
+
+import javax.ws.rs._
+import javax.ws.rs.core.MediaType
+import edu.uci.ics.texera.web.model.jooq.generated.Tables._
+import edu.uci.ics.texera.web.resource.dashboard.hub.test.TestHubResource.getAllWorkflows
+import io.dropwizard.auth.Auth
+import scala.jdk.CollectionConverters.IterableHasAsScala
+
+object TestHubResource {
+  final private lazy val context = SqlServer.createDSLContext()
+
+  case class Workflow(
+                       workflowId: UInteger,
+                       workflowName: String
+                     )
+
+  def getAllWorkflows: List[Workflow] = {
+    val allWorkflowEntries = context
+      .select(
+        WORKFLOW.WID,
+        WORKFLOW.NAME
+      )
+      .from(
+        WORKFLOW
+      )
+      .fetch()
+
+    allWorkflowEntries
+      .map(workflowRecord => {
+        Workflow(
+          workflowRecord.get(WORKFLOW.WID),
+          workflowRecord.get(WORKFLOW.NAME)
+        )
+      })
+      .asScala
+      .toList
+  }
+}
+
+
+@Path("/hub")
+class TestHubResource {
+  @GET
+  @Path("/get_all_workflows")
+  @Produces(Array(MediaType.APPLICATION_JSON))
+  def getCreatedWorkflow: List[Workflow] = {
+    getAllWorkflows
+  }
+}

core/amber/src/main/scala/edu/uci/ics/texera/web/resource/dashboard/user/workflow/WorkflowAccessResource.scala

@@ -7,7 +7,8 @@ import edu.uci.ics.texera.web.model.jooq.generated.Tables.{
   PROJECT_USER_ACCESS,
   USER,
   WORKFLOW_OF_PROJECT,
-  WORKFLOW_USER_ACCESS
+  WORKFLOW_USER_ACCESS,
+  WORKFLOW
 }
 import edu.uci.ics.texera.web.model.jooq.generated.enums.WorkflowUserAccessPrivilege
 import edu.uci.ics.texera.web.model.jooq.generated.tables.daos.{
@@ -36,7 +37,7 @@ object WorkflowAccessResource {
     * @return boolean value indicating yes/no
     */
   def hasReadAccess(wid: UInteger, uid: UInteger): Boolean = {
-    getPrivilege(wid, uid).eq(WorkflowUserAccessPrivilege.READ) || hasWriteAccess(wid, uid)
+    isPublic(wid) || getPrivilege(wid, uid).eq(WorkflowUserAccessPrivilege.READ) || hasWriteAccess(wid, uid)
   }
 
   /**
@@ -77,6 +78,14 @@ object WorkflowAccessResource {
       access.getPrivilege
     }
   }
+
+  def isPublic(wid: UInteger): Boolean = {
+    context
+      .select(WORKFLOW.IS_PUBLISHED)
+      .from(WORKFLOW)
+      .where(WORKFLOW.WID.eq(wid))
+      .fetchOneInto(classOf[Boolean])
+  }
 }
 
 @Produces(Array(MediaType.APPLICATION_JSON))

core/amber/src/main/scala/edu/uci/ics/texera/web/resource/dashboard/user/workflow/WorkflowResource.scala

@@ -4,21 +4,11 @@ import com.typesafe.scalalogging.LazyLogging
 import edu.uci.ics.texera.web.SqlServer
 import edu.uci.ics.texera.web.auth.SessionUser
 import edu.uci.ics.texera.web.model.jooq.generated.Tables._
-import edu.uci.ics.texera.web.model.jooq.generated.enums.WorkflowUserAccessPrivilege
-import edu.uci.ics.texera.web.model.jooq.generated.tables.daos.{
-  EnvironmentOfWorkflowDao,
-  WorkflowDao,
-  WorkflowOfProjectDao,
-  WorkflowOfUserDao,
-  WorkflowUserAccessDao
-}
-import edu.uci.ics.texera.web.model.jooq.generated.tables.pojos._
+import edu.uci.ics.texera.web.model.jooq.generated.enums.{UserRole, WorkflowUserAccessPrivilege}
+import edu.uci.ics.texera.web.model.jooq.generated.tables.daos.{EnvironmentOfWorkflowDao, WorkflowDao, WorkflowOfProjectDao, WorkflowOfUserDao, WorkflowUserAccessDao}
+import edu.uci.ics.texera.web.model.jooq.generated.tables.pojos.{User, _}
 import edu.uci.ics.texera.web.resource.dashboard.user.environment.EnvironmentResource
-import edu.uci.ics.texera.web.resource.dashboard.user.environment.EnvironmentResource.{
-  createEnvironment,
-  doesWorkflowHaveEnvironment,
-  copyEnvironment
-}
+import edu.uci.ics.texera.web.resource.dashboard.user.environment.EnvironmentResource.{copyEnvironment, createEnvironment, doesWorkflowHaveEnvironment}
 import edu.uci.ics.texera.web.resource.dashboard.user.workflow.WorkflowAccessResource.hasReadAccess
 import edu.uci.ics.texera.web.resource.dashboard.user.workflow.WorkflowResource._
 import io.dropwizard.auth.Auth
@@ -122,7 +112,6 @@ object WorkflowResource {
 
 }
 @Produces(Array(MediaType.APPLICATION_JSON))
-@RolesAllowed(Array("REGULAR", "ADMIN"))
 @Path("/workflow")
 class WorkflowResource extends LazyLogging {
 
@@ -132,6 +121,7 @@ class WorkflowResource extends LazyLogging {
     * @return WorkflowID[]
     */
   @GET
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/user-workflow-ids")
   def retrieveIDs(@Auth user: SessionUser): util.List[String] = {
     context
@@ -147,6 +137,7 @@ class WorkflowResource extends LazyLogging {
     * @return OwnerName[]
     */
   @GET
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/user-workflow-owners")
   def retrieveOwners(@Auth user: SessionUser): util.List[String] = {
     context
@@ -166,6 +157,7 @@ class WorkflowResource extends LazyLogging {
     * @return WorkflowID[]
     */
   @GET
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/search-by-operators")
   def searchWorkflowByOperator(
       @QueryParam("operator") operator: String,
@@ -218,6 +210,7 @@ class WorkflowResource extends LazyLogging {
     * @return Workflow[]
     */
   @GET
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/list")
   def retrieveWorkflowsBySessionUser(
       @Auth sessionUser: SessionUser
@@ -276,6 +269,7 @@ class WorkflowResource extends LazyLogging {
     * @return a json string representing an savedWorkflow
     */
   @GET
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/{wid}")
   def retrieveWorkflow(
       @PathParam("wid") wid: UInteger,
@@ -298,6 +292,41 @@ class WorkflowResource extends LazyLogging {
     }
   }
 
+  /**
+   * This method handles the client request to get a specific workflow to be displayed in canvas
+   * at current design, it only takes the workflowID and searches within the database for the matching workflow
+   * for future design, it should also take userID as an parameter.
+   *
+   * @param wid workflow id, which serves as the primary key in the UserWorkflow database
+   * @return a json string representing an savedWorkflow
+   */
+  @GET
+  @Path("/public/{wid}")
+  def retrievePublicWorkflow(
+      @PathParam("wid") wid: UInteger
+  ): WorkflowWithPrivilege = {
+    val dummyUser = new User()
+    dummyUser.setRole(UserRole.REGULAR)
+    Console.println(WorkflowAccessResource.hasReadAccess(wid, new SessionUser(dummyUser).getUid))
+    if (WorkflowAccessResource.hasReadAccess(wid, new SessionUser(dummyUser).getUid)) {
+      Console.println("has read access")
+      val workflow = workflowDao.fetchOneByWid(wid)
+      WorkflowWithPrivilege(
+        workflow.getName,
+        workflow.getDescription,
+        workflow.getWid,
+        workflow.getContent,
+        workflow.getCreationTime,
+        workflow.getLastModifiedTime,
+        workflow.getIsPublished,
+        true
+      )
+    } else {
+      Console.println("no read access")
+      throw new ForbiddenException("No sufficient access privilege.")
+    }
+  }
+
   /**
     * This method persists the workflow into database
     *
@@ -309,6 +338,7 @@ class WorkflowResource extends LazyLogging {
     */
   @POST
   @Consumes(Array(MediaType.APPLICATION_JSON))
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/persist")
   def persistWorkflow(workflow: Workflow, @Auth sessionUser: SessionUser): Workflow = {
     val user = sessionUser.getUser
@@ -349,6 +379,7 @@ class WorkflowResource extends LazyLogging {
     */
   @POST
   @Consumes(Array(MediaType.APPLICATION_JSON))
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/duplicate")
   def duplicateWorkflow(
       workflowIDs: WorkflowIDs,
@@ -414,7 +445,6 @@ class WorkflowResource extends LazyLogging {
 
   @POST
   @Consumes(Array(MediaType.APPLICATION_JSON))
-  @Produces(Array(MediaType.APPLICATION_JSON))
   @Path("/clone/{wid}")
   def cloneWorkflow(@PathParam("wid") wid: UInteger, @Auth sessionUser: SessionUser): UInteger  = {
     val workflow: Workflow = workflowDao.fetchOneByWid(wid)
@@ -442,6 +472,7 @@ class WorkflowResource extends LazyLogging {
   @POST
   @Consumes(Array(MediaType.APPLICATION_JSON))
   @Produces(Array(MediaType.APPLICATION_JSON))
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/create")
   def createWorkflow(workflow: Workflow, @Auth sessionUser: SessionUser): DashboardWorkflow = {
     val user = sessionUser.getUser
@@ -469,6 +500,7 @@ class WorkflowResource extends LazyLogging {
     * @return Response, deleted - 200, not exists - 400
     */
   @POST
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/delete")
   def deleteWorkflow(workflowIDs: WorkflowIDs, @Auth sessionUser: SessionUser): Unit = {
     val user = sessionUser.getUser
@@ -497,6 +529,7 @@ class WorkflowResource extends LazyLogging {
   @POST
   @Consumes(Array(MediaType.APPLICATION_JSON))
   @Produces(Array(MediaType.APPLICATION_JSON))
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/update/name")
   def updateWorkflowName(
       workflow: Workflow,
@@ -519,6 +552,7 @@ class WorkflowResource extends LazyLogging {
   @POST
   @Consumes(Array(MediaType.APPLICATION_JSON))
   @Produces(Array(MediaType.APPLICATION_JSON))
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/update/description")
   def updateWorkflowDescription(
       workflow: Workflow,
@@ -540,6 +574,7 @@ class WorkflowResource extends LazyLogging {
   }
 
   @GET
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/{wid}/environment")
   def retrieveWorkflowEnvironment(
       @PathParam("wid") wid: UInteger,
@@ -577,6 +612,7 @@ class WorkflowResource extends LazyLogging {
   }
 
   @GET
+  @RolesAllowed(Array("REGULAR", "ADMIN"))
   @Path("/type/{wid}")
   def getWorkflowType(@PathParam("wid") wid: UInteger): String = {
     val workflow: Workflow = workflowDao.fetchOneByWid(wid)

core/amber/yarn.lock

@@ -0,0 +1,4 @@
+# THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.
+# yarn lockfile v1
+
+

core/gui/src/app/common/service/workflow-persist/workflow-persist.service.ts

@@ -21,6 +21,7 @@ export const WORKFLOW_UPDATENAME_URL = WORKFLOW_BASE_URL + "/update/name";
 export const WORKFLOW_UPDATEDESCRIPTION_URL = WORKFLOW_BASE_URL + "/update/description";
 export const WORKFLOW_OWNER_URL = WORKFLOW_BASE_URL + "/user-workflow-owners";
 export const WORKFLOW_ID_URL = WORKFLOW_BASE_URL + "/user-workflow-ids";
+export const WORKFLOW_PUBLIC_URL = WORKFLOW_BASE_URL + "/public"
 
 export const DEFAULT_WORKFLOW_NAME = "Untitled workflow";
 export const WORKFLOW_ENVIRONMENT = "environment";
@@ -97,6 +98,13 @@ export class WorkflowPersistService {
     );
   }
 
+  public retrievePublicWorkflow(wid: number): Observable<Workflow> {
+    return this.http.get<Workflow>(`${AppSettings.getApiEndpoint()}/${WORKFLOW_PUBLIC_URL}/${wid}`).pipe(
+      filter((workflow: Workflow) => workflow != null),
+      map(WorkflowUtilService.parseWorkflowInfo)
+    );
+  }
+
   private makeRequestAndFormatWorkflowResponse(url: string): Observable<DashboardWorkflow[]> {
     return this.http.get<DashboardWorkflow[]>(url).pipe(
       map((dashboardWorkflowEntries: DashboardWorkflow[]) =>

core/gui/src/app/dashboard/component/user/share-access/share-access.component.ts

@@ -45,7 +45,7 @@ export class ShareAccessComponent implements OnInit {
       accessLevel: ["READ"],
     });
     this.currentEmail = this.userService.getCurrentUser()?.email;
-    
+
   }
 
   ngOnInit(): void {
@@ -89,12 +89,12 @@ export class ShareAccessComponent implements OnInit {
             this.gmailService.sendEmail(
               "Texera: " + this.owner + " shared a " + this.type + " with you",
               this.owner +
-                " shared a " +
-                this.type +
-                " with you, access the workflow at " +
-                location.origin +
-                "/workflow/" +
-                this.id,
+              " shared a " +
+              this.type +
+              " with you, access the workflow at " +
+              location.origin +
+              "/workflow/" +
+              this.id,
               this.validateForm.value.email
             );
           },
@@ -138,7 +138,7 @@ export class ShareAccessComponent implements OnInit {
         ]
       });
     }
-    
+
   }
   verifyUnpublish(): void {
     if (this.isPublic) {

core/gui/src/app/hub/component/workflow/detail/hub-workflow-detail.component.html

@@ -28,6 +28,12 @@ <h2>Created By</h2>
       <p *ngIf="ownerUser">{{ ownerUser.name }}</p>
     </div>
   </div>
+  <h2>preview</h2>
+  <div class="preview-containers">
+    <texera-workflow-editor></texera-workflow-editor>
+    <texera-mini-map></texera-mini-map>
+  </div>
+  <ng-template #codeEditor></ng-template>
   <div class="workflow-steps">
     <h2>Steps</h2>
     <div
@@ -39,3 +45,6 @@ <h3>{{ step.name }}</h3>
     </div>
   </div>
 </div>
+
+
+