studisram/SSHRemotePlugin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: studisram:main
Branches Tags
studisram:main
studisram:dev
..
compare: studisram:dev
Branches Tags
studisram:main
studisram:dev

No commits in common. "main" and "dev" have entirely different histories.
main ... dev

12 changed files with 143 additions and 401 deletions
Show Stats Expand all files Collapse all files

1
build.gradle.kts
View File

@ -14,7 +14,6 @@ dependencies {
// IntelliJ Platform Gradle Plugin Dependencies Extension - read more: https://plugins.jetbrains.com/docs/intellij/tools-intellij-platform-gradle-plugin-dependencies-extension.html
intellijPlatform {
intellijIdeaCommunity("2024.1.7")
bundledPlugin("org.jetbrains.plugins.terminal")
testFramework(TestFrameworkType.Platform)
}
}

11
src/main/java/com/example/plugin/ChooseServerWidget.java
View File

@ -11,6 +11,7 @@ import org.jetbrains.annotations.Nullable;
import javax.swing.*;
import java.awt.event.MouseEvent;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
@ -35,6 +36,7 @@ public class ChooseServerWidget implements StatusBarWidget,
return this;
}
// ---------- IconPresentation ----------
@Override
public @Nullable Icon getIcon() {
return null;
@ -74,6 +76,7 @@ public class ChooseServerWidget implements StatusBarWidget,
};
}
// ---------- TextPresentation ----------
@Override
public @Nullable String getText() {
String serverId = ProjectServerMapping.getInstance().getServerIdForProject(project.getBasePath());
@ -89,10 +92,12 @@ public class ChooseServerWidget implements StatusBarWidget,
return JComponent.CENTER_ALIGNMENT;
}
// ---------- Логика переключения ----------
private void switchToServer(SshServer server) {
SshServerManager.getInstance().setCurrentServerId(server.id);
String localPath = SshServerManager.getLocalProjectPath(server);
String localPath = Paths.get(System.getProperty("user.home"), "ssh-remote-projects",
sanitize(server.host), sanitize(server.remoteProjectPath)).toString().replace('\\', '/');
for (Project openProject : ProjectManager.getInstance().getOpenProjects()) {
if (openProject.getBasePath() != null && openProject.getBasePath().equals(localPath)) {
@ -113,4 +118,8 @@ public class ChooseServerWidget implements StatusBarWidget,
com.intellij.openapi.options.ShowSettingsUtil.getInstance()
.showSettingsDialog(project, SshServerConfigurable.class);
}
private String sanitize(String input) {
return input.replaceAll("[^a-zA-Z0-9.-]", "_");
}
}

146
src/main/java/com/example/plugin/ConnectToRemoteAction.java
View File

@ -16,25 +16,33 @@ import com.jcraft.jsch.*;
import org.jetbrains.annotations.NotNull;
import java.io.IOException;
import org.jdom.JDOMException;
import java.io.File;
import java.io.*;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.Optional;
import java.util.Vector;
public class ConnectToRemoteAction extends AnAction {
@Override
public void actionPerformed(@NotNull AnActionEvent e) {
// Показываем окно настройки серверов
ShowSettingsUtil.getInstance().showSettingsDialog(e.getProject(), SshServerConfigurable.class);
}
// Статический метод для открытия проекта (используется из виджета и действия)
public static void openProjectForServer(SshServer server) {
String localPath = SshServerManager.getLocalProjectPath(server);
String localPath = Paths.get(System.getProperty("user.home"), "ssh-remote-projects",
sanitize(server.host), sanitize(server.remoteProjectPath)).toString().replace('\\', '/');
// Если папка уже существует, просто открываем
File localDir = new File(localPath);
if (localDir.exists() && localDir.listFiles().length > 0) {
openExistingProject(localPath, server.id);
} else {
// Скачиваем и открываем
downloadAndOpen(localPath, server);
}
}
@ -66,28 +74,6 @@ public class ConnectToRemoteAction extends AnAction {
}
}
public static void syncProject(SshServer server, String localPath, ProgressIndicator indicator) throws Exception {
JSch jsch = new JSch();
Session session = jsch.getSession(server.user, server.host, server.port);
session.setPassword(SshServerManager.getInstance().getPassword(server.id));
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect(5000);
ChannelSftp sftp = (ChannelSftp) session.openChannel("sftp");
sftp.connect(3000);
try {
File localDir = new File(localPath);
if (!localDir.exists()) localDir.mkdirs();
syncDir(sftp, server.remoteProjectPath, localDir, indicator);
} finally {
sftp.disconnect();
session.disconnect();
}
}
private static void downloadProject(ProgressIndicator indicator, String localPath, SshServer server) throws Exception {
JSch jsch = new JSch();
Session session = jsch.getSession(server.user, server.host, server.port);
@ -130,49 +116,6 @@ public class ConnectToRemoteAction extends AnAction {
}
}
private static void syncDir(ChannelSftp sftp, String remoteDir, File localDir, ProgressIndicator indicator) {
try {
@SuppressWarnings("unchecked")
Vector<ChannelSftp.LsEntry> entries = sftp.ls(remoteDir);
for (ChannelSftp.LsEntry entry : entries) {
if (indicator.isCanceled()) break;
String filename = entry.getFilename();
if (filename.equals(".") || filename.equals("..")) continue;
String remotePath = remoteDir + "/" + filename;
try {
if (entry.getAttrs().isDir()) {
File subDir = new File(localDir, filename);
if (!subDir.exists()) subDir.mkdirs();
syncDir(sftp, remotePath, subDir, indicator);
} else {
File localFile = new File(localDir, filename);
boolean needDownload = !localFile.exists();
if (!needDownload && localFile.isFile()) {
long remoteSize = entry.getAttrs().getSize();
long remoteMtime = entry.getAttrs().getMTime();
if (localFile.length() != remoteSize || localFile.lastModified() / 1000L != remoteMtime) {
needDownload = true;
}
}
if (needDownload) {
indicator.setText("Syncing: " + filename);
sftp.get(remotePath, localFile.getAbsolutePath());
if (entry.getAttrs().getMTime() > 0) {
localFile.setLastModified(entry.getAttrs().getMTime() * 1000L);
}
}
}
} catch (Exception e) {
System.err.println("Skip entry: " + remotePath + " - " + e.getMessage());
}
}
} catch (SftpException e) {
System.err.println("Cannot list directory: " + remoteDir + " - " + e.getMessage());
}
}
private static void createProjectStructure(File projectDir) throws IOException {
File ideaDir = new File(projectDir, ".idea");
if (!ideaDir.exists()) ideaDir.mkdirs();
@ -220,4 +163,75 @@ public class ConnectToRemoteAction extends AnAction {
writer.write(content);
}
}
private static String sanitize(String input) {
return input.replaceAll("[^a-zA-Z0-9.-]", "_");
}
public static void syncProject(SshServer server, String localPath, ProgressIndicator indicator) throws Exception {
JSch jsch = new JSch();
Session session = jsch.getSession(server.user, server.host, server.port);
session.setPassword(SshServerManager.getInstance().getPassword(server.id));
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect(5000);
ChannelSftp sftp = (ChannelSftp) session.openChannel("sftp");
sftp.connect(3000);
try {
File localDir = new File(localPath);
if (!localDir.exists()) localDir.mkdirs();
syncDir(sftp, server.remoteProjectPath, localDir, indicator);
} finally {
sftp.disconnect();
session.disconnect();
}
}
private static void syncDir(ChannelSftp sftp, String remoteDir, File localDir, ProgressIndicator indicator) {
try {
@SuppressWarnings("unchecked")
Vector<ChannelSftp.LsEntry> entries = sftp.ls(remoteDir);
for (ChannelSftp.LsEntry entry : entries) {
if (indicator.isCanceled()) break;
String filename = entry.getFilename();
if (filename.equals(".") || filename.equals("..")) continue;
String remotePath = remoteDir + "/" + filename;
try {
if (entry.getAttrs().isDir()) {
File subDir = new File(localDir, filename);
if (!subDir.exists()) subDir.mkdirs();
syncDir(sftp, remotePath, subDir, indicator);
} else {
File localFile = new File(localDir, filename);
boolean needDownload = !localFile.exists();
if (!needDownload && localFile.isFile()) {
long remoteSize = entry.getAttrs().getSize();
long remoteMtime = entry.getAttrs().getMTime();
if (localFile.length() != remoteSize || localFile.lastModified() / 1000L != remoteMtime) {
needDownload = true;
}
}
if (needDownload) {
indicator.setText("Syncing: " + filename);
sftp.get(remotePath, localFile.getAbsolutePath());
if (entry.getAttrs().getMTime() > 0) {
localFile.setLastModified(entry.getAttrs().getMTime() * 1000L);
}
}
}
} catch (Exception e) {
// Логируем и пропускаем файл, который не удалось скачать/записать
System.err.println("Skip entry: " + remotePath + " - " + e.getMessage());
}
}
} catch (SftpException e) {
System.err.println("Cannot list directory: " + remoteDir + " - " + e.getMessage());
}
}
}

