Commit Graph

507 Commits

Author SHA1 Message Date
Alessandro (Ale) Segala 760948a533
Local storage binding: disable access to other system folders for security reasons (#2947)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-07-12 13:50:03 -07:00
Crypt Keeper 651834e9de
wasm: implements strictSandbox for output binding and HTTP middleware (#2884)
Signed-off-by: Adrian Cole <adrian@tetrate.io>
2023-07-11 14:37:19 +00:00
Alessandro (Ale) Segala cef854fab6
Some linting in metadata.yaml files (#2977)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-07-11 01:53:58 +00:00
Phillip LeBlanc 6d6cb2af0a
Update Cloudflare Queues docs link (#2974)
Signed-off-by: Phillip LeBlanc <phillip@leblanc.tech>
2023-07-09 23:16:57 -07:00
ItalyPaleAle ea5954f66a Merge branch 'release-1.11' of https://github.com/dapr/components-contrib
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-06-20 17:57:40 -07:00
Bernd Verst 457f4e43be
Ensure ASBQ custom attributes are urlencoded on delivery (#2923)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-06-20 15:04:12 -07:00
ItalyPaleAle ce926db071 Merge branch 'release-1.11' 2023-06-12 12:07:56 -07:00
Robert Oh d9c9fa819d
[RabbitMQ] use metadata from request as header of the published message (#2895)
Signed-off-by: Ohlicher Robert <r.ohlicher@palfinger.com>
Co-authored-by: Ohlicher Robert <r.ohlicher@palfinger.com>
2023-06-07 21:20:38 +00:00
Bernd Verst 78eea16ea8 fix metadata.yaml: rename binding to azure.servicebus.queues
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-31 18:18:18 -07:00
Alessandro (Ale) Segala 899f4407dd
[Metadata] Clarify that MySQL components work with MariaDB too (#2866) 2023-05-26 15:19:40 -07:00
Bernd Verst ac20c0a703 Merge remote-tracking branch 'upstream/master' into merge-release-1.11-rc4-into-master 2023-05-17 18:27:42 -07:00
Alessandro (Ale) Segala e30d140479
Remove native/transactional BulkSet/BulkDelete from state stores (#2834)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-05-17 14:56:34 -07:00
Yann Nicolas b9e11ecf77
Add dynamic template support to Twilio Sendgrid binding (#2844)
Signed-off-by: Yann Nicolas <yannart@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
2023-05-17 15:04:24 +00:00
Bernd Verst 58dbcf92ad
Makes Redis7 (v9 client) match the Redis6 (v8 client) behavior (#2833)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-05-11 14:43:56 -07:00
Andre Bossard 9f4086fbb0
RabbitMQ Bindings: Support for mTLS and external authentication with SASL (#2656)
Signed-off-by: Andre Bossard <anbossar@microsoft.com>
Signed-off-by: Andre Bossard <abossard@users.noreply.github.com>
Co-authored-by: Andre Bossard <anbossar@microsoft.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-05-03 22:07:50 +00:00
Crypt Keeper d22c4bc7f0
Changes wasm middleware and output binding config to url instead of path (#2817)
Signed-off-by: Adrian Cole <adrian@tetrate.io>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
2023-05-02 00:48:01 +00:00
mdarii e46130ad74
Tls renegotiation (#2822)
Signed-off-by: mdarii <dariimaxim@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-05-01 11:39:18 -07:00
Roberto Rojas 33934396a2
AWS S3 Bindings Certification Tests (#2536)
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2023-04-27 22:17:01 +00:00
Tiago Alves Macambira 5128594307
Add component metadata YAML for bindings.redis. (#2796)
Signed-off-by: Tiago Alves Macambira <tmacam@burocrata.org>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-24 21:59:05 +00:00
Tiago Alves Macambira 6e38a579fc
Add component metadata YAML for Azure Event Grid input/output binding. (#2783)
Signed-off-by: Tiago Alves Macambira <tmacam@burocrata.org>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-24 09:58:37 -07:00
Yash Nisar 1df2980aee
Add component metadata YAML for Postgres binding (#2802)
Signed-off-by: Yash Nisar <yashnisar@microsoft.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-24 09:53:57 -07:00
Bernd Verst a7ac906757
Fix Redis metadata parsing and reporting (#2803)
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Tiago Alves Macambira <tmacam@burocrata.org>
2023-04-23 06:28:22 +00:00
Tiago Alves Macambira 585597e95e
Add component metadata YAML for Azure Event Hubs input and output binding (#2784)
Signed-off-by: Tiago Alves Macambira <tmacam@burocrata.org>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
2023-04-19 21:35:14 +00:00
Pravin Pushkar 3030834160
Refactor http binding to support https (#2766)
Signed-off-by: Pravin Pushkar <ppushkar@microsoft.com>
2023-04-19 18:23:45 +00:00
MregXN 289c784a6a
Create Azure Component template for bindings.mysql (#2787)
Signed-off-by: MregXN <mregxn@gmail.com>
2023-04-19 15:32:39 +00:00
Tiago Alves Macambira 0221ad7edf
Add component metadata YAML for Azure Cosmos DB (Gremlin API) output binding (#2785)
Signed-off-by: Tiago Alves Macambira <tmacam@burocrata.org>
2023-04-16 20:04:00 -07:00
Alessandro (Ale) Segala e59e03eb32
Azure Storage Queues: Make polling interval configurable (#2781)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-04-14 23:08:18 +00:00
Tiago Alves Macambira c6546ffe7d
Add component metadata YAML for Azure CosmosDB output binding. (#2782)
Signed-off-by: Tiago Alves Macambira <tmacam@burocrata.org>
2023-04-14 15:09:12 -07:00
addjuarez cab5707308
Add azure blob binding and app config yaml (#2771)
Signed-off-by: addjuarez <6789375+addjuarez@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-12 21:28:36 -07:00
Alessandro (Ale) Segala ae28aec903
Metadata YAML for Azure Storage Queues binding (#2775)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-12 21:10:02 -07:00
Alessandro (Ale) Segala 26dea0c1c2
Add metadata for bindings.azure.signalr (#2772)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-04-12 14:25:03 -07:00
Alessandro (Ale) Segala 5dad8a867c
Metadata parser: add support for built-in authentication profiles and metadata properties (#2760)
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-12 00:04:34 +00:00
MregXN 8a4d7b8542
Create component metadata for bindings.zeebe.command (#2752)
Signed-off-by: MregXN <mregxn@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-11 21:13:07 +00:00
MregXN 3f7e5890ca
Create component metadata for bindings.zeebe.jobworker (#2763)
Signed-off-by: MregXN <mregxn@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-04-11 21:02:30 +00:00
Bernd Verst 2b89d78a2d
Refactor Metadata Parsing of all PubSub Components (#2759)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-04-09 18:21:56 +00:00
Bernd Verst cfbac4d794
Refactor of Metadata parsing in Bindings (#2720)
Signed-off-by: Bernd Verst <github@bernd.dev>
Signed-off-by: Shivam Kumar <shivamkm07@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>
Signed-off-by: Alessandro (Ale) Segala <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Roberto Rojas <robertojrojas@gmail.com>
Signed-off-by: spike <hello@spike.wiki>
Signed-off-by: zhangchao <zchao9100@gmail.com>
Signed-off-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Signed-off-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Signed-off-by: handlerww <handlerww@gmail.com>
Co-authored-by: Shivam Kumar <shivamkm07@gmail.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Roberto Rojas <robertojrojas@gmail.com>
Co-authored-by: spike <39330606+SpikeWong@users.noreply.github.com>
Co-authored-by: Mukundan Sundararajan <65565396+mukundansundar@users.noreply.github.com>
Co-authored-by: Taction <zchao9100@gmail.com>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Yiwen Chen <handlerww@gmail.com>
2023-04-05 22:19:08 +00:00
cciobanu98 2681d97673
Remove required checks from SES metadata (#2699)
Signed-off-by: Ciobanu Cristian <cristian.ciobanu1998@outlook.com>
Co-authored-by: Ciobanu Cristian <cristian.ciobanu1998@outlook.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-03-27 21:59:43 +00:00
Crypt Keeper 3dc2691635
deps: updates wazero to 1.0.0 (#2709)
Signed-off-by: Adrian Cole <adrian@tetrate.io>
2023-03-25 17:10:07 +00:00
Taction d9e1cc4e86
Support reconnection between sidecar and broker for RabbitMQ bindings (#2565)
Signed-off-by: zhangchao <zchao9100@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Taction <zchao9100@gmail.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Josh van Leeuwen <me@joshvanl.dev>
2023-03-23 17:21:45 +00:00
chad e7c51333f8
graphql binding variable support (#2701)
Signed-off-by: chad <41795094+serpentfabric@users.noreply.github.com>
Signed-off-by: Jiri Kopecky <jiri.kopecky@resideo.com>
Co-authored-by: Jiri Kopecky <jiri.kopecky@resideo.com>
2023-03-23 17:18:53 +00:00
Crypt Keeper b1558f8c0d
wasm: close module on invoke (#2697)
Signed-off-by: Adrian Cole <adrian@tetrate.io>
2023-03-23 16:04:04 +00:00
Crypt Keeper 9b669c03d8
Add output binding wasm (#2685)
Signed-off-by: Adrian Cole <adrian@tetrate.io>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Signed-off-by: Crypt Keeper <64215+codefromthecrypt@users.noreply.github.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-03-22 22:59:44 +00:00
MregXN ff532364de
Create component metadata for bindings.cron (#2684)
Signed-off-by: MregXN <46479059+MregXN@users.noreply.github.com>
2023-03-20 07:53:56 -07:00
halst 42583085ce
Add kitex output binding (#2563)
Signed-off-by: liusong <liusongstep@gmail.com>
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
Co-authored-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-03-16 16:59:03 +00:00
Vishal Kumar 9e30be0192
Adding GetDel support for Redis Bindings (#2662)
Signed-off-by: Vishal Kumar <vkgkrt@gmail.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Yaron Schneider <schneider.yaron@live.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-03-14 17:57:16 +00:00
Bernd Verst 6feae775e6
Support Increment Operation, TTL in Redis Binding (#2654)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-03-09 21:23:04 +00:00
Josh van Leeuwen 4be795d812
Remove `context.TODO()`s with passed context. (#2650)
Signed-off-by: joshvanl <me@joshvanl.dev>
2023-03-08 17:53:02 +00:00
Bernd Verst 907b6b9ebe
TEST COMMIT for Merge Queue. No-op (#2614)
Signed-off-by: Bernd Verst <github@bernd.dev>
2023-03-02 00:00:33 +00:00
ItalyPaleAle 8cc74c7331 Completed the removal of the Azure SDK track 1
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-27 22:37:23 +00:00
ItalyPaleAle 2916e53a72 WIP
Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
2023-02-27 21:28:08 +00:00
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