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
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License. You may obtain
# a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
# License for the specific language governing permissions and limitations
# under the License.
import logging
from osc_lib.command import command
from osc_lib import exceptions
from osc_lib import utils as oscutils
from manilaclient import api_versions
from manilaclient.common._i18n import _
from manilaclient.common.apiclient import utils as apiutils
LOG = logging.getLogger(__name__)
MESSAGE_ATTRIBUTES = [
'id',
'resource_type',
'resource_id',
'action_id',
'user_message',
'message_level',
'detail_id',
'created_at',
'expires_at',
'request_id'
]
class DeleteMessage(command.Command):
"""Remove one or more messages."""
_description = _("Remove one or more messages")
def get_parser(self, prog_name):
parser = super(DeleteMessage, self).get_parser(prog_name)
parser.add_argument(
'message',
metavar='<message>',
nargs='+',
help=_('ID of the message(s).'))
return parser
def take_action(self, parsed_args):
share_client = self.app.client_manager.share
failure_count = 0
for message in parsed_args.message:
try:
message_ref = apiutils.find_resource(
share_client.messages,
message)
share_client.messages.delete(message_ref)
except Exception as e:
failure_count += 1
LOG.error(_(
"Delete for message %(message)s failed: %(e)s"),
{'message': message, 'e': e})
if failure_count > 0:
raise exceptions.CommandError(_(
"Unable to delete some or all of the specified messages."))
class ListMessage(command.Lister):
"""Lists all messages."""
_description = _("Lists all messages")
def get_parser(self, prog_name):
parser = super(ListMessage, self).get_parser(prog_name)
parser.add_argument(
'--resource-id',
metavar='<resource-id>',
default=None,
help=_('Filters results by a resource uuid. Default=None.'))
parser.add_argument(
'--resource-type',
metavar='<resource-type>',
default=None,
help=_('Filters results by a resource type. Default=None. '
'Example: "openstack message list --resource-type share"'))
parser.add_argument(
'--action-id',
metavar='<action-id>',
default=None,
help=_('Filters results by action id. Default=None.'))
parser.add_argument(
'--detail-id',
metavar='<detail-id>',
default=None,
help=_('Filters results by detail id. Default=None.'))
parser.add_argument(
'--request-id',
metavar='<request-id>',
default=None,
help=_('Filters results by request id. Default=None.'))
parser.add_argument(
'--message-level',
metavar='<message-level>',
default=None,
help=_('Filters results by the message level. Default=None. '
'Example: "openstack message list --message-level ERROR".'))
parser.add_argument(
'--limit',
metavar='<limit>',
type=int,
default=None,
help=_('Maximum number of messages to return. (Default=None)'))
parser.add_argument(
'--since',
metavar='<since>',
default=None,
help=_('Return only user messages created since given date. '
'The date format must be conforming to ISO8601. '
'Available only for microversion >= 2.52.'))
parser.add_argument(
'--before',
metavar='<before>',
default=None,
help=_('Return only user messages created before given date. '
'The date format must be conforming to ISO8601. '
'Available only for microversion >= 2.52.'))
return parser
def take_action(self, parsed_args):
share_client = self.app.client_manager.share
search_opts = {
'limit': parsed_args.limit,
'request_id': parsed_args.request_id,
'resource_type': parsed_args.resource_type,
'resource_id': parsed_args.resource_id,
'action_id': parsed_args.action_id,
'detail_id': parsed_args.detail_id,
'message_level': parsed_args.message_level
}
if share_client.api_version < api_versions.APIVersion("2.52"):
if getattr(parsed_args, 'since') or getattr(parsed_args, 'before'):
raise exceptions.CommandError(_(
"Filtering messages by 'since' and 'before'"
" is possible only with Manila API version >=2.52"))
else:
search_opts['created_since'] = parsed_args.since
search_opts['created_before'] = parsed_args.before
messages = share_client.messages.list(search_opts=search_opts)
columns = [
'ID',
'Resource Type',
'Resource ID',
'Action ID',
'User Message',
'Detail ID',
'Created At']
return (columns, (oscutils.get_item_properties
(m, columns) for m in messages))
class ShowMessage(command.ShowOne):
"""Show details about a message."""
_description = _("Show details about a message")
def get_parser(self, prog_name):
parser = super(ShowMessage, self).get_parser(prog_name)
parser.add_argument(
'message',
metavar='<message>',
help=_('ID of the message.'))
return parser
def take_action(self, parsed_args):
share_client = self.app.client_manager.share
message = apiutils.find_resource(
share_client.messages,
parsed_args.message)
return (MESSAGE_ATTRIBUTES, oscutils.get_dict_properties(
message._info, MESSAGE_ATTRIBUTES))
|