88
src/main/java/com/example/plugin/OpenRemoteTerminalAction.java
View File

@ -1,88 +0,0 @@
package com.example.plugin;
import com.intellij.openapi.Disposable;
import com.intellij.openapi.actionSystem.AnAction;
import com.intellij.openapi.actionSystem.AnActionEvent;
import com.intellij.openapi.project.Project;
import com.intellij.openapi.ui.Messages;
import com.intellij.openapi.util.Disposer;
import com.intellij.openapi.wm.ToolWindow;
import com.intellij.openapi.wm.ToolWindowManager;
import com.intellij.terminal.JBTerminalWidget;
import com.intellij.ui.content.Content;
import com.intellij.ui.content.ContentFactory;
import com.jcraft.jsch.ChannelShell;
import com.jediterm.terminal.TtyConnector;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.plugins.terminal.JBTerminalSystemSettingsProvider;
import java.util.Optional;
public class OpenRemoteTerminalAction extends AnAction {
@Override
public void actionPerformed(@NotNull AnActionEvent e) {
Project project = e.getProject();
if (project == null) return;
String serverId = ProjectServerMapping.getInstance()
.getServerIdForProject(project.getBasePath());
if (serverId == null) {
Messages.showErrorDialog("No server associated with this project.", "Error");
return;
}
Optional<SshServer> maybeServer =
SshServerManager.getInstance().findServer(serverId);
if (maybeServer.isEmpty()) {
Messages.showErrorDialog("Server not found.", "Error");
return;
}
SshServer server = maybeServer.get();
try {
ChannelShell shellChannel =
SftpSessionManager.getInstance(project)
.getShellChannel(server);
TtyConnector connector = new SshTtyConnector(shellChannel, server.remoteProjectPath);
ToolWindow terminalToolWindow =
ToolWindowManager.getInstance(project).getToolWindow("Terminal");
if (terminalToolWindow == null) {
Messages.showErrorDialog("Terminal tool window not found.", "Error");
return;
}
Disposable disposable =
Disposer.newDisposable(project, "Remote SSH Terminal");
JBTerminalWidget widget =
new JBTerminalWidget(
project,
new JBTerminalSystemSettingsProvider(),
disposable
);
Content content =
ContentFactory.getInstance()
.createContent(widget, "Remote: " + server.name, false);
content.setDisposer(disposable);
terminalToolWindow.getContentManager().addContent(content);
terminalToolWindow.getContentManager().setSelectedContent(content, true);
terminalToolWindow.activate(() -> widget.start(connector), true);
} catch (Exception ex) {
Messages.showErrorDialog(
"Failed to open terminal: " + ex.getMessage(),
"Error"
);
}
}
}

