Remove unused mongo db methods from emco code

Remove the set of unused (legacy from v1) mongo
db methods so that they are not used in the emco
code base.

Issue-ID: MULTICLOUD-1227
Signed-off-by: Eric Multanen <eric.w.multanen@intel.com>
Change-Id: Ibe94892e5b1d0f33192be7ea3db5c55b3f8cbf60

1 files changed, 0 insertions, 203 deletions

diff --git a/src/orchestrator/pkg/infra/db/mongo.go b/src/orchestrator/pkg/infra/db/mongo.go
index a3fdc570..cae57e1d 100644
--- a/src/orchestrator/pkg/infra/db/mongo.go
+++ b/src/orchestrator/pkg/infra/db/mongo.go
@@ -18,7 +18,6 @@ package db
 
 import (
 	"encoding/json"
-	"log"
 	"sort"
 
 	"golang.org/x/net/context"
@@ -135,88 +134,6 @@ func (m *MongoStore) validateParams(args ...interface{}) bool {
 	return true
 }
 
-// Create is used to create a DB entry
-func (m *MongoStore) Create(coll string, key Key, tag string, data interface{}) error {
-	if data == nil || !m.validateParams(coll, key, tag) {
-		return pkgerrors.New("No Data to store")
-	}
-
-	c := getCollection(coll, m)
-	ctx := context.Background()
-
-	//Insert the data and then add the objectID to the masterTable
-	res, err := c.InsertOne(ctx, bson.D{
-		{tag, data},
-	})
-	if err != nil {
-		return pkgerrors.Errorf("Error inserting into database: %s", err.Error())
-	}
-
-	//Add objectID of created data to masterKey document
-	//Create masterkey document if it does not exist
-	filter := bson.D{{"key", key}}
-
-	_, err = decodeBytes(
-		c.FindOneAndUpdate(
-			ctx,
-			filter,
-			bson.D{
-				{"$set", bson.D{
-					{tag, res.InsertedID},
-				}},
-			},
-			options.FindOneAndUpdate().SetUpsert(true).SetReturnDocument(options.After)))
-
-	if err != nil {
-		return pkgerrors.Errorf("Error updating master table: %s", err.Error())
-	}
-
-	return nil
-}
-
-// Update is used to update a DB entry
-func (m *MongoStore) Update(coll string, key Key, tag string, data interface{}) error {
-	if data == nil || !m.validateParams(coll, key, tag) {
-		return pkgerrors.New("No Data to update")
-	}
-
-	c := getCollection(coll, m)
-	ctx := context.Background()
-
-	//Get the masterkey document based on given key
-	filter := bson.D{{"key", key}}
-	keydata, err := decodeBytes(c.FindOne(context.Background(), filter))
-	if err != nil {
-		return pkgerrors.Errorf("Error finding master table: %s", err.Error())
-	}
-
-	//Read the tag objectID from document
-	tagoid, ok := keydata.Lookup(tag).ObjectIDOK()
-	if !ok {
-		return pkgerrors.Errorf("Error finding objectID for tag %s", tag)
-	}
-
-	//Update the document with new data
-	filter = bson.D{{"_id", tagoid}}
-
-	_, err = decodeBytes(
-		c.FindOneAndUpdate(
-			ctx,
-			filter,
-			bson.D{
-				{"$set", bson.D{
-					{tag, data},
-				}},
-			},
-			options.FindOneAndUpdate().SetReturnDocument(options.After)))
-
-	if err != nil {
-		return pkgerrors.Errorf("Error updating record: %s", err.Error())
-	}
-
-	return nil
-}
-
 // Unmarshal implements an unmarshaler for bson data that
 // is produced from the mongo database
 func (m *MongoStore) Unmarshal(inp []byte, out interface{}) error {
@@ -227,126 +144,6 @@ func (m *MongoStore) Unmarshal(inp []byte, out interface{}) error {
 	return nil
 }
 
-// Read method returns the data stored for this key and for this particular tag
-func (m *MongoStore) Read(coll string, key Key, tag string) ([]byte, error) {
-	if !m.validateParams(coll, key, tag) {
-		return nil, pkgerrors.New("Mandatory fields are missing")
-	}
-
-	c := getCollection(coll, m)
-	ctx := context.Background()
-
-	//Get the masterkey document based on given key
-	filter := bson.D{{"key", key}}
-	keydata, err := decodeBytes(c.FindOne(context.Background(), filter))
-	if err != nil {
-		return nil, pkgerrors.Errorf("Error finding master table: %s", err.Error())
-	}
-
-	//Read the tag objectID from document
-	tagoid, ok := keydata.Lookup(tag).ObjectIDOK()
-	if !ok {
-		return nil, pkgerrors.Errorf("Error finding objectID for tag %s", tag)
-	}
-
-	//Use tag objectID to read the data from store
-	filter = bson.D{{"_id", tagoid}}
-	tagdata, err := decodeBytes(c.FindOne(ctx, filter))
-	if err != nil {
-		return nil, pkgerrors.Errorf("Error reading found object: %s", err.Error())
-	}
-
-	//Return the data as a byte array
-	//Convert string data to byte array using the built-in functions
-	switch tagdata.Lookup(tag).Type {
-	case bson.TypeString:
-		return []byte(tagdata.Lookup(tag).StringValue()), nil
-	default:
-		return tagdata.Lookup(tag).Value, nil
-	}
-}
-
-// Helper function that deletes an object by its ID
-func (m *MongoStore) deleteObjectByID(coll string, objID primitive.ObjectID) error {
-
-	c := getCollection(coll, m)
-	ctx := context.Background()
-
-	_, err := c.DeleteOne(ctx, bson.D{{"_id", objID}})
-	if err != nil {
-		return pkgerrors.Errorf("Error Deleting from database: %s", err.Error())
-	}
-
-	log.Printf("Deleted Obj with ID %s", objID.String())
-	return nil
-}
-
-// Delete method removes a document from the Database that matches key
-// TODO: delete all referenced docs if tag is empty string
-func (m *MongoStore) Delete(coll string, key Key, tag string) error {
-	if !m.validateParams(coll, key, tag) {
-		return pkgerrors.New("Mandatory fields are missing")
-	}
-
-	c := getCollection(coll, m)
-	ctx := context.Background()
-
-	//Get the masterkey document based on given key
-	filter := bson.D{{"key", key}}
-	//Remove the tag ID entry from masterkey table
-	update := bson.D{
-		{
-			"$unset", bson.D{
-				{tag, ""},
-			},
-		},
-	}
-	keydata, err := decodeBytes(c.FindOneAndUpdate(ctx, filter, update,
-		options.FindOneAndUpdate().SetReturnDocument(options.Before)))
-	if err != nil {
-		//No document was found. Return nil.
-		if err == mongo.ErrNoDocuments {
-			return nil
-		}
-		//Return any other error that was found.
-		return pkgerrors.Errorf("Error decoding master table after update: %s",
-			err.Error())
-	}
-
-	//Read the tag objectID from document
-	elems, err := keydata.Elements()
-	if err != nil {
-		return pkgerrors.Errorf("Error reading elements from database: %s", err.Error())
-	}
-
-	tagoid, ok := keydata.Lookup(tag).ObjectIDOK()
-	if !ok {
-		return pkgerrors.Errorf("Error finding objectID for tag %s", tag)
-	}
-
-	//Use tag objectID to read the data from store
-	err = m.deleteObjectByID(coll, tagoid)
-	if err != nil {
-		return pkgerrors.Errorf("Error deleting from database: %s", err.Error())
-	}
-
-	//Delete master table if no more tags left
-	//_id, key and tag should be elements in before doc
-	//if master table needs to be removed too
-	if len(elems) == 3 {
-		keyid, ok := keydata.Lookup("_id").ObjectIDOK()
-		if !ok {
-			return pkgerrors.Errorf("Error finding objectID for key %s", key)
-		}
-		err = m.deleteObjectByID(coll, keyid)
-		if err != nil {
-			return pkgerrors.Errorf("Error deleting master table from database: %s", err.Error())
-		}
-	}
-
-	return nil
-}
-
 func (m *MongoStore) findFilter(key Key) (primitive.M, error) {
 
 	var bsonMap bson.M