Chilkat HOME Android™ Classic ASP C C++ C# Mono C# .NET Core C# C# UWP/WinRT DataFlex Delphi ActiveX Delphi DLL Visual FoxPro Java Lianja MFC Objective-C Perl PHP ActiveX PHP Extension PowerBuilder PowerShell PureBasic CkPython Chilkat2-Python Ruby SQL Server Swift 2 Swift 3/4 Tcl Unicode C Unicode C++ Visual Basic 6.0 VB.NET VB.NET UWP/WinRT VBScript Xojo Plugin Node.js Excel Go
(VBScript) Firebase Receive Server-Sent Events (text/event-stream)
Demonstrates how to start receiving server-sent events and update your JSON database with each event.
Important: A problem in reading the response text/event-stream was found and fixed after the release of Chilkat v18.104.22.168. This example is valid for Chilkat v22.214.171.124 and greater. (At the time of this writing, which is 18-Sep-2017, Chilkat v126.96.36.199 is not yet released. A .70 pre-release can be obtained by sending a request to email@example.com.)
Dim fso, outFile Set fso = CreateObject("Scripting.FileSystemObject") Set outFile = fso.CreateTextFile("output.txt", True) ' --------------------------------------------------------------------------------------------- ' Important: A problem in reading the response text/event-stream was found and fixed after the release of Chilkat v188.8.131.52. ' This example is valid for Chilkat v184.108.40.206 and greater. ' (At the time of this writing, which is 18-Sep-2017, Chilkat v220.127.116.11 is not yet released. ' A .70 pre-release can be obtained by sending a request to firstname.lastname@example.org.) ' --------------------------------------------------------------------------------------------- ' Demonstrates how to begin receiving server-sent events, and to update ' your JSON database for each event. ' This example requires the Chilkat API to have been previously unlocked. ' See Global Unlock Sample for sample code. ' This example assumes a JWT authentication token, if required, has been previously obtained. ' See Get Firebase Access Token from JSON Service Account Private Key for sample code. ' Load the previously obtained Firebase access token into a string. set fac = CreateObject("Chilkat_9_5_0.FileAccess") accessToken = fac.ReadEntireTextFile("qa_data/tokens/firebaseToken.txt","utf-8") If (fac.LastMethodSuccess <> 1) Then outFile.WriteLine(fac.LastErrorText) WScript.Quit End If set rest = CreateObject("Chilkat_9_5_0.Rest") ' Make the initial connection (without sending a request yet). ' Once connected, any number of requests may be sent. It is not necessary to explicitly ' call Connect before each request. success = rest.Connect("chilkat.firebaseio.com",443,1,1) If (success <> 1) Then outFile.WriteLine(rest.LastErrorText) WScript.Quit End If set authGoogle = CreateObject("Chilkat_9_5_0.AuthGoogle") authGoogle.AccessToken = accessToken success = rest.SetAuthGoogle(authGoogle) success = rest.AddHeader("Accept","text/event-stream") success = rest.AddHeader("Cache-Control","no-cache") responseBody = rest.FullRequestNoBody("GET","/.json") ' A 307 redirect response is expected. If (rest.ResponseStatusCode <> 307) Then outFile.WriteLine("Unexpected response code: " & rest.ResponseStatusCode) outFile.WriteLine(responseBody) outFile.WriteLine("Failed.") WScript.Quit End If ' Get the redirect URL ' url is a Chilkat_9_5_0.Url Set url = rest.RedirectUrl() If (rest.LastMethodSuccess <> 1) Then outFile.WriteLine(rest.LastErrorText) WScript.Quit End If outFile.WriteLine("redirect URL domain: " & url.Host) outFile.WriteLine("redirect URL path: " & url.Path) outFile.WriteLine("redirect URL query params: " & url.Query) outFile.WriteLine("redirect URL path with query params: " & url.PathWithQueryParams) ' Our text/event-stream will be obtained from the redirect URL... set rest2 = CreateObject("Chilkat_9_5_0.Rest") success = rest2.Connect(url.Host,443,1,1) If (success <> 1) Then outFile.WriteLine(rest2.LastErrorText) WScript.Quit End If success = rest2.AddHeader("Accept","text/event-stream") success = rest2.AddHeader("Cache-Control","no-cache") ' Add the redirect query params to the request success = rest2.AddQueryParams(url.Query) ' In our case, we don't actually need the auth query param, ' so remove it. success = rest2.RemoveQueryParam("auth") ' Send the request. (We are only sending the request here. ' We are not yet getting the response because the response ' will be a text/event-stream.) success = rest2.SendReqNoBody("GET",url.Path) If (success <> 1) Then outFile.WriteLine(rest2.LastErrorText) WScript.Quit End If ' Read the response header. ' We want to first get the response header to see if it's a successful ' response status code. If not, then the response will not be a text/event-stream ' and we should read the response body normally. responseStatusCode = rest2.ReadResponseHeader() If (responseStatusCode < 0) Then outFile.WriteLine(rest2.LastErrorText) WScript.Quit End If ' If successful, a 200 response code is expected. ' If the reponse code is not 200, then read the response body and fail.. If (responseStatusCode <> 200) Then outFile.WriteLine("Response Code: " & responseStatusCode) outFile.WriteLine("Response Status Text: " & rest2.ResponseStatusText) outFile.WriteLine("Response Header: " & rest2.ResponseHeader) responseBody = rest2.ReadRespBodyString() If (rest2.LastMethodSuccess = 1) Then outFile.WriteLine("Error Response Body: " & responseBody) End If outFile.WriteLine("Failed.") WScript.Quit End If ' For this example, our JSON database will be empty at the beginning. ' The incoming events (put and patch) will be applied to this database. set jsonDb = CreateObject("Chilkat_9_5_0.JsonObject") ' Make sure to set the JSON path delimiter to "/". The default is "." and this ' is not compatible with Firebase paths. jsonDb.DelimiterChar = "/" ' At this point, we've received the response header. Now it's time to begin ' receiving the event stream. We'll start a background thread to read the ' stream. (Our main application (foreground) thread can cancel it at any time.) ' While receiving in the background thread, our foreground thread can read the stream ' as it desires.. set eventStream = CreateObject("Chilkat_9_5_0.Stream") ' This sse object will be used as a helper to parse the server-sent event stream. set sse = CreateObject("Chilkat_9_5_0.ServerSentEvent") ' task is a Chilkat_9_5_0.Task Set task = rest2.ReadRespBodyStreamAsync(eventStream,1) success = task.Run() ' For this example, we'll just read a few events, and then cancel the ' async task. count = 0 Do While (count < 3) And (task.Finished = 0) ' Get the next event, which is a series of text lines ending with ' a blank line. ' Note: This method blocks the calling thread until a message arrives. ' a program might instead periodically check the availability of ' data via the stream's DataAvailable property, and then do the read. ' An alternative to writing a while loop to read the event stream ' would be to setup some sort of timer event in your program (using whatever timer functionality ' is provided in a programming language/environment), to periodically check the eventStream's ' DataAvailable property and consume the incoming event. eventStr = eventStream.ReadUntilMatch(vbCrLf & vbCrLf) If (eventStream.LastMethodSuccess <> 1) Then outFile.WriteLine(eventStream.LastErrorText) ' Force the loop to exit by setting the count to a high number. count = 99999 Else outFile.WriteLine("Event: [" & eventStr & "]") ' We have an event. Let's update our local copy of the JSON database. success = sse.LoadEvent(eventStr) If (success <> 1) Then outFile.WriteLine("Failed to load sse event: " & eventStr) Else ' Now we can easily access the event name and data, and apply it to our JSON database: success = jsonDb.FirebaseApplyEvent(sse.EventName,sse.Data) If (success <> 1) Then outFile.WriteLine("Failed to apply event: " & sse.EventName & ": " & sse.Data) Else outFile.WriteLine("Successfully applied event: " & sse.EventName & ": " & sse.Data) End If End If End If count = count + 1 Loop ' Make sure the background task is cancelled if still running. success = task.Cancel() ' Examine the JSON database after applying events.. jsonDb.EmitCompact = 0 outFile.WriteLine("----") outFile.WriteLine(jsonDb.Emit()) outFile.Close
© 2000-2019 Chilkat Software, Inc. All Rights Reserved.