Merge bcornec's pull request + my fixes

redfish/connection.py

@@ -130,8 +130,15 @@ import sys
 
 class RedfishConnection(object):
 
-    def __init__(self):
+    def __init__(self, host, user_name, password):
         super(RedfishConnection, self).__init__()
+        self.host = host
+        self.user_name = user_name
+        self.password = password
+        authen = {'Password': self.password, 'UserName': self.user_name}
+        self.rest_post(self.host, '/rest/v1/sessions', None, json.dumps(authen),
+            self.user_name, self.password)
+
         # XXX add members, we're going to have to cache
 
     def _op(self, operation, host, suburi, request_headers, request_body,

redfish/functions.py

@@ -0,0 +1,57 @@
+
+ # Copyright 2014 Hewlett-Packard Development Company, L.P.
+ #
+ # 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
+ #
+ # Unless required by applicable law or agreed to in writing, software
+ # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ # License for the specific language governing permissions and limitations
+ # under the License.
+
+
+"""
+
+Provides functions for using the Redfish RESTful API.
+
+"""
+
+import collections
+import json
+import sys
+from redfish import connection
+
+class RedfishOperation(connection.RedfishConnection):
+
+    def __init__(self, host, user_name, password):
+        super(RedfishOperation, self).__init__(host,
+                user_name, password)
+        # XXX add members, we're going to have to cache
+
+    # noinspection PyPep8Naming
+    def reset_server(self):
+        (status, headers, system) = self.rest_get(self.host,
+                    '/rest/v1/Systems', None, self.user_name, self.password)
+
+        memberuri = system['links']['Member'][0]['href']
+        # verify expected type
+        # hint:  don't limit to version 0 here as we will rev to 1.0 at some point hopefully with minimal changes
+#        assert(connection.get_type(system) == 'ComputerSystem.0' or connection.get_type(system) == 'ComputerSystem.1')
+
+        # verify it supports POST
+#        assert(connection.operation_allowed(headers, 'POST'))
+
+        action = dict()
+        action['Action'] = 'Reset'
+        action['ResetType'] = 'ForceRestart'
+
+        # perform the POST action
+        print('POST ' + json.dumps(action) + ' to ' + memberuri)
+        (status, headers, response) = self.rest_post(self.host, memberuri, None,
+                action, self.user_name, self.password)
+        print('POST response = ' + str(status))
+        connection.print_extended_error(response)