shared

package
v0.28.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 9, 2026 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StageNoopNodeViaAgentPatch added in v0.28.0 

func StageNoopNodeViaAgentPatch(
	t *testing.T,
	organizationID uuid.UUID,
	userID uuid.UUID,
	canvasID uuid.UUID,
	nodeName string,
	pos models.Position,
)

StageNoopNodeViaAgentPatch stages a noop node the same way the managed agent does (patch_staging -> PutCanvasStaging -> staging_updated websocket).

Types

type CanvasSteps 

type CanvasSteps struct {
	CanvasName string
	WorkflowID uuid.UUID
	// contains filtered or unexported fields
}

func NewCanvasSteps 

func NewCanvasSteps(name string, t *testing.T, session *session.TestSession) *CanvasSteps

func (*CanvasSteps) AddApproval 

func (s *CanvasSteps) AddApproval(nodeName string, pos models.Position)

func (*CanvasSteps) AddBuildingBlockByTestID added in v0.22.0 

func (s *CanvasSteps) AddBuildingBlockByTestID(blockTestID string, pos models.Position)

func (*CanvasSteps) AddFilter added in v0.1.4 

func (s *CanvasSteps) AddFilter(name string, pos models.Position)

func (*CanvasSteps) AddManualTrigger 

func (s *CanvasSteps) AddManualTrigger(name string, pos models.Position)

func (*CanvasSteps) AddNoop 

func (s *CanvasSteps) AddNoop(name string, pos models.Position)

func (*CanvasSteps) AddNoopWithDefaultName added in v0.1.4 

func (s *CanvasSteps) AddNoopWithDefaultName(pos models.Position) string

AddNoopWithDefaultName adds a noop node using the auto-generated name and returns that name.

func (*CanvasSteps) AddNote added in v0.16.0 

func (s *CanvasSteps) AddNote()

func (*CanvasSteps) AddTimeGate 

func (s *CanvasSteps) AddTimeGate(name string, pos models.Position)

func (*CanvasSteps) AddWait 

func (s *CanvasSteps) AddWait(name string, pos models.Position, duration int, unit string)

func (*CanvasSteps) AssertDraftCommittedHasNode added in v0.26.0 

func (s *CanvasSteps) AssertDraftCommittedHasNode(versionID uuid.UUID, nodeName string)

AssertDraftCommittedHasNode verifies a node exists on the committed version row (not staging).

func (*CanvasSteps) AssertDraftCommittedLacksNode added in v0.26.0 

func (s *CanvasSteps) AssertDraftCommittedLacksNode(versionID uuid.UUID, nodeName string)

AssertDraftCommittedLacksNode verifies a node is absent from the committed version row.

func (*CanvasSteps) AssertDraftCount added in v0.25.0 

func (s *CanvasSteps) AssertDraftCount(expected int)

AssertDraftCount is deprecated and only checks that a live version exists when expected > 0.

func (*CanvasSteps) AssertEditModeTabChrome added in v0.28.0 

func (s *CanvasSteps) AssertEditModeTabChrome()

AssertEditModeTabChrome verifies the header tabs use edit-mode orange styling.

func (*CanvasSteps) AssertHasStaging added in v0.26.0 

func (s *CanvasSteps) AssertHasStaging(_ uuid.UUID)

AssertHasStaging verifies the current user has workflow_staged_files rows.

func (*CanvasSteps) AssertHasStagingForUser added in v0.28.0 

func (s *CanvasSteps) AssertHasStagingForUser(userID uuid.UUID)

AssertHasStagingForUser verifies a specific user has workflow_staged_files rows.

func (*CanvasSteps) AssertLiveCanvasHasNode added in v0.26.0 

func (s *CanvasSteps) AssertLiveCanvasHasNode(nodeName string)

AssertLiveCanvasHasNode verifies a node exists on the live (published) canvas.

func (*CanvasSteps) AssertLiveCanvasLacksNode added in v0.28.0 

func (s *CanvasSteps) AssertLiveCanvasLacksNode(nodeName string)

