Skip to content

Commit

Permalink
feat: add a support for transact items in dynago to do put or delete …
Browse files Browse the repository at this point in the history
…operations synchronously (#5)

- [x] add a support for transact items in dynago to do put or delete
operations synchronously

Tested : locally using integrated testing with local db
  • Loading branch information
omkar-till authored Nov 20, 2023
2 parents da47710 + fc1a8c6 commit bbd199d
Show file tree
Hide file tree
Showing 3 changed files with 189 additions and 0 deletions.
1 change: 1 addition & 0 deletions interface.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ type WriteAPI interface {

type TransactionAPI interface {
TransactPutItems(ctx context.Context, items []*TransactPutItemsInput) error
TransactItems(ctx context.Context, input []types.TransactWriteItem) error
}

type ReadAPI interface {
Expand Down
134 changes: 134 additions & 0 deletions tests/transact_items_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,134 @@
package tests

import (
"context"
"reflect"
"strings"
"testing"

"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
"github.com/oolio-group/dynago"
)

type Terminal struct {
Id string
Pk string
Sk string
}

func TestTransactItems(t *testing.T) {
endoint, purge := startLocalDatabase(t)
defer purge()

table := prepareTable(t, endoint, "transcact_item_test")

testCases := []struct {
title string
condition string
keys map[string]types.AttributeValue
opts []dynago.QueryOptions
//items to be added
newItems []Terminal
operations []types.TransactWriteItem
//items expected to exist in table after transaction operation
expected []Terminal
expectedErr error
}{{
title: "assign terminal - only add a terminal",
condition: "pk = :pk",
keys: map[string]types.AttributeValue{
":pk": &types.AttributeValueMemberS{Value: "terminal1"},
},
newItems: []Terminal{},
operations: []types.TransactWriteItem{
table.WithPutItem("terminal1", "merchant1", Terminal{
Id: "1",
Pk: "terminal1",
Sk: "merchant1",
}),
},
expected: []Terminal{
{
Id: "1",
Pk: "terminal1",
Sk: "merchant1",
},
},
},
{
title: "assign terminal - delete existing and update with new",
condition: "pk = :pk",
keys: map[string]types.AttributeValue{
":pk": &types.AttributeValueMemberS{Value: "terminal1"},
},
newItems: []Terminal{{
Id: "1",
Pk: "terminal1",
Sk: "merchant2",
}},
operations: []types.TransactWriteItem{
table.WithDeleteItem("terminal1", "merchant1"),
table.WithPutItem("terminal1", "merchant2", Terminal{
Id: "1",
Pk: "terminal1",
Sk: "merchant2",
}),
},
expected: []Terminal{
{
Id: "1",
Pk: "terminal1",
Sk: "merchant2",
},
},
},
}
for _, tc := range testCases {
t.Run(tc.title, func(t *testing.T) {
t.Helper()
ctx := context.TODO()
// Create Item
if len(tc.newItems) > 0 {
items := make([]*dynago.TransactPutItemsInput, 0, len(tc.newItems))
for _, item := range tc.newItems {
items = append(items, &dynago.TransactPutItemsInput{
dynago.StringValue(item.Pk), dynago.StringValue(item.Sk), item,
})
}
err := table.TransactPutItems(ctx, items)
if err != nil {
t.Fatalf("transaction put items failed; got %s", err)
}
}
//perform operations
if len(tc.operations) > 0 {
err := table.TransactItems(ctx, tc.operations)
if err != nil {
t.Fatalf("error occurred %s", err)
}

}

var out []Terminal
_, err := table.Query(ctx, tc.condition, tc.keys, &out)
if tc.expectedErr != nil {
if err == nil {
t.Fatalf("expected query to fail with %s", tc.expectedErr)
}
if !strings.Contains(err.Error(), tc.expectedErr.Error()) {
t.Fatalf("expected query to fail with %s; got %s", tc.expectedErr, err)
}
return
}
if err != nil {
t.Fatalf("expected query to succeed; got %s", err)
}
if !reflect.DeepEqual(tc.expected, out) {
t.Errorf("expected query to return %v; got %v", tc.expected, out)
}

})

}

}
54 changes: 54 additions & 0 deletions transaction_items.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,54 @@
package dynago

import (
"context"
"log"

"github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue"
"github.com/aws/aws-sdk-go-v2/service/dynamodb"
"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
)

func (t *Client) WithDeleteItem(pk string, sk string) types.TransactWriteItem {
return types.TransactWriteItem{
Delete: &types.Delete{
TableName: &t.TableName,
Key: map[string]types.AttributeValue{
"pk": &types.AttributeValueMemberS{Value: pk},
"sk": &types.AttributeValueMemberS{Value: sk},
},
},
}

}

func (t *Client) WithPutItem(pk string, sk string, item interface{}) types.TransactWriteItem {
av, err := attributevalue.MarshalMap(item)
if err != nil {
log.Println("Failed to Marshal item" + err.Error())
return types.TransactWriteItem{}
}
keys := map[string]types.AttributeValue{
"pk": &types.AttributeValueMemberS{Value: pk},
"sk": &types.AttributeValueMemberS{Value: sk},
}
for k, v := range keys {
av[k] = v
}
return types.TransactWriteItem{
Put: &types.Put{
TableName: &t.TableName,
Item: av,
},
}

}

// TransactItems is a synchronous for writing or deletion operation performed in dynamodb grouped together

func (t *Client) TransactItems(ctx context.Context, input []types.TransactWriteItem) error {
_, err := t.client.TransactWriteItems(ctx, &dynamodb.TransactWriteItemsInput{
TransactItems: input,
})
return err
}

0 comments on commit bbd199d

Please sign in to comment.