# Copyright 2017 The Chromium OS Authors. All rights reserved.
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.

"""Meeting related operations"""

from __future__ import print_function

import logging
import random

MIN_VOL = 1
MAX_VOL = 100

def restart_chrome(handle, is_meeting, recovery):
    """
    Restart chrome and wait for telemetry commands to be ready.
    @param handle: CfM telemetry remote facade,
    @param is_meeting: True, None if CfM running MEET mode,
                       False if CfM running hangout mode
    @returns: True, None if success,
              False otherwise.
    """
    try:
        if recovery:
            logging.info('+++Restart chrome')
            handle.restart_chrome_for_cfm()
        if is_meeting:
            handle.wait_for_meetings_telemetry_commands()
        else:
            handle.wait_for_hangouts_telemetry_commands()
    except Exception as e:
        errmsg = 'Fail to run telemetry api restart_chrome_for_cfm.'
        logging.exception(errmsg)
        return False, errmsg
    return True, None

def join_meeting(handle, is_meeting, meet_code):
    """
    Join meeting.
    @param handle: CfM telemetry remote facade,
    @param is_meeting: True, None if CfM running MEET mode,
                       False if CfM running hangout mode
    @param meeting_code: meeting code
    @returns: True, None if CfM joins meeting successfully,
              False otherwise.
    """
    try:
        if is_meeting:
            logging.info('+++Start meet meeting')
            if meet_code:
                handle.join_meeting_session(meet_code)
            else:
                handle.start_meeting_session()
        else:
            logging.info('+++start hangout meeting')
            if meet_code:
                handle.start_new_hangout_session(meet_code)
            else:
                errmsg = 'Meeting code is required for hangout meet.'
                logging.exception(errmsg)
                return False, errmsg
        logging.info('+++Meeting %s joined.', meet_code)
        return True, None
    except Exception as e:
        errmsg = 'Fail to run telemetry api to join meeting.'
        logging.exception(errmsg)
        return False, errmsg

def leave_meeting(handle, is_meeting):
    """
    Leave meeting.
    @param handle: CfM telemetry remote facade,
    @param is_meeting: True, None if CfM running MEET mode,
                       False if CfM running hangout mode
    @returns: True, None if CfM leaves meeting successfully,
              False otherwise.

    """
    try:
        if is_meeting:
            handle.end_meeting_session()
        else:
            handle.end_hangout_session()
    except Exception as e:
        errmsg = 'Fail to run telemetry api to leave meeting.'
        logging.exception(errmsg)
        return False, errmsg
    logging.info('+++meet ended')
    return True, None


def mute_unmute_camera(handle, is_muted):
    """
    @param handle: CfM telemetry remote facade,
    @param is_muted: True, None if camera is muted,
                     False otherwise.
    @returns: True, None if camera is muted/unmuted successfully,
              False otherwise.
    """
    try:
        if is_muted:
            logging.info('+++unmute camera')
            handle.unmute_camera()
        else:
            logging.info('+++mute camera')
            handle.mute_camera()
    except Exception as e:
        errmsg = 'Fail to run telemetry api to mute/unmute camera.'
        logging.exception(errmsg)
        return False, errmsg
    return True, None


def mute_unmute_mic(handle, is_muted):
    """
    @param handle: CfM telemetry remote facade,
    @param is_muted: True, None if mic is muted,
                     False otherwise.
    @returns: True, None if camera is muted/unmuted successfully,
              False otherwise.
    """
    try:
         if is_muted:
             logging.info('+++unmute mic')
             handle.unmute_mic()
         else:
             logging.info('+++mute mic')
             handle.mute_mic()
    except Exception as e:
        errmsg = 'Fail to run telemetry api to mute/unmute mic.'
        logging.exception(errmsg)
        return False, errmsg
    return True, None


def set_speaker_volume(handle, volume):
    """
    Change speaker's volume.
    @param handle: CfM telemetry remote facade
    @param volume: volume for speaker
    """
    try:
        handle.set_speaker_volume(volume)
    except Exception as e:
        errmsg = 'Fail to run telemetry api to set speaker volume.'
        logging.exception(errmsg)
        return False, errmsg
    return True, str(volume)


def speaker_volume_test(handle, step, mode, randommode):
    """
    Change speaker's volume.
    @param handle: CfM telemetry remote facade,
    @param step: volume to be increased or decreased in one call
    @param mode: if it equal to 1, update volume directly to
                 targeted value,
                 else, update volume in multiple calls.
    @param randommode: if True, None, the value of volume to be change in
                 each call is randomly set,
                 else, the value is fixed defined by step.
    """
    test_volume = random.randrange(MIN_VOL, MAX_VOL)
    if mode == 1:
        return set_speaker_volume(handle, test_volume)
    step = max(2, step)
    try:
        current = int(handle.get_speaker_volume())
    except Exception as e:
        errmsg = 'Fail to run telemetry api to set speaker volume.'
        logging.exception(errmsg)
        return False, errmsg

    if test_volume > current:
        while test_volume > current:
            if randommode:
                transit_volume = current + random.randrange(1, step)
            else:
                transit_volume = current + step

            if transit_volume > test_volume:
                transit_volume = test_volume

            handle.set_speaker_volume(transit_volume)
            try:
                current = int(handle.get_speaker_volume())
            except Exception as e:
                errmsg = 'Fail to run telemetry api to set speaker volume.'
                logging.exception(errmsg)
                return False, errmsg

            logging.info('+++set vol %d, current %d, target %d',
                         transit_volume, current, test_volume)
    else:
        while test_volume < current:
            if randommode:
                transit_volume = current - random.randrange(1, step)
            else:
                transit_volume = current - step
            if transit_volume < test_volume:
                transit_volume = test_volume
            handle.set_speaker_volume(transit_volume)
            try:
                current = int(handle.get_speaker_volume())
            except Exception as e:
                errmsg = 'Fail to run telemetry api to set speaker volume.'
                logging.exception(errmsg)
                return False, errmsg

            logging.info('+++set vol %d, current %d, target %d',
                          transit_volume, current, test_volume)
    return True, str(current)
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
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213