Class TransitionViewerPlugin

java.lang.Object

com.scivicslab.actoriac.plugins.transitionviewer.TransitionViewerPlugin

All Implemented Interfaces:

com.scivicslab.pojoactor.core.CallableByActionName, com.scivicslab.pojoactor.workflow.ActorSystemAware

public class TransitionViewerPlugin
extends Object
implements com.scivicslab.pojoactor.core.CallableByActionName, com.scivicslab.pojoactor.workflow.ActorSystemAware

ワークフロー実行時に記録されたTransition履歴を表示するプラグイン。

指定したアクター（ノードまたはNodeGroup）のTransition履歴を データベースから取得し、人間が読みやすい形式で出力する。

アクション:

• showTransitions - 指定アクターのTransition履歴を表示

使用例（ワークフロー）:

- actor: loader
  method: createChild
  arguments: ["ROOT", "transitionViewer", "com.scivicslab.actoriac.plugins.transitionviewer.TransitionViewerPlugin"]
- actor: transitionViewer
  method: showTransitions
  arguments:
    target: "node-localhost"

Since:

2.15.0

Author:

devteam@scivicslab.com

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TransitionViewerPlugin.SessionInfo	セッション情報を保持する内部クラス。
private static class	TransitionViewerPlugin.TransitionEntry	Transition履歴エントリ。

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	CLASS_NAME
private Connection	connection
private static final Logger	logger
private com.scivicslab.pojoactor.workflow.IIActorSystem	system
private static final DateTimeFormatter	TIME_FORMAT

Constructor Summary

Constructors

Constructor	Description
TransitionViewerPlugin()	デフォルトコンストラクタ。loader.createChildで使用される。

Method Summary

Modifier and Type	Method	Description
private String	buildAggregatedOutput(long sessionId)	NodeGroupと配下ノードの集約出力を構築する。
private String	buildSingleActorOutput(String source, long sessionId)	単一アクターのTransition履歴を構築する。
com.scivicslab.pojoactor.core.ActionResult	callByActionName(String actionName, String args)
private String	extractTransition(String message)	後方互換性のためのラッパー
private String[]	extractTransitionAndNote(String message)	messageから状態遷移とnoteを抽出する。 例: "Transition SUCCESS: 0 -> 1" → ["0 -> 1", ""] 例: "Transition SUCCESS: 0 -> 1 [Collect info]" → ["0 -> 1", "Collect info"] 例: "[node-localhost] Transition SUCCESS: 1 -> 2 [Process data]" → ["1 -> 2", "Process data"]
private long	getSessionIdFromNodeGroup()
private void	initConnection()
private void	outputToMultiplexer(String data)
private List<String>	queryDistinctSources(long sessionId)	セッション内でTransitionを記録した全アクターを取得する。
private TransitionViewerPlugin.SessionInfo	querySessionInfo(long sessionId)	セッション情報（ワークフロー名、説明）を取得する。
private List<TransitionViewerPlugin.TransitionEntry>	queryTransitions(String source, long sessionId)	指定アクターのTransitionログをクエリする。
private String	readWorkflowDescription(String cwd, String workflowName)	ワークフローYAMLからdescriptionを読み取る。
void	setActorSystem(com.scivicslab.pojoactor.workflow.IIActorSystem system)
void	setConnection(Connection connection)	テスト用にデータベース接続を設定する。
private com.scivicslab.pojoactor.core.ActionResult	showTransitions(String args)	指定されたアクターのTransition履歴を表示する。

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_NAME

private static final String CLASS_NAME

logger

private static final Logger logger

TIME_FORMAT

private static final DateTimeFormatter TIME_FORMAT

system

private com.scivicslab.pojoactor.workflow.IIActorSystem system

connection

private Connection connection

Constructor Details

TransitionViewerPlugin

public TransitionViewerPlugin()

デフォルトコンストラクタ。loader.createChildで使用される。

Method Details

initConnection

private void initConnection()

setActorSystem

public void setActorSystem(com.scivicslab.pojoactor.workflow.IIActorSystem system)

Specified by:

setActorSystem in interface com.scivicslab.pojoactor.workflow.ActorSystemAware

setConnection

public void setConnection(Connection connection)

テスト用にデータベース接続を設定する。

callByActionName

public com.scivicslab.pojoactor.core.ActionResult callByActionName(String actionName,
 String args)

Specified by:

callByActionName in interface com.scivicslab.pojoactor.core.CallableByActionName

showTransitions

private com.scivicslab.pojoactor.core.ActionResult showTransitions(String args)

指定されたアクターのTransition履歴を表示する。

Parameters:

args - JSON形式の引数 - target: アクター名（必須） - session: セッションID（省略時は最新） - includeChildren: trueの場合、配下ノードも含める

buildSingleActorOutput

private String buildSingleActorOutput(String source,
 long sessionId)
                               throws Exception

単一アクターのTransition履歴を構築する。

Throws:

Exception

buildAggregatedOutput

private String buildAggregatedOutput(long sessionId)
                              throws Exception

NodeGroupと配下ノードの集約出力を構築する。

Throws:

Exception

queryTransitions

private List<TransitionViewerPlugin.TransitionEntry> queryTransitions(String source,
 long sessionId)
                                                               throws Exception

指定アクターのTransitionログをクエリする。

Throws:

Exception

queryDistinctSources

private List<String> queryDistinctSources(long sessionId)
                                   throws Exception

セッション内でTransitionを記録した全アクターを取得する。

Throws:

Exception

querySessionInfo

private TransitionViewerPlugin.SessionInfo querySessionInfo(long sessionId)
                                                     throws Exception

セッション情報（ワークフロー名、説明）を取得する。

Throws:

Exception

readWorkflowDescription

private String readWorkflowDescription(String cwd,
 String workflowName)

ワークフローYAMLからdescriptionを読み取る。

getSessionIdFromNodeGroup

private long getSessionIdFromNodeGroup()

extractTransitionAndNote

private String[] extractTransitionAndNote(String message)

messageから状態遷移とnoteを抽出する。 例: "Transition SUCCESS: 0 -> 1" → ["0 -> 1", ""] 例: "Transition SUCCESS: 0 -> 1 [Collect info]" → ["0 -> 1", "Collect info"] 例: "[node-localhost] Transition SUCCESS: 1 -> 2 [Process data]" → ["1 -> 2", "Process data"]

Returns:

String[2] where [0]=transition, [1]=note

extractTransition

private String extractTransition(String message)

後方互換性のためのラッパー

outputToMultiplexer

private void outputToMultiplexer(String data)