-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
SerialCommutator now manages its own serial port
- This is an attempt at getting around a possible issue with Bonsai's serial port libary implementation which is failing on some machines. - Not sure if it will fix anything - SerialCommutator is now used in AutoCommuator
- Loading branch information
Showing
3 changed files
with
140 additions
and
96 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,41 @@ | ||
| using System.ComponentModel; | ||
| using System.IO.Ports; | ||
| using System.Linq; | ||
| using Bonsai; | ||
| using Bonsai.Expressions; | ||
| using Bonsai.IO.Ports; | ||
|
|
||
| namespace OpenEphys.Commutator | ||
| { | ||
| class PortNameConverter : StringConverter | ||
| { | ||
| public override bool GetStandardValuesSupported(ITypeDescriptorContext context) | ||
| { | ||
| return true; | ||
| } | ||
|
|
||
| public override StandardValuesCollection GetStandardValues(ITypeDescriptorContext context) | ||
| { | ||
| if (context != null) | ||
| { | ||
| var workflowBuilder = (WorkflowBuilder)context.GetService(typeof(WorkflowBuilder)); | ||
| if (workflowBuilder != null) | ||
| { | ||
| var portNames = (from builder in workflowBuilder.Workflow.Descendants() | ||
| where builder is not DisableBuilder | ||
| let createPort = ExpressionBuilder.GetWorkflowElement(builder) as CreateSerialPort | ||
| where createPort != null && !string.IsNullOrEmpty(createPort.PortName) | ||
| select !string.IsNullOrEmpty(createPort.Name) ? createPort.Name : createPort.PortName) | ||
| .Distinct() | ||
| .ToList(); | ||
| if (portNames.Count > 0) | ||
| { | ||
| return new StandardValuesCollection(portNames); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| return new StandardValuesCollection(SerialPort.GetPortNames()); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,91 @@ | ||
| using System; | ||
| using System.ComponentModel; | ||
| using System.IO.Ports; | ||
| using System.Reactive.Linq; | ||
| using System.Reactive.Subjects; | ||
| using Bonsai; | ||
|
|
||
| namespace OpenEphys.Commutator | ||
| { | ||
| /// <summary> | ||
| /// Represents an operator controls an Open Ephys commutator by writing a JSON-encoded | ||
| /// representations of each element of the input sequence to a serial port and produces the | ||
| /// JSON-encoded command string. | ||
| /// </summary> | ||
| [Description("Controls an Open Ephys commutator using a serial port.")] | ||
| public class SerialCommutator : Combinator<double, string> | ||
| { | ||
|
|
||
| const string ConfigurationCategory = "Configuration"; | ||
| const string AcquisitionCategory = "Acquisition"; | ||
|
|
||
| readonly BehaviorSubject<bool> enabled = new(true); | ||
| readonly BehaviorSubject<bool> led = new(true); | ||
|
|
||
| /// <summary> | ||
| /// Gets or sets the name of the serial port. | ||
| /// </summary> | ||
| [Category(ConfigurationCategory)] | ||
| [TypeConverter(typeof(PortNameConverter))] | ||
| [Description("The name of the serial port.")] | ||
| public string PortName { get; set; } | ||
|
|
||
| /// <summary> | ||
| /// Gets or sets the commutator enable state. | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// If true, the commutator will activate the motor and respond to turn commands. If false, | ||
| /// the motor driver will be deactivated and motion commands will be ignored. | ||
| /// </remarks> | ||
| [Category(AcquisitionCategory)] | ||
| [Description("If true, the commutator will be enabled. If false, it will disable the motor and ignore motion commands.")] | ||
| public bool Enable | ||
| { | ||
| get => enabled.Value; | ||
| set => enabled.OnNext(value); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Gets or sets the commutator indication LED enable state. | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// If true, the commutator indication LED turn on. If false, the indication LED will turn | ||
| /// off. | ||
| /// </remarks> | ||
| [Category(AcquisitionCategory)] | ||
| [Description("If true, the commutator indication LED turn on. If false, the indication LED will turn off.")] | ||
| public bool EnableLed | ||
| { | ||
| get => led.Value; | ||
| set => led.OnNext(value); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Writes a JSON-encoded representations of each element of the input sequence, as well as | ||
| /// configuration property values, to a serial port. | ||
| /// </summary> | ||
| /// <param name="source">A sequence of motor turn values in units of full rotations.</param> | ||
| /// <returns>JSON-encoded command string sent to the commutator.</returns> | ||
| public override IObservable<string> Process(IObservable<double> source) | ||
| { | ||
| return Observable.Using( | ||
| () => | ||
| { | ||
| var s = new SerialPort(PortName); | ||
| s.Open(); | ||
| return s; | ||
| }, | ||
| s => | ||
| { | ||
| var turnCommands = source.Select(x => $"{{turn:{x}}}"); | ||
| var enabledCommands = enabled.Select(x => x ? "true" : "false").Select(x => $"{{enable:{x}}}"); | ||
| var ledCommands = led.Select(x => x ? "true" : "false").Select(x => $"{{led:{x}}}"); | ||
| return turnCommands | ||
| .Merge(enabledCommands) | ||
| .Merge(ledCommands) | ||
| .Do(command => s.Write(command)); | ||
| } | ||
| ); | ||
| } | ||
| } | ||
| } |