Pesquisando sua localização com Atlas Search e operadores geoespaciais

1
npm init -y
2
npm install mongodb express cors

1
const { MongoClient } = require("mongodb");
2
const Express = require("express");
3
const Cors = require("cors");
4
5
const app = Express();
6
7
app.use(Express.json());
8
app.use(Express.urlencoded({ extended: true }));
9
app.use(Cors());
10
11
const client = new MongoClient(
12
    process.env["ATLAS_URI"], 
13
    { 
14
        useUnifiedTopology: true 
15
    }
16
);
17
18
var collection;
19
20
app.post("/search", async (request, response, next) => {
21
    console.log(JSON.stringify(request.body));
22
    try {
23
        let result = await collection.aggregate([/* Search Logic Here */]).toArray();
24
        response.send(result);
25
    } catch (e) {
26
        response.status(500).send({ message: e.message });
27
    }
28
});
29
30
app.listen(3000, async () => {
31
    try {
32
        await client.connect();
33
        collection = client.db("sample_airbnb").collection("listingsAndReviews");
34
    } catch (e) {
35
        console.error(e);
36
    }
37
});

1
const client = new MongoClient(
2
    process.env["ATLAS_URI"], 
3
    { 
4
        useUnifiedTopology: true 
5
    }
6
);

1
{
2
    "mappings": {
3
        "dynamic": false,
4
        "fields": {
5
            "address": {
6
                "fields": {
7
                    "location": {
8
                        "type": "geo"
9
                    }
10
                },
11
                "type": "document"
12
            },
13
            "name": [
14
                {
15
                    "foldDiacritics": false,
16
                    "maxGrams": 7,
17
                    "minGrams": 3,
18
                    "tokenization": "edgeGram",
19
                    "type": "autocomplete"
20
                }
21
            ]
22
        }
23
    }
24
}

1
{
2
    "$search": {
3
        "index": "autocomplete",
4
        {
5
            "autocomplete": {
6
                "query": "apartment",
7
                "path": "name",
8
                "fuzzy": {
9
                    "maxEdits": 2,
10
                    "prefixLength": 3
11
                }
12
            }
13
        }
14
    }
15
}

1
{
2
    "$search": {
3
        "index": "autocomplete",
4
        {
5
            "geoWithin": {
6
                "circle": {
7
                    "center": {
8
                        "type": "Point",
9
                        "coordinates": [-74.0060, 40.7128]
10
                    },
11
                    "radius": 10000
12
                },
13
                "path": "address.location"
14
            }
15
        }
16
    }
17
}

1
app.post("/search", async (request, response, next) => {
2
    try {
3
        let result = await collection.aggregate([
4
            {
5
                "$search": {
6
                    "index": "autocomplete",
7
                    "compound": {
8
                        "must": [
9
                            {
10
                                "autocomplete": {
11
                                    "query": `${request.body.query}`,
12
                                    "path": "name",
13
                                    "fuzzy": {
14
                                        "maxEdits": 2,
15
                                        "prefixLength": 3
16
                                    }
17
                                }
18
                            },
19
                            {
20
                                "geoWithin": {
21
                                    "circle": {
22
                                        "center": {
23
                                            "type": "Point",
24
                                            "coordinates": [request.body.position.lng, request.body.position.lat]
25
                                        },
26
                                        "radius": 10000
27
                                    },
28
                                    "path": "address.location"
29
                                }
30
                            }
31
                        ]
32
                    }
33
                }
34
            }
35
        ]).toArray();
36
        response.send(result);
37
    } catch (e) {
38
        response.status(500).send({ message: e.message });
39
    }
40
});

1
{
2
    "query": "apartment",
3
    "position": {
4
        "lng": -74.0060,
5
        "lat": 40.7128
6
    }
7
}

1
app.post("/search", async (request, response, next) => {
2
    try {
3
        let result = await collection.aggregate([
4
            {
5
                "$search": {
6
                    "index": "autocomplete",
7
                    "compound": {
8
                        "must": [
9
                            {
10
                                "autocomplete": {
11
                                    "query": `${request.body.query}`,
12
                                    "path": "name",
13
                                    "fuzzy": {
14
                                        "maxEdits": 2,
15
                                        "prefixLength": 3
16
                                    }
17
                                }
18
                            },
19
                            {
20
                                "geoWithin": {
21
                                    "circle": {
22
                                        "center": {
23
                                            "type": "Point",
24
                                            "coordinates": [request.body.position.lng, request.body.position.lat]
25
                                        },
26
                                        "radius": 10000
27
                                    },
28
                                    "path": "address.location"
29
                                }
30
                            }
31
                        ]
32
                    }
33
                }
34
            },
35
            {
36
                "$project": {
37
                    "name": 1,
38
                    "address": 1,
39
                    "score": { "$meta": "searchScore" }
40
                }
41
            }
42
        ]).toArray();
43
        response.send(result);
44
    } catch (e) {
45
        response.status(500).send({ message: e.message });
46
    }
47
});

1
{
2
    "$project": {
3
        "name": 1,
4
        "address": 1,
5
        "score": { "$meta": "searchScore" }
6
    }
7
}

1
<!DOCTYPE html>
2
<html>
3
    <head>
4
        <link rel="stylesheet" href="https://code.jquery.com/ui/1.12.1/themes/base/jquery-ui.css">
5
        <script src="https://code.jquery.com/jquery-1.12.4.js"></script>
6
        <script src="https://code.jquery.com/ui/1.12.1/jquery-ui.js"></script>
7
    </head>
8
    <body>
9
        <div class="ui-widget">
10
            <label for="bnb">Bed and Breakfast [40.7128, -74.0060]:</label><br />
11
            <input id="bnb">
12
        </div>
13
        <script>
14
            $(document).ready(function () {
15
                // Autocomplete logic here...
16
            });
17
        </script>
18
    </body>
19
</html>

1
$(document).ready(function () {
2
    $("#bnb").autocomplete({
3
        source: async function (request, response) {
4
            let data = await fetch("http://localhost:3000/search", {
5
                    "method": "POST",
6
                    "headers": {
7
                        "content-type": "application/json"
8
                    },
9
                    "body": JSON.stringify({
10
                        "query": `${request.term}`,
11
                        "position": {
12
                            "lat": 40.7128,
13
                            "lng": -74.0060
14
                        }
15
                    })
16
                })
17
                .then(results => results.json())
18
                .then(results => results.map(result => {
19
                    return { label: result.name, value: result.name, id: result._id };
20
                }));
21
            response(data);
22
        },
23
        minLength: 2,
24
        select: function (event, ui) {
25
            // Further logic here...
26
        }
27
    });
28
});

1
node main.js

1
python -m SimpleHTTPServer