Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# Connected Systems API for Python (conSys4Py)
# Connected Systems API for Python (consys4py)
This package aims to help simplify the process of communicating with OGC's Connected Systems API.

---
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/con_sys_api.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import BaseModel, HttpUrl, Field

from conSys4Py.endpoints import Endpoint
from conSys4Py.request_wrappers import post_request, put_request, get_request, delete_request
from consys4py.endpoints import Endpoint
from consys4py.request_wrappers import post_request, put_request, get_request, delete_request


class ConnectedSystemAPIRequest(BaseModel):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/core/default_api_helpers.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@

from pydantic import BaseModel, Field

from conSys4Py.con_sys_api import ConnectedSystemAPIRequest
from conSys4Py.constants import APIResourceTypes, EncodingSchema, APITerms
from consys4py.con_sys_api import ConnectedSystemAPIRequest
from consys4py.constants import APIResourceTypes, EncodingSchema, APITerms


def determine_parent_type(res_type: APIResourceTypes):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/datamodels/control_streams.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,8 @@

from pydantic import BaseModel, Field, SerializeAsAny

from conSys4Py.datamodels.encoding import Encoding
from conSys4Py.datamodels.swe_components import AnyComponentSchema
from consys4py.datamodels.encoding import Encoding
from consys4py.datamodels.swe_components import AnyComponentSchema


class ControlStreamJSONSchema(BaseModel):
Expand Down
6 changes: 3 additions & 3 deletions conSys4Py/datamodels/datastreams.py
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
from pydantic import BaseModel, Field, field_validator, SerializeAsAny

from conSys4Py.constants import ObservationFormat
from conSys4Py.datamodels.encoding import Encoding
from conSys4Py.datamodels.swe_components import AnyComponentSchema
from consys4py.constants import ObservationFormat
from consys4py.datamodels.encoding import Encoding
from consys4py.datamodels.swe_components import AnyComponentSchema


class DatastreamSchema(BaseModel):
Expand Down
2 changes: 1 addition & 1 deletion conSys4Py/datamodels/geometry.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
from pydantic import BaseModel, Field

from conSys4Py.constants import GeometryTypes
from consys4py.constants import GeometryTypes


# TODO: Add specific validations for each type
Expand Down
2 changes: 1 addition & 1 deletion conSys4Py/datamodels/observations.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@

from pydantic import BaseModel, Field

from conSys4Py.datamodels.api_utils import Link
from consys4py.datamodels.api_utils import Link


class ObservationOMJSONInline(BaseModel):
Expand Down
6 changes: 3 additions & 3 deletions conSys4Py/datamodels/swe_components.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@

from pydantic import BaseModel, Field, field_validator, SerializeAsAny

from conSys4Py.constants import GeometryTypes
from conSys4Py.datamodels.api_utils import UCUMCode, URI
from conSys4Py.datamodels.geometry import Geometry
from consys4py.constants import GeometryTypes
from consys4py.datamodels.api_utils import UCUMCode, URI
from consys4py.datamodels.geometry import Geometry

