Silverlight Multi-part File Upload Form Post

Silverlight not actually very web friendly. It lacks of built-in support for the current HTML form post protocol. So, we have to write it our own. I have written an extension class and two serializer classes, one for normal form post (DataContractQueryStringSerializer) while the other for multipart upload form post (DataContractMultiPartSerializer).

If you only want to have the working code, just copy the code below. Detail explanation is available at Multi-Part Form Post in Shane's Shelf

view plainprint?

1. public static class Extensions  
2. {  
3.     public static void PostFormAsync(this HttpWebRequest request, object parameters, AsyncCallback callback)  
4.     {  
5.         request.Method = "POST";  
6.         request.ContentType = "application/x-www-form-urlencoded";  
7.         request.BeginGetRequestStream(new AsyncCallback(asyncResult =>  
8.         {  
9.             Stream stream = request.EndGetRequestStream(asyncResult);  
10.             DataContractQueryStringSerializer ser = new DataContractQueryStringSerializer();  
11.             ser.WriteObject(stream, parameters);  
12.             stream.Close();  
13.             request.BeginGetResponse(callback, request);  
14.         }), request);  
15.     }  
16.   
17.     public static void PostMultiPartAsync(this HttpWebRequest request, object parameters, AsyncCallback callback)  
18.     {  
19.         request.Method = "POST";  
20.         string boundary = "---------------" + DateTime.Now.Ticks.ToString();  
21.         request.ContentType = "multipart/form-data; boundary=" + boundary;  
22.         request.BeginGetRequestStream(new AsyncCallback(asyncResult =>  
23.         {  
24.             Stream stream = request.EndGetRequestStream(asyncResult);  
25.   
26.             DataContractMultiPartSerializer ser = new DataContractMultiPartSerializer(boundary);  
27.             ser.WriteObject(stream, parameters);  
28.             stream.Close();  
29.             request.BeginGetResponse(callback, request);  
30.         }), request);  
31.     }  
32. }  
33.   
34. public class DataContractQueryStringSerializer  
35. {  
36.     public void WriteObject(Stream stream, object data)  
37.     {  
38.         StreamWriter writer = new StreamWriter(stream);  
39.         if (data != null)  
40.         {  
41.             if (data is Dictionary<string, string>)  
42.             {  
43.                 foreach (var entry in data as Dictionary<string, string>)  
44.                 {  
45.                     writer.Write("{0}={1}&", entry.Key, entry.Value);  
46.                 }  
47.             }  
48.             else  
49.             {  
50.                 foreach (var prop in data.GetType().GetFields())  
51.                 {  
52.                     foreach (var attribute in prop.GetCustomAttributes(true))  
53.                     {  
54.                         if (attribute is DataMemberAttribute)  
55.                         {  
56.                             DataMemberAttribute member = attribute as DataMemberAttribute;  
57.                             writer.Write("{0}={1}&", member.Name ?? prop.Name, prop.GetValue(data));  
58.                         }  
59.                     }  
60.                 }  
61.                 foreach (var prop in data.GetType().GetProperties())  
62.                 {  
63.                     if (prop.CanRead)  
64.                     {  
65.                         foreach (var attribute in prop.GetCustomAttributes(true))  
66.                         {  
67.                             if (attribute is DataMemberAttribute)  
68.                             {  
69.                                 DataMemberAttribute member = attribute as DataMemberAttribute;  
70.                                 writer.Write("{0}={1}&", member.Name ?? prop.Name, prop.GetValue(data, null));  
71.                             }  
72.                         }  
73.                     }  
74.                 }  
75.             }  
76.             writer.Flush();  
77.         }  
78.     }  
79. }  
80.   
81. public class DataContractMultiPartSerializer  
82. {  
83.     private string boundary;  
84.     public DataContractMultiPartSerializer(string boundary)  
85.     {  
86.         this.boundary = boundary;  
87.     }  
88.   
89.     private void WriteEntry(StreamWriter writer, string key, object value)  
90.     {  
91.         if (value != null)  
92.         {  
93.             writer.Write("--");  
94.             writer.WriteLine(boundary);  
95.             if (value is FileInfo)  
96.             {  
97.                 
98.                 FileInfo f = value as FileInfo;  
99.                 writer.WriteLine(@"Content-Disposition: form-data; name=""{0}""; filename=""{1}""", key, f.Name);  
100.                 writer.WriteLine("Content-Type: application/octet-stream");  
101.                 writer.WriteLine("Content-Length: " + f.Length);  
102.                 writer.WriteLine();  
103.                 writer.Flush();  
104.                 Stream output = writer.BaseStream;  
105.                 Stream input = f.OpenRead();  
106.                 byte[] buffer = new byte[4096];  
107.                 for (int size = input.Read(buffer, 0, buffer.Length); size > 0; size = input.Read(buffer, 0, buffer.Length))  
108.                 {  
109.                     output.Write(buffer, 0, size);  
110.                 }  
111.                 output.Flush();  
112.                 writer.WriteLine();  
113.             }  
114.             else  
115.             {  
116.                 writer.WriteLine(@"Content-Disposition: form-data; name=""{0}""", key);  
117.                 writer.WriteLine();  
118.                 writer.WriteLine(value.ToString());  
119.             }  
120.         }  
121.     }  
122.   
123.     public void WriteObject(Stream stream, object data)  
124.     {  
125.         StreamWriter writer = new StreamWriter(stream);  
126.         if (data != null)  
127.         {  
128.             if (data is Dictionary<string, object>)  
129.             {  
130.                 foreach (var entry in data as Dictionary<string, object>)  
131.                 {  
132.                     WriteEntry(writer, entry.Key, entry.Value);  
133.                 }  
134.             }  
135.             else  
136.             {  
137.                 foreach (var prop in data.GetType().GetFields())  
138.                 {  
139.                     foreach (var attribute in prop.GetCustomAttributes(true))  
140.                     {  
141.                         if (attribute is DataMemberAttribute)  
142.                         {  
143.                             DataMemberAttribute member = attribute as DataMemberAttribute;  
144.                             WriteEntry(writer, member.Name ?? prop.Name, prop.GetValue(data));  
145.                         }  
146.                     }  
147.                 }  
148.                 foreach (var prop in data.GetType().GetProperties())  
149.                 {  
150.                     if (prop.CanRead)  
151.                     {  
152.                         foreach (var attribute in prop.GetCustomAttributes(true))  
153.                         {  
154.                             if (attribute is DataMemberAttribute)  
155.                             {  
156.                                 DataMemberAttribute member = attribute as DataMemberAttribute;  
157.                                 WriteEntry(writer, member.Name ?? prop.Name, prop.GetValue(data, null));  
158.                             }  
159.                         }  
160.                     }  
161.                 }  
162.             }  
163.         }  
164.         writer.Write("--");  
165.         writer.Write(boundary);  
166.         writer.WriteLine("--");  
167.         writer.Flush();  
168.     }  
169. }  

  public static class Extensions
  {
      public static void PostFormAsync(this HttpWebRequest request, object parameters, AsyncCallback callback)
      {
          request.Method = "POST";
          request.ContentType = "application/x-www-form-urlencoded";
          request.BeginGetRequestStream(new AsyncCallback(asyncResult =>
          {
              Stream stream = request.EndGetRequestStream(asyncResult);
              DataContractQueryStringSerializer ser = new DataContractQueryStringSerializer();
              ser.WriteObject(stream, parameters);
              stream.Close();
              request.BeginGetResponse(callback, request);
          }), request);
      }

      public static void PostMultiPartAsync(this HttpWebRequest request, object parameters, AsyncCallback callback)
      {
          request.Method = "POST";
          string boundary = "---------------" + DateTime.Now.Ticks.ToString();
          request.ContentType = "multipart/form-data; boundary=" + boundary;
          request.BeginGetRequestStream(new AsyncCallback(asyncResult =>
          {
              Stream stream = request.EndGetRequestStream(asyncResult);

              DataContractMultiPartSerializer ser = new DataContractMultiPartSerializer(boundary);
              ser.WriteObject(stream, parameters);
              stream.Close();
              request.BeginGetResponse(callback, request);
          }), request);
      }
  }

  public class DataContractQueryStringSerializer
  {
      public void WriteObject(Stream stream, object data)
      {
          StreamWriter writer = new StreamWriter(stream);
          if (data != null)
          {
              if (data is Dictionary<string, string>)
              {
                  foreach (var entry in data as Dictionary<string, string>)
                  {
                      writer.Write("{0}={1}&", entry.Key, entry.Value);
                  }
              }
              else
              {
                  foreach (var prop in data.GetType().GetFields())
                  {
                      foreach (var attribute in prop.GetCustomAttributes(true))
                      {
                          if (attribute is DataMemberAttribute)
                          {
                              DataMemberAttribute member = attribute as DataMemberAttribute;
                              writer.Write("{0}={1}&", member.Name ?? prop.Name, prop.GetValue(data));
                          }
                      }
                  }
                  foreach (var prop in data.GetType().GetProperties())
                  {
                      if (prop.CanRead)
                      {
                          foreach (var attribute in prop.GetCustomAttributes(true))
                          {
                              if (attribute is DataMemberAttribute)
                              {
                                  DataMemberAttribute member = attribute as DataMemberAttribute;
                                  writer.Write("{0}={1}&", member.Name ?? prop.Name, prop.GetValue(data, null));
                              }
                          }
                      }
                  }
              }
              writer.Flush();
          }
      }
  }

  public class DataContractMultiPartSerializer
  {
      private string boundary;
      public DataContractMultiPartSerializer(string boundary)
      {
          this.boundary = boundary;
      }

      private void WriteEntry(StreamWriter writer, string key, object value)
      {
          if (value != null)
          {
              writer.Write("--");
              writer.WriteLine(boundary);
              if (value is FileInfo)
              {
                
                  FileInfo f = value as FileInfo;
                  writer.WriteLine(@"Content-Disposition: form-data; name=""{0}""; filename=""{1}""", key, f.Name);
                  writer.WriteLine("Content-Type: application/octet-stream");
                  writer.WriteLine("Content-Length: " + f.Length);
                  writer.WriteLine();
                  writer.Flush();
                  Stream output = writer.BaseStream;
                  Stream input = f.OpenRead();
                  byte[] buffer = new byte[4096];
                  for (int size = input.Read(buffer, 0, buffer.Length); size > 0; size = input.Read(buffer, 0, buffer.Length))
                  {
                      output.Write(buffer, 0, size);
                  }
                  output.Flush();
                  writer.WriteLine();
              }
              else
              {
                  writer.WriteLine(@"Content-Disposition: form-data; name=""{0}""", key);
                  writer.WriteLine();
                  writer.WriteLine(value.ToString());
              }
          }
      }

      public void WriteObject(Stream stream, object data)
      {
          StreamWriter writer = new StreamWriter(stream);
          if (data != null)
          {
              if (data is Dictionary<string, object>)
              {
                  foreach (var entry in data as Dictionary<string, object>)
                  {
                      WriteEntry(writer, entry.Key, entry.Value);
                  }
              }
              else
              {
                  foreach (var prop in data.GetType().GetFields())
                  {
                      foreach (var attribute in prop.GetCustomAttributes(true))
                      {
                          if (attribute is DataMemberAttribute)
                          {
                              DataMemberAttribute member = attribute as DataMemberAttribute;
                              WriteEntry(writer, member.Name ?? prop.Name, prop.GetValue(data));
                          }
                      }
                  }
                  foreach (var prop in data.GetType().GetProperties())
                  {
                      if (prop.CanRead)
                      {
                          foreach (var attribute in prop.GetCustomAttributes(true))
                          {
                              if (attribute is DataMemberAttribute)
                              {
                                  DataMemberAttribute member = attribute as DataMemberAttribute;
                                  WriteEntry(writer, member.Name ?? prop.Name, prop.GetValue(data, null));
                              }
                          }
                      }
                  }
              }
          }
          writer.Write("--");
          writer.Write(boundary);
          writer.WriteLine("--");
          writer.Flush();
      }
  }

