Skip to content

Commit c1225a0

Browse files
zucchinidevzucchinidev
authored
feat: MondoDB should not be retired (#836)
* feat: MongoDB should not be retired * feat: MongoDB should not be retired
1 parent c1bbe9f commit c1225a0

26 files changed

+1478
-6
lines changed

‎.github/dependabot.yml

+7
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,13 @@ updates:
1414
azure-sdk-for-go:
1515
patterns:
1616
- "github.com/Azure/azure-sdk-for-go/*"
17+
- package-ecosystem: gomod
18+
directory: "/acceptance-tests/apps/mongodbapp"
19+
schedule:
20+
interval: "weekly"
21+
day: "saturday"
22+
labels:
23+
- "test-dependencies"
1724
- package-ecosystem: gomod
1825
directory: "/acceptance-tests/apps/postgresqlapp"
1926
schedule:

‎acceptance-tests/apps/mongodbapp/go.mod

+23
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
module mongodbapp
2+
3+
go 1.22.6
4+
5+
require (
6+
github.com/cloudfoundry-community/go-cfenv v1.18.0
7+
github.com/mitchellh/mapstructure v1.5.0
8+
go.mongodb.org/mongo-driver v1.16.1
9+
)
10+
11+
require (
12+
github.com/golang/snappy v0.0.4 // indirect
13+
github.com/klauspost/compress v1.13.6 // indirect
14+
github.com/montanaflynn/stats v0.7.1 // indirect
15+
github.com/onsi/gomega v1.10.5 // indirect
16+
github.com/xdg-go/pbkdf2 v1.0.0 // indirect
17+
github.com/xdg-go/scram v1.1.2 // indirect
18+
github.com/xdg-go/stringprep v1.0.4 // indirect
19+
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect
20+
golang.org/x/crypto v0.22.0 // indirect
21+
golang.org/x/sync v0.7.0 // indirect
22+
golang.org/x/text v0.14.0 // indirect
23+
)

‎acceptance-tests/apps/mongodbapp/go.sum

+105
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,105 @@
1+
github.com/cloudfoundry-community/go-cfenv v1.18.0 h1:dOIRSHUSaj4r6Q9Cx+nzz2OytHt+QNKqtOuKTQsa+zw=
2+
github.com/cloudfoundry-community/go-cfenv v1.18.0/go.mod h1:qGMSI6lygPzqugFs9M1NFjJBtEPgl0MgT6drMFZGUoU=
3+
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
4+
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
5+
github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
6+
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
7+
github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
8+
github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
9+
github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=
10+
github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w=
11+
github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0=
12+
github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
13+
github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
14+
github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
15+
github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
16+
github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
17+
github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
18+
github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
19+
github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
20+
github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
21+
github.com/joefitzgerald/rainbow-reporter v0.1.0 h1:AuMG652zjdzI0YCCnXAqATtRBpGXMcAnrajcaTrSeuo=
22+
github.com/joefitzgerald/rainbow-reporter v0.1.0/go.mod h1:481CNgqmVHQZzdIbN52CupLJyoVwB10FQ/IQlF1pdL8=
23+
github.com/klauspost/compress v1.13.6 h1:P76CopJELS0TiO2mebmnzgWaajssP/EszplttgQxcgc=
24+
github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk=
25+
github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
26+
github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY=
27+
github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
28+
github.com/montanaflynn/stats v0.7.1 h1:etflOAAHORrCC44V+aR6Ftzort912ZU+YLiSTuV8eaE=
29+
github.com/montanaflynn/stats v0.7.1/go.mod h1:etXPPgVO6n31NxCd9KQUMvCM+ve0ruNzt6R8Bnaayow=
30+
github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
31+
github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
32+
github.com/onsi/ginkgo v1.8.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
33+
github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk=
34+
github.com/onsi/gomega v1.5.0/go.mod h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
35+
github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY=
36+
github.com/onsi/gomega v1.10.5 h1:7n6FEkpFmfCoo2t+YYqXH0evK+a9ICQz0xcAy9dYcaQ=
37+
github.com/onsi/gomega v1.10.5/go.mod h1:gza4q3jKQJijlu05nKWRCW/GavJumGt8aNRxWg7mt48=
38+
github.com/sclevine/spec v1.2.0 h1:1Jwdf9jSfDl9NVmt8ndHqbTZ7XCCPbh1jI3hkDBHVYA=
39+
github.com/sclevine/spec v1.2.0/go.mod h1:W4J29eT/Kzv7/b9IWLB055Z+qvVC9vt0Arko24q7p+U=
40+
github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
41+
github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
42+
github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY=
43+
github.com/xdg-go/scram v1.1.2/go.mod h1:RT/sEzTbU5y00aCK8UOx6R7YryM0iF1N2MOmC3kKLN4=
44+
github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8=
45+
github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
46+
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d h1:splanxYIlg+5LfHAM6xpdFEAYOk8iySO56hMFq6uLyA=
47+
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
48+
github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
49+
go.mongodb.org/mongo-driver v1.16.1 h1:rIVLL3q0IHM39dvE+z2ulZLp9ENZKThVfuvN/IiN4l8=
50+
go.mongodb.org/mongo-driver v1.16.1/go.mod h1:oB6AhJQvFQL4LEHyXi6aJzQJtBiTQHiAd83l0GdFaiw=
51+
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
52+
golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
53+
golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
54+
golang.org/x/crypto v0.22.0 h1:g1v0xeRhjcugydODzvb3mEM9SQ0HGp9s/nh3COQ/C30=
55+
golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M=
56+
golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
57+
golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
58+
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
59+
golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
60+
golang.org/x/net v0.0.0-20201202161906-c7110b5ffcbb/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
61+
golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
62+
golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
63+
golang.org/x/net v0.21.0 h1:AQyQV4dYCvJ7vGmJyKki9+PBdyvhkSd8EIx/qb0AYv4=
64+
golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
65+
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
66+
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
67+
golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
68+
golang.org/x/sync v0.7.0 h1:YsImfSBoP9QPYL0xyKJPq0gcaJdG3rInoqxTWbfQu9M=
69+
golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
70+
golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
71+
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
72+
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
73+
golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
74+
golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
75+
golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
76+
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
77+
golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
78+
golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
79+
golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
80+
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
81+
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
82+
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
83+
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
84+
golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
85+
golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ=
86+
golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
87+
golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
88+
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
89+
golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
90+
golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
91+
golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
92+
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
93+
google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
94+
google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
95+
google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
96+
google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE=
97+
google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo=
98+
google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
99+
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
100+
gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
101+
gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
102+
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
103+
gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
104+
gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU=
105+
gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=

‎acceptance-tests/apps/mongodbapp/internal/app/app.go

+48
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,48 @@
1+
package app
2+
3+
import (
4+
"context"
5+
"fmt"
6+
"log"
7+
"net/http"
8+
"time"
9+
10+
"go.mongodb.org/mongo-driver/mongo"
11+
"go.mongodb.org/mongo-driver/mongo/options"
12+
)
13+
14+
const (
15+
documentNameKey = "name"
16+
documentDataKey = "data"
17+
documentTTLKey = "ttl"
18+
)
19+
20+
func App(uri string) http.Handler {
21+
client := connect(uri)
22+
23+
r := http.NewServeMux()
24+
r.HandleFunc("GET /", handleListDatabases(client))
25+
r.HandleFunc("GET /{database}", handleListCollections(client))
26+
r.HandleFunc("GET /{database}/{collection}/{document}", handleFetchDocument(client))
27+
r.HandleFunc("PUT /{database}/{collection}/{document}", handleStoreDocument(client))
28+
29+
return r
30+
}
31+
32+
func connect(uri string) *mongo.Client {
33+
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
34+
defer cancel()
35+
36+
client, err := mongo.Connect(ctx, options.Client().ApplyURI(uri))
37+
if err != nil {
38+
log.Fatalf("error connecting to MongoDB: %s", err)
39+
}
40+
41+
return client
42+
}
43+
44+
func fail(w http.ResponseWriter, code int, format string, a ...any) {
45+
msg := fmt.Sprintf(format, a...)
46+
log.Println(msg)
47+
http.Error(w, msg, code)
48+
}

‎acceptance-tests/apps/mongodbapp/internal/app/fetch_document.go

+64
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,64 @@
1+
package app
2+
3+
import (
4+
"fmt"
5+
"log"
6+
"net/http"
7+
8+
"go.mongodb.org/mongo-driver/bson"
9+
"go.mongodb.org/mongo-driver/mongo"
10+
)
11+
12+
func handleFetchDocument(client *mongo.Client) func(w http.ResponseWriter, r *http.Request) {
13+
return func(w http.ResponseWriter, r *http.Request) {
14+
log.Println("Handling fetch.")
15+
16+
databaseName := r.PathValue("database")
17+
if databaseName == "" {
18+
fail(w, http.StatusBadRequest, "database name must be supplied")
19+
}
20+
collectionName := r.PathValue("collection")
21+
if collectionName == "" {
22+
fail(w, http.StatusBadRequest, "collection name must be supplied")
23+
}
24+
documentName := r.PathValue("document")
25+
if documentName == "" {
26+
fail(w, http.StatusBadRequest, "document name must be supplied")
27+
}
28+
29+
filter := bson.D{{Key: documentNameKey, Value: documentName}}
30+
result := client.Database(databaseName).Collection(collectionName).FindOne(r.Context(), filter)
31+
if result.Err() != nil {
32+
fail(w, http.StatusNotFound, "error finding document: %s", result.Err())
33+
return
34+
}
35+
36+
var receiver bson.D
37+
if err := result.Decode(&receiver); err != nil {
38+
fail(w, http.StatusNotFound, "error decoding document: %s", err)
39+
return
40+
}
41+
42+
var data any
43+
for _, e := range receiver {
44+
if e.Key == documentDataKey {
45+
data = e.Value
46+
}
47+
}
48+
49+
if data == nil {
50+
fail(w, http.StatusNotFound, "error find document data: %+v", receiver)
51+
return
52+
}
53+
54+
w.WriteHeader(http.StatusOK)
55+
w.Header().Set("Content-Type", "text/html")
56+
_, err := w.Write([]byte(fmt.Sprintf("%v", data)))
57+
if err != nil {
58+
log.Printf("Error writing value: %s", err)
59+
return
60+
}
61+
62+
log.Printf("Data %q retrived from document %q.", data, documentName)
63+
}
64+
}

‎acceptance-tests/apps/mongodbapp/internal/app/list_collections.go

+44
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
package app
2+
3+
import (
4+
"encoding/json"
5+
"log"
6+
"net/http"
7+
"strings"
8+
9+
"go.mongodb.org/mongo-driver/bson"
10+
"go.mongodb.org/mongo-driver/mongo"
11+
)
12+
13+
func handleListCollections(client *mongo.Client) func(w http.ResponseWriter, r *http.Request) {
14+
return func(w http.ResponseWriter, r *http.Request) {
15+
log.Println("Handling list collections.")
16+
17+
databaseName := r.PathValue("database")
18+
if databaseName == "" {
19+
fail(w, http.StatusBadRequest, "database name must be supplied")
20+
}
21+
22+
list, err := client.Database(databaseName).ListCollectionNames(r.Context(), bson.D{})
23+
if err != nil {
24+
fail(w, http.StatusNotFound, "error listing collections: %s", err)
25+
return
26+
}
27+
28+
data, err := json.Marshal(list)
29+
if err != nil {
30+
fail(w, http.StatusNotFound, "JSON error: %s", err)
31+
return
32+
}
33+
34+
w.WriteHeader(http.StatusOK)
35+
w.Header().Set("Content-Type", "text/html")
36+
_, err = w.Write(data)
37+
if err != nil {
38+
log.Printf("Error writing value: %s", err)
39+
return
40+
}
41+
42+
log.Printf("Listed collections: %s", strings.Join(list, ", "))
43+
}
44+
}

‎acceptance-tests/apps/mongodbapp/internal/app/list_databases.go

+38
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
package app
2+
3+
import (
4+
"encoding/json"
5+
"log"
6+
"net/http"
7+
"strings"
8+
9+
"go.mongodb.org/mongo-driver/bson"
10+
"go.mongodb.org/mongo-driver/mongo"
11+
)
12+
13+
func handleListDatabases(client *mongo.Client) func(w http.ResponseWriter, r *http.Request) {
14+
return func(w http.ResponseWriter, r *http.Request) {
15+
log.Println("Handling list database.")
16+
list, err := client.ListDatabaseNames(r.Context(), bson.D{})
17+
if err != nil {
18+
fail(w, http.StatusNotFound, "error listing databases: %s", err)
19+
return
20+
}
21+
22+
data, err := json.Marshal(list)
23+
if err != nil {
24+
fail(w, http.StatusNotFound, "JSON error: %s", err)
25+
return
26+
}
27+
28+
w.WriteHeader(http.StatusOK)
29+
w.Header().Set("Content-Type", "text/html")
30+
_, err = w.Write(data)
31+
if err != nil {
32+
log.Printf("Error writing value: %s", err)
33+
return
34+
}
35+
36+
log.Printf("Listed database: %s", strings.Join(list, ", "))
37+
}
38+
}

‎acceptance-tests/apps/mongodbapp/internal/app/store_document.go

+47
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
package app
2+
3+
import (
4+
"io"
5+
"log"
6+
"net/http"
7+
8+
"go.mongodb.org/mongo-driver/bson"
9+
"go.mongodb.org/mongo-driver/mongo"
10+
)
11+
12+
func handleStoreDocument(client *mongo.Client) func(w http.ResponseWriter, r *http.Request) {
13+
return func(w http.ResponseWriter, r *http.Request) {
14+
log.Println("Handling store.")
15+
16+
databaseName := r.PathValue("database")
17+
if databaseName == "" {
18+
fail(w, http.StatusBadRequest, "database name must be supplied")
19+
}
20+
collectionName := r.PathValue("collection")
21+
if collectionName == "" {
22+
fail(w, http.StatusBadRequest, "collection name must be supplied")
23+
}
24+
documentName := r.PathValue("document")
25+
if documentName == "" {
26+
fail(w, http.StatusBadRequest, "document name must be supplied")
27+
}
28+
29+
rawData, err := io.ReadAll(r.Body)
30+
if err != nil {
31+
fail(w, http.StatusBadRequest, "Error parsing data: %s", err)
32+
return
33+
}
34+
35+
data := string(rawData)
36+
document := bson.M{documentNameKey: documentName, documentDataKey: data, documentTTLKey: int32(-1)}
37+
38+
result, err := client.Database(databaseName).Collection(collectionName).InsertOne(r.Context(), document)
39+
if err != nil {
40+
fail(w, http.StatusFailedDependency, "Error creating document %q with data %q in database %q, collection %q: %s", documentName, data, databaseName, collectionName, err)
41+
return
42+
}
43+
44+
w.WriteHeader(http.StatusCreated)
45+
log.Printf("Created document %q (named %q) with data %q in database %q, collection %q.", result.InsertedID, documentName, data, databaseName, collectionName)
46+
}
47+
}

0 commit comments

Comments
 (0)