Modified project api to use new mongodb methods 67/103567/3
authorSrivahni Chivukula <srivahni.chivukula@intel.com>
Wed, 11 Mar 2020 20:59:21 +0000 (13:59 -0700)
committerSrivahni Chivukula <srivahni.chivukula@intel.com>
Thu, 12 Mar 2020 19:01:41 +0000 (19:01 +0000)
Issue-ID: MULTICLOUD-994
Signed-off-by: Srivahni Chivukula <srivahni.chivukula@intel.com>
Change-Id: I8e7e17a1dab164c4ea7d50743b20f0e08958a957

src/orchestrator/pkg/module/project.go

index a95251b..a6f5925 100644 (file)
@@ -90,7 +90,7 @@ func (v *ProjectClient) CreateProject(p Project) (Project, error) {
                return Project{}, pkgerrors.New("Project already exists")
        }
 
-       err = db.DBconn.Create(v.storeName, key, v.tagMeta, p)
+       err = db.DBconn.Insert(v.storeName, key, nil, v.tagMeta, p)
        if err != nil {
                return Project{}, pkgerrors.Wrap(err, "Creating DB Entry")
        }
@@ -105,7 +105,7 @@ func (v *ProjectClient) GetProject(name string) (Project, error) {
        key := ProjectKey{
                ProjectName: name,
        }
-       value, err := db.DBconn.Read(v.storeName, key, v.tagMeta)
+       value, err := db.DBconn.Find(v.storeName, key, v.tagMeta)
        if err != nil {
                return Project{}, pkgerrors.Wrap(err, "Get Project")
        }
@@ -113,7 +113,7 @@ func (v *ProjectClient) GetProject(name string) (Project, error) {
        //value is a byte array
        if value != nil {
                proj := Project{}
-               err = db.DBconn.Unmarshal(value, &proj)
+               err = db.DBconn.Unmarshal(value[0], &proj)
                if err != nil {
                        return Project{}, pkgerrors.Wrap(err, "Unmarshaling Value")
                }
@@ -130,7 +130,7 @@ func (v *ProjectClient) DeleteProject(name string) error {
        key := ProjectKey{
                ProjectName: name,
        }
-       err := db.DBconn.Delete(v.storeName, key, v.tagMeta)
+       err := db.DBconn.Remove(v.storeName, key)
        if err != nil {
                return pkgerrors.Wrap(err, "Delete Project Entry;")
        }