Skip to content

Commit

Permalink
erge branch 'master' into refactor-command-producers
Browse files Browse the repository at this point in the history
  • Loading branch information
eduwercamacaro committed Nov 27, 2024
2 parents 82451b0 + 956d78a commit 06ec897
Show file tree
Hide file tree
Showing 163 changed files with 794 additions and 696 deletions.
28 changes: 0 additions & 28 deletions dashboard/src/app/(authenticated)/layout.tsx

This file was deleted.

Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
'use client'
import { ThreadRunWithNodeRuns } from '@/app/(authenticated)/(diagram)/wfRun/[...ids]/getWfRun'
import { ThreadRunWithNodeRuns } from '@/app/[tenantId]/(diagram)/wfRun/[...ids]/getWfRun'
import { NodeRun, WfRun, WfSpec } from 'littlehorse-client/proto'
import { ReadonlyURLSearchParams, useSearchParams } from 'next/navigation'
import { FC, useCallback, useEffect, useMemo, useState } from 'react'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ export const Layouter: FC<{ nodeRuns?: NodeRun[]; nodeRunNameToBeHighlighted?: s
setNodes(layoutedNodes)
fitView()
},
[fitView, nodeRuns, setNodes]
[fitView, nodeRuns, setNodes, nodeRunNameToBeHighlighted]
)

useEffect(() => {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ export const Edge: FC<Modal> = ({ data }) => {
<span className="rounded bg-green-300 p-1 text-xs">{mutation.operation}</span>
<NodeOutput nodeOutput={mutation.nodeOutput} />
<LiteralValue literalValue={mutation.literalValue} />
<SourceVariable sourceVariable={mutation.sourceVariable} />
<RhsAssignment rhsAssignment={mutation.rhsAssignment} />
</div>
))}
</DialogContent>
Expand All @@ -41,12 +41,12 @@ const NodeOutput: FC<Pick<VariableMutation, 'nodeOutput'>> = ({ nodeOutput }) =>
)
}

