Fix schema issues and parameter validation

2025-09-16 19:42:21 +00:00 · 2018-05-16 11:15:13 +02:00
34 changed files with 351 additions and 677 deletions
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -18,8 +18,6 @@ before_script:
  stage: test
  script:
    - make -e test-$PYTHON_VERSION
-  except:
-    - tags # Avoid unnecessary double testing
    
 test-3.5:
  <<: *test_definition
--- a/.makefiles/docker.mk
+++ b/.makefiles/docker.mk
@@ -1,14 +1,5 @@
-ifndef IMAGENAME
-	ifdef CI_REGISTRY_IMAGE
-		IMAGENAME=$(CI_REGISTRY_IMAGE)
-	else
-		IMAGENAME=$(NAME)
-	endif
-endif
-
+IMAGENAME?=$(NAME)
 IMAGEWTAG?=$(IMAGENAME):$(VERSION)
-DOCKER_FLAGS?=$(-ti)
-DOCKER_CMD?=

 docker-login: ## Log in to the registry. It will only be used in the server, or when running a CI task locally (if CI_BUILD_TOKEN is set).
 ifeq ($(CI_BUILD_TOKEN),)
@@ -28,19 +19,6 @@ else
 	@docker logout
 endif

-docker-run: ## Build a generic docker image
-	docker run $(DOCKER_FLAGS) $(IMAGEWTAG) $(DOCKER_CMD)
-
-docker-build: ## Build a generic docker image
-	docker build . -t $(IMAGEWTAG)
-
-docker-push: docker-login ## Push a generic docker image
-	docker push $(IMAGEWTAG)
-
-docker-latest-push: docker-login ## Push the latest image
-	docker tag $(IMAGEWTAG) $(IMAGENAME)
-	docker push $(IMAGENAME)
-
 login:: docker-login

 clean:: docker-clean
--- a/.makefiles/git.mk
+++ b/.makefiles/git.mk
@@ -14,7 +14,7 @@ push-github: ## Push the code to github. You need to set up GITHUB_DEPLOY_KEY
 ifeq ($(GITHUB_DEPLOY_KEY),)
 else
 	$(eval KEY_FILE := "$(shell mktemp)")
-	@printf '%b' '$(GITHUB_DEPLOY_KEY)' > $(KEY_FILE)
+	@echo "$(GITHUB_DEPLOY_KEY)" > $(KEY_FILE)
 	@git remote rm github-deploy || true
 	git remote add github-deploy $(GITHUB_REPO)
 	-@GIT_SSH_COMMAND="ssh -i $(KEY_FILE)" git fetch github-deploy $(CI_COMMIT_REF_NAME)
--- a/.makefiles/k8s.mk
+++ b/.makefiles/k8s.mk
@@ -13,7 +13,7 @@
 KUBE_CA_TEMP=false
 ifndef KUBE_CA_PEM_FILE
 KUBE_CA_PEM_FILE:=$$PWD/.ca.crt
-CREATED:=$(shell printf '%b\n' '$(KUBE_CA_BUNDLE)' > $(KUBE_CA_PEM_FILE))
+CREATED:=$(shell echo -e "$(KUBE_CA_BUNDLE)" > $(KUBE_CA_PEM_FILE))
 endif 
 KUBE_TOKEN?=""
 KUBE_NAMESPACE?=$(NAME)
--- a/.makefiles/python.mk
+++ b/.makefiles/python.mk
@@ -26,7 +26,6 @@ Dockerfile-%: Dockerfile.template  ## Generate a specific dockerfile (e.g. Docke
 quick_build: $(addprefix build-, $(PYMAIN))

 build: $(addprefix build-, $(PYVERSIONS)) ## Build all images / python versions
-	docker tag $(IMAGEWTAG)-python$(PYMAIN) $(IMAGEWTAG)

 build-%: version Dockerfile-%  ## Build a specific version (e.g. build-2.7)
 	docker build -t '$(IMAGEWTAG)-python$*' -f Dockerfile-$* .;
@@ -76,9 +75,8 @@ pip_upload: pip_test  ## Upload package to pip

 push-latest: $(addprefix push-latest-,$(PYVERSIONS)) ## Push the "latest" tag to dockerhub
 	docker tag '$(IMAGEWTAG)-python$(PYMAIN)' '$(IMAGEWTAG)'
-	docker tag '$(IMAGEWTAG)-python$(PYMAIN)' '$(IMAGENAME):latest'
+	docker tag '$(IMAGEWTAG)-python$(PYMAIN)' '$(IMAGENAME)'
 	docker push '$(IMAGENAME):latest'
-	docker push '$(IMAGEWTAG)'

 push-latest-%: build-%  ## Push the latest image for a specific python version
 	docker tag $(IMAGENAME):$(VERSION)-python$* $(IMAGENAME):python$*
--- a/docker-compose.dev.yml
+++ b/docker-compose.dev.yml
@@ -1,10 +0,0 @@
-version: '3'
-services:
-    senpy:
-        image: "${IMAGENAME-gsiupm/senpy}:${VERSION-latest}"
-        entrypoint: ["/bin/bash"]
-        working_dir: "/senpy-plugins"
-        ports:
-            - 5000:5000
-        volumes:
-            - ".:/usr/src/app/"
--- a/docker-compose.test.yml
+++ b/docker-compose.test.yml
@@ -1,9 +0,0 @@
-version: '3'
-services:
-    test:
-        image: "${IMAGENAME-gsiupm/senpy}:${VERSION-dev}"
-        entrypoint: ["py.test"]
-        volumes:
-            - ".:/usr/src/app/"
-        command:
-          []
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -1,11 +0,0 @@
-version: '3'
-services:
-    senpy:
-        image: "${IMAGENAME-gsiupm/senpy}:${VERSION-dev}"
-        build:
-          context: .
-          dockerfile: Dockerfile${PYVERSION--2.7}
-        ports:
-            - 5001:5000
-        volumes:
-            - "./data:/data"
--- a/example-plugins/configurable_plugin.py
+++ b/example-plugins/configurable_plugin.py
@@ -43,6 +43,7 @@ class Dictionary(plugins.SentimentPlugin):

 class EmojiOnly(Dictionary):
    '''Sentiment annotation with a basic lexicon of emojis'''
+    description = 'A plugin'
    dictionaries = [basic.emojis]

    test_cases = [{
--- a/requirements.txt
+++ b/requirements.txt
@@ -12,4 +12,3 @@ rdflib-jsonld
 numpy
 scipy
 scikit-learn
-responses
--- a/senpy/main.py
+++ b/senpy/main.py
@@ -78,15 +78,10 @@ def main():
        help='Do not run a server, only install plugin dependencies')
    parser.add_argument(
        '--only-test',
-        action='store_true',
-        default=False,
-        help='Do not run a server, just test all plugins')
-    parser.add_argument(
-        '--test',
        '-t',
        action='store_true',
        default=False,
-        help='Test all plugins before launching the server')
+        help='Do not run a server, just test all plugins')
    parser.add_argument(
        '--only-list',
        '--list',
@@ -104,24 +99,12 @@ def main():
        action='store_false',
        default=True,
        help='Run a threaded server')
-    parser.add_argument(
-        '--no-deps',
-        '-n',
-        action='store_true',
-        default=False,
-        help='Skip installing dependencies')
    parser.add_argument(
        '--version',
        '-v',
        action='store_true',
        default=False,
        help='Output the senpy version and exit')
-    parser.add_argument(
-        '--allow-fail',
-        '--fail',
-        action='store_true',
-        default=False,
-        help='Do not exit if some plugins fail to activate')
    args = parser.parse_args()
    if args.version:
        print('Senpy version {}'.format(senpy.__version__))
@@ -136,27 +119,19 @@ def main():
               data_folder=args.data_folder)
    if args.only_list:
        plugins = sp.plugins()
-        maxname = max(len(x.name) for x in plugins)
-        maxversion = max(len(x.version) for x in plugins)
-        print('Found {} plugins:'.format(len(plugins)))
+        maxwidth = max(len(x.id) for x in plugins)
        for plugin in plugins:
            import inspect
            fpath = inspect.getfile(plugin.__class__)
-            print('\t{: <{maxname}} @ {: <{maxversion}} -> {}'.format(plugin.name,
-                                                                      plugin.version,
-                                                                      fpath,
-                                                                      maxname=maxname,
-                                                                      maxversion=maxversion))
+            print('{: <{width}} @ {}'.format(plugin.id, fpath, width=maxwidth))
        return
-    if not args.no_deps:
-        sp.install_deps()
+    sp.install_deps()
    if args.only_install:
        return
-    sp.activate_all(allow_fail=args.allow_fail)
-    if args.test or args.only_test:
-        easy_test(sp.plugins(), debug=args.debug)
-        if args.only_test:
-            return
+    sp.activate_all()
+    if args.only_test:
+        easy_test(sp.plugins())
+        return
    print('Senpy version {}'.format(senpy.__version__))
    print('Server running on port %s:%d. Ctrl+C to quit' % (args.host,
                                                            args.port))
