5.2.1. Accessing the JSONLDschema API for functions available in this package

Using the API:

# In order to use the JSONSchema-LD API, you first need to activate it in a separate python script
# You can then run queries on the different endpoints

# Let's first create a client
from wsgiref import simple_server
from api_client.client import create_client


if __name__ == '__main__':
    app = create_client()  # Create the client
    # Run the client forever
    httpd = simple_server.make_server('localhost', 8001, app)
    httpd.serve_forever()

# From there, all endpoints should be accessible.
# For more details on these endpoints, look at the example above.

---

import requests
import json
import os


class MircatClient:
    """
    A simple client example plugged on the api_client
    :param port: the port to target
    :type port: int
    :param client_url: the url of the api_client
    :type client_url: basestring
    """

    def __init__(self, client_url, port):
        self.headers = {
            "Content-Type": "application/json",
        }
        self.port = port
        self.base_URL = client_url
        self.request_base_url = self.base_URL + ":" + str(self.port)

    def create_context(self):
        """ Method to create contexts for the given network
        :return: a variable containing a context for each vocabulary and schema
        """
        extra_url = "/create_context"
        test_input = {
            "schema_url": "https://w3id.org/dats/schema/access_schema.json",
            "vocab":  {
                "obo": "http://purl.obolibrary.org/obo/",
                "sdo": "http://schema.org"
            }
        }
        response = requests.get(self.request_base_url + extra_url,
                                data=json.dumps(test_input),
                                headers=self.headers)

        return response.text

    def resolve_network(self):
        extra_url = "/resolve_network"
        test_input = {"schema_url": "https://w3id.org/dats/schema/access_schema.json"}
        response = requests.get(self.request_base_url + extra_url,
                                data=json.dumps(test_input),
                                headers=self.headers)
        return response.text

    def make_full_sem_diff(self):
        extra_url = "/semDiff"

        path = os.path.join(os.path.dirname(__file__), "../tests/data")
        with open(os.path.join(path, "dats.json"), 'r') as dats_file:
            # Load the JSON schema and close the file
            network1 = json.load(dats_file)
            dats_file.close()

        path = os.path.join(os.path.dirname(__file__), "../tests/data")
        with open(os.path.join(path, "miaca.json"), 'r') as miaca_file:
            # Load the JSON schema and close the file
            network2 = json.load(miaca_file)
            miaca_file.close()

        test_input = {
            "network_1": network1["schemas"],
            "network_2": network2["schemas"],
            "mapping": [network1["contexts"], network2["contexts"]]
        }
        response = requests.get(self.request_base_url + extra_url,
                                data=json.dumps(test_input),
                                headers=self.headers)
        return response.text

    def validate_schema(self):
        extra_url = "/validate/schema"
        schema_url = "https://w3id.org/dats/schema/access_schema.json"

        response = requests.get(self.request_base_url + extra_url,
                                data=json.dumps(schema_url),
                                headers=self.headers)

        return response.text

    def validate_instance(self):
        extra_url = "/validate/instance"

        user_input = {
            "schema_url": "https://w3id.org/dats/schema/activity_schema.json",
            "instance_url": "https://w3id.org/mircat/miflowcyt/schema/sample_schema.json"
        }

        response = requests.get(self.request_base_url + extra_url,
                                data=json.dumps(user_input),
                                headers=self.headers)

        return response.text

    def validate_network(self):
        extra_url = "/validate/network"
        schema_url = "https://w3id.org/dats/schema/activity_schema.json"
        response = requests.get(self.request_base_url + extra_url,
                                data=json.dumps(schema_url),
                                headers=self.headers)

        return response.text

    def merge_entities(self):
        extra_url = '/merge'
        urls = {
            "schema_url_1": "https://w3id.org/dats/schema/person_schema.json",
            "schema_url_2": "https://w3id.org/dats/schema/person_schema.json",
            "context_url_1": "https://raw.githubusercontent.com/"
                             "datatagsuite/context/master/obo/person_obo_context.jsonld",
            "context_url_2": "https://raw.githubusercontent.com/"
                             "FAIRsharing/mircat/master/miaca/context/"
                             "obo/source_obo_context.jsonld"
        }
        response = requests.get(self.request_base_url + extra_url,
                                data=json.dumps(urls),
                                headers=self.headers)

        return response.text


if __name__ == '__main__':
    client = MircatClient("http://localhost", 8001)
    # print(client.create_context())
    # print(client.resolve_network())
    # print(client.make_full_sem_diff())
    # print(client.validate_schema())
    # print(client.validate_instance())
    # print(client.validate_network())
    print(client.merge_entities())