mirror of
https://github.com/temporalio/temporal.git
synced 2026-08-30 18:41:49 -07:00
91893f1064
## 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`.
112 lines
3.0 KiB
Go
112 lines
3.0 KiB
Go
package testing
|
|
|
|
import (
|
|
"fmt"
|
|
"runtime/debug"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/suite"
|
|
historypb "go.temporal.io/api/history/v1"
|
|
)
|
|
|
|
type (
|
|
historyEventTestSuit struct {
|
|
suite.Suite
|
|
generator Generator
|
|
}
|
|
)
|
|
|
|
func TestHistoryEventTestSuite(t *testing.T) {
|
|
suite.Run(t, new(historyEventTestSuit))
|
|
}
|
|
|
|
func (s *historyEventTestSuit) SetupSuite() {
|
|
s.generator = InitializeHistoryEventGenerator("namespace", "ns-id", 1)
|
|
}
|
|
|
|
func (s *historyEventTestSuit) SetupTest() {
|
|
s.generator.Reset()
|
|
}
|
|
|
|
// This is a sample about how to use the generator
|
|
func (s *historyEventTestSuit) Test_HistoryEvent_Generator() {
|
|
defer func() {
|
|
if r := recover(); r != nil {
|
|
fmt.Println("stacktrace from panic: \n" + string(debug.Stack()))
|
|
}
|
|
}()
|
|
maxEventID := int64(0)
|
|
maxVersion := int64(1)
|
|
maxTaskID := int64(1)
|
|
for i := 0; i < 10 && s.generator.HasNextVertex(); i++ {
|
|
events := s.generator.GetNextVertices()
|
|
|
|
fmt.Println("########################")
|
|
for _, e := range events {
|
|
event := e.GetData().(*historypb.HistoryEvent)
|
|
if maxEventID != event.GetEventId()-1 {
|
|
s.Fail("event id sequence is incorrect")
|
|
}
|
|
maxEventID = event.GetEventId()
|
|
if maxVersion > event.GetVersion() {
|
|
s.Fail("event version is incorrect")
|
|
}
|
|
maxVersion = event.GetVersion()
|
|
if maxTaskID > event.GetTaskId() {
|
|
s.Fail("event task id is incorrect")
|
|
}
|
|
maxTaskID = event.GetTaskId()
|
|
fmt.Println(e.GetName())
|
|
fmt.Println(event.GetEventId())
|
|
}
|
|
}
|
|
s.NotEmpty(s.generator.ListGeneratedVertices())
|
|
fmt.Println("==========================")
|
|
branchGenerator1 := s.generator.DeepCopy()
|
|
for i := 0; i < 10 && branchGenerator1.HasNextVertex(); i++ {
|
|
events := branchGenerator1.GetNextVertices()
|
|
fmt.Println("########################")
|
|
for _, e := range events {
|
|
event := e.GetData().(*historypb.HistoryEvent)
|
|
if maxEventID != event.GetEventId()-1 {
|
|
s.Fail("event id sequence is incorrect")
|
|
}
|
|
maxEventID = event.GetEventId()
|
|
if maxVersion > event.GetVersion() {
|
|
s.Fail("event version is incorrect")
|
|
}
|
|
maxVersion = event.GetVersion()
|
|
if maxTaskID > event.GetTaskId() {
|
|
s.Fail("event task id is incorrect")
|
|
}
|
|
maxTaskID = event.GetTaskId()
|
|
fmt.Println(e.GetName())
|
|
fmt.Println(event.GetEventId())
|
|
}
|
|
}
|
|
fmt.Println("==========================")
|
|
history := s.generator.ListGeneratedVertices()
|
|
maxEventID = history[len(history)-1].GetData().(*historypb.HistoryEvent).GetEventId()
|
|
for i := 0; i < 10 && s.generator.HasNextVertex(); i++ {
|
|
events := s.generator.GetNextVertices()
|
|
fmt.Println("########################")
|
|
for _, e := range events {
|
|
event := e.GetData().(*historypb.HistoryEvent)
|
|
if maxEventID != event.GetEventId()-1 {
|
|
s.Fail("event id sequence is incorrect")
|
|
}
|
|
maxEventID = event.GetEventId()
|
|
if maxVersion > event.GetVersion() {
|
|
s.Fail("event version is incorrect")
|
|
}
|
|
maxVersion = event.GetVersion()
|
|
if maxTaskID > event.GetTaskId() {
|
|
s.Fail("event task id is incorrect")
|
|
}
|
|
maxTaskID = event.GetTaskId()
|
|
fmt.Println(e.GetName())
|
|
fmt.Println(event.GetEventId())
|
|
}
|
|
}
|
|
}
|