D-Net

                 <div class="row">

                <div class="panel panel-primary">

                    <div class="panel-body">

                        <hr>

                        Sources

                        <ul>

            }

        }).error(function (data) {

        })

    }

import os

from os import path

log = logging.getLogger("scholexplorer-portal")

pid_resolver = {

def resolveIdentifier(pid, pid_type):

    if pid_type != None:

        regex = r"\b(10[.][0-9]{4,}(?:[.][0-9]+)*/(?:(?![\"&\'<>])\S)+)\b"

            log.debug("It should be doi")

            pid_type = 'doi'

        if pid_type.lower() in pid_resolver:

            if pid_type.lower() == 'openaire':

                return "https://www.openaire.eu/search/publication?articleId=%s" % pid.replace('oai:dnet:', '')

            elif pid_type.lower() == 'url':

            else:

                return "http://identifiers.org/%s:%s" % (pid_type, pid)

    return ""

def create_typology_filter(value):

    return Q('match', typology=value)

        self.index_name = props['api.index']

    def get_main_page_stats(self):

        for item in ['dataset', 'publication']:

            stats[item] = s.count()

        return stats

    def query_by_id(self, id):

        s = s.query(create_pid_query(id))

        s.aggs.bucket('typologies', 'terms', field='typology')

        s.aggs.bucket('all_datasources', 'nested', path='datasources').bucket('all_names', 'terms',

                                        publishers=publishers), hits=hits)

    def simple_query(self, textual_query, start=None, end=None, user_filter=None):

            q = Q("multi_match", query=textual_query, fields=['title', 'abstract'])

        else:

            q = Q()

            s = s[start:end]

        response = s.execute()

        hits = []

        for index_result in response.hits:

                for t in input_source.get('title', []):

                    if len(t) > 0 and t[0] == '"' and t[-1] == '"':

                        fixed_titles.append(t[1:-1])

                    else:

                        fixed_titles.append(t)

            else:

            input_source['title'] = fixed_titles

            hits.append(input_source)

        pid_types = []

        for tag in response.aggs.all_pids.all_types.buckets:

            pid_types.append(dict(key=tag.key, count=tag.doc_count))

        query_type = Q('nested', path='target', query=Q('bool', must=[Q('match', **args)]))

        args_id = {'source.dnetIdentifier': object_id}

        query_for_id = Q('nested', path='source', query=Q('bool', must=[Q('match', **args_id)]))

        if start:

            s = s[start:start + 10]

        response = s.execute()

        hits = []

        for index_hit in response.hits:

                for item in current_item['target']['identifier']:

                    c_it = item

                    c_it['url'] = resolveIdentifier(item['identifier'], item['schema'])

                current_item['target']['identifier'] = ids

            hits.append(current_item)

        if relation is None:

            return

        relSource = relation.get('source')

        if collectedFrom is not None:

            for coll in collectedFrom:

                for d in source['datasources']:

    def item_by_id(self, id, type=None, start=None):

        try:

            hits = []

            input_source = res['_source']

            fixed_titles = []

                if len(t) > 0 and t[0] == '"' and t[-1] == '"':

                    fixed_titles.append(t[1:-1])

                else:

                    fixed_titles.append(t)

            input_source['title'] = fixed_titles

            related_publications = []

            related_dataset = []

            rel_source = None

            if input_source.get('relatedPublications') > 0:

                else:

                    rel_source = {}

            if input_source.get('relatedDatasets') > 0:

                if 'dataset' == type:

                    related_dataset = self.related_type(id, 'dataset', start)

                             related_unknown=related_unknown))

            return DLIESResponse(total=1, hits=hits)

            log.error("Error on getting item ")

            log.error("on line %i" % sys.exc_info)

            return DLIESResponse()

from starlette.responses import FileResponse

from eu.dnetlib.es_connector import DLIESConnector

import sys

from eu.dnetlib.metricsMiddleware import PrometheusMiddleware

_CURDIR = os.path.dirname(os.path.abspath(__file__))

log = logging.getLogger("scholexplorer-portal")

log.setLevel(logging.INFO)

fh.setLevel(logging.INFO)

formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')

fh.setFormatter(formatter)

    return dict(result=connector.get_main_page_stats())

@app.post('/api/queryPid/')

    return dict(result=connector.query_by_id(pid))

@app.post('/api/post/')

def query_post(*, start:int= Form(default=0), action:str=Form(default="query"), query:str=Form(...),filter:str=Form(default=None)):

    filter_key = None

    if filter:

        filter_key = filter

    if action == 'query' and query is not None:

        connector = DLIESConnector()

        try:

            result = connector.simple_query(query, start=start, user_filter=filter_key)

@app.get('/api/item/{identifier}')

@app.post('/api/item/{identifier}')

def get_item(identifier:str, object_type:str=Form(default=None), start:int=Form(default=0)):

        connector = DLIESConnector()

        return dict(result=connector.item_by_id(identifier, object_type, start))

    else: