Skip to content

Commit 034d8fa

Browse files
committed
fix: bugs
1 parent f16c647 commit 034d8fa

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

pkg/repository/olap.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2745,10 +2745,10 @@ func (r *OLAPRepositoryImpl) ListEvents(ctx context.Context, opts sqlcv1.ListEve
27452745

27462746
for i, event := range events {
27472747
eventExternalIds[i] = event.ExternalID
2748-
readPayloadOpts = append(readPayloadOpts, ReadOLAPPayloadOpts{
2748+
readPayloadOpts[i] = ReadOLAPPayloadOpts{
27492749
ExternalId: event.ExternalID,
27502750
InsertedAt: event.SeenAt,
2751-
})
2751+
}
27522752

27532753
if event.SeenAt.Time.Before(minSeenAt.Time) {
27542754
minSeenAt = event.SeenAt
@@ -3070,11 +3070,9 @@ func (r *OLAPRepositoryImpl) ReadPayload(ctx context.Context, tenantId uuid.UUID
30703070

30713071
func (r *OLAPRepositoryImpl) readPayloads(ctx context.Context, tx sqlcv1.DBTX, tenantId uuid.UUID, opts ...ReadOLAPPayloadOpts) (map[uuid.UUID][]byte, error) {
30723072
externalIds := make([]uuid.UUID, len(opts))
3073-
insertedAts := make([]pgtype.Timestamptz, len(opts))
30743073

30753074
for i, opt := range opts {
30763075
externalIds[i] = opt.ExternalId
3077-
insertedAts[i] = opt.InsertedAt
30783076
}
30793077

30803078
payloads, err := r.queries.ReadPayloadsOLAP(ctx, tx, sqlcv1.ReadPayloadsOLAPParams{

0 commit comments

Comments
 (0)