root/lang/csharp/MTFileUploader/MTFileUploader/MainForm.cs

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading;
using System.Windows.Forms;

using CookComputing.XmlRpc;
using MTFileUploader.Properties;

namespace MTFileUploader
{
    public partial class MainForm : Form
    {
        private Settings _settings = new Settings();
        private Boolean _isUploading = false;

        public MainForm()
        {
            InitializeComponent();

            comboSites.DataSource = _settings.Sites;
            UpdateSites();
        }

        #region イベントハンドラ

        private void comboSites_SelectedIndexChanged(object sender, EventArgs e)
        {
            if (comboSites.SelectedItem != null)
                txtUploadPath.Text = (comboSites.SelectedItem as SiteSetting).DefaultSitePath;
        }

        private void lvUploadFiles_DragEnter(object sender, DragEventArgs e)
        {
            if (!_isUploading && e.Data.GetDataPresent("FileDrop"))
            {
                e.Effect = DragDropEffects.Copy;
            }
        }

        private void lvUploadFiles_DragDrop(object sender, DragEventArgs e)
        {
            if (!_isUploading && e.Data.GetDataPresent("FileDrop"))
            {
                lvUploadFiles.Items.Clear();
                foreach (var fileName in (e.Data.GetData("FileDrop") as String[]))
                {
                    String fileNameOnly = Path.GetFileName(fileName);
                    String dirName = Path.GetDirectoryName(fileName);
                    if (Directory.Exists(fileName))
                    {
                        // ディレクトリ
                        FindUploadFiles(dirName, fileName);
                    }
                    else
                    {
                        // ファイル
                        ListViewItem item = new ListViewItem(fileNameOnly);
                        item.Tag = fileNameOnly;
                        item.ImageKey = "Image_File";
                        item.SubItems.Add(fileNameOnly);
                        item.SubItems.Add(fileName);
                        lvUploadFiles.Items.Add(item);
                    }
                }
                UpdateServerPath();
            }
        }

        private void btnUpload_Click(object sender, EventArgs e)
        {
            if (_isUploading)
            {
                backgroundWorker.CancelAsync();
                return;
            }

            SiteSetting settings = comboSites.SelectedItem as SiteSetting;
            if (settings == null)
            {
                MessageBox.Show(this, "接続先が選択されていません。", this.Text, MessageBoxButtons.OK, MessageBoxIcon.Error);
                return;
            }

            _isUploading = true;
            lvUploadFiles.ContextMenuStrip = null;
            txtUploadPath.Enabled = false;
            comboSites.Enabled = false;
            btnUpload.Text = "キャンセル(&C)";

            foreach (ListViewItem item in lvUploadFiles.Items)
                item.ImageKey = "Image_File";

            backgroundWorker.RunWorkerAsync();
        }

        private void btnSettings_Click(object sender, EventArgs e)
        {
            using (SettingsForm settingsForm = new SettingsForm())
            {
                settingsForm.ShowDialog();
                _settings.Reload();
                UpdateSites();
            }
        }

        private void backgroundWorker_DoWork(object sender, DoWorkEventArgs e)
        {
            ExecuteUpload(e);
        }

        private void backgroundWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
            if (e.Cancelled)
                toolStripStatusLabel.Text = "ファイルのアップロードはキャンセルされました";
            else if (e.Result == null)
                toolStripStatusLabel.Text = "ファイルのアップロードが完了しました";
            else
                toolStripStatusLabel.Text = e.Result.ToString();

            _isUploading = false;

            btnUpload.Text = "アップロード(&U)";
            txtUploadPath.Enabled = true;
            comboSites.Enabled = true;
        }

        private void backgroundWorker_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            StatusState state = e.UserState as StatusState;
            if (state.Status != Status.Error)
            {
                toolStripStatusLabel.Text = state.Text;
            }
            else
            {
                toolStripStatusLabel.Text = "アップロード中にエラーが発生しました";
                MessageBox.Show(this, state.Text, this.Text, MessageBoxButtons.OK, MessageBoxIcon.Error);
            }

