This is an automated email from the ASF dual-hosted git repository. lahirujayathilake pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/airavata-custos.git
commit 1d7f16cbfc61ff8f51e1cac0e3931ec6b36aaebc Author: lahiruj <[email protected]> AuthorDate: Mon Apr 20 16:00:15 2026 -0400 Add person soft-delete, email dedup, and GlobalID mapping for AMIE merge support - Replace hard-delete with soft-delete (is_active flag) on person merge - Deduplicate persons by email to avoid creating multiple accounts for the same person with different ACCESS Global IDs - Add person_global_ids mapping table so a person can be looked up by any of their historical Global IDs - Rename amie_audit_logs table to amie_audit_log --- .../{store/audit_store.go => db/errors.go} | 31 +- .../db/migrations/000001_initial_schema.down.sql | 3 +- .../db/migrations/000001_initial_schema.up.sql | 17 +- allocations/access-amie/main.go | 19 +- allocations/access-amie/service/account_service.go | 17 +- .../access-amie/service/membership_service.go | 4 + allocations/access-amie/service/person_service.go | 112 +++-- .../access-amie/service/person_service_test.go | 117 ++++-- allocations/access-amie/service/project_service.go | 4 + allocations/access-amie/store/audit_store.go | 2 +- allocations/access-amie/worker/processor.go | 27 +- allocations/domain/model/person.go | 7 + allocations/domain/store/person_store.go | 46 ++- allocations/domain/store/stores.go | 9 + allocations/go.work.sum | 451 +++++++++++++++++++++ 15 files changed, 750 insertions(+), 116 deletions(-) diff --git a/allocations/access-amie/store/audit_store.go b/allocations/access-amie/db/errors.go similarity index 53% copy from allocations/access-amie/store/audit_store.go copy to allocations/access-amie/db/errors.go index 5a06e15df..aed2591c1 100644 --- a/allocations/access-amie/store/audit_store.go +++ b/allocations/access-amie/db/errors.go @@ -15,32 +15,17 @@ // specific language governing permissions and limitations // under the License. -package store +package db import ( - "context" - "database/sql" + "errors" - "github.com/apache/airavata-custos/allocations/access-amie/model" - "github.com/jmoiron/sqlx" + "github.com/go-sql-driver/mysql" ) -type AuditStore interface { - Save(ctx context.Context, tx *sql.Tx, a *model.AuditLog) error -} - -type mariaDBauditStore struct { - db *sqlx.DB -} - -func NewAuditStore(db *sqlx.DB) AuditStore { - return &mariaDBauditStore{db: db} -} - -func (s *mariaDBauditStore) Save(ctx context.Context, tx *sql.Tx, a *model.AuditLog) error { - _, err := tx.ExecContext(ctx, - `INSERT INTO amie_audit_logs (packet_id, event_id, action, entity_type, entity_id, summary, created_at) - VALUES (?, ?, ?, ?, ?, ?, ?)`, - a.PacketID, a.EventID, a.Action, a.EntityType, a.EntityID, a.Summary, a.CreatedAt) - return err +// IsDuplicateKeyError returns true if the error is a MariaDB/MySQL duplicate +// key violation (error code 1062). +func IsDuplicateKeyError(err error) bool { + var dbErr *mysql.MySQLError + return errors.As(err, &dbErr) && dbErr.Number == 1062 } diff --git a/allocations/access-amie/db/migrations/000001_initial_schema.down.sql b/allocations/access-amie/db/migrations/000001_initial_schema.down.sql index 7821cf204..0affd31bb 100644 --- a/allocations/access-amie/db/migrations/000001_initial_schema.down.sql +++ b/allocations/access-amie/db/migrations/000001_initial_schema.down.sql @@ -15,7 +15,7 @@ -- specific language governing permissions and limitations -- under the License. -DROP TABLE IF EXISTS amie_audit_logs; +DROP TABLE IF EXISTS amie_audit_log; DROP TABLE IF EXISTS amie_processing_errors; DROP TABLE IF EXISTS amie_processing_events; DROP TABLE IF EXISTS amie_packets; @@ -23,4 +23,5 @@ DROP TABLE IF EXISTS project_memberships; DROP TABLE IF EXISTS projects; DROP TABLE IF EXISTS cluster_accounts; DROP TABLE IF EXISTS person_dns; +DROP TABLE IF EXISTS person_global_ids; DROP TABLE IF EXISTS persons; diff --git a/allocations/access-amie/db/migrations/000001_initial_schema.up.sql b/allocations/access-amie/db/migrations/000001_initial_schema.up.sql index beacd370d..51870b778 100644 --- a/allocations/access-amie/db/migrations/000001_initial_schema.up.sql +++ b/allocations/access-amie/db/migrations/000001_initial_schema.up.sql @@ -28,10 +28,23 @@ CREATE TABLE IF NOT EXISTS persons organization VARCHAR(255) NULL, org_code VARCHAR(255) NULL, nsf_status_code VARCHAR(32) NULL, + is_active BOOLEAN NOT NULL DEFAULT TRUE, created_at TIMESTAMP(6) NOT NULL DEFAULT CURRENT_TIMESTAMP(6), updated_at TIMESTAMP(6) NOT NULL DEFAULT CURRENT_TIMESTAMP(6) ON UPDATE CURRENT_TIMESTAMP(6), PRIMARY KEY (id), - UNIQUE KEY uq_persons_amie_global_id (access_global_id) + UNIQUE KEY uq_persons_amie_global_id (access_global_id), + KEY idx_persons_active (is_active), + KEY idx_persons_email (email) +) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 COLLATE = utf8mb4_unicode_ci; + +CREATE TABLE IF NOT EXISTS person_global_ids +( + id BIGINT NOT NULL AUTO_INCREMENT, + person_id VARCHAR(255) NOT NULL, + global_id VARCHAR(255) NOT NULL, + PRIMARY KEY (id), + CONSTRAINT fk_global_ids_person FOREIGN KEY (person_id) REFERENCES persons (id) ON DELETE CASCADE, + UNIQUE KEY uq_person_global_id (global_id) ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 COLLATE = utf8mb4_unicode_ci; CREATE TABLE IF NOT EXISTS person_dns @@ -142,7 +155,7 @@ CREATE TABLE IF NOT EXISTS amie_processing_errors KEY idx_errors_amie_occurred_at (occurred_at) ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 COLLATE = utf8mb4_unicode_ci; -CREATE TABLE IF NOT EXISTS amie_audit_logs +CREATE TABLE IF NOT EXISTS amie_audit_log ( id BIGINT NOT NULL AUTO_INCREMENT, packet_id VARCHAR(255) NOT NULL, diff --git a/allocations/access-amie/main.go b/allocations/access-amie/main.go index 77e78b424..74ddd4d42 100644 --- a/allocations/access-amie/main.go +++ b/allocations/access-amie/main.go @@ -22,6 +22,7 @@ import ( "log/slog" "os" "os/signal" + "sync" "syscall" "github.com/apache/airavata-custos/allocations/access-amie/amieclient" @@ -61,6 +62,7 @@ func main() { personStore := domainstore.NewPersonStore(database) personDNStore := domainstore.NewPersonDNStore(database) + personGlobalIDStore := domainstore.NewPersonGlobalIDStore(database) accountStore := domainstore.NewClusterAccountStore(database) projectStore := domainstore.NewProjectStore(database) membershipStore := domainstore.NewMembershipStore(database) @@ -69,7 +71,7 @@ func main() { errorStore := store.NewProcessingErrorStore(database) auditStore := store.NewAuditStore(database) - personSvc := service.NewPersonService(personStore, personDNStore, accountStore) + personSvc := service.NewPersonService(personStore, personDNStore, accountStore, personGlobalIDStore) accountSvc := service.NewUserAccountService(accountStore) projectSvc := service.NewProjectService(projectStore) membershipSvc := service.NewProjectMembershipService(membershipStore, projectStore, accountStore) @@ -108,13 +110,22 @@ func main() { ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM) defer cancel() - go poller.Run(ctx) - go processor.Run(ctx) + var wg sync.WaitGroup + wg.Add(2) + go func() { + defer wg.Done() + poller.Run(ctx) + }() + go func() { + defer wg.Done() + processor.Run(ctx) + }() slog.Info("access-amie service started successfully") <-ctx.Done() - slog.Info("shutting down...") + slog.Info("shutting down, waiting for workers to finish...") + wg.Wait() if err := srv.Shutdown(context.Background()); err != nil { slog.Error("HTTP server shutdown error", "error", err) } diff --git a/allocations/access-amie/service/account_service.go b/allocations/access-amie/service/account_service.go index 632fb224c..473e104c2 100644 --- a/allocations/access-amie/service/account_service.go +++ b/allocations/access-amie/service/account_service.go @@ -23,7 +23,9 @@ import ( "fmt" "log/slog" "strings" + "time" + "github.com/apache/airavata-custos/allocations/access-amie/db" "github.com/apache/airavata-custos/allocations/domain/model" "github.com/google/uuid" ) @@ -59,16 +61,19 @@ func (s *UserAccountService) ProvisionClusterAccount(ctx context.Context, tx *sq return nil, fmt.Errorf("account_service: ensuring unique username for person %s: %w", person.ID, err) } + now := time.Now().UTC() acct := &model.ClusterAccount{ - ID: uuid.NewString(), - PersonID: person.ID, - Username: uniqueUsername, + ID: uuid.NewString(), + PersonID: person.ID, + Username: uniqueUsername, + CreatedAt: now, + UpdatedAt: now, } if err := s.accounts.Save(ctx, tx, acct); err != nil { - // Handle MySQL duplicate key race condition: another transaction - // may have inserted a record between our check and insert. - if strings.Contains(err.Error(), "Duplicate entry") { + // Handle MariaDB duplicate key race condition: + // another transaction may have inserted a record between our check and insert. + if db.IsDuplicateKeyError(err) { retryExisting, retryErr := s.accounts.FindByPerson(ctx, person.ID) if retryErr != nil { return nil, fmt.Errorf("account_service: retry finding accounts for person %s: %w", person.ID, retryErr) diff --git a/allocations/access-amie/service/membership_service.go b/allocations/access-amie/service/membership_service.go index 119107b53..f2233efcb 100644 --- a/allocations/access-amie/service/membership_service.go +++ b/allocations/access-amie/service/membership_service.go @@ -22,6 +22,7 @@ import ( "database/sql" "fmt" "log/slog" + "time" "github.com/apache/airavata-custos/allocations/domain/model" "github.com/google/uuid" @@ -81,12 +82,15 @@ func (s *ProjectMembershipService) CreateMembership(ctx context.Context, tx *sql return existing, nil } + now := time.Now().UTC() m := &model.ProjectMembership{ ID: uuid.NewString(), ProjectID: projectID, ClusterAccountID: clusterAccountID, Role: &role, IsActive: true, + CreatedAt: now, + UpdatedAt: now, } if err := s.memberships.Save(ctx, tx, m); err != nil { diff --git a/allocations/access-amie/service/person_service.go b/allocations/access-amie/service/person_service.go index ea9391b9d..131a4aeaf 100644 --- a/allocations/access-amie/service/person_service.go +++ b/allocations/access-amie/service/person_service.go @@ -22,6 +22,7 @@ import ( "database/sql" "fmt" "log/slog" + "time" "github.com/apache/airavata-custos/allocations/domain/model" "github.com/google/uuid" @@ -30,7 +31,10 @@ import ( type personStore interface { FindByID(ctx context.Context, id string) (*model.Person, error) FindByAccessGlobalID(ctx context.Context, globalID string) (*model.Person, error) + FindActiveByEmail(ctx context.Context, email string) (*model.Person, error) Save(ctx context.Context, tx *sql.Tx, p *model.Person) error + Update(ctx context.Context, tx *sql.Tx, p *model.Person) error + Deactivate(ctx context.Context, tx *sql.Tx, id string) error Delete(ctx context.Context, tx *sql.Tx, id string) error } @@ -47,29 +51,39 @@ type personAccountStore interface { UpdatePersonID(ctx context.Context, tx *sql.Tx, accountID, newPersonID string) error } +type personGlobalIDStore interface { + FindPersonByGlobalID(ctx context.Context, globalID string) (*model.Person, error) + Save(ctx context.Context, tx *sql.Tx, g *model.PersonGlobalID) error + UpdatePersonID(ctx context.Context, tx *sql.Tx, oldPersonID, newPersonID string) error +} + type PersonService struct { - persons personStore - dns personDNStore - accounts personAccountStore + persons personStore + dns personDNStore + accounts personAccountStore + globalIDs personGlobalIDStore } -func NewPersonService(persons personStore, dns personDNStore, accounts personAccountStore) *PersonService { +func NewPersonService(persons personStore, dns personDNStore, accounts personAccountStore, globalIDs personGlobalIDStore) *PersonService { return &PersonService{ - persons: persons, - dns: dns, - accounts: accounts, + persons: persons, + dns: dns, + accounts: accounts, + globalIDs: globalIDs, } } -// FindOrCreateFromPacket looks up a person by their ACCESS Global ID or -// creates a new person record from the supplied AMIE packet body. +// FindOrCreateFromPacket looks up a person by their ACCESS Global ID (via the +// mapping table), then by email. Creates a new person only if neither lookup +// finds an existing active person. This deduplicates persons who share the same +// email but arrive with different ACCESS Global IDs. func (s *PersonService) FindOrCreateFromPacket(ctx context.Context, tx *sql.Tx, body map[string]any) (*model.Person, error) { globalID, _ := body["UserGlobalID"].(string) if globalID == "" { return nil, fmt.Errorf("person_service: UserGlobalID is required") } - existing, err := s.persons.FindByAccessGlobalID(ctx, globalID) + existing, err := s.globalIDs.FindPersonByGlobalID(ctx, globalID) if err != nil { return nil, fmt.Errorf("person_service: finding person by global ID %s: %w", globalID, err) } @@ -77,10 +91,31 @@ func (s *PersonService) FindOrCreateFromPacket(ctx context.Context, tx *sql.Tx, return existing, nil } + email, _ := body["UserEmail"].(string) + if email != "" { + byEmail, err := s.persons.FindActiveByEmail(ctx, email) + if err != nil { + return nil, fmt.Errorf("person_service: finding person by email %s: %w", email, err) + } + if byEmail != nil { + slog.InfoContext(ctx, "deduplicating person by email", "person_id", byEmail.ID, "email", email, "new_global_id", globalID) + + byEmail.AccessGlobalID = globalID + if err := s.persons.Update(ctx, tx, byEmail); err != nil { + return nil, fmt.Errorf("person_service: updating person %s with new global ID: %w", byEmail.ID, err) + } + g := &model.PersonGlobalID{PersonID: byEmail.ID, GlobalID: globalID} + if err := s.globalIDs.Save(ctx, tx, g); err != nil { + return nil, fmt.Errorf("person_service: saving global ID mapping for person %s: %w", byEmail.ID, err) + } + return byEmail, nil + } + } + firstName, _ := body["UserFirstName"].(string) lastName, _ := body["UserLastName"].(string) - email, _ := body["UserEmail"].(string) + now := time.Now().UTC() p := &model.Person{ ID: uuid.NewString(), AccessGlobalID: globalID, @@ -90,15 +125,22 @@ func (s *PersonService) FindOrCreateFromPacket(ctx context.Context, tx *sql.Tx, Organization: optionalString(body, "UserOrganization"), OrgCode: optionalString(body, "UserOrgCode"), NsfStatusCode: optionalString(body, "NsfStatusCode"), + IsActive: true, + CreatedAt: now, + UpdatedAt: now, } if err := s.persons.Save(ctx, tx, p); err != nil { return nil, fmt.Errorf("person_service: saving new person %s: %w", p.ID, err) } + g := &model.PersonGlobalID{PersonID: p.ID, GlobalID: globalID} + if err := s.globalIDs.Save(ctx, tx, g); err != nil { + return nil, fmt.Errorf("person_service: saving global ID mapping for new person %s: %w", p.ID, err) + } + slog.DebugContext(ctx, "created person from packet", "person_id", p.ID, "global_id", globalID) - // Persist DN list if present. if dnList, ok := body["UserDnList"].([]any); ok { for _, raw := range dnList { dn, _ := raw.(string) @@ -131,7 +173,6 @@ func (s *PersonService) ReplaceFromModifyPacket(ctx context.Context, tx *sql.Tx, return fmt.Errorf("person_service: person %s not found", personID) } - // Update only fields present in the body. if v, ok := body["UserFirstName"]; ok { p.FirstName, _ = v.(string) } @@ -151,7 +192,6 @@ func (s *PersonService) ReplaceFromModifyPacket(ctx context.Context, tx *sql.Tx, p.NsfStatusCode = optionalString(body, "NsfStatusCode") } - // Handle DN list updates. if rawDNs, ok := body["UserDnList"]; ok { dnList, isList := rawDNs.([]any) if isList && len(dnList) > 0 { @@ -184,8 +224,8 @@ func (s *PersonService) ReplaceFromModifyPacket(ctx context.Context, tx *sql.Tx, } } - if err := s.persons.Save(ctx, tx, p); err != nil { - return fmt.Errorf("person_service: saving updated person %s: %w", personID, err) + if err := s.persons.Update(ctx, tx, p); err != nil { + return fmt.Errorf("person_service: updating person %s: %w", personID, err) } slog.DebugContext(ctx, "updated person from modify packet", "person_id", personID) @@ -208,8 +248,10 @@ func (s *PersonService) DeleteFromModifyPacket(ctx context.Context, tx *sql.Tx, return nil } -// MergePersons transfers all accounts and DNs from the retiring person to the -// surviving person, then deletes the retiring person. +// MergePersons transfers all accounts, DNs, and GlobalID mappings from the +// retiring person to the surviving person, then deactivates the retiring person. +// If the retiring person is not found or already inactive (e.g., email dedup +// already consolidated them), the merge is treated as a no-op. func (s *PersonService) MergePersons(ctx context.Context, tx *sql.Tx, survivingID, retiringID string) error { surviving, err := s.persons.FindByID(ctx, survivingID) if err != nil { @@ -224,10 +266,14 @@ func (s *PersonService) MergePersons(ctx context.Context, tx *sql.Tx, survivingI return fmt.Errorf("person_service: finding retiring person %s: %w", retiringID, err) } if retiring == nil { - return fmt.Errorf("person_service: retiring person %s not found", retiringID) + slog.WarnContext(ctx, "retiring person not found, merge is a no-op (may have been deduplicated)", "retiring_id", retiringID, "surviving_id", survivingID) + return nil + } + if !retiring.IsActive { + slog.WarnContext(ctx, "retiring person already inactive, merge is a no-op", "retiring_id", retiringID, "surviving_id", survivingID) + return nil } - // Move cluster accounts from the retiring person to the surviving person. retiringAccounts, err := s.accounts.FindByPerson(ctx, retiringID) if err != nil { return fmt.Errorf("person_service: finding accounts for retiring person %s: %w", retiringID, err) @@ -257,18 +303,34 @@ func (s *PersonService) MergePersons(ctx context.Context, tx *sql.Tx, survivingI } } - // Delete the retiring person; cascade rules handle related records. - if err := s.persons.Delete(ctx, tx, retiringID); err != nil { - return fmt.Errorf("person_service: deleting retiring person %s: %w", retiringID, err) + if err := s.globalIDs.UpdatePersonID(ctx, tx, retiringID, survivingID); err != nil { + return fmt.Errorf("person_service: reassigning global IDs from %s to %s: %w", retiringID, survivingID, err) + } + + if err := s.persons.Deactivate(ctx, tx, retiringID); err != nil { + return fmt.Errorf("person_service: deactivating retiring person %s: %w", retiringID, err) } - slog.DebugContext(ctx, "merged persons", "surviving_id", survivingID, "retiring_id", retiringID) + slog.InfoContext(ctx, "merged persons", "surviving_id", survivingID, "retiring_id", retiringID) return nil } // PersistDNsForPerson saves any distinguished names that the person does not -// already have. +// already have. Skips gracefully if person is not found or inactive. func (s *PersonService) PersistDNsForPerson(ctx context.Context, tx *sql.Tx, personID string, dnList []string) error { + p, err := s.persons.FindByID(ctx, personID) + if err != nil { + return fmt.Errorf("person_service: finding person %s: %w", personID, err) + } + if p == nil { + slog.WarnContext(ctx, "skipping DN persistence for unknown person (may have been merged/deleted)", "person_id", personID) + return nil + } + if !p.IsActive { + slog.WarnContext(ctx, "skipping DN persistence for inactive person (merged)", "person_id", personID) + return nil + } + for _, dn := range dnList { exists, err := s.dns.ExistsByPersonAndDN(ctx, personID, dn) if err != nil { diff --git a/allocations/access-amie/service/person_service_test.go b/allocations/access-amie/service/person_service_test.go index 621682579..7aeee129e 100644 --- a/allocations/access-amie/service/person_service_test.go +++ b/allocations/access-amie/service/person_service_test.go @@ -58,6 +58,24 @@ func (m *mockPersonStore) Save(ctx context.Context, tx *sql.Tx, p *model.Person) return args.Error(0) } +func (m *mockPersonStore) Update(ctx context.Context, tx *sql.Tx, p *model.Person) error { + args := m.Called(ctx, tx, p) + return args.Error(0) +} + +func (m *mockPersonStore) FindActiveByEmail(ctx context.Context, email string) (*model.Person, error) { + args := m.Called(ctx, email) + if args.Get(0) == nil { + return nil, args.Error(1) + } + return args.Get(0).(*model.Person), args.Error(1) +} + +func (m *mockPersonStore) Deactivate(ctx context.Context, tx *sql.Tx, id string) error { + args := m.Called(ctx, tx, id) + return args.Error(0) +} + func (m *mockPersonStore) Delete(ctx context.Context, tx *sql.Tx, id string) error { args := m.Called(ctx, tx, id) return args.Error(0) @@ -112,6 +130,28 @@ func (m *mockPersonAccountStore) UpdatePersonID(ctx context.Context, tx *sql.Tx, return args.Error(0) } +type mockPersonGlobalIDStore struct { + mock.Mock +} + +func (m *mockPersonGlobalIDStore) FindPersonByGlobalID(ctx context.Context, globalID string) (*model.Person, error) { + args := m.Called(ctx, globalID) + if args.Get(0) == nil { + return nil, args.Error(1) + } + return args.Get(0).(*model.Person), args.Error(1) +} + +func (m *mockPersonGlobalIDStore) Save(ctx context.Context, tx *sql.Tx, g *model.PersonGlobalID) error { + args := m.Called(ctx, tx, g) + return args.Error(0) +} + +func (m *mockPersonGlobalIDStore) UpdatePersonID(ctx context.Context, tx *sql.Tx, oldPersonID, newPersonID string) error { + args := m.Called(ctx, tx, oldPersonID, newPersonID) + return args.Error(0) +} + // --------------------------------------------------------------------------- // FindOrCreateFromPacket tests // --------------------------------------------------------------------------- @@ -121,17 +161,18 @@ func TestFindOrCreateFromPacket_FindExistingByGlobalID(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + globalIDs := new(mockPersonGlobalIDStore) + svc := NewPersonService(persons, dns, accounts, globalIDs) existing := &model.Person{ID: "p1", AccessGlobalID: "global-123"} - persons.On("FindByAccessGlobalID", ctx, "global-123").Return(existing, nil) + globalIDs.On("FindPersonByGlobalID", ctx, "global-123").Return(existing, nil) body := map[string]any{"UserGlobalID": "global-123"} got, err := svc.FindOrCreateFromPacket(ctx, nil, body) require.NoError(t, err) assert.Equal(t, existing, got) - persons.AssertExpectations(t) + globalIDs.AssertExpectations(t) } func TestFindOrCreateFromPacket_CreateNewWithAllFields(t *testing.T) { @@ -139,10 +180,13 @@ func TestFindOrCreateFromPacket_CreateNewWithAllFields(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + globalIDs := new(mockPersonGlobalIDStore) + svc := NewPersonService(persons, dns, accounts, globalIDs) - persons.On("FindByAccessGlobalID", ctx, "global-456").Return(nil, nil) + globalIDs.On("FindPersonByGlobalID", ctx, "global-456").Return(nil, nil) + persons.On("FindActiveByEmail", ctx, "[email protected]").Return(nil, nil) persons.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.Person")).Return(nil) + globalIDs.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.PersonGlobalID")).Return(nil) body := map[string]any{ "UserGlobalID": "global-456", @@ -164,6 +208,7 @@ func TestFindOrCreateFromPacket_CreateNewWithAllFields(t *testing.T) { require.NotNil(t, got.Organization) assert.Equal(t, "Test Org", *got.Organization) persons.AssertExpectations(t) + globalIDs.AssertExpectations(t) } func TestFindOrCreateFromPacket_CreateWithDNList(t *testing.T) { @@ -171,10 +216,13 @@ func TestFindOrCreateFromPacket_CreateWithDNList(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + globalIDs := new(mockPersonGlobalIDStore) + svc := NewPersonService(persons, dns, accounts, globalIDs) - persons.On("FindByAccessGlobalID", ctx, "global-789").Return(nil, nil) + globalIDs.On("FindPersonByGlobalID", ctx, "global-789").Return(nil, nil) + persons.On("FindActiveByEmail", ctx, "[email protected]").Return(nil, nil) persons.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.Person")).Return(nil) + globalIDs.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.PersonGlobalID")).Return(nil) dns.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.PersonDN")).Return(nil).Times(2) body := map[string]any{ @@ -190,11 +238,12 @@ func TestFindOrCreateFromPacket_CreateWithDNList(t *testing.T) { require.NotNil(t, got) persons.AssertExpectations(t) dns.AssertExpectations(t) + globalIDs.AssertExpectations(t) } func TestFindOrCreateFromPacket_ErrorOnMissingUserGlobalID(t *testing.T) { ctx := context.Background() - svc := NewPersonService(new(mockPersonStore), new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(new(mockPersonStore), new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) body := map[string]any{"UserFirstName": "No", "UserLastName": "ID"} _, err := svc.FindOrCreateFromPacket(ctx, nil, body) @@ -212,11 +261,11 @@ func TestReplaceFromModifyPacket_UpdateAllFields(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + svc := NewPersonService(persons, dns, accounts, new(mockPersonGlobalIDStore)) p := &model.Person{ID: "p1", FirstName: "Old", LastName: "Name", Email: "[email protected]"} persons.On("FindByID", ctx, "p1").Return(p, nil) - persons.On("Save", ctx, mock.Anything, p).Return(nil) + persons.On("Update", ctx, mock.Anything, p).Return(nil) body := map[string]any{ "PersonID": "p1", @@ -238,11 +287,11 @@ func TestReplaceFromModifyPacket_PartialUpdate(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + svc := NewPersonService(persons, dns, accounts, new(mockPersonGlobalIDStore)) p := &model.Person{ID: "p1", FirstName: "Keep", LastName: "This", Email: "[email protected]"} persons.On("FindByID", ctx, "p1").Return(p, nil) - persons.On("Save", ctx, mock.Anything, p).Return(nil) + persons.On("Update", ctx, mock.Anything, p).Return(nil) body := map[string]any{ "PersonID": "p1", @@ -261,12 +310,12 @@ func TestReplaceFromModifyPacket_PreserveOrgWhenAbsent(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + svc := NewPersonService(persons, dns, accounts, new(mockPersonGlobalIDStore)) org := "Original Org" p := &model.Person{ID: "p1", FirstName: "F", Organization: &org} persons.On("FindByID", ctx, "p1").Return(p, nil) - persons.On("Save", ctx, mock.Anything, p).Return(nil) + persons.On("Update", ctx, mock.Anything, p).Return(nil) // No UserOrganization key in body - org should be preserved body := map[string]any{ @@ -285,12 +334,12 @@ func TestReplaceFromModifyPacket_ClearDNsWhenEmpty(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + svc := NewPersonService(persons, dns, accounts, new(mockPersonGlobalIDStore)) p := &model.Person{ID: "p1"} persons.On("FindByID", ctx, "p1").Return(p, nil) dns.On("DeleteByPersonID", ctx, mock.Anything, "p1").Return(nil) - persons.On("Save", ctx, mock.Anything, p).Return(nil) + persons.On("Update", ctx, mock.Anything, p).Return(nil) body := map[string]any{ "PersonID": "p1", @@ -307,14 +356,14 @@ func TestReplaceFromModifyPacket_UpdateDNList(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + svc := NewPersonService(persons, dns, accounts, new(mockPersonGlobalIDStore)) p := &model.Person{ID: "p1"} persons.On("FindByID", ctx, "p1").Return(p, nil) dns.On("DeleteByPersonIDNotIn", ctx, mock.Anything, "p1", []string{"/CN=new"}).Return(nil) dns.On("ExistsByPersonAndDN", ctx, "p1", "/CN=new").Return(false, nil) dns.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.PersonDN")).Return(nil) - persons.On("Save", ctx, mock.Anything, p).Return(nil) + persons.On("Update", ctx, mock.Anything, p).Return(nil) body := map[string]any{ "PersonID": "p1", @@ -329,7 +378,7 @@ func TestReplaceFromModifyPacket_UpdateDNList(t *testing.T) { func TestReplaceFromModifyPacket_ErrorOnMissingPersonID(t *testing.T) { ctx := context.Background() - svc := NewPersonService(new(mockPersonStore), new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(new(mockPersonStore), new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) body := map[string]any{"UserFirstName": "No", "UserLastName": "ID"} err := svc.ReplaceFromModifyPacket(ctx, nil, body) @@ -341,7 +390,7 @@ func TestReplaceFromModifyPacket_ErrorOnMissingPersonID(t *testing.T) { func TestReplaceFromModifyPacket_ErrorOnUnknownPersonID(t *testing.T) { ctx := context.Background() persons := new(mockPersonStore) - svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) persons.On("FindByID", ctx, "unknown").Return(nil, nil) @@ -362,8 +411,9 @@ func TestPersistDNsForPerson_PersistNewDN(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + svc := NewPersonService(persons, dns, accounts, new(mockPersonGlobalIDStore)) + persons.On("FindByID", ctx, "p1").Return(&model.Person{ID: "p1", IsActive: true}, nil) dns.On("ExistsByPersonAndDN", ctx, "p1", "/CN=new").Return(false, nil) dns.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.PersonDN")).Return(nil) @@ -378,8 +428,9 @@ func TestPersistDNsForPerson_SkipExistingDN(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + svc := NewPersonService(persons, dns, accounts, new(mockPersonGlobalIDStore)) + persons.On("FindByID", ctx, "p1").Return(&model.Person{ID: "p1", IsActive: true}, nil) dns.On("ExistsByPersonAndDN", ctx, "p1", "/CN=existing").Return(true, nil) // Save should NOT be called for existing DNs @@ -399,10 +450,11 @@ func TestMergePersons_MoveAccountsAndDNs(t *testing.T) { persons := new(mockPersonStore) dns := new(mockPersonDNStore) accounts := new(mockPersonAccountStore) - svc := NewPersonService(persons, dns, accounts) + globalIDs := new(mockPersonGlobalIDStore) + svc := NewPersonService(persons, dns, accounts, globalIDs) surviving := &model.Person{ID: "survivor"} - retiring := &model.Person{ID: "retiring"} + retiring := &model.Person{ID: "retiring", IsActive: true} persons.On("FindByID", ctx, "survivor").Return(surviving, nil) persons.On("FindByID", ctx, "retiring").Return(retiring, nil) @@ -411,7 +463,8 @@ func TestMergePersons_MoveAccountsAndDNs(t *testing.T) { dns.On("FindByPersonID", ctx, "retiring").Return([]model.PersonDN{{PersonID: "retiring", DN: "/CN=retiring"}}, nil) dns.On("ExistsByPersonAndDN", ctx, "survivor", "/CN=retiring").Return(false, nil) dns.On("Save", ctx, mock.Anything, mock.AnythingOfType("*model.PersonDN")).Return(nil) - persons.On("Delete", ctx, mock.Anything, "retiring").Return(nil) + globalIDs.On("UpdatePersonID", ctx, mock.Anything, "retiring", "survivor").Return(nil) + persons.On("Deactivate", ctx, mock.Anything, "retiring").Return(nil) err := svc.MergePersons(ctx, nil, "survivor", "retiring") @@ -419,12 +472,13 @@ func TestMergePersons_MoveAccountsAndDNs(t *testing.T) { persons.AssertExpectations(t) accounts.AssertExpectations(t) dns.AssertExpectations(t) + globalIDs.AssertExpectations(t) } func TestMergePersons_ErrorOnUnknownSurvivingPerson(t *testing.T) { ctx := context.Background() persons := new(mockPersonStore) - svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) persons.On("FindByID", ctx, "missing").Return(nil, nil) @@ -438,7 +492,7 @@ func TestMergePersons_ErrorOnUnknownSurvivingPerson(t *testing.T) { func TestMergePersons_ErrorOnUnknownRetiringPerson(t *testing.T) { ctx := context.Background() persons := new(mockPersonStore) - svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) surviving := &model.Person{ID: "survivor"} persons.On("FindByID", ctx, "survivor").Return(surviving, nil) @@ -446,8 +500,7 @@ func TestMergePersons_ErrorOnUnknownRetiringPerson(t *testing.T) { err := svc.MergePersons(ctx, nil, "survivor", "missing-retiring") - require.Error(t, err) - assert.Contains(t, err.Error(), "retiring person") + require.NoError(t, err) persons.AssertExpectations(t) } @@ -458,7 +511,7 @@ func TestMergePersons_ErrorOnUnknownRetiringPerson(t *testing.T) { func TestDeleteFromModifyPacket_DeleteByID(t *testing.T) { ctx := context.Background() persons := new(mockPersonStore) - svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) persons.On("Delete", ctx, mock.Anything, "p1").Return(nil) @@ -471,7 +524,7 @@ func TestDeleteFromModifyPacket_DeleteByID(t *testing.T) { func TestDeleteFromModifyPacket_ErrorOnMissingPersonID(t *testing.T) { ctx := context.Background() - svc := NewPersonService(new(mockPersonStore), new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(new(mockPersonStore), new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) body := map[string]any{} err := svc.DeleteFromModifyPacket(ctx, nil, body) @@ -483,7 +536,7 @@ func TestDeleteFromModifyPacket_ErrorOnMissingPersonID(t *testing.T) { func TestDeleteFromModifyPacket_PropagatesStoreError(t *testing.T) { ctx := context.Background() persons := new(mockPersonStore) - svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore)) + svc := NewPersonService(persons, new(mockPersonDNStore), new(mockPersonAccountStore), new(mockPersonGlobalIDStore)) persons.On("Delete", ctx, mock.Anything, "p1").Return(errors.New("db error")) diff --git a/allocations/access-amie/service/project_service.go b/allocations/access-amie/service/project_service.go index f21012aab..3d2ffd60a 100644 --- a/allocations/access-amie/service/project_service.go +++ b/allocations/access-amie/service/project_service.go @@ -22,6 +22,7 @@ import ( "database/sql" "fmt" "log/slog" + "time" "github.com/apache/airavata-custos/allocations/domain/model" ) @@ -51,10 +52,13 @@ func (s *ProjectService) CreateOrFindProject(ctx context.Context, tx *sql.Tx, pr return existing, nil } + now := time.Now().UTC() p := &model.Project{ ID: projectID, GrantNumber: grantNumber, IsActive: true, + CreatedAt: now, + UpdatedAt: now, } if err := s.projects.Save(ctx, tx, p); err != nil { diff --git a/allocations/access-amie/store/audit_store.go b/allocations/access-amie/store/audit_store.go index 5a06e15df..709c03446 100644 --- a/allocations/access-amie/store/audit_store.go +++ b/allocations/access-amie/store/audit_store.go @@ -39,7 +39,7 @@ func NewAuditStore(db *sqlx.DB) AuditStore { func (s *mariaDBauditStore) Save(ctx context.Context, tx *sql.Tx, a *model.AuditLog) error { _, err := tx.ExecContext(ctx, - `INSERT INTO amie_audit_logs (packet_id, event_id, action, entity_type, entity_id, summary, created_at) + `INSERT INTO amie_audit_log (packet_id, event_id, action, entity_type, entity_id, summary, created_at) VALUES (?, ?, ?, ?, ?, ?, ?)`, a.PacketID, a.EventID, a.Action, a.EntityType, a.EntityID, a.Summary, a.CreatedAt) return err diff --git a/allocations/access-amie/worker/processor.go b/allocations/access-amie/worker/processor.go index 2535a6269..99ee80804 100644 --- a/allocations/access-amie/worker/processor.go +++ b/allocations/access-amie/worker/processor.go @@ -97,7 +97,6 @@ func (p *Processor) Run(ctx context.Context) { ticker := time.NewTicker(p.workerInterval) defer ticker.Stop() - // Process immediately on start, then on ticker. p.processPendingEvents(ctx) for { select { @@ -159,7 +158,6 @@ func (p *Processor) executeInTransaction(ctx context.Context, ewp model.EventWit "attempt", ewp.Attempts+1, ) - // Mark the event as RUNNING and increment the attempt counter. now := time.Now().UTC() ewp.Status = model.ProcessingStatusRunning ewp.StartedAt = &now @@ -168,26 +166,21 @@ func (p *Processor) executeInTransaction(ctx context.Context, ewp model.EventWit return fmt.Errorf("update event to RUNNING: %w", err) } - // Parse the packet's raw JSON. var packetJSON map[string]any if err := json.Unmarshal([]byte(ewp.PacketRawJSON), &packetJSON); err != nil { return fmt.Errorf("unmarshal packet raw JSON: %w", err) } - // Build a Packet from the EventWithPacket projection fields. - packet := &model.Packet{ - ID: ewp.PacketID, - AmieID: ewp.PacketAmieID, - Type: ewp.PacketType, - RawJSON: ewp.PacketRawJSON, + // Load the full packet from DB to preserve all fields (e.g. retries). + packet, err := p.packetStore.FindByID(ctx, ewp.PacketID) + if err != nil { + return fmt.Errorf("load packet %s: %w", ewp.PacketID, err) } - // Route the packet to its handler. if err := p.router.Route(ctx, tx, packetJSON, packet, ewp.ID); err != nil { return fmt.Errorf("route packet: %w", err) } - // Mark the event as SUCCEEDED. finishedAt := time.Now().UTC() ewp.Status = model.ProcessingStatusSucceeded ewp.FinishedAt = &finishedAt @@ -196,7 +189,6 @@ func (p *Processor) executeInTransaction(ctx context.Context, ewp model.EventWit return fmt.Errorf("update event to SUCCEEDED: %w", err) } - // Mark the packet as DECODED. decodedAt := time.Now().UTC() packet.Status = model.PacketStatusDecoded packet.DecodedAt = &decodedAt @@ -227,7 +219,6 @@ func (p *Processor) recordFailureInNewTransaction(ctx context.Context, eventID s return nil } - // Load the associated packet. packet, err := p.packetStore.FindByID(ctx, event.PacketID) if err != nil { return fmt.Errorf("find packet for failure recording: %w", err) @@ -248,6 +239,13 @@ func (p *Processor) recordFailureInNewTransaction(ctx context.Context, eventID s event.Status = model.ProcessingStatusRetryScheduled nextRetry := ComputeNextRetryAt(effectiveAttempts) event.NextRetryAt = &nextRetry + + packet.Retries = effectiveAttempts + packet.LastError = &errMsg + if err := p.packetStore.Update(ctx, tx, packet); err != nil { + return fmt.Errorf("update packet retries: %w", err) + } + p.metrics.RecordRetry() p.metrics.RecordPacketProcessed(packet.Type, "retry_scheduled") slog.Warn("event failed, scheduling retry", @@ -261,8 +259,8 @@ func (p *Processor) recordFailureInNewTransaction(ctx context.Context, eventID s p.metrics.RecordPacketProcessed(packet.Type, "permanently_failed") slog.Error("event permanently failed after max attempts", "eventId", eventID) - // Mark the packet as FAILED. packet.Status = model.PacketStatusFailed + packet.Retries = effectiveAttempts packet.LastError = &errMsg if err := p.packetStore.Update(ctx, tx, packet); err != nil { return fmt.Errorf("update packet status: %w", err) @@ -273,7 +271,6 @@ func (p *Processor) recordFailureInNewTransaction(ctx context.Context, eventID s return fmt.Errorf("update event: %w", err) } - // Create a processing error record. detail := cause.Error() if len(detail) > 8000 { detail = detail[:8000] diff --git a/allocations/domain/model/person.go b/allocations/domain/model/person.go index 1b1b65382..00a9c7f0e 100644 --- a/allocations/domain/model/person.go +++ b/allocations/domain/model/person.go @@ -28,10 +28,17 @@ type Person struct { Organization *string `db:"organization" json:"organization,omitempty"` OrgCode *string `db:"org_code" json:"org_code,omitempty"` NsfStatusCode *string `db:"nsf_status_code" json:"nsf_status_code,omitempty"` + IsActive bool `db:"is_active" json:"is_active"` CreatedAt time.Time `db:"created_at" json:"created_at"` UpdatedAt time.Time `db:"updated_at" json:"updated_at"` } +type PersonGlobalID struct { + ID int64 `db:"id" json:"id"` + PersonID string `db:"person_id" json:"person_id"` + GlobalID string `db:"global_id" json:"global_id"` +} + type PersonDN struct { ID int64 `db:"id" json:"id"` PersonID string `db:"person_id" json:"person_id"` diff --git a/allocations/domain/store/person_store.go b/allocations/domain/store/person_store.go index 00122edf5..4b7861230 100644 --- a/allocations/domain/store/person_store.go +++ b/allocations/domain/store/person_store.go @@ -21,11 +21,14 @@ import ( "context" "database/sql" "errors" + "time" "github.com/apache/airavata-custos/allocations/domain/model" "github.com/jmoiron/sqlx" ) +const personColumns = `id, access_global_id, first_name, last_name, email, organization, org_code, nsf_status_code, is_active, created_at, updated_at` + type mariaDBPersonStore struct { db *sqlx.DB } @@ -37,8 +40,7 @@ func NewPersonStore(db *sqlx.DB) PersonStore { func (s *mariaDBPersonStore) FindByID(ctx context.Context, id string) (*model.Person, error) { var p model.Person err := s.db.GetContext(ctx, &p, - `SELECT id, access_global_id, first_name, last_name, email, organization, org_code, nsf_status_code, created_at, updated_at - FROM persons WHERE id = ?`, id) + `SELECT `+personColumns+` FROM persons WHERE id = ?`, id) if err != nil { if errors.Is(err, sql.ErrNoRows) { return nil, nil @@ -51,8 +53,20 @@ func (s *mariaDBPersonStore) FindByID(ctx context.Context, id string) (*model.Pe func (s *mariaDBPersonStore) FindByAccessGlobalID(ctx context.Context, globalID string) (*model.Person, error) { var p model.Person err := s.db.GetContext(ctx, &p, - `SELECT id, access_global_id, first_name, last_name, email, organization, org_code, nsf_status_code, created_at, updated_at - FROM persons WHERE access_global_id = ?`, globalID) + `SELECT `+personColumns+` FROM persons WHERE access_global_id = ?`, globalID) + if err != nil { + if errors.Is(err, sql.ErrNoRows) { + return nil, nil + } + return nil, err + } + return &p, nil +} + +func (s *mariaDBPersonStore) FindActiveByEmail(ctx context.Context, email string) (*model.Person, error) { + var p model.Person + err := s.db.GetContext(ctx, &p, + `SELECT `+personColumns+` FROM persons WHERE email = ? AND is_active = TRUE LIMIT 1`, email) if err != nil { if errors.Is(err, sql.ErrNoRows) { return nil, nil @@ -64,14 +78,32 @@ func (s *mariaDBPersonStore) FindByAccessGlobalID(ctx context.Context, globalID func (s *mariaDBPersonStore) Save(ctx context.Context, tx *sql.Tx, p *model.Person) error { _, err := tx.ExecContext(ctx, - `INSERT INTO persons (id, access_global_id, first_name, last_name, email, organization, org_code, nsf_status_code, created_at, updated_at) - VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`, + `INSERT INTO persons (id, access_global_id, first_name, last_name, email, organization, org_code, nsf_status_code, is_active, created_at, updated_at) + VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`, p.ID, p.AccessGlobalID, p.FirstName, p.LastName, p.Email, - p.Organization, p.OrgCode, p.NsfStatusCode, + p.Organization, p.OrgCode, p.NsfStatusCode, p.IsActive, p.CreatedAt, p.UpdatedAt) return err } +func (s *mariaDBPersonStore) Update(ctx context.Context, tx *sql.Tx, p *model.Person) error { + _, err := tx.ExecContext(ctx, + `UPDATE persons SET access_global_id = ?, first_name = ?, last_name = ?, email = ?, + organization = ?, org_code = ?, nsf_status_code = ?, is_active = ?, updated_at = ? + WHERE id = ?`, + p.AccessGlobalID, p.FirstName, p.LastName, p.Email, + p.Organization, p.OrgCode, p.NsfStatusCode, p.IsActive, + p.UpdatedAt, p.ID) + return err +} + +func (s *mariaDBPersonStore) Deactivate(ctx context.Context, tx *sql.Tx, id string) error { + _, err := tx.ExecContext(ctx, + `UPDATE persons SET is_active = FALSE, updated_at = ? WHERE id = ?`, + time.Now().UTC(), id) + return err +} + func (s *mariaDBPersonStore) Delete(ctx context.Context, tx *sql.Tx, id string) error { _, err := tx.ExecContext(ctx, `DELETE FROM persons WHERE id = ?`, id) diff --git a/allocations/domain/store/stores.go b/allocations/domain/store/stores.go index 786119497..d009a6450 100644 --- a/allocations/domain/store/stores.go +++ b/allocations/domain/store/stores.go @@ -27,10 +27,19 @@ import ( type PersonStore interface { FindByID(ctx context.Context, id string) (*model.Person, error) FindByAccessGlobalID(ctx context.Context, globalID string) (*model.Person, error) + FindActiveByEmail(ctx context.Context, email string) (*model.Person, error) Save(ctx context.Context, tx *sql.Tx, p *model.Person) error + Update(ctx context.Context, tx *sql.Tx, p *model.Person) error + Deactivate(ctx context.Context, tx *sql.Tx, id string) error Delete(ctx context.Context, tx *sql.Tx, id string) error } +type PersonGlobalIDStore interface { + FindPersonByGlobalID(ctx context.Context, globalID string) (*model.Person, error) + Save(ctx context.Context, tx *sql.Tx, g *model.PersonGlobalID) error + UpdatePersonID(ctx context.Context, tx *sql.Tx, oldPersonID, newPersonID string) error +} + type PersonDNStore interface { ExistsByPersonAndDN(ctx context.Context, personID, dn string) (bool, error) Save(ctx context.Context, tx *sql.Tx, d *model.PersonDN) error diff --git a/allocations/go.work.sum b/allocations/go.work.sum new file mode 100644 index 000000000..6390a5c4f --- /dev/null +++ b/allocations/go.work.sum @@ -0,0 +1,451 @@ +cloud.google.com/go v0.112.1 h1:uJSeirPke5UNZHIb4SxfZklVSiWWVqW4oXlETwZziwM= +cloud.google.com/go v0.112.1/go.mod h1:+Vbu+Y1UU+I1rjmzeMOb/8RfkKJK2Gyxi1X6jJCZLo4= +cloud.google.com/go/compute v1.25.1 h1:ZRpHJedLtTpKgr3RV1Fx23NuaAEN1Zfx9hw1u4aJdjU= +cloud.google.com/go/compute v1.25.1/go.mod h1:oopOIR53ly6viBYxaDhBfJwzUAxf1zE//uf3IB011ls= +cloud.google.com/go/compute/metadata v0.2.3 h1:mg4jlk7mCAj6xXp9UJ4fjI9VUI5rubuGBW5aJ7UnBMY= +cloud.google.com/go/compute/metadata v0.2.3/go.mod h1:VAV5nSsACxMJvgaAuX6Pk2AawlZn8kiOGuCv6gTkwuA= +cloud.google.com/go/iam v1.1.6 h1:bEa06k05IO4f4uJonbB5iAgKTPpABy1ayxaIZV/GHVc= +cloud.google.com/go/iam v1.1.6/go.mod h1:O0zxdPeGBoFdWW3HWmBxJsk0pfvNM/p/qa82rWOGTwI= +cloud.google.com/go/longrunning v0.5.5 h1:GOE6pZFdSrTb4KAiKnXsJBtlE6mEyaW44oKyMILWnOg= +cloud.google.com/go/longrunning v0.5.5/go.mod h1:WV2LAxD8/rg5Z1cNW6FJ/ZpX4E4VnDnoTk0yawPBB7s= +cloud.google.com/go/spanner v1.56.0 h1:o/Cv7/zZ1WgRXVCd5g3Nc23ZI39p/1pWFqFwvg6Wcu8= +cloud.google.com/go/spanner v1.56.0/go.mod h1:DndqtUKQAt3VLuV2Le+9Y3WTnq5cNKrnLb/Piqcj+h0= +cloud.google.com/go/storage v1.38.0 h1:Az68ZRGlnNTpIBbLjSMIV2BDcwwXYlRlQzis0llkpJg= +cloud.google.com/go/storage v1.38.0/go.mod h1:tlUADB0mAb9BgYls9lq+8MGkfzOXuLrnHXlpHmvFJoY= +filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA= +filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4= +github.com/99designs/go-keychain v0.0.0-20191008050251-8e49817e8af4 h1:/vQbFIOMbk2FiG/kXiLl8BRyzTWDw7gX/Hz7Dd5eDMs= +github.com/99designs/go-keychain v0.0.0-20191008050251-8e49817e8af4/go.mod h1:hN7oaIRCjzsZ2dE+yG5k+rsdt3qcwykqK6HVGcKwsw4= +github.com/99designs/keyring v1.2.1 h1:tYLp1ULvO7i3fI5vE21ReQuj99QFSs7lGm0xWyJo87o= +github.com/99designs/keyring v1.2.1/go.mod h1:fc+wB5KTk9wQ9sDx0kFXB3A0MaeGHM9AwRStKOQ5vOA= +github.com/Azure/azure-sdk-for-go/sdk/azcore v1.4.0 h1:rTnT/Jrcm+figWlYz4Ixzt0SJVR2cMC8lvZcimipiEY= +github.com/Azure/azure-sdk-for-go/sdk/azcore v1.4.0/go.mod h1:ON4tFdPTwRcgWEaVDrN3584Ef+b7GgSJaXxe5fW9t4M= +github.com/Azure/azure-sdk-for-go/sdk/internal v1.1.2 h1:+5VZ72z0Qan5Bog5C+ZkgSqUbeVUd9wgtHOrIKuc5b8= +github.com/Azure/azure-sdk-for-go/sdk/internal v1.1.2/go.mod h1:eWRD7oawr1Mu1sLCawqVc0CUiF43ia3qQMxLscsKQ9w= +github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.0.0 h1:u/LLAOFgsMv7HmNL4Qufg58y+qElGOt5qv0z1mURkRY= +github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v1.0.0/go.mod h1:2e8rMJtl2+2j+HXbTBwnyGpm5Nou7KhvSfxOq8JpTag= +github.com/Azure/go-ansiterm v0.0.0-20230124172434-306776ec8161 h1:L/gRVlceqvL25UVaW/CKtUDjefjrs0SPonmDGUVOYP0= +github.com/Azure/go-ansiterm v0.0.0-20230124172434-306776ec8161/go.mod h1:xomTg63KZ2rFqZQzSB4Vz2SUXa1BpHTVz9L5PTmPC4E= +github.com/Azure/go-autorest v14.2.0+incompatible h1:V5VMDjClD3GiElqLWO7mz2MxNAK/vTfRHdAubSIPRgs= +github.com/Azure/go-autorest v14.2.0+incompatible/go.mod h1:r+4oMnoxhatjLLJ6zxSWATqVooLgysK6ZNox3g/xq24= +github.com/Azure/go-autorest/autorest/adal v0.9.16 h1:P8An8Z9rH1ldbOLdFpxYorgOt2sywL9V24dAwWHPuGc= +github.com/Azure/go-autorest/autorest/adal v0.9.16/go.mod h1:tGMin8I49Yij6AQ+rvV+Xa/zwxYQB5hmsd6DkfAx2+A= +github.com/Azure/go-autorest/autorest/date v0.3.0 h1:7gUk1U5M/CQbp9WoqinNzJar+8KY+LPI6wiWrP/myHw= +github.com/Azure/go-autorest/autorest/date v0.3.0/go.mod h1:BI0uouVdmngYNUzGWeSYnokU+TrmwEsOqdt8Y6sso74= +github.com/Azure/go-autorest/logger v0.2.1 h1:IG7i4p/mDa2Ce4TRyAO8IHnVhAVF3RFU+ZtXWSmf4Tg= +github.com/Azure/go-autorest/logger v0.2.1/go.mod h1:T9E3cAhj2VqvPOtCYAvby9aBXkZmbF5NWuPV8+WeEW8= +github.com/Azure/go-autorest/tracing v0.6.0 h1:TYi4+3m5t6K48TGI9AUdb+IzbnSxvnvUMfuitfgcfuo= +github.com/Azure/go-autorest/tracing v0.6.0/go.mod h1:+vhtPC754Xsa23ID7GlGsrdKBpUA79WCAKPPZVC2DeU= +github.com/ClickHouse/clickhouse-go v1.4.3 h1:iAFMa2UrQdR5bHJ2/yaSLffZkxpcOYQMCUuKeNXGdqc= +github.com/ClickHouse/clickhouse-go v1.4.3/go.mod h1:EaI/sW7Azgz9UATzd5ZdZHRUhHgv5+JMS9NSr2smCJI= +github.com/Microsoft/go-winio v0.6.2 h1:F2VQgta7ecxGYO8k3ZZz3RS8fVIXVxONVUPlNERoyfY= +github.com/Microsoft/go-winio v0.6.2/go.mod h1:yd8OoFMLzJbo9gZq8j5qaps8bJ9aShtEA8Ipt1oGCvU= +github.com/alecthomas/kingpin/v2 v2.4.0 h1:f48lwail6p8zpO1bC4TxtqACaGqHYA22qkHjHpqDjYY= +github.com/alecthomas/kingpin/v2 v2.4.0/go.mod h1:0gyi0zQnjuFk8xrkNKamJoyUo382HRL7ATRpFZCw6tE= +github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137 h1:s6gZFSlWYmbqAuRjVTiNNhvNRfY2Wxp9nhfyel4rklc= +github.com/alecthomas/units v0.0.0-20211218093645-b94a6e3cc137/go.mod h1:OMCwj8VM1Kc9e19TLln2VL61YJF0x1XFtfdL4JdbSyE= +github.com/andybalholm/brotli v1.0.4 h1:V7DdXeJtZscaqfNuAdSRuRFzuiKlHSC/Zh3zl9qY3JY= +github.com/andybalholm/brotli v1.0.4/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig= +github.com/apache/arrow/go/v10 v10.0.1 h1:n9dERvixoC/1JjDmBcs9FPaEryoANa2sCgVFo6ez9cI= +github.com/apache/arrow/go/v10 v10.0.1/go.mod h1:YvhnlEePVnBS4+0z3fhPfUy7W1Ikj0Ih0vcRo/gZ1M0= +github.com/apache/thrift v0.16.0 h1:qEy6UW60iVOlUy+b9ZR0d5WzUWYGOo4HfopoyBaNmoY= +github.com/apache/thrift v0.16.0/go.mod h1:PHK3hniurgQaNMZYaCLEqXKsYK8upmhPbmdP2FXSqgU= +github.com/aws/aws-sdk-go v1.49.6 h1:yNldzF5kzLBRvKlKz1S0bkvc2+04R1kt13KfBWQBfFA= +github.com/aws/aws-sdk-go v1.49.6/go.mod h1:LF8svs817+Nz+DmiMQKTO3ubZ/6IaTpq3TjupRn3Eqk= +github.com/aws/aws-sdk-go-v2 v1.16.16 h1:M1fj4FE2lB4NzRb9Y0xdWsn2P0+2UHVxwKyOa4YJNjk= +github.com/aws/aws-sdk-go-v2 v1.16.16/go.mod h1:SwiyXi/1zTUZ6KIAmLK5V5ll8SiURNUYOqTerZPaF9k= +github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.4.8 h1:tcFliCWne+zOuUfKNRn8JdFBuWPDuISDH08wD2ULkhk= +github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.4.8/go.mod h1:JTnlBSot91steJeti4ryyu/tLd4Sk84O5W22L7O2EQU= +github.com/aws/aws-sdk-go-v2/credentials v1.12.20 h1:9+ZhlDY7N9dPnUmf7CDfW9In4sW5Ff3bh7oy4DzS1IE= +github.com/aws/aws-sdk-go-v2/credentials v1.12.20/go.mod h1:UKY5HyIux08bbNA7Blv4PcXQ8cTkGh7ghHMFklaviR4= +github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.11.33 h1:fAoVmNGhir6BR+RU0/EI+6+D7abM+MCwWf8v4ip5jNI= +github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.11.33/go.mod h1:84XgODVR8uRhmOnUkKGUZKqIMxmjmLOR8Uyp7G/TPwc= +github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.23 h1:s4g/wnzMf+qepSNgTvaQQHNxyMLKSawNhKCPNy++2xY= +github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.23/go.mod h1:2DFxAQ9pfIRy0imBCJv+vZ2X6RKxves6fbnEuSry6b4= +github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.17 h1:/K482T5A3623WJgWT8w1yRAFK4RzGzEl7y39yhtn9eA= +github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.17/go.mod h1:pRwaTYCJemADaqCbUAxltMoHKata7hmB5PjEXeu0kfg= +github.com/aws/aws-sdk-go-v2/internal/v4a v1.0.14 h1:ZSIPAkAsCCjYrhqfw2+lNzWDzxzHXEckFkTePL5RSWQ= +github.com/aws/aws-sdk-go-v2/internal/v4a v1.0.14/go.mod h1:AyGgqiKv9ECM6IZeNQtdT8NnMvUb3/2wokeq2Fgryto= +github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.9 h1:Lh1AShsuIJTwMkoxVCAYPJgNG5H+eN6SmoUn8nOZ5wE= +github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.9/go.mod h1:a9j48l6yL5XINLHLcOKInjdvknN+vWqPBxqeIDw7ktw= +github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.1.18 h1:BBYoNQt2kUZUUK4bIPsKrCcjVPUMNsgQpNAwhznK/zo= +github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.1.18/go.mod h1:NS55eQ4YixUJPTC+INxi2/jCqe1y2Uw3rnh9wEOVJxY= +github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.17 h1:Jrd/oMh0PKQc6+BowB+pLEwLIgaQF29eYbe7E1Av9Ug= +github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.17/go.mod h1:4nYOrY41Lrbk2170/BGkcJKBhws9Pfn8MG3aGqjjeFI= +github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.13.17 h1:HfVVR1vItaG6le+Bpw6P4midjBDMKnjMyZnw9MXYUcE= +github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.13.17/go.mod h1:YqMdV+gEKCQ59NrB7rzrJdALeBIsYiVi8Inj3+KcqHI= +github.com/aws/aws-sdk-go-v2/service/s3 v1.27.11 h1:3/gm/JTX9bX8CpzTgIlrtYpB3EVBDxyg/GY/QdcIEZw= +github.com/aws/aws-sdk-go-v2/service/s3 v1.27.11/go.mod h1:fmgDANqTUCxciViKl9hb/zD5LFbvPINFRgWhDbR+vZo= +github.com/aws/smithy-go v1.13.3 h1:l7LYxGuzK6/K+NzJ2mC+VvLUbae0sL3bXU//04MkmnA= +github.com/aws/smithy-go v1.13.3/go.mod h1:Tg+OJXh4MB2R/uN61Ko2f6hTZwB/ZYGOtib8J3gBHzA= +github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM= +github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw= +github.com/cenkalti/backoff/v4 v4.1.2 h1:6Yo7N8UP2K6LWZnW94DLVSSrbobcWdVzAYOisuDPIFo= +github.com/cenkalti/backoff/v4 v4.1.2/go.mod h1:scbssz8iZGpm3xbr14ovlUdkxfGXNInqkPWOWmG2CLw= +github.com/census-instrumentation/opencensus-proto v0.4.1 h1:iKLQ0xPNFxR/2hzXZMrBo8f1j86j5WHzznCCQxV/b8g= +github.com/census-instrumentation/opencensus-proto v0.4.1/go.mod h1:4T9NM4+4Vw91VeyqjLS6ao50K5bOcLKN6Q42XnYaRYw= +github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs= +github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= +github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58 h1:F1EaeKL/ta07PY/k9Os/UFtwERei2/XzGemhpGnBKNg= +github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58/go.mod h1:EOBUe0h4xcZ5GoxqC5SDxFQ8gwyZPKQoEzownBlhI80= +github.com/cncf/xds/go v0.0.0-20240318125728-8a4994d93e50 h1:DBmgJDC9dTfkVyGgipamEh2BpGYxScCH1TOF1LL1cXc= +github.com/cncf/xds/go v0.0.0-20240318125728-8a4994d93e50/go.mod h1:5e1+Vvlzido69INQaVO6d87Qn543Xr6nooe9Kz7oBFM= +github.com/cockroachdb/cockroach-go/v2 v2.1.1 h1:3XzfSMuUT0wBe1a3o5C0eOTcArhmmFAg2Jzh/7hhKqo= +github.com/cockroachdb/cockroach-go/v2 v2.1.1/go.mod h1:7NtUnP6eK+l6k483WSYNrq3Kb23bWV10IRV1TyeSpwM= +github.com/cznic/mathutil v0.0.0-20180504122225-ca4c9f2c1369 h1:XNT/Zf5l++1Pyg08/HV04ppB0gKxAqtZQBRYiYrUuYk= +github.com/cznic/mathutil v0.0.0-20180504122225-ca4c9f2c1369/go.mod h1:e6NPNENfs9mPDVNRekM7lKScauxd5kXTr1Mfyig6TDM= +github.com/danieljoos/wincred v1.1.2 h1:QLdCxFs1/Yl4zduvBdcHB8goaYk9RARS2SgLLRuAyr0= +github.com/danieljoos/wincred v1.1.2/go.mod h1:GijpziifJoIBfYh+S7BbkdUTU4LfM+QnGqR5Vl2tAx0= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/dhui/dktest v0.4.3 h1:wquqUxAFdcUgabAVLvSCOKOlag5cIZuaOjYIBOWdsR0= +github.com/dhui/dktest v0.4.3/go.mod h1:zNK8IwktWzQRm6I/l2Wjp7MakiyaFWv4G1hjmodmMTs= +github.com/distribution/reference v0.6.0 h1:0IXCQ5g4/QMHHkarYzh5l+u8T3t73zM5QvfrDyIgxBk= +github.com/distribution/reference v0.6.0/go.mod h1:BbU0aIcezP1/5jX/8MP0YiH4SdvB5Y4f/wlDRiLyi3E= +github.com/docker/docker v27.2.0+incompatible h1:Rk9nIVdfH3+Vz4cyI/uhbINhEZ/oLmc+CBXmH6fbNk4= +github.com/docker/docker v27.2.0+incompatible/go.mod h1:eEKB0N0r5NX/I1kEveEz05bcu8tLC/8azJZsviup8Sk= +github.com/docker/go-connections v0.5.0 h1:USnMq7hx7gwdVZq1L49hLXaFtUdTADjXGp+uj1Br63c= +github.com/docker/go-connections v0.5.0/go.mod h1:ov60Kzw0kKElRwhNs9UlUHAE/F9Fe6GLaXnqyDdmEXc= +github.com/docker/go-units v0.5.0 h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4= +github.com/docker/go-units v0.5.0/go.mod h1:fgPhTUdO+D/Jk86RDLlptpiXQzgHJF7gydDDbaIK4Dk= +github.com/dvsekhvalnov/jose2go v1.6.0 h1:Y9gnSnP4qEI0+/uQkHvFXeD2PLPJeXEL+ySMEA2EjTY= +github.com/dvsekhvalnov/jose2go v1.6.0/go.mod h1:QsHjhyTlD/lAVqn/NSbVZmSCGeDehTB/mPZadG+mhXU= +github.com/edsrzf/mmap-go v0.0.0-20170320065105-0bce6a688712 h1:aaQcKT9WumO6JEJcRyTqFVq4XUZiUcKR2/GI31TOcz8= +github.com/edsrzf/mmap-go v0.0.0-20170320065105-0bce6a688712/go.mod h1:YO35OhQPt3KJa3ryjFM5Bs14WD66h8eGKpfaBNrHW5M= +github.com/envoyproxy/go-control-plane v0.12.0 h1:4X+VP1GHd1Mhj6IB5mMeGbLCleqxjletLK6K0rbxyZI= +github.com/envoyproxy/go-control-plane v0.12.0/go.mod h1:ZBTaoJ23lqITozF0M6G4/IragXCQKCnYbmlmtHvwRG0= +github.com/envoyproxy/protoc-gen-validate v1.0.4 h1:gVPz/FMfvh57HdSJQyvBtF00j8JU4zdyUgIUNhlgg0A= +github.com/envoyproxy/protoc-gen-validate v1.0.4/go.mod h1:qys6tmnRsYrQqIhm2bvKZH4Blx/1gTIZ2UKVY1M+Yew= +github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg= +github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U= +github.com/form3tech-oss/jwt-go v3.2.5+incompatible h1:/l4kBbb4/vGSsdtB5nUe8L7B9mImVMaBPw9L/0TBHU8= +github.com/form3tech-oss/jwt-go v3.2.5+incompatible/go.mod h1:pbq4aXjuKjdthFRnoDwaVPLA+WlJuPGy+QneDUgJi2k= +github.com/fsouza/fake-gcs-server v1.17.0 h1:OeH75kBZcZa3ZE+zz/mFdJ2btt9FgqfjI7gIh9+5fvk= +github.com/fsouza/fake-gcs-server v1.17.0/go.mod h1:D1rTE4YCyHFNa99oyJJ5HyclvN/0uQR+pM/VdlL83bw= +github.com/gabriel-vasile/mimetype v1.4.1 h1:TRWk7se+TOjCYgRth7+1/OYLNiRNIotknkFtf/dnN7Q= +github.com/gabriel-vasile/mimetype v1.4.1/go.mod h1:05Vi0w3Y9c/lNvJOdmIwvrrAhX3rYhfQQCaf9VJcv7M= +github.com/go-kit/log v0.2.1 h1:MRVx0/zhvdseW+Gza6N9rVzU/IVzaeE1SFI4raAhmBU= +github.com/go-kit/log v0.2.1/go.mod h1:NwTd00d/i8cPZ3xOwwiv2PO5MOcx78fFErGNcVmBjv0= +github.com/go-logfmt/logfmt v0.5.1 h1:otpy5pqBCBZ1ng9RQ0dPu4PN7ba75Y/aA+UpowDyNVA= +github.com/go-logfmt/logfmt v0.5.1/go.mod h1:WYhtIu8zTZfxdn5+rREduYbwxfcBr/Vr6KEVveWlfTs= +github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY= +github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY= +github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag= +github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE= +github.com/go-sql-driver/mysql v1.8.1 h1:LedoTUt/eveggdHS9qUFC1EFSa8bU2+1pZjSRpvNJ1Y= +github.com/go-sql-driver/mysql v1.8.1/go.mod h1:wEBSXgmK//2ZFJyE+qWnIsVGmvmEKlqwuVSjsCm7DZg= +github.com/go-stack/stack v1.8.0 h1:5SgMzNM5HxrEjV0ww2lTmX6E2Izsfxas4+YHWRs3Lsk= +github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY= +github.com/gobuffalo/here v0.6.0 h1:hYrd0a6gDmWxBM4TnrGw8mQg24iSVoIkHEk7FodQcBI= +github.com/gobuffalo/here v0.6.0/go.mod h1:wAG085dHOYqUpf+Ap+WOdrPTp5IYcDAs/x7PLa8Y5fM= +github.com/goccy/go-json v0.9.11 h1:/pAaQDLHEoCq/5FFmSKBswWmK6H0e8g4159Kc/X/nqk= +github.com/goccy/go-json v0.9.11/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= +github.com/gocql/gocql v0.0.0-20210515062232-b7ef815b4556 h1:N/MD/sr6o61X+iZBAT2qEUF023s4KbA8RWfKzl0L6MQ= +github.com/gocql/gocql v0.0.0-20210515062232-b7ef815b4556/go.mod h1:DL0ekTmBSTdlNF25Orwt/JMzqIq3EJ4MVa/J/uK64OY= +github.com/godbus/dbus v0.0.0-20190726142602-4481cbc300e2 h1:ZpnhV/YsD2/4cESfV5+Hoeu/iUR3ruzNvZ+yQfO03a0= +github.com/godbus/dbus v0.0.0-20190726142602-4481cbc300e2/go.mod h1:bBOAhwG1umN6/6ZUMtDFBMQR8jRg9O75tm9K00oMsK4= +github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q= +github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q= +github.com/golang-jwt/jwt/v4 v4.4.2 h1:rcc4lwaZgFMCZ5jxF9ABolDcIHdBytAFgqFPbSJQAYs= +github.com/golang-jwt/jwt/v4 v4.4.2/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0= +github.com/golang-migrate/migrate/v4 v4.18.1 h1:JML/k+t4tpHCpQTCAD62Nu43NUFzHY4CV3uAuvHGC+Y= +github.com/golang-migrate/migrate/v4 v4.18.1/go.mod h1:HAX6m3sQgcdO81tdjn5exv20+3Kb13cmGli1hrD6hks= +github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe h1:lXe2qZdvpiX5WZkZR4hgp4KJVfY3nMkvmwbVkpv1rVY= +github.com/golang-sql/civil v0.0.0-20190719163853-cb61b32ac6fe/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0= +github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A= +github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI= +github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE= +github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= +github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= +github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= +github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM= +github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q= +github.com/google/flatbuffers v2.0.8+incompatible h1:ivUb1cGomAB101ZM1T0nOiWz9pSrTMoa9+EiY7igmkM= +github.com/google/flatbuffers v2.0.8+incompatible/go.mod h1:1AeVuKshWv4vARoZatz6mlQ0JxURH0Kv5+zNeJKJCa8= +github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= +github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= +github.com/google/go-github/v39 v39.2.0 h1:rNNM311XtPOz5rDdsJXAp2o8F67X9FnROXTvto3aSnQ= +github.com/google/go-github/v39 v39.2.0/go.mod h1:C1s8C5aCC9L+JXIYpJM5GYytdX52vC1bLvHEF1IhBrE= +github.com/google/go-querystring v1.1.0 h1:AnCroh3fv4ZBgVIf1Iwtovgjaw/GiKJo8M8yD/fhyJ8= +github.com/google/go-querystring v1.1.0/go.mod h1:Kcdr2DB4koayq7X8pmAG4sNG59So17icRSOU623lUBU= +github.com/google/s2a-go v0.1.7 h1:60BLSyTrOV4/haCDW4zb1guZItoSq8foHCXrAnjBo/o= +github.com/google/s2a-go v0.1.7/go.mod h1:50CgR4k1jNlWBu4UfS4AcfhVe1r6pdZPygJ3R8F0Qdw= +github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= +github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/googleapis/enterprise-certificate-proxy v0.3.2 h1:Vie5ybvEvT75RniqhfFxPRy3Bf7vr3h0cechB90XaQs= +github.com/googleapis/enterprise-certificate-proxy v0.3.2/go.mod h1:VLSiSSBs/ksPL8kq3OBOQ6WRI2QnaFynd1DCjZ62+V0= +github.com/googleapis/gax-go/v2 v2.12.2 h1:mhN09QQW1jEWeMF74zGR81R30z4VJzjZsfkUhuHF+DA= +github.com/googleapis/gax-go/v2 v2.12.2/go.mod h1:61M8vcyyXR2kqKFxKrfA22jaA8JGF7Dc8App1U3H6jc= +github.com/gorilla/handlers v1.4.2 h1:0QniY0USkHQ1RGCLfKxeNHK9bkDHGRYGNDFBCS+YARg= +github.com/gorilla/handlers v1.4.2/go.mod h1:Qkdc/uu4tH4g6mTK6auzZ766c4CA0Ng8+o/OAirnOIQ= +github.com/gorilla/mux v1.7.4 h1:VuZ8uybHlWmqV03+zRzdwKL4tUnIp1MAQtp1mIFE1bc= +github.com/gorilla/mux v1.7.4/go.mod h1:DVbg23sWSpFRCP0SfiEN6jmj59UnW/n46BH5rLB71So= +github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c h1:6rhixN/i8ZofjG1Y75iExal34USq5p+wiN1tpie8IrU= +github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c/go.mod h1:NMPJylDgVpX0MLRlPy15sqSwOFv/U1GZ2m21JhFfek0= +github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed h1:5upAirOpQc1Q53c0bnx2ufif5kANL7bfZWcc6VJWJd8= +github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed/go.mod h1:tMWxXQ9wFIaZeTI9F+hmhFiGpFmhOHzyShyFUhRm0H4= +github.com/hashicorp/errwrap v1.0.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4= +github.com/hashicorp/errwrap v1.1.0 h1:OxrOeh75EUXMY8TBjag2fzXGZ40LB6IKw45YeGUDY2I= +github.com/hashicorp/errwrap v1.1.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4= +github.com/hashicorp/go-multierror v1.1.1 h1:H5DkEtf6CXdFp0N0Em5UCwQpXMWke8IA0+lD48awMYo= +github.com/hashicorp/go-multierror v1.1.1/go.mod h1:iw975J/qwKPdAO1clOe2L8331t/9/fmwbPZ6JB6eMoM= +github.com/jackc/chunkreader/v2 v2.0.1 h1:i+RDz65UE+mmpjTfyz0MoVTnzeYxroil2G82ki7MGG8= +github.com/jackc/chunkreader/v2 v2.0.1/go.mod h1:odVSm741yZoC3dpHEUXIqA9tQRhFrgOHwnPIn9lDKlk= +github.com/jackc/pgconn v1.14.3 h1:bVoTr12EGANZz66nZPkMInAV/KHD2TxH9npjXXgiB3w= +github.com/jackc/pgconn v1.14.3/go.mod h1:RZbme4uasqzybK2RK5c65VsHxoyaml09lx3tXOcO/VM= +github.com/jackc/pgerrcode v0.0.0-20220416144525-469b46aa5efa h1:s+4MhCQ6YrzisK6hFJUX53drDT4UsSW3DEhKn0ifuHw= +github.com/jackc/pgerrcode v0.0.0-20220416144525-469b46aa5efa/go.mod h1:a/s9Lp5W7n/DD0VrVoyJ00FbP2ytTPDVOivvn2bMlds= +github.com/jackc/pgio v1.0.0 h1:g12B9UwVnzGhueNavwioyEEpAmqMe1E/BN9ES+8ovkE= +github.com/jackc/pgio v1.0.0/go.mod h1:oP+2QK2wFfUWgr+gxjoBH9KGBb31Eio69xUb0w5bYf8= +github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM= +github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg= +github.com/jackc/pgproto3/v2 v2.3.3 h1:1HLSx5H+tXR9pW3in3zaztoEwQYRC9SQaYUHjTSUOag= +github.com/jackc/pgproto3/v2 v2.3.3/go.mod h1:WfJCnwN3HIg9Ish/j3sgWXnAfK8A9Y0bwXYU5xKaEdA= +github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a h1:bbPeKD0xmW/Y25WS6cokEszi5g+S0QxI/d45PkRi7Nk= +github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM= +github.com/jackc/pgtype v1.14.0 h1:y+xUdabmyMkJLyApYuPj38mW+aAIqCe5uuBB51rH3Vw= +github.com/jackc/pgtype v1.14.0/go.mod h1:LUMuVrfsFfdKGLw+AFFVv6KtHOFMwRgDDzBt76IqCA4= +github.com/jackc/pgx/v4 v4.18.2 h1:xVpYkNR5pk5bMCZGfClbO962UIqVABcAGt7ha1s/FeU= +github.com/jackc/pgx/v4 v4.18.2/go.mod h1:Ey4Oru5tH5sB6tV7hDmfWFahwF15Eb7DNXlRKx2CkVw= +github.com/jackc/pgx/v5 v5.5.4 h1:Xp2aQS8uXButQdnCMWNmvx6UysWQQC+u1EoizjguY+8= +github.com/jackc/pgx/v5 v5.5.4/go.mod h1:ez9gk+OAat140fv9ErkZDYFWmXLfV+++K0uAOiwgm1A= +github.com/jackc/puddle/v2 v2.2.1 h1:RhxXJtFG022u4ibrCSMSiu5aOq1i77R3OHKNJj77OAk= +github.com/jackc/puddle/v2 v2.2.1/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4= +github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg= +github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo= +github.com/jmoiron/sqlx v1.4.0 h1:1PLqN7S1UYp5t4SrVVnt4nUVNemrDAtxlulVe+Qgm3o= +github.com/jmoiron/sqlx v1.4.0/go.mod h1:ZrZ7UsYB/weZdl2Bxg6jCRO9c3YHl8r3ahlKmRT4JLY= +github.com/jpillora/backoff v1.0.0 h1:uvFg412JmmHBHw7iwprIxkPMI+sGQ4kzOWsMeHnm2EA= +github.com/jpillora/backoff v1.0.0/go.mod h1:J/6gKK9jxlEcS3zixgDgUAsiuZ7yrSoa/FX5e0EB2j4= +github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM= +github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo= +github.com/julienschmidt/httprouter v1.3.0 h1:U0609e9tgbseu3rBINet9P48AI/D3oJs4dN7jwJOQ1U= +github.com/julienschmidt/httprouter v1.3.0/go.mod h1:JR6WtHb+2LUe8TCKY3cZOxFyyO8IZAc4RVcycCCAKdM= +github.com/k0kubun/pp v2.3.0+incompatible h1:EKhKbi34VQDWJtq+zpsKSEhkHHs9w2P8Izbq8IhLVSo= +github.com/k0kubun/pp v2.3.0+incompatible/go.mod h1:GWse8YhT0p8pT4ir3ZgBbfZild3tgzSScAn6HmfYukg= +github.com/kardianos/osext v0.0.0-20190222173326-2bc1f35cddc0 h1:iQTw/8FWTuc7uiaSepXwyf3o52HaUYcV+Tu66S3F5GA= +github.com/kardianos/osext v0.0.0-20190222173326-2bc1f35cddc0/go.mod h1:1NbS8ALrpOvjt0rHPNLyCIeMtbizbir8U//inJ+zuB8= +github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 h1:Z9n2FFNUXsshfwJMBgNA0RU6/i7WVaAegv3PtuIHPMs= +github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51/go.mod h1:CzGEWj7cYgsdH8dAjBGEr58BoE7ScuLd+fwFZ44+/x8= +github.com/klauspost/asmfmt v1.3.2 h1:4Ri7ox3EwapiOjCki+hw14RyKk201CN4rzyCJRFLpK4= +github.com/klauspost/asmfmt v1.3.2/go.mod h1:AG8TuvYojzulgDAMCnYn50l/5QV3Bs/tp6j0HLHbNSE= +github.com/klauspost/compress v1.17.9 h1:6KIumPrER1LHsvBVuDa0r5xaG0Es51mhhB9BQB2qeMA= +github.com/klauspost/compress v1.17.9/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw= +github.com/klauspost/cpuid/v2 v2.0.9 h1:lgaqFMSdTdQYdZ04uHyN2d/eKdOMyi2YLSvlQIBFYa4= +github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg= +github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= +github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= +github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= +github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= +github.com/ktrysmt/go-bitbucket v0.6.4 h1:C8dUGp0qkwncKtAnozHCbbqhptefzEd1I0sfnuy9rYQ= +github.com/ktrysmt/go-bitbucket v0.6.4/go.mod h1:9u0v3hsd2rqCHRIpbir1oP7F58uo5dq19sBYvuMoyQ4= +github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc= +github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw= +github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw= +github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o= +github.com/markbates/pkger v0.15.1 h1:3MPelV53RnGSW07izx5xGxl4e/sdRD6zqseIk0rMASY= +github.com/markbates/pkger v0.15.1/go.mod h1:0JoVlrol20BSywW79rN3kdFFsE5xYM+rSCQDXbLhiuI= +github.com/mattn/go-colorable v0.1.6 h1:6Su7aK7lXmJ/U79bYtBjLNaha4Fs1Rg9plHpcH+vvnE= +github.com/mattn/go-colorable v0.1.6/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc= +github.com/mattn/go-isatty v0.0.16 h1:bq3VjFmv/sOjHtdEhmkEV4x1AJtvUvOJ2PFAZ5+peKQ= +github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= +github.com/mattn/go-sqlite3 v1.14.22 h1:2gZY6PC6kBnID23Tichd1K+Z0oS6nE/XwU+Vz/5o4kU= +github.com/mattn/go-sqlite3 v1.14.22/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y= +github.com/microsoft/go-mssqldb v1.0.0 h1:k2p2uuG8T5T/7Hp7/e3vMGTnnR0sU4h8d1CcC71iLHU= +github.com/microsoft/go-mssqldb v1.0.0/go.mod h1:+4wZTUnz/SV6nffv+RRRB/ss8jPng5Sho2SmM1l2ts4= +github.com/minio/asm2plan9s v0.0.0-20200509001527-cdd76441f9d8 h1:AMFGa4R4MiIpspGNG7Z948v4n35fFGB3RR3G/ry4FWs= +github.com/minio/asm2plan9s v0.0.0-20200509001527-cdd76441f9d8/go.mod h1:mC1jAcsrzbxHt8iiaC+zU4b1ylILSosueou12R++wfY= +github.com/minio/c2goasm v0.0.0-20190812172519-36a3d3bbc4f3 h1:+n/aFZefKZp7spd8DFdX7uMikMLXX4oubIzJF4kv/wI= +github.com/minio/c2goasm v0.0.0-20190812172519-36a3d3bbc4f3/go.mod h1:RagcQ7I8IeTMnF8JTXieKnO4Z6JCsikNEzj0DwauVzE= +github.com/mitchellh/mapstructure v1.1.2 h1:fmNYVwqnSfB9mZU6OS2O6GsXM+wcskZDuKQzvN1EDeE= +github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y= +github.com/moby/docker-image-spec v1.3.1 h1:jMKff3w6PgbfSa69GfNg+zN/XLhfXJGnEx3Nl2EsFP0= +github.com/moby/docker-image-spec v1.3.1/go.mod h1:eKmb5VW8vQEh/BAr2yvVNvuiJuY6UIocYsFu/DxxRpo= +github.com/moby/term v0.5.0 h1:xt8Q1nalod/v7BqbG21f8mQPqH+xAaC9C3N3wfWbVP0= +github.com/moby/term v0.5.0/go.mod h1:8FzsFHVUBGZdbDsJw/ot+X+d5HLUbvklYLJ9uGfcI3Y= +github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= +github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= +github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= +github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= +github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A= +github.com/morikuni/aec v1.0.0/go.mod h1:BbKIizmSmc5MMPqRYbxO4ZU0S0+P200+tUnFx7PXmsc= +github.com/mtibben/percent v0.2.1 h1:5gssi8Nqo8QU/r2pynCm+hBQHpkB/uNK7BJCFogWdzs= +github.com/mtibben/percent v0.2.1/go.mod h1:KG9uO+SZkUp+VkRHsCdYQV3XSZrrSpR3O9ibNBTZrns= +github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA= +github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ= +github.com/mutecomm/go-sqlcipher/v4 v4.4.0 h1:sV1tWCWGAVlPhNGT95Q+z/txFxuhAYWwHD1afF5bMZg= +github.com/mutecomm/go-sqlcipher/v4 v4.4.0/go.mod h1:PyN04SaWalavxRGH9E8ZftG6Ju7rsPrGmQRjrEaVpiY= +github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f h1:KUppIJq7/+SVif2QVs3tOP0zanoHgBEVAwHxUSIzRqU= +github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U= +github.com/nakagami/firebirdsql v0.0.0-20190310045651-3c02a58cfed8 h1:P48LjvUQpTReR3TQRbxSeSBsMXzfK0uol7eRcr7VBYQ= +github.com/nakagami/firebirdsql v0.0.0-20190310045651-3c02a58cfed8/go.mod h1:86wM1zFnC6/uDBfZGNwB65O+pR2OFi5q/YQaEUid1qA= +github.com/neo4j/neo4j-go-driver v1.8.1-0.20200803113522-b626aa943eba h1:fhFP5RliM2HW/8XdcO5QngSfFli9GcRIpMXvypTQt6E= +github.com/neo4j/neo4j-go-driver v1.8.1-0.20200803113522-b626aa943eba/go.mod h1:ncO5VaFWh0Nrt+4KT4mOZboaczBZcLuHrG+/sUeP8gI= +github.com/onsi/ginkgo v1.16.4 h1:29JGrr5oVBm5ulCWet69zQkzWipVXIol6ygQUe/EzNc= +github.com/onsi/ginkgo v1.16.4/go.mod h1:dX+/inL/fNMqNlz0e9LfyB9TswhZpCVdJM/Z6Vvnwo0= +github.com/onsi/gomega v1.15.0 h1:WjP/FQ/sk43MRmnEcT+MlDw2TFvkrXlprrPST/IudjU= +github.com/onsi/gomega v1.15.0/go.mod h1:cIuvLEne0aoVhAgh/O6ac0Op8WWw9H6eYCriF+tEHG0= +github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U= +github.com/opencontainers/go-digest v1.0.0/go.mod h1:0JzlMkj0TRzQZfJkVvzbP0HBR3IKzErnv2BNG4W4MAM= +github.com/opencontainers/image-spec v1.1.0 h1:8SG7/vwALn54lVB/0yZ/MMwhFrPYtpEHQb2IpWsCzug= +github.com/opencontainers/image-spec v1.1.0/go.mod h1:W4s4sFTMaBeK1BQLXbG4AdM2szdn85PY75RI83NrTrM= +github.com/pierrec/lz4/v4 v4.1.16 h1:kQPfno+wyx6C5572ABwV+Uo3pDFzQ7yhyGchSyRda0c= +github.com/pierrec/lz4/v4 v4.1.16/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4= +github.com/pkg/browser v0.0.0-20210911075715-681adbf594b8 h1:KoWmjvw+nsYOo29YJK9vDA65RGE3NrOnUtO7a+RF9HU= +github.com/pkg/browser v0.0.0-20210911075715-681adbf594b8/go.mod h1:HKlIX3XHQyzLZPlr7++PzdhaXEj94dEiJgZDTsxEqUI= +github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= +github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/prometheus/client_golang v1.20.5 h1:cxppBPuYhUnsO6yo/aoRol4L7q7UFfdm+bR9r+8l63Y= +github.com/prometheus/client_golang v1.20.5/go.mod h1:PIEt8X02hGcP8JWbeHyeZ53Y/jReSnHgO035n//V5WE= +github.com/prometheus/client_model v0.6.1 h1:ZKSh/rekM+n3CeS952MLRAdFwIKqeY8b62p8ais2e9E= +github.com/prometheus/client_model v0.6.1/go.mod h1:OrxVMOVHjw3lKMa8+x6HeMGkHMQyHDk9E3jmP2AmGiY= +github.com/prometheus/common v0.55.0 h1:KEi6DK7lXW/m7Ig5i47x0vRzuBsHuvJdi5ee6Y3G1dc= +github.com/prometheus/common v0.55.0/go.mod h1:2SECS4xJG1kd8XF9IcM1gMX6510RAEL65zxzNImwdc8= +github.com/prometheus/procfs v0.15.1 h1:YagwOFzUgYfKKHX6Dr+sHT7km/hxC76UB0learggepc= +github.com/prometheus/procfs v0.15.1/go.mod h1:fB45yRUv8NstnjriLhBQLuOUt+WW4BsoGhij/e3PBqk= +github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0 h1:OdAsTTz6OkFY5QxjkYwrChwuRruF69c169dPK26NUlk= +github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo= +github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU5NdKM8= +github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4= +github.com/rqlite/gorqlite v0.0.0-20230708021416-2acd02b70b79 h1:V7x0hCAgL8lNGezuex1RW1sh7VXXCqfw8nXZti66iFg= +github.com/rqlite/gorqlite v0.0.0-20230708021416-2acd02b70b79/go.mod h1:xF/KoXmrRyahPfo5L7Szb5cAAUl53dMWBh9cMruGEZg= +github.com/shopspring/decimal v1.2.0 h1:abSATXmQEYyShuxI4/vyW3tV1MrKAJzCZ/0zLUXYbsQ= +github.com/shopspring/decimal v1.2.0/go.mod h1:DKyhrW/HYNuLGql+MJL6WCR6knT2jwCFRcu2hWCYk4o= +github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ= +github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ= +github.com/snowflakedb/gosnowflake v1.6.19 h1:KSHXrQ5o7uso25hNIzi/RObXtnSGkFgie91X82KcvMY= +github.com/snowflakedb/gosnowflake v1.6.19/go.mod h1:FM1+PWUdwB9udFDsXdfD58NONC0m+MlOSmQRvimobSM= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY= +github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA= +github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= +github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA= +github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +github.com/xanzy/go-gitlab v0.15.0 h1:rWtwKTgEnXyNUGrOArN7yyc3THRkpYcKXIXia9abywQ= +github.com/xanzy/go-gitlab v0.15.0/go.mod h1:8zdQa/ri1dfn8eS3Ir1SyfvOKlw7WBJ8DVThkpGiXrs= +github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c= +github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI= +github.com/xdg-go/scram v1.1.1 h1:VOMT+81stJgXW3CpHyqHN3AXDYIMsx56mEFrB37Mb/E= +github.com/xdg-go/scram v1.1.1/go.mod h1:RaEWvsqvNKKvBPvcKeFjrG2cJqOkHTiyTpzz23ni57g= +github.com/xdg-go/stringprep v1.0.3 h1:kdwGpVNwPFtjs98xCGkHjQtGKh86rDcRZN17QEMCOIs= +github.com/xdg-go/stringprep v1.0.3/go.mod h1:W3f5j4i+9rC0kuIEJL0ky1VpHXQU3ocBgklLGvcBnW8= +github.com/xhit/go-str2duration/v2 v2.1.0 h1:lxklc02Drh6ynqX+DdPyp5pCKLUQpRT8bp8Ydu2Bstc= +github.com/xhit/go-str2duration/v2 v2.1.0/go.mod h1:ohY8p+0f07DiV6Em5LKB0s2YpLtXVyJfNt1+BlmyAsU= +github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d h1:splanxYIlg+5LfHAM6xpdFEAYOk8iySO56hMFq6uLyA= +github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA= +github.com/zeebo/xxh3 v1.0.2 h1:xZmwmqxHZA8AI603jOQ0tMqmBr9lPeFwGg6d+xy9DC0= +github.com/zeebo/xxh3 v1.0.2/go.mod h1:5NWz9Sef7zIDm2JHfFlcQvNekmcEl9ekUZQQKCYaDcA= +gitlab.com/nyarla/go-crypt v0.0.0-20160106005555-d9a5dc2b789b h1:7gd+rd8P3bqcn/96gOZa3F5dpJr/vEiDQYlNb/y2uNs= +gitlab.com/nyarla/go-crypt v0.0.0-20160106005555-d9a5dc2b789b/go.mod h1:T3BPAOm2cqquPa0MKWeNkmOM5RQsRhkrwMWonFMN7fE= +go.mongodb.org/mongo-driver v1.7.5 h1:ny3p0reEpgsR2cfA5cjgwFZg3Cv/ofFh/8jbhGtz9VI= +go.mongodb.org/mongo-driver v1.7.5/go.mod h1:VXEWRZ6URJIkUq2SCAyapmhH0ZLRBP+FT4xhp5Zvxng= +go.opencensus.io v0.24.0 h1:y73uSU6J157QMP2kn2r30vwW1A2W2WFwSCGnAVxeaD0= +go.opencensus.io v0.24.0/go.mod h1:vNK8G9p7aAivkbmorf4v+7Hgx+Zs0yY+0fOtgBfjQKo= +go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.49.0 h1:4Pp6oUg3+e/6M4C0A/3kJ2VYa++dsWVTtGgLVj5xtHg= +go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.49.0/go.mod h1:Mjt1i1INqiaoZOMGR1RIUJN+i3ChKoFRqzrRQhlkbs0= +go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.54.0 h1:TT4fX+nBOA/+LUkobKGW1ydGcn+G3vRw9+g5HwCphpk= +go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.54.0/go.mod h1:L7UH0GbB0p47T4Rri3uHjbpCFYrVrwc1I25QhNPiGK8= +go.opentelemetry.io/otel v1.29.0 h1:PdomN/Al4q/lN6iBJEN3AwPvUiHPMlt93c8bqTG5Llw= +go.opentelemetry.io/otel v1.29.0/go.mod h1:N/WtXPs1CNCUEx+Agz5uouwCba+i+bJGFicT8SR4NP8= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.29.0 h1:dIIDULZJpgdiHz5tXrTgKIMLkus6jEFa7x5SOKcyR7E= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.29.0/go.mod h1:jlRVBe7+Z1wyxFSUs48L6OBQZ5JwH2Hg/Vbl+t9rAgI= +go.opentelemetry.io/otel/metric v1.29.0 h1:vPf/HFWTNkPu1aYeIsc98l4ktOQaL6LeSoeV2g+8YLc= +go.opentelemetry.io/otel/metric v1.29.0/go.mod h1:auu/QWieFVWx+DmQOUMgj0F8LHWdgalxXqvp7BII/W8= +go.opentelemetry.io/otel/sdk v1.29.0 h1:vkqKjk7gwhS8VaWb0POZKmIEDimRCMsopNYnriHyryo= +go.opentelemetry.io/otel/sdk v1.29.0/go.mod h1:pM8Dx5WKnvxLCb+8lG1PRNIDxu9g9b9g59Qr7hfAAok= +go.opentelemetry.io/otel/trace v1.29.0 h1:J/8ZNK4XgR7a21DZUAsbF8pZ5Jcw1VhACmnYt39JTi4= +go.opentelemetry.io/otel/trace v1.29.0/go.mod h1:eHl3w0sp3paPkYstJOmAimxhiFXPg+MMTlEh3nsQgWQ= +go.opentelemetry.io/proto/otlp v1.3.1 h1:TrMUixzpM0yuc/znrFTP9MMRh8trP93mkCiDVeXrui0= +go.opentelemetry.io/proto/otlp v1.3.1/go.mod h1:0X1WI4de4ZsLrrJNLAQbFeLCm3T7yBkR0XqQ7niQU+8= +go.uber.org/atomic v1.7.0 h1:ADUqmZGgLDDfbSL9ZmPxKTybcoEYHgpYfELNoN+7hsw= +go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= +golang.org/x/crypto v0.27.0 h1:GXm2NjJrPaiv/h1tb2UH8QfgC/hOf/+z0p6PT8o1w7A= +golang.org/x/crypto v0.27.0/go.mod h1:1Xngt8kV6Dvbssa53Ziq6Eqn0HqbZi5Z6R0ZpwQzt70= +golang.org/x/exp v0.0.0-20230315142452-642cacee5cc0 h1:pVgRXcIictcr+lBQIFeiwuwtDIs4eL21OuM9nyAADmo= +golang.org/x/exp v0.0.0-20230315142452-642cacee5cc0/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc= +golang.org/x/mod v0.21.0 h1:vvrHzRwRfVKSiLrG+d4FMl/Qi4ukBCE6kZlTUkDYRT0= +golang.org/x/mod v0.21.0/go.mod h1:6SkKJ3Xj0I0BrPOZoBy3bdMptDDU9oJrpohJ3eWZ1fY= +golang.org/x/net v0.29.0 h1:5ORfpBpCs4HzDYoodCDBbwHzdR5UrLBZ3sOnUJmFoHo= +golang.org/x/net v0.29.0/go.mod h1:gLkgy8jTGERgjzMic6DS9+SP0ajcu6Xu3Orq/SpETg0= +golang.org/x/oauth2 v0.21.0 h1:tsimM75w1tF/uws5rbeHzIWxEqElMehnc+iW793zsZs= +golang.org/x/oauth2 v0.21.0/go.mod h1:XYTD2NtWslqkgxebSiOHnXEap4TF09sJSc7H1sXbhtI= +golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ= +golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sys v0.25.0 h1:r+8e+loiHxRqhXVl6ML1nO3l1+oFoWbnlu2Ehimmi34= +golang.org/x/sys v0.25.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/term v0.24.0 h1:Mh5cbb+Zk2hqqXNO7S1iTjEphVL+jb8ZWaqh/g+JWkM= +golang.org/x/term v0.24.0/go.mod h1:lOBK/LVxemqiMij05LGJ0tzNr8xlmwBRJ81PX6wVLH8= +golang.org/x/text v0.18.0 h1:XvMDiNzPAl0jr17s6W9lcaIhGUfUORdGCNsuLmPG224= +golang.org/x/text v0.18.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY= +golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk= +golang.org/x/time v0.5.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM= +golang.org/x/tools v0.24.0 h1:J1shsA93PJUEVaUSaay7UXAyE8aimq3GW0pjlolpa24= +golang.org/x/tools v0.24.0/go.mod h1:YhNqVBIfWHdzvTLs0d8LCuMhkKUgSUKldakyV7W/WDQ= +golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 h1:+cNy6SZtPcJQH3LJVLOSmiC7MMxXNOb3PU/VUEz+EhU= +golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028/go.mod h1:NDW/Ps6MPRej6fsCIbMTohpP40sJ/P/vI1MoTEGwX90= +google.golang.org/api v0.169.0 h1:QwWPy71FgMWqJN/l6jVlFHUa29a7dcUy02I8o799nPY= +google.golang.org/api v0.169.0/go.mod h1:gpNOiMA2tZ4mf5R9Iwf4rK/Dcz0fbdIgWYWVoxmsyLg= +google.golang.org/appengine v1.6.8 h1:IhEN5q69dyKagZPYMSdIjS2HqprW324FRQZJcGqPAsM= +google.golang.org/appengine v1.6.8/go.mod h1:1jJ3jBArFh5pcgW8gCtRJnepW8FzD1V44FJffLiz/Ds= +google.golang.org/genproto v0.0.0-20240213162025-012b6fc9bca9 h1:9+tzLLstTlPTRyJTh+ah5wIMsBW5c4tQwGTN3thOW9Y= +google.golang.org/genproto v0.0.0-20240213162025-012b6fc9bca9/go.mod h1:mqHbVIp48Muh7Ywss/AD6I5kNVKZMmAa/QEW58Gxp2s= +google.golang.org/genproto/googleapis/api v0.0.0-20240513163218-0867130af1f8 h1:W5Xj/70xIA4x60O/IFyXivR5MGqblAb8R3w26pnD6No= +google.golang.org/genproto/googleapis/api v0.0.0-20240513163218-0867130af1f8/go.mod h1:vPrPUTsDCYxXWjP7clS81mZ6/803D8K4iM9Ma27VKas= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240513163218-0867130af1f8 h1:mxSlqyb8ZAHsYDCfiXN1EDdNTdvjUJSLY+OnAUtYNYA= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240513163218-0867130af1f8/go.mod h1:I7Y+G38R2bu5j1aLzfFmQfTcU/WnFuqDwLZAbvKTKpM= +google.golang.org/grpc v1.64.1 h1:LKtvyfbX3UGVPFcGqJ9ItpVWW6oN/2XqTxfAnwRRXiA= +google.golang.org/grpc v1.64.1/go.mod h1:hiQF4LFZelK2WKaP6W0L92zGHtiQdZxk8CrSdvyjeP0= +google.golang.org/protobuf v1.36.4 h1:6A3ZDJHn/eNqc1i+IdefRzy/9PokBTPvcqMySR7NNIM= +google.golang.org/protobuf v1.36.4/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= +gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc= +gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw= +gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= +gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +lukechampine.com/uint128 v1.2.0 h1:mBi/5l91vocEN8otkC5bDLhi2KdCticRiwbdB0O+rjI= +lukechampine.com/uint128 v1.2.0/go.mod h1:c4eWIwlEGaxC/+H1VguhU4PHXNWDCDMUlWdIWl2j1gk= +modernc.org/b v1.0.0 h1:vpvqeyp17ddcQWF29Czawql4lDdABCDRbXRAS4+aF2o= +modernc.org/b v1.0.0/go.mod h1:uZWcZfRj1BpYzfN9JTerzlNUnnPsV9O2ZA8JsRcubNg= +modernc.org/cc/v3 v3.36.3 h1:uISP3F66UlixxWEcKuIWERa4TwrZENHSL8tWxZz8bHg= +modernc.org/cc/v3 v3.36.3/go.mod h1:NFUHyPn4ekoC/JHeZFfZurN6ixxawE1BnVonP/oahEI= +modernc.org/ccgo/v3 v3.16.9 h1:AXquSwg7GuMk11pIdw7fmO1Y/ybgazVkMhsZWCV0mHM= +modernc.org/ccgo/v3 v3.16.9/go.mod h1:zNMzC9A9xeNUepy6KuZBbugn3c0Mc9TeiJO4lgvkJDo= +modernc.org/db v1.0.0 h1:2c6NdCfaLnshSvY7OU09cyAY0gYXUZj4lmg5ItHyucg= +modernc.org/db v1.0.0/go.mod h1:kYD/cO29L/29RM0hXYl4i3+Q5VojL31kTUVpVJDw0s8= +modernc.org/file v1.0.0 h1:9/PdvjVxd5+LcWUQIfapAWRGOkDLK90rloa8s/au06A= +modernc.org/file v1.0.0/go.mod h1:uqEokAEn1u6e+J45e54dsEA/pw4o7zLrA2GwyntZzjw= +modernc.org/fileutil v1.0.0 h1:Z1AFLZwl6BO8A5NldQg/xTSjGLetp+1Ubvl4alfGx8w= +modernc.org/fileutil v1.0.0/go.mod h1:JHsWpkrk/CnVV1H/eGlFf85BEpfkrp56ro8nojIq9Q8= +modernc.org/golex v1.0.0 h1:wWpDlbK8ejRfSyi0frMyhilD3JBvtcx2AdGDnU+JtsE= +modernc.org/golex v1.0.0/go.mod h1:b/QX9oBD/LhixY6NDh+IdGv17hgB+51fET1i2kPSmvk= +modernc.org/internal v1.0.0 h1:XMDsFDcBDsibbBnHB2xzljZ+B1yrOVLEFkKL2u15Glw= +modernc.org/internal v1.0.0/go.mod h1:VUD/+JAkhCpvkUitlEOnhpVxCgsBI90oTzSCRcqQVSM= +modernc.org/libc v1.17.1 h1:Q8/Cpi36V/QBfuQaFVeisEBs3WqoGAJprZzmf7TfEYI= +modernc.org/libc v1.17.1/go.mod h1:FZ23b+8LjxZs7XtFMbSzL/EhPxNbfZbErxEHc7cbD9s= +modernc.org/lldb v1.0.0 h1:6vjDJxQEfhlOLwl4bhpwIz00uyFK4EmSYcbwqwbynsc= +modernc.org/lldb v1.0.0/go.mod h1:jcRvJGWfCGodDZz8BPwiKMJxGJngQ/5DrRapkQnLob8= +modernc.org/mathutil v1.5.0 h1:rV0Ko/6SfM+8G+yKiyI830l3Wuz1zRutdslNoQ0kfiQ= +modernc.org/mathutil v1.5.0/go.mod h1:mZW8CKdRPY1v87qxC/wUdX5O1qDzXMP5TH3wjfpga6E= +modernc.org/memory v1.2.1 h1:dkRh86wgmq/bJu2cAS2oqBCz/KsMZU7TUM4CibQ7eBs= +modernc.org/memory v1.2.1/go.mod h1:PkUhL0Mugw21sHPeskwZW4D6VscE/GQJOnIpCnW6pSU= +modernc.org/opt v0.1.3 h1:3XOZf2yznlhC+ibLltsDGzABUGVx8J6pnFMS3E4dcq4= +modernc.org/opt v0.1.3/go.mod h1:WdSiB5evDcignE70guQKxYUl14mgWtbClRi5wmkkTX0= +modernc.org/ql v1.0.0 h1:bIQ/trWNVjQPlinI6jdOQsi195SIturGo3mp5hsDqVU= +modernc.org/ql v1.0.0/go.mod h1:xGVyrLIatPcO2C1JvI/Co8c0sr6y91HKFNy4pt9JXEY= +modernc.org/sortutil v1.1.0 h1:oP3U4uM+NT/qBQcbg/K2iqAX0Nx7B1b6YZtq3Gk/PjM= +modernc.org/sortutil v1.1.0/go.mod h1:ZyL98OQHJgH9IEfN71VsamvJgrtRX9Dj2gX+vH86L1k= +modernc.org/sqlite v1.18.1 h1:ko32eKt3jf7eqIkCgPAeHMBXw3riNSLhl2f3loEF7o8= +modernc.org/sqlite v1.18.1/go.mod h1:6ho+Gow7oX5V+OiOQ6Tr4xeqbx13UZ6t+Fw9IRUG4d4= +modernc.org/strutil v1.1.3 h1:fNMm+oJklMGYfU9Ylcywl0CO5O6nTfaowNsh2wpPjzY= +modernc.org/strutil v1.1.3/go.mod h1:MEHNA7PdEnEwLvspRMtWTNnp2nnyvMfkimT1NKNAGbw= +modernc.org/token v1.0.0 h1:a0jaWiNMDhDUtqOj09wvjWWAqd3q7WpBulmL9H2egsk= +modernc.org/token v1.0.0/go.mod h1:UGzOrNV1mAFSEB63lOFHIpNRUVMvYTc6yu1SMY/XTDM= +modernc.org/zappy v1.0.0 h1:dPVaP+3ueIUv4guk8PuZ2wiUGcJ1WUVvIheeSSTD0yk= +modernc.org/zappy v1.0.0/go.mod h1:hHe+oGahLVII/aTTyWK/b53VDHMAGCBYYeZ9sn83HC4=
