Permalink
Browse files

moving repo

  • Loading branch information...
1 parent da0fb92 commit ba43e8a4aa47ab3060d2869691f662bfce194b3c geremy committed Mar 21, 2013
Showing with 2 additions and 30,655 deletions.
  1. +0 −396 csharp/3.1/Pubnub.cs
  2. BIN csharp/3.1/Pubnub.exe
  3. BIN csharp/3.1/Pubnub.exe.mdb
  4. +0 −400 csharp/3.1/Pubnub2.cs
  5. +0 −1,007 csharp/3.1/PubnubAsync.cs
  6. +0 −392 csharp/3.1/PubnubCustomer.cs
  7. BIN csharp/3.1/PubnubCustomer.exe
  8. BIN csharp/3.1/PubnubCustomer.exe.mdb
  9. BIN csharp/3.1/System.Runtime.Serialization.Json.dll
  10. +0 −65 csharp/3.1/System.Runtime.Serialization.Json.xml
  11. BIN csharp/3.1/System.Web.Extensions.dll
  12. +0 −10,600 csharp/3.1/System.Web.Extensions.xml
  13. +0 −8 csharp/3.1/customer-api-build
  14. +0 −8 csharp/3.1/mono-build
  15. +0 −7 csharp/3.1/mono-build-asyc
  16. +0 −7 csharp/3.1/mono-build-async
  17. +0 −35 csharp/3.2/PubNub-Messaging.Tests/Properties/AssemblyInfo.cs
  18. +0 −77 csharp/3.2/PubNub-Messaging.Tests/PubNub-Messaging.Tests.csproj
  19. +0 −58 csharp/3.2/PubNub-Messaging.Tests/WhenAClientIsPresented.cs
  20. +0 −119 csharp/3.2/PubNub-Messaging.Tests/WhenAMessageIsPublished.cs
  21. +0 −39 csharp/3.2/PubNub-Messaging.Tests/WhenGetRequestHistoryMessage.cs
  22. +0 −33 csharp/3.2/PubNub-Messaging.Tests/WhenGetRequestServerTime.cs
  23. +0 −38 csharp/3.2/PubNub-Messaging.Tests/WhenSubscribedToAChannel.cs
  24. +0 −103 csharp/3.2/PubNub-Messaging/PubNub-Messaging.csproj
  25. +0 −13 csharp/3.2/PubNub-Messaging/PubNub-Messaging.csproj.user
  26. +0 −1,167 csharp/3.2/PubNub-Messaging/Pubnub.cs
  27. +0 −201 csharp/3.2/PubNub-Messaging/Pubnub_Example.cs
  28. +0 −3 csharp/3.2/PubNub-Messaging/app.config
  29. +0 −54 csharp/3.2/PubNub.sln
  30. BIN csharp/3.2/PubNub.suo
  31. +0 −1 csharp/3.3.0.1/.gitignore
  32. BIN csharp/3.3.0.1/NugetPkg/Pubnub.3.3.0.1-release-01-02-13-5.nupkg
  33. BIN csharp/3.3.0.1/NugetPkg/Pubnub.3.3.0.1-release-12-17-12-1.nupkg
  34. BIN csharp/3.3.0.1/NugetPkg/Pubnub.3.3.0.2.nupkg
  35. +0 −23 csharp/3.3.0.1/PubNub-Messaging.Tests/App.config
  36. +0 −513 csharp/3.3.0.1/PubNub-Messaging.Tests/EncryptionTests.cs
  37. +0 −36 csharp/3.3.0.1/PubNub-Messaging.Tests/Properties/AssemblyInfo.cs
  38. +0 −118 csharp/3.3.0.1/PubNub-Messaging.Tests/PubNub-Messaging.Tests.csproj
  39. +0 −16 csharp/3.3.0.1/PubNub-Messaging.Tests/PubNub-Messaging.Tests.csproj.user
  40. +0 −411 csharp/3.3.0.1/PubNub-Messaging.Tests/PubnubUnitTest.cs
  41. +0 −214 csharp/3.3.0.1/PubNub-Messaging.Tests/WhenAClientIsPresented.cs
  42. +0 −495 csharp/3.3.0.1/PubNub-Messaging.Tests/WhenAMessageIsPublished.cs
  43. +0 −193 csharp/3.3.0.1/PubNub-Messaging.Tests/WhenDetailedHistoryIsRequested.cs
  44. +0 −116 csharp/3.3.0.1/PubNub-Messaging.Tests/WhenGetRequestServerTime.cs
  45. +0 −126 csharp/3.3.0.1/PubNub-Messaging.Tests/WhenSubscribedToAChannel.cs
  46. BIN csharp/3.3.0.1/PubNub-Messaging.Tests/bin/Debug/Newtonsoft.Json.dll
  47. BIN csharp/3.3.0.1/PubNub-Messaging.Tests/bin/Debug/nunit.framework.dll
  48. BIN csharp/3.3.0.1/PubNub-Messaging.Tests/bin/Release/nunit.framework.dll
  49. BIN csharp/3.3.0.1/PubNub-Messaging.Tests/v3.5/Newtonsoft.Json.dll
  50. BIN csharp/3.3.0.1/PubNub-Messaging.Tests/v4.0/Newtonsoft.Json.dll
  51. +0 −183 csharp/3.3.0.1/PubNub-Messaging/PubNub-Messaging.csproj
  52. +0 −14 csharp/3.3.0.1/PubNub-Messaging/PubNub-Messaging.csproj.user
  53. +0 −3,591 csharp/3.3.0.1/PubNub-Messaging/Pubnub.cs
  54. +0 −245 csharp/3.3.0.1/PubNub-Messaging/PubnubExample.cs
  55. +0 −22 csharp/3.3.0.1/PubNub-Messaging/app.config
  56. BIN csharp/3.3.0.1/PubNub-Messaging/bin/Debug/Newtonsoft.Json.dll
  57. BIN csharp/3.3.0.1/PubNub-Messaging/bin/Release/Newtonsoft.Json.dll
  58. BIN csharp/3.3.0.1/PubNub-Messaging/v3.5/Newtonsoft.Json.dll
  59. +0 −1 csharp/3.3.0.1/PubNub-Messaging/v3.5/Notes.txt
  60. BIN csharp/3.3.0.1/PubNub-Messaging/v3.5/System.Threading.dll
  61. BIN csharp/3.3.0.1/PubNub-Messaging/v4.0/Newtonsoft.Json.dll
  62. +0 −44 csharp/3.3.0.1/PubNub.sln
  63. +0 −35 csharp/3.3/PubNub-Messaging.Tests/Properties/AssemblyInfo.cs
  64. +0 −78 csharp/3.3/PubNub-Messaging.Tests/PubNub-Messaging.Tests.csproj
  65. +0 −60 csharp/3.3/PubNub-Messaging.Tests/WhenAClientIsPresented.cs
  66. +0 −123 csharp/3.3/PubNub-Messaging.Tests/WhenAMessageIsPublished.cs
  67. +0 −42 csharp/3.3/PubNub-Messaging.Tests/WhenDetailedHistoryIsRequested.cs
  68. +0 −40 csharp/3.3/PubNub-Messaging.Tests/WhenGetRequestHistoryMessage.cs
  69. +0 −34 csharp/3.3/PubNub-Messaging.Tests/WhenGetRequestServerTime.cs
  70. +0 −39 csharp/3.3/PubNub-Messaging.Tests/WhenSubscribedToAChannel.cs
  71. +0 −103 csharp/3.3/PubNub-Messaging/PubNub-Messaging.csproj
  72. +0 −13 csharp/3.3/PubNub-Messaging/PubNub-Messaging.csproj.user
  73. +0 −1,254 csharp/3.3/PubNub-Messaging/Pubnub.cs
  74. +0 −486 csharp/3.3/PubNub-Messaging/Pubnub_Example.cs
  75. +0 −3 csharp/3.3/PubNub-Messaging/app.config
  76. +0 −42 csharp/3.3/PubNub.sln
  77. BIN csharp/3.3/PubNub.suo
  78. +0 −1 csharp/3.4/.gitignore
  79. BIN csharp/3.4/NugetPkg/Pubnub.3.3.0.2.nupkg
  80. BIN csharp/3.4/NugetPkg/Pubnub.3.4.0.1-rc1.nupkg
  81. +0 −23 csharp/3.4/PubNub-Messaging.Tests/App.config
  82. +0 −546 csharp/3.4/PubNub-Messaging.Tests/EncryptionTests.cs
  83. +0 −36 csharp/3.4/PubNub-Messaging.Tests/Properties/AssemblyInfo.cs
  84. +0 −120 csharp/3.4/PubNub-Messaging.Tests/PubNub-Messaging.Tests.csproj
  85. +0 −16 csharp/3.4/PubNub-Messaging.Tests/PubNub-Messaging.Tests.csproj.user
  86. +0 −515 csharp/3.4/PubNub-Messaging.Tests/PubnubUnitTest.cs
  87. +0 −284 csharp/3.4/PubNub-Messaging.Tests/WhenAClientIsPresented.cs
  88. +0 −571 csharp/3.4/PubNub-Messaging.Tests/WhenAMessageIsPublished.cs
  89. +0 −194 csharp/3.4/PubNub-Messaging.Tests/WhenDetailedHistoryIsRequested.cs
  90. +0 −116 csharp/3.4/PubNub-Messaging.Tests/WhenGetRequestServerTime.cs
  91. +0 −295 csharp/3.4/PubNub-Messaging.Tests/WhenSubscribedToAChannel.cs
  92. +0 −127 csharp/3.4/PubNub-Messaging.Tests/WhenUnsubscribedToAChannel.cs
  93. BIN csharp/3.4/PubNub-Messaging.Tests/v3.5/Newtonsoft.Json.dll
  94. BIN csharp/3.4/PubNub-Messaging.Tests/v4.0/Newtonsoft.Json.dll
  95. +0 −183 csharp/3.4/PubNub-Messaging/PubNub-Messaging.csproj
  96. +0 −14 csharp/3.4/PubNub-Messaging/PubNub-Messaging.csproj.user
  97. +0 −3,686 csharp/3.4/PubNub-Messaging/Pubnub.cs
  98. +0 −283 csharp/3.4/PubNub-Messaging/PubnubExample.cs
  99. +0 −23 csharp/3.4/PubNub-Messaging/app.config
  100. BIN csharp/3.4/PubNub-Messaging/v3.5/Newtonsoft.Json.dll
  101. +0 −1 csharp/3.4/PubNub-Messaging/v3.5/Notes.txt
  102. BIN csharp/3.4/PubNub-Messaging/v3.5/System.Threading.dll
  103. BIN csharp/3.4/PubNub-Messaging/v4.0/Newtonsoft.Json.dll
  104. +0 −44 csharp/3.4/PubNub.sln
  105. +2 −33 csharp/README.md