"""
NOTE: The following classes are used to represent the Record Schemas that are required for use with Datastreams
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/datamodels/system_events_and_history.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import BaseModel, Field, HttpUrl

from conSys4Py.datamodels.api_utils import Link, URI
from conSys4Py.datamodels.geometry import Geometry
from consys4py.datamodels.api_utils import Link, URI
from consys4py.datamodels.geometry import Geometry


class SystemEventOMJSON(BaseModel):
Expand Down
2 changes: 1 addition & 1 deletion conSys4Py/endpoints.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
# import websockets
from pydantic import BaseModel, Field

from conSys4Py.constants import APITerms
from consys4py.constants import APITerms


class Endpoint(BaseModel):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_1/capabilities.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def get_landing_page(server_addr: HttpUrl, api_root: str = APITerms.API.value):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_1/collections_ep.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_collections(server_addr: HttpUrl, api_root: str = APITerms.API.value):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_1/deployments.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_deployments(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_1/procedures.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_procedures(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_1/properties.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_properties(server_addr: HttpUrl, api_root: str = APITerms.API.value):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_1/sampling_features.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_sampling_features(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers=None):
Expand Down
6 changes: 3 additions & 3 deletions conSys4Py/part_1/systems.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
import requests
from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from conSys4Py.request_wrappers import post_request
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms
from consys4py.request_wrappers import post_request


def list_all_systems(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_2/commands.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_commands(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_2/control_channels.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_control_streams(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_2/datastreams.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_datastreams(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_2/observations.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_all_observations(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers=None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_2/system_events.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_system_events(server_addr: HttpUrl, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
4 changes: 2 additions & 2 deletions conSys4Py/part_2/system_history.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from pydantic import HttpUrl

from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from conSys4Py.constants import APITerms
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.constants import APITerms


def list_system_history(server_addr: HttpUrl, system_id: str, api_root: str = APITerms.API.value, headers: dict = None):
Expand Down
8 changes: 4 additions & 4 deletions conSys4Py/request_bodies.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,10 @@

from pydantic import BaseModel, HttpUrl, Field, model_serializer, RootModel, SerializeAsAny

from conSys4Py.constants import DatastreamResultTypes
from conSys4Py.datamodels.datastreams import DatastreamSchema
from conSys4Py.datamodels.geometry import Geometry
from conSys4Py.sensor_ml.sml import TypeOf
from consys4py.constants import DatastreamResultTypes
from consys4py.datamodels.datastreams import DatastreamSchema
from consys4py.datamodels.geometry import Geometry
from consys4py.sensor_ml.sml import TypeOf


# TODO: Consider some sort of Abstract Base Class for all valid request bodies to inherit from to reduce the complexity
Expand Down
2 changes: 1 addition & 1 deletion docs/source/conf.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ def setup(app):
# -- Project information -----------------------------------------------------
# https://www.sphinx-doc.org/en/master/usage/configuration.html#project-information

project = 'conSys4Py'
project = 'consys4py'
copyright = '2024, Botts Innovative Research, Inc.'
author = 'Ian Patterson'
release = '0.1'
Expand Down
2 changes: 1 addition & 1 deletion docs/source/pydocs.rst
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
ConSys4Py API Docs
==================

.. automodule:: conSys4Py
.. automodule:: consys4py
:members:
:undoc-members:
:show-inheritance:
4 changes: 2 additions & 2 deletions pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[tool.poetry]
name = "conSys4Py"
version = "0.0.1-alpha.3"
name = "consys4py"
version = "0.0.1-alpha.7"
authors = ["Ian Patterson <ian@botts-inc.com>"]
description = "OGC Connected Systems API client for Python"
readme = "README.md"
Expand Down
10 changes: 5 additions & 5 deletions tests/test_commands.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,11 @@
import time
from datetime import datetime

from conSys4Py import GeoJSONBody, Systems, ControlChannels, ObservationFormat, Commands
from conSys4Py.datamodels.commands import CommandJSON
from conSys4Py.datamodels.control_streams import ControlStreamJSONSchema, JSONControlChannelSchema
from conSys4Py.datamodels.swe_components import DataRecordSchema, TimeSchema, CountSchema, URI
from conSys4Py.comm.mqtt import MQTTCommClient
from consys4py import GeoJSONBody, Systems, ControlChannels, ObservationFormat, Commands
from consys4py.datamodels.commands import CommandJSON
from consys4py.datamodels.control_streams import ControlStreamJSONSchema, JSONControlChannelSchema
from consys4py.datamodels.swe_components import DataRecordSchema, TimeSchema, CountSchema, URI
from consys4py.comm.mqtt import MQTTCommClient

server_url = "http://localhost:8282/sensorhub"
geo_json_headers = {"Content-Type": "application/geo+json"}
Expand Down
4 changes: 2 additions & 2 deletions tests/test_default_api_helpers.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import conSys4Py.core.default_api_helpers as helpers
from conSys4Py import APIResourceTypes, GeoJSONBody
import consys4py.core.default_api_helpers as helpers
from consys4py import APIResourceTypes, GeoJSONBody

server_url = 'http://localhost:8282/sensorhub'
api_endpoint = 'api'
Expand Down
2 changes: 1 addition & 1 deletion tests/test_delete_all.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from conSys4Py import Systems, SamplingFeatures, Datastreams, Procedures, ControlChannels, Observations, \
from consys4py import Systems, SamplingFeatures, Datastreams, Procedures, ControlChannels, Observations, \
Commands

server_url = 'http://localhost:8282/sensorhub'
Expand Down
2 changes: 1 addition & 1 deletion tests/test_params.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from conSys4Py.con_sys_api import ConnectedSystemsRequestBuilder
from consys4py.con_sys_api import ConnectedSystemsRequestBuilder


def test_get_params():
Expand Down
26 changes: 13 additions & 13 deletions tests/test_script_full_suite.py
Original file line number Diff line number Diff line change
@@ -1,20 +1,20 @@
import random
from datetime import datetime

from conSys4Py.constants import ObservationFormat
from conSys4Py.datamodels.api_utils import URI
from conSys4Py.datamodels.control_streams import ControlStreamJSONSchema, SWEControlChannelSchema, \
from consys4py.constants import ObservationFormat
from consys4py.datamodels.api_utils import URI
from consys4py.datamodels.control_streams import ControlStreamJSONSchema, SWEControlChannelSchema, \
JSONControlChannelSchema
from conSys4Py.datamodels.datastreams import SWEDatastreamSchema
from conSys4Py.datamodels.encoding import JSONEncoding
from conSys4Py.datamodels.geometry import Geometry
from conSys4Py.datamodels.swe_components import BooleanSchema, TimeSchema, DataRecordSchema, CountSchema
from conSys4Py.datamodels.observations import ObservationOMJSONInline
from conSys4Py.datamodels.commands import CommandJSON
from conSys4Py.part_1 import systems, deployments, sampling_features
from conSys4Py.part_2 import datastreams, observations, commands, control_channels
from conSys4Py.request_bodies import DatastreamBodyJSON, GeoJSONBody, SmlJSONBody
from conSys4Py.utilities import model_utils
from consys4py.datamodels.datastreams import SWEDatastreamSchema
from consys4py.datamodels.encoding import JSONEncoding
from consys4py.datamodels.geometry import Geometry
from consys4py.datamodels.swe_components import BooleanSchema, TimeSchema, DataRecordSchema, CountSchema
from consys4py.datamodels.observations import ObservationOMJSONInline
from consys4py.datamodels.commands import CommandJSON
from consys4py.part_1 import systems, deployments, sampling_features
from consys4py.part_2 import datastreams, observations, commands, control_channels
from consys4py.request_bodies import DatastreamBodyJSON, GeoJSONBody, SmlJSONBody
from consys4py.utilities import model_utils

server_url = "http://localhost:8282/sensorhub"
geo_json_headers = {"Content-Type": "application/geo+json"}
Expand Down
16 changes: 8 additions & 8 deletions tests/test_system_events_and_history.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,16 +2,16 @@

from datetime import datetime

from conSys4Py import Systems, SamplingFeatures, Datastreams, SmlJSONBody, GeoJSONBody, model_utils, \
from consys4py import Systems, SamplingFeatures, Datastreams, SmlJSONBody, GeoJSONBody, model_utils, \
DatastreamBodyJSON, ObservationFormat, URI, Procedures, Geometry, Deployments, ControlChannels, Observations, \
Commands
from conSys4Py.datamodels.control_streams import ControlStreamJSONSchema, SWEControlChannelSchema, JSONControlChannelSchema
from conSys4Py.datamodels.datastreams import SWEDatastreamSchema
from conSys4Py.datamodels.encoding import JSONEncoding
from conSys4Py.datamodels.swe_components import BooleanSchema, TimeSchema, DataRecordSchema, CountSchema
from conSys4Py.datamodels.observations import ObservationOMJSONInline
from conSys4Py.datamodels.commands import CommandJSON
from conSys4Py.datamodels.system_events_and_history import SystemEventOMJSON
from consys4py.datamodels.control_streams import ControlStreamJSONSchema, SWEControlChannelSchema, JSONControlChannelSchema
from consys4py.datamodels.datastreams import SWEDatastreamSchema
from consys4py.datamodels.encoding import JSONEncoding
from consys4py.datamodels.swe_components import BooleanSchema, TimeSchema, DataRecordSchema, CountSchema
from consys4py.datamodels.observations import ObservationOMJSONInline
from consys4py.datamodels.commands import CommandJSON
from consys4py.datamodels.system_events_and_history import SystemEventOMJSON

server_url = "http://localhost:8282/sensorhub"
geo_json_headers = {"Content-Type": "application/geo+json"}
Expand Down
2 changes: 1 addition & 1 deletion tests/test_systems.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
from pydantic import HttpUrl

from conSys4Py.part_1.systems import list_all_systems, retrieve_system_by_id, list_all_systems_in_collection, \
from consys4py.part_1.systems import list_all_systems, retrieve_system_by_id, list_all_systems_in_collection, \
list_system_components, list_sampling_features_of_system


Expand Down
Loading