1#!/usr/bin/env python3
 2
 3# SK 23/06/2023: Created
 4
 5import logging
 6from chart.db import ts
 7from chart.events.event import Event, include_event_check
 8from chart.products.events.multitable_utils import process_ordering_sensing_time
 9from chart.products.pus.packetdef import PacketDef
10from chart.db.model.table import TableInfo
11from chart.common.traits import is_listlike
12from chart.web.user import User
13
14DECODER_ID = 'MANOEUVRE-HISTORY-EVENTS'
15TABLE = 'MANOEUVRE_HISTORY'
16EVENT_CLASSNAME = 'MANOEUVRE-HISTORY-EVENTS'
17
18logger = logging.getLogger()
19
20def find_events(sid,
21                start_time,
22                start_time_eq,
23                stop_time,
24                event_classes,
25                ordering,
26                from_to,
27                properties,
28                count,
29                single,
30                filtering,
31                multitable_extra_params,
32                user: User = None):
33
34    if from_to is not None:
35        page_start, page_stop = from_to
36
37    limit = 1 if single and start_time_eq is None else None
38
39    events = []
40    event_count = 0
41
42    # Reset ordering for sensing_time
43    order_clauses = process_ordering_sensing_time(ordering)
44
45    table_info = TableInfo(TABLE, sid=sid, fast_load=True)
46
47    if not single and count:
48        # just return count of events
49        event_count = ts.count(
50            table=table_info.storage_table,
51            field='SENSING_TIME',
52            method='ap',
53            sid=sid,
54            sensing_start=start_time,
55            sensing_stop=stop_time)
56
57        return event_count, events
58
59    fields = ('SENSING_TIME', 'PRODUCT', 'ACC_COMP_1', 'ACC_COMP_2', 'ACC_COMP_3', 'REC_FLAG')
60
61    for row in ts.select(sid=sid,
62                         sensing_start=start_time,
63                         sensing_stop=stop_time,
64                         sensing_time=start_time_eq,
65                         table=table_info.storage_table,
66                         fields=fields,
67                         ordering=order_clauses,
68                         limit=limit):
69
70        sensing_time, product, acc_comp_1, acc_comp_2, acc_comp_3, rec_flag = row
71        
72        inst_properties = {
73            'SID_NUM': sid.sid_num,
74            'PRODUCT': product,
75            'ACC_COMP_1': acc_comp_1,
76            'ACC_COMP_2': acc_comp_2,
77            'ACC_COMP_3': acc_comp_3,
78            'REC_FLAG': rec_flag
79        }
80
81        if not include_event_check(properties, inst_properties):
82            continue
83
84        event_count += 1
85
86        if not count and (from_to is None or (page_start <= event_count and event_count <= page_stop)):
87            events.append(Event(sid=sid,
88                                event_classname=EVENT_CLASSNAME,
89                                start_time=sensing_time,
90                                instance_properties=inst_properties))
91        if single:
92            break
93    
94    return event_count, events