From f75c3de15f45ab8660ea4ff0f0b501848cc0d90c Mon Sep 17 00:00:00 2001
From: Dan Riedl <amkoenigsholz9@gmail.com>
Date: Wed, 30 Oct 2024 09:43:16 +0100
Subject: [PATCH] feat(sftp): add modtime as metadata. [#2955]

---
 internal/impl/sftp/input.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/internal/impl/sftp/input.go b/internal/impl/sftp/input.go
index e4fb3bed94..878c2fc085 100644
--- a/internal/impl/sftp/input.go
+++ b/internal/impl/sftp/input.go
@@ -53,6 +53,7 @@ func sftpInputSpec() *service.ConfigSpec {
 This input adds the following metadata fields to each message:
 
 - sftp_path
+- sftp_modification_time
 
 You can access these metadata fields using xref:configuration:interpolation.adoc#bloblang-queries[function interpolation].`).
 		Fields(
@@ -295,6 +296,8 @@ func (s *sftpReader) ReadBatch(ctx context.Context) (service.MessageBatch, servi
 
 	for _, part := range parts {
 		part.MetaSetMut("sftp_path", currentPath)
+		fileInfo, _ := s.client.Stat(currentPath)
+		part.MetaSetMut("sftp_modification_time", fileInfo.ModTime())
 	}
 
 	return parts, func(ctx context.Context, res error) error {