Compare commits
15 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 4520739c3a | |||
| ddac7ea41a | |||
| 75a4e6278c | |||
| 218280caa2 | |||
| 06a919cfd5 | |||
| 5f7c977f77 | |||
| 91d28b844d | |||
| 2566f356b2 | |||
| 24331ac3d4 | |||
| 6fd7fc0300 | |||
| 3ec3ccf1ef | |||
| ef5beeff94 | |||
| d34e919f40 | |||
| e6b806d2c1 | |||
| 33c26ec310 |
@@ -0,0 +1,32 @@
|
||||
name: SonarQube
|
||||
|
||||
on:
|
||||
workflow_dispatch:
|
||||
|
||||
jobs:
|
||||
sonarqube:
|
||||
name: SonarQube
|
||||
runs-on: build-htz-01
|
||||
steps:
|
||||
- name: Checkout Code
|
||||
uses: actions/checkout@v4
|
||||
with:
|
||||
fetch-depth: 0
|
||||
|
||||
- name: Create Valid Project Key
|
||||
id: sonar_setup
|
||||
run: |
|
||||
CLEAN_KEY=$(echo "${{ gitea.repository }}" | tr '/' ':')
|
||||
echo "key=$CLEAN_KEY" >> $GITHUB_OUTPUT
|
||||
|
||||
- name: SonarQube Scan
|
||||
uses: sonarsource/sonarqube-scan-action@master
|
||||
continue-on-error: true
|
||||
env:
|
||||
SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}
|
||||
SONAR_HOST_URL: ${{ secrets.SONAR_HOST_URL }}
|
||||
with:
|
||||
args: >
|
||||
-Dsonar.projectKey=${{ steps.sonar_setup.outputs.key }}
|
||||
-Dsonar.projectName=${{ gitea.repository }}
|
||||
-Dsonar.qualitygate.wait=true
|
||||
@@ -16,6 +16,7 @@ import (
|
||||
"goexplore/internal/transfer"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"sync"
|
||||
|
||||
"github.com/google/uuid"
|
||||
"github.com/wailsapp/wails/v2/pkg/runtime"
|
||||
@@ -25,6 +26,8 @@ type App struct {
|
||||
ctx context.Context
|
||||
cfg *config.Config
|
||||
transferManager *transfer.Manager
|
||||
explorers map[string]explorer.Explorer
|
||||
explorersMu sync.Mutex
|
||||
}
|
||||
|
||||
func NewApp() *App {
|
||||
@@ -38,6 +41,7 @@ func NewApp() *App {
|
||||
return &App{
|
||||
cfg: cfg,
|
||||
transferManager: transfer.NewManager(3),
|
||||
explorers: make(map[string]explorer.Explorer),
|
||||
}
|
||||
}
|
||||
|
||||
@@ -95,6 +99,69 @@ func (a *App) DeleteConnection(id string) error {
|
||||
return config.SaveConfig(a.cfg)
|
||||
}
|
||||
|
||||
func (a *App) ReorderConnections(ids []string) error {
|
||||
var newConns []config.ConnectionConfig
|
||||
connMap := make(map[string]config.ConnectionConfig)
|
||||
for _, c := range a.cfg.Connections {
|
||||
connMap[c.ID] = c
|
||||
}
|
||||
|
||||
for _, id := range ids {
|
||||
if c, ok := connMap[id]; ok {
|
||||
newConns = append(newConns, c)
|
||||
}
|
||||
}
|
||||
|
||||
// Add any connections that might have been missed
|
||||
added := make(map[string]bool)
|
||||
for _, c := range newConns {
|
||||
added[c.ID] = true
|
||||
}
|
||||
for _, c := range a.cfg.Connections {
|
||||
if !added[c.ID] {
|
||||
newConns = append(newConns, c)
|
||||
}
|
||||
}
|
||||
|
||||
a.cfg.Connections = newConns
|
||||
return config.SaveConfig(a.cfg)
|
||||
}
|
||||
|
||||
func (a *App) getConnection(id string) (explorer.Explorer, error) {
|
||||
if id == "local" {
|
||||
return local.New(), nil
|
||||
}
|
||||
|
||||
a.explorersMu.Lock()
|
||||
defer a.explorersMu.Unlock()
|
||||
|
||||
if exp, ok := a.explorers[id]; ok {
|
||||
return exp, nil
|
||||
}
|
||||
|
||||
exp, err := a.getExplorerForConnection(id)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if err := exp.Connect(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
a.explorers[id] = exp
|
||||
return exp, nil
|
||||
}
|
||||
|
||||
func (a *App) DisconnectConnection(id string) {
|
||||
a.explorersMu.Lock()
|
||||
defer a.explorersMu.Unlock()
|
||||
|
||||
if exp, ok := a.explorers[id]; ok {
|
||||
exp.Disconnect()
|
||||
delete(a.explorers, id)
|
||||
}
|
||||
}
|
||||
|
||||
func (a *App) getExplorerForConnection(id string) (explorer.Explorer, error) {
|
||||
if id == "local" {
|
||||
return local.New(), nil
|
||||
@@ -132,38 +199,26 @@ func (a *App) getExplorerForConnection(id string) (explorer.Explorer, error) {
|
||||
}
|
||||
|
||||
func (a *App) ListDir(connId, path string) ([]explorer.FileEntry, error) {
|
||||
exp, err := a.getExplorerForConnection(connId)
|
||||
exp, err := a.getConnection(connId)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := exp.Connect(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
defer exp.Disconnect()
|
||||
return exp.ListDir(path)
|
||||
}
|
||||
|
||||
func (a *App) MkDir(connId, path string) error {
|
||||
exp, err := a.getExplorerForConnection(connId)
|
||||
exp, err := a.getConnection(connId)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := exp.Connect(); err != nil {
|
||||
return err
|
||||
}
|
||||
defer exp.Disconnect()
|
||||
return exp.MkDir(path)
|
||||
}
|
||||
|
||||
func (a *App) Delete(connId, path string) error {
|
||||
exp, err := a.getExplorerForConnection(connId)
|
||||
exp, err := a.getConnection(connId)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := exp.Connect(); err != nil {
|
||||
return err
|
||||
}
|
||||
defer exp.Disconnect()
|
||||
return exp.Delete(path)
|
||||
}
|
||||
|
||||
@@ -197,14 +252,10 @@ func (a *App) ClearTransfers() {
|
||||
}
|
||||
|
||||
func (a *App) Rename(connId, src, dst string) error {
|
||||
exp, err := a.getExplorerForConnection(connId)
|
||||
exp, err := a.getConnection(connId)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if err := exp.Connect(); err != nil {
|
||||
return err
|
||||
}
|
||||
defer exp.Disconnect()
|
||||
return exp.Rename(src, dst)
|
||||
}
|
||||
|
||||
|
||||
+3
-3
@@ -95,7 +95,7 @@
|
||||
<label>Host</label>
|
||||
<input type="text" id="conn-host" placeholder="example.com">
|
||||
</div>
|
||||
<div class="form-group" style="flex: 1;">
|
||||
<div class="form-group" style="flex: 1;" id="port-group">
|
||||
<label>Port</label>
|
||||
<input type="number" id="conn-port" placeholder="22">
|
||||
</div>
|
||||
@@ -104,7 +104,7 @@
|
||||
<div id="bucket-fields" style="display: none;">
|
||||
<div class="form-row">
|
||||
<div class="form-group" style="flex: 1;">
|
||||
<label>Bucket / Share</label>
|
||||
<label id="bucket-label">Bucket / Share</label>
|
||||
<input type="text" id="conn-bucket" placeholder="my-bucket-or-share">
|
||||
</div>
|
||||
<div class="form-group" style="flex: 1;" id="region-group">
|
||||
@@ -123,7 +123,7 @@
|
||||
<label style="margin: 0;">Use FTPS (Secure Explicit TLS)</label>
|
||||
</div>
|
||||
|
||||
<div class="form-row">
|
||||
<div class="form-row" id="auth-row">
|
||||
<div class="form-group" style="flex: 1;">
|
||||
<label>Username / Access Key</label>
|
||||
<input type="text" id="conn-username" placeholder="user">
|
||||
|
||||
+119
-12
@@ -1,4 +1,4 @@
|
||||
import { GetVersion, ListDir, GetConnections, SaveConnection, DeleteConnection, Delete, Rename, PromptUploadFiles, PromptUploadDirectory, PromptDownload, TransferItems, GetTransfers, ClearTransfers } from '../wailsjs/go/main/App.js';
|
||||
import { GetVersion, ListDir, GetConnections, SaveConnection, DeleteConnection, Delete, Rename, PromptUploadFiles, PromptUploadDirectory, PromptDownload, TransferItems, GetTransfers, ClearTransfers, ReorderConnections } from '../wailsjs/go/main/App.js';
|
||||
|
||||
let currentConn = 'local';
|
||||
let currentPath = '';
|
||||
@@ -8,6 +8,7 @@ let lastSelectedPath = null;
|
||||
let showHiddenFiles = false;
|
||||
let sortField = 'name';
|
||||
let sortAsc = true;
|
||||
let draggedConnId = null;
|
||||
|
||||
function uuidv4() {
|
||||
return "10000000-1000-4000-8000-100000000000".replace(/[018]/g, c =>
|
||||
@@ -79,6 +80,53 @@ async function loadConnections() {
|
||||
el.className = `conn-item ${currentConn === c.id ? 'active' : ''}`;
|
||||
el.innerHTML = `<span class="badge">${c.protocol}</span> <span style="flex:1">${c.name}</span> <svg class="edit-btn" viewBox="0 0 24 24" width="16" height="16" fill="var(--accent)" style="cursor: pointer;" onclick="event.stopPropagation(); editConnection('${c.id}')"><path d="M19.14,12.94c0.04-0.3,0.06-0.61,0.06-0.94c0-0.32-0.02-0.64-0.06-0.94l2.03-1.58c0.18-0.14,0.23-0.41,0.12-0.61 l-1.92-3.32c-0.12-0.22-0.37-0.29-0.59-0.22l-2.39,0.96c-0.5-0.38-1.03-0.7-1.62-0.94L14.4,2.81c-0.04-0.24-0.24-0.41-0.48-0.41 h-3.84c-0.24,0-0.43,0.17-0.47,0.41L9.25,5.35C8.66,5.59,8.12,5.92,7.63,6.29L5.24,5.33c-0.22-0.08-0.47,0-0.59,0.22L2.73,8.87 C2.62,9.08,2.66,9.34,2.86,9.48l2.03,1.58C4.84,11.36,4.8,11.69,4.8,12s0.02,0.64,0.06,0.94l-2.03,1.58 c-0.18,0.14-0.23,0.41-0.12,0.61l1.92,3.32c0.12,0.22,0.37,0.29,0.59,0.22l2.39-0.96c0.5,0.38,1.03,0.7,1.62,0.94l0.36,2.54 c0.05,0.24,0.24,0.41,0.48,0.41h3.84c0.24,0,0.43-0.17,0.47-0.41l0.36-2.54c0.59-0.24,1.13-0.56,1.62-0.94l2.39,0.96 c0.22,0.08,0.47,0,0.59-0.22l1.92-3.32c0.12-0.22,0.07-0.49-0.12-0.61L19.14,12.94z M12,15.6c-1.98,0-3.6-1.62-3.6-3.6 s1.62-3.6,3.6-3.6s3.6,1.62,3.6,3.6S13.98,15.6,12,15.6z"/></svg>`;
|
||||
el.onclick = () => switchConn(c.id);
|
||||
|
||||
el.draggable = true;
|
||||
el.addEventListener('dragstart', (e) => {
|
||||
draggedConnId = c.id;
|
||||
e.dataTransfer.effectAllowed = 'move';
|
||||
e.dataTransfer.setData('text/plain', c.id);
|
||||
el.style.opacity = '0.5';
|
||||
});
|
||||
el.addEventListener('dragend', () => {
|
||||
draggedConnId = null;
|
||||
el.style.opacity = '1';
|
||||
});
|
||||
el.addEventListener('dragenter', (e) => {
|
||||
e.preventDefault();
|
||||
if (draggedConnId && draggedConnId !== c.id) {
|
||||
el.style.boxShadow = 'inset 0 2px 0 var(--accent)';
|
||||
}
|
||||
});
|
||||
el.addEventListener('dragleave', (e) => {
|
||||
el.style.boxShadow = '';
|
||||
});
|
||||
el.addEventListener('dragover', (e) => {
|
||||
e.preventDefault();
|
||||
e.dataTransfer.dropEffect = 'move';
|
||||
});
|
||||
el.addEventListener('drop', async (e) => {
|
||||
e.preventDefault();
|
||||
el.style.boxShadow = '';
|
||||
if (!draggedConnId || draggedConnId === c.id) return;
|
||||
|
||||
const ids = connectionsCache.map(conn => conn.id);
|
||||
const draggedIdx = ids.indexOf(draggedConnId);
|
||||
const targetIdx = ids.indexOf(c.id);
|
||||
|
||||
if (draggedIdx !== -1 && targetIdx !== -1) {
|
||||
ids.splice(draggedIdx, 1);
|
||||
ids.splice(targetIdx, 0, draggedConnId);
|
||||
|
||||
try {
|
||||
await ReorderConnections(ids);
|
||||
} catch (err) {
|
||||
console.error("Failed to reorder connections:", err);
|
||||
}
|
||||
await loadConnections();
|
||||
}
|
||||
});
|
||||
|
||||
list.appendChild(el);
|
||||
});
|
||||
}
|
||||
@@ -137,9 +185,27 @@ window.closeConnModal = () => {
|
||||
window.updateProtocolFields = () => {
|
||||
const protocol = document.getElementById('conn-protocol').value;
|
||||
|
||||
const showBucket = protocol === 's3' || protocol === 'smb';
|
||||
const showBucket = protocol === 's3' || protocol === 'smb' || protocol === 'nfs';
|
||||
document.getElementById('bucket-fields').style.display = showBucket ? 'block' : 'none';
|
||||
|
||||
const bucketLabel = document.getElementById('bucket-label');
|
||||
if (bucketLabel) {
|
||||
if (protocol === 'nfs') {
|
||||
bucketLabel.innerText = 'Export Path';
|
||||
} else if (protocol === 'smb') {
|
||||
bucketLabel.innerText = 'Share';
|
||||
} else {
|
||||
bucketLabel.innerText = 'Bucket';
|
||||
}
|
||||
}
|
||||
|
||||
const isNFS = protocol === 'nfs';
|
||||
const portGroup = document.getElementById('port-group');
|
||||
if (portGroup) portGroup.style.display = isNFS ? 'none' : 'block';
|
||||
|
||||
const authRow = document.getElementById('auth-row');
|
||||
if (authRow) authRow.style.display = isNFS ? 'none' : 'flex';
|
||||
|
||||
// Only show S3 specific fields when S3 is selected
|
||||
const showS3Specific = protocol === 's3';
|
||||
document.getElementById('region-group').style.display = showS3Specific ? 'flex' : 'none';
|
||||
@@ -427,8 +493,19 @@ document.addEventListener('contextmenu', (e) => {
|
||||
document.getElementById('ctx-divider').style.display = 'block';
|
||||
|
||||
menu.style.display = 'block';
|
||||
menu.style.left = `${e.pageX}px`;
|
||||
menu.style.top = `${e.pageY}px`;
|
||||
|
||||
let left = e.pageX;
|
||||
let top = e.pageY;
|
||||
|
||||
if (left + menu.offsetWidth > window.innerWidth) {
|
||||
left = window.innerWidth - menu.offsetWidth;
|
||||
}
|
||||
if (top + menu.offsetHeight > window.innerHeight) {
|
||||
top = window.innerHeight - menu.offsetHeight;
|
||||
}
|
||||
|
||||
menu.style.left = `${left}px`;
|
||||
menu.style.top = `${top}px`;
|
||||
} else if (isBrowserPane && !e.target.closest('#transfer-dest-list')) {
|
||||
e.preventDefault();
|
||||
|
||||
@@ -439,8 +516,19 @@ document.addEventListener('contextmenu', (e) => {
|
||||
document.getElementById('ctx-divider').style.display = 'none';
|
||||
|
||||
menu.style.display = 'block';
|
||||
menu.style.left = `${e.pageX}px`;
|
||||
menu.style.top = `${e.pageY}px`;
|
||||
|
||||
let left = e.pageX;
|
||||
let top = e.pageY;
|
||||
|
||||
if (left + menu.offsetWidth > window.innerWidth) {
|
||||
left = window.innerWidth - menu.offsetWidth;
|
||||
}
|
||||
if (top + menu.offsetHeight > window.innerHeight) {
|
||||
top = window.innerHeight - menu.offsetHeight;
|
||||
}
|
||||
|
||||
menu.style.left = `${left}px`;
|
||||
menu.style.top = `${top}px`;
|
||||
}
|
||||
});
|
||||
|
||||
@@ -485,9 +573,10 @@ window.handleContextMenu = async (action) => {
|
||||
const item = selectedItems[0];
|
||||
const newName = prompt(`Enter new name for ${item.name}:`, item.name);
|
||||
if (newName && newName !== item.name) {
|
||||
const pathParts = item.path.split('/');
|
||||
const sep = item.path.includes('\\') ? '\\' : '/';
|
||||
const pathParts = item.path.split(/[/\\]/);
|
||||
pathParts[pathParts.length - 1] = newName;
|
||||
const newPath = pathParts.join('/');
|
||||
const newPath = pathParts.join(sep);
|
||||
|
||||
await Rename(currentConn, item.path, newPath);
|
||||
refreshCurrentDir();
|
||||
@@ -507,9 +596,18 @@ window.handleContextMenu = async (action) => {
|
||||
|
||||
window.navigateUp = () => {
|
||||
if (!currentPath || currentPath === '/') return;
|
||||
const parts = currentPath.split('/').filter(p => p);
|
||||
const startsWithSlash = currentPath.startsWith('/');
|
||||
const sep = currentPath.includes('\\') ? '\\' : '/';
|
||||
const parts = currentPath.split(/[/\\]/).filter(p => p);
|
||||
parts.pop();
|
||||
currentPath = parts.length ? '/' + parts.join('/') : '';
|
||||
if (parts.length === 0) {
|
||||
currentPath = '';
|
||||
} else {
|
||||
currentPath = (startsWithSlash ? '/' : '') + parts.join(sep);
|
||||
if (!startsWithSlash && parts.length === 1 && parts[0].endsWith(':')) {
|
||||
currentPath += sep;
|
||||
}
|
||||
}
|
||||
loadDirectory(currentConn, currentPath);
|
||||
};
|
||||
|
||||
@@ -553,9 +651,18 @@ window.loadTransferDestDirectory = async (connId, path) => {
|
||||
tr.innerHTML = `<td>📁 ..</td>`;
|
||||
tr.style.cursor = 'pointer';
|
||||
tr.ondblclick = () => {
|
||||
const parts = path.split('/').filter(p => p);
|
||||
const startsWithSlash = path.startsWith('/');
|
||||
const sep = path.includes('\\') ? '\\' : '/';
|
||||
const parts = path.split(/[/\\]/).filter(p => p);
|
||||
parts.pop();
|
||||
loadTransferDestDirectory(connId, parts.length ? '/' + parts.join('/') : '');
|
||||
let newPath = '';
|
||||
if (parts.length > 0) {
|
||||
newPath = (startsWithSlash ? '/' : '') + parts.join(sep);
|
||||
if (!startsWithSlash && parts.length === 1 && parts[0].endsWith(':')) {
|
||||
newPath += sep;
|
||||
}
|
||||
}
|
||||
loadTransferDestDirectory(connId, newPath);
|
||||
};
|
||||
tbody.appendChild(tr);
|
||||
}
|
||||
|
||||
@@ -57,6 +57,14 @@ body {
|
||||
transition: background 0.2s;
|
||||
}
|
||||
|
||||
.conn-item * {
|
||||
pointer-events: none;
|
||||
}
|
||||
|
||||
.conn-item .edit-btn {
|
||||
pointer-events: auto;
|
||||
}
|
||||
|
||||
.conn-item:hover {
|
||||
background: var(--surface-hover);
|
||||
}
|
||||
|
||||
Vendored
+6
-2
@@ -11,6 +11,8 @@ export function Delete(arg1:string,arg2:string):Promise<void>;
|
||||
|
||||
export function DeleteConnection(arg1:string):Promise<void>;
|
||||
|
||||
export function DisconnectConnection(arg1:string):Promise<void>;
|
||||
|
||||
export function GetConnections():Promise<Array<config.ConnectionConfig>>;
|
||||
|
||||
export function GetTransfers():Promise<Array<transfer.Transfer>>;
|
||||
@@ -27,10 +29,12 @@ export function PromptUploadDirectory(arg1:string,arg2:string):Promise<void>;
|
||||
|
||||
export function PromptUploadFiles(arg1:string,arg2:string):Promise<void>;
|
||||
|
||||
export function QueueTransfer(arg1:string,arg2:string,arg3:string,arg4:string,arg5:string,arg6:string,arg7:number):Promise<void>;
|
||||
export function QueueTransfer(arg1:string,arg2:string,arg3:string,arg4:string,arg5:string,arg6:string,arg7:number,arg8:boolean,arg9:number):Promise<void>;
|
||||
|
||||
export function Rename(arg1:string,arg2:string,arg3:string):Promise<void>;
|
||||
|
||||
export function ReorderConnections(arg1:Array<string>):Promise<void>;
|
||||
|
||||
export function SaveConnection(arg1:config.ConnectionConfig,arg2:string):Promise<void>;
|
||||
|
||||
export function TransferItems(arg1:string,arg2:string,arg3:string,arg4:Array<main.TransferItem>):Promise<void>;
|
||||
export function TransferItems(arg1:string,arg2:string,arg3:string,arg4:Array<main.TransferItem>,arg5:boolean,arg6:number):Promise<void>;
|
||||
|
||||
@@ -14,6 +14,10 @@ export function DeleteConnection(arg1) {
|
||||
return window['go']['main']['App']['DeleteConnection'](arg1);
|
||||
}
|
||||
|
||||
export function DisconnectConnection(arg1) {
|
||||
return window['go']['main']['App']['DisconnectConnection'](arg1);
|
||||
}
|
||||
|
||||
export function GetConnections() {
|
||||
return window['go']['main']['App']['GetConnections']();
|
||||
}
|
||||
@@ -46,18 +50,22 @@ export function PromptUploadFiles(arg1, arg2) {
|
||||
return window['go']['main']['App']['PromptUploadFiles'](arg1, arg2);
|
||||
}
|
||||
|
||||
export function QueueTransfer(arg1, arg2, arg3, arg4, arg5, arg6, arg7) {
|
||||
return window['go']['main']['App']['QueueTransfer'](arg1, arg2, arg3, arg4, arg5, arg6, arg7);
|
||||
export function QueueTransfer(arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9) {
|
||||
return window['go']['main']['App']['QueueTransfer'](arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9);
|
||||
}
|
||||
|
||||
export function Rename(arg1, arg2, arg3) {
|
||||
return window['go']['main']['App']['Rename'](arg1, arg2, arg3);
|
||||
}
|
||||
|
||||
export function ReorderConnections(arg1) {
|
||||
return window['go']['main']['App']['ReorderConnections'](arg1);
|
||||
}
|
||||
|
||||
export function SaveConnection(arg1, arg2) {
|
||||
return window['go']['main']['App']['SaveConnection'](arg1, arg2);
|
||||
}
|
||||
|
||||
export function TransferItems(arg1, arg2, arg3, arg4) {
|
||||
return window['go']['main']['App']['TransferItems'](arg1, arg2, arg3, arg4);
|
||||
export function TransferItems(arg1, arg2, arg3, arg4, arg5, arg6) {
|
||||
return window['go']['main']['App']['TransferItems'](arg1, arg2, arg3, arg4, arg5, arg6);
|
||||
}
|
||||
|
||||
@@ -9,6 +9,7 @@ export namespace config {
|
||||
bucket?: string;
|
||||
region?: string;
|
||||
path_style?: boolean;
|
||||
secure?: boolean;
|
||||
username?: string;
|
||||
keychain_key?: string;
|
||||
|
||||
@@ -26,6 +27,7 @@ export namespace config {
|
||||
this.bucket = source["bucket"];
|
||||
this.region = source["region"];
|
||||
this.path_style = source["path_style"];
|
||||
this.secure = source["secure"];
|
||||
this.username = source["username"];
|
||||
this.keychain_key = source["keychain_key"];
|
||||
}
|
||||
@@ -96,6 +98,8 @@ export namespace transfer {
|
||||
eta_seconds: number;
|
||||
status: string;
|
||||
error?: string;
|
||||
verify: boolean;
|
||||
limit_mbps: number;
|
||||
|
||||
static createFrom(source: any = {}) {
|
||||
return new Transfer(source);
|
||||
@@ -113,6 +117,8 @@ export namespace transfer {
|
||||
this.eta_seconds = source["eta_seconds"];
|
||||
this.status = source["status"];
|
||||
this.error = source["error"];
|
||||
this.verify = source["verify"];
|
||||
this.limit_mbps = source["limit_mbps"];
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -9,12 +9,14 @@ require (
|
||||
github.com/aws/aws-sdk-go-v2/service/s3 v1.103.3
|
||||
github.com/google/uuid v1.6.0
|
||||
github.com/hirochachacha/go-smb2 v1.1.0
|
||||
github.com/jlaffaye/ftp v0.2.1
|
||||
github.com/pkg/sftp v1.13.10
|
||||
github.com/studio-b12/gowebdav v0.12.0
|
||||
github.com/vmware/go-nfs-client v0.0.0-20190605212624-d43b92724c1b
|
||||
github.com/wailsapp/wails/v2 v2.12.0
|
||||
github.com/zalando/go-keyring v0.2.8
|
||||
golang.org/x/crypto v0.53.0
|
||||
golang.org/x/time v0.15.0
|
||||
gopkg.in/yaml.v3 v3.0.1
|
||||
)
|
||||
|
||||
@@ -41,7 +43,6 @@ require (
|
||||
github.com/godbus/dbus/v5 v5.2.2 // indirect
|
||||
github.com/gorilla/websocket v1.5.3 // indirect
|
||||
github.com/jchv/go-winloader v0.0.0-20210711035445-715c2860da7e // indirect
|
||||
github.com/jlaffaye/ftp v0.2.1 // indirect
|
||||
github.com/kr/fs v0.1.0 // indirect
|
||||
github.com/labstack/echo/v4 v4.13.3 // indirect
|
||||
github.com/labstack/gommon v0.4.2 // indirect
|
||||
@@ -64,7 +65,6 @@ require (
|
||||
golang.org/x/net v0.55.0 // indirect
|
||||
golang.org/x/sys v0.46.0 // indirect
|
||||
golang.org/x/text v0.38.0 // indirect
|
||||
golang.org/x/time v0.15.0 // indirect
|
||||
)
|
||||
|
||||
// replace github.com/wailsapp/wails/v2 v2.12.0 => /home/jamie/go/pkg/mod
|
||||
|
||||
@@ -12,6 +12,7 @@ import (
|
||||
"github.com/aws/aws-sdk-go-v2/config"
|
||||
"github.com/aws/aws-sdk-go-v2/credentials"
|
||||
"github.com/aws/aws-sdk-go-v2/service/s3"
|
||||
"github.com/aws/aws-sdk-go-v2/service/s3/types"
|
||||
appcfg "goexplore/internal/config"
|
||||
"goexplore/internal/explorer"
|
||||
)
|
||||
@@ -243,11 +244,61 @@ func (e *S3Explorer) Delete(path string) error {
|
||||
return err
|
||||
}
|
||||
|
||||
// Try to delete the exact object (might be a file or a folder marker)
|
||||
_, err = e.client.DeleteObject(context.TODO(), &s3.DeleteObjectInput{
|
||||
Bucket: aws.String(bucket),
|
||||
Key: aws.String(subpath),
|
||||
})
|
||||
return err
|
||||
if err != nil {
|
||||
// Ignore error; it might just be a prefix with no exact marker
|
||||
}
|
||||
|
||||
// Also treat subpath as a folder prefix and delete all matching objects
|
||||
prefix := subpath
|
||||
if !strings.HasSuffix(prefix, "/") {
|
||||
prefix += "/"
|
||||
}
|
||||
|
||||
var continuationToken *string
|
||||
for {
|
||||
listInput := &s3.ListObjectsV2Input{
|
||||
Bucket: aws.String(bucket),
|
||||
Prefix: aws.String(prefix),
|
||||
ContinuationToken: continuationToken,
|
||||
}
|
||||
listOutput, err := e.client.ListObjectsV2(context.TODO(), listInput)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if len(listOutput.Contents) > 0 {
|
||||
var objectsToDelete []types.ObjectIdentifier
|
||||
for _, obj := range listOutput.Contents {
|
||||
objectsToDelete = append(objectsToDelete, types.ObjectIdentifier{
|
||||
Key: obj.Key,
|
||||
})
|
||||
}
|
||||
|
||||
_, err = e.client.DeleteObjects(context.TODO(), &s3.DeleteObjectsInput{
|
||||
Bucket: aws.String(bucket),
|
||||
Delete: &types.Delete{
|
||||
Objects: objectsToDelete,
|
||||
Quiet: aws.Bool(true),
|
||||
},
|
||||
})
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
||||
if listOutput.IsTruncated != nil && *listOutput.IsTruncated {
|
||||
continuationToken = listOutput.NextContinuationToken
|
||||
} else {
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func (e *S3Explorer) Rename(src, dst string) error {
|
||||
|
||||
@@ -6,12 +6,14 @@ import (
|
||||
"fmt"
|
||||
"io"
|
||||
"path/filepath"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"goexplore/internal/config"
|
||||
"goexplore/internal/explorer"
|
||||
|
||||
"github.com/pkg/sftp"
|
||||
"golang.org/x/crypto/ssh"
|
||||
"goexplore/internal/config"
|
||||
"goexplore/internal/explorer"
|
||||
)
|
||||
|
||||
type SFTPExplorer struct {
|
||||
@@ -31,19 +33,46 @@ func (e *SFTPExplorer) Connect() error {
|
||||
port = 22
|
||||
}
|
||||
|
||||
var authMethod ssh.AuthMethod
|
||||
signer, err := ssh.ParsePrivateKey([]byte(e.secret))
|
||||
if err == nil {
|
||||
authMethod = ssh.PublicKeys(signer)
|
||||
var authMethods []ssh.AuthMethod
|
||||
|
||||
secretStr := strings.TrimSpace(e.secret)
|
||||
// Handle case where newlines might be escaped by mistake
|
||||
secretStr = strings.ReplaceAll(secretStr, "\\n", "\n")
|
||||
|
||||
if strings.Contains(secretStr, "-----BEGIN") {
|
||||
signer, err := ssh.ParsePrivateKey([]byte(secretStr))
|
||||
if err != nil {
|
||||
return fmt.Errorf("failed to parse private key: %w", err)
|
||||
}
|
||||
authMethods = append(authMethods, ssh.PublicKeys(signer))
|
||||
} else {
|
||||
authMethod = ssh.Password(e.secret)
|
||||
authMethods = append(authMethods, ssh.Password(e.secret))
|
||||
}
|
||||
|
||||
// Always add KeyboardInteractive to support Duo MFA and servers that require interactive auth.
|
||||
authMethods = append(authMethods, ssh.KeyboardInteractive(func(user, instruction string, questions []string, echos []bool) (answers []string, err error) {
|
||||
answers = make([]string, len(questions))
|
||||
for i, q := range questions {
|
||||
qLower := strings.ToLower(q)
|
||||
if strings.Contains(secretStr, "-----BEGIN") {
|
||||
// If using a private key, we don't have a password.
|
||||
// If it's a Duo prompt asking for an option, "1" is typically Duo Push.
|
||||
if strings.Contains(qLower, "duo push") || strings.Contains(qLower, "passcode or option") {
|
||||
answers[i] = "1"
|
||||
} else {
|
||||
answers[i] = ""
|
||||
}
|
||||
} else {
|
||||
// Otherwise, respond with the password to keyboard interactive prompts
|
||||
answers[i] = e.secret
|
||||
}
|
||||
}
|
||||
return answers, nil
|
||||
}))
|
||||
|
||||
config := &ssh.ClientConfig{
|
||||
User: e.cfg.Username,
|
||||
Auth: []ssh.AuthMethod{
|
||||
authMethod,
|
||||
},
|
||||
User: e.cfg.Username,
|
||||
Auth: authMethods,
|
||||
HostKeyCallback: ssh.InsecureIgnoreHostKey(),
|
||||
}
|
||||
|
||||
@@ -74,9 +103,17 @@ func (e *SFTPExplorer) Disconnect() error {
|
||||
|
||||
func (e *SFTPExplorer) ListDir(path string) ([]explorer.FileEntry, error) {
|
||||
if path == "" {
|
||||
path = "."
|
||||
if e.cfg.Bucket != "" {
|
||||
path = e.cfg.Bucket
|
||||
} else {
|
||||
path = "/"
|
||||
}
|
||||
} else if path == "." {
|
||||
path = "/"
|
||||
}
|
||||
|
||||
files, err := e.client.ReadDir(path)
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user