Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>

* Misc fixes
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Improvements for E2E test
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Allow running workflow e2e test without Kubernetes
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* 💄Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* 💄Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Added fmt.Stringer for debugging
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Tests have a random suffix
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Some memory optimization
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* More memory optimizations
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Add GetBulkState to actor runtime to be used by internal actors
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Update pkg/runtime/wfengine/workflow.go
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>

* Apply suggestions from code review
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>

* 💄Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Lint
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Apply suggestions from code review
Co-Authored-By: NChris Gillum <cgillum@microsoft.com>
Signed-off-by: NChris Gillum <cgillum@microsoft.com>
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>

* Changed
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

Signed-off-by: NHal Spang <halspang@microsoft.com>

* Change channel callers to dynamically fetch channels to enable dynamic
configuration
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Move outbox creation to pubsub processor package.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Name the return string variable pair in api_directmessaging.go
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* pkg/grpc/manager/dial_test.go: Adds copyright headers
Signed-off-by: Njoshvanl <me@joshvanl.dev>

---------
Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* Initial fix for timers in workflow
Signed-off-by: NRyan Lettieri <ryanLettieri@microsoft.com>

* Simplifying fix for workflow timer
Signed-off-by: NRyan Lettieri <ryanLettieri@microsoft.com>

* Fixing inbox unit test for workflow
Signed-off-by: NRyan Lettieri <ryanLettieri@microsoft.com>

* Cleaning up code
Signed-off-by: NRyan Lettieri <ryanLettieri@microsoft.com>

---------
Signed-off-by: NRyan Lettieri <ryanLettieri@microsoft.com>

* Add Pending Activity check
Signed-off-by: NDeepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Incorporate review comments
Signed-off-by: NDeepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

---------
Signed-off-by: NDeepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Co-authored-by: NLoong Dai <long.dai@intel.com>

* Remove ServiceInvocationStreaming feature flag
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* mod tidy
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Fix
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

Signed-off-by: NHongkai Wang <whk.private@gmail.com>

Removes the need to maintain a goroutine for each active timer, improving perf and resource utilization.
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* Block on metrics Run when disabled to prevent immediate closing on
concurrency runner.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Update metrics tests now Run blocks
Signed-off-by: Njoshvanl <me@joshvanl.dev>

---------
Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NYaron Schneider <schneider.yaron@live.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

Signed-off-by: Naddjuarez <adjuarez@microsoft.com>
Co-authored-by: NLoong Dai <long.dai@intel.com>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>

* Fix actor reminder locks to prevent race conditions with evaluations

Currently, a channel (`evaluationChan`) used as mutex prevents reminders to be saved or deleted while reminder evaluation (which happens every time the placement table changes) is in progress. However, nothing was preventing reminder evaluation to begin while a save/delete operation on reminders was in progress.

This changes the use of locks in the package so evaluation can't start while a reminder is being created/deleted.
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Use a queue for evaluationChan to prevent blocking
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Fixed reminders
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>

From the now-closed PR #6546

Most notable includes a fix in how DAPR_ENV_KEYS is handled, so it's case-insensitive
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NYaron Schneider <schneider.yaron@live.com>

* pluggable component: Secret store
Signed-off-by: NPravin Pushkar <ppushkar@microsoft.com>

* Adding unit tests
Signed-off-by: NPravin Pushkar <ppushkar@microsoft.com>

* lint fix
Signed-off-by: NPravin Pushkar <ppushkar@microsoft.com>

* start proto message field with 1
Signed-off-by: NPravin Pushkar <ppushkar@microsoft.com>

---------
Signed-off-by: NPravin Pushkar <ppushkar@microsoft.com>
Co-authored-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* fix trace headers for existing cloud events
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* add tests and refactor method
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* linter
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* fix linter for unrelated code
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

---------
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

Linter _should_ have caught that 🤔Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Update placement to use security pkg
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Adds `mtls.sentryAddres` to helm values file
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Linting
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Linting
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Review comment nits
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Use correct port for sentry port
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Revert sentry service port to 80 to maintain backwards compat
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Use legacy Server authenticator to allow placement to connect to legacy
(pre v1.12) daprd clients.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Return connection error in daprd actor gRPC client
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Adds `cluster.local` DNS to placement server certificate
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Remove block and returning connection error for actor placement client
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Increase timeout for security file change test
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Use the `dapr.io/control-plane` annotation on the placement pod instead
of `dapr.io/app-id`
Signed-off-by: Njoshvanl <me@joshvanl.dev>

---------
Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

Signed-off-by: Nyaron2 <schneider.yaron@live.com>

