Merge branch 'canbula:master' into master

Author: keremkaynak3

Projects/CyberGoose/app.py

@@ -0,0 +1,270 @@
+from flask import Flask,url_for, jsonify, redirect, request,render_template
+from flask_cors import CORS
+import os_folder as mycomp
+from ftpconn import FTPOperations
+from sftpconn import SFTPOperations
+from db import DbMyFtp
+from dropboxIslemleri import DropboxOperations
+from drive_conn import DriveService
+import string
+
+app = Flask(__name__)
+CORS(app)  # Tüm kaynaklardan gelen isteklere izin verir
+
+servers_dirs = dict()
+serverConn = None
+db = DbMyFtp()
+
+@app.route('/')
+def index():
+    return open('template/index.html', encoding='utf-8').read()
+
+@app.route('/serverconnection.html')
+def serverconnection():
+    return open('template/serverconnection.html', encoding='utf-8').read()
+
+@app.route('/bookmarks.html')
+def openbookmarks():
+    return open('template/bookmarks.html', encoding='utf-8').read()
+
+@app.route('/file_inf.html')
+def openFileInfo():
+    return open('template/file_inf.html', encoding='utf-8').read()
+
+@app.route('/api/fileinfo', methods=['POST'])
+def file_info():
+    global serverConn
+    data = request.json
+    filepath = data.get('filepath')
+    print("geldim")
+    print(filepath)
+    if not filepath:
+        return jsonify({"error": "Filepath is required"}), 400
+    file_info = serverConn.get_file_details(filepath)
+    return jsonify(file_info)
+
+@app.route('/api/fileUpdate', methods=['POST'])
+def filemodechange():
+    if request.method == 'POST':
+        if request.headers['Content-Type'] == 'application/json':
+            data = request.json
+            filepath = data.get('filepath')
+            filemod = data.get('filemod')
+            global serverConn
+            serverConn.change_file_mode(filepath, filemod)         
+            return jsonify({'ISLEM': 'BASARILI'})
+    else:
+        return jsonify({'error': 'İçerik tipi "application/json" değil'})
+
+@app.route('/submit', methods=['POST'])
+def submit():
+    if request.method == 'POST':
+        if request.headers['Content-Type'] == 'application/json':
+            data = request.json
+            conn_type = data.get('conn_type')
+            username = data.get('username')
+            server = data.get('server')
+            port = data.get('port')
+            passwd = data.get('passwd')
+            sshkey = data.get('sshkey')
+            global serverConn
+
+            if conn_type == "DropBox":
+                try:
+                    serverConn = DropboxOperations()
+                except Exception as e:
+                    print(e)
+                    print("Dropbox bağlantısı kurulamadı")
+                    return jsonify({'error': 'var'})
+                if serverConn.access_token:
+                    print("Dropbox bağlantısı kuruldu")
+                    return jsonify({'Bağlantı': 'Başarılı'})
+                return jsonify({'error': 'var'})
+            
+            if conn_type == "GoogleDrive":
+                try:
+                    serverConn = DriveService()
+                except Exception as e:
+                    print(e)
+                    print("Drive bağlantısı kurulamadı")
+                    return jsonify({'error': 'var'})
+                print("Drive bağlantısı kuruldu")
+                return jsonify({'Bağlantı': 'Başarılı'})
+            if username and server and port and passwd or sshkey:
+                if conn_type == "FTP":
+                    try:
+                        serverConn = FTPOperations(server, int(port), username, passwd)
+                    except Exception as e:
+                        print(e)
+                        return jsonify({'error': 'var'})
+                elif conn_type == "SFTP":
+                    try:
+                        serverConn = SFTPOperations(server, int(port), username, passwd)
+                    except Exception as e:
+                        print(e)
+                        return jsonify({'error': 'var'})                    
+                return jsonify({'Bağlantı': 'Başarılı'})
+            else:
+                return jsonify({'Bağlantı': 'Parametreleri Eksik'})
+        else:
+            return jsonify({'error': 'İçerik tipi "application/json" değil'})
+
+@app.route('/api/compdirs', methods=['GET'])
+def getCompDirList():
+    mycompDirlists = mycomp.list_files("C:\\Users\\bilalayakdas\\Desktop\\FtpDirectory")
+    return jsonify(mycompDirlists)
+
+@app.route('/api/serverfilelist', methods=['POST'])
+def getDirs():
+    data = request.json
+    path = data.get('path')
+    if path == None:
+        path = "/"
+    global serverConn
+    global servers_dirs
+
+    if serverConn is None:
+        return jsonify({"error": "Sunucu bağlantısı kurulmadı"}), 500
+    
+    servers_dirs = serverConn.open_folder(path)
+    return jsonify(servers_dirs)
+
+@app.route('/api/localfiles', methods=['POST'])
+def localfiles():
+    if request.method == 'POST':
+        if request.headers['Content-Type'] == 'application/json':
+            data = request.json
+            filepath = data.get('filepath')
+            mycompDirlists = mycomp.list_files(str(filepath))
+    return jsonify(mycompDirlists)
+    
+@app.route('/api/uploadFile', methods=['POST'])
+def uploadFile():
+    try:
+        print("uploadFile")
+        # JSON içeriğini alalım
+        data = request.json
+        folderPath = data.get('folderPath')
+        fileName = data.get('fileName')
+        serverpath = data.get('serverpath')
+        serverpath = serverpath +"/"+ fileName
+        print(folderPath)
+        print(fileName)
+        global serverConn
+        print(serverpath)
+        serverConn.dosya_yukle(serverpath,folderPath.replace("\\","/")+"/"+fileName)
+        return jsonify("uploadFile: OK")
+    except Exception as e:
+        print(e)
+        return jsonify("uploadFile: Error")
+    
+@app.route('/api/downloadFile', methods=['POST'])
+def downloadFile():
+    try:
+        data = request.json
+        folderPath = data.get('folderPath')
+        fileName = data.get('fileName')
+        serverpath = data.get('serverpath')
+        serverpath = serverpath +"/"+ fileName
+        print(folderPath)
+        print(fileName)
+        global serverConn
+        print(serverpath)
+        serverConn.dosya_indir(serverpath,folderPath.replace("\\","/")+"/"+fileName)
+        return jsonify("DownoladFile: OK")
+    except Exception as e:
+        print(e)
+        return jsonify("DownoladFile: Error")
+    
+@app.route('/api/deleteFileFromServer', methods=['POST'])
+def deleteFileFromServer():
+    try:
+        data = request.json
+        fileName = data.get('fileName')
+        serverpath = data.get('serverpath')
+        serverpath = serverpath +"/"+ fileName
+        print(fileName)
+        global serverConn
+        print(serverpath)
+        serverConn.dosya_sil(serverpath)
+        print("DeleteFile: OK")
+        return jsonify("DeleteFile: OK")
+    except Exception as e:
+        print(e)
+        return jsonify("DeleteFile: Error")
+        
+@app.route('/api/deleteFileFromLocal', methods=['POST'])
+def deleteFileFromLocal():
+    try:
+        data = request.json
+        fileName = data.get('fileName')
+        folderPath = data.get('folderPath')
+        print(fileName)
+        print(folderPath)
+        mycomp.delete_file(folderPath+"/"+fileName)
+        print("DeleteFile: OK")
+        return jsonify("DeleteFile: OK")
+    except Exception as e:
+        print(e)
+        return jsonify("DeleteFile: Error")
+
+@app.route('/api/bookmark', methods=['GET'])
+def get_bookmark():
+    bookmark_data = db.selectBookMarks()
+    if bookmark_data:
+        return jsonify(bookmark_data)
+    else:
+        return jsonify({"error": "No data found"}), 404
+
+@app.route('/api/localBookmark', methods=['GET'])
+def get_localbookmark():
+    bookmark_data = db.selectLocalBookMarks()
+    if bookmark_data:
+        return jsonify(bookmark_data)
+    else:
+        return jsonify({"error": "No data found"}), 404
+
+@app.route('/api/getBookmarksList', methods=['GET'])
+def get_allbookmark():
+    bookmark_data = db.selectAllBookMarks()
+    if bookmark_data:
+        return jsonify(bookmark_data)
+    else:
+        return jsonify({"error": "No data found"}), 404
+
+@app.route('/api/saveBookmark', methods=['POST'])
+def save_bookmark():
+    if request.method == 'POST':
+        if request.headers['Content-Type'] == 'application/json':
+            data = request.json
+            conn_name = data.get('CONNECTION_NAME') 
+            conn_type = data.get('CONNECTION_TYPE')
+            server = data.get('HOSTNAME')
+            port = data.get('PORT')
+            username = data.get('USERNAME')
+            passwd = data.get('PASSWORD')
+            sshkey = data.get('SSHKEY', None)  # SSH key optional
+            db.insertBookMarks(conn_name,conn_type, username, server, port, passwd)
+            return jsonify({'CEVAP': 'Kayıt başarılı'})
+
+        else:
+            return jsonify({'error': 'Parametreler eksik veya yanlış'})
+    else:
+        return jsonify({'error': 'İçerik tipi "application/json" değil'})
+
+@app.route('/api/deleteBookmark', methods=['POST'])
+def delete_bookmark():
+    if request.method == 'POST':
+        if request.headers['Content-Type'] == 'application/json':
+            data = request.json
+            id = data.get('id')
+            db.deleteBookMarks(id)
+            return jsonify({'CEVAP': 'SİLİNDİ'})
+
+        else:
+            return jsonify({'error': 'Parametreler eksik veya yanlış'})
+    else:
+        return jsonify({'error': 'İçerik tipi "application/json" değil'})
+
+if __name__ == '__main__':
+    app.run(host='127.0.0.1', port=5502,debug=True)