--- a/senpy/api.py
+++ b/senpy/api.py
@@ -3,10 +3,6 @@ from .models import Error, Results, Entry, from_string
 import logging
 logger = logging.getLogger(__name__)

-
-boolean = [True, False]
-
-
 API_PARAMS = {
    "algorithm": {
        "aliases": ["algorithms", "a", "algo"],
@@ -17,14 +13,14 @@ API_PARAMS = {
    "expanded-jsonld": {
        "@id": "expanded-jsonld",
        "aliases": ["expanded"],
-        "options": boolean,
+        "options": "boolean",
        "required": True,
        "default": False
    },
    "with_parameters": {
        "aliases": ['withparameters',
                    'with-parameters'],
-        "options": boolean,
+        "options": "boolean",
        "default": False,
        "required": True
    },
@@ -33,14 +29,14 @@ API_PARAMS = {
        "aliases": ["o"],
        "default": "json-ld",
        "required": True,
-        "options": ["json-ld", "turtle", "ntriples"],
+        "options": ["json-ld", "turtle"],
    },
    "help": {
        "@id": "help",
        "description": "Show additional help to know more about the possible parameters",
        "aliases": ["h"],
        "required": True,
-        "options": boolean,
+        "options": "boolean",
        "default": False
    },
    "emotionModel": {
@@ -87,7 +83,7 @@ WEB_PARAMS = {
        "aliases": ["headers"],
        "required": True,
        "default": False,
-        "options": boolean
+        "options": "boolean"
    },
 }

@@ -136,7 +132,7 @@ NIF_PARAMS = {
        "aliases": ["u"],
        "required": False,
        "default": "RFC5147String",
-        "options": ["RFC5147String", ]
+        "options": "RFC5147String"
    }
 }

@@ -163,7 +159,7 @@ def parse_params(indict, *specs):
                    wrong_params[param] = spec[param]
                continue
            if "options" in options:
-                if options["options"] == boolean:
+                if options["options"] == "boolean":
                    outdict[param] = outdict[param] in [None, True, 'true', '1']
                elif outdict[param] not in options["options"]:
                    wrong_params[param] = spec[param]
@@ -176,7 +172,7 @@ def parse_params(indict, *specs):
            errors=wrong_params)
        raise message
    if 'algorithm' in outdict and not isinstance(outdict['algorithm'], list):
-        outdict['algorithm'] = list(outdict['algorithm'].split(','))
+        outdict['algorithm'] = outdict['algorithm'].split(',')
    return outdict


@@ -194,8 +190,7 @@ def parse_call(params):
    params = parse_params(params, NIF_PARAMS)
    if params['informat'] == 'text':
        results = Results()
-        entry = Entry(nif__isString=params['input'],
-                      id='#')  # Use @base
+        entry = Entry(nif__isString=params['input'])
        results.entries.append(entry)
    elif params['informat'] == 'json-ld':
        results = from_string(params['input'], cls=Results)
--- a/senpy/blueprints.py
+++ b/senpy/blueprints.py
@@ -18,15 +18,15 @@
 Blueprints for Senpy
 """
 from flask import (Blueprint, request, current_app, render_template, url_for,
-                   jsonify, redirect)
+                   jsonify)
 from .models import Error, Response, Help, Plugins, read_schema, dump_schema, Datasets
 from . import api
 from .version import __version__
 from functools import wraps

 import logging
+import traceback
 import json
-import base64

 logger = logging.getLogger(__name__)

@@ -34,24 +34,6 @@ api_blueprint = Blueprint("api", __name__)
 demo_blueprint = Blueprint("demo", __name__, template_folder='templates')
 ns_blueprint = Blueprint("ns", __name__)

-_mimetypes_r = {'json-ld': ['application/ld+json'],
-                'turtle': ['text/turtle'],
-                'ntriples': ['application/n-triples'],
-                'text': ['text/plain']}
-
-MIMETYPES = {}
-
-for k, vs in _mimetypes_r.items():
-    for v in vs:
-        if v in MIMETYPES:
-            raise Exception('MIMETYPE {} specified for two formats: {} and {}'.format(v,
-                                                                                      v,
-                                                                                      MIMETYPES[v]))
-        MIMETYPES[v] = k
-
-DEFAULT_MIMETYPE = 'application/ld+json'
-DEFAULT_FORMAT = 'json-ld'
-

 def get_params(req):
    if req.method == 'POST':
@@ -63,60 +45,22 @@ def get_params(req):
    return indict


-def encoded_url(url=None, base=None):
-    code = ''
-    if not url:
-        if request.method == 'GET':
-            url = request.full_path[1:]  # Remove the first slash
-        else:
-            hash(frozenset(request.form.params().items()))
-            code = 'hash:{}'.format(hash)
-
-    code = code or base64.urlsafe_b64encode(url.encode()).decode()
-
-    if base:
-        return base + code
-    return url_for('api.decode', code=code, _external=True)
-
-
-def decoded_url(code, base=None):
-    if code.startswith('hash:'):
-        raise Exception('Can not decode a URL for a POST request')
-    base = base or request.url_root
-    path = base64.urlsafe_b64decode(code.encode()).decode()
-    return base + path
-
-
@demo_blueprint.route('/')
 def index():
-    ev = str(get_params(request).get('evaluation', False))
-    evaluation_enabled = ev.lower() not in ['false', 'no', 'none']
-
-    return render_template("index.html",
-                           evaluation=evaluation_enabled,
-                           version=__version__)
+    return render_template("index.html", version=__version__)


@api_blueprint.route('/contexts/<entity>.jsonld')
 def context(entity="context"):
    context = Response._context
    context['@vocab'] = url_for('ns.index', _external=True)
-    context['endpoint'] = url_for('api.api_root', _external=True)
    return jsonify({"@context": context})


-@api_blueprint.route('/d/<code>')
-def decode(code):
-    try:
-        return redirect(decoded_url(code))
-    except Exception:
-        return Error('invalid URL').flask()
-
-
@ns_blueprint.route('/')  # noqa: F811
 def index():
-    context = Response._context.copy()
-    context['endpoint'] = url_for('api.api_root', _external=True)
+    context = Response._context
+    context['@vocab'] = url_for('.ns', _external=True)
    return jsonify({"@context": context})


@@ -132,7 +76,7 @@ def basic_api(f):
    default_params = {
        'inHeaders': False,
        'expanded-jsonld': False,
-        'outformat': None,
+        'outformat': 'json-ld',
        'with_parameters': True,
    }

@@ -151,34 +95,29 @@ def basic_api(f):
                request.parameters = params
            response = f(*args, **kwargs)
        except (Exception) as ex:
-            if current_app.debug or current_app.config['TESTING']:
+            if current_app.debug:
                raise
            if not isinstance(ex, Error):
-                msg = "{}".format(ex)
+                msg = "{}:\n\t{}".format(ex,
+                                         traceback.format_exc())
                ex = Error(message=msg, status=500)
+            logger.exception('Error returning analysis result')
            response = ex
            response.parameters = raw_params
-            logger.exception(ex)
+            logger.error(ex)

        if 'parameters' in response and not params['with_parameters']:
            del response.parameters

        logger.info('Response: {}'.format(response))
-        mime = request.accept_mimetypes\
-                      .best_match(MIMETYPES.keys(),
-                                  DEFAULT_MIMETYPE)
-
-        mimeformat = MIMETYPES.get(mime, DEFAULT_FORMAT)
-        outformat = params['outformat'] or mimeformat
-
        return response.flask(
            in_headers=params['inHeaders'],
            headers=headers,
-            prefix=params.get('prefix', encoded_url()),
+            prefix=url_for('.api_root', _external=True),
            context_uri=url_for('api.context',
                                entity=type(response).__name__,
                                _external=True),
-            outformat=outformat,
+            outformat=params['outformat'],
            expanded=params['expanded-jsonld'])

    return decorated_function
--- a/senpy/client.py
+++ b/senpy/client.py
@@ -13,7 +13,7 @@ class Client(object):
        return self.request('/', method=method, input=input, **kwargs)

    def evaluate(self, input, method='GET', **kwargs):
-        return self.request('/evaluate', method=method, input=input, **kwargs)
+        return self.request('/evaluate', method = method, input=input, **kwargs)

    def plugins(self, *args, **kwargs):
        resp = self.request(path='/plugins').plugins
@@ -24,7 +24,7 @@ class Client(object):
        return {d.name: d for d in resp}

    def request(self, path=None, method='GET', **params):
-        url = '{}{}'.format(self.endpoint.rstrip('/'), path)
+        url = '{}{}'.format(self.endpoint, path)
        response = requests.request(method=method, url=url, params=params)
        try:
            resp = models.from_dict(response.json())
--- a/senpy/extensions.py
+++ b/senpy/extensions.py
@@ -18,10 +18,15 @@ import errno
 import logging


-from . import gsitk_compat
-
 logger = logging.getLogger(__name__)

+try:
+    from gsitk.datasets.datasets import DatasetManager
+    GSITK_AVAILABLE = True
+except ImportError:
+    logger.warn('GSITK is not installed. Some functions will be unavailable.')
+    GSITK_AVAILABLE = False
+

 class Senpy(object):
    """ Default Senpy extension for Flask """
@@ -90,7 +95,7 @@ class Senpy(object):
        if plugin in self._plugins:
            return self._plugins[plugin]

-        results = self.plugins(id='endpoint:plugins/{}'.format(name))
+        results = self.plugins(id='plugins/{}'.format(name))

        if not results:
            return Error(message="Plugin not found", status=404)
@@ -162,7 +167,8 @@ class Senpy(object):
            yield i

    def install_deps(self):
-        plugins.install_deps(*self.plugins())
+        for plugin in self.plugins(is_activated=True):
+            plugins.install_deps(plugin)

    def analyse(self, request):
        """
@@ -197,14 +203,16 @@ class Senpy(object):
                raise Error(
                    status=404,
                    message="The dataset '{}' is not valid".format(dataset))
-        dm = gsitk_compat.DatasetManager()
+        dm = DatasetManager()
        datasets = dm.prepare_datasets(datasets_name)
        return datasets

    @property
    def datasets(self):
+        if not GSITK_AVAILABLE:
+            raise Exception('GSITK is not available. Install it to use this function.')
        self._dataset_list = {}
-        dm = gsitk_compat.DatasetManager()
+        dm = DatasetManager()
        for item in dm.get_datasets():
            for key in item:
                if key in self._dataset_list:
@@ -215,6 +223,8 @@ class Senpy(object):
        return self._dataset_list

    def evaluate(self, params):
+        if not GSITK_AVAILABLE:
+            raise Exception('GSITK is not available. Install it to use this function.')
        logger.debug("evaluating request: {}".format(params))
        results = AggregatedEvaluation()
        results.parameters = params
@@ -308,15 +318,10 @@ class Senpy(object):
        else:
            self._default = self._plugins[value.lower()]

-    def activate_all(self, sync=True, allow_fail=False):
+    def activate_all(self, sync=True):
        ps = []
        for plug in self._plugins.keys():
-            try:
-                self.activate_plugin(plug, sync=sync)
-            except Exception as ex:
-                if not allow_fail:
-                    raise
-                logger.error('Could not activate {}: {}'.format(plug, ex))
+            ps.append(self.activate_plugin(plug, sync=sync))
        return ps

    def deactivate_all(self, sync=True):
@@ -341,7 +346,6 @@ class Senpy(object):
            logger.info(msg)
            success = True
            self._set_active(plugin, success)
-        return success

    def activate_plugin(self, plugin_name, sync=True):
        plugin_name = plugin_name.lower()
@@ -353,7 +357,7 @@ class Senpy(object):
        logger.info("Activating plugin: {}".format(plugin.name))

        if sync or 'async' in plugin and not plugin.async:
-            return self._activate(plugin)
+            self._activate(plugin)
        else:
            th = Thread(target=partial(self._activate, plugin))
            th.start()
--- a/senpy/gsitk_compat.py
+++ b/senpy/gsitk_compat.py
@@ -1,23 +0,0 @@
-import logging
-
-logger = logging.getLogger(__name__)
-
-MSG = 'GSITK is not (properly) installed.'
-IMPORTMSG = '{} Some functions will be unavailable.'.format(MSG)
-RUNMSG = '{} Install it to use this function.'.format(MSG)
-
-
-def raise_exception(*args, **kwargs):
-    raise Exception(RUNMSG)
-
-
-try:
-    from gsitk.datasets.datasets import DatasetManager
-    from gsitk.evaluation.evaluation import Evaluation as Eval
-    from sklearn.pipeline import Pipeline
-    GSITK_AVAILABLE = True
-    modules = locals()
-except ImportError:
-    logger.warn(IMPORTMSG)
-    GSITK_AVAILABLE = False
-    DatasetManager = Eval = Pipeline = raise_exception
--- a/senpy/models.py
+++ b/senpy/models.py
@@ -138,7 +138,7 @@ class BaseModel(with_metaclass(BaseMeta, CustomDict)):
    @property
    def id(self):
        if '@id' not in self:
-            self['@id'] = '_:{}_{}'.format(type(self).__name__, time.time())
+            self['@id'] = ':{}_{}'.format(type(self).__name__, time.time())
        return self['@id']

    @id.setter
@@ -146,7 +146,7 @@ class BaseModel(with_metaclass(BaseMeta, CustomDict)):
        self['@id'] = value

    def flask(self,
-              in_headers=False,
+              in_headers=True,
              headers=None,
              outformat='json-ld',
              **kwargs):
@@ -176,22 +176,20 @@ class BaseModel(with_metaclass(BaseMeta, CustomDict)):

    def serialize(self, format='json-ld', with_mime=False, **kwargs):
        js = self.jsonld(**kwargs)
-        content = json.dumps(js, indent=2, sort_keys=True)
        if format == 'json-ld':
+            content = json.dumps(js, indent=2, sort_keys=True)
            mimetype = "application/json"
-        elif format in ['turtle', 'ntriples']:
+        elif format in ['turtle', ]:
            logger.debug(js)
-            base = kwargs.get('prefix')
+            content = json.dumps(js, indent=2, sort_keys=True)
            g = Graph().parse(
                data=content,
                format='json-ld',
-                base=base,
-                context=[self._context,
-                         {'@base': base}])
+                base=kwargs.get('prefix'),
+                context=self._context)
            logger.debug(
                'Parsing with prefix: {}'.format(kwargs.get('prefix')))
