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
|
// Copyright 2020 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROME_BROWSER_NEARBY_SHARING_INSTANTMESSAGING_STREAM_PARSER_H_
#define CHROME_BROWSER_NEARBY_SHARING_INSTANTMESSAGING_STREAM_PARSER_H_
#include <string>
#include <string_view>
#include "base/functional/callback.h"
#include "chrome/browser/nearby_sharing/instantmessaging/proto/instantmessaging.pb.h"
namespace google {
namespace protobuf {
namespace io {
class CodedInputStream;
} // namespace io
} // namespace protobuf
} // namespace google
namespace net {
class GrowableIOBuffer;
} // namespace net
namespace chrome_browser_nearby_sharing_instantmessaging {
class StreamBody;
} // namespace chrome_browser_nearby_sharing_instantmessaging
// Parses incoming stream of data into valid proto objects.
class StreamParser {
public:
StreamParser();
~StreamParser();
// Appends the stream data (which should be the partial or full serialized
// StreamBody) and returns a vector of response protos that can be parsed
// from the available stream data. If no responses can be parsed yet, an
// empty vector is returned.
std::vector<
chrome_browser_nearby_sharing_instantmessaging::ReceiveMessagesResponse>
Append(std::string_view data);
private:
enum class StreamParsingResult {
kSuccessfullyParsedResponse,
kNoop,
kNotEnoughDataYet,
kParsingUnexpectedlyFailed
};
std::vector<
chrome_browser_nearby_sharing_instantmessaging::ReceiveMessagesResponse>
ParseStreamIfAvailable();
// Only supports reading single field type and assumes the StreamBody messages
// field and the noop field are the only ones we will ever see.
StreamParsingResult ParseNextMessagesFieldFromStream(
google::protobuf::io::CodedInputStream* input_stream,
chrome_browser_nearby_sharing_instantmessaging::ReceiveMessagesResponse*
parsed_response);
scoped_refptr<net::GrowableIOBuffer> unparsed_data_buffer_;
};
#endif // CHROME_BROWSER_NEARBY_SHARING_INSTANTMESSAGING_STREAM_PARSER_H_
|