10
src/main/java/com/example/plugin/RefreshFromServerAction.java
View File

@ -13,6 +13,7 @@ import com.intellij.openapi.vfs.VfsUtil;
import com.intellij.openapi.vfs.VirtualFile;
import org.jetbrains.annotations.NotNull;
import java.nio.file.Paths;
import java.util.Optional;
public class RefreshFromServerAction extends AnAction {
@ -41,9 +42,12 @@ public class RefreshFromServerAction extends AnAction {
@Override
public void run(@NotNull ProgressIndicator indicator) {
try {
String localRoot = SshServerManager.getLocalProjectPath(server);
String localRoot = Paths.get(System.getProperty("user.home"), "ssh-remote-projects",
sanitize(server.host), sanitize(server.remoteProjectPath))
.toString().replace('\\', '/');
ConnectToRemoteAction.syncProject(server, localRoot, indicator);
// Обновляем виртуальную файловую систему, чтобы IDE увидела изменения
ApplicationManager.getApplication().invokeLater(() -> {
VirtualFile rootDir = LocalFileSystem.getInstance().findFileByPath(localRoot);
if (rootDir != null) {
@ -58,4 +62,8 @@ public class RefreshFromServerAction extends AnAction {
}
});
}
private String sanitize(String input) {
return input.replaceAll("[^a-zA-Z0-9.-]", "_");
}
}

45
src/main/java/com/example/plugin/SftpSessionManager.java
View File

@ -4,11 +4,11 @@ import com.intellij.openapi.project.Project;
import com.jcraft.jsch.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicReference;
public class SftpSessionManager {
private final ConcurrentHashMap<String, ChannelSftp> channels = new ConcurrentHashMap<>();
private final ConcurrentHashMap<String, Session> sessions = new ConcurrentHashMap<>();
private final ConcurrentHashMap<String, ChannelShell> shellChannels = new ConcurrentHashMap<>();
private final Object lock = new Object();
public ChannelSftp getChannel(SshServer server) throws Exception {
@ -20,59 +20,32 @@ public class SftpSessionManager {
channel = channels.get(server.id);
if (channel != null && channel.isConnected() && !channel.isClosed()) return channel;
Session session = getSession(server);
ChannelSftp newChannel = (ChannelSftp) session.openChannel("sftp");
newChannel.connect(3000);
channels.put(server.id, newChannel);
return newChannel;
}
}
public ChannelShell getShellChannel(SshServer server) throws Exception {
ChannelShell shell = shellChannels.get(server.id);
if (shell != null && shell.isConnected() && !shell.isClosed()) {
return shell;
}
synchronized (lock) {
shell = shellChannels.get(server.id);
if (shell != null && shell.isConnected() && !shell.isClosed()) return shell;
Session session = getSession(server);
ChannelShell newShell = (ChannelShell) session.openChannel("shell");
newShell.connect(5000);
shellChannels.put(server.id, newShell);
return newShell;
}
}
private Session getSession(SshServer server) throws JSchException {
Session session = sessions.get(server.id);
if (session == null || !session.isConnected()) {
JSch jsch = new JSch();
session = jsch.getSession(server.user, server.host, server.port);
Session session = jsch.getSession(server.user, server.host, server.port);
session.setPassword(SshServerManager.getInstance().getPassword(server.id));
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect(5000);
ChannelSftp newChannel = (ChannelSftp) session.openChannel("sftp");
newChannel.connect(3000);
sessions.put(server.id, session);
channels.put(server.id, newChannel);
return newChannel;
}
return session;
}
public void disconnect() {
synchronized (lock) {
for (ChannelShell sh : shellChannels.values()) {
if (sh.isConnected()) sh.disconnect();
}
shellChannels.clear();
for (ChannelSftp ch : channels.values()) {
if (ch.isConnected()) ch.disconnect();
}
channels.clear();
for (Session s : sessions.values()) {
if (s.isConnected()) s.disconnect();
}
channels.clear();
sessions.clear();
}
}

7
src/main/java/com/example/plugin/SshServerConfigurable.java
View File

@ -189,11 +189,6 @@ class ServerDialog extends DialogWrapper {
result.add(new ValidationInfo("Invalid port", portField));
}
if (remotePathField.getText().trim().isEmpty()) result.add(new ValidationInfo("Remote path required", remotePathField));
// Требуем пароль для нового сервера
if (SshServerManager.getInstance().findServer(server.id).isEmpty() && passwordField.getPassword().length == 0) {
result.add(new ValidationInfo("Password required for new server", passwordField));
}
return result;
}
@ -211,7 +206,7 @@ class ServerDialog extends DialogWrapper {
if (!pass.isEmpty()) {
SshServerManager.getInstance().setPassword(server.id, pass);
}
// Если пароль пустой и сервер уже существует – старый пароль остаётся без изменений
// Если поле пустое – оставляем старый пароль (если есть) нетронутым
super.doOKAction();
}
}

20
src/main/java/com/example/plugin/SshServerManager.java
View File

@ -9,7 +9,6 @@ import com.intellij.util.xmlb.XmlSerializerUtil;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
@ -57,6 +56,7 @@ public class SshServerManager implements PersistentStateComponent<SshServerManag
if (id.equals(myState.currentServerId)) {
myState.currentServerId = null;
}
// Удаляем сохранённый пароль
PasswordSafe.getInstance().setPassword(createCredentialAttributes(id), null);
}
@ -103,22 +103,4 @@ public class SshServerManager implements PersistentStateComponent<SshServerManag
return com.intellij.openapi.application.ApplicationManager.getApplication()
.getService(SshServerManager.class);
}
// ---------- Вспомогательные статические методы ----------
/**
* Возвращает локальный путь к папке проекта на основе хоста и имени сервера.
*/
public static String getLocalProjectPath(SshServer server) {
return Paths.get(System.getProperty("user.home"), "ssh-remote-projects",
sanitize(server.host), sanitize(server.name))
.toString().replace('\\', '/');
}
/**
* Заменяет в строке все символы, кроме букв, цифр, точки и дефиса, на '_'.
*/
public static String sanitize(String input) {
return input.replaceAll("[^a-zA-Z0-9.-]", "_");
}
}

