Adding start and stop database tasks

Author: jdewinne

src/main/resources/delphix/DelphixClient.py

@@ -12,6 +12,7 @@
 from delphixpy.web.database import database
 from delphixpy.web.selfservice import bookmark
 from delphixpy.web.selfservice import branch
+from delphixpy.web.source import source
 
 from delphix.lib.DelphixSession import DelphixSession
 from delphix.lib.GetReferences import find_bookmark_ref
@@ -72,4 +73,10 @@ def delphix_syncdatabase(self, variables):
         return database.sync(self.engine, variables['vdb'], None)
 
     def delphix_rollbackdatabase(self, variables):
-        return database.rollback(self.engine, variables['vdb'], None)
+        return database.rollback(self.engine, variables['vdb'], None)
+
+    def delphix_stopdatabase(self, variables):
+        return source.stop(self.engine, variables['vdb'], None)
+
+    def delphix_startdatabase(self, variables):
+        return source.start(self.engine, variables['vdb'], None)

src/main/resources/synthetic.xml

@@ -55,5 +55,13 @@
         <property name="vdb" category="input"/>
     </type>
 
+    <type type="delphix.stopkDatabase" extends="delphix.Task">
+        <property name="vdb" category="input"/>
+    </type>
+
+    <type type="delphix.startDatabase" extends="delphix.Task">
+        <property name="vdb" category="input"/>
+    </type>
+
 
 </synthetic>

src/main/resources/delphix/Stop.py …est/jython/itests/Database_start_test.pysrc/main/resources/delphix/Stop.py renamed to src/test/jython/itests/Database_start_test.py src/main/resources/delphix/Stop.py renamed to src/test/jython/itests/Database_start_test.py

@@ -8,19 +8,18 @@
 # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #
 
-if __name__ == '__main__':
-    import sys
 
-#    sys.path.append('/Users/bmoussaud/Workspace/xebialabs-community/xlr-delphix-plugin/src/main/resources')
-    sys.path.append('/u02/app/xebialabs/xlr-delphix-plugin/src/main/resources')
-#    server = {'url': 'http://ba5b5824.ngrok.io', 'username': 'delphix_admin', 'password': 'landshark'}
-    server = {'url': 'http://192.168.247.132', 'username': 'delphix_admin', 'password': 'landshark'}
-    vdb = 'XEBIA'
 
+import unittest
+from itests import DelphixServerCi
 from delphix.DelphixClient import DelphixClient
+from delphix.lib.DlpxException import DlpxException
 
 
-client = DelphixClient(server)
-output = client.stop(vdb)
-job = output['job']
-action = output['action']
+class StartDatabase(unittest.TestCase):
+
+
+    def test_start_database(self):
+        client = DelphixClient.create_client(DelphixServerCi())
+        variables = {"vdb": "somevirtualdatabase" }
+        client.delphix_startdatabase(variables)

src/main/resources/delphix/Start.py …test/jython/itests/Database_stop_test.pysrc/main/resources/delphix/Start.py renamed to src/test/jython/itests/Database_stop_test.py src/main/resources/delphix/Start.py renamed to src/test/jython/itests/Database_stop_test.py

@@ -8,18 +8,18 @@
 # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #
 
-if __name__ == '__main__':
-    import sys
 
-#    sys.path.append('/Users/bmoussaud/Workspace/xebialabs-community/xlr-delphix-plugin/src/main/resources')
-    sys.path.append('/u02/app/xebialabs/xlr-delphix-plugin/src/main/resources')
-#    server = {'url': 'http://ba5b5824.ngrok.io', 'username': 'delphix_admin', 'password': 'landshark'}
-    server = {'url': 'http://192.168.247.132', 'username': 'delphix_admin', 'password': 'landshark'}
-    vdb = 'XEBIA'
 
+import unittest
+from itests import DelphixServerCi
 from delphix.DelphixClient import DelphixClient
+from delphix.lib.DlpxException import DlpxException
 
-client = DelphixClient(server)
-output = client.start(vdb)
-job = output['job']
-action = output['action']
+
+class StopDatabase(unittest.TestCase):
+
+
+    def test_stop_database(self):
+        client = DelphixClient.create_client(DelphixServerCi())
+        variables = {"vdb": "somevirtualdatabase" }
+        client.delphix_stopdatabase(variables)

src/test/resources/docker/delphix/main.go

@@ -25,6 +25,9 @@ func main() {
 
 	router.HandleFunc("/resources/json/delphix/selfservice/bookmark", ReturnBookmarkResponse).Methods("GET")
 	router.HandleFunc("/resources/json/delphix/selfservice/template", ReturnTemplateResponse).Methods("GET")
+
+	router.HandleFunc("/resources/json/delphix/source/{ref_id}/stop", ReturnDatabaseResponse).Methods("POST")
+	router.HandleFunc("/resources/json/delphix/source/{ref_id}/start", ReturnDatabaseResponse).Methods("POST")
 
 
 	router.HandleFunc("/resources/json/delphix/session", ReturnSessionResponse).Methods("POST")