Commit Graph

507 Commits

Author SHA1 Message Date
Bernd Verst 3a616c5678 Remove Track 1 SDK references
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-27 12:44:32 -08:00
Bernd Verst 4b01912b0f Address review comments
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-24 16:23:00 -08:00
Bernd Verst 358ebbf0bc Merge remote-tracking branch 'upstream/master' into azqueue 2023-02-24 15:52:10 -08:00
Bernd Verst 7c005d134a Upgrade Azure Storage Queue Binding to Track2 SDK
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-24 15:52:03 -08:00
ItalyPaleAle 2a5abb9a4f Remove deprecated components: pubsub.hazelcast, bindings.twitter
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-24 22:11:11 +00:00
Bernd Verst 4068531538
Merge branch 'master' into metadata 2023-02-22 16:46:43 -08:00
ItalyPaleAle 55b6a04805 Merge branch 'master' of https://github.com/dapr/components-contrib into newdeps
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-17 21:20:45 +00:00
ItalyPaleAle 848eec4fe6 Changed linter version for now
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-17 18:02:55 +00:00
ItalyPaleAle 9c9d96b64e Merge branch 'master' of https://github.com/dapr/components-contrib into release-1.10 2023-02-17 01:16:55 +00:00
ItalyPaleAle bc47aa3049 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-17 00:59:25 +00:00
Bernd Verst 83ebec68c1
HTTP binding: Make response timeout customizable (#2540)
* HTTP binding: Make response timeout customizable

Signed-off-by: Bernd Verst <github@bernd.dev>

* use optional context timeout

Signed-off-by: Bernd Verst <github@bernd.dev>

---------

Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-16 16:19:05 -08:00
ItalyPaleAle 8c7ae10f4c 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-17 00:02:23 +00:00
ItalyPaleAle a484d7ebc7 Merge branch 'master' of https://github.com/dapr/components-contrib into newdeps
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-16 23:35:28 +00:00
ItalyPaleAle f9cf54ca6f Merge branch 'master' of https://github.com/dapr/components-contrib into release-1.10
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-16 23:23:23 +00:00
Josh van Leeuwen d098e38d6a
Propagate context from caller to appropriate places in the code (#2474)
* Propagates contexts to callers where appropriate.

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

* Updates units tests with new func signature

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

* Fix linting errors

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

* Add atomic gate to alicloud rocketmq close channel.

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

* bindings/aws/kinesis use a separate ctx variable name

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

* binding/kafka: use atomic to prevent closing the channel twice

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

* bindings/mqtt3: use atomic bool to prevent close channel being closed multiple times

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

* bindings/mqtt3: use Background context for handle operations:w

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

* state/cocroachdb: add context to Ping()

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

* bindings/postgres: add comment explaining use of context.

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

* Adds comment header to health/pinger.go

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

* pubsub/aws/snssqs: add waitgroup to wait for all go routines to finish
and block on Close(). Shuts down the subscription if there are no topic
handlers.

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

* pubsub/mqtt3: add atomic bool to prevent multiple channel closes. Add
wait group to block close on all goroutines to finish.

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

* pubsub/rabbitmq: fixes race conditions, uses atomic to prevent multiple
closes, add wait group to block close on all goroutines

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

* pubsub/redis: revert ctx passed when it could be cancelled. Add wait
group wait when closing.

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

* state/postges: pass context in init, and wait group on close.

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

* Update all `Ping()` to `PingContext()` where possible.

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

* state/in-memory: add atomic bool to prevent closing channel multiple
times. Add wait group to block on close()

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

* state/mysql: don't use same ctx variable name

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

* Pass correct loop context to redis go routines

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

* Rename context when creating timeouts in state

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

* Remove state.Features() from requiring a context

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

* Revert wasm request handle Close func to be without context to
implement io.Closer interface. Add 5 second timeout. Add io.Closer
assertion in test.

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

* Remove superfluous go lint vet directive

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

* Change Configuration Init function to take context

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

* Updates input binding interface to include a `Close() error` function. `Close`
blocks until all resources have been released and go routines have returned.

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

* Change `Close() error` in input binding struct to `io.Closer` interface.

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

* Update go.mod files to point to dapr/dapr PR https://github.com/dapr/dapr/pull/5831

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

* pubsub/redis: watch closeCh to shutdown worker instead of init context.

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

* pubsub/aws/snssqs + bindings/kubemq: ensure closeCh is caught so Close
correctly returns

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

* Close kubemq binding client on close. Ensure kafka consumer channel
cannot be closed more than once.

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

* Tweaks

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

* Fixed cert tests

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

* binding/mqtt3: add inline Background context instead of passing to
handleMessage

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

* pubsub/mqtt3: remove context from createSubscriberClientOptions

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

* pubsub/mqtt3: Remove `ResetConnection` func

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

* pubsub/kafka: Don't resubscribe if Subscribe is cancelled.

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

* binding/mqtt3: don't use context to control establishing connection

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

* bindings/mqtt3: Fix linting errors

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

---------

Signed-off-by: joshvanl <me@joshvanl.dev>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2023-02-16 14:18:35 -08:00
ItalyPaleAle a8957062f0 Fixed tests
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-16 01:42:05 +00:00
ItalyPaleAle 6f30dbf6c6 Updated Azure Event Hubs and Azure Blob Storage SDKs
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-16 00:21:56 +00:00
ItalyPaleAle 643a2abff2 Removed go.uber.org/atomic and github.com/pkg/errors
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-15 19:56:20 +00:00
ItalyPaleAle 052618ddcb Use a single library for JWTs
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-15 19:35:53 +00:00
Bernd Verst b1c1304a86 Add and update component metadata definition files
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-13 17:09:09 -08:00
Alessandro (Ale) Segala 12acf8effe
[release-1.10] Azure Service Bus: fix goroutine "explosion" after recovering from failure and many other bugs (#2523)
* Fixed context leak

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

* Finalize messages in background

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

* More tweaks

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

* Moved a lot more code to the shared implementation package

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

* Fixed:
- Fixed: if number of messages received in bulk is greater than maxConcurrentHandlers, a deadlock happens
- Fixed: maxRetriableErrorsPerSec was not working

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

* Some refactorings

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

* Simplifications

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

* Avoid checking if topic/queue exists every time we send a message

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

* Ensuring locks are renewed for all 3 components

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

* Updated ASB SDK

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

* Improvements to closing

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

* Improvements to closing

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

* Changed context propagation

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

* Debug logs in cert tests

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

* Initial delay before renewing locks

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

* That last change was actually unnecessary

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

* Tweaks

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

* More tweaks

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

* 💄

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

---------

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-13 09:23:03 -08:00
Bernd Verst 785033b03e Move vendor neutral OSS components
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-09 16:20:15 -08:00
Bernd Verst de5f3c234e Fix linter
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-03 13:25:29 -08:00
Bernd Verst 0ee01e0620 Add Twitter Binding deprecation notice
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-02-03 13:23:29 -08:00
ItalyPaleAle c5f50a9948 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-03 12:49:08 -08:00
ItalyPaleAle 52383b6e0c Allow using relative paths again
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-03 12:40:26 -08:00
Matthias Wessendorf 42a2e8f5b0 Make use of CloudEvent content header constant to avoid duplication
Signed-off-by: Matthias Wessendorf <mwessend@redhat.com>
2023-02-02 15:43:49 +01:00
Bernd Verst a08a813fe7 Fix Azure metadata parsing
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-01-31 17:07:31 -08:00
ItalyPaleAle d7b6177b56 Event Grid binding: validate the Authorization header in incoming requests
- Changed component to require a bearer token in the Authorization header in all incoming requests
- Validate the bearer token as a JWT signed by Azure AD
- Updated the infra setup script to configure the Azure AD app correctly
- Event Grid binding now accepts any path (which can also include a random token) and not just `/api/events`

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-31 13:58:57 -08:00
ItalyPaleAle 7047ad533d More logging when Service Bus reconnects after publishing error
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-31 17:58:30 +00:00
ItalyPaleAle 7880c77d69 Fixed unit tests
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-26 00:34:35 +00:00
Alessandro (Ale) Segala 00e7d1d19a
Merge branch 'master' into mqtt3-conn-fixes 2023-01-25 16:29:04 -08:00
ItalyPaleAle 64087d7f4b Lots of fixes
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-26 00:26:00 +00:00
ItalyPaleAle dbf8426993 Updated mqtt binding too
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-25 23:47:30 +00:00
yaron2 1a653144bf add security token header support
Signed-off-by: yaron2 <schneider.yaron@live.com>
2023-01-25 15:03:43 -08:00
Pravin Pushkar be72232489 fix error: filename too long
Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
2023-01-24 19:15:23 +05:30
Bernd Verst 38ed5d7f97
Merge branch 'master' into httpBindingTracing 2023-01-23 19:18:12 -08:00
Bernd Verst a80b234a64 Apply suggestions from code review
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-01-24 10:59:46 +09:00
Drew Robbins 6faaf6065d Remove traceheaders from metadata
Signed-off-by: Drew Robbins <drew@drewby.com>
2023-01-24 10:59:46 +09:00
Drew Robbins dfae145b4b Remove component metadata, overwrite headers if exist
Signed-off-by: Drew Robbins <drew@drewby.com>
2023-01-24 10:59:46 +09:00
Drew Robbins 7bcdaca458 Updates to test
Signed-off-by: Drew Robbins <drew@drewby.com>
2023-01-24 10:59:46 +09:00
Drew Robbins f8d69c93d2 Changes from PR feedback
Signed-off-by: Drew Robbins <drew@drewby.com>
2023-01-24 10:59:46 +09:00
Drew Robbins dd3eae1bd5 Add tracing headers to HTTP request
Signed-off-by: Drew Robbins <drew@drewby.com>
2023-01-24 10:59:46 +09:00
ItalyPaleAle 6632c12dea Fixed tests
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-23 17:02:02 -08:00
ItalyPaleAle 8965515993 Ensure component works with MSI and certificates
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-23 16:58:50 -08:00
ItalyPaleAle ce12c255da ⚙️🧹 & 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-24 00:23:50 +00:00
ItalyPaleAle c38575561a Updates and fixes to Event Grid binding
1. Updated management SDK to "track 2"
2. If the Event Grid endpoint needs to be updated, do not override the previously-set properties
3. Be more tolerant with "subscriberEndpoint" if path is missing

Fixes #2454

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-24 00:20:29 +00:00
ItalyPaleAle caf0c1ad05 Fixes to cert tests
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-23 19:22:24 +00:00
ItalyPaleAle 232c8d813f Working on binding
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-21 19:28:00 +00:00
Alessandro (Ale) Segala fe8479f2d9
bindings.localstorage fixes (#2449)
* bindings.localstorage: enforcements on rootPath

Also includes ability to disallow certain root paths such as /var/run/secrets

Fixes #2444

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

* Fixed tests on Windows

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

* Fixed tests on Windows pt 2

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

* 💄

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

* Fixes #2374

- Close file descriptor after reading a file
- Report a more specific error if the file doesn't exist

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

* Updated cert tests

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

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-18 15:27:22 -08:00
ItalyPaleAle 2afca71c2a Renamed mqtt components to mqtt3
Fixes #2359

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-13 09:51:30 -08:00
ItalyPaleAle 9eaccaf01f Merge branch 'master' of https://github.com/dapr/components-contrib into s3-fix
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-12 15:16:47 -08:00
Pravin Pushkar 1ef514df3f
HTTP binding: add TLS config options for client cert verification (#2399)
* adding client cert for client verification

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

* logic for getting certs is provided as pem encoded strings

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

* adding test for https endpoint

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

* tls min version

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

* adding tests

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

* added more tests and some test refactoring

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

* modify err check for file not exist

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

* review comments

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>

Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
2023-01-10 21:18:48 -08:00
ItalyPaleAle 2634e85e81 Merge branch 'master' of https://github.com/dapr/components-contrib into s3-fix 2023-01-10 14:47:10 -08:00
ItalyPaleAle cd800cdbff Last few fixes
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-10 18:35:29 +00:00
ItalyPaleAle 47e8e41492 Using metadata.DecodeMetadata + other fixes
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-10 18:28:35 +00:00
ItalyPaleAle 80dbd4f878 Misc improvements and fixes to S3 binding
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-10 18:14:01 +00:00
ItalyPaleAle 32f14568ec Moved Unquote to utils package
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-10 17:52:38 +00:00
ItalyPaleAle 3aefab1125 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-10 17:19:16 +00:00
ItalyPaleAle c33be7f858 bindings.twilio.sms: Properly handle JSON-formatted req.Data
Fixes #2422

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-10 17:16:28 +00:00
Joni Collinge 382f84f30c
Add support for Azure Service Bus sessions for topics (#2346)
* WIP: ASB sessions

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* WIP: Support ASB sessions

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add metadata

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add sessionIdleTimeoutInSec md

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Support blank session IDs

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* If require sessions and no session id, set blank

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* move session config to per subscription metadata

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* add some unit tests

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove auto blank session id

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* go mod tidy

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* add basic cert test

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* update comment

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* remove dead code

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Update certification test

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add comment

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Add cert test for roundrobin

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* go mod tidy

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Update readme

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Use struct for NewSubscription to simplify parameters

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Address feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Address feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Only async receive

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* isTruthy on map without check

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Use if not select for context check

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* Feedback

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

* lint

Signed-off-by: Joni Collinge <jonathancollinge@live.com>

Signed-off-by: Joni Collinge <jonathancollinge@live.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
2023-01-06 09:59:26 -08:00
Alessandro (Ale) Segala ec5791492e
Merge branch 'master' into cfqueues-binding 2022-12-20 14:49:46 -08:00
ItalyPaleAle 135d460b05 Configurable timeouts
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-19 17:46:54 +00:00
ItalyPaleAle 6aa9ccc364 Binding -> CFBinding
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-19 17:39:30 +00:00
ItalyPaleAle 416aa46157 Added provisional links to docs
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-19 17:37:14 +00:00
seachen 5dda098868 feature: add context to lock&pubsub API
Signed-off-by: seachen <seachen@tencent.com>
2022-12-19 09:11:53 +08:00
Bernd Verst adc7bd8ca5
Merge branch 'master' into cfqueues-binding
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-12-16 14:46:03 -08:00
Bernd Verst 3e08736911
Add support for Redis 7 in all Dapr Components (#2228)
* Add support for Redis 7

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Add Redis 7 to conformance tests

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* automatically detect redis version, make redis7 state conformant

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Additions for REDIS without JSON support

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Return helpful query API error when missing redis-json

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Change Redis 7 port for conformance test

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Fix nil reference

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

* Update Redis7 port

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Enable ContextTimeoutEnabled for Redis v9 client

Co-Authored-By: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>

* Add timeouts, address code review

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Add another timeout

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Redis: so much more context

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* modtidy

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* fix issue from latest merge

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* modtidy

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Add generic redis nil error

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* fix redis version check

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* upgrade redis v9 client

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Remove flaky redis v7 pubsub conformance test

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* modtidy

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-16 14:12:11 -08:00
ItalyPaleAle e8353379e1 Merge branch 'master' of https://github.com/dapr/components-contrib into cfqueues-binding 2022-12-15 10:01:54 -08:00
seachen 1ea2cff9fd feature: add context to lock&pubsub API
Signed-off-by: seachen <seachen@tencent.com>
2022-12-15 09:53:32 +08:00
Bernd Verst 64a2c3aad1 Revert "revert amqp changes, eventhubs library update"
This reverts commit b236279d81.
2022-12-14 16:19:06 -08:00
Bernd Verst b236279d81 revert amqp changes, eventhubs library update
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-12-14 15:05:56 -08:00
seachen e59dfd63c0 feature: add context to lock&pubsub API
Signed-off-by: seachen <seachen@tencent.com>
2022-12-14 19:37:24 +08:00
Bernd Verst 0d7a7e73db pin latest dapr
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-12-13 17:10:10 -08:00
Bernd Verst fce17f592e Update SDKs again
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-12-13 12:27:40 -08:00
ItalyPaleAle 308f3c987c 💄
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-13 10:02:42 -08:00
ItalyPaleAle 47db769066 Add Cloudflare KV state store
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-13 01:52:06 +00:00
ItalyPaleAle d4b0980cec Refactored to use a shared package
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-13 00:32:55 +00:00
ItalyPaleAle adc70a0143 Automatically deploy and update workers
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-12 22:53:35 +00:00
ItalyPaleAle 456caaef6a WIP
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-12 20:06:04 +00:00
ItalyPaleAle 385d0480a7 Added authorization
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-10 02:31:41 +00:00
ItalyPaleAle 20285ba6f9 WIP: Added Cloudflare Queues binding
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-12-10 00:49:45 +00:00
Sarthak Sharma a4b27ae49b
fix flaky tests (#2338) 2022-12-03 13:59:42 -08:00
Sarthak Sharma 0e0cf8fe58
Add certification tests for Cron Binding (#2191)
* fix typos

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add basic tests

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update tests

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add Readme

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update mod file

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add entry in workflow

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add conformance test

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add conformance tests to workflow

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use watcher to assert

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update readme

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix linting

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* Apply suggestions from code review

Co-authored-by: Shubham Sharma <shubhash@microsoft.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* change to dapr/go-sdk from hunter007/dapr-go-sdk

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix cron delete operation

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add check if cron not triggered after delete

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* update README

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* parameterise application and assertions

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use mock clock for cron

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* change cron to input only binding

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add forked cron library to internal/cron

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use cron internal fork for binding

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* resolve comments

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* resolve comments

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add test matrix to test various schedules

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* add cron init unit tests

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* resolve comments

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix linting

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* fix linting

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* go modtidy all

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* go modtidy

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* move cron fork to dapr/kit

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

* use pinned v0.0.3 for dapr/kit

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>

Signed-off-by: Sarthak Sharma <sartsharma@microsoft.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Shubham Sharma <shubhash@microsoft.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2022-12-02 02:30:01 -08:00
John Ewart aef7ec77dc Fix naming to make ci-linter happy
Signed-off-by: John Ewart <john@johnewart.net>
2022-11-29 14:56:06 -08:00
John Ewart 49bdf702e9 gofumpt'd
Signed-off-by: John Ewart <john@johnewart.net>
2022-11-29 13:51:56 -08:00
John Ewart 4227cf7716 Update tests to be a little more isolated
Signed-off-by: John Ewart <john@johnewart.net>
2022-11-29 13:41:45 -08:00
John Ewart 9e9d7086e1 Allow HTTP binding to not error on non-200 responses
Signed-off-by: John Ewart <john@johnewart.net>
2022-11-29 13:41:36 -08:00
Bernd Verst 385c6b79b6 remove unnecessary reader close()
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-28 15:51:03 -08:00
Bernd Verst 23d36a08d7 more refactoring and address code review
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-18 17:56:02 -08:00
Bernd Verst 8811d5e64f AzBlob components: Extract shared code
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-17 21:37:17 -08:00
Bernd Verst 70eb9f3a9c Address code review comments
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-17 20:35:05 -08:00
Bernd Verst c3027b8fb1 some small improvements
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-17 19:54:32 -08:00
Bernd Verst 51e0aa992c Azure Blobstorage Binding: Migrate to Track2 Azure SDK
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-17 19:54:32 -08:00
ItalyPaleAle 1e728597b4 Misc refactorings
- Removed `state.DeleteWithOptions` and `state.SetWithOptions` which were useless at this point (likely a leftover from when there were retries)
- Some improvements in etag handling in postgres
- Other minor refactorings

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-11-17 16:29:29 +00:00
Bernd Verst 1b645097df
Merge branch 'master' into asbq-visibilitytimeout 2022-11-15 17:04:21 -08:00
Bernd Verst 14d89afeef Add user agent back to Cosmos DB Binding
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-15 14:59:04 -08:00
Bernd Verst 507fbc5c8b Merge branch 'master' into asbq-visibilitytimeout
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-15 12:57:34 -08:00
Bernd Verst d916808824 address linter issue
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-14 18:14:19 -08:00
Bernd Verst 5c9a5792be ASQ Binding: Make visibilityTimeout configurable
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-14 11:48:20 -08:00
Lior Nabat 1024190fcc update for gofumpt
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 23:41:09 +02:00
KubeMQ adb840bb84
Merge branch 'dapr:master' into master 2022-11-11 23:34:39 +02:00
Bernd Verst 462e2faadc Upgrade linter and fix linter issues
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-11 13:19:57 -08:00
Lior Nabat 12ad3b9bde update new line for linter
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 22:47:34 +02:00
Lior Nabat ac46b110c8 re-Arrange for lint
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 22:06:08 +02:00
Lior Nabat f928b2235e Remove Content-Type
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 21:47:55 +02:00
Lior Nabat a47d8f87dd Adding KubeMQ Binding - Queue
Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
2022-11-11 16:03:25 +02:00
Bernd Verst c8aa090e56
Merge branch 'master' into storagequeuesencode 2022-11-09 15:58:49 -08:00
wxbty e69ae3751d
feat:add redis binder invoke of del&get (#2197)
Signed-off-by: x-shadow-man <1494445739@qq.com>

Signed-off-by: x-shadow-man <1494445739@qq.com>
Co-authored-by: x-shadow-man <1494445739@qq.com>
2022-11-09 14:42:49 -08:00
Bernd Verst 73ec4e3cfc Storage Queues Binding: Add b64encoding option for messages
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-08 21:35:56 -08:00
Alessandro (Ale) Segala ca3e80b76b
Updated depguard linter config (#2245)
* Updated depguard linter config

1. Add older (pre-v4) versions of `github.com/cenkalti/backoff` to the denylist
2. Add `github.com/agrea/ptr` to the denylist (use `github.com/dapr/kit/ptr` instead)
3. Fixed error messages for denied deps

Port of dapr/dapr#5438

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

* ⚙️🧹

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

* Remove some github.com/pkg/errors

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

* make modtidy-all after rebase

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2022-11-03 22:19:21 -07:00
Bernd Verst 27365fbb35 Update many libraries again
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-11-01 16:00:27 -07:00
Alessandro (Ale) Segala cc856d4e13
Fix Azure Service Bus cert/conf tests (#2218)
* Correct location for certification test

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

* Removed log file added by mistake

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

* Fixed parsing metadata for ASB Queue binding

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

* Fixed replace path

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

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-24 15:05:36 -07:00
Alessandro (Ale) Segala 04242ce38a
New PubSub component: Azure Service Bus Queues (#2211)
* Implementation for Azure Service Bus Queue pubsub component

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

* Fixed syntax errors in unused files

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

* Moved components to subfolders and enabled conf tests

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

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-10-24 14:07:23 -07:00
ItalyPaleAle 254a2141ad Moved sender handling to common implementation too
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-19 21:01:15 +00:00
ItalyPaleAle 065ef86ee5 Moved client creation to common implementation
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-19 20:34:10 +00:00
ItalyPaleAle 7ecfb6edd0 Moved code to add metadata to ASB messages to shared impl too
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-19 20:08:07 +00:00
ItalyPaleAle 8bce0d5200 Moved metadata to impl package
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-19 19:47:26 +00:00
Bernd Verst 0f0aaf4e9b Merge remote-tracking branch 'upstream/master' into merge19intomaster 2022-10-14 12:16:57 -07:00
ItalyPaleAle 4de7a2fc9d The people demand defers
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-12 18:46:38 +00:00
ItalyPaleAle 047f3948c5 Fix for handling "context deadline exceeded" on ASB publishing
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-12 18:18:33 +00:00
Bernd Verst e7367a4bbe update commercetools to v1.1.0
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-10-11 14:55:15 -07:00
Bernd Verst 83a562d71a update lots of dependencies
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-10-11 14:01:38 -07:00
Bernd Verst b9654bd979 upgrade to v5 of jackc/pgx
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-10-10 15:08:07 -07:00
Bernd Verst f137bc7373 rabbitmq: use ctx for publishing
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-10-10 14:37:21 -07:00
ItalyPaleAle 132acafe54 Remove ipfs binding which is not part of the runtime
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-10-07 22:24:57 +00:00
deepanshuagarwal 38c58ac87b
Merge branch 'master' into feature/pubsub-batching 2022-09-29 13:16:43 +05:30
Yaron Schneider b4d68ed28a
Add AWS S3 standalone presign operation (#2138)
* add aws s3 standalone presign operation

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

* linter

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

Signed-off-by: yaron2 <schneider.yaron@live.com>
2022-09-28 16:01:30 -07:00
Mukundan Sundararajan eab68d1a7e
Merge branch 'master' into feature/pubsub-batching 2022-09-28 09:14:03 +05:30
Alessandro (Ale) Segala f15a50581d
Component metadata schema and tools (#2077)
* Component metadata schema and tools

Includes tools to generate and validate components' schema, and a CI check to ensure the schema is always up-to-date.

Also, includes schemas for 4 components as a starter

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

* Changed version as requested

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

* fix workflow

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-27 10:44:54 -07:00
Mukundan Sundararajan 803c0591c2
Merge branch 'master' into feature/pubsub-batching 2022-09-25 12:35:33 +05:30
Yaron Schneider 47d5b90e44
Add presigning to aws s3 binding (#2121)
* add presigning to aws s3 binding

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

* fix error shadowing

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

* typo and error consistency

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

Signed-off-by: yaron2 <schneider.yaron@live.com>
2022-09-23 15:35:15 -07:00
Shubham Sharma 4f406a597f
Add bulk subscribe support to Azure Service Bus (#2100)
* Initial implementation

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* 

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Add comment

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor messages.go and add tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update message tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor servicebus.go logic

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor handleAsync

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Refactor ReceiveAndBlock

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update binding

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update metadata name

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update activeMessagesChan logic for concurrency control

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix tests

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Update metadata name

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Use request metadata instead of component metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Review comments addressed

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix merge issue with metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Remove unused metadata key

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Fix merge issue with metadata

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

* Lint!!!

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>

Signed-off-by: Shubham Sharma <shubhash@microsoft.com>
2022-09-23 10:49:06 -07:00
deepanshuagarwal 8500da577c
Conf test for Bulk Subscribe and Kafka fixes (#2113)
* Conf test for Bulk Sub and Kafka Fixes

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Fix linting

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

* Incorporating comments

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>

Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
2022-09-23 09:54:21 -07:00
ItalyPaleAle 1a6e11fc63 Do not allow Unicode letters in sanitized metadata
Follow-up from #2112

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2022-09-22 16:46:14 +00:00
Bernd Verst 0b8b663e3e add warning message for changing metadata key
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-21 23:05:22 -07:00
Bernd Verst abb3ce3030
Merge branch 'master' into creatblobmetadata 2022-09-21 22:53:30 -07:00
Bernd Verst ddf16a11b2 add test case
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-21 22:34:28 -07:00
Bernd Verst 6e4f8e9ca9 sanitize creatBlob request metadata in AzStorageBlob
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-21 18:39:14 -07:00
Bernd Verst 0510b094bf Use latest Azure SDK for Go minor / patch SDK versions
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-21 14:54:24 -07:00
Crypt Keeper b379f80b75
middleware: changes wasm basic to use waPC (#1833)
Updates wasm basic middleware and simplifies some code inside of it,
notably by using [waPC](https://github.com/wapc/wapc-go).

This changes the entrypoint function to be named "rewrite" and
uses a pool because known memory allocators are not goroutine
safe.

Signed-off-by: Adrian Cole <adrian@tetrate.io>

Signed-off-by: Adrian Cole <adrian@tetrate.io>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2022-09-13 17:12:59 -07:00
Bernd Verst ed31cfa815 revert zeebe duration type
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-12 18:57:13 -07:00
Bernd Verst 1d0ad9c6d8 Use standardized metadata parser
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-12 18:50:05 -07:00
Bernd Verst 393f24280b Fix Zeebe metadata duration issue
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-12 16:42:36 -07:00
Bernd Verst 385bb9fe82
Azure Service Bus Queues Binding: disable entity management option (#2022) 2022-08-26 23:49:39 -07:00
Alessandro (Ale) Segala bcea284c7b
Components' init functions should return interfaces (#1997)
* Components' init functions should return interfaces

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

* 💄

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

* pin latest berndverst contrib fork

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Fixed component registration in tests

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

* Updated all cert tests

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

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-08-25 18:27:45 -07:00
Marcos Candeia 8964d8bf41
Define common metadata across components (#1994)
* Add base metadata for all components

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>

* Fix lint issues on consul and mysql tests

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>

* Pin candeia/dapr runtime version

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>

* Add replace directive to use mcandeia/dapr on all go submodules

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>

* Fixed runtime config instantiation

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>

Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
2022-08-25 10:10:53 -07:00
Bernd Verst e87cd5e4cb
Go 1.19 support and linter fixes (#1975)
* Go 1.19 support and linter fixes

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Update workflows for Go1.19 and new linter version

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Remove unnecessary space in nolint directive

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* disable additional linters which aren't used because of Go generics

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* enable gosec linter again

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Update bindings/zeebe/command/publish_message_test.go

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Update bindings/output_binding.go

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Use prepared statement for mysql table creation

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Ping is not ping

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* c'mon linter

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* Fix MySQL gosec issue

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

* revert mysql to be fixed later

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>

Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-08-18 00:45:23 -07:00
halspang 4bc800f612
Allow metadata to flow through service bus queue (#1911)
* Allow metadata to flow through service bus queue

This commit lets metadata bind to a message and be read when
the message is received. This allows for the distributed tracing
of events.

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

* Remove saved fields from ApplicationProperties

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

* Add a certification test for metadata

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

Signed-off-by: Hal Spang <halspang@microsoft.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-08-15 17:31:14 -07:00
yellow chicks 0ffa1f3119
fix: bindings.ipfs unit test (#1961)
Signed-off-by: 1046102779 <seachen@tencent.com>

Signed-off-by: 1046102779 <seachen@tencent.com>
2022-08-11 16:13:18 -07:00