AssertLiveCanvasLacksNode verifies a node is absent from the materialized live canvas.

func (*CanvasSteps) AssertLiveVersionCommitMessage added in v0.28.0 

func (s *CanvasSteps) AssertLiveVersionCommitMessage(message string)

AssertLiveVersionCommitMessage verifies the live version commit message.

func (*CanvasSteps) AssertLiveVersionHasNode added in v0.28.0 

func (s *CanvasSteps) AssertLiveVersionHasNode(nodeName string)

AssertLiveVersionHasNode verifies a node exists on the live version spec row.

func (*CanvasSteps) AssertLiveVersionLacksNode added in v0.28.0 

func (s *CanvasSteps) AssertLiveVersionLacksNode(nodeName string)

AssertLiveVersionLacksNode verifies a node is absent from the live version spec row.

func (*CanvasSteps) AssertNoStaging added in v0.26.0 

func (s *CanvasSteps) AssertNoStaging(_ uuid.UUID)

AssertNoStaging verifies the current user has no workflow_staged_files rows.

func (*CanvasSteps) AssertNoStagingForUser added in v0.28.0 

func (s *CanvasSteps) AssertNoStagingForUser(userID uuid.UUID)

AssertNoStagingForUser verifies a specific user has no workflow_staged_files rows.

func (*CanvasSteps) AssertStagingActionsVisibleAndDisabled added in v0.28.0 

func (s *CanvasSteps) AssertStagingActionsVisibleAndDisabled()

AssertStagingActionsVisibleAndDisabled verifies commit/reset stay visible but disabled with no staged changes.

func (*CanvasSteps) AssertStagingActionsVisibleAndEnabled added in v0.28.0 

func (s *CanvasSteps) AssertStagingActionsVisibleAndEnabled()

AssertStagingActionsVisibleAndEnabled verifies commit/reset are visible and actionable once staging exists.

func (*CanvasSteps) AssertStagingStaleForUser added in v0.28.0 

func (s *CanvasSteps) AssertStagingStaleForUser(userID uuid.UUID)

AssertStagingStaleForUser verifies staged files were created against an older live version.

func (*CanvasSteps) AssertVersionCountAtLeast added in v0.28.0 

func (s *CanvasSteps) AssertVersionCountAtLeast(expected int)

AssertVersionCountAtLeast verifies the canvas has at least the expected number of versions.

func (*CanvasSteps) AssertVersionHistoryContains added in v0.28.0 

func (s *CanvasSteps) AssertVersionHistoryContains(labels ...string)

AssertVersionHistoryContains verifies commit labels appear in the versions sidebar.

func (*CanvasSteps) ClickOnEmptyCanvasArea added in v0.14.0 

func (s *CanvasSteps) ClickOnEmptyCanvasArea()

ClickOnEmptyCanvasArea clicks on an empty area of the canvas to dismiss any open sidebars and deselect all nodes.

func (*CanvasSteps) CommitAndPublish added in v0.26.0 

func (s *CanvasSteps) CommitAndPublish()

CommitAndPublish commits staged edits to main (commit replaces publish).

func (*CanvasSteps) CommitStaging added in v0.26.0 

func (s *CanvasSteps) CommitStaging()

CommitStaging opens the commit dialog, submits a message, and waits for staging to clear.

func (*CanvasSteps) Connect 

func (s *CanvasSteps) Connect(sourceName, targetName string)

func (*CanvasSteps) Create 

func (s *CanvasSteps) Create()

func (*CanvasSteps) CreatePublishedWithParameterizedManualRun added in v0.24.0 

func (s *CanvasSteps) CreatePublishedWithParameterizedManualRun()

func (*CanvasSteps) DeleteConnection 

func (s *CanvasSteps) DeleteConnection(sourceName, targetName string)

func (*CanvasSteps) DraftCommittedNodeNames added in v0.26.0 

func (s *CanvasSteps) DraftCommittedNodeNames(versionID uuid.UUID) []string

