1

import sys

     2

import gluon.contrib.simplejson as simplejson

     3

     4

     5

class JSONRPCServiceBase(object):

     6

     7

    def __init__(self):

     8

        self.methods = {}

     9

    10

    def response(self, id, result):

    11

        return simplejson.dumps({'version': '1.1', 'id': id,

    12

                                 'result': result, 'error': None})

    13

    14

    def error(self, id, code, message):

    15

        return simplejson.dumps({

    16

            'id': id,

    17

            'version': '1.1',

    18

            'error': {'name': 'JSONRPCError',

    19

                      'code': code,

    20

                      'message': message}

    21

        })

    22

    23

    def add_method(self, name, method):

    24

        self.methods[name] = method

    25

    26

    def process(self, data):

    27

        data = simplejson.loads(data)

    28

        id, method, params = data["id"], data["method"], data["params"]

    29

        if method in self.methods:

    30

            try:

    31

                result = self.methods[method](*params)

    32

                return self.response(id, result)

    33

            except BaseException:

    34

                etype, eval, _etb = sys.exc_info()

    35

                return self.error(id, 100, '%s: %s' % (etype.__name__, eval))

    36

            except Exception:

    37

                etype, eval, _etb = sys.exc_info()

    38

                return self.error(id, 100, 'Exception %s: %s' % (etype, eval))

    39

        else:

    40

            return self.error(id, 100, 'method "%s" does not exist' % method)

    41

    42

    def listmethods(self):

    43

        return self.methods.keys()