110
src/main/java/com/example/plugin/SshSyncStartupActivity.java
View File

@ -13,8 +13,8 @@ import com.intellij.openapi.vfs.*;
import com.jcraft.jsch.*;
import org.jetbrains.annotations.NotNull;
import java.nio.file.Paths;
import java.util.Optional;
import java.util.Vector;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@ -35,7 +35,7 @@ public class SshSyncStartupActivity implements StartupActivity {
}
});
// Слушатель изменений файлов для синхронизации (создание, изменение, удаление)
// Слушатель изменений файлов для синхронизации
VirtualFile baseDir = project.getBaseDir();
if (baseDir != null) {
VirtualFileManager.getInstance().addVirtualFileListener(new VirtualFileListener() {
@ -49,11 +49,6 @@ public class SshSyncStartupActivity implements StartupActivity {
syncFile(event.getFile(), project);
}
@Override
public void fileDeleted(@NotNull VirtualFileEvent event) {
deleteRemoteFile(event.getFile(), project);
}
private void syncFile(VirtualFile file, Project project) {
if (!file.isDirectory()) {
uploadFile(file, project);
@ -70,13 +65,18 @@ public class SshSyncStartupActivity implements StartupActivity {
Optional<SshServer> maybeServer = SshServerManager.getInstance().findServer(serverId);
if (maybeServer.isPresent()) {
SshServer server = maybeServer.get();
// Модальный диалог – блокирует IDE до завершения синхронизации
ApplicationManager.getApplication().invokeLater(() -> {
ProgressManager.getInstance().run(new Task.Modal(project, "Synchronizing with " + server.name, true) {
@Override
public void run(@NotNull ProgressIndicator indicator) {
try {
String localRoot = SshServerManager.getLocalProjectPath(server);
String localRoot = Paths.get(System.getProperty("user.home"), "ssh-remote-projects",
sanitize(server.host), sanitize(server.remoteProjectPath))
.toString().replace('\\', '/');
ConnectToRemoteAction.syncProject(server, localRoot, indicator);
// Обновляем виртуальную файловую систему, чтобы IDE увидела изменения
ApplicationManager.getApplication().invokeLater(() -> {
VirtualFile rootDir = LocalFileSystem.getInstance().findFileByPath(localRoot);
if (rootDir != null) {
@ -99,6 +99,7 @@ public class SshSyncStartupActivity implements StartupActivity {
String projectPath = project.getBasePath();
if (projectPath == null) return;
// Определяем привязанный сервер
String serverId = ProjectServerMapping.getInstance().getServerIdForProject(projectPath);
if (serverId == null) return;
@ -106,24 +107,31 @@ public class SshSyncStartupActivity implements StartupActivity {
if (maybeServer.isEmpty()) return;
SshServer server = maybeServer.get();
String localRoot = SshServerManager.getLocalProjectPath(server);
// Вычисляем локальный корень проекта (как он был сохранен при создании)
String localRoot = Paths.get(System.getProperty("user.home"), "ssh-remote-projects",
sanitize(server.host), sanitize(server.remoteProjectPath))
.toString().replace('\\', '/');
String localFilePath = localFile.getPath();
String localFilePath = localFile.getPath(); // всегда с прямыми слешами
// Игнорируем служебные файлы IDE
if (localFilePath.contains("/.idea/") || localFile.getName().equals("remote.iml")) {
return;
}
// Проверяем, что файл принадлежит проекту
if (!localFilePath.startsWith(localRoot)) {
return;
}
// Относительный путь и удалённый путь
String relativePath = localFilePath.substring(localRoot.length());
if (relativePath.startsWith("/")) {
relativePath = relativePath.substring(1);
}
String remoteFilePath = server.remoteProjectPath + "/" + relativePath;
// Отправляем файл в отдельном потоке через общее SFTP-соединение
uploadExecutor.submit(() -> {
try {
ChannelSftp sftp = SftpSessionManager.getInstance(project).getChannel(server);
@ -141,84 +149,6 @@ public class SshSyncStartupActivity implements StartupActivity {
});
}
private void deleteRemoteFile(VirtualFile localFile, Project project) {
String projectPath = project.getBasePath();
if (projectPath == null) return;
String serverId = ProjectServerMapping.getInstance().getServerIdForProject(projectPath);
if (serverId == null) return;
Optional<SshServer> maybeServer = SshServerManager.getInstance().findServer(serverId);
if (maybeServer.isEmpty()) return;
SshServer server = maybeServer.get();
String localRoot = SshServerManager.getLocalProjectPath(server);
String localFilePath = localFile.getPath();
if (localFilePath.contains("/.idea/") || localFile.getName().equals("remote.iml")) {
return;
}
if (!localFilePath.startsWith(localRoot)) {
return;
}
String relativePath = localFilePath.substring(localRoot.length());
if (relativePath.startsWith("/")) {
relativePath = relativePath.substring(1);
}
String remoteFilePath = server.remoteProjectPath + "/" + relativePath;
uploadExecutor.submit(() -> {
try {
ChannelSftp sftp = SftpSessionManager.getInstance(project).getChannel(server);
deleteRemotePath(sftp, remoteFilePath, localFile.isDirectory());
} catch (Exception e) {
ApplicationManager.getApplication().invokeLater(() ->
com.intellij.openapi.ui.Messages.showErrorDialog(
"Delete error " + localFile.getName() + ": " + e.getMessage(),
"SFTP Error"
)
);
}
});
}
private void deleteRemotePath(ChannelSftp sftp, String remotePath, boolean isDirectory) throws Exception {
if (isDirectory) {
try {
Vector<ChannelSftp.LsEntry> entries = sftp.ls(remotePath);
for (ChannelSftp.LsEntry entry : entries) {
String name = entry.getFilename();
if (name.equals(".") || name.equals("..")) continue;
String childPath = remotePath + "/" + name;
if (entry.getAttrs().isDir()) {
deleteRemotePath(sftp, childPath, true);
} else {
try {
sftp.rm(childPath);
} catch (SftpException e) {
if (e.id != ChannelSftp.SSH_FX_NO_SUCH_FILE) throw e;
}
}
}
} catch (SftpException e) {
if (e.id != ChannelSftp.SSH_FX_NO_SUCH_FILE) throw e;
}
sftp.rmdir(remotePath);
} else {
try {
sftp.rm(remotePath);
} catch (SftpException e) {
if (e.id != ChannelSftp.SSH_FX_NO_SUCH_FILE) {
throw e;
}
// иначе файл уже удалён – пропускаем
}
}
}
private void createRemoteDirs(ChannelSftp sftp, String dir) throws SftpException {
if (dir.isEmpty() || dir.equals("/")) return;
String[] parts = dir.split("/");
@ -237,4 +167,8 @@ public class SshSyncStartupActivity implements StartupActivity {
}
}
}
private String sanitize(String input) {
return input.replaceAll("[^a-zA-Z0-9.-]", "_");
}
}

89
src/main/java/com/example/plugin/SshTtyConnector.java
View File

@ -1,89 +0,0 @@
package com.example.plugin;
import com.jcraft.jsch.ChannelShell;
import com.jediterm.terminal.TtyConnector;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import java.awt.*;
import java.io.*;
import java.nio.charset.StandardCharsets;
public class SshTtyConnector implements TtyConnector {
private final ChannelShell channel;
private final InputStream inputStream;
private final OutputStream outputStream;
private final Reader reader;
public SshTtyConnector(ChannelShell channel, String initialPath) {
this.channel = channel;
try {
this.inputStream = channel.getInputStream();
this.outputStream = channel.getOutputStream();
this.reader = new InputStreamReader(inputStream, StandardCharsets.UTF_8);
if (initialPath != null && !initialPath.isBlank()) {
outputStream.write(
("cd \"" + initialPath + "\"\n")
.getBytes(StandardCharsets.UTF_8)
);
outputStream.flush();
}
} catch (Exception e) {
throw new RuntimeException(e);
}
}
@Override
public boolean isConnected() {
return channel.isConnected() && !channel.isClosed();
}
@Override
public void close() {
if (channel.isConnected()) {
channel.disconnect();
}
}
@Override
public @Nullable String getName() {
return "SSH Remote";
}
@Override
public int read(char[] buf, int offset, int length) throws IOException {
return reader.read(buf, offset, length);
}
@Override
public void write(String string) throws IOException {
write(string.getBytes(StandardCharsets.UTF_8));
}
@Override
public void write(byte[] bytes) throws IOException {
outputStream.write(bytes);
outputStream.flush();
}
@Override
public void resize(@NotNull Dimension size) {
channel.setPtySize(size.width, size.height, 0, 0);
}
@Override
public int waitFor() throws InterruptedException {
while (isConnected()) {
Thread.sleep(100);
}
return channel.getExitStatus();
}
@Override
public boolean ready() throws IOException {
return reader.ready();
}
}

10
src/main/java/com/example/plugin/SwitchServerAction.java
View File

@ -48,8 +48,11 @@ public class SwitchServerAction extends AnAction {
private void switchToServer(SshServer server, Project currentProject) {
SshServerManager.getInstance().setCurrentServerId(server.id);
String localPath = SshServerManager.getLocalProjectPath(server);
String localPath = Paths.get(System.getProperty("user.home"), "ssh-remote-projects",
sanitize(server.host), sanitize(server.remoteProjectPath))
.toString().replace('\\', '/');
// Проверяем, открыт ли уже проект с этим путём
for (Project openProject : ProjectManager.getInstance().getOpenProjects()) {
if (openProject.getBasePath() != null && openProject.getBasePath().equals(localPath)) {
ApplicationManager.getApplication().invokeLater(() ->
@ -58,10 +61,15 @@ public class SwitchServerAction extends AnAction {
}
}
// Закрываем текущий проект и открываем новый
if (currentProject != null && !currentProject.isDisposed()) {
ProjectManager.getInstance().closeProject(currentProject);
}
ConnectToRemoteAction.openProjectForServer(server);
}
private String sanitize(String input) {
return input.replaceAll("[^a-zA-Z0-9.-]", "_");
}
}

7
src/main/resources/META-INF/plugin.xml
View File

@ -28,14 +28,15 @@
]]>
</description>
<depends>com.intellij.modules.platform</depends>
<depends>org.jetbrains.plugins.terminal</depends>
<extensions defaultExtensionNs="com.intellij">
<projectConfigurable instance="com.example.plugin.SshServerConfigurable"
displayName="SSH Remote Project"/>
<applicationService serviceImplementation="com.example.plugin.SshServerManager"/>
<applicationService serviceImplementation="com.example.plugin.ProjectServerMapping"/>
<projectService serviceImplementation="com.example.plugin.SftpSessionManager"/>
<applicationService serviceImplementation="com.example.plugin.ProjectMappingService"/>
<postStartupActivity implementation="com.example.plugin.SshSyncStartupActivity"/>
</extensions>
@ -60,10 +61,6 @@
class="com.example.plugin.RemoteCommandAction"
text="Run Remote Command"
description="Execute command on the associated server"/>
<action id="SshRemote.OpenTerminal"
class="com.example.plugin.OpenRemoteTerminalAction"
text="Open Remote Terminal"
description="Open integrated terminal connected to the remote server"/>
<add-to-group group-id="ToolsMenu" anchor="last"/>
</group>
</actions>