Commit 8f8505a9 authored by Ignacio Corderi's avatar Ignacio Corderi
Browse files

Added GetLog to Client/AsyncClient

parent 193c26b3

CHANGES.md

+1 −0
Original line number Diff line number Diff line
@@ -17,6 +17,7 @@ This section will document changes to the library since the last release 
- Added unsolicited status support

- Pin based operations MUST have a pin set and SSL enabled

- setSecurity MUST have SSL enabled

- getLog / getLogAsync added to Client/AsyncClient



## Behavior changes

- Removed GreenClient (Feature overlap with AsyncClient)

kinetic/asyncclient.py

+2 −2
Original line number Diff line number Diff line
@@ -101,8 +101,8 @@ class AsyncClient(baseasync.BaseAsync): 
        d.error = None

        d.result = None



        def innerSuccess(header, value):

            d.result = (header, value)

        def innerSuccess(m, r, value):

            d.result = (m, r, value)

            done.send()



        def innerError(e):

kinetic/baseasync.py

+10 −7
Original line number Diff line number Diff line
@@ -96,7 +96,7 @@ class BaseAsync(Client): 
                onSuccess,_ = self._pending[seq]

                del self._pending[seq]

                try:

                    self.dispatch(onSuccess,resp,value)

                    self.dispatch(onSuccess, m, resp, value)

                except Exception as e:

                    self._raise(e)

        except Exception as e:
@@ -115,8 +115,8 @@ class BaseAsync(Client): 
        d.error = None

        d.result = None



        def innerSuccess(response, value):

            d.result = (response, value)

        def innerSuccess(m, resp, value):

            d.result = (m, resp, value)

            done.set()



        def innerError(e):
@@ -142,10 +142,10 @@ class BaseAsync(Client): 
            self._raise(common.NotConnected("Not connected."), onError)

            return #skip the rest



        def innerSuccess(response, value):

        def innerSuccess(m, response, value):

            try:

                operations._check_status(response)

                onSuccess(response, value)

                onSuccess(m, response, value)

            except Exception as ex:

                onError(ex)
@@ -167,7 +167,7 @@ class BaseAsync(Client): 
    def _processAsync(self, op, onSuccess, onError, *args, **kwargs):

        if not self.isConnected: raise common.NotConnected("Must call connect() before sending operations.")



        def innerSuccess(header, value):

        def innerSuccess(m, header, value):

            onSuccess(op.parse(header, value))



        def innerError(e):
@@ -217,3 +217,6 @@ class BaseAsync(Client): 
    def mediaOptimizeAsync(self, onSuccess, onError, *args, **kwargs):

        self._processAsync(operations.MediaOptimize, onSuccess, onError, *args, **kwargs)



    def getLogAsync(self, onSuccess, onError, *args, **kwargs):

        self._processAsync(operations.GetLog, onSuccess, onError, *args, **kwargs)

kinetic/client.py

+2 −0
Original line number Diff line number Diff line
@@ -95,6 +95,8 @@ class Client(BaseClient): 
    def mediaOptimize(self, *args, **kwargs):

        return self._process(operations.MediaOptimize, *args, **kwargs)



    def getLog(self, *args, **kwargs):

        return self._process(operations.GetLog, *args, **kwargs)



class KineticRangeIter(object):