Skip to content

GitLab

Merged
Created by Trishna Saeharaseelan@trishnaOwner

Create initial message schemas

11 unresolved threads
Compare
and
32 files
+ 1320
- 1299
Show latest version
do‎cs‎
__ini‎t__.py‎ +0 -9
generate_‎swagger.py‎ +0 -394
exam‎ples‎
autonom‎y_engine‎
configura‎tion.jsonc‎ +0 -71
mission_‎plan.json‎ +0 -0
autos‎ub_c2‎
sample_autosub.alr-3.‎v1.mission_script.sbd‎ +0 -0
sample_decoded_‎ah1_status.json‎ +0 -199
ecos‎ub_c2‎
mission_‎plan.json‎ +54 -0
observat‎ion.json‎ +24 -0
platform_status-fro‎m_usbl_example.json‎ +17 -0
platform_s‎tatus.json‎ +40 -0
g‎ui‎
emergency‎_stop.json‎ +0 -0
planning_conf‎iguration.json‎ +157 -0
hydrosur‎v_adapter‎
acknowledg‎ement.json‎ +12 -0
mission_‎plan.json‎ +26 -0
platform_s‎tatus.json‎ +26 -0
for‎mats‎
__ini‎t__.py‎ +60 -66
acknowled‎gement.py‎ +30 -0
autonomy_con‎figuration.py‎ +0 -101
message_w‎rapper.py‎ +61 -0
mission‎_plan.py‎ +89 -0
observa‎tion.py‎ +64 -24
planning_con‎figuration.py‎ +187 -0
platform_‎status.py‎ +180 -116
pro‎ject‎
SOAR_RE‎ADME.md‎ +51 -0
.giti‎gnore‎ +1 -0
CONTRIB‎UTING.md‎ +73 -0
READ‎ME.md‎ +23 -89
__ini‎t__.py‎ +4 -5
autonomy_con‎figuration.py‎ +0 -101
generate_‎swagger.py‎ +137 -0
platform_‎status.py‎ +0 -124
requirem‎ents.txt‎ +4 -0
docs/__init__.py deleted
+ 0
- 9
from . import api
import os
__all__ = [
os.path.splitext(os.path.basename(x))[0]
for x in os.listdir(os.path.dirname(__file__))
if x.endswith(".py") and x != "__init__.py"
]
docs/generate_swagger.py deleted
+ 0
- 394
"""
Generate swagger to view models/schemas.
Command:
1/ python3 generate_swagger.py
2/ Go to http://127.0.0.1:5000/soardocs
WARNING: API Endpoints are NOT functional. Purely for easy-reading.
"""
from flask import Flask, request
from flasgger import Swagger, LazyString
from flask_restx import Api, fields, Resource
app = Flask(__name__)
api = Api(app)
swagger_template = dict(
info={
"title": LazyString(lambda: "SoAR Backbone Message Formats"),
"version": LazyString(lambda: "0.1"),
"description": LazyString(
lambda: "Backbone Message Format component for the Squad of Autonomous Robots (SoAR) message definitions."
),
},
host=LazyString(lambda: request.host),
)
message_header_schema = api.model(
"MessageHeader",
{
"timestamp": fields.DateTime(
required=True,
description="Timestamp of message",
example="2022-11-16T00:00:00Z",
),
"source": fields.String(
required=True,
description="Where is this message from",
example="autonomy_engine",
),
"destination": fields.String(
required=True,
description="What is the destination of this message",
example="ah-1",
),
"encoded": fields.Boolean(
required=True,
description="Indicate that message raw (encoded) or decoded. "
+ "Options: encoded=True, decoded=False",
example=False,
),
"type": fields.String(
required=True,
description="Type of message",
example="platform_status",
),
# "payload":# TODO: schema applicable changes according to "type"
},
)
platform_schema = api.model(
"Platform",
{
"platform_ID": fields.Integer(
required=True,
description="unique identifier for platform",
example="ah-1",
),
"serial": fields.Integer(
required=True,
description="platform serial number",
example="ah-1",
),
"model": fields.Integer(
required=True,
description="platform serial number",
example="ah-1",
),
"active": fields.Boolean(
required=False,
description="platform in mission",
example=True,
),
},
)
squad_metadata_schema = api.model(
"SquadMetadata",
{
"squad_ID": fields.Integer(
required=True,
description="platform serial number",
example="ah-1",
),
"no_of_platforms": fields.Integer(
required=True,
description="number of platform serial number",
example="ah-1",
),
"platforms": fields.List(
fields.Nested(platform_schema),
required=True,
description="Metadata pf each platform",
),
"squad_mission_type": fields.String(
required=True,
description="Survey or Detail",
example="survey",
),
"squad_state": fields.Boolean(
required=True,
description="True if given Squad is executing mission type "
+ "according to the Autonomy Engine plan",
example=False,
),
},
)
constraints_schema = api.model(
"Constraints",
# TODO: Should this be per platform instead of squad?
{
"min_altitude": fields.Float(
required=True,
description="Minimum altitude set for squad.",
example=15.2,
),
"min_velocity": fields.Float(
required=True,
description="Minimum velocity set for squad.",
example=0.1,
),
"max_velocity": fields.Float(
required=True,
description="Maximum altitude set for squad.",
example=0.9,
),
},
)
environment_config_schema = api.model( # TODO: Discuss how regions are defined
"EnvironmentConfig",
{
"region_of_interest": fields.String(),
"exclusion_zone": fields.String(),
},
)
# Main Autonomy Configuration Schema
autonomy_configuration_schema = api.model(
"Configuration",
{
"message": fields.Nested(
message_header_schema,
required=True,
description="Message header",
),
"ID": fields.Integer(
required=True,
description="Unique identifier tagged to version of this"
+ " configuration plan",
example=3,
),
"time": fields.String(
required=True,
description="",
example="",
),
"squads": fields.Nested(
squad_metadata_schema,
required=False,
description="Details of each squad",
),
"environment": fields.Nested(
environment_config_schema,
required=False,
description="Region of interest and exclusion zone",
),
},
)
gps_schema = api.model(
"GPS",
{
"gps_source": fields.Float( # TODO: TBD with partners
required=False,
description="Source of gps position. E.g. Beacon",
example="internal",
),
"latitude_type": fields.String(
required=False,
description="",
example="",
),
"longitude_type": fields.String(
required=False,
description="",
example="",
),
"latitude": fields.Float(
required=False,
description="Latitude in <insert units>",
example="",
),
"longitude": fields.Float(
required=False,
description="Longitude in <insert units>",
example="",
),
"depth": fields.Float(
required=False,
description="",
example="",
),
"gps_fix_seconds_ago": fields.Float(
required=False,
description="",
example="",
),
},
)
observation_schema = api.model(
"Observation",
{
"message": fields.Nested(
message_header_schema,
required=True,
description="Message header",
),
"platform": fields.Nested(platform_schema),
"time": fields.String(
required=True,
description="Timestamp of message",
example="2022-11-16T00:00:00Z",
),
"discuss_other_fields": fields.String(
required=False,
description="", # we can track the version of the AE plan?
example="",
),
}
)
platform_status_message_schema = api.model(
"PlatformStatusMessage",
{
"message": fields.Nested(
message_header_schema,
required=True,
description="Message header",
),
"platform": fields.Nested(platform_schema),
"time": fields.String(
required=True,
description="Timestamp of message",
example="2022-11-16T00:00:00Z",
),
"version": fields.Integer(
required=False,
description="", # we can track the version of the AE plan?
example="",
),
"platform_state": fields.String(
# TODO: Define dictionary with potential STATES of each platform
required=True,
description="Current state executed by platform. E.g. "
+ "STOP, IDLE, ABORT.",
example="IDLE",
),
"mission_track_number": fields.Integer(
required=False,
description=(
"Track number - stage in mission (e.g. "
+ "4 --> Waypoint 3 to Waypoint 4)"
),
example=4,
),
"range_to_go": fields.Float(
required=False,
description="Estimated distance to reach next waypoint",
example=124.3,
),
"c2_health_status": fields.String(
required=False,
description="Health status extracted by respective platform's C2 "
+ "if any diagnosis available checks on sensors",
example="Warning",
),
"gps_data": fields.Nested(gps_schema),
"battery_voltage": fields.Float(
required=True,
description="Volts",
example=23.0,
),
"battery_current": fields.Float(
required=False,
description="Amps",
example=1.2,
),
"battery_current_per_hour": fields.Float(
required=False,
description="Amp-Hours",
example=1.2,
),
"battery_wattage": fields.Float(
required=False,
description="Watts",
example=23.0,
),
"battery_wattage_per_hour": fields.Float(
required=False,
description="Watt-Hours",
example=23.0,
),
},
)
swagger_config = {
"headers": [],
"specs": [
{
"endpoint": "swagger",
"route": "/swagger.json",
"rule_filter": lambda rule: True,
"model_filter": lambda tag: True,
}
],
"static_url_path": "/flasgger_static",
"swagger_ui": True,
"specs_route": "/soardocs/",
"swagger": "2.0",
"basePath": "/soar",
"info": {
"title": "soar",
"version": "0.1",
"description": "SoAR message schemas",
},
"produces": ["application/json"],
"consumes": ["application/json"],
}
swagger = Swagger(app, template=swagger_template, config=swagger_config)
ns1 = api.namespace("message", description="Message Header Format")
@ns1.route("/header")
class MessageHeader(Resource):
@ns1.response(200, "Success", message_header_schema)
def get(self):
pass
ns2 = api.namespace("platform_status", description="Platform Status Message Format")
@ns2.route("")
class PlatformStatus(Resource):
@ns2.response(200, "Success", platform_status_message_schema)
def get(self):
pass
ns3 = api.namespace(
"autonomy_configuration", description="Autonomy Configuration Format"
)
@ns3.route("")
class AutonomyConfiguration(Resource):
@ns3.response(200, "Success", autonomy_configuration_schema)
def get(self):
pass
# @api.route('/mission-plan/<str:platform_type')
# @api.doc(params={"platform_type": "The type of platform of the mission plan to target."})
ns4 = api.namespace("mission_plan", description="Mission Plan Format Per Platform")
@ns4.route("/ecosub")
class MissionPlanEcosub(Resource):
@ns4.response(200, "Success", {})
def get(self):
pass
@ns4.route("/reav")
class MissionPlanReav(Resource):
@ns4.response(200, "Success", {})
def get(self):
pass
@ns4.route("/autosubhover")
class MissionPlanAutosubHover(Resource):
@ns4.response(200, "Success", {})
def get(self):
pass
ns5 = api.namespace("observation", description="Observation Format --> Per Platform or generic?")
@ns5.route("")
class Observation(Resource):
@ns5.response(200, "Success", observation_schema)
def get(self):
pass
if __name__ == "__main__":
app.run()
examples/autonomy_engine/configuration.jsonc deleted
+ 0
- 71
//****************************************************************
// File: config.json (THIS FILE WILL BE IN JSON FORMAT, NOT JSONC)
// Description: This file is configured by the respective
// platform's C2 if a platform is no longer active or change
// a configured value.
//
// Notes: All comments in this document will be stripped out
// during SOAR operations.
// (TODO: RHU to identify values that can and cannot be
// configured).
//----------------------------------------------------------------
// CHANGELOG
// -------------------
// 11-11-2022 Trishna S. Added comments, header, and data types
// for each field.
// 10-11-2022 Izzat K. Converted contents to json schema.
// 06-10-2022 Trishna S. New initialisation file.
//****************************************************************
{
"mission_config": {
"execute_stage": {
"survey": true, // bool
"detail": false // bool
}
},
"survey_team": {
"no_of_platforms": 3, // int
"platforms": [
{
"id": 1, // int
"platform": "ecosub", // str
"platform_serial": "eco101", // str
"active": true // bool
},
{
"id": 2,
"platform": "ecosub", // str
"platform_serial": "eco-102", // str
"active": true // bool
},
{
"id": 3, // int
"platform": "ecosub", // str
"platform_serial": "ecosub3", // str
"active": true // bool
}
],
"min_altitude": 0.0, // float
"min_velocity": 0.0, // float
"max_velocity": 0.0 // float
},
"detail_team": {
"execute_stage": true, // bool
"no_of_platforms": 1, // int
"platforms": [
{
"id": 1, // int
"platform": "autosub-hover", // str
"platform_serial": "ah1", // str
"active": true // bool
}
],
"min_altitude": 0.0, // float
"min_velocity": 0.0, // float
"max_velocity": 0.0 // float
},
"environment": {
"region_of_interest": 0.0, // float
"exclusion_zone": 0.0 // float
}
}
\ No newline at end of file
examples/autonomy_engine/mission_plan.json deleted
+ 0
- 0
examples/autosub_c2/sample_autosub.alr-3.v1.mission_script.sbd deleted
+ 0
- 0
examples/autosub_c2/sample_decoded_ah1_status.json deleted
+ 0
- 199
examples/ecosub_c2/mission_plan.json
+ 54
- 0
examples/ecosub_c2/observation.json
+ 24
- 0
examples/ecosub_c2/platform_status-from_usbl_example.json
+ 17
- 0
examples/ecosub_c2/platform_status.json
+ 40
- 0
examples/gui/emergency_stop.json deleted
+ 0
- 0
examples/gui/planning_configuration.json
+ 157
- 0
examples/hydrosurv_adapter/acknowledgement.json
+ 12
- 0
examples/hydrosurv_adapter/mission_plan.json
+ 26
- 0
examples/hydrosurv_adapter/platform_status.json
+ 26
- 0
formats/__init__.py
+ 60
- 66
formats/acknowledgement.py
+ 30
- 0
formats/autonomy_configuration.py deleted
+ 0
- 101
formats/message_wrapper.py
+ 61
- 0
formats/mission_plan.py
+ 89
- 0
formats/observation.py
+ 64
- 24
formats/planning_configuration.py
+ 187
- 0
formats/platform_status.py
+ 180
- 116
project/SOAR_README.md
+ 51
- 0
.gitignore
+ 1
- 0
CONTRIBUTING.md
+ 73
- 0
README.md
+ 23
- 89
__init__.py
+ 4
- 5
autonomy_configuration.py deleted
+ 0
- 101
generate_swagger.py
+ 137
- 0
platform_status.py deleted
+ 0
- 124
requirements.txt
+ 4
- 0