Skip to content

Commit

Permalink
preparing to add additional endpoints and start of tests (#4)
Browse files Browse the repository at this point in the history
* preparing to add additional endpoints and start of tests
Signed-off-by: vsoch <[email protected]>
  • Loading branch information
vsoch authored Mar 1, 2022
1 parent 62f057b commit de8c43e
Show file tree
Hide file tree
Showing 15 changed files with 296 additions and 19 deletions.
20 changes: 18 additions & 2 deletions .github/workflows/main.yml
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,7 @@ jobs:
formatting:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v1

- uses: actions/checkout@v2
- name: Setup black linter
run: conda create --quiet --name black pyflakes

Expand All @@ -37,3 +36,20 @@ jobs:
pyflakes usrse/*.py
pyflakes usrse/utils/fileio.py
pyflakes usrse/utils/terminal.py
testing:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v2

- name: Setup black linter
run: conda create --quiet --name testing pytest

- name: Run Tests
run: |
export PATH="/usr/share/miniconda/bin:$PATH"
source activate testing
pip install -e .
cd usrse/tests
/bin/bash test_client.sh
pytest -xsv test_*.py
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -14,4 +14,5 @@ and **Merged pull requests**. Critical items to know are:
The versions coincide with releases on pip. Only major versions will be released as tags on Github.

## [0.0.x](https://github.com/USRSE/usrse-python/tree/main) (0.0.x)
- Adding support for jobs and member counts endpoint (0.0.11)
- Initial creation of project (0.0.1)
3 changes: 1 addition & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -11,10 +11,9 @@ See our ⭐️ [Documentation](https://us-rse.org/usrse-python/) to get started!

## Coming Soon / TODO

- full tests for all endpoints
- automated deployment to pypi on release
- nightly test run to ensure US-RSE static API functioning as expected
- endpoints for jobs and then functions here
- other endpoints and functions here

## Contributors

Expand Down
9 changes: 3 additions & 6 deletions docs/getting_started/index.rst
Original file line number Diff line number Diff line change
Expand Up @@ -4,12 +4,9 @@
Getting Started
===============

Singularity Registry (HPC) is a tool that makes it easy to install containers as
Lmod modules. You can create your own registry entries (e.g., a specification
to pull a particular container and expose some number of entrypoints) or
the library also provides you with a community set.

If you have any questions or issues, please `let us know <https://github.com/singularityhub/singularity-hpc/issues>`_
USRSE-Python provides easy ways to interact with content from the US-RSE website
and community!
If you have any questions or issues, please `let us know <https://github.com/USRSE/usrse-python/issues>`_

.. toctree::
:maxdepth: 2
Expand Down
48 changes: 44 additions & 4 deletions docs/getting_started/user-guide.rst
Original file line number Diff line number Diff line change
Expand Up @@ -28,10 +28,12 @@ Once you have usrse installed, you likely quickly want to get data

.. code-block:: console
$ usrse get posts
$ usrse get newsletters
$ usrse get dei
$ usrse get events
$ usrse get posts
$ usrse get newsletters
$ usrse get dei
$ usrse get events
$ usrse get member-counts
$ usrse get jobs
Or snazz things up a bit!

Expand All @@ -41,6 +43,8 @@ Or snazz things up a bit!
$ usrse get newsletters --live
$ usrse get dei --live
$ usrse get events --live
$ usrse get member-counts --live
$ usrse get jobs --live
Or output as json or save to json for later.

Expand All @@ -60,6 +64,36 @@ Commands

The following commands are available!

.. _getting_started-commands-list:

List
----

The first thing you might want to do is see what endpoints are available.
You can do that with ``list``:

.. code-block:: console
$ usrse list
dei
events
jobs
member-counts
newsletters
posts
This is also nice to pipe into a bash loop for doing something:

.. code-block:: console
for endpoint in $(usrse list); do
# do something here
echo $endpoint;
done
Once you know endpoints, then you can ``get`` them, discussed next.

.. _getting_started-commands-get:

Get
Expand All @@ -79,6 +113,8 @@ The most basic functionality is to get content. Here are all the types we can as
posts
dei
newsletters
member-counts
jobs
optional arguments:
-h, --help show this help message and exit
Expand Down Expand Up @@ -133,6 +169,8 @@ Here are all the content types you can ask for:
$ usrse get newsletters
$ usrse get dei
$ usrse get events
$ usrse get member-counts
$ usrse get jobs
Want to have some fun? Try the live tables!

Expand All @@ -143,6 +181,8 @@ Want to have some fun? Try the live tables!
$ usrse get newsletters --live
$ usrse get dei --live
$ usrse get events --live
$ usrse get member-counts --live
$ usrse get jobs --live
Changing the baseurl
Expand Down
8 changes: 7 additions & 1 deletion usrse/client/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
__license__ = "MPL 2.0"

import usrse
import usrse.main.endpoints as endpoints
from usrse.logger import setup_logger
import argparse
import sys
Expand Down Expand Up @@ -59,6 +60,9 @@ def get_parser():
# print version and exit
subparsers.add_parser("version", description="show software version")

# List endpoints available
subparsers.add_parser("list", description="list endpoints available")

# Local shell with client loaded
shell = subparsers.add_parser(
"shell",
Expand All @@ -82,7 +86,7 @@ def get_parser():
)
get.add_argument(
"content_type",
help="content type\nevents\nposts\ndei\nnewsletters",
help="content type\n%s" % "\n".join(endpoints.register_names),
)
get.add_argument("--json", help="output json", default=False, action="store_true")
get.add_argument("--all", help="output json", default=False, action="store_true")
Expand Down Expand Up @@ -151,6 +155,8 @@ def help(return_code=0):
from .get import main
elif args.command == "shell":
from .shell import main
elif args.command == "list":
from .listing import main

# Pass on to the correct parser
return_code = 0
Expand Down
10 changes: 10 additions & 0 deletions usrse/client/listing.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
__author__ = "Vanessa Sochat"
__copyright__ = "Copyright 2022, Vanessa Sochat"
__license__ = "MPL 2.0"

import usrse.main.endpoints as endpoints


def main(args, parser, extra, subparser):
for endpoint in endpoints.register_names:
print(endpoint)
11 changes: 9 additions & 2 deletions usrse/main/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,12 @@ class Result:
"""

def __init__(self, data, endpoint):
self.data = data or {}
self.endpoint = endpoint

# Does the endpoint want to sort or otherwise order?
data = data or {}
self.data = self.endpoint.order(data)

# Keep track of the max length for each field not truncated
self.max_widths = {}
self.ensure_complete()
Expand All @@ -42,7 +45,10 @@ def available_width(self, columns):
Calculate available width based on fields we cannot truncate (urls)
"""
# We will determine column width based on terminal size
width = os.get_terminal_size().columns
try:
width = os.get_terminal_size().columns
except OSError:
width = 120

# Calculate column width
column_width = int(width / len(columns))
Expand Down Expand Up @@ -270,4 +276,5 @@ def get(self, name):
result = requests.get(endpoint.url)
if result.status_code != 200:
sys.exit("Issue retrieving %s:\n%s" % (endpoint.url, result.txt))

return Result(result.json(), endpoint)
31 changes: 30 additions & 1 deletion usrse/main/endpoints.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
__license__ = "MPL 2.0"

import usrse.defaults as defaults
from datetime import datetime
import sys

# Registered endpoints (populated on init)
Expand All @@ -22,6 +23,10 @@ def __init__(self, baseurl):
"Misconfigured endpoint %s missing %s attribute" % (self, attr)
)

# If needed, make sure endpoint data is sorted
def order(self, data):
return data

@property
def url(self):
return self.baseurl + self.path
Expand Down Expand Up @@ -52,6 +57,28 @@ class Dei(Endpoint):
emoji = "sparkles"


class Jobs(Endpoint):
name = "jobs"
path = "/api/jobs.json"
emoji = "briefcase"


class MemberCounts(Endpoint):
name = "member-counts"
path = "/api/member-counts.json"
emoji = "1234"

def order(self, data):
"""
Sort by month and year
"""
return sorted(
data,
key=lambda entry: datetime.strptime(entry["date"], "%B %Y"),
reverse=True,
)


class Newsletters(Endpoint):
name = "newsletters"
path = "/api/newsletters.json"
Expand All @@ -72,6 +99,8 @@ class Events(Endpoint):
skips = ["repeated", "published", "description"]


for endpoint in [Dei, Newsletters, Posts, Events]:
for endpoint in [Dei, Newsletters, Posts, Events, Jobs, MemberCounts]:
register_names.append(endpoint.name)
register[endpoint.name] = endpoint

register_names.sort()
Empty file added usrse/tests/__init__.py
Empty file.
26 changes: 26 additions & 0 deletions usrse/tests/helpers.sh
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
runTest() {

# The first argument is the code we should get
ERROR="${1:-}"
shift
OUTPUT=${1:-}
shift
echo "$@"

"$@" > "${OUTPUT}" 2>&1
RETVAL="$?"

if [ "$ERROR" = "0" -a "$RETVAL" != "0" ]; then
echo "$@ (retval=$RETVAL) ERROR"
cat ${OUTPUT}
echo "Output in ${OUTPUT}"
exit 1
elif [ "$ERROR" != "0" -a "$RETVAL" = "0" ]; then
echo "$@ (retval=$RETVAL) ERROR"
echo "Output in ${OUTPUT}"
cat ${OUTPUT}
exit 1
else
echo "$@ (retval=$RETVAL) OK"
fi
}
29 changes: 29 additions & 0 deletions usrse/tests/test_client.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,29 @@
#!/usr/bin/python

# Copyright (C) 2022 Vanessa Sochat.

# This Source Code Form is subject to the terms of the
# Mozilla Public License, v. 2.0. If a copy of the MPL was not distributed
# with this file, You can obtain one at http://mozilla.org/MPL/2.0/.

import pytest
import os

import usrse.main.endpoints as endpoints
from usrse.main import Client

here = os.path.dirname(os.path.abspath(__file__))
root = os.path.dirname(here)

tests = [(ep, item) for ep in endpoints.register_names for item in [True, False]]


@pytest.mark.parametrize("endpoint,is_live", tests)
def test_install_get(tmp_path, endpoint, is_live):
"""Test install and get"""
client = Client(quiet=False)
result = client.get(endpoint)
if is_live:
result.table_live()
else:
result.table()
45 changes: 45 additions & 0 deletions usrse/tests/test_client.sh
Original file line number Diff line number Diff line change
@@ -0,0 +1,45 @@
#!/bin/bash

echo
echo "************** START: test_client.sh **********************"

# Create temporary testing directory
echo "Creating temporary directory to work in."
here="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null 2>&1 && pwd )"
shpc_root="$( dirname "${here}" )"

. $here/helpers.sh

# Create temporary testing directory
tmpdir=$(mktemp -d)
output=$(mktemp ${tmpdir:-/tmp}/usrse_test.XXXXXX)
printf "Created temporary directory to work in. ${tmpdir}\n"

# Make sure it's installed
if ! command -v usrse &> /dev/null
then
printf "usrse is not installed\n"
exit 1
else
printf "usrse is installed\n"
fi

echo
echo "#### Testing base client "
runTest 0 $output usrse --version

echo
echo "#### Testing list "
runTest 0 $output usrse list --help
runTest 0 $output usrse list


echo
echo "#### Testing get "
runTest 0 $output usrse get --help
for endpoint in $(usrse list); do
runTest 0 $output usrse get $endpoint
runTest 0 $output usrse get $endpoint --live
done

rm -rf ${tmpdir}
Loading

0 comments on commit de8c43e

Please sign in to comment.