Fixes #3 - basic client for file upload

@@ -2,20 +2,31 @@ use std::fmt::Display;
 
 use super::super::error::*;
 use super::super::client::Client;
+use crate::upload::upload::Upload;
 
 #[derive(Debug, Clone)]
-pub struct Upload {
-    client: Client,
+pub struct UploadApi {
+    client :Client,
 }
 
-impl Upload {
-    pub(crate) async fn new(name :&str) -> Result<()> {
-        Ok(())
-        /*
+impl UploadApi {
+    pub(crate) async fn new() -> Result<UploadApi> {
+        let client = Client::new()?;
+        Ok(UploadApi { client })
+    }
+
+    pub(crate) async fn store(&self, upload :&Upload) -> Result<&UploadApi> {
+        let response = self.client.post_stream( "/api/v0/upload"
+                                              , &upload.mime_type()
+                                              , upload.data() ).await?;
         match response.status() {
             200 => Ok(self),
             status => Err(Self::status_error(status)),
         }
-        */
+    }
+
+    fn status_error<I: Display>(status :I) -> Error {
+        let err_str = format!("Invalid response status: {}", status);
+        Error::from(err_str.as_str())
     }
 }

 use mogwai::prelude::*;
-use web_sys::{HtmlInputElement, ImageBitmap, HtmlCanvasElement, CanvasRenderingContext2d};
+use web_sys::{HtmlInputElement, HtmlCanvasElement, CanvasRenderingContext2d};
+
+use crate::api::upload::UploadApi;
 
 use super::upload::Upload;
 
@@ -7,6 +9,7 @@ use super::upload::Upload;
 pub(super) enum UploadLogic {
     Add(DomEvent),
     Remove(usize),
+    Upload,
 }
 
 pub(super) async fn upload_preview_logic( mut rx_canvas :broadcast::Receiver<Dom>
@@ -27,7 +30,7 @@ pub(super) async fn upload_preview_logic( mut rx_canvas :broadcast::Receiver<Dom
         }
     }
 
-    while let Some(event) = rx_click.next().await {
+    while let Some(_) = rx_click.next().await {
         upload.tx_logic . try_broadcast(UploadLogic::Remove(upload.id))
                         . unwrap();
     }
@@ -38,6 +41,7 @@ pub(super) async fn upload_logic( mut rx_logic :broadcast::Receiver<UploadLogic>
                                 , tx_previews: mpmc::Sender<ListPatch<ViewBuilder<Dom>>>
                                 ) {
     let mut uploads: ListPatchModel<Upload> = ListPatchModel::new();
+    let api = UploadApi::new().await.unwrap();
 
     mogwai::spawn(uploads.stream().for_each(move |patch| {
         let patch = patch.map(|u| u.into());
@@ -80,6 +84,14 @@ pub(super) async fn upload_logic( mut rx_logic :broadcast::Receiver<UploadLogic>
                     uploads.list_patch_remove(index).unwrap();
                 }
             },
+            UploadLogic::Upload => {
+                for upload in uploads.read().await.iter() {
+                    match api.store(upload).await {
+                        Ok(_) => (),
+                        Err(e) => log::error!("{:?}", e),
+                    }
+                }
+            }
         }
     }
 }

 mod logic;
-mod upload;
+pub(crate) mod upload;
 mod view;
 
 use mogwai::prelude::*;

@@ -4,7 +4,7 @@ use web_sys::{File, ImageBitmap, ReadableStream};
 use super::{view::upload_preview_view, logic::{upload_preview_logic, UploadLogic}};
 
 #[derive(Clone, Debug)]
-pub(super) struct Upload {
+pub(crate) struct Upload {
     pub(super) id       :usize,
                file     :File,
                bitmap   :ImageBitmap,
@@ -26,11 +26,11 @@ impl Upload {
         Self { id, file, bitmap, tx_logic }
     }
 
-    pub(super) fn mime_type(&self) -> String {
+    pub(crate) fn mime_type(&self) -> String {
         self.file.type_()
     }
 
-    pub(super) fn data(&self) -> ReadableStream {
+    pub(crate) fn data(&self) -> ReadableStream {
         self.file.stream()
     }
 

@@ -32,9 +32,10 @@ pub(super) fn upload_preview_view( tx_canvas :broadcast::Sender<Dom>
 pub(super) fn upload_view( tx_logic: broadcast::Sender<UploadLogic>
                          , rx_previews: mpmc::Receiver<ListPatch<ViewBuilder<Dom>>>
                          ) -> ViewBuilder<Dom> {
-    let on_change_filter = tx_logic
-                         . sink()
-                         . contra_map(|e| UploadLogic::Add(e));
+    let select_filter = tx_logic.sink()
+                      . contra_map(|e| UploadLogic::Add(e));
+    let upload_filter = tx_logic.sink()
+                      . contra_map(|_| UploadLogic::Upload);
 
 //            <div class="spin"></div>
     builder! {
@@ -43,8 +44,8 @@ pub(super) fn upload_view( tx_logic: broadcast::Sender<UploadLogic>
                 <input type="file"
                        multiple="multiple"
                        accept="image/*"
-                       on:change=on_change_filter />
-                <button>"Upload"</button>
+                       on:change=select_filter />
+                <button on:click=upload_filter>"Upload"</button>
             </div>
             <ul patch:children=rx_previews>
             </ul>