observer Package

commsocket Module

class satnogsclient.observer.commsocket.Commsocket(ip, port)[source]

Handles connectivity with remote ctl demons Namely: rotctl and rigctl

accept()[source]
bind()[source]
buffer_size
connect()[source]
disconnect()[source]
ip
is_connected
listen()[source]
port
receive(size)[source]
send(message)[source]
send_not_recv(message)[source]
tasks_buffer_size

observer Module

class satnogsclient.observer.observer.Observer[source]
frequency
location
observation_decoded_data
observation_end
observation_id
observation_ogg_file
observation_raw_file
observation_receiving_decoded_data
observation_waterfall_file
observation_waterfall_png
observe()[source]

Starts threads for rotcrl and rigctl.

origin
plot_waterfall()[source]
poll_gnu_proc_status()[source]
remove_waterfall_file()[source]
rename_data_file()[source]
rename_ogg_file()[source]
rig_ip
rig_port
rot_ip
rot_port
run_rig()[source]
run_rot()[source]
setup(observation_id, tle, observation_end, frequency, baud, origin, user_args, script_name)[source]

Sets up required internal variables. * returns True if setup is ok * returns False if issue is encountered

tle

orbital Module

satnogsclient.observer.orbital.pinpoint(observer_dict, satellite_dict, timestamp=None)[source]

Provides azimuth and altitude of tracked object.

args:

observer_dict: dictionary with details of observation point. satellite_dict: dictionary with details of satellite. time: timestamp we want to use for pinpointing the observed object.

returns:
Dictionary containing azimuth, altitude and “ok” for error detection.

worker Module

class satnogsclient.observer.worker.Worker(ip, port, time_to_stop=None, frequency=None, proc=None, sleep_time=None)[source]

Class to facilitate as a worker for rotctl/rigctl.

check_observation_end_reached()[source]
is_alive

Returns if tracking loop is alive or not.

observer_dict = {}
satellite_dict = {}
send_to_socket()[source]
trackobject(observer_dict, satellite_dict)[source]

Sets tracking object. Can also be called while tracking to manipulate observation.

trackstart(port, start_thread)[source]

Starts the thread that communicates tracking info to remote socket. Stops by calling trackstop()

trackstop()[source]

Sets object flag to false and stops the tracking thread.

class satnogsclient.observer.worker.WorkerFreq(ip, port, time_to_stop=None, frequency=None, proc=None, sleep_time=None)[source]

Bases: satnogsclient.observer.worker.Worker

send_to_socket(p, sock)[source]
class satnogsclient.observer.worker.WorkerTrack(ip, port, time_to_stop=None, frequency=None, proc=None, sleep_time=None)[source]

Bases: satnogsclient.observer.worker.Worker

send_to_socket(p, sock)[source]