001_update_default_queue.update_default_queue_id()   A
last analyzed

Complexity

Conditions 1

Size

Total Lines 8
Code Lines 7

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 1
eloc 7
nop 1
dl 0
loc 8
rs 10
c 0
b 0
f 0
1
#!/usr/bin/env python
2
# -*- coding: utf-8 -*-
3
import os
4
import sys
5
from kytos.core.db import Mongo
6
7
8
9
query = {"queue_id": None, "archived": False}
10
update = { "$set": { "queue_id": -1 }}
11
12
def update_default_queue_id(mongo: Mongo):
13
    db = mongo.client[mongo.db_name]
14
    count = db.evcs.update_many(
15
        query,
16
        update
17
    ).modified_count
18
19
    print(f"Change default queue_id from None to -1 updated: {count}")
20
21
22
def read_evcs(mongo: Mongo):
23
    db = mongo.client[mongo.db_name]
24
    cursor = db.evcs.find(
25
        query
26
    )
27
    print(f"EVCs that queue_id will be changed from None to -1:")
28
    for document in cursor:
29
        print("EVC ID: ", document["id"], "\n", document, "\n")
30
31
32
33
def main() -> None:
34
    """Main function."""
35
    mongo = Mongo()
36
    cmds = {
37
        "update_database": update_default_queue_id,
38
        "get_candidates": read_evcs,
39
    }
40
    try:
41
        cmd = os.environ["CMD"]
42
        cmds[cmd](mongo)
43
    except KeyError:
44
        print(
45
            f"Please set the 'CMD' env var. \nIt has to be one of these: {list(cmds.keys())}"
46
        )
47
        sys.exit(1)
48
49
50
if __name__ == "__main__":
51
    main()
52