View
396 csharp/3.1/Pubnub.cs
@@ -1,396 +0,0 @@
-using System;
-using System.IO;
-using System.Net;
-using System.Text;
-using System.Collections;
-using System.Collections.Generic;
-using System.Security.Cryptography;
-using System.Web.Script.Serialization;
-
-/**
- * PubNub 3.0 Real-time Push Cloud API
- *
- * @author Stephen Blum
- * @package pubnub
- */
-public class PubnubTEST {
- static public void Main() {
- // -----------------
- // Init Pubnub Class
- // -----------------
- Pubnub pubnub = new Pubnub(
- "demo", // PUBLISH_KEY
- "demo", // SUBSCRIBE_KEY
- "", // SECRET_KEY
- false // SSL_ON?
- );
- string channel = "test-channel-顶";
-
- // ---------------
- // Publish Message
- // ---------------
- List<object> info = pubnub.Publish( channel, "Hello World" );
-
- // ----------------
- // Publish Response
- // ----------------
- Console.WriteLine(
- "Publish Success: " + info[0].ToString() +
- "\nPublish Info: " + info[1]
- );
-
- // -------
- // History
- // -------
- List<object> history = pubnub.History( channel, 1 );
- foreach (object history_message in history) {
- Console.Write("History Message: ");
- Console.WriteLine(history_message);
- }
-
- // ----------------------
- // Get PubNub Server Time
- // ----------------------
- object timestamp = pubnub.Time();
- Console.WriteLine("Server Time: " + timestamp.ToString());
-
- // ---------
- // Subscribe
- // ---------
- pubnub.Subscribe(
- channel,
- delegate (object message) {
- Console.WriteLine("Received Message -> '" + message + "'");
- return true;
- }
- );
- }
-}
-
-
-/**
- * PubNub 3.0 Real-time Push Cloud API
- *
- * @author Stephen Blum
- * @package pubnub
- */
-public class Pubnub {
- private string ORIGIN = "pubsub.pubnub.com";
- private int LIMIT = 1800;
- private string PUBLISH_KEY = "";
- private string SUBSCRIBE_KEY = "";
- private string SECRET_KEY = "";
- private bool SSL = false;
-
- public delegate bool Procedure(object message);
-
- /**
- * PubNub 3.0
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- * @param bool SSL Enabled.
- */
- public Pubnub(
- string publish_key,
- string subscribe_key,
- string secret_key,
- bool ssl_on
- ) {
- this.init( publish_key, subscribe_key, secret_key, ssl_on );
- }
-
- /**
- * PubNub 2.0 Compatibility
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- */
- public Pubnub(
- string publish_key,
- string subscribe_key
- ) {
- this.init( publish_key, subscribe_key, "", false );
- }
-
- /**
- * PubNub 3.0 without SSL
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- */
- public Pubnub(
- string publish_key,
- string subscribe_key,
- string secret_key
- ) {
- this.init( publish_key, subscribe_key, secret_key, false );
- }
-
- /**
- * Init
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- * @param bool SSL Enabled.
- */
- public void init(
- string publish_key,
- string subscribe_key,
- string secret_key,
- bool ssl_on
- ) {
- this.PUBLISH_KEY = publish_key;
- this.SUBSCRIBE_KEY = subscribe_key;
- this.SECRET_KEY = secret_key;
- this.SSL = ssl_on;
-
- // SSL On?
- if (this.SSL) {
- this.ORIGIN = "https://" + this.ORIGIN;
- }
- else {
- this.ORIGIN = "http://" + this.ORIGIN;
- }
- }
-
- /**
- * History
- *
- * Load history from a channel.
- *
- * @param String channel name.
- * @param int limit history count response.
- * @return ListArray of history.
- */
- public List<object> History( string channel, int limit ) {
- List<string> url = new List<string>();
-
- url.Add("history");
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(channel);
- url.Add("0");
- url.Add(limit.ToString());
-
- return _request(url);
- }
-
- /**
- * Publish
- *
- * Send a message to a channel.
- *
- * @param String channel name.
- * @param List<object> info.
- * @return bool false on fail.
- */
- public List<object> Publish( string channel, object message ) {
- JavaScriptSerializer serializer = new JavaScriptSerializer();
-
- // Generate String to Sign
- string signature = "0";
- if (this.SECRET_KEY.Length > 0) {
- StringBuilder string_to_sign = new StringBuilder();
- string_to_sign
- .Append(this.PUBLISH_KEY)
- .Append('/')
- .Append(this.SUBSCRIBE_KEY)
- .Append('/')
- .Append(this.SECRET_KEY)
- .Append('/')
- .Append(channel)
- .Append('/')
- .Append(serializer.Serialize(message));
-
- // Sign Message
- signature = md5(string_to_sign.ToString());
- }
-
- // Build URL
- List<string> url = new List<string>();
- url.Add("publish");
- url.Add(this.PUBLISH_KEY);
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(signature);
- url.Add(channel);
- url.Add("0");
- url.Add(serializer.Serialize(message));
-
- // Return JSONArray
- return _request(url);
- }
-
- /**
- * Subscribe
- *
- * This function is BLOCKING.
- * Listen for a message on a channel.
- *
- * @param string channel name.
- * @param Procedure function callback.
- */
- public void Subscribe( string channel, Procedure callback ) {
- this._subscribe( channel, callback, 0 );
- }
-
- /**
- * Subscribe - Private Interface
- *
- * @param string channel name.
- * @param Procedure function callback.
- * @param string timetoken.
- */
- private void _subscribe(
- string channel,
- Procedure callback,
- object timetoken
- ) {
- // Begin Recusive Subscribe
- try {
- // Build URL
- List<string> url = new List<string>();
- url.Add("subscribe");
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(channel);
- url.Add("0");
- url.Add(timetoken.ToString());
-
- // Wait for Message
- List<object> response = _request(url);
-
- // Update TimeToken
- if (response[1].ToString().Length > 0)
- timetoken = (object)response[1];
-
- // Run user Callback and Reconnect if user permits.
- foreach (object message in (object[])response[0]) {
- if (!callback(message)) return;
- }
-
- // Keep listening if Okay.
- this._subscribe( channel, callback, timetoken );
- }
- catch {
- System.Threading.Thread.Sleep(1000);
- this._subscribe( channel, callback, timetoken );
- }
- }
-
- /**
- * Time
- *
- * Timestamp from PubNub Cloud.
- *
- * @return object timestamp.
- */
- public object Time() {
- List<string> url = new List<string>();
-
- url.Add("time");
- url.Add("0");
-
- List<object> response = _request(url);
- return response[0];
- }
-
- /**
- * Request URL
- *
- * @param List<string> request of url directories.
- * @return List<object> from JSON response.
- */
- private List<object> _request(List<string> url_components) {
- string temp = null;
- int count = 0;
- byte[] buf = new byte[8192];
- StringBuilder url = new StringBuilder();
- StringBuilder sb = new StringBuilder();
-
- JavaScriptSerializer serializer = new JavaScriptSerializer();
-
- // Add Origin To The Request
- url.Append(this.ORIGIN);
-
- // Generate URL with UTF-8 Encoding
- foreach ( string url_bit in url_components) {
- url.Append("/");
- url.Append(_encodeURIcomponent(url_bit));
- }
-
- // Fail if string too long
- if (url.Length > this.LIMIT) {
- List<object> too_long = new List<object>();
- too_long.Add(0);
- too_long.Add("Message Too Long.");
- return too_long;
- }
-
- // Create Request
- HttpWebRequest request = (HttpWebRequest)
- WebRequest.Create(url.ToString());
-
- // Set Timeout
- request.Timeout = 200000;
- request.ReadWriteTimeout = 200000;
-
- // Receive Response
- HttpWebResponse response = (HttpWebResponse)request.GetResponse();
- Stream resStream = response.GetResponseStream();
-
- // Read
- do {
- count = resStream.Read( buf, 0, buf.Length );
- if (count != 0) {
- temp = Encoding.UTF8.GetString( buf, 0, count );
- sb.Append(temp);
- }
- } while (count > 0);
-
- // Parse Response
- string message = sb.ToString();
-
- return serializer.Deserialize<List<object>>(message);
- }
-
- private string _encodeURIcomponent(string s) {
- StringBuilder o = new StringBuilder();
- foreach (char ch in s.ToCharArray()) {
- if (isUnsafe(ch)) {
- o.Append('%');
- o.Append(toHex(ch / 16));
- o.Append(toHex(ch % 16));
- }
- else o.Append(ch);
- }
- return o.ToString();
- }
-
- private char toHex(int ch) {
- return (char)(ch < 10 ? '0' + ch : 'A' + ch - 10);
- }
-
- private bool isUnsafe(char ch) {
- return " ~`!@#$%^&*()+=[]\\{}|;':\",./<>?".IndexOf(ch) >= 0;
- }
-
- private static string md5(string text) {
- MD5 md5 = new MD5CryptoServiceProvider();
- byte[] data = Encoding.Default.GetBytes(text);
- byte[] hash = md5.ComputeHash(data);
- string hexaHash = "";
- foreach (byte b in hash) hexaHash += String.Format("{0:x2}", b);
- return hexaHash;
- }
-}
-
View
BIN csharp/3.1/Pubnub.exe
Binary file not shown.
View
BIN csharp/3.1/Pubnub.exe.mdb
Binary file not shown.
View
400 csharp/3.1/Pubnub2.cs
@@ -1,400 +0,0 @@
-using System;
-using System.IO;
-using System.Net;
-using System.Text;
-using System.Collections.Generic;
-using System.Security.Cryptography;
-//using System.Web.Script.Serialization;
-using Newtonsoft.Json;
-using Newtonsoft.Json.Linq;
-using System.Threading;
-
-/**
- * PubNub 3.0 Real-time Push Cloud API
- *
- * @author Stephen Blum
- * @package pubnub
- */
-namespace BackupStack.Push
-{
- public class Pubnub
- {
- private string ORIGIN = "pubsub.pubnub.com";
- private int LIMIT = 1800;
- private string PUBLISH_KEY = "";
- private string SUBSCRIBE_KEY = "";
- private string SECRET_KEY = "";
- private bool SSL = false;
- private ManualResetEvent webRequestDone;
- volatile private bool abort;
- public delegate bool Procedure(object message);
-
- /**
- * PubNub 3.0
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- * @param bool SSL Enabled.
- */
- public Pubnub(
- string publish_key,
- string subscribe_key,
- string secret_key,
- bool ssl_on
- )
- {
- this.init(publish_key, subscribe_key, secret_key, ssl_on);
- }
-
- /**
- * PubNub 2.0 Compatibility
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- */
- public Pubnub(
- string publish_key,
- string subscribe_key
- )
- {
- this.init(publish_key, subscribe_key, "", false);
- }
-
- /**
- * PubNub 3.0 without SSL
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- */
- public Pubnub(
- string publish_key,
- string subscribe_key,
- string secret_key
- )
- {
- this.init(publish_key, subscribe_key, secret_key, false);
- }
-
- /**
- * Init
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- * @param bool SSL Enabled.
- */
- public void init(
- string publish_key,
- string subscribe_key,
- string secret_key,
- bool ssl_on
- )
- {
- this.PUBLISH_KEY = publish_key;
- this.SUBSCRIBE_KEY = subscribe_key;
- this.SECRET_KEY = secret_key;
- this.SSL = ssl_on;
-
- // SSL On?
- if (this.SSL)
- {
- this.ORIGIN = "https://" + this.ORIGIN;
- }
- else
- {
- this.ORIGIN = "http://" + this.ORIGIN;
- }
- webRequestDone = new ManualResetEvent(true);
- }
-
- /**
- * History
- *
- * Load history from a channel.
- *
- * @param String channel name.
- * @param int limit history count response.
- * @return ListArray of history.
- */
- public List<object> History(string channel, int limit)
- {
- List<string> url = new List<string>();
-
- url.Add("history");
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(channel);
- url.Add("0");
- url.Add(limit.ToString());
-
- return _request(url);
- }
-
- /**
- * Publish
- *
- * Send a message to a channel.
- *
- * @param String channel name.
- * @param List<object> info.
- * @return bool false on fail.
- */
- public List<object> Publish(string channel, object message)
- {
- //JavaScriptSerializer serializer = new JavaScriptSerializer();
-
- // Generate String to Sign
- string signature = "0";
- if (this.SECRET_KEY.Length > 0)
- {
- StringBuilder string_to_sign = new StringBuilder();
- string_to_sign
- .Append(this.PUBLISH_KEY)
- .Append('/')
- .Append(this.SUBSCRIBE_KEY)
- .Append('/')
- .Append(this.SECRET_KEY)
- .Append('/')
- .Append(channel)
- .Append('/')
- .Append(JsonConvert.SerializeObject(message));
-
- // Sign Message
- signature = md5(string_to_sign.ToString());
- }
-
- // Build URL
- List<string> url = new List<string>();
- url.Add("publish");
- url.Add(this.PUBLISH_KEY);
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(signature);
- url.Add(channel);
- url.Add("0");
- url.Add(JsonConvert.SerializeObject(message));
-
- // Return JSONArray
- return _request(url);
- }
-
- /**
- * Subscribe
- *
- * This function is BLOCKING.
- * Listen for a message on a channel.
- *
- * @param string channel name.
- * @param Procedure function callback.
- */
- public void Subscribe(string channel, Procedure callback)
- {
- if (!string.IsNullOrEmpty(channel))
- {
- this._subscribe(channel, callback, 0);
- }
- }
-
- /**
- * Subscribe - Private Interface
- *
- * @param string channel name.
- * @param Procedure function callback.
- * @param string timetoken.
- */
- private void _subscribe(
- string channel,
- Procedure callback,
- object timetoken
- )
- {
- // Begin Recusive Subscribe - causes stack overflow
- // loop instead!!
- while (!abort && !string.IsNullOrEmpty(channel))
- {
- try
- {
- // Build URL
- List<string> url = new List<string>();
- url.Add("subscribe");
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(channel);
- url.Add("0");
- url.Add(timetoken.ToString());
-
- // Wait for Message
- List<object> response = _request(url);
-
- // Update TimeToken
- if (response[1].ToString().Length > 0)
- timetoken = (object)response[1];
-
- // Run user Callback and Reconnect if user permits.
- foreach (object message in (JArray)response[0])
- {
- if (!callback(message)) return;
- }
-
- // Keep listening if Okay.
- //this._subscribe(channel, callback, timetoken);
- }
- catch
- {
- if (!abort)
- {
- System.Threading.Thread.Sleep(1000);
- }
- //this._subscribe(channel, callback, timetoken);
- }
- }
- }
-
- /**
- * Time
- *
- * Timestamp from PubNub Cloud.
- *
- * @return object timestamp.
- */
- public object Time()
- {
- List<string> url = new List<string>();
-
- url.Add("time");
- url.Add("0");
-
- List<object> response = _request(url);
- return response[0];
- }
-
- /**
- * Request URL
- *
- * @param List<string> request of url directories.
- * @return List<object> from JSON response.
- */
- private List<object> _request(List<string> url_components)
- {
- string temp = null;
- int count = 0;
- byte[] buf = new byte[8192];
- StringBuilder url = new StringBuilder();
- StringBuilder sb = new StringBuilder();
-
- //JavaScriptSerializer serializer = new JavaScriptSerializer();
-
- // Add Origin To The Request
- url.Append(this.ORIGIN);
-
- // Generate URL with UTF-8 Encoding
- foreach (string url_bit in url_components)
- {
- url.Append("/");
- url.Append(_encodeURIcomponent(url_bit));
- }
-
- // Fail if string too long
- if (url.Length > this.LIMIT)
- {
- List<object> too_long = new List<object>();
- too_long.Add(0);
- too_long.Add("Message Too Long.");
- return too_long;
- }
-
- // Create Request
- HttpWebRequest request = (HttpWebRequest)
- WebRequest.Create(url.ToString());
-
- // Set Timeout
- request.Timeout = 200000;
- request.ReadWriteTimeout = 200000;
-
- // Receive Response
- //changed to begin get response
- webRequestDone.Reset();
- IAsyncResult asyncResult = request.BeginGetResponse(new AsyncCallback(requestCallBack), null);
- webRequestDone.WaitOne();
-
- if (abort)
- {
- return new List<object>();
- }
- HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(asyncResult);
-
- using (Stream resStream = response.GetResponseStream())
- {
- do
- {
- count = resStream.Read(buf, 0, buf.Length);
- if (count != 0)
- {
- temp = Encoding.UTF8.GetString(buf, 0, count);
- sb.Append(temp);
- }
- } while (count > 0);
- }
-
- // Read
- // Parse Response
- string message = sb.ToString();
- return JsonConvert.DeserializeObject<List<object>>(message);
- }
-
- private void requestCallBack(IAsyncResult result)
- {
- //reslease thread block
- webRequestDone.Set();
- }
-
- private string _encodeURIcomponent(string s)
- {
- StringBuilder o = new StringBuilder();
- foreach (char ch in s.ToCharArray())
- {
- if (isUnsafe(ch))
- {
- o.Append('%');
- o.Append(toHex(ch / 16));
- o.Append(toHex(ch % 16));
- }
- else o.Append(ch);
- }
- return o.ToString();
- }
-
- private char toHex(int ch)
- {
- return (char)(ch < 10 ? '0' + ch : 'A' + ch - 10);
- }
-
- private bool isUnsafe(char ch)
- {
- return " ~`!@#$%^&*()+=[]\\{}|;':\",./<>?".IndexOf(ch) >= 0;
- }
-
- private static string md5(string text)
- {
- MD5 md5 = new MD5CryptoServiceProvider();
- byte[] data = Encoding.Default.GetBytes(text);
- byte[] hash = md5.ComputeHash(data);
- string hexaHash = "";
- foreach (byte b in hash) hexaHash += String.Format("{0:x2}", b);
- return hexaHash;
- }
-
- public void Abort()
- {
- abort = true;
- webRequestDone.Set();
- }
- }
-}
View
1,007 csharp/3.1/PubnubAsync.cs
@@ -1,1007 +0,0 @@
-using System;
-using System.IO;
-using System.Net;
-using System.Text;
-using System.Collections;
-using System.Collections.Generic;
-using System.Security.Cryptography;
-using System.Runtime.Serialization;
-using System.Runtime.Serialization.Json;
-using System.ComponentModel;
-
-namespace Pubnub
-{
- // INotifyPropertyChanged provides a standard event for objects to notify clients that one of its properties has changed
- public class PubnubClass : INotifyPropertyChanged
- {
- // Common property changed event
- public event PropertyChangedEventHandler PropertyChanged;
- public void RaisePropertyChanged(string propertyName)
- {
- var handler = PropertyChanged;
- if (handler != null)
- {
- handler(this, new PropertyChangedEventArgs(propertyName));
- }
- }
-
- // Message that is published through PubNub
- private object _ReturnMessage = new object();
- public object ReturnMessage
- {
- get
- {
- return _ReturnMessage;
- }
- set
- {
- _ReturnMessage = value; RaisePropertyChanged("ReturnMessage");
- }
- }
-
- // Publish
- private List<object> _Publish = new List<object>();
- public List<object> Publish
- {
- get
- {
- return _Publish;
- }
- set
- {
- _Publish = value;
- RaisePropertyChanged("Publish");
- }
- }
-
- // History of Messages
- private List<object> _History = new List<object>();
- public List<object> History { get { return _History; } set { _History = value; RaisePropertyChanged("History"); } }
-
- // Subscribe
- private List<object> _Subscribe = new List<object>();
- public List<object> Subscribe
- {
- get
- {
- return _Subscribe;
- }
- set
- {
- _Subscribe = value;
- if (Int64.Parse(value[1].ToString()) > 0)
- _subscribe(value[2].ToString(), Int64.Parse(value[1].ToString()) - 1);
- RaisePropertyChanged("Subscribe");
- }
- }
-
- // Time stamp
- private List<object> _Time = new List<object>();
- public List<object> Time { get { return _Time; } set { _Time = value; RaisePropertyChanged("Time"); } }
-
- private string ORIGIN = "pubsub.pubnub.com";
- private int LIMIT = 1800;
- private string PUBLISH_KEY = "";
- private string SUBSCRIBE_KEY = "";
- private string SECRET_KEY = "";
- private bool SSL = false;
-
- public delegate bool Procedure(object message);
-
- /**
- * PubNub 3.0
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- * @param bool SSL Enabled.
- */
- public PubnubClass(string publish_key, string subscribe_key, string secret_key, bool ssl_on)
- {
- this.init(publish_key, subscribe_key, secret_key, ssl_on);
- }
-
- /**
- * PubNub 2.0 Compatibility
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- */
- public PubnubClass( string publish_key, string subscribe_key)
- {
- this.init(publish_key, subscribe_key, "", false);
- }
-
- /**
- * PubNub 3.0 without SSL
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- */
- public PubnubClass( string publish_key, string subscribe_key, string secret_key)
- {
- this.init(publish_key, subscribe_key, secret_key, false);
- }
-
- /**
- * Init
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- * @param bool SSL Enabled.
- */
- public void init(string publish_key, string subscribe_key, string secret_key, bool ssl_on)
- {
- this.PUBLISH_KEY = publish_key;
- this.SUBSCRIBE_KEY = subscribe_key;
- this.SECRET_KEY = secret_key;
- this.SSL = ssl_on;
-
- // SSL On?
- if (this.SSL)
- {
- this.ORIGIN = "https://" + this.ORIGIN;
- }
- else
- {
- this.ORIGIN = "http://" + this.ORIGIN;
- }
- }
-
- /**
- * History
- *
- * Load history from a channel.
- *
- * @param String channel name.
- * @param int limit history count response.
- * @return ListArray of history.
- */
- public void history(string channel, int limit)
- {
- List<string> url = new List<string>();
-
- url.Add("history");
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(channel);
- url.Add("0");
- url.Add(limit.ToString());
-
- _request(url, ResponseType.History);
- }
-
- /**
- * Publish
- *
- * Send a message to a channel.
- *
- * @param String channel name.
- * @param List<object> info.
- * @return bool false on fail.
- */
- public void publish(string channel, object message)
- {
- // Generate String to Sign
- string signature = "0";
- if (this.SECRET_KEY.Length > 0)
- {
- StringBuilder string_to_sign = new StringBuilder();
- string_to_sign
- .Append(this.PUBLISH_KEY)
- .Append('/')
- .Append(this.SUBSCRIBE_KEY)
- .Append('/')
- .Append(this.SECRET_KEY)
- .Append('/')
- .Append(channel)
- .Append('/')
- .Append(SerializeToJsonString(message)); // 1
- ;
- // Sign Message
- signature = md5(string_to_sign.ToString());
- }
-
- // Build URL
- List<string> url = new List<string>();
- url.Add("publish");
- url.Add(this.PUBLISH_KEY);
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(signature);
- url.Add(channel);
- url.Add("0");
- url.Add(SerializeToJsonString(message));
-
- _request(url, ResponseType.Publish);
- }
-
- /**
- * Subscribe
- *
- * This function is BLOCKING.
- * Listen for a message on a channel.
- *
- * @param string channel name.
- * @param Procedure function callback.
- */
- public void subscribe(string channel)
- {
- this._subscribe(channel, 0);
- }
-
- /**
- * Subscribe - Private Interface
- *
- * @param string channel name.
- * @param Procedure function callback.
- * @param string timetoken.
- */
- private void _subscribe(string channel, object timetoken)
- {
- // Begin Recusive Subscribe
- try
- {
- // Build URL
- List<string> url = new List<string>();
- url.Add("subscribe");
- url.Add(this.SUBSCRIBE_KEY);
- url.Add(channel);
- url.Add("0");
- url.Add(timetoken.ToString());
-
- // Wait for Message
- _request(url, ResponseType.Subscribe);
-
- if (Subscribe.Count > 0)
- {
- // Update TimeToken
- if (Subscribe[1].ToString().Length > 0)
- timetoken = (object)Subscribe[1];
- }
- }
- catch
- {
- System.Threading.Thread.Sleep(1000);
- this._subscribe(channel, timetoken);
- }
- }
-
- /**
- * Time
- *
- * Timestamp from PubNub Cloud.
- *
- * @return object timestamp.
- */
- public void time()
- {
- List<string> url = new List<string>();
-
- url.Add("time");
- url.Add("0");
-
- _request(url, ResponseType.Time);
- }
-
- /**
- * Request URL
- *
- * @param List<string> request of url directories.
- * @return List<object> from JSON response.
- */
- private void _request(List<string> url_components, ResponseType type)
- {
- List<object> result = new List<object>();
- StringBuilder url = new StringBuilder();
-
- // Add Origin To The Request
- url.Append(this.ORIGIN);
-
- // Generate URL with UTF-8 Encoding
- foreach (string url_bit in url_components)
- {
- url.Append("/");
- url.Append(_encodeURIcomponent(url_bit));
- }
-
- // Fail if string too long
- if (url.Length > this.LIMIT)
- {
- result.Add(0);
- result.Add("Message Too Long.");
- //return result;
- }
-
- // Create Request
- HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url.ToString());
-
- // Make request with the following inline Async Call back
- //IAsyncResult result1 = request.BeginGetResponse(new AsyncCallback((asynchronousResult) =>
- request.BeginGetResponse(new AsyncCallback((asynchronousResult) =>
- {
- //System.Deployment.Current.Dispatcher.BeginInvoke(delegate()
- //{
- HttpWebRequest aRequest = (HttpWebRequest)asynchronousResult.AsyncState;
- HttpWebResponse aResponse = (HttpWebResponse)aRequest.EndGetResponse(asynchronousResult);
- using (StreamReader streamReader = new StreamReader(aResponse.GetResponseStream()))
- {
- // Deserialize the result
- result = DeserializeToListOfObject(streamReader.ReadToEnd());
- if (result[0] is object[])
- {
- foreach (object message in (object[])result[0])
- {
- this.ReturnMessage = message;
- }
- }
- switch (type)
- {
- case ResponseType.Publish:
- result.Add(url_components[4]);
- Publish = result;
- break;
- case ResponseType.History:
- History = result;
- break;
- case ResponseType.Time:
- Time = result;
- break;
- default:
- result.Add(url_components[2]);
- Subscribe = result;
- break;
- }
-
- }
- //});
- }), request);
- }
-
-
- /// <summary>
- /// Serialize the given object into JSON
- /// </summary>
- /// <param name="objectToSerialize"></param>
- /// <returns></returns>
- public static string SerializeToJsonString(object objectToSerialize)
- {
- using (MemoryStream ms = new MemoryStream())
- {
- DataContractJsonSerializer serializer = new DataContractJsonSerializer(objectToSerialize.GetType());
- serializer.WriteObject(ms, objectToSerialize);
- ms.Position = 0;
-
- using (StreamReader reader = new StreamReader(ms))
- {
- return reader.ReadToEnd();
- }
- }
- }
-
- /// <summary>
- /// Deserialize JSON string into List of Objects
- /// </summary>
- /// <param name="jsonString"></param>
- /// <returns></returns>
- public static List<object> DeserializeToListOfObject(string jsonString)
- {
- using (MemoryStream ms = new MemoryStream(Encoding.Unicode.GetBytes(jsonString)))
- {
- DataContractJsonSerializer serializer =
- new DataContractJsonSerializer(typeof(List<object>));
-
- return (List<object>)serializer.ReadObject(ms);
- }
- }
-
- private string _encodeURIcomponent(string s)
- {
- StringBuilder o = new StringBuilder();
- foreach (char ch in s.ToCharArray())
- {
- if (isUnsafe(ch))
- {
- o.Append('%');
- o.Append(toHex(ch / 16));
- o.Append(toHex(ch % 16));
- }
- else o.Append(ch);
- }
- return o.ToString();
- }
-
- private char toHex(int ch)
- {
- return (char)(ch < 10 ? '0' + ch : 'A' + ch - 10);
- }
-
- private bool isUnsafe(char ch)
- {
- return " ~`!@#$%^&*()+=[]\\{}|;':\",./<>?".IndexOf(ch) >= 0;
- }
-
- public static string md5(string text)
- {
- MD5 md5 = new MD5CryptoServiceProvider();
- byte[] data = Encoding.Unicode.GetBytes(text);
- byte[] hash = md5.ComputeHash(data);
- string hexaHash = "";
- foreach (byte b in hash) hexaHash += String.Format("{0:x2}", b);
- return hexaHash;
- }
-
- enum ResponseType
- {
- Publish,
- History,
- Time,
- Subscribe
- }
- }
-
- public class MD5CryptoServiceProvider : MD5
- {
- public MD5CryptoServiceProvider()
- : base()
- {
- }
- }
- /// <summary>
- /// Summary description for MD5.
- /// </summary>
- public class MD5 : IDisposable
- {
- static public MD5 Create(string hashName)
- {
- if (hashName == "MD5")
- return new MD5();
- else
- throw new NotSupportedException();
- }
-
- static public String GetMd5String(String source)
- {
- MD5 md = MD5CryptoServiceProvider.Create();
- byte[] hash;
-
- //Create a new instance of ASCIIEncoding to
- //convert the string into an array of Unicode bytes.
- UTF8Encoding enc = new UTF8Encoding();
- // ASCIIEncoding enc = new ASCIIEncoding();
-
- //Convert the string into an array of bytes.
- byte[] buffer = enc.GetBytes(source);
-
- //Create the hash value from the array of bytes.
- hash = md.ComputeHash(buffer);
-
- StringBuilder sb = new StringBuilder();
- foreach (byte b in hash)
- sb.Append(b.ToString("x2"));
- return sb.ToString();
- }
-
- static public MD5 Create()
- {
- return new MD5();
- }
-
- #region base implementation of the MD5
- #region constants
- private const byte S11 = 7;
- private const byte S12 = 12;
- private const byte S13 = 17;
- private const byte S14 = 22;
- private const byte S21 = 5;
- private const byte S22 = 9;
- private const byte S23 = 14;
- private const byte S24 = 20;
- private const byte S31 = 4;
- private const byte S32 = 11;
- private const byte S33 = 16;
- private const byte S34 = 23;
- private const byte S41 = 6;
- private const byte S42 = 10;
- private const byte S43 = 15;
- private const byte S44 = 21;
- static private byte[] PADDING = new byte[] {
- 0x80, 0, 0, 0, 0, 0,
-0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0,
-0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
- 0, 0, 0, 0, 0, 0, 0,
-0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0
- };
- #endregion
-
- #region F, G, H and I are basic MD5 functions.
- static private uint F(uint x, uint y, uint z)
- {
- return (((x) & (y)) | ((~x) & (z)));
- }
- static private uint G(uint x, uint y, uint z)
- {
- return (((x) & (z)) | ((y) & (~z)));
- }
- static private uint H(uint x, uint y, uint z)
- {
- return ((x) ^ (y) ^ (z));
- }
- static private uint I(uint x, uint y, uint z)
- {
- return ((y) ^ ((x) | (~z)));
- }
- #endregion
-
- #region rotates x left n bits.
- /// <summary>
- /// rotates x left n bits.
- /// </summary>
- /// <param name="x"></param>
- /// <param name="n"></param>
- /// <returns></returns>
- static private uint ROTATE_LEFT(uint x, byte n)
- {
- return (((x) << (n)) | ((x) >> (32 - (n))));
- }
- #endregion
-
- #region FF, GG, HH, and II transformations
- /// FF, GG, HH, and II transformations
- /// for rounds 1, 2, 3, and 4.
- /// Rotation is separate from addition to prevent recomputation.
- static private void FF(ref uint a, uint b, uint c, uint d, uint x, byte s, uint ac)
- {
- (a) += F((b), (c), (d)) + (x) + (uint)(ac);
- (a) = ROTATE_LEFT((a), (s));
- (a) += (b);
- }
- static private void GG(ref uint a, uint b, uint c, uint d, uint x, byte s, uint ac)
- {
- (a) += G((b), (c), (d)) + (x) + (uint)(ac);
- (a) = ROTATE_LEFT((a), (s));
- (a) += (b);
- }
- static private void HH(ref uint a, uint b, uint c, uint d, uint x, byte s, uint ac)
- {
- (a) += H((b), (c), (d)) + (x) + (uint)(ac);
- (a) = ROTATE_LEFT((a), (s));
- (a) += (b);
- }
- static private void II(ref uint a, uint b, uint c, uint d, uint x, byte s, uint ac)
- {
- (a) += I((b), (c), (d)) + (x) + (uint)(ac);
- (a) = ROTATE_LEFT((a), (s));
- (a) += (b);
- }
- #endregion
-
- #region context info
- /// <summary>
- /// state (ABCD)
- /// </summary>
- uint[] state = new uint[4];
-
- /// <summary>
- /// number of bits, modulo 2^64 (lsb first)
- /// </summary>
- uint[] count = new uint[2];
-
- /// <summary>
- /// input buffer
- /// </summary>
- byte[] buffer = new byte[64];
- #endregion
-
- internal MD5()
- {
- Initialize();
- }
-
- /// <summary>
- /// MD5 initialization. Begins an MD5 operation, writing a new context.
- /// </summary>
- /// <remarks>
- /// The RFC named it "MD5Init"
- /// </remarks>
- public virtual void Initialize()
- {
- count[0] = count[1] = 0;
-
- // Load magic initialization constants.
- state[0] = 0x67452301;
- state[1] = 0xefcdab89;
- state[2] = 0x98badcfe;
- state[3] = 0x10325476;
- }
-
- /// <summary>
- /// MD5 block update operation. Continues an MD5 message-digest
- /// operation, processing another message block, and updating the
- /// context.
- /// </summary>
- /// <param name="input"></param>
- /// <param name="offset"></param>
- /// <param name="count"></param>
- /// <remarks>The RFC Named it MD5Update</remarks>
- protected virtual void HashCore(byte[] input, int offset, int count)
- {
- int i;
- int index;
- int partLen;
-
- // Compute number of bytes mod 64
- index = (int)((this.count[0] >> 3) & 0x3F);
-
- // Update number of bits
- if ((this.count[0] += (uint)((uint)count << 3)) < ((uint)count << 3))
- this.count[1]++;
- this.count[1] += ((uint)count >> 29);
-
- partLen = 64 - index;
-
- // Transform as many times as possible.
- if (count >= partLen)
- {
- Buffer.BlockCopy(input, offset, this.buffer, index, partLen);
- Transform(this.buffer, 0);
-
- for (i = partLen; i + 63 < count; i += 64)
- Transform(input, offset + i);
-
- index = 0;
- }
- else
- i = 0;
-
- // Buffer remaining input
- Buffer.BlockCopy(input, offset + i, this.buffer, index, count - i);
- }
-
- /// <summary>
- /// MD5 finalization. Ends an MD5 message-digest operation, writing the
- /// the message digest and zeroizing the context.
- /// </summary>
- /// <returns>message digest</returns>
- /// <remarks>The RFC named it MD5Final</remarks>
- protected virtual byte[] HashFinal()
- {
- byte[] digest = new byte[16];
- byte[] bits = new byte[8];
- int index, padLen;
-
- // Save number of bits
- Encode(bits, 0, this.count, 0, 8);
-
- // Pad out to 56 mod 64.
- index = (int)((uint)(this.count[0] >> 3) & 0x3f);
- padLen = (index < 56) ? (56 - index) : (120 - index);
- HashCore(PADDING, 0, padLen);
-
- // Append length (before padding)
- HashCore(bits, 0, 8);
-
- // Store state in digest
- Encode(digest, 0, state, 0, 16);
-
- // Zeroize sensitive information.
- count[0] = count[1] = 0;
- state[0] = 0;
- state[1] = 0;
- state[2] = 0;
- state[3] = 0;
-
- // initialize again, to be ready to use
- Initialize();
-
- return digest;
- }
-
- /// <summary>
- /// MD5 basic transformation. Transforms state based on 64 bytes block.
- /// </summary>
- /// <param name="block"></param>
- /// <param name="offset"></param>
- private void Transform(byte[] block, int offset)
- {
- uint a = state[0], b = state[1], c = state[2], d = state[3];
- uint[] x = new uint[16];
- Decode(x, 0, block, offset, 64);
-
- // Round 1
- FF(ref a, b, c, d, x[0], S11, 0xd76aa478); /* 1 */
- FF(ref d, a, b, c, x[1], S12, 0xe8c7b756); /* 2 */
- FF(ref c, d, a, b, x[2], S13, 0x242070db); /* 3 */
- FF(ref b, c, d, a, x[3], S14, 0xc1bdceee); /* 4 */
- FF(ref a, b, c, d, x[4], S11, 0xf57c0faf); /* 5 */
- FF(ref d, a, b, c, x[5], S12, 0x4787c62a); /* 6 */
- FF(ref c, d, a, b, x[6], S13, 0xa8304613); /* 7 */
- FF(ref b, c, d, a, x[7], S14, 0xfd469501); /* 8 */
- FF(ref a, b, c, d, x[8], S11, 0x698098d8); /* 9 */
- FF(ref d, a, b, c, x[9], S12, 0x8b44f7af); /* 10 */
- FF(ref c, d, a, b, x[10], S13, 0xffff5bb1); /* 11 */
- FF(ref b, c, d, a, x[11], S14, 0x895cd7be); /* 12 */
- FF(ref a, b, c, d, x[12], S11, 0x6b901122); /* 13 */
- FF(ref d, a, b, c, x[13], S12, 0xfd987193); /* 14 */
- FF(ref c, d, a, b, x[14], S13, 0xa679438e); /* 15 */
- FF(ref b, c, d, a, x[15], S14, 0x49b40821); /* 16 */
-
- // Round 2
- GG(ref a, b, c, d, x[1], S21, 0xf61e2562); /* 17 */
- GG(ref d, a, b, c, x[6], S22, 0xc040b340); /* 18 */
- GG(ref c, d, a, b, x[11], S23, 0x265e5a51); /* 19 */
- GG(ref b, c, d, a, x[0], S24, 0xe9b6c7aa); /* 20 */
- GG(ref a, b, c, d, x[5], S21, 0xd62f105d); /* 21 */
- GG(ref d, a, b, c, x[10], S22, 0x2441453); /* 22 */
- GG(ref c, d, a, b, x[15], S23, 0xd8a1e681); /* 23 */
- GG(ref b, c, d, a, x[4], S24, 0xe7d3fbc8); /* 24 */
- GG(ref a, b, c, d, x[9], S21, 0x21e1cde6); /* 25 */
- GG(ref d, a, b, c, x[14], S22, 0xc33707d6); /* 26 */
- GG(ref c, d, a, b, x[3], S23, 0xf4d50d87); /* 27 */
- GG(ref b, c, d, a, x[8], S24, 0x455a14ed); /* 28 */
- GG(ref a, b, c, d, x[13], S21, 0xa9e3e905); /* 29 */
- GG(ref d, a, b, c, x[2], S22, 0xfcefa3f8); /* 30 */
- GG(ref c, d, a, b, x[7], S23, 0x676f02d9); /* 31 */
- GG(ref b, c, d, a, x[12], S24, 0x8d2a4c8a); /* 32 */
-
- // Round 3
- HH(ref a, b, c, d, x[5], S31, 0xfffa3942); /* 33 */
- HH(ref d, a, b, c, x[8], S32, 0x8771f681); /* 34 */
- HH(ref c, d, a, b, x[11], S33, 0x6d9d6122); /* 35 */
- HH(ref b, c, d, a, x[14], S34, 0xfde5380c); /* 36 */
- HH(ref a, b, c, d, x[1], S31, 0xa4beea44); /* 37 */
- HH(ref d, a, b, c, x[4], S32, 0x4bdecfa9); /* 38 */
- HH(ref c, d, a, b, x[7], S33, 0xf6bb4b60); /* 39 */
- HH(ref b, c, d, a, x[10], S34, 0xbebfbc70); /* 40 */
- HH(ref a, b, c, d, x[13], S31, 0x289b7ec6); /* 41 */
- HH(ref d, a, b, c, x[0], S32, 0xeaa127fa); /* 42 */
- HH(ref c, d, a, b, x[3], S33, 0xd4ef3085); /* 43 */
- HH(ref b, c, d, a, x[6], S34, 0x4881d05); /* 44 */
- HH(ref a, b, c, d, x[9], S31, 0xd9d4d039); /* 45 */
- HH(ref d, a, b, c, x[12], S32, 0xe6db99e5); /* 46 */
- HH(ref c, d, a, b, x[15], S33, 0x1fa27cf8); /* 47 */
- HH(ref b, c, d, a, x[2], S34, 0xc4ac5665); /* 48 */
-
- // Round 4
- II(ref a, b, c, d, x[0], S41, 0xf4292244); /* 49 */
- II(ref d, a, b, c, x[7], S42, 0x432aff97); /* 50 */
- II(ref c, d, a, b, x[14], S43, 0xab9423a7); /* 51 */
- II(ref b, c, d, a, x[5], S44, 0xfc93a039); /* 52 */
- II(ref a, b, c, d, x[12], S41, 0x655b59c3); /* 53 */
- II(ref d, a, b, c, x[3], S42, 0x8f0ccc92); /* 54 */
- II(ref c, d, a, b, x[10], S43, 0xffeff47d); /* 55 */
- II(ref b, c, d, a, x[1], S44, 0x85845dd1); /* 56 */
- II(ref a, b, c, d, x[8], S41, 0x6fa87e4f); /* 57 */
- II(ref d, a, b, c, x[15], S42, 0xfe2ce6e0); /* 58 */
- II(ref c, d, a, b, x[6], S43, 0xa3014314); /* 59 */
- II(ref b, c, d, a, x[13], S44, 0x4e0811a1); /* 60 */
- II(ref a, b, c, d, x[4], S41, 0xf7537e82); /* 61 */
- II(ref d, a, b, c, x[11], S42, 0xbd3af235); /* 62 */
- II(ref c, d, a, b, x[2], S43, 0x2ad7d2bb); /* 63 */
- II(ref b, c, d, a, x[9], S44, 0xeb86d391); /* 64 */
-
- state[0] += a;
- state[1] += b;
- state[2] += c;
- state[3] += d;
-
- // Zeroize sensitive information.
- for (int i = 0; i < x.Length; i++)
- x[i] = 0;
- }
-
- /// <summary>
- /// Encodes input (uint) into output (byte). Assumes len is
- /// multiple of 4.
- /// </summary>
- /// <param name="output"></param>
- /// <param name="outputOffset"></param>
- /// <param name="input"></param>
- /// <param name="inputOffset"></param>
- /// <param name="count"></param>
- private static void Encode(byte[] output, int outputOffset, uint[] input, int inputOffset, int count)
- {
- int i, j;
- int end = outputOffset + count;
- for (i = inputOffset, j = outputOffset; j < end; i++, j += 4)
- {
- output[j] = (byte)(input[i] & 0xff);
- output[j + 1] = (byte)((input[i] >> 8) & 0xff);
- output[j + 2] = (byte)((input[i] >> 16) & 0xff);
- output[j + 3] = (byte)((input[i] >> 24) & 0xff);
- }
- }
-
- /// <summary>
- /// Decodes input (byte) into output (uint). Assumes len is
- /// a multiple of 4.
- /// </summary>
- /// <param name="output"></param>
- /// <param name="outputOffset"></param>
- /// <param name="input"></param>
- /// <param name="inputOffset"></param>
- /// <param name="count"></param>
- static private void Decode(uint[] output, int outputOffset, byte[] input, int inputOffset, int count)
- {
- int i, j;
- int end = inputOffset + count;
- for (i = outputOffset, j = inputOffset; j < end; i++, j += 4)
- output[i] = ((uint)input[j]) | (((uint)input[j + 1]) << 8) | (((uint)input[j + 2]) << 16) | (((uint)input[j + 3]) <<
-24);
- }
- #endregion
-
- #region expose the same interface as the regular MD5 object
-
- protected byte[] HashValue;
- protected int State;
- public virtual bool CanReuseTransform
- {
- get
- {
- return true;
- }
- }
-
- public virtual bool CanTransformMultipleBlocks
- {
- get
- {
- return true;
- }
- }
- public virtual byte[] Hash
- {
- get
- {
- if (this.State != 0)
- throw new InvalidOperationException();
- return (byte[])HashValue.Clone();
- }
- }
- public virtual int HashSize
- {
- get
- {
- return HashSizeValue;
- }
- }
- protected int HashSizeValue = 128;
-
- public virtual int InputBlockSize
- {
- get
- {
- return 1;
- }
- }
- public virtual int OutputBlockSize
- {
- get
- {
- return 1;
- }
- }
-
- public void Clear()
- {
- Dispose(true);
- }
-
- public byte[] ComputeHash(byte[] buffer)
- {
- return ComputeHash(buffer, 0, buffer.Length);
- }
- public byte[] ComputeHash(byte[] buffer, int offset, int count)
- {
- Initialize();
- HashCore(buffer, offset, count);
- HashValue = HashFinal();
- return (byte[])HashValue.Clone();
- }
-
- public byte[] ComputeHash(Stream inputStream)
- {
- Initialize();
- int count;
- byte[] buffer = new byte[4096];
- while (0 < (count = inputStream.Read(buffer, 0, 4096)))
- {
- HashCore(buffer, 0, count);
- }
- HashValue = HashFinal();
- return (byte[])HashValue.Clone();
- }
-
- public int TransformBlock(
- byte[] inputBuffer,
- int inputOffset,
- int inputCount,
- byte[] outputBuffer,
- int outputOffset
- )
- {
- if (inputBuffer == null)
- {
- throw new ArgumentNullException("inputBuffer");
- }
- if (inputOffset < 0)
- {
- throw new ArgumentOutOfRangeException("inputOffset");
- }
- if ((inputCount < 0) || (inputCount > inputBuffer.Length))
- {
- throw new ArgumentException("inputCount");
- }
- if ((inputBuffer.Length - inputCount) < inputOffset)
- {
- throw new ArgumentOutOfRangeException("inputOffset");
- }
- if (this.State == 0)
- {
- Initialize();
- this.State = 1;
- }
-
- HashCore(inputBuffer, inputOffset, inputCount);
- if ((inputBuffer != outputBuffer) || (inputOffset != outputOffset))
- {
- Buffer.BlockCopy(inputBuffer, inputOffset, outputBuffer, outputOffset, inputCount);
- }
- return inputCount;
- }
- public byte[] TransformFinalBlock(
- byte[] inputBuffer,
- int inputOffset,
- int inputCount
- )
- {
- if (inputBuffer == null)
- {
- throw new ArgumentNullException("inputBuffer");
- }
- if (inputOffset < 0)
- {
- throw new ArgumentOutOfRangeException("inputOffset");
- }
- if ((inputCount < 0) || (inputCount > inputBuffer.Length))
- {
- throw new ArgumentException("inputCount");
- }
- if ((inputBuffer.Length - inputCount) < inputOffset)
- {
- throw new ArgumentOutOfRangeException("inputOffset");
- }
- if (this.State == 0)
- {
- Initialize();
- }
- HashCore(inputBuffer, inputOffset, inputCount);
- HashValue = HashFinal();
- byte[] buffer = new byte[inputCount];
- Buffer.BlockCopy(inputBuffer, inputOffset, buffer, 0, inputCount);
- this.State = 0;
- return buffer;
- }
- #endregion
-
- protected virtual void Dispose(bool disposing)
- {
- if (!disposing)
- Initialize();
- }
- public void Dispose()
- {
- Dispose(true);
- }
- }
-}
View
392 csharp/3.1/PubnubCustomer.cs
@@ -1,392 +0,0 @@
-using System;
-using System.IO;
-using System.Net;
-using System.Text;
-using System.Collections;
-using System.Collections.Generic;
-using System.Security.Cryptography;
-using System.Web.Script.Serialization;
-
-/**
- * PubNub Customer API TEST CLASS
- */
-public class PubnubTEST {
- static public void Main() {
- // ------------------------------------------------
- // USE MASTER CUSTOMER PUB/SUB/SEC Keys
- // ------------------------------------------------
- PubnubCustomer pubnub_customer = new PubnubCustomer(
- "", // Master Account PUBLISH_KEY
- "", // Master Account SUBSCRIBE_KEY
- "" // Master Account SECRET_KEY
- );
-
- // ===================================================================
- // Customer Create /w Custom Data
- // ===================================================================
- Dictionary<object,object> data = new Dictionary<object,object>();
-
- data.Add( "internal_uid", "123456" );
- data.Add( "anything", "anything" );
-
- Dictionary<object,object> new_customer = pubnub_customer.Create(data);
-
- if ((int)new_customer["status"] != 200) {
- Console.WriteLine("Error, Unalbe to Create Customer:");
- Console.WriteLine(new_customer["message"]);
- return;
- }
-
- Console.WriteLine("================================================");
- Console.WriteLine("NEW CUSTOMER:");
- Console.WriteLine("status: " + new_customer["status"]);
- Console.WriteLine("uid: " + new_customer["uid"]);
- Console.WriteLine("publish_key: " + new_customer["publish_key"]);
- Console.WriteLine("subscribe_key: " + new_customer["subscribe_key"]);
- Console.WriteLine("secret_key: " + new_customer["secret_key"]);
- Console.WriteLine("CUSTOM VALUES:");
- Console.WriteLine("------------------------------------------------");
- Console.WriteLine("internal_uid: " + new_customer["internal_uid"]);
- Console.WriteLine("anything: " + new_customer["anything"]);
- Console.WriteLine("================================================");
-
- // ===================================================================
- // Customer Update
- // ===================================================================
- Dictionary<object,object> updates = new Dictionary<object,object>();
-
- updates.Add( "anything", "something else" );
- updates.Add( "more-data", "more custom data" );
-
- Dictionary<object,object> updated_customer = pubnub_customer.Update(
- (string)new_customer["uid"], // CUSTOMER'S UID
- updates // CUSTOM VALUE UPDATES
- );
-
- if ((int)updated_customer["status"] != 200) {
- Console.WriteLine("Error, Unalbe to Update Customer:");
- Console.WriteLine(updated_customer["message"]);
- return;
- }
-
- Console.WriteLine("================================================");
- Console.WriteLine("UPDATED CUSTOMER:");
- Console.WriteLine("status: " + updated_customer["status"]);
- Console.WriteLine("UPDATED VALUES:");
- Console.WriteLine("------------------------------------------------");
- Console.WriteLine("internal_uid: " + updated_customer["internal_uid"]);
- Console.WriteLine("anything: " + updated_customer["anything"]);
- Console.WriteLine("more-data: " + updated_customer["more-data"]);
- Console.WriteLine("================================================");
-
- // ===================================================================
- // Customer Get
- // ===================================================================
- Dictionary<object,object> get_customer = pubnub_customer.Get(
- (string)updated_customer["uid"] // CUSTOMER'S UID
- );
-
- if ((int)get_customer["status"] != 200) {
- Console.WriteLine("Error, Unalbe to Get Customer:");
- Console.WriteLine(get_customer["message"]);
- return;
- }
-
- Console.WriteLine("================================================");
- Console.WriteLine("GET CUSTOMER:");
- Console.WriteLine("status: " + get_customer["status"]);
- Console.WriteLine("uid: " + get_customer["uid"]);
- Console.WriteLine("publish_key: " + get_customer["publish_key"]);
- Console.WriteLine("subscribe_key: " + get_customer["subscribe_key"]);
- Console.WriteLine("secret_key: " + get_customer["secret_key"]);
- Console.WriteLine("------------------------------------------------");
- Console.WriteLine("BALANCE VALUES:");
- Console.WriteLine("------------------------------------------------");
- Console.WriteLine("balance: " + get_customer["balance"]);
- Console.WriteLine("free_credits_used: " + get_customer["free_credits_used"]);
- Console.WriteLine("total_credits_used: " + get_customer["total_credits_used"]);
- Console.WriteLine("------------------------------------------------");
- Console.WriteLine("CUSTOM VALUES:");
- Console.WriteLine("------------------------------------------------");
- Console.WriteLine("internal_uid: " + get_customer["internal_uid"]);
- Console.WriteLine("anything: " + get_customer["anything"]);
- Console.WriteLine("more-data: " + get_customer["more-data"]);
- Console.WriteLine("================================================");
-
- // ===================================================================
- // Disable Customer
- // ===================================================================
- Dictionary<object,object> disable_customer = pubnub_customer.Disable(
- (string)updated_customer["uid"] // CUSTOMER'S UID
- );
-
- Console.WriteLine("================================================");
- Console.WriteLine("DISABLE CUSTOMER:");
- Console.WriteLine("status: " + disable_customer["status"]);
- Console.WriteLine("message: " + disable_customer["message"]);
- Console.WriteLine("================================================");
-
- // ===================================================================
- // Enable Customer
- // ===================================================================
- Dictionary<object,object> enable_customer = pubnub_customer.Enable(
- (string)updated_customer["uid"] // CUSTOMER'S UID
- );
-
- Console.WriteLine("================================================");
- Console.WriteLine("ENABLE CUSTOMER:");
- Console.WriteLine("status: " + enable_customer["status"]);
- Console.WriteLine("message: " + enable_customer["message"]);
- Console.WriteLine("================================================");
- }
-}
-
-
-/**
- * PubNub Customer API
- *
- * @author Stephen Blum
- * @package PubnubCustomer
- */
-public class PubnubCustomer {
- private string ORIGIN = "http://pubnub-prod.appspot.com/";
- private string PUBLISH_KEY = "";
- private string SUBSCRIBE_KEY = "";
- private string SECRET_KEY = "";
-
- /**
- * Constructor
- *
- * Prepare PubNub Class State.
- *
- * @param string Publish Key.
- * @param string Subscribe Key.
- * @param string Secret Key.
- */
- public PubnubCustomer(
- string publish_key,
- string subscribe_key,
- string secret_key
- ) {
- this.PUBLISH_KEY = publish_key;
- this.SUBSCRIBE_KEY = subscribe_key;
- this.SECRET_KEY = secret_key;
- }
-
- /**
- * Create Customer
- *
- * Create a new customer and receive API Keys
- *
- * @param object custom_data with key/value dictionary data.
- * @return Dictionary<object,object> customer new API keys.
- */
- public Dictionary<object,object> Create( object custom_data ) {
- List<string> url = new List<string>();
- JavaScriptSerializer serializer = new JavaScriptSerializer();
-
- url.Add("customer-api-2.0-create?");
- url.Add(
- "custom-data=" +
- this.encodeURIcomponent(serializer.Serialize(custom_data))
- );
-
- return this.request(url);
- }
-
- /**
- * Update Customer
- *
- * Update a new customer and receive API Keys
- *
- * @param string cuuid PubNub Customer ID.
- * @param object custom_data with key/value dictionary data.
- * @return Dictionary<object,object> customer with updates and keys.
- */
- public Dictionary<object,object> Update(
- string cuuid,
- object custom_data
- ) {
- List<string> url = new List<string>();
- JavaScriptSerializer serializer = new JavaScriptSerializer();
-
- url.Add("customer-api-2.0-create?");
- url.Add("cuuid=" + cuuid);
- url.Add(
- "custom-data=" +
- this.encodeURIcomponent(serializer.Serialize(custom_data))
- );
-
- return this.request(url);
- }
-
- /**
- * Get Customer
- *
- * Get a customer and receive API Keys and Custom Data
- *
- * @param string cuuid PubNub Customer ID.
- * @param object custom_data with key/value dictionary data.
- * @return Dictionary<object,object> customer with updates and keys.
- */
- public Dictionary<object,object> Get( string cuuid ) {
- List<string> url = new List<string>();
-
- url.Add("customer-api-2.0-get?");
- url.Add("cuuid=" + cuuid);
-
- return this.request(url);
- }
-
- /**
- * Enable Customer
- *
- * Enable a Customer
- *
- * @param string cuuid PubNub Customer ID.
- * @return Dictionary<object,object> success info.
- */
- public Dictionary<object,object> Enable(string cuuid) {
- List<string> url = new List<string>();
-
- url.Add("customer-api-2.0-enable?");
- url.Add("cuuid=" + cuuid);
- url.Add("enabled=1");
-
- return this.request(url);
- }
-
- /**
- * Disable Customer
- *
- * Disable a Customer
- *
- * @param string cuuid PubNub Customer ID.
- * @return Dictionary<object,object> success info.
- */
- public Dictionary<object,object> Disable(string cuuid) {
- List<string> url = new List<string>();
-
- url.Add("customer-api-2.0-enable?");
- url.Add("cuuid=" + cuuid);
- url.Add("enabled=0");
-
- return this.request(url);
- }
-
- /**
- * Request URL
- *
- * @param List<string> request of url directories.
- * @return Dictionary<object,object> from JSON response.
- */
- private Dictionary<object,object> request(List<string> url_components) {
- string temp = null;
- int count = 0;
- byte[] buf = new byte[8192];
- StringBuilder url = new StringBuilder();
- StringBuilder sb = new StringBuilder();
- long timestamp = this.unixTimeNow();
-
- JavaScriptSerializer serializer = new JavaScriptSerializer();
-
- // Add Origin To The Request
- url.Append(this.ORIGIN);
-
- // Add Signature
- url_components.Add("pub-key=" + this.PUBLISH_KEY);
- url_components.Add("timestamp=" + timestamp.ToString());
- url_components.Add("signature=" + this.createSignature(timestamp));
- url_components.Add("end=1");
-
- // Generate URL with UTF-8 Encoding
- foreach ( string url_bit in url_components) {
- url.Append(url_bit);
- url.Append("&");
- }
-
- /*
- Console.WriteLine("REQUEST:");
- Console.WriteLine(url.ToString());
- */
-
- // Create Request
- HttpWebRequest request = (HttpWebRequest)
- WebRequest.Create(url.ToString());
-
- // Receive Response
- HttpWebResponse response = (HttpWebResponse)request.GetResponse();
- Stream resStream = response.GetResponseStream();
-
- // Read
- do {
- count = resStream.Read( buf, 0, buf.Length );
- if (count != 0) {
- temp = Encoding.UTF8.GetString( buf, 0, count );
- sb.Append(temp);
- }
- } while (count > 0);
-
- // Parse Response
- string message = sb.ToString();
-
- /*
- Console.WriteLine("RESPONSE:");
- Console.WriteLine(message);
- */
-
- return serializer.Deserialize<Dictionary<object,object>>(message);
- }
-
- private string createSignature(long timestamp) {
- StringBuilder string_to_sign = new StringBuilder();
- string_to_sign
- .Append(this.PUBLISH_KEY)
- .Append('/')
- .Append(this.SUBSCRIBE_KEY)
- .Append('/')
- .Append(this.SECRET_KEY)
- .Append('/')
- .Append(timestamp);
-
- return md5(string_to_sign.ToString());
- }
-
- private long unixTimeNow() {
- TimeSpan _TimeSpan = (
- DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0)
- );
- return (long)_TimeSpan.TotalSeconds;
- }
-
- private string encodeURIcomponent(string s) {
- StringBuilder o = new StringBuilder();
- foreach (char ch in s.ToCharArray()) {
- if (isUnsafe(ch)) {
- o.Append('%');
- o.Append(toHex(ch / 16));
- o.Append(toHex(ch % 16));
- }
- else o.Append(ch);
- }
- return o.ToString();
- }
-
- private char toHex(int ch) {
- return (char)(ch < 10 ? '0' + ch : 'A' + ch - 10);
- }
-
- private bool isUnsafe(char ch) {
- return " ~`!@#$%^&*()+=[]\\{}|;':\",./<>?".IndexOf(ch) >= 0;
- }
-
- private static string md5(string text) {
- MD5 md5 = new MD5CryptoServiceProvider();
- byte[] data = Encoding.Default.GetBytes(text);
- byte[] hash = md5.ComputeHash(data);
- string hexaHash = "";
- foreach (byte b in hash) hexaHash += String.Format("{0:x2}", b);
- return hexaHash;
- }
-}
-
View
BIN csharp/3.1/PubnubCustomer.exe
Binary file not shown.
View
BIN csharp/3.1/PubnubCustomer.exe.mdb
Binary file not shown.
View
BIN csharp/3.1/System.Runtime.Serialization.Json.dll
Binary file not shown.
View
65 csharp/3.1/System.Runtime.Serialization.Json.xml
@@ -1,65 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?>
-<doc>
- <assembly>
- <name>System.Runtime.Serialization.Json</name>
- </assembly>
- <members>
- <member name="T:System.Runtime.Serialization.Json.JsonReaderWriterFactory">
- <summary>Produces instances of <see cref="T:System.Xml.XmlDictionaryReader" /> that can read data encoded with JavaScript Object Notation (JSON) from a stream or buffer and map it to an XML Infoset, and produces instances of <see cref="T:System.Xml.XmlDictionaryWriter" /> that can map an XML Infoset to JSON and write JSON-encoded data to a stream. </summary>
- </member>
- <member name="M:System.Runtime.Serialization.Json.JsonReaderWriterFactory.CreateJsonReader(System.Byte[],System.Int32,System.Int32,System.Xml.XmlDictionaryReaderQuotas)">
- <summary>Creates an <see cref="T:System.Xml.XmlDictionaryReader" /> that can map a buffer encoded with JavaScript Object Notation (JSON), of a specified size and offset, to an XML Infoset.</summary>
- <returns>An <see cref="T:System.Xml.XmlDictionaryReader" /> that can read JSON.</returns>
- <param name="buffer">The input <see cref="T:System.Byte" /> buffer array from which to read.</param>
- <param name="offset">Starting position from which to read in <paramref name="buffer" />.</param>
- <param name="count">Number of bytes that can be read from <paramref name="buffer" />.</param>
- <param name="quotas">The <see cref="T:System.Xml.XmlDictionaryReaderQuotas" /> must be set to <see cref="P:System.Xml.XmlDictionaryReaderQuotas.Max" /> in Silverlight version 4 Release Candidate applications.</param>
- <exception cref="T:System.ArgumentNullException">
- <paramref name="stream" /> is null.</exception>
- <exception cref="T:System.ArgumentOutOfRangeException">
- <paramref name="offset" /> is negative or exceeds the <paramref name="buffer" /> length.</exception>
- <exception cref="T:System.ArgumentOutOfRangeException">
- <paramref name="count" /> is negative or exceeds the <paramref name="buffer" /> length minus the <paramref name="offset" />.</exception>
- </member>
- <member name="M:System.Runtime.Serialization.Json.JsonReaderWriterFactory.CreateJsonReader(System.Byte[],System.Xml.XmlDictionaryReaderQuotas)">
- <summary>Creates an <see cref="T:System.Xml.XmlDictionaryReader" /> that can map a specified buffer encoded with JavaScript Object Notation (JSON) to an XML Infoset.</summary>
- <returns>An <see cref="T:System.Xml.XmlDictionaryReader" /> that can process JavaScript Object Notation (JSON) data from the buffer specified.</returns>
- <param name="buffer">The input <see cref="T:System.Byte" /> buffer array from which to read.</param>
- <param name="quotas">The <see cref="T:System.Xml.XmlDictionaryReaderQuotas" /> must be set to <see cref="P:System.Xml.XmlDictionaryReaderQuotas.Max" /> in Silverlight version 4 Release Candidate applications used to prevent Denial of Service (DoS) attacks when reading untrusted data. </param>
- <exception cref="T:System.ArgumentNullException">
- <paramref name="buffer" /> is null.</exception>
- </member>
- <member name="M:System.Runtime.Serialization.Json.JsonReaderWriterFactory.CreateJsonReader(System.IO.Stream,System.Xml.XmlDictionaryReaderQuotas)">
- <summary>Creates an <see cref="T:System.Xml.XmlDictionaryReader" /> that can map a specified stream encoded with JavaScript Object Notation (JSON) to an XML Infoset.</summary>
- <returns>An <see cref="T:System.Xml.XmlDictionaryReader" /> that can read JSON.</returns>
- <param name="stream">The input <see cref="T:System.IO.Stream" /> from which to read.</param>
- <param name="quotas">The <see cref="T:System.Xml.XmlDictionaryReaderQuotas" /> must be set to <see cref="P:System.Xml.XmlDictionaryReaderQuotas.Max" /> in Silverlight version 4 Release Candidate applications. </param>
- <exception cref="T:System.ArgumentNullException">
- <paramref name="stream" /> is null.</exception>
- </member>
- <member name="M:System.Runtime.Serialization.Json.JsonReaderWriterFactory.CreateJsonWriter(System.IO.Stream)">
- <summary>Creates an <see cref="T:System.Xml.XmlDictionaryWriter" /> that writes data encoded with JSON to a stream using a UTF-8 character encoding.</summary>
- <returns>An <see cref="T:System.Xml.XmlDictionaryWriter" /> that writes data encoded with JSON to the stream from an XML Infoset.</returns>
- <param name="stream">The output <see cref="T:System.IO.Stream" /> for the JSON writer.</param>
- <exception cref="T:System.ArgumentNullException">
- <paramref name="stream" /> is null.</exception>
- </member>
- <member name="M:System.Runtime.Serialization.Json.JsonReaderWriterFactory.CreateJsonWriter(System.IO.Stream,System.Text.Encoding)