mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Alex ShtinandGitHub
8e8f1b0f7c
## What changed?
<!-- Describe what has changed in this PR -->
Remove license header from every file. Because it is really hard to
follow in this PR here is the summary:
1. License header is removed from all `.go` and `.proto` files
:fireworks::fireworks:🎆.
2. `LICENSE` file in the root directory has only Temporal and Uber
copyrights.
3. 5 other `LICENSE` files added to the packages which have copyrights
different from Temporal and Uber: Datadog, Xargin, "Mat Ryer, Tyler
Bunnell and contributors".
4. `license_file` flag is removed from all code generation tools.
5. `copyright_file` flag is removed from `go:generate mockgen`
directive.
6. All copyright related targets are removed from `Makefile`.
7. Updated Temporal copyright year to 2025 everywhere.
## Why?
<!-- Tell your future self why have you made these changes -->
I double checked with legal department that it is not needed to have
license header in every file. One file per repo is enough. I put all
copyrights to the root `LICENSE` file and removed header from all other
files. Also updated tools and `Makefile`.
122 lines
3.4 KiB
Go
122 lines
3.4 KiB
Go
package clitest
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
"github.com/stretchr/testify/suite"
|
|
"go.temporal.io/server/common/config"
|
|
"go.temporal.io/server/common/dynamicconfig"
|
|
persistencetests "go.temporal.io/server/common/persistence/persistence-tests"
|
|
persistencesql "go.temporal.io/server/common/persistence/sql"
|
|
"go.temporal.io/server/common/primitives"
|
|
"go.temporal.io/server/common/resolver"
|
|
"go.temporal.io/server/tools/sql"
|
|
)
|
|
|
|
type (
|
|
// VersionTestSuite defines a test suite
|
|
VersionTestSuite struct {
|
|
*require.Assertions // override suite.Suite.Assertions with require.Assertions; this means that s.NotNil(nil) will stop the test, not merely log an error
|
|
suite.Suite
|
|
|
|
host string
|
|
port string
|
|
pluginName string
|
|
executionSchemaFileLocation string
|
|
visibilitySchemaFileLocation string
|
|
}
|
|
)
|
|
|
|
// NewVersionTestSuite returns a test suite
|
|
func NewVersionTestSuite(
|
|
host string,
|
|
port string,
|
|
pluginName string,
|
|
executionSchemaFileLocation string,
|
|
visibilitySchemaFileLocation string,
|
|
) *VersionTestSuite {
|
|
return &VersionTestSuite{
|
|
host: host,
|
|
port: port,
|
|
pluginName: pluginName,
|
|
executionSchemaFileLocation: executionSchemaFileLocation,
|
|
visibilitySchemaFileLocation: visibilitySchemaFileLocation,
|
|
}
|
|
}
|
|
|
|
// SetupTest setups test suite
|
|
func (s *VersionTestSuite) SetupTest() {
|
|
s.Assertions = require.New(s.T()) // Have to define our overridden assertions in the test setup. If we did it earlier, s.T() will return nil
|
|
}
|
|
|
|
// TestVerifyCompatibleVersion test
|
|
func (s *VersionTestSuite) TestVerifyCompatibleVersion() {
|
|
database := "temporal_ver_test_" + persistencetests.GenerateRandomDBName(3)
|
|
visDatabase := "temporal_vis_ver_test_" + persistencetests.GenerateRandomDBName(3)
|
|
|
|
defer s.createDatabase(database)()
|
|
defer s.createDatabase(visDatabase)()
|
|
err := sql.RunTool([]string{
|
|
"./tool",
|
|
"-ep", s.host,
|
|
"-p", s.port,
|
|
"-u", testUser,
|
|
"-pw", testPassword,
|
|
"-db", database,
|
|
"-pl", s.pluginName,
|
|
"-q",
|
|
"setup-schema",
|
|
"-f", s.executionSchemaFileLocation,
|
|
"-version", "10.0",
|
|
"-o",
|
|
})
|
|
s.NoError(err)
|
|
err = sql.RunTool([]string{
|
|
"./tool",
|
|
"-ep", s.host,
|
|
"-p", s.port,
|
|
"-u", testUser,
|
|
"-pw", testPassword,
|
|
"-db", visDatabase,
|
|
"-pl", s.pluginName,
|
|
"-q",
|
|
"setup-schema",
|
|
"-f", s.visibilitySchemaFileLocation,
|
|
"-version", "10.0",
|
|
"-o",
|
|
})
|
|
s.NoError(err)
|
|
|
|
defaultCfg := config.SQL{
|
|
ConnectAddr: fmt.Sprintf("%v:%v", s.host, s.port),
|
|
User: testUser,
|
|
Password: testPassword,
|
|
PluginName: s.pluginName,
|
|
DatabaseName: database,
|
|
}
|
|
visibilityCfg := defaultCfg
|
|
visibilityCfg.DatabaseName = visDatabase
|
|
cfg := config.Persistence{
|
|
DefaultStore: "default",
|
|
VisibilityStore: "visibility",
|
|
DataStores: map[string]config.DataStore{
|
|
"default": {SQL: &defaultCfg},
|
|
"visibility": {SQL: &visibilityCfg},
|
|
},
|
|
TransactionSizeLimit: dynamicconfig.GetIntPropertyFn(primitives.DefaultTransactionSizeLimit),
|
|
}
|
|
s.NoError(persistencesql.VerifyCompatibleVersion(cfg, resolver.NewNoopResolver()))
|
|
}
|
|
|
|
func (s *VersionTestSuite) createDatabase(database string) func() {
|
|
connection, err := newTestConn("", s.host, s.port, s.pluginName)
|
|
s.NoError(err)
|
|
err = connection.CreateDatabase(database)
|
|
s.NoError(err)
|
|
return func() {
|
|
s.NoError(connection.DropDatabase(database))
|
|
connection.Close()
|
|
}
|
|
}
|