+3 -1

knotserver/ingester.go

Reviewed

··· 8 8 "net/http" 9 9 "net/url" 10 10 "path/filepath" 11 11 + "strings" 11 12 12 13 comatproto "github.com/bluesky-social/indigo/api/atproto" 13 14 "github.com/bluesky-social/indigo/atproto/syntax" ··· 21 22 knotxrpc "tangled.org/core/knotserver/xrpc" 22 23 "tangled.org/core/log" 23 24 "tangled.org/core/rbac" 25 25 + "tangled.org/core/tid" 24 26 "tangled.org/core/workflow" 25 27 ) 26 28 ··· 356 358 } 357 359 358 360 ev := db.Event{ 359 359 - Rkey: TID(), 361 361 + Rkey: tid.TID(), 360 362 Nsid: tangled.PipelineNSID, 361 363 EventJson: string(eventJson), 362 364 }

+3 -2

knotserver/internal.go

Reviewed

··· 25 25 "tangled.org/core/log" 26 26 "tangled.org/core/notifier" 27 27 "tangled.org/core/rbac" 28 28 + "tangled.org/core/tid" 28 29 "tangled.org/core/workflow" 29 30 ) 30 31 ··· 312 313 } 313 314 314 315 event := db.Event{ 315 315 - Rkey: TID(), 316 316 + Rkey: tid.TID(), 316 317 Nsid: tangled.GitRefUpdateNSID, 317 318 EventJson: string(eventJson), 318 319 } ··· 416 417 } 417 418 418 419 event := db.Event{ 419 419 - Rkey: TID(), 420 420 + Rkey: tid.TID(), 420 421 Nsid: tangled.PipelineNSID, 421 422 EventJson: string(eventJson), 422 423 }

-11

knotserver/util.go

Reviewed

··· 1 1 - package knotserver 2 2 - 3 3 - import ( 4 4 - "github.com/bluesky-social/indigo/atproto/syntax" 5 5 - ) 6 6 - 7 7 - var TIDClock = syntax.NewTIDClock(0) 8 8 - 9 9 - func TID() string { 10 10 - return TIDClock.Next().String() 11 11 - }