/*=============================================================================

*

* ＦＴＰコマンド操作

*

===============================================================================

/ Copyright (C) 1997-2007 Sota. All rights reserved.

/

/ Redistribution and use in source and binary forms, with or without

/ modification, are permitted provided that the following conditions

/ are met:

/

/ 1. Redistributions of source code must retain the above copyright

/ notice, this list of conditions and the following disclaimer.

/ 2. Redistributions in binary form must reproduce the above copyright

/ notice, this list of conditions and the following disclaimer in the

/ documentation and/or other materials provided with the distribution.

/

/ THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR

/ IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES

/ OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.

/ IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,

/ INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,

/ BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF

/ USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON

/ ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

/ (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF

/ THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

/============================================================================*/

#include "common.h"

/*===== プロトタイプ =====*/

static int CheckRemoteFile(TRANSPACKET *Pkt, std::vector<FILELIST> const& ListList);

static void DispMirrorFiles(std::vector<FILELIST> const& Local, std::vector<FILELIST> const& Remote);

static void MirrorDeleteAllLocalDir(std::vector<FILELIST> const& Local, TRANSPACKET& item, std::vector<TRANSPACKET>& list);

static int CheckLocalFile(TRANSPACKET *Pkt) noexcept;

static std::wstring RemoveAfterSemicolon(std::wstring&& path);

static void MirrorDeleteAllDir(std::vector<FILELIST> const& Remote, TRANSPACKET& item, std::vector<TRANSPACKET>& list);

static int MirrorNotify(bool upload) noexcept;

static void CountMirrorFiles(HWND hDlg, std::vector<TRANSPACKET> const& list);

static int AskMirrorNoTrn(std::wstring_view path, int Mode);

static int AskUploadFileAttr(std::wstring const& path);

static bool UpDownAsDialog(std::wstring& name, int win) noexcept;

static void DeleteAllDir(std::vector<FILELIST> const& Dt, int Win, int *Sw, int *Flg, std::wstring& CurDir);

static void DelNotifyAndDo(FILELIST const& Dt, int Win, int *Sw, int *Flg, std::wstring& CurDir);

static std::wstring ReformToVMSstyleDirName(std::wstring&& path);

static std::wstring ReformToVMSstylePathName(std::wstring_view path);

static std::wstring RenameUnuseableName(std::wstring&& filename) noexcept;

static int ExistNotify; /* 確認ダイアログを出すかどうか YES/NO */

static inline auto RemoteName(std::wstring&& name) {

return FnameCnv == FNAME_LOWER ? lc(std::move(name)) : FnameCnv == FNAME_UPPER ? uc(std::move(name)) : std::move(name);

}

/*----- ファイル一覧で指定されたファイルをダウンロードする --------------------

*

* Parameter

* int ChName : 名前を変えるかどうか (YES/NO)

* int ForceFile : ディレクトリをファイル見なすかどうか (YES/NO)

* int All : 全てが選ばれている物として扱うかどうか (YES/NO)

*

* Return Value

* なし

*----------------------------------------------------------------------------*/

// ローカル側のパスから必要なフォルダを作成

void MakeDirFromLocalPath(fs::path const& LocalFile, fs::path const& Old) {

TRANSPACKET Pkt;

auto oit = Old.begin();

fs::path path;

for (auto& current : LocalFile) {

if (oit != Old.end() && current == *oit) {

++oit;

path /= current;

} else {

oit = Old.end();

path /= RemoteName(current);

Pkt.Local = path;

Pkt.Command = L"MKD "s;

Pkt.Remote.clear();

AddTransFileList(&Pkt);

}

}

}

void DownloadProc(int ChName, int ForceFile, int All)