            if (state.Item != null)
            {
                state.Item.ImageKey = (
                   state.Status == Status.Done      ? "Done" :
                   state.Status == Status.Uploading ? "Publish" :
                   state.Status == Status.Error     ? "Error" :
                                                      "Image_File");
            }
        }

        private void txtUploadPath_TextChanged(object sender, EventArgs e)
        {
            UpdateServerPath();
        }

        private void lvUploadFiles_KeyUp(object sender, KeyEventArgs e)
        {
            if (!_isUploading)
            {
                if (e.KeyCode == Keys.Delete && lvUploadFiles.SelectedItems.Count > 0)
                {
                    var itemsTemp = new List<ListViewItem>(lvUploadFiles.SelectedItems.OfType<ListViewItem>());
                    foreach (var item in itemsTemp)
                        lvUploadFiles.Items.Remove(item);
                }
            }
        }

        private void deleteToolStripMenuItem_Click(object sender, EventArgs e)
        {
            if (!_isUploading)
            {
                if (lvUploadFiles.SelectedItems.Count > 0)
                {
                    var itemsTemp = new List<ListViewItem>(lvUploadFiles.SelectedItems.OfType<ListViewItem>());
                    foreach (var item in itemsTemp)
                        lvUploadFiles.Items.Remove(item);
                }
            }
        }

        private void lvUploadFiles_ItemSelectionChanged(object sender, ListViewItemSelectionChangedEventArgs e)
        {
            if (!_isUploading)
            {
                lvUploadFiles.ContextMenuStrip = ((lvUploadFiles.SelectedItems.Count > 0) ? contextMenuStrip : null);
            }
        }
        #endregion

        private void UpdateServerPath()
        {
            var baseDir = txtUploadPath.Text.Trim('/');
            foreach (ListViewItem item in lvUploadFiles.Items)
            {
                var fileRelPath = item.Tag as String;
                item.SubItems[1].Text = (baseDir.Length == 0 ? fileRelPath : String.Format("{0}/{1}", baseDir, fileRelPath));
            }
        }

        private void ExecuteUpload(DoWorkEventArgs e)
        {
            SiteSetting settings = Invoke((Func<Object>)(() => comboSites.SelectedItem)) as SiteSetting;
            IMetaWeblog metaWeblog = CookComputing.XmlRpc.XmlRpcProxyGen.Create<IMetaWeblog>();
            metaWeblog.Url = settings.EndPointUrl;

            // Basic 認証
            if (!String.IsNullOrEmpty(settings.HttpUserName))
            {
                CredentialCache credCache = new CredentialCache();
                credCache.Add(new Uri(metaWeblog.Url), "Basic", new NetworkCredential(settings.HttpUserName, settings.HttpPassword));
                metaWeblog.Credentials = credCache;
                metaWeblog.PreAuthenticate = true;
            }

            var userName = settings.UserName;
            var password = settings.Password;
            var blogId = settings.BlogId;

            // ログインチェック
            try
            {
                backgroundWorker.ReportProgress(0, new StatusState() { Text = "ログイン認証を確認しています..." });
                metaWeblog.GetUsersBlogs(1, userName, password);
            }
            catch (XmlRpcFaultException ex)
            {
                String errorMessage = String.Format("ログイン時にエラーが発生しました。{0}\r\n\r\n詳細なメッセージ: \r\n{1}", ex.FaultString, ex.Message);
                backgroundWorker.ReportProgress(0, new StatusState() { Text = errorMessage, Status = Status.Error });
                e.Result = "アップロード中にエラーが発生しました。";
                return;
            }
            catch (XmlRpcServerException ex)
            {
                String errorMessage = String.Format("サーバへ接続時にエラーが発生しました。\r\n\r\n詳細なメッセージ: \r\n{0}", ex.Message);
                backgroundWorker.ReportProgress(0, new StatusState() { Text = errorMessage, Status = Status.Error });
                e.Result = "アップロード中にエラーが発生しました。";
                return;
            }

            var baseDir = txtUploadPath.Text.Trim('/');
            // アップロード
            foreach (var i in Enumerable.Range(0, lvUploadFiles.Items.Count))
            {
                // キャンセル
                if (backgroundWorker.CancellationPending)
                {
                    e.Cancel = true;
                    return;
                }

                var item = Invoke((Func<ListViewItem>)(() => lvUploadFiles.Items[i])) as ListViewItem;
                var fileRelPath = item.SubItems[1].Text;
                var statusText = String.Format("ファイル {0} をアップロードしています(残り{1}個のファイル)...", fileRelPath, lvUploadFiles.Items.Count - i);
                Int32 progressPct = (i / lvUploadFiles.Items.Count) * 100;
                backgroundWorker.ReportProgress(progressPct, new StatusState() { Text = statusText, Item = item, Status = Status.Uploading });

                var mediaObject = new CookComputing.XmlRpc.XmlRpcStruct();
                mediaObject.Add("name", fileRelPath);
                mediaObject.Add("bits", File.ReadAllBytes(item.SubItems[2].Text));
                try
                {
                    metaWeblog.NewMediaObject(blogId, userName, password, mediaObject);
                    backgroundWorker.ReportProgress(progressPct, new StatusState() { Text = statusText, Item = item, Status = Status.Done });
                }
                catch (XmlRpcFaultException ex)
                {
                    String errorMessage = String.Format("エラーが発生しました。{0}\r\n\r\n詳細なメッセージ: \r\n{1}", ex.FaultString, ex.Message);
                    backgroundWorker.ReportProgress(progressPct, new StatusState() { Text = errorMessage, Item = item, Status = Status.Error });
                    e.Result = "アップロード中にエラー発生しました";
                    return;
                }
                catch (XmlRpcServerException ex)
                {
                    String errorMessage = String.Format("サーバへ接続時にエラーが発生しました。\r\n\r\n詳細なメッセージ: \r\n{0}", ex.Message);
                    backgroundWorker.ReportProgress(progressPct, new StatusState() { Text = errorMessage, Item = item, Status = Status.Error });
                    e.Result = "アップロード中にエラー発生しました";
                    return;
                }
            }
        }

        private void FindUploadFiles(String baseDir, String searchDir)
        {
            foreach (var dirName in Directory.GetDirectories(searchDir))
            {
                FindUploadFiles(baseDir, dirName);
            }
            foreach (var fileName in Directory.GetFiles(searchDir))
            {
                // ファイル
                String fileNameOnly = Path.GetFileName(fileName);
                String dirName = Path.GetDirectoryName(fileName);
                String fileRelativePath = fileName.Remove(0, baseDir.Length + 1);

                ListViewItem item = new ListViewItem(fileNameOnly, "Image_File");
                item.Tag = fileRelativePath.Replace('\\', '/');
                item.SubItems.Add(fileRelativePath.Replace('\\', '/')); // Server path
                item.SubItems.Add(fileName); // File path
                lvUploadFiles.Items.Add(item);
            }
        }

        private void UpdateSites()
        {
            comboSites.DataSource = _settings.Sites;
            comboSites.BindingContext[_settings.Sites].SuspendBinding();
            comboSites.BindingContext[_settings.Sites].ResumeBinding();
            comboSites.SelectedItem = null;
        }

        private enum Status
        {
            Ready = 1 << 0,
            Uploading = 1 << 2,
            Done = 1 << 3,
            Error = 255
        }

        private class StatusState
        {
            public String Text { get; set; }
            public Status Status { get; set; }
            public ListViewItem Item { get; set; }
        }
    }
}