Added 827 as vendor

facebook/accs_to_db.py

@@ -86,18 +86,23 @@ def to_accs(db, data, info, profiles, vendor, accs="accs"):
 
     n0 = 0
     n1 = 0
-    
+
     for profile in data:
+
         if len(profile) < 3:
             continue
 
         doc = {}
         doc["vendor"] = vendor
         doc["created"] = now()
+        
         if "email" in info:
             doc["email"] = profile[info.index("email")]
+
         elif "login" in info:
             doc["email"] = profile[info.index("login")]
+
+
         if doc["email"] in used_accs or doc["email"] in used_profiles:
             n1 += 1
             continue
@@ -120,37 +125,45 @@ def to_accs(db, data, info, profiles, vendor, accs="accs"):
                 for c in cookies.split(";"):
                     cookie[c[: c.find("=")].strip()] = c[c.find("=") + 1 :].strip()
             else:
-                try:
-                    cookies_base64 = cookies.strip()  # .strip('=')
-                    # print()
-                    # print(cookies_base64)
-                    # print()
-                    cookies64_bytes = cookies_base64.encode("ascii")
-                    cookies_bytes = base64.b64decode(cookies64_bytes)
-                    # exit()
-                    cookies_str = (
-                        cookies_bytes.decode("ascii")
-                        .replace("'", '"')
-                        .replace("False", "false")
-                        .replace("True", "true")
-                    )
+                #try:
+                cookies_base64 = cookies.strip()  # .strip('=')
+    
+                cookies64_bytes = cookies_base64.encode("ascii")
+                cookies_bytes = base64.b64decode(cookies64_bytes)
+                # exit()
+                cookies_str = (
+                    cookies_bytes.decode("ascii")
+                    .replace("'", '"')
+                    .replace("False", "false")
+                    .replace("True", "true")
+                )
+                if vendor in ["827"]:
+                    cookies = {}
+                    for c in cookies_str.split(';'): 
+                        cookies[c[:c.find('=')]] = c[c.find('=')+1:]
+                
+                else:
                     cookies = json.loads(cookies_str)
-                    
-                    cookie = {}
-                    if vendor == "159":
-                        for c in cookies["cookies"]:
-                            cookie[c["name"]] = c["value"]
-                    else:
-                        for c in cookies:
-                            name = c["name"]
-                            del c["name"]
-                            cookie[name] = c["value"]
-                    doc["cookie"] = cookie
-                except Exception as e:
-                    print('\n\nFel på cookie.\n', e, '\n')
-                    for i in profile:
-                        print(i)
-                        continue
+
+                cookie = {}
+                if vendor in ["159"]:
+                    for c in cookies["cookies"]:
+                        cookie[c["name"]] = c["value"]
+                elif vendor in ["827"]:
+                    cookie = cookies
+                else:
+                    for c in cookies:
+                        name = c["name"]
+                        del c["name"]
+                        cookie[name] = c["value"]
+                doc["cookie"] = cookie
+                # except Exception as e:
+                #     print('\n\nFel på cookie.\n', e, '\n')
+                #     for i in profile:
+                #         print(i)
+                        
+                #     exit()
+
         else:
             cookie = {}
         if "birthday" in info:
@@ -163,7 +176,6 @@ def to_accs(db, data, info, profiles, vendor, accs="accs"):
     
     print(f'\nInlagda profiler: {n0}\nProfiler redan i db: {n1}')
 
-
 def used_servers(profiles="profiles"):
     cursor = db.aql.execute(
         """
@@ -231,7 +243,9 @@ if __name__ == "__main__":
         },
         #'1113': {'info': 'login:mail:password:emailpassword:birthday:useragent:token:cookie', 'sep': '|'},
         "159": {"info": "login:password:mail:email password:birthday:id", "sep": ":"},
-        #'159': {'info': 'login:password:birthday:id:cookie', 'sep':':'
+        #'159': {'info': 'login:password:birthday:id:cookie', 'sep':':',
+        "827": {"info": "login:password:mail:email password:birthday:useragent:token:cookie",
+        "sep": "|"}
     }
 
     ###############################
@@ -258,8 +272,8 @@ if __name__ == "__main__":
     # Öppna SSH-tunnel till RBP/db.
     pwd_key = getpass("Password for rsa-key: ")
     with open_tunnel(
-        ("studio-garda.asuscomm.com", 2200),
-        ssh_username="Lasse",
+        ("studio-garda.asuscomm.com", 2210),
+        ssh_username="lasse",
         ssh_pkey=paramiko.RSAKey.from_private_key_file(
             "/Users/Lasse/.ssh/id_rsa", password=pwd_key
         ),