added s3 fetch

src/app/api/s3list/route.ts

@@ -1,7 +1,6 @@
 import { logger } from '@/libs/Logger';
 import { NextResponse } from 'next/server';
-import { S3Client, ListObjectsV2Command, GetObjectCommand } from '@aws-sdk/client-s3';
-import { getSignedUrl } from '@aws-sdk/s3-request-presigner';
+import { S3Client, ListObjectsV2Command } from '@aws-sdk/client-s3';
 
 const s3Client = new S3Client({ region: 'us-east-1' , credentials:{
     accessKeyId: process.env.AWS_ACCESS_KEY_ID_S3 || '',
@@ -43,21 +42,15 @@ export async function GET(request: Request) {
 
         const files = await Promise.all(
             sortedContents.map(async (item) => {
-                const getObjectParams = {
-                    Bucket: bucketName,
-                    Key: item.Key,
-                };
-                const url = await getSignedUrl(s3Client, new GetObjectCommand(getObjectParams), { expiresIn: 3600 });
                 return {
                     key: item.Key,
-                    url,
                     lastModified: item.LastModified,
                 };
             })
         );
 
         return NextResponse.json({ files });
-    } catch (error:any) {
+    } catch (error: any) {
         logger.error(`Error listing S3 files for session ${sessionId}:`, error);
         return NextResponse.json({ error: 'Error listing S3 files' }, { status: 500 });
     }

src/app/api/s3view/route.ts

@@ -0,0 +1,58 @@
+import { logger } from '@/libs/Logger';
+import { S3Client, GetObjectCommand } from '@aws-sdk/client-s3';
+import { NextResponse } from 'next/server';
+
+const s3Client = new S3Client({
+    region: 'us-east-1',
+    credentials: {
+        accessKeyId: process.env.AWS_ACCESS_KEY_ID_S3 || '',
+        secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY_S3 || ''
+    }
+});
+
+export async function GET(request: Request) {
+    const { searchParams } = new URL(request.url);
+    const key = searchParams.get('key');
+    const sessionId = request.headers.get('X-Session-Id');
+
+    if (!key || !sessionId) {
+        return NextResponse.json({ error: 'Missing key or session ID' }, { status: 400 });
+    }
+
+    try {
+        const command = new GetObjectCommand({
+            Bucket: process.env.S3_BUCKET_NAME || '',
+            Key: key
+        });
+
+        const response = await s3Client.send(command);
+
+        if (!response.Body) {
+            throw new Error('No body in response');
+        }
+
+        // Convert the readable stream to text
+        const streamReader = response.Body.transformToWebStream();
+        const decoder = new TextDecoderStream();
+        const textStream = streamReader.pipeThrough(decoder);
+        const reader = textStream.getReader();
+
+        let content = '';
+        while (true) {
+            const { done, value } = await reader.read();
+            if (done) break;
+            content += value;
+        }
+
+        return new NextResponse(content, {
+            headers: {
+                'Content-Type': response.ContentType || 'application/json',
+                'Content-Disposition': `inline; filename="${key.split('/').pop()}"`,
+            },
+        });
+
+    } catch (error: any) {
+        logger.error(`Error downloading file ${key}:`, error);
+        return NextResponse.json({ error: 'Error downloading file' }, { status: 500 });
+    }
+}

src/app/s3/page.tsx

@@ -33,11 +33,19 @@ function App() {
         fetchFiles();
     }, []);
 
-    const handleFileClick = async (url: string) => {
+    const handleFileClick = async (file: any) => {
         try {
             setLoading(true);
-            console.log('Fetching JSON:', url);
-            const response = await fetch(url);
+            const response = await fetch(`/api/s3view?key=${encodeURIComponent(file.key)}`, {
+                headers: {
+                    'X-Session-Id': sessionId || ''
+                }
+            });
+
+            if (!response.ok) {
+                throw new Error('Failed to fetch file');
+            }
+
             const ndJsonData = await response.text();
             const jsonData = ndJsonData
                 .split('\n')
@@ -78,7 +86,7 @@ function App() {
                                 >
                                     <td
                                         className="px-6 py-4 text-sm font-medium text-gray-900"
-                                        onClick={() => handleFileClick(file.url)}
+                                        onClick={() => handleFileClick(file)}
                                     >
                                         {file.key}
                                     </td>