Projects/CyberGoose/data.db

@@ -0,0 +1,106 @@
+import sqlite3
+import json
+class DbMyFtp:
+
+    def __init__(self):
+        pass
+        
+    def selectBookMarks(self):
+        connection = sqlite3.connect("data.db")
+        cursor = connection.cursor()
+        cursor.execute("""SELECT CONNECTION_TYPE, ID, HOSTNAME, PORT, USERNAME, PASSWORD 
+                        FROM BOOKMARKS 
+                        WHERE ID = (SELECT MAX(ID) FROM BOOKMARKS)""")
+        row = cursor.fetchone()  # Tek bir kayıt almak için fetchone() kullanılır.
+        connection.close()
+        
+        if row:
+            data = {
+                "CONNECTION_TYPE": row[0],
+                "ID": row[1],
+                "HOSTNAME": row[2],
+                "PORT": row[3],
+                "USERNAME": row[4],
+                "PASSWORD": row[5]
+            }
+            return data
+        else:
+            return None  # Eğer sonuç yoksa, None döndür.
+
+    def selectAllBookMarks(self):
+        connection = sqlite3.connect("data.db")
+        cursor = connection.cursor()
+        cursor.execute("""SELECT ID,CONNECTION_NAME,CONNECTION_TYPE, HOSTNAME, PORT, USERNAME, PASSWORD 
+                        FROM BOOKMARKS ORDER BY ID """)
+        rows = cursor.fetchall()  
+        connection.close()
+        
+        if rows:
+            data = []
+            for row in rows:
+                data.append({
+                    "ID": row[0],
+                    "CONNECTION_NAME": row[1],
+                    "CONNECTION_TYPE": row[2],
+                    "HOSTNAME": row[3],
+                    "PORT": row[4],
+                    "USERNAME": row[5],
+                    "PASSWORD": row[6]
+                })
+            return data
+        else:
+            return None  # Eğer sonuç yoksa, None döndür.
+        
+    def selectLocalBookMarks(self):
+        connection = sqlite3.connect("data.db")
+        cursor = connection.cursor()
+        cursor.execute("""SELECT PATH FROM local_bookmarks 
+                          WHERE ID = (SELECT MAX(ID) FROM local_bookmarks)""")
+        row = cursor.fetchone()  # Tek bir kayıt almak için fetchone() kullanılır.
+        connection.close()
+        if row:
+            
+            data = {
+                "PATH": row[0]
+            }
+            return data
+        else:
+            return None  # Eğer sonuç yoksa, None döndür.
+        
+        
+
+    def insertBookMarks(self,conn_name,conn_type, username, server, port, passwd):
+        connection = sqlite3.connect("data.db")
+        sql = "INSERT INTO BOOKMARKS (CONNECTION_NAME,CONNECTION_TYPE, HOSTNAME, PORT, USERNAME, PASSWORD) VALUES (?,?,?,?,?,?)"
+        values = (conn_name,conn_type, username, server, port, passwd)    
+        connection.execute(sql,values)
+        connection.commit()
+        connection.close()
+        
+    def updateBookMarks(self, id, new_hostname, new_port, new_username, new_password):
+        connection = sqlite3.connect("data.db")
+        sql = "UPDATE BOOKMARKS SET HOSTNAME = ?, PORT = ?, USERNAME = ?, PASSWORD = ? WHERE ID = ?"
+        values = (new_hostname, new_port, new_username, new_password, id)    
+        connection.execute(sql, values)
+        connection.commit()
+        connection.close()
+            
+    def deleteBookMarks(self, id):
+        connection = sqlite3.connect("data.db")
+        sql = "DELETE FROM BOOKMARKS WHERE ID = ?"
+        values = (id,)    
+        connection.execute(sql, values)
+        connection.commit()
+        connection.close()
+
+        
+
+    
+        
+db = DbMyFtp()        
+if __name__ == '__main__':
+    #db.deleteBookMarks()
+    #db.insertBookMarks("hkljnjk","21","kbnljnlk","passs")
+ #   db.updateBookMarks(id=4,new_hostname="bbbb",new_port="21",new_username="bb",new_password="bbbb")
+   print(db.selectLocalBookMarks())
+