Sentry Kubernetes Validator ensures control-plane clients have the control plane annotation set. (#6791)

* Sentry Kubernetes Validator ensures control-plane clients have the
control plane annotation set.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Adds tests for checking that the kubernetes validator erros if the
control plane component is not known
Signed-off-by: Njoshvanl <me@joshvanl.dev>

---------
Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* Gracefully shutdown Dapr, waiting for all go routines and servers to
close before exiting.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Stop ticker when returning `startWorkloadCertRotation`
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Don't use concurrency runner when closing http servers. Concurrently
close apiClosers
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Review comments
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* runtime_test.go Init pubsub before running runtime
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Pass through context to actor placement connection client
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Ensure placement client dial has context passed
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Ignore gRPC server stopped errors
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Gracefully shutdown Dapr, waiting for all go routines and servers to
close before exiting.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Adds concurrency RuntimeCloserManager to handle closing of all
runtime components.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Use a dedicated http client in tests which close idle connections on
test cleanup
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Address review comments
Signed-off-by: Njoshvanl <me@joshvanl.dev>

---------
Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* adding service invocation metrics in grpc proxy
Signed-off-by: NAnnu Singh <annu4444.as@gmail.com>

* fixes and tests
Signed-off-by: NFilinto Duran <filinto@diagrid.io>

* remove noop line
Signed-off-by: NFilinto Duran <filinto@diagrid.io>

* fix linting
Signed-off-by: NFilinto Duran <filinto@diagrid.io>

* add connection failure tests, refactor
Signed-off-by: NFilinto Duran <filinto@diagrid.io>

* lint format
Signed-off-by: NFilinto Duran <filinto@diagrid.io>

* refactor to make metrics assertion clearer
Signed-off-by: NFilinto Duran <filinto@diagrid.io>

* remove question comment
Signed-off-by: NFilinto Duran <filinto@diagrid.io>

---------
Signed-off-by: NAnnu Singh <annu4444.as@gmail.com>
Signed-off-by: NFilinto Duran <filinto@diagrid.io>
Co-authored-by: NAnnu Singh <annu4444.as@gmail.com>
Co-authored-by: NYaron Schneider <schneider.yaron@live.com>
Co-authored-by: NArtur Souza <asouza.pro@gmail.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* outbox improvements
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* linter
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* go mod tidy + fix test
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

---------
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Update HTTPEndpoint tls tests with generated PKI, with failure cases and
1 length chains.
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Generate PKI in e2e test setup and create with client rather than using
cert-manager
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Fix error string check on new message and use PKCS8 for private key PEM
encoding
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Correctly ignore missing Secret resource in e2e Kubernetes platform
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Use correct Secret key for TLS private key reference
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Linting
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Adds context timeouts to Secret kubernetes platform resource
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Flush HTTPEndpoints before building pipeline
Signed-off-by: Njoshvanl <me@joshvanl.dev>

---------
Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* Fix postgres overrides
Signed-off-by: NShubham Sharma <shubhash@microsoft.com>

* Update tests/dapr_tests.mk
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NShubham Sharma <shubhash@microsoft.com>
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>

When the HTTP and gRPC APIs are created, they now receive the same instance of the UniversalAPI object.

This should:

- Offer some (small) memory improvements
- Make it so the metadata API allows setting custom metadata using gRPC and read it using HTTP, and vice versa.
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>

* Misc fixes and tweaks from #6729

Includes:

- Avoid unnecessary compStore property in gRPC and HTTP API structs
- Remove now-unused KeepWildcardUnescaped property
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Make metrics regex test safer for concurrent access
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Few more small tweaks
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Update pkg/http/server.go
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>

* Update pkg/diagnostics/metrics.go
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: NAlessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

Stop SubscribeConfiguration when client disconnects to prevent leaks and enable graceful shutdown (#6769)

* Stop SubscribeConfiguration when client disconnects to prevent leaks

Fixes #6560

Clients can continue to call UnsubscribeConfiguration for backwards-compatibility. However, doing so will show a warning encouraging users to simply close the connection to the SubscribeConfiguration RPC.
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* E2E tests
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

Signed-off-by: Njoshvanl <me@joshvanl.dev>
Co-authored-by: NArtur Souza <asouza.pro@gmail.com>

Signed-off-by: Njoshvanl <me@joshvanl.dev>

Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: NMukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>

* Flaky unit tests: fix many race conditions

Also increases the timeout on resiliency tests which seem to sometimes take longer on our Actions runners
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Use RWMutex
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* Fix: AKS tests not working due to invalid K8s version

* Fixed AKS SKU
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Updated pinned contrib
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Updated contrib
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Updated pinned contrib
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

---------
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* fix connection leak with app channel
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* remove unused var
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

---------
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

Removes a 3rd-party dependency which is unmaintained
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: NYaron Schneider <schneider.yaron@live.com>
Co-authored-by: NDapr Bot <56698301+dapr-bot@users.noreply.github.com>

* return error on failing grpc app health probe
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* add setResult=false to error condition
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* remove comment
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

---------
Signed-off-by: Nyaron2 <schneider.yaron@live.com>

* Use eventuallys in outbox integration tests
Signed-off-by: Njoshvanl <me@joshvanl.dev>

* Linting
Signed-off-by: Njoshvanl <me@joshvanl.dev>

---------
Signed-off-by: Njoshvanl <me@joshvanl.dev>

On my dev box, these tests were failing over 50% of times, due to race conditions in the tests (not in the code)
Signed-off-by: NItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>