Implement the registered workflows and activities APIs in testsuite (#1343)

Update TestActivityEnvironment with new APIs so that it implements the ActivityRegistry interface
Update TestWorkflowEnvironment with new APIs so that it implements the Registry interface

Author: ketsiambaku

internal/internal_workflow_testsuite.go

@@ -1884,6 +1884,22 @@ func (env *testWorkflowEnvironmentImpl) ExecuteChildWorkflow(params executeWorkf
 	return env.executeChildWorkflowWithDelay(0, params, callback, startedHandler)
 }
 
+func (env *testWorkflowEnvironmentImpl) GetRegisteredWorkflows() []string {
+	return env.registry.GetRegisteredWorkflows()
+}
+
+func (env *testWorkflowEnvironmentImpl) GetWorkflowFunc(registerName string) (interface{}, bool) {
+	return env.registry.GetWorkflowFunc(registerName)
+}
+
+func (env *testWorkflowEnvironmentImpl) GetRegisteredActivities() []string {
+	return env.registry.GetRegisteredActivities()
+}
+
+func (env *testWorkflowEnvironmentImpl) GetActivityFunc(registerName string) (interface{}, bool) {
+	return env.registry.GetActivityFunc(registerName)
+}
+
 func (env *testWorkflowEnvironmentImpl) executeChildWorkflowWithDelay(delayStart time.Duration, params executeWorkflowParams, callback resultHandler, startedHandler func(r WorkflowExecution, e error)) error {
 	childEnv, err := env.newTestWorkflowEnvironmentForChild(&params, callback, startedHandler)
 	if err != nil {

internal/workflow_testsuite.go

@@ -141,6 +141,14 @@ func (t *TestActivityEnvironment) RegisterActivityWithOptions(a interface{}, opt
 	t.impl.RegisterActivityWithOptions(a, options)
 }
 
+func (t *TestActivityEnvironment) GetRegisteredActivities() []string {
+	return t.impl.GetRegisteredActivities()
+}
+
+func (t *TestActivityEnvironment) GetActivityFunc(registerName string) (interface{}, bool) {
+	return t.impl.GetActivityFunc(registerName)
+}
+
 // ExecuteActivity executes an activity. The tested activity will be executed synchronously in the calling goroutinue.
 // Caller should use Value.Get() to extract strong typed result value.
 func (t *TestActivityEnvironment) ExecuteActivity(activityFn interface{}, args ...interface{}) (Value, error) {
@@ -206,6 +214,22 @@ func (t *TestWorkflowEnvironment) RegisterActivityWithOptions(a interface{}, opt
 	t.impl.RegisterActivityWithOptions(a, options)
 }
 
+func (t *TestWorkflowEnvironment) GetRegisteredWorkflows() []string {
+	return t.impl.GetRegisteredWorkflows()
+}
+
+func (t *TestWorkflowEnvironment) GetWorkflowFunc(registerName string) (interface{}, bool) {
+	return t.impl.GetWorkflowFunc(registerName)
+}
+
+func (t *TestWorkflowEnvironment) GetRegisteredActivities() []string {
+	return t.impl.GetRegisteredActivities()
+}
+
+func (t *TestWorkflowEnvironment) GetActivityFunc(registerName string) (interface{}, bool) {
+	return t.impl.GetActivityFunc(registerName)
+}
+
 // SetStartTime sets the start time of the workflow. This is optional, default start time will be the wall clock time when
 // workflow starts. Start time is the workflow.Now(ctx) time at the beginning of the workflow.
 func (t *TestWorkflowEnvironment) SetStartTime(startTime time.Time) {