{

TRANSPACKET Pkt;

// ファイル一覧バグ修正

int ListSts;

// 同時接続対応

CancelFlg = NO;

if(CheckClosedAndReconnect() == FFFTP_SUCCESS)

{

DisableUserOpe();

ExistNotify = YES;

std::vector<FILELIST> FileListBase;

ListSts = MakeSelectedFileList(WIN_REMOTE, ForceFile == YES ? NO : YES, All, FileListBase, &CancelFlg);

if(AskNoFullPathMode() == YES)

{

Pkt.Command = L"SETCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

for (auto const& f : FileListBase) {

// ファイル一覧バグ修正

if (AbortOnListError == YES && ListSts == FFFTP_FAIL)

break;

Pkt.Local = AskLocalCurDir();

auto name = f.Name;

if (ChName == NO || ForceFile == NO && f.Node == NODE_DIR)

name = RemoveAfterSemicolon(RemoteName(std::move(name)));

else {

if (!UpDownAsDialog(name, WIN_REMOTE))

break;

}

name = RenameUnuseableName(std::move(name));

if (empty(name))

break;

Pkt.Local /= name;

if (ForceFile == NO && f.Node == NODE_DIR) {

Pkt.Command = L"MKD "s;

Pkt.Remote.clear();

AddTransFileList(&Pkt);

} else if (f.Node == NODE_FILE || ForceFile == YES && f.Node == NODE_DIR) {

Pkt.Remote

= AskHostType() == HTYPE_ACOS ? std::format(L"'{}({})'"sv, GetConnectingHost().LsName, f.Name)

: AskHostType() == HTYPE_ACOS_4 ? f.Name

: ReplaceAll(SetSlashTail(std::wstring{ AskRemoteCurDir() }) + f.Name, L'\\', L'/');

Pkt.Command = L"RETR "s;

#if defined(HAVE_TANDEM)

if (AskHostType() == HTYPE_TANDEM) {

if (AskTransferType() != TYPE_X) {

Pkt.Type = AskTransferType();

} else {

Pkt.Attr = f.Attr;

if (Pkt.Attr == 101)

Pkt.Type = TYPE_A;

else

Pkt.Type = TYPE_I;

}

} else

#endif

Pkt.Type = AskTransferTypeAssoc(Pkt.Remote, AskTransferType());

Pkt.Size = f.Size;

Pkt.Time = f.Time;

Pkt.KanjiCode = AskHostKanjiCode();

// UTF-8対応

Pkt.KanjiCodeDesired = AskLocalKanjiCode();

Pkt.KanaCnv = AskHostKanaCnv();

auto Tmp = Pkt.Local;

Pkt.Mode = CheckLocalFile(&Pkt); /* Pkt.ExistSize がセットされる */

// ミラーリング設定追加

Pkt.NoTransfer = NO;

if (Pkt.Mode == EXIST_ABORT)

break;

if (Pkt.Mode != EXIST_IGNORE) {

if (MakeAllDir == YES)

MakeDirFromLocalPath(Pkt.Local, Tmp);

AddTransFileList(&Pkt);

}

}

}

if(AskNoFullPathMode() == YES)

{

Pkt.Command = L"BACKCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

// バグ対策

AddNullTransFileList();

GoForwardTransWindow();

// KeepTransferDialog(NO);

EnableUserOpe();

}

return;

}

// 指定されたファイルを一つダウンロードする

void DirectDownloadProc(std::wstring_view Fname) {

TRANSPACKET Pkt;

// 同時接続対応

CancelFlg = NO;

if(CheckClosedAndReconnect() == FFFTP_SUCCESS)

{

DisableUserOpe();

ExistNotify = YES;

// KeepTransferDialog(YES);

if(AskNoFullPathMode() == YES)

{

Pkt.Command = L"SETCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

if (!empty(Fname)) {

Pkt.Local = AskLocalCurDir();

if (auto const filename = RenameUnuseableName(RemoveAfterSemicolon(RemoteName(std::wstring{ Fname }))); !empty(filename)) {

Pkt.Local /= filename;

Pkt.Remote

= AskHostType() == HTYPE_ACOS ? std::format(L"'{}({})'"sv, GetConnectingHost().LsName, Fname)

: AskHostType() == HTYPE_ACOS_4 ? std::wstring{ Fname }

: ReplaceAll(SetSlashTail(std::wstring{ AskRemoteCurDir() }) + Fname, L'\\', L'/');

Pkt.Command = L"RETR-S "s;

Pkt.Type = AskTransferTypeAssoc(Pkt.Remote, AskTransferType());

/* サイズと日付は転送側スレッドで取得し、セットする */

Pkt.KanjiCode = AskHostKanjiCode();

// UTF-8対応

Pkt.KanjiCodeDesired = AskLocalKanjiCode();

Pkt.KanaCnv = AskHostKanaCnv();

auto Tmp = Pkt.Local;

Pkt.Mode = CheckLocalFile(&Pkt); /* Pkt.ExistSize がセットされる */

// ミラーリング設定追加

Pkt.NoTransfer = NO;

if((Pkt.Mode != EXIST_ABORT) && (Pkt.Mode != EXIST_IGNORE))

// ディレクトリ自動作成

// AddTransFileList(&Pkt);

{

if(MakeAllDir == YES)

MakeDirFromLocalPath(Pkt.Local, Tmp);

AddTransFileList(&Pkt);

}

}

}

if(AskNoFullPathMode() == YES)

{

Pkt.Command = L"BACKCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

// バグ対策

AddNullTransFileList();

GoForwardTransWindow();

// KeepTransferDialog(NO);

EnableUserOpe();

}

return;

}

struct MirrorList {

using result_t = bool;

Resizable<Controls<MIRROR_DEL, MIRROR_SIZEGRIP>, Controls<IDOK, IDCANCEL, IDHELP, MIRROR_DEL, MIRROR_COPYNUM, MIRROR_MAKENUM, MIRROR_DELNUM, MIRROR_SIZEGRIP, MIRROR_NO_TRANSFER>, Controls<MIRROR_LIST>> resizable{ MirrorDlgSize };

std::vector<TRANSPACKET>& list;

MirrorList(std::vector<TRANSPACKET>& list) noexcept : list{ list } {}

INT_PTR OnInit(HWND hDlg) {

for (auto const& item : list) {

std::tuple<int, std::wstring_view> data;

if (item.Command.starts_with(L"R-DELE"sv) || item.Command.starts_with(L"R-RMD"sv))

data = { IDS_MSGJPN052, item.Remote };

else if (item.Command.starts_with(L"R-MKD"sv))

data = { IDS_MSGJPN053, item.Remote };

else if (item.Command.starts_with(L"STOR"sv))

data = { IDS_MSGJPN054, item.Remote };

else if (item.Command.starts_with(L"L-DELE"sv) || item.Command.starts_with(L"L-RMD"sv))

data = { IDS_MSGJPN052, item.Local.native() };

else if (item.Command.starts_with(L"L-MKD"sv))

data = { IDS_MSGJPN053, item.Local.native() };

else if (item.Command.starts_with(L"RETR"sv))

data = { IDS_MSGJPN054, item.Local.native() };

if (auto [id, str] = data; id != 0)

SendDlgItemMessageW(hDlg, MIRROR_LIST, LB_ADDSTRING, 0, (LPARAM)std::format(L"{}: {}"sv, GetString(id), str).c_str());

}

CountMirrorFiles(hDlg, list);

EnableWindow(GetDlgItem(hDlg, MIRROR_DEL), FALSE);

SendDlgItemMessageW(hDlg, MIRROR_NO_TRANSFER, BM_SETCHECK, MirrorNoTransferContents, 0);

return TRUE;

}

void OnCommand(HWND hDlg, WORD cmd, WORD id) {

switch (id) {

case IDOK:

case IDCANCEL:

EndDialog(hDlg, id == IDOK);

return;

case MIRROR_DEL: {

std::vector<int> indexes((size_t)SendDlgItemMessageW(hDlg, MIRROR_LIST, LB_GETSELCOUNT, 0, 0));

auto const count = (int)SendDlgItemMessageW(hDlg, MIRROR_LIST, LB_GETSELITEMS, size_as<WPARAM>(indexes), (LPARAM)data(indexes));

assert(size_as<int>(indexes) == count);

for (int const index : indexes | std::ranges::views::reverse)

if (index < size_as<int>(list)) {

list.erase(begin(list) + index);

SendDlgItemMessageW(hDlg, MIRROR_LIST, LB_DELETESTRING, index, 0);

} else

MessageBeep(-1);

CountMirrorFiles(hDlg, list);

break;

}

case MIRROR_LIST:

if (cmd == LBN_SELCHANGE)

EnableWindow(GetDlgItem(hDlg, MIRROR_DEL), 0 < SendDlgItemMessageW(hDlg, MIRROR_LIST, LB_GETSELCOUNT, 0, 0));

break;

case MIRROR_NO_TRANSFER:

for (auto& item : list)

if (item.Command.starts_with(L"STOR"sv) || item.Command.starts_with(L"RETR"sv))

item.NoTransfer = (int)SendDlgItemMessageW(hDlg, MIRROR_NO_TRANSFER, BM_GETCHECK, 0, 0);

break;

case IDHELP:

ShowHelp(IDH_HELP_TOPIC_0000012);

break;

}

}

};

/*----- ミラーリングダウンロードを行う ----------------------------------------

*

* Parameter

* int Notify : 確認を行うかどうか (YES/NO)

*

* Return Value

* なし

*----------------------------------------------------------------------------*/

void MirrorDownloadProc(int Notify)

{

TRANSPACKET Pkt;

int Level;

int Mode;

// ファイル一覧バグ修正

int ListSts;

// 同時接続対応

CancelFlg = NO;

if(CheckClosedAndReconnect() == FFFTP_SUCCESS)

{

DisableUserOpe();

std::vector<TRANSPACKET> list;

Notify = Notify == YES ? MirrorNotify(false) : YES;

if((Notify == YES) || (Notify == YES_LIST))

{

/*===== ファイルリスト取得 =====*/

std::vector<FILELIST> LocalListBase;

ListSts = MakeSelectedFileList(WIN_LOCAL, YES, YES, LocalListBase, &CancelFlg);

std::vector<FILELIST> RemoteListBase;

if(ListSts == FFFTP_SUCCESS)

ListSts = MakeSelectedFileList(WIN_REMOTE, YES, YES, RemoteListBase, &CancelFlg);

for (auto& f : RemoteListBase)

f.Attr = YES; /* RemotePos->Attrは転送するかどうかのフラグに使用 (YES/NO) */

for (auto LocalPos = begin(LocalListBase); LocalPos != end(LocalListBase);) {

if (AskMirrorNoTrn(LocalPos->Name, 1) == NO) {

LocalPos->Attr = YES;

++LocalPos;

} else {

LocalPos->Attr = NO; /* LocalPos->Attrは削除するかどうかのフラグに使用 (YES/NO) */

if (LocalPos->Node == NODE_DIR) {

Level = LocalPos->DirLevel();

++LocalPos;

while (LocalPos != end(LocalListBase)) {

if (LocalPos->Node == NODE_DIR && LocalPos->DirLevel() <= Level)

break;

LocalPos->Attr = NO;

++LocalPos;

}

} else

++LocalPos;

}

}

/*===== ファイルリスト比較 =====*/

for (auto RemotePos = begin(RemoteListBase); RemotePos != end(RemoteListBase);) {

if (AskMirrorNoTrn(RemotePos->Name, 0) == NO) {

Mode = MirrorFnameCnv == YES ? COMP_LOWERMATCH : COMP_STRICT;

if (auto LocalPos = SearchFileList(RemotePos->Name, LocalListBase, Mode)) {

if ((RemotePos->Node == NODE_DIR) && (LocalPos->Node == NODE_DIR)) {

LocalPos->Attr = NO;

RemotePos->Attr = NO;

} else if ((RemotePos->Node == NODE_FILE) && (LocalPos->Node == NODE_FILE)) {

LocalPos->Attr = NO;

if (CompareFileTime(&RemotePos->Time, &LocalPos->Time) <= 0)

RemotePos->Attr = NO;

}

}

++RemotePos;

} else {

if (RemotePos->Node == NODE_FILE) {

RemotePos->Attr = NO;

++RemotePos;

} else {

RemotePos->Attr = NO;

Level = RemotePos->DirLevel();

++RemotePos;

while (RemotePos != end(RemoteListBase)) {

if (RemotePos->Node == NODE_DIR && RemotePos->DirLevel() <= Level)

break;

RemotePos->Attr = NO;

++RemotePos;

}

}

}

}

DispMirrorFiles(LocalListBase, RemoteListBase);

/*===== 削除／アップロード =====*/

for (auto const& f : LocalListBase)

if (f.Attr == YES && f.Node == NODE_FILE) {

Pkt.Local = AskLocalCurDir() / f.Name;

Pkt.Remote.clear();

Pkt.Command = L"L-DELE "s;

list.push_back(Pkt);

}

MirrorDeleteAllLocalDir(LocalListBase, Pkt, list);

for (auto const& f : RemoteListBase)

if (f.Attr == YES) {

Pkt.Local = AskLocalCurDir();

auto name = f.Name;

if (MirrorFnameCnv == YES)

name = lc(std::move(name));

Pkt.Local /= RemoveAfterSemicolon(std::move(name));

if (f.Node == NODE_DIR) {

Pkt.Remote.clear();

Pkt.Command = L"L-MKD "s;

list.push_back(Pkt);

} else if (f.Node == NODE_FILE) {

Pkt.Remote = ReplaceAll(SetSlashTail(std::wstring{ AskRemoteCurDir() }) + f.Name, L'\\', L'/');

Pkt.Command = L"RETR "s;

Pkt.Type = AskTransferTypeAssoc(Pkt.Remote, AskTransferType());

Pkt.Size = f.Size;

Pkt.Time = f.Time;

Pkt.KanjiCode = AskHostKanjiCode();

// UTF-8対応

Pkt.KanjiCodeDesired = AskLocalKanjiCode();

Pkt.KanaCnv = AskHostKanaCnv();

Pkt.Mode = EXIST_OVW;

// ミラーリング設定追加

Pkt.NoTransfer = MirrorNoTransferContents;

list.push_back(Pkt);

}

}

if ((AbortOnListError == NO || ListSts == FFFTP_SUCCESS) && (Notify == YES || Dialog(GetFtpInst(), mirrordown_notify_dlg, GetMainHwnd(), MirrorList{ list })))

{

if(AskNoFullPathMode() == YES)

{

Pkt.Command = L"SETCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

AppendTransFileList(std::move(list));

if(AskNoFullPathMode() == YES)

{

Pkt.Command = L"BACKCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

}

// バグ対策

AddNullTransFileList();

GoForwardTransWindow();

}

EnableUserOpe();

}

return;

}

// ミラーリングのファイル一覧を表示

static void DispMirrorFiles(std::vector<FILELIST> const& Local, std::vector<FILELIST> const& Remote) {

if (DebugConsole != YES)

return;

FILETIME ft;

SYSTEMTIME st;

Debug(L"---- MIRROR FILE LIST ----"sv);

for (auto& [type, list] : { std::tuple{ L"LOCAL"sv, Local }, std::tuple{ L"REMOTE"sv, Remote } })

for (auto const& f : list) {

auto const date = FileTimeToLocalFileTime(&f.Time, &ft) && FileTimeToSystemTime(&ft, &st) ? std::format(L"{:04}/{:02}/{:02} {:02}:{:02}:{:02}.{:03}"sv, st.wYear, st.wMonth, st.wDay, st.wHour, st.wMinute, st.wSecond, st.wMilliseconds) : L""s;

Debug(L"{:6} : {:3} {:4} [{}] {}"sv, type, f.Attr == 1 ? L"YES"sv : L"NO"sv, f.Node == NODE_DIR ? L"DIR"sv : L"FILE"sv, date, f.Name);

}

Debug(L"---- END ----"sv);

}

// ミラーリング時のローカル側のフォルダ削除

static void MirrorDeleteAllLocalDir(std::vector<FILELIST> const& Local, TRANSPACKET& item, std::vector<TRANSPACKET>& list) {

for (auto it = rbegin(Local); it != rend(Local); ++it)

if (it->Node == NODE_DIR && it->Attr == YES) {

item.Local = AskLocalCurDir() / it->Name;

item.Remote.clear();

item.Command = L"L-RMD "s;

list.push_back(item);

}

}

// ファイル名のセミコロン以降を取り除く

static std::wstring RemoveAfterSemicolon(std::wstring&& path) {

if (VaxSemicolon == YES)

if (auto const pos = path.find(';'); pos != std::wstring::npos)

path.resize(pos);

return path;

}

/*----- ローカルに同じ名前のファイルがないかチェック --------------------------

*

* Parameter

* TRANSPACKET *Pkt : 転送ファイル情報

*

* Return Value

* int 処理方法

* EXIST_OVW/EXIST_RESUME/EXIST_IGNORE

*

* Note

* Pkt.ExistSize, ExistMode、ExistNotify が変更される

*----------------------------------------------------------------------------*/

static int CheckLocalFile(TRANSPACKET *Pkt) noexcept {

struct DownExistDialog {

using result_t = bool;

using DownExistButton = RadioButton<DOWN_EXIST_OVW, DOWN_EXIST_NEW, DOWN_EXIST_RESUME, DOWN_EXIST_IGNORE, DOWN_EXIST_LARGE>;

TRANSPACKET* Pkt;

DownExistDialog(TRANSPACKET* Pkt) noexcept : Pkt{ Pkt } {}

INT_PTR OnInit(HWND hDlg) {

SendDlgItemMessageW(hDlg, DOWN_EXIST_NAME, EM_LIMITTEXT, FMAX_PATH, 0);

SetText(hDlg, DOWN_EXIST_NAME, Pkt->Local);

if (Pkt->Type == TYPE_A || Pkt->ExistSize <= 0)

EnableWindow(GetDlgItem(hDlg, DOWN_EXIST_RESUME), FALSE);

DownExistButton::Set(hDlg, ExistMode);

return TRUE;

}

void OnCommand(HWND hDlg, WORD id) {

switch (id) {

case IDOK_ALL:

ExistNotify = NO;

[[fallthrough]];

case IDOK:

ExistMode = DownExistButton::Get(hDlg);

Pkt->Local = GetText(hDlg, DOWN_EXIST_NAME);

EndDialog(hDlg, true);

break;

case IDCANCEL:

EndDialog(hDlg, false);

break;

case IDHELP:

ShowHelp(IDH_HELP_TOPIC_0000009);

break;

}

}

};

int Ret;

// タイムスタンプのバグ修正

SYSTEMTIME TmpStime;

Ret = EXIST_OVW;

Pkt->ExistSize = 0;

if(RecvMode != TRANS_OVW)

{

if (WIN32_FILE_ATTRIBUTE_DATA attr; GetFileAttributesExW(Pkt->Local.c_str(), GetFileExInfoStandard, &attr))

{

Pkt->ExistSize = LONGLONG(attr.nFileSizeHigh) << 32 | attr.nFileSizeLow;

if(ExistNotify == YES)

{

Sound::Error.Play();

Ret = Dialog(GetFtpInst(), down_exist_dlg, GetMainHwnd(), DownExistDialog{ Pkt }) ? ExistMode : EXIST_ABORT;

}

else

Ret = ExistMode;

if(Ret == EXIST_NEW)

{

/*ファイル日付チェック */

// タイムスタンプのバグ修正

if (FileTimeToSystemTime(&attr.ftLastWriteTime, &TmpStime)) {

if (DispTimeSeconds == NO)

TmpStime.wSecond = 0;

TmpStime.wMilliseconds = 0;

SystemTimeToFileTime(&TmpStime, &attr.ftLastWriteTime);

} else

attr.ftLastWriteTime = {};

if(CompareFileTime(&attr.ftLastWriteTime, &Pkt->Time) < 0)

Ret = EXIST_OVW;

else

Ret = EXIST_IGNORE;

}

// 同じ名前のファイルの処理方法追加

if (Ret == EXIST_LARGE)

Ret = (LONGLONG(attr.nFileSizeHigh) << 32 | attr.nFileSizeLow) < Pkt->Size ? EXIST_OVW : EXIST_IGNORE;

}

}

return(Ret);

}

/*----- ファイル一覧で指定されたファイルをアップロードする --------------------

*

* Parameter

* int ChName : 名前を変えるかどうか (YES/NO)

* int All : 全てが選ばれている物として扱うかどうか (YES/NO)

*

* Return Value

* なし

*----------------------------------------------------------------------------*/

// ディレクトリ自動作成

// リモート側のパスから必要なディレクトリを作成

int MakeDirFromRemotePath(fs::path const& RemoteFile, fs::path const& Old, int FirstAdd) {

fs::path path;

auto const RemotePath = RemoteFile.parent_path();

auto const OldPath = Old.parent_path();

auto rit = RemotePath.begin(), rend = RemotePath.end();

for (auto oit = OldPath.begin(), oend = OldPath.end(); rit != rend && oit != oend && *rit == *oit; ++rit, ++oit)

path /= *rit;

if (rit == rend)

return NO;

TRANSPACKET Pkt;

if (FirstAdd == YES && AskNoFullPathMode() == YES) {

Pkt.Command = L"SETCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

do {

auto name = RemoteName(*rit);

path /= name;

#if defined(HAVE_TANDEM)

Pkt.FileCode = 0;

Pkt.PriExt = DEF_PRIEXT;

Pkt.SecExt = DEF_SECEXT;

Pkt.MaxExt = DEF_MAXEXT;

#endif

Pkt.Remote = AskHostType() == HTYPE_ACOS ? std::format(L"'{}({})'"sv, GetConnectingHost().LsName, name) : AskHostType() == HTYPE_ACOS_4 ? name : path.generic_wstring();

Pkt.Command = L"MKD "s;

Pkt.Local.clear();

AddTransFileList(&Pkt);

} while (++rit != rend);

return YES;

}

void UploadListProc(int ChName, int All)

{

#if defined(HAVE_TANDEM)

struct UpDownAsWithExt {

using result_t = bool;

std::wstring name;

int win;

int filecode;

UpDownAsWithExt(std::wstring_view name, int win) : name{ name }, win{ win }, filecode{} {}

INT_PTR OnInit(HWND hDlg) {

SetText(hDlg, GetString(win == WIN_LOCAL ? IDS_MSGJPN064 : IDS_MSGJPN065));

SendDlgItemMessageW(hDlg, UPDOWNAS_NEW, EM_LIMITTEXT, FMAX_PATH, 0);

SetText(hDlg, UPDOWNAS_NEW, name);

SetText(hDlg, UPDOWNAS_TEXT, name);

SendDlgItemMessageW(hDlg, UPDOWNAS_FILECODE, EM_LIMITTEXT, 4, 0);

SetText(hDlg, UPDOWNAS_FILECODE, L"0");

return TRUE;

}

void OnCommand(HWND hDlg, WORD id) {

switch (id) {

case IDOK:

name = GetText(hDlg, UPDOWNAS_NEW);

filecode = GetDecimalText(hDlg, UPDOWNAS_FILECODE);

EndDialog(hDlg, true);

break;

case UPDOWNAS_STOP:

EndDialog(hDlg, false);

break;

}

}

};

#endif

TRANSPACKET Pkt;

TRANSPACKET Pkt1;

int FirstAdd;

// ファイル一覧バグ修正

int ListSts;

// 同時接続対応

CancelFlg = NO;

if(CheckClosedAndReconnect() == FFFTP_SUCCESS)

{

DisableUserOpe();

// ローカル側で選ばれているファイルをFileListBaseに登録

std::vector<FILELIST> FileListBase;

ListSts = MakeSelectedFileList(WIN_LOCAL, YES, All, FileListBase, &CancelFlg);

// 現在ホスト側のファイル一覧に表示されているものをRemoteListに登録

// 同名ファイルチェック用

std::vector<FILELIST> RemoteList;

AddRemoteTreeToFileList(0, {}, RDIR_NONE, RemoteList);

FirstAdd = YES;

ExistNotify = YES;

for (auto const& f : FileListBase) {

// ファイル一覧バグ修正

if((AbortOnListError == YES) && (ListSts == FFFTP_FAIL))

break;

Pkt.Remote = SetSlashTail(std::wstring{ AskRemoteCurDir() });

auto offset = size(Pkt.Remote);

if (ChName == NO || f.Node == NODE_DIR) {

Pkt.Remote += RemoteName(std::wstring{ f.Name });

#if defined(HAVE_TANDEM)

Pkt.FileCode = 0;

Pkt.PriExt = DEF_PRIEXT;

Pkt.SecExt = DEF_SECEXT;

Pkt.MaxExt = DEF_MAXEXT;

#endif

}

else

{

// 名前を変更する

#if defined(HAVE_TANDEM)

if(AskHostType() == HTYPE_TANDEM && AskOSS() == NO) {

UpDownAsWithExt data{ f.Name, WIN_LOCAL };

if (!Dialog(GetFtpInst(), updown_as_with_ext_dlg, GetMainHwnd(), data))

break;

Pkt.Remote += data.name;

Pkt.FileCode = data.filecode;

} else

#endif

if (std::wstring name = f.Name; UpDownAsDialog(name, WIN_LOCAL))

Pkt.Remote += name;

else

break;

}

if (Pkt.Remote.starts_with(SetSlashTail(std::wstring{ AskRemoteCurDir() }))) {

if (offset = Pkt.Remote.rfind(L'/'); offset != std::wstring::npos)

offset++;

else

offset = 0;

}

Pkt.Remote = ReplaceAll(std::move(Pkt.Remote), L'\\', L'/');

if (AskHostType() == HTYPE_ACOS)

Pkt.Remote = std::format(L"'{}({})'"sv, GetConnectingHost().LsName, std::wstring_view{ Pkt.Remote }.substr(offset));

else if (AskHostType() == HTYPE_ACOS_4)

Pkt.Remote = Pkt.Remote.substr(offset);

if(f.Node == NODE_DIR)

{

// フォルダの場合

// ホスト側のファイル一覧をRemoteListに登録

// 同名ファイルチェック用

RemoteList.clear();

auto const Tmp = AskRemoteCurDir();

if(DoCWD(Pkt.Remote, NO, NO, NO) == FTP_COMPLETE)

{

if(DoDirList(L""sv, 998, &CancelFlg) == FTP_COMPLETE)

AddRemoteTreeToFileList(998, {}, RDIR_NONE, RemoteList);

DoCWD(Tmp, NO, NO, NO);

}

else

{

// フォルダを作成

if((FirstAdd == YES) && (AskNoFullPathMode() == YES))

{

Pkt1.Command = L"SETCUR"s;

Pkt1.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt1);

}

FirstAdd = NO;

Pkt.Command = L"MKD "s;

Pkt.Local.clear();

AddTransFileList(&Pkt);

}

}

else if(f.Node == NODE_FILE)

{

// ファイルの場合

Pkt.Local = AskLocalCurDir() / f.Name;

Pkt.Command = L"STOR "s;

Pkt.Type = AskTransferTypeAssoc(Pkt.Local.native(), AskTransferType());

Pkt.Size = f.Size;

Pkt.Time = f.Time;

Pkt.Attr = AskUploadFileAttr(Pkt.Remote);

Pkt.KanjiCode = AskHostKanjiCode();

// UTF-8対応

Pkt.KanjiCodeDesired = AskLocalKanjiCode();

Pkt.KanaCnv = AskHostKanaCnv();

#if defined(HAVE_TANDEM)

if(AskHostType() == HTYPE_TANDEM && AskOSS() == NO) {

CalcExtentSize(&Pkt, f.Size);

}

#endif

auto dir = Pkt.Remote;

Pkt.Mode = CheckRemoteFile(&Pkt, RemoteList);

// ミラーリング設定追加

Pkt.NoTransfer = NO;

if(Pkt.Mode == EXIST_ABORT)

break;

else if(Pkt.Mode != EXIST_IGNORE)

{

// ディレクトリ自動作成

if(MakeAllDir == YES)

{

if(MakeDirFromRemotePath(Pkt.Remote, dir, FirstAdd) == YES)

FirstAdd = NO;

}

if((FirstAdd == YES) && (AskNoFullPathMode() == YES))

{

Pkt1.Command = L"SETCUR"s;

Pkt1.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt1);

}

FirstAdd = NO;

AddTransFileList(&Pkt);

}

}

}

if((FirstAdd == NO) && (AskNoFullPathMode() == YES))

{

Pkt.Command = L"BACKCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

// バグ対策

AddNullTransFileList();

GoForwardTransWindow();

EnableUserOpe();

}

return;

}

/*----- ドラッグ＆ドロップで指定されたファイルをアップロードする --------------

*

* Parameter

* WPARAM wParam : ドロップされたファイルの情報

*

* Return Value

* なし

*----------------------------------------------------------------------------*/

void UploadDragProc(WPARAM wParam)

{

TRANSPACKET Pkt;

TRANSPACKET Pkt1;

int FirstAdd;

// 同時接続対応

CancelFlg = NO;

if(CheckClosedAndReconnect() == FFFTP_SUCCESS)

{

DisableUserOpe();

// ローカル側で選ばれているファイルをFileListBaseに登録

auto [cur, files] = MakeDroppedFileList(wParam);

// 現在ホスト側のファイル一覧に表示されているものをRemoteListに登録

// 同名ファイルチェック用

std::vector<FILELIST> RemoteList;

AddRemoteTreeToFileList(0, {}, RDIR_NONE, RemoteList);

FirstAdd = YES;

ExistNotify = YES;

for (auto const& f : files) {

auto Cat = RemoteName(std::wstring{ f.Name });

Pkt.Remote

= AskHostType() == HTYPE_ACOS ? std::format(L"'{}({})'"sv, GetConnectingHost().LsName, Cat)

: AskHostType() == HTYPE_ACOS_4 ? std::move(Cat)

: ReplaceAll(SetSlashTail(std::wstring{ AskRemoteCurDir() }) + Cat, L'\\', L'/');

#if defined(HAVE_TANDEM)

Pkt.FileCode = 0;

Pkt.PriExt = DEF_PRIEXT;

Pkt.SecExt = DEF_SECEXT;

Pkt.MaxExt = DEF_MAXEXT;

#endif

if(f.Node == NODE_DIR)

{

// フォルダの場合

// ホスト側のファイル一覧をRemoteListに登録

// 同名ファイルチェック用

RemoteList.clear();

auto const Tmp = AskRemoteCurDir();

if(DoCWD(Pkt.Remote, NO, NO, NO) == FTP_COMPLETE)

{

if(DoDirList(L""sv, 998, &CancelFlg) == FTP_COMPLETE)

AddRemoteTreeToFileList(998, {}, RDIR_NONE, RemoteList);

DoCWD(Tmp, NO, NO, NO);

}

else

{

if((FirstAdd == YES) && (AskNoFullPathMode() == YES))

{

Pkt1.Command = L"SETCUR"s;

Pkt1.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt1);

}

FirstAdd = NO;

Pkt.Command = L"MKD "s;

Pkt.Local.clear();

AddTransFileList(&Pkt);

}

}

else if(f.Node == NODE_FILE)

{

// ファイルの場合

Pkt.Local = cur / f.Name;

Pkt.Command = L"STOR "s;

Pkt.Type = AskTransferTypeAssoc(Pkt.Local.native(), AskTransferType());

Pkt.Size = f.Size;

Pkt.Time = f.Time;

Pkt.Attr = AskUploadFileAttr(Pkt.Remote);

Pkt.KanjiCode = AskHostKanjiCode();

// UTF-8対応

Pkt.KanjiCodeDesired = AskLocalKanjiCode();

Pkt.KanaCnv = AskHostKanaCnv();

#if defined(HAVE_TANDEM)

if(AskHostType() == HTYPE_TANDEM && AskOSS() == NO) {

CalcExtentSize(&Pkt, f.Size);

}

#endif

// ディレクトリ自動作成

auto dir = Pkt.Remote;

Pkt.Mode = CheckRemoteFile(&Pkt, RemoteList);

// ミラーリング設定追加

Pkt.NoTransfer = NO;

if(Pkt.Mode == EXIST_ABORT)

break;

else if(Pkt.Mode != EXIST_IGNORE)

{

// ディレクトリ自動作成

if(MakeAllDir == YES)

{

if(MakeDirFromRemotePath(Pkt.Remote, dir, FirstAdd) == YES)

FirstAdd = NO;

}

if((FirstAdd == YES) && (AskNoFullPathMode() == YES))

{

Pkt1.Command = L"SETCUR"s;

Pkt1.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt1);

}

FirstAdd = NO;

AddTransFileList(&Pkt);

}

}

}

if((FirstAdd == NO) && (AskNoFullPathMode() == YES))

{

Pkt.Command = L"BACKCUR"s;

Pkt.Remote = AskRemoteCurDir();

AddTransFileList(&Pkt);

}

// バグ対策

AddNullTransFileList();