mirror of
https://github.com/jwetzell/qController.git
synced 2026-08-11 02:13:55 +00:00
117 lines
4.3 KiB
C#
117 lines
4.3 KiB
C#
//Class used for updating local "copy" of workspace info, cue-lists, cues, etc.
|
|
using System;
|
|
using System.Threading;
|
|
using Serilog;
|
|
using Xamarin.Forms;
|
|
using Serilog;
|
|
|
|
namespace qController.Communication
|
|
{
|
|
public class QUpdater
|
|
{
|
|
|
|
private bool active = true;
|
|
private bool started = false;
|
|
private QController qController;
|
|
private Thread updateThread;
|
|
|
|
public QUpdater(QController controller)
|
|
{
|
|
qController = controller;
|
|
updateThread = new Thread(new ThreadStart(UpdateLoop));
|
|
qController.qClient.qParser.CueInfoUpdated += OnCueUpdateReceived;
|
|
qController.qClient.qParser.WorkspaceUpdated += OnWorkspaceUpdated;
|
|
qController.qClient.qParser.PlaybackPositionUpdated += OnPlaybackPositionUpdated;
|
|
qController.qClient.qParser.WorkspaceLoadError += OnWorkspaceLoadError;
|
|
qController.qClient.qParser.ConnectionStatusChanged += OnConnectionStatusChanged;
|
|
|
|
}
|
|
|
|
private void OnConnectionStatusChanged(object source, ConnectEventArgs args)
|
|
{
|
|
Log.Debug("QUPDATER - Connection Status Changed: " + args.Status);
|
|
if (args.Status == "ok")
|
|
{
|
|
qController.qClient.sendTCP("/workspace/" + qController.qWorkspace.workspace_id + "/updates", 1);
|
|
qController.qClient.sendTCP("/workspace/" + qController.qWorkspace.workspace_id + "/cueLists");
|
|
}
|
|
}
|
|
|
|
private void OnWorkspaceLoadError(object source, WorkspaceEventArgs args)
|
|
{
|
|
Log.Debug("QUPDATER - Loading cuelists has failed for some reason retrying");
|
|
//qController.qClient.sendArgsUDP("/workspace/" + args.UpdatedWorkspace.workspace_id + "/connect");
|
|
//qController.qClient.sendArgsUDP("/workspace/" + args.UpdatedWorkspace.workspace_id + "/updates", 1);
|
|
//qController.qClient.sendTCP("/workspace/" + args.UpdatedWorkspace.workspace_id + "/cueLists");
|
|
|
|
}
|
|
|
|
public void Start(){
|
|
Log.Debug("QUPDATER - Start() method called");
|
|
try
|
|
{
|
|
//updateThread.Start();
|
|
Log.Debug("QUPDATER - updateThread started");
|
|
}
|
|
catch (ThreadStateException tSe)
|
|
{
|
|
Log.Debug("QUPDATER - updateThread already started");
|
|
}
|
|
}
|
|
|
|
//Attempt at a "keep alive" message
|
|
public void UpdateLoop()
|
|
{
|
|
active = true;
|
|
Device.StartTimer(TimeSpan.FromSeconds(5.0), () => {
|
|
SendThump();
|
|
return active;
|
|
});
|
|
}
|
|
|
|
public void OnCueUpdateReceived(object source, CueEventArgs args)
|
|
{
|
|
qController.qWorkspace.UpdateCue(args.Cue);
|
|
|
|
if (args.Cue.type == "Group")
|
|
{
|
|
//Log.Debug("QUpdater/Updated cue was group cue, sending children request");
|
|
qController.qClient.sendTCP("/workspace/"+qController.qWorkspace.workspace_id+"/cue_id/" + args.Cue.uniqueID + "/children");
|
|
}
|
|
}
|
|
|
|
public void OnWorkspaceUpdated(object source, WorkspaceEventArgs args)
|
|
{
|
|
qController.qWorkspace = args.UpdatedWorkspace;
|
|
qController.playbackPosition = null;
|
|
qController.qWorkspace.CheckPopulated();
|
|
if (qController.qWorkspace.IsPopulated)
|
|
{
|
|
Log.Debug("QUPDATER - Workspace group cues are already populated");
|
|
App.showToast("Workspace cues have been loaded....");
|
|
//get selected cue
|
|
qController.qClient.UpdateSelectedCue(qController.qWorkspace.workspace_id);
|
|
return;
|
|
}
|
|
}
|
|
|
|
public void OnPlaybackPositionUpdated(object source, PlaybackPositionArgs args)
|
|
{
|
|
qController.playbackPosition = args.PlaybackPosition;
|
|
Log.Debug("QUPDATER - Update Specific Cue Called because of Playback Position Updated");
|
|
qController.qClient.UpdateSpecificCue(qController.qWorkspace.workspace_id,args.PlaybackPosition);
|
|
}
|
|
|
|
public void SendThump()
|
|
{
|
|
|
|
qController.qClient.sendTCP("/workspace/" + qController.qWorkspace.workspace_id + "/thump");
|
|
}
|
|
|
|
public void Kill(){
|
|
active = false;
|
|
updateThread.Abort();
|
|
}
|
|
}
|
|
}
|