Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Enable topic value telemetry and add data logging #37

Open
wants to merge 8 commits into
base: master
Choose a base branch
from
Open

Enable topic value telemetry and add data logging #37

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
22f6044
update packages
codeflight1 Feb 7, 2023
b6b55de
remove whitespace
codeflight1 Feb 7, 2023
970bec8
complete topic realtime telemetry
codeflight1 Feb 11, 2023
9d302ca
add default plugins
codeflight1 Feb 11, 2023
1fc0802
QuestDB datalogging
codeflight1 Mar 18, 2023
4f6179f
Connection fixes
codeflight1 Mar 23, 2023
22a29db
QuestDB setup instructions
codeflight1 Mar 30, 2023
20e4a07
DISABLE_QUESTDB env var
codeflight1 Mar 30, 2023
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
18 changes: 18 additions & 0 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,24 @@ Rosbridge runs on the local ros system and acts a a websocket server to translat

`TODO: configuring the server-side connection between the realtime server and rosbridge (order of deployment, url/port, etc)`

## QuestDB setup

Recording historical telemetry requires setting up a QuestDB instance. This can be disabled with the `DISABLE_QUESTDB` environment variable.

The schema is as follow:

```sql
CREATE TABLE <rossystemname> (
ts timestamp,
id symbol,
data string
) timestamp(ts);

CREATE TABLE dictionaries (
dictionary string
);
```

## Roslibjs

`todo`
Expand Down
123 changes: 120 additions & 3 deletions index.html
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,17 +5,134 @@
<script src="node_modules/openmct/dist/openmct.js"></script>
<script src="lib/http.js"></script>
<script src="node_modules/q/q.js"></script>
<script src="src/plugin/rosmctPlugin.js"></script>
<script src="src/plugin/rosmctPlugin.js"></script>
</head>
<body>
<script>
const THIRTY_SECONDS = 30 * 1000;
const ONE_MINUTE = THIRTY_SECONDS * 2;
const FIVE_MINUTES = ONE_MINUTE * 5;
const FIFTEEN_MINUTES = FIVE_MINUTES * 3;
const THIRTY_MINUTES = FIFTEEN_MINUTES * 2;
const ONE_HOUR = THIRTY_MINUTES * 2;
const TWO_HOURS = ONE_HOUR * 2;
const ONE_DAY = ONE_HOUR * 24;

openmct.setAssetPath('node_modules/openmct/dist');
openmct.install(openmct.plugins.LocalStorage());
openmct.install(openmct.plugins.MyItems());
openmct.install(openmct.plugins.PlanLayout());
openmct.install(openmct.plugins.Timeline());
openmct.install(openmct.plugins.Hyperlink());
openmct.install(openmct.plugins.UTCTimeSystem());
openmct.time.clock('local', {start: -15 * 60 * 1000, end: 0});
openmct.time.timeSystem('utc');
openmct.install(openmct.plugins.Espresso());
openmct.install(openmct.plugins.AutoflowView({
type: "telemetry.panel"
}));
openmct.install(openmct.plugins.DisplayLayout({
showAsView: ['summary-widget', 'example.imagery']
}));

openmct.install(openmct.plugins.Conductor({
menuOptions: [
{
name: "Fixed",
timeSystem: 'utc',
bounds: {
start: Date.now() - THIRTY_MINUTES,
end: Date.now()
},
// commonly used bounds can be stored in history
// bounds (start and end) can accept either a milliseconds number
// or a callback function returning a milliseconds number
// a function is useful for invoking Date.now() at exact moment of preset selection
presets: [
{
label: 'Last Day',
bounds: {
start: () => Date.now() - ONE_DAY,
end: () => Date.now()
}
},
{
label: 'Last 2 hours',
bounds: {
start: () => Date.now() - TWO_HOURS,
end: () => Date.now()
}
},
{
label: 'Last hour',
bounds: {
start: () => Date.now() - ONE_HOUR,
end: () => Date.now()
}
}
],
// maximum recent bounds to retain in conductor history
records: 10
// maximum duration between start and end bounds
// for utc-based time systems this is in milliseconds
// limit: ONE_DAY
},
{
name: "Realtime",
timeSystem: 'utc',
clock: 'local',
clockOffsets: {
start: - THIRTY_MINUTES,
end: THIRTY_SECONDS
},
presets: [
{
label: '1 Hour',
bounds: {
start: - ONE_HOUR,
end: THIRTY_SECONDS
}
},
{
label: '30 Minutes',
bounds: {
start: - THIRTY_MINUTES,
end: THIRTY_SECONDS
}
},
{
label: '15 Minutes',
bounds: {
start: - FIFTEEN_MINUTES,
end: THIRTY_SECONDS
}
},
{
label: '5 Minutes',
bounds: {
start: - FIVE_MINUTES,
end: THIRTY_SECONDS
}
},
{
label: '1 Minute',
bounds: {
start: - ONE_MINUTE,
end: THIRTY_SECONDS
}
}
]
}
]
}));
openmct.install(openmct.plugins.SummaryWidget());
openmct.install(openmct.plugins.Notebook());
openmct.install(openmct.plugins.LADTable());
openmct.install(openmct.plugins.Filters(['table', 'telemetry.plot.overlay']));
openmct.install(openmct.plugins.ObjectMigration());
openmct.install(openmct.plugins.Clock({ enableClockIndicator: true }));
openmct.install(openmct.plugins.Timer());
openmct.install(openmct.plugins.Timelist());
openmct.install(openmct.plugins.BarChart());
openmct.install(openmct.plugins.ScatterPlot());

openmct.install(rosmctPlugin());

Expand Down
10 changes: 5 additions & 5 deletions package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,7 @@
"start": "node src/servers/server.js",
"ros-system-test": "node test/ros-system-test.js",
"ros-system-collection-test": "node test/ros-system-collection-test.js",
"realtime-server-test": "node test/realtime-server-test.js",
"postinstall": "cd node_modules/openmct && npm install"
"realtime-server-test": "node test/realtime-server-test.js"
},
"repository": {
"type": "git",
Expand All @@ -25,10 +24,11 @@
"homepage": "https://github.com/rosmod/rosmct#readme",
"dependencies": {
"express": "^4.16.2",
"express-ws": "^3.0.0",
"openmct": "nasa/openmct",
"express-ws": "^5.0.2",
"openmct": "latest",
"pg": "^8.10.0",
"q": "^1.5.1",
"roslib": "^0.19.0",
"roslib": "^1.3.0",
"ws": "^3.3.2"
}
}
Loading