The usage is as follows:
First a PHP file

view plainprint?

1. <?php  
2. print_r($_REQUEST);  
3. $src = $_FILES['y']['tmp_name'];  
4. $dest = "C:\\Windows\\Temp\\".$_FILES['y']['name'];  
5. echo $src;  
6. echo "\r\n";  
7. echo $dest;  
8. echo @copy($src, $dest);  
9. ?>  

<?php
print_r($_REQUEST);
$src = $_FILES['y']['tmp_name'];
$dest = "C:\\Windows\\Temp\\".$_FILES['y']['name'];
echo $src;
echo "\r\n";
echo $dest;
echo @copy($src, $dest);
?>

Then the Page control

view plainprint?

1.   public partial class Page : UserControl  
2. {  
3.     public Page()  
4.     {  
5.         InitializeComponent();  
6.         // Create a request object  
7.         HttpWebRequest request = (HttpWebRequest)WebRequest.Create(new Uri("http://localhost/rms/test.php"));  
8.         OpenFileDialog dlg = new OpenFileDialog();  
9.         if (dlg.ShowDialog().Value)  
10.         {  
11.             request.PostMultiPartAsync(new Dictionary<string, object> { { "x", "1" }, { "y", dlg.File } }, new AsyncCallback(asyncResult =>  
12.             {  
13.                 HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(asyncResult);  
14.   
15.                 Stream responseStream = response.GetResponseStream();  
16.                 StreamReader reader = new StreamReader(responseStream);  
17.                 this.Dispatcher.BeginInvoke(delegate  
18.                 {  
19.                     // output is a TextBlock  
20.                     output.Text = reader.ReadToEnd();  
21.                     response.Close();  
22.                 });  
23.             }));  
24.         }  
25.     }  
26. }  

    public partial class Page : UserControl
  {
      public Page()
      {
          InitializeComponent();
          // Create a request object
          HttpWebRequest request = (HttpWebRequest)WebRequest.Create(new Uri("http://localhost/rms/test.php"));
          OpenFileDialog dlg = new OpenFileDialog();
          if (dlg.ShowDialog().Value)
          {
              request.PostMultiPartAsync(new Dictionary<string, object> { { "x", "1" }, { "y", dlg.File } }, new AsyncCallback(asyncResult =>
              {
                  HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(asyncResult);

                  Stream responseStream = response.GetResponseStream();
                  StreamReader reader = new StreamReader(responseStream);
                  this.Dispatcher.BeginInvoke(delegate
                  {
                      // output is a TextBlock
                      output.Text = reader.ReadToEnd();
                      response.Close();
                  });
              }));
          }
      }
  }

Since it is able to serialize data contract, you could actually replace

view plainprint?

1. new Dictionary<string, object> { { "x", "1" }, { "y", dlg.File } }  

new Dictionary<string, object> { { "x", "1" }, { "y", dlg.File } }

with

view plainprint?

1. new Point(){X=1, Y=2}  

new Point(){X=1, Y=2}

given the point class is like this:

view plainprint?

1.   [DataContract]  
2. public class Point  
3. {  
4.     [DataMember]  
5.     public int X { get; set; }  
6.     [DataMember(Name="y")]  
7.     public int Y { get; set; }  
8. }  

    [DataContract]
  public class Point
  {
      [DataMember]
      public int X { get; set; }
      [DataMember(Name="y")]
      public int Y { get; set; }
  }