(ctx context.Context)
| 211 | } |
| 212 | |
| 213 | func (api *API) refreshEntitlements(ctx context.Context) error { |
| 214 | api.Logger.Info(ctx, "refresh entitlements now") |
| 215 | |
| 216 | err := api.updateEntitlements(ctx) |
| 217 | if err != nil { |
| 218 | return xerrors.Errorf("failed to update entitlements: %w", err) |
| 219 | } |
| 220 | err = api.Pubsub.Publish(PubsubEventLicenses, []byte("refresh")) |
| 221 | if err != nil { |
| 222 | api.Logger.Error(ctx, "failed to publish forced entitlement update", slog.Error(err)) |
| 223 | return xerrors.Errorf("failed to publish forced entitlement update, other replicas might not be updated: %w", err) |
| 224 | } |
| 225 | return nil |
| 226 | } |
| 227 | |
| 228 | // @Summary Get licenses |
| 229 | // @ID get-licenses |
no test coverage detected