sinq/internal/luapi/lua-api.go at v0.0.2 · Veitangie/sinq · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
// sinq - A concurrent integration testing tool
// Copyright (C) 2026 Veitangie
// SPDX-License-Identifier: GPL-3.0-or-later
package luapi

import (
	"bytes"
	_ "embed"
	"sync"

	lua "github.com/yuin/gopher-lua"
	"github.com/yuin/gopher-lua/parse"
)

//go:embed lua/retry-when.lua
var retryWhenScript []byte

var RetryWhen func() *lua.FunctionProto = sync.OnceValue(func() *lua.FunctionProto {
	ast, err := parse.Parse(bytes.NewReader(retryWhenScript), "luapi")
	if err != nil {
		panic(err)
	}
	compiled, err := lua.Compile(ast, "luapi")
	if err != nil {
		panic(err)
	}
	return compiled
})

//go:embed lua/retry-exponential.lua
var retryExponentialScript []byte

var RetryExponential func() *lua.FunctionProto = sync.OnceValue(func() *lua.FunctionProto {
	ast, err := parse.Parse(bytes.NewReader(retryExponentialScript), "luapi")
	if err != nil {
		panic(err)
	}
	compiled, err := lua.Compile(ast, "luapi")
	if err != nil {
		panic(err)
	}
	return compiled
})

//go:embed lua/retry-jitter.lua
var retryJitterScript []byte

var RetryJitter func() *lua.FunctionProto = sync.OnceValue(func() *lua.FunctionProto {
	ast, err := parse.Parse(bytes.NewReader(retryJitterScript), "luapi")
	if err != nil {
		panic(err)
	}
	compiled, err := lua.Compile(ast, "luapi")
	if err != nil {
		panic(err)
	}
	return compiled
})

//go:embed lua/assert-code.lua
var assertCodeScript []byte

var AssertCode func() *lua.FunctionProto = sync.OnceValue(func() *lua.FunctionProto {
	ast, err := parse.Parse(bytes.NewReader(assertCodeScript), "luapi")
	if err != nil {
		panic(err)
	}
	compiled, err := lua.Compile(ast, "luapi")
	if err != nil {
		panic(err)
	}
	return compiled
})

//go:embed lua/assert-equals.lua
var assertEqualsScript []byte

var AssertEquals func() *lua.FunctionProto = sync.OnceValue(func() *lua.FunctionProto {
	ast, err := parse.Parse(bytes.NewReader(assertEqualsScript), "luapi")
	if err != nil {
		panic(err)
	}
	compiled, err := lua.Compile(ast, "luapi")
	if err != nil {
		panic(err)
	}
	return compiled
})

//go:embed lua/assert-contains.lua
var assertContainsScript []byte

var AssertContains func() *lua.FunctionProto = sync.OnceValue(func() *lua.FunctionProto {
	ast, err := parse.Parse(bytes.NewReader(assertContainsScript), "luapi")
	if err != nil {
		panic(err)
	}
	compiled, err := lua.Compile(ast, "luapi")
	if err != nil {
		panic(err)
	}
	return compiled
})

//go:embed lua/assert-condition.lua
var assertConditionScript []byte

var AssertCondition func() *lua.FunctionProto = sync.OnceValue(func() *lua.FunctionProto {
	ast, err := parse.Parse(bytes.NewReader(assertConditionScript), "luapi")
	if err != nil {
		panic(err)
	}
	compiled, err := lua.Compile(ast, "luapi")
	if err != nil {
		panic(err)
	}
	return compiled
})