| 
									
										
										
										
											2022-02-04 14:13:30 +03:30
										 |  |  | /*
 | 
					
						
							|  |  |  |  * Copyright (c) 2021, Dex♪ <dexes.ttp@gmail.com> | 
					
						
							|  |  |  |  * Copyright (c) 2022, Ali Mohammad Pur <mpfard@serenityos.org> | 
					
						
							| 
									
										
										
										
											2022-03-04 14:08:30 -07:00
										 |  |  |  * Copyright (c) 2022, the SerenityOS developers. | 
					
						
							| 
									
										
										
										
											2022-02-04 14:13:30 +03:30
										 |  |  |  * | 
					
						
							|  |  |  |  * SPDX-License-Identifier: BSD-2-Clause | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | #pragma once
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | #include <AK/ByteBuffer.h>
 | 
					
						
							|  |  |  | #include <AK/Span.h>
 | 
					
						
							|  |  |  | #include <AK/String.h>
 | 
					
						
							|  |  |  | #include <LibWebSocket/ConnectionInfo.h>
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | namespace WebSocket { | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-11-08 18:40:33 +01:00
										 |  |  | class WebSocketImpl : public RefCounted<WebSocketImpl> { | 
					
						
							| 
									
										
										
										
											2022-02-04 14:13:30 +03:30
										 |  |  | public: | 
					
						
							| 
									
										
										
										
											2022-11-08 18:40:33 +01:00
										 |  |  |     virtual ~WebSocketImpl(); | 
					
						
							| 
									
										
										
										
											2022-02-04 14:13:30 +03:30
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-11-08 18:40:33 +01:00
										 |  |  |     virtual void connect(ConnectionInfo const&) = 0; | 
					
						
							|  |  |  |     virtual bool can_read_line() = 0; | 
					
						
							|  |  |  |     virtual ErrorOr<String> read_line(size_t) = 0; | 
					
						
							|  |  |  |     virtual ErrorOr<ByteBuffer> read(int max_size) = 0; | 
					
						
							|  |  |  |     virtual bool send(ReadonlyBytes) = 0; | 
					
						
							|  |  |  |     virtual bool eof() = 0; | 
					
						
							|  |  |  |     virtual void discard_connection() = 0; | 
					
						
							| 
									
										
										
										
											2022-02-04 14:13:30 +03:30
										 |  |  | 
 | 
					
						
							|  |  |  |     Function<void()> on_connected; | 
					
						
							|  |  |  |     Function<void()> on_connection_error; | 
					
						
							|  |  |  |     Function<void()> on_ready_to_read; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2022-11-08 18:40:33 +01:00
										 |  |  | protected: | 
					
						
							|  |  |  |     WebSocketImpl(); | 
					
						
							| 
									
										
										
										
											2022-02-04 14:13:30 +03:30
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | } |