From 5711c3b4da82e9daa2ac80a6a43d38dbb1c8e5df Mon Sep 17 00:00:00 2001
From: Cassie Tarakajian <ctarakajian@gmail.com>
Date: Tue, 13 Dec 2016 20:07:02 -0500
Subject: [PATCH] start to add file to delete unused files from S3

---
 client/modules/IDE/actions/uploader.js |  4 +-
 server/utils/db_reformat.js            | 69 ++++++++++++++++++++++----
 2 files changed, 63 insertions(+), 10 deletions(-)

diff --git a/client/modules/IDE/actions/uploader.js b/client/modules/IDE/actions/uploader.js
index fb7976dc..11ca1ba3 100644
--- a/client/modules/IDE/actions/uploader.js
+++ b/client/modules/IDE/actions/uploader.js
@@ -31,7 +31,9 @@ function localIntercept(file, options = {}) {
 }
 
 export function dropzoneAcceptCallback(file, done) {
-  return () => {
+  return (dispatch, getState) => {
+    const state = getState();
+    console.log(state);
     // for text files and small files
     // check mime type
     // if text, local interceptor
diff --git a/server/utils/db_reformat.js b/server/utils/db_reformat.js
index c311aacb..0f4afb2d 100644
--- a/server/utils/db_reformat.js
+++ b/server/utils/db_reformat.js
@@ -1,4 +1,6 @@
 import mongoose from 'mongoose';
+import path from 'path';
+require('dotenv').config({path: path.resolve('.env')});
 const ObjectId = mongoose.Types.ObjectId;
 mongoose.connect('mongodb://localhost:27017/p5js-web-editor');
 mongoose.connection.on('error', () => {
@@ -9,6 +11,55 @@ mongoose.connection.on('error', () => {
 import Project from '../models/project';
 import User from '../models/user';
 
+import s3 from 's3';
+
+let client = s3.createClient({
+  maxAsyncS3: 20,
+  s3RetryCount: 3,
+  s3RetryDelay: 1000,
+  multipartUploadThreshold: 20971520, // this is the default (20 MB) 
+  multipartUploadSize: 15728640, // this is the default (15 MB) 
+  s3Options: {
+    accessKeyId: `${process.env.AWS_ACCESS_KEY}`,
+    secretAccessKey: `${process.env.AWS_SECRET_KEY}`,
+    region: 'us-west-2'
+  },
+});
+
+const s3Files = [];
+
+Project.find({})
+  .exec((err, projects) => {
+    projects.forEach((project, projectIndex) => {
+      project.files.forEach((file, fileIndex) => {
+        if (file.url && !file.url.includes("https://rawgit.com/")) {
+          s3Files.push(file.url.split('/').pop());
+        }
+      });
+    });
+    console.log(s3Files);
+    console.log(s3Files.length);
+  });
+
+const uploadedFiles = [];
+const params = {'s3Params': {'Bucket': `${process.env.S3_BUCKET}`}};
+let objectsResponse = client.listObjects(params);
+objectsResponse.on('data', function(objects) {
+  objects.Contents.forEach(object => {
+    uploadedFiles.push(object.Key);
+  });
+});
+
+objectsResponse.on('end', () => {
+  console.log(uploadedFiles.length);
+  uploadedFiles.forEach(fileKey => {
+    if (s3Files.indexOf(fileKey) === -1) {
+      //delete file
+      console.log("would delete file: ", fileKey);
+    }
+  });
+});
+
 // let projectsNotToUpdate;
 // Project.find({'files.name': 'root'})
 //   .exec((err, projects) => {
@@ -126,12 +177,12 @@ import User from '../models/user';
 //     });
 //   });
 
-User.find({})
-  .exec((err, users) => {
-    users.forEach(user => {
-      user.preferences.autorefresh = false;
-      user.save((err, savedUser) => {
-        console.log('user saved');
-      });
-    });
-  });
+// User.find({})
+//   .exec((err, users) => {
+//     users.forEach(user => {
+//       user.preferences.autorefresh = false;
+//       user.save((err, savedUser) => {
+//         console.log('user saved');
+//       });
+//     });
+//   });