Commit Graph

507 Commits

Author SHA1 Message Date
Long Dai 189d2d6717
bindings: support rabbitmq send any content types (#1147)
Signed-off-by: Long <long0dai@foxmail.com>
2021-09-17 10:21:41 -07:00
Phil Kedy 45f577e137
Bumping ASB version and fixing test for azure auth (MSI_ENDPOINT) (#1132)
Co-authored-by: Bernd Verst <berndverst@users.noreply.github.com>

Co-authored-by: Bernd Verst <berndverst@users.noreply.github.com>
2021-09-13 11:06:04 -07:00
Javier Vela 418fc726f5
Update S3 binding (#1081)
* S3 update create operation: support upload files in base64, return location and versionId on create operation

* S3 add get operation

* S3 add delete operation

* S3 add list operation

* S3 fix lint errors

* S3 add close method

* S3 add option to encoode data respose in base64

* S3 fix test get option

* S3 fix metadata test delete option

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-09-07 11:03:22 -07:00
Phil Kedy a0542ec922
Adding `initialOffset` option to Kafka binding and pubsub components (#1120)
* Adding `initialOffset` option to Kafka binding and pubsub components

* Only allow oldest and newest

* Fix tests

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-09-02 18:02:10 -07:00
Simon Leet 710fd9767f
Add Close() method to influx bindings (#1114)
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-09-02 10:09:26 -07:00
Simon Leet 6400db8717
Add Close() to GCPStorage binding (#1111)
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-09-02 09:51:50 -07:00
Alessandro (Ale) Segala a992cd19f0
Support Azure AD auth for Cosmos DB (#1104)
* Support Azure AD auth for Cosmos DB

* Fixed linting errors

* Tidying go.sum

* Removed the need for nolint:shadow

Co-authored-by: Simon Leet <31784195+CodeMonkeyLeet@users.noreply.github.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2021-09-01 12:44:05 -07:00
Simon Leet 5e05c8d4ef
Add Close() to GCPPubSub binding (#1110)
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2021-09-01 12:24:20 -07:00
Simon Leet 6591b0de68
Add Close() method to EventHubs bindings (#1093)
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2021-08-26 15:56:15 -07:00
jerrylisl d62eee779d
add Close() function to Postgres binding (#1087)
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2021-08-17 15:29:23 -07:00
Javier Vela a3ad87f04e
smtp allow use smtp server without auth (#1083) 2021-08-17 15:17:23 -07:00
Simon Leet 796df4dd61
Add Close() function to Azure ServiceBusQueues binding (#1052)
* Add Close() conformance test

* Add Close() to AzureServiceBusQueues binding

* Accept nil on bindings Read Close() test

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2021-08-13 18:15:39 -07:00
Javier Vela 405ba37eb8
added binding AWS SES (#1021)
* added binding AWS SES

* binding AWS SES: removed unused code

* binding AWS SES: fix lint

* binding AWS SES: fix parse session token

* binding AWS SES: support multiple email && fix cc / bcc parse error

* binding AWS S3: add TODO configuration set

* binding AWS SES: handle error on unquote req.Data

* binding AWS SES: fix lint errors

* binding AWS SES: reuse SES instance

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-08-13 17:24:00 -07:00
Artur Souza 1042314c63
Add binding alicloud.tablestore (#1076)
* add binding alicoloud.tablestore

* Fix lint.

Co-authored-by: theonefx <chenxilzx1@gmail.com>
2021-08-13 10:03:14 -07:00
Javier Vela 203da8b2ca
biinding smtp: fix multiple recipients (#1074) 2021-08-12 13:13:30 -07:00
Javier Vela 71c5b2088c
Add priority option in SMTP binding. It will allow select email priority (#1018)
* binding smtp add priority option

* binding SMTP add priority: fix lint

* binding SMTP add priority: added a priority metadata support

* binding SMTP add priority: lowest and hight priority as const

* binding SMTP add priority: handle error on unquote req.Data

* binding SMTP add priority: lowest and hight priority as const (msg error)

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-08-04 10:39:20 -07:00
Maarten Mulders 0968aca6d4
Improve error message in case of missing property (#1012)
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-07-18 18:44:38 -07:00
Christian Kaps 80f0110fa8
Return blob metadata and add list operation (#999)
* Return blob metadata if configured

* Enhance error msg

* Add list functionality

* Fix linting issues

* Finalize list implementation

* Fix linting errors

* Add backward compatibility and align code to be more consistent

* Add tests

* Fix linting errors

* Rename properties

* Fix max result logic

* Fix linting error

* Fix PR suggestions

* Add comments for constants

* Run go mod tidy

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-07-14 09:17:48 -07:00
Hossam Kandil 13f96c42a6
Added new output binding for Cosmos Graph DB - Gremlin (#885)
* Added new output binding for Cosmos Graph DB - Gremlin

* applying gofumpt on cosmosdbgraphdb

* removed unnecessary conversion from cosmosgraphdb

* removed unwanted comments from cosmosgraphdb

* resolving gomod confilicts

* resolving go mod conflict

* resolve conflicting error messages

* change Gremlin query to req.data.

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-07-14 08:49:40 -07:00
Taction abac56b082
Delete unused code and update test (#924)
Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-07-13 18:41:21 -07:00
Simon Leet 3877f5c793
Return SystemProperties on events from EventHubs bindings and pubsub (#1009)
- Update azure-event-hubs-go dependency to currently supported v3 with
  IoT Hub SystemProperties.
- Write Event.SystemProperties to ReadResponse.Metadata for EventHubs
  input binding.
- Write Event.SystemProperties to NewMessage.Metadata for EventHubs
  pubsub.
2021-07-13 16:04:22 -07:00
Christian Kaps cb9a510d16
Implement E2E tests for zeebe (#973)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-07-12 11:40:38 -07:00
Ian Luo 0777a6a943
fix: Mysql should support more data types. #923 (#926)
* fix: Mysql should support more data types. #923

* go fmt

* fix lint issue

* revise according to the review comment

Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-07-08 10:57:18 -07:00
Long Dai a538b80452
switch to golang-jwt (#993)
Signed-off-by: Long Dai <long0dai@foxmail.com>

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-07-08 10:49:44 -07:00
Fabian Steinbach 4412ba019f
unmarshal getBlobRetryCount as int (#919)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-07-08 10:45:52 -07:00
Long Dai 4281cb2ea1
deps: upgrade dgrijalva/jwt-go (#981)
Signed-off-by: Long Dai <long0dai@foxmail.com>
2021-07-02 19:55:17 -07:00
amirmm11 f438298214
Add GraphQL Binding (#844)
* add Hasura Binding

* Added GraphQL binding

* add prefix header

* add prefix header

* add prefix header

* Add Phil's changes

* Added a few fixes recommended by Phil

Co-authored-by: Amir Mousavi <amir@equilibriumenergy.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-06-23 10:01:22 -07:00
Phil Kedy 8e6b36ecdf
Importing the retry and config packages from kit instead of internal (#940)
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-06-22 09:38:55 -07:00
Christian Kaps 3689020fb5
Update Zeebe to version 1.0 (#876)
* Update Zeebe to version 1.0

* Fix lint error regarding import

* Don't panic on error

* Log error as string

* Pass reason msg to process engine on fail job command

* Pass job specific variables as headers to a worker

* Fix formatting issue

Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-06-11 16:34:01 -07:00
Phil Kedy a28587ed98
Resolving gofumpt issues (#932) 2021-06-09 15:18:50 -07:00
Taction 464d53d94b
Move the common Redis code to internal (#859)
* Move pubsub redis client to internal

* Add failover for common redis. Refactor state redis.

* refactor binding redis

* fix lint

* Refactor to setting partten

* fix db and lint

* fix lint

* for backward compatibility

* Using a type alias to handle decoding duration values of -1 for Redis.

* Linter fixes

Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
2021-06-06 23:24:36 -07:00
Long Dai d499387a44
Fix Kafka binding implements Close() for cleanup (#906)
Signed-off-by: Long Dai <long0dai@foxmail.com>

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-06-04 15:47:18 -07:00
Long Dai 01ca433ad9
mqtt: implement Close (#905)
* mqtt: implement Close

Signed-off-by: Long Dai <long0dai@foxmail.com>

* feedback

Signed-off-by: Long Dai <long0dai@foxmail.com>

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-06-04 15:38:04 -07:00
Long Dai 4ee732e0bd
ci: enable gofumt linter (#887)
Signed-off-by: Long Dai <long0dai@foxmail.com>
2021-05-27 22:21:24 -07:00
cinience efd198026f
Add bindings dingtalk webhook (#817)
* Add bindings dingtalk-webhook

* Fix lint

* Fixing logger dependency

* Updated tests

* Tweaks to use the "settings pattern"

* Make webhooks global again

* Update sync.map to built-in map and RWMutex

* Fixing linter errors

Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-05-14 09:11:16 -07:00
cinience de417e429d
Add bindings rocketmq (#815)
* Add bindings rocketmq

* Fix lint

* Update parseMetadata

* Update logger import

* Tweaks to use "the settings pattern"

* Add back off policy configuration

Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-05-13 15:41:49 -07:00
cinience 5e547d7efd
Add bindings nacos (#814)
* Add bindings nacos

* Fix lint

* Fixed CR #814

* Update logger import

* Update go.sum

* Remove signal handler

* Tweaks to move metadata to the "Settings pattern"

* Fixing typo

Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-05-13 12:53:54 -07:00
Phil Kedy 1b30e75e60
Configurable retry (#854)
* no message

* Switching over usages of retry to the new package and making use of the DecodeConfig function

* Added decoding configuration using settings with a specific prefix

* Linter fixes

* Fixing linter error

* time.Sleep is the enemy

* Fix typo in comment

* Moving config to a pointer parameter so that the component can pass in the config with default values that make sense for that component.

* Renamed config struct

* Fix comment

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-05-06 09:43:57 -07:00
zhangchao 651d754496 Merge branch 'master' into upgrade_redis_client_to_v8
* master:
  add handle timeout to cancel req for it would be redelivered (#832)
  Add optional metadata param maxLen for redis stream PubSub component (#835)
  Implement bindings for the Zeebe workflow engine (#806)
  Automerge in contrib. (#849)

# Conflicts:
#	go.mod
#	go.sum
#	pubsub/redis/redis.go
2021-04-29 11:49:26 +08:00
Christian Kaps 83803f575d
Implement bindings for the Zeebe workflow engine (#806)
* Implement bindings for the Zeebe workflow engine

* Fix PR suggestion regarding error handling

* Refactor cancel_instance test to not use a mocking library

* Refactor all tests to not use a mocking library

* Use error vars

* Fix linting error regarding ineffective error assignment

* Check for mandatory jobType

* Remove double method call

* Fix suggestion regarding mock client instantiation

* Check if either bpmnProcessId or workflowKey is given for workflow instantiation

* Changed logger module to dapr/kit. Misc tweaks.

* Fix go.mod

* Fixing some lint errors

* Ignoring linter false positive

Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
2021-04-28 17:23:11 -07:00
zhangchao 69b24d0394 fix lint 2021-04-23 22:32:26 +08:00
zhangchao c55d88cd98 fix add add a ctx context variable in the Redis struct. And implemet `Close() error` function 2021-04-23 22:02:07 +08:00
zhangchao 5190fe4e7d Merge branch 'master' into upgrade_redis_client_to_v8
resolve conflict

* master:
  Increasing overall test timeout to allow for conformance tests to run (#834)
  Improve SMTP binding performance (#782)
  add redis cluter mode for pubsub (#823)
  downgrade the verbosity of lock renewal errors from warn to debug. This error is expected when messages are processed before beingrenewed (#803)
  Improve pulsar publisher performance. (#827)
  optimze(state/redis): output detail redis error (#825)
  Consul nameresolution component (#750)
  Add DNS name resolver. Add unit tests. (#743)
  Azure Service Bus: Changed log level of error on close to info (#830)
  Removed dependency on dapr/dapr in favor of dapr/kit. Fixed go mod dependencies afterwards. Go 1.16 in go.mod. Removed accidental log dependency. (#807)
  Update state/blobstorage.go to add metadata. (#786)
  Azure Service Bus publishing retries when server is "too busy" (#821)

# Conflicts:
#	bindings/redis/redis.go
#	go.mod
#	go.sum
#	pubsub/redis/redis.go
2021-04-22 09:13:01 +08:00
Edwin van Wijk c1541031fd
Improve SMTP binding performance (#782)
* Fix issues from review by @skyao

* Fix lint errors

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-04-21 11:57:26 -07:00
Phil Kedy 688df9bda4
Removed dependency on dapr/dapr in favor of dapr/kit. Fixed go mod dependencies afterwards. Go 1.16 in go.mod. Removed accidental log dependency. (#807) 2021-04-19 12:06:10 -07:00
Phil Kedy 814145dca3
Merge branch 'master' into upgrade_redis_client_to_v8 2021-04-12 19:52:16 -04:00
Phil Kedy 20164f43c1
Merge branch 'master' into patch-1 2021-04-12 19:24:47 -04:00
zhangchao 3ec4b336a9 upgrade go-redis/redis to v8, and use context in pubsub/redis to cancel redis request. 2021-04-10 23:41:58 +08:00
Phil Kedy 6803b49e56 tls -> ssl for good measure 2021-04-06 17:50:42 -04:00
Phil Kedy bc0c4fd72e Adding small coalesce on scheme to ensure backward compatibility in both the pubsub and binding mqtt components 2021-04-06 17:32:47 -04:00
Phil Kedy 810ec429a7 Adding small coalesce on scheme to ensure backward compatibility in both the pubsub and binding mqtt components 2021-04-06 17:30:33 -04:00
0to1 f01b3e0cef
Update Readme.md
Add missing closing bracket ")"
2021-03-30 18:03:19 +08:00
Phil Kedy bad759f6d8 Adding the mqtt binding to the conformance tests 2021-03-26 11:05:19 -04:00
Hugo Meyronneinc f172b9a4d6
feat: change binding mqtt options to the same as pubsub 2021-03-25 21:11:25 +01:00
Lynn Orrell c1905ba63b
Local Storage Binding Updates (#776)
* Introduced localstorage binding

* Code cleanup

* Linter cleanup

* Linter cleanup

* Now using ioutil.ReadAll() as io.ReadAll() fails to build on Windows

* Renamed metadata field

* Now returning the filename on create

* Now only generating a UUID filename for creates

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-03-24 20:56:20 -07:00
Lynn Orrell 08305017c1
Localstorage (#753)
* Introduced localstorage binding

* Code cleanup

* Linter cleanup

* Linter cleanup

* Now using ioutil.ReadAll() as io.ReadAll() fails to build on Windows

* Renamed metadata field

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Phil Kedy <phil.kedy@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-03-23 18:00:56 -07:00
Yaron Schneider 192461889c
Add app response to input binding event (#764)
* add app response to input binding event

* lint
2021-03-18 14:22:14 -07:00
Fabian Steinbach 3a3998bb60
add delete to blob storage binding (#705)
* add delete to blob storage binding

* adjust linting

* make deletesnapshotsoption configurable

* update linting

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-03-09 00:20:43 -08:00
Phil Kedy 5290fe157d
Removes github.com/satori/go.uuid in favor of google's uuid package (#704) 2021-02-18 21:11:36 -08:00
Edwin van Wijk 6baa30ee75
Add SMTP output binding (#646)
* Add smtp output binding

* Go mod tidy

* Remove obsolete func

* Refactor metadata overrides from request

* Add comment

* Fix mergeRequest func

* Add #nosec directive for SkipTLSVerify

* Add test for MergeWithRequestMetadata

* Format test code

* Change level of succesfull email logging

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-02-09 19:13:14 -08:00
Yaron Schneider 3ef025c604
change headers (#679) 2021-02-09 18:57:55 -08:00
Phil Kedy e6924c6d7b
Improving the versatility of the HTTP output binding (#661)
* no message

* Removing HTTP input binding from conformance test

* Moving // nolint: noctx

* Fixed linter issue

* Tweaks

* Tweak

* Setting request headers from metadata

* More comments and handling of non-200 response codes

* Fixing conformance test for HTTP

* Temporarily bumping up redis timeouts

Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
Co-authored-by: Charlie Stanley <charlie.stanley@microsoft.com>
2021-02-09 12:02:47 -08:00
Yaron Schneider 58e92479ac
Add kafka max message bytes and pubsub partition key (#669)
* add kafka max message bytes and pubsub partition key

* linter
2021-02-08 11:14:52 -08:00
Artur Souza ac28629cb0
Increase timeout for conf test + more logging for EventGrid. (#663) 2021-02-05 19:10:44 -08:00
Artur Souza 795b62417e
Add verbosity to conf tests. More debug logging in eventgrid binding. (#662) 2021-02-05 17:41:06 -08:00
Ian Luo 97912e75c6
mysql outbinding support (#615)
* mysql outbinding support

* fix lint issues

* use time duration string instead of number of seconds

* correct typo

* use 'addr' instead of 'server' and 'port' in order to align with url in dsn format

* simplify configuration, and allow PEM configurable

* jsonfy the query result

* add more unit test for mysql binding

* add unit test to verify timestamp

* add type verify in integration test

* add test to verify BOOLEAN

* update comment

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-01-25 18:45:26 -08:00
kzmake 66b9734bcc
Add priority parameters to RabbitMQ queue and message (#606)
* Add message priority in RabbitMQ

* Fix integration test for ExclusiveQueue

* Revert priority parameters from pubsub

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2021-01-22 14:03:53 -08:00
Bruno Rodrigues da Silva fe9faadb46
Added Exclusive Flag to RabbitMQ queues (#580)
* Added Exclusive Flag to RabbitMQ queues

* Fixing Linter issues

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2021-01-12 14:18:04 -08:00
Artur Souza e6dadfab6c
TTL in PubSub. (#565)
* TTL in PubSub.

* Handle message TTL only if component cannot handle it.

* Removig dead code for overflow check in pubsub expiration.
2020-12-29 14:28:52 -08:00
Michaël Hompus 6079c3b113
Add postmark as an output binding (#546)
* Add postmark as an output binding

* go tidy

* Update comments
2020-12-09 14:28:32 -08:00
Yaron Schneider d260ec85e6
add access level to azure blob storage (#549) 2020-12-05 07:38:13 -08:00
Trond Hindenes 8d6978372f
Various AWS improvements (#525)
* Support sessiontoken

* Fixed tests and other components

* Fixed tests and things

* fmt

* Fix lint errors

* gofmt

* Fixed lint bugs

* Remove unneeded parameter

* gofmt

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-11-23 13:21:29 -08:00
Trond Hindenes b1f1ecc18b
properly initialize logger in bindings/sqs (#531) 2020-11-23 13:13:04 -08:00
Yaron Schneider 01f90bdbc8
Fix azure blob storage json payload (#516)
* fix azure blob storage json payload

* handle non-json strings
2020-11-03 10:05:30 -08:00
Aaron Crawfis a27e486ef9
Update docs with new docs links (#513) 2020-10-26 11:52:20 -07:00
halspang f647d9eedb
Upgrade golang lint to 1.31 (#490)
Upgrade golang lint to 1.31.0

https://github.com/dapr/components-contrib/issues/439
2020-10-12 12:54:15 -07:00
Michael Collins b08e920cdd
Apns output binding (#481)
* Create Apple Push Notification Output Binding

I created the apns package and created apns.go to implement the output
binding to send push notifications to Apple devices using the Apple Push
Notification Service.

* Refactor Code

I refactored and cleaned up the source code in apns.go. I made the code
easier to read and understand. I split out the JWT generation into
authorization_builder.go. I split out the create operation code into
create_operation.go and refactored it to follow a pipeline pattern.

I created doc.go and added documentation for how to use the APNS binding
to send push notifications to Apple devices.

* Fix Lint Issuer

I corrected issues reported by golangci-lint in the pull request. I ran
gofumpt against the test cases for the APNs binding. I fixed a naming
error in create_operation.go.

* Address Review Comment

I revised extractKeyID in apns.go to address a readability concern in
the code. I simplified the if/else block to make the logic easier to
understand.

* Add License Header to APNs Binding

I added the standard Microsoft copyright and MIT license header to the
source files for the APNs binding. This was requested from the PR
review.

* Revise APNS.extractTeamID for Readability

Per a PR comment, I revised the APNS.extractTeamID function to make the
function more readable.

* Revise APNS Create Operation

I revised the APNS create operation based on discussions in the PR
(#481). I deleted create_operation.go and merged the code back into the
main APNS type to simplify the code.

* Fix Linter Errors

I fixed linter errors reported in apns.go.

* Fix Code Review Comments

I switched from using encoding/json for JSON encoding and decoding to
using jsoniter.

I updated authorization_builder.go to define the expiration period as a
constant and provided a comment describing the need for and use of the
expiration period.

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Mark Chmarny <mchmarny@users.noreply.github.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-10-09 10:26:44 -07:00
Mark Chmarny fbc3a3dd87
RethinkDB state store support (#423)
* rethinkdb state store

* added actor state change binding

* updated db record

* reconnect

* passing lint

* updated binding repsonse keys

* rethinkdb load test

* lint validated tests

* updated comments

* updates TransactionalStateRequest

* parameterized table

* correct error message

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-09-24 16:19:14 -07:00
Mark Chmarny d8035411f7
cleaner tests (#476) 2020-09-24 11:56:21 -07:00
Yaron Schneider 1e92e0e8e1
Add blob url to azure blob create (#474)
* add blob url to azure blob create

* add missing err statement
2020-09-23 17:42:46 -07:00
Mark Chmarny d2dcd8e508
Bi-directional output binding for PostgreSQL (#468)
* wip: postgres

* postgres crud binding

* CRUD postgres bidirectional output binding

* live test setup comments

* updated example conn string

* lint fixes

* test sql linting

* pr review updates

* lint fixes

* comment spelling

* metadata optional for close
2020-09-23 17:19:37 -07:00
Yaron Schneider b91469732c
Add get operation for azure blob storage binding (#473)
* add get operation for azure blob storage binding

* fix retry count

* make retry configurable, add default
2020-09-23 15:00:34 -07:00
Mohammad Taghavi e5a50cb2da
add decodeBase64 option to azure blob storage component (#393)
* add decodeBase64 option to azure blob storage component

* fix lint error

* Apply suggestions from code review

some code improvements (apply review suggestion)

Co-authored-by: Nghia Tran <tcnghia@gmail.com>

* add comment to help assure the reader (resolve review comment)

Co-authored-by: Mohammad Taghavi <Mohammad.Taghavi@plan-b-gmbh.com>
Co-authored-by: Nghia Tran <tcnghia@gmail.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-09-22 13:44:36 -07:00
AbserAri 04ce9b8299
make rabbitMQ input binding could configure the Qos of Consumer. (#457)
* update logger form nats-io's to dapr's

* run go mod tidy and go mod delete the nats-io gnatsd

* update rabbitmq prefetch feature because want to set each instance the number of messages could  hold in once until ack.

* update for parse int

* update parseMetadata of rabbitMQ to read prefetchCount by string.

* [update rabbitMQ binding parseMetadata] Make error clear

* [in rabbitMQ metadata parse] fix the bug of golint

* update rabbitMQ with a new parseMetadata way.

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-09-08 13:15:11 -07:00
Mukundan Sundararajan c6623da87e
Change Kubernetes client to official go-client in the events binding. (#436)
* Change Kubernetes client to official go-client in the events binding.

* Change adding flags to init

* go mod tidy

* Proper call for handler

* Remove commented out code

* Refactor indentation
2020-08-18 11:49:06 -07:00
Geert Baeke 467375c254
Influx binding (#401)
* influx binding

* corrected linting errors

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-08-17 12:45:58 -07:00
Young Bu Park 3efcb40430
Upgrade Go to 1.15 (#432)
* Upgrade Go to 1.15

* fix string conversion warn
2020-08-12 10:22:48 -07:00
Yaron Schneider 8f30f3a6e6
Update common operations list docs (#428) 2020-08-10 12:24:01 -07:00
Mark Chmarny b16d55f8ad
renames the cron package (#395) 2020-07-16 18:18:34 -07:00
Mark Chmarny 47a329c3ce
Adds output support to Twitter binding #366 (#385)
* twitter output binding

* output metadata format to match input

* fixes lint error

* fixed init query validation

* fixes test timeouts

* fixes lint errors

* fixes lint errors

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-07-09 17:01:30 -07:00
Mark Chmarny 111836eac8 adds Operations method implementation 2020-07-08 05:46:08 -07:00
Mark Chmarny 8b169a7d65 fixes lint errors, adds invoke test 2020-07-08 05:09:10 -07:00
Mark Chmarny d662a1829f fixes lint errors, adds invoke test 2020-07-08 04:58:09 -07:00
Mark Chmarny e98b3fc968 adds cron binding 2020-07-07 16:58:53 -07:00
Nils Schmidt 4007ba3622
Handle errors in AzureEventHubs.Read (#371) 2020-06-30 07:16:36 -07:00
Yaron Schneider d779825d38
Update Readme.md (#351) 2020-05-27 15:05:05 -07:00
Yaron Schneider e82164f4e7
Add bi-directional bindings support (#350)
* add bi-directional bindings

* added invoke response

* added explicit types

* change operationtype to operationkind
2020-05-26 23:32:20 -07:00
Trond Hindenes d3e9a7b3a7
Use shared aws auth package (#347)
* Use shared sqs auth package

* Goimports-ed files

* Added support for endpoint param in aws credentials abstraction, since the sqs-sns pubsub module required it

* Added endpoint support for all aws things

* Updated tests
2020-05-26 16:27:16 -07:00
Trond Hindenes 52e37224e5
aws sqs: Use implicit creds and region by default, explicit if specified (#340)
* Use implicit creds by default, explicit if specified

* Remove log lines

* Support implicit region as well

* gofmt-ed file

* removed a newline

* Use a separate package for aws auth stuff

* Rename + alias imports

* gofmt

* goimportsed file

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-05-22 15:59:22 -07:00
Mark Chmarny b647397b2c
Fixed termination signal, added read test (#321)
* titter search binding

* refactored signal processing for lint comp

* titter search binding

* refactored signal processing for lint comp

* fixed twitter ref

* fixed termination signal, added read test

* removed unused maxTweet property

* fixed lint issues

* lint fix

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-30 14:21:23 -07:00
Ben Coleman e97529a4a8
Unescape azure blob data (#313)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-30 08:15:18 -07:00
Mark Chmarny 0e731f96aa
Added Twitter search input binding (#318)
* titter search binding

* refactored signal processing for lint comp

* titter search binding

* refactored signal processing for lint comp

* fixed twitter ref

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-04-29 08:02:57 -07:00
Lynn Orrell 8480a29c18
EventGrid Component Updates (#319)
* event grid udpates

* Initial event grid input binding

* Added Write() support to EventGrid component

* Updated eventgrid binding to use fasthttp instead of net/http

* Fixed linting issue in EventGrid binding

* Tidy up go.mod

* Added handshakePort to allow custom port for EG callback

* Now properly throwing an http 500 on handler err

* Updated event grid sdk for cloud event 1.0 support
Added support for all event grid sources via scope
Now validating required metadata on read/write

* Updated tests

* Fixed linting issue

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2020-04-29 08:02:22 -07:00
Lynn Orrell 8827c58e78
Added Azure Event Grid Bindings (#290)
* event grid udpates

* Initial event grid input binding

* Added Write() support to EventGrid component

* Updated eventgrid binding to use fasthttp instead of net/http

* Fixed linting issue in EventGrid binding

* Tidy up go.mod

* Added handshakePort to allow custom port for EG callback

* Now properly throwing an http 500 on handler err

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Artur Souza <artursouza.ms@outlook.com>
2020-04-28 12:50:13 -07:00
Ben Coleman ebf31ef7c5
Added SendGrid output binding for sending emails (#308)
* Added first cut of SendGrid binding

* Removed some junk

* tidy up based on PR review comments
Removed duped line, and logging, normalised error messages

* Silly mistakes on emailTo and subject checks

* Moving to new twilio folder structure

* adds BCC and CC, better error handling

* microscopic comment typo

* linter was complaining

* removing my accidental docs commit

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-22 21:54:01 -07:00
Sivamuthu Kumar fd531b006f
Cosmos - Nested PartitionKey Support (#296)
* Nested partition key in cosmosdb bindings

* fix lint

* Lookup values by iterating

* fix lint

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-15 10:29:43 -07:00
Francisco Beltrao 75fcd7accf
Add message time to live in RabbitMQ, Azure Service Bus/Storage Queue bindings (#298)
* Add message ttl for Azure Service Bus/Storage Queue
and RabbitMQ

* Rename metadata key to ttlInSeconds
Move defaultQueueTTL to RabbitMQ metadata

* Move integration tests to own files

* Add +build integration_test tag

* Remove integration test skip

Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-15 10:07:16 -07:00
Yaron Schneider 4f9d6d97e3
add partitionKey to kafka binding (#303)
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-04-09 14:42:01 -07:00
Pruthvidhar R Dhodda a36e498d02
Add TLS support for bindings.redis (#302)
* Add TLS support for bindings.redis

* Remove unsused dependencies

* Fix failing tests

* Remove unused variables
2020-04-09 12:02:24 -07:00
Young Bu Park 0489fb17f3
Fix linter errors (#293) 2020-04-01 17:22:15 -07:00
Sivamuthu Kumar b14500315a
Add Kinesis data stream binding (#273)
* Add Kinesis data stream binding

* fix lint kinesis

* Add license at top of the file

Co-authored-by: Young Bu Park <youngp@microsoft.com>
2020-03-24 11:33:23 -07:00
Ricardo Niepel 934ef7a7ba
Add metadata support to Azure Blob binding (#281)
* add metadata support to AzBlobBinding

* change to tabs

* fix lint error

* improve error message

* uncap error message
2020-03-21 16:33:35 -07:00
madhugilla dc1e938e61
Alicloudoss (#278)
* Object storage implementation for AliCloud

* linting fixes

* fixed comments and ran "go mod tidy" based on the feedback

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-03-20 12:34:38 -07:00
Carlos Landeras 22717373ca
[Azure Storage Queue Binding] Add option to decode base64 payloads #232 (#251)
* [Azure Storage Queue Binding] Add option to decode base64 payloads

* Fix tests

* Fix linting

* Fix wrong assertion

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
2020-03-20 03:47:00 -07:00
Sivamuthu Kumar f21a0e93e1
eventhub read and write from same partition (#269) 2020-03-19 12:31:10 -07:00
Abhishek Gupta cf077cca65
Updated Event Hubs bindings implementation to use EPH (#253)
* update implementation to use EPH

* fixed minor lint error

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-03-09 22:07:52 -07:00
Sivamuthu Kumar da7ce3f738
Twilio Binding - Get To Number from Request (#256)
* Twilio Binding - Get To Number from Request

* fix typo and rephrase error message

Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-03-09 15:44:59 -07:00
Aaron Crawfis d38b341044 Updated binding docs to point to dapr docs 2020-03-09 09:47:43 -07:00
Young Bu Park ee97c3c56a
Use dapr logger (#238)
* Use dapr logger

* skip linter false alarm
2020-02-28 15:49:49 -08:00
Aaron Crawfis 275b115232
Update bindings doc (#219)
* Updated bindings docs

* Added spec reminder

* Added how to link
2020-02-10 19:09:48 -08:00
Young Bu Park 5a24823c89
Upgrade go to 1.13.7 and linter to 1.23.2 (#205)
* upgrade go

* Fix all linter errors
2020-02-03 14:29:29 -08:00
Mark Russinovich 3833ca9eb7
Added Twilio binding (#203)
* Added Twilio binding

* Fixed linter bugs
2020-01-30 18:18:52 -08:00
Shalabh Mohan Shrivastava e7639f90c9
Modify the AppResponse struct to have the store name (#183)
* Need to change the AppResponse struct to have the store name and state requests separately to support multiple state stores support in Dapr.

This is needed to support this requirement : dapr/dapr#636

* Putting the state in a separate struct

* Reverting the last commit - and keeping the things simple, just adding the storeName in the struct
2020-01-09 15:52:45 -08:00
Dr. David Kunz 49553859a0 Update redis_test.go (#165)
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
2020-01-09 12:34:32 -08:00
Abhishek Gupta 9323c44ecf check etag for etcd update and delete ops (#175) 2020-01-09 12:33:23 -08:00
Marcin Kosieradzki 3db863cac6 Changed schema to be consistent with blobstorage (#166)
* Changed schema to be consistent with blobstorage

* Updated tests to match the updated schema
2019-12-27 10:35:28 -08:00
Yaron Schneider 94d9988642
fix close channel by queue redecleration (#162) 2019-12-23 16:17:00 -08:00
thinkerou a2f4b4c510 upgrade logrus to v1.4.2 (#150)
* fix conflict

* upgrade logrus to v1.4.2

* fix lint error

error: `depguard  `github.com/sirupsen/logrus` is in the blacklist`
2019-12-12 09:34:39 -08:00
stather 744880306f Azure storage queue binding implementation (#146)
* folders and files

* boilerplate added

* write queue done
parse metadata done

* refactor of init and write

* All done

* lint updates

* Additional lint fixes

* lint simplifications

* UPdated to make testable
Make read blocking

* working tests

* linting fix

* Added backoff so we dont eat CPU

* go mod tidy to fix error

* fixed test failures

* Fixed lint error
2019-12-03 21:31:46 -08:00
Francisco Beltrao f89682397b Add Azure SignalR binding (#148)
* Add Azure SignalR binding

* Fixes from go lint

* Go lint

* Use "github.com/dgrijalva/jwt-go" for jwt
Fix bug parsing connection string
Normalize usage of len vs == in strings

* Consistent usage of http header Set
2019-12-03 09:08:53 -08:00
Yaron Schneider 62856f9e0c
Merge branch 'master' into naming 2019-11-22 11:15:50 -08:00
Shalabh Mohan Shrivastava ad0e80bd3c Removing unused import 2019-11-21 18:23:43 -08:00
Shalabh Mohan Shrivastava b1ae76550b Split the requests and responses for input/output bindings 2019-11-21 18:19:17 -08:00
Shalabh Mohan Shrivastava 8c9a3bd806 [Commit - Bindings Package names]
Changing the names of the packages directory so to be consistent with name of the company .

It is to be noted that package name can not have hyphen "-" in the name.
So changing the directory names and putting under company names.

For example - dynamodb  package would be

dapr/components-contrib/bindings/aws/dynamodb
2019-11-18 15:33:13 -08:00
Flier Lu 342e0d6223 [WIP] Add zookeeper state store (#80)
* [WIP] Add zookeeper state store

* go mod vendor

* fix lint warnings

* change state.StateStore to state.Store
2019-10-31 21:04:34 -07:00
Abhishek Gupta 9f90855bf7 Updated Kafka binding component to add SASL authentication (#77)
* updated implementation

* removed InsecureSkipVerify
2019-10-29 23:40:30 -07:00
sayboras 8adf323961 Add github action for CI (#59)
* Initial commit

* Fixed all linting error

* Used prepared query instead of string format

* Enabled linter for test
Enabled below linters
    - gochecknoglobals
    - gochecknoinits

* Enabled below linters
    - godox
    - interfacer
    - maligned

* Revert name change for StateStore in pkg state

* Incorporate review comments

* Cleanup the github ci

* Correct typo

* Add golangci-lint version in github ci step

* Update Readme.md
2019-10-28 15:39:48 -07:00
Łukasz Kałużny 195b14e610 Fix typo in comment in blobstorage.go (#63) 2019-10-28 09:13:16 -07:00
Philippe Coval c9c1a54867 docs: Fix RabbitMQ link (#40)
Change-Id: I9ed68882624f65203ec0bb472a8729951a662d87
Forwarded: https://github.com/dapr/components-contrib/pull/40
Signed-off-by: Philippe Coval <p.coval@samsung.com>
2019-10-18 03:40:17 -07:00
Yaron Schneider d0a26589f2
Update Readme.md (#37) 2019-10-15 11:32:40 -07:00
Yaron Schneider 887cd92b8d
vendor update (#34) 2019-10-14 23:49:50 -07:00
shalabhs 4a62360ad4 - adding more corrections 2019-10-10 18:16:08 -07:00
shalabhs ae8c77f43b Adding and Correcting code comments and types 2019-10-10 18:09:13 -07:00
Aman Bhardwaj 04bef3ac3f Adding license header and updating to MIT license. (#26) 2019-10-09 10:58:08 -07:00
Yaron Schneider 2b8dbd2b44
dapr name change (#21) 2019-10-02 13:21:22 -07:00
Yaron Schneider 96bfa841c2
Update Readme.md (#20) 2019-10-01 10:21:22 -07:00
Brendan Burns a1ab528d56 Add a Kubernetes input binding. (#15) 2019-09-30 22:01:43 -07:00
Yaron Schneider ad1d4aaec2
Add GCP Pub/Sub input and output binding (#18)
* add gcp pub-sub input/output binding

* update bindings list

* Update pubsub_test.go
2019-09-30 08:46:20 -07:00
Yaron Schneider 80358f0a11
add New() method for Service Bus Queues (#14) 2019-09-27 16:43:45 -07:00
Yaron Schneider 1c5bc048e9
Update Readme.md 2019-09-27 16:27:12 -07:00
Yaron Schneider a50e3de151
Add Azure Service Bus Queues binding (#13)
* add azure service bus queues bindings

* update table
2019-09-27 16:10:00 -07:00
Yaron Schneider 8dacdab522
Update input_binding.go (#12) 2019-09-27 14:49:25 -07:00
Yaron Schneider 0a710b46dc
add s3 binding (#6)
* add s3 binding

* add debug log on nonexistent key

* include key in debug log
2019-09-27 09:13:35 -07:00
Yaron Schneider 071f9ec31b
add azure blob storage binding (#4) 2019-09-27 07:45:26 -07:00
Yaron Schneider 07ac7d0af5
Update Readme.md 2019-09-26 16:19:17 -07:00
yaron2 cf986a3ab7 table update 2019-09-26 16:16:41 -07:00
yaron2 22fea6f43d initial commit 2019-09-26 15:47:41 -07:00