From 582bf08e0f03a0d20265f4581ab1cb217d712d29 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=89mile=20R=C3=A9?= Date: Mon, 8 Dec 2025 12:15:31 +0100 Subject: [PATCH] Fix some queries MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Émile Ré --- pkg/coredata/trust_center_document_access.go | 16 +++++++++++++--- pkg/probo/trust_center_access_service.go | 2 +- 2 files changed, 14 insertions(+), 4 deletions(-) diff --git a/pkg/coredata/trust_center_document_access.go b/pkg/coredata/trust_center_document_access.go index 752de1ed7..3afa7d4d7 100644 --- a/pkg/coredata/trust_center_document_access.go +++ b/pkg/coredata/trust_center_document_access.go @@ -638,7 +638,6 @@ func DeleteByTrustCenterAccessID( conn pg.Conn, scope Scoper, trustCenterAccessID gid.GID, - updatedAt time.Time, ) error { q := ` DELETE FROM trust_center_document_accesses @@ -651,7 +650,6 @@ WHERE args := pgx.StrictNamedArgs{ "trust_center_access_id": trustCenterAccessID, - "updated_at": updatedAt, } maps.Copy(args, scope.SQLArguments()) @@ -886,12 +884,24 @@ WITH report_access_data AS ( unnest(@report_ids::text[]) AS report_id, null::text AS trust_center_file_id, false AS active, + 'REQUESTED'::trust_center_document_access_status AS status, @requested::boolean AS requested, @created_at::timestamptz AS created_at, @updated_at::timestamptz AS updated_at ) INSERT INTO trust_center_document_accesses ( - id, tenant_id, organization_id, trust_center_access_id, document_id, report_id, trust_center_file_id, active, requested, created_at, updated_at + id, + tenant_id, + organization_id, + trust_center_access_id, + document_id, + report_id, + trust_center_file_id, + active, + status, + requested, + created_at, + updated_at ) SELECT * FROM report_access_data ON CONFLICT DO NOTHING diff --git a/pkg/probo/trust_center_access_service.go b/pkg/probo/trust_center_access_service.go index 261c79fe9..6fc68e87e 100644 --- a/pkg/probo/trust_center_access_service.go +++ b/pkg/probo/trust_center_access_service.go @@ -397,7 +397,7 @@ func (s TrustCenterAccessService) upsertDocumentAccesses( return nil } - if err := coredata.DeleteByTrustCenterAccessID(ctx, tx, s.svc.scope, accessID, now); err != nil { + if err := coredata.DeleteByTrustCenterAccessID(ctx, tx, s.svc.scope, accessID); err != nil { return fmt.Errorf("cannot delete existing document accesses: %w", err) }