Function TestTestmoPlugin

backend/test/e2e/manual/testmo/testmo_test.go:37–147

(t *testing.T)

const pluginName = "testmo"

func TestTestmoPlugin(t *testing.T) {
	cfg := helper.GetTestConfig[TestConfig]()

	// Disable remote plugins to avoid poetry dependency
	config.GetConfig().Set("DISABLED_REMOTE_PLUGINS", true)

	client := helper.ConnectLocalServer(t, &helper.LocalClientConfig{
		ServerPort:   8089,
		DbURL:        config.GetConfig().GetString("E2E_DB_URL"),
		CreateServer: true,
		DropDb:       true, // Use fresh database for each test run
		TruncateDb:   true,
		Plugins: []plugin.PluginMeta{
			&impl.Testmo{},
		},
	})
	client.SetTimeout(0)
	client.SetPipelineTimeout(0)
	connection := createConnection(cfg, client)
	t.Run("blueprint v200", func(t *testing.T) {
		projectScopes := helper.RemoteScopesOutput{}
		var scopeData []any
		for {
			projectScopes = client.RemoteScopes(helper.RemoteScopesQuery{
				PluginName:   pluginName,
				ConnectionId: connection.ID,
				PageToken:    projectScopes.NextPageToken,
				Params:       nil,
			})
			for _, remoteScope := range projectScopes.Children {
				if remoteScope.Type == "scope" {
					data := helper.Cast[pluginmodels.TestmoProject](remoteScope.Data)
					for _, projectName := range cfg.Projects {
						if projectName == data.Name {
							scopeData = append(scopeData, &data)
						}
					}
				}
			}
			if projectScopes.NextPageToken == "" {
				break
			}
		}
		createdScopes := helper.Cast[[]*pluginmodels.TestmoProject](client.CreateScopes(pluginName, connection.ID, scopeData...))
		require.True(t, len(createdScopes) > 0)

		projectName := fmt.Sprintf("testmo-project-%s-%s", pluginName, "unique")

		outputProject := client.CreateProject(&helper.ProjectConfig{
			ProjectName: projectName,
			EnableDora:  true,
		})

		// Delete any existing blueprints for this project
		if outputProject.Blueprint != nil {
			client.DeleteBlueprint(outputProject.Blueprint.ID)
		}