DraftCommittedNodeNames returns node names stored on the committed draft version row.

func (*CanvasSteps) DraftEffectiveSpec added in v0.26.0 

func (s *CanvasSteps) DraftEffectiveSpec() ([]models.Node, []models.Edge)

DraftEffectiveSpec returns nodes and edges from staged canvas.yaml when present, otherwise from the live version row.

func (*CanvasSteps) DraftNodeByName added in v0.26.0 

func (s *CanvasSteps) DraftNodeByName(name string) (models.Node, bool)

DraftNodeByName returns a node from the effective draft state (staged or committed).

func (*CanvasSteps) EmitManualTrigger added in v0.22.0 

func (s *CanvasSteps) EmitManualTrigger(name string)

func (*CanvasSteps) EnterEditMode added in v0.17.0 

func (s *CanvasSteps) EnterEditMode()

EnterEditMode clicks the Edit button in the header to start editing the live canvas. This must be called before making any canvas changes.

func (*CanvasSteps) EnterEditModeWithoutStagingActionAssertions added in v0.28.0 

func (s *CanvasSteps) EnterEditModeWithoutStagingActionAssertions()

EnterEditModeWithoutStagingActionAssertions enters edit mode without assuming which staging actions the current user's permissions allow.

func (*CanvasSteps) ExitEditMode added in v0.25.0 

func (s *CanvasSteps) ExitEditMode()

ExitEditMode leaves edit mode and returns to the live canvas view. Commit already ends the edit session in the UI; this is a no-op when live view is active.

func (*CanvasSteps) FindCurrentDraft added in v0.17.0 

func (s *CanvasSteps) FindCurrentDraft() *models.CanvasVersion

FindCurrentDraft returns the live canvas version used as the staging base.

func (*CanvasSteps) FindDraftByDisplayName added in v0.26.0 

func (s *CanvasSteps) FindDraftByDisplayName(_ string) *models.CanvasVersion

FindDraftByDisplayName returns the live version (display names are no longer used).

func (*CanvasSteps) GetExecutionsForNode 

func (s *CanvasSteps) GetExecutionsForNode(name string) []models.CanvasNodeExecution

func (*CanvasSteps) GetExecutionsForNodeInState 

func (s *CanvasSteps) GetExecutionsForNodeInState(name string, state string) []models.CanvasNodeExecution

func (*CanvasSteps) GetExecutionsForNodeInStates added in v0.1.6 

func (s *CanvasSteps) GetExecutionsForNodeInStates(name string, states []string) []models.CanvasNodeExecution

func (*CanvasSteps) GetNodeFromDB 

func (s *CanvasSteps) GetNodeFromDB(name string) *models.CanvasNode

func (*CanvasSteps) GetWorkflowFromDB 

func (s *CanvasSteps) GetWorkflowFromDB() *models.Canvas

func (*CanvasSteps) ListDraftVersions added in v0.25.0 

func (s *CanvasSteps) ListDraftVersions() []models.CanvasVersion

ListDraftVersions is deprecated; editable state is per-user staging on the live canvas.

func (*CanvasSteps) LiveVersionID added in v0.28.0 

func (s *CanvasSteps) LiveVersionID() uuid.UUID

LiveVersionID returns the current live workflow_versions row id.

func (*CanvasSteps) LoginAs added in v0.28.0 

func (s *CanvasSteps) LoginAs(account *models.Account)

LoginAs switches the browser session to another account in the same organization.

func (*CanvasSteps) OpenBuildingBlockCategory added in v0.22.0 

func (s *CanvasSteps) OpenBuildingBlockCategory(categoryName string)

func (*CanvasSteps) OpenBuildingBlocksSidebar 

func (s *CanvasSteps) OpenBuildingBlocksSidebar()

func (*CanvasSteps) OpenVersionsSidebar added in v0.25.0 

func (s *CanvasSteps) OpenVersionsSidebar()

OpenVersionsSidebar reveals the versions sidebar from the current canvas mode. If the header toggle is not available yet, it enters edit mode first.

