Skip to content

Commit

Permalink
revert back to last commit
Browse files Browse the repository at this point in the history
  • Loading branch information
jianmingtu committed Jan 26, 2024
1 parent e9f4707 commit 37d5f24
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ public SessionFactory<SftpClient.DirEntry> sftpSessionFactory() throws InvalidCo
factory.setUser(properties.getUsername());
if (properties.getSshPrivateKey() != null) {
logger.info("SFTP Configuration: setPrivateKey");
factory.setPrivateKey(new DefaultResourceLoader().getResource(properties.getSshPrivateKey()));
factory.setPrivateKey(properties.getSshPrivateKey());
factory.setPrivateKeyPassphrase(properties.getSshPrivatePassphrase());
} else {
logger.info("SFTP Configuration: setPassword");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,9 @@
import org.springframework.boot.context.properties.ConfigurationProperties;

import jakarta.validation.constraints.Min;
import org.springframework.core.io.ByteArrayResource;
import org.springframework.core.io.Resource;

import java.util.Optional;

/**
Expand Down Expand Up @@ -114,14 +117,14 @@ public void setMaxMessagePerPoll(String maxMessagePerPoll) {
this.maxMessagePerPoll = maxMessagePerPoll;
}

public String getSshPrivateKey() {
public Resource getSshPrivateKey() {
logger.info("getSshPrivateKey sshPrivateKey = {}", this.sshPrivateKey);
logger.info("getSshPrivateKey from System.getenv(SSH_PRIVATE_KEY): {}", System.getenv("SSH_PRIVATE_KEY"));
logger.info("getSshPrivateKey from System.getenv(SFTP_HOST): {}", System.getenv("SFTP_HOST"));
logger.info("getSshPrivateKey from System.getenv(SFTP_KNOWN_HOST_FILE): {}", System.getenv("SFTP_KNOWN_HOST_FILE"));
if (StringUtils.isBlank(this.sshPrivateKey)) { logger.info("getSshPrivateKey return null"); return null;}
logger.info("getSshPrivateKey return not null {}", this.sshPrivateKey);
return this.sshPrivateKey;
logger.info("getSshPrivateKey return not null {}", this.sshPrivateKey.getBytes());
return new ByteArrayResource(this.sshPrivateKey.getBytes());
}

public void setSshPrivateKey(String sshPrivateKey) {
Expand Down

0 comments on commit 37d5f24

Please sign in to comment.