seba-365 - implemented dep
Change-Id: Ia6226d50e7615935a0c8876809a687427ff88c22
diff --git a/vendor/github.com/mongodb/mongo-go-driver/internal/channel_connection.go b/vendor/github.com/mongodb/mongo-go-driver/internal/channel_connection.go
new file mode 100644
index 0000000..770cb33
--- /dev/null
+++ b/vendor/github.com/mongodb/mongo-go-driver/internal/channel_connection.go
@@ -0,0 +1,74 @@
+// Copyright (C) MongoDB, Inc. 2017-present.
+//
+// Licensed under the Apache License, Version 2.0 (the "License"); you may
+// not use this file except in compliance with the License. You may obtain
+// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
+
+package internal
+
+import (
+ "context"
+
+ "github.com/mongodb/mongo-go-driver/bson"
+ "github.com/mongodb/mongo-go-driver/x/bsonx"
+ "github.com/mongodb/mongo-go-driver/x/network/wiremessage"
+ "errors"
+ "fmt"
+)
+
+// Implements the connection.Connection interface by reading and writing wire messages
+// to a channel
+type ChannelConn struct {
+ WriteErr error
+ Written chan wiremessage.WireMessage
+ ReadResp chan wiremessage.WireMessage
+ ReadErr chan error
+}
+
+func (c *ChannelConn) WriteWireMessage(ctx context.Context, wm wiremessage.WireMessage) error {
+ select {
+ case c.Written <- wm:
+ default:
+ c.WriteErr = errors.New("could not write wiremessage to written channel")
+ }
+ return c.WriteErr
+}
+
+func (c *ChannelConn) ReadWireMessage(ctx context.Context) (wiremessage.WireMessage, error) {
+ var wm wiremessage.WireMessage
+ var err error
+ select {
+ case wm = <-c.ReadResp:
+ case err = <-c.ReadErr:
+ case <-ctx.Done():
+ }
+ return wm, err
+}
+
+func (c *ChannelConn) Close() error {
+ return nil
+}
+
+func (c *ChannelConn) Expired() bool {
+ return false
+}
+
+func (c *ChannelConn) Alive() bool {
+ return true
+}
+
+func (c *ChannelConn) ID() string {
+ return "faked"
+}
+
+// Create a OP_REPLY wiremessage from a BSON document
+func MakeReply(doc bsonx.Doc) (wiremessage.WireMessage, error) {
+ rdr, err := doc.MarshalBSON()
+ if err != nil {
+ return nil, errors.New(fmt.Sprintf("could not create document: %v", err))
+ }
+ return wiremessage.Reply{
+ NumberReturned: 1,
+ Documents: []bson.Raw{rdr},
+ }, nil
+}