Skip to content

Instantly share code, notes, and snippets.

@chrishamant

chrishamant/ServerSentEventsClient.cs

Forked from dmiddlecamp/ServerSentEventsClient.cs
Created September 9, 2022 20:08
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save chrishamant/a951588f65606929b25e4477e2f54ff8 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save chrishamant/a951588f65606929b25e4477e2f54ff8 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. @dmiddlecamp dmiddlecamp revised this gist May 12, 2014. 1 changed file with 8 additions and 0 deletions.
    8 changes: 8 additions & 0 deletions ServerSentEventsClient.cs
    View file
    Original file line number Diff line number Diff line change
    @@ -77,6 +77,7 @@ public static void ProcessLines() {

    SSEvent lastEvent = null;
    int index = 0;
    int lastEventIdx = -1;

    for(int i=0;i<lines.Count;i++) {
    var line = lines[i];
    @@ -102,8 +103,15 @@ public static void ProcessLines() {
    Console.WriteLine("Name was: " + lastEvent.Name);
    Console.WriteLine("Data was: " + lastEvent.Data);
    index++;
    lastEventIdx = i;
    }
    }
    //trim previously processed events
    if (lastEventIdx >= 0) {
    lines.RemoveRange(0, lastEventIdx);
    }


    }

    /*
  2. @dmiddlecamp dmiddlecamp created this gist May 8, 2014.
    120 changes: 120 additions & 0 deletions ServerSentEventsClient.cs
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,120 @@
    using System;
    using System.IO;
    using System.Net;
    using System.Text;
    using System.Collections.Generic;


    public class SSEvent {
    public string Name { get; set; }
    public string Data { get; set; }
    }


    public class Application {
    public static List<string> Queue = new List<string>(1024);


    public static void Main() {
    Console.Write("Hello World\n");
    Console.Write("Attempting to open stream\n");

    var response = Application.OpenSSEStream("https://api.spark.io/v1/events?access_token=<YOUR_ACCESS_TOKEN>");
    Console.Write("Success! \n");
    }


    public static Stream OpenSSEStream(string url) {
    /*
    Optionally ignore certificate errors
    ServicePointManager.ServerCertificateValidationCallback =
    new System.Net.Security.RemoteCertificateValidationCallback(AcceptAllCertifications);
    */


    var request = WebRequest.Create( new Uri(url));
    ((HttpWebRequest)request).AllowReadStreamBuffering = false;
    var response = request.GetResponse();
    var stream = response.GetResponseStream();

    Application.ReadStreamForever(stream);

    return stream;
    }

    public static void ReadStreamForever(Stream stream) {
    var encoder = new UTF8Encoding();
    var buffer = new byte[2048];
    while(true) {
    //TODO: Better evented handling of the response stream

    if (stream.CanRead) {
    int len = stream.Read(buffer, 0, 2048);
    if (len > 0) {
    var text = encoder.GetString(buffer, 0, len);
    Application.Push(text);
    }
    }
    //System.Threading.Thread.Sleep(250);
    }
    }

    public static void Push(string text) {
    if (String.IsNullOrWhiteSpace(text)) {
    return;
    }

    var lines = text.Trim().Split('\n');
    Application.Queue.AddRange(lines);

    if (text.Contains("data:")) {
    Application.ProcessLines();
    }
    }

    public static void ProcessLines() {
    var lines = Application.Queue;

    SSEvent lastEvent = null;
    int index = 0;

    for(int i=0;i<lines.Count;i++) {
    var line = lines[i];
    if (String.IsNullOrWhiteSpace(line)) {
    continue;
    }
    line = line.Trim();

    if (line.StartsWith("event:")) {
    lastEvent = new SSEvent() {
    Name = line.Replace("event:", String.Empty)
    };
    }
    else if (line.StartsWith("data:")) {
    if (lastEvent == null) {
    continue;
    }


    lastEvent.Data = line.Replace("data:", String.Empty);

    Console.WriteLine("Found event: " + index);
    Console.WriteLine("Name was: " + lastEvent.Name);
    Console.WriteLine("Data was: " + lastEvent.Data);
    index++;
    }
    }
    }

    /*
    Optionally ignore certificate errors
    */
    public bool AcceptALlCertifications(object sender,
    System.Security.Cryptography.X509Certificates.X509Certificate cert,
    System.Security.Cryptography.X509Certificates.X509Chain chain,
    System.Net.Security.SslPolicyErrors errors)
    {
    return true;
    }
    }