Skip to content

Commit 03eb2ab

Browse files
achettyiitrachettyiitr
authored
chore: revert "feat: adapting to helpers in go-kit" (#4561)
1 parent 3c515dd commit 03eb2ab

File tree

82 files changed

+729
-430
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

82 files changed

+729
-430
lines changed

‎app/app.go

-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ import (
1212

1313
"github.com/rudderlabs/rudder-go-kit/config"
1414
"github.com/rudderlabs/rudder-go-kit/logger"
15-
1615
backendconfig "github.com/rudderlabs/rudder-server/backend-config"
1716
configenv "github.com/rudderlabs/rudder-server/enterprise/config-env"
1817
"github.com/rudderlabs/rudder-server/enterprise/replay"

‎app/apphandlers/embeddedAppHandler.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -48,10 +48,10 @@ type embeddedApp struct {
4848
log logger.Logger
4949
config struct {
5050
enableReplay bool
51-
processorDSLimit config.ValueLoader[int]
52-
routerDSLimit config.ValueLoader[int]
53-
batchRouterDSLimit config.ValueLoader[int]
54-
gatewayDSLimit config.ValueLoader[int]
51+
processorDSLimit misc.ValueLoader[int]
52+
routerDSLimit misc.ValueLoader[int]
53+
batchRouterDSLimit misc.ValueLoader[int]
54+
gatewayDSLimit misc.ValueLoader[int]
5555
}
5656
}
5757

‎app/apphandlers/gatewayAppHandler.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@ import (
1111
"github.com/rudderlabs/rudder-go-kit/config"
1212
"github.com/rudderlabs/rudder-go-kit/logger"
1313
"github.com/rudderlabs/rudder-go-kit/stats"
14-
1514
"github.com/rudderlabs/rudder-server/app"
1615
"github.com/rudderlabs/rudder-server/app/cluster"
1716
backendconfig "github.com/rudderlabs/rudder-server/backend-config"
@@ -34,7 +33,7 @@ type gatewayApp struct {
3433
versionHandler func(w http.ResponseWriter, r *http.Request)
3534
log logger.Logger
3635
config struct {
37-
gatewayDSLimit config.ValueLoader[int]
36+
gatewayDSLimit misc.ValueLoader[int]
3837
}
3938
}
4039

‎app/apphandlers/processorAppHandler.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -49,10 +49,10 @@ type processorApp struct {
4949
versionHandler func(w http.ResponseWriter, r *http.Request)
5050
log logger.Logger
5151
config struct {
52-
processorDSLimit config.ValueLoader[int]
53-
routerDSLimit config.ValueLoader[int]
54-
batchRouterDSLimit config.ValueLoader[int]
55-
gatewayDSLimit config.ValueLoader[int]
52+
processorDSLimit misc.ValueLoader[int]
53+
routerDSLimit misc.ValueLoader[int]
54+
batchRouterDSLimit misc.ValueLoader[int]
55+
gatewayDSLimit misc.ValueLoader[int]
5656
http struct {
5757
ReadTimeout time.Duration
5858
ReadHeaderTimeout time.Duration

‎app/cluster/integration_test.go

-1
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ import (
2020
"github.com/rudderlabs/rudder-go-kit/config"
2121
"github.com/rudderlabs/rudder-go-kit/logger"
2222
"github.com/rudderlabs/rudder-go-kit/stats"
23-
2423
"github.com/rudderlabs/rudder-server/admin"
2524
"github.com/rudderlabs/rudder-server/app/cluster"
2625
arc "github.com/rudderlabs/rudder-server/archiver"

‎backend-config/backend-config.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,11 @@ import (
1919
"github.com/rudderlabs/rudder-go-kit/config"
2020
"github.com/rudderlabs/rudder-go-kit/logger"
2121
"github.com/rudderlabs/rudder-go-kit/stats"
22-
2322
"github.com/rudderlabs/rudder-server/backend-config/internal/cache"
2423
"github.com/rudderlabs/rudder-server/rruntime"
2524
"github.com/rudderlabs/rudder-server/services/controlplane/identity"
2625
"github.com/rudderlabs/rudder-server/services/diagnostics"
26+
"github.com/rudderlabs/rudder-server/utils/misc"
2727
"github.com/rudderlabs/rudder-server/utils/pubsub"
2828
"github.com/rudderlabs/rudder-server/utils/sysUtils"
2929
"github.com/rudderlabs/rudder-server/utils/types"
@@ -34,7 +34,7 @@ var (
3434
// environment variables
3535
configBackendURL string
3636
cpRouterURL string
37-
pollInterval config.ValueLoader[time.Duration]
37+
pollInterval misc.ValueLoader[time.Duration]
3838
configJSONPath string
3939
configFromFile bool
4040
configEnvReplacementEnabled bool

‎backend-config/backend_config_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,10 @@ import (
2323
"github.com/rudderlabs/rudder-go-kit/config"
2424
"github.com/rudderlabs/rudder-go-kit/logger"
2525
"github.com/rudderlabs/rudder-go-kit/stats"
26-
2726
adminpkg "github.com/rudderlabs/rudder-server/admin"
2827
"github.com/rudderlabs/rudder-server/backend-config/internal/cache"
2928
"github.com/rudderlabs/rudder-server/services/diagnostics"
29+
"github.com/rudderlabs/rudder-server/utils/misc"
3030
"github.com/rudderlabs/rudder-server/utils/pubsub"
3131
"github.com/rudderlabs/rudder-server/utils/types/deployment"
3232
)
@@ -331,7 +331,7 @@ func TestWaitForConfig(t *testing.T) {
331331
defer ctrl.Finish()
332332

333333
pkgLogger = logger.NOP
334-
pollInterval = config.SingleValueLoader(time.Millisecond)
334+
pollInterval = misc.SingleValueLoader(time.Millisecond)
335335
bc := &backendConfigImpl{initialized: false}
336336

337337
var done int32

‎cmd/backupfilemigrator/file_migrator.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ import (
1212
"strings"
1313
"time"
1414

15-
"github.com/rudderlabs/rudder-go-kit/stringify"
1615
obskit "github.com/rudderlabs/rudder-observability-kit/go/labels"
1716

1817
kitconfig "github.com/rudderlabs/rudder-go-kit/config"
@@ -32,7 +31,6 @@ import (
3231

3332
"github.com/rudderlabs/rudder-go-kit/filemanager"
3433
kitlogger "github.com/rudderlabs/rudder-go-kit/logger"
35-
3634
"github.com/rudderlabs/rudder-server/enterprise/replay/utils"
3735
)
3836

@@ -118,7 +116,7 @@ func (m *fileMigrator) convertToNewFormat(lineBytes []byte, createdAt time.Time)
118116
j.UserID = userID
119117
j.EventPayload = payloadBytes
120118
j.CreatedAt = createdAt
121-
j.MessageID = stringify.Data(singleEvent["messageId"])
119+
j.MessageID = misc.GetStringifiedData(singleEvent["messageId"])
122120
listOfNewEvents = append(listOfNewEvents, j)
123121
}
124122
return listOfNewEvents, nil

‎enterprise/reporting/error_extractor.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ import (
1111

1212
"github.com/rudderlabs/rudder-go-kit/config"
1313
"github.com/rudderlabs/rudder-go-kit/logger"
14+
"github.com/rudderlabs/rudder-server/utils/misc"
1415
)
1516

1617
const (
@@ -68,7 +69,7 @@ var lowercasedDeprecationKeywords = lo.MapKeys(deprecationKeywords, func(_ int,
6869
type ExtractorHandle struct {
6970
log logger.Logger
7071
ErrorMessageKeys []string // the keys where in we may have error message
71-
versionDeprecationThresholdScore config.ValueLoader[int]
72+
versionDeprecationThresholdScore misc.ValueLoader[int]
7273
}
7374

7475
func NewErrorDetailExtractor(log logger.Logger) *ExtractorHandle {

‎enterprise/reporting/error_index/error_index_reporting.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@ import (
1616
"github.com/rudderlabs/rudder-go-kit/logger"
1717
"github.com/rudderlabs/rudder-go-kit/stats"
1818
kitsync "github.com/rudderlabs/rudder-go-kit/sync"
19-
2019
"github.com/rudderlabs/rudder-server/jobsdb"
20+
"github.com/rudderlabs/rudder-server/utils/misc"
2121
. "github.com/rudderlabs/rudder-server/utils/tx" //nolint:staticcheck
2222
"github.com/rudderlabs/rudder-server/utils/types"
2323
"github.com/rudderlabs/rudder-server/utils/workerpool"
@@ -43,7 +43,7 @@ type ErrorIndexReporter struct {
4343
update kitsync.Limiter
4444
}
4545

46-
concurrency config.ValueLoader[int]
46+
concurrency misc.ValueLoader[int]
4747

4848
statsFactory stats.Stats
4949
stats struct {

‎enterprise/reporting/error_index/worker.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -55,11 +55,11 @@ type worker struct {
5555
lastUploadTime time.Time
5656

5757
config struct {
58-
parquetParallelWriters, parquetRowGroupSize, parquetPageSize config.ValueLoader[int64]
58+
parquetParallelWriters, parquetRowGroupSize, parquetPageSize misc.ValueLoader[int64]
5959
bucketName, instanceID string
60-
payloadLimit, eventsLimit config.ValueLoader[int64]
60+
payloadLimit, eventsLimit misc.ValueLoader[int64]
6161
minWorkerSleep, uploadFrequency, jobsDBCommandTimeout time.Duration
62-
jobsDBMaxRetries config.ValueLoader[int]
62+
jobsDBMaxRetries misc.ValueLoader[int]
6363
}
6464
}
6565

‎enterprise/reporting/error_index/worker_test.go

+10-10
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@ import (
3636
kitsync "github.com/rudderlabs/rudder-go-kit/sync"
3737
"github.com/rudderlabs/rudder-go-kit/testhelper/docker/resource/minio"
3838
"github.com/rudderlabs/rudder-go-kit/testhelper/docker/resource/postgres"
39-
4039
"github.com/rudderlabs/rudder-server/jobsdb"
40+
"github.com/rudderlabs/rudder-server/utils/misc"
4141
warehouseutils "github.com/rudderlabs/rudder-server/warehouse/utils"
4242
)
4343

@@ -84,9 +84,9 @@ func TestWorkerWriter(t *testing.T) {
8484
buf := bytes.NewBuffer(make([]byte, 0, 1024))
8585

8686
w := worker{}
87-
w.config.parquetRowGroupSize = config.SingleValueLoader(512 * bytesize.MB)
88-
w.config.parquetPageSize = config.SingleValueLoader(8 * bytesize.KB)
89-
w.config.parquetParallelWriters = config.SingleValueLoader(int64(8))
87+
w.config.parquetRowGroupSize = misc.SingleValueLoader(512 * bytesize.MB)
88+
w.config.parquetPageSize = misc.SingleValueLoader(8 * bytesize.KB)
89+
w.config.parquetParallelWriters = misc.SingleValueLoader(int64(8))
9090

9191
require.NoError(t, w.encodeToParquet(buf, toEncode))
9292

@@ -125,9 +125,9 @@ func TestWorkerWriter(t *testing.T) {
125125
require.NoError(t, err)
126126

127127
w := worker{}
128-
w.config.parquetRowGroupSize = config.SingleValueLoader(512 * bytesize.MB)
129-
w.config.parquetPageSize = config.SingleValueLoader(8 * bytesize.KB)
130-
w.config.parquetParallelWriters = config.SingleValueLoader(int64(8))
128+
w.config.parquetRowGroupSize = misc.SingleValueLoader(512 * bytesize.MB)
129+
w.config.parquetPageSize = misc.SingleValueLoader(8 * bytesize.KB)
130+
w.config.parquetParallelWriters = misc.SingleValueLoader(int64(8))
131131

132132
require.NoError(t, w.encodeToParquet(fw, toEncode))
133133

@@ -713,9 +713,9 @@ func BenchmarkFileFormat(b *testing.B) {
713713
}
714714

715715
w := worker{}
716-
w.config.parquetRowGroupSize = config.SingleValueLoader(512 * bytesize.MB)
717-
w.config.parquetPageSize = config.SingleValueLoader(8 * bytesize.KB)
718-
w.config.parquetParallelWriters = config.SingleValueLoader(int64(8))
716+
w.config.parquetRowGroupSize = misc.SingleValueLoader(512 * bytesize.MB)
717+
w.config.parquetPageSize = misc.SingleValueLoader(8 * bytesize.KB)
718+
w.config.parquetParallelWriters = misc.SingleValueLoader(int64(8))
719719

720720
buf := bytes.NewBuffer(make([]byte, 0, 1024))
721721

‎enterprise/reporting/error_reporting.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@ import (
2222
"github.com/rudderlabs/rudder-go-kit/config"
2323
"github.com/rudderlabs/rudder-go-kit/logger"
2424
"github.com/rudderlabs/rudder-go-kit/stats"
25-
2625
migrator "github.com/rudderlabs/rudder-server/services/sql-migrator"
2726
"github.com/rudderlabs/rudder-server/utils/httputil"
27+
"github.com/rudderlabs/rudder-server/utils/misc"
2828
. "github.com/rudderlabs/rudder-server/utils/tx" //nolint:staticcheck
2929
"github.com/rudderlabs/rudder-server/utils/types"
3030
)
@@ -65,9 +65,9 @@ type ErrorDetailReporter struct {
6565

6666
instanceID string
6767
region string
68-
sleepInterval config.ValueLoader[time.Duration]
69-
mainLoopSleepInterval config.ValueLoader[time.Duration]
70-
maxConcurrentRequests config.ValueLoader[int]
68+
sleepInterval misc.ValueLoader[time.Duration]
69+
mainLoopSleepInterval misc.ValueLoader[time.Duration]
70+
maxConcurrentRequests misc.ValueLoader[int]
7171
maxOpenConnections int
7272

7373
httpClient *http.Client

‎enterprise/reporting/reporting.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,9 @@ import (
2525
"github.com/rudderlabs/rudder-go-kit/config"
2626
"github.com/rudderlabs/rudder-go-kit/logger"
2727
"github.com/rudderlabs/rudder-go-kit/stats"
28-
2928
migrator "github.com/rudderlabs/rudder-server/services/sql-migrator"
3029
"github.com/rudderlabs/rudder-server/utils/httputil"
30+
"github.com/rudderlabs/rudder-server/utils/misc"
3131
. "github.com/rudderlabs/rudder-server/utils/tx" //nolint:staticcheck
3232
"github.com/rudderlabs/rudder-server/utils/types"
3333
)
@@ -61,12 +61,12 @@ type DefaultReporter struct {
6161
instanceID string
6262
whActionsOnly bool
6363
region string
64-
sleepInterval config.ValueLoader[time.Duration]
65-
mainLoopSleepInterval config.ValueLoader[time.Duration]
64+
sleepInterval misc.ValueLoader[time.Duration]
65+
mainLoopSleepInterval misc.ValueLoader[time.Duration]
6666
dbQueryTimeout *config.Reloadable[time.Duration]
6767
sourcesWithEventNameTrackingDisabled []string
6868
maxOpenConnections int
69-
maxConcurrentRequests config.ValueLoader[int]
69+
maxConcurrentRequests misc.ValueLoader[int]
7070

7171
getMinReportedAtQueryTime stats.Measurement
7272
getReportsQueryTime stats.Measurement

‎enterprise/suppress-user/factory.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ func (m *Factory) retryIndefinitely(ctx context.Context, f func() error, wait ti
189189
}
190190
}
191191

192-
func (m *Factory) newSyncerWithBadgerRepo(repoPath string, seederSource func() (io.ReadCloser, error), maxSeedWaitTime time.Duration, identity identity.Identifier, pollInterval config.ValueLoader[time.Duration]) (*Syncer, Repository, error) {
192+
func (m *Factory) newSyncerWithBadgerRepo(repoPath string, seederSource func() (io.ReadCloser, error), maxSeedWaitTime time.Duration, identity identity.Identifier, pollInterval misc.ValueLoader[time.Duration]) (*Syncer, Repository, error) {
193193
repo, err := NewBadgerRepository(
194194
repoPath,
195195
m.Log,

‎gateway/gateway_test.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ import (
1717
"time"
1818

1919
kithelper "github.com/rudderlabs/rudder-go-kit/testhelper"
20-
kituuid "github.com/rudderlabs/rudder-go-kit/uuid"
2120

2221
"github.com/golang/mock/gomock"
2322
"github.com/google/uuid"
@@ -31,7 +30,6 @@ import (
3130
"github.com/rudderlabs/rudder-go-kit/logger"
3231
"github.com/rudderlabs/rudder-go-kit/stats"
3332
"github.com/rudderlabs/rudder-go-kit/stats/memstats"
34-
3533
"github.com/rudderlabs/rudder-server/admin"
3634
"github.com/rudderlabs/rudder-server/app"
3735
backendconfig "github.com/rudderlabs/rudder-server/backend-config"
@@ -221,7 +219,7 @@ var _ = Describe("Reconstructing JSON for ServerSide SDK", func() {
221219
{"anonymousId":"anon_id_1","event":"event_1_3"}
222220
]}`
223221
response, payloadError := getUsersPayload([]byte(testValidBody))
224-
key, err := kituuid.GetMD5UUID(inputKey)
222+
key, err := misc.GetMD5UUID(inputKey)
225223
Expect(string(response[key.String()])).To(Equal(value))
226224
Expect(err).To(BeNil())
227225
Expect(payloadError).To(BeNil())

‎gateway/handle.go

+9-13
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,6 @@ import (
1717
"github.com/tidwall/gjson"
1818
"github.com/tidwall/sjson"
1919

20-
"github.com/rudderlabs/rudder-go-kit/sanitize"
21-
"github.com/rudderlabs/rudder-go-kit/stringify"
22-
kituuid "github.com/rudderlabs/rudder-go-kit/uuid"
23-
2420
"github.com/rudderlabs/rudder-go-kit/config"
2521
"github.com/rudderlabs/rudder-go-kit/logger"
2622
"github.com/rudderlabs/rudder-go-kit/stats"
@@ -101,18 +97,18 @@ type Handle struct {
10197
conf struct { // configuration parameters
10298
webPort, maxUserWebRequestWorkerProcess, maxDBWriterProcess int
10399
maxUserWebRequestBatchSize, maxDBBatchSize, maxHeaderBytes, maxConcurrentRequests int
104-
userWebRequestBatchTimeout, dbBatchWriteTimeout config.ValueLoader[time.Duration]
100+
userWebRequestBatchTimeout, dbBatchWriteTimeout misc.ValueLoader[time.Duration]
105101

106-
maxReqSize config.ValueLoader[int]
107-
enableRateLimit config.ValueLoader[bool]
102+
maxReqSize misc.ValueLoader[int]
103+
enableRateLimit misc.ValueLoader[bool]
108104
enableSuppressUserFeature bool
109105
diagnosisTickerTime time.Duration
110106
ReadTimeout time.Duration
111107
ReadHeaderTimeout time.Duration
112108
WriteTimeout time.Duration
113109
IdleTimeout time.Duration
114-
allowReqsWithoutUserIDAndAnonymousID config.ValueLoader[bool]
115-
gwAllowPartialWriteWithErrors config.ValueLoader[bool]
110+
allowReqsWithoutUserIDAndAnonymousID misc.ValueLoader[bool]
111+
gwAllowPartialWriteWithErrors misc.ValueLoader[bool]
116112
}
117113

118114
// additional internal http handlers
@@ -284,7 +280,7 @@ func (gw *Handle) getJobDataFromRequest(req *webRequestT) (jobData *jobFromReq,
284280

285281
fillMessageID := func(event map[string]interface{}) {
286282
messageID, _ := event["messageId"].(string)
287-
messageID = strings.TrimSpace(sanitize.Unicode(messageID))
283+
messageID = strings.TrimSpace(misc.SanitizeUnicode(messageID))
288284
if messageID == "" {
289285
event["messageId"] = uuid.New().String()
290286
} else {
@@ -334,8 +330,8 @@ func (gw *Handle) getJobDataFromRequest(req *webRequestT) (jobData *jobFromReq,
334330
return
335331
}
336332

337-
anonIDFromReq := strings.TrimSpace(sanitize.Unicode(stringify.Data(toSet["anonymousId"])))
338-
userIDFromReq := strings.TrimSpace(sanitize.Unicode(stringify.Data(toSet["userId"])))
333+
anonIDFromReq := strings.TrimSpace(misc.SanitizeUnicode(misc.GetStringifiedData(toSet["anonymousId"])))
334+
userIDFromReq := strings.TrimSpace(misc.SanitizeUnicode(misc.GetStringifiedData(toSet["userId"])))
339335
eventTypeFromReq, _ := misc.MapLookup(
340336
toSet,
341337
"type",
@@ -392,7 +388,7 @@ func (gw *Handle) getJobDataFromRequest(req *webRequestT) (jobData *jobFromReq,
392388

393389
// hashing combination of userIDFromReq + anonIDFromReq, using colon as a delimiter
394390
var rudderId uuid.UUID
395-
rudderId, err = kituuid.GetMD5UUID(userIDFromReq + ":" + anonIDFromReq)
391+
rudderId, err = misc.GetMD5UUID(userIDFromReq + ":" + anonIDFromReq)
396392
if err != nil {
397393
err = errors.New(response.NonIdentifiableRequest)
398394
return

0 commit comments

Comments
 (0)