func (*CanvasSteps) Publish added in v0.17.0 

func (s *CanvasSteps) Publish()

Publish is deprecated; use CommitStaging or CommitAndPublish instead.

func (*CanvasSteps) RenameNode 

func (s *CanvasSteps) RenameNode(name string, newName string)

func (*CanvasSteps) RunManualTrigger 

func (s *CanvasSteps) RunManualTrigger(name string)

func (*CanvasSteps) RunParameterizedManualTrigger added in v0.24.0 

func (s *CanvasSteps) RunParameterizedManualTrigger(name string, parameters map[string]string)

func (*CanvasSteps) Save 

func (s *CanvasSteps) Save()

func (*CanvasSteps) SelectAllNodes added in v0.14.0 

func (s *CanvasSteps) SelectAllNodes()

SelectAllNodes performs a rubber-band drag selection across the entire visible canvas area to select all nodes. The sidebar must be closed before calling this.

func (*CanvasSteps) SelectRunInSidebar added in v0.26.0 

func (s *CanvasSteps) SelectRunInSidebar(runID string)

SelectRunInSidebar opens run inspection by selecting a run from the runs sidebar.

func (*CanvasSteps) SelectVersionInHistorySidebar added in v0.28.0 

func (s *CanvasSteps) SelectVersionInHistorySidebar(versionLabel string)

SelectVersionInHistorySidebar selects a commit in the versions sidebar history list.

func (*CanvasSteps) StageNoopNodeViaAgentPatch added in v0.28.0 

func (s *CanvasSteps) StageNoopNodeViaAgentPatch(nodeName string, pos models.Position)

StageNoopNodeViaAgentPatch is a CanvasSteps wrapper around StageNoopNodeViaAgentPatch.

func (*CanvasSteps) StagingContainsNodeForUser added in v0.28.0 

func (s *CanvasSteps) StagingContainsNodeForUser(userID uuid.UUID, nodeName string) bool

StagingContainsNodeForUser reports whether a user's staged canvas.yaml includes a node name.

func (*CanvasSteps) StartAddingTimeGate 

func (s *CanvasSteps) StartAddingTimeGate(name string, pos models.Position)

func (*CanvasSteps) StartEditingNode 

func (s *CanvasSteps) StartEditingNode(name string)

func (*CanvasSteps) UserIDForEmail added in v0.28.0 

func (s *CanvasSteps) UserIDForEmail(email string) uuid.UUID

UserIDForEmail resolves the organization user id for an account email.

func (*CanvasSteps) Visit 

func (s *CanvasSteps) Visit()

func (*CanvasSteps) WaitForEnabledExitEditButton added in v0.26.0 

func (s *CanvasSteps) WaitForEnabledExitEditButton()

func (*CanvasSteps) WaitForExecution 

func (s *CanvasSteps) WaitForExecution(name string, state string, timeout time.Duration)

func (*CanvasSteps) WaitForExecutionInStates added in v0.1.6 

func (s *CanvasSteps) WaitForExecutionInStates(name string, states []string, timeout time.Duration)

func (*CanvasSteps) WaitForPublishEnabled added in v0.26.0 

func (s *CanvasSteps) WaitForPublishEnabled()

WaitForPublishEnabled is deprecated; commit replaces publish.

func (*CanvasSteps) WaitForRunsSidebar added in v0.26.0 

func (s *CanvasSteps) WaitForRunsSidebar()

WaitForRunsSidebar waits until the runs sidebar is visible on the canvas tab.

func (*CanvasSteps) WaitForStaging added in v0.26.0 

func (s *CanvasSteps) WaitForStaging(_ uuid.UUID)

WaitForStaging waits until the current user has workflow_staged_files rows.

func (*CanvasSteps) WaitForStagingOnCurrentDraft added in v0.26.0 

func (s *CanvasSteps) WaitForStagingOnCurrentDraft() uuid.UUID

WaitForStagingOnCurrentDraft waits until the current user has staging rows and returns the live version id.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.