const SourceVariable: FC<Pick<VariableMutation, 'sourceVariable'>> = ({ sourceVariable }) => {
if (!sourceVariable) return <></>
const RhsAssignment: FC<Pick<VariableMutation, 'rhsAssignment'>> = ({ rhsAssignment }) => {
if (!rhsAssignment) return <></>
return (
<>
<span className="rounded bg-gray-200 p-1 text-xs">Source Variable</span>
<span className="rounded bg-gray-100 p-1 font-mono text-xs text-orange-500">{getVariable(sourceVariable)}</span>
<span className="rounded bg-gray-200 p-1 text-xs">RHS Assignment</span>
<span className="rounded bg-gray-100 p-1 font-mono text-xs text-orange-500">{getVariable(rhsAssignment)}</span>
</>
)
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,3 @@
import { FormValues, WfRunForm } from '@/app/(authenticated)/(diagram)/components/Forms/WfRunForm'
import { Button } from '@/components/ui/button'
import {
Dialog,
Expand All @@ -9,18 +8,19 @@ import {
DialogHeader,
DialogTitle,
} from '@/components/ui/dialog'
import { useWhoAmI } from '@/contexts/WhoAmIContext'
import { ThreadVarDef, VariableType, WfSpec } from 'littlehorse-client/proto'
import { useRouter } from 'next/navigation'
import { useParams, useRouter } from 'next/navigation'
import { FC, useRef } from 'react'
import { toast } from 'sonner'
import { Modal } from '../../context'
import { useModal } from '../../hooks/useModal'
import { runWfSpec } from '../../wfSpec/[...props]/actions/runWfSpec'
import { FormValues, WfRunForm } from '../Forms/WfRunForm'

export const ExecuteWorkflowRun: FC<Modal> = ({ data }) => {
const { showModal, setShowModal } = useModal()
const lhWorkflowSpec = data as WfSpec
const { tenantId } = useWhoAmI()
const tenantId = useParams().tenantId as string
const router = useRouter()
const formRef = useRef<HTMLFormElement | null>(null)
const wfSpecVariables = lhWorkflowSpec.threadSpecs?.entrypoint?.variableDefs
Expand Down Expand Up @@ -62,7 +62,6 @@ export const ExecuteWorkflowRun: FC<Modal> = ({ data }) => {
wfSpecName: lhWorkflowSpec.id.name,
majorVersion: lhWorkflowSpec.id.majorVersion,
revision: lhWorkflowSpec.id.revision,

id: customWfRunId || undefined,
variables: formatVariablesPayload(values),
})
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
import { NodeRun, UserTaskNode } from 'littlehorse-client/proto'
import { FC } from 'react'
import { NodeType } from '../../NodeTypes/extractNodes'
import {
ExternalEventDefDetail,
Expand All @@ -9,7 +10,6 @@ import {
WaitForThreadDefDetail,
WorkflowEventDefDetail,
} from './'
import { FC } from 'react'

export type AccordionNode = { nodeRun: NodeRun; userTaskNode?: UserTaskNode }
type AccordionNodes = {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import React, { FC } from 'react'
import { AccordionComponents } from './AccordionContent'
import { NodeRun, UserTaskNode } from 'littlehorse-client/proto'
import * as AccordionRedux from '@radix-ui/react-accordion'
import { NodeRun, UserTaskNode } from 'littlehorse-client/proto'
import { ChevronDownIcon } from 'lucide-react'
import { FC } from 'react'
import { statusColors } from '../../../wfRun/[...ids]/components/Details'
import { getNodeType } from '../../NodeTypes/extractNodes'
import { AccordionComponents } from './AccordionContent'

export const AccordionItem: FC<{ node: NodeRun; userTaskNode?: UserTaskNode }> = ({ node, userTaskNode }) => {
const nodeType = getNodeType(node)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { FC } from 'react'
import { RefreshCwIcon, ClipboardIcon } from 'lucide-react'
import { getVariable, getVariableValue, utcToLocalDateTime } from '@/app/utils'
import { useQuery } from '@tanstack/react-query'
import { UserTaskRunStatus, UserTaskRun as LHUserTaskRun } from 'littlehorse-client/proto'
import { UserTaskRun as LHUserTaskRun, UserTaskRunStatus } from 'littlehorse-client/proto'
import { ClipboardIcon, RefreshCwIcon } from 'lucide-react'
import { FC } from 'react'
import { getUserTaskRun } from '../../NodeTypes/UserTask/getUserTaskRun'
import { AccordionNode } from './AccordionContent'
import { getVariableValue, getVariable, utcToLocalDateTime } from '@/app/utils'
import { getUserTaskRun } from '@/app/(authenticated)/(diagram)/components/NodeTypes/UserTask/getUserTaskRun'

export const UserTaskDefDetail: FC<AccordionNode> = ({ nodeRun, userTaskNode }) => {
const taskId = nodeRun?.userTask?.userTaskRunId?.userTaskGuid
Expand Down
Original file line number Diff line number Diff line change
@@ -1,19 +1,18 @@
import { FC } from 'react'
import { useWhoAmI } from '@/contexts/WhoAmIContext'
import { RefreshCwIcon, ClipboardIcon } from 'lucide-react'
import { NodeRun } from 'littlehorse-client/proto'
import { useQuery } from '@tanstack/react-query'

import { cn } from '@/components/utils'
import { getVariableValue, utcToLocalDateTime } from '@/app/utils'
import { getWorkflowEvent } from '@/app/(authenticated)/(diagram)/components/NodeTypes/ThrowEvent/getWorkflowEvent'
import { cn } from '@/components/utils'
import { useQuery } from '@tanstack/react-query'
import { NodeRun } from 'littlehorse-client/proto'
import { ClipboardIcon, RefreshCwIcon } from 'lucide-react'
import { useParams } from 'next/navigation'
import { FC } from 'react'
import { getWorkflowEvent } from '../../NodeTypes/ThrowEvent/getWorkflowEvent'

export const WorkflowEventDefDetail: FC<{ nodeRun: NodeRun }> = ({ nodeRun }) => {
const { tenantId } = useWhoAmI()
const tenantId = useParams().tenantId as string
const wfRunId = nodeRun?.throwEvent?.workflowEventId?.wfRunId?.id
const workflowEventDefId = nodeRun?.throwEvent?.workflowEventId
const { data, isLoading } = useQuery({
queryKey: ['taskRun', wfRunId, workflowEventDefId],
queryKey: ['taskRun', wfRunId, workflowEventDefId, tenantId],
queryFn: async () => {
if (!wfRunId) return
if (!workflowEventDefId) return
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { NodeRun, TaskNode, UserTaskNode } from 'littlehorse-client/proto'
import { FC, useCallback } from 'react'
import { EyeIcon } from 'lucide-react'
import { useModal } from '@/app/(authenticated)/(diagram)/hooks/useModal'
import { FC, useCallback } from 'react'
import { useModal } from '../hooks/useModal'

type Prop = {
nodeRuns: [NodeRun]
Expand All @@ -14,7 +14,7 @@ export const NodeRunsList: FC<Prop> = ({ nodeRuns, taskNode, userTaskNode, nodeR
const showNodeRuns = useCallback(() => {
setModal({ type: 'nodeRunList', data: { nodeRunsList: nodeRuns, taskNode, nodeRun, userTaskNode } })
setShowModal(true)
}, [nodeRuns, setModal, setShowModal, taskNode])
}, [nodeRun, nodeRuns, setModal, setShowModal, taskNode, userTaskNode])

if (!nodeRuns?.length) return

Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
import { formatTime, getVariableValue } from '@/app/utils'
import { Node as NodeProto } from 'littlehorse-client/proto'
import { ExternalLinkIcon, MailOpenIcon } from 'lucide-react'
import Link from 'next/link'
import { FC, memo } from 'react'
import { Handle, Position } from 'reactflow'
import { NodeProps } from '..'
Expand All @@ -10,6 +9,7 @@ import { Fade } from '../Fade'
import { NodeDetails } from '../NodeDetails'

import { NodeRunsList } from '../../NodeRunsList'
import LinkWithTenant from '@/app/[tenantId]/components/LinkWithTenant'

const Node: FC<NodeProps<NodeProto>> = ({ data }) => {
if (!data.externalEvent) return null
Expand All @@ -22,13 +22,13 @@ const Node: FC<NodeProps<NodeProto>> = ({ data }) => {
<div>
<div className="flex items-center gap-1 text-nowrap">
<h3 className="font-bold">ExternalEventDef</h3>
<Link
<LinkWithTenant
className="flex items-center justify-center gap-1 text-blue-500 hover:underline"
target="_blank"
href={`/externalEventDef/${externalEventNode.externalEventDefId?.name}`}
>
{externalEventNode.externalEventDefId?.name} <ExternalLinkIcon className="h-4 w-4" />
</Link>
</LinkWithTenant>
</div>
{
<div className="flex gap-2 text-nowrap">
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
import { formatTime, getVariable } from '@/app/utils'
import { NodeRun, SleepNode } from 'littlehorse-client/proto'
import { FC } from 'react'
import { NodeDetails } from '../NodeDetails'
import { getVariable, formatTime } from '@/app/utils'
import { NodeRunsList } from '../../NodeRunsList'
import { NodeDetails } from '../NodeDetails'
export const SleepDetails: FC<{ sleepNode?: SleepNode; nodeRunsList: [NodeRun] }> = ({ sleepNode, nodeRunsList }) => {
if (!sleepNode) return

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,10 @@ import { FC, memo } from 'react'
import { Handle, Position } from 'reactflow'
import { NodeProps } from '.'
import { useThread } from '../../hooks/useThread'
import { NodeRunsList } from '../NodeRunsList'
import { Fade } from './Fade'
import { NodeDetails } from './NodeDetails'
import { NodeRunsList } from '@/app/(authenticated)/(diagram)/components/NodeRunsList'

const Node: FC<NodeProps> = ({ data }) => {
const { fade, nodeRunsList } = data
const { setThread } = useThread()
Expand Down
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { getTaskDef } from '@/app/(authenticated)/taskDef/[name]/getTaskDef'
import LinkWithTenant from '@/app/[tenantId]/components/LinkWithTenant'
import { getTaskDef } from '@/app/[tenantId]/taskDef/[name]/getTaskDef'
import { getVariable, getVariableValue } from '@/app/utils'
import { useWhoAmI } from '@/contexts/WhoAmIContext'
import { useQuery } from '@tanstack/react-query'
import { NodeRun, TaskNode } from 'littlehorse-client/proto'
import { ExternalLinkIcon } from 'lucide-react'
import Link from 'next/link'
import { useParams } from 'next/navigation'
import { FC } from 'react'
import { NodeRunsList } from '../../NodeRunsList'
import { NodeDetails } from '../NodeDetails'
Expand All @@ -16,7 +16,7 @@ export const TaskDetails: FC<{
selected: boolean
nodeRunsList: [NodeRun]
}> = ({ taskNode, nodeRun, selected, nodeRunsList }) => {
const { tenantId } = useWhoAmI()
const tenantId = useParams().tenantId as string
const { data } = useQuery({
queryKey: ['taskRun', nodeRun, tenantId],
queryFn: async () => {
Expand All @@ -31,7 +31,7 @@ export const TaskDetails: FC<{
if (!taskNode?.taskDefId?.name) return null
if (nodeRun?.task?.taskRunId) return null
if (!selected) return null
const taskDef = await getTaskDef({
const taskDef = await getTaskDef(tenantId, {
name: taskNode?.taskDefId?.name,
})
return taskDef
Expand Down Expand Up @@ -95,12 +95,12 @@ export const TaskDetails: FC<{

export const TaskLink: FC<{ taskName?: string }> = ({ taskName }) => {
return (
<Link
<LinkWithTenant
className="flex items-center justify-center gap-1 text-blue-500 hover:underline"
target="_blank"
href={`/taskDef/${taskName}`}
>
{taskName} <ExternalLinkIcon className="h-4 w-4" />
</Link>
</LinkWithTenant>
)
}
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
import { Node as NodeProto } from 'littlehorse-client/proto'
import { CircleArrowOutUpRightIcon, ExternalLinkIcon } from 'lucide-react'
import Link from 'next/link'
import { FC, memo } from 'react'
import { Handle, Position } from 'reactflow'
import { NodeProps } from '..'

import LinkWithTenant from '@/app/[tenantId]/components/LinkWithTenant'
import { Fade } from '../Fade'
import { NodeDetails } from '../NodeDetails'

Expand All @@ -21,13 +21,13 @@ const Node: FC<NodeProps<NodeProto>> = ({ data }) => {
<div>
<div className="flex items-center gap-1 text-nowrap">
<h3 className="font-bold">WorkflowEventDef</h3>
<Link
<LinkWithTenant
className="flex items-center justify-center gap-1 text-blue-500 hover:underline"
target="_blank"
href={`/workflowEventDef/${throwEventNode.eventDefId?.name}`}
>
{throwEventNode.eventDefId?.name} <ExternalLinkIcon className="h-4 w-4" />
</Link>
</LinkWithTenant>
</div>
</div>

Expand Down
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
import { UserTaskDefDetails } from '@/app/(authenticated)/(diagram)/components/NodeTypes/UserTask/UserTaskDefDetails'
import { UserTaskDefDetails } from '@/app/[tenantId]/(diagram)/components/NodeTypes/UserTask/UserTaskDefDetails'
import LinkWithTenant from '@/app/[tenantId]/components/LinkWithTenant'
import { ExternalLinkIcon, UserIcon } from 'lucide-react'
import Link from 'next/link'
import { FC, memo } from 'react'
import { Handle, Position } from 'reactflow'
import { NodeRunsList } from '../../NodeRunsList'
import { Fade } from '../Fade'
import { NodeProps } from '../index'
import { NodeDetails } from '../NodeDetails'
import { NodeRunsList } from '../../NodeRunsList'

const Node: FC<NodeProps> = ({ data, selected }) => {
if (!data.userTask) return null
Expand All @@ -18,13 +18,13 @@ const Node: FC<NodeProps> = ({ data, selected }) => {
<div className="">
<div className="flex items-center gap-1 text-nowrap">
<h3 className="font-bold">UserTask</h3>
<Link
<LinkWithTenant
className="flex items-center justify-center gap-1 text-blue-500 hover:underline"
target="_blank"
href={`/userTaskDef/${userTask.userTaskDefName}`}
>
{userTask.userTaskDefName} <ExternalLinkIcon className="h-4 w-4" />
</Link>
</LinkWithTenant>
</div>
{nodeRun ? (
<NodeRunsList nodeRuns={nodeRunsList} userTaskNode={userTask} nodeRun={nodeRun} />
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { UserAndGroupAssignmentInfo } from '@/app/(authenticated)/(diagram)/components/NodeTypes/UserTask/UserAndGroupAssignmentInfo'
import { UserAndGroupAssignmentInfo } from '@/app/[tenantId]/(diagram)/components/NodeTypes/UserTask/UserAndGroupAssignmentInfo'
import { getVariable } from '@/app/utils'
import { UserTaskNode } from 'littlehorse-client/proto'
import { FC } from 'react'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@ import { PlusIcon } from 'lucide-react'
import { FC, memo } from 'react'
import { Handle, Position } from 'reactflow'
import { NodeProps } from '.'
import { NodeRunsList } from '../NodeRunsList'
import { Fade } from './Fade'
import { NodeDetails } from './NodeDetails'
import { NodeRunsList } from '@/app/(authenticated)/(diagram)/components/NodeRunsList'

const Node: FC<NodeProps> = ({ data }) => {
const { fade, nodeRunsList } = data
Expand Down
Loading

0 comments on commit 06ec897

Please sign in to comment.