-            content = g.serialize(format=format,
-                                  base=base).decode('utf-8')
+            content = g.serialize(format='turtle').decode('utf-8')
            mimetype = 'text/{}'.format(format)
        else:
            raise Error('Unknown outformat: {}'.format(format))
@@ -205,23 +203,24 @@ class BaseModel(with_metaclass(BaseMeta, CustomDict)):
               context_uri=None,
               prefix=None,
               expanded=False):
+        ser = self.serializable()

-        result = self.serializable()
-
+        result = jsonld.compact(
+            ser,
+            self._context,
+            options={
+                'base': prefix,
+                'expandContext': self._context,
+                'senpy': prefix
+            })
+        if context_uri:
+            result['@context'] = context_uri
        if expanded:
            result = jsonld.expand(
                result, options={'base': prefix,
-                                 'expandContext': self._context})[0]
+                                 'expandContext': self._context})
        if not with_context:
-            try:
-                del result['@context']
-            except KeyError:
-                pass
-        elif context_uri:
-            result['@context'] = context_uri
-        else:
-            result['@context'] = self._context
-
+            del result['@context']
        return result

    def validate(self, obj=None):
@@ -324,10 +323,7 @@ def _add_class_from_schema(*args, **kwargs):


 for i in [
-        'aggregatedEvaluation',
        'analysis',
-        'dataset',
-        'datasets',
        'emotion',
        'emotionConversion',
        'emotionConversionPlugin',
@@ -335,17 +331,19 @@ for i in [
        'emotionModel',
        'emotionPlugin',
        'emotionSet',
-        'evaluation',
        'entity',
        'help',
-        'metric',
        'plugin',
        'plugins',
        'response',
        'results',
        'sentimentPlugin',
        'suggestion',
-        'topic',
+        'aggregatedEvaluation',
+        'evaluation',
+        'metric',
+        'dataset',
+        'datasets',

 ]:
    _add_class_from_schema(i)
--- a/senpy/plugins/init.py
+++ b/senpy/plugins/init.py
@@ -3,7 +3,6 @@ standard_library.install_aliases()


 from future.utils import with_metaclass
-from functools import partial

 import os.path
 import os
@@ -19,16 +18,21 @@ import subprocess
 import importlib
 import yaml
 import threading
-import nltk

 from .. import models, utils
 from .. import api
-from .. import gsitk_compat
-from .. import testing


 logger = logging.getLogger(__name__)

+try:
+    from gsitk.evaluation.evaluation import Evaluation as Eval
+    from sklearn.pipeline import Pipeline
+    GSITK_AVAILABLE = True
+except ImportError:
+    logger.warn('GSITK is not installed. Some functions will be unavailable.')
+    GSITK_AVAILABLE = False
+

 class PluginMeta(models.BaseMeta):
    _classes = {}
@@ -87,30 +91,10 @@ class Plugin(with_metaclass(PluginMeta, models.Plugin)):
        if info:
            self.update(info)
        self.validate()
-        self.id = 'endpoint:plugins/{}_{}'.format(self['name'], self['version'])
+        self.id = 'plugins/{}_{}'.format(self['name'], self['version'])
        self.is_activated = False
        self._lock = threading.Lock()
-        self._directory = os.path.abspath(os.path.dirname(inspect.getfile(self.__class__)))
-
-        data_folder = data_folder or os.getcwd()
-        subdir = os.path.join(data_folder, self.name)
-
-        self._data_paths = [
-            data_folder,
-            subdir,
-            self._directory,
-            os.path.join(self._directory, 'data'),
-        ]
-
-        if os.path.exists(subdir):
-            data_folder = subdir
-        self.data_folder = data_folder
-
-        self._log = logging.getLogger('{}.{}'.format(__name__, self.name))
-
-    @property
-    def log(self):
-        return self._log
+        self.data_folder = data_folder or os.getcwd()

    def validate(self):
        missing = []
@@ -139,28 +123,19 @@ class Plugin(with_metaclass(PluginMeta, models.Plugin)):
        for case in test_cases:
            try:
                self.test_case(case)
-                self.log.debug('Test case passed:\n{}'.format(pprint.pformat(case)))
+                logger.debug('Test case passed:\n{}'.format(pprint.pformat(case)))
            except Exception as ex:
-                self.log.warn('Test case failed:\n{}'.format(pprint.pformat(case)))
+                logger.warn('Test case failed:\n{}'.format(pprint.pformat(case)))
                raise

-    def test_case(self, case, mock=testing.MOCK_REQUESTS):
+    def test_case(self, case):
        entry = models.Entry(case['entry'])
        given_parameters = case.get('params', case.get('parameters', {}))
        expected = case.get('expected', None)
        should_fail = case.get('should_fail', False)
-        responses = case.get('responses', [])
-
        try:
            params = api.parse_params(given_parameters, self.extra_params)
-
-            method = partial(self.analyse_entries, [entry, ], params)
-
-            if mock:
-                res = list(method())
-            else:
-                with testing.patch_all_requests(responses):
-                    res = list(method())
+            res = list(self.analyse_entries([entry, ], params))

            if not isinstance(expected, list):
                expected = [expected]
@@ -173,22 +148,10 @@ class Plugin(with_metaclass(PluginMeta, models.Plugin)):
            raise
        assert not should_fail

-    def find_file(self, fname):
-        for p in self._data_paths:
-            alternative = os.path.join(p, fname)
-            if os.path.exists(alternative):
-                return alternative
-        raise IOError('File does not exist: {}'.format(fname))
-
-    def open(self, fpath, mode='r'):
-        if 'w' in mode:
-            # When writing, only use absolute paths or data_folder
-            if not os.path.isabs(fpath):
-                fpath = os.path.join(self.data_folder, fpath)
-        else:
-            fpath = self.find_file(fpath)
-
-        return open(fpath, mode=mode)
+    def open(self, fpath, *args, **kwargs):
+        if not os.path.isabs(fpath):
+            fpath = os.path.join(self.data_folder, fpath)
+        return open(fpath, *args, **kwargs)

    def serve(self, debug=True, **kwargs):
        utils.easy(plugin_list=[self, ], plugin_folder=None, debug=debug, **kwargs)
@@ -223,7 +186,7 @@ class Analysis(Plugin):

    def analyse_entries(self, entries, parameters):
        for entry in entries:
-            self.log.debug('Analysing entry with plugin {}: {}'.format(self, entry))
+            logger.debug('Analysing entry with plugin {}: {}'.format(self, entry))
            results = self.analyse_entry(entry, parameters)
            if inspect.isgenerator(results):
                for result in results:
@@ -336,7 +299,7 @@ class Box(AnalysisPlugin):
        return self.transform(X)

    def as_pipe(self):
-        pipe = gsitk_compat.Pipeline([('plugin', self)])
+        pipe = Pipeline([('plugin', self)])
        pipe.name = self.name
        return pipe

@@ -412,7 +375,7 @@ class ShelfMixin(object):
                    with self.open(self.shelf_file, 'rb') as p:
                        self._sh = pickle.load(p)
                except (IndexError, EOFError, pickle.UnpicklingError):
-                    self.log.warning('Corrupted shelf file: {}'.format(self.shelf_file))
+                    logger.warning('{} has a corrupted shelf file!'.format(self.id))
                    if not self.get('force_shelf', False):
                        raise
        return self._sh
@@ -439,31 +402,32 @@ class ShelfMixin(object):
        self._shelf_file = value

    def save(self):
-        self.log.debug('Saving pickle')
+        logger.debug('saving pickle')
        if hasattr(self, '_sh') and self._sh is not None:
            with self.open(self.shelf_file, 'wb') as f:
                pickle.dump(self._sh, f)


-def pfilter(plugins, plugin_type=Analysis, **kwargs):
+def pfilter(plugins, **kwargs):
    """ Filter plugins by different criteria """
    if isinstance(plugins, models.Plugins):
        plugins = plugins.plugins
    elif isinstance(plugins, dict):
        plugins = plugins.values()
+    ptype = kwargs.pop('plugin_type', Plugin)
    logger.debug('#' * 100)
-    logger.debug('plugin_type {}'.format(plugin_type))
-    if plugin_type:
-        if isinstance(plugin_type, PluginMeta):
-            plugin_type = plugin_type.__name__
+    logger.debug('ptype {}'.format(ptype))
+    if ptype:
+        if isinstance(ptype, PluginMeta):
+            ptype = ptype.__name__
        try:
-            plugin_type = plugin_type[0].upper() + plugin_type[1:]
-            pclass = globals()[plugin_type]
+            ptype = ptype[0].upper() + ptype[1:]
+            pclass = globals()[ptype]
            logger.debug('Class: {}'.format(pclass))
            candidates = filter(lambda x: isinstance(x, pclass),
                                plugins)
        except KeyError:
-            raise models.Error('{} is not a valid type'.format(plugin_type))
+            raise models.Error('{} is not a valid type'.format(ptype))
    else:
        candidates = plugins

@@ -498,7 +462,6 @@ def _log_subprocess_output(process):

 def install_deps(*plugins):
    installed = False
-    nltk_resources = set()
    for info in plugins:
        requirements = info.get('requirements', [])
        if requirements:
@@ -513,10 +476,7 @@ def install_deps(*plugins):
            exitcode = process.wait()
            installed = True
            if exitcode != 0:
-                raise models.Error("Dependencies not properly installed: {}".format(pip_args))
-        nltk_resources |= set(info.get('nltk_resources', []))
-
-    installed |= nltk.download(list(nltk_resources))
+                raise models.Error("Dependencies not properly installed")
    return installed


@@ -534,7 +494,7 @@ def find_plugins(folders):
                yield fpath


-def from_path(fpath, install_on_fail=False, **kwargs):
+def from_path(fpath, **kwargs):
    logger.debug("Loading plugin from {}".format(fpath))
    if fpath.endswith('.py'):
        # We asume root is the dir of the file, and module is the name of the file
@@ -544,7 +504,7 @@ def from_path(fpath, install_on_fail=False, **kwargs):
            yield instance
    else:
        info = parse_plugin_info(fpath)
-        yield from_info(info, install_on_fail=install_on_fail, **kwargs)
+        yield from_info(info, **kwargs)


 def from_folder(folders, loader=from_path, **kwargs):
@@ -555,7 +515,7 @@ def from_folder(folders, loader=from_path, **kwargs):
    return plugins


-def from_info(info, root=None, install_on_fail=True, **kwargs):
+def from_info(info, root=None, **kwargs):
    if any(x not in info for x in ('module',)):
        raise ValueError('Plugin info is not valid: {}'.format(info))
    module = info["module"]
@@ -563,12 +523,7 @@ def from_info(info, root=None, install_on_fail=True, **kwargs):
    if not root and '_path' in info:
        root = os.path.dirname(info['_path'])

-    fun = partial(one_from_module, module, root=root, info=info, **kwargs)
-    try:
-        return fun()
-    except (ImportError, LookupError):
-        install_deps(info)
-        return fun()
+    return one_from_module(module, root=root, info=info, **kwargs)


 def parse_plugin_info(fpath):
@@ -615,8 +570,14 @@ def _instances_in_module(module):
            yield obj


-def _from_module_name(module, root, info=None, **kwargs):
-    module = load_module(module, root)
+def _from_module_name(module, root, info=None, install=True, **kwargs):
+    try:
+        module = load_module(module, root)
+    except ImportError:
+        if not install or not info:
+            raise
+        install_deps(info)
+        module = load_module(module, root)
    for plugin in _from_loaded_module(module=module, root=root, info=info, **kwargs):
        yield plugin

@@ -629,9 +590,12 @@ def _from_loaded_module(module, info=None, **kwargs):


 def evaluate(plugins, datasets, **kwargs):
-    ev = gsitk_compat.Eval(tuples=None,
-                           datasets=datasets,
-                           pipelines=[plugin.as_pipe() for plugin in plugins])
+    if not GSITK_AVAILABLE:
+        raise Exception('GSITK is not available. Install it to use this function.')
+
+    ev = Eval(tuples=None,
+              datasets=datasets,
+              pipelines=[plugin.as_pipe() for plugin in plugins])
    ev.evaluate()
    results = ev.results
    evaluations = evaluations_to_JSONLD(results, **kwargs)
--- a/senpy/plugins/misc/split_plugin.py
+++ b/senpy/plugins/misc/split_plugin.py
@@ -5,27 +5,13 @@ from nltk.tokenize.simple import LineTokenizer
 import nltk


-class Split(AnalysisPlugin):
+class SplitPlugin(AnalysisPlugin):
    '''description: A sample plugin that chunks input text'''

-    author = ["@militarpancho", '@balkian']
-    version = '0.2'
-    url = "https://github.com/gsi-upm/senpy"
-
-    extra_params = {
-        'delimiter': {
-            'aliases': ['type', 't'],
-            'required': False,
-            'default': 'sentence',
-            'options': ['sentence', 'paragraph']
-        },
-    }
-
    def activate(self):
        nltk.download('punkt')

    def analyse_entry(self, entry, params):
-        yield entry
        chunker_type = params["delimiter"]
        original_text = entry['nif:isString']
        if chunker_type == "sentence":
--- a/senpy/plugins/misc/split.senpy
+++ b/senpy/plugins/misc/split.senpy
@@ -0,0 +1,19 @@
+---
+name: split
+module: senpy.plugins.misc.split
+description: A sample plugin that chunks input text
+author: "@militarpancho"
+version: '0.2'
+url: "https://github.com/gsi-upm/senpy"
+requirements:
+    - nltk
+extra_params:
+  delimiter:
+    aliases:
+    - type
+    - t
+    required: false
+    default: sentence
+    options:
+    - sentence
+    - paragraph
--- a/senpy/plugins/sentiment/sentiment140/sentiment140_plugin.py
+++ b/senpy/plugins/sentiment/sentiment140/sentiment140_plugin.py
@@ -4,31 +4,12 @@ import json
 from senpy.plugins import SentimentPlugin
 from senpy.models import Sentiment

-ENDPOINT = 'http://www.sentiment140.com/api/bulkClassifyJson'

-
-class Sentiment140(SentimentPlugin):
+class Sentiment140Plugin(SentimentPlugin):
    '''Connects to the sentiment140 free API: http://sentiment140.com'''
-
-    author = "@balkian"
-    version = '0.2'
-    url = "https://github.com/gsi-upm/senpy-plugins-community"
-    extra_params = {
-        'language': {
-            "@id": 'lang_sentiment140',
-            'aliases': ['language', 'l'],
-            'required': False,
-            'default': 'auto',
-            'options': ['es', 'en', 'auto']
-        }
-    }
-
-    maxPolarityValue = 1
-    minPolarityValue = 0
-
    def analyse_entry(self, entry, params):
        lang = params["language"]
-        res = requests.post(ENDPOINT,
+        res = requests.post("http://www.sentiment140.com/api/bulkClassifyJson",
                            json.dumps({
                                "language": lang,
                                "data": [{
@@ -50,10 +31,23 @@ class Sentiment140(SentimentPlugin):
            marl__hasPolarity=polarity,
            marl__polarityValue=polarity_value)
        sentiment.prov__wasGeneratedBy = self.id
+        entry.sentiments = []
        entry.sentiments.append(sentiment)
        entry.language = lang
        yield entry

+    def test(self, *args, **kwargs):
+        '''
+        To avoid calling the sentiment140 API, we will mock the results
+        from requests.
+        '''
+        from senpy.test import patch_requests
+        expected = {"data": [{"polarity": 4}]}
+        with patch_requests(expected) as (request, response):
+            super(Sentiment140Plugin, self).test(*args, **kwargs)
+            assert request.called
+            assert response.json.called
+
    test_cases = [
        {
            'entry': {
@@ -67,9 +61,6 @@ class Sentiment140(SentimentPlugin):
                        'marl:hasPolarity': 'marl:Positive',
                    }
                ]
-            },
-            'responses': [{'url': ENDPOINT,
-                           'method': 'POST',
-                           'json': {'data': [{'polarity': 4}]}}]
+            }
        }
    ]
--- a/senpy/plugins/sentiment/sentiment140/sentiment140.senpy
+++ b/senpy/plugins/sentiment/sentiment140/sentiment140.senpy
@@ -0,0 +1,22 @@
+---
+name: sentiment140
+module: sentiment140
+description: "Connects to the sentiment140 free API: http://sentiment140.com"
+author: "@balkian"
+version: '0.2'
+url: "https://github.com/gsi-upm/senpy-plugins-community"
+extra_params:
+  language:
+    "@id": lang_sentiment140
+    aliases:
+    - language
+    - l
+    required: false
+    options:
+    - es
+    - en
+    - auto
+    default: auto
+requirements: {}
+maxPolarityValue: 1
+minPolarityValue: 0
--- a/senpy/schemas/context.jsonld
+++ b/senpy/schemas/context.jsonld
@@ -10,10 +10,8 @@
    "wna": "http://www.gsi.dit.upm.es/ontologies/wnaffect/ns#",
    "emoml": "http://www.gsi.dit.upm.es/ontologies/onyx/vocabularies/emotionml/ns#",
    "xsd": "http://www.w3.org/2001/XMLSchema#",
-    "fam": "http://vocab.fusepool.info/fam#",
    "topics": {
-      "@id": "nif:topic",
-      "@container": "@set"
+      "@id": "dc:subject"
    },
    "entities": {
      "@id": "me:hasEntities"
--- a/senpy/static/css/main.css
+++ b/senpy/static/css/main.css
@@ -167,36 +167,3 @@ textarea{
    color: inherit;
    text-decoration: inherit;
 }
-
-.collapsed .collapseicon {
-    display: none !important;
-}
-
-.collapsed .expandicon {
-    display: inline-block !important;
-}
-
-.expandicon {
-    display: none !important;
-}
-
-.collapseicon {
-    display: inline-block !important;
-}
-
-.loader {
-    border: 6px solid #f3f3f3; /* Light grey */
-    border-top: 6px solid blue;
-    border-bottom: 6px solid blue;
-
-    border-radius: 50%;
-    width: 3em;
-    height: 3em;
-    animation: spin 2s linear infinite;
-
-}
-
-@keyframes spin {
-    0% { transform: rotate(0deg); }
-    100% { transform: rotate(360deg); }
-}
--- a/senpy/static/js/main.js
+++ b/senpy/static/js/main.js
@@ -4,7 +4,6 @@ var plugins_params = default_params = {};
 var plugins = [];
 var defaultPlugin = {};
 var gplugins = {};
-var pipeline = [];

 function replaceURLWithHTMLLinks(text) {
    console.log('Text: ' + text);
@@ -31,10 +30,7 @@ function hashchanged(){


 function get_plugins(response){
-    for(ix in response.plugins){
-        plug = response.plugins[ix];
-        plugins[plug.name] = plug;
-    }
+    plugins = response.plugins;
 }

 function get_datasets(response){
@@ -87,32 +83,10 @@ function draw_plugins_selection(){
    html += "</optgroup>"
    // Two elements with plugin class
    // One from the evaluate tab and another one from the analyse tab
-    plugin_lists  = document.getElementsByClassName('plugin')
-    for (element in plugin_lists){
-        plugin_lists[element].innerHTML = html;
-    }
-    draw_plugin_pipeline();
+    document.getElementsByClassName('plugin')[0].innerHTML = html;
+    document.getElementsByClassName('plugin')[1].innerHTML = html;
 }

-function draw_plugin_pipeline(){
-    var pipeHTML = "";
-    console.log("Drawing pipeline: ", pipeline);
-    for (ix in pipeline){
-        plug = pipeline[ix];
-        pipeHTML += '<span onclick="remove_plugin_pipeline(\'' + plug + '\')" class="btn btn-primary"><span ><i class="fa fa-minus"></i></span> ' + plug + '</span> <i class="fa fa-arrow-right"></i> ';
-    }
-    console.log(pipeHTML);
-    $("#pipeline").html(pipeHTML);
-}
-
-
-function remove_plugin_pipeline(name){
-    console.log("Removing plugin: ", name);
-    var index = pipeline.indexOf(name);
-    pipeline.splice(index, 1);
-    draw_plugin_pipeline();
-
-}
 function draw_plugins_list(){
    var availablePlugins = document.getElementById('availablePlugins');

@@ -131,13 +105,6 @@ function draw_plugins_list(){
    }
 }

-function add_plugin_pipeline(){
-    var selected = get_selected_plugin();
-    pipeline.push(selected);
-    console.log("Adding ", selected);
-    draw_plugin_pipeline();
-}
-
 function draw_datasets(){
    html = "";
    repeated_html = "<input class=\"checks-datasets\" type=\"checkbox\" value=\"";
@@ -151,20 +118,16 @@ function draw_datasets(){
 $(document).ready(function() {
    var response = JSON.parse($.ajax({type: "GET", url: "/api/plugins/" , async: false}).responseText);
    defaultPlugin= JSON.parse($.ajax({type: "GET", url: "/api/plugins/default" , async: false}).responseText);
+    var response2 = JSON.parse($.ajax({type: "GET", url: "/api/datasets/" , async: false}).responseText);

    get_plugins(response);
    get_default_parameters();
+    get_datasets(response2);

    draw_plugins_list();
    draw_plugins_selection();
    draw_parameters();
-    draw_plugin_description();
-
-    if (evaluation_enabled) {
-        var response2 = JSON.parse($.ajax({type: "GET", url: "/api/datasets/" , async: false}).responseText);
-        get_datasets(response2);
-        draw_datasets();
-    }
+    draw_datasets();

    $(window).on('hashchange', hashchanged);
    hashchanged();
@@ -181,34 +144,17 @@ function get_default_parameters(){

 }

-function get_selected_plugin(){
-    return document.getElementsByClassName('plugin')[0].options[document.getElementsByClassName('plugin')[0].selectedIndex].value;
-}
-
 function draw_default_parameters(){
    var basic_params = document.getElementById("basic_params");
    basic_params.innerHTML = params_div(default_params);
 }

-function update_params(params, plug){
-    ep = plugins_params[plug];
-    for(k in ep){
-        params[k] = ep[k];
-    }
-    return params
-}
-
 function draw_extra_parameters(){
-    var plugin = get_selected_plugin();
+    var plugin = document.getElementsByClassName('plugin')[0].options[document.getElementsByClassName('plugin')[0].selectedIndex].value;
    get_parameters();

    var extra_params = document.getElementById("extra_params");
-    var params = {};
-    for (sel in pipeline){
-        update_params(params, pipeline[sel]);
-    }
-    update_params(params, plugin);
-    extra_params.innerHTML = params_div(params);
+    extra_params.innerHTML = params_div(plugins_params[plugin]);
 }

 function draw_parameters(){
@@ -315,15 +261,6 @@ function add_param(key, value){
    return "&"+key+"="+value;
 }

-function get_pipeline_arg(){
-    arg = "";
-    for (ix in pipeline){
-        arg = arg + pipeline[ix] + ",";
-    }
-    arg = arg + get_selected_plugin();
-    return arg;
-}
-

 function load_JSON(){
    url = "/api";
@@ -332,9 +269,7 @@ function load_JSON(){
    rawcontainer.innerHTML = '';
    container.innerHTML = '';

-    var plugin = get_pipeline_arg();
-    $(".loading").addClass("loader");
-    $("#preview").hide();
+    var plugin = document.getElementsByClassName("plugin")[0].options[document.getElementsByClassName("plugin")[0].selectedIndex].value;

    var input = encodeURIComponent(document.getElementById("input").value);
    url += "?algo="+plugin+"&i="+input
@@ -345,27 +280,27 @@ function load_JSON(){
        url += add_param(key, params[key]);
    }

-    $.ajax({type: "GET", url: url}).always(function(response){
-        document.getElementById("results-div").style.display = 'block';
-        if(typeof response=="object") {
-            var options = {
-                mode: 'view'
-            };
-            var editor = new JSONEditor(container, options, response);
-            editor.expandAll();
-            $('#results-div a[href="#viewer"]').click();
-            response = JSON.stringify(response, null, 4);
-        } else {
-            console.log("Got turtle?");
-            $('#results-div a[href="#raw"]').click();
-        }
+    var response =  $.ajax({type: "GET", url: url , async: false}).responseText;
+    rawcontainer.innerHTML = replaceURLWithHTMLLinks(response);

-        rawcontainer.innerHTML = replaceURLWithHTMLLinks(response);
-        document.getElementById("input_request").innerHTML = "<a href='"+url+"'>"+url+"</a>"
-
-        $(".loading").removeClass("loader");
-        $("#preview").show();
-    });
+    document.getElementById("input_request").innerHTML = "<a href='"+url+"'>"+url+"</a>"
+    document.getElementById("results-div").style.display = 'block';
+    try {
+        response = JSON.parse(response);
+        var options = {
+            mode: 'view'
+        };
+        var editor = new JSONEditor(container, options, response);
+        editor.expandAll();
+        // $('#results-div a[href="#viewer"]').tab('show');
+        $('#results-div a[href="#viewer"]').click();
+        // location.hash = 'raw';
+    }
+    catch(err){
+        console.log("Error decoding JSON (got turtle?)");
+        $('#results-div a[href="#raw"]').click();
+        // location.hash = 'raw';
+    }
 }

 function get_datasets_from_checkbox(){
@@ -412,53 +347,40 @@ function evaluate_JSON(){

    url += "?algo="+plugin+"&dataset="+datasets

-    $('#doevaluate').attr("disabled", true);
-    $.ajax({type: "GET", url: url, dataType: 'json'}).always(function(resp) {
-        $('#doevaluate').attr("disabled", false);
-        response = resp.responseText;  
-
-        rawcontainer.innerHTML = replaceURLWithHTMLLinks(response);
-
-        document.getElementById("input_request_eval").innerHTML = "<a href='"+url+"'>"+url+"</a>"
-        document.getElementById("evaluate-div").style.display = 'block';
-
-        try {
-            response = JSON.parse(response);
-            var options = {
-                mode: 'view'
-            };
-
-            //Control the single response results
-            if (!(Array.isArray(response.evaluations))){
-                response.evaluations = [response.evaluations]
-            }
-
-            new_tbody = create_body_metrics(response.evaluations)
-            table.replaceChild(new_tbody, table.lastElementChild)
-
-            var editor = new JSONEditor(container, options, response);
-            editor.expandAll();
-            // $('#results-div a[href="#viewer"]').tab('show');
-            $('#evaluate-div a[href="#evaluate-table"]').click();
-            // location.hash = 'raw';
+    var response =  $.ajax({type: "GET", url: url , async: false, dataType: 'json'}).responseText;
+    rawcontainer.innerHTML = replaceURLWithHTMLLinks(response);

+    document.getElementById("input_request_eval").innerHTML = "<a href='"+url+"'>"+url+"</a>"
+    document.getElementById("evaluate-div").style.display = 'block';
+    
+    try {
+        response = JSON.parse(response);
+        var options = {
+            mode: 'view'
+        };

+        //Control the single response results
+        if (!(Array.isArray(response.evaluations))){
+            response.evaluations = [response.evaluations]
        }
-        catch(err){
-            console.log("Error decoding JSON (got turtle?)");
-            $('#evaluate-div a[href="#evaluate-raw"]').click();
-            // location.hash = 'raw';
-        }
-    })
-}

-function draw_plugin_description(){
-    var plugin = plugins[get_selected_plugin()];
-    $("#plugdescription").text(plugin.description);
-    console.log(plugin);
-}
+        new_tbody = create_body_metrics(response.evaluations)
+        table.replaceChild(new_tbody, table.lastElementChild)

-function plugin_selected(){
-    draw_extra_parameters();
-    draw_plugin_description();
-}
+        var editor = new JSONEditor(container, options, response);
+        editor.expandAll();
+        // $('#results-div a[href="#viewer"]').tab('show');
+        $('#evaluate-div a[href="#evaluate-table"]').click();
+        // location.hash = 'raw';
+        
+        
+    }
+    catch(err){
+        console.log("Error decoding JSON (got turtle?)");
+        $('#evaluate-div a[href="#evaluate-raw"]').click();
+        // location.hash = 'raw';
+    }
+
+    
+
+}
--- a/senpy/templates/index.html
+++ b/senpy/templates/index.html
@@ -5,9 +5,6 @@
    <title>Playground {{version}}</title>

  </head>
-  <script>
-   this.evaluation_enabled = {% if evaluation %}true{%else %}false{%endif%};
-  </script>
  <script src="static/js/jquery-2.1.1.min.js" ></script>
  <!--<script src="jquery.autosize.min.js"></script>-->
  <link rel="stylesheet" href="static/css/bootstrap.min.css">
@@ -35,9 +32,7 @@
      <ul class="nav nav-tabs" role="tablist">
        <li role="presentation" ><a class="active" href="#about">About</a></li>
        <li role="presentation"class="active"><a class="active" href="#test">Test it</a></li>
-        {% if evaluation %}
        <li role="presentation"><a class="active" href="#evaluate">Evaluate Plugins</a></li>
-        {% endif %}

      </ul>

@@ -66,14 +61,6 @@
                    </ul>

                  </p>
-                  <p>Senpy is a research project. If you use it in your research, please cite:
-                  <pre>
-Senpy: A Pragmatic Linked Sentiment Analysis Framework.
-Sánchez-Rada, J. F., Iglesias, C. A., Corcuera, I., & Araque, Ó.
-In Data Science and Advanced Analytics (DSAA),
-2016 IEEE International Conference on (pp. 735-742). IEEE.
-                  </pre>
-                  </p>
                  
                </div>
            <div class="col-lg-6 ">
@@ -83,6 +70,8 @@ In Data Science and Advanced Analytics (DSAA),
                </div>
                <div class="panel-body"><ul id=availablePlugins></ul></div>
              </div>
+            </div>
+            <div class="col-lg-6 ">
              <a href="http://senpy.readthedocs.io">
              <div class="panel panel-default">
                <div class="panel-heading"><i class="fa fa-book"></i> If you are new to senpy, you might want to read senpy's documentation</div>
@@ -93,6 +82,9 @@ In Data Science and Advanced Analytics (DSAA),
                <div class="panel-heading"><i class="fa fa-sign-in"></i> Feel free to follow us on GitHub</div>
              </div>
              </a>
+              <div class="panel panel-default">
+                <div class="panel-heading"><i class="fa fa-child"></i> Enjoy.</div>
+              </div>
            </div>     
          </div>
        </div>
@@ -104,28 +96,17 @@ In Data Science and Advanced Analytics (DSAA),
 whilst this text makes me happy and surprised at the same time.
 I cannot believe it!</textarea>
                </div>
+                <div>
+                    <label>Select the plugin:</label>
+                    <select id="plugins" name="plugins" class=plugin onchange="draw_extra_parameters()">
+                    </select>
+                </div>
                <!-- PARAMETERS -->
                <div class="panel-group" id="parameters">
                    <div class="panel panel-default">
-                        <div class="panel-heading">
-                            <h4 class="panel-title">
-                                Select the plugin.
-                            </h4>
-                        </div>
-                        <div id="plugin_selection" class="panel-collapse panel-body">
-                            <span id="pipeline"></span>
-                            <select name="plugins" class="plugin" onchange="plugin_selected()">
-                            </select>
-                            <span onclick="add_plugin_pipeline()"><span class="btn"><i class="fa fa-plus" title="Add more plugins to the pipeline. Processing order is left to right. i.e. the results of the leftmost plugin will be used as input for the second leftmost, and so on."></i></span></span>
-                            <label class="help-block " id="plugdescription"></label>
-                        </div>
-                    </div>
-                    <div class="panel panel-default">
-                        <a data-toggle="collapse" class="deco-none collapsed" href="#basic_params">
+                        <a data-toggle="collapse" class="deco-none" href="#basic_params">
                            <div class="panel-heading">
                                <h4 class="panel-title">
-                                    <i class="fa fa-chevron-right pull-left expandicon"></i>
-                                    <i class="fa fa-chevron-down pull-left collapseicon"></i>
                                    Basic API parameters
                                </h4>
                            </div>
@@ -137,8 +118,6 @@ I cannot believe it!</textarea>
                        <a data-toggle="collapse" class="deco-none" href="#extra_params">
                            <div class="panel-heading">
                                <h4 class="panel-title">
-                                    <i class="fa fa-chevron-right pull-left expandicon"></i>
-                                    <i class="fa fa-chevron-down pull-left collapseicon"></i>
                                    Plugin extra parameters
                                </h4>
                            </div>
@@ -150,7 +129,6 @@ I cannot believe it!</textarea>
                <!-- END PARAMETERS -->
 
                <a id="preview" class="btn btn-lg btn-primary" onclick="load_JSON()">Analyse!</a>
-                <div id="loading-results" class="loading"></div>
                <!--<button id="visualise" name="type" type="button">Visualise!</button>-->
            </form>
          </div>
@@ -177,8 +155,6 @@ I cannot believe it!</textarea>
            </div>
        </div>

-        {% if evaluation %}
-
        <div class="tab-pane" id="evaluate">
          <div class="well">
            <form id="form" class="container" onsubmit="return getPlugins();" accept-charset="utf-8">
@@ -193,7 +169,7 @@ I cannot believe it!</textarea>
                    </select>
                </div>
 
-                <a id="doevaluate" class="btn btn-lg btn-primary" onclick="evaluate_JSON()">Evaluate Plugin!</a>
+                <a id="preview" class="btn btn-lg btn-primary" onclick="evaluate_JSON()">Evaluate Plugin!</a>
                <!--<button id="visualise" name="type" type="button">Visualise!</button>-->
            </form>
          </div>
@@ -240,7 +216,6 @@ I cannot believe it!</textarea>
                </div>
              </div>
            </div>
-            {% endif %}
        </div>

        <a href="http://www.gsi.dit.upm.es" target="_blank"><img class="center-block" src="static/img/gsi.png"/>  </a> 
--- a/senpy/test.py
+++ b/senpy/test.py
@@ -0,0 +1,36 @@
+try:
+    from unittest.mock import patch, MagicMock
+except ImportError:
+    from mock import patch, MagicMock
+
+from past.builtins import basestring
+
+
+import json
+from contextlib import contextmanager
+
+from .models import BaseModel
+
+
+@contextmanager
+def patch_requests(value, code=200):
+    success = MagicMock()
+    if isinstance(value, BaseModel):
+        value = value.jsonld()
+    if not isinstance(value, basestring):
+        data = json.dumps(value)
+    else:
+        data = value
+
+    success.json.return_value = value
+
+    success.status_code = code
+    success.content = data
+    success.text = data
+
+    method_mocker = MagicMock()
+    method_mocker.return_value = success
+    with patch.multiple('requests', request=method_mocker,
+                        get=method_mocker, post=method_mocker):
+        yield method_mocker, success
+        assert method_mocker.called
--- a/senpy/testing.py
+++ b/senpy/testing.py
@@ -1,31 +0,0 @@
-from past.builtins import basestring
-
-import os
-import responses as requestmock
-
-from .models import BaseModel
-
-
-MOCK_REQUESTS = os.environ.get('MOCK_REQUESTS', '').lower() in ['no', 'false']
-
-
-def patch_all_requests(responses):
-
-    patched = requestmock.RequestsMock()
-
-    for response in responses or []:
-        args = response.copy()
-        if 'json' in args and isinstance(args['json'], BaseModel):
-            args['json'] = args['json'].jsonld()
-        args['method'] = getattr(requestmock, args.get('method', 'GET'))
-        patched.add(**args)
-    return patched
-
-
-def patch_requests(url, response, method='GET', status=200):
-    args = {'url': url, 'method': method, 'status': status}
-    if isinstance(response, basestring):
-        args['body'] = response
-    else:
-        args['json'] = response
-    return patch_all_requests([args])
--- a/senpy/utils.py
+++ b/senpy/utils.py
@@ -1,7 +1,6 @@
 from . import models, __version__
 from collections import MutableMapping
 import pprint
-import pdb

 import logging
 logger = logging.getLogger(__name__)
@@ -33,8 +32,8 @@ def check_template(indict, template):
        if indict != template:
            raise models.Error(('Differences found.\n'
                                '\tExpected: {}\n'
-                                '\tFound: {}').format(pprint.pformat(template),
-                                                      pprint.pformat(indict)))
+                                '\tFound: {}').format(pprint.pformat(indict),
+                                                      pprint.pformat(template)))


 def convert_dictionary(original, mappings):
@@ -68,23 +67,18 @@ def easy_load(app=None, plugin_list=None, plugin_folder=None, **kwargs):
    return sp, app


-def easy_test(plugin_list=None, debug=True):
+def easy_test(plugin_list=None):
    logger.setLevel(logging.DEBUG)
    logging.getLogger().setLevel(logging.INFO)
-    try:
-        if not plugin_list:
-            import __main__
-            logger.info('Loading classes from {}'.format(__main__))
-            from . import plugins
-            plugin_list = plugins.from_module(__main__)
-        for plug in plugin_list:
-            plug.test()
-            plug.log.info('My tests passed!')
-        logger.info('All tests passed for {} plugins!'.format(len(plugin_list)))
-    except Exception:
-        if not debug:
-            raise
-        pdb.post_mortem()
+    if not plugin_list:
+        import __main__
+        logger.info('Loading classes from {}'.format(__main__))
+        from . import plugins
+        plugin_list = plugins.from_module(__main__)
+    for plug in plugin_list:
+        plug.test()
+        logger.info('The tests for {} passed!'.format(plug.name))
+    logger.info('All tests passed!')


 def easy(host='0.0.0.0', port=5000, debug=True, **kwargs):
--- a/tests/test_blueprints.py
+++ b/tests/test_blueprints.py
@@ -21,6 +21,7 @@ class BlueprintsTest(TestCase):
    def setUpClass(cls):
        """Set up only once, and re-use in every individual test"""
        cls.app = Flask("test_extensions")
+        cls.app.debug = False
        cls.client = cls.app.test_client()
        cls.senpy = Senpy(default_plugins=True)
        cls.senpy.init_app(cls.app)
@@ -30,21 +31,17 @@ class BlueprintsTest(TestCase):
        cls.senpy.activate_plugin("DummyRequired", sync=True)
        cls.senpy.default_plugin = 'Dummy'

-    def setUp(self):
-        self.app.config['TESTING'] = True  # Tell Flask not to catch Exceptions
-
    def assertCode(self, resp, code):
        self.assertEqual(resp.status_code, code)

    def test_playground(self):
        resp = self.client.get("/")
-        assert "main.js" in resp.get_data(as_text=True)
+        assert "main.js" in resp.data.decode()

    def test_home(self):
        """
        Calling with no arguments should ask the user for more arguments
        """
-        self.app.config['TESTING'] = False  # Errors are expected in this case
        resp = self.client.get("/api/")
        self.assertCode(resp, 400)
        js = parse_resp(resp)
@@ -84,7 +81,7 @@ class BlueprintsTest(TestCase):
        Extra params that have a required argument that does not
        have a default should raise an error.
        """
-        self.app.config['TESTING'] = False  # Errors are expected in this case
+        self.app.debug = False
        resp = self.client.get("/api/?i=My aloha mohame&algo=DummyRequired")
        self.assertCode(resp, 400)
        js = parse_resp(resp)
@@ -100,7 +97,7 @@ class BlueprintsTest(TestCase):
        The dummy plugin returns an empty response,\
        it should contain the context
        """
-        self.app.config['TESTING'] = False  # Errors are expected in this case
+        self.app.debug = False
        resp = self.client.get("/api/?i=My aloha mohame&algo=DOESNOTEXIST")
        self.assertCode(resp, 404)
        js = parse_resp(resp)
@@ -142,7 +139,7 @@ class BlueprintsTest(TestCase):
        js = parse_resp(resp)
        logging.debug(js)
        assert "@id" in js
-        assert js["@id"] == "endpoint:plugins/Dummy_0.1"
+        assert js["@id"] == "plugins/Dummy_0.1"

    def test_default(self):
        """ Show only one plugin"""
@@ -151,7 +148,7 @@ class BlueprintsTest(TestCase):
        js = parse_resp(resp)
        logging.debug(js)
        assert "@id" in js
-        assert js["@id"] == "endpoint:plugins/Dummy_0.1"
+        assert js["@id"] == "plugins/Dummy_0.1"

    def test_context(self):
        resp = self.client.get("/api/contexts/context.jsonld")
@@ -175,6 +172,5 @@ class BlueprintsTest(TestCase):
        assert "help" in js["valid_parameters"]

    def test_conversion(self):
-        self.app.config['TESTING'] = False  # Errors are expected in this case
        resp = self.client.get("/api/?input=hello&algo=emoRand&emotionModel=DOES NOT EXIST")
        self.assertCode(resp, 404)
--- a/tests/test_client.py
+++ b/tests/test_client.py
@@ -1,6 +1,6 @@
 from unittest import TestCase

-from senpy.testing import patch_requests
+from senpy.test import patch_requests
 from senpy.client import Client
 from senpy.models import Results, Plugins, Error
 from senpy.plugins import AnalysisPlugin
@@ -14,15 +14,22 @@ class ModelsTest(TestCase):
    def test_client(self):
        endpoint = 'http://dummy/'
        client = Client(endpoint)
-        with patch_requests('http://dummy/', Results()):
+        with patch_requests(Results()) as (request, response):
            resp = client.analyse('hello')
            assert isinstance(resp, Results)
-        with patch_requests('http://dummy/', Error('Nothing')):
+        request.assert_called_with(
+            url=endpoint + '/', method='GET', params={'input': 'hello'})
+        with patch_requests(Error('Nothing')) as (request, response):
            try:
                client.analyse(input='hello', algorithm='NONEXISTENT')
                raise Exception('Exceptions should be raised. This is not golang')
            except Error:
                pass
+        request.assert_called_with(
+            url=endpoint + '/',
+            method='GET',
+            params={'input': 'hello',
+                    'algorithm': 'NONEXISTENT'})

    def test_plugins(self):
        endpoint = 'http://dummy/'
@@ -30,8 +37,11 @@ class ModelsTest(TestCase):
        plugins = Plugins()
        p1 = AnalysisPlugin({'name': 'AnalysisP1', 'version': 0, 'description': 'No'})
        plugins.plugins = [p1, ]
-        with patch_requests('http://dummy/plugins', plugins):
+        with patch_requests(plugins) as (request, response):
            response = client.plugins()
            assert isinstance(response, dict)
            assert len(response) == 1
            assert "AnalysisP1" in response
+        request.assert_called_with(
+            url=endpoint + '/plugins', method='GET',
+            params={})
--- a/tests/test_extensions.py
+++ b/tests/test_extensions.py
@@ -47,7 +47,7 @@ class ExtensionsTest(TestCase):

    def test_add_delete(self):
        '''Should be able to add and delete new plugins. '''
-        new = plugins.Analysis(name='new', description='new', version=0)
+        new = plugins.Plugin(name='new', description='new', version=0)
        self.senpy.add_plugin(new)
        assert new in self.senpy.plugins()
        self.senpy.delete_plugin(new)
@@ -121,8 +121,8 @@ class ExtensionsTest(TestCase):
        # Leaf (defaultdict with  __setattr__ and __getattr__.
        r1 = analyse(self.senpy, algorithm="Dummy", input="tupni", output="tuptuo")
        r2 = analyse(self.senpy, input="tupni", output="tuptuo")
-        assert r1.analysis[0] == "endpoint:plugins/Dummy_0.1"
-        assert r2.analysis[0] == "endpoint:plugins/Dummy_0.1"
+        assert r1.analysis[0] == "plugins/Dummy_0.1"
+        assert r2.analysis[0] == "plugins/Dummy_0.1"
        assert r1.entries[0]['nif:isString'] == 'input'

    def test_analyse_empty(self):
@@ -156,8 +156,8 @@ class ExtensionsTest(TestCase):
        r2 = analyse(self.senpy,
                     input="tupni",
                     output="tuptuo")
-        assert r1.analysis[0] == "endpoint:plugins/Dummy_0.1"
-        assert r2.analysis[0] == "endpoint:plugins/Dummy_0.1"
+        assert r1.analysis[0] == "plugins/Dummy_0.1"
+        assert r2.analysis[0] == "plugins/Dummy_0.1"
        assert r1.entries[0]['nif:isString'] == 'input'

    def test_analyse_error(self):
--- a/tests/test_plugins.py
+++ b/tests/test_plugins.py
@@ -6,7 +6,7 @@ import pickle
 import shutil
 import tempfile

-from unittest import TestCase
+from unittest import TestCase, skipIf
 from senpy.models import Results, Entry, EmotionSet, Emotion, Plugins
 from senpy import plugins
 from senpy.plugins.conversion.emotion.centroids import CentroidConversion
@@ -312,7 +312,9 @@ class PluginsTest(TestCase):
        res = c._backwards_conversion(e)
        assert res["onyx:hasEmotionCategory"] == "c2"

-    def _test_evaluation(self):
+    @skipIf(sys.version_info < (3, 0),
+            reason="requires Python3")
+    def test_evaluation(self):
        testdata = []
        for i in range(50):
            testdata.append(["good", 1])
@@ -346,14 +348,6 @@ class PluginsTest(TestCase):
        smart_metrics = results[0].metrics[0]
        assert abs(smart_metrics['accuracy'] - 1) < 0.01

-    def test_evaluation(self):
-        if sys.version_info < (3, 0):
-            with self.assertRaises(Exception) as context:
-                self._test_evaluation()
-            self.assertTrue('GSITK ' in str(context.exception))
-        else:
-            self._test_evaluation()
-

 def make_mini_test(fpath):
    def mini_test(self):
--- a/tests/test_test.py
+++ b/tests/test_test.py
@@ -2,32 +2,31 @@ from unittest import TestCase

 import requests
 import json
-from senpy.testing import patch_requests
+from senpy.test import patch_requests
 from senpy.models import Results

-ENDPOINT = 'http://example.com'
-

 class TestTest(TestCase):
    def test_patch_text(self):
-        with patch_requests(ENDPOINT, 'hello'):
-            r = requests.get(ENDPOINT)
+        with patch_requests('hello'):
+            r = requests.get('http://example.com')
            assert r.text == 'hello'
+            assert r.content == 'hello'

    def test_patch_json(self):
        r = Results()
-        with patch_requests(ENDPOINT, r):
-            res = requests.get(ENDPOINT)
-            assert res.text == json.dumps(r.jsonld())
+        with patch_requests(r):
+            res = requests.get('http://example.com')
+            assert res.content == json.dumps(r.jsonld())
            js = res.json()
            assert js
            assert js['@type'] == r['@type']

    def test_patch_dict(self):
        r = {'nothing': 'new'}
-        with patch_requests(ENDPOINT, r):
-            res = requests.get(ENDPOINT)
-            assert res.text == json.dumps(r)
+        with patch_requests(r):
+            res = requests.get('http://example.com')
+            assert res.content == json.dumps(r)
            js = res.json()
            assert js
            assert js['nothing'] == 'new'