saffron-proxy/proxy.js at main · zyrikl/saffron-proxy · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
let db;
const request = indexedDB.open('volume', 2);

request.onupgradeneeded = function(event) {
    const database = event.target.result;
    if (!database.objectStoreNames.contains('urls')) {
        database.createObjectStore('urls', { keyPath: 'path', autoIncrement: true });
    }
};

request.onsuccess = function(event) {
    db = event.target.result;
    console.log('Database is ready for external calls.');
};

request.onerror = function(event) {
    console.error('Database failed to open:', event.target.error);
};

function add_website(user_data) {
    if (!db) {
        console.error('Database not ready yet');
        return;
    }

    const transaction = db.transaction(['urls'], 'readwrite');
    const store = transaction.objectStore('urls');

    const add_request = store.put(user_data);

    add_request.onsuccess = function() {
        console.log('Entry added successfully!');
    };

    add_request.onerror = function(event) {
        console.error('Failed to add entry:', event.target.error);
    };
}

async function get_record(id) {
    return new Promise((resolve, reject) => {
        if (!db) {
            console.error('Database not ready yet');
            reject('Database not ready');
            return;
        }

        const transaction = db.transaction(['urls'], 'readonly');
        const store = transaction.objectStore('urls');
        const get_request = store.get(id);

        get_request.onsuccess = function() {
            resolve(get_request.result);
        };

        get_request.onerror = function() {
            reject(get_request.error);
        };
    });
}

async function get_path(id) {
    return new Promise((resolve, reject) => {
        if (!db) {
            console.error('Database not ready yet');
            reject('Database not ready');
            return;
        }

        const transaction = db.transaction(['urls'], 'readonly');
        const store = transaction.objectStore('urls');
        const get_request = store.get(id);

        get_request.onsuccess = function() {
            resolve(get_request.result.path);
        };

        get_request.onerror = function() {
            reject(get_request.error);
        };
    });
}

async function get_type(id) {
    return new Promise((resolve, reject) => {
        if (!db) {
            console.error('Database not ready yet');
            reject('Database not ready');
            return;
        }

        const transaction = db.transaction(['urls'], 'readonly');
        const store = transaction.objectStore('urls');
        const get_request = store.get(id);

        get_request.onsuccess = function() {
            resolve(get_request.result.type);
        };

        get_request.onerror = function() {
            reject(get_request.error);
        };
    });
}

async function get_contents(id) {
    return new Promise((resolve, reject) => {
        if (!db) {
            console.error('Database not ready yet');
            reject('Database not ready');
            return;
        }

        const transaction = db.transaction(['urls'], 'readonly');
        const store = transaction.objectStore('urls');
        const get_request = store.get(id);

        get_request.onsuccess = function() {
            resolve(get_request.result.contents);
        };

        get_request.onerror = function() {
            reject(get_request.error);
        };
    });
}

async function get_cors_url(url) {
    const response = await fetch(`https://cors.io/?url=${url}`);
    const data = await response.json();

    console.log(`Status of ${url}:`, data.status);
    //add_website({ 'path': url, 'type': data.headers['content-type'], 'contents': data.body });

    return await Promise.all([
        url,
        data.headers['content-type'],
        data.body
    ]);
}