Method Complete

internal/idempotency/store.go:247–259

Complete records the response for an OutcomeAcquired claim. After this point any subsequent Claim with the same key either replays (body matches) or 422s (body differs), until the row is swept. Idempotent against double-call: only updates rows still marked in_progress, so a stray re-Complete from a

(ctx context.Context, userID, key string, resp CachedResponse)

// in_progress, so a stray re-Complete from a buggy caller cannot
// overwrite an already-cached response.
func (s *Store) Complete(ctx context.Context, userID, key string, resp CachedResponse) error {
	_, err := s.pool.Exec(ctx,
		`UPDATE idempotency_keys
		    SET status                = 'completed',
		        response_status       = $3,
		        response_content_type = $4,
		        response_body         = $5,
		        completed_at          = now()
		  WHERE user_id = $1 AND key = $2 AND status = 'in_progress'`,
		userID, key, resp.StatusCode, resp.ContentType, resp.Body,
	)
	return err
}

// Release drops an OutcomeAcquired claim without recording a response.
// Use when the caller decided not to perform the side effect (e.g.